Documentation ¶
Index ¶
- Constants
- Variables
- func NewContext(importsHandler api.ImportsHandler, instance api.WasmInstance) api.ABIContext
- type DefaultImportsHandler
- func (d *DefaultImportsHandler) CallForeignFunction(funcName string, param []byte) ([]byte, api.WasmResult)
- func (d *DefaultImportsHandler) CancelGrpcCall(token int32) api.WasmResult
- func (d *DefaultImportsHandler) CloseDownstream() api.WasmResult
- func (d *DefaultImportsHandler) CloseGrpcCall(token int32) api.WasmResult
- func (d *DefaultImportsHandler) CloseHttpRequest() api.WasmResult
- func (d *DefaultImportsHandler) CloseHttpResponse() api.WasmResult
- func (d *DefaultImportsHandler) CloseUpstream() api.WasmResult
- func (d *DefaultImportsHandler) DefineMetric(metricType api.MetricType, name string) (int32, api.WasmResult)
- func (d *DefaultImportsHandler) DequeueSharedQueue(queueID uint32) (string, api.WasmResult)
- func (d *DefaultImportsHandler) Done() api.WasmResult
- func (d *DefaultImportsHandler) EnqueueSharedQueue(queueID uint32, data string) api.WasmResult
- func (d *DefaultImportsHandler) GetCurrentTimeNanoseconds() (int32, api.WasmResult)
- func (d *DefaultImportsHandler) GetDownStreamData() api.IoBuffer
- func (d *DefaultImportsHandler) GetFuncCallData() api.IoBuffer
- func (d *DefaultImportsHandler) GetGrpcReceiveBuffer() api.IoBuffer
- func (d *DefaultImportsHandler) GetGrpcReceiveInitialMetaData() api.HeaderMap
- func (d *DefaultImportsHandler) GetGrpcReceiveTrailerMetaData() api.HeaderMap
- func (d *DefaultImportsHandler) GetHttpCallResponseBody() api.IoBuffer
- func (d *DefaultImportsHandler) GetHttpCallResponseHeaders() api.HeaderMap
- func (d *DefaultImportsHandler) GetHttpCallResponseTrailer() api.HeaderMap
- func (d *DefaultImportsHandler) GetHttpRequestBody() api.IoBuffer
- func (d *DefaultImportsHandler) GetHttpRequestHeader() api.HeaderMap
- func (d *DefaultImportsHandler) GetHttpRequestTrailer() api.HeaderMap
- func (d *DefaultImportsHandler) GetHttpResponseBody() api.IoBuffer
- func (d *DefaultImportsHandler) GetHttpResponseHeader() api.HeaderMap
- func (d *DefaultImportsHandler) GetHttpResponseTrailer() api.HeaderMap
- func (d *DefaultImportsHandler) GetLogLevel() api.LogLevel
- func (d *DefaultImportsHandler) GetMetric(metricID int32) (int64, api.WasmResult)
- func (d *DefaultImportsHandler) GetPluginConfig() api.IoBuffer
- func (d *DefaultImportsHandler) GetProperty(key string) (string, api.WasmResult)
- func (d *DefaultImportsHandler) GetRootContextID() int32
- func (d *DefaultImportsHandler) GetSharedData(key string) (string, uint32, api.WasmResult)
- func (d *DefaultImportsHandler) GetStatus() (int32, string, api.WasmResult)
- func (d *DefaultImportsHandler) GetUpstreamData() api.IoBuffer
- func (d *DefaultImportsHandler) GetVmConfig() api.IoBuffer
- func (d *DefaultImportsHandler) GrpcCall(grpcService string, serviceName string, method string, data api.IoBuffer, ...) (int32, api.WasmResult)
- func (d *DefaultImportsHandler) HttpCall(url string, headers api.HeaderMap, body api.IoBuffer, trailer api.HeaderMap, ...) (int32, api.WasmResult)
- func (d *DefaultImportsHandler) IncrementMetric(metricID int32, offset int64) api.WasmResult
- func (d *DefaultImportsHandler) Log(level api.LogLevel, msg string) api.WasmResult
- func (d *DefaultImportsHandler) OpenGrpcStream(grpcService string, serviceName string, method string) (int32, api.WasmResult)
- func (d *DefaultImportsHandler) RecordMetric(metricID int32, value int64) api.WasmResult
- func (d *DefaultImportsHandler) RegisterSharedQueue(queueName string) (uint32, api.WasmResult)
- func (d *DefaultImportsHandler) ResolveSharedQueue(queueName string) (uint32, api.WasmResult)
- func (d *DefaultImportsHandler) ResumeDownstream() api.WasmResult
- func (d *DefaultImportsHandler) ResumeHttpRequest() api.WasmResult
- func (d *DefaultImportsHandler) ResumeHttpResponse() api.WasmResult
- func (d *DefaultImportsHandler) ResumeUpstream() api.WasmResult
- func (d *DefaultImportsHandler) SendGrpcCallMsg(token int32, data api.IoBuffer, endOfStream int32) api.WasmResult
- func (d *DefaultImportsHandler) SendHttpResp(respCode int32, respCodeDetail api.IoBuffer, respBody api.IoBuffer, ...) api.WasmResult
- func (d *DefaultImportsHandler) SetEffectiveContextID(contextID int32) api.WasmResult
- func (d *DefaultImportsHandler) SetProperty(key string, value string) api.WasmResult
- func (d *DefaultImportsHandler) SetSharedData(key string, value string, cas uint32) api.WasmResult
- func (d *DefaultImportsHandler) SetTickPeriodMilliseconds(tickPeriodMilliseconds int32) api.WasmResult
- func (d *DefaultImportsHandler) Wait() api.Action
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 (d *DefaultImportsHandler) Done() api.WasmResult
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) IncrementMetric ¶
func (d *DefaultImportsHandler) IncrementMetric(metricID int32, offset int64) api.WasmResult
func (*DefaultImportsHandler) Log ¶
func (d *DefaultImportsHandler) Log(level api.LogLevel, msg string) api.WasmResult
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 (*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
Click to show internal directories.
Click to hide internal directories.