Documentation
¶
Index ¶
- func Cleanup(ctx context.Context, olderThan time.Duration) error
- func ParseManifestMetadata(ctx context.Context, rd io.Reader, ownerID int64, imageName string) (*v1.Manifest, *packages_model.PackageFileDescriptor, ...)
- func RemoveBlobUploadByID(ctx context.Context, id string) error
- func ShouldBeSkipped(ctx context.Context, pcr *packages_model.PackageCleanupRule, ...) (bool, error)
- func UpdateRepositoryNames(ctx context.Context, owner *user_model.User, newOwnerName string) error
- type BlobUploader
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Cleanup ¶
Cleanup removes expired container data
func ParseManifestMetadata ¶
func ParseManifestMetadata(ctx context.Context, rd io.Reader, ownerID int64, imageName string) (*v1.Manifest, *packages_model.PackageFileDescriptor, *container_module.Metadata, error)
func RemoveBlobUploadByID ¶
RemoveBlobUploadByID Remove deletes the data and the model of a blob upload
func ShouldBeSkipped ¶
func ShouldBeSkipped(ctx context.Context, pcr *packages_model.PackageCleanupRule, p *packages_model.Package, pv *packages_model.PackageVersion) (bool, error)
Types ¶
type BlobUploader ¶
type BlobUploader struct {
*packages_model.PackageBlobUpload
*packages_module.MultiHasher
// contains filtered or unexported fields
}
BlobUploader handles chunked blob uploads
func NewBlobUploader ¶
func NewBlobUploader(ctx context.Context, id string) (*BlobUploader, error)
NewBlobUploader creates a new blob uploader for the given id
func (*BlobUploader) Append ¶
Append appends a chunk of data and updates the model
func (*BlobUploader) Read ¶
func (u *BlobUploader) Read(p []byte) (int, error)
Read implements io.Reader
func (*BlobUploader) Size ¶
func (u *BlobUploader) Size() int64
Source Files
¶
- blob_uploader.go
- cleanup.go
- common.go
Click to show internal directories.
Click to hide internal directories.