Package org.apache.nifi.controller.leader.election

Class TrackedLeaderElectionManager

java.lang.Object

org.apache.nifi.controller.leader.election.TrackedLeaderElectionManager

All Implemented Interfaces:

LeaderElectionManager

public abstract class TrackedLeaderElectionManager
extends Object
implements LeaderElectionManager

Abstract implementation of Leader Election Manager supporting tracking of operations

Field Summary

Fields

Modifier and Type	Field	Description
private final ConcurrentMap<String,TimedBuffer<TimestampedLong>>	leaderChanges
private final TimedBuffer<TimestampedLongAggregation>	pollTimes

Constructor Summary

Constructors

Constructor	Description
TrackedLeaderElectionManager()

Method Summary

Modifier and Type	Method	Description
long	getAveragePollTime(TimeUnit timeUnit)
Map<String,Integer>	getLeadershipChangeCount(long duration, TimeUnit unit)
long	getMaxPollTime(TimeUnit timeUnit)
long	getMinPollTime(TimeUnit timeUnit)
long	getPollCount()
protected boolean	isParticipating(String participantId)	Is specified identifier participating in the election based on null or empty participant identifier
protected void	onLeaderChanged(String roleName)	On Leader Changed register role name changes
void	register(String roleName, LeaderElectionStateChangeListener listener)	Register as observer without Participant Identifier
protected void	registerPollTime(long nanos)	Register Poll Time in nanoseconds

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.nifi.controller.leader.election.LeaderElectionManager

getLeader, isActiveParticipant, isLeader, register, start, stop, unregister

Field Details

leaderChanges

private final ConcurrentMap<String,TimedBuffer<TimestampedLong>> leaderChanges

pollTimes

private final TimedBuffer<TimestampedLongAggregation> pollTimes

Constructor Details

TrackedLeaderElectionManager

public TrackedLeaderElectionManager()

Method Details

register

public void register(String roleName,
 LeaderElectionStateChangeListener listener)

Register as observer without Participant Identifier

Specified by:

register in interface LeaderElectionManager

Parameters:

roleName - Name of role to be registered for elections

listener - Listener notified on leader state changes

getLeadershipChangeCount

public Map<String,Integer> getLeadershipChangeCount(long duration,
 TimeUnit unit)

Specified by:

getLeadershipChangeCount in interface LeaderElectionManager

getAveragePollTime

public long getAveragePollTime(TimeUnit timeUnit)

Specified by:

getAveragePollTime in interface LeaderElectionManager

getMinPollTime

public long getMinPollTime(TimeUnit timeUnit)

Specified by:

getMinPollTime in interface LeaderElectionManager

getMaxPollTime

public long getMaxPollTime(TimeUnit timeUnit)

Specified by:

getMaxPollTime in interface LeaderElectionManager

getPollCount

public long getPollCount()

Specified by:

getPollCount in interface LeaderElectionManager

registerPollTime

protected void registerPollTime(long nanos)

Register Poll Time in nanoseconds

Parameters:

nanos - Elapsed System Time in nanoseconds

onLeaderChanged

protected void onLeaderChanged(String roleName)

On Leader Changed register role name changes

Parameters:

roleName - Role Name for leader changes

isParticipating

protected boolean isParticipating(String participantId)

Is specified identifier participating in the election based on null or empty participant identifier

Parameters:

participantId - Participant Identifier

Returns:

Participating status