protocol

Documentation

Index

• Constants
• func Pack(ctx context.Context, m *Message) []byte
• type Message
  • func ReadSocket(ctx context.Context, buffer *bytes.Buffer) (*Message, error)

Constants

const (
	PackageLengthSize = 4
	HeaderLengthSize  = 2
	VersionSize       = 4
	OperationSize     = 4
	SequenceIdSize    = 4
)

const MaxSize = int32(1 << 12)

Functions

func Pack

func Pack(ctx context.Context, m *Message) []byte

Types

type Message

type Message struct {
	HeaderLen  int16
	Version    int16
	Operation  int32
	SequenceId int32
	Body       string
}

func ReadSocket

func ReadSocket(ctx context.Context, buffer *bytes.Buffer) (*Message, error)