protocol

package

v1.23.1 Latest Latest Go to latest Published: Aug 11, 2025 License: BSD-3-Clause Imports: 11 Imported by: 0

Details

View Source

const (
	ZEROKMSG_SERVER = "ZEROKMSG_SERVER"
	ZEROKMSG_CLIENT = "ZEROKMSG_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 ParseKMessageLength(datas []byte) int

func RunKMessageClient(addr string, heartbeatTime int, heartbeatCheckInterval int, operator ZeroKMessageOperator, unk ...string)

func RunKMessageServer(addr string, heartbeatTime int, operator ZeroKMessageOperator, watchers ...server.ZeroServerWatcher)

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

func NewAckKMessage(messageType byte, messageId string, xBody []byte) *ZeroKMessage

func NewKMessage(messageType byte, xBody []byte) (*ZeroKMessage, error)

func ParseKMessage(datas []byte) *ZeroKMessage

func (v1msg *ZeroKMessage) AddUniqueKey(uniquekey string) error

func (v1msg *ZeroKMessage) BodyLength() int

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

func (v1msg *ZeroKMessage) Check() error

func (v1msg *ZeroKMessage) Complete() error

func (v1msg *ZeroKMessage) DataLength() int

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

func (v1msg *ZeroKMessage) EndString() string

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

func (v1msg *ZeroKMessage) HeadString() string

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

func (v1msg *ZeroKMessage) MessageId() string

func (v1msg *ZeroKMessage) MessageType() int

func (v1msg *ZeroKMessage) String() string

func (v1msg *ZeroKMessage) UniqueKey() string

func (v1msg *ZeroKMessage) Version() int

type ZeroKMessageClient interface {
	Active() bool
	ExecMessage(*ZeroKMessage, int) (*ZeroKMessage, error)
	PushMessage(*ZeroKMessage) error
}

type ZeroKMessageOperator interface {
	Operation(server.ZeroConnect, *ZeroKMessage) (bool, error)
}

type ZeroKMessageServer interface {
	ExecMessage(string, *ZeroKMessage, int) (*ZeroKMessage, error)
	PushMessage(string, *ZeroKMessage) error
}