Class AgentJobCleanupTask

  • All Implemented Interfaces:
    java.lang.Runnable

    public class AgentJobCleanupTask
    extends LeaderTask
    Leader task that cleans up jobs whose agent crashed or disconnected.
    Since:
    4.0.0
    • Constructor Detail

      • AgentJobCleanupTask

        public AgentJobCleanupTask​(DataServices dataServices,
                                   AgentCleanupProperties properties,
                                   io.micrometer.core.instrument.MeterRegistry registry,
                                   AgentRoutingService agentRoutingService)
        Constructor.
        Parameters:
        dataServices - The DataServices encapsulation instance to use
        properties - the task properties
        registry - the metrics registry
        agentRoutingService - the agent routing service
    • Method Detail

      • run

        public void run()
      • 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 LeaderTask
      • 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