admin

type Admin interface {
	CreateTopic(ctx context.Context, opts ...OptionCreate) error
	DeleteTopic(ctx context.Context, opts ...OptionDelete) error

	GetAllSubscriptionGroup(ctx context.Context, brokerAddr string, timeoutMillis time.Duration) (*SubscriptionGroupWrapper, error)
	FetchAllTopicList(ctx context.Context) (*TopicList, error)
	QueryTopicRouteInfo(topic string) (*internal.TopicRouteData, error)
	QueryConsumersByTopic(topic string) (*internal.TopicRouteData, error)
	QueryConsumerConnectsByGroup(ctx context.Context, group string) (*ConsumerConnection, error)
	//GetBrokerClusterInfo(ctx context.Context) (*remote.RemotingCommand, error)
	FetchPublishMessageQueues(ctx context.Context, topic string) ([]*primitive.MessageQueue, error)
	Close() error
}

type AdminConsumerRunningInfo struct {
	*internal.ConsumerRunningInfo
	RemotingSerializable
}

type AdminOption func(options *adminOptions)

type ClientVersion string

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

type Comparable interface {
	CompareTo(o interface{}) int
}

type Connection struct {
	ClientId   string              `json:"clientId"`
	ClientAddr string              `json:"clientAddr"`
	Language   remote.LanguageCode `json:"language"`
	Version    int64               `json:"version"`
}

type ConnectionInfo struct {
	Connection
	VersionDesc string `json:"versionDesc"`
}

type ConsumeFromWhere string

type ConsumeMessageDirectlyResult struct {
	Order          bool   `json:"order"`
	AutoCommit     bool   `json:"autoCommit"`
	ConsumeResult  string `json:"consumeResult"`
	Remark         string `json:"remark"`
	SpentTimeMills int64  `json:"spentTimeMills"`
	RemotingSerializable
}

type ConsumeStats struct {
	OffsetTable map[*primitive.MessageQueue]*OffsetWrapper `json:"-"`
	ConsumeTps  float64                                    `json:"consumeTps"`
	RemotingSerializable
}

type ConsumeType string

type ConsumerConfigInfo struct {
	ClusterNameList         []string                `json:"clusterNameList"`
	BrokerNameList          []string                `json:"brokerNameList"`
	SubscriptionGroupConfig SubscriptionGroupConfig `json:"subscriptionGroupConfig"`
}

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

type ConsumerConnectionInfo struct {
	ConnectionSet []*ConnectionInfo `json:"connectionSet"`
	*ConsumerConnection
}

type ConsumerGroupRollBackStat struct {
	Status            bool             `json:"status"`
	ErrMsg            string           `json:"errMsg"`
	RollbackStatsList []*RollbackStats `json:"rollbackStatsList"`
}

type DataVersion struct {
	Timestamp int64
	Counter   int32
}

type DeleteSubGroupRequest struct {
	GroupName      string   `json:"groupName"`
	BrokerNameList []string `json:"brokerNameList"`
}

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

type GroupConsumeInfo struct {
	Group        string       `json:"group"`
	Version      string       `json:"version"`
	Count        int          `json:"count"`
	ConsumeType  ConsumeType  `json:"consumeType"`
	MessageModel MessageModel `json:"messageModel"`
	ConsumeTps   int          `json:"consumeTps"`
	DiffTotal    int64        `json:"diffTotal"`
}

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

type KVTable struct {
	Table map[string]string `json:"table"`
	RemotingSerializable
}

type MessageModel string

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

type MessageView struct {
	*primitive.MessageExt
	MessageBody string `json:"messageBody"`
}

type MqAdmin struct {
	Cli internal.RMQClient
	// contains filtered or unexported fields
}

type MqClientApi struct {
	Cli internal.RMQClient
}

type MqConsumerApi struct {
	Cli      internal.RMQClient
	Consumer *consumer.DefaultPullConsumer
}

type OffsetWrapper struct {
	BrokerOffset   int64
	ConsumerOffset int64
	LastTimestamp  int64
}

type OptionCreate func(*TopicConfigCreate)

type OptionDelete func(*TopicConfigDelete)

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

type QueryResult struct {
	IndexLastUpdateTimestamp int64          `json:"indexLastUpdateTimestamp"`
	MessageList              []*MessageView `json:"messageList"`
}

type QueueStatInfo struct {
	BrokerName     string `json:"brokerName"`
	QueueId        int    `json:"queueId"`
	BrokerOffset   int64  `json:"brokerOffset"`
	ConsumerOffset int64  `json:"consumerOffset"`
	ClientInfo     string `json:"clientInfo"`
	LastTimestamp  int64  `json:"lastTimestamp"`
}

type RemotingSerializable struct {
	ObjToKey bool `json:"-"`
}

type ResetOffsetRequest struct {
	ConsumerGroupList []string `json:"consumerGroupList"`
	Topic             string   `json:"topic"`
	ResetTime         int64    `json:"resetTime"`
	Force             bool     `json:"force"`
}

type RollbackStats struct {
	BrokerName      string `json:"brokerName"`
	QueueId         int    `json:"queueId"`
	BrokerOffset    int64  `json:"brokerOffset"`
	ConsumerOffset  int64  `json:"consumerOffset"`
	TimestampOffset int64  `json:"timestampOffset"`
	RollbackOffset  int64  `json:"rollbackOffset"`
}

type SendTopicMessageRequest struct {
	Topic       string `json:"topic"`
	Key         string `json:"key"`
	Tag         string `json:"tag"`
	MessageBody string `json:"messageBody"`
}

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

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

type SubscriptionGroupConfig struct {
	GroupName                      string
	ConsumeEnable                  bool
	ConsumeFromMinEnable           bool
	ConsumeBroadcastEnable         bool
	RetryMaxTimes                  int
	RetryQueueNums                 int
	BrokerId                       int
	WhichBrokerWhenConsumeSlowly   int
	NotifyConsumerIdsChangedEnable bool
}

type SubscriptionGroupWrapper struct {
	SubscriptionGroupTable map[string]SubscriptionGroupConfig
	DataVersion            DataVersion
	RemotingSerializable
}

type TopicConfigCreate struct {
	Topic           string
	BrokerAddr      string
	DefaultTopic    string
	ReadQueueNums   int
	WriteQueueNums  int
	Perm            int
	TopicFilterType string
	TopicSysFlag    int
	Order           bool
}

type TopicConfigDelete struct {
	Topic       string
	ClusterName string
	NameSrvAddr []string
	BrokerAddr  string
}

type TopicConsumerInfo struct {
	Topic             string           `json:"topic"`
	DiffTotal         int64            `json:"diffTotal"`
	LastTimestamp     int64            `json:"lastTimestamp"`
	QueueStatInfoList []*QueueStatInfo `json:"queueStatInfoList"`
}

type TopicList struct {
	TopicList  []string `json:"topicList"`
	BrokerAddr string   `json:"brokerAddr"`
	RemotingSerializable
}

type TopicOffset struct {
	MinOffset           int64 `json:"minOffset"`
	MaxOffset           int64 `json:"maxOffset"`
	LastUpdateTimestamp int64 `json:"lastUpdateTimestamp"`
}

type TopicStatsTable struct {
	OffsetTable map[*primitive.MessageQueue]*TopicOffset `json:"offsetTable"`
	RemotingSerializable
}

type TrackType string