Versions in this module Expand all Collapse all v2 v2.1.2 Jul 3, 2022 v2.1.2-rc1 Jul 3, 2022 v2.1.1 Jul 3, 2022 Changes in this version + type Admin interface + Close func() error + CreateTopic func(ctx context.Context, opts ...OptionCreate) error + DeleteTopic func(ctx context.Context, opts ...OptionDelete) error + func NewAdmin(opts ...AdminOption) (Admin, error) + type AdminOption func(options *adminOptions) + func WithResolver(resolver primitive.NsResolver) AdminOption + type OptionCreate func(*TopicConfigCreate) + func WithBrokerAddrCreate(BrokerAddr 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 WithClusterName(ClusterName string) OptionDelete + func WithNameSrvAddr(NameSrvAddr []string) OptionDelete + func WithTopicDelete(Topic string) OptionDelete + type TopicConfigCreate struct + BrokerAddr 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