Index

A

Access (class in zaqar.common.access) admin (Access attribute) AOD (Capabilities attribute)

api (Bootstrap attribute) Api (class in zaqar.common.api.api) api_version_manager() (in module zaqar.common.decorators)

B

BadRequest BASE_CAPABILITIES (DataDriver attribute), [1], [2] (DataDriverBase attribute) (FIFODataDriver attribute) before_hooks (Driver attribute) body (Message attribute)

Bootstrap (class in zaqar.bootstrap) bulk_delete() (Message method) (MessageController method), [1], [2] bulk_get() (Message method) (MessageController method), [1], [2]

C

cache (Bootstrap attribute) cached_gen() (in module zaqar.storage.mongodb.utils) caches() (in module zaqar.common.decorators) calculate_backoff() (in module zaqar.storage.mongodb.utils) can_connect() (in module zaqar.storage.utils) Capabilities (class in zaqar.storage.base) capabilities (DataDriver attribute), [1], [2], [3] (DataDriverBase attribute) capabilities() (PoolsBase method) Catalog (class in zaqar.storage.pooling) Catalog Database catalogue_controller (ControlDriver attribute), [1], [2] (ControlDriverBase attribute) CatalogueBase (class in zaqar.storage.base) CatalogueController (class in zaqar.storage.mongodb.catalogue) (class in zaqar.storage.sqlalchemy.catalogue) cid_decode() (in module zaqar.storage.sqlalchemy.utils) cid_encode() (in module zaqar.storage.sqlalchemy.utils) Claim (class in zaqar.storage.base) Claim TTL claim_controller (DataDriver attribute), [1], [2], [3] (DataDriverBase attribute) claim_create() (Endpoints method) claim_creation() (Validator method) claim_delete() (Endpoints method) claim_expires (Message attribute) (MessageEnvelope attribute) claim_get() (Endpoints method) claim_grace (ResourceDefaults attribute) claim_id (Message attribute) (MessageEnvelope attribute) claim_ttl (ResourceDefaults attribute) claim_update() (Endpoints method) claim_updating() (Validator method)

ClaimConflict ClaimController (class in zaqar.storage.mongodb.claims) (class in zaqar.storage.pooling) (class in zaqar.storage.redis.claims) ClaimDoesNotExist CLAIMS (Capabilities attribute) clean_subscriptions() (Handler method) client_uuid (Message attribute) (MessageEnvelope attribute) close() (ControlDriver method), [1], [2] (ControlDriverBase method) (DataDriver method), [1], [2], [3] (DataDriverBase method) CollectionResource (class in zaqar.transport.wsgi.v1_0.claims) (class in zaqar.transport.wsgi.v1_0.messages) (class in zaqar.transport.wsgi.v1_0.queues) (class in zaqar.transport.wsgi.v1_1.claims) (class in zaqar.transport.wsgi.v1_1.messages) (class in zaqar.transport.wsgi.v1_1.queues) (class in zaqar.transport.wsgi.v2_0.claims) (class in zaqar.transport.wsgi.v2_0.messages) (class in zaqar.transport.wsgi.v2_0.queues) (class in zaqar.transport.wsgi.v2_0.subscriptions) ConfigurationError confirm() (Subscription method) (SubscriptionController method), [1], [2] confirmed (SubscriptionEnvelope attribute) ConfirmResource (class in zaqar.transport.wsgi.v2_0.subscriptions) Conflict connection (ControlDriver attribute), [1], [2] (DataDriver attribute), [1] connection_lost() (NotificationProtocol method) connection_made() (NotificationProtocol method) ConnectionError ConnectionURI (class in zaqar.storage.redis.driver) consumer_for() (Pipeline method) control (Bootstrap attribute) ControlDriver (class in zaqar.storage.mongodb.driver) (class in zaqar.storage.redis.driver) (class in zaqar.storage.sqlalchemy.driver) ControlDriverBase (class in zaqar.storage.base) ControllerBase (class in zaqar.storage.base) create() (Claim method) (ClaimController method), [1], [2] (FlavorsBase method) (FlavorsController method) (MessageQueueHandler method) (PoolsBase method) (Queue method) (Subscription method) (SubscriptionController method), [1], [2] create_request() (Handler static method) create_response() (Handler method) create_signed_url() (in module zaqar.common.urls) created (Message attribute) (MessageEnvelope attribute)

