admin

package

Go to main page

Versions in this module

v0

v0.18.0

Dec 8, 2025

v0.18.0-candidate-2

Dec 8, 2025

v0.18.0-candidate-1

Dec 1, 2025

v0.17.0

Oct 10, 2025

Changes in this version

type BrokerStats

+ GetAllocatorStatsWithContext func(ctx context.Context, allocatorName string) (*utils.AllocatorStats, error)

+ GetLoadReportWithContext func(context.Context) (*utils.LocalBrokerData, error)

+ GetMBeansWithContext func(context.Context) ([]utils.Metrics, error)

+ GetMetricsWithContext func(context.Context) ([]utils.Metrics, error)

+ GetTopicsWithContext func(context.Context) (string, error)

type Brokers

+ DeleteDynamicConfigurationWithContext func(ctx context.Context, configName string) error

+ GetActiveBrokersWithContext func(ctx context.Context, cluster string) ([]string, error)

+ GetAllDynamicConfigurationsWithContext func(context.Context) (map[string]string, error)

+ GetDynamicConfigurationNamesWithContext func(context.Context) ([]string, error)

+ GetInternalConfigurationDataWithContext func(context.Context) (*utils.InternalConfigurationData, error)

+ GetLeaderBrokerWithContext func(context.Context) (utils.BrokerInfo, error)

+ GetListActiveBrokersWithContext func(context.Context) ([]string, error)

+ GetOwnedNamespacesWithContext func(ctx context.Context, cluster, brokerURL string) (map[string]utils.NamespaceOwnershipStatus, error)

+ GetRuntimeConfigurationsWithContext func(context.Context) (map[string]string, error)

+ HealthCheckWithContext func(context.Context) error

+ HealthCheckWithTopicVersionWithContext func(context.Context, utils.TopicVersion) error

+ UpdateDynamicConfigurationWithContext func(ctx context.Context, configName, configValue string) error

type Clusters

+ CreateFailureDomainWithContext func(context.Context, utils.FailureDomainData) error

+ CreateWithContext func(context.Context, utils.ClusterData) error

+ DeleteFailureDomainWithContext func(context.Context, utils.FailureDomainData) error

+ DeleteWithContext func(context.Context, string) error

+ GetFailureDomainWithContext func(ctx context.Context, clusterName, domainName string) (utils.FailureDomainData, error)

+ GetPeerClustersWithContext func(context.Context, string) ([]string, error)

+ GetWithContext func(context.Context, string) (utils.ClusterData, error)

+ ListFailureDomainsWithContext func(context.Context, string) (utils.FailureDomainMap, error)

+ ListWithContext func(context.Context) ([]string, error)

+ UpdateFailureDomainWithContext func(context.Context, utils.FailureDomainData) error

+ UpdatePeerClustersWithContext func(context.Context, string, []string) error

+ UpdateWithContext func(context.Context, utils.ClusterData) error

type Functions

+ CreateFuncWithContext func(ctx context.Context, data *utils.FunctionConfig, fileName string) error

+ CreateFuncWithURLWithContext func(ctx context.Context, data *utils.FunctionConfig, pkgURL string) error

+ DeleteFunctionWithContext func(ctx context.Context, tenant, namespace, name string) error

+ DownloadFunctionByNsWithContext func(ctx context.Context, destinationFile, tenant, namespace, function string) error

+ DownloadFunctionWithContext func(ctx context.Context, path, destinationFile string) error

+ GetFunctionStateWithContext func(ctx context.Context, tenant, namespace, name, key string) (utils.FunctionState, error)

+ GetFunctionStatsWithContext func(ctx context.Context, tenant, namespace, name string) (utils.FunctionStats, error)

+ GetFunctionStatsWithInstanceIDWithContext func(ctx context.Context, tenant, namespace, name string, instanceID int) (utils.FunctionInstanceStatsData, error)

+ GetFunctionStatusWithContext func(ctx context.Context, tenant, namespace, name string) (utils.FunctionStatus, error)

+ GetFunctionStatusWithInstanceIDWithContext func(ctx context.Context, tenant, namespace, name string, instanceID int) (utils.FunctionInstanceStatusData, error)

+ GetFunctionWithContext func(ctx context.Context, tenant, namespace, name string) (utils.FunctionConfig, error)

+ GetFunctionsWithContext func(ctx context.Context, tenant, namespace string) ([]string, error)

+ PutFunctionStateWithContext func(ctx context.Context, tenant, namespace, name string, state utils.FunctionState) error

+ RestartFunctionWithContext func(ctx context.Context, tenant, namespace, name string) error

+ RestartFunctionWithIDWithContext func(ctx context.Context, tenant, namespace, name string, instanceID int) error

+ StartFunctionWithContext func(ctx context.Context, tenant, namespace, name string) error

+ StartFunctionWithIDWithContext func(ctx context.Context, tenant, namespace, name string, instanceID int) error

+ StopFunctionWithContext func(ctx context.Context, tenant, namespace, name string) error

+ StopFunctionWithIDWithContext func(ctx context.Context, tenant, namespace, name string, instanceID int) error

+ TriggerFunctionWithContext func(ctx context.Context, ...) (string, error)

+ UpdateFunctionWithContext func(ctx context.Context, functionConfig *utils.FunctionConfig, fileName string, ...) error

+ UpdateFunctionWithURLWithContext func(ctx context.Context, functionConfig *utils.FunctionConfig, pkgURL string, ...) error

+ UploadWithContext func(ctx context.Context, sourceFile, path string) error

type FunctionsWorker

+ GetAssignmentsWithContext func(context.Context) (map[string][]string, error)

+ GetClusterLeaderWithContext func(context.Context) (*utils.WorkerInfo, error)

+ GetClusterWithContext func(context.Context) ([]*utils.WorkerInfo, error)

+ GetFunctionsStatsWithContext func(context.Context) ([]*utils.WorkerFunctionInstanceStats, error)

+ GetMetricsWithContext func(context.Context) ([]*utils.Metrics, error)

type Namespaces

+ ClearNamespaceBacklogForSubscriptionWithContext func(ctx context.Context, namespace utils.NameSpaceName, sName string) error

+ ClearNamespaceBacklogWithContext func(ctx context.Context, namespace utils.NameSpaceName) error

+ ClearNamespaceBundleBacklogForSubscriptionWithContext func(ctx context.Context, namespace utils.NameSpaceName, bundle, sName string) error

+ ClearNamespaceBundleBacklogWithContext func(ctx context.Context, namespace utils.NameSpaceName, bundle string) error

+ ClearOffloadDeleteLagWithContext func(ctx context.Context, namespace utils.NameSpaceName) error

+ CreateNamespaceWithContext func(ctx context.Context, namespace string) error

+ CreateNsWithBundlesDataWithContext func(ctx context.Context, namespace string, bundleData *utils.BundlesData) error

+ CreateNsWithNumBundlesWithContext func(ctx context.Context, namespace string, numBundles int) error

+ CreateNsWithPolicesWithContext func(ctx context.Context, namespace string, polices utils.Policies) error

+ DeleteBookieAffinityGroupWithContext func(ctx context.Context, namespace string) error

+ DeleteNamespaceAntiAffinityGroupWithContext func(ctx context.Context, namespace string) error

+ DeleteNamespaceBundleWithContext func(ctx context.Context, namespace string, bundleRange string) error

+ DeleteNamespaceWithContext func(ctx context.Context, namespace string) error

+ GetAntiAffinityNamespacesWithContext func(ctx context.Context, tenant, cluster, namespaceAntiAffinityGroup string) ([]string, error)

+ GetBacklogQuotaMapWithContext func(ctx context.Context, namespace string) (map[utils.BacklogQuotaType]utils.BacklogQuota, error)

+ GetBookieAffinityGroupWithContext func(ctx context.Context, namespace string) (*utils.BookieAffinityGroupData, error)

+ GetCompactionThresholdWithContext func(ctx context.Context, namespace utils.NameSpaceName) (int64, error)

+ GetDispatchRateWithContext func(ctx context.Context, namespace utils.NameSpaceName) (utils.DispatchRate, error)

+ GetInactiveTopicPoliciesWithContext func(ctx context.Context, namespace utils.NameSpaceName) (utils.InactiveTopicPolicies, error)

+ GetIsAllowAutoUpdateSchemaWithContext func(ctx context.Context, namespace utils.NameSpaceName) (bool, error)

