container

Documentation

Index

• func Cleanup(ctx context.Context, olderThan time.Duration) error
• 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
  • func NewBlobUploader(ctx context.Context, id string) (*BlobUploader, error)
  • func (u *BlobUploader) Append(ctx context.Context, r io.Reader) error
  • func (u *BlobUploader) Close() error
  • func (u *BlobUploader) Read(p []byte) (int, error)
  • func (u *BlobUploader) Size() int64

Functions

func Cleanup

func Cleanup(ctx context.Context, olderThan time.Duration) error

Cleanup removes expired container data

func RemoveBlobUploadByID

func RemoveBlobUploadByID(ctx context.Context, id string) error

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)

func UpdateRepositoryNames

func UpdateRepositoryNames(ctx context.Context, owner *user_model.User, newOwnerName string) error

UpdateRepositoryNames updates the repository name property for all packages of the specific owner

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

func (u *BlobUploader) Append(ctx context.Context, r io.Reader) error

Append appends a chunk of data and updates the model

func (*BlobUploader) Close

func (u *BlobUploader) Close() error

Close implements io.Closer

func (*BlobUploader) Read

func (u *BlobUploader) Read(p []byte) (int, error)

Read implements io.Reader

func (*BlobUploader) Size

func (u *BlobUploader) Size() int64