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(ctx context.Context, cm *system.CleanupManager, ...) (executor.ExecutorProvider, error)
• func NewStandardStorageProvider(_ context.Context, cm *system.CleanupManager, ...) (storage.StorageProvider, error)
• type InputLocalityStrategy
  • func NewInputLocalityStrategy(params InputLocalityStrategyParams) *InputLocalityStrategy
  • func (s *InputLocalityStrategy) ShouldBid(ctx context.Context, request bidstrategy.BidStrategyRequest) (bidstrategy.BidStrategyResponse, error)
  • func (s *InputLocalityStrategy) ShouldBidBasedOnUsage(_ context.Context, _ bidstrategy.BidStrategyRequest, _ model.ResourceUsageData) (bidstrategy.BidStrategyResponse, error)
• type InputLocalityStrategyParams
• 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(
	ctx context.Context,
	cm *system.CleanupManager,
	executorOptions StandardExecutorOptions,
) (executor.ExecutorProvider, error)

func NewStandardStorageProvider

func NewStandardStorageProvider(
	_ context.Context,
	cm *system.CleanupManager,
	options StandardStorageProviderOptions,
) (storage.StorageProvider, error)

Types

type InputLocalityStrategy

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

func NewInputLocalityStrategy

func NewInputLocalityStrategy(params InputLocalityStrategyParams) *InputLocalityStrategy

func (*InputLocalityStrategy) ShouldBid

func (s *InputLocalityStrategy) ShouldBid(
	ctx context.Context,
	request bidstrategy.BidStrategyRequest,
) (bidstrategy.BidStrategyResponse, error)

func (*InputLocalityStrategy) ShouldBidBasedOnUsage

func (s *InputLocalityStrategy) ShouldBidBasedOnUsage(
	_ context.Context, _ bidstrategy.BidStrategyRequest, _ model.ResourceUsageData) (bidstrategy.BidStrategyResponse, error)

type InputLocalityStrategyParams

type InputLocalityStrategyParams struct {
	Locality  model.JobSelectionDataLocality
	Executors executor.ExecutorProvider
}

type StandardExecutorOptions

type StandardExecutorOptions struct {
	DockerID string
	Storage  StandardStorageProviderOptions
}

type StandardStorageProviderOptions

type StandardStorageProviderOptions struct {
	API                  ipfs.Client
	FilecoinUnsealedPath string
	DownloadPath         string
	EstuaryAPIKey        string
}