crossbar.edge.worker.realmstore¶

Classes¶

RealmStoreDatabase

Database-backed realm store.

Module Contents¶

class RealmStoreDatabase(personality, factory, config)[source]¶

Bases: object

Database-backed realm store.

GLOBAL_HISTORY_LIMIT = 100[source]¶: The global history limit, in case not overridden.

STORE_TYPE = 'cfxdb'[source]¶

_buffer = [][source]¶

_buffer_flush[source]¶

_config[source]¶

_db[source]¶

_factory[source]¶

_log_counter = 0[source]¶

_max_buffer[source]¶

_personality[source]¶

_process_buffer()[source]¶

_process_buffers()[source]¶

_process_buffers_thread = None[source]¶

_queued_calls[source]¶

_reactor[source]¶

_running = False[source]¶

_schema[source]¶

_store_event(txn, session, publication_id, publish)[source]¶

_store_event_history(txn, publication_id, subscription_id, receiver)[source]¶

_store_session_joined(txn: zlmdb.Transaction, ses: cfxdb.realmstore.Session)[source]¶

_store_session_left(txn: zlmdb.Transaction, session: autobahn.wamp.interfaces.ISession, details: autobahn.wamp.types.CloseDetails)[source]¶

_type[source]¶

attach_subscription_map(subscription_map: crossbar.router.observation.UriObservationMap)[source]¶: Implements crossbar._interfaces.IRealmStore.attach_subscription_map()

get_event_history(subscription_id: int, from_ts: int, until_ts: int, reverse: bool | None = None, limit: int | None = None) → List[Dict[str, Any]] | None[source]¶: Implements crossbar._interfaces.IRealmStore.get_event_history()

get_events(subscription_id: int, limit: int | None = None)[source]¶: Implements crossbar._interfaces.IRealmStore.get_events()

get_queued_call(registration)[source]¶: Implements crossbar._interfaces.IRealmStore.get_queued_call()

get_session_by_session_id(session_id: int, joined_before: int | None = None) → Dict[str, Any] | None[source]¶: Implements crossbar._interfaces.IRealmStore.get_session_by_session_id()

get_sessions_by_authid(authid: str) → List[Tuple[str, int]] | None[source]¶: Implements crossbar._interfaces.IRealmStore.get_sessions_by_authid()

is_running() → bool[source]¶: Implements crossbar._interfaces.IRealmStore.is_running()

log[source]¶

maybe_queue_call(session, call, registration, authorization)[source]¶: Implements crossbar._interfaces.IRealmStore.maybe_queue_call()

pop_queued_call(registration)[source]¶: Implements crossbar._interfaces.IRealmStore.get_event_history()

start()[source]¶: Implements crossbar._interfaces.IRealmStore.start()

stop()[source]¶: Implements crossbar._interfaces.IRealmStore.stop()

store_event(session: autobahn.wamp.interfaces.ISession, publication_id: int, publish: autobahn.wamp.message.Publish)[source]¶: Implements crossbar._interfaces.IRealmStore.store_event()

store_event_history(publication_id: int, subscription_id: int, receiver: autobahn.wamp.interfaces.ISession)[source]¶: Implements crossbar._interfaces.IRealmStore.store_event_history()

store_session_joined(session: autobahn.wamp.interfaces.ISession, details: autobahn.wamp.types.SessionDetails)[source]¶: Implements crossbar._interfaces.IRealmStore.store_session_joined()

store_session_left(session: autobahn.wamp.interfaces.ISession, details: autobahn.wamp.types.CloseDetails)[source]¶: Implements crossbar._interfaces.IRealmStore.store_session_left()

type() → str[source]¶: Implements crossbar._interfaces.IRealmStore.type()