message

Documentation

Index

• func MessageAddData(builder *flatbuffers.Builder, Data flatbuffers.UOffsetT)
• func MessageAddDstID(builder *flatbuffers.Builder, DstID uint32)
• func MessageAddID(builder *flatbuffers.Builder, ID flatbuffers.UOffsetT)
• func MessageAddKind(builder *flatbuffers.Builder, Kind int16)
• func MessageAddType(builder *flatbuffers.Builder, Type int8)
• func MessageEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
• func MessageStart(builder *flatbuffers.Builder)
• func MessageStartDataVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
• func MessageStartIDVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
• func Serialize(ID snoflinga.Flake, k Kind, p []byte) []byte
• type Kind
  • func (k Kind) Int16() int16
  • func (i Kind) String() string
• type Message
  • func GetRootAsMessage(buf []byte, offset flatbuffers.UOffsetT) *Message
  • func (rcv *Message) Data(j int) byte
  • func (rcv *Message) DataBytes() []byte
  • func (rcv *Message) DataLength() int
  • func (rcv *Message) DstID() uint32
  • func (rcv *Message) ID(j int) byte
  • func (rcv *Message) IDBytes() []byte
  • func (rcv *Message) IDLength() int
  • func (rcv *Message) Init(buf []byte, i flatbuffers.UOffsetT)
  • func (rcv *Message) Kind() int16
  • func (rcv *Message) Type() int8

Functions

func MessageAddData

func MessageAddData(builder *flatbuffers.Builder, Data flatbuffers.UOffsetT)

func MessageAddDstID

func MessageAddDstID(builder *flatbuffers.Builder, DstID uint32)

func MessageAddID

func MessageAddID(builder *flatbuffers.Builder, ID flatbuffers.UOffsetT)

func MessageAddKind

func MessageAddKind(builder *flatbuffers.Builder, Kind int16)

func MessageAddType

func MessageAddType(builder *flatbuffers.Builder, Type int8)

func MessageEnd

func MessageEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func MessageStart

func MessageStart(builder *flatbuffers.Builder)

func MessageStartDataVector

func MessageStartDataVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func MessageStartIDVector

func MessageStartIDVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func Serialize

func Serialize(ID snoflinga.Flake, k Kind, p []byte) []byte

Serialize creates a flatbuffer serialized message and returns the bytes.

Types

type Kind

type Kind int16

Kind is the kind of message.Message. This is used for routing.

const (
	Unknown Kind = iota
	EOT          // end of transmission (for sequences that involve multiple messages, e.g. handshake)
	Generic
	Command
	SysInfoFB
	SysInfoJSON
	ClientConf
	CPUUtilization // CPU Utilization information
	LoadAvg        // Sysinfo based load avg
	MemInfo        // Sysinfo based mem info
	NetUsage       // network interface usage info
)

func (Kind) Int16

func (k Kind) Int16() int16

Int16 is a convenience method that returns the Kind as an int16 value. This could also be accomplished by doing the conversion directly.

func (Kind) String

func (i Kind) String() string

type Message

type Message struct {
	// contains filtered or unexported fields
}

func GetRootAsMessage

func GetRootAsMessage(buf []byte, offset flatbuffers.UOffsetT) *Message

func (*Message) Data

func (rcv *Message) Data(j int) byte

func (*Message) DataBytes

func (rcv *Message) DataBytes() []byte

func (*Message) DataLength

func (rcv *Message) DataLength() int

func (*Message) DstID

func (rcv *Message) DstID() uint32

func (*Message) ID

func (rcv *Message) ID(j int) byte

func (*Message) IDBytes

func (rcv *Message) IDBytes() []byte

func (*Message) IDLength

func (rcv *Message) IDLength() int

func (*Message) Init

func (rcv *Message) Init(buf []byte, i flatbuffers.UOffsetT)

func (*Message) Kind

func (rcv *Message) Kind() int16

func (*Message) Type

func (rcv *Message) Type() int8