wasm

package
v1.0.0-rc0 Latest Latest
Warning

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

 Go to latest Published: Jan 12, 2023 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var NameVersion = "w3bstream@v0.0.1"

Functions

func DBExecutorFromContext 

func DBExecutorFromContext(ctx context.Context) (sqlx.DBExecutor, bool)

func EnvPrefixFromContext added in v1.0.0 

func EnvPrefixFromContext(ctx context.Context) (string, bool)

func LoggerFromContext added in v1.0.0 

func LoggerFromContext(ctx context.Context) (log.Logger, bool)

func MustDBExecutorFromContext 

func MustDBExecutorFromContext(ctx context.Context) sqlx.DBExecutor

func MustEnvPrefixFromContext added in v1.0.0 

func MustEnvPrefixFromContext(ctx context.Context) string

func MustLoggerFromContext added in v1.0.0 

func MustLoggerFromContext(ctx context.Context) log.Logger

func MustRedisPrefixFromContext added in v1.0.0 

func MustRedisPrefixFromContext(ctx context.Context) string

func MustRuntimeResourceFromContext added in v1.0.0 

func MustRuntimeResourceFromContext(ctx context.Context) *mapx.Map[uint32, []byte]

func RedisPrefixFromContext added in v1.0.0 

func RedisPrefixFromContext(ctx context.Context) (string, bool)

func RuntimeResourceFromContext added in v1.0.0 

func RuntimeResourceFromContext(ctx context.Context) (*mapx.Map[uint32, []byte], bool)

func WithChainClient added in v1.0.0 

func WithChainClient(ctx context.Context, v *ChainClient) context.Context

func WithChainClientContext added in v1.0.0 

func WithChainClientContext(v *ChainClient) contextx.WithContext

func WithDBExecutor 

func WithDBExecutor(ctx context.Context, v sqlx.DBExecutor) context.Context

func WithDBExecutorContext 

func WithDBExecutorContext(v sqlx.DBExecutor) contextx.WithContext

func WithEnv added in v1.0.0 

func WithEnv(ctx context.Context, v *Env) context.Context

func WithEnvContext added in v1.0.0 

func WithEnvContext(v *Env) contextx.WithContext

func WithEnvPrefix added in v1.0.0 

func WithEnvPrefix(ctx context.Context, v string) context.Context

func WithEnvPrefixContext added in v1.0.0 

func WithEnvPrefixContext(v string) contextx.WithContext

func WithKVStore added in v1.0.0 

func WithKVStore(ctx context.Context, v KVStore) context.Context

func WithKVStoreContext added in v1.0.0 

func WithKVStoreContext(v KVStore) contextx.WithContext

func WithLogger added in v1.0.0 

func WithLogger(ctx context.Context, v log.Logger) context.Context

func WithLoggerContext added in v1.0.0 

func WithLoggerContext(v log.Logger) contextx.WithContext

func WithRedisPrefix added in v1.0.0 

func WithRedisPrefix(ctx context.Context, v string) context.Context

func WithRedisPrefixContext added in v1.0.0 

func WithRedisPrefixContext(v string) contextx.WithContext

func WithRuntimeResource added in v1.0.0 

func WithRuntimeResource(ctx context.Context, v *mapx.Map[uint32, []byte]) context.Context

func WithRuntimeResourceContext added in v1.0.0 

func WithRuntimeResourceContext(v *mapx.Map[uint32, []byte]) contextx.WithContext

Types

type ABI 

type ABI interface {
	Log(loglevel, ptr, size int32) int32
	GetData(rid, vmAddrPtr, vmSizePtr int32) int32
	SetData(rid, addr, size int32) int32
	GetDB(kAddr, kSize, vmAddrPtr, vmSizePtr int32) int32
	SetDB(kAddr, kSize, vAddr, vSize int32) int32
	SendTX(offset, size int32) int32
	CallContract(offset, size, vmAddrPtr, vmSizePtr int32) int32
	SetSQLDB(addr, size int32) int32
	GetSQLDB(addr, size, vmAddrPtr, vmSizePtr int32) int32
	GetEnv(kAddr, kSize, vmAddrPtr, vmSizePtr int32) int32
}

type Cache added in v1.0.0 

type Cache struct {
	Mode   enums.CacheMode `json:"mode"`
	Prefix string          `json:"prefix,omitempty"`
}

func DefaultCache added in v1.0.0 

func DefaultCache() *Cache

func (*Cache) ConfigType added in v1.0.0 

func (c *Cache) ConfigType() enums.ConfigType

func (*Cache) NewKVStore added in v1.0.0 

func (c *Cache) NewKVStore(ctx context.Context) KVStore

func (*Cache) WithContext added in v1.0.0 

func (c *Cache) WithContext(ctx context.Context) context.Context

type ChainClient added in v1.0.0 

type ChainClient struct {
	PrivateKey    string `json:"privateKey"`
	ChainEndpoint string `chainEndpoint:"chainEndpoint"`
	// contains filtered or unexported fields
}

func ChainClientFromContext added in v1.0.0 

func ChainClientFromContext(ctx context.Context) (*ChainClient, bool)

func MustChainClientFromContext added in v1.0.0 

func MustChainClientFromContext(ctx context.Context) *ChainClient

func (*ChainClient) Build 

func (c *ChainClient) Build() error

func (*ChainClient) CallContract added in v1.0.0 

func (c *ChainClient) CallContract(toStr, dataStr string) ([]byte, error)

