scheduler

type GaiaScheduler interface {
	Init() error
	SchedulePipeline(p *gaia.Pipeline, args []gaia.Argument) (*gaia.PipelineRun, error)
	SetPipelineJobs(p *gaia.Pipeline) error
}

type Plugin interface {
	// NewPlugin creates a new instance of plugin
	NewPlugin(ca security.CAAPI) Plugin

	// Connect initializes the connection with the execution command
	// and the log path wbere the logs should be stored.
	Connect(command *exec.Cmd, logPath *string) error

	// Execute executes one job of a pipeline.
	Execute(j *gaia.Job) error

	// GetJobs returns all real jobs from the pipeline.
	GetJobs() ([]gaia.Job, error)

	// Close closes the connection and cleansup open file writes.
	Close()
}

type Scheduler struct {
	// contains filtered or unexported fields
}