Index

A

AbstractClient (class in tavrida.amqp_driver.base) AbstractController (class in tavrida.controller) AbstractDiscovery (class in tavrida.discovery) AbstractMessageController (class in tavrida.controller) AbstractReader (class in tavrida.amqp_driver.base) AbstractWriter (class in tavrida.amqp_driver.base) AbstractWriterFactory (class in tavrida.amqp_driver.base)

AckableException (class in tavrida.exceptions) add_headers() (tavrida.proxies.RPCProxy method) add_incoming_middleware() (tavrida.service.ServiceController method) add_outgoing_middleware() (tavrida.service.ServiceController method) AMQPDriver (class in tavrida.amqp_driver.driver) AMQPMessage (class in tavrida.messages)

B

BaseAckableException BaseError (class in tavrida.messages) BaseException BaseNackableException BasePikaAsync (class in tavrida.amqp_driver.pika_async) BaseResponse (class in tavrida.messages)

bind_queue() (tavrida.amqp_driver.base.AbstractReader method) (tavrida.amqp_driver.driver.AMQPDriver method) (tavrida.amqp_driver.pika_async.Reader method) (tavrida.amqp_driver.pika_sync.Reader method) BindingCreator (class in tavrida.amqp_driver.pika_async) body (tavrida.messages.Message attribute) body_deserialize() (tavrida.messages.AMQPMessage method) body_serialize() (tavrida.messages.Message method)

C

call() (tavrida.proxies.RCPCallProxy method) CantRegisterRemotePublisher cast() (tavrida.proxies.RCPCallProxy method) channel (tavrida.amqp_driver.pika_async.BasePikaAsync attribute) (tavrida.amqp_driver.pika_sync.PikaClient attribute) close_channel() (tavrida.amqp_driver.pika_async.BasePikaAsync method) close_connection() (tavrida.amqp_driver.base.AbstractClient method) (tavrida.amqp_driver.pika_async.BasePikaAsync method) (tavrida.amqp_driver.pika_async.BindingCreator method) (tavrida.amqp_driver.pika_async.ExchangeCreator method) (tavrida.amqp_driver.pika_async.Publisher method) (tavrida.amqp_driver.pika_async.QueueCreator method) (tavrida.amqp_driver.pika_sync.PikaClient method) code (tavrida.exceptions.BaseException attribute) config (tavrida.amqp_driver.base.AbstractClient attribute) ConfigFileIsNotDefined connect() (tavrida.amqp_driver.base.AbstractClient method) (tavrida.amqp_driver.pika_async.BasePikaAsync method) (tavrida.amqp_driver.pika_async.BindingCreator method) (tavrida.amqp_driver.pika_async.ExchangeCreator method) (tavrida.amqp_driver.pika_async.Publisher method) (tavrida.amqp_driver.pika_async.QueueCreator method) (tavrida.amqp_driver.pika_sync.Reader method) (tavrida.amqp_driver.pika_sync.Writer method) connection (tavrida.amqp_driver.base.AbstractClient attribute) ConnectionConfig (class in tavrida.config) context (tavrida.messages.Message attribute) copy() (tavrida.entry_point.EntryPoint method) (tavrida.entry_point.ServiceEntryPoint method)

create() (tavrida.entry_point.EntryPointFactory method) (tavrida.messages.IncomingMessageFactory method) create_binding() (tavrida.amqp_driver.pika_async.BindingCreator method) create_by_request() (tavrida.messages.Error class method) (tavrida.messages.Response class method) create_exchange() (tavrida.amqp_driver.base.AbstractWriter method) (tavrida.amqp_driver.driver.AMQPDriver method) (tavrida.amqp_driver.pika_async.ExchangeCreator method) (tavrida.amqp_driver.pika_async.Reader method) (tavrida.amqp_driver.pika_async.Writer method) (tavrida.amqp_driver.pika_sync.Writer method) create_from_message() (tavrida.messages.AMQPMessage class method) create_from_reader() (tavrida.amqp_driver.pika_sync.Writer class method) create_notification() (tavrida.messages.IncomingMessageFactory method) create_queue() (tavrida.amqp_driver.base.AbstractReader method) (tavrida.amqp_driver.driver.AMQPDriver method) (tavrida.amqp_driver.pika_async.QueueCreator method) (tavrida.amqp_driver.pika_async.Reader method) (tavrida.amqp_driver.pika_sync.Reader method) create_reader() (tavrida.amqp_driver.driver.AMQPDriver method) create_transfer() (tavrida.messages.Request class method) create_writer() (tavrida.amqp_driver.driver.AMQPDriver method) CreateAMQPMiddleware (class in tavrida.steps) CreateMessageMiddleware (class in tavrida.steps) Credentials (class in tavrida.config)

D

Destination (class in tavrida.entry_point) discovery_service (tavrida.postprocessor.PostProcessor attribute) DiscoveryFactory (class in tavrida.discovery) Dispatcher (class in tavrida.dispatcher)

