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