scheduler

Documentation

Index

• func Cleaner(nbToKeep int)
• func CleanerRun(nbToKeep int) ([]sdk.PipelineSchedulerExecution, error)
• func Delete(db gorp.SqlExecutor, s *sdk.PipelineScheduler) error
• func DeleteExecution(db gorp.SqlExecutor, s *sdk.PipelineSchedulerExecution) error
• func Executer()
• func ExecuterRun() ([]sdk.PipelineSchedulerExecution, error)
• func GetByApplication(db gorp.SqlExecutor, app *sdk.Application) ([]sdk.PipelineScheduler, error)
• func GetByApplicationPipeline(db gorp.SqlExecutor, app *sdk.Application, pip *sdk.Pipeline) ([]sdk.PipelineScheduler, error)
• func GetByApplicationPipelineEnv(db gorp.SqlExecutor, app *sdk.Application, pip *sdk.Pipeline, ...) ([]sdk.PipelineScheduler, error)
• func GetByPipeline(db gorp.SqlExecutor, pip *sdk.Pipeline) ([]sdk.PipelineScheduler, error)
• func Initialize(nbExecToKeep int)
• func Insert(db gorp.SqlExecutor, s *sdk.PipelineScheduler) error
• func InsertExecution(db gorp.SqlExecutor, s *sdk.PipelineSchedulerExecution) error
• func Load(db gorp.SqlExecutor, id int64) (*sdk.PipelineScheduler, error)
• func LoadAll(db gorp.SqlExecutor) ([]sdk.PipelineScheduler, error)
• func LoadExecutions(db gorp.SqlExecutor, schedulerID int64) ([]sdk.PipelineSchedulerExecution, error)
• func LoadLastExecutedExecution(db gorp.SqlExecutor, id int64) (*sdk.PipelineSchedulerExecution, error)
• func LoadLastExecution(db gorp.SqlExecutor, id int64) (*sdk.PipelineSchedulerExecution, error)
• func LoadNextExecution(db gorp.SqlExecutor, id int64) (*sdk.PipelineSchedulerExecution, error)
• func LoadPastExecutions(db gorp.SqlExecutor, id int64) ([]sdk.PipelineSchedulerExecution, error)
• func LoadPendingExecutions(db gorp.SqlExecutor) ([]sdk.PipelineSchedulerExecution, error)
• func LoadUnscheduledPipelines(db gorp.SqlExecutor) ([]sdk.PipelineScheduler, error)
• func LockPipelineExecutions(db gorp.SqlExecutor) error
• func New(app *sdk.Application, pip *sdk.Pipeline, env *sdk.Environment, cron string, ...) (*sdk.PipelineScheduler, error)
• func Next(db gorp.SqlExecutor, s *sdk.PipelineScheduler) (*sdk.PipelineSchedulerExecution, error)
• func Run() ([]sdk.PipelineSchedulerExecution, string, error)
• func Scheduler()
• func Status() string
• func Update(db gorp.SqlExecutor, s *sdk.PipelineScheduler) error
• func UpdateExecution(db gorp.SqlExecutor, s *sdk.PipelineSchedulerExecution) error

Functions

func Cleaner

func Cleaner(nbToKeep int)

Cleaner is the cleaner main goroutine

func CleanerRun

func CleanerRun(nbToKeep int) ([]sdk.PipelineSchedulerExecution, error)

CleanerRun is the core function of the cleaner goroutine

func Delete

func Delete(db gorp.SqlExecutor, s *sdk.PipelineScheduler) error

Delete a pipeline scheduler

func DeleteExecution

func DeleteExecution(db gorp.SqlExecutor, s *sdk.PipelineSchedulerExecution) error

DeleteExecution deletes executions

func Executer

func Executer()

Executer is the goroutine which run the pipelines

func ExecuterRun

func ExecuterRun() ([]sdk.PipelineSchedulerExecution, error)

ExecuterRun is the core function of Executer goroutine

func GetByApplication

func GetByApplication(db gorp.SqlExecutor, app *sdk.Application) ([]sdk.PipelineScheduler, error)

GetByApplication get all pipeline schedulers for an application

func GetByApplicationPipeline

