API Documentation ================= Continuation based API ---------------------- This module is for *callbacks* style of asynchronous application development. We depend on the `pika` library for lower level communication and event loop. .. autoclass:: eventail.async_service.pika.Service :members: __init__, use_json, use_exclusive_queues, log, send_command, return_success, return_error, publish_event, publish_configuration, call_later, run, stop, handle_event, handle_command, handle_config, handle_result, handle_returned_message, on_ready, PREFETCH_COUNT, RETRY_DELAY, HEARTBEAT, BLOCKED_TIMEOUT .. autoclass:: eventail.async_service.pika.ReconnectingSupervisor :members: __init__, run Synchronous publisher --------------------- Depends on the kombu library:: pip install .[synchronous] .. autoclass:: eventail.sync_publisher.Endpoint :members: __init__, publish_configuration, publish_event, log, force_json Shared temporary data store --------------------------- .. autoclass:: eventail.tmp_store.STDataStore :members: simple_redis_backend, sentinel_backend, is_down, set, mset, pop, mpop, peek, peek_or_create