memory

package

v0.0.0-...-c8ec3b5 Latest Latest Go to latest Published: Jan 14, 2016 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package memory registers the "memory" blobserver storage type, storing blobs in an in-memory map.

This section is empty.

This section is empty.

This section is empty.

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

Storage is an in-memory implementation of the blobserver Storage interface. It also includes other convenience methods used by tests.

Its zero value is usable.

func NewCache(size int64) *Storage

NewCache returns a cache that won't store more than size bytes. Blobs are evicted in LRU order.

func (s *Storage) BlobContents(br blob.Ref) (contents string, ok bool)

BlobContents returns as a string the contents of the blob br.

func (s *Storage) BlobrefStrings() []string

BlobrefStrings returns the sorted stringified blobrefs stored in s.

func (s *Storage) EnumerateBlobs(ctx context.Context, dest chan<- blob.SizedRef, after string, limit int) error

func (s *Storage) Fetch(ref blob.Ref) (file io.ReadCloser, size uint32, err error)

func (s *Storage) NumBlobs() int

NumBlobs returns the number of blobs stored in s.

func (s *Storage) ReceiveBlob(br blob.Ref, source io.Reader) (blob.SizedRef, error)

func (s *Storage) RemoveBlobs(blobs []blob.Ref) error

func (s *Storage) StatBlobs(dest chan<- blob.SizedRef, blobs []blob.Ref) error

func (s *Storage) Stats() (blobsFetched, bytesFetched int64)

Stats returns the number of blobs and number of bytes that were fetched from s.

func (s *Storage) StreamBlobs(ctx context.Context, dest chan<- blobserver.BlobAndToken, contToken string) error

func (s *Storage) SubFetch(ref blob.Ref, offset, length int64) (io.ReadCloser, error)

func (s *Storage) SumBlobSize() int64

SumBlobSize returns the total size in bytes of all the blobs in s.