Source code for cfxdb.gen.log.MWorkerLog

# automatically generated by the FlatBuffers compiler, do not modify

# namespace: log

import flatbuffers
from flatbuffers.compat import import_numpy

[docs] np = import_numpy()
# Heartbeat log record from managed node workers. Primary key: (timestamp, node_id, worker_id).
[docs] class MWorkerLog(object):
[docs] __slots__ = ["_tab"]
@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)