cas

Documentation

Index

• type Memory
  • func NewMemory() *Memory
  • func (m *Memory) Exists(_ context.Context, target ocispec.Descriptor) (bool, error)
  • func (m *Memory) Fetch(_ context.Context, target ocispec.Descriptor) (io.ReadCloser, error)
  • func (m *Memory) Map() map[descriptor.Descriptor][]byte
  • func (m *Memory) Push(_ context.Context, expected ocispec.Descriptor, content io.Reader) error
• type Proxy
  • func NewProxy(base content.ReadOnlyStorage, cache content.Storage) *Proxy
  • func NewProxyWithLimit(base content.ReadOnlyStorage, cache content.Storage, pushLimit int64) *Proxy
  • func (p *Proxy) Exists(ctx context.Context, target ocispec.Descriptor) (bool, error)
  • func (p *Proxy) Fetch(ctx context.Context, target ocispec.Descriptor) (io.ReadCloser, error)
  • func (p *Proxy) FetchCached(ctx context.Context, target ocispec.Descriptor) (io.ReadCloser, error)

Types

type Memory

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

Memory is a memory based CAS.

func NewMemory

func NewMemory() *Memory

NewMemory creates a new Memory CAS.

func (*Memory) Exists

func (m *Memory) Exists(_ context.Context, target ocispec.Descriptor) (bool, error)

Exists returns true if the described content exists.

func (*Memory) Fetch

func (m *Memory) Fetch(_ context.Context, target ocispec.Descriptor) (io.ReadCloser, error)

Fetch fetches the content identified by the descriptor.

func (*Memory) Map

func (m *Memory) Map() map[descriptor.Descriptor][]byte

Map dumps the memory into a built-in map structure. Like other operations, calling Map() is go-routine safe. However, it does not necessarily correspond to any consistent snapshot of the storage contents.

func (*Memory) Push

func (m *Memory) Push(_ context.Context, expected ocispec.Descriptor, content io.Reader) error

Push pushes the content, matching the expected descriptor.

type Proxy

type Proxy struct {
	content.ReadOnlyStorage
	Cache       content.Storage
	StopCaching bool
}

Proxy is a caching proxy for the storage. The first fetch call of a described content will read from the remote and cache the fetched content. The subsequent fetch call will read from the local cache.

func NewProxy

func NewProxy(base content.ReadOnlyStorage, cache content.Storage) *Proxy

NewProxy creates a proxy for the `base` storage, using the `cache` storage as the cache.

func NewProxyWithLimit

func NewProxyWithLimit(base content.ReadOnlyStorage, cache content.Storage, pushLimit int64) *Proxy

NewProxyWithLimit creates a proxy for the `base` storage, using the `cache` storage with a push size limit as the cache.

func (*Proxy) Exists

func (p *Proxy) Exists(ctx context.Context, target ocispec.Descriptor) (bool, error)

Exists returns true if the described content exists.

func (*Proxy) Fetch

func (p *Proxy) Fetch(ctx context.Context, target ocispec.Descriptor) (io.ReadCloser, error)

Fetch fetches the content identified by the descriptor.

func (*Proxy) FetchCached

func (p *Proxy) FetchCached(ctx context.Context, target ocispec.Descriptor) (io.ReadCloser, error)

FetchCached fetches the content identified by the descriptor. If the content is not cached, it will be fetched from the remote without caching.