exec

Documentation

Index

• Variables
• func RunModule(ctx context.Context, executor ModuleExecutor, ...) (*pbssinternal.ModuleOutput, []byte, error)
• type BaseExecutor
  • func NewBaseExecutor(ctx context.Context, moduleName string, wasmModule wasm.Module, ...) *BaseExecutor
  • func (e *BaseExecutor) Close(ctx context.Context) error
• type ErrorExecutor
  • func (e *ErrorExecutor) Error() string
• type MapperModuleExecutor
  • func NewMapperModuleExecutor(baseExecutor *BaseExecutor, outputType string) *MapperModuleExecutor
  • func (e *MapperModuleExecutor) HasValidOutput() bool
  • func (e *MapperModuleExecutor) Name() string
  • func (e *MapperModuleExecutor) String() string
• type ModuleExecutor
• type StoreModuleExecutor
  • func NewStoreModuleExecutor(baseExecutor *BaseExecutor, outputStore store.DeltaAccessor) *StoreModuleExecutor
  • func (e *StoreModuleExecutor) HasValidOutput() bool
  • func (e *StoreModuleExecutor) Name() string
  • func (e *StoreModuleExecutor) String() string

Variables

var ErrWasmDeterministicExec = errors.New("wasm execution failed deterministically")

Functions

func RunModule

func RunModule(ctx context.Context, executor ModuleExecutor, execOutput execout.ExecutionOutputGetter) (*pbssinternal.ModuleOutput, []byte, error)

Types

type BaseExecutor

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

func NewBaseExecutor

func NewBaseExecutor(ctx context.Context, moduleName string, wasmModule wasm.Module, cacheEnabled bool, wasmArguments []wasm.Argument, entrypoint string, tracer ttrace.Tracer) *BaseExecutor

func (*BaseExecutor) Close

func (e *BaseExecutor) Close(ctx context.Context) error

type ErrorExecutor

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

func (*ErrorExecutor) Error

func (e *ErrorExecutor) Error() string

type MapperModuleExecutor

type MapperModuleExecutor struct {
	BaseExecutor
	// contains filtered or unexported fields
}

func NewMapperModuleExecutor

func NewMapperModuleExecutor(baseExecutor *BaseExecutor, outputType string) *MapperModuleExecutor

func (*MapperModuleExecutor) HasValidOutput

func (e *MapperModuleExecutor) HasValidOutput() bool

func (*MapperModuleExecutor) Name

func (e *MapperModuleExecutor) Name() string

Name implements ModuleExecutor

func (*MapperModuleExecutor) String

func (e *MapperModuleExecutor) String() string

type ModuleExecutor

type ModuleExecutor interface {
	// Name returns the name of the module as defined in the manifest.
	Name() string
	String() string
	Close(ctx context.Context) error

	HasValidOutput() bool
	// contains filtered or unexported methods
}

type StoreModuleExecutor

type StoreModuleExecutor struct {
	BaseExecutor
	// contains filtered or unexported fields
}

func NewStoreModuleExecutor

func NewStoreModuleExecutor(baseExecutor *BaseExecutor, outputStore store.DeltaAccessor) *StoreModuleExecutor

func (*StoreModuleExecutor) HasValidOutput

func (e *StoreModuleExecutor) HasValidOutput() bool

func (*StoreModuleExecutor) Name

func (e *StoreModuleExecutor) Name() string

func (*StoreModuleExecutor) String

func (e *StoreModuleExecutor) String() string