proxywasm

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 GetPropertyMap(path []string) ([][2]string, error)

v0.19.0

Jul 10, 2022

v0.18.0

May 8, 2022

v0.17.0

Mar 23, 2022

v0.16.0

Dec 28, 2021

v0.15.0

Oct 27, 2021

v0.14.0

Jul 20, 2021

v0.13.0

Jun 25, 2021

Changes in this version

+ func SetVMContext(ctx types.VMContext)

type MetricCounter

+ func (m MetricCounter) Value() uint64

type MetricGauge

+ func (m MetricGauge) Value() int64

type MetricHistogram

+ func (m MetricHistogram) Value() uint64

v0.12.0

Dec 4, 2020

v0.3.0

Jun 18, 2021

Changes in this version

+ func ContinueTcpStream() error

+ func PluginDone()

+ func ReplaceHttpRequestHeader(key, value string) error

+ func ReplaceHttpRequestHeaders(headers [][2]string) error

+ func ReplaceHttpRequestTrailer(key, value string) error

+ func ReplaceHttpRequestTrailers(trailers [][2]string) error

+ func ReplaceHttpResponseHeader(key, value string) error

+ func ReplaceHttpResponseHeaders(headers [][2]string) error

+ func ReplaceHttpResponseTrailer(key, value string) error

+ func ReplaceHttpResponseTrailers(trailers [][2]string) error

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

v0.2.0

May 28, 2021

Changes in this version

+ func AppendDownstreamData(data []byte) error

+ func AppendHttpRequestBody(data []byte) error

+ func AppendHttpResponseBody(data []byte) error

+ func AppendUpstreamData(data []byte) error

+ func CallForeignFunction(funcName string, param []byte) (ret []byte, err error)

+ func CloseDownstream() error

+ func CloseUpstream() error

+ func ContinueDownstream() error

+ func ContinueUpstream() error

+ func GetDownstreamData(start, maxSize int) ([]byte, error)

+ func PrependDownstreamData(data []byte) error

+ func PrependHttpRequestBody(data []byte) error

+ func PrependHttpResponseBody(data []byte) error

+ func PrependUpstreamData(data []byte) error

+ func ReplaceDownstreamData(data []byte) error

+ func ReplaceHttpRequestBody(data []byte) error

+ func ReplaceHttpResponseBody(data []byte) error

+ func ReplaceUpstreamData(data []byte) error

type DefaultRootContext

+ func (*DefaultRootContext) OnPluginDone() bool

type RootContext

+ OnPluginDone func() bool

v0.1.1

Mar 22, 2021

v0.1.0

Mar 15, 2021

v0.0.15

Mar 9, 2021

Changes in this version

type DefaultRootContext

+ func (*DefaultRootContext) NewHttpContext(uint32) HttpContext

+ func (*DefaultRootContext) NewStreamContext(uint32) StreamContext

type RootContext

+ NewHttpContext func(contextID uint32) HttpContext

+ NewStreamContext func(contextID uint32) StreamContext

v0.0.14

Jan 12, 2021

v0.0.13

Dec 21, 2020

Changes in this version

+ func FinishVMContext()

type DefaultHttpContext

+ func (*DefaultHttpContext) OnLog()

type DefaultRootContext

+ func (*DefaultRootContext) OnLog()

type DefaultStreamContext

+ func (*DefaultStreamContext) OnLog()

type HttpContext

+ OnLog func()

type RootContext

+ OnLog func()

type StreamContext

+ OnLog func()

v0.0.12

Nov 20, 2020

Changes in this version

+ var ErrorRootContextNotFound = errors.New("root context not found")

type RootContext

+ func GetRootContextByID(rootContextID uint32) (RootContext, error)

v0.0.11

Nov 13, 2020

v0.0.10

Oct 29, 2020

v0.0.9

Oct 19, 2020

Changes in this version

+ func SetHttpRequestBody(body []byte) error

+ func SetHttpResponseBody(body []byte) error

v0.0.8

Oct 5, 2020

v0.0.7

Oct 5, 2020

v0.0.6

Oct 3, 2020

v0.0.5

Oct 3, 2020

Changes in this version

+ func AddHttpRequestHeader(key, value string) error

+ func AddHttpRequestTrailer(key, value string) error

