MCPcopy Create free account

hub / github.com/boltmq/boltmq / functions

Functions1,049 in github.com/boltmq/boltmq

⨍ Functions 1,049◇ Types & classes 145
↓ 2 callersMethodisLocked
isLocked 是否已被锁住 Author rongzhihong Since 2017/9/20
broker/server/rebalance_manager.go:47
↓ 2 callersMethodisWriteFull
()
store/persistent/index.go:377
↓ 2 callersFunctionmin
min int64 的最小值 Author rongzhihong Since 2017/9/18
broker/server/utils.go:28
↓ 2 callersFunctionnewAllocateRequest
(filePath string, fileSize int64)
store/persistent/allocate.go:37
↓ 2 callersFunctionnewChannelInfo
(ctx core.Context, clientId string, langCode, addr string, version int32)
broker/server/consumer_client.go:303
↓ 2 callersFunctionnewConfig
(storeRootDir string)
store/persistent/config.go:100
↓ 2 callersFunctionnewConsumeQueue
(topic string, queueId int32, storePath string, mfSize int64, messageStore *PersistentMessageStore)
store/persistent/consume_queue.go:40
↓ 2 callersFunctionnewConsumeQueueTable
()
store/persistent/message_store.go:45
↓ 2 callersFunctionnewIndexFile
(fileName string, hashSlotNum, indexNum int32, endPhyOffset, endTimestamp int64)
store/persistent/index.go:333
↓ 2 callersFunctionnewMappedBufferResult
(startOffset int64, byteBuffer *mappedByteBuffer, size int32, mfile *mappedFile)
store/persistent/mapped_buffer_result.go:33
↓ 2 callersFunctionnewMappedFileQueue
newMappedFileQueue create mapped file queue
store/persistent/mapped_file_queue.go:54
↓ 2 callersFunctionnewProducerGroupConnTable
()
broker/server/producer_manager.go:260
↓ 2 callersFunctionnewScheduleMessageService
(messageStore *PersistentMessageStore)
store/persistent/schedule.go:39
↓ 2 callersMethodnotifyMessageArriving
notifyMessageArriving 消息到来通知 Author rongzhihong Since 2017/9/5
broker/server/pull_request_hold_service.go:111
↓ 2 callersFunctionoffset2FileName
offset2FileName 格式化位20个字符长度的string Author: tantexian, <tantexian@qq.com> Since: 2017/8/9
store/persistent/utils.go:80
↓ 2 callersMethodparseFloatProperty
(propertyName string, defaultValue float64)
store/persistent/commit_log.go:1055
↓ 2 callersMethodprintAllPeriodically
printAllPeriodically 定期打印当前类的数据结构(常用于业务调试) Author: tianyuliang Since: 2017/9/6
namesrv/server/route_info_manager.go:640
↓ 2 callersMethodprintAtMinutes
printAtMinutes 打印 Author rongzhihong Since 2017/9/19
stats/moment_stats_item_set.go:60
↓ 2 callersMethodprintFlushProgress
()
store/persistent/commit_log.go:785
↓ 2 callersMethodprintbrokerLiveTable
printbrokerLiveTable 打印rim.brokerLiveTable 数据
namesrv/server/route_info_manager.go:693
↓ 2 callersMethodprocessRequest
(request *protocol.RemotingCommand, ctx core.Context, brokerAllowSuspend bool)
broker/server/pull_message_processor.go:88
↓ 2 callersMethodputDispatchRequest
(dRequest *dispatchRequest)
store/persistent/message_store.go:355
↓ 2 callersMethodputMessagePostionInfo
(offset, size, tagsCode, cqOffset int64)
store/persistent/consume_queue.go:301
↓ 2 callersMethodputRequest
(request *groupCommitRequest)
store/persistent/commit_log.go:640
↓ 2 callersMethodrecover
(lastExitOK bool)
store/persistent/message_store.go:269
↓ 2 callersMethodremoveConnection
(haConn *haConnection)
store/persistent/ha.go:778
↓ 2 callersMethodreportSlaveMaxOffset
(maxOffset int64)
store/persistent/ha.go:566
↓ 2 callersMethodresetMsgStoreItemMemory
(length int32)
store/persistent/commit_log.go:1015
↓ 2 callersMethodretryGetAndCreateIndexFile
()
store/persistent/index.go:164
↓ 2 callersMethodrun
()
store/persistent/commit_log.go:1076
↓ 2 callersMethodshutdown
()
store/persistent/ha.go:304
↓ 2 callersMethodstartDeleteTopicTask
startDeleteTopicTask 清除未使用Topic Author: tianyuliang Since: 2017/10/10
broker/server/controller_tasks.go:96
↓ 2 callersMethodupdateMasterAddress
(newAddr string)
store/persistent/ha.go:505
↓ 2 callersMethodwakeupCustomer
(flushOK bool)
store/persistent/commit_log.go:600
↓ 2 callersMethodwhichTopicByConsumer
whichTopicByConsumer 获得消费者的Topic Author rongzhihong Since 2017/9/18
broker/server/consumer_offset_manager.go:171
↓ 1 callersMethodAddManyPullRequest
AddManyPullRequest 插入请求列表 Author rongzhihong Since 2017/9/5
broker/server/longpolling/many_pull_request.go:41
↓ 1 callersMethodAddMessage
(bufferResult BufferResult)
store/get_message.go:105
↓ 1 callersMethodAddPullRequest
AddPullRequest 插入请求 Author rongzhihong Since 2017/9/5
broker/server/longpolling/many_pull_request.go:31
↓ 1 callersMethodAppendToCommitLog
数据复制使用：获取CommitLog数据
store/message_store.go:47
↓ 1 callersMethodBrokerStats
()
store/message_store.go:58
↓ 1 callersFunctionCallShell
callShell 执行命令 Author rongzhihong Since 2017/9/8
broker/server/utils.go:38
↓ 1 callersMethodCheckInDiskByConsumeOffset
批量获取 messageId
store/message_store.go:55
↓ 1 callersMethodCleanExpiredConsumerQueue
()
store/message_store.go:53
↓ 1 callersMethodCleanUnusedTopic
Slave落后Master多少，单位字节
store/message_store.go:52
↓ 1 callersMethodCloneListAndClear
CloneListAndClear 克隆并清空请求列表 Author rongzhihong Since 2017/9/5
broker/server/longpolling/many_pull_request.go:51
↓ 1 callersMethodConsumeMessageBefore
(context *ConsumeMessageContext)
broker/trace/consume_message_hook.go:21
↓ 1 callersMethodConsumerSendMsgBack
consumerSendMsgBack 客户端返回未消费消息 Author gaoyanlei Since 2017/8/17
broker/server/send_message_processor.go:77
↓ 1 callersMethodContexts
()
sample/net/core/multi/client/client.go:68
↓ 1 callersFunctionDiskUsage
DiskUsage get disk usage
common/statfs/statfs.go:23
↓ 1 callersFunctionDoResponse
(ctx core.Context, request *protocol.RemotingCommand, response *protocol.RemotingCommand)
broker/server/send_message_processor.go:567
↓ 1 callersMethodEncodeBody
EncodeBody 将MessageBufferList存入Body中 Author rongzhihong Since 2017/9/17
broker/server/pagecache/query_message_transfer.go:45
↓ 1 callersMethodEncodeBody
EncodeBody 将MessageBufferList存入Body中 Author rongzhihong Since 2017/9/17
broker/server/pagecache/one_message_transfer.go:43
↓ 1 callersMethodEncodeBody
EncodeBody 将MessageBufferList存入Body中 Author rongzhihong Since 2017/9/17
broker/server/pagecache/many_message_transfer.go:45
↓ 1 callersMethodEncodeScheduleMsg
判断消息是否在磁盘
store/message_store.go:56
↓ 1 callersMethodExecuteConsumeMessageHookAfter
ExecuteConsumeMessageHookAfter 消费消息后执行回调 Author rongzhihong Since 2017/9/5
broker/server/send_message_processor.go:412
↓ 1 callersMethodExecuteConsumeMessageHookAfter
ExecuteConsumeMessageHookAfter 消费消息后执行的回调函数 Author rongzhihong Since 2017/9/14
broker/server/client_manage_processor.go:269
↓ 1 callersMethodExecuteSendMessageHookAfter
ExecuteSendMessageHookAfter 发送消息后执行回调函数 Author rongzhihong Since 2017/9/11
broker/server/send_message_processor.go:622
↓ 1 callersMethodExecuteSendMessageHookBefore
ExecuteSendMessageHookBefore 发送消息前执行回调函数 Author rongzhihong Since 2017/9/11
broker/server/send_message_processor.go:595
↓ 1 callersMethodFetchNSAddr
()
broker/client/top_addr.go:45
↓ 1 callersMethodFetchNameServerAddr
FetchNameServerAddr 获取NameServerAddr Author gaoyanlei Since 2017/8/22
broker/client/call_outer_service.go:84
↓ 1 callersMethodGetAllConsumerOffset
GetAllConsumerOffset 获取所有Consumer Offset Author gaoyanlei Since 2017/8/22
broker/client/call_outer_service.go:245
↓ 1 callersMethodGetAllDelayOffset
GetAllDelayOffset 获取所有DelayOffset Author gaoyanlei Since 2017/8/22
broker/client/call_outer_service.go:269
↓ 1 callersMethodGetAllSubscriptionGroupConfig
GetAllSubscriptionGroupConfig 获取订阅组配置 Author gaoyanlei Since 2017/8/22
broker/client/call_outer_service.go:286
↓ 1 callersMethodGetAllTopicConfig
GetAllTopicConfig 获取全部topic信息 Author gaoyanlei Since 2017/8/22
broker/client/call_outer_service.go:221
↓ 1 callersMethodGetAndCreateStatsItem
GetAndCreateStatsItem GetAndCreateStatsItem Author rongzhihong Since 2017/9/19
stats/moment_stats_item_set.go:90
↓ 1 callersMethodGetCommitLogData
(offset int64)
store/message_store.go:46
↓ 1 callersMethodGetMessage
(group string, topic string, queueId int32, offset int64, maxMsgNums int32, subscriptionData *heartbeat.Subscr
store/message_store.go:31
↓ 1 callersMethodGetMsgGetTotalTodayMorning
()
stats/broker_stats_related_store.go:21
↓ 1 callersMethodGetMsgGetTotalTodayNow
()
stats/broker_stats_related_store.go:20
↓ 1 callersMethodGetMsgGetTotalYesterdayMorning
()
stats/broker_stats_related_store.go:22
↓ 1 callersMethodGetMsgPutTotalTodayMorning
()
stats/broker_stats_related_store.go:23
↓ 1 callersMethodGetMsgPutTotalTodayNow
()
stats/broker_stats_related_store.go:19
↓ 1 callersMethodGetMsgPutTotalYesterdayMorning
()
stats/broker_stats_related_store.go:24
↓ 1 callersMethodHasConsumeMessageHook
HasConsumeMessageHook 判断是否存在消费消息回调 Author rongzhihong Since 2017/9/5
broker/server/send_message_processor.go:398
↓ 1 callersMethodHasSendMessageHook
HasSendMessageHook 判断是否存在发送消息回调 Author rongzhihong Since 2017/9/5
broker/server/send_message_processor.go:384
↓ 1 callersMethodIncBrokerGetNums
(incValue int)
stats/broker_stats.go:43
↓ 1 callersMethodIncBrokerPutNums
()
stats/broker_stats.go:42
↓ 1 callersMethodIncGroupGetNums
(group, topic string, incValue int)
stats/broker_stats.go:40
↓ 1 callersMethodIncGroupGetSize
(group, topic string, incValue int)
stats/broker_stats.go:41
↓ 1 callersMethodIncSendBackNums
(group, topic string)
stats/broker_stats.go:44
↓ 1 callersMethodIncTopicPutNums
(topic string)
stats/broker_stats.go:38
↓ 1 callersMethodIncTopicPutSize
(topic string, size int64)
stats/broker_stats.go:39
↓ 1 callersMethodIsMessageMatched
(subscriptionData *heartbeat.SubscriptionData, tagsCode int64)
store/persistent/message_filter.go:26
↓ 1 callersMethodIsOk
()
store/put_message.go:63
↓ 1 callersMethodIsWaitStoreMsgOK
()
store/message_ext_inner.go:32
↓ 1 callersMethodMarshalJSONBuf
MarshalJSONBuf marshal buff to json - template
broker/server/offset_table_ffjson.go:38
↓ 1 callersFunctionNewClock
(precision int64)
store/persistent/clock.go:30
↓ 1 callersFunctionNewKVConfigSerializeWrapper
NewKVConfigSerializeWrapper 初始化KV配置 Author: tianyuliang Since: 2017/9/4
namesrv/server/kv_config_serialize_wrapper.go:26
↓ 1 callersFunctionNewMomentStatsItem
NewMomentStatsItem 初始化结构体 Author rongzhihong Since 2017/9/19
stats/moment_stats_item_set.go:38
↓ 1 callersFunctionNewMomentStatsItemSet
NewMomentStatsItemSet 初始化 Author rongzhihong Since 2017/9/17
stats/moment_stats_item_set.go:77
↓ 1 callersFunctionNewSendMessageProcessor
(brokerController *BrokerController)
broker/server/send_message_processor.go:49
↓ 1 callersFunctionNewStatsItem
NewStatsItem 统计单元初始化 Author rongzhihong Since 2017/9/19
stats/stats_item_set.go:42
↓ 1 callersMethodPut
(k string, v map[string]*channelInfo)
broker/server/producer_manager.go:273
↓ 1 callersMethodPutAll
PutAll 同步Offset配置文件 Author rongzhihong Since 2017/9/18
broker/server/offset_table.go:93
↓ 1 callersMethodQueryMessage
(topic string, key string, maxNum int32, begin int64, end int64)
store/message_store.go:49
↓ 1 callersMethodQueryMessage
ProcessRequest 查询请求 Author rongzhihong Since 2017/9/18
broker/server/query_message_processor.go:59
↓ 1 callersMethodReadInt16
()
store/buffer_result.go:34
↓ 1 callersMethodReadInt8
()
store/buffer_result.go:33
↓ 1 callersMethodRecord
()
stats/broker_stats_related_store.go:18
↓ 1 callersMethodRecordDiskFallBehind
(group, topic string, queueId int32, fallBehind int64)
stats/broker_stats.go:46
← previousnext →201–300 of 1,049, ranked by callers