Type Members

1.  case class CronScheduleProperty(labelOrCronExpr: String) extends SingleScheduleProperty with Product with Serializable
2.  case class CronSchedulePropertyExtractor(propertyName: String = CronPropertyDefaultName) extends SchedulePropertyExtractor with LazyLogging with Product with Serializable
3.  class DeploymentActor extends Actor with Timers with LazyLogging
4.  case class DeploymentRetryConfig(deployMaxRetries: Int = 0, deployRetryPenalize: FiniteDuration = Duration.Zero) extends Product with Serializable

   Periodic Flink scenarios deployment retry configuration.

   Periodic Flink scenarios deployment retry configuration. Used by PeriodicBatchConfig This config is only for retries of failures during scenario deployment. Failure recovery of running scenario should be handled by Flink's restart strategy.

   deployMaxRetries

   Maximum amount of retries for failed deployment. Default is zero.

   deployRetryPenalize

   An amount of time by which the next retry should be delayed. Default is zero.

5.  class FlinkPeriodicDeploymentManagerProvider extends DeploymentManagerProvider with LazyLogging
6.  case class MultipleScheduleProperty(schedules: Map[String, SingleScheduleProperty]) extends ScheduleProperty with Product with Serializable
7.  case class PeriodicBatchConfig(db: Config, processingType: String, rescheduleCheckInterval: FiniteDuration = 13 seconds, deployInterval: FiniteDuration = 17 seconds, deploymentRetry: DeploymentRetryConfig, executionConfig: PeriodicExecutionConfig, jarsDir: String) extends Product with Serializable

   Periodic Flink scenarios deployment configuration.

   Periodic Flink scenarios deployment configuration.

   db

   Nussknacker db configuration.

   processingType

   processing type of scenarios to be managed by this instance of the periodic engine.

   rescheduleCheckInterval

   RescheduleFinishedActor check interval.

   deployInterval

   DeploymentActor check interval.

   deploymentRetry

   DeploymentRetryConfig for deployment failure recovery.

   jarsDir

   Directory for jars storage.

8.  trait PeriodicCustomActionsProvider extends AnyRef
9.  trait PeriodicCustomActionsProviderFactory extends AnyRef
10.  class PeriodicDeploymentManager extends DeploymentManager with LazyLogging
11.  case class PeriodicExecutionConfig(rescheduleOnFailure: Boolean = false) extends Product with Serializable
12.  class PeriodicProcessException extends RuntimeException
13.  class PeriodicProcessService extends LazyLogging
14.  class PeriodicProcessStateDefinitionManager extends OverridingProcessStateDefinitionManager
15.  class RescheduleFinishedActor extends Actor with Timers with LazyLogging
16.  sealed trait ScheduleProperty extends AnyRef
17.  trait SchedulePropertyExtractor extends AnyRef
18.  trait SchedulePropertyExtractorFactory extends AnyRef
19.  sealed trait SingleScheduleProperty extends ScheduleProperty
20.  class WithRunNowPeriodicCustomActionsProviderFactory extends PeriodicCustomActionsProviderFactory