local

Documentation

Index

• Constants
• func DirExists(d string) bool
• func NewImageStore(rootDir string, gc bool, gcDelay time.Duration, dedupe, commit bool, ...) storage.ImageStore
• func ValidateHardLink(rootDir string) error
• type ImageStoreLocal
  • func (is *ImageStoreLocal) BlobPath(repo string, digest godigest.Digest) string
  • func (is *ImageStoreLocal) BlobUploadInfo(repo, uuid string) (int64, error)
  • func (is *ImageStoreLocal) BlobUploadPath(repo, uuid string) string
  • func (is *ImageStoreLocal) CheckBlob(repo string, digest godigest.Digest) (bool, int64, error)
  • func (is *ImageStoreLocal) DedupeBlob(src string, dstDigest godigest.Digest, dst string) error
  • func (is *ImageStoreLocal) DeleteBlob(repo string, digest godigest.Digest) error
  • func (is *ImageStoreLocal) DeleteBlobUpload(repo, uuid string) error
  • func (is *ImageStoreLocal) DeleteImageManifest(repo, reference string, detectCollision bool) error
  • func (is *ImageStoreLocal) DirExists(d string) bool
  • func (is *ImageStoreLocal) FinishBlobUpload(repo, uuid string, body io.Reader, dstDigest godigest.Digest) error
  • func (is *ImageStoreLocal) FullBlobUpload(repo string, body io.Reader, dstDigest godigest.Digest) (string, int64, error)
  • func (is *ImageStoreLocal) GetBlob(repo string, digest godigest.Digest, mediaType string) (io.ReadCloser, int64, error)
  • func (is *ImageStoreLocal) GetBlobContent(repo string, digest godigest.Digest) ([]byte, error)
  • func (is *ImageStoreLocal) GetBlobPartial(repo string, digest godigest.Digest, mediaType string, from, to int64) (io.ReadCloser, int64, int64, error)
  • func (is *ImageStoreLocal) GetBlobUpload(repo, uuid string) (int64, error)
  • func (is *ImageStoreLocal) GetImageManifest(repo, reference string) ([]byte, godigest.Digest, string, error)
  • func (is *ImageStoreLocal) GetImageTags(repo string) ([]string, error)
  • func (is *ImageStoreLocal) GetIndexContent(repo string) ([]byte, error)
  • func (is *ImageStoreLocal) GetNextRepository(repo string) (string, error)
  • func (is *ImageStoreLocal) GetOrasReferrers(repo string, gdigest godigest.Digest, artifactType string) ([]oras.Descriptor, error)
  • func (is *ImageStoreLocal) GetReferrers(repo string, gdigest godigest.Digest, artifactType string) (ispec.Index, error)
  • func (is *ImageStoreLocal) GetRepositories() ([]string, error)
  • func (is *ImageStoreLocal) InitRepo(name string) error
  • func (is *ImageStoreLocal) Lock(lockStart *time.Time)
  • func (is *ImageStoreLocal) NewBlobUpload(repo string) (string, error)
  • func (is *ImageStoreLocal) PutBlobChunk(repo, uuid string, from, to int64, body io.Reader) (int64, error)
  • func (is *ImageStoreLocal) PutBlobChunkStreamed(repo, uuid string, body io.Reader) (int64, error)
  • func (is *ImageStoreLocal) PutImageManifest(repo, reference, mediaType string, body []byte) (godigest.Digest, error)
  • func (is *ImageStoreLocal) RLock(lockStart *time.Time)
  • func (is *ImageStoreLocal) RUnlock(lockStart *time.Time)
  • func (is *ImageStoreLocal) RootDir() string
  • func (is *ImageStoreLocal) RunGCPeriodically(interval time.Duration, sch *scheduler.Scheduler)
  • func (is *ImageStoreLocal) RunGCRepo(repo string) error
  • func (is *ImageStoreLocal) Unlock(lockStart *time.Time)
  • func (is *ImageStoreLocal) ValidateRepo(name string) (bool, error)

