Versions in this module Expand all Collapse all v2 v2.3.1 Aug 12, 2024 v2.3.0 Aug 12, 2024 Changes in this version type AdminOption + func WithTls(useTls bool) AdminOption v2.2.2 Mar 22, 2023 v2.2.1 Mar 22, 2023 Changes in this version + 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) (*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(options *adminOptions) + func WithCredentials(c primitive.Credentials) AdminOption + func WithNamespace(namespace string) AdminOption + func WithResolver(resolver primitive.NsResolver) AdminOption + type DataVersion struct + Counter int32 + Timestamp int64 + 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 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 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 + type TopicList struct + BrokerAddr string + TopicList []string
Go to main page