port

type ArtifactStore interface {
	// Preflight 는 정지 창에 들어가기 전에 연결·인증·쓰기·용량을 검사한다.
	//
	// 정지 창을 소비하고도 산출물을 못 만드는 것이 최악의 조합이라
	// (§9 F7b·F8), 멈추기 전에 실패할 수 있는 것은 전부 먼저 확인한다.
	Preflight(ctx context.Context, requiredBytes int64) error
	Put(ctx context.Context, key string, r io.Reader) (PutResult, error)
	Get(ctx context.Context, key string) (io.ReadCloser, error)
	Delete(ctx context.Context, prefix string) error
	Stat(ctx context.Context, key string) (int64, string, error)
}

type BackupRepository interface {
	CreateRun(ctx context.Context, run *domain.BackupRun) error
	UpdateRun(ctx context.Context, run *domain.BackupRun) error
	GetRun(ctx context.Context, id string) (*domain.BackupRun, error)
	ListRuns(ctx context.Context, orgID string, limit int) ([]*domain.BackupRun, error)
	// ListRunsBySet 은 한 백업 세트의 실행들이다(domain.PlanBackupSet). 순서는 생성순.
	ListRunsBySet(ctx context.Context, setID string) ([]*domain.BackupRun, error)
	ListSummaries(ctx context.Context, orgID string) ([]domain.RunSummary, error)

	AddArtifact(ctx context.Context, a *domain.Artifact) error
	ListArtifacts(ctx context.Context, backupRunID string) ([]*domain.Artifact, error)
	DeleteArtifacts(ctx context.Context, backupRunID string) error

	CreateRestore(ctx context.Context, run *domain.RestoreRun) error
	UpdateRestore(ctx context.Context, run *domain.RestoreRun) error
	GetRestore(ctx context.Context, id string) (*domain.RestoreRun, error)
}

type ConnectionResetter interface {
	Reset()
}

type DBDumper interface {
	// ServerVersion 은 pg_dump 클라이언트 선택에 쓴다 (§3.1 버전 함정).
	ServerVersion(ctx context.Context, target DBTarget) (string, error)
	Dump(ctx context.Context, target DBTarget, out io.Writer) (DumpResult, error)
	Restore(ctx context.Context, target DBTarget, in io.Reader) error
	SchemaState(ctx context.Context, target DBTarget) (domain.SchemaState, error)
}

type DBTarget struct {
	Component domain.Component
	Host      string
	Port      int
	Database  string
	User      string
	Password  string
	// PreserveTables 는 복원이 건드리지 않는 테이블이다(public 스키마). 덤프에는 담긴다 —
	// 플랫폼 DB 를 잃었을 때 손으로 되살릴 사본이다. 플랫폼 DB 의 백업 이력이 그렇다(domain.HistoryTables).
	PreserveTables []string
}

type DumpResult struct {
	ClientVersion string
	BytesWritten  int64
}

type GatewayAliasRepinner interface {
	RepinGatewayAliases(ctx context.Context, stackID, namespace string, kubeconfig []byte) (gatewayIP string, updated []string, err error)
}

type HelmReleaseLister interface {
	ListHelmReleases(ctx context.Context, namespace string) ([]domain.HelmReleaseSpec, error)
}

type KVExportResult struct {
	PathCount int
	Bytes     int64
}

type KVExporter interface {
	Export(ctx context.Context, stackID string, out io.Writer) (KVExportResult, error)
	Import(ctx context.Context, stackID string, in io.Reader) error
	// PathExists 는 참조 정합성 검사에 쓴다 (§6.4).
	PathExists(ctx context.Context, stackID, path string) (bool, error)
}

type NamespaceEnsurer interface {
	EnsureNamespace(ctx context.Context, namespace, restoredFromBackupID string) error
}

type Notifier interface {
	NotifyBackupResult(ctx context.Context, run *domain.BackupRun) error
}

type OrganizationChecker interface {
	OrganizationExists(ctx context.Context, orgID string) (bool, error)
}

type PutResult struct {
	Bytes          int64
	ChecksumSHA256 string
	Location       string
}

type ResourceDumper interface {
	Dump(ctx context.Context, namespace string, out io.Writer) (int64, error)
	Apply(ctx context.Context, namespace string, in io.Reader) error
}

type Sealer interface {
	KeyID() string
	Seal(ctx context.Context, plaintext io.Reader, out io.Writer) error
	Unseal(ctx context.Context, ciphertext io.Reader, out io.Writer) error
}

type SharedComponentsEnsurer interface {
	// EnsureSharedComponents 는 돌린 단계 이름과, 멈추지 않고 넘긴 실패(metrics-server)를 돌려준다.
	// cert-manager 를 세우지 못하면 오류다 — 그것 없이는 내부 CA 를 되살릴 수 없다.
	EnsureSharedComponents(ctx context.Context, kubeconfig []byte, namespace string) (steps []string, warnings []string, err error)
}

type SharedResourceDumper interface {
	// DumpShared 는 담을 것이 없으면 0 을 돌려주고 아무것도 쓰지 않는다.
	DumpShared(ctx context.Context, out io.Writer) (int64, error)
	// ApplyShared 는 공용 자원을 **없을 때만** 만든다. 다른 스택이 쓰는 지금의 CA 나 CRD 를
	// 백업 때의 것으로 덮으면 그 스택이 깨진다. 종류의 CRD 가 없으면(cert-manager 없음)
	// 무엇을 먼저 설치해야 하는지 말하고 오류를 돌려준다.
	ApplyShared(ctx context.Context, in io.Reader) error
	// ApplySharedSecrets 는 덤프 가운데 CRD 가 필요 없는 것 — 내부 CA Secret 과 그 네임스페이스 — 만
	// 없을 때 먼저 만든다. cert-manager 를 다시 세우기 **전에** 불러야 한다: 부트스트랩이 Secret 이
	// 있으면 옛 키를 채택하고, 없으면 새 키를 발급해 백업의 CA 는 영영 돌아오지 못한다.
	ApplySharedSecrets(ctx context.Context, in io.Reader) error
}

type StackLister interface {
	ListCompletedStacks(ctx context.Context, orgID string) ([]domain.StackRef, error)
}

type TokenSourceLister interface {
	ListPaths(ctx context.Context, orgID string) ([]TokenSourceRef, error)
}

type TokenSourceRef struct {
	ID   string
	Path string
}

type VolumeArchiver interface {
	ListPVCs(ctx context.Context, namespace string) ([]domain.VolumeSpec, error)
	Archive(ctx context.Context, namespace, pvc string, out io.Writer) (int64, error)
	Restore(ctx context.Context, namespace, pvc string, in io.Reader) error
	EnsurePVC(ctx context.Context, namespace string, spec domain.VolumeSpec, restoredFromBackupID string) error
}

type WorkloadScaler interface {
	List(ctx context.Context, namespace string) ([]domain.Workload, error)
	Scale(ctx context.Context, w domain.QuiesceTarget, replicas int32) error
	// WaitStopped 는 볼륨이 실제로 언마운트될 때까지 기다린다. 파드가 남아
	// 있는 채로 복사하면 정지 백업의 의미가 사라진다.
	WaitStopped(ctx context.Context, namespace string, targets []domain.QuiesceTarget) error
}