Functions — github.com/boltmq/boltmq

hub / github.com/boltmq/boltmq / functions

Functions1,049 in github.com/boltmq/boltmq

⨍ Functions 1,049◇ Types & classes 145

↓ 3 callersMethodInit

Init 统计单元初始化 Author rongzhihong Since 2017/9/19

stats/stats_item_set.go:113

↓ 3 callersMethodIsExpired

()

broker/rebalance/lock_entry.go:46

↓ 3 callersMethodIsLocked

(clientId string)

broker/rebalance/lock_entry.go:54

↓ 3 callersMethodMaxPhyOffset

取运行时统计数据

store/message_store.go:41

↓ 3 callersFunctionPathExists

stats/call_snapshot.go:66

↓ 3 callersMethodcheckMessageAndReturnSize

(byteBuffer *mappedByteBuffer, checkCRC bool, readBody bool)

store/persistent/commit_log.go:288

↓ 3 callersMethodcopyMappedFiles

copyMappedFiles 获取当前mappedFiles列表中的副本slice Params: reservedMappedFiles 只有当mappedFiles列表中文件个数大于reservedMappedFiles才返回副本 Return: 返回大于等于reservedMappedFil

store/persistent/mapped_file_queue.go:98

↓ 3 callersMethoddeleteFile

(fileName string)

store/persistent/message_store.go:534

↓ 3 callersMethodexecuteRequestWhenWakeup

executeRequestWhenWakeup 唤醒拉取消息的请求 Author rongzhihong Since 2017/9/5

broker/server/pull_message_processor.go:62

↓ 3 callersMethodfindSubscriptionGroupConfig

findSubscriptionGroupConfig 查找订阅关系 Author gaoyanlei Since 2017/8/17

broker/server/subscription_group_manager.go:73

↓ 3 callersMethodgetFirstMappedFileOnLock

()

store/persistent/mapped_file_queue.go:530

↓ 3 callersMethodgetGetTotalTpsByTime

(time int)

stats/store_stats.go:371

↓ 3 callersMethodgetKVListByNamespace

getKVListByNamespace 获取指定Namespace所有的KV配置列表 Author: tianyuliang Since: 2017/9/6

namesrv/server/request_processor.go:151

↓ 3 callersMethodgetMinOffsetInQueue

()

store/persistent/consume_queue.go:273

↓ 3 callersMethodload

()

broker/server/config_manager.go:46

↓ 3 callersFunctionnewCallSnapshotPlus

()

stats/call_snapshot.go:44

↓ 3 callersFunctionnewConfigManagerLoader

(cfgManager configManager)

broker/server/config_manager.go:40

↓ 3 callersFunctionnewStoreCheckpoint

(scpPath string)

store/persistent/store_checkpoint.go:34

↓ 3 callersMethodpersist

persist 将内存中的namesrv配置项持久化到kvConfig.json文件 Author: tianyuliang Since: 2017/9/6

namesrv/server/kv_config_manager.go:69

↓ 3 callersMethodpickupStoretimestamp

(offset int64, size int32)

store/persistent/commit_log.go:253

↓ 3 callersMethodprintTopicQueueTable

printTopicQueueTable 打印rim.topicQueueTable 数据

namesrv/server/route_info_manager.go:650

↓ 3 callersFunctionremove

()

store/persistent/mapped_file_test.go:25

↓ 3 callersMethodrollNextFile

(offset int64)

store/persistent/commit_log.go:202

↓ 3 callersMethodscanNotActiveChannel

scanNotActiveChannel 扫描不活跃通道 Author rongzhihong Since 2017/9/17

broker/server/producer_manager.go:158

↓ 3 callersMethodswapRequests

()

store/persistent/commit_log.go:651

↓ 3 callersFunctiontimeMillisecondToHumanString

(t time.Time)

store/persistent/utils.go:48

↓ 3 callersMethodtruncateDirtyFiles

truncateDirtyFiles recover时调用，不需要加锁 Author: tantexian, <tantexian@qq.com> Since: 2017/8/7

store/persistent/mapped_file_queue.go:120

↓ 2 callersMethodConsumeMessageAfter

(context *ConsumeMessageContext)

broker/trace/consume_message_hook.go:22

↓ 2 callersMethodEarliestMessageTime

(topic string, queueId int32)

store/message_store.go:43

