Package org.apache.pulsar.client.admin

Interface BrokerStats

public interface BrokerStats
Admin interface for brokers management.

  • Method Details

    • getMetrics

      String getMetrics() throws PulsarAdminException
      Returns Monitoring metrics.
      Returns:
      Throws:
      PulsarAdminException

    • getMetricsAsync

      CompletableFuture<String> getMetricsAsync()
      Returns Monitoring metrics asynchronously.
      Returns:

    • getMBeans

      String getMBeans() throws PulsarAdminException
      Requests JSON string server mbean dump.

      Notes: since we don't plan to introspect the response we avoid converting the response into POJO.

      Returns:
      Throws:
      PulsarAdminException

    • getMBeansAsync

      CompletableFuture<String> getMBeansAsync()
      Requests JSON string server mbean dump asynchronously.

      Notes: since we don't plan to introspect the response we avoid converting the response into POJO.

      Returns:

    • getTopics

      String getTopics() throws PulsarAdminException
      Returns JSON string topics stats.

      Notes: since we don't plan to introspect the response we avoid converting the response into POJO.

      Returns:
      Throws:
      PulsarAdminException

    • getTopicsAsync

      CompletableFuture<String> getTopicsAsync()
      Returns JSON string topics stats asynchronously.

      Notes: since we don't plan to introspect the response we avoid converting the response into POJO.

      Returns:

    • getPendingBookieOpsStats

      String getPendingBookieOpsStats() throws PulsarAdminException
      Get pending bookie client op stats by namespace.

      Notes: since we don't plan to introspect the response we avoid converting the response into POJO.

      Returns:
      Throws:
      PulsarAdminException

    • getPendingBookieOpsStatsAsync

      CompletableFuture<String> getPendingBookieOpsStatsAsync()
      Get pending bookie client op stats by namespace asynchronously.

      Notes: since we don't plan to introspect the response we avoid converting the response into POJO.

      Returns:

    • getAllocatorStats

      AllocatorStats getAllocatorStats(String allocatorName) throws PulsarAdminException
      Get the stats for the Netty allocator.
      Parameters:
      allocatorName -
      Returns:
      Throws:
      PulsarAdminException

    • getAllocatorStatsAsync

      CompletableFuture<AllocatorStats> getAllocatorStatsAsync(String allocatorName)
      Get the stats for the Netty allocator asynchronously.
      Parameters:
      allocatorName -
      Returns:

    • getLoadReport

      LoadManagerReport getLoadReport() throws PulsarAdminException
      Get load for this broker.
      Returns:
      Throws:
      PulsarAdminException

    • getLoadReportAsync

      CompletableFuture<LoadManagerReport> getLoadReportAsync()
      Get load for this broker asynchronously.
      Returns: