head

type CMResult int

type CheckTransactionStateRequestHeader struct {
	MsgId                string
	TransactionId        string
	TranStateTableOffset int64
	CommitLogOffset      int64
}

type CloneGroupOffsetRequestHeader struct {
	SrcGroup  string `json:"srcGroup"`
	DestGroup string `json:"destGroup"`
	Topic     string `json:"topic"`
	Offline   bool   `json:"offline"`
}

type ConsumeMessageDirectlyResult struct {
	Order          bool
	AutoCommit     bool
	ConsumeResult  CMResult
	Remark         string
	SpentTimeMills int64
}

type ConsumeMessageDirectlyResultRequestHeader struct {
	ConsumerGroup string `json:"consumerGroup"`
	ClientId      string `json:"clientId"`
	MsgId         string `json:"msgId"`
	BrokerName    string `json:"brokerName"`
}

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"`
}

type CreateTopicRequestHeader struct {
	Topic           string // 真正的topic名称是位于topicConfig.Topic字段
	DefaultTopic    string // 表示创建topic的key值
	ReadQueueNums   int32
	WriteQueueNums  int32
	Perm            int
	TopicFilterType basis.TopicFilterType
	TopicSysFlag    int
	Order           bool
}

type DeleteKVConfigRequestHeader struct {
	Namespace string
	Key       string
}

type DeleteSubscriptionGroupRequestHeader struct {
	GroupName string
}

type DeleteTopicInNamesrvRequestHeader struct {
	Topic string
}

type DeleteTopicRequestHeader struct {
	Topic string `json:"topic"`
}

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"`
}

type GetAllTopicConfigResponseHeader struct {
}

type GetBrokerConfigResponseHeader struct {
	Version string
}

type GetConsumerConnectionsRequestHeader struct {
	ConsumerGroup string `json:"consumerGroup"`
}

type GetConsumerRunningInfoRequestHeader struct {
	ConsumerGroup string `json:"consumerGroup"`
	ClientId      string `json:"clientId"`
	JstackEnable  bool   `json:"jstackEnable"`
}

type GetConsumerStatsRequestHeader struct {
	Topic         string `json:"topic"`
	ConsumerGroup string `json:"consumerGroup"`
}

type GetConsumerStatusRequestHeader struct {
	Topic      string `json:"topic"`
	Group      string `json:"group"`
	ClientAddr string `json:"clientAddr"`
}

type GetConsumersByGroupRequestHeader struct {
	ConsumerGroup string
}

type GetEarliestMsgStoretimeRequestHeader struct {
	Topic   string
	QueueId int32
}

type GetEarliestMsgStoretimeResponseHeader struct {
	Timestamp int64
}

type GetKVConfigRequestHeader struct {
	Namespace string `json:"namespace"`
	Key       string `json:"key"`
}

type GetKVConfigResponseHeader struct {
	Value string `json:"value"`
}

type GetKVListByNamespaceRequestHeader struct {
	Namespace string
}

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

type GetMaxOffsetResponseHeader struct {
	Offset int64 `json:"offset"`
}

type GetMinOffsetRequestHeader struct {
	Topic   string `json:"topic"`
	QueueId int32  `json:"queueId"`
}

type GetMinOffsetResponseHeader struct {
	Offset int64 `json:"offset"`
}

type GetProducerConnectionsRequestHeader struct {
	ProducerGroup string `json:"producerGroup"`
}

type GetRouteInfoRequestHeader struct {
	Topic string
}

type GetTopicStatsInfoRequestHeader struct {
	Topic string `json:"topic"`
}

type GetTopicsByClusterRequestHeader struct {
	Cluster string `json:"cluster"` // 集群名称
	Extra   bool   `json:"extra"`   // 是否额外查询topic、cluster对应关系
}

type NotifyConsumerIdsChangedRequestHeader struct {
	ConsumerGroup string
}

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"`
}

type PullMessageResponseHeader struct {
	SuggestWhichBrokerId int64 `json:"suggestWhichBrokerId"`
	NextBeginOffset      int64 `json:"nextBeginOffset"`
	MinOffset            int64 `json:"minOffset"`
	MaxOffset            int64 `json:"maxOffset"`
}

type PutKVConfigRequestHeader struct {
	Namespace string `json:"namespace"`
	Key       string `json:"key"`
	Value     string `json:"value"`
}

type QueryConsumerOffsetRequestHeader struct {
	ConsumerGroup string `json:"consumerGroup"`
	Topic         string `json:"topic"`
	QueueId       int32  `json:"queueId"`
}

type QueryConsumerOffsetResponseHeader struct {
	Offset int64 `json:"offset"`
}

type QueryConsumerTimeSpanRequestHeader struct {
	Topic string `json:"topic"`
	Group string `json:"group"`
}

type QueryCorrectionOffsetRequestHeader struct {
	FilterGroups string `json:"filterGroups"`
	CompareGroup string `json:"compareGroup"`
	Topic        string `json:"topic"`
}

type QueryMessageRequestHeader struct {
	Topic          string `json:"topic"`
	Key            string `json:"key"`
	MaxNum         int32  `json:"maxNum"`
	BeginTimestamp int64  `json:"beginTimestamp"`
	EndTimestamp   int64  `json:"endTimestamp"`
}

type QueryMessageResponseHeader struct {
	IndexLastUpdateTimestamp int64 `json:"indexLastUpdateTimestamp"`
	IndexLastUpdatePhyoffset int64 `json:"indexLastUpdatePhyoffset"`
}

type QueryTopicConsumeByWhoRequestHeader struct {
	Topic string
}

type RegisterBrokerRequestHeader struct {
	BrokerName   string // broker名称
	BrokerAddr   string // broker地址(ip:port)
	ClusterName  string // 集群名字
	HaServerAddr string // ha地址
	BrokerId     int64  // brokerId
}

type RegisterBrokerResponseHeader struct {
	HaServerAddr string // broker备节点地址
	MasterAddr   string // broker主节点地址
}

type RegisterFilterServerRequestHeader struct {
	FilterServerAddr string `json:"filterServerAddr"`
}

type RegisterFilterServerResponseHeader struct {
	BrokerName string `json:"brokerName"`
	BrokerId   int64  `json:"brokerId"`
}

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

type SearchOffsetRequestHeader struct {
	Topic     string
	QueueId   int32
	Timestamp int64
}

type SearchOffsetResponseHeader struct {
	Offset int64
}

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"`
}

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"`
}

type SendMessageResponseHeader struct {
	MsgId         string `json:"msgId"`
	QueueId       int32  `json:"queueId"`
	QueueOffset   int64  `json:"queueOffset"`
	TransactionId string `json:"transactionId"`
}

type UnRegisterBrokerRequestHeader struct {
	BrokerName  string // broker名字
	BrokerAddr  string // broker地址
	ClusterName string // 集群名字
	BrokerId    int    // brokerId
}

type UnRegisterClientRequestHeader struct {
	ClientID      string `json:"clientID"`
	ProducerGroup string `json:"producerGroup"`
	ConsumerGroup string `json:"consumerGroup"`
}

type UpdateConsumerOffsetRequestHeader struct {
	ConsumerGroup string `json:"consumerGroup"`
	Topic         string `json:"topic"`
	QueueId       int    `json:"queueId"`
	CommitOffset  int64  `json:"commitOffset"`
}

type ViewBrokerStatsDataRequestHeader struct {
	StatsName string `json:"statsName"`
	StatsKey  string `json:"statsKey"`
}

type ViewMessageRequestHeader struct {
	Offset uint64 `json:"offset"`
}

type WipeWritePermOfBrokerRequestHeader struct {
	BrokerName string // broker名称
}

type WipeWritePermOfBrokerResponseHeader struct {
	WipeTopicCount int
}