2 stable releases
| 2.1.0 | Mar 1, 2024 |
|---|---|
| 2.0.0 | Mar 1, 2024 |
#417 in Database interfaces
35 downloads per month
1.5MB
23K
SLoC
Rust API client for pulsar-admin-sdk
This provides the REST API for admin operations
Overview
This API client was generated by the OpenAPI Generator project. By using the openapi-spec from a remote server, you can easily generate an API client.
- API version: v2
- Package version: v2
- Build package:
org.openapitools.codegen.languages.RustClientCodegen
Installation
Put the package under your project folder in a directory named pulsar-admin-sdk and add the following to Cargo.toml under [dependencies]:
pulsar-admin-sdk = { path = "./pulsar-admin-sdk" }
Documentation for API Endpoints
All URIs are relative to /admin/v2
| Class | Method | HTTP request | Description |
|---|---|---|---|
| BookiesApi | bookies_delete_bookie_rack_info | DELETE /bookies/racks-info/{bookie} | Removed the rack placement information for a specific bookie in the cluster |
| BookiesApi | bookies_get_all_bookies | GET /bookies/all | Gets raw information for all the bookies in the cluster |
| BookiesApi | bookies_get_bookie_rack_info | GET /bookies/racks-info/{bookie} | Gets the rack placement information for a specific bookie in the cluster |
| BookiesApi | bookies_get_bookies_rack_info | GET /bookies/racks-info | Gets the rack placement information for all the bookies in the cluster |
| BookiesApi | bookies_update_bookie_rack_info | POST /bookies/racks-info/{bookie} | Updates the rack placement information for a specific bookie in the cluster (note. bookie address format:address:port) |
| BrokerStatsApi | broker_stats_base_get_allocator_stats | GET /broker-stats/allocator-stats/{allocator} | Get the stats for the Netty allocator. Available allocators are 'default' and 'ml-cache' |
| BrokerStatsApi | broker_stats_base_get_load_report | GET /broker-stats/load-report | Get Load for this broker |
| BrokerStatsApi | broker_stats_base_get_m_beans | GET /broker-stats/mbeans | Get all the mbean details of this broker JVM |
| BrokerStatsApi | broker_stats_base_get_metrics | GET /broker-stats/metrics | Gets the metrics for Monitoring |
| BrokerStatsApi | broker_stats_base_get_pending_bookie_ops_stats | GET /broker-stats/bookieops | Get pending bookie client op stats by namespace |
| BrokerStatsApi | broker_stats_get_broker_resource_availability | GET /broker-stats/broker-resource-availability/{tenant}/{namespace} | Broker availability report |
| BrokerStatsApi | broker_stats_get_topics2 | GET /broker-stats/topics | Get all the topic stats by namespace |
| BrokersApi | brokers_base_backlog_quota_check | GET /brokers/backlog-quota-check | An REST endpoint to trigger backlogQuotaCheck |
| BrokersApi | brokers_base_delete_dynamic_configuration | DELETE /brokers/configuration/{configName} | Delete dynamic ServiceConfiguration into metadata only. This operation requires Pulsar super-user privileges. |
| BrokersApi | brokers_base_get_active_brokers | GET /brokers | Get the list of active brokers (broker ids) in the local cluster.If authorization is not enabled |
| BrokersApi | brokers_base_get_active_brokers_0 | GET /brokers/{cluster} | Get the list of active brokers (broker ids) in the cluster.If authorization is not enabled, any cluster name is valid. |
| BrokersApi | brokers_base_get_all_dynamic_configurations | GET /brokers/configuration/values | Get value of all dynamic configurations' value overridden on local config |
| BrokersApi | brokers_base_get_dynamic_configuration_name | GET /brokers/configuration | Get all updatable dynamic configurations's name |
| BrokersApi | brokers_base_get_internal_configuration_data | GET /brokers/internal-configuration | Get the internal configuration data |
| BrokersApi | brokers_base_get_leader_broker | GET /brokers/leaderBroker | Get the information of the leader broker. |
| BrokersApi | brokers_base_get_owned_namespaces | GET /brokers/{clusterName}/{brokerId}/ownedNamespaces | Get the list of namespaces served by the specific broker id |
| BrokersApi | brokers_base_get_runtime_configuration | GET /brokers/configuration/runtime | Get all runtime configurations. This operation requires Pulsar super-user privileges. |
| BrokersApi | brokers_base_health_check | GET /brokers/health | Run a healthCheck against the broker |
| BrokersApi | brokers_base_is_ready | GET /brokers/ready | Check if the broker is fully initialized |
| BrokersApi | brokers_base_shut_down_broker_gracefully | POST /brokers/shutdown | Shutdown broker gracefully. |
| BrokersApi | brokers_base_update_dynamic_configuration | POST /brokers/configuration/{configName}/{configValue} | Update dynamic serviceconfiguration into zk only. This operation requires Pulsar super-user privileges. |
| BrokersApi | brokers_base_version | GET /brokers/version | Get version of current broker |
| ClustersApi | clusters_base_create_cluster | PUT /clusters/{cluster} | Create a new cluster. |
| ClustersApi | clusters_base_delete_cluster | DELETE /clusters/{cluster} | Delete an existing cluster. |
| ClustersApi | clusters_base_delete_failure_domain | DELETE /clusters/{cluster}/failureDomains/{domainName} | Delete the failure domain of the cluster |
| ClustersApi | clusters_base_delete_namespace_isolation_policy | DELETE /clusters/{cluster}/namespaceIsolationPolicies/{policyName} | Delete namespace isolation policy. |
| ClustersApi | clusters_base_get_broker_with_namespace_isolation_policy | GET /clusters/{cluster}/namespaceIsolationPolicies/brokers/{broker} | Get a broker with namespace-isolation policies attached to it. |
| ClustersApi | clusters_base_get_brokers_with_namespace_isolation_policy | GET /clusters/{cluster}/namespaceIsolationPolicies/brokers | Get list of brokers with namespace-isolation policies attached to them. |
| ClustersApi | clusters_base_get_cluster | GET /clusters/{cluster} | Get the configuration for the specified cluster. |
| ClustersApi | clusters_base_get_cluster_migration | GET /clusters/{cluster}/migrate | Get the cluster migration configuration for the specified cluster. |
| ClustersApi | clusters_base_get_clusters | GET /clusters | Get the list of all the Pulsar clusters. |
| ClustersApi | clusters_base_get_domain | GET /clusters/{cluster}/failureDomains/{domainName} | Get a domain in a cluster |
| ClustersApi | clusters_base_get_failure_domains | GET /clusters/{cluster}/failureDomains | Get the cluster failure domains. |
| ClustersApi | clusters_base_get_namespace_isolation_policies | GET /clusters/{cluster}/namespaceIsolationPolicies | Get the namespace isolation policies assigned to the cluster. |
| ClustersApi | clusters_base_get_namespace_isolation_policy | GET /clusters/{cluster}/namespaceIsolationPolicies/{policyName} | Get the single namespace isolation policy assigned to the cluster. |
| ClustersApi | clusters_base_get_peer_cluster | GET /clusters/{cluster}/peers | Get the peer-cluster data for the specified cluster. |
| ClustersApi | clusters_base_set_failure_domain | POST /clusters/{cluster}/failureDomains/{domainName} | Set the failure domain of the cluster. |
| ClustersApi | clusters_base_set_namespace_isolation_policy | POST /clusters/{cluster}/namespaceIsolationPolicies/{policyName} | Set namespace isolation policy. |
| ClustersApi | clusters_base_set_peer_cluster_names | POST /clusters/{cluster}/peers | Update peer-cluster-list for a cluster. |
| ClustersApi | clusters_base_update_cluster | POST /clusters/{cluster} | Update the configuration for a cluster. |
| ClustersApi | clusters_base_update_cluster_migration | POST /clusters/{cluster}/migrate | Update the configuration for a cluster migration. |
| DefaultApi | worker_drain | PUT /worker/drain | Drains this worker, i.e., moves its work-assignments to other workers |
| DefaultApi | worker_drain_at_leader | PUT /worker/leader/drain | Drains the specified worker, i.e., moves its work-assignments to other workers |
| DefaultApi | worker_get_assignments | GET /worker/assignments | Fetches information about which Pulsar Functions are assigned to which Pulsar clusters |
| DefaultApi | worker_get_cluster | GET /worker/cluster | Fetches information about the Pulsar cluster running Pulsar Functions |
| DefaultApi | worker_get_cluster_leader | GET /worker/cluster/leader | Fetches info about the leader node of the Pulsar cluster running Pulsar Functions |
| DefaultApi | worker_get_connectors_list | GET /worker/connectors | Fetches a list of supported Pulsar IO connectors currently running in cluster mode |
| DefaultApi | worker_get_drain_status | GET /worker/drain | Get the status of any ongoing drain operation at this worker |
| DefaultApi | worker_get_drain_status_from_leader | GET /worker/leader/drain | Get the status of any ongoing drain operation at the specified worker |
| DefaultApi | worker_is_leader_ready | GET /worker/cluster/leader/ready | Checks if this node is the leader and is ready to service requests |
| DefaultApi | worker_rebalance | PUT /worker/rebalance | Triggers a rebalance of functions to workers |
| DefaultApi | worker_stats_get_metrics | GET /worker-stats/metrics | Gets the metrics for Monitoring |
| DefaultApi | worker_stats_get_stats | GET /worker-stats/functionsmetrics | Get metrics for all functions owned by worker |
| NamespacesApi | namespaces_clear_namespace_backlog | POST /namespaces/{tenant}/{namespace}/clearBacklog | Clear backlog for all topics on a namespace. |
| NamespacesApi | namespaces_clear_namespace_backlog_for_subscription | POST /namespaces/{tenant}/{namespace}/clearBacklog/{subscription} | Clear backlog for a given subscription on all topics on a namespace. |
| NamespacesApi | namespaces_clear_namespace_bundle_backlog | POST /namespaces/{tenant}/{namespace}/{bundle}/clearBacklog | Clear backlog for all topics on a namespace bundle. |
| NamespacesApi | namespaces_clear_namespace_bundle_backlog_for_subscription | POST /namespaces/{tenant}/{namespace}/{bundle}/clearBacklog/{subscription} | Clear backlog for a given subscription on all topics on a namespace bundle. |
| NamespacesApi | namespaces_clear_offload_deletion_lag | DELETE /namespaces/{tenant}/{namespace}/offloadDeletionLagMs | Clear the namespace configured offload deletion lag. The topics in the namespace will fallback to using the default configured deletion lag for the broker |
| NamespacesApi | namespaces_clear_properties | DELETE /namespaces/{tenant}/{namespace}/properties | Clear properties on a given namespace. |
| NamespacesApi | namespaces_create_namespace | PUT /namespaces/{tenant}/{namespace} | Creates a new namespace with the specified policies |
| NamespacesApi | namespaces_delete_bookie_affinity_group | DELETE /namespaces/{property}/{namespace}/persistence/bookieAffinity | Delete the bookie-affinity-group from namespace-local policy. |
| NamespacesApi | namespaces_delete_compaction_threshold | DELETE /namespaces/{tenant}/{namespace}/compactionThreshold | Delete maximum number of uncompacted bytes in a topic before compaction is triggered. |
| NamespacesApi | namespaces_delete_dispatch_rate | DELETE /namespaces/{tenant}/{namespace}/dispatchRate | Delete dispatch-rate throttling for all topics of the namespace |
| NamespacesApi | namespaces_delete_namespace | DELETE /namespaces/{tenant}/{namespace} | Delete a namespace and all the topics under it. |
| NamespacesApi | namespaces_delete_namespace_bundle | DELETE /namespaces/{tenant}/{namespace}/{bundle} | Delete a namespace bundle and all the topics under it. |
| NamespacesApi | namespaces_delete_persistence | DELETE /namespaces/{tenant}/{namespace}/persistence | Delete the persistence configuration for all topics on a namespace |
| NamespacesApi | namespaces_delete_subscribe_rate | DELETE /namespaces/{tenant}/{namespace}/subscribeRate | Delete subscribe-rate throttling for all topics of the namespace |
| NamespacesApi | namespaces_delete_subscription_dispatch_rate | DELETE /namespaces/{tenant}/{namespace}/subscriptionDispatchRate | Delete Subscription dispatch-rate throttling for all topics of the namespace |
| NamespacesApi | namespaces_get_anti_affinity_namespaces | GET /namespaces/{cluster}/antiAffinity/{group} | Get all namespaces that are grouped by given anti-affinity group in a given cluster. api can be only accessed by admin of any of the existing tenant |
| NamespacesApi | namespaces_get_auto_subscription_creation | GET /namespaces/{tenant}/{namespace}/autoSubscriptionCreation | Get autoSubscriptionCreation info in a namespace |
| NamespacesApi | namespaces_get_auto_topic_creation | GET /namespaces/{tenant}/{namespace}/autoTopicCreation | Get autoTopicCreation info in a namespace |
| NamespacesApi | namespaces_get_backlog_quota_map | GET /namespaces/{tenant}/{namespace}/backlogQuotaMap | Get backlog quota map on a namespace. |
| NamespacesApi | namespaces_get_bookie_affinity_group | GET /namespaces/{property}/{namespace}/persistence/bookieAffinity | Get the bookie-affinity-group from namespace-local policy. |
| NamespacesApi | namespaces_get_bundles_data | GET /namespaces/{tenant}/{namespace}/bundles | Get the bundles split data. |
| NamespacesApi | namespaces_get_compaction_threshold | GET /namespaces/{tenant}/{namespace}/compactionThreshold | Maximum number of uncompacted bytes in topics before compaction is triggered. |
| NamespacesApi | namespaces_get_deduplication | GET /namespaces/{tenant}/{namespace}/deduplication | Get broker side deduplication for all topics in a namespace |
| NamespacesApi | namespaces_get_deduplication_snapshot_interval | GET /namespaces/{tenant}/{namespace}/deduplicationSnapshotInterval | Get deduplicationSnapshotInterval config on a namespace. |
| NamespacesApi | namespaces_get_delayed_delivery_policies | GET /namespaces/{tenant}/{namespace}/delayedDelivery | Get delayed delivery messages config on a namespace. |
| NamespacesApi | namespaces_get_dispatch_rate | GET /namespaces/{tenant}/{namespace}/dispatchRate | Get dispatch-rate configured for the namespace, null means dispatch-rate not configured, -1 means msg-dispatch-rate or byte-dispatch-rate not configured in dispatch-rate yet |
| NamespacesApi | namespaces_get_dispatcher_pause_on_ack_state_persistent | GET /namespaces/{tenant}/{namespace}/dispatcherPauseOnAckStatePersistent | Get dispatcher pause on ack state persistent config on a namespace. |
| NamespacesApi | namespaces_get_encryption_required | GET /namespaces/{tenant}/{namespace}/encryptionRequired | Get message encryption required status in a namespace |
| NamespacesApi | namespaces_get_entry_filters_per_topic | GET /namespaces/{tenant}/{namespace}/entryFilters | Get maxConsumersPerSubscription config on a namespace. |
| NamespacesApi | namespaces_get_inactive_topic_policies | GET /namespaces/{tenant}/{namespace}/inactiveTopicPolicies | Get inactive topic policies config on a namespace. |
| NamespacesApi | namespaces_get_is_allow_auto_update_schema | GET /namespaces/{tenant}/{namespace}/isAllowAutoUpdateSchema | The flag of whether allow auto update schema |
| NamespacesApi | namespaces_get_max_consumers_per_subscription | GET /namespaces/{tenant}/{namespace}/maxConsumersPerSubscription | Get maxConsumersPerSubscription config on a namespace. |
| NamespacesApi | namespaces_get_max_consumers_per_topic | GET /namespaces/{tenant}/{namespace}/maxConsumersPerTopic | Get maxConsumersPerTopic config on a namespace. |
| NamespacesApi | namespaces_get_max_producers_per_topic | GET /namespaces/{tenant}/{namespace}/maxProducersPerTopic | Get maxProducersPerTopic config on a namespace. |
| NamespacesApi | namespaces_get_max_subscriptions_per_topic | GET /namespaces/{tenant}/{namespace}/maxSubscriptionsPerTopic | Get maxSubscriptionsPerTopic config on a namespace. |
| NamespacesApi | namespaces_get_max_topics_per_namespace | GET /namespaces/{tenant}/{namespace}/maxTopicsPerNamespace | Get maxTopicsPerNamespace config on a namespace. |
| NamespacesApi | namespaces_get_max_unacked_messages_per_consumer | GET /namespaces/{tenant}/{namespace}/maxUnackedMessagesPerConsumer | Get maxUnackedMessagesPerConsumer config on a namespace. |
| NamespacesApi | namespaces_get_max_unackedmessages_per_subscription | GET /namespaces/{tenant}/{namespace}/maxUnackedMessagesPerSubscription | Get maxUnackedMessagesPerSubscription config on a namespace. |
| NamespacesApi | namespaces_get_namespace_anti_affinity_group | GET /namespaces/{tenant}/{namespace}/antiAffinity | Get anti-affinity group of a namespace. |
| NamespacesApi | namespaces_get_namespace_message_ttl | GET /namespaces/{tenant}/{namespace}/messageTTL | Get the message TTL for the namespace |
| NamespacesApi | namespaces_get_namespace_replication_clusters | GET /namespaces/{tenant}/{namespace}/replication | Get the replication clusters for a namespace. |
| NamespacesApi | namespaces_get_namespace_resource_group | GET /namespaces/{tenant}/{namespace}/resourcegroup | Get the resource group attached to the namespace |
| NamespacesApi | namespaces_get_offload_deletion_lag | GET /namespaces/{tenant}/{namespace}/offloadDeletionLagMs | Number of milliseconds to wait before deleting a ledger segment which has been offloaded from the Pulsar cluster's local storage (i.e. BookKeeper) |
| NamespacesApi | namespaces_get_offload_policies | GET /namespaces/{tenant}/{namespace}/offloadPolicies | Get offload configuration on a namespace. |
| NamespacesApi | namespaces_get_offload_threshold | GET /namespaces/{tenant}/{namespace}/offloadThreshold | Maximum number of bytes stored on the pulsar cluster for a topic, before the broker will start offloading to longterm storage |
| NamespacesApi | namespaces_get_offload_threshold_in_seconds | GET /namespaces/{tenant}/{namespace}/offloadThresholdInSeconds | Maximum number of bytes stored on the pulsar cluster for a topic, before the broker will start offloading to longterm storage |
| NamespacesApi | namespaces_get_permission_on_subscription | GET /namespaces/{tenant}/{namespace}/permissions/subscription | Retrieve the permissions for a subscription. |
| NamespacesApi | namespaces_get_permissions | GET /namespaces/{tenant}/{namespace}/permissions | Retrieve the permissions for a namespace. |
| NamespacesApi | namespaces_get_persistence | GET /namespaces/{tenant}/{namespace}/persistence | Get the persistence configuration for a namespace. |
| NamespacesApi | namespaces_get_policies | GET /namespaces/{tenant}/{namespace} | Get the dump all the policies specified for a namespace. |
| NamespacesApi | namespaces_get_properties | GET /namespaces/{tenant}/{namespace}/properties | Get key value pair properties for a given namespace. |
| NamespacesApi | namespaces_get_property | GET /namespaces/{tenant}/{namespace}/property/{key} | Get property value for a given key on a namespace. |
| NamespacesApi | namespaces_get_replicator_dispatch_rate | GET /namespaces/{tenant}/{namespace}/replicatorDispatchRate | Get replicator dispatch-rate configured for the namespace, null means replicator dispatch-rate not configured, -1 means msg-dispatch-rate or byte-dispatch-rate not configured in dispatch-rate yet |
| NamespacesApi | namespaces_get_retention | GET /namespaces/{tenant}/{namespace}/retention | Get retention config on a namespace. |
| NamespacesApi | namespaces_get_schema_auto_update_compatibility_strategy | GET /namespaces/{tenant}/{namespace}/schemaAutoUpdateCompatibilityStrategy | The strategy used to check the compatibility of new schemas, provided by producers, before automatically updating the schema |
| NamespacesApi | namespaces_get_schema_compatibility_strategy | GET /namespaces/{tenant}/{namespace}/schemaCompatibilityStrategy | The strategy of the namespace schema compatibility |
| NamespacesApi | namespaces_get_schema_validtion_enforced | GET /namespaces/{tenant}/{namespace}/schemaValidationEnforced | Get schema validation enforced flag for namespace. |
| NamespacesApi | namespaces_get_subscribe_rate | GET /namespaces/{tenant}/{namespace}/subscribeRate | Get subscribe-rate configured for the namespace |
| NamespacesApi | namespaces_get_subscription_auth_mode | GET /namespaces/{tenant}/{namespace}/subscriptionAuthMode | Get subscription auth mode in a namespace |
| NamespacesApi | namespaces_get_subscription_dispatch_rate | GET /namespaces/{tenant}/{namespace}/subscriptionDispatchRate | Get subscription dispatch-rate configured for the namespace, null means subscription dispatch-rate not configured, -1 means msg-dispatch-rate or byte-dispatch-rate not configured in dispatch-rate yet |
| NamespacesApi | namespaces_get_subscription_expiration_time | GET /namespaces/{tenant}/{namespace}/subscriptionExpirationTime | Get the subscription expiration time for the namespace |
| NamespacesApi | namespaces_get_subscription_types_enabled | GET /namespaces/{tenant}/{namespace}/subscriptionTypesEnabled | The set of whether allow subscription types |
| NamespacesApi | namespaces_get_tenant_namespaces | GET /namespaces/{tenant} | Get the list of all the namespaces for a certain tenant. |
| NamespacesApi | namespaces_get_topic_hash_positions | GET /namespaces/{tenant}/{namespace}/{bundle}/topicHashPositions | Get hash positions for topics |
| NamespacesApi | namespaces_get_topics | GET /namespaces/{tenant}/{namespace}/topics | Get the list of all the topics under a certain namespace. |
| NamespacesApi | namespaces_grant_permission_on_namespace | POST /namespaces/{tenant}/{namespace}/permissions/{role} | Grant a new permission to a role on a namespace. |
| NamespacesApi | namespaces_modify_deduplication | POST /namespaces/{tenant}/{namespace}/deduplication | Enable or disable broker side deduplication for all topics in a namespace |
| NamespacesApi | namespaces_modify_encryption_required | POST /namespaces/{tenant}/{namespace}/encryptionRequired | Message encryption is required or not for all topics in a namespace |
| NamespacesApi | namespaces_remove_auto_subscription_creation | DELETE /namespaces/{tenant}/{namespace}/autoSubscriptionCreation | Remove override of broker's allowAutoSubscriptionCreation in a namespace |
| NamespacesApi | namespaces_remove_auto_topic_creation | DELETE /namespaces/{tenant}/{namespace}/autoTopicCreation | Remove override of broker's allowAutoTopicCreation in a namespace |
| NamespacesApi | namespaces_remove_backlog_quota | DELETE /namespaces/{tenant}/{namespace}/backlogQuota | Remove a backlog quota policy from a namespace. |
| NamespacesApi | namespaces_remove_deduplication | DELETE /namespaces/{tenant}/{namespace}/deduplication | Remove broker side deduplication for all topics in a namespace |
| NamespacesApi | namespaces_remove_delayed_delivery_policies | DELETE /namespaces/{tenant}/{namespace}/delayedDelivery | Delete delayed delivery messages config on a namespace. |
| NamespacesApi | namespaces_remove_dispatcher_pause_on_ack_state_persistent | DELETE /namespaces/{tenant}/{namespace}/dispatcherPauseOnAckStatePersistent | Remove dispatcher pause on ack state persistent configuration for specified namespace. |
| NamespacesApi | namespaces_remove_inactive_topic_policies | DELETE /namespaces/{tenant}/{namespace}/inactiveTopicPolicies | Remove inactive topic policies from a namespace. |
| NamespacesApi | namespaces_remove_max_consumers_per_subscription | DELETE /namespaces/{tenant}/{namespace}/maxConsumersPerSubscription | Set maxConsumersPerSubscription configuration on a namespace. |
| NamespacesApi | namespaces_remove_max_consumers_per_topic | DELETE /namespaces/{tenant}/{namespace}/maxConsumersPerTopic | Remove maxConsumersPerTopic configuration on a namespace. |
| NamespacesApi | namespaces_remove_max_producers_per_topic | DELETE /namespaces/{tenant}/{namespace}/maxProducersPerTopic | Remove maxProducersPerTopic configuration on a namespace. |
| NamespacesApi | namespaces_remove_max_subscriptions_per_topic | DELETE /namespaces/{tenant}/{namespace}/maxSubscriptionsPerTopic | Remove maxSubscriptionsPerTopic configuration on a namespace. |
| NamespacesApi | namespaces_remove_max_topics_per_namespace | DELETE /namespaces/{tenant}/{namespace}/maxTopicsPerNamespace | Remove maxTopicsPerNamespace config on a namespace. |
| NamespacesApi | namespaces_remove_max_unackedmessages_per_consumer | DELETE /namespaces/{tenant}/{namespace}/maxUnackedMessagesPerConsumer | Remove maxUnackedMessagesPerConsumer config on a namespace. |
| NamespacesApi | namespaces_remove_max_unackedmessages_per_subscription | DELETE /namespaces/{tenant}/{namespace}/maxUnackedMessagesPerSubscription | Remove maxUnackedMessagesPerSubscription config on a namespace. |
| NamespacesApi | namespaces_remove_namespace_anti_affinity_group | DELETE /namespaces/{tenant}/{namespace}/antiAffinity | Remove anti-affinity group of a namespace. |
| NamespacesApi | namespaces_remove_namespace_entry_filters | DELETE /namespaces/{tenant}/{namespace}/entryFilters | Remove entry filters for namespace |
| NamespacesApi | namespaces_remove_namespace_message_ttl | DELETE /namespaces/{tenant}/{namespace}/messageTTL | Remove message TTL in seconds for namespace |
| NamespacesApi | namespaces_remove_namespace_resource_group | DELETE /namespaces/{tenant}/{namespace}/resourcegroup | Delete resourcegroup for a namespace |
| NamespacesApi | namespaces_remove_offload_policies | DELETE /namespaces/{tenant}/{namespace}/removeOffloadPolicies | Set offload configuration on a namespace. |
| NamespacesApi | namespaces_remove_property | DELETE /namespaces/{tenant}/{namespace}/property/{key} | Remove property value for a given key on a namespace. |
| NamespacesApi | namespaces_remove_replicator_dispatch_rate | DELETE /namespaces/{tenant}/{namespace}/replicatorDispatchRate | Remove replicator dispatch-rate throttling for all topics of the namespace |
| NamespacesApi | namespaces_remove_retention | DELETE /namespaces/{tenant}/{namespace}/retention | Remove retention configuration on a namespace. |
| NamespacesApi | namespaces_remove_subscription_expiration_time | DELETE /namespaces/{tenant}/{namespace}/subscriptionExpirationTime | Remove subscription expiration time for namespace |
| NamespacesApi | namespaces_remove_subscription_types_enabled | DELETE /namespaces/{tenant}/{namespace}/subscriptionTypesEnabled | Remove subscription types enabled on a namespace. |
| NamespacesApi | namespaces_revoke_permissions_on_namespace | DELETE /namespaces/{tenant}/{namespace}/permissions/{role} | Revoke all permissions to a role on a namespace. |
| NamespacesApi | namespaces_scan_offloaded_ledgers | GET /namespaces/{tenant}/{namespace}/scanOffloadedLedgers | Trigger the scan of offloaded Ledgers on the LedgerOffloader for the given namespace |
| NamespacesApi | namespaces_set_auto_subscription_creation | POST /namespaces/{tenant}/{namespace}/autoSubscriptionCreation | Override broker's allowAutoSubscriptionCreation setting for a namespace |
| NamespacesApi | namespaces_set_auto_topic_creation | POST /namespaces/{tenant}/{namespace}/autoTopicCreation | Override broker's allowAutoTopicCreation setting for a namespace |
| NamespacesApi | namespaces_set_backlog_quota | POST /namespaces/{tenant}/{namespace}/backlogQuota | Set a backlog quota for all the topics on a namespace. |
| NamespacesApi | namespaces_set_bookie_affinity_group | POST /namespaces/{tenant}/{namespace}/persistence/bookieAffinity | Set the bookie-affinity-group to namespace-persistent policy. |
| NamespacesApi | namespaces_set_compaction_threshold | PUT /namespaces/{tenant}/{namespace}/compactionThreshold | Set maximum number of uncompacted bytes in a topic before compaction is triggered. |
| NamespacesApi | namespaces_set_deduplication_snapshot_interval | POST /namespaces/{tenant}/{namespace}/deduplicationSnapshotInterval | Set deduplicationSnapshotInterval config on a namespace. |
| NamespacesApi | namespaces_set_delayed_delivery_policies | POST /namespaces/{tenant}/{namespace}/delayedDelivery | Set delayed delivery messages config on a namespace. |
| NamespacesApi | namespaces_set_dispatch_rate | POST /namespaces/{tenant}/{namespace}/dispatchRate | Set dispatch-rate throttling for all topics of the namespace |
| NamespacesApi | namespaces_set_dispatcher_pause_on_ack_state_persistent | POST /namespaces/{tenant}/{namespace}/dispatcherPauseOnAckStatePersistent | Set dispatcher pause on ack state persistent configuration for specified namespace. |
| NamespacesApi | namespaces_set_entry_filters_per_topic | POST /namespaces/{tenant}/{namespace}/entryFilters | Set entry filters for namespace |
| NamespacesApi | namespaces_set_inactive_topic_policies | POST /namespaces/{tenant}/{namespace}/inactiveTopicPolicies | Set inactive topic policies config on a namespace. |
| NamespacesApi | namespaces_set_is_allow_auto_update_schema | POST /namespaces/{tenant}/{namespace}/isAllowAutoUpdateSchema | Update flag of whether allow auto update schema |
| NamespacesApi | namespaces_set_max_consumers_per_subscription | POST /namespaces/{tenant}/{namespace}/maxConsumersPerSubscription | Set maxConsumersPerSubscription configuration on a namespace. |
| NamespacesApi | namespaces_set_max_consumers_per_topic | POST /namespaces/{tenant}/{namespace}/maxConsumersPerTopic | Set maxConsumersPerTopic configuration on a namespace. |
| NamespacesApi | namespaces_set_max_producers_per_topic | POST /namespaces/{tenant}/{namespace}/maxProducersPerTopic | Set maxProducersPerTopic configuration on a namespace. |
| NamespacesApi | namespaces_set_max_subscriptions_per_topic | POST /namespaces/{tenant}/{namespace}/maxSubscriptionsPerTopic | Set maxSubscriptionsPerTopic configuration on a namespace. |
| NamespacesApi | namespaces_set_max_topics_per_namespace | POST /namespaces/{tenant}/{namespace}/maxTopicsPerNamespace | Set maxTopicsPerNamespace config on a namespace. |
| NamespacesApi | namespaces_set_max_unacked_messages_per_consumer | POST /namespaces/{tenant}/{namespace}/maxUnackedMessagesPerConsumer | Set maxConsumersPerTopic configuration on a namespace. |
| NamespacesApi | namespaces_set_max_unacked_messages_per_subscription | POST /namespaces/{tenant}/{namespace}/maxUnackedMessagesPerSubscription | Set maxUnackedMessagesPerSubscription configuration on a namespace. |
| NamespacesApi | namespaces_set_namespace_anti_affinity_group | POST /namespaces/{tenant}/{namespace}/antiAffinity | Set anti-affinity group for a namespace |
| NamespacesApi | namespaces_set_namespace_message_ttl | POST /namespaces/{tenant}/{namespace}/messageTTL | Set message TTL in seconds for namespace |
| NamespacesApi | namespaces_set_namespace_replication_clusters | POST /namespaces/{tenant}/{namespace}/replication | Set the replication clusters for a namespace. |
| NamespacesApi | namespaces_set_namespace_resource_group | POST /namespaces/{tenant}/{namespace}/resourcegroup/{resourcegroup} | Set resourcegroup for a namespace |
| NamespacesApi | namespaces_set_offload_deletion_lag | PUT /namespaces/{tenant}/{namespace}/offloadDeletionLagMs | 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) |
| NamespacesApi | namespaces_set_offload_policies | POST /namespaces/{tenant}/{namespace}/offloadPolicies | Set offload configuration on a namespace. |
| NamespacesApi | namespaces_set_offload_threshold | PUT /namespaces/{tenant}/{namespace}/offloadThreshold | Set maximum number of bytes stored on the pulsar cluster for a topic, before the broker will start offloading to longterm storage |
| NamespacesApi | namespaces_set_offload_threshold_in_seconds | PUT /namespaces/{tenant}/{namespace}/offloadThresholdInSeconds | Set maximum number of seconds stored on the pulsar cluster for a topic, before the broker will start offloading to longterm storage |
| NamespacesApi | namespaces_set_persistence | POST /namespaces/{tenant}/{namespace}/persistence | Set the persistence configuration for all the topics on a namespace. |
| NamespacesApi | namespaces_set_properties | PUT /namespaces/{tenant}/{namespace}/properties | Put key value pairs property on a namespace. |
| NamespacesApi | namespaces_set_property | PUT /namespaces/{tenant}/{namespace}/property/{key}/{value} | Put a key value pair property on a namespace. |
| NamespacesApi | namespaces_set_replicator_dispatch_rate | POST /namespaces/{tenant}/{namespace}/replicatorDispatchRate | Set replicator dispatch-rate throttling for all topics of the namespace |
| NamespacesApi | namespaces_set_retention | POST /namespaces/{tenant}/{namespace}/retention | Set retention configuration on a namespace. |
| NamespacesApi | namespaces_set_schema_auto_update_compatibility_strategy | PUT /namespaces/{tenant}/{namespace}/schemaAutoUpdateCompatibilityStrategy | Update the strategy used to check the compatibility of new schemas, provided by producers, before automatically updating the schema |
| NamespacesApi | namespaces_set_schema_compatibility_strategy | PUT /namespaces/{tenant}/{namespace}/schemaCompatibilityStrategy | Update the strategy used to check the compatibility of new schema |
| NamespacesApi | namespaces_set_schema_validation_enforced | POST /namespaces/{tenant}/{namespace}/schemaValidationEnforced | Set schema validation enforced flag on namespace. |
| NamespacesApi | namespaces_set_subscribe_rate | POST /namespaces/{tenant}/{namespace}/subscribeRate | Set subscribe-rate throttling for all topics of the namespace |
| NamespacesApi | namespaces_set_subscription_auth_mode | POST /namespaces/{tenant}/{namespace}/subscriptionAuthMode | Set a subscription auth mode for all the topics on a namespace. |
| NamespacesApi | namespaces_set_subscription_dispatch_rate | POST /namespaces/{tenant}/{namespace}/subscriptionDispatchRate | Set Subscription dispatch-rate throttling for all topics of the namespace |
| NamespacesApi | namespaces_set_subscription_expiration_time | POST /namespaces/{tenant}/{namespace}/subscriptionExpirationTime | Set subscription expiration time in minutes for namespace |
| NamespacesApi | namespaces_set_subscription_types_enabled | POST /namespaces/{tenant}/{namespace}/subscriptionTypesEnabled | Update set of whether allow share sub type |
| NamespacesApi | namespaces_split_namespace_bundle | PUT /namespaces/{tenant}/{namespace}/{bundle}/split | Split a namespace bundle |
| NamespacesApi | namespaces_unload_namespace | PUT /namespaces/{tenant}/{namespace}/unload | Unload namespace |
| NamespacesApi | namespaces_unload_namespace_bundle | PUT /namespaces/{tenant}/{namespace}/{bundle}/unload | Unload a namespace bundle |
| NamespacesApi | namespaces_unsubscribe_namespace | POST /namespaces/{tenant}/{namespace}/unsubscribe/{subscription} | Unsubscribes the given subscription on all topics on a namespace. |
| NamespacesApi | namespaces_unsubscribe_namespace_bundle | POST /namespaces/{tenant}/{namespace}/{bundle}/unsubscribe/{subscription} | Unsubscribes the given subscription on all topics on a namespace bundle. |
| NonPersistentTopicApi | non_persistent_topics_create_partitioned_topic | PUT /non-persistent/{tenant}/{namespace}/{topic}/partitions | Create a partitioned topic. |
| NonPersistentTopicApi | non_persistent_topics_get_entry_filters | GET /non-persistent/{tenant}/{namespace}/{topic}/entryFilters | Get entry filters for a topic. |
| NonPersistentTopicApi | non_persistent_topics_get_internal_stats | GET /non-persistent/{tenant}/{namespace}/{topic}/internalStats | Get the internal stats for the topic. |
| NonPersistentTopicApi | non_persistent_topics_get_list | GET /non-persistent/{tenant}/{namespace} | Get the list of non-persistent topics under a namespace. |
| NonPersistentTopicApi | non_persistent_topics_get_list_from_bundle | GET /non-persistent/{tenant}/{namespace}/{bundle} | Get the list of non-persistent topics under a namespace bundle. |
| NonPersistentTopicApi | non_persistent_topics_get_partitioned_metadata | GET /non-persistent/{tenant}/{namespace}/{topic}/partitions | Get partitioned topic metadata. |
| NonPersistentTopicApi | non_persistent_topics_get_partitioned_stats | GET /non-persistent/{tenant}/{namespace}/{topic}/partitioned-stats | Get the stats for the partitioned topic. |
| NonPersistentTopicApi | non_persistent_topics_remove_entry_filters | DELETE /non-persistent/{tenant}/{namespace}/{topic}/entryFilters | Remove entry filters for specified topic. |
| NonPersistentTopicApi | non_persistent_topics_set_entry_filters | POST /non-persistent/{tenant}/{namespace}/{topic}/entryFilters | Set entry filters for specified topic |
| NonPersistentTopicApi | non_persistent_topics_truncate_topic | DELETE /non-persistent/{tenant}/{namespace}/{topic}/truncate | Truncate a topic. |
| NonPersistentTopicApi | non_persistent_topics_unload_topic | PUT /non-persistent/{tenant}/{namespace}/{topic}/unload | Unload a topic |
| NonPersistentTopicApi | persistent_topics_analyze_subscription_backlog | POST /non-persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/analyzeBacklog | Analyse a subscription, by scanning all the unprocessed messages |
| NonPersistentTopicApi | persistent_topics_compact | PUT /non-persistent/{tenant}/{namespace}/{topic}/compaction | Trigger a compaction operation on a topic. |
| NonPersistentTopicApi | persistent_topics_compaction_status | GET /non-persistent/{tenant}/{namespace}/{topic}/compaction | Get the status of a compaction operation for a topic. |
| NonPersistentTopicApi | persistent_topics_create_missed_partitions | POST /non-persistent/{tenant}/{namespace}/{topic}/createMissedPartitions | Create missed partitions of an existing partitioned topic. |
| NonPersistentTopicApi | persistent_topics_create_non_partitioned_topic | PUT /non-persistent/{tenant}/{namespace}/{topic} | Create a non-partitioned topic. |
| NonPersistentTopicApi | persistent_topics_create_subscription | PUT /non-persistent/{tenant}/{namespace}/{topic}/subscription/{subscriptionName} | Create a subscription on the topic. |
| NonPersistentTopicApi | persistent_topics_delete_deduplication_snapshot_interval | DELETE /non-persistent/{tenant}/{namespace}/{topic}/deduplicationSnapshotInterval | Delete deduplicationSnapshotInterval config on a topic. |
| NonPersistentTopicApi | persistent_topics_delete_delayed_delivery_policies | DELETE /non-persistent/{tenant}/{namespace}/{topic}/delayedDelivery | Set delayed delivery messages config on a topic. |
| NonPersistentTopicApi | persistent_topics_delete_inactive_topic_policies | DELETE /non-persistent/{tenant}/{namespace}/{topic}/inactiveTopicPolicies | Delete inactive topic policies on a topic. |
| NonPersistentTopicApi | persistent_topics_delete_max_unacked_messages_on_consumer | DELETE /non-persistent/{tenant}/{namespace}/{topic}/maxUnackedMessagesOnConsumer | Delete max unacked messages per consumer config on a topic. |
| NonPersistentTopicApi | persistent_topics_delete_max_unacked_messages_on_subscription | DELETE /non-persistent/{tenant}/{namespace}/{topic}/maxUnackedMessagesOnSubscription | Delete max unacked messages per subscription config on a topic. |
| NonPersistentTopicApi | persistent_topics_delete_partitioned_topic | DELETE /non-persistent/{tenant}/{namespace}/{topic}/partitions | Delete a partitioned topic. |
| NonPersistentTopicApi | persistent_topics_delete_shadow_topics | DELETE /non-persistent/{tenant}/{namespace}/{topic}/shadowTopics | Delete shadow topics for a topic |
| NonPersistentTopicApi | persistent_topics_delete_subscription | DELETE /non-persistent/{tenant}/{namespace}/{topic}/subscription/{subName} | Delete a subscription. |
| NonPersistentTopicApi | persistent_topics_delete_topic | DELETE /non-persistent/{tenant}/{namespace}/{topic} | Delete a topic. |
| NonPersistentTopicApi | persistent_topics_examine_message | GET /non-persistent/{tenant}/{namespace}/{topic}/examinemessage | Examine a specific message on a topic by position relative to the earliest or the latest message. |
| NonPersistentTopicApi | persistent_topics_expire_messages_for_all_subscriptions | POST /non-persistent/{tenant}/{namespace}/{topic}/all_subscription/expireMessages/{expireTimeInSeconds} | Expiry messages on all subscriptions of topic. |
| NonPersistentTopicApi | persistent_topics_expire_topic_messages | POST /non-persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/expireMessages | Expiry messages on a topic subscription. |
| NonPersistentTopicApi | persistent_topics_expire_topic_messages_0 | POST /non-persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/expireMessages/{expireTimeInSeconds} | Expiry messages on a topic subscription. |
| NonPersistentTopicApi | persistent_topics_get_auto_subscription_creation | GET /non-persistent/{tenant}/{namespace}/{topic}/autoSubscriptionCreation | Get autoSubscriptionCreation info in a topic |
| NonPersistentTopicApi | persistent_topics_get_backlog | GET /non-persistent/{tenant}/{namespace}/{topic}/backlog | Get estimated backlog for offline topic. |
| NonPersistentTopicApi | persistent_topics_get_backlog_quota_map | GET /non-persistent/{tenant}/{namespace}/{topic}/backlogQuotaMap | Get backlog quota map on a topic. |
| NonPersistentTopicApi | persistent_topics_get_backlog_size_by_message_id | PUT /non-persistent/{tenant}/{namespace}/{topic}/backlogSize | Calculate backlog size by a message ID (in bytes). |
| NonPersistentTopicApi | persistent_topics_get_compaction_threshold | GET /non-persistent/{tenant}/{namespace}/{topic}/compactionThreshold | Get compaction threshold configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_get_deduplication | GET /non-persistent/{tenant}/{namespace}/{topic}/deduplicationEnabled | Get deduplication configuration of a topic. |
| NonPersistentTopicApi | persistent_topics_get_deduplication_snapshot_interval | GET /non-persistent/{tenant}/{namespace}/{topic}/deduplicationSnapshotInterval | Get deduplicationSnapshotInterval config on a topic. |
| NonPersistentTopicApi | persistent_topics_get_delayed_delivery_policies | GET /non-persistent/{tenant}/{namespace}/{topic}/delayedDelivery | Get delayed delivery messages config on a topic. |
| NonPersistentTopicApi | persistent_topics_get_dispatch_rate | GET /non-persistent/{tenant}/{namespace}/{topic}/dispatchRate | Get dispatch rate configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_get_dispatcher_pause_on_ack_state_persistent | GET /non-persistent/{tenant}/{namespace}/{topic}/dispatcherPauseOnAckStatePersistent | Get dispatcher pause on ack state persistent config on a topic. |
| NonPersistentTopicApi | persistent_topics_get_inactive_topic_policies | GET /non-persistent/{tenant}/{namespace}/{topic}/inactiveTopicPolicies | Get inactive topic policies on a topic. |
| NonPersistentTopicApi | persistent_topics_get_last_message_id | GET /non-persistent/{tenant}/{namespace}/{topic}/lastMessageId | Return the last commit message id of topic |
| NonPersistentTopicApi | persistent_topics_get_managed_ledger_info | GET /non-persistent/{tenant}/{namespace}/{topic}/internal-info | Get the stored topic metadata. |
| NonPersistentTopicApi | persistent_topics_get_max_consumers | GET /non-persistent/{tenant}/{namespace}/{topic}/maxConsumers | Get maxConsumers config for specified topic. |
| NonPersistentTopicApi | persistent_topics_get_max_consumers_per_subscription | GET /non-persistent/{tenant}/{namespace}/{topic}/maxConsumersPerSubscription | Get max consumers per subscription configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_get_max_message_size | GET /non-persistent/{tenant}/{namespace}/{topic}/maxMessageSize | Get maxMessageSize config for specified topic. |
| NonPersistentTopicApi | persistent_topics_get_max_producers | GET /non-persistent/{tenant}/{namespace}/{topic}/maxProducers | Get maxProducers config for specified topic. |
| NonPersistentTopicApi | persistent_topics_get_max_subscriptions_per_topic | GET /non-persistent/{tenant}/{namespace}/{topic}/maxSubscriptionsPerTopic | Get maxSubscriptionsPerTopic config for specified topic. |
| NonPersistentTopicApi | persistent_topics_get_max_unacked_messages_on_consumer | GET /non-persistent/{tenant}/{namespace}/{topic}/maxUnackedMessagesOnConsumer | Get max unacked messages per consumer config on a topic. |
| NonPersistentTopicApi | persistent_topics_get_max_unacked_messages_on_subscription | GET /non-persistent/{tenant}/{namespace}/{topic}/maxUnackedMessagesOnSubscription | Get max unacked messages per subscription config on a topic. |
| NonPersistentTopicApi | persistent_topics_get_message_by_id | GET /non-persistent/{tenant}/{namespace}/{topic}/ledger/{ledgerId}/entry/{entryId} | Get message by its messageId. |
| NonPersistentTopicApi | persistent_topics_get_message_id_by_timestamp | GET /non-persistent/{tenant}/{namespace}/{topic}/messageid/{timestamp} | Get message ID published at or just after this absolute timestamp (in ms). |
| NonPersistentTopicApi | persistent_topics_get_message_ttl | GET /non-persistent/{tenant}/{namespace}/{topic}/messageTTL | Get message TTL in seconds for a topic |
| NonPersistentTopicApi | persistent_topics_get_offload_policies | GET /non-persistent/{tenant}/{namespace}/{topic}/offloadPolicies | Get offload policies on a topic. |
| NonPersistentTopicApi | persistent_topics_get_partitioned_stats_internal | GET /non-persistent/{tenant}/{namespace}/{topic}/partitioned-internalStats | Get the stats-internal for the partitioned topic. |
| NonPersistentTopicApi | persistent_topics_get_partitioned_topic_list | GET /non-persistent/{tenant}/{namespace}/partitioned | Get the list of partitioned topics under a namespace. |
| NonPersistentTopicApi | persistent_topics_get_permissions_on_topic | GET /non-persistent/{tenant}/{namespace}/{topic}/permissions | Get permissions on a topic. |
| NonPersistentTopicApi | persistent_topics_get_persistence | GET /non-persistent/{tenant}/{namespace}/{topic}/persistence | Get configuration of persistence policies for specified topic. |
| NonPersistentTopicApi | persistent_topics_get_properties | GET /non-persistent/{tenant}/{namespace}/{topic}/properties | Get topic properties. |
| NonPersistentTopicApi | persistent_topics_get_publish_rate | GET /non-persistent/{tenant}/{namespace}/{topic}/publishRate | Get publish rate configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_get_replicated_subscription_status | GET /non-persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/replicatedSubscriptionStatus | Get replicated subscription status on a topic. |
| NonPersistentTopicApi | persistent_topics_get_replication_clusters | GET /non-persistent/{tenant}/{namespace}/{topic}/replication | Get the replication clusters for a topic |
| NonPersistentTopicApi | persistent_topics_get_replicator_dispatch_rate | GET /non-persistent/{tenant}/{namespace}/{topic}/replicatorDispatchRate | Get replicatorDispatchRate config for specified topic. |
| NonPersistentTopicApi | persistent_topics_get_retention | GET /non-persistent/{tenant}/{namespace}/{topic}/retention | Get retention configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_get_schema_compatibility_strategy | GET /non-persistent/{tenant}/{namespace}/{topic}/schemaCompatibilityStrategy | Get schema compatibility strategy on a topic |
| NonPersistentTopicApi | persistent_topics_get_schema_validation_enforced | GET /non-persistent/{tenant}/{namespace}/{topic}/schemaValidationEnforced | Get schema validation enforced flag for topic. |
| NonPersistentTopicApi | persistent_topics_get_shadow_topics | GET /non-persistent/{tenant}/{namespace}/{topic}/shadowTopics | Get the shadow topic list for a topic |
| NonPersistentTopicApi | persistent_topics_get_stats | GET /non-persistent/{tenant}/{namespace}/{topic}/stats | Get the stats for the topic. |
| NonPersistentTopicApi | persistent_topics_get_subscribe_rate | GET /non-persistent/{tenant}/{namespace}/{topic}/subscribeRate | Get subscribe rate configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_get_subscription_dispatch_rate | GET /non-persistent/{tenant}/{namespace}/{topic}/subscriptionDispatchRate | Get subscription message dispatch rate configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_get_subscription_level_dispatch_rate | GET /non-persistent/{tenant}/{namespace}/{topic}/{subName}/dispatchRate | Get message dispatch rate configuration for specified subscription. |
| NonPersistentTopicApi | persistent_topics_get_subscription_properties | GET /non-persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/properties | Return all the properties on the given subscription |
| NonPersistentTopicApi | persistent_topics_get_subscription_types_enabled | GET /non-persistent/{tenant}/{namespace}/{topic}/subscriptionTypesEnabled | Get is enable sub type fors specified topic. |
| NonPersistentTopicApi | persistent_topics_get_subscriptions | GET /non-persistent/{tenant}/{namespace}/{topic}/subscriptions | Get the list of persistent subscriptions for a given topic. |
| NonPersistentTopicApi | persistent_topics_grant_permissions_on_topic | POST /non-persistent/{tenant}/{namespace}/{topic}/permissions/{role} | Grant a new permission to a role on a single topic. |
| NonPersistentTopicApi | persistent_topics_offload_status | GET /non-persistent/{tenant}/{namespace}/{topic}/offload | Offload a prefix of a topic to long term storage |
| NonPersistentTopicApi | persistent_topics_peek_nth_message | GET /non-persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/position/{messagePosition} | Peek nth message on a topic subscription. |
| NonPersistentTopicApi | persistent_topics_remove_auto_subscription_creation | DELETE /non-persistent/{tenant}/{namespace}/{topic}/autoSubscriptionCreation | Remove autoSubscriptionCreation ina a topic. |
| NonPersistentTopicApi | persistent_topics_remove_backlog_quota | DELETE /non-persistent/{tenant}/{namespace}/{topic}/backlogQuota | Remove a backlog quota policy from a topic. |
| NonPersistentTopicApi | persistent_topics_remove_compaction_threshold | DELETE /non-persistent/{tenant}/{namespace}/{topic}/compactionThreshold | Remove compaction threshold configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_remove_deduplication | DELETE /non-persistent/{tenant}/{namespace}/{topic}/deduplicationEnabled | Remove deduplication configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_remove_dispatch_rate | DELETE /non-persistent/{tenant}/{namespace}/{topic}/dispatchRate | Remove message dispatch rate configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_remove_dispatcher_pause_on_ack_state_persistent | DELETE /non-persistent/{tenant}/{namespace}/{topic}/dispatcherPauseOnAckStatePersistent | Remove dispatcher pause on ack state persistent configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_remove_max_consumers | DELETE /non-persistent/{tenant}/{namespace}/{topic}/maxConsumers | Remove maxConsumers config for specified topic. |
| NonPersistentTopicApi | persistent_topics_remove_max_consumers_per_subscription | DELETE /non-persistent/{tenant}/{namespace}/{topic}/maxConsumersPerSubscription | Remove max consumers per subscription configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_remove_max_message_size | DELETE /non-persistent/{tenant}/{namespace}/{topic}/maxMessageSize | Remove maxMessageSize config for specified topic. |
| NonPersistentTopicApi | persistent_topics_remove_max_producers | DELETE /non-persistent/{tenant}/{namespace}/{topic}/maxProducers | Remove maxProducers config for specified topic. |
| NonPersistentTopicApi | persistent_topics_remove_max_subscriptions_per_topic | DELETE /non-persistent/{tenant}/{namespace}/{topic}/maxSubscriptionsPerTopic | Remove maxSubscriptionsPerTopic config for specified topic. |
| NonPersistentTopicApi | persistent_topics_remove_message_ttl | DELETE /non-persistent/{tenant}/{namespace}/{topic}/messageTTL | Remove message TTL in seconds for a topic |
| NonPersistentTopicApi | persistent_topics_remove_offload_policies | DELETE /non-persistent/{tenant}/{namespace}/{topic}/offloadPolicies | Delete offload policies on a topic. |
| NonPersistentTopicApi | persistent_topics_remove_persistence | DELETE /non-persistent/{tenant}/{namespace}/{topic}/persistence | Remove configuration of persistence policies for specified topic. |
| NonPersistentTopicApi | persistent_topics_remove_properties | DELETE /non-persistent/{tenant}/{namespace}/{topic}/properties | Remove the key in properties on the given topic. |
| NonPersistentTopicApi | persistent_topics_remove_publish_rate | DELETE /non-persistent/{tenant}/{namespace}/{topic}/publishRate | Remove message publish rate configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_remove_replication_clusters | DELETE /non-persistent/{tenant}/{namespace}/{topic}/replication | Remove the replication clusters from a topic. |
| NonPersistentTopicApi | persistent_topics_remove_replicator_dispatch_rate | DELETE /non-persistent/{tenant}/{namespace}/{topic}/replicatorDispatchRate | Remove replicatorDispatchRate config for specified topic. |
| NonPersistentTopicApi | persistent_topics_remove_retention | DELETE /non-persistent/{tenant}/{namespace}/{topic}/retention | Remove retention configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_remove_schema_compatibility_strategy | DELETE /non-persistent/{tenant}/{namespace}/{topic}/schemaCompatibilityStrategy | Remove schema compatibility strategy on a topic |
| NonPersistentTopicApi | persistent_topics_remove_subscribe_rate | DELETE /non-persistent/{tenant}/{namespace}/{topic}/subscribeRate | Remove subscribe rate configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_remove_subscription_dispatch_rate | DELETE /non-persistent/{tenant}/{namespace}/{topic}/subscriptionDispatchRate | Remove subscription message dispatch rate configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_remove_subscription_level_dispatch_rate | DELETE /non-persistent/{tenant}/{namespace}/{topic}/{subName}/dispatchRate | Remove message dispatch rate configuration for specified subscription. |
| NonPersistentTopicApi | persistent_topics_remove_subscription_types_enabled | DELETE /non-persistent/{tenant}/{namespace}/{topic}/subscriptionTypesEnabled | Remove subscription types enabled for specified topic. |
| NonPersistentTopicApi | persistent_topics_reset_cursor | POST /non-persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/resetcursor/{timestamp} | Reset subscription to message position closest to absolute timestamp (in ms). |
| NonPersistentTopicApi | persistent_topics_reset_cursor_on_position | POST /non-persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/resetcursor | Reset subscription to message position closest to given position. |
| NonPersistentTopicApi | persistent_topics_revoke_permissions_on_topic | DELETE /non-persistent/{tenant}/{namespace}/{topic}/permissions/{role} | Revoke permissions on a topic. |
| NonPersistentTopicApi | persistent_topics_set_auto_subscription_creation | POST /non-persistent/{tenant}/{namespace}/{topic}/autoSubscriptionCreation | Override namespace's allowAutoSubscriptionCreation setting for a topic |
| NonPersistentTopicApi | persistent_topics_set_backlog_quota | POST /non-persistent/{tenant}/{namespace}/{topic}/backlogQuota | Set a backlog quota for a topic. |
| NonPersistentTopicApi | persistent_topics_set_compaction_threshold | POST /non-persistent/{tenant}/{namespace}/{topic}/compactionThreshold | Set compaction threshold configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_set_deduplication | POST /non-persistent/{tenant}/{namespace}/{topic}/deduplicationEnabled | Set deduplication enabled on a topic. |
| NonPersistentTopicApi | persistent_topics_set_deduplication_snapshot_interval | POST /non-persistent/{tenant}/{namespace}/{topic}/deduplicationSnapshotInterval | Set deduplicationSnapshotInterval config on a topic. |
| NonPersistentTopicApi | persistent_topics_set_delayed_delivery_policies | POST /non-persistent/{tenant}/{namespace}/{topic}/delayedDelivery | Set delayed delivery messages config on a topic. |
| NonPersistentTopicApi | persistent_topics_set_dispatch_rate | POST /non-persistent/{tenant}/{namespace}/{topic}/dispatchRate | Set message dispatch rate configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_set_dispatcher_pause_on_ack_state_persistent | POST /non-persistent/{tenant}/{namespace}/{topic}/dispatcherPauseOnAckStatePersistent | Set dispatcher pause on ack state persistent configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_set_inactive_topic_policies | POST /non-persistent/{tenant}/{namespace}/{topic}/inactiveTopicPolicies | Set inactive topic policies on a topic. |
| NonPersistentTopicApi | persistent_topics_set_max_consumers | POST /non-persistent/{tenant}/{namespace}/{topic}/maxConsumers | Set maxConsumers config for specified topic. |
| NonPersistentTopicApi | persistent_topics_set_max_consumers_per_subscription | POST /non-persistent/{tenant}/{namespace}/{topic}/maxConsumersPerSubscription | Set max consumers per subscription configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_set_max_message_size | POST /non-persistent/{tenant}/{namespace}/{topic}/maxMessageSize | Set maxMessageSize config for specified topic. |
| NonPersistentTopicApi | persistent_topics_set_max_producers | POST /non-persistent/{tenant}/{namespace}/{topic}/maxProducers | Set maxProducers config for specified topic. |
| NonPersistentTopicApi | persistent_topics_set_max_subscriptions_per_topic | POST /non-persistent/{tenant}/{namespace}/{topic}/maxSubscriptionsPerTopic | Set maxSubscriptionsPerTopic config for specified topic. |
| NonPersistentTopicApi | persistent_topics_set_max_unacked_messages_on_consumer | POST /non-persistent/{tenant}/{namespace}/{topic}/maxUnackedMessagesOnConsumer | Set max unacked messages per consumer config on a topic. |
| NonPersistentTopicApi | persistent_topics_set_max_unacked_messages_on_subscription | POST /non-persistent/{tenant}/{namespace}/{topic}/maxUnackedMessagesOnSubscription | Set max unacked messages per subscription config on a topic. |
| NonPersistentTopicApi | persistent_topics_set_message_ttl | POST /non-persistent/{tenant}/{namespace}/{topic}/messageTTL | Set message TTL in seconds for a topic |
| NonPersistentTopicApi | persistent_topics_set_offload_policies | POST /non-persistent/{tenant}/{namespace}/{topic}/offloadPolicies | Set offload policies on a topic. |
| NonPersistentTopicApi | persistent_topics_set_persistence | POST /non-persistent/{tenant}/{namespace}/{topic}/persistence | Set configuration of persistence policies for specified topic. |
| NonPersistentTopicApi | persistent_topics_set_publish_rate | POST /non-persistent/{tenant}/{namespace}/{topic}/publishRate | Set message publish rate configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_set_replicated_subscription_status | POST /non-persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/replicatedSubscriptionStatus | Enable or disable a replicated subscription on a topic. |
| NonPersistentTopicApi | persistent_topics_set_replication_clusters | POST /non-persistent/{tenant}/{namespace}/{topic}/replication | Set the replication clusters for a topic. |
| NonPersistentTopicApi | persistent_topics_set_replicator_dispatch_rate | POST /non-persistent/{tenant}/{namespace}/{topic}/replicatorDispatchRate | Set replicatorDispatchRate config for specified topic. |
| NonPersistentTopicApi | persistent_topics_set_retention | POST /non-persistent/{tenant}/{namespace}/{topic}/retention | Set retention configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_set_schema_compatibility_strategy | PUT /non-persistent/{tenant}/{namespace}/{topic}/schemaCompatibilityStrategy | Set schema compatibility strategy on a topic |
| NonPersistentTopicApi | persistent_topics_set_schema_validation_enforced | POST /non-persistent/{tenant}/{namespace}/{topic}/schemaValidationEnforced | Set schema validation enforced flag on topic. |
| NonPersistentTopicApi | persistent_topics_set_shadow_topics | PUT /non-persistent/{tenant}/{namespace}/{topic}/shadowTopics | Set shadow topic list for a topic |
| NonPersistentTopicApi | persistent_topics_set_subscribe_rate | POST /non-persistent/{tenant}/{namespace}/{topic}/subscribeRate | Set subscribe rate configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_set_subscription_dispatch_rate | POST /non-persistent/{tenant}/{namespace}/{topic}/subscriptionDispatchRate | Set subscription message dispatch rate configuration for specified topic. |
| NonPersistentTopicApi | persistent_topics_set_subscription_level_dispatch_rate | POST /non-persistent/{tenant}/{namespace}/{topic}/{subName}/dispatchRate | Set message dispatch rate configuration for specified subscription. |
| NonPersistentTopicApi | persistent_topics_set_subscription_types_enabled | POST /non-persistent/{tenant}/{namespace}/{topic}/subscriptionTypesEnabled | Set is enable sub types for specified topic |
| NonPersistentTopicApi | persistent_topics_skip_all_messages | POST /non-persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/skip_all | Skip all messages on a topic subscription. |
| NonPersistentTopicApi | persistent_topics_skip_messages | POST /non-persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/skip/{numMessages} | Skipping messages on a topic subscription. |
| NonPersistentTopicApi | persistent_topics_terminate | POST /non-persistent/{tenant}/{namespace}/{topic}/terminate | Terminate a topic. A topic that is terminated will not accept any more messages to be published and will let consumer to drain existing messages in backlog |
| NonPersistentTopicApi | persistent_topics_terminate_partitioned_topic | POST /non-persistent/{tenant}/{namespace}/{topic}/terminate/partitions | Terminate all partitioned topic. A topic that is terminated will not accept any more messages to be published and will let consumer to drain existing messages in backlog |
| NonPersistentTopicApi | persistent_topics_trigger_offload | PUT /non-persistent/{tenant}/{namespace}/{topic}/offload | Offload a prefix of a topic to long term storage |
| NonPersistentTopicApi | persistent_topics_trim_topic | POST /non-persistent/{tenant}/{namespace}/{topic}/trim | Trim a topic |
| NonPersistentTopicApi | persistent_topics_update_partitioned_topic | POST /non-persistent/{tenant}/{namespace}/{topic}/partitions | Increment partitions of an existing partitioned topic. |
| NonPersistentTopicApi | persistent_topics_update_properties | PUT /non-persistent/{tenant}/{namespace}/{topic}/properties | Update the properties on the given topic. |
| NonPersistentTopicApi | persistent_topics_update_subscription_properties | PUT /non-persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/properties | Replace all the properties on the given subscription |
| PersistentTopicApi | persistent_topics_analyze_subscription_backlog | POST /persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/analyzeBacklog | Analyse a subscription, by scanning all the unprocessed messages |
| PersistentTopicApi | persistent_topics_compact | PUT /persistent/{tenant}/{namespace}/{topic}/compaction | Trigger a compaction operation on a topic. |
| PersistentTopicApi | persistent_topics_compaction_status | GET /persistent/{tenant}/{namespace}/{topic}/compaction | Get the status of a compaction operation for a topic. |
| PersistentTopicApi | persistent_topics_create_missed_partitions | POST /persistent/{tenant}/{namespace}/{topic}/createMissedPartitions | Create missed partitions of an existing partitioned topic. |
| PersistentTopicApi | persistent_topics_create_non_partitioned_topic | PUT /persistent/{tenant}/{namespace}/{topic} | Create a non-partitioned topic. |
| PersistentTopicApi | persistent_topics_create_partitioned_topic | PUT /persistent/{tenant}/{namespace}/{topic}/partitions | Create a partitioned topic. |
| PersistentTopicApi | persistent_topics_create_subscription | PUT /persistent/{tenant}/{namespace}/{topic}/subscription/{subscriptionName} | Create a subscription on the topic. |
| PersistentTopicApi | persistent_topics_delete_deduplication_snapshot_interval | DELETE /persistent/{tenant}/{namespace}/{topic}/deduplicationSnapshotInterval | Delete deduplicationSnapshotInterval config on a topic. |
| PersistentTopicApi | persistent_topics_delete_delayed_delivery_policies | DELETE /persistent/{tenant}/{namespace}/{topic}/delayedDelivery | Set delayed delivery messages config on a topic. |
| PersistentTopicApi | persistent_topics_delete_inactive_topic_policies | DELETE /persistent/{tenant}/{namespace}/{topic}/inactiveTopicPolicies | Delete inactive topic policies on a topic. |
| PersistentTopicApi | persistent_topics_delete_max_unacked_messages_on_consumer | DELETE /persistent/{tenant}/{namespace}/{topic}/maxUnackedMessagesOnConsumer | Delete max unacked messages per consumer config on a topic. |
| PersistentTopicApi | persistent_topics_delete_max_unacked_messages_on_subscription | DELETE /persistent/{tenant}/{namespace}/{topic}/maxUnackedMessagesOnSubscription | Delete max unacked messages per subscription config on a topic. |
| PersistentTopicApi | persistent_topics_delete_partitioned_topic | DELETE /persistent/{tenant}/{namespace}/{topic}/partitions | Delete a partitioned topic. |
| PersistentTopicApi | persistent_topics_delete_shadow_topics | DELETE /persistent/{tenant}/{namespace}/{topic}/shadowTopics | Delete shadow topics for a topic |
| PersistentTopicApi | persistent_topics_delete_subscription | DELETE /persistent/{tenant}/{namespace}/{topic}/subscription/{subName} | Delete a subscription. |
| PersistentTopicApi | persistent_topics_delete_topic | DELETE /persistent/{tenant}/{namespace}/{topic} | Delete a topic. |
| PersistentTopicApi | persistent_topics_examine_message | GET /persistent/{tenant}/{namespace}/{topic}/examinemessage | Examine a specific message on a topic by position relative to the earliest or the latest message. |
| PersistentTopicApi | persistent_topics_expire_messages_for_all_subscriptions | POST /persistent/{tenant}/{namespace}/{topic}/all_subscription/expireMessages/{expireTimeInSeconds} | Expiry messages on all subscriptions of topic. |
| PersistentTopicApi | persistent_topics_expire_topic_messages | POST /persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/expireMessages | Expiry messages on a topic subscription. |
| PersistentTopicApi | persistent_topics_expire_topic_messages_0 | POST /persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/expireMessages/{expireTimeInSeconds} | Expiry messages on a topic subscription. |
| PersistentTopicApi | persistent_topics_get_auto_subscription_creation | GET /persistent/{tenant}/{namespace}/{topic}/autoSubscriptionCreation | Get autoSubscriptionCreation info in a topic |
| PersistentTopicApi | persistent_topics_get_backlog | GET /persistent/{tenant}/{namespace}/{topic}/backlog | Get estimated backlog for offline topic. |
| PersistentTopicApi | persistent_topics_get_backlog_quota_map | GET /persistent/{tenant}/{namespace}/{topic}/backlogQuotaMap | Get backlog quota map on a topic. |
| PersistentTopicApi | persistent_topics_get_backlog_size_by_message_id | PUT /persistent/{tenant}/{namespace}/{topic}/backlogSize | Calculate backlog size by a message ID (in bytes). |
| PersistentTopicApi | persistent_topics_get_compaction_threshold | GET /persistent/{tenant}/{namespace}/{topic}/compactionThreshold | Get compaction threshold configuration for specified topic. |
| PersistentTopicApi | persistent_topics_get_deduplication | GET /persistent/{tenant}/{namespace}/{topic}/deduplicationEnabled | Get deduplication configuration of a topic. |
| PersistentTopicApi | persistent_topics_get_deduplication_snapshot_interval | GET /persistent/{tenant}/{namespace}/{topic}/deduplicationSnapshotInterval | Get deduplicationSnapshotInterval config on a topic. |
| PersistentTopicApi | persistent_topics_get_delayed_delivery_policies | GET /persistent/{tenant}/{namespace}/{topic}/delayedDelivery | Get delayed delivery messages config on a topic. |
| PersistentTopicApi | persistent_topics_get_dispatch_rate | GET /persistent/{tenant}/{namespace}/{topic}/dispatchRate | Get dispatch rate configuration for specified topic. |
| PersistentTopicApi | persistent_topics_get_dispatcher_pause_on_ack_state_persistent | GET /persistent/{tenant}/{namespace}/{topic}/dispatcherPauseOnAckStatePersistent | Get dispatcher pause on ack state persistent config on a topic. |
| PersistentTopicApi | persistent_topics_get_entry_filters | GET /persistent/{tenant}/{namespace}/{topic}/entryFilters | Get entry filters for a topic. |
| PersistentTopicApi | persistent_topics_get_inactive_topic_policies | GET /persistent/{tenant}/{namespace}/{topic}/inactiveTopicPolicies | Get inactive topic policies on a topic. |
| PersistentTopicApi | persistent_topics_get_internal_stats | GET /persistent/{tenant}/{namespace}/{topic}/internalStats | Get the internal stats for the topic. |
| PersistentTopicApi | persistent_topics_get_last_message_id | GET /persistent/{tenant}/{namespace}/{topic}/lastMessageId | Return the last commit message id of topic |
| PersistentTopicApi | persistent_topics_get_list | GET /persistent/{tenant}/{namespace} | Get the list of topics under a namespace. |
| PersistentTopicApi | persistent_topics_get_managed_ledger_info | GET /persistent/{tenant}/{namespace}/{topic}/internal-info | Get the stored topic metadata. |
| PersistentTopicApi | persistent_topics_get_max_consumers | GET /persistent/{tenant}/{namespace}/{topic}/maxConsumers | Get maxConsumers config for specified topic. |
| PersistentTopicApi | persistent_topics_get_max_consumers_per_subscription | GET /persistent/{tenant}/{namespace}/{topic}/maxConsumersPerSubscription | Get max consumers per subscription configuration for specified topic. |
| PersistentTopicApi | persistent_topics_get_max_message_size | GET /persistent/{tenant}/{namespace}/{topic}/maxMessageSize | Get maxMessageSize config for specified topic. |
| PersistentTopicApi | persistent_topics_get_max_producers | GET /persistent/{tenant}/{namespace}/{topic}/maxProducers | Get maxProducers config for specified topic. |
| PersistentTopicApi | persistent_topics_get_max_subscriptions_per_topic | GET /persistent/{tenant}/{namespace}/{topic}/maxSubscriptionsPerTopic | Get maxSubscriptionsPerTopic config for specified topic. |
| PersistentTopicApi | persistent_topics_get_max_unacked_messages_on_consumer | GET /persistent/{tenant}/{namespace}/{topic}/maxUnackedMessagesOnConsumer | Get max unacked messages per consumer config on a topic. |
| PersistentTopicApi | persistent_topics_get_max_unacked_messages_on_subscription | GET /persistent/{tenant}/{namespace}/{topic}/maxUnackedMessagesOnSubscription | Get max unacked messages per subscription config on a topic. |
| PersistentTopicApi | persistent_topics_get_message_by_id | GET /persistent/{tenant}/{namespace}/{topic}/ledger/{ledgerId}/entry/{entryId} | Get message by its messageId. |
| PersistentTopicApi | persistent_topics_get_message_id_by_timestamp | GET /persistent/{tenant}/{namespace}/{topic}/messageid/{timestamp} | Get message ID published at or just after this absolute timestamp (in ms). |
| PersistentTopicApi | persistent_topics_get_message_ttl | GET /persistent/{tenant}/{namespace}/{topic}/messageTTL | Get message TTL in seconds for a topic |
| PersistentTopicApi | persistent_topics_get_offload_policies | GET /persistent/{tenant}/{namespace}/{topic}/offloadPolicies | Get offload policies on a topic. |
| PersistentTopicApi | persistent_topics_get_partitioned_metadata | GET /persistent/{tenant}/{namespace}/{topic}/partitions | Get partitioned topic metadata. |
| PersistentTopicApi | persistent_topics_get_partitioned_stats | GET /persistent/{tenant}/{namespace}/{topic}/partitioned-stats | Get the stats for the partitioned topic. |
| PersistentTopicApi | persistent_topics_get_partitioned_stats_internal | GET /persistent/{tenant}/{namespace}/{topic}/partitioned-internalStats | Get the stats-internal for the partitioned topic. |
| PersistentTopicApi | persistent_topics_get_partitioned_topic_list | GET /persistent/{tenant}/{namespace}/partitioned | Get the list of partitioned topics under a namespace. |
| PersistentTopicApi | persistent_topics_get_permissions_on_topic | GET /persistent/{tenant}/{namespace}/{topic}/permissions | Get permissions on a topic. |
| PersistentTopicApi | persistent_topics_get_persistence | GET /persistent/{tenant}/{namespace}/{topic}/persistence | Get configuration of persistence policies for specified topic. |
| PersistentTopicApi | persistent_topics_get_properties | GET /persistent/{tenant}/{namespace}/{topic}/properties | Get topic properties. |
| PersistentTopicApi | persistent_topics_get_publish_rate | GET /persistent/{tenant}/{namespace}/{topic}/publishRate | Get publish rate configuration for specified topic. |
| PersistentTopicApi | persistent_topics_get_replicated_subscription_status | GET /persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/replicatedSubscriptionStatus | Get replicated subscription status on a topic. |
| PersistentTopicApi | persistent_topics_get_replication_clusters | GET /persistent/{tenant}/{namespace}/{topic}/replication | Get the replication clusters for a topic |
| PersistentTopicApi | persistent_topics_get_replicator_dispatch_rate | GET /persistent/{tenant}/{namespace}/{topic}/replicatorDispatchRate | Get replicatorDispatchRate config for specified topic. |
| PersistentTopicApi | persistent_topics_get_retention | GET /persistent/{tenant}/{namespace}/{topic}/retention | Get retention configuration for specified topic. |
| PersistentTopicApi | persistent_topics_get_schema_compatibility_strategy | GET /persistent/{tenant}/{namespace}/{topic}/schemaCompatibilityStrategy | Get schema compatibility strategy on a topic |
| PersistentTopicApi | persistent_topics_get_schema_validation_enforced | GET /persistent/{tenant}/{namespace}/{topic}/schemaValidationEnforced | Get schema validation enforced flag for topic. |
| PersistentTopicApi | persistent_topics_get_shadow_topics | GET /persistent/{tenant}/{namespace}/{topic}/shadowTopics | Get the shadow topic list for a topic |
| PersistentTopicApi | persistent_topics_get_stats | GET /persistent/{tenant}/{namespace}/{topic}/stats | Get the stats for the topic. |
| PersistentTopicApi | persistent_topics_get_subscribe_rate | GET /persistent/{tenant}/{namespace}/{topic}/subscribeRate | Get subscribe rate configuration for specified topic. |
| PersistentTopicApi | persistent_topics_get_subscription_dispatch_rate | GET /persistent/{tenant}/{namespace}/{topic}/subscriptionDispatchRate | Get subscription message dispatch rate configuration for specified topic. |
| PersistentTopicApi | persistent_topics_get_subscription_level_dispatch_rate | GET /persistent/{tenant}/{namespace}/{topic}/{subName}/dispatchRate | Get message dispatch rate configuration for specified subscription. |
| PersistentTopicApi | persistent_topics_get_subscription_properties | GET /persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/properties | Return all the properties on the given subscription |
| PersistentTopicApi | persistent_topics_get_subscription_types_enabled | GET /persistent/{tenant}/{namespace}/{topic}/subscriptionTypesEnabled | Get is enable sub type fors specified topic. |
| PersistentTopicApi | persistent_topics_get_subscriptions | GET /persistent/{tenant}/{namespace}/{topic}/subscriptions | Get the list of persistent subscriptions for a given topic. |
| PersistentTopicApi | persistent_topics_grant_permissions_on_topic | POST /persistent/{tenant}/{namespace}/{topic}/permissions/{role} | Grant a new permission to a role on a single topic. |
| PersistentTopicApi | persistent_topics_offload_status | GET /persistent/{tenant}/{namespace}/{topic}/offload | Offload a prefix of a topic to long term storage |
| PersistentTopicApi | persistent_topics_peek_nth_message | GET /persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/position/{messagePosition} | Peek nth message on a topic subscription. |
| PersistentTopicApi | persistent_topics_remove_auto_subscription_creation | DELETE /persistent/{tenant}/{namespace}/{topic}/autoSubscriptionCreation | Remove autoSubscriptionCreation ina a topic. |
| PersistentTopicApi | persistent_topics_remove_backlog_quota | DELETE /persistent/{tenant}/{namespace}/{topic}/backlogQuota | Remove a backlog quota policy from a topic. |
| PersistentTopicApi | persistent_topics_remove_compaction_threshold | DELETE /persistent/{tenant}/{namespace}/{topic}/compactionThreshold | Remove compaction threshold configuration for specified topic. |
| PersistentTopicApi | persistent_topics_remove_deduplication | DELETE /persistent/{tenant}/{namespace}/{topic}/deduplicationEnabled | Remove deduplication configuration for specified topic. |
| PersistentTopicApi | persistent_topics_remove_dispatch_rate | DELETE /persistent/{tenant}/{namespace}/{topic}/dispatchRate | Remove message dispatch rate configuration for specified topic. |
| PersistentTopicApi | persistent_topics_remove_dispatcher_pause_on_ack_state_persistent | DELETE /persistent/{tenant}/{namespace}/{topic}/dispatcherPauseOnAckStatePersistent | Remove dispatcher pause on ack state persistent configuration for specified topic. |
| PersistentTopicApi | persistent_topics_remove_entry_filters | DELETE /persistent/{tenant}/{namespace}/{topic}/entryFilters | Remove entry filters for specified topic. |
| PersistentTopicApi | persistent_topics_remove_max_consumers | DELETE /persistent/{tenant}/{namespace}/{topic}/maxConsumers | Remove maxConsumers config for specified topic. |
| PersistentTopicApi | persistent_topics_remove_max_consumers_per_subscription | DELETE /persistent/{tenant}/{namespace}/{topic}/maxConsumersPerSubscription | Remove max consumers per subscription configuration for specified topic. |
| PersistentTopicApi | persistent_topics_remove_max_message_size | DELETE /persistent/{tenant}/{namespace}/{topic}/maxMessageSize | Remove maxMessageSize config for specified topic. |
| PersistentTopicApi | persistent_topics_remove_max_producers | DELETE /persistent/{tenant}/{namespace}/{topic}/maxProducers | Remove maxProducers config for specified topic. |
| PersistentTopicApi | persistent_topics_remove_max_subscriptions_per_topic | DELETE /persistent/{tenant}/{namespace}/{topic}/maxSubscriptionsPerTopic | Remove maxSubscriptionsPerTopic config for specified topic. |
| PersistentTopicApi | persistent_topics_remove_message_ttl | DELETE /persistent/{tenant}/{namespace}/{topic}/messageTTL | Remove message TTL in seconds for a topic |
| PersistentTopicApi | persistent_topics_remove_offload_policies | DELETE /persistent/{tenant}/{namespace}/{topic}/offloadPolicies | Delete offload policies on a topic. |
| PersistentTopicApi | persistent_topics_remove_persistence | DELETE /persistent/{tenant}/{namespace}/{topic}/persistence | Remove configuration of persistence policies for specified topic. |
| PersistentTopicApi | persistent_topics_remove_properties | DELETE /persistent/{tenant}/{namespace}/{topic}/properties | Remove the key in properties on the given topic. |
| PersistentTopicApi | persistent_topics_remove_publish_rate | DELETE /persistent/{tenant}/{namespace}/{topic}/publishRate | Remove message publish rate configuration for specified topic. |
| PersistentTopicApi | persistent_topics_remove_replication_clusters | DELETE /persistent/{tenant}/{namespace}/{topic}/replication | Remove the replication clusters from a topic. |
| PersistentTopicApi | persistent_topics_remove_replicator_dispatch_rate | DELETE /persistent/{tenant}/{namespace}/{topic}/replicatorDispatchRate | Remove replicatorDispatchRate config for specified topic. |
| PersistentTopicApi | persistent_topics_remove_retention | DELETE /persistent/{tenant}/{namespace}/{topic}/retention | Remove retention configuration for specified topic. |
| PersistentTopicApi | persistent_topics_remove_schema_compatibility_strategy | DELETE /persistent/{tenant}/{namespace}/{topic}/schemaCompatibilityStrategy | Remove schema compatibility strategy on a topic |
| PersistentTopicApi | persistent_topics_remove_subscribe_rate | DELETE /persistent/{tenant}/{namespace}/{topic}/subscribeRate | Remove subscribe rate configuration for specified topic. |
| PersistentTopicApi | persistent_topics_remove_subscription_dispatch_rate | DELETE /persistent/{tenant}/{namespace}/{topic}/subscriptionDispatchRate | Remove subscription message dispatch rate configuration for specified topic. |
| PersistentTopicApi | persistent_topics_remove_subscription_level_dispatch_rate | DELETE /persistent/{tenant}/{namespace}/{topic}/{subName}/dispatchRate | Remove message dispatch rate configuration for specified subscription. |
| PersistentTopicApi | persistent_topics_remove_subscription_types_enabled | DELETE /persistent/{tenant}/{namespace}/{topic}/subscriptionTypesEnabled | Remove subscription types enabled for specified topic. |
| PersistentTopicApi | persistent_topics_reset_cursor | POST /persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/resetcursor/{timestamp} | Reset subscription to message position closest to absolute timestamp (in ms). |
| PersistentTopicApi | persistent_topics_reset_cursor_on_position | POST /persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/resetcursor | Reset subscription to message position closest to given position. |
| PersistentTopicApi | persistent_topics_revoke_permissions_on_topic | DELETE /persistent/{tenant}/{namespace}/{topic}/permissions/{role} | Revoke permissions on a topic. |
| PersistentTopicApi | persistent_topics_set_auto_subscription_creation | POST /persistent/{tenant}/{namespace}/{topic}/autoSubscriptionCreation | Override namespace's allowAutoSubscriptionCreation setting for a topic |
| PersistentTopicApi | persistent_topics_set_backlog_quota | POST /persistent/{tenant}/{namespace}/{topic}/backlogQuota | Set a backlog quota for a topic. |
| PersistentTopicApi | persistent_topics_set_compaction_threshold | POST /persistent/{tenant}/{namespace}/{topic}/compactionThreshold | Set compaction threshold configuration for specified topic. |
| PersistentTopicApi | persistent_topics_set_deduplication | POST /persistent/{tenant}/{namespace}/{topic}/deduplicationEnabled | Set deduplication enabled on a topic. |
| PersistentTopicApi | persistent_topics_set_deduplication_snapshot_interval | POST /persistent/{tenant}/{namespace}/{topic}/deduplicationSnapshotInterval | Set deduplicationSnapshotInterval config on a topic. |
| PersistentTopicApi | persistent_topics_set_delayed_delivery_policies | POST /persistent/{tenant}/{namespace}/{topic}/delayedDelivery | Set delayed delivery messages config on a topic. |
| PersistentTopicApi | persistent_topics_set_dispatch_rate | POST /persistent/{tenant}/{namespace}/{topic}/dispatchRate | Set message dispatch rate configuration for specified topic. |
| PersistentTopicApi | persistent_topics_set_dispatcher_pause_on_ack_state_persistent | POST /persistent/{tenant}/{namespace}/{topic}/dispatcherPauseOnAckStatePersistent | Set dispatcher pause on ack state persistent configuration for specified topic. |
| PersistentTopicApi | persistent_topics_set_entry_filters | POST /persistent/{tenant}/{namespace}/{topic}/entryFilters | Set entry filters for specified topic |
| PersistentTopicApi | persistent_topics_set_inactive_topic_policies | POST /persistent/{tenant}/{namespace}/{topic}/inactiveTopicPolicies | Set inactive topic policies on a topic. |
| PersistentTopicApi | persistent_topics_set_max_consumers | POST /persistent/{tenant}/{namespace}/{topic}/maxConsumers | Set maxConsumers config for specified topic. |
| PersistentTopicApi | persistent_topics_set_max_consumers_per_subscription | POST /persistent/{tenant}/{namespace}/{topic}/maxConsumersPerSubscription | Set max consumers per subscription configuration for specified topic. |
| PersistentTopicApi | persistent_topics_set_max_message_size | POST /persistent/{tenant}/{namespace}/{topic}/maxMessageSize | Set maxMessageSize config for specified topic. |
| PersistentTopicApi | persistent_topics_set_max_producers | POST /persistent/{tenant}/{namespace}/{topic}/maxProducers | Set maxProducers config for specified topic. |
| PersistentTopicApi | persistent_topics_set_max_subscriptions_per_topic | POST /persistent/{tenant}/{namespace}/{topic}/maxSubscriptionsPerTopic | Set maxSubscriptionsPerTopic config for specified topic. |
| PersistentTopicApi | persistent_topics_set_max_unacked_messages_on_consumer | POST /persistent/{tenant}/{namespace}/{topic}/maxUnackedMessagesOnConsumer | Set max unacked messages per consumer config on a topic. |
| PersistentTopicApi | persistent_topics_set_max_unacked_messages_on_subscription | POST /persistent/{tenant}/{namespace}/{topic}/maxUnackedMessagesOnSubscription | Set max unacked messages per subscription config on a topic. |
| PersistentTopicApi | persistent_topics_set_message_ttl | POST /persistent/{tenant}/{namespace}/{topic}/messageTTL | Set message TTL in seconds for a topic |
| PersistentTopicApi | persistent_topics_set_offload_policies | POST /persistent/{tenant}/{namespace}/{topic}/offloadPolicies | Set offload policies on a topic. |
| PersistentTopicApi | persistent_topics_set_persistence | POST /persistent/{tenant}/{namespace}/{topic}/persistence | Set configuration of persistence policies for specified topic. |
| PersistentTopicApi | persistent_topics_set_publish_rate | POST /persistent/{tenant}/{namespace}/{topic}/publishRate | Set message publish rate configuration for specified topic. |
| PersistentTopicApi | persistent_topics_set_replicated_subscription_status | POST /persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/replicatedSubscriptionStatus | Enable or disable a replicated subscription on a topic. |
| PersistentTopicApi | persistent_topics_set_replication_clusters | POST /persistent/{tenant}/{namespace}/{topic}/replication | Set the replication clusters for a topic. |
| PersistentTopicApi | persistent_topics_set_replicator_dispatch_rate | POST /persistent/{tenant}/{namespace}/{topic}/replicatorDispatchRate | Set replicatorDispatchRate config for specified topic. |
| PersistentTopicApi | persistent_topics_set_retention | POST /persistent/{tenant}/{namespace}/{topic}/retention | Set retention configuration for specified topic. |
| PersistentTopicApi | persistent_topics_set_schema_compatibility_strategy | PUT /persistent/{tenant}/{namespace}/{topic}/schemaCompatibilityStrategy | Set schema compatibility strategy on a topic |
| PersistentTopicApi | persistent_topics_set_schema_validation_enforced | POST /persistent/{tenant}/{namespace}/{topic}/schemaValidationEnforced | Set schema validation enforced flag on topic. |
| PersistentTopicApi | persistent_topics_set_shadow_topics | PUT /persistent/{tenant}/{namespace}/{topic}/shadowTopics | Set shadow topic list for a topic |
| PersistentTopicApi | persistent_topics_set_subscribe_rate | POST /persistent/{tenant}/{namespace}/{topic}/subscribeRate | Set subscribe rate configuration for specified topic. |
| PersistentTopicApi | persistent_topics_set_subscription_dispatch_rate | POST /persistent/{tenant}/{namespace}/{topic}/subscriptionDispatchRate | Set subscription message dispatch rate configuration for specified topic. |
| PersistentTopicApi | persistent_topics_set_subscription_level_dispatch_rate | POST /persistent/{tenant}/{namespace}/{topic}/{subName}/dispatchRate | Set message dispatch rate configuration for specified subscription. |
| PersistentTopicApi | persistent_topics_set_subscription_types_enabled | POST /persistent/{tenant}/{namespace}/{topic}/subscriptionTypesEnabled | Set is enable sub types for specified topic |
| PersistentTopicApi | persistent_topics_skip_all_messages | POST /persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/skip_all | Skip all messages on a topic subscription. |
| PersistentTopicApi | persistent_topics_skip_messages | POST /persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/skip/{numMessages} | Skipping messages on a topic subscription. |
| PersistentTopicApi | persistent_topics_terminate | POST /persistent/{tenant}/{namespace}/{topic}/terminate | Terminate a topic. A topic that is terminated will not accept any more messages to be published and will let consumer to drain existing messages in backlog |
| PersistentTopicApi | persistent_topics_terminate_partitioned_topic | POST /persistent/{tenant}/{namespace}/{topic}/terminate/partitions | Terminate all partitioned topic. A topic that is terminated will not accept any more messages to be published and will let consumer to drain existing messages in backlog |
| PersistentTopicApi | persistent_topics_trigger_offload | PUT /persistent/{tenant}/{namespace}/{topic}/offload | Offload a prefix of a topic to long term storage |
| PersistentTopicApi | persistent_topics_trim_topic | POST /persistent/{tenant}/{namespace}/{topic}/trim | Trim a topic |
| PersistentTopicApi | persistent_topics_truncate_topic | DELETE /persistent/{tenant}/{namespace}/{topic}/truncate | Truncate a topic. |
| PersistentTopicApi | persistent_topics_unload_topic | PUT /persistent/{tenant}/{namespace}/{topic}/unload | Unload a topic |
| PersistentTopicApi | persistent_topics_update_partitioned_topic | POST /persistent/{tenant}/{namespace}/{topic}/partitions | Increment partitions of an existing partitioned topic. |
| PersistentTopicApi | persistent_topics_update_properties | PUT /persistent/{tenant}/{namespace}/{topic}/properties | Update the properties on the given topic. |
| PersistentTopicApi | persistent_topics_update_subscription_properties | PUT /persistent/{tenant}/{namespace}/{topic}/subscription/{subName}/properties | Replace all the properties on the given subscription |
| ResourceQuotasApi | resource_quotas_get_default_resource_quota | GET /resource-quotas | Get the default quota |
| ResourceQuotasApi | resource_quotas_get_namespace_bundle_resource_quota | GET /resource-quotas/{tenant}/{namespace}/{bundle} | Get resource quota of a namespace bundle. |
| ResourceQuotasApi | resource_quotas_remove_namespace_bundle_resource_quota | DELETE /resource-quotas/{tenant}/{namespace}/{bundle} | Remove resource quota for a namespace. |
| ResourceQuotasApi | resource_quotas_set_default_resource_quota | POST /resource-quotas | Set the default quota |
| ResourceQuotasApi | resource_quotas_set_namespace_bundle_resource_quota | POST /resource-quotas/{tenant}/{namespace}/{bundle} | Set resource quota on a namespace. |
| ResourcegroupsApi | resource_groups_create_or_update_resource_group | PUT /resourcegroups/{resourcegroup} | Creates a new resourcegroup with the specified rate limiters |
| ResourcegroupsApi | resource_groups_delete_resource_group | DELETE /resourcegroups/{resourcegroup} | Delete a resourcegroup. |
| ResourcegroupsApi | resource_groups_get_resource_group | GET /resourcegroups/{resourcegroup} | Get the rate limiters specified for a resourcegroup. |
| ResourcegroupsApi | resource_groups_get_resource_groups | GET /resourcegroups | Get the list of all the resourcegroups. |
| SchemasApi | schemas_resource_delete_schema | DELETE /schemas/{tenant}/{namespace}/{topic}/schema | Delete all versions schema of a topic |
| SchemasApi | schemas_resource_get_all_schemas | GET /schemas/{tenant}/{namespace}/{topic}/schemas | Get the all schemas of a topic |
| SchemasApi | schemas_resource_get_schema | GET /schemas/{tenant}/{namespace}/{topic}/schema | Get the schema of a topic |
| SchemasApi | schemas_resource_get_schema_0 | GET /schemas/{tenant}/{namespace}/{topic}/schema/{version} | Get the schema of a topic at a given version |
| SchemasApi | schemas_resource_get_version_by_schema | POST /schemas/{tenant}/{namespace}/{topic}/version | get the version of the schema |
| SchemasApi | schemas_resource_post_schema | POST /schemas/{tenant}/{namespace}/{topic}/schema | Update the schema of a topic |
| SchemasApi | schemas_resource_test_compatibility | POST /schemas/{tenant}/{namespace}/{topic}/compatibility | test the schema compatibility |
| TenantsApi | tenants_base_create_tenant | PUT /tenants/{tenant} | Create a new tenant. |
| TenantsApi | tenants_base_delete_tenant | DELETE /tenants/{tenant} | Delete a tenant and all namespaces and topics under it. |
| TenantsApi | tenants_base_get_tenant_admin | GET /tenants/{tenant} | Get the admin configuration for a given tenant. |
| TenantsApi | tenants_base_get_tenants | GET /tenants | Get the list of existing tenants. |
| TenantsApi | tenants_base_update_tenant | POST /tenants/{tenant} | Update the admins for a tenant. |
Documentation For Models
- AllocatorStats
- AuthPolicies
- AuthenticationDataSource
- AuthenticationParameters
- AutoFailoverPolicyData
- AutoSubscriptionCreationOverride
- AutoSubscriptionCreationOverrideImpl
- AutoTopicCreationOverride
- BacklogQuota
- BacklogQuotaImpl
- BookieAffinityGroupData
- BookieInfo
- BookiesClusterInfo
- BrokerInfo
- BrokerNamespaceIsolationData
- BundlesData
- Certificate
- ClusterData
- ClusterUrl
- CompactionStats
- CompactionStatsImpl
- CompletableFuture
- CompletableFutureClusterData
- CompletableFutureListSchemaAndMetadata
- CompletableFutureLong
- CompletableFuturePairBooleanSchemaCompatibilityStrategy
- CompletableFuturePartitionedTopicMetadata
- CompletableFutureResourceQuota
- CompletableFutureSchemaAndMetadata
- CompletableFutureSchemaVersion
- CompletableFutureVoid
- ConnectorDefinition
- ConsumerStats
- CursorDetails
- CursorInfo
- CursorStats
- DelayedDeliveryPolicies
- DeleteSchemaResponse
- DispatchRate
- DispatchRateImpl
- EntryFilters
- FailureDomain
- FunctionInstanceStatsData
- FunctionInstanceStatsDataBase
- Functions
- FunctionsV2
- FunctionsV2WorkerService
- FunctionsWorkerService
- GetAllVersionsSchemaResponse
- GetSchemaResponse
- InactiveTopicPolicies
- InternalConfigurationData
- IsCompatibilityResponse
- KubernetesContainerFactory
- LedgerDetails
- LedgerInfo
- LoadReport
- LongRunningProcessStatus
- LongSchemaVersion
- ManagedLedgerInfo
- MemoryLimit
- MessageRangeInfo
- Metrics
- NamespaceBundleStats
- NamespaceIsolationData
- NamespaceOwnershipStatus
- NonPersistentPartitionedTopicStatsImpl
- NonPersistentPublisherStats
- NonPersistentReplicatorStats
- NonPersistentSubscriptionStats
- NonPersistentTopicStatsImpl
- OffloadPolicies
- OffloadPoliciesImpl
- PartitionedManagedLedgerInfo
- PartitionedTopicInternalStats
- PartitionedTopicMetadata
- PartitionedTopicStatsImpl
- PendingBookieOpsStats
- PersistencePolicies
- PersistentOfflineTopicStats
- PersistentTopicInternalStats
- PersistentTopicStats
- Policies
- PoolArenaStats
- PoolChunkListStats
- PoolChunkStats
- PoolSubpageStats
- PositionInfo
- PostSchemaPayload
- PostSchemaResponse
- ProcessContainerFactory
- PublicKey
- PublishRate
- PublisherStats
- RawBookieInfo
- ReplicatorStats
- ResetCursorData
- ResourceDescription
- ResourceGroup
- ResourceQuota
- ResourceUnit
- ResourceUsage
- Resources
- RetentionPolicies
- Sinks
- SinksWorkerService
- Sources
- SourcesWorkerService
- SubscribeRate
- SubscriptionStats
- SystemResourceUsage
- TenantInfo
- ThreadContainerFactory
- TopicStats
- WorkerConfig
- WorkerFunctionInstanceStats
- WorkerInfo
- WorkerService
To get access to the crate's generated documentation, use:
cargo doc --open
Author
Dependencies
~4–18MB
~253K SLoC