+ GetMaxConsumersPerSubscriptionWithContext func(ctx context.Context, namespace utils.NameSpaceName) (int, error)

+ GetMaxConsumersPerTopicWithContext func(ctx context.Context, namespace utils.NameSpaceName) (int, error)

+ GetMaxProducersPerTopicWithContext func(ctx context.Context, namespace utils.NameSpaceName) (int, error)

+ GetMaxTopicsPerNamespace func(namespace utils.NameSpaceName) (int, error)

+ GetMaxTopicsPerNamespaceWithContext func(ctx context.Context, namespace utils.NameSpaceName) (int, error)

+ GetNamespaceAntiAffinityGroupWithContext func(ctx context.Context, namespace string) (string, error)

+ GetNamespaceMessageTTLWithContext func(ctx context.Context, namespace string) (int, error)

+ GetNamespacePermissionsWithContext func(ctx context.Context, namespace utils.NameSpaceName) (map[string][]utils.AuthAction, error)

+ GetNamespaceReplicationClustersWithContext func(ctx context.Context, namespace string) ([]string, error)

+ GetNamespacesWithContext func(ctx context.Context, tenant string) ([]string, error)

+ GetOffloadDeleteLagWithContext func(ctx context.Context, namespace utils.NameSpaceName) (int64, error)

+ GetOffloadThresholdInSecondsWithContext func(ctx context.Context, namespace utils.NameSpaceName) (int64, error)

+ GetOffloadThresholdWithContext func(ctx context.Context, namespace utils.NameSpaceName) (int64, error)

+ GetPersistenceWithContext func(ctx context.Context, namespace string) (*utils.PersistencePolicies, error)

+ GetPoliciesWithContext func(ctx context.Context, namespace string) (*utils.Policies, error)

+ GetPropertiesWithContext func(ctx context.Context, namespace utils.NameSpaceName) (map[string]string, error)

+ GetPublishRateWithContext func(ctx context.Context, namespace utils.NameSpaceName) (utils.PublishRate, error)

+ GetReplicatorDispatchRateWithContext func(ctx context.Context, namespace utils.NameSpaceName) (utils.DispatchRate, error)

+ GetRetentionWithContext func(ctx context.Context, namespace string) (*utils.RetentionPolicies, error)

+ GetSchemaAutoUpdateCompatibilityStrategyWithContext func(ctx context.Context, namespace utils.NameSpaceName) (utils.SchemaAutoUpdateCompatibilityStrategy, error)

+ GetSchemaCompatibilityStrategyWithContext func(ctx context.Context, namespace utils.NameSpaceName) (utils.SchemaCompatibilityStrategy, error)

+ GetSchemaValidationEnforcedWithContext func(ctx context.Context, namespace utils.NameSpaceName) (bool, error)

+ GetSubPermissionsWithContext func(ctx context.Context, namespace utils.NameSpaceName) (map[string][]string, error)

+ GetSubscribeRateWithContext func(ctx context.Context, namespace utils.NameSpaceName) (utils.SubscribeRate, error)

+ GetSubscriptionDispatchRateWithContext func(ctx context.Context, namespace utils.NameSpaceName) (utils.DispatchRate, error)

+ GetSubscriptionExpirationTimeWithContext func(ctx context.Context, namespace utils.NameSpaceName) (int, error)

+ GetTopicAutoCreationWithContext func(ctx context.Context, namespace utils.NameSpaceName) (*utils.TopicAutoCreationConfig, error)

+ GetTopicsWithContext func(ctx context.Context, namespace string) ([]string, error)

+ GrantNamespacePermissionWithContext func(ctx context.Context, namespace utils.NameSpaceName, role string, ...) error

+ GrantSubPermissionWithContext func(ctx context.Context, namespace utils.NameSpaceName, sName string, ...) error

+ RemoveBacklogQuotaWithContext func(ctx context.Context, namespace string) error

+ RemoveInactiveTopicPoliciesWithContext func(ctx context.Context, namespace utils.NameSpaceName) error

+ RemoveMaxTopicsPerNamespace func(namespace utils.NameSpaceName) error

+ RemoveMaxTopicsPerNamespaceWithContext func(ctx context.Context, namespace utils.NameSpaceName) error

+ RemovePropertiesWithContext func(ctx context.Context, namespace utils.NameSpaceName) error

+ RemoveSubscriptionExpirationTimeWithContext func(ctx context.Context, namespace utils.NameSpaceName) error

+ RemoveTopicAutoCreationWithContext func(ctx context.Context, namespace utils.NameSpaceName) error

+ RevokeNamespacePermissionWithContext func(ctx context.Context, namespace utils.NameSpaceName, role string) error

+ RevokeSubPermissionWithContext func(ctx context.Context, namespace utils.NameSpaceName, sName, role string) error

+ SetBacklogQuotaWithContext func(ctx context.Context, namespace string, backlogQuota utils.BacklogQuota, ...) error

+ SetBookieAffinityGroupWithContext func(ctx context.Context, namespace string, ...) error

+ SetCompactionThresholdWithContext func(ctx context.Context, namespace utils.NameSpaceName, threshold int64) error

+ SetDeduplicationStatusWithContext func(ctx context.Context, namespace string, enableDeduplication bool) error

+ SetDispatchRateWithContext func(ctx context.Context, namespace utils.NameSpaceName, rate utils.DispatchRate) error

+ SetEncryptionRequiredStatusWithContext func(ctx context.Context, namespace utils.NameSpaceName, encrypt bool) error

+ SetInactiveTopicPoliciesWithContext func(ctx context.Context, namespace utils.NameSpaceName, ...) error

+ SetIsAllowAutoUpdateSchemaWithContext func(ctx context.Context, namespace utils.NameSpaceName, ...) error

+ SetMaxConsumersPerSubscriptionWithContext func(ctx context.Context, namespace utils.NameSpaceName, max int) error

+ SetMaxConsumersPerTopicWithContext func(ctx context.Context, namespace utils.NameSpaceName, max int) error

+ SetMaxProducersPerTopicWithContext func(ctx context.Context, namespace utils.NameSpaceName, max int) error

+ SetMaxTopicsPerNamespace func(namespace utils.NameSpaceName, max int) error

+ SetMaxTopicsPerNamespaceWithContext func(ctx context.Context, namespace utils.NameSpaceName, max int) error

+ SetNamespaceAntiAffinityGroupWithContext func(ctx context.Context, namespace string, namespaceAntiAffinityGroup string) error

+ SetNamespaceMessageTTLWithContext func(ctx context.Context, namespace string, ttlInSeconds int) error

+ SetNamespaceReplicationClustersWithContext func(ctx context.Context, namespace string, clusterIDs []string) error

+ SetOffloadDeleteLagWithContext func(ctx context.Context, namespace utils.NameSpaceName, timeMs int64) error

+ SetOffloadThresholdInSecondsWithContext func(ctx context.Context, namespace utils.NameSpaceName, threshold int64) error

+ SetOffloadThresholdWithContext func(ctx context.Context, namespace utils.NameSpaceName, threshold int64) error

+ SetPersistenceWithContext func(ctx context.Context, namespace string, persistence utils.PersistencePolicies) error

+ SetPublishRateWithContext func(ctx context.Context, namespace utils.NameSpaceName, pubRate utils.PublishRate) error

+ SetReplicatorDispatchRateWithContext func(ctx context.Context, namespace utils.NameSpaceName, rate utils.DispatchRate) error

+ SetRetentionWithContext func(ctx context.Context, namespace string, policy utils.RetentionPolicies) error

+ SetSchemaAutoUpdateCompatibilityStrategyWithContext func(ctx context.Context, namespace utils.NameSpaceName, ...) error

+ SetSchemaCompatibilityStrategyWithContext func(ctx context.Context, namespace utils.NameSpaceName, ...) error

+ SetSchemaValidationEnforcedWithContext func(ctx context.Context, namespace utils.NameSpaceName, ...) error

+ SetSubscribeRateWithContext func(ctx context.Context, namespace utils.NameSpaceName, rate utils.SubscribeRate) error

+ SetSubscriptionAuthModeWithContext func(ctx context.Context, namespace utils.NameSpaceName, ...) error

+ SetSubscriptionDispatchRateWithContext func(ctx context.Context, namespace utils.NameSpaceName, rate utils.DispatchRate) error

+ SetSubscriptionExpirationTimeWithContext func(ctx context.Context, namespace utils.NameSpaceName, ...) error

+ SetTopicAutoCreationWithContext func(ctx context.Context, namespace utils.NameSpaceName, ...) error

+ SplitNamespaceBundleWithContext func(ctx context.Context, namespace, bundle string, unloadSplitBundles bool) error

+ UnloadNamespaceBundleWithContext func(ctx context.Context, namespace, bundle string) error

+ UnloadWithContext func(ctx context.Context, namespace string) error

+ UnsubscribeNamespaceBundleWithContext func(ctx context.Context, namespace utils.NameSpaceName, bundle, sName string) error

+ UnsubscribeNamespaceWithContext func(ctx context.Context, namespace utils.NameSpaceName, sName string) error

+ UpdatePropertiesWithContext func(ctx context.Context, namespace utils.NameSpaceName, ...) error

type NsIsolationPolicy

+ CreateNamespaceIsolationPolicyWithContext func(ctx context.Context, cluster, policyName string, ...) error

+ DeleteNamespaceIsolationPolicyWithContext func(ctx context.Context, cluster, policyName string) error

+ GetBrokerWithNamespaceIsolationPolicyWithContext func(ctx context.Context, cluster, broker string) (*utils.BrokerNamespaceIsolationData, error)

+ GetBrokersWithNamespaceIsolationPolicyWithContext func(ctx context.Context, cluster string) ([]utils.BrokerNamespaceIsolationData, error)

+ GetNamespaceIsolationPoliciesWithContext func(ctx context.Context, cluster string) (map[string]utils.NamespaceIsolationData, error)

+ GetNamespaceIsolationPolicyWithContext func(ctx context.Context, cluster, policyName string) (*utils.NamespaceIsolationData, error)

type Packages

+ DeleteWithContext func(ctx context.Context, packageURL string) error

+ DownloadWithContext func(ctx context.Context, packageURL, destinationFile string) error

+ GetMetadataWithContext func(ctx context.Context, packageURL string) (utils.PackageMetadata, error)

+ ListVersionsWithContext func(ctx context.Context, packageURL string) ([]string, error)

+ ListWithContext func(ctx context.Context, typeName, namespace string) ([]string, error)

+ UpdateMetadataWithContext func(ctx context.Context, packageURL, description, contact string, ...) error

+ UploadWithContext func(ctx context.Context, packageURL, filePath, description, contact string, ...) error

type ResourceQuotas

+ GetDefaultResourceQuotaWithContext func(ctx context.Context) (*utils.ResourceQuota, error)

+ GetNamespaceBundleResourceQuotaWithContext func(ctx context.Context, namespace, bundle string) (*utils.ResourceQuota, error)

+ ResetNamespaceBundleResourceQuotaWithContext func(ctx context.Context, namespace, bundle string) error

+ SetDefaultResourceQuotaWithContext func(ctx context.Context, quota utils.ResourceQuota) error

+ SetNamespaceBundleResourceQuotaWithContext func(ctx context.Context, namespace, bundle string, quota utils.ResourceQuota) error

type Sinks

+ CreateSinkWithContext func(ctx context.Context, config *utils.SinkConfig, fileName string) error

+ CreateSinkWithURLWithContext func(ctx context.Context, config *utils.SinkConfig, pkgURL string) error

+ DeleteSinkWithContext func(ctx context.Context, tenant, namespace, Sink string) error

+ GetBuiltInSinksWithContext func(ctx context.Context) ([]*utils.ConnectorDefinition, error)

+ GetSinkStatusWithContext func(ctx context.Context, tenant, namespace, Sink string) (utils.SinkStatus, error)

+ GetSinkStatusWithIDWithContext func(ctx context.Context, tenant, namespace, Sink string, id int) (utils.SinkInstanceStatusData, error)

+ GetSinkWithContext func(ctx context.Context, tenant, namespace, Sink string) (utils.SinkConfig, error)

+ ListSinksWithContext func(ctx context.Context, tenant, namespace string) ([]string, error)

+ ReloadBuiltInSinksWithContext func(ctx context.Context) error

+ RestartSinkWithContext func(ctx context.Context, tenant, namespace, Sink string) error

+ RestartSinkWithIDWithContext func(ctx context.Context, tenant, namespace, Sink string, id int) error

+ StartSinkWithContext func(ctx context.Context, tenant, namespace, Sink string) error

+ StartSinkWithIDWithContext func(ctx context.Context, tenant, namespace, Sink string, id int) error

+ StopSinkWithContext func(ctx context.Context, tenant, namespace, Sink string) error

+ StopSinkWithIDWithContext func(ctx context.Context, tenant, namespace, Sink string, id int) error

+ UpdateSinkWithContext func(ctx context.Context, config *utils.SinkConfig, fileName string, ...) error

+ UpdateSinkWithURLWithContext func(ctx context.Context, config *utils.SinkConfig, pkgURL string, ...) error

type Sources

+ CreateSourceWithContext func(ctx context.Context, config *utils.SourceConfig, fileName string) error

+ CreateSourceWithURLWithContext func(ctx context.Context, config *utils.SourceConfig, pkgURL string) error

+ DeleteSourceWithContext func(ctx context.Context, tenant, namespace, source string) error

+ GetBuiltInSourcesWithContext func(ctx context.Context) ([]*utils.ConnectorDefinition, error)

+ GetSourceStatusWithContext func(ctx context.Context, tenant, namespace, source string) (utils.SourceStatus, error)

+ GetSourceStatusWithIDWithContext func(ctx context.Context, tenant, namespace, source string, id int) (utils.SourceInstanceStatusData, error)

+ GetSourceWithContext func(ctx context.Context, tenant, namespace, source string) (utils.SourceConfig, error)

+ ListSourcesWithContext func(ctx context.Context, tenant, namespace string) ([]string, error)

+ ReloadBuiltInSourcesWithContext func(ctx context.Context) error

+ RestartSourceWithContext func(ctx context.Context, tenant, namespace, source string) error

+ RestartSourceWithIDWithContext func(ctx context.Context, tenant, namespace, source string, id int) error

+ StartSourceWithContext func(ctx context.Context, tenant, namespace, source string) error

+ StartSourceWithIDWithContext func(ctx context.Context, tenant, namespace, source string, id int) error

+ StopSourceWithContext func(ctx context.Context, tenant, namespace, source string) error

+ StopSourceWithIDWithContext func(ctx context.Context, tenant, namespace, source string, id int) error

+ UpdateSourceWithContext func(ctx context.Context, config *utils.SourceConfig, fileName string, ...) error

+ UpdateSourceWithURLWithContext func(ctx context.Context, config *utils.SourceConfig, pkgURL string, ...) error

type Subscriptions

+ ClearBacklogWithContext func(context.Context, utils.TopicName, string) error

+ CreateWithContext func(context.Context, utils.TopicName, string, utils.MessageID) error

+ DeleteWithContext func(context.Context, utils.TopicName, string) error

+ ExpireAllMessagesWithContext func(context.Context, utils.TopicName, int64) error

+ ExpireMessagesWithContext func(context.Context, utils.TopicName, string, int64) error

+ ForceDeleteWithContext func(context.Context, utils.TopicName, string) error

+ GetMessageByIDWithContext func(ctx context.Context, topic utils.TopicName, ledgerID, entryID int64) (*utils.Message, error)

+ GetMessagesByIDWithContext func(ctx context.Context, topic utils.TopicName, ledgerID, entryID int64) ([]*utils.Message, error)

+ ListWithContext func(context.Context, utils.TopicName) ([]string, error)

+ PeekMessagesWithContext func(context.Context, utils.TopicName, string, int) ([]*utils.Message, error)

+ ResetCursorToMessageIDWithContext func(context.Context, utils.TopicName, string, utils.MessageID) error

+ ResetCursorToTimestampWithContext func(context.Context, utils.TopicName, string, int64) error

+ SkipMessagesWithContext func(context.Context, utils.TopicName, string, int64) error

type Tenants

+ CreateWithContext func(context.Context, utils.TenantData) error

+ DeleteWithContext func(context.Context, string) error

+ GetWithContext func(context.Context, string) (utils.TenantData, error)

+ ListWithContext func(context.Context) ([]string, error)

+ UpdateWithContext func(context.Context, utils.TenantData) error

type Topics

+ CompactStatusWithContext func(context.Context, utils.TopicName) (utils.LongRunningProcessStatus, error)

