socket

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

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

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

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

type ClientOption struct {
	Uid         int         // 用户识别ID
	Channel     IChannel    // 渠道信息
	Storage     IStorage    // 自定义缓存组件, 用于绑定用户与客户端的关系
	IdGenerator IdGenerator // 客户端ID生成器(唯一ID), 默认使用雪花算法
	Buffer      int         // 缓冲区大小根据业务, 自行调整
}

type ClientResponse struct {
	IsAck   bool   `json:"-"`                 // 是否需要 ack 回调
	Sid     string `json:"sid,omitempty"`     // ACK ID
	Event   string `json:"event"`             // 事件名
	Content any    `json:"content,omitempty"` // 事件内容
	Retry   int    `json:"-"`                 // 重试次数(0 默认不重试)
}

type CloseEvent func(client IClient, code int, text string)

type DestroyEvent func(client IClient)

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

type EventOption func(event *Event)

type IChannel interface {
	Name() string
	Count() int64
	Client(cid int64) (*Client, bool)
	Write(data *SenderContent)
	// contains filtered or unexported methods
}

type IClient interface {
	Cid() int64                       // 客户端ID
	Uid() int                         // 客户端关联用户ID
	Close(code int, text string)      // 关闭客户端
	Write(data *ClientResponse) error // 写入数据
	Channel() IChannel                // 获取客户端所属渠道
}

type IConn interface {
	// Read 数据读取
	Read() ([]byte, error)
	// Write 数据写入
	Write([]byte) error
	// Close 连接关闭
	Close() error
	// SetCloseHandler 设置连接关闭回调事件
	SetCloseHandler(fn func(code int, text string) error)
	// Network 网络协议类型
	Network() string
}

type IEvent interface {
	Open(client IClient)
	Message(client IClient, data []byte)
	Close(client IClient, code int, text string)
	Destroy(client IClient)
}

type IStorage interface {
	Bind(ctx context.Context, channel string, cid int64, uid int) error
	UnBind(ctx context.Context, channel string, cid int64) error
}

type IdGenerator interface {
	//   获取自增ID
	IdGen() int64
}

type Message struct {
	Event   string `json:"event"`   // 事件名称
	Content any    `json:"content"` // 消息内容
}

type MessageEvent func(client IClient, data []byte)

type OpenEvent func(client IClient)

type SenderContent struct {
	IsAck bool
	// contains filtered or unexported fields
}

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