storage

Documentation

Index

• func ParallelPrepareStorage(ctx context.Context, provider StorageProvider, specs []model.StorageSpec) (map[*model.StorageSpec]StorageVolume, error)
• type FileSystemNodeType
  • func (i FileSystemNodeType) String() string
• type Storage
• type StorageProvider
• type StorageVolume
• type StorageVolumeConnectorType
  • func (i StorageVolumeConnectorType) String() string

Functions

func ParallelPrepareStorage

func ParallelPrepareStorage(
	ctx context.Context,
	provider StorageProvider,
	specs []model.StorageSpec,
) (map[*model.StorageSpec]StorageVolume, error)

ParallelPrepareStorage downloads all of the data necessary for the passed storage specs in parallel, and returns a map of specs to their download volume counterparts.

Types

type FileSystemNodeType

type FileSystemNodeType int

Used to distinguish files from directories

const (
	FileSystemNodeDirectory FileSystemNodeType
	FileSystemNodeFile
)

func (FileSystemNodeType) String

func (i FileSystemNodeType) String() string

type Storage

type Storage interface {
	model.Providable

	HasStorageLocally(context.Context, model.StorageSpec) (bool, error)

	// how big is the given volume in terms of resource consumption?
	GetVolumeSize(context.Context, model.StorageSpec) (uint64, error)

	PrepareStorage(context.Context, model.StorageSpec) (StorageVolume, error)

	CleanupStorage(context.Context, model.StorageSpec, StorageVolume) error

	// given a local file path - "store" it and return a StorageSpec
	Upload(context.Context, string) (model.StorageSpec, error)
}

type StorageProvider

type StorageProvider interface {
	model.Provider[model.StorageSourceType, Storage]
}

StorageProvider returns a storage that can be used by the job to store data.

type StorageVolume

type StorageVolume struct {
	Type   StorageVolumeConnectorType `json:"type"`
	Source string                     `json:"source"`
	Target string                     `json:"target"`
}

a storage entity that is consumed are produced by a job input storage specs are turned into storage volumes by drivers for example - the input storage spec might be ipfs cid XXX and a driver will turn that into a host path that can be consumed by a job another example - a wasm storage driver references the upstream ipfs cid (source) that can be streamed via a library call using the target name put simply - the nature of a storage volume depends on it's use by the executor engine

type StorageVolumeConnectorType

type StorageVolumeConnectorType int

StorageVolumeConnector is how an upstream storage source will present the volume to a job - examples are "bind" or "library"

const (
	StorageVolumeConnectorBind StorageVolumeConnectorType
)

func (StorageVolumeConnectorType) String

func (i StorageVolumeConnectorType) String() string