Documentation ¶
Index ¶
- type CheckTransactionStateRequestHeader
- type CloneGroupOffsetRequestHeader
- type ConsumeMessageDirectlyResultRequestHeader
- type ConsumerSendMsgBackRequestHeader
- type CreateTopicRequestHeader
- type DeleteSubscriptionGroupRequestHeader
- type DeleteTopicRequestHeader
- type EndTransactionRequestHeader
- type GetAllTopicConfigResponseHeader
- type GetBrokerConfigResponseHeader
- type GetConsumeStatsRequestHeader
- type GetConsumerConnectionListRequestHeader
- type GetConsumerListByGroupRequestHeader
- type GetConsumerListByGroupResponseBody
- type GetConsumerRunningInfoRequestHeader
- type GetConsumerStatusRequestHeader
- type GetEarliestMsgStoretimeRequestHeader
- type GetEarliestMsgStoretimeResponseHeader
- type GetMaxOffsetRequestHeader
- type GetMaxOffsetResponseHeader
- type GetMinOffsetRequestHeader
- type GetMinOffsetResponseHeader
- type GetProducerConnectionListRequestHeader
- type GetTopicStatsInfoRequestHeader
- type GetTopicsByClusterRequestHeader
- type NotifyConsumerIdsChangedRequestHeader
- type PullMessageRequestHeader
- type PullMessageResponseHeader
- type QueryConsumeTimeSpanRequestHeader
- type QueryConsumerOffsetRequestHeader
- type QueryConsumerOffsetResponseHeader
- type QueryCorrectionOffsetRequestHeader
- type QueryMessageRequestHeader
- type QueryMessageResponseHeader
- type QueryTopicConsumeByWhoRequestHeader
- type ResetOffsetRequestHeader
- type SearchOffsetRequestHeader
- type SearchOffsetResponseHeader
- type SendMessageRequestHeader
- type SendMessageRequestHeaderV2
- type SendMessageResponseHeader
- type UnregisterClientRequestHeader
- type UpdateConsumerOffsetRequestHeader
- type ViewBrokerStatsDataRequestHeader
- type ViewMessageRequestHeader
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CheckTransactionStateRequestHeader ¶
type CheckTransactionStateRequestHeader struct { MsgId string TransactionId string TranStateTableOffset int64 CommitLogOffset int64 }
CheckTransactionStateRequestHeader 检查事务状态的请求头 Author rongzhihong Since 2017/9/11
func (*CheckTransactionStateRequestHeader) CheckFields ¶
func (header *CheckTransactionStateRequestHeader) CheckFields() error
type CloneGroupOffsetRequestHeader ¶
type CloneGroupOffsetRequestHeader struct { SrcGroup string `json:"srcGroup"` DestGroup string `json:"destGroup"` Topic string `json:"topic"` Offline bool `json:"offline"` }
cloneGroupOffset 克隆cloneGroupOffset的请求头 Author rongzhihong Since 2017/9/19
func NewCloneGroupOffsetRequestHeader ¶
func NewCloneGroupOffsetRequestHeader(srcGroup, destGroup, topic string, isOffline bool) *CloneGroupOffsetRequestHeader
NewCloneGroupOffsetRequestHeader 初始化 Author: tianyuliang Since: 2017/11/1
func (*CloneGroupOffsetRequestHeader) CheckFields ¶
func (header *CloneGroupOffsetRequestHeader) CheckFields() error
type ConsumeMessageDirectlyResultRequestHeader ¶
type ConsumeMessageDirectlyResultRequestHeader struct { ConsumerGroup string `json:"consumerGroup"` ClientId string `json:"clientId"` MsgId string `json:"msgId"` BrokerName string `json:"brokerName"` }
consumeMessageDirectlyResultRequestHeader consumeMessageDirectlyResult请求头 Author rongzhihong Since 2017/9/19
func (*ConsumeMessageDirectlyResultRequestHeader) CheckFields ¶
func (header *ConsumeMessageDirectlyResultRequestHeader) CheckFields() error
type ConsumerSendMsgBackRequestHeader ¶
type ConsumerSendMsgBackRequestHeader struct { Offset int64 `json:"offset"` Group string `json:"group"` DelayLevel int32 `json:"delayLevel"` OriginMsgId string `json:"originMsgId"` OriginTopic string `json:"originTopic"` UnitMode bool `json:"unitMode"` }
ConsumerSendMsgBackRequestHeader: 消费消息头 Author: yintongqiang Since: 2017/8/17
func NewConsumerSendMsgBackRequestHeader ¶
func NewConsumerSendMsgBackRequestHeader() *ConsumerSendMsgBackRequestHeader
初始化 ConsumerSendMsgBackRequestHeader Author gaoyanlei Since 2017/8/17
func (*ConsumerSendMsgBackRequestHeader) CheckFields ¶
func (header *ConsumerSendMsgBackRequestHeader) CheckFields() error
type CreateTopicRequestHeader ¶
type CreateTopicRequestHeader struct { Topic string // 真正的topic名称是位于topicConfig.Topic字段 DefaultTopic string // 表示创建topic的key值 ReadQueueNums int32 WriteQueueNums int32 Perm int TopicFilterType stgcommon.TopicFilterType TopicSysFlag int Order bool }
CreateTopicRequestHeader: 创建topic头信息 Author: yintongqiang Since: 2017/8/17
func NewCreateTopicRequestHeader ¶
func NewCreateTopicRequestHeader(topicWithProjectGroup, defaultTopic string, topicConfig *stgcommon.TopicConfig) *CreateTopicRequestHeader
func (*CreateTopicRequestHeader) CheckFields ¶
func (header *CreateTopicRequestHeader) CheckFields() error
type DeleteSubscriptionGroupRequestHeader ¶
type DeleteSubscriptionGroupRequestHeader struct {
GroupName string
}
deleteSubscriptionGroup 删除消费分组的请求头 Author rongzhihong Since 2017/9/19
func (*DeleteSubscriptionGroupRequestHeader) CheckFields ¶
func (header *DeleteSubscriptionGroupRequestHeader) CheckFields() error
type DeleteTopicRequestHeader ¶
type DeleteTopicRequestHeader struct {
Topic string `json:"topic"`
}
DeleteTopicRequestHeader 删除Topic Author gaoyanlei Since 2017/8/25
func (*DeleteTopicRequestHeader) CheckFields ¶
func (header *DeleteTopicRequestHeader) CheckFields() error
type EndTransactionRequestHeader ¶
type EndTransactionRequestHeader struct { ProducerGroup string `json:"producerGroup"` TranStateTableOffset int64 `json:"tranStateTableOffset"` CommitLogOffset int64 `json:"commitLogOffset"` CommitOrRollback int64 `json:"commitOrRollback"` FromTransactionCheck bool `json:"fromTransactionCheck"` MsgId string `json:"msgId"` TransactionId string `json:"transactionId"` }
EndTransactionRequestHeader 事务请求头 Author rongzhihong Since 2017/9/18
func (*EndTransactionRequestHeader) CheckFields ¶
func (header *EndTransactionRequestHeader) CheckFields() error
type GetAllTopicConfigResponseHeader ¶
type GetAllTopicConfigResponseHeader struct { }
GetAllTopicConfigResponseHeader 获得Topic配置的返回头 Author rongzhihong Since 2017/9/19
func (*GetAllTopicConfigResponseHeader) CheckFields ¶
func (header *GetAllTopicConfigResponseHeader) CheckFields() error
type GetBrokerConfigResponseHeader ¶
type GetBrokerConfigResponseHeader struct {
Version string
}
GetBrokerConfigResponseHeader 获得Broker配置信息的返回头 Author rongzhihong Since 2017/9/19
func (*GetBrokerConfigResponseHeader) CheckFields ¶
func (header *GetBrokerConfigResponseHeader) CheckFields() error
type GetConsumeStatsRequestHeader ¶
type GetConsumeStatsRequestHeader struct { Topic string `json:"topic"` ConsumerGroup string `json:"consumerGroup"` }
GetConsumeStatsRequestHeader 获得消费者统计信息的请求头 Author rongzhihong Since 2017/9/19
func NewGetConsumeStatsRequestHeader ¶
func NewGetConsumeStatsRequestHeader(consumerGroup, topic string) *GetConsumeStatsRequestHeader
NewGetConsumeStatsRequestHeader 初始化 Author: tianyuliang Since: 2017/11/1
func (*GetConsumeStatsRequestHeader) CheckFields ¶
func (header *GetConsumeStatsRequestHeader) CheckFields() error
type GetConsumerConnectionListRequestHeader ¶
type GetConsumerConnectionListRequestHeader struct {
ConsumerGroup string `json:"consumerGroup"`
}
GetConsumerConnectionListRequestHeader 获得Toipc统计信息的请求头 Author rongzhihong Since 2017/9/19
func NewGetConsumerConnectionListRequestHeader ¶
func NewGetConsumerConnectionListRequestHeader(consumerGroup string) *GetConsumerConnectionListRequestHeader
NewGetConsumerConnectionListRequestHeader 初始化 Author: tianyuliang Since: 2017/11/1
func (*GetConsumerConnectionListRequestHeader) CheckFields ¶
func (header *GetConsumerConnectionListRequestHeader) CheckFields() error
type GetConsumerListByGroupRequestHeader ¶
type GetConsumerListByGroupRequestHeader struct {
ConsumerGroup string
}
GetConsumerListByGroupRequestHeader: 获取消费列表 Author: yintongqiang Since: 2017/8/11
func (*GetConsumerListByGroupRequestHeader) CheckFields ¶
func (header *GetConsumerListByGroupRequestHeader) CheckFields() error
type GetConsumerListByGroupResponseBody ¶
type GetConsumerListByGroupResponseBody struct { ConsumerIdList []string `json:"consumerIdList"` *protocol.RemotingSerializable }
GetConsumerListByGroupResponseBody: 获取消费者列表 Author: yintongqiang Since: 2017/8/23
func (*GetConsumerListByGroupResponseBody) CheckFields ¶
func (header *GetConsumerListByGroupResponseBody) CheckFields() error
type GetConsumerRunningInfoRequestHeader ¶
type GetConsumerRunningInfoRequestHeader struct { ConsumerGroup string `json:"consumerGroup"` ClientId string `json:"clientId"` JstackEnable bool `json:"jstackEnable"` }
GetConsumerRunningInfoRequestHeader 获取Consumer内存数据结构的请求头 Author rongzhihong Since 2017/9/19
func NewGetConsumerRunningInfoRequestHeader ¶
func NewGetConsumerRunningInfoRequestHeader(consumerGroup, clientId string, jstackEnable bool) *GetConsumerRunningInfoRequestHeader
NewGetConsumerRunningInfoRequestHeader 初始化 Author: tianyuliang Since: 2017/11/6
func (*GetConsumerRunningInfoRequestHeader) CheckFields ¶
func (header *GetConsumerRunningInfoRequestHeader) CheckFields() error
type GetConsumerStatusRequestHeader ¶
type GetConsumerStatusRequestHeader struct { Topic string `json:"topic"` Group string `json:"group"` ClientAddr string `json:"clientAddr"` }
getConsumerStatus 获得消费者状态的请求头 Author rongzhihong Since 2017/9/19
func NewGetConsumerStatusRequestHeader ¶
func NewGetConsumerStatusRequestHeader(topic, group, clientAddr string) *GetConsumerStatusRequestHeader
NewGetConsumerStatusRequestHeader 初始化 Author: tianyuliang Since: 2017/11/6
func (*GetConsumerStatusRequestHeader) CheckFields ¶
func (header *GetConsumerStatusRequestHeader) CheckFields() error
type GetEarliestMsgStoretimeRequestHeader ¶
GetEarliestMsgStoretimeRequestHeader 获得早期消息存储时间的请求头 Author rongzhihong Since 2017/9/19
func (*GetEarliestMsgStoretimeRequestHeader) CheckFields ¶
func (header *GetEarliestMsgStoretimeRequestHeader) CheckFields() error
type GetEarliestMsgStoretimeResponseHeader ¶
type GetEarliestMsgStoretimeResponseHeader struct {
Timestamp int64
}
GetEarliestMsgStoretimeResponseHeader 获得早期消息存储时间的返回头 Author rongzhihong Since 2017/9/19
func (*GetEarliestMsgStoretimeResponseHeader) CheckFields ¶
func (header *GetEarliestMsgStoretimeResponseHeader) CheckFields() error
type GetMaxOffsetRequestHeader ¶
GetMaxOffsetRequestHeader: 获取队列最大offset Author: yintongqiang Since: 2017/8/23
func NewGetMaxOffsetRequestHeader ¶
func NewGetMaxOffsetRequestHeader() *GetMaxOffsetRequestHeader
func (*GetMaxOffsetRequestHeader) CheckFields ¶
func (header *GetMaxOffsetRequestHeader) CheckFields() error
type GetMaxOffsetResponseHeader ¶
type GetMaxOffsetResponseHeader struct {
Offset int64 `json:"offset"`
}
GetMaxOffsetResponseHeader: 最大偏移响应头 Author: yintongqiang Since: 2017/8/23
func (*GetMaxOffsetResponseHeader) CheckFields ¶
func (header *GetMaxOffsetResponseHeader) CheckFields() error
type GetMinOffsetRequestHeader ¶
type GetMinOffsetRequestHeader struct { Topic string `json:"topic"` QueueId int32 `json:"queueId"` }
GetMinOffsetRequestHeader 获得最小偏移量的请求头 Author rongzhihong Since 2017/9/19
func (*GetMinOffsetRequestHeader) CheckFields ¶
func (header *GetMinOffsetRequestHeader) CheckFields() error
type GetMinOffsetResponseHeader ¶
type GetMinOffsetResponseHeader struct {
Offset int64 `json:"offset"`
}
GetMinOffsetResponseHeader 获得最小偏移量的返回头 Author rongzhihong Since 2017/9/19
func (*GetMinOffsetResponseHeader) CheckFields ¶
func (header *GetMinOffsetResponseHeader) CheckFields() error
type GetProducerConnectionListRequestHeader ¶
type GetProducerConnectionListRequestHeader struct {
ProducerGroup string `json:"producerGroup"`
}
GetProducerConnectionListRequestHeader 获得生产者连接信息请求头 Author rongzhihong Since 2017/9/19
func NewGetProducerConnectionListRequestHeader ¶
func NewGetProducerConnectionListRequestHeader(producerGroup string) *GetProducerConnectionListRequestHeader
NewGetProducerConnectionListRequestHeader 初始化 Author: tianyuliang Since: 2017/11/6
func (*GetProducerConnectionListRequestHeader) CheckFields ¶
func (header *GetProducerConnectionListRequestHeader) CheckFields() error
type GetTopicStatsInfoRequestHeader ¶
type GetTopicStatsInfoRequestHeader struct {
Topic string `json:"topic"`
}
GetTopicStatsInfoRequestHeader 获得Topic统计信息的请求头 Author rongzhihong Since 2017/9/19
func NewGetTopicStatsInfoRequestHeader ¶
func NewGetTopicStatsInfoRequestHeader(topic string) *GetTopicStatsInfoRequestHeader
NewGetTopicStatsInfoRequestHeader 初始化 Author: tianyuliang Since: 2017/11/6
func (*GetTopicStatsInfoRequestHeader) CheckFields ¶
func (header *GetTopicStatsInfoRequestHeader) CheckFields() error
type GetTopicsByClusterRequestHeader ¶
type GetTopicsByClusterRequestHeader struct { Cluster string `json:"cluster"` // 集群名称 Extra bool `json:"extra"` // 是否额外查询topic、cluster对应关系 }
func (*GetTopicsByClusterRequestHeader) CheckFields ¶
func (header *GetTopicsByClusterRequestHeader) CheckFields() error
type NotifyConsumerIdsChangedRequestHeader ¶
type NotifyConsumerIdsChangedRequestHeader struct {
ConsumerGroup string
}
NotifyConsumerIdsChangedRequestHeader 通知请求头部 Author: rongzhihong Since: 2017/9/11
func (*NotifyConsumerIdsChangedRequestHeader) CheckFields ¶
func (notify *NotifyConsumerIdsChangedRequestHeader) CheckFields() error
CheckFields Author: rongzhihong Since: 2017/9/11
type PullMessageRequestHeader ¶
type PullMessageRequestHeader struct { ConsumerGroup string `json:"consumerGroup"` Topic string `json:"topic"` QueueId int32 `json:"queueId"` QueueOffset int64 `json:"queueOffset"` MaxMsgNums int `json:"maxMsgNums"` SysFlag int `json:"sysFlag"` CommitOffset int64 `json:"commitOffset"` SuspendTimeoutMillis int `json:"suspendTimeoutMillis"` Subscription string `json:"subscription"` SubVersion int `json:"subVersion"` }
PullMessageRequestHeader: 拉取消息请求头信息 Author: yintongqiang Since: 2017/8/14
func (*PullMessageRequestHeader) CheckFields ¶
func (header *PullMessageRequestHeader) CheckFields() error
type PullMessageResponseHeader ¶
type PullMessageResponseHeader struct { SuggestWhichBrokerId int64 `json:"suggestWhichBrokerId"` NextBeginOffset int64 `json:"nextBeginOffset"` MinOffset int64 `json:"minOffset"` MaxOffset int64 `json:"maxOffset"` }
PullMessageResponseHeader: 拉取消息响应头 Author: yintongqiang Since: 2017/8/16
func (*PullMessageResponseHeader) CheckFields ¶
func (header *PullMessageResponseHeader) CheckFields() error
type QueryConsumeTimeSpanRequestHeader ¶
type QueryConsumeTimeSpanRequestHeader struct { Topic string `json:"topic"` Group string `json:"group"` }
queryConsumeTimeSpan 根据 topic 和 group 获取消息的时间跨度的请求头 Author rongzhihong Since 2017/9/19
func (*QueryConsumeTimeSpanRequestHeader) CheckFields ¶
func (header *QueryConsumeTimeSpanRequestHeader) CheckFields() error
type QueryConsumerOffsetRequestHeader ¶
type QueryConsumerOffsetRequestHeader struct { ConsumerGroup string `json:"consumerGroup"` Topic string `json:"topic"` QueueId int32 `json:"queueId"` }
QueryConsumerOffsetRequestHeader: 查询消费offset Author: yintongqiang Since: 2017/8/24
func (*QueryConsumerOffsetRequestHeader) CheckFields ¶
func (header *QueryConsumerOffsetRequestHeader) CheckFields() error
type QueryConsumerOffsetResponseHeader ¶
type QueryConsumerOffsetResponseHeader struct {
Offset int64 `json:"offset"`
}
QueryConsumerOffsetResponseHeader: 查询offset响应头 Author: yintongqiang Since: 2017/8/24
func (*QueryConsumerOffsetResponseHeader) CheckFields ¶
func (header *QueryConsumerOffsetResponseHeader) CheckFields() error
type QueryCorrectionOffsetRequestHeader ¶
type QueryCorrectionOffsetRequestHeader struct { FilterGroups string `json:"filterGroups"` CompareGroup string `json:"compareGroup"` Topic string `json:"topic"` }
QueryCorrectionOffsetRequestHeader 查找被修正 offset (转发组件)的请求头 Author rongzhihong Since 2017/9/19
func (*QueryCorrectionOffsetRequestHeader) CheckFields ¶
func (header *QueryCorrectionOffsetRequestHeader) CheckFields() error
type QueryMessageRequestHeader ¶
type QueryMessageRequestHeader struct { Topic string `json:"topic"` Key string `json:"key"` MaxNum int32 `json:"maxNum"` BeginTimestamp int64 `json:"beginTimestamp"` EndTimestamp int64 `json:"endTimestamp"` }
QueryMessageResponseHeader 查询消息请求头 Author rongzhihong Since 2017/9/18
func (QueryMessageRequestHeader) CheckFields ¶
func (query QueryMessageRequestHeader) CheckFields() error
type QueryMessageResponseHeader ¶
type QueryMessageResponseHeader struct { IndexLastUpdateTimestamp int64 `json:"indexLastUpdateTimestamp"` IndexLastUpdatePhyoffset int64 `json:"indexLastUpdatePhyoffset"` }
QueryMessageResponseHeader 查询消息返回头 Author rongzhihong Since 2017/9/18
func (QueryMessageResponseHeader) CheckFields ¶
func (query QueryMessageResponseHeader) CheckFields() error
type QueryTopicConsumeByWhoRequestHeader ¶
type QueryTopicConsumeByWhoRequestHeader struct {
Topic string
}
queryTopicConsumeByWho 查询Topic被哪些消费者消费的请求头 Author rongzhihong Since 2017/9/19
func (*QueryTopicConsumeByWhoRequestHeader) CheckFields ¶
func (header *QueryTopicConsumeByWhoRequestHeader) CheckFields() error
type ResetOffsetRequestHeader ¶
ResetOffsetRequestHeader 重置偏移量的请求头 Author rongzhihong Since 2017/9/18
func (*ResetOffsetRequestHeader) CheckFields ¶
func (req *ResetOffsetRequestHeader) CheckFields() error
type SearchOffsetRequestHeader ¶
SearchOffsetRequestHeader 查询偏移量的请求头 Author rongzhihong Since 2017/9/19
func (*SearchOffsetRequestHeader) CheckFields ¶
func (header *SearchOffsetRequestHeader) CheckFields() error
type SearchOffsetResponseHeader ¶
type SearchOffsetResponseHeader struct {
Offset int64
}
SearchOffsetResponseHeader 查询偏移量的返回头 Author rongzhihong Since 2017/9/19
func (*SearchOffsetResponseHeader) CheckFields ¶
func (header *SearchOffsetResponseHeader) CheckFields() error
type SendMessageRequestHeader ¶
type SendMessageRequestHeader struct { ProducerGroup string `json:"producerGroup"` Topic string `json:"topic"` DefaultTopic string `json:"defaultTopic"` DefaultTopicQueueNums int32 `json:"defaultTopicQueueNums"` QueueId int32 `json:"queueId"` SysFlag int32 `json:"sysFlag"` BornTimestamp int64 `json:"bornTimestamp"` Flag int32 `json:"flag"` Properties string `json:"properties"` ReconsumeTimes int32 `json:"reconsumeTimes"` UnitMode bool `json:"unitMode"` }
SendMessageRequestHeader: 发送消息请求头信息 Author: yintongqiang Since: 2017/8/10
func CreateSendMessageRequestHeaderV1 ¶
func CreateSendMessageRequestHeaderV1(v2 *SendMessageRequestHeaderV2) *SendMessageRequestHeader
CreateSendMessageRequestHeaderV1 v2转v1 Author gaoyanlei Since 2017/8/15
func (*SendMessageRequestHeader) CheckFields ¶
func (header *SendMessageRequestHeader) CheckFields() error
type SendMessageRequestHeaderV2 ¶
type SendMessageRequestHeaderV2 struct { A string `json:"a"` B string `json:"b"` C string `json:"c"` D int32 `json:"d"` E int32 `json:"e"` F int32 `json:"f"` G int64 `json:"g"` H int32 `json:"h"` I string `json:"i"` J int32 `json:"j"` K bool `json:"k"` }
SendMessageRequestHeaderV2: 为减少网络传输数量准备 Author: yintongqiang Since: 2017/8/10
func CreateSendMessageRequestHeaderV2 ¶
func CreateSendMessageRequestHeaderV2(v1 *SendMessageRequestHeader) *SendMessageRequestHeaderV2
func (*SendMessageRequestHeaderV2) CheckFields ¶
func (header *SendMessageRequestHeaderV2) CheckFields() error
type SendMessageResponseHeader ¶
type SendMessageResponseHeader struct { MsgId string `json:"msgId"` QueueId int32 `json:"queueId"` QueueOffset int64 `json:"queueOffset"` TransactionId string `json:"transactionId"` }
SendMessageResponseHeader: 发送消息响应头 Author: yintongqiang Since: 2017/8/16
func (*SendMessageResponseHeader) CheckFields ¶
func (header *SendMessageResponseHeader) CheckFields() error
type UnregisterClientRequestHeader ¶
type UnregisterClientRequestHeader struct { ClientID string `json:"clientID"` ProducerGroup string `json:"producerGroup"` ConsumerGroup string `json:"consumerGroup"` }
UnregisterClientRequestHeader: 注销客户端 Author: yintongqiang Since: 2017/8/17
func (*UnregisterClientRequestHeader) CheckFields ¶
func (header *UnregisterClientRequestHeader) CheckFields() error
type UpdateConsumerOffsetRequestHeader ¶
type UpdateConsumerOffsetRequestHeader struct { ConsumerGroup string `json:"consumerGroup"` Topic string `json:"topic"` QueueId int `json:"queueId"` CommitOffset int64 `json:"commitOffset"` }
UpdateConsumerOffsetRequestHeader: 更新消费offset的请求头 Author: yintongqiang Since: 2017/8/11
func (*UpdateConsumerOffsetRequestHeader) CheckFields ¶
func (header *UpdateConsumerOffsetRequestHeader) CheckFields() error
type ViewBrokerStatsDataRequestHeader ¶
type ViewBrokerStatsDataRequestHeader struct { StatsName string `json:"statsName"` StatsKey string `json:"statsKey"` }
ViewBrokerStatsDataRequestHeader 查看Broker统计信息的请求头 Author rongzhihong Since 2017/9/19
func (*ViewBrokerStatsDataRequestHeader) CheckFields ¶
func (header *ViewBrokerStatsDataRequestHeader) CheckFields() error
type ViewMessageRequestHeader ¶
type ViewMessageRequestHeader struct {
Offset uint64 `json:"offset"`
}
ViewMessageRequestHeader 根据MsgId查询消息的请求头 Author rongzhihong Since 2017/9/18
func (*ViewMessageRequestHeader) CheckFields ¶
func (header *ViewMessageRequestHeader) CheckFields() error
Source Files ¶
- check_transaction_state_request_header.go
- clone_group_offset_request_header.go
- consume_message_directly_result_request_header.go
- consumer_send_msg_back_request_header.go
- create_topic_request_header.go
- delete_subscription_group_request_header.go
- delete_topic_request_header.go
- end_transaction_request_header.go
- get_all_topic_config_response_header.go
- get_broker_config_response_header.go
- get_consume_stats_request_header.go
- get_consumer_connectionList_request_header.go
- get_consumer_list_by_group_request_header.go
- get_consumer_list_by_group_response_body.go
- get_consumer_running_info_request_header.go
- get_consumer_status_request_header.go
- get_earliest_msg_storetime_request_header.go
- get_earliest_msg_storetime_response_header.go
- get_max_offset_request_header.go
- get_max_offset_response_header.go
- get_min_offset_request_header.go
- get_min_offset_response_header.go
- get_producer_connectionList_request_header.go
- get_topic_statsInfo_request_header.go
- get_topics_by_cluster_request_header.go
- notify_consumer_ids_changed_request_header.go
- pull_message_request_header.go
- pull_message_response_header.go
- query_consume_timeSpan_request_header.go
- query_consumer_offset_request_header.go
- query_consumer_offset_response_header.go
- query_correction_offset_request_header.go
- query_message_request_header.go
- query_message_response_header.go
- query_topic_consume_by_who_request_header.go
- reset_offset_request_header.go
- search_offset_request_header.go
- search_offset_response_header.go
- send_message_request_header.go
- send_message_request_header_v2.go
- send_message_response_header.go
- unregister_client_request_header.go
- update_consumer_offset_request_header.go
- view_broker_stats_data_request_header.go
- view_message_request_header.go