D

data_received() (NotificationProtocol method) database (ControlDriver attribute) DataDriver (class in zaqar.storage.mongodb.driver) (class in zaqar.storage.pipeline) (class in zaqar.storage.pooling) (class in zaqar.storage.redis.driver) DataDriverBase (class in zaqar.storage.base) delete() (CatalogueBase method) (CatalogueController method), [1] (Claim method) (ClaimController method), [1], [2] (FlavorsBase method) (FlavorsController method) (Message method) (MessageController method), [1], [2] (MessageQueueHandler method), [1] (PoolsBase method) (Queue method) (Subscription method) (SubscriptionController method), [1], [2] deregister() (Catalog method) descope_message_ids_set() (in module zaqar.storage.redis.utils) descope_queue_name() (in module zaqar.storage.mongodb.utils) (in module zaqar.storage.redis.utils) descope_subscription_ids_set() (in module zaqar.storage.redis.utils) DESCRIPTION (HTTPDocumentTypeNotSupported attribute) (HTTPForbidden attribute) (HTTPServiceUnavailable attribute)

deserialize() (in module zaqar.transport.wsgi.utils) dict_to_conf() (in module zaqar.common.utils) DocumentTypeNotSupported DoesNotExist Driver (class in zaqar.transport.websocket.driver) (class in zaqar.transport.wsgi.driver) DriverBase (class in zaqar.storage.base) (class in zaqar.transport.base) drop_all() (CatalogueBase method) (CatalogueController method), [1] (FlavorsBase method) (FlavorsController method) (PoolsBase method) DURABILITY (Capabilities attribute) dynamic_conf() (in module zaqar.storage.utils)

E

Endpoints (class in zaqar.api.v2.endpoints) engine (ControlDriver attribute) error_response() (in module zaqar.common.api.utils) ExceptionBase, [1]

execute() (MailtoTask method) (WebhookTask method) exists() (CatalogueBase method) (CatalogueController method), [1] (FlavorsBase method) (FlavorsController method) (PoolsBase method) (Queue method) (Subscription method) (SubscriptionController method), [1], [2] expires (Message attribute) (MessageEnvelope attribute) (SubscriptionEnvelope attribute) extract_project_id() (in module zaqar.common.transport.wsgi.helpers)

F

factory (Driver attribute) fields() (in module zaqar.common.utils) FIFO (Capabilities attribute) FIFODataDriver (class in zaqar.storage.mongodb.driver) FIFOMessageController (class in zaqar.storage.mongodb.messages) filter() (in module zaqar.transport.wsgi.utils) filter_fields() (in module zaqar.common.api.utils) first() (Message method) (MessageController method), [1], [2] flavor (PoolInUseByFlavor attribute) flavor_listing() (Validator method) FlavorDoesNotExist

flavors_controller (ControlDriver attribute), [1], [2] (ControlDriverBase attribute) FlavorsBase (class in zaqar.storage.base) FlavorsController (class in zaqar.storage.mongodb.flavors) format_message() (in module zaqar.common.api.utils) format_message_v1() (in module zaqar.transport.wsgi.utils) format_message_v1_1() (in module zaqar.transport.wsgi.utils) from_hmap() (Message static method) (MessageEnvelope static method) from_redis() (Message static method) (MessageEnvelope static method) (SubscriptionEnvelope static method) from_redis_bulk() (Message static method) (MessageEnvelope static method) FuncMiddleware (class in zaqar.transport.wsgi.driver)

G

gc() (DataDriver method), [1] (DataDriverBase method) (MessageController method) get() (CatalogueBase method) (CatalogueController method), [1] (Claim method) (ClaimController method), [1], [2] (FlavorsBase method) (FlavorsController method) (Message method) (MessageController method), [1], [2] (PoolsBase method) (Queue method) (Subscription method) (SubscriptionController method), [1], [2] get_age() (in module zaqar.storage.sqlalchemy.utils) get_checked_field() (in module zaqar.common.api.utils) (in module zaqar.transport.wsgi.utils) get_claim_controller() (Catalog method) get_client_uuid() (in module zaqar.common.api.utils) (in module zaqar.common.transport.wsgi.helpers) get_default_pool() (Catalog method) get_defaults() (Handler method) get_driver() (Catalog method) get_headers() (in module zaqar.common.api.utils) get_limit_conf_value() (Validator method) get_message_controller() (Catalog method)

