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 for the named repository and
42 // records the repository/blob association. The upload must belong to
43 // that repository; a mismatched repository reports ErrUploadNotFound.
44 FinishBlobUpload(name, uuid, digest string) error
45
46 // CancelBlobUpload cancels an in-progress upload owned by the named
47 // repository.
48 CancelBlobUpload(name, uuid string) error
49
50 // BlobOwnedByRepository reports whether the repository completed an
51 // upload of the digest. Ownership is never inferred from manifest
52 // references, which a repository writer controls.
53 BlobOwnedByRepository(name, digest string) (bool, error)
54
55 // CleanupStaleUploads removes upload files older than maxAge.
56 // Returns the number of uploads removed and total bytes reclaimed.
57 CleanupStaleUploads(maxAge time.Duration) (removed int, bytesReclaimed int64, err error)
58}
59
60// ManifestStorage defines the contract for manifest storage operations.
61type ManifestStorage interface {
62 // GetManifest retrieves a manifest by name and reference.
63 // Returns the manifest data and content type.
64 GetManifest(name, reference string) ([]byte, string, error)
65
66 // PutManifest stores a manifest.
67 PutManifest(name, reference, contentType string, data []byte) error
68
69 // DeleteManifest removes a manifest.
70 DeleteManifest(name, reference string) error
71
72 // ListTags returns all tags for a repository.
73 ListTags(name string) ([]string, error)
74
75 // ListRepositories returns all repository names.
76 ListRepositories() ([]string, error)
77
78 // GetManifestModTime returns the manifest modification time.
79 GetManifestModTime(name, reference string) (time.Time, error)
80}