↓ 2 callersMethodForeachByWPerm

ForeachByWPerm 写操作迭代 Author rongzhihong Since 2017/10/17

broker/server/producer_manager.go:316

↓ 2 callersMethodGet

(k string)

broker/server/producer_manager.go:279

↓ 2 callersMethodGetGetMessageTransferedMsgCount

()

stats/store_stats.go:42

↓ 2 callersMethodGetPutMessageTimesTotal

()

stats/store_stats.go:41

↓ 2 callersMethodGetPutMessageTimesTotal

()

stats/store_stats.go:176

↓ 2 callersMethodGetSinglePutMessageTopicSizeTotal

(topic string)

stats/store_stats.go:30

↓ 2 callersMethodGetSinglePutMessageTopicTimesTotal

(topic string)

stats/store_stats.go:32

↓ 2 callersMethodGetStatsDataInDay

GetStatsDataInDay 获得天统计数据 Author rongzhihong Since 2017/9/19

stats/stats_item_set.go:106

↓ 2 callersMethodGetStatsDataInHour

GetStatsDataInDay 获得小时统计数据 Author rongzhihong Since 2017/9/19

stats/stats_item_set.go:99

↓ 2 callersMethodGetStatsItem

(statsName, statsKey string)

stats/broker_stats.go:37

↓ 2 callersMethodHasConsumeMessageHook

hasConsumeMessageHook 判断是否有回调函数 Author rongzhihong Since 2017/9/14

broker/server/client_manage_processor.go:255

↓ 2 callersMethodHasReadable

HasReadable 校验Broker是否有读权限 Author: tianyuliang Since: 2017/9/29

broker/config/config.go:81

↓ 2 callersMethodHasSendMessageHook

hasSendMessageHook 检查SendMessageHookList的长度 Author rongzhihong Since 2017/9/11

broker/server/send_message_processor.go:581

↓ 2 callersMethodHookName

()

broker/trace/send_message_hook.go:20

↓ 2 callersMethodLoad

()

store/message_store.go:26

↓ 2 callersMethodLookMessageByOffset

根据消息时间获取某个队列中对应的offset

store/message_store.go:36

↓ 2 callersMethodMessageIds

清除失效的消费队列

store/message_store.go:54

↓ 2 callersMethodOffsetInQueueByTime

(topic string, queueId int32, timestamp int64)

store/message_store.go:35

↓ 2 callersFunctionParentDirectory

(dir string)

common/file.go:22

↓ 2 callersFunctionParseConfig

ParseConfig 解析配置文件

broker/config/parse.go:38

↓ 2 callersMethodPrintAtDay

PrintAtDay 输出天统计 Author rongzhihong Since 2017/9/19

stats/stats_item_set.go:167

↓ 2 callersMethodPrintAtHour

PrintAtHour 输出小时统计 Author rongzhihong Since 2017/9/19

stats/stats_item_set.go:158

↓ 2 callersMethodPrintAtMinutes

PrintAtMinutes 输出分钟统计 Author rongzhihong Since 2017/9/19

stats/stats_item_set.go:149

↓ 2 callersMethodRemove

(k string)

broker/server/producer_manager.go:291

↓ 2 callersMethodRemoveByFlag

(fn func(k string, v map[int]int64) bool)

broker/server/offset_table.go:80

↓ 2 callersMethodSamplingInHour

SamplingInHour 小时统计单元 Author rongzhihong Since 2017/9/19

stats/stats_item_set.go:209

↓ 2 callersMethodSamplingInMinutes

SamplingInMinutes 分钟统计单元 Author rongzhihong Since 2017/9/19

stats/stats_item_set.go:192

↓ 2 callersMethodSamplingInSeconds

SamplingInSeconds 秒统计单元 Author rongzhihong Since 2017/9/19

stats/stats_item_set.go:176

↓ 2 callersMethodSelectOneMessageByOffset

通过物理队列Offset，查询消息。如果发生错误，则返回null

store/message_store.go:37

↓ 2 callersMethodShutdown

Shutdown BrokerController停止入口 Author rongzhihong Since 2017/9/12

broker/server/controller.go:211

↓ 2 callersMethodSize

()

stats/call_snapshot.go:50

↓ 2 callersMethodStart

()

store/message_store.go:27

↓ 2 callersMethodStart

()

stats/broker_stats.go:35

