Functions — github.com/chenxilol/gohub

hub / github.com/chenxilol/gohub / functions

Functions347 in github.com/chenxilol/gohub

⨍ Functions 347◇ Types & classes 58

FunctionTestNatsBus_MultipleSubscribers

TestNatsBus_MultipleSubscribers 测试多个订阅者

pkg/bus/nats/core_test.go:112

FunctionTestNatsBus_PublishErrors

TestNatsBus_PublishErrors 测试发布错误情况

pkg/bus/nats/publish_test.go:41

FunctionTestNatsBus_PublishSubscribe

TestNatsBus_PublishSubscribe 测试基本的发布订阅功能

pkg/bus/nats/core_test.go:68

FunctionTestNatsBus_PublishSuccessful

TestNatsBus_PublishSuccessful 测试成功发布

pkg/bus/nats/publish_test.go:13

FunctionTestNatsBus_PublishTimeout

TestNatsBus_PublishTimeout 测试发布超时

pkg/bus/nats/publish_test.go:123

FunctionTestNatsBus_Reconnect

TestNatsBus_Reconnect 测试重连功能

pkg/bus/nats/core_test.go:229

FunctionTestNatsBus_Unsubscribe

TestNatsBus_Unsubscribe 测试取消订阅

pkg/bus/nats/core_test.go:163

FunctionTestNoopBus_PublishSubscribe

TestNoopBus_PublishSubscribe 测试NoopBus的Publish和Subscribe功能

pkg/bus/noop/noop_test.go:12

FunctionTestRedisBus_Close

TestRedisBus_Close 测试关闭功能

pkg/bus/redis/redis_test.go:130

FunctionTestRedisBus_Connection

TestRedisBus_Connection 测试Redis连接

pkg/bus/redis/redis_test.go:36

FunctionTestRedisBus_EmptyTopic

TestRedisBus_EmptyTopic 测试空主题

pkg/bus/redis/redis_test.go:103

FunctionTestRedisBus_Publish

TestRedisBus_Publish 测试发布消息功能

pkg/bus/redis/redis_test.go:55

FunctionTestRedisBus_PublishTimeout

TestRedisBus_PublishTimeout 测试发布超时

pkg/bus/redis/redis_test.go:79

FunctionTestSendBufferFull

TestSendBufferFull 测试发送缓冲区已满的情况

internal/integration/client_lifecycle_test.go:209

FunctionTestServerWithAuth

(t *testing.T)

examples/test/server_test.go:80

FunctionTestSimpleServer

(t *testing.T)

examples/test/server_test.go:15

pkg/hub/integration_test.go:90

MethodUnsubscribe

(topic string)

pkg/hub/hub_test.go:171

MethodUnsubscribe

(topic string)

pkg/hub/cluster_test.go:119

MethodUnsubscribe

Unsubscribe 实现MessageBus.Unsubscribe，不做任何操作

pkg/bus/noop/noop.go:77

MethodUnsubscribe

Unsubscribe 实现MessageBus.Unsubscribe，取消Redis订阅

pkg/bus/redis/core_pubsub.go:45

MethodWithBusTimeout

(timeout time.Duration)

pkg/hub/hub.go:46

MethodWriteControl

(messageType int, data []byte, deadline time.Time)

pkg/hub/hub_test.go:40

MethodWriteControl

(int, []byte, time.Time)

pkg/hub/client.go:38

MethodWriteControl

(messageType int, data []byte, deadline time.Time)

internal/integration/mocks.go:38

MethodWriteControl

(int, []byte, time.Time)

internal/websocket/conn_iface.go:8

MethodWriteMessage

(msgType int, data []byte)

pkg/hub/hub_test.go:29

MethodWriteMessage

重写WriteMessage方法使其阻塞

pkg/hub/hub_test.go:72

(msgType int, data []byte)

internal/integration/mocks.go:27

MethodWriteMessage

重写WriteMessage方法使其阻塞

internal/integration/mocks.go:77

FunctionhandleDirectMessage

处理私信

internal/handlers/handlers.go:205

FunctionhandleEcho

handleEcho 回显消息处理器

examples/simple/main.go:73

examples/simple/main.go:95

FunctionhandleJoinRoom

处理加入房间消息

internal/handlers/handlers.go:77

FunctionhandleLeaveRoom

处理离开房间消息

internal/handlers/handlers.go:121

FunctionhandlePing

处理ping消息，用于心跳检测

internal/handlers/handlers.go:37

FunctionhandleRoomMessage

处理房间消息

internal/handlers/handlers.go:158

MethodhandleWebSocket

handleWebSocket 处理WebSocket连接

server/server.go:220

Functioninit

注册指标

pkg/bus/redis/metrics.go:46

Functioninit

注册指标

pkg/bus/nats/metrics.go:70

examples/simple/main.go:18

Functionmain

()

examples/cluster/main.go:20

FunctionredisExample

redisExample 演示使用Redis的集群模式

examples/cluster/main.go:51

← previous301–347 of 347, ranked by callers