orchestrator

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

type FakeOrchestrator struct {

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

	// Track calls for testing
	ExecInInstanceCalls []ExecInInstanceCall
	// 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)

	// Lifecycle operations
	GetInstanceByID(ctx context.Context, namespace, instanceID string) (*types.Instance, error)
	RestartService(ctx context.Context, namespace, serviceName string) 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)
}

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