+ func AddHttpResponseHeader(key, value string) error

+ func AddHttpResponseTrailer(key, value string) error

+ func DequeueSharedQueue(queueID uint32) ([]byte, error)

+ func DispatchHttpCall(upstream string, headers [][2]string, body string, trailers [][2]string, ...) (calloutID uint32, err error)

+ func EnqueueSharedQueue(queueID uint32, data []byte) error

+ func FinishContext()

+ func GetCurrentTime() int64

+ func GetDownStreamData(start, maxSize int) ([]byte, error)

+ func GetHttpCallResponseBody(start, maxSize int) ([]byte, error)

+ func GetHttpCallResponseHeaders() ([][2]string, error)

+ func GetHttpCallResponseTrailers() ([][2]string, error)

+ func GetHttpRequestBody(start, maxSize int) ([]byte, error)

+ func GetHttpRequestHeader(key string) (string, error)

+ func GetHttpRequestHeaders() ([][2]string, error)

+ func GetHttpRequestTrailer(key string) (string, error)

+ func GetHttpRequestTrailers() ([][2]string, error)

+ func GetHttpResponseBody(start, maxSize int) ([]byte, error)

+ func GetHttpResponseHeader(key string) (string, error)

+ func GetHttpResponseHeaders() ([][2]string, error)

+ func GetHttpResponseTrailer(key string) (string, error)

+ func GetHttpResponseTrailers() ([][2]string, error)

+ func GetPluginConfiguration(dataSize int) ([]byte, error)

+ func GetProperty(path []string) ([]byte, error)

+ func GetSharedData(key string) (value []byte, cas uint32, err error)

+ func GetUpstreamData(start, maxSize int) ([]byte, error)

+ func GetVMConfiguration(dataSize int) ([]byte, error)

+ func RegisterSharedQueue(name string) (uint32, error)

+ func RemoveHttpRequestHeader(key string) error

+ func RemoveHttpRequestTrailer(key string) error

+ func RemoveHttpResponseHeader(key string) error

+ func RemoveHttpResponseTrailer(key string) error

+ func ResolveSharedQueue(vmID, queueName string) (uint32, error)

+ func ResumeHttpRequest() error

+ func ResumeHttpResponse() error

+ func SendHttpResponse(statusCode uint32, headers [][2]string, body string) types.Status

+ func SetEffectiveContext(contextID uint32)

+ func SetHttpRequestHeader(key, value string) error

+ func SetHttpRequestHeaders(headers [][2]string) error

+ func SetHttpRequestTrailer(key, value string) error

+ func SetHttpRequestTrailers(headers [][2]string) error

+ func SetHttpResponseHeader(key, value string) error

+ func SetHttpResponseHeaders(headers [][2]string) error

+ func SetHttpResponseTrailer(key, value string) error

+ func SetHttpResponseTrailers(headers [][2]string) error

+ func SetProperty(path string, data []byte) error

+ func SetSharedData(key string, data []byte, cas uint32) error

+ func SetTickPeriodMilliSeconds(millSec uint32) error

+ type DefaultHttpContext struct

+ func (*DefaultHttpContext) OnHttpRequestBody(int, bool) types.Action

+ func (*DefaultHttpContext) OnHttpRequestHeaders(int, bool) types.Action

+ func (*DefaultHttpContext) OnHttpRequestTrailers(int) types.Action

+ func (*DefaultHttpContext) OnHttpResponseBody(int, bool) types.Action

+ func (*DefaultHttpContext) OnHttpResponseHeaders(int, bool) types.Action

+ func (*DefaultHttpContext) OnHttpResponseTrailers(int) types.Action

+ func (*DefaultHttpContext) OnHttpStreamDone()

+ type DefaultRootContext struct

+ func (*DefaultRootContext) OnPluginStart(int) bool

+ func (*DefaultRootContext) OnQueueReady(uint32)

+ func (*DefaultRootContext) OnTick()

+ func (*DefaultRootContext) OnVMDone() bool

+ func (*DefaultRootContext) OnVMStart(int) bool

+ type DefaultStreamContext struct

+ func (*DefaultStreamContext) OnDownstreamClose(types.PeerType)

+ func (*DefaultStreamContext) OnDownstreamData(int, bool) types.Action