get_metadata() (Queue method) (QueueController method), [1], [2], [3] get_partition() (in module zaqar.storage.mongodb.utils) get_pools_by_group() (PoolsBase method) get_qid() (in module zaqar.storage.sqlalchemy.utils) get_queue_controller() (Catalog method) get_request() (Request method) get_response() (Response method) get_schema() (Api method) get_subscriber() (NotificationFactory method) get_subscription_controller() (Catalog method) get_with_subscriber() (Subscription method) (SubscriptionController method), [1], [2]

H

Handler (class in zaqar.api.handler) headers (RequestSchema attribute), [1], [2] health() (DataDriverBase method) HIGH_THROUGHPUT (Capabilities attribute) HookedCursor (class in zaqar.storage.mongodb.utils) HTTPBadRequestAPI HTTPBadRequestBody

HTTPConflict HTTPDocumentTypeNotSupported HTTPForbidden HTTPNotFound HTTPServiceUnavailable HTTPUnsupportedMediaType

I

id (Message attribute) (MessageEnvelope attribute) (SubscriptionEnvelope attribute) inject_context() (in module zaqar.common.transport.wsgi.helpers) insert() (CatalogueBase method) (CatalogueController method), [1] install() (zaqar.transport.auth.KeystoneAuth class method)

InvalidAction InvalidDriver is_alive() (DataDriver method), [1], [2], [3] (DataDriverBase method) ItemResource (class in zaqar.transport.wsgi.v1_0.claims) (class in zaqar.transport.wsgi.v1_0.messages) (class in zaqar.transport.wsgi.v1_0.queues) (class in zaqar.transport.wsgi.v1_1.claims) (class in zaqar.transport.wsgi.v1_1.messages) (class in zaqar.transport.wsgi.v1_1.queues) (class in zaqar.transport.wsgi.v2_0.claims) (class in zaqar.transport.wsgi.v2_0.messages) (class in zaqar.transport.wsgi.v2_0.queues) (class in zaqar.transport.wsgi.v2_0.subscriptions)

J

json_decode() (in module zaqar.storage.sqlalchemy.utils) json_encode() (in module zaqar.storage.sqlalchemy.utils) JSONArray (in module zaqar.transport.wsgi.utils)

JSONObject (in module zaqar.transport.wsgi.utils) julian_to_unix() (in module zaqar.storage.sqlalchemy.utils)

K

keyify() (in module zaqar.storage.utils)

KeystoneAuth (class in zaqar.transport.auth)

L

lazy_property() (in module zaqar.common.decorators) list() (CatalogueBase method) (CatalogueController method), [1] (FlavorsBase method) (FlavorsController method) (Message method) (MessageController method), [1], [2] (PoolsBase method) (Queue method) (Subscription method) (SubscriptionController method), [1], [2] listen() (Driver method), [1] (DriverBase method) Listing (class in zaqar.transport.wsgi.v1_0.pools) (class in zaqar.transport.wsgi.v1_1.flavors) (class in zaqar.transport.wsgi.v1_1.pools) (class in zaqar.transport.wsgi.v2_0.flavors) (class in zaqar.transport.wsgi.v2_0.pools)

load() (in module zaqar.transport.wsgi.utils) load_storage_driver() (in module zaqar.storage.utils) load_storage_impl() (in module zaqar.storage.utils) lookup() (Catalog method)

M

MailtoTask (class in zaqar.notification.tasks.mailto) MalformedJSON marker_decode() (in module zaqar.storage.sqlalchemy.utils) marker_encode() (in module zaqar.storage.sqlalchemy.utils) memoized_getattr() (in module zaqar.common.decorators) Message (class in zaqar.storage.base) (class in zaqar.storage.redis.models) Message TTL message_content() (Validator method) message_controller (DataDriver attribute), [1], [2], [3] (DataDriverBase attribute) (FIFODataDriver attribute) message_databases (DataDriver attribute) message_delete() (Endpoints method) message_delete_many() (Endpoints method) message_deletion() (Validator method) message_get() (Endpoints method) message_get_many() (Endpoints method) message_length() (Validator method) message_list() (Endpoints method) message_listing() (Validator method) message_post() (Endpoints method) message_posting() (Validator method)

