wazero

Documentation

Index

• func NewWazeroFunctionRuntimeFactory() api.FunctionRuntimeFactory
• type WazeroFunctionRuntime
  • func (r *WazeroFunctionRuntime) Call(e contube.Record) (contube.Record, error)
  • func (r *WazeroFunctionRuntime) Stop()
  • func (r *WazeroFunctionRuntime) WaitForReady() <-chan error
• type WazeroFunctionRuntimeFactory
  • func (f *WazeroFunctionRuntimeFactory) NewFunctionRuntime(instance api.FunctionInstance) (api.FunctionRuntime, error)

Functions

func NewWazeroFunctionRuntimeFactory

func NewWazeroFunctionRuntimeFactory() api.FunctionRuntimeFactory

Types

type WazeroFunctionRuntime

type WazeroFunctionRuntime struct {
	api.FunctionRuntime
	// contains filtered or unexported fields
}

func (*WazeroFunctionRuntime) Call

func (r *WazeroFunctionRuntime) Call(e contube.Record) (contube.Record, error)

func (*WazeroFunctionRuntime) Stop

func (r *WazeroFunctionRuntime) Stop()

func (*WazeroFunctionRuntime) WaitForReady

func (r *WazeroFunctionRuntime) WaitForReady() <-chan error

type WazeroFunctionRuntimeFactory

type WazeroFunctionRuntimeFactory struct {
}

func (*WazeroFunctionRuntimeFactory) NewFunctionRuntime

func (f *WazeroFunctionRuntimeFactory) NewFunctionRuntime(instance api.FunctionInstance) (api.FunctionRuntime, error)