MCPcopy Create free account

hub / github.com/boltmq/boltmq / types & classes

Types & classes145 in github.com/boltmq/boltmq

⨍ Functions 1,049◇ Types & classes 145
↓ 1 callersTypeAliasfiles
store/persistent/index.go:37
StructAppendMessageResult
AppendMessageResult 写入commitlong返回结果集 Author gaoyanlei Since 2017/8/16
store/append_message.go:26
TypeAliasAppendMessageStatus
AppendMessageStatus 写入commitlog 返回code Author gaoyanlei Since 2017/8/16
store/append_message.go:38
StructBrokerConfig
BrokerConfig
broker/config/config.go:42
StructBrokerController
BrokerController broker服务控制器 Author gaoyanlei Since 2017/8/25
broker/server/controller.go:39
TypeAliasBrokerRoleType
store/persistent/config.go:196
InterfaceBrokerStats
stats/broker_stats.go:34
InterfaceBrokerStatsRelatedStore
BrokerStatsRelatedStore 统计store相关的数据
stats/broker_stats_related_store.go:17
InterfaceBufferResult
store/buffer_result.go:16
InterfaceByteBuffer
ByteBuffer
store/buffer_result.go:23
StructCallOuterService
CallOuterService 调用Broker对外的接口封装
broker/client/call_outer_service.go:36
StructClock
store/persistent/clock.go:24
StructClusterConfig
ClusterConfig 集群配置
broker/config/config.go:32
StructConfig
namesrv/config/config.go:16
StructConfig
Config 存储层配置文件类 Author zhoufei Since 2017/9/6
store/persistent/config.go:32
StructConfig
broker/config/config.go:22
StructConsumeMessageContext
broker/trace/consume_message_context.go:16
InterfaceConsumeMessageHook
ConsumeMessageHook 消费消息回调 Author rongzhihong Since 2017/9/5
broker/trace/consume_message_hook.go:19
InterfaceConsumerIdsChangeListener
broker/server/consumer_client.go:29
StructDiskStatus
common/statfs/statfs.go:16
TypeAliasFlushDiskType
store/persistent/config.go:230
StructGetMessageResult
GetMessageResult 访问消息返回结果 Author gaoyanlei Since 2017/8/17
store/get_message.go:72
TypeAliasGetMessageStatus
GetMessageStatus 访问消息返回的状态码 Author gaoyanlei Since 2017/8/17
store/get_message.go:42
StructGetTopicStatisInfoProcessor
sample/net/remoting/benchmark/serve/server.go:29
StructGetTopicStatisInfoProcessor
sample/net/remoting/simple/serve/serve.go:30
StructKVConfigSerializeWrapper
KVConfigSerializeWrapper KV配置的json序列化结构 Author: tianyuliang Since: 2017/9/4
namesrv/server/kv_config_serialize_wrapper.go:19
StructLockEntry
LockEntry LockEntry Author: rongzhihong Since: 2017/9/19
broker/rebalance/lock_entry.go:32
StructLockEntryTable
LockEntryTable.lock.LockEntryTable Author rongzhihong Since 2017/9/20
broker/rebalance/lock_entry_table.go:25
StructLogConfig
LogConfig 日志配置
namesrv/config/config.go:29
StructLogConfig
LogConfig 日志配置
broker/config/config.go:74
TypeAliasMMap
MMap represents a file mapped into memory.
store/persistent/mmap/mmap.go:54
StructMQLockTable
MQLockTable MQLockTable Author rongzhihong Since 2017/9/20
broker/rebalance/mq_lock_table.go:23
StructManyMessageTransfer
ManyMessageTransfer 消息转移 Author rongzhihong Since 2017/9/17
broker/server/pagecache/many_message_transfer.go:26
StructManyPullRequest
ManyPullRequest 长轮询请求 Author rongzhihong Since 2017/9/5
broker/server/longpolling/many_pull_request.go:23
StructMemoryMessageStore
store/memory/message_store.go:16
StructMessageExtInner
MessageExtInner 存储内部使用的Message对象 Author gaoyanlei Since 2017/8/16
store/message_ext_inner.go:26
InterfaceMessageFilter
MessageFilter 消息过滤接口 Author zhoufei Since 2017/9/6
store/persistent/message_filter.go:25
InterfaceMessageStore
MessageStore 存储层对外提供的接口 Author zhoufei Since 2017/9/6
store/message_store.go:25
StructMomentStatsItem
MomentStatsItem MomentStatsItem Author rongzhihong Since 2017/9/19
stats/moment_stats_item_set.go:29
StructMomentStatsItemSet
MomentStatsItemSet QueueId@Topic@Group的offset落后数量的记录集合 Author rongzhihong Since 2017/9/17
stats/moment_stats_item_set.go:67
StructNameSrvConfig
NameSrvConfig namesrv相关配置
namesrv/config/config.go:22
StructNameSrvController
namesrv/server/controller.go:24
StructOffsetTable
broker/server/offset_table.go:22
StructOneMessageTransfer
OneMessageTransfer 消息转移 Author rongzhihong Since 2017/9/17
broker/server/pagecache/one_message_transfer.go:24
StructOtherProcessor
sample/net/remoting/simple/serve/serve.go:50
StructPersistentMessageStore
PersistentMessageStore 存储层对外提供的接口 Author zhoufei Since 2017/9/6
store/persistent/message_store.go:54
StructPullRequest
PullRequest 拉消息请求 Author gaoyanlei Since 2017/8/18
broker/server/longpolling/pull_request.go:24
StructPullRequestTable
PullRequestTable 消息集合 Author rongzhihong Since 2017/9/5
broker/server/longpolling/pull_request_table.go:21
StructPutMessageResult
PutMessageResult 写入消息返回结果 Author gaoyanlei Since 2017/8/16
store/put_message.go:58
TypeAliasPutMessageStatus
PutMessageStatus 写入消息过程的返回结果 Author gaoyanlei Since 2017/8/16
store/put_message.go:30
StructQueryMessageResult
QueryMessageResult 通过Key查询消息，返回结果 Author zhoufei Since 2017/9/6
store/get_message.go:124
StructQueryMessageTransfer
OneMessageTransfer 消息转移 Author rongzhihong Since 2017/9/17
broker/server/pagecache/query_message_transfer.go:26
StructSendMessageContext
SendMessageContext 消息发送上下文 Author gaoyanlei Since 2017/8/15
broker/trace/send_message_context.go:19
InterfaceSendMessageHook
SendMessageHook 发送消息回调 Author rongzhihong Since 2017/9/5
broker/trace/send_message_hook.go:19
StructSendMessageProcessor
SendMessageProcessor 处理客户端发送消息的请求 Author gaoyanlei Since 2017/8/24
broker/server/send_message_processor.go:42
StructServerContextEventListener
sample/net/remoting/benchmark/serve/server.go:49
StructServerContextEventListener
sample/net/remoting/simple/serve/serve.go:63
StructStatsItem
StatsItem 统计单元 Author rongzhihong Since 2017/9/19
stats/stats_item_set.go:29
StructStatsItemSet
StatsItemSet 统计单元集合 Author rongzhihong Since 2017/9/19
stats/stats_item_set.go:226
StructStatsSnapshot
StatsSnapshot Stats Snapshot Author rongzhihong Since 2017/9/19
stats/call_snapshot.go:86
StructStoreConfig
StoreConfig 存储相关配置
broker/config/config.go:67
InterfaceStoreStats
stats/store_stats.go:27
TypeAliasSynchronizationMethod
store/persistent/config.go:177
StructTOPAddr
TOPAddr 寻址服务 Author gaoyanlei Since 2017/8/9
broker/client/top_addr.go:31
StructacceptSocketService
acceptSocketService Author zhoufei Since 2017/10/19
store/persistent/ha.go:350
StructadminBrokerProcessor
adminBrokerProcessor 管理类请求处理 Author gaoyanlei Since 2017/8/23
broker/server/admin_processor.go:39
StructallocateMappedFileService
store/persistent/allocate.go:58
InterfaceallocateMappedFileStrategy
allocateMappedFileStrategy 分配mapped file方式
store/persistent/mapped_file_queue.go:30
StructallocateRequest
allocateRequest 分配请求
store/persistent/allocate.go:30
InterfaceappendMessageCallback
appendMessageCallback 写消息回调接口 Author: tantexian, <tantexian@qq.com> Since: 2017/8/6
store/persistent/mapped_file.go:39
StructbasicSendMessageProcessor
basicSendMessageProcessor 发送处理类 Author gaoyanlei Since 2017/8/14
broker/server/send_message_processor.go:442
Structbroker2Client
broker2Client Broker主动调用客户端接口 Author gaoyanlei Since 2017/8/9
broker/server/broker_client.go:33
StructbrokerHouseKeepingListener
brokerHouseKeepingListener Broker活动检测服务
namesrv/server/broker_house_keeping_listener.go:22
StructbrokerStatsRelatedStoreService
brokerStatsRelatedStoreService broker统计的数据（昨天和今天的Get、Put数据量） Author rongzhihong Since 2017/9/12
stats/sstats/broker_stats_related_store_service.go:25
StructbrokerStatsService
brokerStatsService broker统计 Author gaoyanlei Since 2017/8/18
stats/broker_stats.go:52
StructcallSnapshot
callSnapshot Call Snapshot Author rongzhihong Since 2017/9/19
stats/call_snapshot.go:23
StructcallSnapshotPlus
callSnapshotPlus Call Snapshot安全数组 Author rongzhihong Since 2017/9/19
stats/call_snapshot.go:39
StructchannelInfo
broker/server/consumer_client.go:294
StructcleanCommitLogService
cleanCommitLogService 清理物理文件服务 Author zhoufei Since 2017/10/13
store/persistent/commit_log.go:1032
StructcleanConsumeQueueService
cleanConsumeQueueService 清理逻辑文件服务 Author zhoufei Since 2017/10/13
store/persistent/consume.go:101
StructclientEventListener
sample/net/core/multi/client/client.go:28
StructclientEventListener
sample/net/core/simple/client/client.go:23
StructclientHouseKeepingService
clientHouseKeepingService 定期检测客户端连接，清除不活动的连接 Author rongzhihong Since 2017/9/8
broker/server/client_house_keeping_service.go:27
StructclientManageProcessor
broker/server/client_manage_processor.go:29
StructcommitLog
store/persistent/commit_log.go:44
InterfaceconfigManager
configManager 配置管理
broker/server/config_manager.go:26
StructconfigManagerLoader
configManagerLoader 配置管理加载器
broker/server/config_manager.go:35
StructconsumeQueue
store/persistent/consume_queue.go:28
StructconsumeQueueTable
store/persistent/message_store.go:40
StructconsumerGroupInfo
consumerGroupInfo 整个Consumer Group信息 Author gaoyanlei Since 2017/8/17
broker/server/consumer_client.go:63
StructconsumerManager
consumerManager 消费者管理 Author gaoyanlei Since 2017/8/9
broker/server/consumer_manager.go:28
StructconsumerOffsetManager
consumerOffsetManager Consumer消费进度管理 Author gaoyanlei Since 2017/8/9
broker/server/consumer_offset_manager.go:37
StructcontrollerTask
namesrv/server/controller_task.go:22
StructcontrollerTasks
controllerTasks broker控制器的各种任务 Author: tianyuliang Since: 2017/10/11
broker/server/controller_tasks.go:26
StructdefaultAppendMessageCallback
store/persistent/commit_log.go:852
StructdefaultConsumerIdsChangeListener
defaultConsumerIdsChangeListener ConsumerId列表变化，通知所有Consumer Author gaoyanlei Since 2017/8/9
broker/server/consumer_client.go:36
StructdefaultMessageFilter
defaultMessageFilter 消息过滤规则实现 Author zhoufei Since 2017/9/6
store/persistent/message_filter.go:32
StructdefaultRequestProcessor
defaultRequestProcessor NameServer网络请求处理结构体 Author: tianyuliang Since: 2017/9/6
namesrv/server/request_processor.go:35
StructdispatchMessageService
store/persistent/dispatch.go:40
StructdispatchRequest
store/persistent/dispatch.go:25
next →1–100 of 145, ranked by callers