message_ttl (ResourceDefaults attribute) message_url() (in module zaqar.transport.wsgi.utils) MessageConflict MessageController (class in zaqar.storage.mongodb.messages) (class in zaqar.storage.pooling) (class in zaqar.storage.redis.messages) MessageDoesNotExist MessageEnvelope (class in zaqar.storage.redis.models) MessageIsClaimed MessageNotClaimed MessageNotClaimedBy MessageQueueHandler (class in zaqar.storage.mongodb.messages) (class in zaqar.storage.redis.messages) MessageType (class in zaqar.notification.notifier) MessagingProtocol (class in zaqar.transport.websocket.protocol) Mixin (class in zaqar.storage.redis.scripting) msg_claimed_filter() (in module zaqar.storage.redis.utils) msg_echo_filter() (in module zaqar.storage.redis.utils) msg_expired_filter() (in module zaqar.storage.redis.utils) msg_format (BadRequest attribute) (ClaimConflict attribute) (ClaimDoesNotExist attribute) (ExceptionBase attribute), [1] (FlavorDoesNotExist attribute) (MessageConflict attribute) (MessageDoesNotExist attribute) (MessageIsClaimed attribute) (MessageNotClaimed attribute) (MessageNotClaimedBy attribute) (NoPoolFound attribute) (PoolAlreadyExists attribute) (PoolCapabilitiesMismatch attribute) (PoolDoesNotExist attribute) (PoolGroupDoesNotExist attribute) (PoolInUseByFlavor attribute) (QueueDoesNotExist attribute) (QueueIsEmpty attribute) (QueueNotMapped attribute) (SubscriptionAlreadyExists attribute) (SubscriptionDoesNotExist attribute) msgid_decode() (in module zaqar.storage.sqlalchemy.utils) msgid_encode() (in module zaqar.storage.sqlalchemy.utils) msgset_key() (in module zaqar.storage.redis.utils)

N

next() (HookedCursor method) (QueueListCursor method) (SubscriptionListCursor method) NoPoolFound NoResult normalize_none_str() (in module zaqar.storage.mongodb.utils) (in module zaqar.storage.redis.utils) Notification (MessageType attribute)

notification_factory (Driver attribute) NotificationFactory (class in zaqar.transport.websocket.factory) NotificationProtocol (class in zaqar.transport.websocket.protocol) NotifierDriver (class in zaqar.notification.notifier) NotPermitted

O

oid_ts() (in module zaqar.storage.mongodb.utils) on_delete() (CollectionResource method), [1], [2] (ItemResource method), [1], [2], [3], [4], [5], [6], [7], [8], [9] (Resource method), [1], [2], [3], [4] on_exception_sends_500() (in module zaqar.common.api.utils) on_get() (CollectionResource method), [1], [2], [3], [4], [5], [6] (ItemResource method), [1], [2], [3], [4], [5], [6], [7], [8], [9] (Listing method), [1], [2], [3], [4] (Resource method), [1], [2], [3], [4], [5], [6], [7], [8], [9], [10], [11], [12], [13], [14], [15], [16], [17] on_head() (ItemResource method) (Resource method), [1], [2] on_patch() (ItemResource method), [1], [2], [3], [4] (Resource method), [1], [2], [3], [4] on_post() (CollectionResource method), [1], [2], [3], [4], [5], [6] (Resource method)

on_put() (ConfirmResource method) (ItemResource method), [1], [2] (Resource method), [1], [2], [3], [4], [5] onClose() (MessagingProtocol method) onConnect() (MessagingProtocol method) onMessage() (MessagingProtocol method) onOpen() (MessagingProtocol method) options (SubscriptionEnvelope attribute) OverflowedJSONInteger

P

parse_scoped_project_queue() (in module zaqar.storage.mongodb.utils) PatternNotFound Pipeline (class in zaqar.common.pipeline) pool_listing() (Validator method) PoolAlreadyExists PoolCapabilitiesMismatch PoolDoesNotExist PoolGroupDoesNotExist Pooling PoolInUseByFlavor pools_controller (ControlDriver attribute), [1], [2] (ControlDriverBase attribute) PoolsBase (class in zaqar.storage.base)

