runtime

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

type ExecuteOptions struct {
	// Resume enables resume mode for the pipeline.
	Resume bool
	// RunID is the unique identifier for this pipeline run.
	// If resuming, this should match the previous run's ID.
	RunID string
	// PipelineID is the unique identifier for this pipeline.
	// Used to scope resource versions to a specific pipeline.
	PipelineID string
	// Namespace is the namespace for this execution.
	Namespace string
}

type ExecutorOptions struct {
	// Resume enables resume mode for the pipeline.
	Resume bool
	// RunID is the unique identifier for this pipeline run.
	// If resuming, this should match the previous run's ID.
	RunID string
	// PipelineID is the unique identifier for this pipeline.
	// Used to scope resource versions to a specific pipeline.
	PipelineID string
	// Namespace is the namespace for this execution (internal use).
	Namespace string
}

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

type NativeResourceInfo struct {
	Request  json.RawMessage `json:"request"`
	Response json.RawMessage `json:"response"`
}

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

type NotifyConfig struct {
	Type       string            `json:"type"`       // slack, teams, http
	Token      string            `json:"token"`      // For Slack
	Webhook    string            `json:"webhook"`    // For Teams
	URL        string            `json:"url"`        // For HTTP
	Channels   []string          `json:"channels"`   // For Slack
	Headers    map[string]string `json:"headers"`    // For HTTP
	Method     string            `json:"method"`     // For HTTP (defaults to POST)
	Recipients []string          `json:"recipients"` // Generic recipients
}

type NotifyContext struct {
	PipelineName string            `json:"pipelineName"`
	JobName      string            `json:"jobName"`
	BuildID      string            `json:"buildID"`
	Status       string            `json:"status"` // pending, running, success, failure, error
	StartTime    string            `json:"startTime"`
	EndTime      string            `json:"endTime"`
	Duration     string            `json:"duration"`
	Environment  map[string]string `json:"environment"`
	TaskResults  map[string]any    `json:"taskResults"`
}

type NotifyInput struct {
	Name    string `json:"name"`    // Config name (for named configs)
	Message string `json:"message"` // Template message
	Async   bool   `json:"async"`   // Fire-and-forget mode
}

type NotifyResult struct {
	Success bool   `json:"success"`
	Error   string `json:"error,omitempty"`
}

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

type OutputCallback func(stream string, data string)

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

type PipelineState struct {
	// RunID is a unique identifier for this pipeline run.
	RunID string `json:"run_id"`
	// Steps contains the state of each step, keyed by step ID.
	Steps map[string]*StepState `json:"steps"`
	// StepOrder maintains the order in which steps were created.
	StepOrder []string `json:"step_order"`
	// StartedAt is when the pipeline run started.
	StartedAt *time.Time `json:"started_at,omitempty"`
	// CompletedAt is when the pipeline run finished.
	CompletedAt *time.Time `json:"completed_at,omitempty"`
	// ResumeEnabled indicates if resumability was enabled for this run.
	ResumeEnabled bool `json:"resume_enabled"`
}

type ResourceCheckInput struct {
	Type    string                 `json:"type"`
	Source  map[string]interface{} `json:"source"`
	Version map[string]string      `json:"version,omitempty"`
}

type ResourceCheckResult struct {
	Versions []map[string]string `json:"versions"`
}

type ResourceFetchInput struct {
	Type    string                 `json:"type"`
	Source  map[string]interface{} `json:"source"`
	Version map[string]string      `json:"version"`
	Params  map[string]interface{} `json:"params,omitempty"`
	DestDir string                 `json:"destDir"`
}

type ResourceFetchResult struct {
	Version  map[string]string `json:"version"`
	Metadata []struct {
		Name  string `json:"name"`
		Value string `json:"value"`
	} `json:"metadata"`
}

type ResourcePushInput struct {
	Type   string                 `json:"type"`
	Source map[string]interface{} `json:"source"`
	Params map[string]interface{} `json:"params,omitempty"`
	SrcDir string                 `json:"srcDir"`
}

type ResourcePushResult struct {
	Version  map[string]string `json:"version"`
	Metadata []struct {
		Name  string `json:"name"`
		Value string `json:"value"`
	} `json:"metadata"`
}

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

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

type ResumeOptions struct {
	// RunID is the unique identifier for this pipeline run.
	// If resuming, this should match the previous run's ID.
	RunID string
	// Resume indicates whether to attempt resuming a previous run.
	Resume bool
}

type RunInput struct {
	Command struct {
		Path string   `json:"path"`
		Args []string `json:"args"`
		User string   `json:"user"`
	} `json:"command"`
	ContainerLimits struct {
		CPU    int64 `json:"cpu"`
		Memory int64 `json:"memory"`
	} `json:"container_limits"`
	Env        map[string]string       `json:"env"`
	Image      string                  `json:"image"`
	Mounts     map[string]VolumeResult `json:"mounts"`
	Name       string                  `json:"name"`
	Privileged bool                    `json:"privileged"`
	Stdin      string                  `json:"stdin"`
	// OnOutput is called with streaming output chunks as the container runs.
	// If provided, the callback receives (stream, data) where stream is "stdout" or "stderr".
	OnOutput OutputCallback `json:"-"` // Not serialized from JS, set programmatically
	// has to be string because goja doesn't support string -> time.Duration
	Timeout string `json:"timeout"`
}

type RunResult struct {
	Code   int    `json:"code"`
	Stderr string `json:"stderr"`
	Stdout string `json:"stdout"`

	Status RunStatus `json:"status"`
}

type RunStatus string

type Runner interface {
	Run(input RunInput) (*RunResult, error)
	CreateVolume(input VolumeInput) (*VolumeResult, error)
	CleanupVolumes() error
}

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

type StepState struct {
	// StepID is a unique identifier for this step within the pipeline run.
	StepID string `json:"step_id"`
	// Name is the human-readable name of the step.
	Name string `json:"name"`
	// Status is the current execution status.
	Status StepStatus `json:"status"`
	// ContainerID is the driver-specific container identifier (for reattachment).
	ContainerID string `json:"container_id,omitempty"`
	// TaskID is the task identifier used by the orchestrator.
	TaskID string `json:"task_id,omitempty"`
	// StartedAt is when the step started executing.
	StartedAt *time.Time `json:"started_at,omitempty"`
	// CompletedAt is when the step finished (successfully or not).
	CompletedAt *time.Time `json:"completed_at,omitempty"`
	// ExitCode is the container exit code (if completed).
	ExitCode *int `json:"exit_code,omitempty"`
	// Result stores the serialized step result for completed steps.
	Result *RunResult `json:"result,omitempty"`
	// Error stores the error message if the step failed.
	Error string `json:"error,omitempty"`
}

type StepStatus string

type VolumeInput struct {
	Name string `json:"name"`
	Size int    `json:"size"`
}

type VolumeResult struct {
	Name string `json:"name"`
	Path string `json:"path"`
	// contains filtered or unexported fields
}

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