com.netflix.genie.web.tasks.leader

Class DatabaseCleanupTask

java.lang.Object

com.netflix.genie.web.tasks.GenieTask

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

com.netflix.genie.web.tasks.leader.DatabaseCleanupTask

All Implemented Interfaces:

java.lang.Runnable

public class DatabaseCleanupTask
extends LeadershipTask

A task which will clean up the database of old jobs if desired.

Since:

3.0.0

Constructor Summary

Constructors

Constructor and Description
DatabaseCleanupTask(@NotNull DatabaseCleanupProperties cleanupProperties, @NotNull JobPersistenceService jobPersistenceService, @NotNull ClusterPersistenceService clusterPersistenceService, @NotNull FilePersistenceService filePersistenceService, @NotNull TagPersistenceService tagPersistenceService, @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.
GenieTaskScheduleType	getScheduleType() Get the type of scheduling mechanism which should be used to schedule this task.
org.springframework.scheduling.Trigger	getTrigger() Get the Trigger which this task should be scheduled with.
void	run() Clean out database based on date.

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

getFixedDelay, getFixedRate

Methods inherited from class java.lang.Object

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

Constructor Detail

DatabaseCleanupTask

public DatabaseCleanupTask(@NotNull
                           @NotNull DatabaseCleanupProperties cleanupProperties,
                           @NotNull
                           @NotNull JobPersistenceService jobPersistenceService,
                           @NotNull
                           @NotNull ClusterPersistenceService clusterPersistenceService,
                           @NotNull
                           @NotNull FilePersistenceService filePersistenceService,
                           @NotNull
                           @NotNull TagPersistenceService tagPersistenceService,
                           @NotNull
                           @NotNull io.micrometer.core.instrument.MeterRegistry registry)

Constructor.

Parameters:

cleanupProperties - The properties to use to configure this task

jobPersistenceService - The persistence service to use to cleanup the data store

clusterPersistenceService - The cluster service to use to delete terminated clusters

filePersistenceService - The file service to use to delete unused file references

tagPersistenceService - The tag service to use to delete unused tag references

registry - The metrics registry

Method Detail

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

getTrigger

public org.springframework.scheduling.Trigger getTrigger()

Get the Trigger which this task should be scheduled with.

Overrides:

getTrigger in class GenieTask

Returns:

The trigger

run

public void run()

Clean out database based on date.

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