Versions in this module Expand all Collapse all v0 v0.4.0 Jan 27, 2017 Changes in this version + func Run() ([]sdk.PipelineSchedulerExecution, string, error) + func Status() string v0.3.0 Jan 12, 2017 Changes in this version + 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 Scheduler() + func SchedulerRun() ([]sdk.PipelineSchedulerExecution, error) + func Update(db gorp.SqlExecutor, s *sdk.PipelineScheduler) error + func UpdateExecution(db gorp.SqlExecutor, s *sdk.PipelineSchedulerExecution) error
Go to main page