util

Documentation

Index

• Constants
• 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 NewPluginExecutorProvider(ctx context.Context, cm *system.CleanupManager, ...) (executor.ExecutorProvider, error)
• func NewStandardExecutorProvider(cfg types.EngineConfig, executorOptions StandardExecutorOptions) (executor.ExecutorProvider, error)
• func NewStandardStorageProvider(cfg types.Bacalhau) (storage.StorageProvider, error)
• type PluginExecutorManager
  • func NewPluginExecutorManager() *PluginExecutorManager
  • func (e *PluginExecutorManager) Get(ctx context.Context, key string) (executor.Executor, error)
  • func (e *PluginExecutorManager) Has(ctx context.Context, key string) bool
  • func (e *PluginExecutorManager) Keys(ctx context.Context) []string
  • func (e *PluginExecutorManager) RegisterPlugin(config PluginExecutorManagerConfig) error
  • func (e *PluginExecutorManager) Start(ctx context.Context) error
  • func (e *PluginExecutorManager) Stop(ctx context.Context) error
• type PluginExecutorManagerConfig
• type PluginExecutorOptions
• type StandardExecutorOptions
• type StandardStorageProviderOptions

Constants

const PluggableExecutorPluginName = "PLUGGABLE_EXECUTOR"

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 NewPluginExecutorProvider

func NewPluginExecutorProvider(
	ctx context.Context,
	cm *system.CleanupManager,
	pluginOptions PluginExecutorOptions,
) (executor.ExecutorProvider, 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 PluginExecutorManager

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

func NewPluginExecutorManager

func NewPluginExecutorManager() *PluginExecutorManager

func (*PluginExecutorManager) Get

func (e *PluginExecutorManager) Get(ctx context.Context, key string) (executor.Executor, error)

func (*PluginExecutorManager) Has

func (e *PluginExecutorManager) Has(ctx context.Context, key string) bool

func (*PluginExecutorManager) Keys

func (e *PluginExecutorManager) Keys(ctx context.Context) []string

Keys returns the keys of the registered executors

func (*PluginExecutorManager) RegisterPlugin

func (e *PluginExecutorManager) RegisterPlugin(config PluginExecutorManagerConfig) error

func (*PluginExecutorManager) Start

func (e *PluginExecutorManager) Start(ctx context.Context) error

func (*PluginExecutorManager) Stop

func (e *PluginExecutorManager) Stop(ctx context.Context) error

type PluginExecutorManagerConfig

type PluginExecutorManagerConfig struct {
	Name             string
	Path             string
	Command          string
	ProtocolVersion  uint
	MagicCookieKey   string
	MagicCookieValue string
}

type PluginExecutorOptions

type PluginExecutorOptions struct {
	Plugins []PluginExecutorManagerConfig
}

type StandardExecutorOptions

type StandardExecutorOptions struct {
	DockerID string
}

type StandardStorageProviderOptions

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