Index

A

apply() (kuyruk.Task method)

C

channel() (kuyruk.Kuyruk method)

Config (class in kuyruk) connection() (kuyruk.Kuyruk method)

D

Discard

E

EAGER (kuyruk.Config attribute)

F

from_dict() (kuyruk.Config method) from_env_vars() (kuyruk.Config method)

from_object() (kuyruk.Config method) from_pyfile() (kuyruk.Config method)

H

HeartbeatError

K

Kuyruk (class in kuyruk) kuyruk.exceptions module

kuyruk.signals module KuyrukError

M

module kuyruk.exceptions kuyruk.signals

N

name (kuyruk.Task property)

new_connection() (kuyruk.Kuyruk method)

R

RABBIT_CONNECT_TIMEOUT (kuyruk.Config attribute) RABBIT_HEARTBEAT (kuyruk.Config attribute) RABBIT_HOST (kuyruk.Config attribute) RABBIT_IDLE_DURATION (kuyruk.Config attribute) RABBIT_PASSWORD (kuyruk.Config attribute) RABBIT_PORT (kuyruk.Config attribute) RABBIT_READ_TIMEOUT (kuyruk.Config attribute)

RABBIT_SSL (kuyruk.Config attribute) RABBIT_USER (kuyruk.Config attribute) RABBIT_VIRTUAL_HOST (kuyruk.Config attribute) RABBIT_WRITE_TIMEOUT (kuyruk.Config attribute) Reject RemoteException ResultTimeout

S

send_to_queue() (kuyruk.Task method)

T

Task (class in kuyruk) task() (kuyruk.Kuyruk method) task_error (in module kuyruk.signals) task_failure (in module kuyruk.signals) task_init (in module kuyruk.signals) task_postapply (in module kuyruk.signals) task_postrun (in module kuyruk.signals)

task_postsend (in module kuyruk.signals) task_preapply (in module kuyruk.signals) task_prerun (in module kuyruk.signals) task_presend (in module kuyruk.signals) task_success (in module kuyruk.signals) TCP_USER_TIMEOUT (kuyruk.Config attribute) Timeout

W

worker_failure (in module kuyruk.signals) worker_init (in module kuyruk.signals) WORKER_LOGGING_LEVEL (kuyruk.Config attribute) WORKER_MAX_LOAD (kuyruk.Config attribute)

WORKER_MAX_RUN_TIME (kuyruk.Config attribute) WORKER_RECONNECT_INTERVAL (kuyruk.Config attribute) worker_shutdown (in module kuyruk.signals) worker_start (in module kuyruk.signals)