Functions — github.com/boltmq/boltmq

hub / github.com/boltmq/boltmq / functions

Functions1,049 in github.com/boltmq/boltmq

⨍ Functions 1,049◇ Types & classes 145

↓ 1 callersMethodreportSlaveMaxOffsetPlus

()

store/persistent/ha.go:585

↓ 1 callersMethodresetMsgStoreItemMemory

(length int32)

store/persistent/consume_queue.go:443

↓ 1 callersMethodresetOffset

resetOffset 所有消费者的定时偏移量 Author rongzhihong Since 2017/9/19

broker/server/admin_processor.go:773

↓ 1 callersMethodretryDeleteFirstFile

(intervalForcibly int64)

store/persistent/commit_log.go:515

↓ 1 callersMethodrun

run 运行入口 Author rongzhihong Since 2017/9/5

broker/server/pull_request_hold_service.go:163

↓ 1 callersFunctionrunDaemon

(pidfile string)

namesrv/main.go:96

↓ 1 callersFunctionrunDaemon

(pidfile string)

broker/main.go:104

↓ 1 callersMethodrunTasks

runTasks 启动tasks任务 Author: tianyuliang Since: 2017/9/14

namesrv/server/controller.go:106

↓ 1 callersMethodsampling

()

stats/store_stats.go:125

↓ 1 callersMethodsamplingInHour

samplingInHour 每小时统计取样 Author rongzhihong Since 2017/9/19

stats/stats_item_set.go:380

↓ 1 callersMethodsamplingInMinutes

samplingInMinutes 每分钟统计取样 Author rongzhihong Since 2017/9/19

stats/stats_item_set.go:368

↓ 1 callersMethodsamplingInSeconds

samplingInSeconds 每秒统计取样 Author rongzhihong Since 2017/9/19

stats/stats_item_set.go:356

↓ 1 callersMethodscanExceptionChannel

scanExceptionChannel 扫描异常通道 Author rongzhihong Since 2017/9/8

broker/server/client_house_keeping_service.go:69

↓ 1 callersMethodscanNotActiveBroker

scanNotActiveBroker 清除2分钟接受不到心跳的broker列表 (1)NameServer会每10s，扫描一次这个brokerLiveTable变量 (2)如果发现上次更新时间距离当前时间超过了2分钟，则认为此broker死亡 Author: tianyuliang Since

namesrv/server/route_info_manager.go:494

↓ 1 callersMethodscanUnsubscribedTopic

scanUnsubscribedTopic 扫描被删除Topic，并删除该Topic对应的Offset Author gaoyanlei Since 2017/8/22

broker/server/consumer_offset_manager.go:88

↓ 1 callersMethodscheduleClockUpdating

(tick *time.Ticker)

store/persistent/clock.go:39

↓ 1 callersMethodsearchOffsetByTimestamp

searchOffsetByTimestamp 根据时间查询偏移量 Author rongzhihong Since 2017/9/19

broker/server/admin_processor.go:266

↓ 1 callersMethodselectMappedBufferByPosAndSize

(pos int64, size int32)

store/persistent/mapped_file.go:336

↓ 1 callersFunctionsendHearBeat

(addr string)

sample/net/remoting/simple/client/client.go:97

↓ 1 callersFunctionsendMsg

(rm *responseManager, sync bool, ctx core.Context, msg []byte)

sample/net/core/multi/client/client.go:197

↓ 1 callersMethodsetBeginPhyOffset

(beginPhyOffset int64)

store/persistent/index.go:524

↓ 1 callersMethodsetBeginTimestamp

(beginTimestamp int64)

store/persistent/index.go:514

↓ 1 callersMethodsetEndPhyOffset

(endPhyOffset int64)

store/persistent/index.go:529

↓ 1 callersMethodsetEndTimestamp

(endTimestamp int64)

store/persistent/index.go:519

↓ 1 callersMethodsetReputFromOffset

(offset int64)

store/persistent/reput_message.go:47

↓ 1 callersMethodshutdown

(intervalForcibly int64)

store/persistent/mapped_file.go:305

