orchestrator

type ExecInInstanceCall struct {
	Namespace  string
	ServiceID  string
	InstanceID string
	Options    types.ExecOptions
	Stream     types.ExecStream
	Error      error
}

type FakeDialCall struct {
	Namespace   string
	InstanceID  string
	ServiceName string
	Port        uint32
}

type FakeOrchestrator struct {

	// Exec-related fields for testing
	ExecStdout   []byte
	ExecStderr   []byte
	ExecExitCode int

	// Track calls for testing
	ExecInInstanceCalls []ExecInInstanceCall

	// Port-forward (RUNE-122)
	DialError    error
	DialCalls    []FakeDialCall
	LastDialPeer net.Conn
	// contains filtered or unexported fields
}

type Orchestrator interface {
	// Lifecycle
	Start(ctx context.Context) error
	Stop() error

	// Service operations
	CreateService(ctx context.Context, service *types.Service) error
	UpdateService(ctx context.Context, service *types.Service) error
	DeleteService(ctx context.Context, request *types.DeletionRequest) (*types.DeletionResponse, error)
	GetService(ctx context.Context, namespace, name string) (*types.Service, error)
	ListServices(ctx context.Context, namespace string) ([]*types.Service, error)

	// Status and monitoring
	GetServiceStatus(ctx context.Context, namespace, name string) (*types.ServiceStatusInfo, error)
	GetInstanceStatus(ctx context.Context, namespace, instanceID string) (*types.InstanceStatusInfo, error)

	// Logs
	GetServiceLogs(ctx context.Context, namespace, name string, opts types.LogOptions) (io.ReadCloser, error)
	GetInstanceLogs(ctx context.Context, namespace, instanceID string, opts types.LogOptions) (io.ReadCloser, error)

	// Execution
	ExecInService(ctx context.Context, namespace, serviceName string, options types.ExecOptions) (types.ExecStream, error)
	ExecInInstance(ctx context.Context, namespace, instanceID string, options types.ExecOptions) (types.ExecStream, error)
	// DebugInInstance spawns an ephemeral inspection sidecar from a
	// Failed instance's template (image, env, mounts) with the
	// entrypoint overridden to `sleep infinity`, then execs the user's
	// command inside it. Cleanup happens on ExecStream.Close.
	DebugInInstance(ctx context.Context, namespace, instanceID string, options types.ExecOptions) (types.ExecStream, error)

	// Port-forward (RUNE-122)
	DialInService(ctx context.Context, namespace, serviceName string, port uint32) (net.Conn, *types.Instance, error)
	DialInInstance(ctx context.Context, namespace, instanceID string, port uint32) (net.Conn, *types.Instance, error)

	// Lifecycle operations
	GetInstanceByID(ctx context.Context, namespace, instanceID string) (*types.Instance, error)
	RestartService(ctx context.Context, namespace, serviceName string) (templateGeneration int64, scale int, err error)
	RestartInstance(ctx context.Context, namespace, instanceID string) error
	StopService(ctx context.Context, namespace, serviceName string) error
	StopInstance(ctx context.Context, namespace, instanceID string) error

	// Deletion operations
	GetDeletionStatus(ctx context.Context, namespace, name string) (*types.DeletionOperation, error)
	ListDeletionOperations(ctx context.Context, namespace string) ([]*types.DeletionOperation, error)

	// Watch operations
	WatchServices(ctx context.Context, namespace string) (<-chan store.WatchEvent, error)

	// Instance operations
	ListInstances(ctx context.Context, namespace string) ([]*types.Instance, error)
	ListRunningInstances(ctx context.Context, namespace string) ([]*types.Instance, error)

	// Scaling operations
	CreateScalingOperation(ctx context.Context, service *types.Service, params types.ScalingOperationParams) error
	GetActiveScalingOperation(ctx context.Context, namespace, serviceName string) (*types.ScalingOperation, error)

	// SetEndpointPublisher wires the networking data plane (RUNE-063).
	// Optional; nil-safe. Call once at startup before Start().
	SetEndpointPublisher(publisher controllers.EndpointPublisher, nodeID string)

	// SetMountResolver wires the agent-side volumes Subsystem (RUNE-069)
	// into the instance controller. Optional; nil-safe. Call once at
	// startup before Start().
	SetMountResolver(resolver controllers.MountResolver)
}

type OrchestratorOptions struct {
	Store         store.Store
	Logger        log.Logger
	RunnerManager manager.IRunnerManager
	WorkerCount   int
	EnableMetrics bool

	// StorageDriverConfigs is the per-driver configuration block parsed from
	// the runefile [storage] table. Key is the driver name as registered in
	// pkg/storage/driver (e.g. "local", "local-host"); value is the opaque
	// configuration map handed to the driver factory. Optional; nil-safe.
	StorageDriverConfigs map[string]map[string]any

	// DefaultStorageClass mirrors the runefile [storage].defaultStorageClass
	// knob. *string so the empty-string case ("no cluster default") is
	// distinguishable from "unset — keep built-in default".
	DefaultStorageClass *string

	// StoragePreserveOnDelete mirrors the runefile [storage].preserveOnDelete
	// knob. When true, the volume controller demotes ReclaimPolicy:delete
	// to retain for volumes provisioned by the in-tree "local" driver.
	StoragePreserveOnDelete bool

	// StorageSecretLookup resolves `secret:...` references inside
	// StorageClass / Volume parameter maps before the storage drivers
	// see them. Wired by cmd/runed against the store-backed SecretRepo.
	// Nil disables resolution; secret-ref-shaped values then fail the
	// containing operation with a clear error. See RUNE-200 PR 3 and
	// pkg/storage/driverparams.
	StorageSecretLookup driverparams.SecretLookup

	// InitialMountResolver, if set, is installed on the InstanceController
	// before the orchestrator's first reconcile tick. cmd/runed passes a
	// never-ready stub here so the period between orchestrator start and
	// the agent-side volumes Subsystem registering its real resolver is
	// treated as "transient — retry" rather than falling back to using
	// Volume.Handle as the bind source (which would be a UUID for cloud
	// drivers). Without this option set, the controller starts with no
	// resolver and uses the dev/test Handle-fallback path — correct for
	// in-process tests, wrong for production where the agent is racing
	// to come up.
	InitialMountResolver controllers.MountResolver

	// EventLog is the persisted event log (RUNE-126 Phase 2). When set,
	// the instance and volume controllers emit status-transition events
	// for `rune describe`. Nil disables emission; controllers and tests
	// keep working unchanged.
	EventLog events.EventLog
}