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	// Returns the size in bytes of the removed blob.
21	DeleteBlob(digest string) (int64, error)
22
23	// BlobExists checks if a blob exists.
24	BlobExists(digest string) bool
25
26	// ListBlobs returns all blob digests.
27	ListBlobs() ([]string, error)
28
29	// StartBlobUpload starts a new blob upload and returns the upload UUID.
30	StartBlobUpload(name string) (string, error)
31
32	// AppendBlobChunk appends data to an in-progress upload.
33	AppendBlobChunk(name, uuid string, data io.Reader, contentLength, maxBlobSize int64) (int64, error)
34
35	// GetBlobUpload returns a writer for the upload.
36	GetBlobUpload(uuid string) (io.WriteCloser, error)
37
38	// FinishBlobUpload completes an upload and moves it to blob storage.
39	FinishBlobUpload(uuid, digest string) error
40
41	// CancelBlobUpload cancels an in-progress upload.
42	CancelBlobUpload(uuid string) error
43
44	// CleanupStaleUploads removes upload files older than maxAge.
45	// Returns the number of uploads removed and total bytes reclaimed.
46	CleanupStaleUploads(maxAge time.Duration) (removed int, bytesReclaimed int64, err error)
47}
48
49// ManifestStorage defines the contract for manifest storage operations.
50type ManifestStorage interface {
51	// GetManifest retrieves a manifest by name and reference.
52	// Returns the manifest data and content type.
53	GetManifest(name, reference string) ([]byte, string, error)
54
55	// PutManifest stores a manifest.
56	PutManifest(name, reference, contentType string, data []byte) error
57
58	// DeleteManifest removes a manifest.
59	DeleteManifest(name, reference string) error
60
61	// ListTags returns all tags for a repository.
62	ListTags(name string) ([]string, error)
63
64	// ListRepositories returns all repository names.
65	ListRepositories() ([]string, error)
66
67	// GetManifestModTime returns the manifest modification time.
68	GetManifestModTime(name, reference string) (time.Time, error)
69}