Versions in this module Expand all Collapse all v1 v1.27.1 Apr 30, 2026 v1.27.0 Apr 30, 2026 Changes in this version + const Hostname + var Execute = Def + type Client struct + func NewClient(caller service.Publisher) Client + func (_c Client) Execute(ctx context.Context, cmd string, workDir string, stdin string, ...) (exitCode int, stdout string, stderr string, err error) + func (_c Client) ForHost(host string) Client + func (_c Client) WithOptions(opts ...pub.Option) Client + type Def struct + Method string + Route string + func (d Def) URL() string + type ExecuteIn struct + Cmd string + Envars map[string]string + Stdin string + WorkDir string + type ExecuteOut struct + ExitCode int + Stderr string + Stdout string + type ExecuteResponse multicastResponse + func (_res *ExecuteResponse) Get() (exitCode int, stdout string, stderr string, err error) + type Executor struct + func NewExecutor(caller service.Publisher) Executor + func (_c Executor) ForHost(host string) Executor + func (_c Executor) WithInputFlow(flow *workflow.Flow) Executor + func (_c Executor) WithOptions(opts ...pub.Option) Executor + func (_c Executor) WithOutputFlow(flow *workflow.Flow) Executor + func (_c Executor) WithWorkflowRunner(runner WorkflowRunner) Executor + type Hook struct + func NewHook(listener service.Subscriber) Hook + func (c Hook) ForHost(host string) Hook + func (c Hook) WithOptions(opts ...sub.Option) Hook + type MulticastClient struct + func NewMulticastClient(caller service.Publisher) MulticastClient + func (_c MulticastClient) Execute(ctx context.Context, cmd string, workDir string, stdin string, ...) iter.Seq[*ExecuteResponse] + func (_c MulticastClient) ForHost(host string) MulticastClient + func (_c MulticastClient) WithOptions(opts ...pub.Option) MulticastClient + type MulticastTrigger struct + func NewMulticastTrigger(caller service.Publisher) MulticastTrigger + func (_c MulticastTrigger) ForHost(host string) MulticastTrigger + func (_c MulticastTrigger) WithOptions(opts ...pub.Option) MulticastTrigger + type WorkflowRunner interface + Run func(ctx context.Context, workflowName string, initialState any) (status string, state map[string]any, err error)
Go to main page