Package org.graylog.scheduler

Class JobTriggerUpdate

java.lang.Object

org.graylog.scheduler.JobTriggerUpdate

public abstract class JobTriggerUpdate
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JobTriggerUpdate.Builder

Constructor Summary

Constructors

Constructor	Description
JobTriggerUpdate()

Method Summary

Modifier and Type	Method	Description
static JobTriggerUpdate.Builder	builder()
abstract boolean	concurrencyReschedule()
abstract Optional<JobTriggerData>	data()
abstract Optional<org.joda.time.DateTime>	nextTime()
abstract Optional<JobTriggerStatus>	status()
abstract JobTriggerUpdate.Builder	toBuilder()
static JobTriggerUpdate	withConcurrencyReschedule(org.joda.time.DateTime nextTime)	Reschedule a trigger because of a concurrency rejection.
static JobTriggerUpdate	withError(JobTriggerDto trigger)
static JobTriggerUpdate	withNextTime(org.joda.time.DateTime nextTime)
static JobTriggerUpdate	withNextTimeAndData(org.joda.time.DateTime nextTime, JobTriggerData data)
static JobTriggerUpdate	withoutNextTime()	Create job trigger update without next time.
static JobTriggerUpdate	withStatusAndNoNextTime(JobTriggerStatus status)

Methods inherited from class java.lang.Object

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

Constructor Details

JobTriggerUpdate

public JobTriggerUpdate()

Method Details

nextTime

public abstract Optional<org.joda.time.DateTime> nextTime()

data

public abstract Optional<JobTriggerData> data()

status

public abstract Optional<JobTriggerStatus> status()

concurrencyReschedule

public abstract boolean concurrencyReschedule()

withNextTime

public static JobTriggerUpdate withNextTime(org.joda.time.DateTime nextTime)

withConcurrencyReschedule

public static JobTriggerUpdate withConcurrencyReschedule(org.joda.time.DateTime nextTime)

Reschedule a trigger because of a concurrency rejection.

Parameters:

nextTime - the next time the trigger should be retried

Returns:

the job trigger update

withoutNextTime

public static JobTriggerUpdate withoutNextTime()

Create job trigger update without next time. That means the trigger will not be scheduled anymore and will be marked as JobTriggerStatus.COMPLETE.

Returns:

the job trigger update object

withError

public static JobTriggerUpdate withError(JobTriggerDto trigger)

withStatusAndNoNextTime

public static JobTriggerUpdate withStatusAndNoNextTime(JobTriggerStatus status)

withNextTimeAndData

public static JobTriggerUpdate withNextTimeAndData(org.joda.time.DateTime nextTime,
 JobTriggerData data)

builder

public static JobTriggerUpdate.Builder builder()

toBuilder

public abstract JobTriggerUpdate.Builder toBuilder()