Index

A

ack() (dramatiq.Consumer method) acquire() (dramatiq.rate_limits.RateLimiter method) Actor (class in dramatiq) actor() (in module dramatiq) actor_name (dramatiq.Actor attribute) (dramatiq.GenericActor attribute) actor_options (dramatiq.Broker attribute) (dramatiq.Middleware property) ActorNotFound add() (dramatiq.rate_limits.RateLimiterBackend method) add_completion_callback() (dramatiq.group method) add_middleware() (dramatiq.Broker method) (dramatiq.brokers.rabbitmq.RabbitmqBroker method) (dramatiq.brokers.redis.RedisBroker method) (dramatiq.brokers.stub.StubBroker method)

after_ack() (dramatiq.Middleware method) after_consumer_thread_boot() (dramatiq.Middleware method) after_declare_actor() (dramatiq.Middleware method) after_declare_delay_queue() (dramatiq.Middleware method) after_declare_queue() (dramatiq.Middleware method) after_enqueue() (dramatiq.Middleware method) after_nack() (dramatiq.Middleware method) after_process_boot() (dramatiq.Middleware method) after_process_message() (dramatiq.Middleware method) after_skip_message() (dramatiq.Middleware method) after_worker_boot() (dramatiq.Middleware method) after_worker_shutdown() (dramatiq.Middleware method) after_worker_thread_boot() (dramatiq.Middleware method) AgeLimit (class in dramatiq.middleware) asdict() (dramatiq.Message method) AsyncIO (class in dramatiq.middleware)

B

Barrier (class in dramatiq.rate_limits) before_ack() (dramatiq.Middleware method) before_consumer_thread_shutdown() (dramatiq.Middleware method) before_declare_actor() (dramatiq.Middleware method) before_declare_queue() (dramatiq.Middleware method) before_delay_message() (dramatiq.Middleware method) before_enqueue() (dramatiq.Middleware method) before_nack() (dramatiq.Middleware method) before_process_message() (dramatiq.Middleware method)

before_worker_boot() (dramatiq.Middleware method) before_worker_shutdown() (dramatiq.Middleware method) before_worker_thread_shutdown() (dramatiq.Middleware method) Broker (class in dramatiq) broker (dramatiq.Actor attribute) (dramatiq.GenericActor attribute) BrokerError BucketRateLimiter (class in dramatiq.rate_limits) build_message_key() (dramatiq.results.ResultBackend method)

C

Callbacks (class in dramatiq.middleware) channel (dramatiq.brokers.rabbitmq.RabbitmqBroker property) clear_exception() (dramatiq.MessageProxy method) close() (dramatiq.Broker method) (dramatiq.brokers.rabbitmq.RabbitmqBroker method) (dramatiq.brokers.redis.RedisBroker method) (dramatiq.brokers.stub.StubBroker method) (dramatiq.Consumer method) completed (dramatiq.group property) (dramatiq.pipeline property) completed_count (dramatiq.group property) (dramatiq.pipeline property)

ConcurrentRateLimiter (class in dramatiq.rate_limits) connection (dramatiq.brokers.rabbitmq.RabbitmqBroker property) ConnectionClosed ConnectionError ConnectionFailed consume() (dramatiq.Broker method) (dramatiq.brokers.rabbitmq.RabbitmqBroker method) (dramatiq.brokers.redis.RedisBroker method) (dramatiq.brokers.stub.StubBroker method) Consumer (class in dramatiq) copy() (dramatiq.Message method) create() (dramatiq.rate_limits.Barrier method) CurrentMessage (class in dramatiq.middleware)

D

dead_letters (dramatiq.brokers.stub.StubBroker property) declare_actor() (dramatiq.Broker method) (dramatiq.brokers.rabbitmq.RabbitmqBroker method) (dramatiq.brokers.redis.RedisBroker method) (dramatiq.brokers.stub.StubBroker method) declare_queue() (dramatiq.Broker method) (dramatiq.brokers.rabbitmq.RabbitmqBroker method) (dramatiq.brokers.redis.RedisBroker method) (dramatiq.brokers.stub.StubBroker method)

decode() (dramatiq.Encoder method) (dramatiq.Message class method) DecodeError decr() (dramatiq.rate_limits.RateLimiterBackend method) dramatiq module DramatiqError

E

encode() (dramatiq.Encoder method) (dramatiq.Message method) Encoder (class in dramatiq)

enqueue() (dramatiq.Broker method) (dramatiq.brokers.rabbitmq.RabbitmqBroker method) (dramatiq.brokers.redis.RedisBroker method) (dramatiq.brokers.stub.StubBroker method)

F

fail() (dramatiq.MessageProxy method) flush() (dramatiq.Broker method) (dramatiq.brokers.rabbitmq.RabbitmqBroker method) (dramatiq.brokers.redis.RedisBroker method) (dramatiq.brokers.stub.StubBroker method)

flush_all() (dramatiq.Broker method) (dramatiq.brokers.rabbitmq.RabbitmqBroker method) (dramatiq.brokers.redis.RedisBroker method) (dramatiq.brokers.stub.StubBroker method) fn (dramatiq.Actor attribute) forks (dramatiq.Middleware property)

