blobstore

Documentation

Index

• type BlobManager
  • func NewBlobManager(fs boshsys.FileSystem, dirProvider boshdir.Provider) (manager BlobManager)
  • func (manager BlobManager) Fetch(blobID string) (blobBytes []byte, err error)
  • func (manager BlobManager) Write(blobID string, blobBytes []byte) (err error)
• type Blobstore
  • func NewExternalBlobstore(provider string, options map[string]interface{}, fs boshsys.FileSystem, ...) Blobstore
  • func NewLocalBlobstore(fs boshsys.FileSystem, uuidGen boshuuid.Generator, ...) Blobstore
  • func NewRetryableBlobstore(blobstore Blobstore, maxTries int, logger boshlog.Logger) Blobstore
  • func NewSHA1VerifiableBlobstore(blobstore Blobstore) Blobstore
• type Provider
  • func NewProvider(platform boshplatform.Platform, dirProvider boshdir.Provider, ...) (p Provider)
  • func (p Provider) Get(settings boshsettings.Blobstore) (blobstore Blobstore, err error)

Types

type BlobManager

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

func NewBlobManager

func NewBlobManager(fs boshsys.FileSystem, dirProvider boshdir.Provider) (manager BlobManager)

func (BlobManager) Fetch

func (manager BlobManager) Fetch(blobID string) (blobBytes []byte, err error)

func (BlobManager) Write

func (manager BlobManager) Write(blobID string, blobBytes []byte) (err error)

type Blobstore

type Blobstore interface {
	// Assuming that local file system is available,
	// file handle is returned to downloaded blob.
	// Caller must not assume anything about layout of such scratch space.
	// Cleanup call is needed to properly cleanup downloaded blob.
	Get(blobID, fingerprint string) (fileName string, err error)

	CleanUp(fileName string) (err error)

	Create(fileName string) (blobID string, fingerprint string, err error)

	Validate() (err error)
}

func NewExternalBlobstore

func NewExternalBlobstore(
	provider string,
	options map[string]interface{},
	fs boshsys.FileSystem,
	runner boshsys.CmdRunner,
	uuidGen boshuuid.Generator,
	configFilePath string,
) Blobstore

func NewLocalBlobstore

func NewLocalBlobstore(
	fs boshsys.FileSystem,
	uuidGen boshuuid.Generator,
	options map[string]interface{},
) Blobstore

func NewRetryableBlobstore

func NewRetryableBlobstore(blobstore Blobstore, maxTries int, logger boshlog.Logger) Blobstore

func NewSHA1VerifiableBlobstore

func NewSHA1VerifiableBlobstore(blobstore Blobstore) Blobstore

type Provider

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

func NewProvider

func NewProvider(
	platform boshplatform.Platform,
	dirProvider boshdir.Provider,
	logger boshlog.Logger,
) (p Provider)

func (Provider) Get

func (p Provider) Get(settings boshsettings.Blobstore) (blobstore Blobstore, err error)