↓ 1 callersMethodshutdown

()

store/persistent/ha.go:86

↓ 1 callersMethodstartBrokerStatsRecordTask

startBrokerStatsRecordTask 定时统计broker各类信息 Author: tianyuliang Since: 2017/10/10

broker/server/controller_tasks.go:115

↓ 1 callersMethodstartFetchNameServerAddrTask

startFetchNameServerAddrTask 更新Namesrv地址列表 Author: tianyuliang Since: 2017/10/10

broker/server/controller_tasks.go:150

↓ 1 callersMethodstartPersistConsumerOffsetTask

startPersistConsumerOffsetTask 定时写入ConsumerOffset文件 Author: tianyuliang Since: 2017/10/10

broker/server/controller_tasks.go:127

↓ 1 callersMethodstartPrintMasterAndSlaveDiffTask

startPrintMasterAndSlaveDiffTask 启动“输出主从偏移量差值”任务 Author: tianyuliang Since: 2017/10/10

broker/server/controller_tasks.go:172

↓ 1 callersMethodstartRegisterAllBrokerTask

startRegisterAllBrokerTask 注册所有Broker Author: tianyuliang Since: 2017/10/10

broker/server/controller_tasks.go:186

↓ 1 callersMethodstartScanUnSubscribedTopicTask

startCcanUnSubscribedTopicTask 扫描被删除Topic，并删除该Topic对应的Offset Author: tianyuliang Since: 2017/10/10

broker/server/controller_tasks.go:139

↓ 1 callersMethodstartSlaveSynchronizeTask

startSlaveSynchronizeTask 启动“Slave同步所有数据”任务 Author: tianyuliang Since: 2017/10/10

broker/server/controller_tasks.go:161

↓ 1 callersMethodsubscriptionTableToMap

subscriptionTableToMap subscriptionTable To Map Author rongzhihong Since 2017/9/17

broker/server/consumer_client.go:285

↓ 1 callersMethodsuspendPullRequest

suspendPullRequest 延缓拉请求 Author rongzhihong Since 2017/9/5

broker/server/pull_request_hold_service.go:64

↓ 1 callersMethodsyncAll

()

broker/server/slave_synchronize.go:39

↓ 1 callersMethodsyncConsumerOffset

syncTopicConfig 同步消费偏移量信息 Author rongzhihong Since 2017/9/18

broker/server/slave_synchronize.go:72

↓ 1 callersMethodsyncDelayOffset

syncTopicConfig 同步定时偏移量信息 Author rongzhihong Since 2017/9/18

broker/server/slave_synchronize.go:91

↓ 1 callersMethodsyncSubscriptionGroupConfig

syncTopicConfig 同步订阅信息 Author rongzhihong Since 2017/9/18

broker/server/slave_synchronize.go:110

↓ 1 callersMethodsyncTopicConfig

syncTopicConfig 同步Topic信息 Author rongzhihong Since 2017/9/18

broker/server/slave_synchronize.go:49

↓ 1 callersMethodsynchronizeMaster2Slave

synchronizeMaster2Slave 定时主从同步 Author: tianyuliang Since: 2017/10/10

broker/server/controller.go:272

↓ 1 callersFunctionsynctest

(addr string, gonum, sendnum, sendsize int)

sample/net/remoting/benchmark/client/client.go:57

↓ 1 callersMethodtruncateDirtyLogicFiles

(phyOffet int64)

store/persistent/consume_queue.go:387

↓ 1 callersMethodtryLockBatch

tryLockBatch 批量方式锁队列，返回锁定成功的队列集合 Author rongzhihong Since 2017/9/20

broker/server/rebalance_manager.go:117

↓ 1 callersMethodunRegisterBroker

unRegisterBroker 卸载指定的Broker，数据都是持久化的 Author: tianyuliang Since: 2017/9/6

namesrv/server/request_processor.go:396

↓ 1 callersMethodunRegisterBrokerAll

unRegisterBrokerAll 注销所有broker Author rongzhihong Since 2017/9/12

broker/server/controller.go:298

