Package org.apache.pulsar.client.admin

Interface Worker

public interface Worker

Admin interface for worker stats management.

Method Summary

Modifier and Type	Method	Description
Map<String,Collection<String>>	getAssignments()	Get the function assignment among the cluster.
CompletableFuture<Map<String,Collection<String>>>	getAssignmentsAsync()	Get the function assignment among the cluster asynchronously.
List<WorkerInfo>	getCluster()	Get List of all workers belonging to this cluster.
CompletableFuture<List<WorkerInfo>>	getClusterAsync()	Get List of all workers belonging to this cluster asynchronously.
WorkerInfo	getClusterLeader()	Get the worker who is the leader of the cluster.
CompletableFuture<WorkerInfo>	getClusterLeaderAsync()	Get the worker who is the leader of the cluster asynchronously.
List<WorkerFunctionInstanceStats>	getFunctionsStats()	Get all functions stats on a worker.
CompletableFuture<List<WorkerFunctionInstanceStats>>	getFunctionsStatsAsync()	Get all functions stats on a worker asynchronously.
Collection<Metrics>	getMetrics()	Get worker metrics.
CompletableFuture<Collection<Metrics>>	getMetricsAsync()	Get worker metrics asynchronously.
void	rebalance()	Triggers a rebalance of functions to workers.
CompletableFuture<Void>	rebalanceAsync()	Triggers a rebalance of functions to workersasynchronously..

Method Details

getFunctionsStats

List<WorkerFunctionInstanceStats> getFunctionsStats()
                                             throws PulsarAdminException

Get all functions stats on a worker.

Returns:

Throws:

PulsarAdminException

getFunctionsStatsAsync

CompletableFuture<List<WorkerFunctionInstanceStats>> getFunctionsStatsAsync()

Get all functions stats on a worker asynchronously.

Returns:

getMetrics

Collection<Metrics> getMetrics()
                        throws PulsarAdminException

Get worker metrics.

Returns:

Throws:

PulsarAdminException

getMetricsAsync

CompletableFuture<Collection<Metrics>> getMetricsAsync()

Get worker metrics asynchronously.

Returns:

getCluster

List<WorkerInfo> getCluster()
                     throws PulsarAdminException

Get List of all workers belonging to this cluster.

Returns:

Throws:

PulsarAdminException

getClusterAsync

CompletableFuture<List<WorkerInfo>> getClusterAsync()

Get List of all workers belonging to this cluster asynchronously.

Returns:

getClusterLeader

WorkerInfo getClusterLeader()
                     throws PulsarAdminException

Get the worker who is the leader of the cluster.

Returns:

Throws:

PulsarAdminException

getClusterLeaderAsync

CompletableFuture<WorkerInfo> getClusterLeaderAsync()

Get the worker who is the leader of the cluster asynchronously.

Returns:

getAssignments

Map<String,Collection<String>> getAssignments()
                                       throws PulsarAdminException

Get the function assignment among the cluster.

Returns:

Throws:

PulsarAdminException

getAssignmentsAsync

CompletableFuture<Map<String,Collection<String>>> getAssignmentsAsync()

Get the function assignment among the cluster asynchronously.

Returns:

rebalance

void rebalance()
        throws PulsarAdminException

Triggers a rebalance of functions to workers.

Throws:

PulsarAdminException

rebalanceAsync

CompletableFuture<Void> rebalanceAsync()

Triggers a rebalance of functions to workersasynchronously..

Throws:

PulsarAdminException