blobstore

package
Version: v2.367.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 9, 2021 License: Apache-2.0 Imports: 10 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewCascadingBlobstore

func NewCascadingBlobstore(
	innerBlobstore utilblobstore.DigestBlobstore,
	blobManagers []BlobManagerInterface,
	logger boshlog.Logger,
) utilblobstore.DigestBlobstore

Types

type BlobManager

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

func NewBlobManager

func NewBlobManager(workdir string) (*BlobManager, error)

func (BlobManager) BlobExists

func (m BlobManager) BlobExists(blobID string) bool

func (BlobManager) Delete

func (m BlobManager) Delete(blobID string) error

func (BlobManager) Fetch

func (m BlobManager) Fetch(blobID string) (boshsys.File, int, error)

func (BlobManager) GetPath

func (m BlobManager) GetPath(blobID string, digest boshcrypto.Digest) (string, error)

func (BlobManager) Write

func (m BlobManager) Write(blobID string, r io.Reader) error

type BlobManagerInterface

type BlobManagerInterface interface {
	Fetch(blobID string) (boshsys.File, int, error)
	Write(blobID string, reader io.Reader) error
	GetPath(blobID string, digest boshcrypto.Digest) (string, error)
	Delete(blobID string) error
	BlobExists(blobID string) bool
}

Directories

Path Synopsis
Code generated by counterfeiter.
Code generated by counterfeiter.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL