Index

_

__init__() (queuebridge.celery.result.TypedAsyncResult method) (queuebridge.hints.TaskSignature method)

A

ALLOWED_MODULE_PREFIXES (in module queuebridge.types)

C

class_fqn() (in module queuebridge.codec)

D

d (queuebridge.types.QBEnvelope attribute) decode() (in module queuebridge) (in module queuebridge.codec) (queuebridge.dramatiq.encoder.QueuebridgeEncoder method) (queuebridge.dramatiq.QueuebridgeEncoder method)

decode_args() (in module queuebridge.hints) decode_return() (in module queuebridge.hints) decode_wire() (in module queuebridge.codec) deserialize() (in module queuebridge.arq.serializer) dumps() (in module queuebridge.celery.serializer)

E

encode() (in module queuebridge) (in module queuebridge.codec) (queuebridge.dramatiq.encoder.QueuebridgeEncoder method) (queuebridge.dramatiq.QueuebridgeEncoder method)

G

get() (queuebridge.celery.result.TypedAsyncResult method) get_serializer_pair() (in module queuebridge.arq) (in module queuebridge.arq.install)

get_task_signature() (in module queuebridge.hints)

I

import_fqn() (in module queuebridge.codec)

is_qb_envelope() (in module queuebridge.codec)

L

loads() (in module queuebridge.celery.serializer)

M

module queuebridge queuebridge.arq queuebridge.arq.install queuebridge.arq.serializer queuebridge.celery queuebridge.celery.install queuebridge.celery.result queuebridge.celery.serializer queuebridge.codec queuebridge.dramatiq queuebridge.dramatiq.encoder queuebridge.hints queuebridge.types

P

params (queuebridge.hints.TaskSignature attribute), [1]

Q

QB_TAG (in module queuebridge.types) qb_task() (in module queuebridge.arq) (in module queuebridge.arq.install) QB_VERSION (in module queuebridge.types) QBEnvelope (class in queuebridge.types) queuebridge module queuebridge.arq module queuebridge.arq.install module queuebridge.arq.serializer module queuebridge.celery module queuebridge.celery.install module queuebridge.celery.result module

queuebridge.celery.serializer module queuebridge.codec module queuebridge.dramatiq module queuebridge.dramatiq.encoder module queuebridge.hints module queuebridge.types module QueuebridgeDecodeError QueuebridgeEncodeError QueuebridgeEncoder (class in queuebridge.dramatiq) (class in queuebridge.dramatiq.encoder) QueuebridgeError QueuebridgeSecurityError

R

register_queuebridge() (in module queuebridge.celery) (in module queuebridge.celery.install) (in module queuebridge.dramatiq) (in module queuebridge.dramatiq.encoder)

return_type (queuebridge.hints.TaskSignature attribute), [1]

S

serialize() (in module queuebridge.arq.serializer)

T

t (queuebridge.types.QBEnvelope attribute) TaskSignature (class in queuebridge.hints) typed_result() (in module queuebridge.arq) (in module queuebridge.arq.install) (in module queuebridge.celery) (in module queuebridge.celery.result)

TypedAsyncResult (class in queuebridge.celery.result)

V

v (queuebridge.types.QBEnvelope attribute)