PoolsController (class in zaqar.storage.mongodb.pools) (class in zaqar.storage.sqlalchemy.pools) pop() (Message method) (MessageController method), [1], [2] post() (FIFOMessageController method) (Message method) (MessageController method), [1], [2] (NotifierDriver method) process_request() (Handler method) process_resource() (FuncMiddleware method) Producer Producer - Consumer project (SubscriptionEnvelope attribute) protocol (NotificationFactory attribute) (ProtocolFactory attribute) ProtocolFactory (class in zaqar.transport.websocket.factory) public (Access attribute) Publish - Subscribe

Q

Queue (class in zaqar.storage.base) queue_controller (ControlDriver attribute), [1], [2] (ControlDriverBase attribute) (DataDriver attribute), [1] (DataDriverBase attribute) queue_create() (Endpoints method) queue_delete() (Endpoints method) queue_get() (Endpoints method) queue_get_stats() (Endpoints method) queue_identification() (Validator method) queue_list() (Endpoints method) queue_listing() (Validator method) queue_metadata_length() (Validator method) queue_metadata_putting() (Validator method)

queue_patching() (Validator method) queue_purge() (Endpoints method) queue_purging() (Validator method) QueueController (class in zaqar.storage.mongodb.queues) (class in zaqar.storage.pooling) (class in zaqar.storage.redis.queues) (class in zaqar.storage.sqlalchemy.queues) QueueDoesNotExist QueueIsEmpty QueueListCursor (class in zaqar.storage.redis.utils) QueueNotMapped Queues Database queues_database (ControlDriver attribute)

R

raises_conn_error() (in module zaqar.storage.mongodb.utils) (in module zaqar.storage.redis.utils) (in module zaqar.storage.sqlalchemy.utils) read_json() (in module zaqar.transport.utils) register() (Catalog method) (MailtoTask method) (WebhookTask method) Request (class in zaqar.common.api.request) RequestContext (class in zaqar.context) RequestSchema (class in zaqar.api.v1.request) (class in zaqar.api.v1_1.request) (class in zaqar.api.v2.request) require_accepts_json() (in module zaqar.common.transport.wsgi.helpers) require_client_id() (in module zaqar.common.transport.wsgi.helpers) require_content_type_be_non_urlencoded() (in module zaqar.common.transport.wsgi.helpers)

Resource (class in zaqar.transport.wsgi.v1_0.claims) (class in zaqar.transport.wsgi.v1_0.health) (class in zaqar.transport.wsgi.v1_0.homedoc) (class in zaqar.transport.wsgi.v1_0.metadata) (class in zaqar.transport.wsgi.v1_0.pools) (class in zaqar.transport.wsgi.v1_0.stats) (class in zaqar.transport.wsgi.v1_1.flavors) (class in zaqar.transport.wsgi.v1_1.health) (class in zaqar.transport.wsgi.v1_1.homedoc) (class in zaqar.transport.wsgi.v1_1.ping) (class in zaqar.transport.wsgi.v1_1.pools) (class in zaqar.transport.wsgi.v1_1.stats) (class in zaqar.transport.wsgi.v2_0.flavors) (class in zaqar.transport.wsgi.v2_0.health) (class in zaqar.transport.wsgi.v2_0.homedoc) (class in zaqar.transport.wsgi.v2_0.ping) (class in zaqar.transport.wsgi.v2_0.pools) (class in zaqar.transport.wsgi.v2_0.stats) (class in zaqar.transport.wsgi.v2_0.urls) (class in zaqar.transport.wsgi.version) ResourceDefaults (class in zaqar.transport.base) Response (class in zaqar.common.api.response) ResponseSchema (class in zaqar.api.v1.response) (class in zaqar.api.v1_1.response) (class in zaqar.api.v2.response) retries_on_autoreconnect() (in module zaqar.storage.mongodb.utils) retries_on_connection_error() (in module zaqar.storage.redis.utils) run() (Bootstrap method) (ControlDriver method) (in module zaqar.cmd.gc) (in module zaqar.cmd.server) runnable() (in module zaqar.common.cli)

S

