class PruningCronSchedule extends IndividualSchedule with CronSchedule
Pruning-specific cron schedules come with a pruning retention
Linear Supertypes
Known Subclasses
Ordering
- Alphabetic
- By Inheritance
Inherited
- PruningCronSchedule
- CronSchedule
- IndividualSchedule
- EnterpriseSchedule
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new PruningCronSchedule(cron: Cron, maxDuration: PositiveSeconds, retention: PositiveSeconds, clock: Clock, logger: TracedLogger)
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- val cron: Cron
- Definition Classes
- PruningCronSchedule → CronSchedule
- def determineNextRun(result: ScheduledRunResult)(implicit traceContext: TraceContext): Option[NextRun]
Determines how long (at millisecond granularity) to wait before running the next task depending on the result of the previous execution result (affects how soon to retry e.g.
Determines how long (at millisecond granularity) to wait before running the next task depending on the result of the previous execution result (affects how soon to retry e.g. on errors or when there is more work to do).
Returns: 1. time to wait and 2. the specific schedule that corresponds to the most immediate time to wait. This can be used by the scheduler job on which actions to perform depending on the triggering schedule.
- Attributes
- protected[scheduler]
- Definition Classes
- PruningCronSchedule → EnterpriseSchedule
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val maxDuration: PositiveSeconds
- Definition Classes
- PruningCronSchedule → CronSchedule
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- val retention: PositiveSeconds
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def waitDurationUntilNextRun(result: ScheduledRunResult, now: CantonTimestamp, logger: TracedLogger)(implicit traceContext: TraceContext): Option[NonNegativeFiniteDuration]
- Attributes
- protected[scheduler]
- Definition Classes
- CronSchedule