content

Documentation

Index

• func NewLocalProvider(workDir string, threshold string, hosts remote.HostFunc, ...) (Provider, *Content, error)
• type Content
  • func NewContent(db *metadata.DB, threshold string) (*Content, error)
  • func (content *Content) ContentStore() content.Store
  • func (content *Content) GC(ctx context.Context) error
  • func (content *Content) Size() (int64, error)
  • func (content *Content) UpdateTime(digest *digest.Digest) error
• type LocalProvider
  • func (pvd *LocalProvider) ContentStore() content.Store
  • func (pvd *LocalProvider) Image(ctx context.Context, ref string) (*ocispec.Descriptor, error)
  • func (pvd *LocalProvider) Pull(ctx context.Context, ref string) error
  • func (pvd *LocalProvider) Push(ctx context.Context, desc ocispec.Descriptor, ref string) error
  • func (pvd *LocalProvider) Resolver(ref string) (remotes.Resolver, error)
  • func (pvd *LocalProvider) UsePlainHTTP()
• type Provider

Functions

func NewLocalProvider

func NewLocalProvider(
	workDir string,
	threshold string,
	hosts remote.HostFunc,
	platformMC platforms.MatchComparer,
) (Provider, *Content, error)

Types

type Content

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

func NewContent

func NewContent(db *metadata.DB, threshold string) (*Content, error)

func (*Content) ContentStore

func (content *Content) ContentStore() content.Store

return the content store in db

func (*Content) GC

func (content *Content) GC(ctx context.Context) error

GC clean the local caches by cfg.Provider.GCPolicy configuration

func (*Content) Size

func (content *Content) Size() (int64, error)

Size return the size of local caches size

func (*Content) UpdateTime

func (content *Content) UpdateTime(digest *digest.Digest) error

update the latest used time

type LocalProvider

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

func (*LocalProvider) ContentStore

func (pvd *LocalProvider) ContentStore() content.Store

func (*LocalProvider) Image

func (pvd *LocalProvider) Image(ctx context.Context, ref string) (*ocispec.Descriptor, error)

func (*LocalProvider) Pull

func (pvd *LocalProvider) Pull(ctx context.Context, ref string) error

func (*LocalProvider) Push

func (pvd *LocalProvider) Push(ctx context.Context, desc ocispec.Descriptor, ref string) error

func (*LocalProvider) Resolver

func (pvd *LocalProvider) Resolver(ref string) (remotes.Resolver, error)

func (*LocalProvider) UsePlainHTTP

func (pvd *LocalProvider) UsePlainHTTP()

type Provider

type Provider interface {
	// Use plain HTTP to communicate with registry.
	UsePlainHTTP()

	// Resolve attempts to resolve the reference into a name and descriptor.
	Resolver(ref string) (remotes.Resolver, error)
	// Pull pulls source image from remote registry by specified reference.
	// This pulls all platforms of the image but Image() returns containerd.Image for
	// the default platform.
	Pull(ctx context.Context, ref string) error
	// Push pushes target image to remote registry by specified reference,
	// the desc parameter represents the manifest of targe image.
	Push(ctx context.Context, desc ocispec.Descriptor, ref string) error

	// Image gets the source image descriptor.
	Image(ctx context.Context, ref string) (*ocispec.Descriptor, error)
	// ContentStore gets the content store object of containerd.
	ContentStore() content.Store
}

Provider provides necessary image utils, image content store for image conversion.