layerfetcher

Documentation

Index

• type BlobReader
  • func NewBlobReader(blobPath string) (*BlobReader, error)
  • func (d *BlobReader) Close() error
  • func (d *BlobReader) Read(p []byte) (int, error)
• type LayerFetcher
  • func NewLayerFetcher(source Source) *LayerFetcher
  • func (f *LayerFetcher) Close() error
  • func (f *LayerFetcher) ImageInfo(logger lager.Logger) (imagepuller.ImageInfo, error)
  • func (f *LayerFetcher) StreamBlob(logger lager.Logger, layerInfo imagepuller.LayerInfo) (io.ReadCloser, int64, error)
• type Manifest
• type QuotaedReader
  • func NewQuotaedReader(delegateReader io.ReadCloser, quotaLeft int64, errorMsg string) *QuotaedReader
  • func (q *QuotaedReader) Close() error
  • func (q *QuotaedReader) Read(p []byte) (int, error)
• type Source

Types

type BlobReader

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

func NewBlobReader

func NewBlobReader(blobPath string) (*BlobReader, error)

func (*BlobReader) Close

func (d *BlobReader) Close() error

func (*BlobReader) Read

func (d *BlobReader) Read(p []byte) (int, error)

type LayerFetcher

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

func NewLayerFetcher

func NewLayerFetcher(source Source) *LayerFetcher

func (*LayerFetcher) Close

func (f *LayerFetcher) Close() error

func (*LayerFetcher) ImageInfo

func (f *LayerFetcher) ImageInfo(logger lager.Logger) (imagepuller.ImageInfo, error)

func (*LayerFetcher) StreamBlob

func (f *LayerFetcher) StreamBlob(logger lager.Logger, layerInfo imagepuller.LayerInfo) (io.ReadCloser, int64, error)

type Manifest

type Manifest interface {
	// Manifest is just a shortcut for the types.Image interface,
	// to make it simpler to test with fakes.
	types.Image
}

type QuotaedReader

type QuotaedReader struct {
	DelegateReader            io.ReadCloser
	QuotaLeft                 int64
	QuotaExceededErrorHandler func() error
}

func NewQuotaedReader

func NewQuotaedReader(delegateReader io.ReadCloser, quotaLeft int64, errorMsg string) *QuotaedReader

func (*QuotaedReader) Close

func (q *QuotaedReader) Close() error

func (*QuotaedReader) Read

func (q *QuotaedReader) Read(p []byte) (int, error)

type Source

type Source interface {
	Manifest(logger lager.Logger) (types.Image, error)
	Blob(logger lager.Logger, layerInfo imagepuller.LayerInfo) (string, int64, error)
	Close() error
}