+ func (*DefaultStreamContext) OnNewConnection() types.Action

+ func (*DefaultStreamContext) OnStreamDone()

+ func (*DefaultStreamContext) OnUpstreamClose(types.PeerType)

+ func (*DefaultStreamContext) OnUpstreamData(int, bool) types.Action

+ type HttpCalloutCallBack = func(numHeaders, bodySize, numTrailers int)

type HttpContext

+ OnHttpStreamDone func()

type RootContext

+ OnPluginStart func(pluginConfigurationSize int) bool

+ OnVMDone func() bool

type StreamContext

+ OnStreamDone func()

v0.0.4

Sep 30, 2020

Changes in this version

+ func LogCriticalf(format string, args ...interface{})

+ func LogDebugf(format string, args ...interface{})

+ func LogErrorf(format string, args ...interface{})

+ func LogInfof(format string, args ...interface{})

+ func LogTracef(format string, args ...interface{})

+ func LogWarnf(format string, args ...interface{})

v0.0.3

Sep 29, 2020

Changes in this version

+ func HostCallGetProperty(path []string) ([]byte, error)

+ func HostCallSetProperty(path string, data []byte) error

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

v0.0.2

Sep 22, 2020

v0.0.1

Sep 17, 2020

Changes in this version

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

+ func HostCallAddHttpRequestHeader(key, value string) error

+ func HostCallAddHttpRequestTrailer(key, value string) error

+ func HostCallAddHttpResponseHeader(key, value string) error

+ func HostCallAddHttpResponseTrailer(key, value string) error

+ func HostCallDequeueSharedQueue(queueID uint32) ([]byte, error)

+ func HostCallDispatchHttpCall(upstream string, headers [][2]string, body string, trailers [][2]string, ...) (uint32, error)

+ func HostCallDone()

+ func HostCallEnqueueSharedQueue(queueID uint32, data []byte) error

+ func HostCallGetCurrentTime() int64

+ func HostCallGetDownStreamData(start, maxSize int) ([]byte, error)

+ func HostCallGetHttpCallResponseBody(start, maxSize int) ([]byte, error)

+ func HostCallGetHttpCallResponseHeaders() ([][2]string, error)

+ func HostCallGetHttpCallResponseTrailers() ([][2]string, error)

+ func HostCallGetHttpRequestBody(start, maxSize int) ([]byte, error)

+ func HostCallGetHttpRequestHeader(key string) (string, error)

+ func HostCallGetHttpRequestHeaders() ([][2]string, error)

+ func HostCallGetHttpRequestTrailer(key string) (string, error)

+ func HostCallGetHttpRequestTrailers() ([][2]string, error)

+ func HostCallGetHttpResponseBody(start, maxSize int) ([]byte, error)

+ func HostCallGetHttpResponseHeader(key string) (string, error)

+ func HostCallGetHttpResponseHeaders() ([][2]string, error)

+ func HostCallGetHttpResponseTrailer(key string) (string, error)

+ func HostCallGetHttpResponseTrailers() ([][2]string, error)

+ func HostCallGetPluginConfiguration(dataSize int) ([]byte, error)

+ func HostCallGetSharedData(key string) (value []byte, cas uint32, err error)

+ func HostCallGetUpstreamData(start, maxSize int) ([]byte, error)

+ func HostCallGetVMConfiguration(dataSize int) ([]byte, error)

+ func HostCallRegisterSharedQueue(name string) (uint32, error)

+ func HostCallRemoveHttpRequestHeader(key string) error

+ func HostCallRemoveHttpRequestTrailer(key string) error

+ func HostCallRemoveHttpResponseHeader(key string) error

+ func HostCallRemoveHttpResponseTrailer(key string) error

+ func HostCallResolveSharedQueue(vmID, queueName string) (uint32, error)

+ func HostCallResumeHttpRequest() error

+ func HostCallResumeHttpResponse() error

+ func HostCallSendHttpResponse(statusCode uint32, headers [][2]string, body string) types.Status

+ func HostCallSetHttpRequestHeader(key, value string) error

+ func HostCallSetHttpRequestHeaders(headers [][2]string) error

+ func HostCallSetHttpRequestTrailer(key, value string) error

+ func HostCallSetHttpRequestTrailers(headers [][2]string) error

