execution

Sep 8, 2026

Changes in this version

type EventKind

+ const EventContext

type TaskExec

+ OutputPath string

Sep 7, 2026

Changes in this version

+ func Render(command string, params map[string]string) (string, error)

type FuncTask

+ TaskName string

type Input

+ func (i Input) Text(key string) (string, error)

type Registry

+ func (r *Registry) Names() []string

type TaskExec

+ Attempt int

+ RunAttempt int

Sep 6, 2026

Changes in this version

+ func Renderizar(comando string, params map[string]string) (string, error)

+ type Event struct

+ Err error

+ ExitCode int

+ Kind EventKind

+ Message string

+ NodeID string

+ Stream string

+ type EventKind string

+ const EventFailed

+ const EventLog

+ const EventStarted

+ const EventSucceeded

+ type Executor interface

+ Cancel func(ctx context.Context, execID string) error

+ Execute func(ctx context.Context, t TaskExec) (<-chan Event, error)

+ Name func() string

+ type FuncTask struct

+ Fn func(ctx context.Context, in Input) error

+ Nome string

+ func (f FuncTask) Name() string

+ func (f FuncTask) Run(ctx context.Context, in Input) error

+ type Input struct

+ Log func(msg string)

+ NodeID string

+ With map[string]any

+ func (i Input) Texto(chave string) (string, error)

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) Get(nome string) (Task, bool)

+ func (r *Registry) MustRegister(t Task)

+ func (r *Registry) Nomes() []string

+ func (r *Registry) Register(t Task) error

+ type Task interface

+ Name func() string

+ Run func(ctx context.Context, in Input) error

+ type TaskExec struct

+ Action string

+ CPU string

+ CPUMax string

+ Command string

+ Env map[string]string

+ ExecutionID string

+ Image string

+ Memoria string

+ MemoriaMax string

+ NodeID string

+ RunID string

+ Secrets map[string]string

+ Shell bool

+ Tentativa int

+ TentativaDoRun int

+ Timeout time.Duration

+ With map[string]any

+ WorkDir string

+ Workflow string