MCPcopy Create free account

hub / github.com/boltmq/boltmq / functions

Functions1,049 in github.com/boltmq/boltmq

⨍ Functions 1,049◇ Types & classes 145
↓ 1 callersMethodflush
()
store/persistent/store_checkpoint.go:80
↓ 1 callersMethodflush
()
store/persistent/mapped_file.go:248
↓ 1 callersMethodflushAllConfig
flushAllConfig 将配置信息刷入文件中 Author rongzhihong Since 2017/9/12
broker/server/controller.go:431
↓ 1 callersMethodforeach
(fn func(k string, v map[string]*channelInfo))
broker/server/producer_manager.go:304
↓ 1 callersMethodgenerateOffsetMovedEvent
generateOffsetMovedEvent 偏移量移动事件 Author rongzhihong Since 2017/9/17
broker/server/pull_message_processor.go:358
↓ 1 callersMethodgenerateRandmonNum
()
broker/server/producer_manager.go:48
↓ 1 callersFunctionget
remove 获得列表中某元素 Author rongzhihong Since 2017/9/17
broker/server/producer_manager.go:244
↓ 1 callersMethodgetAllClientId
getAllClientId 获得所有客户端ID Author rongzhihong Since 2017/9/14
broker/server/consumer_client.go:192
↓ 1 callersMethodgetAllClusterInfo
getAllClusterInfo 获得所有集群名称
namesrv/server/route_info_manager.go:61
↓ 1 callersMethodgetAllConsumerOffset
getAllConsumerOffset 所有消费者的偏移量 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:731
↓ 1 callersMethodgetAllDelayOffset
getAllDelayOffset 所有消费者的定时偏移量 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:752
↓ 1 callersMethodgetAllSubscriptionGroup
getAllSubscriptionGroup 获得所有消费分组 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:441
↓ 1 callersMethodgetAllTopicConfig
getAllTopicConfig 获得Topic配置信息 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:204
↓ 1 callersMethodgetAllTopicList
getAllTopicList 获取所有Topic列表
namesrv/server/route_info_manager.go:85
↓ 1 callersMethodgetAllTopicListFromNamesrv
getAllTopicListFromNamesrv 从Name Server获取全部Topic列表 Author: tianyuliang Since: 2017/9/6
namesrv/server/request_processor.go:194
↓ 1 callersMethodgetAndCreateLastIndexFile
()
store/persistent/index.go:185
↓ 1 callersMethodgetBrokerClusterInfo
getBrokerClusterInfo 获取注册到Name Server的所有Broker集群信息 Author: tianyuliang Since: 2017/9/6
namesrv/server/request_processor.go:232
↓ 1 callersMethodgetBrokerConfig
getBrokerConfig 获得Broker配置信息 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:248
↓ 1 callersMethodgetBrokerRuntimeInfo
getBrokerRuntimeInfo 获取Broker运行时信息 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:329
↓ 1 callersMethodgetConsumeStats
getConsumeStats 获得消费者统计信息 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:633
↓ 1 callersMethodgetConsumeStatus
getConsumeStatus Broker主动获取Consumer端的消息情况 Author rongzhihong Since 2017/9/18
broker/server/broker_client.go:178
↓ 1 callersMethodgetConsumerConnectionList
getConsumerConnectionList 获得消费者连接信息 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:543
↓ 1 callersMethodgetConsumerListByGroup
getConsumerListByGroup 通过Group获得消费列表 Author gaoyanlei Since 2017/8/25
broker/server/client_manage_processor.go:218
↓ 1 callersMethodgetConsumerRunningInfo
getConsumerRunningInfo 调用Consumer，获取Consumer内存数据结构，为监控以及定位问题 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:961
↓ 1 callersMethodgetConsumerStatus
getConsumerStatus Broker主动获取Consumer端的消息情况 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:789
↓ 1 callersFunctiongetDLQTopic
(path string)
broker/server/utils.go:57
↓ 1 callersMethodgetEarliestMsgStoretime
getEarliestMsgStoretime 获得最早消息存储时间 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:308
↓ 1 callersMethodgetFormatRuntime
()
stats/store_stats.go:188
↓ 1 callersMethodgetGetFoundTps
()
stats/store_stats.go:273
↓ 1 callersMethodgetGetMissTps
()
stats/store_stats.go:314
↓ 1 callersMethodgetGetTotalTps
()
stats/store_stats.go:355
↓ 1 callersMethodgetGetTransferedTps
()
stats/store_stats.go:416
↓ 1 callersMethodgetGroupChannelTable
getgroupChannelTable 获得组通道 Author gaoyanlei Since 2017/8/24
broker/server/producer_manager.go:55
↓ 1 callersMethodgetHAServerAddr
getHAServerAddr 获得HAServer的地址 Author rongzhihong Since 2017/9/12
broker/server/controller.go:350
↓ 1 callersMethodgetHasUnitSubTopicList
getHasUnitSubTopicList 获取含有单元化订阅组的Topic列表 Author: tianyuliang Since: 2017/9/6
namesrv/server/request_processor.go:512
↓ 1 callersMethodgetHasUnitSubUnUnitTopicList
getHasUnitSubUnUnitTopicList 获取含有单元化订阅组的非单元化Topic列表 Author: tianyuliang Since: 2017/9/6
namesrv/server/request_processor.go:525
↓ 1 callersMethodgetKVConfigByValue
getKVConfigByValue 通过 project 获取所有的 server ip 信息 Author: tianyuliang Since: 2017/9/6
namesrv/server/request_processor.go:422
↓ 1 callersMethodgetLastOffset
()
store/persistent/consume_queue.go:360
↓ 1 callersFunctiongetMQHome
()
broker/config/parse.go:201
↓ 1 callersMethodgetMappedFileByTime
(timestamp int64)
store/persistent/mapped_file_queue.go:69
↓ 1 callersMethodgetMaxOffset
(ctx core.Context, request *protocol.RemotingCommand)
broker/server/admin_processor.go:167
↓ 1 callersMethodgetMinOffset
getMinOffset 获得最小偏移量 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:287
↓ 1 callersMethodgetMinTimestampIndex
()
store/persistent/store_checkpoint.go:88
↓ 1 callersFunctiongetNameSrvAddrs
()
broker/config/parse.go:144
↓ 1 callersMethodgetOffsetInQueueByTime
(timestamp int64)
store/persistent/consume_queue.go:196
↓ 1 callersMethodgetProducerConnectionList
getProducerConnectionList 获得生产者连接信息 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:592
↓ 1 callersMethodgetPutMessageDistributeTimeStringInfo
(total int64)
stats/store_stats.go:219
↓ 1 callersMethodgetPutTps
()
stats/store_stats.go:232
↓ 1 callersMethodgetRouteInfoByTopic
getRouteInfoByTopic 根据Topic获取BrokerName、队列数(包含读队列、写队列)，间接调用了RouteInfoManager.pickupTopicRouteData()方法来获取Broker和topic信息 Author: tianyuliang Since: 2017
namesrv/server/request_processor.go:244
↓ 1 callersMethodgetSystemProperty
(name string)
store/persistent/commit_log.go:1071
↓ 1 callersMethodgetSystemTopicList
getSystemTopicList 获取系统topic列表
namesrv/server/route_info_manager.go:725
↓ 1 callersMethodgetSystemTopicListFromBroker
getSystemTopicListFromBroker 从Broker获取系统Topic列表 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:926
↓ 1 callersMethodgetSystemTopicListFromNamesrv
getSystemTopicListFromNamesrv 获取所有系统内置Topic列表 Author: tianyuliang Since: 2017/9/6
namesrv/server/request_processor.go:486
↓ 1 callersMethodgetTopicStatsInfo
getTopicStatsInfo 获取Topic的存储统计信息(minOffset、maxOffset、lastUpdateTime) Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:481
↓ 1 callersMethodgetTopicsByCluster
getTopicsByCluster 获取指定集群下的全部Topic列表 Author: tianyuliang Since: 2017/9/6
namesrv/server/request_processor.go:467
↓ 1 callersMethodgetUnitTopicList
getUnitTopicList 获取单元化逻辑Topic列表 Author: tianyuliang Since: 2017/9/6
namesrv/server/request_processor.go:499
↓ 1 callersMethodhandleMessageBody
(masterPhyOffset int64, bodySize int32, msgbuf *bytes.Buffer)
store/persistent/ha.go:652
↓ 1 callersMethodheartBeat
heartBeat 心跳服务 Author gaoyanlei Since 2017/8/23
broker/server/client_manage_processor.go:62
↓ 1 callersMethodhowMuchFallBehind
howMuchFallBehind 刷盘进度落后了多少 Author: tantexian, <tantexian@qq.com> Since: 2017/8/8
store/persistent/mapped_file_queue.go:223
↓ 1 callersMethodincHashSlotCount
()
store/persistent/index.go:534
↓ 1 callersMethodincIndexCount
()
store/persistent/index.go:539
↓ 1 callersMethodindexKeyHashCode
(key string)
store/persistent/index.go:454
↓ 1 callersMethodindexKeyHashMethod
(key string)
store/persistent/index.go:445
↓ 1 callersMethodinit
()
broker/server/controller.go:142
↓ 1 callersMethodinit
()
broker/server/topic_config_manager.go:55
↓ 1 callersMethodinit
init 初始化subscriptionGroupManager Author gaoyanlei Since 2017/8/9
broker/server/subscription_group_manager.go:50
↓ 1 callersMethodinit
init init Author rongzhihong Since 2017/9/19
stats/moment_stats_item_set.go:115
↓ 1 callersFunctioninitClient
()
sample/net/remoting/benchmark/client/client.go:106
↓ 1 callersFunctioninitClient
()
sample/net/remoting/simple/client/client.go:111
↓ 1 callersFunctioninitServer
()
sample/net/remoting/benchmark/serve/server.go:77
↓ 1 callersFunctioninitServer
()
sample/net/remoting/simple/serve/serve.go:91
↓ 1 callersMethodisAbleToFlush
isAbleToFlush 根据最少需要刷盘page数值来判断当前是否需要立即刷新缓存数据到磁盘 Params: flushLeastPages一次刷盘最少个数 Return: 是否需要立即刷盘 Author: tantexian, <tantexian@qq.com> Since: 2017/8/
store/persistent/mapped_file.go:263
↓ 1 callersMethodisBrokerTopicConfigChanged
isBrokerTopicConfigChanged 判断Topic配置信息是否发生变更 Author: tianyuliang Since: 2017/9/6
namesrv/server/route_info_manager.go:218
↓ 1 callersFunctionisIntranetIpv4
(ip string)
broker/config/parse.go:193
↓ 1 callersFunctionisItTimeToDo
isItTimeToDo Author: zhoufei Since: 2017/10/13
store/persistent/utils.go:56
↓ 1 callersMethodisMappedFileMatchedRecover
(mf *mappedFile)
store/persistent/commit_log.go:472
↓ 1 callersMethodisOrderTopic
isOrderTopic 判断是否是顺序topic Author gaoyanlei Since 2017/8/10
broker/server/topic_config_manager.go:318
↓ 1 callersMethodisSpaceToDelete
()
store/persistent/commit_log.go:1126
↓ 1 callersMethodisTempFileExist
()
store/persistent/message_store.go:185
↓ 1 callersMethodisTheBatchFull
(sizePy, maxMsgNums, bufferTotal, messageTotal int32, isInDisk bool)
store/persistent/message_store.go:789
↓ 1 callersMethodisTimeToDelete
()
store/persistent/commit_log.go:1116
↓ 1 callersMethodisTimeToReportOffset
()
store/persistent/ha.go:515
↓ 1 callersMethodisTopicCanSendMessage
(topic string)
broker/server/topic_config_manager.go:135
↓ 1 callersMethodisWriteable
()
store/persistent/running_flags.go:36
↓ 1 callersFunctionlistFilesOrDir
listFilesOrDir 返回当前目录下所有的文件或者目录 Params: path 路径 Return: listType 从ALL|DIR|FILE选取，分别代表返回所有，目录，文件 Author: tantexian, <tantexian@qq.com> Since: 2017/8/8
store/persistent/utils.go:30
↓ 1 callersMethodload
load 加载kvConfig.json至kvConfigManager的configTable，即持久化转移到内存 Author: tianyuliang Since: 2017/9/6
namesrv/server/kv_config_manager.go:216
↓ 1 callersMethodloadConsumeQueue
()
store/persistent/message_store.go:195
↓ 1 callersFunctionlocalAddress
()
broker/config/parse.go:175
↓ 1 callersFunctionlock
(addr, len uintptr)
store/persistent/mmap/mmap_unix.go:55
↓ 1 callersMethodlockBatchMQ
lockBatchMQ 锁队列 Author rongzhihong Since 2017/9/19
broker/server/admin_processor.go:350
↓ 1 callersMethodlookMessageByOffset
(commitLogOffset int64, size int32)
store/persistent/message_store.go:833
↓ 1 callersMethodmakeIndexFileError
()
store/persistent/running_flags.go:48
↓ 1 callersMethodmakeLogicsQueueError
()
store/persistent/running_flags.go:44
↓ 1 callersFunctionmergeConfig
(cfg *Config)
namesrv/config/parse.go:50
↓ 1 callersFunctionmergeConfig
(cfg *Config)
broker/config/parse.go:100
↓ 1 callersFunctionmmap
(len int, inprot, inflags, fd uintptr, off int64)
store/persistent/mmap/mmap_unix.go:23
↓ 1 callersMethodmmapOperation
()
store/persistent/allocate.go:120
↓ 1 callersMethodmsgCheck
msgCheck 校验msg Author gaoyanlei Since 2017/8/16
broker/server/send_message_processor.go:494
↓ 1 callersFunctionnewAcceptSocketService
(port int32, ha *haService)
store/persistent/ha.go:357
↓ 1 callersFunctionnewAdminBrokerProcessor
newAdminBrokerProcessor 初始化 Author gaoyanlei Since 2017/8/23
broker/server/admin_processor.go:46
← previousnext →401–500 of 1,049, ranked by callers