Index

A

ack() (zrq.Queue method) (zrq.stream.Stream method) add() (zrq.stream.Stream method) all() (zrq.stream.Stream static method) Any (in module zrq.typing)

AnyCallable (in module zrq.typing) assert_type() (in module zrq.typing) AsyncCallable (in module zrq.typing) AsyncGenerator (class in zrq.typing) AsyncIterator (class in zrq.typing) Awaitable (class in zrq.typing)

B

BaseQueue (class in zrq.queue)

C

Callable (class in zrq.typing) Callback (in module zrq.typing) cast() (in module zrq.typing) claim() (zrq.Queue method) (zrq.stream.Stream method) client (zrq.context.Redis property) close() (zrq.typing.Coroutine method) (zrq.typing.Generator method)

Command line interface ConsistencyError Constants (class in zrq.context) constants (in module zrq.context) consumers_info() (zrq.stream.Stream method) Coroutine (class in zrq.typing) create_group_with_consumer() (zrq.stream.Stream method)

D

DEFAULT_QUEUE (built-in variable) delete() (zrq.Queue method) (zrq.stream.Stream method)

delete_group() (zrq.stream.Stream method) destroy_group() (zrq.stream.Stream method)

E

enqueue() (zrq.Queue method) (zrq.Task method) enqueue_at() (zrq.Queue method)

enqueue_in() (zrq.Queue method) ENV_PREFIX (built-in variable) Environment variables

F

FrameType (in module zrq.typing)

G

Generator (class in zrq.typing) Generic (class in zrq.typing) get() (zrq.stream.Stream method)

get_pending() (zrq.stream.Stream method) get_type_hints() (in module zrq.typing) groups_info() (zrq.stream.Stream method)

J

Job	JOB_MAX_RETRY (built-in variable) JOB_TIMEOUT (built-in variable)

L

len() (zrq.stream.Stream method)

lock() (zrq.context.Settings method)

M

Mapping (class in zrq.typing) MissingConsumerIdError module zrq zrq.context zrq.exceptions zrq.typing

N

NonCallableTaskError

NonConsumableQueueError

O

overload() (in module zrq.typing)

P

ParamSpec (class in zrq.typing) pending_range() (zrq.stream.Stream method) pop() (zrq.Queue method) Programmatically

push() (zrq.Queue method) push_callable() (zrq.Queue method) push_coroutine() (zrq.Queue method) push_job() (zrq.Queue method) push_task() (zrq.Queue method)

Q

Queue (class in zrq)

QueueError

R

range() (zrq.stream.Stream method) read_group_oldest() (zrq.stream.Stream method)

Redis (class in zrq.context) redis (in module zrq.context) REDIS_URL (built-in variable)

S

send() (zrq.typing.Coroutine method) (zrq.typing.Generator method) Sequence (class in zrq.typing) serializer (zrq.Queue attribute)

Settings (class in zrq.context) settings (in module zrq.context) SSL wrapped TCP socket connection Stream (class in zrq.stream)

T

Task (class in zrq) task() (in module zrq) (in module zrq.Queue) TCP socket connection

throw() (zrq.typing.Coroutine method) (zrq.typing.Generator method) TracebackType (in module zrq.typing) TypedDict (class in zrq.typing) TypeVar (class in zrq.typing)

U

Unix Domain Socket connection

update() (zrq.context.Settings method)

W

WORKER_SIZE (built-in variable)

Z

zrq module zrq.context module

zrq.exceptions module zrq.typing module