Index

_

__init__() (obelisk.asynchronous.client.Client method) (obelisk.asynchronous.consumer.Consumer method) (obelisk.asynchronous.producer.Producer method) (obelisk.strategies.retry.ExponentialBackoffStrategy method) (obelisk.strategies.retry.ImmediateRetryStrategy method) (obelisk.strategies.retry.NoRetryStrategy method) (obelisk.strategies.retry.RetryEvaluator method) (obelisk.strategies.retry.RetryStrategy method) (obelisk.sync.consumer.Consumer method) (obelisk.sync.producer.Producer method) (obelisk.types.Datapoint method) (obelisk.types.IngestMode method) (obelisk.types.ObeliskKind method) (obelisk.types.QueryResult method) (obelisk.types.TimestampPrecision method)

A

async_consumer (obelisk.sync.consumer.Consumer attribute)

AuthenticationError

C

Client (class in obelisk.asynchronous.client) Consumer (class in obelisk.asynchronous.consumer) (class in obelisk.sync.consumer)

copy() (obelisk.types.Datapoint method) (obelisk.types.QueryResult method)

D

Datapoint (class in obelisk.types)

E

ExponentialBackoffStrategy (class in obelisk.strategies.retry)

G

grace_period (obelisk.asynchronous.client.Client attribute) (obelisk.asynchronous.consumer.Consumer attribute) (obelisk.asynchronous.producer.Producer attribute)

H

http_post() (obelisk.asynchronous.client.Client method) (obelisk.asynchronous.consumer.Consumer method) (obelisk.asynchronous.producer.Producer method)

I

ImmediateRetryStrategy (class in obelisk.strategies.retry)

IngestMode (class in obelisk.types)

L

loop (obelisk.sync.consumer.Consumer attribute)

M

make() (obelisk.strategies.retry.ExponentialBackoffStrategy method) (obelisk.strategies.retry.ImmediateRetryStrategy method) (obelisk.strategies.retry.NoRetryStrategy method) (obelisk.strategies.retry.RetryStrategy method) model_config (obelisk.types.Datapoint attribute) (obelisk.types.QueryResult attribute) model_construct() (obelisk.types.Datapoint class method) (obelisk.types.QueryResult class method) model_copy() (obelisk.types.Datapoint method) (obelisk.types.QueryResult method) model_dump() (obelisk.types.Datapoint method) (obelisk.types.QueryResult method) model_dump_json() (obelisk.types.Datapoint method) (obelisk.types.QueryResult method) model_extra (obelisk.types.Datapoint property) (obelisk.types.QueryResult property) model_fields_set (obelisk.types.Datapoint property) (obelisk.types.QueryResult property) model_json_schema() (obelisk.types.Datapoint class method) (obelisk.types.QueryResult class method) model_parametrized_name() (obelisk.types.Datapoint class method) (obelisk.types.QueryResult class method) model_post_init() (obelisk.types.Datapoint method) (obelisk.types.QueryResult method)

model_rebuild() (obelisk.types.Datapoint class method) (obelisk.types.QueryResult class method) model_validate() (obelisk.types.Datapoint class method) (obelisk.types.QueryResult class method) model_validate_json() (obelisk.types.Datapoint class method) (obelisk.types.QueryResult class method) model_validate_strings() (obelisk.types.Datapoint class method) (obelisk.types.QueryResult class method) module obelisk obelisk.asynchronous obelisk.asynchronous.client obelisk.asynchronous.consumer obelisk.asynchronous.consumer_test obelisk.asynchronous.producer obelisk.exceptions obelisk.strategies obelisk.strategies.retry obelisk.sync obelisk.sync.consumer obelisk.sync.consumer_test obelisk.sync.producer obelisk.types

N

NoRetryStrategy (class in obelisk.strategies.retry)

O

obelisk module obelisk.asynchronous module obelisk.asynchronous.client module obelisk.asynchronous.consumer module obelisk.asynchronous.consumer_test module obelisk.asynchronous.producer module obelisk.exceptions module obelisk.strategies module

obelisk.strategies.retry module obelisk.sync module obelisk.sync.consumer module obelisk.sync.consumer_test module obelisk.sync.producer module obelisk.types module ObeliskError ObeliskKind (class in obelisk.types)

P

Producer (class in obelisk.asynchronous.producer) (class in obelisk.sync.producer)

Q

query() (obelisk.asynchronous.consumer.Consumer method) (obelisk.sync.consumer.Consumer method)

query_time_chunked() (obelisk.asynchronous.consumer.Consumer method) (obelisk.sync.consumer.Consumer method) QueryResult (class in obelisk.types)

R

RetryEvaluator (class in obelisk.strategies.retry)

RetryStrategy (class in obelisk.strategies.retry)

S

send() (obelisk.asynchronous.producer.Producer method) (obelisk.sync.producer.Producer method)

should_retry() (obelisk.strategies.retry.RetryEvaluator method) single_chunk() (obelisk.asynchronous.consumer.Consumer method) (obelisk.sync.consumer.Consumer method)

T

test_demo_igent() (in module obelisk.asynchronous.consumer_test) (in module obelisk.sync.consumer_test) test_two_instances() (in module obelisk.sync.consumer_test) TimestampPrecision (class in obelisk.types) token (obelisk.asynchronous.client.Client attribute) (obelisk.asynchronous.consumer.Consumer attribute) (obelisk.asynchronous.producer.Producer attribute)

token_expires (obelisk.asynchronous.client.Client attribute) (obelisk.asynchronous.consumer.Consumer attribute) (obelisk.asynchronous.producer.Producer attribute)