controllers

type CreateInstanceCall struct {
	Service      *types.Service
	InstanceName string
	Ordinal      int
}

type DeleteInstanceCall struct {
	Instance *types.Instance
}

type EndpointPublisher interface {
	// PublishService re-publishes the full Endpoint set for a service.
	// `endpoints` may be empty (the service has no running instances)
	// in which case the publisher should clear/Delete.
	PublishService(ctx context.Context, service *types.Service, endpoints []types.Endpoint) error
	// PublishLocalInstances re-publishes the per-node identity table
	// for `nodeID` so that policy enforcement can map source IPs back
	// to a service identity.
	PublishLocalInstances(ctx context.Context, nodeID string, table map[string]types.InstanceIdentity) error
}

type ExecCall struct {
	Instance *types.Instance
	Options  types.ExecOptions
}

type FakeDialControllerCall struct {
	Instance *types.Instance
	Port     uint32
}

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

type FakeInstanceController struct {
	CreateInstanceCalls      []CreateInstanceCall
	RetryCreateInstanceCalls []RetryCreateInstanceCall
	RecreateInstanceCalls    []RecreateInstanceCall
	UpdateInstanceCalls      []UpdateInstanceCall
	StopInstanceCalls        []StopInstanceCall
	DeleteInstanceCalls      []DeleteInstanceCall
	RestartInstanceCalls     []RestartInstanceCall
	GetStatusCalls           []string // Instance IDs
	GetLogsCalls             []string // Instance IDs
	ExecCalls                []ExecCall

	// Port-forward (RUNE-122)
	DialCalls    []FakeDialControllerCall
	DialError    error
	LastDialPeer net.Conn

	// Custom behavior options
	CreateInstanceFunc      func(ctx context.Context, service *types.Service, instanceName string, ordinal int) (*types.Instance, error)
	RetryCreateInstanceFunc func(ctx context.Context, service *types.Service, instance *types.Instance) error
	RecreateInstanceFunc    func(ctx context.Context, service *types.Service, instance *types.Instance) (*types.Instance, error)
	UpdateInstanceFunc      func(ctx context.Context, service *types.Service, instance *types.Instance) error
	StopInstanceFunc        func(ctx context.Context, instance *types.Instance) error
	DeleteInstanceFunc      func(ctx context.Context, instance *types.Instance) error
	RestartInstanceFunc     func(ctx context.Context, instance *types.Instance, reason InstanceRestartReason) error
	GetStatusFunc           func(ctx context.Context, instance *types.Instance) (*types.InstanceStatusInfo, error)
	GetLogsFunc             func(ctx context.Context, instance *types.Instance, opts types.LogOptions) (io.ReadCloser, error)
	ExecFunc                func(ctx context.Context, instance *types.Instance, options types.ExecOptions) (types.ExecStream, error)
	IsCompatibleFunc        func(ctx context.Context, instance *types.Instance, service *types.Service) (bool, string)

	// Default error responses
	CreateInstanceError      error
	RetryCreateInstanceError error
	RecreateInstanceError    error
	UpdateInstanceError      error
	StopInstanceError        error
	DeleteInstanceError      error
	RestartInstanceError     error
	GetStatusError           error
	GetLogsError             error
	ExecError                error

	// Mock responses
	ExecStdout   []byte
	ExecStderr   []byte
	ExecExitCode int
	// contains filtered or unexported fields
}

type HealthController interface {
	// Start the health controller
	Start(ctx context.Context) error

	// Stop the health controller
	Stop() error

	// AddInstance adds an instance to be monitored
	AddInstance(service *types.Service, instance *types.Instance) error

	// RemoveInstance removes an instance from monitoring
	RemoveInstance(instanceID string) error

	// GetHealthStatus gets the current health status of an instance
	GetHealthStatus(ctx context.Context, instanceID string) (*types.InstanceHealthStatus, error)
}

