MCPcopy Create free account

hub / github.com/boltmq/boltmq / functions

Functions1,049 in github.com/boltmq/boltmq

⨍ Functions 1,049◇ Types & classes 145
MethodOnContextConnect
(ctx core.Context)
sample/net/core/simple/client/client.go:30
MethodOnContextConnect
(ctx core.Context)
sample/net/core/simple/serve/serve.go:29
MethodOnContextConnect
OnContextConnect 监听通道连接 Author rongzhihong Since 2017/9/8
broker/server/client_house_keeping_service.go:91
MethodOnContextError
OnContextError Channel出现异常,通知Topic路由管理器，清除无效Broker Author: tianyuliang Since: 2017/9/6
namesrv/server/broker_house_keeping_listener.go:63
MethodOnContextError
(ctx core.Context, err error)
sample/net/remoting/benchmark/serve/server.go:64
MethodOnContextError
(ctx core.Context, err error)
sample/net/remoting/simple/serve/serve.go:78
MethodOnContextError
(ctx core.Context, err error)
sample/net/core/multi/client/client.go:62
MethodOnContextError
(ctx core.Context, err error)
sample/net/core/multi/serve/serve.go:48
MethodOnContextError
(ctx core.Context, err error)
sample/net/core/simple/client/client.go:43
MethodOnContextError
(ctx core.Context, err error)
sample/net/core/simple/serve/serve.go:37
MethodOnContextError
OnContextError 监听通道异常 Author rongzhihong Since 2017/9/8
broker/server/client_house_keeping_service.go:108
MethodOnContextIdle
OnContextIdle Channe的Idle时间超时,通知Topic路由管理器，清除无效Brokers Author: tianyuliang Since: 2017/9/6
namesrv/server/broker_house_keeping_listener.go:76
MethodOnContextIdle
(ctx core.Context)
sample/net/remoting/benchmark/serve/server.go:68
MethodOnContextIdle
(ctx core.Context)
sample/net/remoting/simple/serve/serve.go:82
MethodOnContextIdle
OnContextIdle 监听通道闲置 Author rongzhihong Since 2017/9/8
broker/server/client_house_keeping_service.go:118
FunctionParseBrokerRoleType
(desc string)
store/persistent/config.go:223
FunctionParseConfig
ParseConfig 解析配置文件
namesrv/config/parse.go:23
FunctionParseFlushDiskType
(desc string)
store/persistent/config.go:255
MethodProcessRequest
ProcessRequest 默认请求处理器 Author: tianyuliang Since: 2017/9/6
namesrv/server/request_processor.go:52
MethodProcessRequest
(ctx core.Context, request *protocol.RemotingCommand)
sample/net/remoting/benchmark/serve/server.go:32
MethodProcessRequest
(ctx core.Context, request *protocol.RemotingCommand)
sample/net/remoting/simple/serve/serve.go:33
MethodProcessRequest
(ctx core.Context, request *protocol.RemotingCommand)
sample/net/remoting/simple/serve/serve.go:53
MethodProcessRequest
ProcessRequest 请求入口 Author rongzhihong Since 2017/8/23
broker/server/admin_processor.go:56
MethodProcessRequest
(ctx core.Context, request *protocol.RemotingCommand)
broker/server/send_message_processor.go:56
MethodProcessRequest
(ctx core.Context, request *protocol.RemotingCommand)
broker/server/client_manage_processor.go:43
MethodProcessRequest
ProcessRequest 请求 Author rongzhihong Since 2017/9/18
broker/server/query_message_processor.go:45
MethodProcessRequest
ProcessRequest 请求 Author rongzhihong Since 2017/9/18
broker/server/transaction_processor.go:48
MethodProcessRequest
(ctx core.Context, request *protocol.RemotingCommand)
broker/server/pull_message_processor.go:55
MethodPut
(key *message.MessageQueue, value *LockEntry)
broker/rebalance/lock_entry_table.go:36
MethodPut
(key string, value *LockEntryTable)
broker/rebalance/mq_lock_table.go:34
MethodPut
put 存放消息 Author rongzhihong Since 2017/9/5
broker/server/longpolling/pull_request_table.go:48
MethodPutMessage
(msg *store.MessageExtInner)
store/persistent/message_store.go:556
MethodQueryMessage
(topic string, key string, maxNum int32, begin int64, end int64)
store/persistent/message_store.go:613
MethodReadInt16
()
store/persistent/mapped_byte_buffer.go:99
MethodReadInt32
()
store/persistent/mapped_byte_buffer.go:106
MethodReadInt64
()
store/persistent/mapped_byte_buffer.go:113
MethodReadInt8
()
store/persistent/mapped_byte_buffer.go:92
MethodRecord
Record 统计 Author rongzhihong Since 2017/9/12
stats/sstats/broker_stats_related_store_service.go:49
MethodRecordDiskFallBehind
RecordDiskFallBehind 记录 QueueId@Topic@Group 的offset落后数量 Author rongzhihong Since 2017/9/17
stats/broker_stats.go:182
MethodRegisterConsumeMessageHook
RegisterSendMessageHook 注册赋值消费消息回调 Author rongzhihong Since 2017/9/5
broker/server/send_message_processor.go:405
MethodRegisterConsumeMessageHook
RegisterConsumeMessageHook 注册回调函数 Author rongzhihong Since 2017/9/14
broker/server/client_manage_processor.go:262
MethodRegisterConsumeMessageHook
registerConsumeMessageHook 消费消息回调 Author rongzhihong Since 2017/9/11
broker/server/pull_message_processor.go:384
MethodRegisterSendMessageHook
RegisterSendMessageHook 注册赋值 Author rongzhihong Since 2017/9/11
broker/server/send_message_processor.go:588
MethodRegisterSendMessageHook
RegisterSendMessageHook 注册发送消息的回调 Author rongzhihong Since 2017/9/11
broker/server/controller.go:411
MethodRelease
Release
store/get_message.go:112
MethodRelease
()
store/persistent/mapped_buffer_result.go:42
MethodRemove
(key *message.MessageQueue)
broker/rebalance/lock_entry_table.go:53
MethodRemove
(key string)
broker/rebalance/mq_lock_table.go:51
MethodRemove
remove 删除消息 Author rongzhihong Since 2017/9/5
broker/server/longpolling/pull_request_table.go:72
MethodRunningDataInfo
通过物理队列Offset、size，查询消息。 如果发生错误，则返回null
store/message_store.go:39
MethodRunningDataInfo
()
store/persistent/message_store.go:1128
MethodRuntimeInfo
RuntimeInfo 获取运行时统计数据 Author: zhoufei Since: 2017/9/21
store/persistent/message_store.go:942
MethodRuntimeInfo
()
stats/store_stats.go:457
MethodSelectOneMessageByOffset
SelectOneMessageByOffset 通过物理队列Offset，查询消息。 如果发生错误，则返回null Author: zhoufei Since: 2017/9/20
store/persistent/message_store.go:888
MethodSelectOneMessageByOffsetAndSize
SelectOneMessageByOffsetAndSize 通过物理队列Offset、size，查询消息。 如果发生错误，则返回null Author: zhoufei Since: 2017/9/20
store/persistent/message_store.go:902
MethodSetDispatchMaxBuffer
(value int64)
stats/store_stats.go:546
MethodSetMessageEntireTimeMax
(value int64)
stats/store_stats.go:164
MethodSetMessageTimesTotalFound
(value int64)
stats/store_stats.go:560
MethodSetMessageTimesTotalMiss
(value int64)
stats/store_stats.go:564
MethodSetMessageTransferedMsgCount
(value int64)
stats/store_stats.go:556
MethodSetPutMessageEntireTimeMax
(value int64)
stats/store_stats.go:502
MethodSetPutMessageFailedTimes
(value int64)
stats/store_stats.go:552
MethodSetSinglePutMessageTopicSizeTotal
(topic string, value int64)
stats/store_stats.go:482
MethodSetSinglePutMessageTopicTimesTotal
(topic string, value int64)
stats/store_stats.go:526
MethodSetValue
SetValue statsKey的数值加value Author rongzhihong Since 2017/9/19
stats/moment_stats_item_set.go:107
MethodShutdown
Shutdown 关闭NamesrvController控制器 Author: tianyuliang Since: 2017/9/14
namesrv/server/controller.go:82
MethodShutdown
()
store/persistent/message_store.go:491
MethodShutdown
()
store/persistent/clock.go:62
MethodShutdown
Shutdown 关闭 Author gaoyanlei Since 2017/8/22
broker/client/call_outer_service.go:64
MethodShutdown
()
stats/broker_stats.go:36
MethodShutdown
Start brokerStatsService停止入口 Author rongzhihong Since 2017/9/12
stats/broker_stats.go:98
MethodShutdown
()
stats/store_stats.go:568
MethodSize
()
store/persistent/mapped_buffer_result.go:56
MethodSize
()
broker/server/offset_table.go:33
MethodSize
()
broker/server/producer_manager.go:266
MethodSize
size 消息集合长度 Author rongzhihong Since 2017/9/5
broker/server/longpolling/pull_request_table.go:38
MethodSlaveFallBehindMuch
SlaveFallBehindMuch Slave落后Master多少byte Author: zhoufei Since: 2017/9/21
store/persistent/message_store.go:1034
MethodStart
Start 启动Namesrv控制服务 Author: tianyuliang Since: 2017/9/14
namesrv/server/controller.go:74
MethodStart
()
store/persistent/message_store.go:416
MethodStart
()
store/persistent/clock.go:57
MethodStart
Start 启动 Author gaoyanlei Since 2017/8/22
broker/client/call_outer_service.go:54
MethodStart
Start brokerStatsService启动入口 Author rongzhihong Since 2017/9/12
stats/broker_stats.go:85
MethodStart
()
stats/store_stats.go:109
MethodStoreStats
()
store/persistent/message_store.go:1098
MethodString
()
store/get_message.go:44
MethodString
()
store/append_message.go:40
MethodString
()
store/persistent/schedule.go:112
MethodString
String
store/persistent/config.go:185
MethodString
()
store/persistent/config.go:210
FunctionString2File
(data []byte, flPath string)
common/file.go:57
MethodSwap
(i, j int)
store/persistent/index.go:47
FunctionTestDiskUsage
(t *testing.T)
common/statfs/statfs_test.go:20
FunctionTestEnsureDir
(t *testing.T)
common/file_test.go:45
FunctionTestFlags
(t *testing.T)
store/persistent/mmap/mmap_test.go:112
FunctionTestMappedFile_MMapBufferWithInt32
(t *testing.T)
store/persistent/mapped_file_test.go:71
FunctionTestMappedFile_Write
(t *testing.T)
store/persistent/mapped_file_test.go:50
FunctionTestNewMappedByteBuffer
(t *testing.T)
store/persistent/mapped_byte_buffer_test.go:20
FunctionTestNonZeroOffset
Test that we can map files from non-0 offsets The page size on most Unixes is 4KB, but on Windows it's 64KB
store/persistent/mmap/mmap_test.go:139
FunctionTestOpenMappedFile
(t *testing.T)
store/persistent/mapped_file_test.go:31
FunctionTestParentDirectory
(t *testing.T)
common/file_test.go:21
← previousnext →801–900 of 1,049, ranked by callers