executor

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

type Creator func(ctx context.Context, step *dag.Step) (Executor, error)

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

type Executor interface {
	SetStdout(out io.Writer)
	SetStderr(out io.Writer)
	Kill(sig os.Signal) error
	Run() error
}

type HTTPConfig struct {
	Timeout     int               `json:"timeout"`
	Headers     map[string]string `json:"headers"`
	QueryParams map[string]string `json:"query"`
	Body        string            `json:"body"`
	Silent      bool              `json:"silent"`
}

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

type JqConfig struct {
	Raw bool `mapstructure:"raw"`
}

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

type MailConfig struct {
	From    string `mapstructure:"from"`
	To      string `mapstructure:"to"`
	Subject string `mapstructure:"subject"`
	Message string `mapstructure:"message"`
}

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

type SSHConfig struct {
	User                  string
	IP                    string
	Port                  int
	Key                   string
	StrictHostKeyChecking bool
}

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

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