kernel

type BrokerData struct {
	Cluster         string           `json:"cluster"`
	BrokerName      string           `json:"brokerName"`
	BrokerAddresses map[int64]string `json:"brokerAddrs"`
	// contains filtered or unexported fields
}

type ClientOption struct {
	NameServerAddr    string
	ClientIP          string
	InstanceName      string
	UnitMode          bool
	UnitName          string
	VIPChannelEnabled bool
	UseTLS            bool
}

type FindBrokerResult struct {
	BrokerAddr    string
	Slave         bool
	BrokerVersion int32
}

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

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

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

type InnerConsumer interface {
	PersistConsumerOffset()
	UpdateTopicSubscribeInfo(topic string, mqs []*MessageQueue)
	IsSubscribeTopicNeedUpdate(topic string) bool
	SubscriptionDataList() []*SubscriptionData
	Rebalance()
	IsUnitMode() bool
}

type InnerProducer interface {
	PublishTopicList() []string
	UpdateTopicPublishInfo(topic string, info *TopicPublishInfo)
	IsPublishTopicNeedUpdate(topic string) bool
	//GetTransactionListener() TransactionListener
	IsUnitMode() bool
}

type Message struct {
	Topic         string
	Body          []byte
	Flag          int32
	Properties    map[string]string
	TransactionId string
	Batch         bool
}

type MessageExt struct {
	Message
	MsgId                     string
	QueueId                   int32
	StoreSize                 int32
	QueueOffset               int64
	SysFlag                   int32
	BornTimestamp             int64
	BornHost                  string
	StoreTimestamp            int64
	StoreHost                 string
	CommitLogOffset           int64
	BodyCRC                   int32
	ReconsumeTimes            int32
	PreparedTransactionOffset int64
}

type MessageQueue struct {
	Topic      string `json:"topic"`
	BrokerName string `json:"brokerName"`
	QueueId    int    `json:"queueId"`
}

type PullMessageRequest struct {
	ConsumerGroup        string        `json:"consumerGroup"`
	Topic                string        `json:"topic"`
	QueueId              int32         `json:"queueId"`
	QueueOffset          int64         `json:"queueOffset"`
	MaxMsgNums           int32         `json:"maxMsgNums"`
	SysFlag              int32         `json:"sysFlag"`
	CommitOffset         int64         `json:"commitOffset"`
	SuspendTimeoutMillis time.Duration `json:"suspendTimeoutMillis"`
	SubExpression        string        `json:"subscription"`
	SubVersion           int64         `json:"subVersion"`
	ExpressionType       string        `json:"expressionType"`
}

type PullMessageResponse struct {
	SuggestWhichBrokerId int64
	NextBeginOffset      int64
	MinOffset            int64
	MaxOffset            int64
}

type PullResult struct {
	NextBeginOffset      int64
	MinOffset            int64
	MaxOffset            int64
	Status               PullStatus
	SuggestWhichBrokerId int64
	// contains filtered or unexported fields
}

type PullStatus int

type QueryConsumerOffsetRequest struct {
	ConsumerGroup string `json:"consumerGroup"`
	Topic         string `json:"topic"`
	QueueId       int    `json:"queueId"`
}

type QueueData struct {
	BrokerName     string `json:"brokerName"`
	ReadQueueNums  int    `json:"readQueueNums"`
	WriteQueueNums int    `json:"writeQueueNums"`
	Perm           int    `json:"perm"`
	TopicSynFlag   int    `json:"topicSynFlag"`
}

type RMQClient struct {
	// contains filtered or unexported fields
}

type SearchOffsetRequest struct {
	Topic     string `json:"topic"`
	QueueId   int    `json:"queueId"`
	Timestamp int64  `json:"timestamp"`
}

type SendMessageRequest struct {
	ProducerGroup     string `json:"producerGroup"`
	Topic             string `json:"topic"`
	QueueId           int    `json:"queueId"`
	SysFlag           int    `json:"sysFlag"`
	BornTimestamp     int64  `json:"bornTimestamp"`
	Flag              int32  `json:"flag"`
	Properties        string `json:"properties"`
	ReconsumeTimes    int    `json:"reconsumeTimes"`
	UnitMode          bool   `json:"unitMode"`
	MaxReconsumeTimes int    `json:"maxReconsumeTimes"`
	Batch             bool
}

type SendMessageResponse struct {
	MsgId         string
	QueueId       int32
	QueueOffset   int64
	TransactionId string
	MsgRegion     string
}

type SendResult struct {
	Status        SendStatus
	MsgID         string
	MessageQueue  *MessageQueue
	QueueOffset   int64
	TransactionID string
	OffsetMsgID   string
	RegionID      string
	TraceOn       bool
}

type SendStatus int

type ServiceState int

type SubscriptionData struct {
	ClassFilterMode bool
	Topic           string
	SubString       string
	Tags            map[string]bool
	Codes           map[int32]bool
	SubVersion      int64
	ExpType         string
}

type TopicPublishInfo struct {
	OrderTopic          bool
	HaveTopicRouterInfo bool
	MqList              []*MessageQueue
	RouteData           *TopicRouteData
	TopicQueueIndex     int32
}

type TopicRouteData struct {
	OrderTopicConf string
	QueueDataList  []*QueueData  `json:"queueDatas"`
	BrokerDataList []*BrokerData `json:"brokerDatas"`
}

type TransactionListener interface {
}

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