+ CompactWithContext func(context.Context, utils.TopicName) error

+ CreateWithContext func(ctx context.Context, topic utils.TopicName, partitions int) error

+ CreateWithPropertiesWithContext func(ctx context.Context, topic utils.TopicName, partitions int, ...) error

+ DeleteWithContext func(ctx context.Context, topic utils.TopicName, force bool, nonPartitioned bool) error

+ GetAutoSubscriptionCreationWithContext func(context.Context, utils.TopicName) (*utils.AutoSubscriptionCreationOverride, error)

+ GetBacklogQuotaMapWithContext func(ctx context.Context, topic utils.TopicName, applied bool) (map[utils.BacklogQuotaType]utils.BacklogQuota, error)

+ GetBundleRangeWithContext func(context.Context, utils.TopicName) (string, error)

+ GetCompactionThresholdWithContext func(ctx context.Context, topic utils.TopicName, applied bool) (int64, error)

+ GetDeduplicationSnapshotIntervalWithContext func(context.Context, utils.TopicName) (int, error)

+ GetDeduplicationStatusWithContext func(context.Context, utils.TopicName) (bool, error)

+ GetDelayedDeliveryWithContext func(context.Context, utils.TopicName) (*utils.DelayedDeliveryData, error)

+ GetDispatchRateWithContext func(context.Context, utils.TopicName) (*utils.DispatchRateData, error)

+ GetInactiveTopicPoliciesWithContext func(ctx context.Context, topic utils.TopicName, applied bool) (utils.InactiveTopicPolicies, error)

+ GetInternalInfoWithContext func(context.Context, utils.TopicName) (utils.ManagedLedgerInfo, error)

+ GetInternalStatsWithContext func(context.Context, utils.TopicName) (utils.PersistentTopicInternalStats, error)

+ GetLastMessageIDWithContext func(context.Context, utils.TopicName) (utils.MessageID, error)

+ GetMaxConsumersPerSubscriptionWithContext func(context.Context, utils.TopicName) (int, error)

+ GetMaxConsumersWithContext func(context.Context, utils.TopicName) (int, error)

+ GetMaxMessageSizeWithContext func(context.Context, utils.TopicName) (int, error)

+ GetMaxProducersWithContext func(context.Context, utils.TopicName) (int, error)

+ GetMaxSubscriptionsPerTopicWithContext func(context.Context, utils.TopicName) (int, error)

+ GetMaxUnackMessagesPerConsumerWithContext func(context.Context, utils.TopicName) (int, error)

+ GetMaxUnackMessagesPerSubscriptionWithContext func(context.Context, utils.TopicName) (int, error)

+ GetMessageIDWithContext func(ctx context.Context, topic utils.TopicName, timestamp int64) (utils.MessageID, error)

+ GetMessageTTLWithContext func(context.Context, utils.TopicName) (int, error)

+ GetMetadataWithContext func(context.Context, utils.TopicName) (utils.PartitionedTopicMetadata, error)

+ GetOffloadPoliciesWithContext func(context.Context, utils.TopicName) (*utils.OffloadPolicies, error)

+ GetPartitionedStatsWithContext func(ctx context.Context, topic utils.TopicName, perPartition bool) (utils.PartitionedTopicStats, error)

+ GetPartitionedStatsWithOptionWithContext func(ctx context.Context, topic utils.TopicName, perPartition bool, ...) (utils.PartitionedTopicStats, error)

+ GetPermissionsWithContext func(context.Context, utils.TopicName) (map[string][]utils.AuthAction, error)

+ GetPersistenceWithContext func(context.Context, utils.TopicName) (*utils.PersistenceData, error)

+ GetPropertiesWithContext func(ctx context.Context, topic utils.TopicName) (map[string]string, error)

+ GetPublishRateWithContext func(context.Context, utils.TopicName) (*utils.PublishRateData, error)

+ GetReplicationClustersWithContext func(ctx context.Context, topic utils.TopicName) ([]string, error)

+ GetReplicatorDispatchRateWithContext func(context.Context, utils.TopicName) (*utils.DispatchRateData, error)

+ GetRetentionWithContext func(ctx context.Context, topic utils.TopicName, applied bool) (*utils.RetentionPolicies, error)

+ GetSchemaCompatibilityStrategyWithContext func(context.Context, utils.TopicName) (utils.SchemaCompatibilityStrategy, error)

+ GetSchemaValidationEnforcedWithContext func(context.Context, utils.TopicName) (bool, error)

+ GetStatsWithContext func(context.Context, utils.TopicName) (utils.TopicStats, error)

+ GetStatsWithOptionWithContext func(ctx context.Context, topic utils.TopicName, option utils.GetStatsOptions) (utils.TopicStats, error)

+ GetSubscribeRateWithContext func(context.Context, utils.TopicName) (*utils.SubscribeRate, error)

+ GetSubscriptionDispatchRateWithContext func(context.Context, utils.TopicName) (*utils.DispatchRateData, error)

+ GrantPermissionWithContext func(ctx context.Context, topic utils.TopicName, role string, ...) error

+ ListWithContext func(context.Context, utils.NameSpaceName) ([]string, []string, error)

+ LookupWithContext func(context.Context, utils.TopicName) (utils.LookupData, error)

+ OffloadStatusWithContext func(context.Context, utils.TopicName) (utils.OffloadProcessStatus, error)

+ OffloadWithContext func(context.Context, utils.TopicName, utils.MessageID) error

+ RemoveAutoSubscriptionCreationWithContext func(context.Context, utils.TopicName) error

+ RemoveBacklogQuotaWithContext func(context.Context, utils.TopicName, utils.BacklogQuotaType) error

+ RemoveCompactionThresholdWithContext func(context.Context, utils.TopicName) error

+ RemoveDeduplicationSnapshotIntervalWithContext func(context.Context, utils.TopicName) error

+ RemoveDeduplicationStatusWithContext func(context.Context, utils.TopicName) error

+ RemoveDelayedDeliveryWithContext func(context.Context, utils.TopicName) error

+ RemoveDispatchRateWithContext func(context.Context, utils.TopicName) error

+ RemoveInactiveTopicPoliciesWithContext func(context.Context, utils.TopicName) error

+ RemoveMaxConsumersPerSubscriptionWithContext func(context.Context, utils.TopicName) error

+ RemoveMaxConsumersWithContext func(context.Context, utils.TopicName) error

+ RemoveMaxMessageSizeWithContext func(context.Context, utils.TopicName) error

+ RemoveMaxProducersWithContext func(context.Context, utils.TopicName) error

+ RemoveMaxSubscriptionsPerTopicWithContext func(context.Context, utils.TopicName) error

+ RemoveMaxUnackMessagesPerConsumerWithContext func(context.Context, utils.TopicName) error

+ RemoveMaxUnackMessagesPerSubscriptionWithContext func(context.Context, utils.TopicName) error

+ RemoveMessageTTLWithContext func(context.Context, utils.TopicName) error

+ RemoveOffloadPoliciesWithContext func(context.Context, utils.TopicName) error

+ RemovePersistenceWithContext func(context.Context, utils.TopicName) error

+ RemovePropertyWithContext func(ctx context.Context, topic utils.TopicName, key string) error

+ RemovePublishRateWithContext func(context.Context, utils.TopicName) error

+ RemoveReplicatorDispatchRateWithContext func(context.Context, utils.TopicName) error

+ RemoveRetentionWithContext func(context.Context, utils.TopicName) error

+ RemoveSchemaCompatibilityStrategyWithContext func(context.Context, utils.TopicName) error

+ RemoveSchemaValidationEnforcedWithContext func(context.Context, utils.TopicName) error

+ RemoveSubscribeRateWithContext func(context.Context, utils.TopicName) error

+ RemoveSubscriptionDispatchRateWithContext func(context.Context, utils.TopicName) error

+ RevokePermissionWithContext func(ctx context.Context, topic utils.TopicName, role string) error

+ SetAutoSubscriptionCreationWithContext func(context.Context, utils.TopicName, utils.AutoSubscriptionCreationOverride) error

+ SetBacklogQuotaWithContext func(context.Context, utils.TopicName, utils.BacklogQuota, utils.BacklogQuotaType) error

+ SetCompactionThresholdWithContext func(ctx context.Context, topic utils.TopicName, threshold int64) error

