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) (InMemoryStorage method) (Message method) (MessageQueueListener method) (SignedMessage method) (SimpleDistributedApplicationListener method) (SocketClient method) (SocketServer method) (SSEChannel method) (UniqueMessage 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) InMemoryStorage (class in eric_sse.repository) InvalidChannelException InvalidListenerException InvalidMessageFormat is_running() (MessageQueueListener method) K KvStorage (class in eric_sse.repository) L ListenerRepositoryInterface (class in eric_sse.interfaces) listeners_repository (ConnectionRepository property) (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() (Queue method) process_queue() (DataProcessingChannel method) push() (Queue method) Q Queue (class in eric_sse.queues) QueueRepositoryInterface (class in eric_sse.interfaces) queues_repository (ConnectionRepository property) (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)