cache

Documentation

Index

• type Cache
  • func NewCache(opts ...Option) (*Cache, error)
  • func (c *Cache) BlobWriter(ctx context.Context, blob string, append bool) (sss.FileWriter, error)
  • func (c *Cache) CleanCacheStatBlob(blob string)
  • func (c *Cache) CleanCacheStatManifest(manifest string)
  • func (c *Cache) CleanCacheStatManifestTag(manifest string)
  • func (c *Cache) Delete(ctx context.Context, cachePath string) error
  • func (c *Cache) DeleteBlob(ctx context.Context, blob string) error
  • func (c *Cache) Get(ctx context.Context, cachePath string) (io.ReadCloser, error)
  • func (c *Cache) GetBlob(ctx context.Context, blob string) (io.ReadCloser, error)
  • func (c *Cache) GetBlobContent(ctx context.Context, blob string) ([]byte, error)
  • func (c *Cache) GetBlobWithOffset(ctx context.Context, blob string, offset int64) (io.ReadCloser, error)
  • func (c *Cache) GetContent(ctx context.Context, cachePath string) ([]byte, error)
  • func (c *Cache) GetManifestContent(ctx context.Context, host, image, tagOrBlob string) (manifest *Manifest, err error)
  • func (c *Cache) GetWithOffset(ctx context.Context, cachePath string, offset int64) (io.ReadCloser, error)
  • func (c *Cache) List(ctx context.Context, cachePath string) ([]string, error)
  • func (c *Cache) ListTags(ctx context.Context, host, image string) ([]string, error)
  • func (c *Cache) Put(ctx context.Context, cachePath string, r io.Reader) (int64, error)
  • func (c *Cache) PutBlob(ctx context.Context, blob string, r io.Reader) (int64, error)
  • func (c *Cache) PutBlobContent(ctx context.Context, blob string, content []byte) (int64, error)
  • func (c *Cache) PutContent(ctx context.Context, cachePath string, content []byte) error
  • func (c *Cache) PutManifestContent(ctx context.Context, host, image, tagOrBlob string, content []byte) error
  • func (c *Cache) PutWithHash(ctx context.Context, cachePath string, r io.Reader, cacheHash string, ...) (int64, error)
  • func (c *Cache) Redirect(ctx context.Context, blobPath string, referer string) (string, error)
  • func (c *Cache) RedirectBlob(ctx context.Context, blob string, referer string) (string, error)
  • func (c *Cache) RelinkManifest(ctx context.Context, host, image, tag string, blob string) error
  • func (c *Cache) Stat(ctx context.Context, cachePath string) (sss.FileInfo, error)
  • func (c *Cache) StatBlob(ctx context.Context, blob string) (sss.FileInfo, error)
  • func (c *Cache) Walk(ctx context.Context, cachePath string, fun fs.WalkDirFunc) error
  • func (c *Cache) WalkTags(ctx context.Context, host, image string, tagCb func(tag string) bool) error
  • func (c *Cache) Writer(ctx context.Context, cachePath string, append bool) (sss.FileWriter, error)
• type Manifest
• type Option
  • func WithBlobCache(ttl time.Duration) Option
  • func WithLinkExpires(d time.Duration) Option
  • func WithManifestCache(ttl time.Duration) Option
  • func WithRedirectLinks(l *url.URL) Option
  • func WithSignLink(signLink bool) Option
  • func WithStorageDriver(storageDriver *sss.SSS) Option

Types

type Cache

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

func NewCache

func NewCache(opts ...Option) (*Cache, error)

func (*Cache) BlobWriter

func (c *Cache) BlobWriter(ctx context.Context, blob string, append bool) (sss.FileWriter, error)

func (*Cache) CleanCacheStatBlob

func (c *Cache) CleanCacheStatBlob(blob string)

func (*Cache) CleanCacheStatManifest

func (c *Cache) CleanCacheStatManifest(manifest string)

func (*Cache) CleanCacheStatManifestTag