func GetByApplicationPipeline(db gorp.SqlExecutor, app *sdk.Application, pip *sdk.Pipeline) ([]sdk.PipelineScheduler, error)

GetByApplicationPipeline get all pipeline schedulers for a application/pipeline

func GetByApplicationPipelineEnv

func GetByApplicationPipelineEnv(db gorp.SqlExecutor, app *sdk.Application, pip *sdk.Pipeline, env *sdk.Environment) ([]sdk.PipelineScheduler, error)

GetByApplicationPipelineEnv get all pipeline schedulers for a application/pipeline

func GetByPipeline

func GetByPipeline(db gorp.SqlExecutor, pip *sdk.Pipeline) ([]sdk.PipelineScheduler, error)

GetByPipeline get all pipeline schedulers for a pipeline

func Initialize

func Initialize(nbExecToKeep int)

Initialize starts the 3 goroutines for pipeline schedulers

func Insert

func Insert(db gorp.SqlExecutor, s *sdk.PipelineScheduler) error

Insert a pipeline scheduler

func InsertExecution

func InsertExecution(db gorp.SqlExecutor, s *sdk.PipelineSchedulerExecution) error

InsertExecution a pipeline scheduler execution

func Load

func Load(db gorp.SqlExecutor, id int64) (*sdk.PipelineScheduler, error)

Load loads a PipelineScheduler by id

func LoadAll

func LoadAll(db gorp.SqlExecutor) ([]sdk.PipelineScheduler, error)

LoadAll retrieves all pipeline scheduler from database

func LoadExecutions

func LoadExecutions(db gorp.SqlExecutor, schedulerID int64) ([]sdk.PipelineSchedulerExecution, error)

LoadExecutions loads all pipeline execution

func LoadLastExecutedExecution

func LoadLastExecutedExecution(db gorp.SqlExecutor, id int64) (*sdk.PipelineSchedulerExecution, error)

LoadLastExecutedExecution loads last pipeline execution

func LoadLastExecution

func LoadLastExecution(db gorp.SqlExecutor, id int64) (*sdk.PipelineSchedulerExecution, error)

LoadLastExecution loads last pipeline execution

func LoadNextExecution

func LoadNextExecution(db gorp.SqlExecutor, id int64) (*sdk.PipelineSchedulerExecution, error)

LoadNextExecution loads next pipeline execution

func LoadPastExecutions

func LoadPastExecutions(db gorp.SqlExecutor, id int64) ([]sdk.PipelineSchedulerExecution, error)

LoadPastExecutions loads all pipeline execution executed prior date 't'

func LoadPendingExecutions

func LoadPendingExecutions(db gorp.SqlExecutor) ([]sdk.PipelineSchedulerExecution, error)

LoadPendingExecutions loads all pipeline execution

func LoadUnscheduledPipelines

func LoadUnscheduledPipelines(db gorp.SqlExecutor) ([]sdk.PipelineScheduler, error)

LoadUnscheduledPipelines loads unscheduled pipelines

func LockPipelineExecutions

func LockPipelineExecutions(db gorp.SqlExecutor) error

LockPipelineExecutions locks table LockPipelineExecutions

func New

func New(app *sdk.Application, pip *sdk.Pipeline, env *sdk.Environment, cron string, args ...sdk.Parameter) (*sdk.PipelineScheduler, error)

New instanciates a new pipeline scheduler

func Next

func Next(db gorp.SqlExecutor, s *sdk.PipelineScheduler) (*sdk.PipelineSchedulerExecution, error)

Next Compute the next PipelineSchedulerExecution

func Run

func Run() ([]sdk.PipelineSchedulerExecution, string, error)

Run is the core function of Scheduler goroutine

func Scheduler

func Scheduler()

Scheduler is the goroutine which compute date of next execution for pipeline scheduler

func Status

func Status() string

Status returns Event status

func Update

func Update(db gorp.SqlExecutor, s *sdk.PipelineScheduler) error

Update a pipeline scheduler

func UpdateExecution

func UpdateExecution(db gorp.SqlExecutor, s *sdk.PipelineSchedulerExecution) error

UpdateExecution a pipeline scheduler execution