dag

type BashExecutor struct {
}

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

type DagCondition struct {
	Input      string
	Expression string
	Expected   string
}

type DagContext map[string]any

type DagNode struct {
	Name          string            `json:"name,omitempty"`
	Type          string            `json:"type,omitempty"`
	Command       string            `json:"command,omitempty"`
	Content       string            `json:"content,omitempty"`
	OutputAlias   map[string]string `json:"output_alias,omitempty"` // alias any=$(echo 'hello')
	Headers       map[string]string `json:"headers,omitempty"`      // for http type
	Timeout       int               `json:"timeout,omitempty"`
	Depends       []string          `json:"depends,omitempty"` // dep and condition
	Conditions    []DagCondition    `json:"conditions,omitempty"`
	Debug         bool              `json:"debug,omitempty"`
	Retry         int               `json:"retry,omitempty"`
	RetryWaitTime int               `json:"retry_wait_time,omitempty"`

	// for more context
	PreContext DagContext `json:"-"`
	Next       []*DagNode `json:"-"`
	// contains filtered or unexported fields
}

type DagType string

type Executor interface {
	Execute(string) (string, error)
}

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