Functions — github.com/boltmq/boltmq

hub / github.com/boltmq/boltmq / functions

Functions1,049 in github.com/boltmq/boltmq

⨍ Functions 1,049◇ Types & classes 145

MethodExcuteDeleteFilesManualy

()

store/persistent/message_store.go:1117

(fn func(k *message.MessageQueue, v *LockEntry))

broker/rebalance/lock_entry_table.go:64

MethodForeach

(fn func(k string, v *LockEntryTable))

broker/rebalance/mq_lock_table.go:62

MethodGet

(key *message.MessageQueue)

broker/rebalance/lock_entry_table.go:42

MethodGet

(key string)

broker/rebalance/mq_lock_table.go:40

MethodGet

get 获得key对应的value Author rongzhihong Since 2017/9/5

broker/server/longpolling/pull_request_table.go:57

MethodGetCommitLogData

GetCommitLogData 数据复制使用：获取CommitLog数据 Author: zhoufei Since: 2017/10/23

store/persistent/message_store.go:386

FunctionGetConfigEnvValue

获取配置文件路径。1. 传入参数得到路径 2.传入参数为空，从环境变量得到路径。以上都未得到，返回默认路径。

common/env.go:36

FunctionGetDelayOffsetStorePath

(rootDir string)

common/disk.go:70

FunctionGetDiskPartitionSpaceUsedPercent

获取磁盘分区空间使用率

common/disk.go:24

MethodGetGetMessageTransferedMsgCount

()

stats/store_stats.go:172

MethodGetMessage

