exec

Documentation

Index

• type CacheReader
• type CacheWriter
• type Executor
  • func NewExecutor(cr CacheReader, cw CacheWriter) *Executor
  • func (e *Executor) ExecuteTask(node *graph.Node, deps map[string]struct{})
  • func (e *Executor) FinalizeResults(t time.Time)

Types

type CacheReader

type CacheReader interface {
	GetCachedResult(dir, name string) (cache.TaskResult, error)
	Validate(node *graph.Node, deps map[string]struct{}) (bool, error)
}

type CacheWriter

type CacheWriter interface {
	WriteTaskResult(dir, name string, res cache.TaskResult) error
	Update() error
}

type Executor

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

func NewExecutor

func NewExecutor(cr CacheReader, cw CacheWriter) *Executor

func (*Executor) ExecuteTask

func (e *Executor) ExecuteTask(node *graph.Node, deps map[string]struct{})

func (*Executor) FinalizeResults

func (e *Executor) FinalizeResults(t time.Time)