header

package
v0.0.0-...-130f5e9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 25, 2018 License: Apache-2.0 Imports: 2 Imported by: 5

Documentation

Index

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

type GetEarliestMsgStoretimeRequestHeader struct {
	Topic   string
	QueueId int32
}

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

type GetMaxOffsetRequestHeader struct {
	Topic   string `json:"topic"`
	QueueId int    `json:"queueId"`
}

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

type ResetOffsetRequestHeader struct {
	Topic     string
	Group     string
	Timestamp int64
	IsForce   bool
}

ResetOffsetRequestHeader 重置偏移量的请求头 Author rongzhihong Since 2017/9/18

func (*ResetOffsetRequestHeader) CheckFields

func (req *ResetOffsetRequestHeader) CheckFields() error

type SearchOffsetRequestHeader

type SearchOffsetRequestHeader struct {
	Topic     string
	QueueId   int32
	Timestamp int64
}

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL