pulsar_admin

func (*APIClient) ChangeBasePath ¶

func (c *APIClient) ChangeBasePath(path string)

Change base path to allow switching to mocks

func (*BookiesApiService) DeleteBookieRackInfo ¶

func (a *BookiesApiService) DeleteBookieRackInfo(ctx context.Context, bookie string) (*http.Response, error)

BookiesApiService Removed the rack placement information for a specific bookie in the cluster

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param bookie

func (*BookiesApiService) GetBookieRackInfo ¶

func (a *BookiesApiService) GetBookieRackInfo(ctx context.Context, bookie string) (BookieInfo, *http.Response, error)

BookiesApiService Gets the rack placement information for a specific bookie in the cluster

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param bookie

@return BookieInfo

func (*BookiesApiService) GetBookiesRackInfo ¶

func (a *BookiesApiService) GetBookiesRackInfo(ctx context.Context) (map[string]map[string]BookieInfo, *http.Response, error)

BookiesApiService Gets the rack placement information for all the bookies in the cluster

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return map[string]map[string]BookieInfo

func (*BookiesApiService) UpdateBookieRackInfo ¶

func (a *BookiesApiService) UpdateBookieRackInfo(ctx context.Context, bookie string, localVarOptionals *UpdateBookieRackInfoOpts) (*http.Response, error)

func (*BrokerStatsApiService) GetAllocatorStats ¶

func (a *BrokerStatsApiService) GetAllocatorStats(ctx context.Context, allocator string) (AllocatorStats, *http.Response, error)

BrokerStatsApiService Get the stats for the Netty allocator. Available allocators are 'default' and 'ml-cache'

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param allocator

@return AllocatorStats

func (*BrokerStatsApiService) GetBrokerResourceAvailability ¶

func (a *BrokerStatsApiService) GetBrokerResourceAvailability(ctx context.Context, tenant string, namespace string) (map[string]ResourceUnit, *http.Response, error)

BrokerStatsApiService Broker availability report This API gives the current broker availability in percent, each resource percentage usage is calculated and thensum of all of the resource usage percent is called broker-resource-availability<br/><br/>THIS API IS ONLY FOR USE BY TESTING FOR CONFIRMING NAMESPACE ALLOCATION ALGORITHM

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return map[string]ResourceUnit

func (*BrokerStatsApiService) GetLoadReport ¶

func (a *BrokerStatsApiService) GetLoadReport(ctx context.Context) (LoadReport, *http.Response, error)

BrokerStatsApiService Get Load for this broker consists of topics stats & systemResourceUsage

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return LoadReport

func (*BrokerStatsApiService) GetMBeans ¶

func (a *BrokerStatsApiService) GetMBeans(ctx context.Context) ([]Metrics, *http.Response, error)

BrokerStatsApiService Get all the mbean details of this broker JVM

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []Metrics

func (*BrokerStatsApiService) GetMetrics ¶

func (a *BrokerStatsApiService) GetMetrics(ctx context.Context) ([]Metrics, *http.Response, error)

BrokerStatsApiService Gets the metrics for Monitoring Requested should be executed by Monitoring agent on each broker to fetch the metrics

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []Metrics

func (*BrokerStatsApiService) GetPendingBookieOpsStats ¶

func (a *BrokerStatsApiService) GetPendingBookieOpsStats(ctx context.Context) (map[string]PendingBookieOpsStats, *http.Response, error)

BrokerStatsApiService Get pending bookie client op stats by namesapce

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return map[string]PendingBookieOpsStats

func (*BrokerStatsApiService) GetTopics2 ¶

func (a *BrokerStatsApiService) GetTopics2(ctx context.Context) (map[string]interface{}, *http.Response, error)

BrokerStatsApiService Get all the topic stats by namespace

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return map[string]interface{}

func (*BrokersApiService) GetActiveBrokers ¶

func (a *BrokersApiService) GetActiveBrokers(ctx context.Context, cluster string) ([]string, *http.Response, error)

BrokersApiService Get the list of active brokers (web service addresses) in the cluster.If authorization is not enabled, any cluster name is valid.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param cluster

@return []string

func (*BrokersApiService) GetAllDynamicConfigurations ¶

func (a *BrokersApiService) GetAllDynamicConfigurations(ctx context.Context) (map[string]map[string]interface{}, *http.Response, error)

BrokersApiService Get value of all dynamic configurations' value overridden on local config

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return map[string]map[string]interface{}

func (*BrokersApiService) GetDynamicConfigurationName ¶

func (a *BrokersApiService) GetDynamicConfigurationName(ctx context.Context) ([]map[string]interface{}, *http.Response, error)

BrokersApiService Get all updatable dynamic configurations's name

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []map[string]interface{}

func (*BrokersApiService) GetInternalConfigurationData ¶

func (a *BrokersApiService) GetInternalConfigurationData(ctx context.Context) (InternalConfigurationData, *http.Response, error)

BrokersApiService Get the internal configuration data

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return InternalConfigurationData

func (*BrokersApiService) GetOwnedNamespaes ¶

func (a *BrokersApiService) GetOwnedNamespaes(ctx context.Context, clusterName string, brokerWebserviceurl string) (map[string]NamespaceOwnershipStatus, *http.Response, error)

BrokersApiService Get the list of namespaces served by the specific broker

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param clusterName
• @param brokerWebserviceurl

@return map[string]NamespaceOwnershipStatus

func (*BrokersApiService) GetRuntimeConfiguration ¶

func (a *BrokersApiService) GetRuntimeConfiguration(ctx context.Context) (map[string]map[string]interface{}, *http.Response, error)

BrokersApiService Get all runtime configurations. This operation requires Pulsar super-user privileges.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return map[string]map[string]interface{}

func (*BrokersApiService) Healthcheck ¶

func (a *BrokersApiService) Healthcheck(ctx context.Context) (*http.Response, error)

BrokersApiService Run a healthcheck against the broker

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

func (*BrokersApiService) UpdateDynamicConfiguration ¶

func (a *BrokersApiService) UpdateDynamicConfiguration(ctx context.Context, configName string, configValue string) (*http.Response, error)

BrokersApiService Update dynamic serviceconfiguration into zk only. This operation requires Pulsar super-user privileges.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param configName
• @param configValue

func (*ClustersApiService) CreateCluster ¶

func (a *ClustersApiService) CreateCluster(ctx context.Context, cluster string, body ClusterData) (*http.Response, error)

ClustersApiService Create a new cluster. This operation requires Pulsar superuser privileges, and the name cannot contain the '/' characters.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param cluster The cluster name
• @param body The cluster data

func (*ClustersApiService) DeleteCluster ¶

func (a *ClustersApiService) DeleteCluster(ctx context.Context, cluster string) (*http.Response, error)

ClustersApiService Delete an existing cluster. This operation requires Pulsar superuser privileges.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param cluster The cluster name

func (*ClustersApiService) DeleteFailureDomain ¶

func (a *ClustersApiService) DeleteFailureDomain(ctx context.Context, cluster string, domainName string) (*http.Response, error)

ClustersApiService Delete the failure domain of the cluster This operation requires Pulsar superuser privileges.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param cluster The cluster name
• @param domainName The failure domain name

func (*ClustersApiService) DeleteNamespaceIsolationPolicy ¶

func (a *ClustersApiService) DeleteNamespaceIsolationPolicy(ctx context.Context, cluster string, policyName string) (*http.Response, error)

ClustersApiService Delete namespace isolation policy. This operation requires Pulsar superuser privileges.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param cluster The cluster name
• @param policyName The namespace isolation policy name

func (*ClustersApiService) GetBrokerWithNamespaceIsolationPolicy ¶

func (a *ClustersApiService) GetBrokerWithNamespaceIsolationPolicy(ctx context.Context, cluster string, broker string) (BrokerNamespaceIsolationData, *http.Response, error)

ClustersApiService Get a broker with namespace-isolation policies attached to it. This operation requires Pulsar superuser privileges.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param cluster The cluster name
• @param broker The broker name (<broker-hostname>:<web-service-port>)

@return BrokerNamespaceIsolationData

func (*ClustersApiService) GetBrokersWithNamespaceIsolationPolicy ¶

func (a *ClustersApiService) GetBrokersWithNamespaceIsolationPolicy(ctx context.Context, cluster string) ([]BrokerNamespaceIsolationData, *http.Response, error)

ClustersApiService Get list of brokers with namespace-isolation policies attached to them. This operation requires Pulsar superuser privileges.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param cluster The cluster name

@return []BrokerNamespaceIsolationData

func (*ClustersApiService) GetCluster ¶

func (a *ClustersApiService) GetCluster(ctx context.Context, cluster string) (ClusterData, *http.Response, error)

ClustersApiService Get the configuration for the specified cluster. This operation requires Pulsar superuser privileges.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param cluster The cluster name

@return ClusterData

func (*ClustersApiService) GetClusters ¶

func (a *ClustersApiService) GetClusters(ctx context.Context) ([]string, *http.Response, error)

ClustersApiService Get the list of all the Pulsar clusters.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []string

func (*ClustersApiService) GetDomain ¶

func (a *ClustersApiService) GetDomain(ctx context.Context, cluster string, domainName string) (FailureDomain, *http.Response, error)

ClustersApiService Get a domain in a cluster This operation requires Pulsar superuser privileges.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param cluster The cluster name
• @param domainName The failure domain name

@return FailureDomain

func (*ClustersApiService) GetFailureDomains ¶

func (a *ClustersApiService) GetFailureDomains(ctx context.Context, cluster string) (map[string]FailureDomain, *http.Response, error)

ClustersApiService Get the cluster failure domains. This operation requires Pulsar superuser privileges.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param cluster The cluster name

@return map[string]FailureDomain

func (*ClustersApiService) GetNamespaceIsolationPolicies ¶

func (a *ClustersApiService) GetNamespaceIsolationPolicies(ctx context.Context, cluster string) (map[string]NamespaceIsolationData, *http.Response, error)

ClustersApiService Get the namespace isolation policies assigned to the cluster. This operation requires Pulsar superuser privileges.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param cluster The cluster name

@return map[string]NamespaceIsolationData

func (*ClustersApiService) GetNamespaceIsolationPolicy ¶

func (a *ClustersApiService) GetNamespaceIsolationPolicy(ctx context.Context, cluster string, policyName string) (NamespaceIsolationData, *http.Response, error)

ClustersApiService Get the single namespace isolation policy assigned to the cluster. This operation requires Pulsar superuser privileges.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param cluster The cluster name
• @param policyName The name of the namespace isolation policy

@return NamespaceIsolationData

func (*ClustersApiService) GetPeerCluster ¶

func (a *ClustersApiService) GetPeerCluster(ctx context.Context, cluster string) ([]string, *http.Response, error)

ClustersApiService Get the peer-cluster data for the specified cluster. This operation requires Pulsar superuser privileges.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param cluster The cluster name

@return []string

func (*ClustersApiService) SetFailureDomain ¶

func (a *ClustersApiService) SetFailureDomain(ctx context.Context, cluster string, domainName string, body FailureDomain) (*http.Response, error)

ClustersApiService Set the failure domain of the cluster. This operation requires Pulsar superuser privileges.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param cluster The cluster name
• @param domainName The failure domain name
• @param body The configuration data of a failure domain

func (*ClustersApiService) SetNamespaceIsolationPolicy ¶

func (a *ClustersApiService) SetNamespaceIsolationPolicy(ctx context.Context, cluster string, policyName string, body NamespaceIsolationData) (*http.Response, error)

ClustersApiService Set namespace isolation policy. This operation requires Pulsar superuser privileges.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param cluster The cluster name
• @param policyName The namespace isolation policy name
• @param body The namespace isolation policy data

func (*ClustersApiService) SetPeerClusterNames ¶

func (a *ClustersApiService) SetPeerClusterNames(ctx context.Context, cluster string, body []string) (*http.Response, error)

ClustersApiService Update peer-cluster-list for a cluster. This operation requires Pulsar superuser privileges.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param cluster The cluster name
• @param body The list of peer cluster names

func (*ClustersApiService) UpdateCluster ¶

func (a *ClustersApiService) UpdateCluster(ctx context.Context, cluster string, body ClusterData) (*http.Response, error)

ClustersApiService Update the configuration for a cluster. This operation requires Pulsar superuser privileges.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param cluster The cluster name
• @param body The cluster data

func (*Configuration) AddDefaultHeader ¶

func (c *Configuration) AddDefaultHeader(key string, value string)

func (GenericOpenAPIError) Body ¶

func (e GenericOpenAPIError) Body() []byte

Body returns the raw bytes of the response

func (GenericOpenAPIError) Error ¶

func (e GenericOpenAPIError) Error() string

Error returns non-empty string if there was an error.

func (GenericOpenAPIError) Model ¶

func (e GenericOpenAPIError) Model() interface{}

Model returns the unpacked model of the error

func (*NamespacesApiService) ClearNamespaceBacklog ¶

func (a *NamespacesApiService) ClearNamespaceBacklog(ctx context.Context, tenant string, namespace string, localVarOptionals *ClearNamespaceBacklogOpts) (*http.Response, error)

func (*NamespacesApiService) ClearNamespaceBacklogForSubscription ¶

func (a *NamespacesApiService) ClearNamespaceBacklogForSubscription(ctx context.Context, tenant string, namespace string, subscription string, localVarOptionals *ClearNamespaceBacklogForSubscriptionOpts) (*http.Response, error)

func (*NamespacesApiService) ClearNamespaceBundleBacklog ¶

func (a *NamespacesApiService) ClearNamespaceBundleBacklog(ctx context.Context, tenant string, namespace string, bundle string, localVarOptionals *ClearNamespaceBundleBacklogOpts) (*http.Response, error)

func (*NamespacesApiService) ClearNamespaceBundleBacklogForSubscription ¶

func (a *NamespacesApiService) ClearNamespaceBundleBacklogForSubscription(ctx context.Context, tenant string, namespace string, subscription string, bundle string, localVarOptionals *ClearNamespaceBundleBacklogForSubscriptionOpts) (*http.Response, error)

func (*NamespacesApiService) ClearOffloadDeletionLag ¶

func (a *NamespacesApiService) ClearOffloadDeletionLag(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Clear the namespace configured offload deletion lag. The topics in the namespace will fallback to using the default configured deletion lag for the broker

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) CreateNamespace ¶

func (a *NamespacesApiService) CreateNamespace(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Creates a new namespace with the specified policies

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) DeleteBookieAffinityGroup ¶

func (a *NamespacesApiService) DeleteBookieAffinityGroup(ctx context.Context, property string, namespace string) (*http.Response, error)

NamespacesApiService Delete the bookie-affinity-group from namespace-local policy.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param property
• @param namespace

func (*NamespacesApiService) DeleteNamespace ¶

func (a *NamespacesApiService) DeleteNamespace(ctx context.Context, tenant string, namespace string, localVarOptionals *DeleteNamespaceOpts) (*http.Response, error)

func (*NamespacesApiService) DeleteNamespaceBundle ¶

func (a *NamespacesApiService) DeleteNamespaceBundle(ctx context.Context, tenant string, namespace string, bundle string, localVarOptionals *DeleteNamespaceBundleOpts) (*http.Response, error)

func (*NamespacesApiService) GetAntiAffinityNamespaces ¶

func (a *NamespacesApiService) GetAntiAffinityNamespaces(ctx context.Context, cluster string, group string, localVarOptionals *GetAntiAffinityNamespacesOpts) ([]map[string]interface{}, *http.Response, error)

func (*NamespacesApiService) GetBacklogQuotaMap ¶

func (a *NamespacesApiService) GetBacklogQuotaMap(ctx context.Context, tenant string, namespace string) (map[string]map[string]interface{}, *http.Response, error)

NamespacesApiService Get backlog quota map on a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return map[string]map[string]interface{}

func (*NamespacesApiService) GetBookieAffinityGroup ¶

func (a *NamespacesApiService) GetBookieAffinityGroup(ctx context.Context, property string, namespace string) (BookieAffinityGroupData, *http.Response, error)

NamespacesApiService Get the bookie-affinity-group from namespace-local policy.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param property
• @param namespace

@return BookieAffinityGroupData

func (*NamespacesApiService) GetBundlesData ¶

func (a *NamespacesApiService) GetBundlesData(ctx context.Context, tenant string, namespace string) (BundlesData, *http.Response, error)

NamespacesApiService Get the bundles split data.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return BundlesData

func (*NamespacesApiService) GetCompactionThreshold ¶

func (a *NamespacesApiService) GetCompactionThreshold(ctx context.Context, tenant string, namespace string) (int64, *http.Response, error)

NamespacesApiService Maximum number of uncompacted bytes in topics before compaction is triggered. The backlog size is compared to the threshold periodically. A threshold of 0 disabled automatic compaction

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return int64

func (*NamespacesApiService) GetDispatchRate ¶

func (a *NamespacesApiService) GetDispatchRate(ctx context.Context, tenant string, namespace string) (DispatchRate, *http.Response, error)

NamespacesApiService Get dispatch-rate configured for the namespace, -1 represents not configured yet

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return DispatchRate

func (*NamespacesApiService) GetMaxConsumersPerSubscription ¶

func (a *NamespacesApiService) GetMaxConsumersPerSubscription(ctx context.Context, tenant string, namespace string) (int32, *http.Response, error)

NamespacesApiService Get maxConsumersPerSubscription config on a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return int32

func (*NamespacesApiService) GetMaxConsumersPerTopic ¶

func (a *NamespacesApiService) GetMaxConsumersPerTopic(ctx context.Context, tenant string, namespace string) (int32, *http.Response, error)

NamespacesApiService Get maxConsumersPerTopic config on a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return int32

func (*NamespacesApiService) GetMaxProducersPerTopic ¶

func (a *NamespacesApiService) GetMaxProducersPerTopic(ctx context.Context, tenant string, namespace string) (int32, *http.Response, error)

NamespacesApiService Get maxProducersPerTopic config on a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return int32

func (*NamespacesApiService) GetNamespaceAntiAffinityGroup ¶

func (a *NamespacesApiService) GetNamespaceAntiAffinityGroup(ctx context.Context, tenant string, namespace string) (string, *http.Response, error)

NamespacesApiService Get anti-affinity group of a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return string

func (*NamespacesApiService) GetNamespaceMessageTTL ¶

func (a *NamespacesApiService) GetNamespaceMessageTTL(ctx context.Context, tenant string, namespace string) (int32, *http.Response, error)

NamespacesApiService Get the message TTL for the namespace

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return int32

func (*NamespacesApiService) GetNamespaceReplicationClusters ¶

func (a *NamespacesApiService) GetNamespaceReplicationClusters(ctx context.Context, tenant string, namespace string) ([]string, *http.Response, error)

NamespacesApiService Get the replication clusters for a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return []string

func (*NamespacesApiService) GetOffloadDeletionLag ¶

func (a *NamespacesApiService) GetOffloadDeletionLag(ctx context.Context, tenant string, namespace string) (int64, *http.Response, error)

NamespacesApiService Number of milliseconds to wait before deleting a ledger segment which has been offloaded from the Pulsar cluster's local storage (i.e. BookKeeper) A negative value denotes that deletion has been completely disabled. &#39;null&#39; denotes that the topics in the namespace will fall back to the broker default for deletion lag.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return int64

func (*NamespacesApiService) GetOffloadThreshold ¶

func (a *NamespacesApiService) GetOffloadThreshold(ctx context.Context, tenant string, namespace string) (int64, *http.Response, error)

NamespacesApiService Maximum number of bytes stored on the pulsar cluster for a topic, before the broker will start offloading to longterm storage A negative value disables automatic offloading

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return int64

func (*NamespacesApiService) GetPermissions ¶

func (a *NamespacesApiService) GetPermissions(ctx context.Context, tenant string, cluster string, namespace string) (map[string]map[string]interface{}, *http.Response, error)

NamespacesApiService Retrieve the permissions for a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param cluster
• @param namespace

@return map[string]map[string]interface{}

func (*NamespacesApiService) GetPersistence ¶

func (a *NamespacesApiService) GetPersistence(ctx context.Context, tenant string, namespace string) (PersistencePolicies, *http.Response, error)

NamespacesApiService Get the persistence configuration for a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return PersistencePolicies

func (*NamespacesApiService) GetPolicies ¶

func (a *NamespacesApiService) GetPolicies(ctx context.Context, tenant string, namespace string) (Policies, *http.Response, error)

NamespacesApiService Get the dump all the policies specified for a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return Policies

func (*NamespacesApiService) GetReplicatorDispatchRate ¶

func (a *NamespacesApiService) GetReplicatorDispatchRate(ctx context.Context, tenant string, namespace string) (DispatchRate, *http.Response, error)

NamespacesApiService Get replicator dispatch-rate configured for the namespace, -1 represents not configured yet

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return DispatchRate

func (*NamespacesApiService) GetRetention ¶

func (a *NamespacesApiService) GetRetention(ctx context.Context, tenant string, namespace string) (RetentionPolicies, *http.Response, error)

NamespacesApiService Get retention config on a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return RetentionPolicies

func (*NamespacesApiService) GetSchemaAutoUpdateCompatibilityStrategy ¶

func (a *NamespacesApiService) GetSchemaAutoUpdateCompatibilityStrategy(ctx context.Context, tenant string, namespace string) (string, *http.Response, error)

NamespacesApiService The strategy used to check the compatibility of new schemas, provided by producers, before automatically updating the schema The value AutoUpdateDisabled prevents producers from updating the schema. If set to AutoUpdateDisabled, schemas must be updated through the REST api

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return string

func (*NamespacesApiService) GetSchemaValidtionEnforced ¶

func (a *NamespacesApiService) GetSchemaValidtionEnforced(ctx context.Context, tenant string, namespace string) (bool, *http.Response, error)

NamespacesApiService Get schema validation enforced flag for namespace. If the flag is set to true, when a producer without a schema attempts to produce to a topic with schema in this namespace, the producer will be failed to connect. PLEASE be carefully on using this, since non-java clients don&#39;t support schema.if you enable this setting, it will cause non-java clients failed to produce.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return bool

func (*NamespacesApiService) GetSubscribeRate ¶

func (a *NamespacesApiService) GetSubscribeRate(ctx context.Context, tenant string, namespace string) (SubscribeRate, *http.Response, error)

NamespacesApiService Get subscribe-rate configured for the namespace

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return SubscribeRate

func (*NamespacesApiService) GetSubscriptionDispatchRate ¶

func (a *NamespacesApiService) GetSubscriptionDispatchRate(ctx context.Context, tenant string, namespace string) (DispatchRate, *http.Response, error)

NamespacesApiService Get Subscription dispatch-rate configured for the namespace, -1 represents not configured yet

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

@return DispatchRate

func (*NamespacesApiService) GetTenantNamespaces ¶

func (a *NamespacesApiService) GetTenantNamespaces(ctx context.Context, tenant string) ([]string, *http.Response, error)

NamespacesApiService Get the list of all the namespaces for a certain tenant.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant

@return []string

func (*NamespacesApiService) GetTopics ¶

func (a *NamespacesApiService) GetTopics(ctx context.Context, tenant string, namespace string, localVarOptionals *GetTopicsOpts) ([]string, *http.Response, error)

func (*NamespacesApiService) GrantPermissionOnNamespace ¶

func (a *NamespacesApiService) GrantPermissionOnNamespace(ctx context.Context, tenant string, namespace string, role string) (*http.Response, error)

NamespacesApiService Grant a new permission to a role on a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace
• @param role

func (*NamespacesApiService) ModifyDeduplication ¶

func (a *NamespacesApiService) ModifyDeduplication(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Enable or disable broker side deduplication for all topics in a namespace

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) ModifyEncryptionRequired ¶

func (a *NamespacesApiService) ModifyEncryptionRequired(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Message encryption is required or not for all topics in a namespace

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) RemoveBacklogQuota ¶

func (a *NamespacesApiService) RemoveBacklogQuota(ctx context.Context, tenant string, namespace string, localVarOptionals *RemoveBacklogQuotaOpts) (*http.Response, error)

func (*NamespacesApiService) RemoveNamespaceAntiAffinityGroup ¶

func (a *NamespacesApiService) RemoveNamespaceAntiAffinityGroup(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Remove anti-affinity group of a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) RevokePermissionsOnNamespace ¶

func (a *NamespacesApiService) RevokePermissionsOnNamespace(ctx context.Context, tenant string, namespace string, role string) (*http.Response, error)

NamespacesApiService Revoke all permissions to a role on a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace
• @param role

func (*NamespacesApiService) SetBacklogQuota ¶

func (a *NamespacesApiService) SetBacklogQuota(ctx context.Context, tenant string, namespace string, localVarOptionals *SetBacklogQuotaOpts) (*http.Response, error)

func (*NamespacesApiService) SetBookieAffinityGroup ¶

func (a *NamespacesApiService) SetBookieAffinityGroup(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Set the bookie-affinity-group to namespace-persistent policy.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) SetCompactionThreshold ¶

func (a *NamespacesApiService) SetCompactionThreshold(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Set maximum number of uncompacted bytes in a topic before compaction is triggered. The backlog size is compared to the threshold periodically. A threshold of 0 disabled automatic compaction

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) SetDispatchRate ¶

func (a *NamespacesApiService) SetDispatchRate(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Set dispatch-rate throttling for all topics of the namespace

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) SetMaxConsumersPerSubscription ¶

func (a *NamespacesApiService) SetMaxConsumersPerSubscription(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Set maxConsumersPerSubscription configuration on a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) SetMaxConsumersPerTopic ¶

