cfxdb.realmstore._event

Classes

Event

Persisted event database object.

Events

Persisted events archive.

Module Contents

class Event(from_fbs=None)[source]

Bases: object

Persisted event database object.

__str__()[source]
_acknowledged_delivery = None[source]
_from_fbs = None[source]
_publication = None[source]
_receiver = None[source]
_retained = None[source]
_subscription = None[source]
_timestamp = None[source]
property acknowledged_delivery[source]

Whether this Event was to be acknowledged by the receiver.

Returns:

acknowledged delivery flag

Return type:

bool

build(builder)[source]
static cast(buf)[source]
marshal()[source]
property publication[source]

The publication ID of the dispatched event.

Returns:

The publication ID.

Return type:

int

property receiver[source]

The WAMP session ID of the receiver.

Returns:

The receiver ID.

Return type:

int

property retained[source]

Whether the message was retained by the broker on the topic, rather than just published.

Returns:

retained flag

Return type:

bool

property subscription[source]

The subscription ID this event is dispatched under.

Returns:

The subscription ID.

Return type:

int

property timestamp[source]

Timestamp when the event was sent to the receiver. Epoch time in ns.

Returns:

Epoc time in ns.

Return type:

int

class Events(slot=None, compress=None, build=None, cast=None)[source]

Bases: zlmdb.MapOidTimestampFlatBuffers

Persisted events archive.

Map zlmdb.MapOid3FlatBuffers from (subscription, time_ns) to cfxdb.eventstore.Event.