+ SetDeduplicationSnapshotIntervalWithContext func(context.Context, utils.TopicName, int) error

+ SetDeduplicationStatusWithContext func(ctx context.Context, topic utils.TopicName, enabled bool) error

+ SetDelayedDeliveryWithContext func(context.Context, utils.TopicName, utils.DelayedDeliveryData) error

+ SetDispatchRateWithContext func(context.Context, utils.TopicName, utils.DispatchRateData) error

+ SetInactiveTopicPoliciesWithContext func(ctx context.Context, topic utils.TopicName, data utils.InactiveTopicPolicies) error

+ SetMaxConsumersPerSubscriptionWithContext func(context.Context, utils.TopicName, int) error

+ SetMaxConsumersWithContext func(ctx context.Context, topic utils.TopicName, maxConsumers int) error

+ SetMaxMessageSizeWithContext func(context.Context, utils.TopicName, int) error

+ SetMaxProducersWithContext func(ctx context.Context, topic utils.TopicName, maxProducers int) error

+ SetMaxSubscriptionsPerTopicWithContext func(context.Context, utils.TopicName, int) error

+ SetMaxUnackMessagesPerConsumerWithContext func(ctx context.Context, topic utils.TopicName, maxUnackedNum int) error

+ SetMaxUnackMessagesPerSubscriptionWithContext func(ctx context.Context, topic utils.TopicName, maxUnackedNum int) error

+ SetMessageTTLWithContext func(ctx context.Context, topic utils.TopicName, messageTTL int) error

+ SetOffloadPoliciesWithContext func(context.Context, utils.TopicName, utils.OffloadPolicies) error

+ SetPersistenceWithContext func(context.Context, utils.TopicName, utils.PersistenceData) error

+ SetPublishRateWithContext func(context.Context, utils.TopicName, utils.PublishRateData) error

+ SetReplicationClustersWithContext func(ctx context.Context, topic utils.TopicName, data []string) error

+ SetReplicatorDispatchRateWithContext func(context.Context, utils.TopicName, utils.DispatchRateData) error

+ SetRetentionWithContext func(context.Context, utils.TopicName, utils.RetentionPolicies) error

+ SetSchemaCompatibilityStrategyWithContext func(context.Context, utils.TopicName, utils.SchemaCompatibilityStrategy) error

+ SetSchemaValidationEnforcedWithContext func(context.Context, utils.TopicName, bool) error

+ SetSubscribeRateWithContext func(context.Context, utils.TopicName, utils.SubscribeRate) error

+ SetSubscriptionDispatchRateWithContext func(context.Context, utils.TopicName, utils.DispatchRateData) error

+ TerminateWithContext func(context.Context, utils.TopicName) (utils.MessageID, error)

+ UnloadWithContext func(context.Context, utils.TopicName) error

+ UpdatePropertiesWithContext func(ctx context.Context, topic utils.TopicName, properties map[string]string) error

+ UpdateWithContext func(ctx context.Context, topic utils.TopicName, partitions int) error

v0.17.0-candidate-1

Oct 10, 2025

v0.16.0

Jul 28, 2025

Changes in this version

type Namespaces

+ GetProperties func(namespace utils.NameSpaceName) (map[string]string, error)

+ GetSchemaCompatibilityStrategy func(namespace utils.NameSpaceName) (utils.SchemaCompatibilityStrategy, error)

+ RemoveProperties func(namespace utils.NameSpaceName) error

+ SetSchemaCompatibilityStrategy func(namespace utils.NameSpaceName, strategy utils.SchemaCompatibilityStrategy) error

+ UpdateProperties func(namespace utils.NameSpaceName, properties map[string]string) error

type Topics

+ GetAutoSubscriptionCreation func(utils.TopicName) (*utils.AutoSubscriptionCreationOverride, error)

+ GetDeduplicationSnapshotInterval func(utils.TopicName) (int, error)

+ GetMaxConsumersPerSubscription func(utils.TopicName) (int, error)

+ GetMaxMessageSize func(utils.TopicName) (int, error)

+ GetMaxSubscriptionsPerTopic func(utils.TopicName) (int, error)

+ GetOffloadPolicies func(utils.TopicName) (*utils.OffloadPolicies, error)

+ GetReplicatorDispatchRate func(utils.TopicName) (*utils.DispatchRateData, error)

+ GetSchemaCompatibilityStrategy func(utils.TopicName) (utils.SchemaCompatibilityStrategy, error)

+ GetSchemaValidationEnforced func(utils.TopicName) (bool, error)

+ GetSubscribeRate func(utils.TopicName) (*utils.SubscribeRate, error)

+ GetSubscriptionDispatchRate func(utils.TopicName) (*utils.DispatchRateData, error)

+ RemoveAutoSubscriptionCreation func(utils.TopicName) error

+ RemoveDeduplicationSnapshotInterval func(utils.TopicName) error

+ RemoveMaxConsumersPerSubscription func(utils.TopicName) error

+ RemoveMaxMessageSize func(utils.TopicName) error

+ RemoveMaxSubscriptionsPerTopic func(utils.TopicName) error

+ RemoveOffloadPolicies func(utils.TopicName) error

+ RemoveProperty func(topic utils.TopicName, key string) error

+ RemoveReplicatorDispatchRate func(utils.TopicName) error

+ RemoveSchemaCompatibilityStrategy func(utils.TopicName) error

+ RemoveSchemaValidationEnforced func(utils.TopicName) error

+ RemoveSubscribeRate func(utils.TopicName) error

+ RemoveSubscriptionDispatchRate func(utils.TopicName) error

+ SetAutoSubscriptionCreation func(utils.TopicName, utils.AutoSubscriptionCreationOverride) error

+ SetDeduplicationSnapshotInterval func(utils.TopicName, int) error

+ SetMaxConsumersPerSubscription func(utils.TopicName, int) error

+ SetMaxMessageSize func(utils.TopicName, int) error

+ SetMaxSubscriptionsPerTopic func(utils.TopicName, int) error

+ SetOffloadPolicies func(utils.TopicName, utils.OffloadPolicies) error

+ SetReplicatorDispatchRate func(utils.TopicName, utils.DispatchRateData) error

+ SetSchemaCompatibilityStrategy func(utils.TopicName, utils.SchemaCompatibilityStrategy) error

+ SetSchemaValidationEnforced func(utils.TopicName, bool) error

+ SetSubscribeRate func(utils.TopicName, utils.SubscribeRate) error

+ SetSubscriptionDispatchRate func(utils.TopicName, utils.DispatchRateData) error

+ UpdateProperties func(topic utils.TopicName, properties map[string]string) error

v0.16.0-candidate-1

Jul 28, 2025

v0.15.1

May 15, 2025

v0.15.1-candidate-2

May 15, 2025

v0.15.1-candidate-1

May 15, 2025

v0.15.0

Mar 17, 2025

Changes in this version

+ const PropertyHeader

type Schema

+ GetAllSchemas func(topic string) ([]*utils.SchemaInfoWithVersion, error)

v0.15.0-candidate-2

Mar 17, 2025

v0.15.0-candidate-1

Jan 3, 2025

v0.14.0

Sep 23, 2024

Changes in this version

type Namespaces

+ GetOffloadThresholdInSeconds func(namespace utils.NameSpaceName) (int64, error)

+ GetSubscriptionExpirationTime func(namespace utils.NameSpaceName) (int, error)

+ RemoveSubscriptionExpirationTime func(namespace utils.NameSpaceName) error

+ SetOffloadThresholdInSeconds func(namespace utils.NameSpaceName, threshold int64) error

+ SetSubscriptionExpirationTime func(namespace utils.NameSpaceName, expirationTimeInMinutes int) error

v0.14.0-candidate-1

Sep 23, 2024

v0.13.1

Jul 31, 2024

Changes in this version

type Namespaces

+ GetSubPermissions func(namespace utils.NameSpaceName) (map[string][]string, error)

v0.13.1-candidate-1

Jul 31, 2024

v0.13.0

Jul 15, 2024

Changes in this version

type Brokers

+ GetLeaderBroker func() (utils.BrokerInfo, error)

+ GetListActiveBrokers func() ([]string, error)

+ HealthCheckWithTopicVersion func(utils.TopicVersion) error

type Schema

+ CreateSchemaBySchemaInfo func(topic string, schemaInfo utils.SchemaInfo) error

+ ForceDeleteSchema func(topic string) error

