Documentation
¶
Index ¶
- type ConditionEvaluator
- type DependencyRunner
- func (dr *DependencyRunner) RunDependencies(task *models.Task, dependencies []models.Task) error
- func (dr *DependencyRunner) RunDependenciesWithContext(ctx context.Context, task *models.Task, dependencies []models.Task) error
- func (dr *DependencyRunner) SetContextRunner(runTaskWithCtx func(context.Context, models.Task, ...string) error)
- type Executor
- type HookExecutor
- type PrefixedWriter
- type Runner
- type Shell
- type TaskCache
- type Watcher
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConditionEvaluator ¶ added in v1.0.14
type ConditionEvaluator struct {
// contains filtered or unexported fields
}
func NewConditionEvaluator ¶ added in v1.0.14
func NewConditionEvaluator() *ConditionEvaluator
type DependencyRunner ¶
type DependencyRunner struct {
// contains filtered or unexported fields
}
func NewDependencyRunner ¶
func NewDependencyRunner(runTask func(models.Task, ...string) error, log taskLogger) *DependencyRunner
func (*DependencyRunner) RunDependencies ¶
func (*DependencyRunner) RunDependenciesWithContext ¶ added in v1.0.14
func (*DependencyRunner) SetContextRunner ¶ added in v1.0.14
type Executor ¶
type Executor struct {
DryRun bool
// contains filtered or unexported fields
}
func NewExecutor ¶
func (*Executor) ExecuteHook ¶
func (*Executor) ExecuteTask ¶
type HookExecutor ¶
type HookExecutor struct {
// contains filtered or unexported fields
}
func NewHookExecutor ¶
func NewHookExecutor(hooks map[string]models.Hook, executor *Executor, log taskLogger) *HookExecutor
func (*HookExecutor) ExecuteHooks ¶
func (he *HookExecutor) ExecuteHooks(hookNames []string) error
type PrefixedWriter ¶ added in v1.0.14
type PrefixedWriter struct {
// contains filtered or unexported fields
}
func NewPrefixedWriter ¶ added in v1.0.14
func NewPrefixedWriter(taskName string, isStdout bool) *PrefixedWriter
func (*PrefixedWriter) Close ¶ added in v1.0.14
func (w *PrefixedWriter) Close() error
type Runner ¶
type Shell ¶
type Shell struct {
// contains filtered or unexported fields
}
func (*Shell) GetShellCommand ¶
type TaskCache ¶
type TaskCache struct {
TaskName string `json:"task_name"`
InputsHash string `json:"inputs_hash"`
OutputsHash string `json:"outputs_hash"`
LastRunTime time.Time `json:"last_run_time"`
CommandHash string `json:"command_hash"`
Dependencies []string `json:"dependencies"`
DepHashes map[string]string `json:"dep_hashes"`
}
Click to show internal directories.
Click to hide internal directories.