driver (tavrida.postprocessor.PostProcessor attribute) DuplicatedEntryPointRegistration DuplicatedMethodRegistration DuplicatedServiceRegistration

E

EntryPoint (class in tavrida.entry_point) EntryPointFactory (class in tavrida.entry_point)

Error (class in tavrida.messages) ExchangeCreator (class in tavrida.amqp_driver.pika_async)

F

FieldMustExist FieldMustFullyDefined

FileBasedDiscoveryService (class in tavrida.discovery) ForbiddenHeaders

G

get_all_exchanges() (tavrida.discovery.AbstractDiscovery method) (tavrida.discovery.LocalDiscovery method) get_class() (tavrida.messages.IncomingMessageFactory method) get_discovery() (tavrida.service.ServiceController class method) get_discovery_service() (tavrida.discovery.DiscoveryFactory method) get_dispatcher() (tavrida.service.ServiceController class method) get_file_ds() (tavrida.discovery.DiscoveryFactory method) get_fqcn() (in module tavrida.utils) get_handler() (tavrida.dispatcher.Dispatcher method) get_local_ds() (tavrida.discovery.DiscoveryFactory method)

get_local_publisher() (tavrida.discovery.AbstractDiscovery method) (tavrida.discovery.LocalDiscovery method) get_publishers() (tavrida.dispatcher.Dispatcher method) get_remote() (tavrida.discovery.AbstractDiscovery method) (tavrida.discovery.LocalDiscovery method) get_remote_publisher() (tavrida.discovery.AbstractDiscovery method) (tavrida.discovery.LocalDiscovery method) get_request_entry_services() (tavrida.dispatcher.Dispatcher method) get_rpc_service_cls() (tavrida.router.Router method) get_subscription_cls() (tavrida.router.Router method) get_writer() (tavrida.amqp_driver.base.AbstractWriterFactory method) (tavrida.amqp_driver.pika_async.WriterFactory method) (tavrida.amqp_driver.pika_sync.WriterFactory method) get_writer_by_reader() (tavrida.amqp_driver.base.AbstractWriterFactory method) (tavrida.amqp_driver.pika_async.WriterFactory method) (tavrida.amqp_driver.pika_sync.WriterFactory method)

H

HandlerNotFound handlers (tavrida.dispatcher.Dispatcher attribute)

headers (tavrida.messages.Message attribute)

I

Incoming (class in tavrida.messages) IncomingError (class in tavrida.messages) IncomingMessageFactory (class in tavrida.messages) IncomingNotification (class in tavrida.messages) IncomingRequest (class in tavrida.messages) IncomingRequestCall (class in tavrida.messages)

IncomingRequestCast (class in tavrida.messages) IncomingResponse (class in tavrida.messages) IncorrectAMQPConfig IncorrectAMQPLibrary IncorrectMessage IncorrectOutgoingMessage

K

kwargs (tavrida.exceptions.BaseException attribute)

L

listen() (tavrida.amqp_driver.driver.AMQPDriver method) LocalDiscovery (class in tavrida.discovery) LoggingMiddleware (class in tavrida.steps)

LogIncomingAMQPMessageMiddleware (class in tavrida.steps) LogOutgoingAMQPMessageMiddleware (class in tavrida.steps)

M

make_response() (tavrida.messages.IncomingRequestCall method) Message (class in tavrida.messages) message_template (tavrida.exceptions.BaseException attribute)

MESSAGE_TYPE (tavrida.messages.AMQPMessage attribute) method (tavrida.entry_point.EntryPoint attribute) Middleware (class in tavrida.middleware)

N

NackableException (class in tavrida.exceptions) NeedToBeController

Notification (class in tavrida.messages) NullEntryPoint (class in tavrida.entry_point)

O

on_connection_open() (tavrida.amqp_driver.pika_async.BasePikaAsync method) on_message() (tavrida.amqp_driver.pika_async.Reader method)

open_channel() (tavrida.amqp_driver.pika_async.BasePikaAsync method) Outgoing (class in tavrida.messages)

P

payload (tavrida.messages.Message attribute) PikaClient (class in tavrida.amqp_driver.pika_sync) PostProcessor (class in tavrida.postprocessor) PreProcessor (class in tavrida.preprocessor) process() (tavrida.controller.AbstractController method) (tavrida.controller.AbstractMessageController method) (tavrida.dispatcher.Dispatcher method) (tavrida.middleware.Middleware method) (tavrida.postprocessor.PostProcessor method) (tavrida.preprocessor.PreProcessor method) (tavrida.router.Router method) (tavrida.service.ServiceController method) (tavrida.steps.CreateAMQPMiddleware method) (tavrida.steps.CreateMessageMiddleware method) (tavrida.steps.LogIncomingAMQPMessageMiddleware method) (tavrida.steps.LogOutgoingAMQPMessageMiddleware method) (tavrida.steps.ValidateMessageMiddleware method)

