remote

Documentation

Index

• type Blob
• type Fetcher
• type Handler
• type Option
  • func WithCacheOpts(cacheOpts ...cache.Option) Option
  • func WithContext(ctx context.Context) Option
• type Resolver
  • func NewResolver(cfg config.BlobConfig, handlers map[string]Handler) *Resolver
  • func (r *Resolver) Resolve(ctx context.Context, hosts source.RegistryHosts, refspec reference.Spec, ...) (Blob, error)

Types

type Blob

type Blob interface {
	Check() error
	Size() int64
	FetchedSize() int64
	ReadAt(p []byte, offset int64, opts ...Option) (int, error)
	Cache(offset int64, size int64, opts ...Option) error
	Refresh(ctx context.Context, host source.RegistryHosts, refspec reference.Spec, desc ocispec.Descriptor) error
	Close() error
}

type Fetcher

type Fetcher interface {
	Fetch(ctx context.Context, off int64, size int64) (io.ReadCloser, error)
	Check() error
	GenID(off int64, size int64) string
}

type Handler

type Handler interface {
	Handle(ctx context.Context, desc ocispec.Descriptor) (fetcher Fetcher, size int64, err error)
}

type Option

type Option func(*options)

func WithCacheOpts

func WithCacheOpts(cacheOpts ...cache.Option) Option

func WithContext

func WithContext(ctx context.Context) Option

type Resolver

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

func NewResolver

func NewResolver(cfg config.BlobConfig, handlers map[string]Handler) *Resolver

func (*Resolver) Resolve

func (r *Resolver) Resolve(ctx context.Context, hosts source.RegistryHosts, refspec reference.Spec, desc ocispec.Descriptor, blobCache cache.BlobCache) (Blob, error)