message

Documentation

Index

• Constants
• type Message
  • func (message *Message) Deserialize(input []byte) (err error)
  • func (message *Message) Serialize() (result []byte, err error)
  • func (message *Message) Validate() error

Constants

const (
	InputStreamDataMessage  = 0 // string = "input_stream_data"
	OutputStreamDataMessage = 1 // string = "output_stream_data"
	SetSizeDataMessage      = 2 //string = "set_size"
	CloseDataChannel        = 3
	StatusDataChannel       = 5
)

const (
	AgentMessage_MessageTypeLength    = 4
	AgentMessage_SchemaVersionLength  = 4
	AgentMessage_SessionIdLength      = 1
	AgentMessage_InstanceIdLength     = 1
	AgentMessage_CreatedDateLength    = 8
	AgentMessage_SequenceNumberLength = 8
	AgentMessage_PayloadLength        = 4
)

const (
	AgentMessage_MessageTypeOffset    = 0
	AgentMessage_SchemaVersionOffset  = AgentMessage_MessageTypeOffset + AgentMessage_MessageTypeLength
	AgentMessage_SessionIdOffset      = AgentMessage_SchemaVersionOffset + AgentMessage_SchemaVersionLength
	AgentMessage_InstanceIdOffset     = AgentMessage_SessionIdOffset + AgentMessage_SessionIdLength
	AgentMessage_CreatedDateOffset    = AgentMessage_InstanceIdOffset + AgentMessage_InstanceIdLength
	AgentMessage_SequenceNumberOffset = AgentMessage_CreatedDateOffset + AgentMessage_CreatedDateLength
	AgentMessage_PayloadLengthOffset  = AgentMessage_SequenceNumberOffset + AgentMessage_SequenceNumberLength
	AgentMessage_PayloadOffset        = AgentMessage_PayloadLengthOffset + AgentMessage_PayloadLength
)

Types

type Message

type Message struct {
	MessageType    uint32
	SchemaVersion  string
	SessionId      string
	CreatedDate    uint64
	SequenceNumber int64
	// MessageId      string
	PayloadLength uint32
	Payload       []byte
}

func (*Message) Deserialize

func (message *Message) Deserialize(input []byte) (err error)

func (*Message) Serialize

func (message *Message) Serialize() (result []byte, err error)

func (*Message) Validate

func (message *Message) Validate() error

Validate returns error if the message is invalid