recovery.go RawHistoryFolder

1package ports
2
3import (
4	"context"
5
6	"github.com/bnema/vev/internal/domain"
7)
8
9type CheckpointRef = domain.CheckpointRef
10
11type SnapshotPublication struct {
12	IncarnationID    domain.IncarnationID
13	Name             string
14	Generation       uint64
15	ParentCheckpoint *domain.CheckpointRef
16	Manifest         []byte
17	Objects          []SnapshotObject
18}
19
20type SnapshotGeneration struct {
21	IncarnationID    domain.IncarnationID
22	Name             string
23	Generation       uint64
24	ParentCheckpoint *domain.CheckpointRef
25	Manifest         []byte
26	Objects          map[SnapshotDigest][]byte
27}
28
29type Catalogue interface {
30	Records() ([]domain.CatalogueRecord, error)
31	Record(string) (domain.CatalogueRecord, bool, error)
32	Create(domain.CatalogueRecord) error
33	UpdateMetadata(domain.CatalogueMetadataUpdate) error
34	Replace(string, domain.CatalogueRecord) error
35	Rename(string, domain.CatalogueRecord) error
36	Delete(string) error
37	// Sync makes buffered metadata durable. Identity operations sync internally.
38	Sync() error
39	Close() error
40}
41
42type SnapshotRepository interface {
43	Publish(context.Context, SnapshotPublication) error
44	LoadCheckpoint(context.Context, domain.IncarnationID, string, CheckpointRef) (SnapshotGeneration, error)
45	ReconcileCheckpoint(context.Context, domain.IncarnationID, CheckpointRef) error
46	DeleteIncarnation(context.Context, domain.IncarnationID) error
47	CollectGarbage(context.Context, map[domain.IncarnationID]domain.CheckpointRef) error
48}