Versions in this module Expand all Collapse all v1 v1.0.0 May 31, 2024 Changes in this version + func ExecutorIsValid(name string) bool + func Register(name string, register Creator) + type CommandExecutor struct + func (e *CommandExecutor) Kill(sig os.Signal) error + func (e *CommandExecutor) Run() error + func (e *CommandExecutor) SetStderr(out io.Writer) + func (e *CommandExecutor) SetStdout(out io.Writer) + type Creator func(ctx context.Context, step *dag.Step) (Executor, error) + type DockerExecutor struct + func (e *DockerExecutor) Kill(sig os.Signal) error + func (e *DockerExecutor) Run() error + func (e *DockerExecutor) SetStderr(out io.Writer) + func (e *DockerExecutor) SetStdout(out io.Writer) + type Executor interface + Kill func(sig os.Signal) error + Run func() error + SetStderr func(out io.Writer) + SetStdout func(out io.Writer) + func CreateCommandExecutor(ctx context.Context, step *dag.Step) (Executor, error) + func CreateDockerExecutor(ctx context.Context, step *dag.Step) (Executor, error) + func CreateExecutor(ctx context.Context, step *dag.Step) (Executor, error) + func CreateHTTPExecutor(ctx context.Context, step *dag.Step) (Executor, error) + func CreateJqExecutor(ctx context.Context, step *dag.Step) (Executor, error) + func CreateMailExecutor(ctx context.Context, step *dag.Step) (Executor, error) + func CreateSSHExecutor(ctx context.Context, step *dag.Step) (Executor, error) + type HTTPConfig struct + Body string + Headers map[string]string + Queries map[string]string + Silent bool + Timeout int + type HTTPExecutor struct + func (e *HTTPExecutor) Kill(sig os.Signal) error + func (e *HTTPExecutor) Run() error + func (e *HTTPExecutor) SetStderr(out io.Writer) + func (e *HTTPExecutor) SetStdout(out io.Writer) + type JqConfig struct + Raw bool + type JqExecutor struct + func (e *JqExecutor) Kill(sig os.Signal) error + func (e *JqExecutor) Run() error + func (e *JqExecutor) SetStderr(out io.Writer) + func (e *JqExecutor) SetStdout(out io.Writer) + type MailConfig struct + From string + Message string + Subject string + To string + type MailExecutor struct + func (e *MailExecutor) Kill(sig os.Signal) error + func (e *MailExecutor) Run() error + func (e *MailExecutor) SetStderr(out io.Writer) + func (e *MailExecutor) SetStdout(out io.Writer) + type SSHConfig struct + IP string + Key string + Port int + StrictHostKeyChecking bool + User string + type SSHExecutor struct + func (e *SSHExecutor) Kill(sig os.Signal) error + func (e *SSHExecutor) Run() error + func (e *SSHExecutor) SetStderr(out io.Writer) + func (e *SSHExecutor) SetStdout(out io.Writer)
Go to main page