MCPcopy Create free account

hub / github.com/boltmq/boltmq / functions

Functions1,049 in github.com/boltmq/boltmq

⨍ Functions 1,049◇ Types & classes 145
↓ 1 callersFunctionnewBasicSendMessageProcessor
newBasicSendMessageProcessor 初始化ConsumerOffsetManager Author gaoyanlei Since 2017/8/14
broker/server/send_message_processor.go:451
↓ 1 callersFunctionnewBroker2Client
newBroker2Client broker2Client Author gaoyanlei Since 2017/8/9
broker/server/broker_client.go:40
↓ 1 callersFunctionnewBrokerHouseKeepingListener
newBrokerHouseKeepingListener 初始化Broker活动检测服务 Author: tianyuliang Since: 2017/9/6
namesrv/server/broker_house_keeping_listener.go:29
↓ 1 callersFunctionnewBrokerStatsRelatedStoreService
newBrokerStatsRelatedStoreService 初始化broker统计 Author rongzhihong Since 2017/9/12
stats/sstats/broker_stats_related_store_service.go:40
↓ 1 callersFunctionnewBrokerStatsService
newBrokerStatsService 初始化 Author gaoyanlei Since 2017/8/18
stats/broker_stats.go:65
↓ 1 callersFunctionnewBytes
(size int)
store/persistent/mmap/mmap_test.go:271
↓ 1 callersFunctionnewCleanCommitLogService
(messageStore *PersistentMessageStore)
store/persistent/commit_log.go:1041
↓ 1 callersFunctionnewCleanConsumeQueueService
(messageStore *PersistentMessageStore)
store/persistent/consume.go:106
↓ 1 callersFunctionnewClientHouseKeepingService
newClientHouseKeepingService 初始化定期检查客户端连接的服务 Author rongzhihong Since 2017/9/8
broker/server/client_house_keeping_service.go:35
↓ 1 callersFunctionnewClientManageProcessor
newClientManageProcessor 初始化clientManageProcessor Author gaoyanlei Since 2017/8/9
broker/server/client_manage_processor.go:37
↓ 1 callersFunctionnewCommitLog
(messageStore *PersistentMessageStore)
store/persistent/commit_log.go:53
↓ 1 callersFunctionnewConsumerGroupInfo
(groupName string, consumeType heartbeat.ConsumeType, messageModel heartbeat.MessageModel, consumeFromWhere h
broker/server/consumer_client.go:73
↓ 1 callersFunctionnewConsumerManager
newConsumerManager 初始化ConsumerManager Author gaoyanlei Since 2017/8/9
broker/server/consumer_manager.go:37
↓ 1 callersFunctionnewConsumerOffsetManager
newConsumerOffsetManager 初始化consumerOffsetManager Author gaoyanlei Since 2017/8/9
broker/server/consumer_offset_manager.go:48
↓ 1 callersFunctionnewControllerTask
(controller *NameSrvController)
namesrv/server/controller_task.go:28
↓ 1 callersFunctionnewControllerTasks
(controller *BrokerController)
broker/server/controller_tasks.go:38
↓ 1 callersFunctionnewDefaultAppendMessageCallback
(size int32, clog *commitLog)
store/persistent/commit_log.go:859
↓ 1 callersFunctionnewDefaultConsumerIdsChangeListener
newDefaultConsumerIdsChangeListener 初始化 Author gaoyanlei Since 2017/8/9
broker/server/consumer_client.go:43
↓ 1 callersFunctionnewDefaultRequestProcessor
newDefaultRequestProcessor 初始化NameServer网络请求处理 Author: tianyuliang Since: 2017/9/6
namesrv/server/request_processor.go:42
↓ 1 callersFunctionnewDispatchMessageService
(putMsgIndexHightWater int32, messageStore *PersistentMessageStore)
store/persistent/dispatch.go:49
↓ 1 callersFunctionnewEndTransactionProcessor
newEndTransactionProcessor 初始化endTransactionProcessor Author rongzhihong Since 2017/9/18
broker/server/transaction_processor.go:39
↓ 1 callersFunctionnewFilterServerManager
newFilterServerManager 初始化filterServerManager Author rongzhihong Since 2017/9/8
broker/server/filter_server_manager.go:48
↓ 1 callersFunctionnewFlushConsumeQueueService
(messageStore *PersistentMessageStore)
store/persistent/consume.go:33
↓ 1 callersFunctionnewFlushRealTimeService
(clog *commitLog)
store/persistent/commit_log.go:732
↓ 1 callersFunctionnewGroupCommitRequest
(nextOffset int64)
store/persistent/commit_log.go:592
↓ 1 callersFunctionnewGroupCommitService
(clog *commitLog)
store/persistent/commit_log.go:629
↓ 1 callersFunctionnewGroupTransferService
(ha *haService)
store/persistent/ha.go:425
↓ 1 callersFunctionnewHAClient
(ha *haService)
store/persistent/ha.go:492
↓ 1 callersFunctionnewHAConnection
(ha *haService, connection *net.TCPConn)
store/persistent/ha.go:321
↓ 1 callersFunctionnewHAService
(messageStore *PersistentMessageStore)
store/persistent/ha.go:740
↓ 1 callersFunctionnewIndexHeader
(byteBuffer *mappedByteBuffer)
store/persistent/index.go:484
↓ 1 callersFunctionnewIndexService
(messageStore *PersistentMessageStore)
store/persistent/index.go:63
↓ 1 callersFunctionnewKVConfigManager
newKVConfigManager 初始化KV配置管理器 Author: tianyuliang Since: 2017/9/6
namesrv/server/kv_config_manager.go:39
↓ 1 callersFunctionnewOffsetTable
()
broker/server/offset_table.go:27
↓ 1 callersFunctionnewPersistentMessageStore
(config *Config, brokerStats stats.BrokerStats)
store/persistent/message_store.go:84
↓ 1 callersFunctionnewProducerManager
()
broker/server/producer_manager.go:38
↓ 1 callersFunctionnewPullMessageProcessor
newPullMessageProcessor 初始化pullMessageProcessor Author gaoyanlei Since 2017/8/9
broker/server/pull_message_processor.go:49
↓ 1 callersFunctionnewPullRequestHoldService
newPullRequestHoldService 初始化拉消息请求服务 Author rongzhihong Since 2017/9/5
broker/server/pull_request_hold_service.go:42
↓ 1 callersFunctionnewQueryMessageProcessor
newQueryMessageProcessor 初始化queryMessageProcessor Author rongzhihong Since 2017/9/18
broker/server/query_message_processor.go:36
↓ 1 callersFunctionnewReadSocketService
(connection *net.TCPConn, haConn *haConnection)
store/persistent/ha.go:48
↓ 1 callersFunctionnewRebalanceManager
newRebalanceManager 初始化 Author rongzhihong Since 2017/9/20
broker/server/rebalance_manager.go:38
↓ 1 callersFunctionnewReputMessageService
(messageStore *PersistentMessageStore)
store/persistent/reput_message.go:32
↓ 1 callersFunctionnewRouteInfoManager
newRouteInfoManager 初始化Topic路由管理器
namesrv/server/route_info_manager.go:48
↓ 1 callersFunctionnewSlaveSynchronize
newSlaveSynchronize 初始化SubscriptionGroupManager Author gaoyanlei Since 2017/8/9
broker/server/slave_synchronize.go:33
↓ 1 callersFunctionnewStoreStatsService
()
stats/store_stats.go:82
↓ 1 callersFunctionnewSubscriptionGroupManager
newSubscriptionGroupManager 创建subscriptionGroupManager Author gaoyanlei Since 2017/8/9
broker/server/subscription_group_manager.go:38
↓ 1 callersFunctionnewTopicConfigManager
newTopicConfigManager 初始化topicConfigManager Author gaoyanlei Since 2017/8/9
broker/server/topic_config_manager.go:44
↓ 1 callersFunctionnewTransactionCheckSupervisor
(brokerController *BrokerController)
broker/server/transaction_check_supervisor.go:25
↓ 1 callersFunctionnewTransactionService
(messageStore *PersistentMessageStore)
store/persistent/transaction.go:20
↓ 1 callersFunctionnewWriteSocketService
(connection *net.TCPConn, haConn *haConnection)
store/persistent/ha.go:176
↓ 1 callersFunctionnewbytes
(size int)
sample/net/remoting/benchmark/client/client.go:48
↓ 1 callersMethodnotify
()
store/persistent/reput_message.go:41
↓ 1 callersMethodnotifyConsumerIdsChanged
notifyConsumerIdsChanged 消费Id 列表改变通知 Author rongzhihong Since 2017/9/11
broker/server/broker_client.go:49
↓ 1 callersMethodnotifyTransferSome
(offset int64)
store/persistent/ha.go:785
↓ 1 callersMethodoffsetBehindMuchThanData
offsetBehindMuchThanData 检查偏移量与数据是否相差很大 Author rongzhihong Since 2017/9/12
broker/server/consumer_offset_manager.go:154
↓ 1 callersMethodparseRequestHeader
(request *protocol.RemotingCommand)
broker/server/send_message_processor.go:458
↓ 1 callersMethodpickProducerChannelRandomly
pickProducerChannelRandomly 事务消息 Author rongzhihong Since 2017/9/17
broker/server/producer_manager.go:201
↓ 1 callersMethodpickupTopicRouteData
pickupTopicRouteData 收集Topic路由数据
namesrv/server/route_info_manager.go:429
↓ 1 callersMethodprepareRuntimeInfo
prepareRuntimeInfo 组装运行中的Broker的信息 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:398
↓ 1 callersMethodprintAllPeriodically
printAllPeriodically 打印namesrv全局配置信息 Author: tianyuliang Since: 2017/9/6
namesrv/server/kv_config_manager.go:50
↓ 1 callersMethodprintAtDay
printAtHour 输出每天的统计数据 Author rongzhihong Since 2017/9/19
stats/stats_item_set.go:416
↓ 1 callersMethodprintAtHour
printAtHour 输出每小时的统计数据 Author rongzhihong Since 2017/9/19
stats/stats_item_set.go:404
↓ 1 callersMethodprintAtMinutes
printAtMinutes 输出每分钟数据 Author rongzhihong Since 2017/9/19
stats/moment_stats_item_set.go:126
↓ 1 callersMethodprintAtMinutes
printAtMinutes 输出每分钟的统计数据 Author rongzhihong Since 2017/9/19
stats/stats_item_set.go:392
↓ 1 callersMethodprintTps
()
stats/store_stats.go:153
↓ 1 callersMethodprintbrokerAddrTable
printbrokerAddrTable 打印rim.brokerAddrTable 数据
namesrv/server/route_info_manager.go:709
↓ 1 callersMethodprintclusterAddrTable
printclusterAddrTable 打印rim.clusterAddrTable 数据
namesrv/server/route_info_manager.go:670
↓ 1 callersMethodprocessRead
()
store/persistent/ha.go:601
↓ 1 callersMethodprocessReadEvent
()
store/persistent/ha.go:100
↓ 1 callersMethodputConsumeQueue
(topic string, queueId int32, cq *consumeQueue)
store/persistent/message_store.go:255
↓ 1 callersMethodputKVConfig
putKVConfig 向Namesrv追加KV配置 Author: tianyuliang Since: 2017/9/6
namesrv/server/request_processor.go:284
↓ 1 callersMethodputKey
(key string, phyOffset int64, storeTimestamp int64)
store/persistent/index.go:389
↓ 1 callersMethodputMessage
(msg *store.MessageExtInner)
store/persistent/commit_log.go:81
↓ 1 callersMethodputMessagePostionInfoWrapper
(offset, size, tagsCode, storeTimestamp, logicOffset int64)
store/persistent/consume_queue.go:281
↓ 1 callersMethodputRequest
(request interface{})
store/persistent/index.go:291
↓ 1 callersMethodputRequest
(request *dispatchRequest)
store/persistent/dispatch.go:84
↓ 1 callersMethodputRequestAndReturnMappedFile
(nextFilePath string, nextNextFilePath string, filesize int64)
store/persistent/mapped_file_queue.go:31
↓ 1 callersMethodqueryConsumeTimeSpan
queryConsumeTimeSpan 根据 topic 和 group 获取消息的相关时间(最早存储时间、最晚存储时间、最新消费时间) Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:863
↓ 1 callersMethodqueryConsumerOffset
queryConsumerOffset 查询Consumer的偏移量 Author rongzhihong Since 2017/9/14
broker/server/client_manage_processor.go:140
↓ 1 callersMethodqueryCorrectionOffset
queryCorrectionOffset 查找被修正 offset (转发组件） Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:1002
↓ 1 callersMethodqueryMinOffsetInAllGroup
queryMinOffsetInAllGroup 查询所有组中最小偏移量 Author rongzhihong Since 2017/9/18
broker/server/consumer_offset_manager.go:217
↓ 1 callersMethodqueryOffset
(topic, key string, maxNum int32, begin, end int64)
store/persistent/index.go:286
↓ 1 callersMethodqueryOffsetByGroupAndTopic
queryOffsetByGroupAndTopic 获取group与topuic所有队列offset Author rongzhihong Since 2017/9/12
broker/server/consumer_offset_manager.go:126
↓ 1 callersMethodqueryTopicConsumeByWho
queryTopicConsumeByWho 查询Topic被哪些消费者消费 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:805
↓ 1 callersMethodreadConfig
readConfig 读取所有配置文件信息 Author rongzhihong Since 2017/9/12
broker/server/controller.go:437
↓ 1 callersMethodrecoverAbnormally
()
store/persistent/commit_log.go:400
↓ 1 callersMethodrecoverConsumeQueue
()
store/persistent/message_store.go:294
↓ 1 callersMethodrecoverNormally
()
store/persistent/commit_log.go:208
↓ 1 callersMethodrecoverTopicQueueTable
()
store/persistent/message_store.go:302
↓ 1 callersMethodredeleteHangedFile
()
store/persistent/commit_log.go:1206
↓ 1 callersMethodregisterBroker
registerBroker 注册旧版Broker(version < 3.0.11) Author: tianyuliang Since: 2017/9/6
namesrv/server/request_processor.go:345
↓ 1 callersMethodregisterBrokerWithFilterServer
registerBrokerWithFilterServer 注册新版本Broker，数据都是持久化的，如果存在则覆盖配置 Author: tianyuliang Since: 2017/9/6
namesrv/server/request_processor.go:102
↓ 1 callersMethodregisterConsumer
registerConsumer 注册Consumer Author gaoyanlei Since 2017/8/24
broker/server/consumer_manager.go:69
↓ 1 callersMethodregisterFilterServer
registerFilterServer 注册过滤器 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:840
↓ 1 callersMethodregisterProcessor
RegisterProcessor 注册默认的请求处理器 Author: tianyuliang Since: 2017/9/14
namesrv/server/controller.go:121
↓ 1 callersMethodregisterProcessor
registerProcessor 注册提供服务 Author gaoyanlei Since 2017/8/25
broker/server/controller.go:174
↓ 1 callersMethodregisterProducer
registerProducer producer注册 Author gaoyanlei Since 2017/8/24
broker/server/producer_manager.go:69
↓ 1 callersFunctionremove
remove 删除列表中某元素 Author rongzhihong Since 2017/9/17
broker/server/producer_manager.go:233
↓ 1 callersMethodremoveQueurFromTopicQueueTable
(topic string, queueId int32)
store/persistent/commit_log.go:281
↓ 1 callersMethodremoveTopicByBrokerName
removeTopicByBrokerName 根据brokerName移除它对应的Topic数据
namesrv/server/route_info_manager.go:400
← previousnext →501–600 of 1,049, ranked by callers