Index _ | A | B | C | D | E | F | G | I | K | L | M | N | O | P | Q | R | S | T | U _ __init__() (AbstractChannel method) (AbstractChannelRepository method) (ChannelContainer method) (Connection method) (ConnectionRepository method) (DataProcessingChannel method) (InMemoryQueue method) (InMemoryStorage method) (ItemNotFound method) (Message method) (MessageQueueListener method) (SignedMessage method) (SimpleDistributedApplicationListener method) (SocketClient method) (SocketServer method) (SSEChannel method) (UniqueMessage method) _channel_to_dict() (AbstractChannelRepository static method) A AbstractChannel (class in eric_sse.entities) AbstractChannelRepository (class in eric_sse.repository) adapt() (AbstractChannel method) (DataProcessingChannel method) (SSEChannel method) add_listener() (AbstractChannel method) B broadcast() (AbstractChannel method) broadcast_message() (SocketClient method) C ChannelContainer (class in eric_sse.servers) ChannelRepositoryInterface (class in eric_sse.interfaces) Connection (class in eric_sse.connection) ConnectionRepository (class in eric_sse.repository) ConnectionRepositoryInterface (class in eric_sse.interfaces) connections_factory (AbstractChannelRepository property) (ChannelRepositoryInterface property) connections_repository (AbstractChannelRepository property) (ChannelRepositoryInterface property) ConnectionsFactory (class in eric_sse.connection) create() (ChannelRepositoryInterface method) (ConnectionsFactory method) (InMemoryConnectionsFactory method) (SSEChannelRepository method) create_channel() (SocketClient method) D DataProcessingChannel (class in eric_sse.prefabs) delete() (AbstractChannelRepository method) (ChannelRepositoryInterface method) (ConnectionRepository method) (ConnectionRepositoryInterface method) (InMemoryStorage method) (KvStorage method) (ListenerRepositoryInterface method) (QueueRepositoryInterface method) deliver_next() (AbstractChannel method) dispatch() (AbstractChannel method) (SocketClient method) dispatch_to() (SimpleDistributedApplicationListener method) E eric_sse.clients module eric_sse.connection module eric_sse.entities module eric_sse.exception module eric_sse.interfaces module eric_sse.listener module eric_sse.message module eric_sse.prefabs module eric_sse.queues module eric_sse.repository module eric_sse.servers module F fetch_all() (InMemoryStorage method) (KvStorage method) fetch_by_prefix() (InMemoryStorage method) (KvStorage method) fetch_one() (InMemoryStorage method) (KvStorage method) G get() (ChannelContainer method) get_all_ids() (ChannelContainer method) I id (AbstractChannel property) (UniqueMessage property) InMemoryConnectionsFactory (class in eric_sse.connection) InMemoryQueue (class in eric_sse.queues) InMemoryStorage (class in eric_sse.repository) InvalidChannelException InvalidConnectionException InvalidListenerException InvalidMessageFormat is_running() (MessageQueueListener method) ItemNotFound K KvStorage (class in eric_sse.repository) L ListenerRepositoryInterface (class in eric_sse.interfaces) listeners_repository (ConnectionRepositoryInterface property) load() (ListenerRepositoryInterface method) (QueueRepositoryInterface method) load_all() (AbstractChannelRepository method) (ChannelRepositoryInterface method) (ConnectionRepository method) (ConnectionRepositoryInterface method) load_one() (AbstractChannelRepository method) (ChannelRepositoryInterface method) (ConnectionRepository method) (ConnectionRepositoryInterface method) M main() (SocketServer method) Message (class in eric_sse.message) message_stream() (AbstractChannel method) MessageContract (class in eric_sse.message) MessageQueueListener (class in eric_sse.listener) module eric_sse.clients eric_sse.connection eric_sse.entities eric_sse.exception eric_sse.interfaces eric_sse.listener eric_sse.message eric_sse.prefabs eric_sse.queues eric_sse.repository eric_sse.servers N NoMessagesException O on_message() (MessageQueueListener method) (SimpleDistributedApplicationListener method) P payload (Message property) (MessageContract property) (UniqueMessage property) persist() (AbstractChannelRepository method) (ChannelRepositoryInterface method) (ConnectionRepository method) (ConnectionRepositoryInterface method) (ListenerRepositoryInterface method) (QueueRepositoryInterface method) pop() (InMemoryQueue method) (Queue method) process_queue() (DataProcessingChannel method) push() (InMemoryQueue method) (Queue method) Q Queue (class in eric_sse.queues) QueueRepositoryInterface (class in eric_sse.interfaces) queues_repository (ConnectionRepositoryInterface property) R register() (ChannelContainer method) (SocketClient method) register_connection() (AbstractChannel method) register_iterable() (ChannelContainer method) register_listener() (AbstractChannel method) (SimpleDistributedApplicationChannel method) remove_channel() (SocketClient method) remove_listener() (SocketClient method) RepositoryError rm() (ChannelContainer method) S send_payload() (SocketClient method) sender_id (SignedMessage property) (UniqueMessage property) set_action() (SimpleDistributedApplicationListener method) shutdown() (SocketServer method) SignedMessage (class in eric_sse.message) SimpleDistributedApplicationChannel (class in eric_sse.prefabs) SimpleDistributedApplicationListener (class in eric_sse.prefabs) SocketClient (class in eric_sse.clients) SocketServer (class in eric_sse.servers) SSEChannel (class in eric_sse.prefabs) SSEChannelRepository (class in eric_sse.prefabs) start() (MessageQueueListener method) (SocketServer static method) stop() (MessageQueueListener method) stream() (SocketClient method) T type (Message property) (MessageContract property) (UniqueMessage property) U UniqueMessage (class in eric_sse.message) upsert() (InMemoryStorage method) (KvStorage method)