sanitize() (in module zaqar.common.api.utils) (in module zaqar.transport.wsgi.utils) schema (Api attribute) (RequestSchema attribute), [1], [2] scope_claim_messages() (in module zaqar.storage.redis.utils) scope_claims_set() (in module zaqar.storage.redis.utils) scope_message_ids_set() (in module zaqar.storage.redis.utils) scope_pool_catalogue() (in module zaqar.storage.redis.utils) scope_queue_catalogue() (in module zaqar.storage.redis.utils) scope_queue_index() (in module zaqar.storage.redis.utils) scope_queue_name() (in module zaqar.storage.mongodb.utils) (in module zaqar.storage.redis.utils) scope_subscription_ids_set() (in module zaqar.storage.redis.utils) scoped_query() (in module zaqar.storage.mongodb.utils) script_names (ClaimController attribute) (MessageController attribute) (Mixin attribute) send_confirm_notification() (NotifierDriver method) send_data() (NotificationFactory method) set_metadata() (Queue method) (QueueController method), [1], [2], [3] set_subscription_factory() (Handler method) set_subscription_url() (NotificationFactory method) SignedHeadersAuth (class in zaqar.transport.auth) source (SubscriptionEnvelope attribute) stat_message() (in module zaqar.storage.mongodb.utils) (in module zaqar.storage.sqlalchemy.utils) stats() (MessageQueueHandler method), [1] (Queue method) storage (Bootstrap attribute)

strategy() (in module zaqar.transport.auth) subscriber (SubscriptionEnvelope attribute) Subscription (class in zaqar.storage.base) subscription_confirming() (Validator method) subscription_controller (DataDriver attribute), [1], [2], [3] (DataDriverBase attribute) subscription_create() (Endpoints method) subscription_delete() (Endpoints method) subscription_get() (Endpoints method) subscription_list() (Endpoints method) subscription_listing() (Validator method) subscription_patching() (Validator method) subscription_posting() (Validator method) subscription_ttl (ResourceDefaults attribute) SubscriptionAlreadyExists SubscriptionConfirmation (MessageType attribute) SubscriptionController (class in zaqar.storage.mongodb.subscriptions) (class in zaqar.storage.pooling) (class in zaqar.storage.redis.subscriptions) SubscriptionDoesNotExist SubscriptionEnvelope (class in zaqar.storage.redis.models) SubscriptionListCursor (class in zaqar.storage.redis.utils) subscriptions_database (DataDriver attribute) subset_key() (in module zaqar.storage.redis.utils)

T

TITLE (HTTPBadRequestAPI attribute) (HTTPBadRequestBody attribute) (HTTPConflict attribute) (HTTPForbidden attribute) (HTTPNotFound attribute) (HTTPServiceUnavailable attribute) to_basic() (Message method) (SubscriptionEnvelope method) to_dict() (RequestContext method) to_json() (in module zaqar.transport.utils) to_oid() (in module zaqar.storage.mongodb.utils)

to_redis() (Message method) (MessageEnvelope method) (SubscriptionEnvelope method) transport (Bootstrap attribute) TransportLog (class in zaqar.common.decorators) ttl (Message attribute) (MessageEnvelope attribute) (SubscriptionEnvelope attribute)

U

unregister() (ProtocolFactory method) UnsubscribeConfirmation (MessageType attribute)

update() (CatalogueBase method) (CatalogueController method), [1] (Claim method) (ClaimController method), [1], [2] (FlavorsBase method) (FlavorsController method) (PoolsBase method) (Subscription method) (SubscriptionController method), [1], [2] update_store() (RequestContext method)

V

validate() (Api method) (in module zaqar.transport.wsgi.utils) validate_queue_identification() (in module zaqar.common.transport.wsgi.helpers) validate_request() (Handler static method) ValidationFailed Validator (class in zaqar.transport.validation)

validators (Api attribute) verify_pre_signed_url() (in module zaqar.common.transport.wsgi.helpers) verify_sha() (in module zaqar.version) verify_signature() (Handler method) verify_signed_headers_data() (in module zaqar.common.urls)

W

WebhookTask (class in zaqar.notification.tasks.webhook) weighted() (in module zaqar.common.storage.select)

Worker write_status() (NotificationProtocol method)

Z