Constants

const (
	DefaultFilePerms = 0o600
	DefaultDirPerms  = 0o700
)

Functions

func DirExists

func DirExists(d string) bool

func NewImageStore

func NewImageStore(rootDir string, gc bool, gcDelay time.Duration, dedupe, commit bool,
	log zlog.Logger, metrics monitoring.MetricServer, linter storage.Lint, cacheDriver cache.Cache,
) storage.ImageStore

NewImageStore returns a new image store backed by a file storage. Use the last argument to properly set a cache database, or it will default to boltDB local storage.

func ValidateHardLink

func ValidateHardLink(rootDir string) error

Types

type ImageStoreLocal

type ImageStoreLocal struct {
	// contains filtered or unexported fields
}

ImageStoreLocal provides the image storage operations.

func (*ImageStoreLocal) BlobPath

func (is *ImageStoreLocal) BlobPath(repo string, digest godigest.Digest) string

BlobPath returns the repository path of a blob.

func (*ImageStoreLocal) BlobUploadInfo

func (is *ImageStoreLocal) BlobUploadInfo(repo, uuid string) (int64, error)

BlobUploadInfo returns the current blob size in bytes.

func (*ImageStoreLocal) BlobUploadPath

func (is *ImageStoreLocal) BlobUploadPath(repo, uuid string) string

BlobUploadPath returns the upload path for a blob in this store.

func (*ImageStoreLocal) CheckBlob

func (is *ImageStoreLocal) CheckBlob(repo string, digest godigest.Digest) (bool, int64, error)

CheckBlob verifies a blob and returns true if the blob is correct.

func (*ImageStoreLocal) DedupeBlob

func (is *ImageStoreLocal) DedupeBlob(src string, dstDigest godigest.Digest, dst string) error

func (*ImageStoreLocal) DeleteBlob

func (is *ImageStoreLocal) DeleteBlob(repo string, digest godigest.Digest) error

DeleteBlob removes the blob from the repository.

func (*ImageStoreLocal) DeleteBlobUpload

func (is *ImageStoreLocal) DeleteBlobUpload(repo, uuid string) error

DeleteBlobUpload deletes an existing blob upload that is currently in progress.

func (*ImageStoreLocal) DeleteImageManifest

func (is *ImageStoreLocal) DeleteImageManifest(repo, reference string, detectCollision bool) error

DeleteImageManifest deletes the image manifest from the repository.

func (*ImageStoreLocal) DirExists

func (is *ImageStoreLocal) DirExists(d string) bool

func (*ImageStoreLocal) FinishBlobUpload

func (is *ImageStoreLocal) FinishBlobUpload(repo, uuid string, body io.Reader, dstDigest godigest.Digest) error

FinishBlobUpload finalizes the blob upload and moves blob the repository.

func (*ImageStoreLocal) FullBlobUpload

func (is *ImageStoreLocal) FullBlobUpload(repo string, body io.Reader, dstDigest godigest.Digest,
) (string, int64, error)

FullBlobUpload handles a full blob upload, and no partial session is created.

func (*ImageStoreLocal) GetBlob

func (is *ImageStoreLocal) GetBlob(repo string, digest godigest.Digest, mediaType string,
) (io.ReadCloser, int64, error)

GetBlob returns a stream to read the blob. blob selector instead of directly downloading the blob.

func (*ImageStoreLocal) GetBlobContent

func (is *ImageStoreLocal) GetBlobContent(repo string, digest godigest.Digest) ([]byte, error)

GetBlobContent returns blob contents, SHOULD lock from outside.

func (*ImageStoreLocal) GetBlobPartial

func (is *ImageStoreLocal) GetBlobPartial(repo string, digest godigest.Digest, mediaType string, from, to int64,
) (io.ReadCloser, int64, int64, error)

GetBlobPartial returns a partial stream to read the blob. blob selector instead of directly downloading the blob.

func (*ImageStoreLocal) GetBlobUpload