publish() (tavrida.proxies.RPCProxy method) publish_message() (tavrida.amqp_driver.base.AbstractWriter method) (tavrida.amqp_driver.driver.AMQPDriver method) (tavrida.amqp_driver.pika_async.Publisher method) (tavrida.amqp_driver.pika_async.Reader method) (tavrida.amqp_driver.pika_async.Writer method) (tavrida.amqp_driver.pika_sync.Writer method) Publisher (class in tavrida.amqp_driver.pika_async) PublisherEndpointNotFound

Q

QueueCreator (class in tavrida.amqp_driver.pika_async)

R

RCPCallProxy (class in tavrida.proxies) Reader (class in tavrida.amqp_driver.pika_async) (class in tavrida.amqp_driver.pika_sync) reader (tavrida.amqp_driver.driver.AMQPDriver attribute) reconnect() (tavrida.amqp_driver.pika_async.BasePikaAsync method) register() (tavrida.dispatcher.Dispatcher method) (tavrida.router.Router method) register_local_publisher() (tavrida.discovery.AbstractDiscovery method) register_remote_publisher() (tavrida.discovery.AbstractDiscovery method) register_remote_service() (tavrida.discovery.AbstractDiscovery method) Request (class in tavrida.messages) REQUIRED_HEADERS (tavrida.messages.AMQPMessage attribute) Response (class in tavrida.messages)

reverse_lookup() (tavrida.router.Router method) Router (class in tavrida.router) rpc_error_method() (in module tavrida.dispatcher) rpc_method() (in module tavrida.dispatcher) rpc_response_method() (in module tavrida.dispatcher) rpc_service() (in module tavrida.dispatcher) RPCClient (class in tavrida.client) RPCMethodProxy (class in tavrida.proxies) RPCProxy (class in tavrida.proxies) RPCServiceProxy (class in tavrida.proxies) run() (tavrida.amqp_driver.base.AbstractReader method) (tavrida.amqp_driver.pika_async.BasePikaAsync method) (tavrida.amqp_driver.pika_sync.Reader method)

S

send_heartbeat() (tavrida.service.ServiceController method) send_heartbeat_via_reader() (tavrida.amqp_driver.driver.AMQPDriver method) SENSITIVE_HEADERS (tavrida.steps.LoggingMiddleware attribute) service (tavrida.entry_point.EntryPoint attribute) service_exchange (tavrida.discovery.FileBasedDiscoveryService attribute) service_name (tavrida.discovery.FileBasedDiscoveryService attribute) ServiceController (class in tavrida.service) ServiceEntryPoint (class in tavrida.entry_point) ServiceIsNotRegister ServiceNotFound

services (tavrida.router.Router attribute) set_discovery() (tavrida.postprocessor.PostProcessor method) (tavrida.service.ServiceController class method) Singleton (class in tavrida.utils) Source (class in tavrida.entry_point) stop() (tavrida.amqp_driver.base.AbstractReader method) (tavrida.amqp_driver.pika_async.Reader method) (tavrida.amqp_driver.pika_sync.Reader method) stop_consuming() (tavrida.amqp_driver.pika_async.Reader method) subscription_method() (in module tavrida.dispatcher) SubscriptionHandlerNotFound subscriptions (tavrida.dispatcher.Dispatcher attribute)

T

tavrida (module) tavrida.amqp_driver (module) tavrida.amqp_driver.base (module) tavrida.amqp_driver.driver (module) tavrida.amqp_driver.pika_async (module) tavrida.amqp_driver.pika_sync (module) tavrida.client (module) tavrida.config (module) tavrida.controller (module) tavrida.discovery (module) tavrida.dispatcher (module) tavrida.entry_point (module) tavrida.exceptions (module) tavrida.messages (module)

tavrida.middleware (module) tavrida.postprocessor (module) tavrida.preprocessor (module) tavrida.proxies (module) tavrida.router (module) tavrida.service (module) tavrida.steps (module) tavrida.utils (module) to_dict() (tavrida.config.ConnectionConfig method) to_pika_params() (tavrida.config.ConnectionConfig method) to_routing_key() (tavrida.entry_point.EntryPoint method) (tavrida.entry_point.NullEntryPoint method) transfer() (tavrida.proxies.RCPCallProxy method) type (tavrida.messages.Message attribute)

U

UnableToDiscover UnknownService unregister_local_publisher() (tavrida.discovery.LocalDiscovery method) unregister_remote_publisher() (tavrida.discovery.LocalDiscovery method)

unregister_remote_service() (tavrida.discovery.LocalDiscovery method) UnsuitableFieldValue update_context() (tavrida.messages.Message method)

V

validate() (tavrida.messages.AMQPMessage method)

ValidateMessageMiddleware (class in tavrida.steps)

W

Writer (class in tavrida.amqp_driver.pika_async) (class in tavrida.amqp_driver.pika_sync) writer (tavrida.amqp_driver.driver.AMQPDriver attribute) WriterFactory (class in tavrida.amqp_driver.pika_async) (class in tavrida.amqp_driver.pika_sync)

WrongEntryPointFormat WrongResponse