executor

May 25, 2024

Changes in this version

type Executor

+ func CreateSubWorkflowExecutor(ctx context.Context, step dag.Step) (Executor, error)

+ type SubWorkflowExecutor struct

+ func (e *SubWorkflowExecutor) Kill(sig os.Signal) error

+ func (e *SubWorkflowExecutor) Run() error

+ func (e *SubWorkflowExecutor) SetStderr(out io.Writer)

+ func (e *SubWorkflowExecutor) SetStdout(out io.Writer)

Sep 10, 2023

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

+ QueryParams 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)