+ GetVersionByPayload func(topic string, schemaPayload utils.PostSchemaPayload) (int64, error)

+ GetVersionBySchemaInfo func(topic string, schemaInfo utils.SchemaInfo) (int64, error)

+ TestCompatibilityWithPostSchemaPayload func(topic string, schemaPayload utils.PostSchemaPayload) (*utils.IsCompatibility, error)

+ TestCompatibilityWithSchemaInfo func(topic string, schemaInfo utils.SchemaInfo) (*utils.IsCompatibility, error)

type Subscriptions

+ GetMessagesByID func(topic utils.TopicName, ledgerID, entryID int64) ([]*utils.Message, error)

type Topics

+ CreateWithProperties func(topic utils.TopicName, partitions int, meta map[string]string) error

+ GetPartitionedStatsWithOption func(topic utils.TopicName, perPartition bool, option utils.GetStatsOptions) (utils.PartitionedTopicStats, error)

+ GetProperties func(topic utils.TopicName) (map[string]string, error)

+ GetStatsWithOption func(topic utils.TopicName, option utils.GetStatsOptions) (utils.TopicStats, error)

v0.13.0-candidate-2

Jul 15, 2024

v0.13.0-candidate-1

Jul 11, 2024

v0.12.1

Feb 29, 2024

v0.12.1-candidate-1

Feb 29, 2024

v0.12.0

Jan 22, 2024

Changes in this version

+ const BatchHeader

+ const DefaultHTTPTimeOutDuration

+ const DefaultWebServiceURL

+ const PropertyPrefix

+ const PublishTimeHeader

+ const ReleaseVersion

+ type BrokerStats interface

+ GetAllocatorStats func(allocatorName string) (*utils.AllocatorStats, error)

+ GetLoadReport func() (*utils.LocalBrokerData, error)

+ GetMBeans func() ([]utils.Metrics, error)

+ GetMetrics func() ([]utils.Metrics, error)

+ GetTopics func() (string, error)

+ type Brokers interface

+ DeleteDynamicConfiguration func(configName string) error

+ GetActiveBrokers func(cluster string) ([]string, error)

+ GetAllDynamicConfigurations func() (map[string]string, error)

+ GetDynamicConfigurationNames func() ([]string, error)

+ GetInternalConfigurationData func() (*utils.InternalConfigurationData, error)

+ GetOwnedNamespaces func(cluster, brokerURL string) (map[string]utils.NamespaceOwnershipStatus, error)

+ GetRuntimeConfigurations func() (map[string]string, error)

+ HealthCheck func() error

+ UpdateDynamicConfiguration func(configName, configValue string) error

+ type Client interface

+ BrokerStats func() BrokerStats

+ Brokers func() Brokers

+ Clusters func() Clusters

+ Functions func() Functions

+ FunctionsWorker func() FunctionsWorker

+ Namespaces func() Namespaces

+ NsIsolationPolicy func() NsIsolationPolicy

+ Packages func() Packages

+ ResourceQuotas func() ResourceQuotas

+ Schemas func() Schema

+ Sinks func() Sinks

+ Sources func() Sources

+ Subscriptions func() Subscriptions

+ Tenants func() Tenants

+ Topics func() Topics

+ func New(config *config.Config) (Client, error)

+ func NewPulsarClientWithAuthProvider(config *config.Config, authProvider auth.Provider) (Client, error)

+ func NewWithAuthProvider(config *config.Config, authProvider auth.Provider) Client

+ type Clusters interface

+ Create func(utils.ClusterData) error

+ CreateFailureDomain func(utils.FailureDomainData) error

+ Delete func(string) error

+ DeleteFailureDomain func(utils.FailureDomainData) error

+ Get func(string) (utils.ClusterData, error)

+ GetFailureDomain func(clusterName, domainName string) (utils.FailureDomainData, error)

+ GetPeerClusters func(string) ([]string, error)

+ List func() ([]string, error)

+ ListFailureDomains func(string) (utils.FailureDomainMap, error)

+ Update func(utils.ClusterData) error

+ UpdateFailureDomain func(utils.FailureDomainData) error

+ UpdatePeerClusters func(string, []string) error

+ type Functions interface

+ CreateFunc func(data *utils.FunctionConfig, fileName string) error

+ CreateFuncWithURL func(data *utils.FunctionConfig, pkgURL string) error

+ DeleteFunction func(tenant, namespace, name string) error

+ DownloadFunction func(path, destinationFile string) error

+ DownloadFunctionByNs func(destinationFile, tenant, namespace, function string) error

+ GetFunction func(tenant, namespace, name string) (utils.FunctionConfig, error)

+ GetFunctionState func(tenant, namespace, name, key string) (utils.FunctionState, error)

+ GetFunctionStats func(tenant, namespace, name string) (utils.FunctionStats, error)

+ GetFunctionStatsWithInstanceID func(tenant, namespace, name string, instanceID int) (utils.FunctionInstanceStatsData, error)

+ GetFunctionStatus func(tenant, namespace, name string) (utils.FunctionStatus, error)

+ GetFunctionStatusWithInstanceID func(tenant, namespace, name string, instanceID int) (utils.FunctionInstanceStatusData, error)

+ GetFunctions func(tenant, namespace string) ([]string, error)

+ PutFunctionState func(tenant, namespace, name string, state utils.FunctionState) error

+ RestartFunction func(tenant, namespace, name string) error

+ RestartFunctionWithID func(tenant, namespace, name string, instanceID int) error

+ StartFunction func(tenant, namespace, name string) error

+ StartFunctionWithID func(tenant, namespace, name string, instanceID int) error

+ StopFunction func(tenant, namespace, name string) error

+ StopFunctionWithID func(tenant, namespace, name string, instanceID int) error

+ TriggerFunction func(tenant, namespace, name, topic, triggerValue, triggerFile string) (string, error)

+ UpdateFunction func(functionConfig *utils.FunctionConfig, fileName string, ...) error

+ UpdateFunctionWithURL func(functionConfig *utils.FunctionConfig, pkgURL string, ...) error

+ Upload func(sourceFile, path string) error

+ type FunctionsWorker interface

+ GetAssignments func() (map[string][]string, error)

+ GetCluster func() ([]*utils.WorkerInfo, error)

+ GetClusterLeader func() (*utils.WorkerInfo, error)

+ GetFunctionsStats func() ([]*utils.WorkerFunctionInstanceStats, error)

+ GetMetrics func() ([]*utils.Metrics, error)

+ type Namespaces interface

+ ClearNamespaceBacklog func(namespace utils.NameSpaceName) error

+ ClearNamespaceBacklogForSubscription func(namespace utils.NameSpaceName, sName string) error

+ ClearNamespaceBundleBacklog func(namespace utils.NameSpaceName, bundle string) error

+ ClearNamespaceBundleBacklogForSubscription func(namespace utils.NameSpaceName, bundle, sName string) error

+ ClearOffloadDeleteLag func(namespace utils.NameSpaceName) error

+ CreateNamespace func(namespace string) error

+ CreateNsWithBundlesData func(namespace string, bundleData *utils.BundlesData) error

+ CreateNsWithNumBundles func(namespace string, numBundles int) error

+ CreateNsWithPolices func(namespace string, polices utils.Policies) error

+ DeleteBookieAffinityGroup func(namespace string) error

+ DeleteNamespace func(namespace string) error

+ DeleteNamespaceAntiAffinityGroup func(namespace string) error

+ DeleteNamespaceBundle func(namespace string, bundleRange string) error

+ GetAntiAffinityNamespaces func(tenant, cluster, namespaceAntiAffinityGroup string) ([]string, error)

+ GetBacklogQuotaMap func(namespace string) (map[utils.BacklogQuotaType]utils.BacklogQuota, error)

+ GetBookieAffinityGroup func(namespace string) (*utils.BookieAffinityGroupData, error)

+ GetCompactionThreshold func(namespace utils.NameSpaceName) (int64, error)

+ GetDispatchRate func(namespace utils.NameSpaceName) (utils.DispatchRate, error)

+ GetInactiveTopicPolicies func(namespace utils.NameSpaceName) (utils.InactiveTopicPolicies, error)

+ GetIsAllowAutoUpdateSchema func(namespace utils.NameSpaceName) (bool, error)

+ GetMaxConsumersPerSubscription func(namespace utils.NameSpaceName) (int, error)