func (c *Cache) CleanCacheStatManifestTag(manifest string)

func (*Cache) Delete

func (c *Cache) Delete(ctx context.Context, cachePath string) error

func (*Cache) DeleteBlob

func (c *Cache) DeleteBlob(ctx context.Context, blob string) error

func (*Cache) Get

func (c *Cache) Get(ctx context.Context, cachePath string) (io.ReadCloser, error)

func (*Cache) GetBlob

func (c *Cache) GetBlob(ctx context.Context, blob string) (io.ReadCloser, error)

func (*Cache) GetBlobContent

func (c *Cache) GetBlobContent(ctx context.Context, blob string) ([]byte, error)

func (*Cache) GetBlobWithOffset

func (c *Cache) GetBlobWithOffset(ctx context.Context, blob string, offset int64) (io.ReadCloser, error)

func (*Cache) GetContent

func (c *Cache) GetContent(ctx context.Context, cachePath string) ([]byte, error)

func (*Cache) GetManifestContent

func (c *Cache) GetManifestContent(ctx context.Context, host, image, tagOrBlob string) (manifest *Manifest, err error)

func (*Cache) GetWithOffset

func (c *Cache) GetWithOffset(ctx context.Context, cachePath string, offset int64) (io.ReadCloser, error)

func (*Cache) List

func (c *Cache) List(ctx context.Context, cachePath string) ([]string, error)

func (*Cache) ListTags

func (c *Cache) ListTags(ctx context.Context, host, image string) ([]string, error)

func (*Cache) Put

func (c *Cache) Put(ctx context.Context, cachePath string, r io.Reader) (int64, error)

func (*Cache) PutBlob

func (c *Cache) PutBlob(ctx context.Context, blob string, r io.Reader) (int64, error)

func (*Cache) PutBlobContent

func (c *Cache) PutBlobContent(ctx context.Context, blob string, content []byte) (int64, error)

func (*Cache) PutContent

func (c *Cache) PutContent(ctx context.Context, cachePath string, content []byte) error

func (*Cache) PutManifestContent

func (c *Cache) PutManifestContent(ctx context.Context, host, image, tagOrBlob string, content []byte) error

func (*Cache) PutWithHash

func (c *Cache) PutWithHash(ctx context.Context, cachePath string, r io.Reader, cacheHash string, cacheSize int64) (int64, error)

func (*Cache) Redirect

func (c *Cache) Redirect(ctx context.Context, blobPath string, referer string) (string, error)

func (*Cache) RedirectBlob

func (c *Cache) RedirectBlob(ctx context.Context, blob string, referer string) (string, error)

func (*Cache) RelinkManifest

func (c *Cache) RelinkManifest(ctx context.Context, host, image, tag string, blob string) error

func (*Cache) Stat

func (c *Cache) Stat(ctx context.Context, cachePath string) (sss.FileInfo, error)

func (*Cache) StatBlob

func (c *Cache) StatBlob(ctx context.Context, blob string) (sss.FileInfo, error)

func (*Cache) Walk

func (c *Cache) Walk(ctx context.Context, cachePath string, fun fs.WalkDirFunc) error

func (*Cache) WalkTags

func (c *Cache) WalkTags(ctx context.Context, host, image string, tagCb func(tag string) bool) error

func (*Cache) Writer

func (c *Cache) Writer(ctx context.Context, cachePath string, append bool) (sss.FileWriter, error)

type Manifest

type Manifest struct {
	Content   []byte
	Digest    string
	MediaType string
}

type Option

type Option func(c *Cache)

func WithBlobCache

func WithBlobCache(ttl time.Duration) Option

func WithLinkExpires

func WithLinkExpires(d time.Duration) Option

func WithManifestCache

func WithManifestCache(ttl time.Duration) Option

func WithRedirectLinks

func WithRedirectLinks(l *url.URL) Option

func WithSignLink

func WithSignLink(signLink bool) Option

func WithStorageDriver

func WithStorageDriver(storageDriver *sss.SSS) Option