func (*ChainClient) ConfigType 

func (c *ChainClient) ConfigType() enums.ConfigType

func (*ChainClient) SendTX added in v1.0.0 

func (c *ChainClient) SendTX(toStr, valueStr, dataStr string) (string, error)

func (*ChainClient) WithContext added in v1.4.6 

func (c *ChainClient) WithContext(ctx context.Context) context.Context

type Configuration added in v1.0.0 

type Configuration interface {
	ConfigType() enums.ConfigType
	WithContext(context.Context) context.Context
}

func NewConfigurationByType added in v1.0.0 

func NewConfigurationByType(t enums.ConfigType) Configuration

type ContextHandler 

type ContextHandler interface {
	Name() string
	GetImports() ImportsHandler
	SetImports(ImportsHandler)
	GetExports() ExportsHandler
	GetInstance() Instance
	SetInstance(Instance)
}

type CtxChainClient added in v1.0.0 

type CtxChainClient struct{}

type CtxDBExecutor 

type CtxDBExecutor struct{}

type CtxEnv added in v1.0.0 

type CtxEnv struct{}

type CtxEnvPrefix added in v1.0.0 

type CtxEnvPrefix struct{}

type CtxKVStore added in v1.0.0 

type CtxKVStore struct{}

type CtxLogger added in v1.0.0 

type CtxLogger struct{}

type CtxRedisPrefix added in v1.0.0 

type CtxRedisPrefix struct{}

type CtxRuntimeResource added in v1.0.0 

type CtxRuntimeResource struct{}

type Env added in v1.0.0 

type Env struct {
	Values [][2]string `json:"values"`
	// contains filtered or unexported fields
}

func EnvFromContext added in v1.0.0 

func EnvFromContext(ctx context.Context) (*Env, bool)

func MustEnvFromContext added in v1.0.0 

func MustEnvFromContext(ctx context.Context) *Env

func NewEvn added in v1.0.0 

func NewEvn(prefix string) *Env

func (*Env) ConfigType added in v1.0.0 

func (env *Env) ConfigType() enums.ConfigType

func (*Env) Get added in v1.0.0 

func (env *Env) Get(k string) (v string, exists bool)

func (*Env) Prefix added in v1.0.0 

func (env *Env) Prefix() string

func (*Env) Set added in v1.0.0 

func (env *Env) Set(k, v string)

func (*Env) WithContext added in v1.0.0 

func (env *Env) WithContext(ctx context.Context) context.Context

type EventConsumer 

type EventConsumer interface {
	HandleEvent(ctx context.Context, handler string, payload []byte) *EventHandleResult
}

type EventHandleResult 

type EventHandleResult struct {
	InstanceID string           `json:"instanceID"`
	Rsp        []byte           `json:"-"`
	Code       ResultStatusCode `json:"code"`
	ErrMsg     string           `json:"errMsg"`
}

type ExportsHandler 

type ExportsHandler interface {
	Start()
	Alloc()
	Free()
}

type Handler 

type Handler interface {
	Name() string
	Call(context.Context, ...interface{})
}

type ImportsHandler 

type ImportsHandler interface {
	GetDB(keyAddr, keySize, valAddr, valSize uint32) (code int32)
	SetDB()
	GetData()
	SetData()
	Log(level uint32)
}

type Instance 

type Instance interface {
	ID() string
	Start(context.Context) error
	Stop(context.Context) error
	State() enums.InstanceState
	AddResource(context.Context, []byte) uint32
	RmvResource(context.Context, uint32)
	GetResource(uint32) ([]byte, bool)
	Get(k string) int32

	EventConsumer
}

type InstanceState 

type InstanceState = enums.InstanceState

type KVStore 

type KVStore interface {
	Get(string) ([]byte, error)
	Set(key string, value []byte) error
}

func KVStoreFromContext added in v1.0.0 

func KVStoreFromContext(ctx context.Context) (KVStore, bool)

func MustKVStoreFromContext added in v1.0.0 

func MustKVStoreFromContext(ctx context.Context) KVStore

type Memory 

type Memory interface {
	Read(context.Context, uint32, uint32) ([]byte, error)
	Write(context.Context, []byte)
}

type Module 

type Module interface {
	Init()
	NewInstance() Instance
	GetABI() []string
}

type ResultStatusCode 

type ResultStatusCode int32

ResultStatusCode wasm call result code 

const (
	ResultStatusCode_OK ResultStatusCode = iota
	ResultStatusCode_UnexportedHandler
	ResultStatusCode_ResourceNotFound
	ResultStatusCode_ImportNotFound
	ResultStatusCode_ImportCallFailed
	ResultStatusCode_TransDataToVMFailed
	ResultStatusCode_TransDataFromVMFailed
	ResultStatusCode_HostInternal
	ResultStatusCode_EnvKeyNotFound
	ResultStatusCode_NoDBContext

	// TODO following result status
	ResultStatusCode_Failed = -1 // reserved for wasm invoke failed
)

type Schema added in v1.0.0 

type Schema struct{ schema.Schema }

func (*Schema) ConfigType added in v1.0.0 

func (s *Schema) ConfigType() enums.ConfigType

func (*Schema) WithContext added in v1.0.0 

func (s *Schema) WithContext(ctx context.Context) context.Context

type VM 

type VM interface {
	Name() string
	Init()
	NewModule(code []byte) Module
}

Source Files

View all Source files

Directories

Path Synopsis

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.