Returns default instance of Queues which uses ds.SimpleQueue - fixed size buffer queues.

DefaultStarted creates default Scheduler using default configuration and SQLite databases, starts that scheduler and returns HTTP server with Scheduler endpoints.

New returns new instance of Scheduler.

NewClient instantiate new Client.

NewDagRunWatcher creates new instance of DagRunWatcher.

NewTaskScheduler initialize new instance of *TaskScheduler.

ParseState parses State based on given string.

Timeout for HTTP request contexts.

Name for environment variable for setting ppacer default logger severity level.

Default Client configuration.

Default Scheduler configuration.

Default DagRunWatcher configuration.

Default taskScheduler configuration.

Client provides API for interacting with Scheduler.

Config represents main configuration for the Scheduler.

DagRun represents single DAG run.

DagRunTask represents an identifier for a single DAG run task which shall be scheduled.

DagRunTaskState represents DagRunTask state.

DagRunWatcher watches on given list of DAGs and sends information about new DAG runs onto the internal queue when it's time for a new DAG run to be scheduled.

Configuration for DagRunWatcher which is responsible for scheduling new DAG runs based on their schedule.

DRTBase represents base information regarding identification a DAG run task.

Queues contains queues internally needed by the Scheduler.

Scheduler is the title object of this package, it connects all other components together.

TaskScheduler is responsible for scheduling tasks for a single DagRun.

Configuration for TaskScheduler which is responsible for scheduling tasks for particular DAG run.

API defines ppacer Scheduler API.

Signature for function which return current Scheduler state.

State for representing current Scheduler state.