protocol

Documentation

Index

• Constants
• func RunZeroV1Client(addr string, heartbeatTime int, heartbeatCheckInterval int, ...)
• func RunZeroV1Server(addr string, heartbeatTime int, heartbeatCheckInterval int, ...)
• type ZeroV1Client
• type ZeroV1Message
  • func NewV1AckMessage(messageType byte, messageId string, xBody []byte) *ZeroV1Message
  • func NewV1Message(messageType byte, xBody []byte) (*ZeroV1Message, error)
  • func ParseV1Message(datas []byte) *ZeroV1Message
  • func (v1msg *ZeroV1Message) BodyLength() int
  • func (v1msg *ZeroV1Message) Bytes() []byte
  • func (v1msg *ZeroV1Message) Check() error
  • func (v1msg *ZeroV1Message) Complete() error
  • func (v1msg *ZeroV1Message) DataLength() int
  • func (v1msg *ZeroV1Message) End() []byte
  • func (v1msg *ZeroV1Message) EndString() string
  • func (v1msg *ZeroV1Message) Head() []byte
  • func (v1msg *ZeroV1Message) HeadString() string
  • func (v1msg *ZeroV1Message) MessageBody() []byte
  • func (v1msg *ZeroV1Message) MessageId() string
  • func (v1msg *ZeroV1Message) MessageType() int
  • func (v1msg *ZeroV1Message) String() string
  • func (v1msg *ZeroV1Message) Version() int
• type ZeroV1MessageOperator
• type ZeroV1ServKeeper

Constants

const (
	ZEROV1SERV_KEEPER = "ZEROV1SERV_KEEPER"
	ZEROV1SERV_CLIENT = "ZEROV1SERV_CLIENT"
)

const (
	MESSAGE_TYPE_CONNECT   = 0x01
	MESSAGE_TYPE_HEARTBEAT = 0x02

	MESSAGE_TYPE_CONNACK = 0x11
	MESSAGE_TYPE_BEATACK = 0x12
)

Functions

func RunZeroV1Client

func RunZeroV1Client(addr string, heartbeatTime int, heartbeatCheckInterval int, operator ZeroV1MessageOperator)

func RunZeroV1Server

func RunZeroV1Server(addr string, heartbeatTime int, heartbeatCheckInterval int, operator ZeroV1MessageOperator)

Types

type ZeroV1Client

type ZeroV1Client interface {
	Active() bool
	ExecMessage(*ZeroV1Message, int) (*ZeroV1Message, error)
	PushMessage(*ZeroV1Message) error
}

type ZeroV1Message

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

func NewV1AckMessage

func NewV1AckMessage(messageType byte, messageId string, xBody []byte) *ZeroV1Message

func NewV1Message

func NewV1Message(messageType byte, xBody []byte) (*ZeroV1Message, error)

func ParseV1Message

func ParseV1Message(datas []byte) *ZeroV1Message

func (*ZeroV1Message) BodyLength

func (v1msg *ZeroV1Message) BodyLength() int

func (*ZeroV1Message) Bytes

func (v1msg *ZeroV1Message) Bytes() []byte

func (*ZeroV1Message) Check

func (v1msg *ZeroV1Message) Check() error

func (*ZeroV1Message) Complete

func (v1msg *ZeroV1Message) Complete() error

func (*ZeroV1Message) DataLength

func (v1msg *ZeroV1Message) DataLength() int

func (*ZeroV1Message) End

func (v1msg *ZeroV1Message) End() []byte

func (*ZeroV1Message) EndString

func (v1msg *ZeroV1Message) EndString() string

func (*ZeroV1Message) Head

func (v1msg *ZeroV1Message) Head() []byte

func (*ZeroV1Message) HeadString

func (v1msg *ZeroV1Message) HeadString() string

func (*ZeroV1Message) MessageBody

func (v1msg *ZeroV1Message) MessageBody() []byte

func (*ZeroV1Message) MessageId

func (v1msg *ZeroV1Message) MessageId() string

func (*ZeroV1Message) MessageType

func (v1msg *ZeroV1Message) MessageType() int

func (*ZeroV1Message) String

func (v1msg *ZeroV1Message) String() string

func (*ZeroV1Message) Version

func (v1msg *ZeroV1Message) Version() int

type ZeroV1MessageOperator

type ZeroV1MessageOperator interface {
	Operation(server.ZeroConnect, *ZeroV1Message) (bool, error)
}

type ZeroV1ServKeeper

type ZeroV1ServKeeper interface {
	ExecMessage(string, *ZeroV1Message, int) (*ZeroV1Message, error)
	PushMessage(string, *ZeroV1Message) error
}