Package io.github.jchejarla.springbatch.clustering.mgmt

Class ClusterNodeManager

java.lang.Object

io.github.jchejarla.springbatch.clustering.mgmt.ClusterNodeManager

public class ClusterNodeManager
extends Object

Constructor Summary

Constructors

Constructor	Description
ClusterNodeManager()

Method Summary

Modifier and Type	Method	Description
protected void	markNodesUnreachable()
protected void	removeNodesUnreachable()
void	start()
protected void	updateCurrentActiveNodes()
protected void	updateHeartbeat()

Methods inherited from class java.lang.Object

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

Constructor Details

ClusterNodeManager

public ClusterNodeManager()

Method Details

start

@EventListener(org.springframework.boot.context.event.ApplicationReadyEvent.class)
public void start()

updateHeartbeat

protected void updateHeartbeat()

markNodesUnreachable

protected void markNodesUnreachable()

removeNodesUnreachable

protected void removeNodesUnreachable()

updateCurrentActiveNodes

protected void updateCurrentActiveNodes()