execution

type Event struct {
	Kind     EventKind
	NodeID   string
	Message  string
	Stream   string // "stdout" | "stderr"
	ExitCode int
	Err      error
}

type EventKind string

type Executor interface {
	Name() string
	Execute(ctx context.Context, t TaskExec) (<-chan Event, error)
	Cancel(ctx context.Context, execID string) error
}

type FuncTask struct {
	Nome string
	Fn   func(ctx context.Context, in Input) error
}

type Input struct {
	NodeID string
	With   map[string]any

	// Log emite uma linha para o fluxo de eventos. Existe para que a task
	// reporte progresso sem conhecer canais nem o executor.
	Log func(msg string)
}

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

type Task interface {
	Name() string
	Run(ctx context.Context, in Input) error
}

type TaskExec struct {
	ExecutionID string
	NodeID      string

	// Workflow, RunID e Tentativa nao mudam a execucao — identificam-na. Em
	// Kubernetes viram rotulos do pod, e sao eles que permitem achar "os pods
	// daquela run" sem procurar por nome.
	Workflow string
	RunID    string

	// Tentativa do PASSO, dentro de uma execucao do run.
	Tentativa int

	// TentativaDoRun e a do RUN, contada pelo dispatcher. As duas entram no
	// nome do pod: sem a segunda, um retry do dispatcher recria o run do zero
	// (passo na tentativa 0 de novo) e reencontra o pod anterior.
	TentativaDoRun int

	Command string // shell, para o ProcessExecutor
	Action  string // nome no registry, para o GoExecutor
	With    map[string]any

	// Image e o runtime deste passo. Vazia no modo local (o comando roda na
	// propria instancia); obrigatoria em Kubernetes, onde ela E o pod.
	Image string

	// Shell decide entre `sh -c "linha"` e argv direto. Importa para imagem
	// distroless, que nao tem shell nenhum.
	Shell bool

	// Recursos do pod, no formato do Kubernetes. Ignorados no modo local, onde
	// o limite de um processo e o da maquina.
	CPU, Memoria       string
	CPUMax, MemoriaMax string

	WorkDir string
	Env     map[string]string

	// Secrets sao variaveis cujo valor o motor NAO carrega: o mapa e
	// nome-da-variavel -> `nome-do-secret/chave`, e quem resolve e o executor.
	//
	// Ficam separadas de Env por isso mesmo. Se o valor viesse resolvido aqui,
	// ele passaria pelo dispatcher, pelo log de montagem da task e por
	// qualquer dump de TaskExec que alguem escrever depois.
	Secrets map[string]string

	// Timeout zero significa sem limite. A secao 37 pede timeout na PHASE 3;
	// deixar o padrao aberto e deliberado — impor um limite arbitrario mataria
	// tasks legitimamente longas.
	Timeout time.Duration
}