G

GenericActor (class in dramatiq) get_actor() (dramatiq.Broker method) (dramatiq.brokers.rabbitmq.RabbitmqBroker method) (dramatiq.brokers.redis.RedisBroker method) (dramatiq.brokers.stub.StubBroker method) get_broker() (in module dramatiq) get_current_message() (dramatiq.middleware.CurrentMessage class method) get_declared_actors() (dramatiq.Broker method) (dramatiq.brokers.rabbitmq.RabbitmqBroker method) (dramatiq.brokers.redis.RedisBroker method) (dramatiq.brokers.stub.StubBroker method) get_declared_delay_queues() (dramatiq.Broker method) (dramatiq.brokers.rabbitmq.RabbitmqBroker method) (dramatiq.brokers.redis.RedisBroker method) (dramatiq.brokers.stub.StubBroker method) get_declared_queues() (dramatiq.Broker method) (dramatiq.brokers.rabbitmq.RabbitmqBroker method) (dramatiq.brokers.redis.RedisBroker method) (dramatiq.brokers.stub.StubBroker method)

get_encoder() (in module dramatiq) get_queue_message_counts() (dramatiq.brokers.rabbitmq.RabbitmqBroker method) get_result() (dramatiq.Message method) (dramatiq.pipeline method) (dramatiq.results.ResultBackend method) get_results() (dramatiq.group method) (dramatiq.pipeline method) get_results_backend() (dramatiq.Broker method) (dramatiq.brokers.rabbitmq.RabbitmqBroker method) (dramatiq.brokers.redis.RedisBroker method) (dramatiq.brokers.stub.StubBroker method) group (class in dramatiq) GroupCallbacks (class in dramatiq.middleware)

I

incr() (dramatiq.rate_limits.RateLimiterBackend method)

incr_and_sum() (dramatiq.rate_limits.RateLimiterBackend method) Interrupt

J

join() (dramatiq.Broker method) (dramatiq.brokers.rabbitmq.RabbitmqBroker method) (dramatiq.brokers.redis.RedisBroker method) (dramatiq.brokers.stub.StubBroker method) (dramatiq.Worker method)

JSONEncoder (class in dramatiq)

L

logger (dramatiq.Actor attribute) (dramatiq.GenericActor attribute)

M

MemcachedBackend (class in dramatiq.rate_limits.backends) (class in dramatiq.results.backends) Message (class in dramatiq) message() (dramatiq.Actor method) message_datetime (dramatiq.Message property)

message_with_options() (dramatiq.Actor method) MessageProxy (class in dramatiq) Middleware (class in dramatiq) MiddlewareError module dramatiq

N

nack() (dramatiq.Consumer method)

O

options (dramatiq.Actor attribute) (dramatiq.GenericActor attribute)

P

pause() (dramatiq.Worker method) perform() (dramatiq.GenericActor method) PickleEncoder (class in dramatiq) pipeline (class in dramatiq)

Pipelines (class in dramatiq.middleware) priority (dramatiq.Actor attribute) (dramatiq.GenericActor attribute) Prometheus (class in dramatiq.middleware.prometheus)

Q

queue_name (dramatiq.Actor attribute) (dramatiq.GenericActor attribute)

QueueNotFound

R

RabbitmqBroker (class in dramatiq.brokers.rabbitmq) RateLimiter (class in dramatiq.rate_limits) RateLimiterBackend (class in dramatiq.rate_limits) RateLimitExceeded RedisBackend (class in dramatiq.rate_limits.backends) (class in dramatiq.results.backends) RedisBroker (class in dramatiq.brokers.redis) requeue() (dramatiq.Consumer method) ResultBackend (class in dramatiq.results)

ResultError ResultFailure ResultMissing Results (class in dramatiq.results) ResultTimeout resume() (dramatiq.Worker method) Retries (class in dramatiq.middleware) Retry run() (dramatiq.group method) (dramatiq.pipeline method)

S

send() (dramatiq.Actor method) send_with_options() (dramatiq.Actor method) set_broker() (in module dramatiq) set_encoder() (in module dramatiq) Shutdown ShutdownNotifications (class in dramatiq.middleware) SkipMessage

start() (dramatiq.Worker method) stop() (dramatiq.Worker method) store_exception() (dramatiq.results.ResultBackend method) store_result() (dramatiq.results.ResultBackend method) StubBackend (class in dramatiq.rate_limits.backends) (class in dramatiq.results.backends) StubBroker (class in dramatiq.brokers.stub) stuff_exception() (dramatiq.MessageProxy method)

T

TimeLimit (class in dramatiq.middleware)

TimeLimitExceeded

U

unwrap_result() (dramatiq.results.ResultBackend method)

W

wait() (dramatiq.group method) (dramatiq.rate_limits.Barrier method) (dramatiq.rate_limits.RateLimiterBackend method)

wait_notify() (dramatiq.rate_limits.RateLimiterBackend method) WindowRateLimiter (class in dramatiq.rate_limits) Worker (class in dramatiq)