# automatically generated by the FlatBuffers compiler, do not modify
# namespace: realmstore
import flatbuffers
from flatbuffers.compat import import_numpy
# This table store WAMP events dispatched to receivers, under WAMP subscriptions on URIs (or patterns).
[docs]
class Event(object):
@classmethod
[docs]
def GetRootAs(cls, buf, offset=0):
n = flatbuffers.encode.Get(flatbuffers.packer.uoffset, buf, offset)
x = Event()
x.Init(buf, n + offset)
return x
@classmethod
[docs]
def GetRootAsEvent(cls, buf, offset=0):
"""This method is deprecated. Please switch to GetRootAs."""
return cls.GetRootAs(buf, offset)
# Event
[docs]
def Init(self, buf, pos):
self._tab = flatbuffers.table.Table(buf, pos)
# Timestamp when the event was sent to the receiver. Epoch time in ns.
# Event
[docs]
def Timestamp(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(4))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# The subscription ID this event is dispatched under.
# Event
[docs]
def Subscription(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(6))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# The publication ID of the dispatched event.
# Event
[docs]
def Publication(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(8))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# The WAMP session ID of the receiver.
# Event
[docs]
def Receiver(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(10))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# Whether the message was retained by the broker on the topic, rather than just published.
# Event
[docs]
def Retained(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(12))
if o != 0:
return bool(self._tab.Get(flatbuffers.number_types.BoolFlags, o + self._tab.Pos))
return False
# Whether this Event was to be acknowledged by the receiver.
# Event
[docs]
def AcknowledgedDelivery(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(14))
if o != 0:
return bool(self._tab.Get(flatbuffers.number_types.BoolFlags, o + self._tab.Pos))
return False
[docs]
def EventStart(builder):
builder.StartObject(6)
[docs]
def Start(builder):
EventStart(builder)
[docs]
def EventAddTimestamp(builder, timestamp):
builder.PrependUint64Slot(0, timestamp, 0)
[docs]
def AddTimestamp(builder, timestamp):
EventAddTimestamp(builder, timestamp)
[docs]
def EventAddSubscription(builder, subscription):
builder.PrependUint64Slot(1, subscription, 0)
[docs]
def AddSubscription(builder, subscription):
EventAddSubscription(builder, subscription)
[docs]
def EventAddPublication(builder, publication):
builder.PrependUint64Slot(2, publication, 0)
[docs]
def AddPublication(builder, publication):
EventAddPublication(builder, publication)
[docs]
def EventAddReceiver(builder, receiver):
builder.PrependUint64Slot(3, receiver, 0)
[docs]
def AddReceiver(builder, receiver):
EventAddReceiver(builder, receiver)
[docs]
def EventAddRetained(builder, retained):
builder.PrependBoolSlot(4, retained, 0)
[docs]
def AddRetained(builder, retained):
EventAddRetained(builder, retained)
[docs]
def EventAddAcknowledgedDelivery(builder, acknowledgedDelivery):
builder.PrependBoolSlot(5, acknowledgedDelivery, 0)
[docs]
def AddAcknowledgedDelivery(builder, acknowledgedDelivery):
EventAddAcknowledgedDelivery(builder, acknowledgedDelivery)
[docs]
def EventEnd(builder):
return builder.EndObject()
[docs]
def End(builder):
return EventEnd(builder)