MCPcopy Create free account

hub / github.com/chenxilol/gohub / functions

Functions347 in github.com/chenxilol/gohub

⨍ Functions 347◇ Types & classes 58
MethodDecodeAndRoute
DecodeAndRoute 实现了 MessageDispatcher 接口
internal/integration/mocks.go:90
MethodDecodeAndRoute
(ctx context.Context, client *hub.Client, message []byte)
internal/dispatcher/dispatcher.go:52
FunctionDecodeMessage
消息解码 DecodeMessage 将JSON数据解码为消息
pkg/hub/message.go:65
MethodDeleteMetadata
DeleteMetadata 删除客户端元数据
pkg/hub/client.go:226
MethodDeleteRoom
DeleteRoom 删除一个房间
pkg/hub/room.go:280
MethodDeleteRoom
(id string)
pkg/sdk/sdk.go:141
MethodDialHook
(hook redis.DialHook)
pkg/bus/redis/redis.go:95
MethodDisconnectClient
(clientID string)
pkg/sdk/sdk.go:45
MethodDisconnectClient
(clientID string)
pkg/sdk/sdk.go:107
MethodGenerateToken
GenerateToken 实现Authenticator接口，生成JWT令牌
pkg/auth/jwt.go:33
MethodGenerateToken
GenerateToken 生成新的令牌
pkg/auth/auth.go:46
MethodGetClient
(clientID string)
pkg/sdk/sdk.go:98
MethodGetClientCount
GetClientCount 获取房间内客户端数量
pkg/hub/room.go:114
MethodGetClientCount
实现SDK接口的连接管理方法
pkg/sdk/sdk.go:94
MethodGetClientPermissions
(clientID string)
pkg/sdk/sdk.go:62
MethodGetClientPermissions
(clientID string)
pkg/sdk/sdk.go:192
MethodGetClientRooms
GetClientRooms 获取客户端加入的所有房间
pkg/hub/room.go:378
MethodGetMetadata
GetMetadata 获取客户端元数据
pkg/hub/client.go:221
MethodGetReconnectCount
GetReconnectCount 获取重连次数
pkg/bus/redis/metrics.go:76
MethodGetReconnectCount
GetReconnectCount 获取重连次数
pkg/bus/nats/nats.go:262
MethodGetRoom
(id string)
pkg/sdk/sdk.go:145
MethodGetRoomCount
()
pkg/sdk/sdk.go:153
MethodGetRoomMembers
(roomID string)
pkg/sdk/sdk.go:58
MethodGetRoomMembers
(roomID string)
pkg/sdk/sdk.go:172
MethodIncReconnects
IncReconnects 增加重连计数
pkg/bus/nats/metrics.go:97
MethodIsAuthenticated
实现SDK接口的认证相关方法
pkg/sdk/sdk.go:183
FunctionIsUnexpectedCloseError
(err error, expectedCodes ...int)
pkg/hub/client.go:170
FunctionIsWebsocketCloseError
(err error)
pkg/hub/client.go:180
MethodJoinRoom
JoinRoom 将客户端加入房间
pkg/hub/room.go:315
MethodJoinRoom
(roomID string, clientID string)
pkg/sdk/sdk.go:157
MethodLeaveRoom
LeaveRoom 让客户端离开房间
pkg/hub/room.go:324
MethodLeaveRoom
(roomID string, clientID string)
pkg/sdk/sdk.go:161
MethodListRooms
ListRooms 列出所有房间
pkg/hub/hub.go:428
MethodListRooms
ListRooms 列出所有房间
pkg/hub/room.go:304
MethodListRooms
()
pkg/sdk/sdk.go:149
FunctionLoadConfig
LoadConfig loads configuration from the specified file
configs/config.go:95
FunctionMessageReceived
MessageReceived 记录收到消息
internal/metrics/metrics.go:182
FunctionNewAutoIncID
NewAutoIncID 创建新的ID生成器
pkg/hub/message.go:80
FunctionNewGorillaConn
(conn *websocket.Conn)
internal/websocket/adapter.go:13
FunctionNewMockBus
()
pkg/hub/hub_test.go:89
MethodNext
Next 获取下一个ID
pkg/hub/message.go:85
MethodOff
(eventType EventType, handler EventHandler)
pkg/sdk/sdk.go:67
MethodOff
(eventType EventType, handler EventHandler)
pkg/sdk/sdk.go:221
MethodOn
实现SDK接口的事件订阅方法
pkg/sdk/sdk.go:217
MethodOnRetry
OnRetry 记录每次重连事件
pkg/bus/redis/redis.go:114
MethodProcessHook
(hook redis.ProcessHook)
pkg/bus/redis/redis.go:101
MethodProcessPipelineHook
(hook redis.ProcessPipelineHook)
pkg/bus/redis/redis.go:107
MethodPublish
(ctx context.Context, topic string, data []byte)
pkg/hub/integration_test.go:36
MethodPublish
(ctx context.Context, topic string, data []byte)
pkg/hub/hub_test.go:97
MethodPublish
(ctx context.Context, topic string, data []byte)
pkg/hub/cluster_test.go:30
MethodPublish
Publish 实现MessageBus.Publish，实际上不做任何事情，直接返回nil
pkg/bus/noop/noop.go:23
MethodPublish
(ctx context.Context, topic string, data []byte)
pkg/bus/redis/core_pubsub.go:9
MethodPublish
(ctx context.Context, topic string, data []byte)
pkg/bus/nats/core_pubsub.go:21
MethodReadMessage
()
pkg/hub/hub_test.go:25
MethodReadMessage
()
pkg/hub/client.go:36
MethodReadMessage
()
internal/integration/mocks.go:23
MethodRegister
(name string, handler MessageHandlerFunc)
pkg/hub/hub_test.go:204
MethodRegister
(name string, handler hub.MessageHandlerFunc)
internal/integration/mocks.go:101
MethodRegister
(msgType string, handler hub.MessageHandlerFunc)
internal/dispatcher/dispatcher.go:45
MethodRegisterMessageHandler
(messageType string, handler hub.MessageHandlerFunc)
pkg/sdk/sdk.go:265
MethodReplyTo
ReplyTo 创建一个对指定消息的回复
pkg/hub/message.go:46
MethodSendToClient
(clientID string, message []byte)
pkg/sdk/sdk.go:47
MethodSendToClient
(clientID string, message []byte)
pkg/sdk/sdk.go:127
MethodSetMetadata
SetMetadata 设置客户端元数据
pkg/hub/client.go:216
MethodSetReadDeadline
(t time.Time)
pkg/hub/hub_test.go:46
MethodSetReadDeadline
(time.Time)
pkg/hub/client.go:40
MethodSetReadDeadline
(t time.Time)
internal/integration/mocks.go:44
MethodSetReadLimit
(limit int64)
pkg/hub/hub_test.go:44
MethodSetReadLimit
(int64)
pkg/hub/client.go:39
MethodSetReadLimit
(limit int64)
internal/integration/mocks.go:42
MethodSetWriteDeadline
(t time.Time)
pkg/hub/hub_test.go:50
MethodSetWriteDeadline
(time.Time)
pkg/hub/client.go:41
MethodSetWriteDeadline
(t time.Time)
internal/integration/mocks.go:48
MethodSubscribe
(ctx context.Context, topic string)
pkg/hub/integration_test.go:75
MethodSubscribe
(ctx context.Context, topic string)
pkg/hub/hub_test.go:133
MethodSubscribe
(ctx context.Context, topic string)
pkg/hub/cluster_test.go:76
MethodSubscribe
Subscribe 实现MessageBus.Subscribe，返回一个立即关闭的通道
pkg/bus/noop/noop.go:40
MethodSubscribe
Subscribe 实现MessageBus.Subscribe，订阅Redis频道
pkg/bus/redis/core_pubsub.go:69
MethodSubscribe
Subscribe 实现MessageBus.Subscribe，订阅NATS主题
pkg/bus/nats/core_pubsub.go:133
MethodSubscribeWithTimestamp
(ctx context.Context, topic string)
pkg/hub/integration_test.go:270
MethodSubscribeWithTimestamp
SubscribeWithTimestamp 实现MessageBus.SubscribeWithTimestamp
pkg/hub/cluster_test.go:157
MethodSubscribeWithTimestamp
SubscribeWithTimestamp 订阅指定主题，返回带时间戳的消息channel
pkg/bus/bus.go:24
MethodSubscribeWithTimestamp
SubscribeWithTimestamp 实现MessageBus.SubscribeWithTimestamp，返回一个立即关闭的通道
pkg/bus/noop/noop.go:59
MethodSubscribeWithTimestamp
SubscribeWithTimestamp 实现MessageBus.SubscribeWithTimestamp，订阅Redis频道并返回带时间戳的消息
pkg/bus/redis/core_pubsub.go:93
MethodSubscribeWithTimestamp
SubscribeWithTimestamp 实现MessageBus.SubscribeWithTimestamp，订阅NATS主题并返回带时间戳的消息
pkg/bus/nats/core_pubsub.go:493
FunctionTestClientConnectionAuthDisconnection
TestClientConnectionAuthDisconnection 测试客户端连接、认证和断开连接的完整生命周期
internal/integration/client_lifecycle_test.go:16
FunctionTestClientReadWriteTimeouts
TestClientReadWriteTimeouts 测试客户端读写超时
internal/integration/client_lifecycle_test.go:137
FunctionTestCluster_Integration
mockDispatcher 和 newMockDispatcher 已在 hub_test.go 中定义，这里不再重复 集成测试：模拟集群环境中的Hub行为
pkg/hub/integration_test.go:121
FunctionTestGohub
(t *testing.T)
examples/test/server_test.go:122
FunctionTestHub_Broadcast_Cluster
T2：集群广播（2个节点）- 两个节点的客户端都能收到
pkg/hub/cluster_test.go:190
FunctionTestHub_Broadcast_SingleNode
T1：单节点广播 - 所有本地客户端都能收到
pkg/hub/hub_test.go:211
FunctionTestHub_ClientTimeout
T4：心跳超时 - 客户端断开连接并被移除
pkg/hub/hub_test.go:267
FunctionTestHub_Push_AcrossNodes
T3：跨节点单播 - 只有目标收到
pkg/hub/cluster_test.go:304
FunctionTestHub_SendBufferFull
T5：发送缓冲区已满 - 返回 ErrSendBufferFull
pkg/hub/hub_test.go:305
FunctionTestLocalRoomOperations
TestLocalRoomOperations 测试本地房间操作
internal/integration/room_management_test.go:15
FunctionTestNatsBus_JetStreamErrorHandling
TestNatsBus_JetStreamErrorHandling 测试JetStream错误处理
pkg/bus/nats/jetstream_test.go:279
FunctionTestNatsBus_JetStreamMultipleMessages
TestNatsBus_JetStreamMultipleMessages 测试JetStream批量处理功能
pkg/bus/nats/jetstream_test.go:75
FunctionTestNatsBus_JetStreamPublishLatency
TestNatsBus_JetStreamPublishLatency 测试JetStream发布延迟统计
pkg/bus/nats/publish_test.go:89
FunctionTestNatsBus_JetStreamPublishSubscribe
TestNatsBus_JetStreamPublishSubscribe 测试JetStream的发布订阅功能
pkg/bus/nats/jetstream_test.go:11
FunctionTestNatsBus_JetStreamReconnect
TestNatsBus_JetStreamReconnect 测试JetStream重连功能
pkg/bus/nats/jetstream_test.go:163
← previousnext →201–300 of 347, ranked by callers