# automatically generated by the FlatBuffers compiler, do not modify
# namespace: realmstore
import flatbuffers
from flatbuffers.compat import import_numpy
# This table stores WAMP publications with configurable amount of details, optionally including application payload.
[docs]
class Publication(object):
@classmethod
[docs]
def GetRootAs(cls, buf, offset=0):
n = flatbuffers.encode.Get(flatbuffers.packer.uoffset, buf, offset)
x = Publication()
x.Init(buf, n + offset)
return x
@classmethod
[docs]
def GetRootAsPublication(cls, buf, offset=0):
"""This method is deprecated. Please switch to GetRootAs."""
return cls.GetRootAs(buf, offset)
# Publication
[docs]
def Init(self, buf, pos):
self._tab = flatbuffers.table.Table(buf, pos)
# Timestamp when the publication was accepted by the broker. Epoch time in ns.
# Publication
[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
# WAMP publication ID that was assigned by the broker.
# Publication
[docs]
def Publication(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
# WAMP session ID of the publisher.
# Publication
[docs]
def Publisher(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 or application URI of the PubSub topic the event was published to.
# Publication
[docs]
def Topic(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(10))
if o != 0:
return self._tab.String(o + self._tab.Pos)
return None
# Positional values for application-defined event payload.
# Publication
[docs]
def Args(self, j):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(12))
if o != 0:
a = self._tab.Vector(o)
return self._tab.Get(
flatbuffers.number_types.Uint8Flags, a + flatbuffers.number_types.UOffsetTFlags.py_type(j * 1)
)
return 0
# Publication
[docs]
def ArgsAsNumpy(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(12))
if o != 0:
return self._tab.GetVectorAsNumpy(flatbuffers.number_types.Uint8Flags, o)
return 0
# Publication
[docs]
def ArgsLength(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(12))
if o != 0:
return self._tab.VectorLen(o)
return 0
# Publication
[docs]
def ArgsIsNone(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(12))
return o == 0
# Keyword values for application-defined event payload.
# Publication
[docs]
def Kwargs(self, j):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(14))
if o != 0:
a = self._tab.Vector(o)
return self._tab.Get(
flatbuffers.number_types.Uint8Flags, a + flatbuffers.number_types.UOffsetTFlags.py_type(j * 1)
)
return 0
# Publication
[docs]
def KwargsAsNumpy(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(14))
if o != 0:
return self._tab.GetVectorAsNumpy(flatbuffers.number_types.Uint8Flags, o)
return 0
# Publication
[docs]
def KwargsLength(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(14))
if o != 0:
return self._tab.VectorLen(o)
return 0
# Publication
[docs]
def KwargsIsNone(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(14))
return o == 0
# Alternative, transparent payload. If given, ``args`` and ``kwargs`` must be left unset.
# Publication
[docs]
def Payload(self, j):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(16))
if o != 0:
a = self._tab.Vector(o)
return self._tab.Get(
flatbuffers.number_types.Uint8Flags, a + flatbuffers.number_types.UOffsetTFlags.py_type(j * 1)
)
return 0
# Publication
[docs]
def PayloadAsNumpy(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(16))
if o != 0:
return self._tab.GetVectorAsNumpy(flatbuffers.number_types.Uint8Flags, o)
return 0
# Publication
[docs]
def PayloadLength(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(16))
if o != 0:
return self._tab.VectorLen(o)
return 0
# Publication
[docs]
def PayloadIsNone(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(16))
return o == 0
# If ``True``, the broker was asked to acknowledge the publication with a success or error response.
# Publication
[docs]
def Acknowledge(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(18))
if o != 0:
return bool(self._tab.Get(flatbuffers.number_types.BoolFlags, o + self._tab.Pos))
return False
# If ``True``, the broker was requested to retain this event.
# Publication
[docs]
def Retain(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(20))
if o != 0:
return bool(self._tab.Get(flatbuffers.number_types.BoolFlags, o + self._tab.Pos))
return False
# If ``True``, the broker was asked to exclude the publisher from receiving the event.
# Publication
[docs]
def ExcludeMe(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(22))
if o != 0:
return bool(self._tab.Get(flatbuffers.number_types.BoolFlags, o + self._tab.Pos))
return False
# List of WAMP session IDs to exclude from receiving this event.
# Publication
[docs]
def Exclude(self, j):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(24))
if o != 0:
a = self._tab.Vector(o)
return self._tab.Get(
flatbuffers.number_types.Uint64Flags, a + flatbuffers.number_types.UOffsetTFlags.py_type(j * 8)
)
return 0
# Publication
[docs]
def ExcludeAsNumpy(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(24))
if o != 0:
return self._tab.GetVectorAsNumpy(flatbuffers.number_types.Uint64Flags, o)
return 0
# Publication
[docs]
def ExcludeLength(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(24))
if o != 0:
return self._tab.VectorLen(o)
return 0
# Publication
[docs]
def ExcludeIsNone(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(24))
return o == 0
# List of WAMP authids to exclude from receiving this event.
# Publication
[docs]
def ExcludeAuthid(self, j):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(26))
if o != 0:
a = self._tab.Vector(o)
return self._tab.String(a + flatbuffers.number_types.UOffsetTFlags.py_type(j * 4))
return ""
# Publication
[docs]
def ExcludeAuthidLength(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(26))
if o != 0:
return self._tab.VectorLen(o)
return 0
# Publication
[docs]
def ExcludeAuthidIsNone(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(26))
return o == 0
# List of WAMP authroles to exclude from receiving this event.
# Publication
[docs]
def ExcludeAuthrole(self, j):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(28))
if o != 0:
a = self._tab.Vector(o)
return self._tab.String(a + flatbuffers.number_types.UOffsetTFlags.py_type(j * 4))
return ""
# Publication
[docs]
def ExcludeAuthroleLength(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(28))
if o != 0:
return self._tab.VectorLen(o)
return 0
# Publication
[docs]
def ExcludeAuthroleIsNone(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(28))
return o == 0
# List of WAMP session IDs eligible to receive this event.
# Publication
[docs]
def Eligible(self, j):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(30))
if o != 0:
a = self._tab.Vector(o)
return self._tab.Get(
flatbuffers.number_types.Uint64Flags, a + flatbuffers.number_types.UOffsetTFlags.py_type(j * 8)
)
return 0
# Publication
[docs]
def EligibleAsNumpy(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(30))
if o != 0:
return self._tab.GetVectorAsNumpy(flatbuffers.number_types.Uint64Flags, o)
return 0
# Publication
[docs]
def EligibleLength(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(30))
if o != 0:
return self._tab.VectorLen(o)
return 0
# Publication
[docs]
def EligibleIsNone(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(30))
return o == 0
# List of WAMP authids eligible to receive this event.
# Publication
[docs]
def EligibleAuthid(self, j):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(32))
if o != 0:
a = self._tab.Vector(o)
return self._tab.String(a + flatbuffers.number_types.UOffsetTFlags.py_type(j * 4))
return ""
# Publication
[docs]
def EligibleAuthidLength(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(32))
if o != 0:
return self._tab.VectorLen(o)
return 0
# Publication
[docs]
def EligibleAuthidIsNone(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(32))
return o == 0
# List of WAMP authroles eligible to receive this event.
# Publication
[docs]
def EligibleAuthrole(self, j):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(34))
if o != 0:
a = self._tab.Vector(o)
return self._tab.String(a + flatbuffers.number_types.UOffsetTFlags.py_type(j * 4))
return ""
# Publication
[docs]
def EligibleAuthroleLength(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(34))
if o != 0:
return self._tab.VectorLen(o)
return 0
# Publication
[docs]
def EligibleAuthroleIsNone(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(34))
return o == 0
# When using payload transparency, the encoding algorithm that was used to encode the payload.
# Publication
[docs]
def EncAlgo(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(36))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint8Flags, o + self._tab.Pos)
return 0
# When using payload transparency with an encryption algorithm, the payload encryption key.
# Publication
[docs]
def EncKey(self, j):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(38))
if o != 0:
a = self._tab.Vector(o)
return self._tab.Get(
flatbuffers.number_types.Uint8Flags, a + flatbuffers.number_types.UOffsetTFlags.py_type(j * 1)
)
return 0
# Publication
[docs]
def EncKeyAsNumpy(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(38))
if o != 0:
return self._tab.GetVectorAsNumpy(flatbuffers.number_types.Uint8Flags, o)
return 0
# Publication
[docs]
def EncKeyLength(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(38))
if o != 0:
return self._tab.VectorLen(o)
return 0
# Publication
[docs]
def EncKeyIsNone(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(38))
return o == 0
# When using payload transparency, the payload object serializer that was used encoding the payload.
# Publication
[docs]
def EncSerializer(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(40))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint8Flags, o + self._tab.Pos)
return 0
[docs]
def PublicationStart(builder):
builder.StartObject(19)
[docs]
def Start(builder):
PublicationStart(builder)
[docs]
def PublicationAddTimestamp(builder, timestamp):
builder.PrependUint64Slot(0, timestamp, 0)
[docs]
def AddTimestamp(builder, timestamp):
PublicationAddTimestamp(builder, timestamp)
[docs]
def PublicationAddPublication(builder, publication):
builder.PrependUint64Slot(1, publication, 0)
[docs]
def AddPublication(builder, publication):
PublicationAddPublication(builder, publication)
[docs]
def PublicationAddPublisher(builder, publisher):
builder.PrependUint64Slot(2, publisher, 0)
[docs]
def AddPublisher(builder, publisher):
PublicationAddPublisher(builder, publisher)
[docs]
def PublicationAddTopic(builder, topic):
builder.PrependUOffsetTRelativeSlot(3, flatbuffers.number_types.UOffsetTFlags.py_type(topic), 0)
[docs]
def AddTopic(builder, topic):
PublicationAddTopic(builder, topic)
[docs]
def PublicationAddArgs(builder, args):
builder.PrependUOffsetTRelativeSlot(4, flatbuffers.number_types.UOffsetTFlags.py_type(args), 0)
[docs]
def AddArgs(builder, args):
PublicationAddArgs(builder, args)
[docs]
def PublicationStartArgsVector(builder, numElems):
return builder.StartVector(1, numElems, 1)
[docs]
def StartArgsVector(builder, numElems: int) -> int:
return PublicationStartArgsVector(builder, numElems)
[docs]
def PublicationAddKwargs(builder, kwargs):
builder.PrependUOffsetTRelativeSlot(5, flatbuffers.number_types.UOffsetTFlags.py_type(kwargs), 0)
[docs]
def AddKwargs(builder, kwargs):
PublicationAddKwargs(builder, kwargs)
[docs]
def PublicationStartKwargsVector(builder, numElems):
return builder.StartVector(1, numElems, 1)
[docs]
def StartKwargsVector(builder, numElems: int) -> int:
return PublicationStartKwargsVector(builder, numElems)
[docs]
def PublicationAddPayload(builder, payload):
builder.PrependUOffsetTRelativeSlot(6, flatbuffers.number_types.UOffsetTFlags.py_type(payload), 0)
[docs]
def AddPayload(builder, payload):
PublicationAddPayload(builder, payload)
[docs]
def PublicationStartPayloadVector(builder, numElems):
return builder.StartVector(1, numElems, 1)
[docs]
def StartPayloadVector(builder, numElems: int) -> int:
return PublicationStartPayloadVector(builder, numElems)
[docs]
def PublicationAddAcknowledge(builder, acknowledge):
builder.PrependBoolSlot(7, acknowledge, 0)
[docs]
def AddAcknowledge(builder, acknowledge):
PublicationAddAcknowledge(builder, acknowledge)
[docs]
def PublicationAddRetain(builder, retain):
builder.PrependBoolSlot(8, retain, 0)
[docs]
def AddRetain(builder, retain):
PublicationAddRetain(builder, retain)
[docs]
def PublicationAddExcludeMe(builder, excludeMe):
builder.PrependBoolSlot(9, excludeMe, 0)
[docs]
def AddExcludeMe(builder, excludeMe):
PublicationAddExcludeMe(builder, excludeMe)
[docs]
def PublicationAddExclude(builder, exclude):
builder.PrependUOffsetTRelativeSlot(10, flatbuffers.number_types.UOffsetTFlags.py_type(exclude), 0)
[docs]
def AddExclude(builder, exclude):
PublicationAddExclude(builder, exclude)
[docs]
def PublicationStartExcludeVector(builder, numElems):
return builder.StartVector(8, numElems, 8)
[docs]
def StartExcludeVector(builder, numElems: int) -> int:
return PublicationStartExcludeVector(builder, numElems)
[docs]
def PublicationAddExcludeAuthid(builder, excludeAuthid):
builder.PrependUOffsetTRelativeSlot(11, flatbuffers.number_types.UOffsetTFlags.py_type(excludeAuthid), 0)
[docs]
def AddExcludeAuthid(builder, excludeAuthid):
PublicationAddExcludeAuthid(builder, excludeAuthid)
[docs]
def PublicationStartExcludeAuthidVector(builder, numElems):
return builder.StartVector(4, numElems, 4)
[docs]
def StartExcludeAuthidVector(builder, numElems: int) -> int:
return PublicationStartExcludeAuthidVector(builder, numElems)
[docs]
def PublicationAddExcludeAuthrole(builder, excludeAuthrole):
builder.PrependUOffsetTRelativeSlot(12, flatbuffers.number_types.UOffsetTFlags.py_type(excludeAuthrole), 0)
[docs]
def AddExcludeAuthrole(builder, excludeAuthrole):
PublicationAddExcludeAuthrole(builder, excludeAuthrole)
[docs]
def PublicationStartExcludeAuthroleVector(builder, numElems):
return builder.StartVector(4, numElems, 4)
[docs]
def StartExcludeAuthroleVector(builder, numElems: int) -> int:
return PublicationStartExcludeAuthroleVector(builder, numElems)
[docs]
def PublicationAddEligible(builder, eligible):
builder.PrependUOffsetTRelativeSlot(13, flatbuffers.number_types.UOffsetTFlags.py_type(eligible), 0)
[docs]
def AddEligible(builder, eligible):
PublicationAddEligible(builder, eligible)
[docs]
def PublicationStartEligibleVector(builder, numElems):
return builder.StartVector(8, numElems, 8)
[docs]
def StartEligibleVector(builder, numElems: int) -> int:
return PublicationStartEligibleVector(builder, numElems)
[docs]
def PublicationAddEligibleAuthid(builder, eligibleAuthid):
builder.PrependUOffsetTRelativeSlot(14, flatbuffers.number_types.UOffsetTFlags.py_type(eligibleAuthid), 0)
[docs]
def AddEligibleAuthid(builder, eligibleAuthid):
PublicationAddEligibleAuthid(builder, eligibleAuthid)
[docs]
def PublicationStartEligibleAuthidVector(builder, numElems):
return builder.StartVector(4, numElems, 4)
[docs]
def StartEligibleAuthidVector(builder, numElems: int) -> int:
return PublicationStartEligibleAuthidVector(builder, numElems)
[docs]
def PublicationAddEligibleAuthrole(builder, eligibleAuthrole):
builder.PrependUOffsetTRelativeSlot(15, flatbuffers.number_types.UOffsetTFlags.py_type(eligibleAuthrole), 0)
[docs]
def AddEligibleAuthrole(builder, eligibleAuthrole):
PublicationAddEligibleAuthrole(builder, eligibleAuthrole)
[docs]
def PublicationStartEligibleAuthroleVector(builder, numElems):
return builder.StartVector(4, numElems, 4)
[docs]
def StartEligibleAuthroleVector(builder, numElems: int) -> int:
return PublicationStartEligibleAuthroleVector(builder, numElems)
[docs]
def PublicationAddEncAlgo(builder, encAlgo):
builder.PrependUint8Slot(16, encAlgo, 0)
[docs]
def AddEncAlgo(builder, encAlgo):
PublicationAddEncAlgo(builder, encAlgo)
[docs]
def PublicationAddEncKey(builder, encKey):
builder.PrependUOffsetTRelativeSlot(17, flatbuffers.number_types.UOffsetTFlags.py_type(encKey), 0)
[docs]
def AddEncKey(builder, encKey):
PublicationAddEncKey(builder, encKey)
[docs]
def PublicationStartEncKeyVector(builder, numElems):
return builder.StartVector(1, numElems, 1)
[docs]
def StartEncKeyVector(builder, numElems: int) -> int:
return PublicationStartEncKeyVector(builder, numElems)
[docs]
def PublicationAddEncSerializer(builder, encSerializer):
builder.PrependUint8Slot(18, encSerializer, 0)
[docs]
def AddEncSerializer(builder, encSerializer):
PublicationAddEncSerializer(builder, encSerializer)
[docs]
def PublicationEnd(builder):
return builder.EndObject()
[docs]
def End(builder):
return PublicationEnd(builder)