util

package
v1.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 24, 2024 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source 
const PluggableExecutorPluginName = "PLUGGABLE_EXECUTOR"

Variables

This section is empty.

Functions

func NewExecutorSpecificBidStrategy added in v0.3.24 

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 added in v1.0.4 

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

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

func NewPluginExecutorManager added in v1.0.4 

func NewPluginExecutorManager() *PluginExecutorManager

func (*PluginExecutorManager) Get added in v1.0.4 

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

func (*PluginExecutorManager) Has added in v1.0.4 

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

func (*PluginExecutorManager) Keys added in v1.0.4 

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

Keys returns the keys of the registered executors

func (*PluginExecutorManager) RegisterPlugin added in v1.0.4 

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

func (*PluginExecutorManager) Start added in v1.0.4 

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

func (*PluginExecutorManager) Stop added in v1.0.4 

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

type PluginExecutorManagerConfig added in v1.0.4 

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

type PluginExecutorOptions added in v1.0.4 

type PluginExecutorOptions struct {
	Plugins []PluginExecutorManagerConfig
}

type StandardExecutorOptions 

type StandardExecutorOptions struct {
	DockerID string
}

type StandardStorageProviderOptions 

type StandardStorageProviderOptions struct {
	API                   ipfs.Client
	DownloadPath          string
	AllowListedLocalPaths []string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.