Package com.github.kagkarlsson.scheduler.stats

Class StatsRegistryAdapter

java.lang.Object

com.github.kagkarlsson.scheduler.stats.StatsRegistryAdapter

All Implemented Interfaces:

SchedulerListener

public class StatsRegistryAdapter
extends Object
implements SchedulerListener

Nested Class Summary

Nested classes/interfaces inherited from interface com.github.kagkarlsson.scheduler.event.SchedulerListener

SchedulerListener.CandidateEventType, SchedulerListener.SchedulerEventType

Field Summary

Fields inherited from interface com.github.kagkarlsson.scheduler.event.SchedulerListener

NOOP

Constructor Summary

Constructors

Constructor	Description
StatsRegistryAdapter(StatsRegistry statsRegistry)

Method Summary

Modifier and Type	Method	Description
void	onCandidateEvent(SchedulerListener.CandidateEventType type)	Internal scheduler event.
void	onExecutionComplete(ExecutionComplete executionComplete)	ExecutionHandler done.
void	onExecutionDead(Execution execution)	Scheduler has detected a dead execution.
void	onExecutionFailedHeartbeat(CurrentlyExecuting currentlyExecuting)	Scheduler failed to update heartbeat-timestamp for execution that it is currently executing.
void	onExecutionScheduled(TaskInstanceId taskInstanceId, Instant executionTime)	Execution scheduled either by the SchedulerClient or by a CompletionHandler
void	onExecutionStart(CurrentlyExecuting currentlyExecuting)	Execution picked and ExecutionHandler about to run.
void	onSchedulerEvent(SchedulerListener.SchedulerEventType type)	Internal scheduler event.

Methods inherited from class java.lang.Object

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

Constructor Details

StatsRegistryAdapter

public StatsRegistryAdapter(StatsRegistry statsRegistry)

Method Details

onExecutionScheduled

public void onExecutionScheduled(TaskInstanceId taskInstanceId,
 Instant executionTime)

Description copied from interface: SchedulerListener

Execution scheduled either by the SchedulerClient or by a CompletionHandler

Specified by:

onExecutionScheduled in interface SchedulerListener

onExecutionStart

public void onExecutionStart(CurrentlyExecuting currentlyExecuting)

Description copied from interface: SchedulerListener

Execution picked and ExecutionHandler about to run. Will typically run in the same thread as onExecutionComplete

Specified by:

onExecutionStart in interface SchedulerListener

onExecutionComplete

public void onExecutionComplete(ExecutionComplete executionComplete)

Description copied from interface: SchedulerListener

ExecutionHandler done. Will typically run in the same thread as onExecutionStart

Specified by:

onExecutionComplete in interface SchedulerListener

onExecutionDead

public void onExecutionDead(Execution execution)

Description copied from interface: SchedulerListener

Scheduler has detected a dead execution. About to run DeadExecutionHandler.

Specified by:

onExecutionDead in interface SchedulerListener

onExecutionFailedHeartbeat

public void onExecutionFailedHeartbeat(CurrentlyExecuting currentlyExecuting)

Description copied from interface: SchedulerListener

Scheduler failed to update heartbeat-timestamp for execution that it is currently executing. Multiple failures will eventually lead to the execution being declared dead (and its DeadExecutionHandler triggered).

Specified by:

onExecutionFailedHeartbeat in interface SchedulerListener

onSchedulerEvent

public void onSchedulerEvent(SchedulerListener.SchedulerEventType type)

Description copied from interface: SchedulerListener

Internal scheduler event. Primarily intended for testing.

Specified by:

onSchedulerEvent in interface SchedulerListener

onCandidateEvent

public void onCandidateEvent(SchedulerListener.CandidateEventType type)

Description copied from interface: SchedulerListener

Internal scheduler event. Primarily intended for testing.

Specified by:

onCandidateEvent in interface SchedulerListener