Documentation
¶
Index ¶
- Variables
- type Client
- type Manager
- func (m *Manager) ClientCount() int
- func (m *Manager) GetAllClients() []string
- func (m *Manager) GetClient(probeID string) (*Client, bool)
- func (m *Manager) Register(client *Client)
- func (m *Manager) Run(ctx context.Context)
- func (m *Manager) SendToClient(probeID string, message []byte) error
- func (m *Manager) SetMessageHandler(handler MessageHandler)
- type MessageHandler
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrClientNotFound = &websocket.CloseError{Code: 1000, Text: "client not found"} ErrSendTimeout = &websocket.CloseError{Code: 1001, Text: "send timeout"} )
错误定义
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
ID string // 探针ID
Conn *websocket.Conn // WebSocket连接
Send chan []byte // 发送消息通道
Manager *Manager // 管理器引用
LastActive time.Time // 最后活跃时间
// contains filtered or unexported fields
}
Client WebSocket客户端
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
Manager WebSocket连接管理器
func (*Manager) SendToClient ¶
SendToClient 发送消息给指定客户端
func (*Manager) SetMessageHandler ¶
func (m *Manager) SetMessageHandler(handler MessageHandler)
SetMessageHandler 设置消息处理器
type MessageHandler ¶
type MessageHandler func(ctx context.Context, probeID string, messageType string, data json.RawMessage) error
MessageHandler 消息处理器接口
Source Files
Click to show internal directories.
Click to hide internal directories.