func (is *ImageStoreLocal) GetBlobUpload(repo, uuid string) (int64, error)

GetBlobUpload returns the current size of a blob upload.

func (*ImageStoreLocal) GetImageManifest

func (is *ImageStoreLocal) GetImageManifest(repo, reference string) ([]byte, godigest.Digest, string, error)

GetImageManifest returns the image manifest of an image in the specific repository.

func (*ImageStoreLocal) GetImageTags

func (is *ImageStoreLocal) GetImageTags(repo string) ([]string, error)

GetImageTags returns a list of image tags available in the specified repository.

func (*ImageStoreLocal) GetIndexContent

func (is *ImageStoreLocal) GetIndexContent(repo string) ([]byte, error)

GetIndexContent returns index.json contents, SHOULD lock from outside.

func (*ImageStoreLocal) GetNextRepository

func (is *ImageStoreLocal) GetNextRepository(repo string) (string, error)

GetNextRepository returns next repository under this store.

func (*ImageStoreLocal) GetOrasReferrers

func (is *ImageStoreLocal) GetOrasReferrers(repo string, gdigest godigest.Digest, artifactType string,
) ([]oras.Descriptor, error)

func (*ImageStoreLocal) GetReferrers

func (is *ImageStoreLocal) GetReferrers(repo string, gdigest godigest.Digest, artifactType string,
) (ispec.Index, error)

func (*ImageStoreLocal) GetRepositories

func (is *ImageStoreLocal) GetRepositories() ([]string, error)

GetRepositories returns a list of all the repositories under this store.

func (*ImageStoreLocal) InitRepo

func (is *ImageStoreLocal) InitRepo(name string) error

InitRepo creates an image repository under this store.

func (*ImageStoreLocal) Lock

func (is *ImageStoreLocal) Lock(lockStart *time.Time)

Lock write-lock.

func (*ImageStoreLocal) NewBlobUpload

func (is *ImageStoreLocal) NewBlobUpload(repo string) (string, error)

NewBlobUpload returns the unique ID for an upload in progress.

func (*ImageStoreLocal) PutBlobChunk

func (is *ImageStoreLocal) PutBlobChunk(repo, uuid string, from, to int64,
	body io.Reader,
) (int64, error)

PutBlobChunk writes another chunk of data to the specified blob. It returns the number of actual bytes to the blob.

func (*ImageStoreLocal) PutBlobChunkStreamed

func (is *ImageStoreLocal) PutBlobChunkStreamed(repo, uuid string, body io.Reader) (int64, error)

PutBlobChunkStreamed appends another chunk of data to the specified blob. It returns the number of actual bytes to the blob.

func (*ImageStoreLocal) PutImageManifest

func (is *ImageStoreLocal) PutImageManifest(repo, reference, mediaType string,
	body []byte,
) (godigest.Digest, error)

PutImageManifest adds an image manifest to the repository.

func (*ImageStoreLocal) RLock

func (is *ImageStoreLocal) RLock(lockStart *time.Time)

RLock read-lock.

func (*ImageStoreLocal) RUnlock

func (is *ImageStoreLocal) RUnlock(lockStart *time.Time)

RUnlock read-unlock.

func (*ImageStoreLocal) RootDir

func (is *ImageStoreLocal) RootDir() string

func (*ImageStoreLocal) RunGCPeriodically

func (is *ImageStoreLocal) RunGCPeriodically(interval time.Duration, sch *scheduler.Scheduler)

func (*ImageStoreLocal) RunGCRepo

func (is *ImageStoreLocal) RunGCRepo(repo string) error

func (*ImageStoreLocal) Unlock

func (is *ImageStoreLocal) Unlock(lockStart *time.Time)

Unlock write-unlock.

func (*ImageStoreLocal) ValidateRepo

func (is *ImageStoreLocal) ValidateRepo(name string) (bool, error)

ValidateRepo validates that the repository layout is complaint with the OCI repo layout.