abi

package
v1.0.5 Latest Latest
Warning

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

Go to latest
Published: Jun 27, 2023 License: Apache-2.0 Imports: 6 Imported by: 8

Documentation

Index

Constants

View Source
const ProxyWasmABI_0_1_0 string = "proxy_abi_version_0_1_0"
View Source
const ProxyWasmABI_0_2_0 string = "proxy_abi_version_0_2_0"
View Source
const ProxyWasmABI_0_2_1 string = "proxy_abi_version_0_2_1"

Variables

View Source
var ErrFuncNotExported = errors.New("function is not exported")
View Source
var ErrInvalidResult = errors.New("invalid result")

Functions

func NewContext

func NewContext(importsHandler api.ImportsHandler, instance api.WasmInstance) api.ABIContext

Types

type DefaultImportsHandler

type DefaultImportsHandler struct{}

func (*DefaultImportsHandler) CallForeignFunction

func (d *DefaultImportsHandler) CallForeignFunction(funcName string, param []byte) ([]byte, api.WasmResult)

func (*DefaultImportsHandler) CancelGrpcCall

func (d *DefaultImportsHandler) CancelGrpcCall(token int32) api.WasmResult

func (*DefaultImportsHandler) CloseDownstream

func (d *DefaultImportsHandler) CloseDownstream() api.WasmResult

func (*DefaultImportsHandler) CloseGrpcCall

func (d *DefaultImportsHandler) CloseGrpcCall(token int32) api.WasmResult

func (*DefaultImportsHandler) CloseHttpRequest

func (d *DefaultImportsHandler) CloseHttpRequest() api.WasmResult

func (*DefaultImportsHandler) CloseHttpResponse

func (d *DefaultImportsHandler) CloseHttpResponse() api.WasmResult

func (*DefaultImportsHandler) CloseUpstream

func (d *DefaultImportsHandler) CloseUpstream() api.WasmResult

func (*DefaultImportsHandler) DefineMetric

func (d *DefaultImportsHandler) DefineMetric(metricType api.MetricType, name string) (int32, api.WasmResult)

func (*DefaultImportsHandler) DequeueSharedQueue

func (d *DefaultImportsHandler) DequeueSharedQueue(queueID uint32) (string, api.WasmResult)

func (*DefaultImportsHandler) Done

func (*DefaultImportsHandler) EnqueueSharedQueue

func (d *DefaultImportsHandler) EnqueueSharedQueue(queueID uint32, data string) api.WasmResult

func (*DefaultImportsHandler) GetCurrentTimeNanoseconds

func (d *DefaultImportsHandler) GetCurrentTimeNanoseconds() (int32, api.WasmResult)

func (*DefaultImportsHandler) GetDownStreamData

func (d *DefaultImportsHandler) GetDownStreamData() api.IoBuffer

func (*DefaultImportsHandler) GetFuncCallData

func (d *DefaultImportsHandler) GetFuncCallData() api.IoBuffer

func (*DefaultImportsHandler) GetGrpcReceiveBuffer

func (d *DefaultImportsHandler) GetGrpcReceiveBuffer() api.IoBuffer

func (*DefaultImportsHandler) GetGrpcReceiveInitialMetaData

func (d *DefaultImportsHandler) GetGrpcReceiveInitialMetaData() api.HeaderMap

func (*DefaultImportsHandler) GetGrpcReceiveTrailerMetaData

func (d *DefaultImportsHandler) GetGrpcReceiveTrailerMetaData() api.HeaderMap

func (*DefaultImportsHandler) GetHttpCallResponseBody

func (d *DefaultImportsHandler) GetHttpCallResponseBody() api.IoBuffer

func (*DefaultImportsHandler) GetHttpCallResponseHeaders

func (d *DefaultImportsHandler) GetHttpCallResponseHeaders() api.HeaderMap

func (*DefaultImportsHandler) GetHttpCallResponseTrailer

func (d *DefaultImportsHandler) GetHttpCallResponseTrailer() api.HeaderMap

func (*DefaultImportsHandler) GetHttpRequestBody

func (d *DefaultImportsHandler) GetHttpRequestBody() api.IoBuffer

func (*DefaultImportsHandler) GetHttpRequestHeader

func (d *DefaultImportsHandler) GetHttpRequestHeader() api.HeaderMap

func (*DefaultImportsHandler) GetHttpRequestTrailer

func (d *DefaultImportsHandler) GetHttpRequestTrailer() api.HeaderMap

func (*DefaultImportsHandler) GetHttpResponseBody

func (d *DefaultImportsHandler) GetHttpResponseBody() api.IoBuffer

func (*DefaultImportsHandler) GetHttpResponseHeader

func (d *DefaultImportsHandler) GetHttpResponseHeader() api.HeaderMap

