Index

A | B | C | D | E | F | G | H | I | J | K | L | M | N | O | P | Q | R | S | T | U | V | W | Z

A

Access (class in zaqar.common.access)
admin (Access attribute)
advance_time_delta() (in module zaqar.openstack.common.timeutils)
advance_time_seconds() (in module zaqar.openstack.common.timeutils)
AOD (Capabilities attribute)
api (Bootstrap attribute)
Api (class in zaqar.common.api.api)
append() (BaseCache method)
append_tail() (BaseCache method)

B

BadRequest
BASE_CAPABILITIES (DataDriver attribute), [1], [2]
(DataDriverBase attribute)
(FIFODataDriver attribute)
BaseCache (class in zaqar.openstack.common.cache.backends)
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)
clear() (BaseCache method)
clear_time_override() (in module zaqar.openstack.common.timeutils)
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
Conflict
connection (ControlDriver attribute), [1], [2]
(DataDriver attribute), [1]
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

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]
delete_cached_file() (in module zaqar.openstack.common.fileutils)
delete_if_exists() (in module zaqar.openstack.common.fileutils)
delta_seconds() (in module zaqar.openstack.common.timeutils)
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)
deserialized_content (Request attribute)
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

emit() (TranslationHandler method)
enable_lazy() (in module zaqar.openstack.common.gettextutils)
Endpoints (class in zaqar.api.v2.endpoints)
engine (ControlDriver attribute)
ensure_tree() (in module zaqar.openstack.common.fileutils)
error_response() (in module zaqar.common.api.utils)
ExceptionBase, [1]
execute() (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)
external_lock() (in module zaqar.openstack.common.lockutils)
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)
file_open() (in module zaqar.openstack.common.fileutils)
FileLock (in module zaqar.openstack.common.lockutils)
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)
FlavorDoesNotExist
flavors_controller (ControlDriver attribute), [1], [2]
(ControlDriverBase attribute)
FlavorsBase (class in zaqar.storage.base)
FlavorsController (class in zaqar.storage.mongodb.flavors)
forever_retry_uncaught_exceptions() (in module zaqar.openstack.common.excutils)
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)
(SubscriptionEnvelope static method)
from_redis() (Message static method)
(MessageEnvelope static method)
(SubscriptionEnvelope static method)
from_redis_bulk() (Message static method)
(MessageEnvelope static method)

G

gc() (DataDriver method), [1]
(DataDriverBase method)
(MessageController method)
get() (BaseCache method)
(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_available_languages() (in module zaqar.openstack.common.gettextutils)
get_cache() (in module zaqar.openstack.common.cache.cache)
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_defaults() (Handler method)
get_driver() (Catalog method)
get_group() (PoolsBase method)
get_headers() (in module zaqar.common.api.utils)
get_many() (BaseCache method)
get_message_controller() (Catalog method)
get_metadata() (Queue method)
(QueueController method), [1], [2], [3]
get_partition() (in module zaqar.storage.mongodb.utils)
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_subscription_controller() (Catalog method)

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
HTTPDocumentTypeNotSupported
HTTPForbidden
HTTPServiceUnavailable

I

id (Message attribute)
(MessageEnvelope attribute)
(SubscriptionEnvelope attribute)
incr() (BaseCache method)
inject_context() (in module zaqar.common.transport.wsgi.helpers)
insert() (CatalogueBase method)
(CatalogueController method), [1]
install() (in module zaqar.openstack.common.gettextutils)
(zaqar.transport.auth.KeystoneAuth class method)
internal_lock() (in module zaqar.openstack.common.lockutils)
InterProcessLock (in module zaqar.openstack.common.lockutils)
InvalidAction
InvalidDriver
is_alive() (DataDriver method), [1], [2], [3]
(DataDriverBase method)
is_newer_than() (in module zaqar.openstack.common.timeutils)
is_older_than() (in module zaqar.openstack.common.timeutils)
is_soon() (in module zaqar.openstack.common.timeutils)
iso8601_from_timestamp() (in module zaqar.openstack.common.timeutils)
isotime() (in module zaqar.openstack.common.timeutils)
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)
lock() (in module zaqar.openstack.common.lockutils)
log_critical (TranslatorFactory attribute)
log_error (TranslatorFactory attribute)
log_info (TranslatorFactory attribute)
log_warning (TranslatorFactory attribute)
lookup() (Catalog method)

M

