network

type Attr interface {
	// Set 设置属性值
	Set(key, value any)
	// Get 获取属性值
	Get(key any) (any, bool)
	// Del 删除属性值
	Del(key any) bool
	// Visit 访问所有的属性值
	Visit(fn func(key, value any) bool)
}

type Client interface {
	// Dial 连接到指定的服务器地址。
	// addr 可以传入多个地址，客户端会依次尝试连接。
	Dial(addr ...string) (Conn, error)
	// Protocol 返回客户端使用的网络协议名称（如 "tcp"、"kcp"、"ws"）。
	Protocol() string
	// OnConnect 注册连接建立时的回调处理器。
	OnConnect(handler ConnectHandler)
	// OnReceive 注册接收到消息时的回调处理器。
	OnReceive(handler ReceiveHandler)
	// OnDisconnect 注册连接断开时的回调处理器。
	OnDisconnect(handler DisconnectHandler)
}

type CloseHandler func()

type Conn interface {
	// ID 获取连接ID
	ID() int64
	// UID 获取用户ID
	UID() int64
	// Attr 属性接口
	Attr() Attr
	// Bind 绑定用户ID
	Bind(uid int64)
	// Unbind 解绑用户ID
	Unbind()
	// Send 发送消息（同步）
	Send(msg []byte) error
	// Push 发送消息（异步）
	Push(msg []byte) error
	// State 获取连接状态
	State() ConnState
	// Close 关闭连接
	Close(force ...bool) error
	// LocalIP 获取本地IP
	LocalIP() (string, error)
	// LocalAddr 获取本地地址
	LocalAddr() (net.Addr, error)
	// RemoteIP 获取远端IP
	RemoteIP() (string, error)
	// RemoteAddr 获取远端地址
	RemoteAddr() (net.Addr, error)
}

type ConnState int32

type ConnectHandler func(conn Conn)

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

type DisconnectHandler func(conn Conn)

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

type HeartbeatConfig struct {
	Interval  time.Duration      // 心跳检测间隔时间
	Mechanism HeartbeatMechanism // 心跳机制
	Timeout   time.Duration      // 心跳超时时间（默认为 2 * Interval）
}

type HeartbeatHandler struct {
	// OnTimeout 心跳超时回调
	OnTimeout func()
	// OnSendHeartbeat 发送心跳回调
	OnSendHeartbeat func() error
}

type HeartbeatMechanism string

type HeartbeatStats struct {
	ConnID            int64
	LastHeartbeatTime time.Time
	Interval          time.Duration
	Mechanism         HeartbeatMechanism
	IsTimeout         bool
}

type ReceiveHandler func(conn Conn, buf buffer.Buffer)

type Server interface {
	// Addr 返回服务器监听的地址
	Addr() string
	// Start 启动服务器，开始监听客户端连接
	Start() error
	// Stop 停止服务器，关闭所有连接
	Stop() error
	// Protocol 返回服务器使用的网络协议名称（如 "tcp"、"kcp"、"ws"）
	Protocol() string
	// OnStart 注册服务器启动时的回调处理器
	OnStart(handler StartHandler)
	// OnStop 注册服务器关闭时的回调处理器
	OnStop(handler CloseHandler)
	// OnConnect 注册连接建立时的回调处理器
	OnConnect(handler ConnectHandler)
	// OnReceive 注册接收到消息时的回调处理器
	OnReceive(handler ReceiveHandler)
	// OnDisconnect 注册连接断开时的回调处理器
	OnDisconnect(handler DisconnectHandler)
}

type StartHandler func()