hub / github.com/boltmq/boltmq

github.com/boltmq/boltmq @main

Chat with this repo

repository ↗ · DeepWiki ↗ · + Follow

1,194 symbols 3,205 edges 118 files 522 documented · 44% ● updated 6y ago★ 52

Browse by type

⨍ Functions 1,049◇ Types & classes 145

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

MessageStore (Interface)

MessageStore 存储层对外提供的接口 Author zhoufei Since 2017/9/6 [1 implementers]

store/message_store.go

ByteBuffer (Interface)

ByteBuffer [1 implementers]

store/buffer_result.go

MessageFilter (Interface)

MessageFilter 消息过滤接口 Author zhoufei Since 2017/9/6 [1 implementers]

store/persistent/message_filter.go

BrokerStatsRelatedStore (Interface)

stats/broker_stats_related_store.go

ConsumeMessageHook (Interface)

ConsumeMessageHook 消费消息回调 Author rongzhihong Since 2017/9/5

broker/trace/consume_message_hook.go

ConsumerIdsChangeListener (Interface)

(no doc) [1 implementers]

broker/server/consumer_client.go

browse all types & interfaces →

Core symbols most depended-on inside this repo

↓ 23 filesByteBuffer

ByteBuffer

store/buffer_result.go

↓ 17 filesMessageStore

MessageStore 存储层对外提供的接口 Author zhoufei Since 2017/9/6

store/message_store.go

↓ 21 filesBufferResult

store/buffer_result.go

↓ 21 filesStoreStats

stats/store_stats.go

↓ 14 filesflushCommitLogService

store/persistent/commit_log.go

↓ 7 filesBrokerController

BrokerController broker服务控制器 Author gaoyanlei Since 2017/8/25

broker/server/controller.go

browse all functions →

Shape

Method 840

Function 209

Struct 122

Interface 14

TypeAlias 9

Languages

Go100%

Modules by API surface

store/persistent/commit_log.go60 symbols

store/persistent/message_store.go56 symbols

stats/store_stats.go53 symbols

store/persistent/ha.go49 symbols

store/persistent/index.go40 symbols

broker/server/admin_processor.go38 symbols

store/message_store.go34 symbols

stats/stats_item_set.go28 symbols

stats/broker_stats.go28 symbols

store/persistent/mapped_file_queue.go26 symbols

namesrv/server/route_info_manager.go25 symbols

store/persistent/mapped_file.go22 symbols

For agents

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

⬇ download graph artifact

github.com/boltmq/boltmq @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