zaqar.api.handler (module) zaqar.api.v1.request (module) zaqar.api.v1.response (module) zaqar.api.v1_1.request (module) zaqar.api.v1_1.response (module) zaqar.api.v2.endpoints (module) zaqar.api.v2.request (module) zaqar.api.v2.response (module) zaqar.bootstrap (module) zaqar.cmd.gc (module) zaqar.cmd.server (module) zaqar.common.access (module) zaqar.common.api.api (module) zaqar.common.api.errors (module) zaqar.common.api.request (module) zaqar.common.api.response (module) zaqar.common.api.schemas.flavors (module) zaqar.common.api.schemas.pools (module) zaqar.common.api.utils (module) zaqar.common.cli (module) zaqar.common.configs (module) zaqar.common.decorators (module) zaqar.common.errors (module) zaqar.common.pipeline (module) zaqar.common.storage.select (module) zaqar.common.transport.wsgi.helpers (module) zaqar.common.urls (module) zaqar.common.utils (module) zaqar.context (module) zaqar.i18n (module) zaqar.notification.notifier (module) zaqar.notification.tasks.mailto (module) zaqar.notification.tasks.webhook (module) zaqar.storage.base (module) zaqar.storage.errors (module) zaqar.storage.mongodb (module) zaqar.storage.mongodb.catalogue (module) zaqar.storage.mongodb.claims (module) zaqar.storage.mongodb.controllers (module) zaqar.storage.mongodb.driver (module) zaqar.storage.mongodb.flavors (module) zaqar.storage.mongodb.messages (module) zaqar.storage.mongodb.options (module) zaqar.storage.mongodb.pools (module) zaqar.storage.mongodb.queues (module) zaqar.storage.mongodb.subscriptions (module) zaqar.storage.mongodb.utils (module) zaqar.storage.pipeline (module) zaqar.storage.pooling (module) zaqar.storage.redis.claims (module) zaqar.storage.redis.controllers (module) zaqar.storage.redis.driver (module) zaqar.storage.redis.messages (module) zaqar.storage.redis.models (module)

zaqar.storage.redis.options (module) zaqar.storage.redis.queues (module) zaqar.storage.redis.scripting (module) zaqar.storage.redis.subscriptions (module) zaqar.storage.redis.utils (module) zaqar.storage.sqlalchemy.catalogue (module) zaqar.storage.sqlalchemy.controllers (module) zaqar.storage.sqlalchemy.driver (module) zaqar.storage.sqlalchemy.options (module) zaqar.storage.sqlalchemy.pools (module) zaqar.storage.sqlalchemy.queues (module) zaqar.storage.sqlalchemy.tables (module) zaqar.storage.sqlalchemy.utils (module) zaqar.storage.utils (module) zaqar.transport.auth (module) zaqar.transport.base (module) zaqar.transport.utils (module) zaqar.transport.validation (module) zaqar.transport.websocket.driver (module) zaqar.transport.websocket.factory (module) zaqar.transport.websocket.protocol (module) zaqar.transport.wsgi.driver (module) zaqar.transport.wsgi.errors (module) zaqar.transport.wsgi.utils (module) zaqar.transport.wsgi.v1_0.claims (module) zaqar.transport.wsgi.v1_0.health (module) zaqar.transport.wsgi.v1_0.homedoc (module) zaqar.transport.wsgi.v1_0.messages (module) zaqar.transport.wsgi.v1_0.metadata (module) zaqar.transport.wsgi.v1_0.pools (module) zaqar.transport.wsgi.v1_0.queues (module) zaqar.transport.wsgi.v1_0.stats (module) zaqar.transport.wsgi.v1_1.claims (module) zaqar.transport.wsgi.v1_1.flavors (module) zaqar.transport.wsgi.v1_1.health (module) zaqar.transport.wsgi.v1_1.homedoc (module) zaqar.transport.wsgi.v1_1.messages (module) zaqar.transport.wsgi.v1_1.ping (module) zaqar.transport.wsgi.v1_1.pools (module) zaqar.transport.wsgi.v1_1.queues (module) zaqar.transport.wsgi.v1_1.stats (module) zaqar.transport.wsgi.v2_0.claims (module) zaqar.transport.wsgi.v2_0.flavors (module) zaqar.transport.wsgi.v2_0.health (module) zaqar.transport.wsgi.v2_0.homedoc (module) zaqar.transport.wsgi.v2_0.messages (module) zaqar.transport.wsgi.v2_0.ping (module) zaqar.transport.wsgi.v2_0.pools (module) zaqar.transport.wsgi.v2_0.queues (module) zaqar.transport.wsgi.v2_0.stats (module) zaqar.transport.wsgi.v2_0.subscriptions (module) zaqar.transport.wsgi.v2_0.urls (module) zaqar.transport.wsgi.version (module) zaqar.version (module)