internal

package

Go to main page

Versions in this module

v0

v0.24.0

Jun 18, 2024

v0.23.0

Jan 2, 2024

v0.22.0

Mar 1, 2023

v0.21.0

Jan 31, 2023

v0.20.0

Oct 3, 2022

Changes in this version

+ func ProxyOnConfigure(pluginContextID uint32, vmConfigurationSize int) types.OnPluginStartStatus

+ func ProxyOnContextCreate(contextID uint32, pluginContextID uint32)

+ func ProxyOnDelete(contextID uint32)

+ func ProxyOnDone(contextID uint32) bool

+ func ProxyOnDownstreamConnectionClose(contextID uint32, pType types.PeerType)

+ func ProxyOnDownstreamData(contextID uint32, dataSize int, endOfStream bool) types.Action

+ func ProxyOnHttpCallResponse(pluginContextID, calloutID uint32, numHeaders, bodySize, numTrailers int)

+ func ProxyOnLog(pluginContextID uint32)

+ func ProxyOnNewConnection(contextID uint32) types.Action

+ func ProxyOnQueueReady(contextID, queueID uint32)

+ func ProxyOnRequestBody(contextID uint32, bodySize int, endOfStream bool) types.Action

+ func ProxyOnRequestHeaders(contextID uint32, numHeaders int, endOfStream bool) types.Action

+ func ProxyOnRequestTrailers(contextID uint32, numTrailers int) types.Action

+ func ProxyOnResponseBody(contextID uint32, bodySize int, endOfStream bool) types.Action

+ func ProxyOnResponseHeaders(contextID uint32, numHeaders int, endOfStream bool) types.Action

+ func ProxyOnResponseTrailers(contextID uint32, numTrailers int) types.Action

+ func ProxyOnTick(pluginContextID uint32)

+ func ProxyOnUpstreamConnectionClose(contextID uint32, pType types.PeerType)

+ func ProxyOnUpstreamData(contextID uint32, dataSize int, endOfStream bool) types.Action

+ func ProxyOnVMStart(pluginContextID uint32, vmConfigurationSize int) types.OnVMStartStatus

+ func RegisterMockWasmHost(host ProxyWasmHost) (release func())

+ func VMStateGetActiveContextID() uint32

+ func VMStateReset()

+ func VMStateSetActiveContextID(contextID uint32)

+ type DefaultProxyWAMSHost struct

+ func (d DefaultProxyWAMSHost) ProxyAddHeaderMapValue(mapType MapType, keyData *byte, keySize int, valueData *byte, valueSize int) Status

+ func (d DefaultProxyWAMSHost) ProxyCallForeignFunction(funcNamePtr *byte, funcNameSize int, paramPtr *byte, paramSize int, ...) Status

+ func (d DefaultProxyWAMSHost) ProxyCloseStream(streamType StreamType) Status

+ func (d DefaultProxyWAMSHost) ProxyContinueStream(streamType StreamType) Status

+ func (d DefaultProxyWAMSHost) ProxyDefineMetric(metricType MetricType, metricNameData *byte, metricNameSize int, ...) Status

+ func (d DefaultProxyWAMSHost) ProxyDequeueSharedQueue(queueID uint32, returnValueData **byte, returnValueSize *int) Status

+ func (d DefaultProxyWAMSHost) ProxyDone() Status

+ func (d DefaultProxyWAMSHost) ProxyEnqueueSharedQueue(queueID uint32, valueData *byte, valueSize int) Status

+ func (d DefaultProxyWAMSHost) ProxyGetBufferBytes(bufferType BufferType, start int, maxSize int, returnBufferData **byte, ...) Status

+ func (d DefaultProxyWAMSHost) ProxyGetHeaderMapPairs(mapType MapType, returnValueData **byte, returnValueSize *int) Status

+ func (d DefaultProxyWAMSHost) ProxyGetHeaderMapValue(mapType MapType, keyData *byte, keySize int, returnValueData **byte, ...) Status

+ func (d DefaultProxyWAMSHost) ProxyGetMetric(metricID uint32, returnMetricValue *uint64) Status

+ func (d DefaultProxyWAMSHost) ProxyGetProperty(pathData *byte, pathSize int, returnValueData **byte, returnValueSize *int) Status

+ func (d DefaultProxyWAMSHost) ProxyGetSharedData(keyData *byte, keySize int, returnValueData **byte, returnValueSize *int, ...) Status

+ func (d DefaultProxyWAMSHost) ProxyHttpCall(upstreamData *byte, upstreamSize int, headerData *byte, headerSize int, ...) Status

+ func (d DefaultProxyWAMSHost) ProxyIncrementMetric(metricID uint32, offset int64) Status

+ func (d DefaultProxyWAMSHost) ProxyLog(logLevel LogLevel, messageData *byte, messageSize int) Status

+ func (d DefaultProxyWAMSHost) ProxyRecordMetric(metricID uint32, value uint64) Status

+ func (d DefaultProxyWAMSHost) ProxyRegisterSharedQueue(nameData *byte, nameSize int, returnID *uint32) Status