type InstanceController interface {
	// GetInstanceByID gets an instance by ID
	GetInstanceByID(ctx context.Context, namespace, instanceID string) (*types.Instance, error)

	// ListInstances lists all instances in a namespace
	ListInstances(ctx context.Context, namespace string) ([]*types.Instance, error)

	// GetRunningInstances lists all running instances
	ListRunningInstances(ctx context.Context, namespace string) ([]*types.Instance, error)

	// CreateInstance creates a new instance for a service. ordinal is the
	// per-replica slot index assigned by the reconciler; it is stored on the
	// instance and drives per-replica volume claimTemplate binding.
	CreateInstance(ctx context.Context, service *types.Service, instanceName string, ordinal int) (*types.Instance, error)

	// RetryCreateInstance re-runs the create pipeline against an
	// existing record that previously failed in a stuck-in-create
	// state (Status=Failed, ContainerEverCreatedAt==nil). Same UUID,
	// same Name. Called by the reconciler when the stuck record's
	// NextCreateAttemptAt backoff has elapsed.
	RetryCreateInstance(ctx context.Context, service *types.Service, instance *types.Instance) error

	// RecreateInstance recreates an instance
	RecreateInstance(ctx context.Context, service *types.Service, instance *types.Instance) (*types.Instance, error)

	// UpdateInstance updates an existing instance
	UpdateInstance(ctx context.Context, service *types.Service, instance *types.Instance) error

	// StopInstance stops an instance temporarily but keeps it in the store
	StopInstance(ctx context.Context, instance *types.Instance) error

	// DeleteInstance marks an instance for deletion and cleans up runner resources
	// The instance will remain in the store with Deleted status until garbage collection
	DeleteInstance(ctx context.Context, instance *types.Instance) error

	// GetInstanceStatus gets the current status of an instance
	GetInstanceStatus(ctx context.Context, instance *types.Instance) (*types.InstanceStatusInfo, error)

	// GetInstanceLogs gets logs for an instance
	GetInstanceLogs(ctx context.Context, instance *types.Instance, opts types.LogOptions) (io.ReadCloser, error)

	// RestartInstance restarts an instance with respect to the service's restart policy
	RestartInstance(ctx context.Context, instance *types.Instance, reason InstanceRestartReason) error

	// Exec executes a command in a running instance
	// Returns an ExecStream for bidirectional communication
	Exec(ctx context.Context, instance *types.Instance, options types.ExecOptions) (types.ExecStream, error)

	// ExecDebug spawns an ephemeral inspection sidecar from a Failed
	// instance's template (image, env, mounts), with the entrypoint
	// overridden to `sleep infinity`, and execs options.Command inside
	// the sidecar. The sidecar is removed when the returned ExecStream
	// is Closed. The original Failed container is never touched.
	ExecDebug(ctx context.Context, instance *types.Instance, options types.ExecOptions) (types.ExecStream, error)

	// Dial opens a TCP connection to the given port on a running
	// instance (RUNE-122). Returns a net.Conn owned by the caller.
	Dial(ctx context.Context, instance *types.Instance, port uint32) (net.Conn, error)

	// SetEndpointPublisher wires the networking data plane (RUNE-063).
	// May be called once at startup; nil-publisher disables publishing.
	SetEndpointPublisher(publisher EndpointPublisher, nodeID string)

	// SetMountResolver wires the agent-side volumes Subsystem
	// (RUNE-069). May be called once at startup; nil disables
	// resolver-first mount-target lookup and falls back to
	// Volume.Handle.
	SetMountResolver(resolver MountResolver)

	// SetEventLog wires the persisted event log (RUNE-126 Phase 2)
	// so status transitions surface in `rune describe`. Nil-safe.
	SetEventLog(eventLog events.EventLog)

	// RepublishServiceByInstance recomputes the data-plane endpoint set
	// for the service owning the given instance. Exposed for callers
	// outside instanceController that change instance reachability
	// (e.g. the health controller promoting Starting→Running on the
	// first readiness pass). Nil-safe when no endpoint publisher is
	// wired; safe to call repeatedly.
	RepublishServiceByInstance(ctx context.Context, instance *types.Instance)

	// RepublishService refreshes the dataplane endpoint set from
	// current store state (including live container IPs). Safe to
	// call on every reconcile tick.
	RepublishService(ctx context.Context, service *types.Service)
	// contains filtered or unexported methods
}

type InstanceRestartReason string

type MountResolver interface {
	// MountTargetFor returns the host-side mount target for the named
	// volume on this node, plus a presence flag. A false return means
	// the subsystem has not (yet) mounted the volume locally; callers
	// should treat this as a transient "not ready" condition.
	MountTargetFor(volumeID string) (string, bool)
}

type RecreateInstanceCall struct {
	Service  *types.Service
	Instance *types.Instance
}

type RestartInstanceCall struct {
	Instance *types.Instance
	Reason   InstanceRestartReason
}

