blobstore

Documentation

Index

• Constants
• type Blobstore
  • func NewExternalBlobstore(provider string, options map[string]interface{}, fs boshsys.FileSystem, ...) Blobstore
  • func NewLocalBlobstore(fs boshsys.FileSystem, uuidGen boshuuid.Generator, ...) Blobstore
• type DigestBlobstore
  • func NewDigestVerifiableBlobstore(blobstore Blobstore, fs boshsys.FileSystem, ...) DigestBlobstore
  • func NewRetryableBlobstore(blobstore DigestBlobstore, maxTries int, logger boshlog.Logger) DigestBlobstore
• type Provider
  • func NewProvider(fs system.FileSystem, runner system.CmdRunner, configDir string, ...) Provider
  • func (p Provider) Get(storeType string, options map[string]interface{}) (DigestBlobstore, error)

Constants

const (
	BlobstoreTypeDummy = "dummy"
	BlobstoreTypeLocal = "local"
)

Types

type Blobstore

type Blobstore interface {
	Get(blobID string) (fileName string, err error)

	CleanUp(fileName string) (err error)

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

	Validate() (err error)

	Delete(blobId string) (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

type DigestBlobstore

type DigestBlobstore 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 string, digest boshcrypto.Digest) (fileName string, err error)

	CleanUp(fileName string) (err error)

	Create(fileName string) (blobID string, digest boshcrypto.MultipleDigest, err error)

	Validate() (err error)

	Delete(blobId string) (err error)
}

func NewDigestVerifiableBlobstore

func NewDigestVerifiableBlobstore(blobstore Blobstore, fs boshsys.FileSystem, createAlgorithms []boshcrypto.Algorithm) DigestBlobstore

func NewRetryableBlobstore

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

type Provider

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

func NewProvider

func NewProvider(
	fs system.FileSystem,
	runner system.CmdRunner,
	configDir string,
	logger boshlog.Logger,
) Provider

func (Provider) Get

func (p Provider) Get(storeType string, options map[string]interface{}) (DigestBlobstore, error)