Versions in this module Expand all Collapse all v2 v2.1.1 Feb 14, 2023 v2.1.0 Feb 14, 2023 Changes in this version + func FetchMasterAddrByClusterName(ctx context.Context, admin *admin, clusterName string) ([]string, error) + func NewAdmin(opts ...AdminOption) (*admin, error) + type Admin interface + Close func() error + CreateTopic func(ctx context.Context, opts ...OptionCreate) error + DeleteTopic func(ctx context.Context, opts ...OptionDelete) error + FetchAllTopicList func(ctx context.Context) (*internal.TopicList, error) + FetchPublishMessageQueues func(ctx context.Context, topic string) ([]*primitive.MessageQueue, error) + GetBrokerClusterInfo func(ctx context.Context) (*internal.ClusterInfo, error) + type AdminOption func(options *adminOptions) + func WithCredentials(c primitive.Credentials) AdminOption + func WithNamespace(namespace string) AdminOption + func WithResolver(resolver primitive.NsResolver) AdminOption + type OptionCreate func(*TopicConfigCreate) + func WithBrokerAddrCreate(BrokerAddr string) OptionCreate + func WithClusterNameCreate(ClusterName string) OptionCreate + func WithOrder(Order bool) OptionCreate + func WithPerm(Perm int) OptionCreate + func WithReadQueueNums(ReadQueueNums int) OptionCreate + func WithTopicCreate(Topic string) OptionCreate + func WithTopicFilterType(TopicFilterType string) OptionCreate + func WithTopicSysFlag(TopicSysFlag int) OptionCreate + func WithWriteQueueNums(WriteQueueNums int) OptionCreate + type OptionDelete func(*TopicConfigDelete) + func WithBrokerAddrDelete(BrokerAddr string) OptionDelete + func WithClusterNameDelete(ClusterName string) OptionDelete + func WithNameSrvAddr(NameSrvAddr []string) OptionDelete + func WithTopicDelete(Topic string) OptionDelete + type TopicConfigCreate struct + BrokerAddr string + ClusterName string + DefaultTopic string + Order bool + Perm int + ReadQueueNums int + Topic string + TopicFilterType string + TopicSysFlag int + WriteQueueNums int + type TopicConfigDelete struct + BrokerAddr string + ClusterName string + NameSrvAddr []string + Topic string
Go to main page