daggy

Documentation

Index

• type Filter
  • func (f Filter) Match(element forensicstore.JSONElement) bool
• type Task
• type Workflow
  • func Parse(workflowFile string) (*Workflow, error)
  • func (workflow *Workflow) Run(storeDir string, plugins map[string]*cobra.Command) error
  • func (workflow *Workflow) SetupGraph()

Types

type Filter

type Filter []map[string]string

A Filter is a list of mappings that should be used for a Task.

func (Filter) Match

func (f Filter) Match(element forensicstore.JSONElement) bool

Match tests if an element matches the filter.

type Task

type Task struct {
	Command   string                 `yaml:"command"`
	Arguments map[string]interface{} `yaml:"arguments"`
	Requires  []string               `yaml:"requires"`
}

A Task is a single element in a workflow yml file.

type Workflow

type Workflow struct {
	Tasks map[string]Task `yaml:"tasks"`
	// contains filtered or unexported fields
}

Workflow can be used to parse workflow yml files.

func Parse

func Parse(workflowFile string) (*Workflow, error)

Parse reads a workflow file.

func (*Workflow) Run

func (workflow *Workflow) Run(storeDir string, plugins map[string]*cobra.Command) error

Run walks the direct acyclic graph to execute each task.

func (*Workflow) SetupGraph

func (workflow *Workflow) SetupGraph()

SetupGraph creates a direct acyclic graph of tasks.