Packages

c

pl.touk.nussknacker.engine.management.periodic.db

SlickPeriodicProcessesRepository

class SlickPeriodicProcessesRepository extends PeriodicProcessesRepository with PeriodicProcessesTableFactory with PeriodicProcessDeploymentsTableFactory with LazyLogging

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SlickPeriodicProcessesRepository
  2. LazyLogging
  3. PeriodicProcessDeploymentsTableFactory
  4. PeriodicProcessesTableFactory
  5. PeriodicProcessesRepository
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new SlickPeriodicProcessesRepository(db: slick.jdbc.JdbcBackend.DatabaseDef, profile: JdbcProfile, clock: Clock, processingType: String)(implicit ec: ExecutionContext)

Type Members

  1. class PeriodicProcessDeploymentsTable extends slick.jdbc.JdbcProfile.API.Table[PeriodicProcessDeploymentEntity]
    Definition Classes
    PeriodicProcessDeploymentsTableFactory
  2. implicit class RunOps[T] extends AnyRef
    Definition Classes
    PeriodicProcessesRepository
  3. class PeriodicProcessesTable extends slick.jdbc.JdbcProfile.API.Table[PeriodicProcessEntity]
    Definition Classes
    PeriodicProcessesTableFactory
  4. type Action[T] = DBIOAction[T, NoStream, All]
    Definition Classes
    SlickPeriodicProcessesRepository → PeriodicProcessesRepository

Value Members

  1. object PeriodicProcessDeployments extends TableQuery[PeriodicProcessDeploymentsTable]
    Definition Classes
    PeriodicProcessDeploymentsTableFactory
  2. object PeriodicProcesses extends TableQuery[PeriodicProcessesTable]
    Definition Classes
    PeriodicProcessesTableFactory
  3. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def ##(): Int
    Definition Classes
    AnyRef → Any
  5. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native() @HotSpotIntrinsicCandidate()
  8. def create(deploymentWithJarData: DeploymentWithJarData, scheduleProperty: ScheduleProperty): Action[PeriodicProcess]
    Definition Classes
    SlickPeriodicProcessesRepository → PeriodicProcessesRepository
  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  11. def findDeployedOrFailedOnDeploy: Action[Seq[PeriodicProcessDeployment]]
    Definition Classes
    SlickPeriodicProcessesRepository → PeriodicProcessesRepository
  12. def findProcessData(processName: ProcessName): Action[Seq[PeriodicProcess]]
    Definition Classes
    SlickPeriodicProcessesRepository → PeriodicProcessesRepository
  13. def findProcessData(id: PeriodicProcessDeploymentId): Action[PeriodicProcessDeployment]
    Definition Classes
    SlickPeriodicProcessesRepository → PeriodicProcessesRepository
  14. def findScheduled(id: PeriodicProcessId): Action[Seq[PeriodicProcessDeployment]]
    Definition Classes
    SlickPeriodicProcessesRepository → PeriodicProcessesRepository
  15. def findToBeDeployed: Action[Seq[PeriodicProcessDeployment]]
    Definition Classes
    SlickPeriodicProcessesRepository → PeriodicProcessesRepository
  16. def findToBeRetried: Action[Seq[PeriodicProcessDeployment]]
    Definition Classes
    SlickPeriodicProcessesRepository → PeriodicProcessesRepository
  17. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  18. def getLatestDeploymentForEachSchedule(processName: ProcessName): Action[Seq[PeriodicProcessDeployment]]
    Definition Classes
    SlickPeriodicProcessesRepository → PeriodicProcessesRepository
  19. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  20. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  21. lazy val logger: Logger
    Attributes
    protected
    Definition Classes
    LazyLogging
    Annotations
    @transient()
  22. def markDeployed(id: PeriodicProcessDeploymentId): Action[Unit]
    Definition Classes
    SlickPeriodicProcessesRepository → PeriodicProcessesRepository
  23. def markFailed(id: PeriodicProcessDeploymentId): Action[Unit]
    Definition Classes
    SlickPeriodicProcessesRepository → PeriodicProcessesRepository
  24. def markFailedOnDeployWithStatus(id: PeriodicProcessDeploymentId, status: PeriodicProcessDeploymentStatus, retriesLeft: Int, retryAt: Option[LocalDateTime]): Action[Unit]
    Definition Classes
    SlickPeriodicProcessesRepository → PeriodicProcessesRepository
  25. def markFinished(id: PeriodicProcessDeploymentId): Action[Unit]
    Definition Classes
    SlickPeriodicProcessesRepository → PeriodicProcessesRepository
  26. def markInactive(processName: ProcessName): Action[Unit]
    Definition Classes
    SlickPeriodicProcessesRepository → PeriodicProcessesRepository
  27. implicit def monad: Monad[Action]
    Definition Classes
    SlickPeriodicProcessesRepository → PeriodicProcessesRepository
  28. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  29. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  30. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  31. implicit val periodicProcessDeploymentStatusColumnTyped: BaseColumnType[PeriodicProcessDeploymentStatus]
    Definition Classes
    PeriodicProcessDeploymentsTableFactory
  32. val profile: JdbcProfile
    Definition Classes
    SlickPeriodicProcessesRepository → PeriodicProcessDeploymentsTableFactory → PeriodicProcessesTableFactory
  33. def run[T](action: DBIOAction[T, NoStream, All]): Future[T]
    Definition Classes
    SlickPeriodicProcessesRepository → PeriodicProcessesRepository
  34. def schedule(id: PeriodicProcessId, scheduleName: Option[String], runAt: LocalDateTime, deployMaxRetries: Int): Action[PeriodicProcessDeployment]
    Definition Classes
    SlickPeriodicProcessesRepository → PeriodicProcessesRepository
  35. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  36. def toString(): String
    Definition Classes
    AnyRef → Any
  37. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  38. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  39. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] ) @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

Inherited from LazyLogging

Inherited from PeriodicProcessDeploymentsTableFactory

Inherited from PeriodicProcessesTableFactory

Inherited from PeriodicProcessesRepository

Inherited from AnyRef

Inherited from Any

Ungrouped