main() (in module zaqar.openstack.common.lockutils)
MalformedJSON
marker_decode() (in module zaqar.storage.sqlalchemy.utils)
marker_encode() (in module zaqar.storage.sqlalchemy.utils)
marshall_now() (in module zaqar.openstack.common.timeutils)
memoized_getattr() (in module zaqar.common.decorators)
MemoryBackend (class in zaqar.openstack.common.cache._backends.memory)
Message
(class in zaqar.openstack.common.gettextutils)
(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)
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)
(PoolCapabilitiesMismatch attribute)
(PoolDoesNotExist attribute)
(PoolInUseByFlavor attribute)
(QueueDoesNotExist attribute)
(QueueIsEmpty attribute)
(QueueNotMapped 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)
normalize_time() (in module zaqar.openstack.common.timeutils)
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_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]
(Resource method), [1], [2], [3], [4]
on_post() (CollectionResource method), [1], [2], [3], [4], [5], [6]
(Resource method)
on_put() (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_isotime() (in module zaqar.openstack.common.timeutils)
parse_scoped_project_queue() (in module zaqar.storage.mongodb.utils)
parse_strtime() (in module zaqar.openstack.common.timeutils)
PatternNotFound
Pipeline (class in zaqar.common.pipeline)
PoolCapabilitiesMismatch
PoolDoesNotExist
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)
primary (TranslatorFactory attribute)
process_request() (Handler method)
Producer
Producer - Consumer
project (SubscriptionEnvelope attribute)
protocol (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)
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.common.api.utils)
(in module zaqar.storage.mongodb.utils)
(in module zaqar.storage.redis.utils)
(in module zaqar.storage.sqlalchemy.utils)
read_cached_file() (in module zaqar.openstack.common.fileutils)
read_json() (in module zaqar.transport.utils)
register() (Catalog method)
register_oslo_configs() (in module zaqar.openstack.common.cache.cache)
remove_external_lock_file() (in module zaqar.openstack.common.lockutils)
remove_path_on_error() (in module zaqar.openstack.common.fileutils)
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)
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)
save_and_reraise_exception (class in zaqar.openstack.common.excutils)
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_subscribers_set() (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)
set() (BaseCache method)
set_defaults() (in module zaqar.openstack.common.lockutils)
set_many() (BaseCache method)
set_metadata() (Queue method)
(QueueController method), [1], [2], [3]
set_time_override() (in module zaqar.openstack.common.timeutils)
setdefault() (BaseCache method)
setFormatter() (TranslationHandler 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)
strtime() (in module zaqar.openstack.common.timeutils)
subscriber (SubscriptionEnvelope attribute)
Subscription (class in zaqar.storage.base)
subscription_controller (DataDriver attribute), [1], [2], [3]
(DataDriverBase attribute)
subscription_expired_filter() (in module zaqar.storage.redis.utils)
subscription_listing() (Validator method)
subscription_patching() (Validator method)
subscription_posting() (Validator method)
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_controller (ControlDriver attribute)
subscriptions_database (DataDriver attribute)
subset_key() (in module zaqar.storage.redis.utils)
synchronized() (in module zaqar.openstack.common.lockutils)
synchronized_with_prefix() (in module zaqar.openstack.common.lockutils)

T

TITLE (HTTPBadRequestAPI attribute)
(HTTPBadRequestBody attribute)
(HTTPForbidden 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)
total_seconds() (in module zaqar.openstack.common.timeutils)
translate() (in module zaqar.openstack.common.gettextutils)
(Message method)
TranslationHandler (class in zaqar.openstack.common.gettextutils)
TranslatorFactory (class in zaqar.openstack.common.gettextutils)
transport (Bootstrap attribute)
ttl (Message attribute)
(MessageEnvelope attribute)
(SubscriptionEnvelope attribute)

U

unmarshall_time() (in module zaqar.openstack.common.timeutils)
unset_many() (BaseCache method)
update() (BaseCache method)
(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)
utcnow() (in module zaqar.openstack.common.timeutils)
utcnow_ts() (in module zaqar.openstack.common.timeutils)

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.task.webhook)
weighted() (in module zaqar.common.storage.select)
Worker
write_to_tempfile() (in module zaqar.openstack.common.fileutils)

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.task.webhook (module)
zaqar.openstack.common.cache._backends.memory (module)
zaqar.openstack.common.cache.backends (module)
zaqar.openstack.common.cache.cache (module)
zaqar.openstack.common.excutils (module)
zaqar.openstack.common.fileutils (module)
zaqar.openstack.common.gettextutils (module)
zaqar.openstack.common.lockutils (module)
zaqar.openstack.common.timeutils (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)

Project Source