content

Documentation

Index

• func NewLocalProvider(cfg *config.Config, platformMC platforms.MatchComparer) (Provider, *Content, error)
• type Content
  • func NewContent(hosts remote.HostFunc, contentDir string, databaseDir string, threshold string) (*Content, error)
  • func (content *Content) Abort(ctx context.Context, ref string) error
  • func (content *Content) Delete(ctx context.Context, dgst digest.Digest) error
  • func (content *Content) GC(ctx context.Context, threshold int64)
  • func (content *Content) Info(ctx context.Context, dgst digest.Digest) (ctrcontent.Info, error)
  • func (content *Content) ListStatuses(ctx context.Context, filters ...string) ([]ctrcontent.Status, error)
  • func (content *Content) ReaderAt(ctx context.Context, desc ocispec.Descriptor) (ctrcontent.ReaderAt, error)
  • func (content *Content) Size() (int64, error)
  • func (content *Content) Status(ctx context.Context, ref string) (ctrcontent.Status, error)
  • func (content *Content) Update(ctx context.Context, info ctrcontent.Info, fieldpaths ...string) (ctrcontent.Info, error)
  • func (content *Content) Walk(ctx context.Context, fn ctrcontent.WalkFunc, fs ...string) error
  • func (content *Content) Writer(ctx context.Context, opts ...ctrcontent.WriterOpt) (ctrcontent.Writer, error)
• type LocalProvider
  • func (pvd *LocalProvider) ContentStore() content.Store
  • func (pvd *LocalProvider) Image(_ context.Context, ref string) (*ocispec.Descriptor, error)
  • func (pvd *LocalProvider) NewRemoteCache(ctx context.Context, cacheRef string) (context.Context, *cache.RemoteCache)
  • 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(cfg *config.Config, platformMC platforms.MatchComparer) (Provider, *Content, error)

Types

type Content

type Content struct {

	// GcMutex works between gc and convert
	GcMutex *sync.RWMutex

	// Threshold is the maximum capacity of the local caches storage
	Threshold int64
	// contains filtered or unexported fields
}

func NewContent

func NewContent(hosts remote.HostFunc, contentDir string, databaseDir string, threshold string) (*Content, error)

NewContent return content support by content store, bolt database and threshold. content store created in contentDir and bolt database created in databaseDir. content.db supported by bolt database and content store, content.lm supported by content.db.

func (*Content) Abort

func (content *Content) Abort(ctx context.Context, ref string) error

func (*Content) Delete

func (content *Content) Delete(ctx context.Context, dgst digest.Digest) error

func (*Content) GC

func (content *Content) GC(ctx context.Context, threshold int64)

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

func (*Content) Info

func (content *Content) Info(ctx context.Context, dgst digest.Digest) (ctrcontent.Info, error)

func (*Content) ListStatuses

func (content *Content) ListStatuses(ctx context.Context, filters ...string) ([]ctrcontent.Status, error)

func (*Content) ReaderAt

func (content *Content) ReaderAt(ctx context.Context, desc ocispec.Descriptor) (ctrcontent.ReaderAt, error)

func (*Content) Size

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

Size return the size of local caches size

func (*Content) Status

func (content *Content) Status(ctx context.Context, ref string) (ctrcontent.Status, error)

func (*Content) Update

func (content *Content) Update(ctx context.Context, info ctrcontent.Info, fieldpaths ...string) (ctrcontent.Info, error)

func (*Content) Walk

func (content *Content) Walk(ctx context.Context, fn ctrcontent.WalkFunc, fs ...string) error

func (*Content) Writer

func (content *Content) Writer(ctx context.Context, opts ...ctrcontent.WriterOpt) (ctrcontent.Writer, error)

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(_ context.Context, ref string) (*ocispec.Descriptor, error)

func (*LocalProvider) NewRemoteCache

func (pvd *LocalProvider) NewRemoteCache(ctx context.Context, cacheRef string) (context.Context, *cache.RemoteCache)

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
	// RemoteCache gets the remote cache for conversion.
	NewRemoteCache(ctx context.Context, ref string) (context.Context, *cache.RemoteCache)
}

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