func (*DefaultImportsHandler) GetHttpResponseTrailer

func (d *DefaultImportsHandler) GetHttpResponseTrailer() api.HeaderMap

func (*DefaultImportsHandler) GetLogLevel

func (d *DefaultImportsHandler) GetLogLevel() api.LogLevel

func (*DefaultImportsHandler) GetMetric

func (d *DefaultImportsHandler) GetMetric(metricID int32) (int64, api.WasmResult)

func (*DefaultImportsHandler) GetPluginConfig

func (d *DefaultImportsHandler) GetPluginConfig() api.IoBuffer

func (*DefaultImportsHandler) GetProperty

func (d *DefaultImportsHandler) GetProperty(key string) (string, api.WasmResult)

func (*DefaultImportsHandler) GetRootContextID

func (d *DefaultImportsHandler) GetRootContextID() int32

utils

func (*DefaultImportsHandler) GetSharedData

func (d *DefaultImportsHandler) GetSharedData(key string) (string, uint32, api.WasmResult)

func (*DefaultImportsHandler) GetStatus

func (d *DefaultImportsHandler) GetStatus() (int32, string, api.WasmResult)

func (*DefaultImportsHandler) GetUpstreamData

func (d *DefaultImportsHandler) GetUpstreamData() api.IoBuffer

func (*DefaultImportsHandler) GetVmConfig

func (d *DefaultImportsHandler) GetVmConfig() api.IoBuffer

func (*DefaultImportsHandler) GrpcCall

func (d *DefaultImportsHandler) GrpcCall(grpcService string, serviceName string, method string, data api.IoBuffer, timeoutMilliseconds int32) (int32, api.WasmResult)

func (*DefaultImportsHandler) HttpCall

func (d *DefaultImportsHandler) HttpCall(url string, headers api.HeaderMap, body api.IoBuffer, trailer api.HeaderMap, timeoutMilliseconds int32) (int32, api.WasmResult)

func (*DefaultImportsHandler) IncrementMetric

func (d *DefaultImportsHandler) IncrementMetric(metricID int32, offset int64) api.WasmResult

func (*DefaultImportsHandler) Log

func (*DefaultImportsHandler) OpenGrpcStream

func (d *DefaultImportsHandler) OpenGrpcStream(grpcService string, serviceName string, method string) (int32, api.WasmResult)

func (*DefaultImportsHandler) RecordMetric

func (d *DefaultImportsHandler) RecordMetric(metricID int32, value int64) api.WasmResult

func (*DefaultImportsHandler) RegisterSharedQueue

func (d *DefaultImportsHandler) RegisterSharedQueue(queueName string) (uint32, api.WasmResult)

func (*DefaultImportsHandler) ResolveSharedQueue

func (d *DefaultImportsHandler) ResolveSharedQueue(queueName string) (uint32, api.WasmResult)

func (*DefaultImportsHandler) ResumeDownstream

func (d *DefaultImportsHandler) ResumeDownstream() api.WasmResult

func (*DefaultImportsHandler) ResumeHttpRequest

func (d *DefaultImportsHandler) ResumeHttpRequest() api.WasmResult

func (*DefaultImportsHandler) ResumeHttpResponse

func (d *DefaultImportsHandler) ResumeHttpResponse() api.WasmResult

func (*DefaultImportsHandler) ResumeUpstream

func (d *DefaultImportsHandler) ResumeUpstream() api.WasmResult

func (*DefaultImportsHandler) SendGrpcCallMsg

func (d *DefaultImportsHandler) SendGrpcCallMsg(token int32, data api.IoBuffer, endOfStream int32) api.WasmResult

func (*DefaultImportsHandler) SendHttpResp

func (d *DefaultImportsHandler) SendHttpResp(respCode int32, respCodeDetail api.IoBuffer, respBody api.IoBuffer, additionalHeaderMap api.HeaderMap, grpcCode int32) api.WasmResult

func (*DefaultImportsHandler) SetEffectiveContextID

func (d *DefaultImportsHandler) SetEffectiveContextID(contextID int32) api.WasmResult

func (*DefaultImportsHandler) SetProperty

func (d *DefaultImportsHandler) SetProperty(key string, value string) api.WasmResult

func (*DefaultImportsHandler) SetSharedData

func (d *DefaultImportsHandler) SetSharedData(key string, value string, cas uint32) api.WasmResult

func (*DefaultImportsHandler) SetTickPeriodMilliseconds

func (d *DefaultImportsHandler) SetTickPeriodMilliseconds(tickPeriodMilliseconds int32) api.WasmResult

func (*DefaultImportsHandler) Wait

func (d *DefaultImportsHandler) Wait() api.Action

for golang host environment, no-op

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL