models

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

type Engine interface {
	InitWorkflow(twf tangled.Pipeline_Workflow, tpl tangled.Pipeline) (*Workflow, error)
	SetupWorkflow(ctx context.Context, wid WorkflowId, wf *Workflow, wfLogger WorkflowLogger) error
	WorkflowTimeout() time.Duration
	DestroyWorkflow(ctx context.Context, wid WorkflowId) error
	RunStep(ctx context.Context, wid WorkflowId, w *Workflow, idx int, secrets []secrets.UnlockedSecret, wfLogger WorkflowLogger) error
}

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

type LogKind string

type LogLine struct {
	Kind    LogKind   `json:"kind"`
	Content string    `json:"content"`
	Time    time.Time `json:"time"`
	StepId  int       `json:"step_id"`

	// fields if kind is "data"
	Stream string `json:"stream,omitempty"`

	// fields if kind is "control"
	StepStatus  StepStatus `json:"step_status,omitempty"`
	StepKind    StepKind   `json:"step_kind,omitempty"`
	StepCommand string     `json:"step_command,omitempty"`
}

type NullLogger struct{}

type Pipeline struct {
	RepoOwner string
	RepoName  string
	Workflows map[Engine][]Workflow
}

type PipelineId struct {
	Knot string
	Rkey string
}

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

type StatusKind string

type Step interface {
	Name() string
	Command() string
	Kind() StepKind
}

type StepKind int

type StepStatus string

type Workflow struct {
	Steps       []Step
	Name        string
	Data        any
	Environment map[string]string
}

type WorkflowId struct {
	PipelineId
	Name string
}

type WorkflowLogger interface {
	Close() error
	DataWriter(idx int, stream string) io.Writer
	ControlWriter(idx int, step Step, stepStatus StepStatus) io.Writer
}