MCPcopy Create free account

hub / github.com/chenxilol/gohub / types & classes

Types & classes58 in github.com/chenxilol/gohub

⨍ Functions 347◇ Types & classes 58
↓ 1 callersFuncTypeMessageHandlerFunc
func(ctx context.Context, client *Client, data json.RawMessage) error
pkg/hub/dispatcher_interface.go:13
StructAuth
configs/config.go:29
InterfaceAuthenticator
Authenticator 认证接口，用于解析和验证令牌
pkg/auth/auth.go:41
InterfaceAuthorizer
Authorizer 授权接口，用于检查权限
pkg/auth/auth.go:50
StructAutoIncID
AutoIncID 自动递增ID生成器
pkg/hub/message.go:74
StructBusMessage
pkg/hub/dedup.go:23
StructClient
pkg/hub/client.go:21
StructCluster
configs/config.go:22
StructClusterMockBus
ClusterMockBus 专门为集群测试设计的消息总线模拟
pkg/hub/cluster_test.go:16
StructConfig
configs/config.go:40
StructConfig
pkg/hub/client.go:45
StructConfig
Config Redis连接配置选项
pkg/bus/redis/redis.go:18
StructConfig
Config NATS连接配置选项
pkg/bus/nats/nats.go:18
StructDispatcher
internal/dispatcher/dispatcher.go:22
StructEnhancedMockBus
更全面的MessageBus模拟
pkg/hub/integration_test.go:16
StructErrorResponse
ErrorResponse 错误响应结构
pkg/hub/error.go:38
StructEvent
pkg/sdk/sdk.go:28
FuncTypeEventHandler
func(ctx context.Context, event Event) error
pkg/sdk/sdk.go:38
FuncTypeEventHandlerFunc
EventHandlerFunc 是事件处理函数的类型
server/server.go:34
TypeAliasEventType
pkg/sdk/sdk.go:14
StructFrame
Frame 封装底层websocket帧
pkg/hub/frame.go:4
StructGoHubSDK
GoHubSDK 是SDK接口的实现
pkg/sdk/sdk.go:77
StructGorillaConn
internal/websocket/adapter.go:7
FuncTypeHandlerFunc
func(ctx context.Context, client *hub.Client, data json.RawMessage) error
internal/dispatcher/dispatcher.go:20
FuncTypeHandlerFunc
func(ctx context.Context, client *hub.Client, data json.RawMessage) error
server/server.go:31
StructHub
Hub 管理WebSocket客户端连接和消息分发
pkg/hub/hub.go:26
StructJWTClaims
pkg/auth/jwt.go:13
StructJWTService
pkg/auth/jwt.go:20
StructLog
configs/config.go:36
StructMessage
Message 表示一个通用的WebSocket消息
pkg/hub/message.go:11
StructMessage
pkg/bus/message.go:8
InterfaceMessageBus
MessageBus 在节点间传播消息
pkg/bus/bus.go:16
StructMessageDeduplicator
MessageDeduplicator 消息去重器
pkg/hub/dedup.go:33
InterfaceMessageDispatcher
pkg/hub/dispatcher_interface.go:8
StructMessageID
MessageID 消息唯一标识符
pkg/hub/dedup.go:12
StructMetrics
Metrics 封装所有监控指标
internal/metrics/metrics.go:19
StructMockBus
MockBus 用于测试的消息总线模拟
pkg/hub/hub_test.go:80
StructMockWSConn
MockWSConn 用于测试的WebSocket连接模拟
pkg/hub/hub_test.go:14
StructMockWSConn
MockWSConn 用于测试的WebSocket连接模拟
internal/integration/mocks.go:12
StructMockWSConnBlocking
MockWSConnBlocking 模拟写入被阻塞的WebSocket连接
pkg/hub/hub_test.go:66
StructMockWSConnBlocking
MockWSConnBlocking 模拟写入被阻塞的WebSocket连接
internal/integration/mocks.go:71
StructNatsBus
NatsBus 基于NATS的消息总线实现
pkg/bus/nats/nats.go:48
StructNoopBus
NoopBus 是一个空操作消息总线，用于本地模式或测试
pkg/bus/noop/noop.go:12
StructOptions
Options 服务器配置选项
server/server.go:37
TypeAliasPermission
pkg/auth/auth.go:17
StructRedisBus
pkg/bus/redis/redis.go:81
StructRetryHook
RetryHook 用于统计重试次数的钩子
pkg/bus/redis/redis.go:91
StructRoom
Room 表示一个聊天房间或频道
pkg/hub/room.go:38
StructRoomManager
pkg/hub/room.go:141
InterfaceSDK
SDK 服务端接口
pkg/sdk/sdk.go:41
StructServer
configs/config.go:17
StructServer
server/server.go:72
StructTokenClaims
TokenClaims 定义令牌的声明内容 (通用结构，由具体的认证实现填充)
pkg/auth/auth.go:31
StructUser
test_client.go:113
InterfaceWSConn
pkg/hub/client.go:35
InterfaceWSConn
internal/websocket/conn_iface.go:5
StructmockDispatcher
mockDispatcher 是 MessageDispatcher 的测试替身实现
pkg/hub/hub_test.go:193
StructmockDispatcher
mockDispatcher 是 hub.MessageDispatcher 的模拟实现
internal/integration/mocks.go:85