controllers

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

type DeleteInstanceCall struct {
	Instance *types.Instance
}

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

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

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

	// Custom behavior options
	CreateInstanceFunc   func(ctx context.Context, service *types.Service, instanceName string) (*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)

	// Default error responses
	CreateInstanceError   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 FakeScalingController struct {
	// 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
	CreateInstance(ctx context.Context, service *types.Service, instanceName string) (*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)
	// contains filtered or unexported methods
}

type InstanceRestartReason string

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

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

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)
	RestartService(ctx context.Context, namespace, serviceName string) 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 StopInstanceCall struct {
	Instance *types.Instance
}

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