(group string, topic string, queueId int32, offset int64, maxMsgNums int32, subscriptionData *heartbeat.Subsc

store/persistent/message_store.go:627

MethodGetMsgGetTotalTodayMorning

()

stats/sstats/broker_stats_related_store_service.go:80

MethodGetMsgGetTotalTodayNow

GetMsgGetTotalTodayNow 获得当前get消息的次数 Author rongzhihong Since 2017/9/12

stats/sstats/broker_stats_related_store_service.go:68

MethodGetMsgGetTotalYesterdayMorning

()

stats/sstats/broker_stats_related_store_service.go:84

MethodGetMsgPutTotalTodayMorning

()

stats/sstats/broker_stats_related_store_service.go:72

MethodGetMsgPutTotalTodayNow

GetMsgPutTotalTodayNow 获得当前put消息的次数 Author rongzhihong Since 2017/9/12

stats/sstats/broker_stats_related_store_service.go:61

MethodGetMsgPutTotalYesterdayMorning

()

stats/sstats/broker_stats_related_store_service.go:76

MethodGetSinglePutMessageTopicSizeTotal

(topic string)

stats/store_stats.go:489

MethodGetSinglePutMessageTopicTimesTotal

(topic string)

stats/store_stats.go:533

MethodGetStatsDataInDay

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

stats/stats_item_set.go:302

MethodGetStatsDataInHour

GetStatsDataInHour 获得statsKey每小时统计数据 Author rongzhihong Since 2017/9/19

stats/stats_item_set.go:288

MethodGetStatsDataInMinute

GetStatsDataInMinute 获得statsKey每分钟统计数据 Author rongzhihong Since 2017/9/19

stats/stats_item_set.go:274

MethodGetStatsItem

NewStatsItemSet 获得statsKey的统计单元 Author rongzhihong Since 2017/9/19

stats/stats_item_set.go:316

MethodGetStatsItem

GetStatsItem 根据statsName、statsKey获得统计数据 Author rongzhihong Since 2017/9/17

stats/broker_stats.go:114

FunctionGetStorePathAbortFile

(rootDir string)

common/disk.go:66

FunctionGetStorePathCheckpoint

(rootDir string)

common/disk.go:62

FunctionGetStorePathCommitLog

(rootDir string)

common/disk.go:50

FunctionGetStorePathConsumeQueue

(rootDir string)

common/disk.go:54

FunctionGetStorePathIndex

(rootDir string)

common/disk.go:58

FunctionGetTranRedoLogStorePath

(rootDir string)

common/disk.go:78

FunctionGetTranStateTableStorePath

broker/trace/consume_message_hook.go:20

MethodIncBrokerGetNums

IncBrokerGetNums broker Get消息个数加incValue Author rongzhihong Since 2017/9/17

stats/broker_stats.go:160

MethodIncBrokerPutNums

incBrokerPutNums broker Put消息次数加1 Author rongzhihong Since 2017/9/17

stats/broker_stats.go:152

MethodIncGroupGetNums

IncGroupGetNums Topic@Group Get消息个数加incValue Author rongzhihong Since 2017/9/17

stats/broker_stats.go:138

MethodIncGroupGetSize

IncGroupGetSize Topic@Group Get消息流量增加incValue Author rongzhihong Since 2017/9/17

stats/broker_stats.go:145

MethodIncSendBackNums

IncSendBackNums Topic@Group 重试Put次数加1 Author rongzhihong Since 2017/9/17

stats/broker_stats.go:168

MethodIncTopicPutNums

IncTopicPutNums Topic Put次数加1 Author rongzhihong Since 2017/9/17

stats/broker_stats.go:124

MethodIncTopicPutSize

IncTopicPutSize Topic Put流量增加size Author rongzhihong Since 2017/9/17

stats/broker_stats.go:131

MethodInit

Init 初始化 Author rongzhihong Since 2017/9/19

stats/moment_stats_item_set.go:47

MethodInit

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

stats/stats_item_set.go:327

FunctionIsBlank

IsBlank 是否为空 Author: rongzhihong Since: 2017/9/19

common/valid.go:23

MethodIsMessageMatched

(subscriptionData *heartbeat.SubscriptionData, tagsCode int64)

store/persistent/message_filter.go:35

MethodLess

(i, j int)

store/persistent/index.go:43

MethodLoad

Load 加载NamesrvController必要的资源

namesrv/server/controller.go:53

MethodLoad

Load

store/persistent/message_store.go:127

MethodLookMessageByOffset

LookMessageByOffset 通过物理队列Offset，查询消息。如果发生错误，则返回null Author: zhoufei Since: 2017/9/20

store/persistent/message_store.go:822

MethodMarshalJSON

MarshalJSON marshal bytes to json - template

broker/server/offset_table_ffjson.go:24

MethodMaxOffsetInQueue

MaxOffsetInQueue 获取指定队列最大Offset 如果队列不存在，返回-1 Author: zhoufei Since: 2017/9/20

store/persistent/message_store.go:319

MethodMaxPhyOffset

MaxPhyOffset 获取物理队列最大offset Author: zhoufei Since: 2017/10/24

store/persistent/message_store.go:398

MethodMessageIds

MessageIds 批量获取MessageId Author: zhoufei Since: 2017/9/21

store/persistent/message_store.go:1050

MethodMessageStoreTimeStamp

MessageStoreTimeStamp 获取队列中存储时间，如果找不到对应时间，则返回-1 Author: zhoufei Since: 2017/9/21

store/persistent/message_store.go:973

MethodMessageTotalInQueue

(topic string, queueId int32)

store/message_store.go:45

MethodMessageTotalInQueue

(topic string, queueId int32)

store/persistent/message_store.go:1120

MethodMinOffsetInQueue

MinOffsetInQueue 获取指定队列最小Offset 如果队列不存在，返回-1 Author: zhoufei Since: 2017/9/20

store/persistent/message_store.go:852

MethodMinPhyOffset

获取物理队列最大offset

store/message_store.go:42

MethodMinPhyOffset

()

store/persistent/message_store.go:1124

FunctionNewBrokerController

NewBrokerController 创建BrokerController对象

broker/server/controller.go:69

FunctionNewBrokerStats

(clusterName string)

stats/broker_stats.go:58

FunctionNewBrokerStatsRelatedStore

(messageStore store.MessageStore)

stats/sstats/broker_stats_related_store_service.go:33

FunctionNewCallOuterService

NewCallOuterService 初始化 Author gaoyanlei Since 2017/8/22

broker/client/call_outer_service.go:45

FunctionNewConfig

(storeRootDir string)

store/persistent/config.go:91

FunctionNewLockEntry

()

broker/rebalance/lock_entry.go:37

FunctionNewLockEntryTable

()

broker/rebalance/lock_entry_table.go:30

FunctionNewMQLockTable

()

broker/rebalance/mq_lock_table.go:28

FunctionNewManyMessageTransfer

NewManyMessageTransfer 初始化 Author rongzhihong Since 2017/9/17

broker/server/pagecache/many_message_transfer.go:34

FunctionNewMessageStore

(config *Config, brokerStats stats.BrokerStats)

store/persistent/message_store.go:80

FunctionNewNamesrvController

NewNamesrvController 初始化默认的NamesrvController Author: tianyuliang Since: 2017/9/12

namesrv/server/controller.go:37

FunctionNewOneMessageTransfer

NewOneMessageTransfer 初始化OneMessageTransfer Author rongzhihong Since 2017/9/17

broker/server/pagecache/one_message_transfer.go:32

FunctionNewPullRequest

(requestCommand *protocol.RemotingCommand, ctx core.Context, timeoutMillis, suspendTimestamp, pullFromThisOffs

broker/server/longpolling/pull_request.go:32

FunctionNewPullRequestTable

newPullRequestTable 初始化消息集合 Author rongzhihong Since 2017/9/5

broker/server/longpolling/pull_request_table.go:29

FunctionNewQueryMessageResult

()

store/get_message.go:132

FunctionNewQueryMessageTransfer

NewOneMessageTransfer 初始化OneMessageTransfer Author rongzhihong Since 2017/9/17

broker/server/pagecache/query_message_transfer.go:34

FunctionNewSendMessageContext

NewSendMessageContext 初始化 Author gaoyanlei Since 2017/8/15

broker/trace/send_message_context.go:37

FunctionNewStoreStats

()

stats/store_stats.go:78

FunctionNewTOPAddr

NewTOPAddr TOPAddr Author gaoyanlei Since 2017/8/9

broker/client/top_addr.go:39

MethodOffsetInQueueByTime

OffsetInQueueByTime 根据消息时间获取某个队列中对应的offset 1、如果指定时间（包含之前之后）有对应的消息，则获取距离此时间最近的offset（优先选择之前） 2、如果指定时间无对应消息，则返回0 Author: zhoufei Since: 2017/9/21

store/persistent/message_store.go:911

MethodOnContextActive

OnContextActive 创建Channel连接

namesrv/server/broker_house_keeping_listener.go:36

MethodOnContextActive

(ctx core.Context)

sample/net/remoting/benchmark/serve/server.go:52

MethodOnContextActive

(ctx core.Context)

sample/net/remoting/simple/serve/serve.go:66

MethodOnContextActive

(ctx core.Context)

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

MethodOnContextActive

(ctx core.Context)

sample/net/core/multi/serve/serve.go:32

MethodOnContextActive

(ctx core.Context)

sample/net/core/simple/client/client.go:26

MethodOnContextActive

(ctx core.Context)

sample/net/core/simple/serve/serve.go:25

MethodOnContextActive

OnContextActive 连接创建 Author: luoji, <gunsluo@gmail.com> Since: 2018-01-07

broker/server/client_house_keeping_service.go:84

MethodOnContextClosed

OnContextClose 关闭Channel,通知Topic路由管理器，清除无效Broker Author: tianyuliang Since: 2017/9/6

namesrv/server/broker_house_keeping_listener.go:50

MethodOnContextClosed

(ctx core.Context)

sample/net/remoting/benchmark/serve/server.go:60

MethodOnContextClosed

(ctx core.Context)

sample/net/remoting/simple/serve/serve.go:74

MethodOnContextClosed

(ctx core.Context)

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

MethodOnContextClosed

(ctx core.Context)

sample/net/core/multi/serve/serve.go:42

MethodOnContextClosed

(ctx core.Context)

sample/net/core/simple/client/client.go:39

MethodOnContextClosed

(ctx core.Context)

sample/net/core/simple/serve/serve.go:33

MethodOnContextClosed

OnContextClose 监听通道关闭 Author rongzhihong Since 2017/9/8

broker/server/client_house_keeping_service.go:98

MethodOnContextConnect

OnContextConnect 创建Channel连接 Author: tianyuliang Since: 2017/9/6

namesrv/server/broker_house_keeping_listener.go:43

MethodOnContextConnect

(ctx core.Context)

sample/net/remoting/benchmark/serve/server.go:56

MethodOnContextConnect

(ctx core.Context)

sample/net/remoting/simple/serve/serve.go:70

MethodOnContextConnect

(ctx core.Context)

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

MethodOnContextConnect

(ctx core.Context)

sample/net/core/multi/serve/serve.go:37

← previous next →701–800 of 1,049, ranked by callers