hub / github.com/didapinchegit/go_rocket_mq

github.com/didapinchegit/go_rocket_mq @main

Chat with this repo

repository ↗ · DeepWiki ↗ · + Follow

125 symbols 220 edges 16 files 2 documented · 2% ● updated 8y ago★ 757 open issues

Browse by type

⨍ Functions 90 ◇ Types & classes 35

What it actually does AI analysis from the code graph — generated when you open this

loading…

Extension points exported contracts — how you extend this code

Consumer (Interface)

(no doc) [1 implementers]

consumer.go

OffsetStore (Interface)

(no doc) [1 implementers]

store.go

AllocateMessageQueueStrategy (Interface)

(no doc) [1 implementers]

rebalance.go

RemotingClient (Interface)

(no doc) [1 implementers]

MessageListener (FuncType)

(no doc)

consumer.go

InvokeCallback (FuncType)

(no doc)

remoting_client.go

Core symbols most depended-on inside this repo

findBrokerAddressInSubscribe

updateTopicRouteInfoFromNameServerByTopic

findBrokerAddrByTopic

called by 2

mqclient.go

Shape

Method 78

Struct 26

Function 12

Interface 5

FuncType 2

TypeAlias 2

Languages

Go100%

Modules by API surface

mqclient.go27 symbols

consumer.go25 symbols

remoting_client.go16 symbols

rebalance.go15 symbols

store.go10 symbols

admin.go8 symbols

message_queue.go6 symbols

remote_cmd.go5 symbols

pull_message.go5 symbols

message.go3 symbols

net.go2 symbols

net_test.go1 symbols

For agents

$ claude mcp add go_rocket_mq \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact

github.com/didapinchegit/go_rocket_mq @main

Extension points exported contracts — how you extend this code

Core symbols most depended-on inside this repo

Shape

Languages

Modules by API surface

For agents

Ask about this repo answers extend the page