# automatically generated by the FlatBuffers compiler, do not modify
# namespace: log
import flatbuffers
from flatbuffers.compat import import_numpy
# Heartbeat log record from managed node workers. Primary key: (timestamp, node_id, worker_id).
[docs]
class MWorkerLog(object):
@classmethod
[docs]
def GetRootAs(cls, buf, offset=0):
n = flatbuffers.encode.Get(flatbuffers.packer.uoffset, buf, offset)
x = MWorkerLog()
x.Init(buf, n + offset)
return x
@classmethod
[docs]
def GetRootAsMWorkerLog(cls, buf, offset=0):
"""This method is deprecated. Please switch to GetRootAs."""
return cls.GetRootAs(buf, offset)
# MWorkerLog
[docs]
def Init(self, buf, pos):
self._tab = flatbuffers.table.Table(buf, pos)
# Primary key: Unix time in ns when this log record was received (from CFC node clock).
# MWorkerLog
[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
# Primary key: CF node ID.
# MWorkerLog
[docs]
def NodeId(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
# MWorkerLog
[docs]
def NodeIdAsNumpy(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
# MWorkerLog
[docs]
def NodeIdLength(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(6))
if o != 0:
return self._tab.VectorLen(o)
return 0
# MWorkerLog
[docs]
def NodeIdIsNone(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(6))
return o == 0
# Primary key: Local Worker ID on running CF node.
# MWorkerLog
[docs]
def WorkerId(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(8))
if o != 0:
return self._tab.String(o + self._tab.Pos)
return None
# Heartbeat period in seconds encompassed by this record.
# MWorkerLog
[docs]
def Period(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(10))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint32Flags, o + self._tab.Pos)
return 0
# Management realm ID.
# MWorkerLog
[docs]
def MrealmId(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
# MWorkerLog
[docs]
def MrealmIdAsNumpy(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
# MWorkerLog
[docs]
def MrealmIdLength(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(12))
if o != 0:
return self._tab.VectorLen(o)
return 0
# MWorkerLog
[docs]
def MrealmIdIsNone(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(12))
return o == 0
# Type of worker.
# MWorkerLog
[docs]
def Type(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(14))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint8Flags, o + self._tab.Pos)
return 0
# Current state of worker.
# MWorkerLog
[docs]
def State(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(16))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint8Flags, o + self._tab.Pos)
return 0
# Unix time in ns. This timestamp is from the original received event payload (from CF node clock).
# MWorkerLog
[docs]
def Sent(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(18))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# Sequence number as sent in the log record by the CF node (started at 0 for CF start and incremented by one on each heartbeat).
# MWorkerLog
[docs]
def Seq(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(20))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# Current load.
# MWorkerLog
[docs]
def NumFds(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(22))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint32Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def NumThreads(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(24))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint16Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def NumCtxSwitchesInvoluntary(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(26))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def NumCtxSwitchesInvoluntaryPerSec(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(28))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint32Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def NumCtxSwitchesVoluntary(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(30))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def NumCtxSwitchesVoluntaryPerSec(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(32))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint32Flags, o + self._tab.Pos)
return 0
# CPU load
# MWorkerLog
[docs]
def CpuSystem(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(34))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Float32Flags, o + self._tab.Pos)
return 0.0
# MWorkerLog
[docs]
def CpuSystemPerSec(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(36))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Float32Flags, o + self._tab.Pos)
return 0.0
# MWorkerLog
[docs]
def CpuWait(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(38))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Float32Flags, o + self._tab.Pos)
return 0.0
# MWorkerLog
[docs]
def CpuWaitPerSec(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(40))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Float32Flags, o + self._tab.Pos)
return 0.0
# MWorkerLog
[docs]
def CpuUser(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(42))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Float32Flags, o + self._tab.Pos)
return 0.0
# MWorkerLog
[docs]
def CpuUserPerSec(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(44))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Float32Flags, o + self._tab.Pos)
return 0.0
# Disk load
# MWorkerLog
[docs]
def ReadBytes(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(46))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def ReadBytesPerSec(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(48))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def ReadIos(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(50))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def ReadIosPerSec(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(52))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def WriteBytes(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(54))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def WriteBytesPerSec(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(56))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def WriteIos(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(58))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def WriteIosPerSec(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(60))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# Network load
# MWorkerLog
[docs]
def SentBytes(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(62))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def SentBytesPerSec(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(64))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def SentIos(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(66))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def SentIosPerSec(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(68))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def RecvBytes(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(70))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def RecvBytesPerSec(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(72))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def RecvIos(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(74))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def RecvIosPerSec(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(76))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# WAMP roles defined on a router worker
# MWorkerLog
[docs]
def RouterRoles(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(78))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# WAMP sessions joined on a router worker
# MWorkerLog
[docs]
def RouterSessions(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(80))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# WAMP messages processed by a router worker
# MWorkerLog
[docs]
def RecvCall(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(82))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def RecvYield(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(84))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def SentInvocation(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(86))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def SentResult(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(88))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def RecvPublish(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(90))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def SentPublished(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(92))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def SentEvent(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(94))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def RecvRegister(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(96))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def SentRegistered(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(98))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def RecvSubscribe(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(100))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
# MWorkerLog
[docs]
def SentSubscribed(self):
o = flatbuffers.number_types.UOffsetTFlags.py_type(self._tab.Offset(102))
if o != 0:
return self._tab.Get(flatbuffers.number_types.Uint64Flags, o + self._tab.Pos)
return 0
[docs]
def MWorkerLogStart(builder):
builder.StartObject(50)
[docs]
def Start(builder):
MWorkerLogStart(builder)
[docs]
def MWorkerLogAddTimestamp(builder, timestamp):
builder.PrependUint64Slot(0, timestamp, 0)
[docs]
def AddTimestamp(builder, timestamp):
MWorkerLogAddTimestamp(builder, timestamp)
[docs]
def MWorkerLogAddNodeId(builder, nodeId):
builder.PrependUOffsetTRelativeSlot(1, flatbuffers.number_types.UOffsetTFlags.py_type(nodeId), 0)
[docs]
def AddNodeId(builder, nodeId):
MWorkerLogAddNodeId(builder, nodeId)
[docs]
def MWorkerLogStartNodeIdVector(builder, numElems):
return builder.StartVector(1, numElems, 1)
[docs]
def StartNodeIdVector(builder, numElems: int) -> int:
return MWorkerLogStartNodeIdVector(builder, numElems)
[docs]
def MWorkerLogAddWorkerId(builder, workerId):
builder.PrependUOffsetTRelativeSlot(2, flatbuffers.number_types.UOffsetTFlags.py_type(workerId), 0)
[docs]
def AddWorkerId(builder, workerId):
MWorkerLogAddWorkerId(builder, workerId)
[docs]
def MWorkerLogAddPeriod(builder, period):
builder.PrependUint32Slot(3, period, 0)
[docs]
def AddPeriod(builder, period):
MWorkerLogAddPeriod(builder, period)
[docs]
def MWorkerLogAddMrealmId(builder, mrealmId):
builder.PrependUOffsetTRelativeSlot(4, flatbuffers.number_types.UOffsetTFlags.py_type(mrealmId), 0)
[docs]
def AddMrealmId(builder, mrealmId):
MWorkerLogAddMrealmId(builder, mrealmId)
[docs]
def MWorkerLogStartMrealmIdVector(builder, numElems):
return builder.StartVector(1, numElems, 1)
[docs]
def StartMrealmIdVector(builder, numElems: int) -> int:
return MWorkerLogStartMrealmIdVector(builder, numElems)
[docs]
def MWorkerLogAddType(builder, type):
builder.PrependUint8Slot(5, type, 0)
[docs]
def AddType(builder, type):
MWorkerLogAddType(builder, type)
[docs]
def MWorkerLogAddState(builder, state):
builder.PrependUint8Slot(6, state, 0)
[docs]
def AddState(builder, state):
MWorkerLogAddState(builder, state)
[docs]
def MWorkerLogAddSent(builder, sent):
builder.PrependUint64Slot(7, sent, 0)
[docs]
def AddSent(builder, sent):
MWorkerLogAddSent(builder, sent)
[docs]
def MWorkerLogAddSeq(builder, seq):
builder.PrependUint64Slot(8, seq, 0)
[docs]
def AddSeq(builder, seq):
MWorkerLogAddSeq(builder, seq)
[docs]
def MWorkerLogAddNumFds(builder, numFds):
builder.PrependUint32Slot(9, numFds, 0)
[docs]
def AddNumFds(builder, numFds):
MWorkerLogAddNumFds(builder, numFds)
[docs]
def MWorkerLogAddNumThreads(builder, numThreads):
builder.PrependUint16Slot(10, numThreads, 0)
[docs]
def AddNumThreads(builder, numThreads):
MWorkerLogAddNumThreads(builder, numThreads)
[docs]
def MWorkerLogAddNumCtxSwitchesInvoluntary(builder, numCtxSwitchesInvoluntary):
builder.PrependUint64Slot(11, numCtxSwitchesInvoluntary, 0)
[docs]
def AddNumCtxSwitchesInvoluntary(builder, numCtxSwitchesInvoluntary):
MWorkerLogAddNumCtxSwitchesInvoluntary(builder, numCtxSwitchesInvoluntary)
[docs]
def MWorkerLogAddNumCtxSwitchesInvoluntaryPerSec(builder, numCtxSwitchesInvoluntaryPerSec):
builder.PrependUint32Slot(12, numCtxSwitchesInvoluntaryPerSec, 0)
[docs]
def AddNumCtxSwitchesInvoluntaryPerSec(builder, numCtxSwitchesInvoluntaryPerSec):
MWorkerLogAddNumCtxSwitchesInvoluntaryPerSec(builder, numCtxSwitchesInvoluntaryPerSec)
[docs]
def MWorkerLogAddNumCtxSwitchesVoluntary(builder, numCtxSwitchesVoluntary):
builder.PrependUint64Slot(13, numCtxSwitchesVoluntary, 0)
[docs]
def AddNumCtxSwitchesVoluntary(builder, numCtxSwitchesVoluntary):
MWorkerLogAddNumCtxSwitchesVoluntary(builder, numCtxSwitchesVoluntary)
[docs]
def MWorkerLogAddNumCtxSwitchesVoluntaryPerSec(builder, numCtxSwitchesVoluntaryPerSec):
builder.PrependUint32Slot(14, numCtxSwitchesVoluntaryPerSec, 0)
[docs]
def AddNumCtxSwitchesVoluntaryPerSec(builder, numCtxSwitchesVoluntaryPerSec):
MWorkerLogAddNumCtxSwitchesVoluntaryPerSec(builder, numCtxSwitchesVoluntaryPerSec)
[docs]
def MWorkerLogAddCpuSystem(builder, cpuSystem):
builder.PrependFloat32Slot(15, cpuSystem, 0.0)
[docs]
def AddCpuSystem(builder, cpuSystem):
MWorkerLogAddCpuSystem(builder, cpuSystem)
[docs]
def MWorkerLogAddCpuSystemPerSec(builder, cpuSystemPerSec):
builder.PrependFloat32Slot(16, cpuSystemPerSec, 0.0)
[docs]
def AddCpuSystemPerSec(builder, cpuSystemPerSec):
MWorkerLogAddCpuSystemPerSec(builder, cpuSystemPerSec)
[docs]
def MWorkerLogAddCpuWait(builder, cpuWait):
builder.PrependFloat32Slot(17, cpuWait, 0.0)
[docs]
def AddCpuWait(builder, cpuWait):
MWorkerLogAddCpuWait(builder, cpuWait)
[docs]
def MWorkerLogAddCpuWaitPerSec(builder, cpuWaitPerSec):
builder.PrependFloat32Slot(18, cpuWaitPerSec, 0.0)
[docs]
def AddCpuWaitPerSec(builder, cpuWaitPerSec):
MWorkerLogAddCpuWaitPerSec(builder, cpuWaitPerSec)
[docs]
def MWorkerLogAddCpuUser(builder, cpuUser):
builder.PrependFloat32Slot(19, cpuUser, 0.0)
[docs]
def AddCpuUser(builder, cpuUser):
MWorkerLogAddCpuUser(builder, cpuUser)
[docs]
def MWorkerLogAddCpuUserPerSec(builder, cpuUserPerSec):
builder.PrependFloat32Slot(20, cpuUserPerSec, 0.0)
[docs]
def AddCpuUserPerSec(builder, cpuUserPerSec):
MWorkerLogAddCpuUserPerSec(builder, cpuUserPerSec)
[docs]
def MWorkerLogAddReadBytes(builder, readBytes):
builder.PrependUint64Slot(21, readBytes, 0)
[docs]
def AddReadBytes(builder, readBytes):
MWorkerLogAddReadBytes(builder, readBytes)
[docs]
def MWorkerLogAddReadBytesPerSec(builder, readBytesPerSec):
builder.PrependUint64Slot(22, readBytesPerSec, 0)
[docs]
def AddReadBytesPerSec(builder, readBytesPerSec):
MWorkerLogAddReadBytesPerSec(builder, readBytesPerSec)
[docs]
def MWorkerLogAddReadIos(builder, readIos):
builder.PrependUint64Slot(23, readIos, 0)
[docs]
def AddReadIos(builder, readIos):
MWorkerLogAddReadIos(builder, readIos)
[docs]
def MWorkerLogAddReadIosPerSec(builder, readIosPerSec):
builder.PrependUint64Slot(24, readIosPerSec, 0)
[docs]
def AddReadIosPerSec(builder, readIosPerSec):
MWorkerLogAddReadIosPerSec(builder, readIosPerSec)
[docs]
def MWorkerLogAddWriteBytes(builder, writeBytes):
builder.PrependUint64Slot(25, writeBytes, 0)
[docs]
def AddWriteBytes(builder, writeBytes):
MWorkerLogAddWriteBytes(builder, writeBytes)
[docs]
def MWorkerLogAddWriteBytesPerSec(builder, writeBytesPerSec):
builder.PrependUint64Slot(26, writeBytesPerSec, 0)
[docs]
def AddWriteBytesPerSec(builder, writeBytesPerSec):
MWorkerLogAddWriteBytesPerSec(builder, writeBytesPerSec)
[docs]
def MWorkerLogAddWriteIos(builder, writeIos):
builder.PrependUint64Slot(27, writeIos, 0)
[docs]
def AddWriteIos(builder, writeIos):
MWorkerLogAddWriteIos(builder, writeIos)
[docs]
def MWorkerLogAddWriteIosPerSec(builder, writeIosPerSec):
builder.PrependUint64Slot(28, writeIosPerSec, 0)
[docs]
def AddWriteIosPerSec(builder, writeIosPerSec):
MWorkerLogAddWriteIosPerSec(builder, writeIosPerSec)
[docs]
def MWorkerLogAddSentBytes(builder, sentBytes):
builder.PrependUint64Slot(29, sentBytes, 0)
[docs]
def AddSentBytes(builder, sentBytes):
MWorkerLogAddSentBytes(builder, sentBytes)
[docs]
def MWorkerLogAddSentBytesPerSec(builder, sentBytesPerSec):
builder.PrependUint64Slot(30, sentBytesPerSec, 0)
[docs]
def AddSentBytesPerSec(builder, sentBytesPerSec):
MWorkerLogAddSentBytesPerSec(builder, sentBytesPerSec)
[docs]
def MWorkerLogAddSentIos(builder, sentIos):
builder.PrependUint64Slot(31, sentIos, 0)
[docs]
def AddSentIos(builder, sentIos):
MWorkerLogAddSentIos(builder, sentIos)
[docs]
def MWorkerLogAddSentIosPerSec(builder, sentIosPerSec):
builder.PrependUint64Slot(32, sentIosPerSec, 0)
[docs]
def AddSentIosPerSec(builder, sentIosPerSec):
MWorkerLogAddSentIosPerSec(builder, sentIosPerSec)
[docs]
def MWorkerLogAddRecvBytes(builder, recvBytes):
builder.PrependUint64Slot(33, recvBytes, 0)
[docs]
def AddRecvBytes(builder, recvBytes):
MWorkerLogAddRecvBytes(builder, recvBytes)
[docs]
def MWorkerLogAddRecvBytesPerSec(builder, recvBytesPerSec):
builder.PrependUint64Slot(34, recvBytesPerSec, 0)
[docs]
def AddRecvBytesPerSec(builder, recvBytesPerSec):
MWorkerLogAddRecvBytesPerSec(builder, recvBytesPerSec)
[docs]
def MWorkerLogAddRecvIos(builder, recvIos):
builder.PrependUint64Slot(35, recvIos, 0)
[docs]
def AddRecvIos(builder, recvIos):
MWorkerLogAddRecvIos(builder, recvIos)
[docs]
def MWorkerLogAddRecvIosPerSec(builder, recvIosPerSec):
builder.PrependUint64Slot(36, recvIosPerSec, 0)
[docs]
def AddRecvIosPerSec(builder, recvIosPerSec):
MWorkerLogAddRecvIosPerSec(builder, recvIosPerSec)
[docs]
def MWorkerLogAddRouterRoles(builder, routerRoles):
builder.PrependUint64Slot(37, routerRoles, 0)
[docs]
def AddRouterRoles(builder, routerRoles):
MWorkerLogAddRouterRoles(builder, routerRoles)
[docs]
def MWorkerLogAddRouterSessions(builder, routerSessions):
builder.PrependUint64Slot(38, routerSessions, 0)
[docs]
def AddRouterSessions(builder, routerSessions):
MWorkerLogAddRouterSessions(builder, routerSessions)
[docs]
def MWorkerLogAddRecvCall(builder, recvCall):
builder.PrependUint64Slot(39, recvCall, 0)
[docs]
def AddRecvCall(builder, recvCall):
MWorkerLogAddRecvCall(builder, recvCall)
[docs]
def MWorkerLogAddRecvYield(builder, recvYield):
builder.PrependUint64Slot(40, recvYield, 0)
[docs]
def AddRecvYield(builder, recvYield):
MWorkerLogAddRecvYield(builder, recvYield)
[docs]
def MWorkerLogAddSentInvocation(builder, sentInvocation):
builder.PrependUint64Slot(41, sentInvocation, 0)
[docs]
def AddSentInvocation(builder, sentInvocation):
MWorkerLogAddSentInvocation(builder, sentInvocation)
[docs]
def MWorkerLogAddSentResult(builder, sentResult):
builder.PrependUint64Slot(42, sentResult, 0)
[docs]
def AddSentResult(builder, sentResult):
MWorkerLogAddSentResult(builder, sentResult)
[docs]
def MWorkerLogAddRecvPublish(builder, recvPublish):
builder.PrependUint64Slot(43, recvPublish, 0)
[docs]
def AddRecvPublish(builder, recvPublish):
MWorkerLogAddRecvPublish(builder, recvPublish)
[docs]
def MWorkerLogAddSentPublished(builder, sentPublished):
builder.PrependUint64Slot(44, sentPublished, 0)
[docs]
def AddSentPublished(builder, sentPublished):
MWorkerLogAddSentPublished(builder, sentPublished)
[docs]
def MWorkerLogAddSentEvent(builder, sentEvent):
builder.PrependUint64Slot(45, sentEvent, 0)
[docs]
def AddSentEvent(builder, sentEvent):
MWorkerLogAddSentEvent(builder, sentEvent)
[docs]
def MWorkerLogAddRecvRegister(builder, recvRegister):
builder.PrependUint64Slot(46, recvRegister, 0)
[docs]
def AddRecvRegister(builder, recvRegister):
MWorkerLogAddRecvRegister(builder, recvRegister)
[docs]
def MWorkerLogAddSentRegistered(builder, sentRegistered):
builder.PrependUint64Slot(47, sentRegistered, 0)
[docs]
def AddSentRegistered(builder, sentRegistered):
MWorkerLogAddSentRegistered(builder, sentRegistered)
[docs]
def MWorkerLogAddRecvSubscribe(builder, recvSubscribe):
builder.PrependUint64Slot(48, recvSubscribe, 0)
[docs]
def AddRecvSubscribe(builder, recvSubscribe):
MWorkerLogAddRecvSubscribe(builder, recvSubscribe)
[docs]
def MWorkerLogAddSentSubscribed(builder, sentSubscribed):
builder.PrependUint64Slot(49, sentSubscribed, 0)
[docs]
def AddSentSubscribed(builder, sentSubscribed):
MWorkerLogAddSentSubscribed(builder, sentSubscribed)
[docs]
def MWorkerLogEnd(builder):
return builder.EndObject()
[docs]
def End(builder):
return MWorkerLogEnd(builder)