wasmtime

Documentation

Index

• Constants
• type ABILinker
• type ExportFuncs
  • func NewExportFuncs(ctx context.Context, rt *Runtime) (*ExportFuncs, error)
  • func (ef *ExportFuncs) CallContract(offset, size int32, vmAddrPtr, vmSizePtr int32) int32
  • func (ef *ExportFuncs) GetDB(kAddr, kSize int32, vmAddrPtr, vmSizePtr int32) int32
  • func (ef *ExportFuncs) GetData(rid, vmAddrPtr, vmSizePtr int32) int32
  • func (ef *ExportFuncs) GetEnv(kAddr, kSize int32, vmAddrPtr, vmSizePtr int32) int32
  • func (ef *ExportFuncs) GetSQLDB(addr, size int32, vmAddrPtr, vmSizePtr int32) int32
  • func (ef *ExportFuncs) LinkABI(impt Import) error
  • func (ef *ExportFuncs) Log(logLevel, ptr, size int32) int32
  • func (ef *ExportFuncs) SendTX(offset, size int32) int32
  • func (ef *ExportFuncs) SetDB(kAddr, kSize, vAddr, vSize int32) int32
  • func (ef *ExportFuncs) SetData(rid, addr, size int32) int32
  • func (ef *ExportFuncs) SetSQLDB(addr, size int32) int32
• type Import
• type Instance
  • func NewInstanceByCode(ctx context.Context, id types.SFID, code []byte) (i *Instance, err error)
  • func (i *Instance) AddResource(ctx context.Context, data []byte) uint32
  • func (i *Instance) Get(k string) int32
  • func (i *Instance) GetResource(id uint32) ([]byte, bool)
  • func (i *Instance) Handle(ctx context.Context, t *Task) *wasm.EventHandleResult
  • func (i *Instance) HandleEvent(ctx context.Context, fn string, data []byte) *wasm.EventHandleResult
  • func (i *Instance) ID() string
  • func (i *Instance) RmvResource(ctx context.Context, id uint32)
  • func (i *Instance) Start(ctx context.Context) error
  • func (i *Instance) State() wasm.InstanceState
  • func (i *Instance) Stop(ctx context.Context) error
• type Runtime
  • func NewRuntime() *Runtime
  • func (rt *Runtime) Call(name string, args ...interface{}) (interface{}, error)
  • func (rt *Runtime) Copy(hostData []byte, vmAddrPtr, vmSizePtr int32) error
  • func (rt *Runtime) Initiate(lk ABILinker, code []byte) error
  • func (rt *Runtime) PutUint32Le(buf []byte, vmAddr int32, val uint32) error
  • func (rt *Runtime) Read(addr, size int32) ([]byte, error)
• type Task
  • func NewTask(vm *Instance, fn string, pl []byte) *Task
  • func (t *Task) Arg() interface{}
  • func (t *Task) Handle(ctx context.Context)
  • func (t *Task) ID() string
  • func (t *Task) Subject() string
  • func (t *Task) Wait(du time.Duration) *wasm.EventHandleResult

Constants

const MaxInt = int(MaxUint >> 1)

const MaxUint = ^uint32(0)

Types

type ABILinker

type ABILinker interface {
	LinkABI(Import) error
}

type ExportFuncs

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

func NewExportFuncs

func NewExportFuncs(ctx context.Context, rt *Runtime) (*ExportFuncs, error)

func (*ExportFuncs) CallContract

func (ef *ExportFuncs) CallContract(offset, size int32, vmAddrPtr, vmSizePtr int32) int32

func (*ExportFuncs) GetDB

func (ef *ExportFuncs) GetDB(kAddr, kSize int32, vmAddrPtr, vmSizePtr int32) int32

func (*ExportFuncs) GetData

func (ef *ExportFuncs) GetData(rid, vmAddrPtr, vmSizePtr int32) int32

func (*ExportFuncs) GetEnv

func (ef *ExportFuncs) GetEnv(kAddr, kSize int32, vmAddrPtr, vmSizePtr int32) int32

func (*ExportFuncs) GetSQLDB

func (ef *ExportFuncs) GetSQLDB(addr, size int32, vmAddrPtr, vmSizePtr int32) int32

func (*ExportFuncs) LinkABI

func (ef *ExportFuncs) LinkABI(impt Import) error

func (*ExportFuncs) Log

func (ef *ExportFuncs) Log(logLevel, ptr, size int32) int32

func (*ExportFuncs) SendTX

func (ef *ExportFuncs) SendTX(offset, size int32) int32

TODO: add chainID in sendtx abi TODO: make sendTX async, and add callback if possible

func (*ExportFuncs) SetDB

func (ef *ExportFuncs) SetDB(kAddr, kSize, vAddr, vSize int32) int32

func (*ExportFuncs) SetData

func (ef *ExportFuncs) SetData(rid, addr, size int32) int32

TODO SetData if rid not exist, should be assigned by wasm?

func (*ExportFuncs) SetSQLDB

func (ef *ExportFuncs) SetSQLDB(addr, size int32) int32

type Import

type Import func(module, name string, f interface{}) error

type Instance

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

func NewInstanceByCode

func NewInstanceByCode(ctx context.Context, id types.SFID, code []byte) (i *Instance, err error)

func (*Instance) AddResource

func (i *Instance) AddResource(ctx context.Context, data []byte) uint32

func (*Instance) Get

func (i *Instance) Get(k string) int32

func (*Instance) GetResource

func (i *Instance) GetResource(id uint32) ([]byte, bool)

func (*Instance) Handle

func (i *Instance) Handle(ctx context.Context, t *Task) *wasm.EventHandleResult

func (*Instance) HandleEvent

func (i *Instance) HandleEvent(ctx context.Context, fn string, data []byte) *wasm.EventHandleResult

func (*Instance) ID

func (i *Instance) ID() string

func (*Instance) RmvResource

func (i *Instance) RmvResource(ctx context.Context, id uint32)

func (*Instance) Start

func (i *Instance) Start(ctx context.Context) error

func (*Instance) State

func (i *Instance) State() wasm.InstanceState

func (*Instance) Stop

func (i *Instance) Stop(ctx context.Context) error

type Runtime

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

func NewRuntime

func NewRuntime() *Runtime

func (*Runtime) Call

func (rt *Runtime) Call(name string, args ...interface{}) (interface{}, error)

func (*Runtime) Copy

func (rt *Runtime) Copy(hostData []byte, vmAddrPtr, vmSizePtr int32) error

func (*Runtime) Initiate

func (rt *Runtime) Initiate(lk ABILinker, code []byte) error

func (*Runtime) PutUint32Le

func (rt *Runtime) PutUint32Le(buf []byte, vmAddr int32, val uint32) error

func (*Runtime) Read

func (rt *Runtime) Read(addr, size int32) ([]byte, error)

type Task

type Task struct {
	EventID string
	Handler string
	Payload []byte
	Res     chan *wasm.EventHandleResult
	mq.TaskState
	// contains filtered or unexported fields
}

func NewTask

func NewTask(vm *Instance, fn string, pl []byte) *Task

func (*Task) Arg

func (t *Task) Arg() interface{}

func (*Task) Handle

func (t *Task) Handle(ctx context.Context)

func (*Task) ID

func (t *Task) ID() string

func (*Task) Subject

func (t *Task) Subject() string

func (*Task) Wait

func (t *Task) Wait(du time.Duration) *wasm.EventHandleResult