spanmanager

Documentation

Index

• Variables
• type MultiReaderCloser
  • func (mrc *MultiReaderCloser) Close() error
• type SectionReaderCloser
  • func (src *SectionReaderCloser) Close() error
• type SpanManager
  • func New(ztoc *ztoc.Ztoc, r *io.SectionReader, cache cache.BlobCache, retries int, ...) *SpanManager
  • func (m *SpanManager) Close()
  • func (m *SpanManager) FetchSingleSpan(spanID compression.SpanID) error
  • func (m *SpanManager) GetContents(startUncompOffset, endUncompOffset compression.Offset) (io.ReadCloser, error)

Variables

var (
	ErrSpanNotAvailable    = errors.New("span not available in cache")
	ErrIncorrectSpanDigest = errors.New("span digests do not match")
	ErrExceedMaxSpan       = errors.New("span id larger than max span id")
)

Specific error types raised by SpanManager.

Types

type MultiReaderCloser

type MultiReaderCloser struct {
	io.Reader
	// contains filtered or unexported fields
}

func (*MultiReaderCloser) Close

func (mrc *MultiReaderCloser) Close() error

type SectionReaderCloser

type SectionReaderCloser struct {
	*io.SectionReader
	// contains filtered or unexported fields
}

func (*SectionReaderCloser) Close

func (src *SectionReaderCloser) Close() error

type SpanManager

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

SpanManager fetches and caches spans of a given layer.

func New

func New(ztoc *ztoc.Ztoc, r *io.SectionReader, cache cache.BlobCache, retries int, cacheOpt ...cache.Option) *SpanManager

TODO: return errors/nil objects on failure

func (*SpanManager) Close

func (m *SpanManager) Close()

Close closes both the underlying zinfo data and blob cache.

func (*SpanManager) FetchSingleSpan

func (m *SpanManager) FetchSingleSpan(spanID compression.SpanID) error

FetchSingleSpan invokes the reader to fetch the span in the background and cache the span without uncompressing. It is invoked by the BackgroundFetcher. span state change: unrequested -> requested -> fetched.

func (*SpanManager) GetContents

func (m *SpanManager) GetContents(startUncompOffset, endUncompOffset compression.Offset) (io.ReadCloser, error)

GetContents returns a reader for the requested contents. The contents may be across multiple spans.