Package io.github.jchejarla.springbatch.clustering.actuate

Class BatchClusterNodesEndpoint

java.lang.Object

io.github.jchejarla.springbatch.clustering.actuate.BatchClusterNodesEndpoint

@Endpoint(id="batch-cluster")
public class BatchClusterNodesEndpoint
extends Object

Actuator endpoint exposed at /actuator/batch-cluster that lists the cluster's nodes and, for a given node, its partition assignments and their status.

Constructor Summary

Constructors

Constructor	Description
BatchClusterNodesEndpoint()

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	clusterNodes()
ClusterNodeInfo	nodeDetails(String nodeId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BatchClusterNodesEndpoint

public BatchClusterNodesEndpoint()

Method Details

clusterNodes

@ReadOperation
public Map<String,Object> clusterNodes()

nodeDetails

@ReadOperation
public ClusterNodeInfo nodeDetails(@Selector
 String nodeId)