admin

type Admin interface {
	CreateTopic(ctx context.Context, opts ...OptionCreate) error
	DeleteTopic(ctx context.Context, opts ...OptionDelete) error
	//TODO
	GetTopicsByCluster(ctx context.Context, opts ...OptionTopicList) (*simplejson.Json, error)
	GetBrokerRuntimeInfo(ctx context.Context, nameserver string, broker string) (*simplejson.Json, error)
	GetConsumeStats(ctx context.Context, opts ...OptionGetConsumeStats) (*simplejson.Json, error)
	WipeWritePerm(ctx context.Context, opts ...OptionWipeWritePerm) error
	QueryTopicConsumeByWho(ctx context.Context, opts ...OptionQueryTopicConsume) (*simplejson.Json, error)
	UpdateAndCreateSubscriptionGroup(ctx context.Context, opts ...OptionUpdatesubGroup) error
	UpdateTopic(ctx context.Context, opts ...OptionCreate) error
	GetConsumerRunningInfo(ctx context.Context, opts ...OptionConsumerInfo) (gjson.Result, error)
	DeleteSubscriptionGroup(ctx context.Context, opts ...OptionDeleteSubGroup) error
	GetConsumerOffset(ctx context.Context, opts ...OptionConsumerOffset) (int64, error)
	GetRouteInfo(ctx context.Context, opts ...OptionGetRouteInfo) (*internal.TopicRouteData, error)
	GetConsumeStatsInBroker(ctx context.Context, opts ...OptionConsumeStatsInBroker) (gjson.Result, error)
	GetBrokerClusterInfo(ctx context.Context, nameserver string) (gjson.Result, error)
	UpdateConsumerOffset(ctx context.Context, opts ...OptionUpdateConsumerOffset) error
	DeleteTopicInBroker(topic string, broker string, nameSrvAddr string) error
	Close() error
}

type AdminOption func(options *adminOptions)

type ClusterListConfig struct {
	NamesvrAddr string
}

type OptionClusterList func(*ClusterListConfig)

type OptionConsumeStatsInBroker func(config *OptionConsumeStatsInBrokerConfig)

type OptionConsumeStatsInBrokerConfig struct {
	IsOrder    bool
	BrokerAddr string
}

type OptionConsumerInfo func(config *OptionConsumerInfoConfig)

type OptionConsumerInfoConfig struct {
	ConsumerGroup string
	BrokerAddr    string
}

type OptionConsumerOffset func(*OptionConsumerOffsetConfig)

type OptionConsumerOffsetConfig struct {
	ConsumerGroup string
	Topic         string
	QueueId       int
	BrokerAddr    string
}

type OptionCreate func(*TopicConfigCreate)

type OptionDelete func(*TopicConfigDelete)

type OptionDeleteSubGroup func(*OptionDeleteSubGroupConfig)

type OptionDeleteSubGroupConfig struct {
	GroupName   string
	ClusterName string
	BrokerAddr  string
}

type OptionGetConsumeStats func(*OptionGetConsumeStatsConfig)

type OptionGetConsumeStatsConfig struct {
	ConsumerGroup string
	Topic         string
	BrokerAddr    string
}

type OptionGetRouteInfo func(*OptionGetRouteInfoConfig)

type OptionGetRouteInfoConfig struct {
	Topic       string
	NamesrvAddr string
}

type OptionQueryConsumeQueue func(*OptionQueryConsumeQueueConfig)

type OptionQueryConsumeQueueConfig struct {
	Topic         string
	QueueId       string
	Index         int
	Count         int
	ConsumerGroup string
}

type OptionQueryTopicConsume func(config *QueryTopicConsumeConfig)

type OptionRegisterBroker func(broker *OptionRegisterBrokerConfig)

type OptionRegisterBrokerConfig struct {
	BrokerName   string
	BrokerAddr   string
	ClusterName  string
	HaServerAddr string
	BrokerId     int

	NameSrvAddr string
	// contains filtered or unexported fields
}

type OptionTopicList func(*OptionTopicListConfig)

type OptionTopicListConfig struct {
	Cluster    string
	Nameserver string
}

type OptionUpdateConsumerOffset func(config *OptionUpdateConsumerOffsetConfig)

type OptionUpdateConsumerOffsetConfig struct {
	ConsumerGroup string
	Topic         string
	QueueId       int
	CommitOffset  int64
	BrokerAddr    string
}

type OptionUpdatesubGroup func(config *OptionUpdatesubGroupConfig)

type OptionUpdatesubGroupConfig struct {
	BrokerAddr             string
	ClusterName            string
	GroupName              string
	BrokerId               string
	NamesrvAddr            string
	RetryQueueNums         int
	RetryMaxTimes          int64
	ConsumeEnable          bool
	ConsumeFromMinEnable   bool
	ConsumeBroadcastEnable bool
}

type OptionWipeWritePerm func(*OptionWipeWritePermConfig)

type OptionWipeWritePermConfig struct {
	BrokerName  string
	NamesrvAddr string
}

type QueryTopicConsumeConfig struct {
	Brokeraddr string
	Topic      string
}

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

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