crossbar.router.realmstore¶

Classes¶

`QueuedCall`
`RealmStoreMemory`	Memory-backed realm store.

Module Contents¶

class QueuedCall(session, call, registration, authorization)[source]¶

Bases: object

__slots__ = ('session', 'call', 'registration', 'authorization')[source]¶

authorization[source]¶

call[source]¶

registration[source]¶

session[source]¶

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

Bases: object

Memory-backed realm store.

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

STORE_TYPE = 'memory'[source]¶

_config[source]¶

_event_history[source]¶

_event_store[source]¶

_event_subscriptions[source]¶

_factory[source]¶

_limit[source]¶

_personality[source]¶

_queued_calls[source]¶

_reactor[source]¶

_running = False[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) → 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()

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.pop_queued_call()

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()