Index

_

__iter__() (dramatiq.Consumer method)

__next__() (dramatiq.Consumer method)

A

ack() (dramatiq.Consumer method) acquire() (dramatiq.rate_limits.RateLimiter method) Actor (class in dramatiq) actor() (in module dramatiq) actor_name (dramatiq.Actor attribute) actor_options (dramatiq.Broker attribute) (dramatiq.Middleware property) (dramatiq.results.Results property) ActorNotFound (class in dramatiq) 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) (dramatiq.results.Results method) after_process_boot() (dramatiq.Middleware method) after_process_message() (dramatiq.Middleware method) (dramatiq.middleware.CurrentMessage method) (dramatiq.results.Results method) after_skip_message() (dramatiq.Middleware method) (dramatiq.results.Results 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) (dramatiq.middleware.CurrentMessage 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) BrokerError (class in dramatiq) 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 (class in dramatiq) ConnectionError (class in dramatiq) ConnectionFailed (class in dramatiq) 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 (class in dramatiq) decr() (dramatiq.rate_limits.RateLimiterBackend method) dramatiq module DramatiqError (class in dramatiq)

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

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)

I

incr() (dramatiq.rate_limits.RateLimiterBackend method)

incr_and_sum() (dramatiq.rate_limits.RateLimiterBackend method) Interrupt (class in dramatiq.middleware)

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)

M

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

MessageProxy (class in dramatiq) Middleware (class in dramatiq) MiddlewareError (class in dramatiq.middleware) module dramatiq

N

nack() (dramatiq.Consumer method)

O

options (dramatiq.Actor attribute)

P

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

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

Q

queue_name (dramatiq.Actor attribute)

QueueNotFound (class in dramatiq)

R

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

ResultFailure (class in dramatiq.results) ResultMissing (class in dramatiq.results) Results (class in dramatiq.results) ResultTimeout (class in dramatiq.results) resume() (dramatiq.Worker method) Retries (class in dramatiq.middleware) Retry (class in dramatiq) 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 (class in dramatiq.middleware) ShutdownNotifications (class in dramatiq.middleware) SkipMessage (class in dramatiq.middleware)

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 (class in dramatiq.middleware)

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)