util

Documentation

Index

• func NewExecutorSpecificBidStrategy(provider executor.ExecutorProvider) bidstrategy.BidStrategy
• func NewNoopExecutors(config noop_executor.ExecutorConfig) executor.ExecutorProvider
• func NewNoopStorageProvider(ctx context.Context, cm *system.CleanupManager, ...) (storage.StorageProvider, error)
• func NewStandardExecutorProvider(cfg types.EngineConfig, executorOptions StandardExecutorOptions) (executor.ExecutorProvider, error)
• func NewStandardStorageProvider(cfg types.Bacalhau) (storage.StorageProvider, error)
• type StandardExecutorOptions
• type StandardStorageProviderOptions

Functions

func NewExecutorSpecificBidStrategy

func NewExecutorSpecificBidStrategy(provider executor.ExecutorProvider) bidstrategy.BidStrategy

func NewNoopExecutors

func NewNoopExecutors(config noop_executor.ExecutorConfig) executor.ExecutorProvider

return noop executors for all engines

func NewNoopStorageProvider

func NewNoopStorageProvider(
	ctx context.Context,
	cm *system.CleanupManager,
	config noop_storage.StorageConfig,
) (storage.StorageProvider, error)

func NewStandardExecutorProvider

func NewStandardExecutorProvider(
	cfg types.EngineConfig,
	executorOptions StandardExecutorOptions,
) (executor.ExecutorProvider, error)

func NewStandardStorageProvider

func NewStandardStorageProvider(cfg types.Bacalhau) (storage.StorageProvider, error)

Types

type StandardExecutorOptions

type StandardExecutorOptions struct {
	DockerID string
}

type StandardStorageProviderOptions

type StandardStorageProviderOptions struct {
	IPFSConnect           string
	DownloadPath          string
	AllowListedLocalPaths []string
}