↓ 1 callersFunctionunlock

(addr, len uintptr)

store/persistent/mmap/mmap_unix.go:63

↓ 1 callersMethodunlockBatch

unlockBatch 批量方式解锁队列 Author rongzhihong Since 2017/9/20

broker/server/rebalance_manager.go:187

↓ 1 callersMethodunlockBatchMQ

lockBatchMQ 解锁队列 Author rongzhihong Since 2017/9/19

broker/server/admin_processor.go:379

↓ 1 callersFunctionunmap

(addr, len uintptr)

store/persistent/mmap/mmap_unix.go:71

↓ 1 callersMethodunmap

()

store/persistent/mapped_byte_buffer.go:131

↓ 1 callersMethodunregisterChannel

unregisterChannel 注销通道 Author rongzhihong Since 2017/9/14

broker/server/consumer_client.go:206

↓ 1 callersMethodunregisterClient

unregisterClient 注销客户端 Author gaoyanlei Since 2017/8/24

broker/server/client_manage_processor.go:105

↓ 1 callersMethodunregisterConsumer

unregisterConsumer 注销消费者 Author rongzhihong Since 2017/9/18

broker/server/consumer_manager.go:97

↓ 1 callersMethodunregisterProducer

unregisterProducer 注销producer Author gaoyanlei Since 2017/8/24

broker/server/producer_manager.go:119

↓ 1 callersMethodupdateAllConfig

updateAllConfig 更新所有文件 Author rongzhihong Since 2017/9/12

broker/server/controller.go:419

↓ 1 callersMethodupdateAndCreateSubscriptionGroup

updateAndCreateSubscriptionGroup 更新或者创建消费分组 Author rongzhihong Since 2017/9/19

broker/server/admin_processor.go:419

↓ 1 callersMethodupdateAndCreateTopic

updateAndCreateTopic 更新创建TOPIC Author rongzhihong Since 2017/8/23

broker/server/admin_processor.go:133

↓ 1 callersMethodupdateBrokerConfig

updateBrokerConfig 更新Broker服务器端的BrokerConfig, MessageStoreConfig信息 Author rongzhihong Since 2017/9/19

broker/server/admin_processor.go:227

↓ 1 callersMethodupdateByteBuffer

()

store/persistent/index.go:504

↓ 1 callersMethodupdateChannel

** * updateChannel 更新通道 * Author gaoyanlei * Since 2017/9/21 */

broker/server/consumer_client.go:121

↓ 1 callersMethodupdateConsumerOffset

updateConsumerOffset 更新消费者offset Author gaoyanlei Since 2017/8/25

broker/server/client_manage_processor.go:180

↓ 1 callersMethodupdateNameServerAddr

updateNameServerAddr 更新Namesrv地址 Author: tianyuliang Since: 2017/10/10

broker/server/controller.go:259

↓ 1 callersMethodupdateNextTransferOffset

()

store/persistent/ha.go:189

↓ 1 callersMethodupdateOrderTopicConfig

updateOrderTopicConfig 更新顺序topic Author gaoyanlei Since 2017/8/11

broker/server/topic_config_manager.go:274

↓ 1 callersMethodupdateSubscription

updateSubscription 更新订阅 Author rongzhihong Since 2017/9/17

broker/server/consumer_client.go:220

↓ 1 callersMethodupdateSubscriptionGroupConfig

updateSubscriptionGroupConfig 更新订阅组配置 Author rongzhihong Since 2017/9/18

broker/server/subscription_group_manager.go:115

↓ 1 callersMethodupdateTopicConfig

updateTopicConfig 更新topic信息 Author gaoyanlei Since 2017/8/10

broker/server/topic_config_manager.go:260

↓ 1 callersMethodwaitForFlush

(timeout int64)

store/persistent/commit_log.go:605

↓ 1 callersMethodwaitForRunning

()

store/persistent/commit_log.go:684

↓ 1 callersMethodwaitForRunning

(interval int64)

store/persistent/commit_log.go:789

↓ 1 callersMethodwakeup

()