+ func (d DefaultProxyWAMSHost) ProxyRemoveHeaderMapValue(mapType MapType, keyData *byte, keySize int) Status

+ func (d DefaultProxyWAMSHost) ProxyReplaceHeaderMapValue(mapType MapType, keyData *byte, keySize int, valueData *byte, valueSize int) Status

+ func (d DefaultProxyWAMSHost) ProxyResolveSharedQueue(vmIDData *byte, vmIDSize int, nameData *byte, nameSize int, returnID *uint32) Status

+ func (d DefaultProxyWAMSHost) ProxySendLocalResponse(statusCode uint32, statusCodeDetailData *byte, statusCodeDetailsSize int, ...) Status

+ func (d DefaultProxyWAMSHost) ProxySetBufferBytes(bufferType BufferType, start int, maxSize int, bufferData *byte, ...) Status

+ func (d DefaultProxyWAMSHost) ProxySetEffectiveContext(contextID uint32) Status

+ func (d DefaultProxyWAMSHost) ProxySetHeaderMapPairs(mapType MapType, mapData *byte, mapSize int) Status

+ func (d DefaultProxyWAMSHost) ProxySetProperty(pathData *byte, pathSize int, valueData *byte, valueSize int) Status

+ func (d DefaultProxyWAMSHost) ProxySetSharedData(keyData *byte, keySize int, valueData *byte, valueSize int, cas uint32) Status

+ func (d DefaultProxyWAMSHost) ProxySetTickPeriodMilliseconds(period uint32) Status

+ type ProxyWasmHost interface

+ ProxyAddHeaderMapValue func(mapType MapType, keyData *byte, keySize int, valueData *byte, valueSize int) Status

+ ProxyCallForeignFunction func(funcNamePtr *byte, funcNameSize int, paramPtr *byte, paramSize int, ...) Status

+ ProxyCloseStream func(streamType StreamType) Status

+ ProxyContinueStream func(streamType StreamType) Status

+ ProxyDefineMetric func(metricType MetricType, metricNameData *byte, metricNameSize int, ...) Status

+ ProxyDequeueSharedQueue func(queueID uint32, returnValueData **byte, returnValueSize *int) Status

+ ProxyDone func() Status

+ ProxyEnqueueSharedQueue func(queueID uint32, valueData *byte, valueSize int) Status

+ ProxyGetBufferBytes func(bufferType BufferType, start int, maxSize int, returnBufferData **byte, ...) Status

+ ProxyGetHeaderMapPairs func(mapType MapType, returnValueData **byte, returnValueSize *int) Status

+ ProxyGetHeaderMapValue func(mapType MapType, keyData *byte, keySize int, returnValueData **byte, ...) Status

+ ProxyGetMetric func(metricID uint32, returnMetricValue *uint64) Status

+ ProxyGetProperty func(pathData *byte, pathSize int, returnValueData **byte, returnValueSize *int) Status

+ ProxyGetSharedData func(keyData *byte, keySize int, returnValueData **byte, returnValueSize *int, ...) Status

+ ProxyHttpCall func(upstreamData *byte, upstreamSize int, headerData *byte, headerSize int, ...) Status

+ ProxyIncrementMetric func(metricID uint32, offset int64) Status

+ ProxyLog func(logLevel LogLevel, messageData *byte, messageSize int) Status

+ ProxyRecordMetric func(metricID uint32, value uint64) Status

+ ProxyRegisterSharedQueue func(nameData *byte, nameSize int, returnID *uint32) Status

+ ProxyRemoveHeaderMapValue func(mapType MapType, keyData *byte, keySize int) Status

+ ProxyReplaceHeaderMapValue func(mapType MapType, keyData *byte, keySize int, valueData *byte, valueSize int) Status

+ ProxyResolveSharedQueue func(vmIDData *byte, vmIDSize int, nameData *byte, nameSize int, returnID *uint32) Status

+ ProxySendLocalResponse func(statusCode uint32, statusCodeDetailData *byte, statusCodeDetailsSize int, ...) Status

+ ProxySetBufferBytes func(bufferType BufferType, start int, maxSize int, bufferData *byte, ...) Status

+ ProxySetEffectiveContext func(contextID uint32) Status

+ ProxySetHeaderMapPairs func(mapType MapType, mapData *byte, mapSize int) Status

+ ProxySetProperty func(pathData *byte, pathSize int, valueData *byte, valueSize int) Status

+ ProxySetSharedData func(keyData *byte, keySize int, valueData *byte, valueSize int, cas uint32) Status

+ ProxySetTickPeriodMilliseconds func(period uint32) Status

v0.19.0

Jul 10, 2022

v0.18.0

May 8, 2022

v0.17.0

Mar 23, 2022

Changes in this version

type Status

+ const StatusUnimplemented

v0.16.0

Dec 28, 2021

v0.14.0

Jul 20, 2021

v0.13.0

Jun 25, 2021

Changes in this version

+ func SetVMContext(vmContext types.VMContext)

v0.3.0

Jun 18, 2021

Changes in this version

+ const MetricTypeCounter

+ const MetricTypeGauge

