combo

Documentation

Index

• type AllProviderFetcher
• type ComboStorageProvider
  • func NewStorage(_ *system.CleanupManager, allFetcher AllProviderFetcher, ...) (*ComboStorageProvider, error)
  • func (driver *ComboStorageProvider) CleanupStorage(ctx context.Context, storageSpec models.InputSource, ...) error
  • func (driver *ComboStorageProvider) GetVolumeSize(ctx context.Context, storageSpec models.InputSource) (uint64, error)
  • func (driver *ComboStorageProvider) HasStorageLocally(ctx context.Context, storageSpec models.InputSource) (bool, error)
  • func (driver *ComboStorageProvider) IsInstalled(ctx context.Context) (bool, error)
  • func (driver *ComboStorageProvider) PrepareStorage(ctx context.Context, storageDirectory string, storageSpec models.InputSource) (storage.StorageVolume, error)
  • func (driver *ComboStorageProvider) Upload(ctx context.Context, localPath string) (models.SpecConfig, error)
• type ReadProviderFetcher
• type WriteProviderFetcher

Types

type AllProviderFetcher

type AllProviderFetcher func(ctx context.Context) ([]storage.Storage, error)

type ComboStorageProvider

type ComboStorageProvider struct {
	AllFetcher   AllProviderFetcher
	ReadFetcher  ReadProviderFetcher
	WriteFetcher WriteProviderFetcher
}

func NewStorage

func NewStorage(
	_ *system.CleanupManager,
	allFetcher AllProviderFetcher,
	readFetcher ReadProviderFetcher,
	writeFetcher WriteProviderFetcher,
) (*ComboStorageProvider, error)

func (*ComboStorageProvider) CleanupStorage

func (driver *ComboStorageProvider) CleanupStorage(
	ctx context.Context,
	storageSpec models.InputSource,
	volume storage.StorageVolume,
) error

func (*ComboStorageProvider) GetVolumeSize

func (driver *ComboStorageProvider) GetVolumeSize(ctx context.Context, storageSpec models.InputSource) (uint64, error)

func (*ComboStorageProvider) HasStorageLocally

func (driver *ComboStorageProvider) HasStorageLocally(ctx context.Context, storageSpec models.InputSource) (bool, error)

func (*ComboStorageProvider) IsInstalled

func (driver *ComboStorageProvider) IsInstalled(ctx context.Context) (bool, error)

func (*ComboStorageProvider) PrepareStorage

func (driver *ComboStorageProvider) PrepareStorage(
	ctx context.Context,
	storageDirectory string,
	storageSpec models.InputSource,
) (storage.StorageVolume, error)

func (*ComboStorageProvider) Upload

func (driver *ComboStorageProvider) Upload(
	ctx context.Context,
	localPath string,
) (models.SpecConfig, error)

type ReadProviderFetcher

type ReadProviderFetcher func(ctx context.Context, spec models.InputSource) (storage.Storage, error)

type WriteProviderFetcher

type WriteProviderFetcher func(ctx context.Context) (storage.Storage, error)