protocol

Documentation

Index

• Constants
• Variables
• type HelloRequest
  • func (rq *HelloRequest) VampUnionAlt() (uint, any)
• type RequestHeader
• type ResponseCode
  • func (i ResponseCode) String() string
  • func (rc *ResponseCode) VampFromUint16(i uint16) error
  • func (rp ResponseCode) VampUnionAlt() (uint, any)

Constants

const (
	ReqIDHello uint = iota
)

const (
	RspIDEmpty uint = iota
)

const StreamOffSize = vamp.Size32

Variables

var (
	ReqVersion []byte
	RspVersion []byte
)

var VampRequest = vamp.NewUnion(vamp.Size8,
	vamp.MustNamed("hello", vamp.MustUseStruct(HelloRequest{})),
).SetAltReader(func(alt uint, into any) (any, error) {
	i := into.(*any)
	switch alt {
	case ReqIDHello:
		*i = new(HelloRequest)
		return *i, nil
	}
	return nil, fmt.Errorf("unknown request id %d", alt)
})

var VampResponse = vamp.NewUnion(vamp.Size8,
	vamp.MustNamed("empty", vamp.Uint16),
).SetAltReader(func(alt uint, into any) (any, error) {
	i := into.(*any)
	switch alt {
	case RspIDEmpty:
		*i = new(ResponseCode)
		return *i, nil
	}
	return nil, fmt.Errorf("unknown response id %d", alt)
})

Types

type HelloRequest

type HelloRequest struct {
	RequestHeader
	ReqProto []byte `vamp:"size=8"`
	RspProto []byte `vamp:"size=8"`
}

func (*HelloRequest) VampUnionAlt

func (rq *HelloRequest) VampUnionAlt() (uint, any)

type RequestHeader

type RequestHeader struct {
	Token   string `vamp:"size=8"`
	MsgTime time.Time
}

type ResponseCode

type ResponseCode uint16

const (
	RspOK ResponseCode = iota
	RspProtoMismatch
)

func (ResponseCode) String

func (i ResponseCode) String() string

func (*ResponseCode) VampFromUint16

func (rc *ResponseCode) VampFromUint16(i uint16) error

func (ResponseCode) VampUnionAlt

func (rp ResponseCode) VampUnionAlt() (uint, any)