+ GetMaxConsumersPerTopic func(namespace utils.NameSpaceName) (int, error)

+ GetMaxProducersPerTopic func(namespace utils.NameSpaceName) (int, error)

+ GetNamespaceAntiAffinityGroup func(namespace string) (string, error)

+ GetNamespaceMessageTTL func(namespace string) (int, error)

+ GetNamespacePermissions func(namespace utils.NameSpaceName) (map[string][]utils.AuthAction, error)

+ GetNamespaceReplicationClusters func(namespace string) ([]string, error)

+ GetNamespaces func(tenant string) ([]string, error)

+ GetOffloadDeleteLag func(namespace utils.NameSpaceName) (int64, error)

+ GetOffloadThreshold func(namespace utils.NameSpaceName) (int64, error)

+ GetPersistence func(namespace string) (*utils.PersistencePolicies, error)

+ GetPolicies func(namespace string) (*utils.Policies, error)

+ GetPublishRate func(namespace utils.NameSpaceName) (utils.PublishRate, error)

+ GetReplicatorDispatchRate func(namespace utils.NameSpaceName) (utils.DispatchRate, error)

+ GetRetention func(namespace string) (*utils.RetentionPolicies, error)

+ GetSchemaAutoUpdateCompatibilityStrategy func(namespace utils.NameSpaceName) (utils.SchemaCompatibilityStrategy, error)

+ GetSchemaValidationEnforced func(namespace utils.NameSpaceName) (bool, error)

+ GetSubscribeRate func(namespace utils.NameSpaceName) (utils.SubscribeRate, error)

+ GetSubscriptionDispatchRate func(namespace utils.NameSpaceName) (utils.DispatchRate, error)

+ GetTopicAutoCreation func(namespace utils.NameSpaceName) (*utils.TopicAutoCreationConfig, error)

+ GetTopics func(namespace string) ([]string, error)

+ GrantNamespacePermission func(namespace utils.NameSpaceName, role string, action []utils.AuthAction) error

+ GrantSubPermission func(namespace utils.NameSpaceName, sName string, roles []string) error

+ RemoveBacklogQuota func(namespace string) error

+ RemoveInactiveTopicPolicies func(namespace utils.NameSpaceName) error

+ RemoveTopicAutoCreation func(namespace utils.NameSpaceName) error

+ RevokeNamespacePermission func(namespace utils.NameSpaceName, role string) error

+ RevokeSubPermission func(namespace utils.NameSpaceName, sName, role string) error

+ SetBacklogQuota func(namespace string, backlogQuota utils.BacklogQuota, ...) error

+ SetBookieAffinityGroup func(namespace string, bookieAffinityGroup utils.BookieAffinityGroupData) error

+ SetCompactionThreshold func(namespace utils.NameSpaceName, threshold int64) error

+ SetDeduplicationStatus func(namespace string, enableDeduplication bool) error

+ SetDispatchRate func(namespace utils.NameSpaceName, rate utils.DispatchRate) error

+ SetEncryptionRequiredStatus func(namespace utils.NameSpaceName, encrypt bool) error

+ SetInactiveTopicPolicies func(namespace utils.NameSpaceName, data utils.InactiveTopicPolicies) error

+ SetIsAllowAutoUpdateSchema func(namespace utils.NameSpaceName, isAllowAutoUpdateSchema bool) error

+ SetMaxConsumersPerSubscription func(namespace utils.NameSpaceName, max int) error

+ SetMaxConsumersPerTopic func(namespace utils.NameSpaceName, max int) error

+ SetMaxProducersPerTopic func(namespace utils.NameSpaceName, max int) error

+ SetNamespaceAntiAffinityGroup func(namespace string, namespaceAntiAffinityGroup string) error

+ SetNamespaceMessageTTL func(namespace string, ttlInSeconds int) error

+ SetNamespaceReplicationClusters func(namespace string, clusterIds []string) error

+ SetOffloadDeleteLag func(namespace utils.NameSpaceName, timeMs int64) error

+ SetOffloadThreshold func(namespace utils.NameSpaceName, threshold int64) error

+ SetPersistence func(namespace string, persistence utils.PersistencePolicies) error

+ SetPublishRate func(namespace utils.NameSpaceName, pubRate utils.PublishRate) error

+ SetReplicatorDispatchRate func(namespace utils.NameSpaceName, rate utils.DispatchRate) error

+ SetRetention func(namespace string, policy utils.RetentionPolicies) error

+ SetSchemaAutoUpdateCompatibilityStrategy func(namespace utils.NameSpaceName, strategy utils.SchemaCompatibilityStrategy) error

+ SetSchemaValidationEnforced func(namespace utils.NameSpaceName, schemaValidationEnforced bool) error

+ SetSubscribeRate func(namespace utils.NameSpaceName, rate utils.SubscribeRate) error

+ SetSubscriptionAuthMode func(namespace utils.NameSpaceName, mode utils.SubscriptionAuthMode) error

+ SetSubscriptionDispatchRate func(namespace utils.NameSpaceName, rate utils.DispatchRate) error

+ SetTopicAutoCreation func(namespace utils.NameSpaceName, config utils.TopicAutoCreationConfig) error

+ SplitNamespaceBundle func(namespace, bundle string, unloadSplitBundles bool) error

+ Unload func(namespace string) error

+ UnloadNamespaceBundle func(namespace, bundle string) error

+ UnsubscribeNamespace func(namespace utils.NameSpaceName, sName string) error

+ UnsubscribeNamespaceBundle func(namespace utils.NameSpaceName, bundle, sName string) error

+ type NsIsolationPolicy interface

+ CreateNamespaceIsolationPolicy func(cluster, policyName string, ...) error

+ DeleteNamespaceIsolationPolicy func(cluster, policyName string) error

+ GetBrokerWithNamespaceIsolationPolicy func(cluster, broker string) (*utils.BrokerNamespaceIsolationData, error)

+ GetBrokersWithNamespaceIsolationPolicy func(cluster string) ([]utils.BrokerNamespaceIsolationData, error)

+ GetNamespaceIsolationPolicies func(cluster string) (map[string]utils.NamespaceIsolationData, error)

+ GetNamespaceIsolationPolicy func(cluster, policyName string) (*utils.NamespaceIsolationData, error)

+ type Packages interface

+ Delete func(packageURL string) error

+ Download func(packageURL, destinationFile string) error

+ GetMetadata func(packageURL string) (utils.PackageMetadata, error)

+ List func(typeName, namespace string) ([]string, error)

+ ListVersions func(packageURL string) ([]string, error)

+ UpdateMetadata func(packageURL, description, contact string, properties map[string]string) error

+ Upload func(packageURL, filePath, description, contact string, ...) error

+ type ResourceQuotas interface

+ GetDefaultResourceQuota func() (*utils.ResourceQuota, error)

+ GetNamespaceBundleResourceQuota func(namespace, bundle string) (*utils.ResourceQuota, error)

+ ResetNamespaceBundleResourceQuota func(namespace, bundle string) error

+ SetDefaultResourceQuota func(quota utils.ResourceQuota) error

+ SetNamespaceBundleResourceQuota func(namespace, bundle string, quota utils.ResourceQuota) error

+ type Schema interface

+ CreateSchemaByPayload func(topic string, schemaPayload utils.PostSchemaPayload) error

+ DeleteSchema func(topic string) error

+ GetSchemaInfo func(topic string) (*utils.SchemaInfo, error)

+ GetSchemaInfoByVersion func(topic string, version int64) (*utils.SchemaInfo, error)

+ GetSchemaInfoWithVersion func(topic string) (*utils.SchemaInfoWithVersion, error)

+ type Sinks interface

+ CreateSink func(config *utils.SinkConfig, fileName string) error

+ CreateSinkWithURL func(config *utils.SinkConfig, pkgURL string) error

+ DeleteSink func(tenant, namespace, Sink string) error

+ GetBuiltInSinks func() ([]*utils.ConnectorDefinition, error)

+ GetSink func(tenant, namespace, Sink string) (utils.SinkConfig, error)

+ GetSinkStatus func(tenant, namespace, Sink string) (utils.SinkStatus, error)

+ GetSinkStatusWithID func(tenant, namespace, Sink string, id int) (utils.SinkInstanceStatusData, error)

+ ListSinks func(tenant, namespace string) ([]string, error)

+ ReloadBuiltInSinks func() error

