content

Oct 16, 2023

Changes in this version

type LocalProvider

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

type Provider

+ NewRemoteCache func(ctx context.Context, ref string) (context.Context, *cache.RemoteCache)

Sep 12, 2023

Changes in this version

type Content

+ GcMutex *sync.RWMutex

+ Threshold int64

+ func (content *Content) NewRemoteCache(cacheRef string) error

type LocalProvider

+ func (pvd *LocalProvider) GetCacheRef() string

+ func (pvd *LocalProvider) SetCacheRef(ref string)

type Provider

+ GetCacheRef func() string

+ SetCacheRef func(ref string)

+ type RemoteCache struct

+ func NewRemoteCache(cacheSize int, host remote.HostFunc) (*RemoteCache, error)

+ func (rc *RemoteCache) Add(key string, value ocispec.Descriptor)

+ func (rc *RemoteCache) Get(key string) (ocispec.Descriptor, bool)

+ func (rc *RemoteCache) NewLRUCache(cacheSize int, cacheRef string) error

+ func (rc *RemoteCache) Remove(key string)

+ func (rc *RemoteCache) Size() int

+ func (rc *RemoteCache) Values() []ocispec.Descriptor

Jul 31, 2023

Changes in this version

type Content

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

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

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

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

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

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

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

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

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

Jun 19, 2023

Changes in this version

+ type Content struct

+ 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

Sep 20, 2022

Changes in this version

type LocalProvider

+ func (pvd *LocalProvider) UsePlainHTTP()

type Provider

+ UsePlainHTTP func()

Jun 10, 2022

Changes in this version

+ type LocalProvider struct

+ func (pvd *LocalProvider) Client() *containerd.Client

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

+ func (pvd *LocalProvider) Image() containerd.Image

+ 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(ctx context.Context, ref string) (remotes.Resolver, error)

+ func (pvd *LocalProvider) Snapshotter() snapshots.Snapshotter

+ type Provider interface

+ Client func() *containerd.Client

+ ContentStore func() content.Store

+ Image func() containerd.Image

+ Pull func(ctx context.Context, ref string) error

+ Push func(ctx context.Context, desc ocispec.Descriptor, ref string) error

+ Resolver func(ctx context.Context, ref string) (remotes.Resolver, error)

+ Snapshotter func() snapshots.Snapshotter

+ func NewLocalProvider(cfg *config.ProviderConfig, client *containerd.Client, ...) (Provider, error)