remote

Documentation

Index

• Variables
• 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 []docker.RegistryHost, refspec reference.Spec, ...) (Blob, error)

Variables

var (
	ErrUnexpectedStatusCode      = errors.New("unexpected status code")
	ErrFailedToRetrieveLayerSize = errors.New("failed to retrieve layer size from remote")
	ErrInvalidHost               = errors.New("invalid host destination")
	ErrFailedToRedirect          = errors.New("failed to redirect")
	ErrUnableToCreateFetcher     = errors.New("unable to create remote fetcher")
	ErrNoRegion                  = errors.New("no regions to fetch")
	ErrCannotParseContentLength  = errors.New("failed to parse Content-Length header")
	ErrCannotParseContentRange   = errors.New("failed to parse Content-Range header")
	ErrCannotParseContentType    = errors.New("failed to parse Content-Type header")
	ErrFailedToRefreshURL        = errors.New("failed to refresh URL")
	ErrRequestFailed             = errors.New("request to registry failed")
)

Types

type Blob

type Blob interface {
	Check() error
	Size() int64
	FetchedSize() int64
	ReadAt(p []byte, offset int64, opts ...Option) (int, error)
	Refresh(ctx context.Context, hosts []docker.RegistryHost, 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 []docker.RegistryHost, refspec reference.Spec, desc ocispec.Descriptor, blobCache cache.BlobCache) (Blob, error)