wasm

Mar 4, 2024

Changes in this version

type Executor

+ func (e *Executor) GetLogStream(ctx context.Context, request executor.LogStreamRequest) (io.ReadCloser, error)

Jan 30, 2024

Changes in this version

+ var ActiveExecutions = lo.Must(telemetry.NewGauge(wasmExecutorMeter, "wasm_active_executions", ...))

Dec 11, 2023

Changes in this version

+ const WasmArch

+ const WasmMaxPagesLimit

+ const WasmPageSize

Nov 16, 2023

Changes in this version

+ const WASM_ARCH

+ const WASM_MAX_PAGES_LIMIT

+ const WASM_PAGE_SIZE

Sep 12, 2023

Changes in this version

type Executor

+ func (*Executor) ShouldBid(ctx context.Context, request bidstrategy.BidStrategyRequest) (bidstrategy.BidStrategyResponse, error)

+ func (*Executor) ShouldBidBasedOnUsage(ctx context.Context, request bidstrategy.BidStrategyRequest, ...) (bidstrategy.BidStrategyResponse, error)

+ func (e *Executor) Cancel(ctx context.Context, executionID string) error

+ func (e *Executor) Start(ctx context.Context, request *executor.RunCommandRequest) error

+ func (e *Executor) Wait(ctx context.Context, executionID string) (<-chan *models.RunCommandResult, <-chan error)

May 9, 2023

Changes in this version

type Executor

+ func (*Executor) GetResourceBidStrategy(context.Context) (bidstrategy.ResourceBidStrategy, error)

+ func (*Executor) GetSemanticBidStrategy(context.Context) (bidstrategy.SemanticBidStrategy, error)

Apr 13, 2023

Changes in this version

+ type ModuleLoader struct

+ func NewModuleLoader(runtime wazero.Runtime, config wazero.ModuleConfig, ...) *ModuleLoader

+ func (loader *ModuleLoader) InstantiateRemoteModule(ctx context.Context, spec model.StorageSpec) (api.Module, error)

+ func (loader *ModuleLoader) Load(ctx context.Context, path string) (wazero.CompiledModule, error)

+ func (loader *ModuleLoader) LoadRemoteModules(ctx context.Context, specs ...model.StorageSpec) ([]wazero.CompiledModule, error)

Mar 21, 2023

Changes in this version

type Executor

+ func (e *Executor) GetOutputStream(context.Context, model.Job) (io.ReadCloser, error)

Mar 4, 2023

Changes in this version

type Executor

+ func (*Executor) GetBidStrategy(context.Context) (bidstrategy.BidStrategy, error)

+ func (e *Executor) Run(ctx context.Context, job model.Job, jobResultsDir string) (*model.RunCommandResult, error)

Feb 28, 2023

Changes in this version

+ func LoadModule(ctx context.Context, runtime wazero.Runtime, path string) (wazero.CompiledModule, error)

+ func LoadRemoteModule(ctx context.Context, runtime wazero.Runtime, provider storage.StorageProvider, ...) (wazero.CompiledModule, error)

+ func ValidateModuleAgainstJob(module wazero.CompiledModule, job model.Spec, ...) error

+ func ValidateModuleAsEntryPoint(module wazero.CompiledModule, name string) error

+ func ValidateModuleHasFunction(module wazero.CompiledModule, name string, parameters []api.ValueType, ...) error

+ func ValidateModuleImports(module wazero.CompiledModule, importModules ...wazero.CompiledModule) error

+ type Executor struct

+ StorageProvider storage.StorageProvider

+ func NewExecutor(_ context.Context, storageProvider storage.StorageProvider) (*Executor, error)

+ func (e *Executor) GetVolumeSize(ctx context.Context, volume model.StorageSpec) (uint64, error)

+ func (e *Executor) HasStorageLocally(ctx context.Context, volume model.StorageSpec) (bool, error)

+ func (e *Executor) IsInstalled(context.Context) (bool, error)

+ func (e *Executor) RunShard(ctx context.Context, shard model.JobShard, jobResultsDir string) (*model.RunCommandResult, error)