blobstore

Documentation

Index

• func NewCascadingBlobstore(innerBlobstore utilblobstore.DigestBlobstore, ...) utilblobstore.DigestBlobstore
• type BlobManager
  • func NewBlobManager(workdir string) (*BlobManager, error)
  • func (m BlobManager) BlobExists(blobID string) bool
  • func (m BlobManager) Delete(blobID string) error
  • func (m BlobManager) Fetch(blobID string) (boshsys.File, int, error)
  • func (m BlobManager) GetPath(blobID string, digest boshcrypto.Digest) (string, error)
  • func (m BlobManager) Write(blobID string, r io.Reader) error
• type BlobManagerInterface

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
}