domain

type Artifact struct {
	ID              string
	BackupRunID     string
	Component       Component
	ResourceName    string // Component=volume 일 때 PVC 이름
	Location        string
	SizeBytes       int64
	ChecksumSHA256  string
	EncryptionKeyID string
	CreatedAt       time.Time
}

type BackupRun struct {
	ID      string
	OrgID   string
	StackID string
	// SetID 는 이 실행이 속한 백업 세트다(backup_set.go). 비어 있으면 단독 실행이다.
	SetID   string
	Trigger Trigger
	Mode    Mode
	Scope   []Component
	Status  Status

	SchemaVersion int

	QuiesceStartedAt *time.Time
	QuiesceEndedAt   *time.Time

	Manifest   map[string]any
	TotalBytes int64
	Error      string

	StartedAt  *time.Time
	FinishedAt *time.Time
	CreatedAt  time.Time
}

type Component string

type ComponentEntry struct {
	Component      Component `json:"component"`
	ResourceName   string    `json:"resource_name,omitempty"`
	Location       string    `json:"location"`
	SizeBytes      int64     `json:"size_bytes"`
	ChecksumSHA256 string    `json:"checksum_sha256"`
}

type DanglingReference struct {
	TokenSourceID string `json:"token_source_id"`
	Path          string `json:"path"`
}

type EncryptionInfo struct {
	KeyID     string `json:"key_id"`
	Algorithm string `json:"algorithm"`
}

type GatewayAliasesOutcome struct {
	GatewayIP string   `json:"gateway_ip,omitempty"`
	Updated   []string `json:"updated,omitempty"`
	Error     string   `json:"error,omitempty"`
}

type HelmReleaseDrift struct {
	Release  string `json:"release"`
	BackedUp string `json:"backed_up"`
	Current  string `json:"current"`
}

type HelmReleaseSpec struct {
	Name       string `json:"name"`
	Chart      string `json:"chart"`
	Version    string `json:"version"`
	AppVersion string `json:"app_version,omitempty"`
	Revision   int    `json:"revision,omitempty"`
}

type IntegrityReport struct {
	CheckedPaths int                 `json:"checked_paths"`
	Dangling     []DanglingReference `json:"dangling"`
	CheckedAt    time.Time           `json:"checked_at"`
	// GatewayAliases 는 복구 뒤 러너·Argo CD hostAliases 를 게이트웨이의 지금 주소로 맞춘 결과다.
	// 스택을 되돌리지 않았으면 없다.
	GatewayAliases *GatewayAliasesOutcome `json:"gateway_aliases,omitempty"`
	// SharedComponents 는 공용 자원을 되살리기 전에 cert-manager·metrics-server 를 다시 세운 결과다.
	// 스택을 되돌리지 않았거나 설치기가 배선되지 않았으면 없다.
	SharedComponents *SharedComponentsOutcome `json:"shared_components,omitempty"`
	// VaultImport 는 스택 금고로 KV 를 되돌린 결과다. 스택을 되돌리지 않았거나 백업에 금고 산출물이 없으면
	// 없다. 실패해도 복구는 성공이다 — 데이터는 되돌아왔고, 금고만 손으로(또는 다시 복구해서) 채울 수 있다.
	VaultImport *VaultImportOutcome `json:"vault_import,omitempty"`
}

type Manifest struct {
	BackupRunID     string  `json:"backup_run_id"`
	OrgID           string  `json:"org_id"`
	StackID         string  `json:"stack_id,omitempty"`
	Mode            Mode    `json:"mode"`
	Trigger         Trigger `json:"trigger"`
	SchemaVersion   int     `json:"schema_version"`
	PlatformVersion string  `json:"platform_version,omitempty"`
	// Namespace 는 스택 백업이 뜬 네임스페이스다. 세트 복구는 스택을 어디로 되돌릴지 여기서 읽는다.
	Namespace string `json:"namespace,omitempty"`

	// pg_dump 는 서버 버전보다 낮으면 실패한다 (설계 §3.1 버전 함정).
	PGServerVersion string `json:"pg_server_version,omitempty"`
	PGDumpVersion   string `json:"pg_dump_version,omitempty"`

	Workloads []WorkloadSpec `json:"workloads,omitempty"`
	Volumes   []VolumeSpec   `json:"volumes,omitempty"`

	QuiesceWindow *QuiesceWindow `json:"quiesce_window,omitempty"`

	// 이 데이터를 만든 차트들. 복구는 같은 버전으로 되돌려야 한다.
	HelmReleases []HelmReleaseSpec `json:"helm_releases,omitempty"`

	Components []ComponentEntry `json:"components"`
	// 복구 시 참조 정합성 검사의 기대값 (설계 §6.4).
	OpenBaoKVPathCount int `json:"openbao_kv_path_count,omitempty"`

	Encryption EncryptionInfo `json:"encryption"`
	CreatedAt  time.Time      `json:"created_at"`
}

