admin

Aug 3, 2023

Changes in this version

type Admin

+ FetchAllTopicList func(ctx context.Context) (*TopicList, error)

+ FetchPublishMessageQueues func(ctx context.Context, topic string) ([]*primitive.MessageQueue, error)

+ GetAllSubscriptionGroup func(ctx context.Context, brokerAddr string, timeoutMillis time.Duration) (*SubscriptionGroupWrapper, error)

type AdminOption

+ func WithCredentials(c primitive.Credentials) AdminOption

+ func WithNamespace(namespace string) AdminOption

+ type DataVersion struct

+ Counter int32

+ Timestamp int64

+ type RemotingSerializable struct

+ func (r *RemotingSerializable) Decode(data []byte, classOfT interface{}) (interface{}, error)

+ func (r *RemotingSerializable) Encode(obj interface{}) ([]byte, error)

+ func (r *RemotingSerializable) FromJson(jsonStr string, classOfT interface{}) (interface{}, error)

+ func (r *RemotingSerializable) ToJson(obj interface{}, prettyFormat bool) string

+ type SubscriptionGroupConfig struct

+ BrokerId int

+ ConsumeBroadcastEnable bool

+ ConsumeEnable bool

+ ConsumeFromMinEnable bool

+ GroupName string

+ NotifyConsumerIdsChangedEnable bool

+ RetryMaxTimes int

+ RetryQueueNums int

+ WhichBrokerWhenConsumeSlowly int

+ type SubscriptionGroupWrapper struct

+ DataVersion DataVersion

+ SubscriptionGroupTable map[string]SubscriptionGroupConfig

+ type TopicList struct

+ BrokerAddr string

+ TopicList []string

Mar 16, 2021

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