↓ 2 callersMethodUpdateHaMasterAddress

(newAddr string)

store/message_store.go:50

↓ 2 callersMethodappendMessageWithCallBack

appendMessageWithCallBack 向MappedBuffer追加消息 Return: appendNums 成功添加消息字节数 Author: tantexian, <tantexian@qq.com> Since: 2017/8/5

store/persistent/mapped_file.go:184

↓ 2 callersMethodbuildKey

buildKey 构造Key Author rongzhihong Since 2017/9/5

broker/server/pull_request_hold_service.go:53

↓ 2 callersMethodcallConsumer

callConsumer call Consumer Author rongzhihong Since 2017/9/19

broker/server/admin_processor.go:974

↓ 2 callersMethodcheckInDiskByCommitOffset

(offsetPy, maxOffsetPy int64)

store/persistent/message_store.go:784

↓ 2 callersMethodcommitOffset

CommitOffset 提交offset Author gaoyanlei Since 2017/9/10

broker/server/consumer_offset_manager.go:135

↓ 2 callersMethodconfigFilePath

()

broker/server/config_manager.go:31

↓ 2 callersFunctioncontains

contains 判断列表是否包含某元素 Author rongzhihong Since 2017/9/17

broker/server/producer_manager.go:221

↓ 2 callersMethodcorrectMinOffset

(phyMinOffset int64)

store/persistent/consume_queue.go:88

↓ 2 callersFunctioncreate2WriteFile

(data []byte, filePath string)

common/file.go:87

↓ 2 callersFunctiondefaultLocalAddress

()

broker/config/parse.go:167

↓ 2 callersFunctiondefaultRootDir

()

broker/config/parse.go:139

↓ 2 callersMethoddeleteExpiredFile

(offset int64)

store/persistent/index.go:238

↓ 2 callersMethoddestroyLogics

()

store/persistent/message_store.go:367

↓ 2 callersMethoddoCommit

()

store/persistent/commit_log.go:657

↓ 2 callersMethoddoFlush

(retryTimes int32)

store/persistent/consume.go:37

↓ 2 callersMethoddoReput

()

store/persistent/reput_message.go:51

↓ 2 callersMethodencodeOffsetTable

()

store/persistent/schedule.go:63

↓ 2 callersMethodfindSubscriptionDataCount

findSubscriptionDataCount 根据group查找订阅数量 Author rongzhihong Since 2017/9/18

broker/server/consumer_manager.go:186

↓ 2 callersFunctionfixPath

(path string)

broker/config/parse.go:119

↓ 2 callersMethodgetAndMakeDiskFull

()

store/persistent/running_flags.go:52

↓ 2 callersMethodgetAndMakeDiskOK

()

store/persistent/running_flags.go:58

↓ 2 callersMethodgetData

(offset int64)

store/persistent/commit_log.go:519

↓ 2 callersMethodgetDiskMaxUsedSpaceRatio

()

store/persistent/config.go:165

↓ 2 callersMethodgetEndTimestamp

()

store/persistent/index.go:385

↓ 2 callersMethodgetFirstMappedFile

()

store/persistent/mapped_file_queue.go:436

↓ 2 callersMethodgetKVConfig

getKVConfig 从Namesrv获取KV配置 Author: tianyuliang Since: 2017/9/6

namesrv/server/request_processor.go:301

↓ 2 callersMethodgetLastMappedFile2

()

store/persistent/mapped_file_queue.go:447

↓ 2 callersMethodgetMappedFileSizeConsumeQueue

()

store/persistent/config.go:160

↓ 2 callersMethodgetMinTimestamp

()

store/persistent/store_checkpoint.go:93

↓ 2 callersMethodgetPutMessageSizeTotal

()

stats/store_stats.go:207

↓ 2 callersFunctiongetRetryTopic

(path string)

broker/server/utils.go:53

↓ 2 callersMethodhasConsumeMessageHook

()

broker/server/pull_message_processor.go:351

↓ 2 callersMethodhostStringToBytes

(hostAddr string)

store/persistent/commit_log.go:994

↓ 2 callersMethodisAvailable

()

store/persistent/mapped_file.go:77

↓ 2 callersMethodisCleanupOver

()

store/persistent/mapped_file.go:81

↓ 2 callersMethodisFull

()

store/persistent/mapped_file.go:284

← previous next →101–200 of 1,049, ranked by callers