# automatically generated by the FlatBuffers compiler, do not modify
# namespace: log
import flatbuffers
from flatbuffers.compat import import_numpy
[docs]
class MNodeSession(object):
@classmethod
[docs]
def GetRootAs(cls, buf, offset=0):
n = flatbuffers.encode.Get(flatbuffers.packer.uoffset, buf, offset)
x = MNodeSession()
x.Init(buf, n + offset)
return x
@classmethod
[docs]
def GetRootAsMNodeSession(cls, buf, offset=0):
"""This method is deprecated. Please switch to GetRootAs."""
return cls.GetRootAs(buf, offset)
# MNodeSession
[docs]
def Init(self, buf, pos):
self._tab = flatbuffers.table.Table(buf, pos)
# When the his run started (Unix time in ns).
# MNodeSession
[docs]
def Left(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 session ID of the CF node uplink management session to this CFC instance.
# MNodeSession
[docs]
def Session(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
# Management realm CFC backend run ID
# MNodeSession
[docs]
def RunId(self, j):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(8))
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
# MNodeSession
[docs]
def RunIdAsNumpy(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(8))
if o != 0:
return self._tab.GetVectorAsNumpy(flatbuffers.number_types.Uint8Flags, o)
return 0
# MNodeSession
[docs]
def RunIdLength(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(8))
if o != 0:
return self._tab.VectorLen(o)
return 0
# MNodeSession
[docs]
def RunIdIsNone(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(8))
return o == 0
# The CF node ID (which is dual-used as WAMP session authid).
# MNodeSession
[docs]
def NodeId(self, j):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(10))
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
# MNodeSession
[docs]
def NodeIdAsNumpy(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(10))
if o != 0:
return self._tab.GetVectorAsNumpy(flatbuffers.number_types.Uint8Flags, o)
return 0
# MNodeSession
[docs]
def NodeIdLength(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(10))
if o != 0:
return self._tab.VectorLen(o)
return 0
# MNodeSession
[docs]
def NodeIdIsNone(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(10))
return o == 0
# When the CF node management session joined this CFC instance.
# MNodeSession
[docs]
def Joined(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(12))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# When the last heartbeat was received on this CF node session.
# MNodeSession
[docs]
def LastHeartbeat(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(14))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
[docs]
def MNodeSessionStart(builder):
builder.StartObject(6)
[docs]
def Start(builder):
MNodeSessionStart(builder)
[docs]
def MNodeSessionAddLeft(builder, left):
builder.PrependUint64Slot(0, left, 0)
[docs]
def AddLeft(builder, left):
MNodeSessionAddLeft(builder, left)
[docs]
def MNodeSessionAddSession(builder, session):
builder.PrependUint64Slot(1, session, 0)
[docs]
def AddSession(builder, session):
MNodeSessionAddSession(builder, session)
[docs]
def MNodeSessionAddRunId(builder, runId):
builder.PrependUOffsetTRelativeSlot(2, flatbuffers.number_types.UOffsetTFlags.py_type(runId), 0)
[docs]
def AddRunId(builder, runId):
MNodeSessionAddRunId(builder, runId)
[docs]
def MNodeSessionStartRunIdVector(builder, numElems):
return builder.StartVector(1, numElems, 1)
[docs]
def StartRunIdVector(builder, numElems: int) -> int:
return MNodeSessionStartRunIdVector(builder, numElems)
[docs]
def MNodeSessionAddNodeId(builder, nodeId):
builder.PrependUOffsetTRelativeSlot(3, flatbuffers.number_types.UOffsetTFlags.py_type(nodeId), 0)
[docs]
def AddNodeId(builder, nodeId):
MNodeSessionAddNodeId(builder, nodeId)
[docs]
def MNodeSessionStartNodeIdVector(builder, numElems):
return builder.StartVector(1, numElems, 1)
[docs]
def StartNodeIdVector(builder, numElems: int) -> int:
return MNodeSessionStartNodeIdVector(builder, numElems)
[docs]
def MNodeSessionAddJoined(builder, joined):
builder.PrependUint64Slot(4, joined, 0)
[docs]
def AddJoined(builder, joined):
MNodeSessionAddJoined(builder, joined)
[docs]
def MNodeSessionAddLastHeartbeat(builder, lastHeartbeat):
builder.PrependUint64Slot(5, lastHeartbeat, 0)
[docs]
def AddLastHeartbeat(builder, lastHeartbeat):
MNodeSessionAddLastHeartbeat(builder, lastHeartbeat)
[docs]
def MNodeSessionEnd(builder):
return builder.EndObject()
[docs]
def End(builder):
return MNodeSessionEnd(builder)