MCPcopy Create free account

hub / github.com/boltmq/boltmq / functions

Functions1,049 in github.com/boltmq/boltmq

⨍ Functions 1,049◇ Types & classes 145
FunctionTestParseConfig
(t *testing.T)
broker/config/parse_test.go:20
FunctionTestParseConfigError
(t *testing.T)
broker/config/parse_test.go:73
FunctionTestPathExist
(t *testing.T)
common/file_test.go:33
FunctionTestProtFlagsAndErr
(t *testing.T)
store/persistent/mmap/mmap_test.go:100
FunctionTestRandReadWrite
(t *testing.T)
store/persistent/mmap/mmap_test.go:191
FunctionTestReadWrite
(t *testing.T)
store/persistent/mmap/mmap_test.go:68
FunctionTestSCWriteAndRead
(t *testing.T)
store/persistent/store_checkpoint_test.go:21
FunctionTestUnmap
(t *testing.T)
store/persistent/mmap/mmap_test.go:52
MethodTpsGroupGetNums
TpsGroupGetNums 根据 Topic@Group 获得TPS Author rongzhihong Since 2017/9/17
stats/broker_stats.go:175
MethodUnmarshalJSON
UnmarshalJSON umarshall json - template of ffjson
broker/server/offset_table_ffjson.go:67
MethodUpdateHaMasterAddress
UpdateHaMasterAddress 更新HaMaster地址 Author: zhoufei Since: 2017/9/21
store/persistent/message_store.go:1025
MethodWriteInt16
(i int16)
store/persistent/mapped_byte_buffer.go:64
MethodWriteInt32
(i int32)
store/persistent/mapped_byte_buffer.go:70
MethodWriteInt64
(i int64)
store/persistent/mapped_byte_buffer.go:76
MethodWriteInt8
(i int8)
store/persistent/mapped_byte_buffer.go:58
Methodcommit
(flushLeastPages int32)
store/persistent/consume_queue.go:356
Methodcommit
(flushLeastPages int32)
store/persistent/mapped_file_queue.go:417
MethodcompareTo
(request *allocateRequest)
store/persistent/allocate.go:46
MethodconfigFilePath
()
broker/server/consumer_offset_manager.go:80
MethodconfigFilePath
()
broker/server/topic_config_manager.go:378
MethodconfigFilePath
()
broker/server/subscription_group_manager.go:107
Methoddecode
(buf []byte)
broker/server/consumer_offset_manager.go:71
Methoddecode
(content []byte)
broker/server/topic_config_manager.go:361
Methoddecode
(buf []byte)
broker/server/subscription_group_manager.go:98
FunctiondefaultConfig
()
store/persistent/config.go:95
MethoddeleteExpiredFile
(offset int64)
store/persistent/consume_queue.go:452
MethoddeleteKVConfig
deleteKVConfig 从Namesrv配置列表中，根据key删除对应的键值对 Author: tianyuliang Since: 2017/9/6
namesrv/server/kv_config_manager.go:169
MethoddeleteKVConfigByValue
deleteKVConfigByValue 从指定Namespace配置中，根据value，删除对应的key键 Author: tianyuliang Since: 2017/9/6
namesrv/server/kv_config_manager.go:88
Methoddestroy
()
store/persistent/index.go:226
Methoddestroy
()
store/persistent/consume_queue.go:437
Methoddestroy
(intervalForcibly int64)
store/persistent/mapped_file.go:288
Methoddestroy
()
store/persistent/commit_log.go:561
FunctiondiskUsage
get Windows disk usage
common/statfs/statfs_windows.go:24
MethoddoAppend
(fileFromOffset int64, byteBuffer *mappedByteBuffer, maxBlank int32, msg interface{})
store/persistent/commit_log.go:869
MethoddoChannelCloseEvent
doChannelCloseEvent 通道关闭事件 Author rongzhihong Since 2017/9/8
broker/server/filter_server_manager.go:167
MethoddoChannelCloseEvent
doChannelCloseEvent 扫描不活跃的通道 Author rongzhihong Since 2017/9/11
broker/server/consumer_manager.go:154
MethoddoChannelCloseEvent
doChannelCloseEvent 关闭通道 Author rongzhihong Since 2017/9/11
broker/server/consumer_client.go:157
Methodencode
()
store/persistent/schedule.go:82
Methodencode
(prettyFormat bool)
broker/server/consumer_offset_manager.go:61
Methodencode
(prettyFormat bool)
broker/server/topic_config_manager.go:354
Methodencode
(prettyFormat bool)
broker/server/subscription_group_manager.go:91
MethodfindChannel
findChannel 根据clientId获得通道 Author rongzhihong Since 2017/9/17
broker/server/consumer_client.go:270
MethodfindSubscriptionData
(topic string)
broker/server/consumer_client.go:96
Methodflip
()
store/persistent/mapped_byte_buffer.go:135
Methodflush
()
store/persistent/mapped_byte_buffer.go:127
MethodgetHasUnitSubTopicList
getHasUnitSubTopicList 获取中心向单元同步的所有topic列表 Author: tianyuliang Since: 2017/9/6
namesrv/server/route_info_manager.go:824
MethodgetHasUnitSubUnUnitTopicList
GetHasUnitSubUnUnitTopicList 获取含有单元化订阅组的 非单元化Topic列表 Author: tianyuliang Since: 2017/9/6
namesrv/server/route_info_manager.go:847
MethodgetKVConfig
getKVConfig 从指定Namespace配置中，根据key获取value值 Author: tianyuliang Since: 2017/9/6
namesrv/server/kv_config_manager.go:132
MethodgetKVConfigByValue
getKVConfigByValue 从指定Namespace配置中，根据value，反向查找key列表，并将key列表通过分号;拼接为字符串 Author: tianyuliang Since: 2017/9/6
namesrv/server/kv_config_manager.go:111
MethodgetKVListByNamespace
getKVListByNamespace 获取指定Namespace所有的KV配置List Author: tianyuliang Since: 2017/9/6
namesrv/server/kv_config_manager.go:146
MethodgetLastAndLastMappedFile
()
store/persistent/mapped_file_queue.go:492
MethodgetMappedMemorySize
()
store/persistent/mapped_file_queue.go:503
MethodgetMaxOffset
()
store/persistent/mapped_file_queue.go:304
MethodgetMinOffset
()
store/persistent/mapped_file_queue.go:293
MethodgetTopicsByCluster
getTopicsByCluster 获取指定集群下的所有topic列表
namesrv/server/route_info_manager.go:763
MethodgetUnitTopicList
getUnitTopics 获取单元逻辑下的所有topic列表
namesrv/server/route_info_manager.go:801
MethodgotoCheck
gotoCheck 回调检查方法 Author rongzhihong Since 2017/9/17
broker/server/transaction_check_supervisor.go:34
MethodhasRemainMessage
()
store/persistent/dispatch.go:147
MethodisReadable
()
store/persistent/running_flags.go:28
MethodisSystemTopic
(topic string)
broker/server/topic_config_manager.go:131
Methodload
(lastExitOK bool)
store/persistent/index.go:76
Methodload
()
store/persistent/index.go:490
Methodload
()
store/persistent/consume_queue.go:57
Methodload
load 从磁盘加载mappedfile到内存映射 Author: tantexian, <tantexian@qq.com> Since: 2017/8/8
store/persistent/mapped_file_queue.go:168
Methodload
()
store/persistent/schedule.go:86
Methodload
()
store/persistent/commit_log.go:70
Methodload
()
broker/server/consumer_offset_manager.go:57
Methodload
()
broker/server/topic_config_manager.go:350
Methodload
()
broker/server/subscription_group_manager.go:87
Functionlock
(addr, len uintptr)
store/persistent/mmap/mmap_windows.go:102
Functionmain
()
namesrv/main.go:30
Functionmain
()
sample/net/remoting/benchmark/client/client.go:34
Functionmain
()
sample/net/remoting/benchmark/serve/server.go:72
Functionmain
()
sample/net/remoting/simple/client/client.go:29
Functionmain
()
sample/net/remoting/simple/serve/serve.go:86
Functionmain
()
sample/net/core/multi/client/client.go:90
Functionmain
()
sample/net/core/multi/serve/serve.go:54
Functionmain
()
sample/net/core/simple/client/client.go:47
Functionmain
()
sample/net/core/simple/serve/serve.go:41
Functionmain
()
broker/main.go:31
Functionmmap
(len int, prot, flags, hfile uintptr, off int64)
store/persistent/mmap/mmap_windows.go:35
FunctionnewAllocateMappedFileService
()
store/persistent/allocate.go:64
FunctionnewReferenceResource
()
store/persistent/mapped_file.go:52
MethodnotifyTransferSome
()
store/persistent/ha.go:457
Methodpersist
()
broker/server/consumer_offset_manager.go:258
MethodputKVConfig
putKVConfig 向Namesrv追加KV配置 Author: tianyuliang Since: 2017/9/6
namesrv/server/kv_config_manager.go:185
MethodputMessagePostionInfo
(topic string, queueId int32, offset int64, size int64, tagsCode, storeTimestamp, logicOffset int64)
store/persistent/message_store.go:375
MethodputRequest
(request *groupCommitRequest)
store/persistent/ha.go:432
MethodputRequestAndReturnMappedFile
(nextFilePath string, nextNextFilePath string, filesize int64)
store/persistent/allocate.go:71
MethodqueryTopicConsumeByWho
queryTopicConsumeByWho 根据topic查找消费者 Author rongzhihong Since 2017/9/18
broker/server/consumer_manager.go:199
Methodrecover
()
store/persistent/consume_queue.go:124
MethodregisterBroker
registerBroker 注册Broker 业务逻辑: (1)如果收到REGISTER_BROKER请求，那么最终会调用到routeInfoManager.registerBroker() (2)注册完成后，返回给Broker端主用Broker的地址和主用Broker的HA服务地址 返回值：
namesrv/server/route_info_manager.go:126
MethodregisterFilterServer
registerFilterServer 注册FilterServer Author rongzhihong Since 2017/9/8
broker/server/filter_server_manager.go:117
MethodresetOffset
resetOffset Broker 主动通知 Consumer，offset列表发生变化，需要进行重置 Author rongzhihong Since 2017/9/18
broker/server/broker_client.go:83
MethodretryDeleteFirstFile
(intervalForcibly int64)
store/persistent/mapped_file_queue.go:507
MethodrollNextFile
(index int64)
store/persistent/consume_queue.go:82
Methodrun
()
store/persistent/consume.go:113
MethodscanNotActiveChannel
scanNotActiveChannel 10s向Broker注册一次，Broker如果发现30s没有注册，则删除它 Author rongzhihong Since 2017/9/8
broker/server/filter_server_manager.go:142
MethodscanNotActiveChannel
scanNotActiveChannel 扫描不活跃的通道 Author rongzhihong Since 2017/9/11
broker/server/consumer_manager.go:116
Methodsetlimit
(newlimit int)
store/persistent/mapped_byte_buffer.go:140
← previousnext →901–1,000 of 1,049, ranked by callers