Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func StartScheduler ¶
StartScheduler creates and starts a new scheduler instance. This is a blocking call and will block the calling go-routine
Types ¶
type ScheduledExecutor ¶
type ScheduledExecutor struct {
// contains filtered or unexported fields
}
ScheduledExecutor used for executing the schedules saved by the native flyte scheduler in the database.
func NewScheduledExecutor ¶
func NewScheduledExecutor(db repositoryInterfaces.SchedulerRepoInterface, workflowExecutorConfig runtimeInterfaces.WorkflowExecutorConfig, scope promutils.Scope, adminServiceClient service.AdminServiceClient) ScheduledExecutor
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package core This is core package for the scheduler which includes
|
Package core This is core package for the scheduler which includes |
|
Package dbapi This package implements the event scheduler interface which is called whenever a launchplan is enabled or disabled.
|
Package dbapi This package implements the event scheduler interface which is called whenever a launchplan is enabled or disabled. |
|
Package executor This package provides an interface to talk to admin for scheduled executions.
|
Package executor This package provides an interface to talk to admin for scheduled executions. |
|
Package identifier This package provides utility functions for creating a unique schedule name and execution name
|
Package identifier This package provides utility functions for creating a unique schedule name and execution name |
|
Package repositories This package provides the interfaces and implementations to save and retrieve schedules and snapshots from the DB.
|
Package repositories This package provides the interfaces and implementations to save and retrieve schedules and snapshots from the DB. |
|
Package snapshoter This package provides the ability to snapshot all the schedules in the scheduler job store and persist them in the DB in GOB binary format.
|
Package snapshoter This package provides the ability to snapshot all the schedules in the scheduler job store and persist them in the DB in GOB binary format. |
Click to show internal directories.
Click to hide internal directories.