type RetryCreateInstanceCall struct {
	Service  *types.Service
	Instance *types.Instance
}

type RunningInstance struct {
	Instance   *types.Instance
	IsOrphaned bool
	Runner     types.RunnerType
}

type ScalingController interface {
	// Start the scaling controller
	Start(ctx context.Context) error

	// Stop the scaling controller
	Stop()

	// CreateScalingOperation creates a new scaling operation
	CreateScalingOperation(ctx context.Context, service *types.Service, params types.ScalingOperationParams) error

	// GetActiveOperation gets the active scaling operation for a service
	GetActiveOperation(ctx context.Context, namespace, serviceName string) (*types.ScalingOperation, error)
}

type ServiceController interface {
	Start(ctx context.Context) error
	Stop() error
	GetServiceStatus(ctx context.Context, namespace, name string) (*types.ServiceStatusInfo, error)
	UpdateServiceStatus(ctx context.Context, service *types.Service, status types.ServiceStatus) error
	GetServiceLogs(ctx context.Context, namespace, name string, opts types.LogOptions) (io.ReadCloser, error)
	ExecInService(ctx context.Context, namespace, serviceName string, options types.ExecOptions) (types.ExecStream, error)
	DialInService(ctx context.Context, namespace, serviceName string, port uint32) (net.Conn, *types.Instance, error)
	RestartService(ctx context.Context, namespace, serviceName string) (templateGeneration int64, scale int, err error)
	StopService(ctx context.Context, namespace, serviceName string) error
	DeleteService(ctx context.Context, request *types.DeletionRequest) (*types.DeletionResponse, error)
	GetDeletionStatus(ctx context.Context, namespace, name string) (*types.DeletionOperation, error)
	// contains filtered or unexported methods
}

type ServiceInstanceData struct {
	Instances         []types.Instance
	OrphanedInstances []*types.Instance // Actual orphaned instance objects
}

type SnapshotController interface {
	Start(ctx context.Context) error
	Stop() error
}

type SnapshotControllerOptions struct {
	Store         store.Store
	Logger        log.Logger
	DriverConfigs map[string]map[string]any

	// SecretLookup resolves `secret:...` references inside the
	// merged driver parameters before Snapshot / DeleteSnapshot
	// calls. See RUNE-200 PR 3 and pkg/storage/driverparams.
	SecretLookup driverparams.SecretLookup
}

type StopInstanceCall struct {
	Instance *types.Instance
}

type UpdateInstanceCall struct {
	Service  *types.Service
	Instance *types.Instance
}

type VolumeController interface {
	Start(ctx context.Context) error
	Stop() error

	// SetEventLog wires the persisted event log (RUNE-126 Phase 2)
	// so volume status transitions surface in `rune describe`. Nil-safe.
	SetEventLog(eventLog events.EventLog)
}

type VolumeControllerOptions struct {
	Store         store.Store
	Logger        log.Logger
	DriverConfigs map[string]map[string]any

	// SecretLookup resolves `secret:<name>[.namespace.rune]/<key>`
	// references inside StorageClass / Volume parameters before the
	// controller calls the driver. Wired by cmd/runed against the
	// store-backed SecretRepo so rotation takes effect on the next
	// reconcile. nil disables resolution — secret-ref-shaped values
	// then fail Provision with a clear error (see RUNE-200 PR 3).
	SecretLookup driverparams.SecretLookup

	// DefaultStorageClass mirrors the runefile [storage].defaultStorageClass
	// knob. nil keeps the built-in default ("local"); a non-nil pointer
	// to a non-empty name promotes that class to Default:true at boot
	// (creating it as a no-op marker if needed); a non-nil pointer to
	// the empty string disables the cluster default entirely (any
	// existing Default flag is cleared, and Volumes with empty
	// storageClassName fail to resolve).
	DefaultStorageClass *string

	// PreserveOnDelete, when true, demotes ReclaimPolicy:delete to
	// retain for volumes provisioned by the in-tree "local" driver. Has
	// no effect on other drivers.
	PreserveOnDelete bool

	// Provision retry tuning. Zero values fall back to defaults
	// (5 attempts, 2s base, 30s cap) so existing callers don't need
	// updating.
	MaxProvisionAttempts int
	ProvisionBaseBackoff time.Duration
	ProvisionMaxBackoff  time.Duration
}