type ManifestInput struct {
	// Namespace 는 스택 백업이 뜬 네임스페이스다. 복구(특히 세트 복구)가 어디로 되돌릴지 여기서 읽는다 —
	// 비어 있으면 사용자가 네임스페이스를 직접 대야 한다.
	Namespace          string
	PlatformVersion    string
	PGServerVersion    string
	PGDumpVersion      string
	EncryptionKeyID    string
	Plan               QuiescePlan
	Volumes            []VolumeSpec
	Artifacts          []Artifact
	OpenBaoKVPathCount int
	HelmReleases       []HelmReleaseSpec
}

type Mode string

type Prerequisites struct {
	// EncryptionKeyPresent — clusters.kubeconfig 복호화 키. 없으면 복구해도
	// 등록된 어떤 클러스터도 조작할 수 없다 (설계 §1.3).
	EncryptionKeyPresent bool
	// BackupSealKeyPresent — 산출물 복호화 키.
	BackupSealKeyPresent bool
	// DestinationCredsPresent — 목적지 자격증명. 스택 OpenBao 가 아니라
	// 컨트롤 플레인에서 온다 (설계 §4.2.1).
	DestinationCredsPresent bool
	DestinationReachable    bool
}

type QuiescePlan struct {
	Targets []QuiesceTarget
}

type QuiesceTarget struct {
	Kind      string
	Namespace string
	Name      string
	// OriginalReplicas 는 재개의 유일한 근거다. 매니페스트에 기록해 두지
	// 않으면 복구 시점에 몇으로 되돌려야 하는지 알 수 없다.
	OriginalReplicas int32
	ScaleDownTo      int32
	// OwnerManaged 는 Workload 의 것을 그대로 잇는다 — 매니페스트까지 가야 복구가 본다.
	OwnerManaged bool
}

type QuiesceWindow struct {
	StartedAt time.Time `json:"started_at"`
	EndedAt   time.Time `json:"ended_at"`
}

type RestoreMode = Mode

type RestoreRun struct {
	ID              string
	BackupRunID     string
	Mode            RestoreMode
	Status          RestoreStatus
	SchemaCheck     SchemaCheckResult
	IntegrityReport IntegrityReport
	Error           string
	StartedAt       *time.Time
	FinishedAt      *time.Time
	CreatedAt       time.Time
}

type RestoreStatus = Status

type RetentionPolicy struct {
	Daily   int
	Weekly  int
	Monthly int
	// MaxTotalBytes 가 0 이면 총량 상한을 적용하지 않는다.
	MaxTotalBytes int64
}

type RunSummary struct {
	ID         string
	CreatedAt  time.Time
	TotalBytes int64
	Status     Status
}

type SchemaCheckResult struct {
	Allowed bool `json:"allowed"`
	// MigrateAfterRestore 는 복원 뒤에 migrate up 이 필요한지 알려준다.
	// 순서를 뒤집으면 실패한다 — 복원이 먼저다.
	MigrateAfterRestore bool   `json:"migrate_after_restore"`
	BackupVersion       int    `json:"backup_version"`
	CurrentVersion      int    `json:"current_version"`
	Reason              string `json:"reason,omitempty"`
}

type SchemaState struct {
	Version int
	Dirty   bool
}

type SetMember struct {
	StackID   string
	Namespace string
	Mode      Mode
	Scope     []Component
}

type SetRestoreStep struct {
	BackupRunID string
	StackID     string
	Namespace   string
	Mode        RestoreMode
}

type SharedComponentsOutcome struct {
	Steps    []string `json:"steps,omitempty"`
	Warnings []string `json:"warnings,omitempty"`
}

type StackRef struct {
	ID        string
	Namespace string
}

type Status string

type Trigger string

type VaultImportOutcome struct {
	Imported bool   `json:"imported"`
	Attempts int    `json:"attempts,omitempty"`
	Error    string `json:"error,omitempty"`
}

type VolumeSpec struct {
	Name           string `json:"name"`
	SizeBytes      int64  `json:"size_bytes"`
	StorageClass   string `json:"storage_class,omitempty"`
	ChecksumSHA256 string `json:"checksum_sha256,omitempty"`
}

type Workload struct {
	Kind      string // Deployment | StatefulSet
	Namespace string
	Name      string
	Replicas  int32
	// OwnerManaged 는 다른 리소스가 소유한 워크로드다(ownerReferences) — 오퍼레이터가 CR 을 읽어
	// 만드는 Prometheus·Alertmanager StatefulSet 이 그렇다. 정지는 똑같이 멈추되(쓰기를 끊어야
	// 한다) 복구의 재개는 건너뛴다: 덤프가 소유된 것을 담지 않으므로 복구 뒤에는 오퍼레이터가
	// CR 에서 다시 만들고, 그때 재개가 그것을 찾지 못해 내는 "수동 조치" 경보는 거짓이다.
	OwnerManaged bool
}

type WorkloadSpec struct {
	Kind      string `json:"kind"`
	Namespace string `json:"namespace"`
	Name      string `json:"name"`
	// OriginalReplicas 는 복원의 필수 입력이다 (설계 §3.4 3단계).
	OriginalReplicas int32 `json:"original_replicas"`
	// OwnerManaged 가 참이면 복구의 재개가 건너뛴다 — 오퍼레이터가 CR 에서 다시 만드는 것이다.
	OwnerManaged bool `json:"owner_managed,omitempty"`
}