com.netflix.genie.web.tasks.leader

Class ClusterCheckerTask

java.lang.Object

com.netflix.genie.web.tasks.GenieTask

com.netflix.genie.web.tasks.leader.LeadershipTask

com.netflix.genie.web.tasks.leader.ClusterCheckerTask

All Implemented Interfaces:

java.lang.Runnable

public class ClusterCheckerTask
extends LeadershipTask

A task which checks to see if this leader node can communicate with all other nodes in the cluster. If it can't it will keep track of which nodes it can't communicate with and perform various actions based on the number of times it can't communicate with that node. Currently (as of 3.0) this task will mark jobs as lost if they miss a certain number of checks.

Since:

3.0.0

Constructor Summary

Constructors

Constructor and Description

ClusterCheckerTask(@NotNull GenieHostInfo genieHostInfo, @NotNull ClusterCheckerProperties properties, @NotNull JobSearchService jobSearchService, @NotNull JobPersistenceService jobPersistenceService, @NotNull AgentConnectionPersistenceService agentConnectionPersistenceService, @NotNull org.springframework.web.client.RestTemplate restTemplate, @NotNull org.springframework.boot.actuate.autoconfigure.endpoint.web.WebEndpointProperties webEndpointProperties, @NotNull io.micrometer.core.instrument.MeterRegistry registry) Constructor.

Method Summary

Modifier and Type	Method and Description
void	cleanup() Any cleanup that needs to be performed when this task is stopped due to leadership being revoked.
long	getFixedRate() Get how long the system should wait between invoking the run() method of this task in milliseconds.
GenieTaskScheduleType	getScheduleType() Get the type of scheduling mechanism which should be used to schedule this task.
void	run() Ping the health check endpoint of all other nodes which have running jobs.

Methods inherited from class com.netflix.genie.web.tasks.GenieTask

getFixedDelay, getTrigger

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterCheckerTask

public ClusterCheckerTask(@NotNull
                          @NotNull GenieHostInfo genieHostInfo,
                          @NotNull
                          @NotNull ClusterCheckerProperties properties,
                          @NotNull
                          @NotNull JobSearchService jobSearchService,
                          @NotNull
                          @NotNull JobPersistenceService jobPersistenceService,
                          @NotNull
                          @NotNull AgentConnectionPersistenceService agentConnectionPersistenceService,
                          @NotNull
                          @NotNull org.springframework.web.client.RestTemplate restTemplate,
                          @NotNull
                          @NotNull org.springframework.boot.actuate.autoconfigure.endpoint.web.WebEndpointProperties webEndpointProperties,
                          @NotNull
                          @NotNull io.micrometer.core.instrument.MeterRegistry registry)

Constructor.

Parameters:

genieHostInfo - Information about the host this Genie process is running on

properties - The properties to use to configure the task

jobSearchService - The job search service to use

jobPersistenceService - The job persistence service to use

agentConnectionPersistenceService - The agent connections persistence service

restTemplate - The rest template for http calls

webEndpointProperties - The properties where Spring actuator is running

registry - The spectator registry for getting metrics

Method Detail

run

public void run()

Ping the health check endpoint of all other nodes which have running jobs. Track results.

getScheduleType

public GenieTaskScheduleType getScheduleType()

Get the type of scheduling mechanism which should be used to schedule this task.

Specified by:

getScheduleType in class GenieTask

Returns:

The schedule type

getFixedRate

public long getFixedRate()

Get how long the system should wait between invoking the run() method of this task in milliseconds.

Overrides:

getFixedRate in class GenieTask

Returns:

The period to wait between invocations of run for this task

cleanup

public void cleanup()

Any cleanup that needs to be performed when this task is stopped due to leadership being revoked.

Overrides:

cleanup in class LeadershipTask