Index

A

ack_message() (micro_framework.amqp.manager.ConsumerManager method) (micro_framework.amqp.manager.RPCManager method) add_entrypoint() (micro_framework.amqp.manager.ConsumerManager method)

after_call() (micro_framework.dependencies.Dependency method) amqp_uri() (micro_framework.amqp.dependencies.Producer property) (micro_framework.amqp.manager.ConsumerManager property) (micro_framework.amqp.manager.RPCManager property)

B

backoff() (micro_framework.routes.Route property) BaseEventListener (class in micro_framework.amqp.entrypoints) bind() (micro_framework.dependencies.Dependency method) (micro_framework.entrypoints.Entrypoint method) (micro_framework.extensions.Extension method)

bind_new_extension() (micro_framework.extensions.Extension method)

C

call_route() (micro_framework.amqp.entrypoints.BaseEventListener method) (micro_framework.entrypoints.Entrypoint method) call_task() (micro_framework.workers.Worker method) callback_worker_class (micro_framework.routes.CallbackRoute attribute) CallbackRoute (class in micro_framework.routes) CallbackWorker (class in micro_framework.workers) CallItem (class in micro_framework.spawners.base)

Config (class in micro_framework.dependencies) connector_class (micro_framework.amqp.dependencies.RPCProxyProvider attribute) ConsumerManager (class in micro_framework.amqp.manager) context_singleton (micro_framework.amqp.manager.ConsumerManager attribute) (micro_framework.amqp.manager.RPCManager attribute) (micro_framework.extensions.Extension attribute) create_task() (micro_framework.spawners.multiprocess.ProcessSpawner method) (micro_framework.spawners.thread.ThreadSpawner method)

D

Dependency (class in micro_framework.dependencies)

dispatch() (in module micro_framework.amqp.dependencies)

E

Entrypoint (class in micro_framework.entrypoints) entrypoint() (micro_framework.routes.Route property) EventListener (class in micro_framework.amqp.entrypoints)

exchange() (micro_framework.amqp.dependencies.Producer property) Extension (class in micro_framework.extensions) ExtensionIsStopped

F

FrameworkException

from_task() (micro_framework.spawners.base.CallItem class method)

G

get_callback_worker_instance() (micro_framework.routes.CallbackRoute method) get_connection() (micro_framework.amqp.manager.ConsumerManager method) (micro_framework.amqp.manager.RPCManager method) get_connector_kwargs() (micro_framework.amqp.dependencies.RPCProxyProvider method) get_consumers() (micro_framework.amqp.manager.ConsumerManager method) (micro_framework.amqp.manager.RPCManager method) get_dependency() (micro_framework.amqp.dependencies.Producer method) (micro_framework.dependencies.Config method) (micro_framework.dependencies.Dependency method)

get_exchange() (micro_framework.amqp.entrypoints.BaseEventListener method) get_message() (micro_framework.translators.MessageTranslator method) get_queue() (micro_framework.amqp.entrypoints.BaseEventListener method) get_queue_name() (micro_framework.amqp.entrypoints.BaseEventListener method) (micro_framework.amqp.entrypoints.EventListener method) (micro_framework.amqp.entrypoints.QueueListener method) get_worker_instance() (micro_framework.routes.Route method)

H

handle_finished_worker() (micro_framework.routes.CallbackRoute method) (micro_framework.routes.Route method)

handle_new_call() (micro_framework.amqp.manager.RPCManager method) handle_new_message() (micro_framework.amqp.manager.ConsumerManager method)

I

initiate_pool() (micro_framework.spawners.multiprocess.ProcessSpawner method) (micro_framework.spawners.thread.ThreadSpawner method)

initiate_queue_task() (micro_framework.spawners.multiprocess.ProcessSpawner method) inject() (in module micro_framework.dependencies) internal (micro_framework.amqp.entrypoints.BaseEventListener attribute)

J

JSONTranslator (class in micro_framework.translators)

K

kill() (micro_framework.spawners.base.Spawner method)

M

manager (micro_framework.amqp.entrypoints.BaseEventListener attribute) (micro_framework.amqp.entrypoints.RPCListener attribute) MaxConnectionsReached MessageTranslator (class in micro_framework.translators) metric_label() (micro_framework.routes.Route property) micro_framework.amqp module micro_framework.amqp.dependencies module micro_framework.amqp.entrypoints module micro_framework.amqp.manager module micro_framework.dependencies module micro_framework.entrypoints module micro_framework.exceptions module micro_framework.extensions module micro_framework.routes module micro_framework.spawners module

micro_framework.spawners.base module micro_framework.spawners.multiprocess module micro_framework.spawners.thread module micro_framework.translators module micro_framework.workers module module micro_framework.amqp micro_framework.amqp.dependencies micro_framework.amqp.entrypoints micro_framework.amqp.manager micro_framework.dependencies micro_framework.entrypoints micro_framework.exceptions micro_framework.extensions micro_framework.routes micro_framework.spawners micro_framework.spawners.base micro_framework.spawners.multiprocess micro_framework.spawners.thread micro_framework.translators micro_framework.workers

O

on_broadcast_message() (micro_framework.amqp.manager.RPCManager method) on_connection_error() (micro_framework.amqp.manager.ConsumerManager method)

on_consume_ready() (micro_framework.amqp.manager.ConsumerManager method) on_message() (micro_framework.amqp.manager.ConsumerManager method) (micro_framework.amqp.manager.RPCManager method)

P

parent (micro_framework.extensions.Extension attribute) PoolStopped process_initializer() (in module micro_framework.spawners.multiprocess)

process_worker() (in module micro_framework.spawners.multiprocess) ProcessPoolSpawner (class in micro_framework.spawners.multiprocess) ProcessSpawner (class in micro_framework.spawners.multiprocess) Producer (class in micro_framework.amqp.dependencies)

Q

QueueListener (class in micro_framework.amqp.entrypoints)

R

reply_listener (micro_framework.amqp.dependencies.RPCProxyProvider attribute) requeue_message() (micro_framework.amqp.manager.ConsumerManager method) (micro_framework.amqp.manager.RPCManager method) Route (class in micro_framework.routes) route (micro_framework.entrypoints.Entrypoint attribute) RPCAsyncResponse RPCException RPCListener (class in micro_framework.amqp.entrypoints)

RPCManager (class in micro_framework.amqp.manager) RPCProxyProvider (class in micro_framework.amqp.dependencies) RPCTargetDoesNotExist run() (micro_framework.spawners.base.Task method) (micro_framework.workers.Worker method) run_backoff() (micro_framework.routes.Route method) run_worker() (micro_framework.routes.Route method) runner() (micro_framework.extensions.Extension property)

S

send_reply() (micro_framework.amqp.manager.RPCManager method) set_message() (micro_framework.translators.MessageTranslator method) setup() (micro_framework.amqp.entrypoints.BaseEventListener method) (micro_framework.amqp.entrypoints.RPCListener method) (micro_framework.amqp.manager.ConsumerManager method) (micro_framework.amqp.manager.RPCManager method) (micro_framework.extensions.Extension method) setup_dependency() (micro_framework.dependencies.Dependency method) shutdown() (micro_framework.spawners.multiprocess.ProcessPoolSpawner method) (micro_framework.spawners.multiprocess.ProcessSpawner method) (micro_framework.spawners.thread.ThreadPoolSpawner method) (micro_framework.spawners.thread.ThreadSpawner method) singleton (micro_framework.extensions.Extension attribute) spawn() (micro_framework.spawners.base.Spawner method) Spawner (class in micro_framework.spawners.base) start() (micro_framework.amqp.manager.ConsumerManager method) (micro_framework.amqp.manager.RPCManager method) (micro_framework.entrypoints.TimeEntrypoint method) (micro_framework.extensions.Extension method)

start_callback_route() (micro_framework.routes.CallbackRoute method) start_new_process() (micro_framework.spawners.multiprocess.ProcessSpawner method) start_new_thread() (micro_framework.spawners.thread.ThreadSpawner method) start_route() (micro_framework.routes.Route method) stop() (micro_framework.amqp.manager.ConsumerManager method) (micro_framework.amqp.manager.RPCManager method) (micro_framework.entrypoints.TimeEntrypoint method) (micro_framework.extensions.Extension method) (micro_framework.routes.Route method) (micro_framework.spawners.base.Spawner method) stop_thread() (micro_framework.spawners.thread.ThreadSpawner method) submit() (micro_framework.spawners.multiprocess.ProcessSpawner method) (micro_framework.spawners.thread.ThreadSpawner method)

T

Task (class in micro_framework.spawners.base) terminate_process() (micro_framework.spawners.multiprocess.ProcessSpawner method) thread_worker() (in module micro_framework.spawners.thread) ThreadPoolSpawner (class in micro_framework.spawners.thread) ThreadSpawner (class in micro_framework.spawners.thread)

TimeEntrypoint (class in micro_framework.entrypoints) translate() (micro_framework.translators.MessageTranslator method) translate_message() (micro_framework.translators.JSONTranslator method) (micro_framework.translators.MessageTranslator method) translators() (micro_framework.routes.Route property) transport_options() (micro_framework.amqp.dependencies.Producer property)

W

Worker (class in micro_framework.workers)

worker_class (micro_framework.routes.Route attribute) worker_init() (in module micro_framework.spawners.base)