MCPcopy Create free account

hub / github.com/boltmq/boltmq / functions

Functions1,049 in github.com/boltmq/boltmq

⨍ Functions 1,049◇ Types & classes 145
↓ 1 callersMethodRegisterBroker
RegisterBroker 向nameService注册broker Author gaoyanlei Since 2017/8/22
broker/client/call_outer_service.go:99
↓ 1 callersMethodRegisterBrokerAll
RegisterBrokerAll 向nameservice注册所有broker Author gaoyanlei Since 2017/8/22
broker/client/call_outer_service.go:154
↓ 1 callersMethodRegisterConsumeMessageHook
RegisterConsumeMessageHook 注册消费消息的回调 Author rongzhihong Since 2017/9/11
broker/server/controller.go:290
↓ 1 callersMethodRegisterSendMessageHook
RegisterSendMessageHook 注册赋值发送消息回调 Author rongzhihong Since 2017/9/5
broker/server/send_message_processor.go:391
↓ 1 callersMethodRuntimeInfo
()
store/message_store.go:40
↓ 1 callersMethodRuntimeInfo
()
stats/store_stats.go:43
↓ 1 callersMethodSelectOneMessageByOffsetAndSize
通过物理队列Offset，查询消息。 如果发生错误，则返回null
store/message_store.go:38
↓ 1 callersMethodSendMessage
sendMessage 正常消息 Author gaoyanlei Since 2017/8/17
broker/server/send_message_processor.go:256
↓ 1 callersMethodSendMessageAfter
(context *SendMessageContext)
broker/trace/send_message_hook.go:22
↓ 1 callersMethodSendMessageBefore
(context *SendMessageContext)
broker/trace/send_message_hook.go:21
↓ 1 callersMethodSetDispatchMaxBuffer
(value int64)
stats/store_stats.go:40
↓ 1 callersMethodSetMessageEntireTimeMax
(value int64)
stats/store_stats.go:38
↓ 1 callersMethodSetMessageTimesTotalFound
(value int64)
stats/store_stats.go:36
↓ 1 callersMethodSetMessageTimesTotalMiss
(value int64)
stats/store_stats.go:37
↓ 1 callersMethodSetMessageTransferedMsgCount
(value int64)
stats/store_stats.go:35
↓ 1 callersMethodSetPutMessageEntireTimeMax
(value int64)
stats/store_stats.go:39
↓ 1 callersMethodSetPutMessageFailedTimes
(value int64)
stats/store_stats.go:34
↓ 1 callersMethodSetSinglePutMessageTopicSizeTotal
(topic string, value int64)
stats/store_stats.go:31
↓ 1 callersMethodSetSinglePutMessageTopicTimesTotal
(topic string, value int64)
stats/store_stats.go:33
↓ 1 callersMethodShutdown
()
store/message_store.go:28
↓ 1 callersMethodSlaveFallBehindMuch
()
store/message_store.go:51
↓ 1 callersMethodStart
Start 控制器的start启动入口 Author rongzhihong Since 2017/9/12
broker/server/controller.go:364
↓ 1 callersMethodTpsGroupGetNums
(group, topic string)
stats/broker_stats.go:45
↓ 1 callersMethodUnRegisterBroker
UnRegisterBroker 注销单个broker Author gaoyanlei Since 2017/8/22
broker/client/call_outer_service.go:182
↓ 1 callersMethodUnRegisterBrokerAll
UnRegisterBrokerAll 注销全部Broker Author gaoyanlei Since 2017/8/22
broker/client/call_outer_service.go:207
↓ 1 callersMethodUnmarshalJSONFFLexer
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
broker/server/offset_table_ffjson.go:73
↓ 1 callersMethodViewBrokerStatsData
ViewBrokerStatsData 查看Broker统计信息 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:1119
↓ 1 callersMethodViewMessageById
ProcessRequest 根据MsgId查询消息 Author rongzhihong Since 2017/9/18
broker/server/query_message_processor.go:99
↓ 1 callersMethodWriteInt16
(int16)
store/buffer_result.go:28
↓ 1 callersMethodWriteInt8
(int8)
store/buffer_result.go:27
↓ 1 callersMethodaddConnection
(haConn *haConnection)
store/persistent/ha.go:771
↓ 1 callersMethodaddScheduleTask
()
store/persistent/message_store.go:472
↓ 1 callersMethodappendData
(startOffset int64, data []byte)
store/persistent/commit_log.go:536
↓ 1 callersMethodbuildData
()
store/persistent/ha.go:219
↓ 1 callersMethodbuildIndex
(request interface{})
store/persistent/index.go:117
↓ 1 callersMethodbuildKey
(topic, key string)
store/persistent/index.go:160
↓ 1 callersMethodbuildMsgContext
(ctx core.Context, requestHeader *head.SendMessageRequestHeader)
broker/server/send_message_processor.go:481
↓ 1 callersMethodbuildNewFilterServerList
buildNewFilterServerList FilterServer地址列表 Author rongzhihong Since 2017/9/8
broker/server/filter_server_manager.go:186
↓ 1 callersMethodbuildRunningStats
(stats map[string]string)
store/persistent/schedule.go:52
↓ 1 callersMethodbuildStartCommand
buildStartCommand 组装CMD命令 Author rongzhihong Since 2017/9/8
broker/server/filter_server_manager.go:96
↓ 1 callersMethodbuildTopicConfigSerializeWrapper
buildTopicConfigSerializeWrapper 创建tpCfgSerialWrapper Author gaoyanlei Since 2017/8/11
broker/server/topic_config_manager.go:343
↓ 1 callersMethodcallClient
callClient 调用客户端 Author rongzhihong Since 2017/9/18
broker/server/broker_client.go:76
↓ 1 callersMethodcheckCommitLogFileSpace
()
store/persistent/commit_log.go:1142
↓ 1 callersMethodcheckConsumeQueueFileSpace
()
store/persistent/commit_log.go:1174
↓ 1 callersMethodcheckHoldRequest
checkHoldRequest 检查拉请求是否有数据，如有，则通知 Author rongzhihong Since 2017/9/5
broker/server/pull_request_hold_service.go:88
↓ 1 callersMethodcheckProducerTransactionState
checkProducerTransactionState Broker主动回查Producer事务状态，Oneway Author rongzhihong Since 2017/9/11
broker/server/broker_client.go:64
↓ 1 callersFunctionclean
(mbb *mappedByteBuffer)
store/persistent/mapped_byte_buffer.go:147
↓ 1 callersMethodcleanExpiredConsumeQueue
cleanExpiredConsumeQueue 删除失效消费队列 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:948
↓ 1 callersMethodcleanFilesPeriodically
()
store/persistent/message_store.go:481
↓ 1 callersMethodcleanup
(currentRef int64)
store/persistent/mapped_file.go:358
↓ 1 callersMethodclearNewLine
(str string)
broker/client/top_addr.go:88
↓ 1 callersMethodcloneGroupOffset
cloneGroupOffset 克隆cloneGroupOffset Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:1070
↓ 1 callersMethodcloneOffset
cloneOffset 克隆偏移量 Author rongzhihong Since 2017/9/18
broker/server/consumer_offset_manager.go:207
↓ 1 callersMethodcomputeDeliverTimestamp
(delayLevel int32, storeTimestamp int64)
store/persistent/schedule.go:73
↓ 1 callersMethodconnectMaster
()
store/persistent/ha.go:526
↓ 1 callersMethodconsumeMessageDirectly
consumeMessageDirectly 直接让客户端消费消息 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:1041
↓ 1 callersMethodcreateAndUpdateQueueData
createAndUpdateQueueData 创建或更新Topic的队列数据 业务逻辑: (1)每来一个Master，创建一个QueueData对象 (2)如果是新建topic，就是添加QueueData对象 (3)如果是修改topic，就是把旧的QueueData删除，加入新的 例如： A
namesrv/server/route_info_manager.go:283
↓ 1 callersMethodcreateFilterServer
createFilterServer 创建FilterServer Author rongzhihong Since 2017/9/8
broker/server/filter_server_manager.go:80
↓ 1 callersMethodcreateTempFile
()
store/persistent/message_store.go:445
↓ 1 callersMethodcreateTopicInSendMessageMethod
createTopicInSendMessageMethod 创建topic Author gaoyanlei Since 2017/8/10
broker/server/topic_config_manager.go:156
↓ 1 callersMethoddecode
(jsonString []byte)
broker/server/config_manager.go:29
↓ 1 callersFunctiondefaultBrokerIP
()
broker/config/parse.go:158
↓ 1 callersFunctiondefaultHaServerIP
()
broker/config/parse.go:149
↓ 1 callersFunctiondefaultValue
(envar string)
common/env.go:48
↓ 1 callersFunctiondelayLevel2QueueId
(delayLevel int32)
store/persistent/schedule.go:48
↓ 1 callersMethoddeleteExpiredFile
(expiredTime int64, deleteFilesInterval int32, intervalForcibly int64, cleanImmediately bool)
store/persistent/commit_log.go:511
↓ 1 callersMethoddeleteExpiredFileByOffset
deleteExpiredFileByOffset 根据物理队列最小Offset来删除逻辑队列 Params: offset 物理队列最小offset Params: unitsize ??? Author: tantexian, <tantexian@qq.com> Since: 17/8/9
store/persistent/mapped_file_queue.go:373
↓ 1 callersMethoddeleteExpiredFileByTime
deleteExpiredFileByTime 根据文件过期时间来删除物理队列文件 Return: 删除过期文件的数量 Author: tantexian, <tantexian@qq.com> Since: 17/8/9
store/persistent/mapped_file_queue.go:330
↓ 1 callersMethoddeleteExpiredFiles
(fls *list.List)
store/persistent/index.go:268
↓ 1 callersMethoddeleteExpiredFiles
()
store/persistent/commit_log.go:1081
↓ 1 callersMethoddeleteExpiredFiles
()
store/persistent/consume.go:117
↓ 1 callersMethoddeleteKVConfig
deleteKVConfig 从Namesrv删除KV配置 Author: tianyuliang Since: 2017/9/6
namesrv/server/request_processor.go:328
↓ 1 callersMethoddeleteKVConfigByValue
deleteKVConfigByValue 删除指定 project group 下的所有 server ip 信息 Author: tianyuliang Since: 2017/9/6
namesrv/server/request_processor.go:449
↓ 1 callersMethoddeleteLastMappedFile
deleteLastMappedFile 恢复时调用
store/persistent/mapped_file_queue.go:316
↓ 1 callersMethoddeleteSubscriptionGroup
deleteSubscriptionGroup 删除消费分组 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:461
↓ 1 callersMethoddeleteSubscriptionGroupConfig
deleteSubscriptionGroupConfig 删除某个订阅组的配置 Author rongzhihong Since 2017/9/18
broker/server/subscription_group_manager.go:130
↓ 1 callersMethoddeleteTopic
deleteTopic 删除Topic
namesrv/server/route_info_manager.go:76
↓ 1 callersMethoddeleteTopic
(ctx core.Context, request *protocol.RemotingCommand)
broker/server/admin_processor.go:184
↓ 1 callersMethoddeleteTopicConfig
deleteTopicConfig 删除topic Author gaoyanlei Since 2017/8/10
broker/server/topic_config_manager.go:329
↓ 1 callersMethoddeleteTopicInNamesrv
deleteTopicInNamesrv 从Namesrv删除Topic配置 Author: tianyuliang Since: 2017/9/6
namesrv/server/request_processor.go:176
↓ 1 callersMethoddestroy
()
store/persistent/dispatch.go:78
↓ 1 callersMethoddestroy
()
store/persistent/commit_log.go:809
↓ 1 callersMethoddestroy
()
store/persistent/ha.go:90
↓ 1 callersMethoddestroy
()
store/persistent/ha.go:291
↓ 1 callersMethoddestroyConnections
()
store/persistent/ha.go:753
↓ 1 callersFunctiondiskUsage
get Linux disk usage
common/statfs/statfs_unix.go:24
↓ 1 callersMethoddiskUtil
diskUtil 磁盘使用情况 Author rongzhihong Since 2017/9/16
broker/server/send_message_processor.go:423
↓ 1 callersMethoddoAppend
write MappedByteBuffer,and return How many bytes to write
store/persistent/mapped_file.go:41
↓ 1 callersMethoddoDispatch
(request *dispatchRequest)
store/persistent/dispatch.go:101
↓ 1 callersMethoddoWaitTransfer
()
store/persistent/ha.go:436
↓ 1 callersMethodendMessageTransaction
endMessageTransactions 消息事务 Author rongzhihong Since 2017/9/18
broker/server/transaction_processor.go:185
↓ 1 callersMethodexecuteConsumeMessageHookBefore
executeConsumeMessageHookBefore 消费消息前，执行回调 Author rongzhihong Since 2017/9/11
broker/server/pull_message_processor.go:391
↓ 1 callersMethodfetchNameServerAddr
(verbose bool, timeoutMills int64)
broker/client/top_addr.go:49
↓ 1 callersMethodfillPreBlank
(mf *mappedFile, untilWhere int64)
store/persistent/consume_queue.go:342
↓ 1 callersMethodfindChannel
findChannel 获得某个组某个消费Id对应的通道 Author rongzhihong Since 2017/9/18
broker/server/consumer_manager.go:219
↓ 1 callersMethodfindSubscriptionDataPlus
(topic string)
broker/server/consumer_client.go:85
↓ 1 callersMethodfixConfig
()
broker/server/controller.go:106
↓ 1 callersFunctionflush
(addr, len uintptr)
store/persistent/mmap/mmap_windows.go:84
↓ 1 callersFunctionflush
(addr, len uintptr)
store/persistent/mmap/mmap_unix.go:47
↓ 1 callersMethodflush
(idxFile *indexFile)
store/persistent/index.go:296
← previousnext →301–400 of 1,049, ranked by callers