storage.go RawHistoryFolder

1package out
2
3import (
4	"io"
5	"time"
6)
7
8// BlobStorage defines the contract for blob storage operations.
9type BlobStorage interface {
10	// GetBlob retrieves a blob by digest.
11	GetBlob(digest string) (io.ReadCloser, error)
12
13	// GetBlobPath returns the filesystem path to a blob.
14	GetBlobPath(digest string) (string, error)
15
16	// PutBlob stores a blob with the given digest.
17	PutBlob(digest string, data io.Reader, size int64) error
18
19	// DeleteBlob removes a blob by digest.
20	DeleteBlob(digest string) error
21
22	// BlobExists checks if a blob exists.
23	BlobExists(digest string) bool
24
25	// ListBlobs returns all blob digests.
26	ListBlobs() ([]string, error)
27
28	// StartBlobUpload starts a new blob upload and returns the upload UUID.
29	StartBlobUpload(name string) (string, error)
30
31	// AppendBlobChunk appends data to an in-progress upload.
32	AppendBlobChunk(name, uuid string, data io.Reader) (int64, error)
33
34	// GetBlobUpload returns a writer for the upload.
35	GetBlobUpload(uuid string) (io.WriteCloser, error)
36
37	// FinishBlobUpload completes an upload and moves it to blob storage.
38	FinishBlobUpload(uuid, digest string) error
39
40	// CancelBlobUpload cancels an in-progress upload.
41	CancelBlobUpload(uuid string) error
42
43	// CleanupStaleUploads removes upload files older than maxAge.
44	// Returns the number of uploads removed and total bytes reclaimed.
45	CleanupStaleUploads(maxAge time.Duration) (removed int, bytesReclaimed int64, err error)
46}
47
48// ManifestStorage defines the contract for manifest storage operations.
49type ManifestStorage interface {
50	// GetManifest retrieves a manifest by name and reference.
51	// Returns the manifest data and content type.
52	GetManifest(name, reference string) ([]byte, string, error)
53
54	// PutManifest stores a manifest.
55	PutManifest(name, reference, contentType string, data []byte) error
56
57	// DeleteManifest removes a manifest.
58	DeleteManifest(name, reference string) error
59
60	// ListTags returns all tags for a repository.
61	ListTags(name string) ([]string, error)
62
63	// ListRepositories returns all repository names.
64	ListRepositories() ([]string, error)
65
66	// GetManifestModTime returns the manifest modification time.
67	GetManifestModTime(name, reference string) (time.Time, error)
68}