Versions in this module Expand all Collapse all v1 v1.0.0 May 31, 2024 Changes in this version + var EXTENSIONS = []string + func EvalCondition(c *Condition) error + func EvalConditions(cond []*Condition) error + func NewContext(ctx context.Context, dag *DAG) context.Context + func ReadFile(file string) (string, error) + type BuildDAGOptions struct + type Condition struct + Condition string + Expected string + func (c *Condition) CheckResult(actualValue string) error + func (c *Condition) Evaluate() (string, error) + type ContinueOn struct + Failure bool + Skipped bool + type DAG struct + DefaultParams string + Delay time.Duration + Description string + Env []string + ErrorMail *MailConfig + Group string + HandlerOn HandlerOn + HistRetentionDays int + InfoMail *MailConfig + Location string + LogDir string + MailOn *MailOn + MaxActiveRuns int + MaxCleanUpTime time.Duration + Name string + Params []string + Preconditions []*Condition + RestartSchedule []*Schedule + RestartWait time.Duration + Schedule []*Schedule + Smtp *SmtpConfig + Steps []*Step + StopSchedule []*Schedule + Tags []string + func GetDAGFromContext(ctx context.Context) *DAG + func (d *DAG) Clone() *DAG + func (d *DAG) HasTag(tag string) bool + func (d *DAG) SockAddr() string + func (d *DAG) String() string + type DAGBuilder struct + type DAGContextKey struct + type ExecutorConfig struct + Config map[string]interface{} + Type string + type HandlerOn struct + Cancel *Step + Exit *Step + Failure *Step + Success *Step + type Loader struct + BaseConfig string + func (cl *Loader) Load(f, params string) (*DAG, error) + func (cl *Loader) LoadData(data []byte) (*DAG, error) + func (cl *Loader) LoadMetadata(f string) (*DAG, error) + func (cl *Loader) LoadWithoutEval(f string) (*DAG, error) + type MailConfig struct + AttachLogs bool + From string + Prefix string + To string + type MailOn struct + Failure bool + Success bool + type RepeatPolicy struct + Interval time.Duration + Repeat bool + type RetryPolicy struct + Interval time.Duration + Limit int + type Schedule struct + Expression string + Parsed cron.Schedule + type SmtpConfig struct + Host string + Password string + Port string + Username string + type Step struct + Args []string + CmdWithArgs string + Command string + ContinueOn ContinueOn + Depends []string + Description string + Dir string + ExecutorConfig ExecutorConfig + MailOnError bool + Name string + Output string + OutputVariables *utils.SyncMap + Preconditions []*Condition + RepeatPolicy RepeatPolicy + RetryPolicy *RetryPolicy + Script string + SignalOnStop string + Stderr string + Stdout string + Variables []string + func (s *Step) String() string