+ func HostCallSetHttpResponseHeader(key, value string) error

+ func HostCallSetHttpResponseHeaders(headers [][2]string) error

+ func HostCallSetHttpResponseTrailer(key, value string) error

+ func HostCallSetHttpResponseTrailers(headers [][2]string) error

+ func HostCallSetSharedData(key string, data []byte, cas uint32) error

+ func HostCallSetTickPeriodMilliSeconds(millSec uint32) error

+ func LogCritical(msgs ...string)

+ func LogDebug(msgs ...string)

+ func LogError(msgs ...string)

+ func LogInfo(msgs ...string)

+ func LogTrace(msgs ...string)

+ func LogWarn(msgs ...string)

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

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

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

+ func SetNewHttpContext(f func(contextID uint32) HttpContext)

+ func SetNewRootContext(f func(contextID uint32) RootContext)

+ func SetNewStreamContext(f func(contextID uint32) StreamContext)

+ type Context interface

+ OnDone func() bool

+ OnHttpCallResponse func(numHeaders, bodySize, numTrailers int)

+ OnLog func()

+ type DefaultContext struct

+ func (d DefaultContext) OnConfigure(int) bool

+ func (d DefaultContext) OnDone() bool

+ func (d DefaultContext) OnDownstreamClose(types.PeerType)

+ func (d DefaultContext) OnDownstreamData(int, bool) types.Action

+ func (d DefaultContext) OnHttpCallResponse(int, int, int)

+ func (d DefaultContext) OnHttpRequestBody(int, bool) types.Action

+ func (d DefaultContext) OnHttpRequestHeaders(int, bool) types.Action

+ func (d DefaultContext) OnHttpRequestTrailers(int) types.Action

+ func (d DefaultContext) OnHttpResponseBody(int, bool) types.Action

+ func (d DefaultContext) OnHttpResponseHeaders(int, bool) types.Action

+ func (d DefaultContext) OnHttpResponseTrailers(int) types.Action

+ func (d DefaultContext) OnLog()

+ func (d DefaultContext) OnNewConnection() types.Action

+ func (d DefaultContext) OnQueueReady(uint32)

+ func (d DefaultContext) OnTick()

+ func (d DefaultContext) OnUpstreamClose(types.PeerType)

+ func (d DefaultContext) OnUpstreamData(int, bool) types.Action

+ func (d DefaultContext) OnVMStart(int) bool

+ type HttpContext interface

+ OnHttpRequestBody func(bodySize int, endOfStream bool) types.Action

+ OnHttpRequestHeaders func(numHeaders int, endOfStream bool) types.Action

+ OnHttpRequestTrailers func(numTrailers int) types.Action

+ OnHttpResponseBody func(bodySize int, endOfStream bool) types.Action

+ OnHttpResponseHeaders func(numHeaders int, endOfStream bool) types.Action

+ OnHttpResponseTrailers func(numTrailers int) types.Action

+ type MetricCounter uint32

+ func DefineCounterMetric(name string) (MetricCounter, error)

+ func (m MetricCounter) Get() (uint64, error)

+ func (m MetricCounter) ID() uint32

+ func (m MetricCounter) Increment(offset uint64) error

+ type MetricGauge uint32

+ func DefineGaugeMetric(name string) (MetricGauge, error)

+ func (m MetricGauge) Add(offset int64) error

+ func (m MetricGauge) Get() (int64, error)

+ func (m MetricGauge) ID() uint32

+ type MetricHistogram uint32

+ func DefineHistogramMetric(name string) (MetricHistogram, error)

+ func (m MetricHistogram) Get() (uint64, error)

+ func (m MetricHistogram) ID() uint32

+ func (m MetricHistogram) Record(value uint64) error

+ type RootContext interface

+ OnConfigure func(pluginConfigurationSize int) bool

+ OnQueueReady func(queueID uint32)

+ OnTick func()

+ OnVMStart func(vmConfigurationSize int) bool

+ type StreamContext interface

+ OnDownstreamClose func(peerType types.PeerType)

+ OnDownstreamData func(dataSize int, endOfStream bool) types.Action

+ OnNewConnection func() types.Action

+ OnUpstreamClose func(peerType types.PeerType)

+ OnUpstreamData func(dataSize int, endOfStream bool) types.Action

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