store/persistent/commit_log.go:802

↓ 1 callersMethodwhichGroupByTopic

whichGroupByTopic 获得Topic的消费者 Author rongzhihong Since 2017/9/18

broker/server/consumer_offset_manager.go:189

↓ 1 callersMethodwipeWritePermOfBroker

wipeWritePermOfBroker 优雅更新Broker写操作返回值：对应Broker上待处理的Topic个数 Author: tianyuliang Since: 2017/9/6

namesrv/server/route_info_manager.go:248

↓ 1 callersMethodwipeWritePermOfBroker

wipeWritePermOfBroker 优雅地向Broker写数据 Author: tianyuliang Since: 2017/9/6

namesrv/server/request_processor.go:206

↓ 1 callersMethodwipeWritePermOfBrokerByLock

wipeWritePermOfBrokerByLock 加锁处理：优雅更新Broker写操作返回值: 对应Broker上待处理的Topic个数 Author: tianyuliang Since: 2017/9/6

namesrv/server/route_info_manager.go:233

MethodAddMessage

(bufferResult BufferResult)

store/get_message.go:136

MethodAppendToCommitLog

AppendToCommitLog 向CommitLog追加数据，并分发至各个Consume Queue Author: zhoufei Since: 2017/10/24

store/persistent/message_store.go:405

FunctionBenchmarkReadWrite

(b *testing.B)

store/persistent/mmap/mmap_test.go:219

MethodBrokerStats

()

store/persistent/message_store.go:1102

MethodBuffer

()

store/persistent/mapped_buffer_result.go:52

MethodBytes

()

store/persistent/mapped_byte_buffer.go:41

MethodBytes

Bytes 实现Serirable接口 Author rongzhihong Since 2017/9/17

broker/server/pagecache/query_message_transfer.go:60

MethodBytes

Bytes 实现Serirable接口 Author rongzhihong Since 2017/9/17

broker/server/pagecache/one_message_transfer.go:53

MethodBytes

Bytes 实现Serirable接口 Author rongzhihong Since 2017/9/17

broker/server/pagecache/many_message_transfer.go:62

MethodCheckInDiskByConsumeOffset

CheckInDiskByConsumeOffset 判断消息是否在磁盘 Author: zhoufei Since: 2017/9/20

store/persistent/message_store.go:864

MethodCleanExpiredConsumerQueue

CleanExpiredConsumerQueue 清除失效的消费队列 Author: zhoufei Since: 2017/9/21

store/persistent/message_store.go:992

MethodCleanUnusedTopic

CleanUnusedTopic 清除未使用Topic

store/persistent/message_store.go:1042

MethodCommitLogOffsetInQueue

获取指定队列最小Offset 如果队列不存在，返回-1

store/message_store.go:34

MethodCommitLogOffsetInQueue

CommitLogOffsetInQueue Author: luoji, <gunsluo@gmail.com> Since: 2018-01-02

store/persistent/message_store.go:1113

MethodConsumerIdsChanged

ConsumerIdsChanged 通知Consumer改变 Author gaoyanlei Since 2017/8/9

broker/server/consumer_client.go:52

FunctionCreateNullFile

CreateNullFile 创建文件

common/file.go:104

FunctionDecode

Decode Json Decode Author: rongzhihong Since: 2017/9/19

common/codec.go:28

MethodDestroy

关闭存储服务

store/message_store.go:29

MethodDestroy

()

store/persistent/message_store.go:548

MethodEarliestMessageTime

EarliestMessageTime 获取队列中最早的消息时间，如果找不到对应时间，则返回-1 Author: zhoufei Since: 2017/9/21

store/persistent/message_store.go:923

FunctionEncode

Encode Json Encode Author: rongzhihong Since: 2017/9/19

common/codec.go:21

MethodEncodeScheduleMsg

()

store/persistent/message_store.go:1106

MethodExcuteDeleteFilesManualy

数据复制使用：向CommitLog追加数据，并分发至各个Consume Queue

store/message_store.go:48

← previous next →601–700 of 1,049, ranked by callers