install

type ExecutionContext struct {
	BundleRoot   string
	StatePath    string
	Context      workflowcontext.Context
	Interaction  operatorio.Interface
	SecretValues []string
	// contains filtered or unexported fields
}

type RunOptions struct {
	BundleRoot           string
	StatePath            string
	StateMetadata        StateMetadata
	DisableStateFallback bool
	StateMigrationSink   func(source string, target string)
	Context              workflowcontext.Context
	EventSink            StepEventSink
	Fresh                bool
	Interaction          operatorio.Interface
	NonInteractive       bool
	// contains filtered or unexported fields
}

type RuntimeSecret struct {
	Phase  string `json:"phase,omitempty"`
	StepID string `json:"stepID,omitempty"`
	Output string `json:"output,omitempty"`
}

type State struct {
	Version         int                      `json:"-"`
	Kind            string                   `json:"-"`
	StateKey        string                   `json:"-"`
	Workflow        StateWorkflow            `json:"-"`
	Status          string                   `json:"-"`
	CreatedAt       string                   `json:"-"`
	UpdatedAt       string                   `json:"-"`
	Phase           string                   `json:"phase,omitempty"`
	CompletedPhases []string                 `json:"completedPhases,omitempty"`
	FailedPhase     string                   `json:"failedPhase,omitempty"`
	RuntimeVars     map[string]any           `json:"runtimeVars,omitempty"`
	RuntimeSecrets  map[string]RuntimeSecret `json:"runtimeSecrets,omitempty"`
	Error           string                   `json:"error,omitempty"`
}

type StateMetadata struct {
	StateKey string
	Workflow StateWorkflow
	Now      func() time.Time
}

type StateWorkflow struct {
	Path   string `json:"path,omitempty"`
	Source string `json:"source,omitempty"`
	SHA256 string `json:"sha256,omitempty"`
}

type StepEvent struct {
	InvocationID   string
	Event          string
	StepID         string
	Kind           string
	Phase          string
	Status         string
	Reason         string
	Attempt        int
	StartedAt      string
	EndedAt        string
	Error          string
	BatchID        string
	ParallelGroup  string
	Parallel       bool
	BatchSize      int
	MaxParallelism int
	FailedStep     string
}

type StepEventSink func(StepEvent)