# automatically generated by the FlatBuffers compiler, do not modify
# namespace: realmstore
import flatbuffers
from flatbuffers.compat import import_numpy
# This table stores WAMP sessions and serves as an anchor for all usage related data.
[docs]
class Session(object):
@classmethod
[docs]
def GetRootAs(cls, buf, offset=0):
n = flatbuffers.encode.Get(flatbuffers.packer.uoffset, buf, offset)
x = Session()
x.Init(buf, n + offset)
return x
@classmethod
[docs]
def GetRootAsSession(cls, buf, offset=0):
"""This method is deprecated. Please switch to GetRootAs."""
return cls.GetRootAs(buf, offset)
# Session
[docs]
def Init(self, buf, pos):
self._tab = flatbuffers.table.Table(buf, pos)
# OID of the application realm this session is/was joined on.
# Session
[docs]
def ArealmOid(self, j):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(4))
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
# Session
[docs]
def ArealmOidAsNumpy(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(4))
if o != 0:
return self._tab.GetVectorAsNumpy(flatbuffers.number_types.Uint8Flags, o)
return 0
# Session
[docs]
def ArealmOidLength(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(4))
if o != 0:
return self._tab.VectorLen(o)
return 0
# Session
[docs]
def ArealmOidIsNone(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(4))
return o == 0
# Unlimited time, globally unique, long-term OID of this session. The pair of WAMP session ID and join time ``(session, joined_at)`` bidirectionally maps to session ``oid``.
# Session
[docs]
def Oid(self, j):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(6))
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
# Session
[docs]
def OidAsNumpy(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(6))
if o != 0:
return self._tab.GetVectorAsNumpy(flatbuffers.number_types.Uint8Flags, o)
return 0
# Session
[docs]
def OidLength(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(6))
if o != 0:
return self._tab.VectorLen(o)
return 0
# Session
[docs]
def OidIsNone(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(6))
return o == 0
# The WAMP session_id of the session.
# Session
[docs]
def Session(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
# Timestamp when the session was joined by the router. Epoch time in ns.
# Session
[docs]
def JoinedAt(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
# Timestamp when the session left the router. Epoch time in ns.
# Session
[docs]
def LeftAt(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
# OID of the node of the router worker hosting this session.
# Session
[docs]
def NodeOid(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
# Session
[docs]
def NodeOidAsNumpy(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
# Session
[docs]
def NodeOidLength(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(14))
if o != 0:
return self._tab.VectorLen(o)
return 0
# Session
[docs]
def NodeOidIsNone(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(14))
return o == 0
# Name (management realm WAMP authid) of the node of the router worker hosting this session.
# Session
[docs]
def NodeAuthid(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(16))
if o != 0:
return self._tab.String(o + self._tab.Pos)
return None
# Local worker name of the router worker hosting this session.
# Session
[docs]
def WorkerName(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(18))
if o != 0:
return self._tab.String(o + self._tab.Pos)
return None
# Local worker PID of the router worker hosting this session.
# Session
[docs]
def WorkerPid(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(20))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Int32Flags, o + self._tab.Pos)
return 0
# Session transport information, the incoming frontend client connection in proxy-router setups. This is also returned as part of authextra to the client.
# Session
[docs]
def Transport(self, j):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(22))
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
# Session
[docs]
def TransportAsNumpy(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(22))
if o != 0:
return self._tab.GetVectorAsNumpy(flatbuffers.number_types.Uint8Flags, o)
return 0
# Session
[docs]
def TransportLength(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(22))
if o != 0:
return self._tab.VectorLen(o)
return 0
# Session
[docs]
def TransportIsNone(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(22))
return o == 0
# From proxy (in proxy-router cluster setups): OID of the node of the proxy worker hosting this session.
# Session
[docs]
def ProxyNodeOid(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.Uint8Flags, a + flatbuffers.number_types.UOffsetTFlags.py_type(j * 1)
)
return 0
# Session
[docs]
def ProxyNodeOidAsNumpy(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(24))
if o != 0:
return self._tab.GetVectorAsNumpy(flatbuffers.number_types.Uint8Flags, o)
return 0
# Session
[docs]
def ProxyNodeOidLength(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(24))
if o != 0:
return self._tab.VectorLen(o)
return 0
# Session
[docs]
def ProxyNodeOidIsNone(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(24))
return o == 0
# From proxy (in proxy-router cluster setups): Name (management realm WAMP authid) of the node of the proxy worker hosting this session.
# Session
[docs]
def ProxyNodeAuthid(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(26))
if o != 0:
return self._tab.String(o + self._tab.Pos)
return None
# From proxy (in proxy-router cluster setups): Local worker name of the proxy worker hosting this session.
# Session
[docs]
def ProxyWorkerName(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(28))
if o != 0:
return self._tab.String(o + self._tab.Pos)
return None
# From proxy (in proxy-router cluster setups): Local worker PID of the proxy worker hosting this session.
# Session
[docs]
def ProxyWorkerPid(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(30))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Int32Flags, o + self._tab.Pos)
return 0
# From proxy (in proxy-router cluster setups): Session transport information, the transport from the proxy to the backend router.
# Session
[docs]
def ProxyTransport(self, j):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(32))
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
# Session
[docs]
def ProxyTransportAsNumpy(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(32))
if o != 0:
return self._tab.GetVectorAsNumpy(flatbuffers.number_types.Uint8Flags, o)
return 0
# Session
[docs]
def ProxyTransportLength(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(32))
if o != 0:
return self._tab.VectorLen(o)
return 0
# Session
[docs]
def ProxyTransportIsNone(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(32))
return o == 0
# The WAMP realm (name) the session is/was joined on.
# Session
[docs]
def Realm(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(34))
if o != 0:
return self._tab.String(o + self._tab.Pos)
return None
# The WAMP authid the session was authenticated under.
# Session
[docs]
def Authid(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(36))
if o != 0:
return self._tab.String(o + self._tab.Pos)
return None
# The WAMP authrole the session was authenticated under.
# Session
[docs]
def Authrole(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(38))
if o != 0:
return self._tab.String(o + self._tab.Pos)
return None
# The WAMP authmethod uses to authenticate the session.
# Session
[docs]
def Authmethod(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(40))
if o != 0:
return self._tab.String(o + self._tab.Pos)
return None
# The WAMP authprovider that was handling the session authentication.
# Session
[docs]
def Authprovider(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(42))
if o != 0:
return self._tab.String(o + self._tab.Pos)
return None
# The WAMP authextra as provided to the authenticated session.
# Session
# Session
# Session
# Session
[docs]
def SessionStart(builder):
builder.StartObject(21)
[docs]
def Start(builder):
SessionStart(builder)
[docs]
def SessionAddArealmOid(builder, arealmOid):
builder.PrependUOffsetTRelativeSlot(0, flatbuffers.number_types.UOffsetTFlags.py_type(arealmOid), 0)
[docs]
def AddArealmOid(builder, arealmOid):
SessionAddArealmOid(builder, arealmOid)
[docs]
def SessionStartArealmOidVector(builder, numElems):
return builder.StartVector(1, numElems, 1)
[docs]
def StartArealmOidVector(builder, numElems: int) -> int:
return SessionStartArealmOidVector(builder, numElems)
[docs]
def SessionAddOid(builder, oid):
builder.PrependUOffsetTRelativeSlot(1, flatbuffers.number_types.UOffsetTFlags.py_type(oid), 0)
[docs]
def AddOid(builder, oid):
SessionAddOid(builder, oid)
[docs]
def SessionStartOidVector(builder, numElems):
return builder.StartVector(1, numElems, 1)
[docs]
def StartOidVector(builder, numElems: int) -> int:
return SessionStartOidVector(builder, numElems)
[docs]
def SessionAddSession(builder, session):
builder.PrependUint64Slot(2, session, 0)
[docs]
def AddSession(builder, session):
SessionAddSession(builder, session)
[docs]
def SessionAddJoinedAt(builder, joinedAt):
builder.PrependUint64Slot(3, joinedAt, 0)
[docs]
def AddJoinedAt(builder, joinedAt):
SessionAddJoinedAt(builder, joinedAt)
[docs]
def SessionAddLeftAt(builder, leftAt):
builder.PrependUint64Slot(4, leftAt, 0)
[docs]
def AddLeftAt(builder, leftAt):
SessionAddLeftAt(builder, leftAt)
[docs]
def SessionAddNodeOid(builder, nodeOid):
builder.PrependUOffsetTRelativeSlot(5, flatbuffers.number_types.UOffsetTFlags.py_type(nodeOid), 0)
[docs]
def AddNodeOid(builder, nodeOid):
SessionAddNodeOid(builder, nodeOid)
[docs]
def SessionStartNodeOidVector(builder, numElems):
return builder.StartVector(1, numElems, 1)
[docs]
def StartNodeOidVector(builder, numElems: int) -> int:
return SessionStartNodeOidVector(builder, numElems)
[docs]
def SessionAddNodeAuthid(builder, nodeAuthid):
builder.PrependUOffsetTRelativeSlot(6, flatbuffers.number_types.UOffsetTFlags.py_type(nodeAuthid), 0)
[docs]
def AddNodeAuthid(builder, nodeAuthid):
SessionAddNodeAuthid(builder, nodeAuthid)
[docs]
def SessionAddWorkerName(builder, workerName):
builder.PrependUOffsetTRelativeSlot(7, flatbuffers.number_types.UOffsetTFlags.py_type(workerName), 0)
[docs]
def AddWorkerName(builder, workerName):
SessionAddWorkerName(builder, workerName)
[docs]
def SessionAddWorkerPid(builder, workerPid):
builder.PrependInt32Slot(8, workerPid, 0)
[docs]
def AddWorkerPid(builder, workerPid):
SessionAddWorkerPid(builder, workerPid)
[docs]
def SessionAddTransport(builder, transport):
builder.PrependUOffsetTRelativeSlot(9, flatbuffers.number_types.UOffsetTFlags.py_type(transport), 0)
[docs]
def AddTransport(builder, transport):
SessionAddTransport(builder, transport)
[docs]
def SessionStartTransportVector(builder, numElems):
return builder.StartVector(1, numElems, 1)
[docs]
def StartTransportVector(builder, numElems: int) -> int:
return SessionStartTransportVector(builder, numElems)
[docs]
def SessionAddProxyNodeOid(builder, proxyNodeOid):
builder.PrependUOffsetTRelativeSlot(10, flatbuffers.number_types.UOffsetTFlags.py_type(proxyNodeOid), 0)
[docs]
def AddProxyNodeOid(builder, proxyNodeOid):
SessionAddProxyNodeOid(builder, proxyNodeOid)
[docs]
def SessionStartProxyNodeOidVector(builder, numElems):
return builder.StartVector(1, numElems, 1)
[docs]
def StartProxyNodeOidVector(builder, numElems: int) -> int:
return SessionStartProxyNodeOidVector(builder, numElems)
[docs]
def SessionAddProxyNodeAuthid(builder, proxyNodeAuthid):
builder.PrependUOffsetTRelativeSlot(11, flatbuffers.number_types.UOffsetTFlags.py_type(proxyNodeAuthid), 0)
[docs]
def AddProxyNodeAuthid(builder, proxyNodeAuthid):
SessionAddProxyNodeAuthid(builder, proxyNodeAuthid)
[docs]
def SessionAddProxyWorkerName(builder, proxyWorkerName):
builder.PrependUOffsetTRelativeSlot(12, flatbuffers.number_types.UOffsetTFlags.py_type(proxyWorkerName), 0)
[docs]
def AddProxyWorkerName(builder, proxyWorkerName):
SessionAddProxyWorkerName(builder, proxyWorkerName)
[docs]
def SessionAddProxyWorkerPid(builder, proxyWorkerPid):
builder.PrependInt32Slot(13, proxyWorkerPid, 0)
[docs]
def AddProxyWorkerPid(builder, proxyWorkerPid):
SessionAddProxyWorkerPid(builder, proxyWorkerPid)
[docs]
def SessionAddProxyTransport(builder, proxyTransport):
builder.PrependUOffsetTRelativeSlot(14, flatbuffers.number_types.UOffsetTFlags.py_type(proxyTransport), 0)
[docs]
def AddProxyTransport(builder, proxyTransport):
SessionAddProxyTransport(builder, proxyTransport)
[docs]
def SessionStartProxyTransportVector(builder, numElems):
return builder.StartVector(1, numElems, 1)
[docs]
def StartProxyTransportVector(builder, numElems: int) -> int:
return SessionStartProxyTransportVector(builder, numElems)
[docs]
def SessionAddRealm(builder, realm):
builder.PrependUOffsetTRelativeSlot(15, flatbuffers.number_types.UOffsetTFlags.py_type(realm), 0)
[docs]
def AddRealm(builder, realm):
SessionAddRealm(builder, realm)
[docs]
def SessionAddAuthid(builder, authid):
builder.PrependUOffsetTRelativeSlot(16, flatbuffers.number_types.UOffsetTFlags.py_type(authid), 0)
[docs]
def AddAuthid(builder, authid):
SessionAddAuthid(builder, authid)
[docs]
def SessionAddAuthrole(builder, authrole):
builder.PrependUOffsetTRelativeSlot(17, flatbuffers.number_types.UOffsetTFlags.py_type(authrole), 0)
[docs]
def AddAuthrole(builder, authrole):
SessionAddAuthrole(builder, authrole)
[docs]
def SessionAddAuthmethod(builder, authmethod):
builder.PrependUOffsetTRelativeSlot(18, flatbuffers.number_types.UOffsetTFlags.py_type(authmethod), 0)
[docs]
def AddAuthmethod(builder, authmethod):
SessionAddAuthmethod(builder, authmethod)
[docs]
def SessionAddAuthprovider(builder, authprovider):
builder.PrependUOffsetTRelativeSlot(19, flatbuffers.number_types.UOffsetTFlags.py_type(authprovider), 0)
[docs]
def AddAuthprovider(builder, authprovider):
SessionAddAuthprovider(builder, authprovider)
[docs]
def SessionEnd(builder):
return builder.EndObject()
[docs]
def End(builder):
return SessionEnd(builder)