etcd

type Endpoint struct {
	Address    string
	ServerName string
}

type EtcdctlSource struct {
	Etcdctl    string
	Etcdutl    string
	Endpoints  []string
	Identity   Identity
	TLS        TLSFiles
	ScratchDir string
	Attest     func(context.Context) (SnapshotInfo, error)
}

type Identity struct {
	Core    string `json:"core"`
	Target  string `json:"target"`
	Cluster string `json:"cluster"`
}

type IsolatedEtcdutl struct {
	Binary                   string
	MemberName               string
	InitialCluster           string
	InitialAdvertisePeerURLs string
	ExpectedMemberNames      []string
}

type Metadata struct {
	Format   int          `json:"format"`
	Identity Identity     `json:"identity"`
	Info     SnapshotInfo `json:"info"`
	Bytes    int64        `json:"bytes"`
	SHA256   string       `json:"sha256"`
	Created  time.Time    `json:"created"`
}

type RecoveryReadiness interface {
	VerifyEtcdQuorum(context.Context, Identity, SnapshotInfo) error
	VerifyPatroniDCS(context.Context, Identity, SnapshotInfo) error
}

type RestorePlan struct {
	Archive, Destination string
	Identity             Identity
	Info                 SnapshotInfo
	SHA256               string
}

type Restorer interface {
	RestoreIsolated(context.Context, string, string, Identity, SnapshotInfo) error
	VerifyIsolated(context.Context, string, Identity, SnapshotInfo) error
}

type SnapshotInfo struct {
	ClusterID string `json:"cluster_id"`
	Version   string `json:"version"`
	Revision  int64  `json:"revision"`
}

type Source interface {
	// Snapshot streams etcd v3 Maintenance.Snapshot (gRPC), never a container shell.
	Snapshot(context.Context, io.Writer) (SnapshotInfo, error)
}

type Store struct {
	Directory string
	Identity  Identity
	Client    Source
}

type TLSFiles struct{ CA, Cert, Key string }