+ const MetricTypeHistogram

+ func DeserializeMap(bs []byte) [][2]string

+ func RawBytePtrToByteSlice(raw *byte, size int) []byte

+ func RawBytePtrToString(raw *byte, size int) string

+ func RegisterHttpCallout(calloutID uint32, callback func(numHeaders, bodySize, numTrailers int))

+ func SerializeMap(ms [][2]string) []byte

+ func SerializePropertyPath(path []string) []byte

+ func SetNewRootContextFn(f func(contextID uint32) types.RootContext)

+ func StatusToError(status Status) error

+ func StringBytePtr(msg string) *byte

+ type BufferType uint32

+ const BufferTypeCallData

+ const BufferTypeDownstreamData

+ const BufferTypeGrpcReceiveBuffer

+ const BufferTypeHttpCallResponseBody

+ const BufferTypeHttpRequestBody

+ const BufferTypeHttpResponseBody

+ const BufferTypePluginConfiguration

+ const BufferTypeUpstreamData

+ const BufferTypeVMConfiguration

+ type LogLevel uint32

+ const LogLevelCritical

+ const LogLevelDebug

+ const LogLevelError

+ const LogLevelInfo

+ const LogLevelMax

+ const LogLevelTrace

+ const LogLevelWarn

+ func (l LogLevel) String() string

+ type MapType uint32

+ const MapTypeHttpCallResponseHeaders

+ const MapTypeHttpCallResponseTrailers

+ const MapTypeHttpRequestHeaders

+ const MapTypeHttpRequestTrailers

+ const MapTypeHttpResponseHeaders

+ const MapTypeHttpResponseTrailers

+ type MetricType uint32

+ type Status uint32

+ const StatusBadArgument

+ const StatusCasMismatch

+ const StatusEmpty

+ const StatusInternalFailure

+ const StatusNotFound

+ const StatusOK

+ func ProxyAddHeaderMapValue(mapType MapType, keyData *byte, keySize int, valueData *byte, valueSize int) Status

+ func ProxyCallForeignFunction(funcNamePtr *byte, funcNameSize int, paramPtr *byte, paramSize int, ...) Status

+ func ProxyCloseStream(streamType StreamType) Status

+ func ProxyContinueStream(streamType StreamType) Status

+ func ProxyDefineMetric(metricType MetricType, metricNameData *byte, metricNameSize int, ...) Status

+ func ProxyDequeueSharedQueue(queueID uint32, returnValueData **byte, returnValueSize *int) Status

+ func ProxyDone() Status

+ func ProxyEnqueueSharedQueue(queueID uint32, valueData *byte, valueSize int) Status

+ func ProxyGetBufferBytes(bufferType BufferType, start int, maxSize int, returnBufferData **byte, ...) Status

+ func ProxyGetHeaderMapPairs(mapType MapType, returnValueData **byte, returnValueSize *int) Status

+ func ProxyGetHeaderMapValue(mapType MapType, keyData *byte, keySize int, returnValueData **byte, ...) Status

+ func ProxyGetMetric(metricID uint32, returnMetricValue *uint64) Status

+ func ProxyGetProperty(pathData *byte, pathSize int, returnValueData **byte, returnValueSize *int) Status

+ func ProxyGetSharedData(keyData *byte, keySize int, returnValueData **byte, returnValueSize *int, ...) Status

+ func ProxyHttpCall(upstreamData *byte, upstreamSize int, headerData *byte, headerSize int, ...) Status

+ func ProxyIncrementMetric(metricID uint32, offset int64) Status

+ func ProxyLog(logLevel LogLevel, messageData *byte, messageSize int) Status

+ func ProxyRecordMetric(metricID uint32, value uint64) Status

+ func ProxyRegisterSharedQueue(nameData *byte, nameSize int, returnID *uint32) Status

+ func ProxyRemoveHeaderMapValue(mapType MapType, keyData *byte, keySize int) Status

+ func ProxyReplaceHeaderMapValue(mapType MapType, keyData *byte, keySize int, valueData *byte, valueSize int) Status

+ func ProxyResolveSharedQueue(vmIDData *byte, vmIDSize int, nameData *byte, nameSize int, returnID *uint32) Status

+ func ProxySendLocalResponse(statusCode uint32, statusCodeDetailData *byte, statusCodeDetailsSize int, ...) Status

+ func ProxySetBufferBytes(bufferType BufferType, start int, maxSize int, bufferData *byte, ...) Status

+ func ProxySetEffectiveContext(contextID uint32) Status

+ func ProxySetHeaderMapPairs(mapType MapType, mapData *byte, mapSize int) Status

+ func ProxySetProperty(pathData *byte, pathSize int, valueData *byte, valueSize int) Status

+ func ProxySetSharedData(keyData *byte, keySize int, valueData *byte, valueSize int, cas uint32) Status

+ func ProxySetTickPeriodMilliseconds(period uint32) Status

+ type StreamType uint32

+ const StreamTypeDownstream

+ const StreamTypeRequest

+ const StreamTypeResponse

+ const StreamTypeUpstream

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