package service

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. trait AdditionalDeploymentDataProvider extends AnyRef
  2. case class DeployedEvent(deployment: PeriodicProcessDeployment[CanonicalProcess], externalDeploymentId: Option[ExternalDeploymentId]) extends PeriodicProcessEvent with Product with Serializable
  3. trait EmptyListener extends PeriodicProcessListener
  4. case class FailedOnDeployEvent(deployment: PeriodicProcessDeployment[CanonicalProcess], processState: Option[StatusDetails]) extends PeriodicProcessEvent with Product with Serializable
  5. case class FailedOnRunEvent(deployment: PeriodicProcessDeployment[CanonicalProcess], processState: Option[StatusDetails]) extends PeriodicProcessEvent with Product with Serializable
  6. case class FinishedEvent(deployment: PeriodicProcessDeployment[CanonicalProcess], processState: Option[StatusDetails]) extends PeriodicProcessEvent with Product with Serializable
  7. sealed trait PeriodicProcessEvent extends AnyRef
  8. trait PeriodicProcessListener extends AnyRef
  9. trait PeriodicProcessListenerFactory extends AnyRef
  10. trait ProcessConfigEnricher extends AnyRef

    Use to enrich scenario config e.g.

    Use to enrich scenario config e.g. with a schedule name that can be later exposed as a global variable. Other use case could be fetching some data specific for a scenario to be used later when starting job on Flink cluster.

    Please note config to enrich is not final scenario config. This config is only passed to Flink during deployment. Consult pl.touk.nussknacker.engine.modelconfig.InputConfigDuringExecution and pl.touk.nussknacker.engine.modelconfig.ModelConfigLoader for details.

    Config enriched on initial schedule is passed to onDeploy method.

  11. trait ProcessConfigEnricherFactory extends AnyRef
  12. case class ScheduledEvent(deployment: PeriodicProcessDeployment[CanonicalProcess], firstSchedule: Boolean) extends PeriodicProcessEvent with Product with Serializable

Value Members

  1. object DefaultAdditionalDeploymentDataProvider extends AdditionalDeploymentDataProvider
  2. object EmptyListener extends EmptyListener
  3. object EmptyPeriodicProcessListenerFactory extends PeriodicProcessListenerFactory
  4. object ProcessConfigEnricher
  5. object ProcessConfigEnricherFactory

Ungrouped