Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/boltmq/boltmq
/ functions
Functions
1,049 in github.com/boltmq/boltmq
⨍
Functions
1,049
◇
Types & classes
145
Method
shutdown
()
namesrv/server/controller_task.go:48
Method
shutdown
()
store/persistent/index.go:315
Method
shutdown
()
store/persistent/allocate.go:170
Method
shutdown
shutdown 关闭队列,队列数据还在,但是不能访问
store/persistent/mapped_file_queue.go:537
Method
shutdown
()
store/persistent/schedule.go:95
Method
shutdown
()
store/persistent/store_checkpoint.go:75
Method
shutdown
()
store/persistent/reput_message.go:114
Method
shutdown
()
store/persistent/dispatch.go:74
Method
shutdown
()
store/persistent/commit_log.go:573
Method
shutdown
()
store/persistent/commit_log.go:710
Method
shutdown
()
store/persistent/commit_log.go:826
Method
shutdown
()
store/persistent/ha.go:339
Method
shutdown
(interrupt bool)
store/persistent/ha.go:408
Method
shutdown
()
store/persistent/ha.go:471
Method
shutdown
()
store/persistent/ha.go:720
Method
shutdown
()
store/persistent/ha.go:811
Method
shutdown
()
store/persistent/consume.go:90
Method
shutdown
shutdown 停止 Author rongzhihong Since 2017/9/5
broker/server/pull_request_hold_service.go:187
Method
shutdown
shutdown 停止定时扫描过期的连接的服务 Author rongzhihong Since 2017/9/8
broker/server/client_house_keeping_service.go:59
Method
shutdown
shutdown 停止检查Filter Server的定时任务 Author rongzhihong Since 2017/9/8
broker/server/filter_server_manager.go:70
Method
shutdown
()
broker/server/controller_tasks.go:45
Method
slice
slice 返回当前mappedByteBuffer.byteBuffer中从开始位置到len的分片buffer Author: tantexian, <tantexian@qq.com> Since: 2017/8/6
store/persistent/mapped_byte_buffer.go:123
Method
start
()
namesrv/server/controller_task.go:43
Method
start
()
store/persistent/index.go:102
Method
start
()
store/persistent/allocate.go:161
Method
start
()
store/persistent/schedule.go:91
Method
start
()
store/persistent/transaction.go:26
Method
start
()
store/persistent/reput_message.go:96
Method
start
()
store/persistent/dispatch.go:60
Method
start
()
store/persistent/commit_log.go:567
Method
start
()
store/persistent/commit_log.go:699
Method
start
()
store/persistent/commit_log.go:743
Method
start
()
store/persistent/ha.go:59
Method
start
()
store/persistent/ha.go:259
Method
start
()
store/persistent/ha.go:334
Method
start
()
store/persistent/ha.go:380
Method
start
()
store/persistent/ha.go:461
Method
start
()
store/persistent/ha.go:683
Method
start
()
store/persistent/ha.go:797
Method
start
()
store/persistent/consume.go:76
Method
start
start 启动入口 Author rongzhihong Since 2017/9/5
broker/server/pull_request_hold_service.go:177
Method
start
start 启动定时扫描过期的连接的服务 Author rongzhihong Since 2017/9/8
broker/server/client_house_keeping_service.go:47
Method
start
start 启动;定时检查Filter Server个数,数量不符合,则创建 Author rongzhihong Since 2017/9/8
broker/server/filter_server_manager.go:62
Method
truncateDirtyLogicFiles
(phyOffset int64)
store/persistent/message_store.go:359
Method
tryLock
tryLock 尝试锁住 Author rongzhihong Since 2017/9/20
broker/server/rebalance_manager.go:68
Method
unRegisterBroker
unRegisterBroker 卸载Broker
namesrv/server/route_info_manager.go:332
Function
unlock
(addr, len uintptr)
store/persistent/mmap/mmap_windows.go:107
Function
unmap
(addr, len uintptr)
store/persistent/mmap/mmap_windows.go:112
Method
updateMasterAddress
(newAddr string)
store/persistent/ha.go:765
← previous
1,001–1,049 of 1,049, ranked by callers