func (a *NamespacesApiService) SetMaxConsumersPerTopic(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Set maxConsumersPerTopic configuration on a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) SetMaxProducersPerTopic ¶

func (a *NamespacesApiService) SetMaxProducersPerTopic(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Set maxProducersPerTopic configuration on a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) SetNamespaceAntiAffinityGroup ¶

func (a *NamespacesApiService) SetNamespaceAntiAffinityGroup(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Set anti-affinity group for a namespace

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) SetNamespaceMessageTTL ¶

func (a *NamespacesApiService) SetNamespaceMessageTTL(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Set message TTL in seconds for namespace

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) SetNamespaceReplicationClusters ¶

func (a *NamespacesApiService) SetNamespaceReplicationClusters(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Set the replication clusters for a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) SetOffloadDeletionLag ¶

func (a *NamespacesApiService) SetOffloadDeletionLag(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Set number of milliseconds to wait before deleting a ledger segment which has been offloaded from the Pulsar cluster's local storage (i.e. BookKeeper) A negative value disables the deletion completely.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) SetOffloadThreshold ¶

func (a *NamespacesApiService) SetOffloadThreshold(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Set maximum number of bytes stored on the pulsar cluster for a topic, before the broker will start offloading to longterm storage A negative value disables automatic offloading

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) SetPersistence ¶

func (a *NamespacesApiService) SetPersistence(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Set the persistence configuration for all the topics on a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) SetReplicatorDispatchRate ¶

func (a *NamespacesApiService) SetReplicatorDispatchRate(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Set replicator dispatch-rate throttling for all topics of the namespace

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) SetRetention ¶

func (a *NamespacesApiService) SetRetention(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Set retention configuration on a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) SetSchemaAutoUpdateCompatibilityStrategy ¶

func (a *NamespacesApiService) SetSchemaAutoUpdateCompatibilityStrategy(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Update the strategy used to check the compatibility of new schemas, provided by producers, before automatically updating the schema The value AutoUpdateDisabled prevents producers from updating the schema. If set to AutoUpdateDisabled, schemas must be updated through the REST api

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) SetSchemaValidtionEnforced ¶

func (a *NamespacesApiService) SetSchemaValidtionEnforced(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Set schema validation enforced flag on namespace. If the flag is set to true, when a producer without a schema attempts to produce to a topic with schema in this namespace, the producer will be failed to connect. PLEASE be carefully on using this, since non-java clients don&#39;t support schema.if you enable this setting, it will cause non-java clients failed to produce.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) SetSubscribeRate ¶

func (a *NamespacesApiService) SetSubscribeRate(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Set subscribe-rate throttling for all topics of the namespace

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) SetSubscriptionAuthMode ¶

func (a *NamespacesApiService) SetSubscriptionAuthMode(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Set a subscription auth mode for all the topics on a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) SetSubscriptionDispatchRate ¶

func (a *NamespacesApiService) SetSubscriptionDispatchRate(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Set Subscription dispatch-rate throttling for all topics of the namespace

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) SplitNamespaceBundle ¶

func (a *NamespacesApiService) SplitNamespaceBundle(ctx context.Context, tenant string, namespace string, bundle string, localVarOptionals *SplitNamespaceBundleOpts) (*http.Response, error)

func (*NamespacesApiService) UnloadNamespace ¶

func (a *NamespacesApiService) UnloadNamespace(ctx context.Context, tenant string, namespace string) (*http.Response, error)

NamespacesApiService Unload namespace Unload an active namespace from the current broker serving it. Performing this operation will let the brokerremoves all producers, consumers, and connections using this namespace, and close all topics (includingtheir persistent store). During that operation, the namespace is marked as tentatively unavailable until thebroker completes the unloading action. This operation requires strictly super user privileges, since it wouldresult in non-persistent message loss and unexpected connection closure to the clients.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace

func (*NamespacesApiService) UnloadNamespaceBundle ¶

func (a *NamespacesApiService) UnloadNamespaceBundle(ctx context.Context, tenant string, namespace string, bundle string, localVarOptionals *UnloadNamespaceBundleOpts) (*http.Response, error)

func (*NamespacesApiService) UnsubscribeNamespace ¶

func (a *NamespacesApiService) UnsubscribeNamespace(ctx context.Context, tenant string, cluster string, namespace string, subscription string, localVarOptionals *UnsubscribeNamespaceOpts) (*http.Response, error)

func (*NamespacesApiService) UnsubscribeNamespaceBundle ¶

func (a *NamespacesApiService) UnsubscribeNamespaceBundle(ctx context.Context, tenant string, namespace string, subscription string, bundle string, localVarOptionals *UnsubscribeNamespaceBundleOpts) (*http.Response, error)

func (*NonPersistentTopicApiService) Compact ¶

func (a *NonPersistentTopicApiService) Compact(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *CompactOpts) (*http.Response, error)

func (*NonPersistentTopicApiService) CompactionStatus ¶

func (a *NonPersistentTopicApiService) CompactionStatus(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *CompactionStatusOpts) (LongRunningProcessStatus, *http.Response, error)

func (*NonPersistentTopicApiService) CreateNonPartitionedTopic ¶

func (a *NonPersistentTopicApiService) CreateNonPartitionedTopic(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *CreateNonPartitionedTopicOpts) (*http.Response, error)

func (*NonPersistentTopicApiService) CreatePartitionedTopic ¶

func (a *NonPersistentTopicApiService) CreatePartitionedTopic(ctx context.Context, tenant string, namespace string, topic string, body int32) (*http.Response, error)

NonPersistentTopicApiService Create a partitioned topic. It needs to be called before creating a producer on a partitioned topic.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant Specify the tenant
• @param namespace Specify the namespace
• @param topic Specify topic name
• @param body The number of partitions for the topic

func (*NonPersistentTopicApiService) CreateSubscription ¶

func (a *NonPersistentTopicApiService) CreateSubscription(ctx context.Context, tenant string, namespace string, topic string, subscriptionName string, localVarOptionals *CreateSubscriptionOpts) (*http.Response, error)

func (*NonPersistentTopicApiService) DeletePartitionedTopic ¶

func (a *NonPersistentTopicApiService) DeletePartitionedTopic(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *DeletePartitionedTopicOpts) (*http.Response, error)

func (*NonPersistentTopicApiService) DeleteSubscription ¶

func (a *NonPersistentTopicApiService) DeleteSubscription(ctx context.Context, tenant string, namespace string, topic string, subName string, localVarOptionals *DeleteSubscriptionOpts) (*http.Response, error)

func (*NonPersistentTopicApiService) DeleteTopic ¶

func (a *NonPersistentTopicApiService) DeleteTopic(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *DeleteTopicOpts) (*http.Response, error)

func (*NonPersistentTopicApiService) ExpireMessagesForAllSubscriptions ¶

func (a *NonPersistentTopicApiService) ExpireMessagesForAllSubscriptions(ctx context.Context, tenant string, namespace string, topic string, expireTimeInSeconds int32, localVarOptionals *ExpireMessagesForAllSubscriptionsOpts) (*http.Response, error)

func (*NonPersistentTopicApiService) ExpireTopicMessages ¶

func (a *NonPersistentTopicApiService) ExpireTopicMessages(ctx context.Context, tenant string, namespace string, topic string, subName string, expireTimeInSeconds int32, localVarOptionals *ExpireTopicMessagesOpts) (*http.Response, error)

func (*NonPersistentTopicApiService) GetBacklog ¶

func (a *NonPersistentTopicApiService) GetBacklog(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *GetBacklogOpts) (PersistentOfflineTopicStats, *http.Response, error)

func (*NonPersistentTopicApiService) GetInternalStats ¶

func (a *NonPersistentTopicApiService) GetInternalStats(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *GetInternalStatsOpts) (PersistentTopicInternalStats, *http.Response, error)

func (*NonPersistentTopicApiService) GetLastMessageId ¶

func (a *NonPersistentTopicApiService) GetLastMessageId(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *GetLastMessageIdOpts) (map[string]interface{}, *http.Response, error)

func (*NonPersistentTopicApiService) GetList ¶

func (a *NonPersistentTopicApiService) GetList(ctx context.Context, tenant string, namespace string) ([]string, *http.Response, error)

NonPersistentTopicApiService Get the list of non-persistent topics under a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant Specify the tenant
• @param namespace Specify the namespace

@return []string

func (*NonPersistentTopicApiService) GetListFromBundle ¶

func (a *NonPersistentTopicApiService) GetListFromBundle(ctx context.Context, tenant string, namespace string, bundle string) ([]string, *http.Response, error)

NonPersistentTopicApiService Get the list of non-persistent topics under a namespace bundle.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace
• @param bundle

@return []string

func (*NonPersistentTopicApiService) GetManagedLedgerInfo ¶

func (a *NonPersistentTopicApiService) GetManagedLedgerInfo(ctx context.Context, tenant string, namespace string, topic string) (*http.Response, error)

NonPersistentTopicApiService Get the internal stats for the topic.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant Specify the tenant
• @param namespace Specify the namespace
• @param topic Specify topic name

func (*NonPersistentTopicApiService) GetPartitionedMetadata ¶

func (a *NonPersistentTopicApiService) GetPartitionedMetadata(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *GetPartitionedMetadataOpts) (PartitionedTopicMetadata, *http.Response, error)

func (*NonPersistentTopicApiService) GetPartitionedStats ¶

func (a *NonPersistentTopicApiService) GetPartitionedStats(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *GetPartitionedStatsOpts) (*http.Response, error)

func (*NonPersistentTopicApiService) GetPartitionedTopicList ¶

func (a *NonPersistentTopicApiService) GetPartitionedTopicList(ctx context.Context, tenant string, namespace string) ([]string, *http.Response, error)

NonPersistentTopicApiService Get the list of partitioned topics under a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant Specify the tenant
• @param namespace Specify the namespace

@return []string

func (*NonPersistentTopicApiService) GetPermissionsOnTopic ¶

func (a *NonPersistentTopicApiService) GetPermissionsOnTopic(ctx context.Context, tenant string, namespace string, topic string) (map[string]map[string]interface{}, *http.Response, error)

NonPersistentTopicApiService Get permissions on a topic. Retrieve the effective permissions for a topic. These permissions are defined by the permissions set at thenamespace level combined (union) with any eventual specific permission set on the topic.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant Specify the tenant
• @param namespace Specify the namespace
• @param topic Specify topic name

@return map[string]map[string]interface{}

func (*NonPersistentTopicApiService) GetStats ¶

func (a *NonPersistentTopicApiService) GetStats(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *GetStatsOpts) (TopicStats, *http.Response, error)

func (*NonPersistentTopicApiService) GetSubscriptions ¶

func (a *NonPersistentTopicApiService) GetSubscriptions(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *GetSubscriptionsOpts) ([]map[string]interface{}, *http.Response, error)

func (*NonPersistentTopicApiService) GrantPermissionsOnTopic ¶

func (a *NonPersistentTopicApiService) GrantPermissionsOnTopic(ctx context.Context, tenant string, namespace string, topic string, role string, localVarOptionals *GrantPermissionsOnTopicOpts) (*http.Response, error)

func (*NonPersistentTopicApiService) OffloadStatus ¶

func (a *NonPersistentTopicApiService) OffloadStatus(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *OffloadStatusOpts) (OffloadProcessStatus, *http.Response, error)

func (*NonPersistentTopicApiService) PeekNthMessage ¶

func (a *NonPersistentTopicApiService) PeekNthMessage(ctx context.Context, tenant string, namespace string, topic string, subName string, messagePosition int32, localVarOptionals *PeekNthMessageOpts) (*http.Response, error)

func (*NonPersistentTopicApiService) ResetCursor ¶

func (a *NonPersistentTopicApiService) ResetCursor(ctx context.Context, tenant string, namespace string, topic string, subName string, timestamp int64, localVarOptionals *ResetCursorOpts) (*http.Response, error)

func (*NonPersistentTopicApiService) ResetCursorOnPosition ¶

func (a *NonPersistentTopicApiService) ResetCursorOnPosition(ctx context.Context, tenant string, namespace string, topic string, subName string, localVarOptionals *ResetCursorOnPositionOpts) (*http.Response, error)

func (*NonPersistentTopicApiService) RevokePermissionsOnTopic ¶

func (a *NonPersistentTopicApiService) RevokePermissionsOnTopic(ctx context.Context, tenant string, namespace string, topic string, role string) (*http.Response, error)

NonPersistentTopicApiService Revoke permissions on a topic. Revoke permissions to a role on a single topic. If the permission was not set at the topiclevel, but rather at the namespace level, this operation will return an error (HTTP status code 412).

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant Specify the tenant
• @param namespace Specify the namespace
• @param topic Specify topic name
• @param role Client role to which grant permissions

func (*NonPersistentTopicApiService) SkipAllMessages ¶

func (a *NonPersistentTopicApiService) SkipAllMessages(ctx context.Context, tenant string, namespace string, topic string, subName string, localVarOptionals *SkipAllMessagesOpts) (*http.Response, error)

func (*NonPersistentTopicApiService) SkipMessages ¶

func (a *NonPersistentTopicApiService) SkipMessages(ctx context.Context, tenant string, namespace string, topic string, subName string, numMessages int32, localVarOptionals *SkipMessagesOpts) (*http.Response, error)

func (*NonPersistentTopicApiService) Terminate ¶

func (a *NonPersistentTopicApiService) Terminate(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *TerminateOpts) (map[string]interface{}, *http.Response, error)

func (*NonPersistentTopicApiService) TriggerOffload ¶

func (a *NonPersistentTopicApiService) TriggerOffload(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *TriggerOffloadOpts) (*http.Response, error)

func (*NonPersistentTopicApiService) UnloadTopic ¶

func (a *NonPersistentTopicApiService) UnloadTopic(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *UnloadTopicOpts) (*http.Response, error)

func (*NonPersistentTopicApiService) UpdatePartitionedTopic ¶

func (a *NonPersistentTopicApiService) UpdatePartitionedTopic(ctx context.Context, tenant string, namespace string, topic string, body int32) (*http.Response, error)

NonPersistentTopicApiService Increment partitons of an existing partitioned topic. It only increments partitions of existing non-global partitioned-topic

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant Specify the tenant
• @param namespace Specify the namespace
• @param topic Specify topic name
• @param body The number of partitions for the topic

func (*PersistentTopicApiService) Compact ¶

func (a *PersistentTopicApiService) Compact(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *CompactOpts) (*http.Response, error)

func (*PersistentTopicApiService) CompactionStatus ¶

func (a *PersistentTopicApiService) CompactionStatus(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *CompactionStatusOpts) (LongRunningProcessStatus, *http.Response, error)

func (*PersistentTopicApiService) CreateNonPartitionedTopic ¶

func (a *PersistentTopicApiService) CreateNonPartitionedTopic(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *CreateNonPartitionedTopicOpts) (*http.Response, error)

func (*PersistentTopicApiService) CreatePartitionedTopic ¶

func (a *PersistentTopicApiService) CreatePartitionedTopic(ctx context.Context, tenant string, namespace string, topic string, body int32) (*http.Response, error)

PersistentTopicApiService Create a partitioned topic. It needs to be called before creating a producer on a partitioned topic.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant Specify the tenant
• @param namespace Specify the namespace
• @param topic Specify topic name
• @param body The number of partitions for the topic

func (*PersistentTopicApiService) CreateSubscription ¶

func (a *PersistentTopicApiService) CreateSubscription(ctx context.Context, tenant string, namespace string, topic string, subscriptionName string, localVarOptionals *CreateSubscriptionOpts) (*http.Response, error)

func (*PersistentTopicApiService) DeletePartitionedTopic ¶

func (a *PersistentTopicApiService) DeletePartitionedTopic(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *DeletePartitionedTopicOpts) (*http.Response, error)

func (*PersistentTopicApiService) DeleteSubscription ¶

func (a *PersistentTopicApiService) DeleteSubscription(ctx context.Context, tenant string, namespace string, topic string, subName string, localVarOptionals *DeleteSubscriptionOpts) (*http.Response, error)

func (*PersistentTopicApiService) DeleteTopic ¶

func (a *PersistentTopicApiService) DeleteTopic(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *DeleteTopicOpts) (*http.Response, error)

func (*PersistentTopicApiService) ExpireMessagesForAllSubscriptions ¶

func (a *PersistentTopicApiService) ExpireMessagesForAllSubscriptions(ctx context.Context, tenant string, namespace string, topic string, expireTimeInSeconds int32, localVarOptionals *ExpireMessagesForAllSubscriptionsOpts) (*http.Response, error)

func (*PersistentTopicApiService) ExpireTopicMessages ¶

func (a *PersistentTopicApiService) ExpireTopicMessages(ctx context.Context, tenant string, namespace string, topic string, subName string, expireTimeInSeconds int32, localVarOptionals *ExpireTopicMessagesOpts) (*http.Response, error)

func (*PersistentTopicApiService) GetBacklog ¶

func (a *PersistentTopicApiService) GetBacklog(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *GetBacklogOpts) (PersistentOfflineTopicStats, *http.Response, error)

func (*PersistentTopicApiService) GetInternalStats ¶

func (a *PersistentTopicApiService) GetInternalStats(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *GetInternalStatsOpts) (PersistentTopicInternalStats, *http.Response, error)

func (*PersistentTopicApiService) GetLastMessageId ¶

func (a *PersistentTopicApiService) GetLastMessageId(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *GetLastMessageIdOpts) (map[string]interface{}, *http.Response, error)

func (*PersistentTopicApiService) GetList ¶

func (a *PersistentTopicApiService) GetList(ctx context.Context, tenant string, namespace string) ([]string, *http.Response, error)

PersistentTopicApiService Get the list of topics under a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant Specify the tenant
• @param namespace Specify the namespace

@return []string

func (*PersistentTopicApiService) GetManagedLedgerInfo ¶

func (a *PersistentTopicApiService) GetManagedLedgerInfo(ctx context.Context, tenant string, namespace string, topic string) (*http.Response, error)

PersistentTopicApiService Get the internal stats for the topic.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant Specify the tenant
• @param namespace Specify the namespace
• @param topic Specify topic name

func (*PersistentTopicApiService) GetPartitionedMetadata ¶

func (a *PersistentTopicApiService) GetPartitionedMetadata(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *GetPartitionedMetadataOpts) (PartitionedTopicMetadata, *http.Response, error)

func (*PersistentTopicApiService) GetPartitionedStats ¶

func (a *PersistentTopicApiService) GetPartitionedStats(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *GetPartitionedStatsOpts) (*http.Response, error)

func (*PersistentTopicApiService) GetPartitionedTopicList ¶

func (a *PersistentTopicApiService) GetPartitionedTopicList(ctx context.Context, tenant string, namespace string) ([]string, *http.Response, error)

PersistentTopicApiService Get the list of partitioned topics under a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant Specify the tenant
• @param namespace Specify the namespace

@return []string

func (*PersistentTopicApiService) GetPermissionsOnTopic ¶

func (a *PersistentTopicApiService) GetPermissionsOnTopic(ctx context.Context, tenant string, namespace string, topic string) (map[string]map[string]interface{}, *http.Response, error)

PersistentTopicApiService Get permissions on a topic. Retrieve the effective permissions for a topic. These permissions are defined by the permissions set at thenamespace level combined (union) with any eventual specific permission set on the topic.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant Specify the tenant
• @param namespace Specify the namespace
• @param topic Specify topic name

@return map[string]map[string]interface{}

func (*PersistentTopicApiService) GetStats ¶

func (a *PersistentTopicApiService) GetStats(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *GetStatsOpts) (TopicStats, *http.Response, error)

func (*PersistentTopicApiService) GetSubscriptions ¶

func (a *PersistentTopicApiService) GetSubscriptions(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *GetSubscriptionsOpts) ([]map[string]interface{}, *http.Response, error)

func (*PersistentTopicApiService) GrantPermissionsOnTopic ¶

func (a *PersistentTopicApiService) GrantPermissionsOnTopic(ctx context.Context, tenant string, namespace string, topic string, role string, localVarOptionals *GrantPermissionsOnTopicOpts) (*http.Response, error)

func (*PersistentTopicApiService) OffloadStatus ¶

func (a *PersistentTopicApiService) OffloadStatus(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *OffloadStatusOpts) (OffloadProcessStatus, *http.Response, error)

func (*PersistentTopicApiService) PeekNthMessage ¶

func (a *PersistentTopicApiService) PeekNthMessage(ctx context.Context, tenant string, namespace string, topic string, subName string, messagePosition int32, localVarOptionals *PeekNthMessageOpts) (*http.Response, error)

func (*PersistentTopicApiService) ResetCursor ¶

func (a *PersistentTopicApiService) ResetCursor(ctx context.Context, tenant string, namespace string, topic string, subName string, timestamp int64, localVarOptionals *ResetCursorOpts) (*http.Response, error)

func (*PersistentTopicApiService) ResetCursorOnPosition ¶

func (a *PersistentTopicApiService) ResetCursorOnPosition(ctx context.Context, tenant string, namespace string, topic string, subName string, localVarOptionals *ResetCursorOnPositionOpts) (*http.Response, error)

func (*PersistentTopicApiService) RevokePermissionsOnTopic ¶

func (a *PersistentTopicApiService) RevokePermissionsOnTopic(ctx context.Context, tenant string, namespace string, topic string, role string) (*http.Response, error)

PersistentTopicApiService Revoke permissions on a topic. Revoke permissions to a role on a single topic. If the permission was not set at the topiclevel, but rather at the namespace level, this operation will return an error (HTTP status code 412).

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant Specify the tenant
• @param namespace Specify the namespace
• @param topic Specify topic name
• @param role Client role to which grant permissions

func (*PersistentTopicApiService) SkipAllMessages ¶

func (a *PersistentTopicApiService) SkipAllMessages(ctx context.Context, tenant string, namespace string, topic string, subName string, localVarOptionals *SkipAllMessagesOpts) (*http.Response, error)

func (*PersistentTopicApiService) SkipMessages ¶

func (a *PersistentTopicApiService) SkipMessages(ctx context.Context, tenant string, namespace string, topic string, subName string, numMessages int32, localVarOptionals *SkipMessagesOpts) (*http.Response, error)

func (*PersistentTopicApiService) Terminate ¶

func (a *PersistentTopicApiService) Terminate(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *TerminateOpts) (map[string]interface{}, *http.Response, error)

func (*PersistentTopicApiService) TriggerOffload ¶

func (a *PersistentTopicApiService) TriggerOffload(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *TriggerOffloadOpts) (*http.Response, error)

func (*PersistentTopicApiService) UnloadTopic ¶

func (a *PersistentTopicApiService) UnloadTopic(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *UnloadTopicOpts) (*http.Response, error)

func (*PersistentTopicApiService) UpdatePartitionedTopic ¶

func (a *PersistentTopicApiService) UpdatePartitionedTopic(ctx context.Context, tenant string, namespace string, topic string, body int32) (*http.Response, error)

PersistentTopicApiService Increment partitons of an existing partitioned topic. It only increments partitions of existing non-global partitioned-topic

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant Specify the tenant
• @param namespace Specify the namespace
• @param topic Specify topic name
• @param body The number of partitions for the topic

func (*ResourceQuotasApiService) GetDefaultResourceQuota ¶

func (a *ResourceQuotasApiService) GetDefaultResourceQuota(ctx context.Context) ([]string, *http.Response, error)

ResourceQuotasApiService Get the default quota

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []string

func (*ResourceQuotasApiService) GetNamespaceBundleResourceQuota ¶

func (a *ResourceQuotasApiService) GetNamespaceBundleResourceQuota(ctx context.Context, tenant string, namespace string, bundle string) (ResourceQuota, *http.Response, error)

ResourceQuotasApiService Get resource quota of a namespace bundle.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace
• @param bundle

@return ResourceQuota

func (*ResourceQuotasApiService) RemoveNamespaceBundleResourceQuota ¶

func (a *ResourceQuotasApiService) RemoveNamespaceBundleResourceQuota(ctx context.Context, tenant string, namespace string, bundle string) (*http.Response, error)

ResourceQuotasApiService Remove resource quota for a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace
• @param bundle

func (*ResourceQuotasApiService) SetDefaultResourceQuota ¶

func (a *ResourceQuotasApiService) SetDefaultResourceQuota(ctx context.Context) ([]string, *http.Response, error)

ResourceQuotasApiService Set the default quota

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return []string

func (*ResourceQuotasApiService) SetNamespaceBundleResourceQuota ¶

func (a *ResourceQuotasApiService) SetNamespaceBundleResourceQuota(ctx context.Context, tenant string, namespace string, bundle string) (*http.Response, error)

ResourceQuotasApiService Set resource quota on a namespace.

• @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
• @param tenant
• @param namespace
• @param bundle

func (*SchemasApiService) DeleteSchema ¶

func (a *SchemasApiService) DeleteSchema(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *DeleteSchemaOpts) (DeleteSchemaResponse, *http.Response, error)

func (*SchemasApiService) GetSchema ¶

func (a *SchemasApiService) GetSchema(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *GetSchemaOpts) (GetSchemaResponse, *http.Response, error)

func (*SchemasApiService) GetSchema_1 ¶

func (a *SchemasApiService) GetSchema_1(ctx context.Context, tenant string, namespace string, topic string, version string, localVarOptionals *GetSchema_1Opts) (GetSchemaResponse, *http.Response, error)

func (*SchemasApiService) PostSchema ¶

func (a *SchemasApiService) PostSchema(ctx context.Context, tenant string, namespace string, topic string, localVarOptionals *PostSchemaOpts) (PostSchemaResponse, *http.Response, error)