client

type Channel struct {
	ChannelID   string
	ChannelType uint8
}

type Client struct {
	Statistics
	wklog.Log
	// contains filtered or unexported fields
}

type OnRecv func(recv *wkproto.RecvPacket) error

type OnSendack func(sendackPacket *wkproto.SendackPacket)

type Option func(*Options) error

type Options struct {
	ProtoVersion   uint8  // 协议版本
	UID            string // 用户uid
	Token          string // 连接IM的token
	AutoReconn     bool   //是否开启自动重连
	DefaultBufSize int    // The size of the bufio reader/writer on top of the socket.

	// ReconnectBufSize is the size of the backing bufio during reconnect.
	// Once this has been exhausted publish operations will return an error.
	// Defaults to 8388608 bytes (8MB).
	ReconnectBufSize int

	// FlusherTimeout is the maximum time to wait for write operations
	// to the underlying connection to complete (including the flusher loop).
	FlusherTimeout time.Duration

	// Timeout sets the timeout for a Dial operation on a connection.
	Timeout time.Duration

	PingInterval time.Duration

	MaxPingCount int // 最大ping的次数

	// ReconnectJitter sets the upper bound for a random delay added to
	// ReconnectWait during a reconnect when no TLS is used.
	ReconnectJitter time.Duration

	// ReconnectWait sets the time to backoff after attempting a reconnect
	// to a server that we were already connected to previously.
	ReconnectWait time.Duration
}

type SendOption func(*SendOptions) error

type SendOptions struct {
	NoPersist   bool // 是否不存储 默认 false
	SyncOnce    bool // 是否同步一次（写模式） 默认 false
	Flush       bool // 是否io flush 默认true
	RedDot      bool // 是否显示红点 默认true
	NoEncrypt   bool // 是否不需要加密
	ClientMsgNo string
}

type Statistics struct {
	InMsgs     atomic.Uint64
	OutMsgs    atomic.Uint64
	InBytes    atomic.Uint64
	OutBytes   atomic.Uint64
	Reconnects atomic.Uint64
}

type Status int