+ RestartSink func(tenant, namespace, Sink string) error

+ RestartSinkWithID func(tenant, namespace, Sink string, id int) error

+ StartSink func(tenant, namespace, Sink string) error

+ StartSinkWithID func(tenant, namespace, Sink string, id int) error

+ StopSink func(tenant, namespace, Sink string) error

+ StopSinkWithID func(tenant, namespace, Sink string, id int) error

+ UpdateSink func(config *utils.SinkConfig, fileName string, options *utils.UpdateOptions) error

+ UpdateSinkWithURL func(config *utils.SinkConfig, pkgURL string, options *utils.UpdateOptions) error

+ type Sources interface

+ CreateSource func(config *utils.SourceConfig, fileName string) error

+ CreateSourceWithURL func(config *utils.SourceConfig, pkgURL string) error

+ DeleteSource func(tenant, namespace, source string) error

+ GetBuiltInSources func() ([]*utils.ConnectorDefinition, error)

+ GetSource func(tenant, namespace, source string) (utils.SourceConfig, error)

+ GetSourceStatus func(tenant, namespace, source string) (utils.SourceStatus, error)

+ GetSourceStatusWithID func(tenant, namespace, source string, id int) (utils.SourceInstanceStatusData, error)

+ ListSources func(tenant, namespace string) ([]string, error)

+ ReloadBuiltInSources func() error

+ RestartSource func(tenant, namespace, source string) error

+ RestartSourceWithID func(tenant, namespace, source string, id int) error

+ StartSource func(tenant, namespace, source string) error

+ StartSourceWithID func(tenant, namespace, source string, id int) error

+ StopSource func(tenant, namespace, source string) error

+ StopSourceWithID func(tenant, namespace, source string, id int) error

+ UpdateSource func(config *utils.SourceConfig, fileName string, options *utils.UpdateOptions) error

+ UpdateSourceWithURL func(config *utils.SourceConfig, pkgURL string, options *utils.UpdateOptions) error

+ type Subscriptions interface

+ ClearBacklog func(utils.TopicName, string) error

+ Create func(utils.TopicName, string, utils.MessageID) error

+ Delete func(utils.TopicName, string) error

+ ExpireAllMessages func(utils.TopicName, int64) error

+ ExpireMessages func(utils.TopicName, string, int64) error

+ ForceDelete func(utils.TopicName, string) error

+ GetMessageByID func(topic utils.TopicName, ledgerID, entryID int64) (*utils.Message, error)

+ List func(utils.TopicName) ([]string, error)

+ PeekMessages func(utils.TopicName, string, int) ([]*utils.Message, error)

+ ResetCursorToMessageID func(utils.TopicName, string, utils.MessageID) error

+ ResetCursorToTimestamp func(utils.TopicName, string, int64) error

+ SkipMessages func(utils.TopicName, string, int64) error

+ type TLSOptions struct

+ AllowInsecureConnection bool

+ TrustCertsFilePath string

+ type Tenants interface

+ Create func(utils.TenantData) error

+ Delete func(string) error

+ Get func(string) (utils.TenantData, error)

+ List func() ([]string, error)

+ Update func(utils.TenantData) error

+ type Topics interface

+ Compact func(utils.TopicName) error

+ CompactStatus func(utils.TopicName) (utils.LongRunningProcessStatus, error)

+ Create func(utils.TopicName, int) error

+ Delete func(utils.TopicName, bool, bool) error

+ GetBacklogQuotaMap func(topic utils.TopicName, applied bool) (map[utils.BacklogQuotaType]utils.BacklogQuota, error)

+ GetBundleRange func(utils.TopicName) (string, error)

+ GetCompactionThreshold func(topic utils.TopicName, applied bool) (int64, error)

+ GetDeduplicationStatus func(utils.TopicName) (bool, error)

+ GetDelayedDelivery func(utils.TopicName) (*utils.DelayedDeliveryData, error)

+ GetDispatchRate func(utils.TopicName) (*utils.DispatchRateData, error)

+ GetInactiveTopicPolicies func(topic utils.TopicName, applied bool) (utils.InactiveTopicPolicies, error)

+ GetInternalInfo func(utils.TopicName) (utils.ManagedLedgerInfo, error)

+ GetInternalStats func(utils.TopicName) (utils.PersistentTopicInternalStats, error)

+ GetLastMessageID func(utils.TopicName) (utils.MessageID, error)

+ GetMaxConsumers func(utils.TopicName) (int, error)

+ GetMaxProducers func(utils.TopicName) (int, error)

+ GetMaxUnackMessagesPerConsumer func(utils.TopicName) (int, error)

+ GetMaxUnackMessagesPerSubscription func(utils.TopicName) (int, error)

+ GetMessageID func(utils.TopicName, int64) (utils.MessageID, error)

+ GetMessageTTL func(utils.TopicName) (int, error)

+ GetMetadata func(utils.TopicName) (utils.PartitionedTopicMetadata, error)

+ GetPartitionedStats func(utils.TopicName, bool) (utils.PartitionedTopicStats, error)

+ GetPermissions func(utils.TopicName) (map[string][]utils.AuthAction, error)

+ GetPersistence func(utils.TopicName) (*utils.PersistenceData, error)

+ GetPublishRate func(utils.TopicName) (*utils.PublishRateData, error)

+ GetReplicationClusters func(topic utils.TopicName) ([]string, error)

+ GetRetention func(utils.TopicName, bool) (*utils.RetentionPolicies, error)

+ GetStats func(utils.TopicName) (utils.TopicStats, error)

+ GrantPermission func(utils.TopicName, string, []utils.AuthAction) error

+ List func(utils.NameSpaceName) ([]string, []string, error)

+ Lookup func(utils.TopicName) (utils.LookupData, error)

+ Offload func(utils.TopicName, utils.MessageID) error

+ OffloadStatus func(utils.TopicName) (utils.OffloadProcessStatus, error)

+ RemoveBacklogQuota func(utils.TopicName, utils.BacklogQuotaType) error

+ RemoveCompactionThreshold func(utils.TopicName) error

+ RemoveDeduplicationStatus func(utils.TopicName) error

+ RemoveDelayedDelivery func(utils.TopicName) error

+ RemoveDispatchRate func(utils.TopicName) error

+ RemoveInactiveTopicPolicies func(utils.TopicName) error

+ RemoveMaxConsumers func(utils.TopicName) error

+ RemoveMaxProducers func(utils.TopicName) error

+ RemoveMaxUnackMessagesPerConsumer func(utils.TopicName) error

+ RemoveMaxUnackMessagesPerSubscription func(utils.TopicName) error

+ RemoveMessageTTL func(utils.TopicName) error

+ RemovePersistence func(utils.TopicName) error

+ RemovePublishRate func(utils.TopicName) error

+ RemoveRetention func(utils.TopicName) error

+ RevokePermission func(utils.TopicName, string) error

+ SetBacklogQuota func(utils.TopicName, utils.BacklogQuota, utils.BacklogQuotaType) error

+ SetCompactionThreshold func(topic utils.TopicName, threshold int64) error

+ SetDeduplicationStatus func(utils.TopicName, bool) error

+ SetDelayedDelivery func(utils.TopicName, utils.DelayedDeliveryData) error

+ SetDispatchRate func(utils.TopicName, utils.DispatchRateData) error

+ SetInactiveTopicPolicies func(topic utils.TopicName, data utils.InactiveTopicPolicies) error

+ SetMaxConsumers func(utils.TopicName, int) error

+ SetMaxProducers func(utils.TopicName, int) error

+ SetMaxUnackMessagesPerConsumer func(utils.TopicName, int) error

+ SetMaxUnackMessagesPerSubscription func(utils.TopicName, int) error

+ SetMessageTTL func(utils.TopicName, int) error

+ SetPersistence func(utils.TopicName, utils.PersistenceData) error

+ SetPublishRate func(utils.TopicName, utils.PublishRateData) error

+ SetReplicationClusters func(topic utils.TopicName, data []string) error

+ SetRetention func(utils.TopicName, utils.RetentionPolicies) error

+ Terminate func(utils.TopicName) (utils.MessageID, error)

+ Unload func(utils.TopicName) error

+ Update func(utils.TopicName, int) error

v0.12.0-candidate-3

Jan 22, 2024

v0.12.0-candidate-2

Jan 15, 2024

v0.12.0-candidate-1

Jan 10, 2024

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL