MCPcopy Create free account

hub / github.com/boltmq/boltmq / functions

Functions1,049 in github.com/boltmq/boltmq

⨍ Functions 1,049◇ Types & classes 145
↓ 88 callersMethodLock
Lock keeps the mapped region in physical memory, ensuring that it will not be swapped out.
store/persistent/mmap/mmap.go:96
↓ 88 callersMethodUnlock
Unlock reverses the effect of Lock, allowing the mapped region to potentially be swapped out. If m is already unlocked, aan error will result.
store/persistent/mmap/mmap.go:104
↓ 60 callersMethodLen
()
store/persistent/index.go:39
↓ 42 callersMethodString
()
broker/server/consumer_client.go:314
↓ 33 callersMethodGet
(k string)
broker/server/offset_table.go:46
↓ 33 callersMethodStart
()
stats/store_stats.go:28
↓ 31 callersMethodWrite
([]byte)
store/buffer_result.go:26
↓ 28 callersMethodBytes
()
store/buffer_result.go:24
↓ 28 callersMethodReadInt64
()
store/buffer_result.go:36
↓ 27 callersMethodString
()
store/put_message.go:32
↓ 26 callersMethodPut
(k string, v map[int]int64)
broker/server/offset_table.go:40
↓ 25 callersMethodReadInt32
()
store/buffer_result.go:35
↓ 23 callersMethodWriteInt32
(int32)
store/buffer_result.go:29
↓ 22 callersMethodRelease
()
store/buffer_result.go:17
↓ 20 callersMethodRead
([]byte)
store/buffer_result.go:32
↓ 20 callersMethodshutdown
()
store/persistent/commit_log.go:612
↓ 19 callersMethodWriteInt64
(int64)
store/buffer_result.go:30
↓ 18 callersMethodRemove
(index int)
stats/call_snapshot.go:72
↓ 18 callersMethodstart
()
store/persistent/commit_log.go:611
↓ 16 callersMethodSize
()
store/buffer_result.go:19
↓ 15 callersMethodNow
()
store/persistent/clock.go:53
↓ 15 callersFunctionnewMappedByteBuffer
(mMap mmap.MMap)
store/persistent/mapped_byte_buffer.go:32
↓ 15 callersMethodpersist
()
broker/server/config_manager.go:72
↓ 14 callersMethodString
String
broker/config/config.go:90
↓ 13 callersFunctionparseChannelRemoteAddr
(ctx core.Context)
broker/server/utils.go:61
↓ 12 callersMethodRemove
(k string)
broker/server/offset_table.go:58
↓ 9 callersMethoddoChannelCloseEvent
doChannelCloseEvent 通道关闭事件 Author rongzhihong Since 2017/9/17
broker/server/producer_manager.go:181
↓ 9 callersMethodfindConsumeQueue
(topic string, queueId int32)
store/persistent/message_store.go:328
↓ 9 callersMethodgetMaxOffset
()
store/persistent/commit_log.go:277
↓ 8 callersMethodFlush
Flush synchronizes the mapping's contents to the file's contents on disk.
store/persistent/mmap/mmap.go:110
↓ 8 callersMethodShutdown
()
stats/store_stats.go:29
↓ 8 callersMethodString
()
store/persistent/config.go:239
↓ 8 callersMethodUnmap
Unmap deletes the memory mapped region, flushes any remaining changes, and sets m to nil. Trying to read or write any remaining references to m after
store/persistent/mmap/mmap.go:121
↓ 8 callersMethoddestroy
(intervalForcibly int64)
store/persistent/index.go:460
↓ 8 callersMethodselectTopicConfig
selectTopicConfig 根据topic查找 Author gaoyanlei Since 2017/8/11
broker/server/topic_config_manager.go:145
↓ 7 callersMethodMaxOffsetInQueue
(topic string, queueId int32)
store/message_store.go:32
↓ 7 callersFunctionNewStatsItemSet
NewStatsItemSet 初始化某个统计维度的统计单元集合 Author rongzhihong Since 2017/9/19
stats/stats_item_set.go:236
↓ 7 callersMethodgetConsumerGroupInfo
(group string)
broker/server/consumer_manager.go:45
↓ 7 callersMethodgetMessage
(offset int64, size int32)
store/persistent/commit_log.go:185
↓ 7 callersFunctionnewMappedFile
newMappedFile 根据文件名新建mappedfile Author: tantexian, <tantexian@qq.com> Since: 2017/8/5
store/persistent/mapped_file.go:119
↓ 7 callersFunctionrecover
()
store/persistent/mmap/mmap_test.go:38
↓ 6 callersFunctionMap
Map maps an entire file into memory. If ANON is set in flags, f is ignored.
store/persistent/mmap/mmap.go:58
↓ 6 callersMethodappendMessage
appendMessage 向存储层追加数据，一般在SLAVE存储结构中使用 Params: data 追加数据 Return: 追加是否成功 Author: tantexian, <tantexian@qq.com> Since: 2017/8/6
store/persistent/mapped_file.go:209
↓ 6 callersMethodcomputeStatsData
computeStatsData 计算获得统计数据 Author rongzhihong Since 2017/9/19
stats/stats_item_set.go:55
↓ 6 callersMethodflush
()
store/persistent/index.go:366
↓ 6 callersMethodgetBrokerAddr
getBrokerAddr 获得brokerAddr Author rongzhihong Since 2017/9/5
broker/server/controller.go:343
↓ 6 callersFunctiongetCallSnapshotListByIndex
(csList *list.List, index int)
stats/store_stats.go:579
↓ 6 callersMethodgetLastMappedFile
getLastMappedFile 获取最后一个MappedFile对象，如果一个都没有，则新创建一个， 如果最后一个写满了，则新创建一个 Params: startOffset 如果创建新的文件，起始offset Author: tantexian, <tantexian@qq.com> Sinc
store/persistent/mapped_file_queue.go:243
↓ 6 callersMethodgetMinOffset
()
store/persistent/commit_log.go:267
↓ 6 callersFunctiongetTPS
(begin, end *callSnapshot)
stats/store_stats.go:572
↓ 6 callersFunctionopenFile
(flags int)
store/persistent/mmap/mmap_test.go:44
↓ 6 callersFunctionprepare
()
store/persistent/mmap/mmap_test.go:32
↓ 5 callersMethodAddValue
AddValue statsKey的统计单元数量增加 Author rongzhihong Since 2017/9/19
stats/stats_item_set.go:265
↓ 5 callersMethodBuffer
()
store/buffer_result.go:18
↓ 5 callersMethodGetMessageCount
GetMessageCount 获取message个数 Author gaoyanlei Since 2017/8/17
store/get_message.go:101
↓ 5 callersMethodMinOffsetInQueue
获取指定队列最大Offset 如果队列不存在，返回-1
store/message_store.go:33
↓ 5 callersMethodcommit
commit 消息提交刷盘 Params: flushLeastPages 一次刷盘最少个数 Return: flushPosition 当前刷盘位置 Author: tantexian, <tantexian@qq.com> Since: 2017/8/6
store/persistent/mapped_file.go:229
↓ 5 callersMethoddestroy
destroy 销毁队列，队列数据被删除，此函数有可能不成功
store/persistent/mapped_file_queue.go:542
↓ 5 callersMethodencode
(prettyFormat bool)
broker/server/config_manager.go:27
↓ 5 callersMethodgetIndexBuffer
(startIndex int64)
store/persistent/consume_queue.go:68
↓ 5 callersMethodheader
()
store/persistent/mmap/mmap.go:90
↓ 5 callersMethodload
()
store/persistent/index.go:362
↓ 5 callersMethodqueryOffset
queryOffset 获取group下topic queueId 的offset Author gaoyanlei Since 2017/9/10
broker/server/consumer_offset_manager.go:111
↓ 5 callersMethodregisterBrokerAll
registerBrokerAll 注册所有broker Author rongzhihong Since 2017/9/12
broker/server/controller.go:307
↓ 5 callersMethodrelease
()
store/persistent/mapped_file.go:379
↓ 5 callersMethodselectMappedBuffer
(pos int64)
store/persistent/mapped_file.go:318
↓ 4 callersMethodForeach
(fn func(k string, v map[int]int64))
broker/server/offset_table.go:71
↓ 4 callersMethodGet
(index int)
stats/call_snapshot.go:56
↓ 4 callersMethodGetAndCreateStatsItem
GetAndCreateStatsItem 创建、获得statsKey的统计单元 Author rongzhihong Since 2017/9/19
stats/stats_item_set.go:248
↓ 4 callersFunctionMapRegion
MapRegion maps part of a file into memory. The offset parameter must be a multiple of the system's page size. If length < 0, the entire file will be m
store/persistent/mmap/mmap.go:66
↓ 4 callersMethodMessageStoreTimeStamp
获取队列中最早的消息时间
store/message_store.go:44
↓ 4 callersFunctionNewStatsSnapshot
NewStatsSnapshot 初始化 Author rongzhihong Since 2017/9/19
stats/call_snapshot.go:95
↓ 4 callersMethodPutIfAbsent
putIfAbsent 不存在时，才存放消息 Author rongzhihong Since 2017/9/5
broker/server/longpolling/pull_request_table.go:88
↓ 4 callersMethodPutMessage
(msg *MessageExtInner)
store/message_store.go:30
↓ 4 callersMethodRead
Read reads the next len(p) bytes from the buffer or until the buffer is drained. The return value n is the number of bytes read. If the buffer has no
store/persistent/mapped_byte_buffer.go:86
↓ 4 callersMethodStoreStats
()
store/message_store.go:57
↓ 4 callersMethodUpdateNameServerAddressList
UpdateNameServerAddressList 更新nameService地址 Author gaoyanlei Since 2017/8/22
broker/client/call_outer_service.go:75
↓ 4 callersMethodWrite
Write appends the contents of data to the buffer
store/persistent/mapped_byte_buffer.go:46
↓ 4 callersMethodcloseMaster
()
store/persistent/ha.go:557
↓ 4 callersMethodcreateTopicInSendMessageBackMethod
createTopicInSendMessageBackMethod 该方法没有判断broker权限. Author gaoyanlei Since 2017/8/11
broker/server/topic_config_manager.go:224
↓ 4 callersMethoddeleteExpiredFile
deleteExpiredFile 删除过期文件只能从头开始删 Author: tantexian, <tantexian@qq.com> Since: 2017/8/7
store/persistent/mapped_file_queue.go:145
↓ 4 callersMethodfindMappedFileByOffset
findMappedFileByOffset
store/persistent/mapped_file_queue.go:462
↓ 4 callersMethodfindSubscriptionData
(group, topic string)
broker/server/consumer_manager.go:58
↓ 4 callersMethodgetAllChannel
getAllChannel 获得所有通道 Author rongzhihong Since 2017/9/11
broker/server/consumer_client.go:178
↓ 4 callersMethodgetEndPhyOffset
()
store/persistent/index.go:381
↓ 4 callersMethodgetGetFoundTpsByTime
(time int)
stats/store_stats.go:289
↓ 4 callersMethodgetGetMissTpsByTime
(time int)
stats/store_stats.go:330
↓ 4 callersMethodgetGetTransferedTpsByTime
(time int)
stats/store_stats.go:432
↓ 4 callersFunctiongetMappedFileByIndex
(mfs *list.List, index int)
store/persistent/consume_queue.go:110
↓ 4 callersMethodgetMaxOffsetInQueue
()
store/persistent/consume_queue.go:277
↓ 4 callersMethodgetPutTpsByTime
(time int)
stats/store_stats.go:248
↓ 4 callersMethodgetStoreHost
getStoreHost 获取StoreHost Author: tianyuliang Since: 2017/9/26
broker/server/controller.go:357
↓ 4 callersMethodhold
()
store/persistent/mapped_file.go:61
↓ 4 callersFunctionnewCallSnapshot
(timestamp, times int64)
stats/call_snapshot.go:29
↓ 4 callersMethodonChannelDestroy
onChannelDestroy Channel被关闭、Channel出现异常、Channe的Idle时间超时 Author: tianyuliang Since: 2017/9/6
namesrv/server/route_info_manager.go:526
↓ 4 callersMethodunmap
()
store/persistent/mapped_file.go:252
↓ 3 callersMethodConsumerIdsChanged
(group string, channels []core.Context)
broker/server/consumer_client.go:30
↓ 3 callersFunctionEnsureDir
(dirName string)
common/file.go:37
↓ 3 callersMethodGetStatsDataInMinute
GetStatsDataInDay 获得分钟统计数据 Author rongzhihong Since 2017/9/19
stats/stats_item_set.go:92
↓ 3 callersMethodHasWriteable
()
broker/config/config.go:85
next →1–100 of 1,049, ranked by callers