rocketmq

type Admin interface {
	SearchTopic() (*TopicData, error)
	SearchClusterInfo() (*ClusterInfo, error)
	CreateTopic(topicName, clusterName string, readQueueNum int, writeQueueNum int, order bool) (bool, error)
	QueryMessageById(msgId string) (*MessageExt, error)
	MessageTrackDetail(msg *MessageExt) ([]*MessageTrack, error)
	QueryConsumerGroupByTopic(topic string) ([]string, error)
	QueryConsumerProgress(consumeGroupId string) (*ConsumerProgress, error)
	QueryConsumerConnection(consumeGroupId string) (*ConsumerConnection, error)
	FetchBrokerRuntimeStats(brokerAddr string) (*BrokerRuntimeInfo, error)
	Close() error
}

type AllocateMessageQueueAveragely struct{}

type AllocateMessageQueueStrategy interface {
	// contains filtered or unexported methods
}

type BrokerData struct {
	BrokerName      string           `json:"brokerName"`
	BrokerAddrs     map[int64]string `json:"brokerAddrs"`
	BrokerAddrsLock sync.RWMutex     `json:"-"`
}

type BrokerRuntimeInfo struct {
	BrokerVersionDesc           string  `json:"brokerVersionDesc"`
	BrokerVersion               string  `json:"brokerVersion"`
	MsgPutTotalYesterdayMorning string  `json:"msgPutTotalYesterdayMorning"`
	MsgPutTotalTodayMorning     string  `json:"msgPutTotalTodayMorning"`
	MsgPutTotalTodayNow         string  `json:"msgPutTotalTodayNow"`
	MsgGetTotalYesterdayMorning string  `json:"msgGetTotalYesterdayMorning"`
	MsgGetTotalTodayNow         string  `json:"msgGetTotalTodayNow"`
	SendThreadPoolQueueSize     string  `json:"sendThreadPoolQueueSize"`
	SendThreadPoolQueueCapacity string  `json:"sendThreadPoolQueueCapacity"`
	MsgGetTotalTodayMorning     string  `json:"msgGetTotalTodayMorning"`
	InTps                       float64 `json:"inTps"`
	OutTps                      float64 `json:"outTps"`
}

type ClusterInfo struct {
	BrokerAddrTable  map[string]BrokerData `json:"brokerAddrTable"`
	ClusterAddrTable map[string][]string   `json:"clusterAddrTable"`
}

type Config struct {
	Nameserver   string
	ClientIp     string
	InstanceName string
}

type Connection struct {
	ClientId   string `json:"clientId"`
	ClientAddr string `json:"clientAddr"`
	Language   string `json:"language"`
	Version    int    `json:"version"`
}

type ConsumeStats struct {
	OffsetTable map[MessageQueue]OffsetWrapper `json:"offsetTable"`
	ConsumeTps  int64                          `json:"consumeTps"`
}

type Consumer interface {
	//Admin
	Start() error
	Shutdown()
	RegisterMessageListener(listener MessageListener)
	Subscribe(topic string, subExpression string)
	UnSubcribe(topic string)
	SendMessageBack(msg MessageExt, delayLevel int) error
	SendMessageBack1(msg MessageExt, delayLevel int, brokerName string) error
	// contains filtered or unexported methods
}

type ConsumerConnection struct {
	ConnectionSet     []*Connection                `json:"connectionSet"`
	SubscriptionTable map[string]*SubscriptionData `json:"subscriptionTable"`
	ConsumeType       string                       `json:"consumeType"`
	MessageModel      string                       `json:"messageModel"`
	ConsumeFromWhere  string                       `json:"consumeFromWhere"`
}

type ConsumerData struct {
	GroupName           string
	ConsumerType        string
	MessageModel        string
	ConsumeFromWhere    string
	SubscriptionDataSet []*SubscriptionData
	UnitMode            bool
}

type ConsumerGroup struct {
	BrokerOffset   int64 `json:"brokerOffset"`
	ConsumerOffset int64 `json:"consumerOffset"`
	Diff           int64 `json:"diff"`
	MessageQueue
}

type ConsumerIdSorter []string

type ConsumerProgress struct {
	GroupId string           `json:"groupId"`
	Tps     int64            `json:"tps"`
	Diff    int64            `json:"diff"`
	List    []*ConsumerGroup `json:"list"`
}

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

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

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

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

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

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

type GetConsumerListByGroupResponseBody struct {
	ConsumerIdList []string `json:"consumerIdList"`
}

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

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

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

type GroupList struct {
	GroupList []string `json:"groupList"`
}

type HeartbeatData struct {
	ClientId        string
	ConsumerDataSet []*ConsumerData
}

type InvokeCallback func(responseFuture *ResponseFuture)

type Message struct {
	Topic      string            `json:"topic"`
	Flag       int32             `json:"flag"`
	Body       []byte            `json:"body"`
	Properties map[string]string `json:"properties"`
}

type MessageExt struct {
	Message
	QueueId                   int32  `json:"queueId"`
	StoreSize                 int32  `json:"storeSize"`
	QueueOffset               int64  `json:"queueOffset"`
	SysFlag                   int32  `json:"sysFlag"`
	BornTimestamp             int64  `json:"bornTimestamp"`
	BornHost                  string `json:"bornHost"`
	StoreTimestamp            int64  `json:"storeTimestamp"`
	StoreHost                 string `json:"storeHost"`
	MsgId                     string `json:"msgId"`
	CommitLogOffset           int64  `json:"commitLogOffset"`
	BodyCRC                   int32  `json:"bodyCRC"`
	ReconsumeTimes            int32  `json:"reconsumeTimes"`
	PreparedTransactionOffset int64  `json:"preparedTransactionOffset"`
}

type MessageListener func(msgs []*MessageExt) (int, error)

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

type MessageQueues []*MessageQueue

type MessageTrack struct {
	ConsumerGroup string `json:"consumerGroup"`
	TrackType     int    `json:"trackType"`
	ExceptionDesc string `json:"exceptionDesc"`
}

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

type OffsetStore interface {
	// contains filtered or unexported methods
}

type OffsetWrapper struct {
	BrokerOffset   int64 `json:"brokerOffset"`
	ConsumerOffset int64 `json:"consumerOffset"`
	LastTimestamp  int64 `json:"lastTimestamp"` // 消费的最后一条消息对应的时间戳
}

type PullMessageRequestHeader 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 int64  `json:"suspendTimeoutMillis"`
	Subscription         string `json:"subscription"`
	SubVersion           int64  `json:"subVersion"`
}

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

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

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

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

type QueueData struct {
	BrokerName     string
	ReadQueueNums  int32
	WriteQueueNums int32
	Perm           int32
	TopicSynFlag   int32
}

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

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

type RemotingClient interface {
	ScanResponseTable()
	// contains filtered or unexported methods
}

type RemotingCommand struct {
	//header
	Code     int    `json:"code"`
	Language string `json:"language"`
	Version  int    `json:"version"`
	Opaque   int32  `json:"opaque"`
	Flag     int    `json:"flag"`

	ExtFields interface{} `json:"extFields"`
	//body
	Body []byte `json:"body,omitempty"`
	// contains filtered or unexported fields
}

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

type SubscriptionData struct {
	Topic           string   `json:"topic"`
	SubString       string   `json:"subString"`
	ClassFilterMode bool     `json:"classFilterMode"`
	TagsSet         []string `json:"tagsSet"`
	CodeSet         []int    `json:"codeSet"`
	SubVersion      int64    `json:"subVersion"`
}

type TopicData struct {
	List []string `json:"topicList"`
}

type TopicRouteData struct {
	OrderTopicConf string
	QueueDatas     []*QueueData
	BrokerDatas    []*BrokerData
}

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

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