protocol

package

v1.13.1 Latest Latest Go to latest Published: Mar 29, 2024 License: BSD-3-Clause Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

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

View Source

const (
	MESSAGE_TYPE_CONNECT   = 0x01
	MESSAGE_TYPE_HEARTBEAT = 0x02

	MESSAGE_TYPE_CONNACK = 0x11
	MESSAGE_TYPE_BEATACK = 0x12
)

This section is empty.

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

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

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

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

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 interface {
	Operation(server.ZeroConnect, *ZeroV1Message) (bool, error)
}

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