proxywasm

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: May 28, 2021 License: Apache-2.0 Imports: 8 Imported by: 91

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func AddHttpRequestHeader added in v0.0.5 

func AddHttpRequestHeader(key, value string) error

func AddHttpRequestTrailer added in v0.0.5 

func AddHttpRequestTrailer(key, value string) error

func AddHttpResponseHeader added in v0.0.5 

func AddHttpResponseHeader(key, value string) error

func AddHttpResponseTrailer added in v0.0.5 

func AddHttpResponseTrailer(key, value string) error

func AppendDownstreamData added in v0.2.0 

func AppendDownstreamData(data []byte) error

func AppendHttpRequestBody added in v0.2.0 

func AppendHttpRequestBody(data []byte) error

func AppendHttpResponseBody added in v0.2.0 

func AppendHttpResponseBody(data []byte) error

func AppendUpstreamData added in v0.2.0 

func AppendUpstreamData(data []byte) error

func CallForeignFunction added in v0.2.0 

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

func CloseDownstream added in v0.2.0 

func CloseDownstream() error

func CloseUpstream added in v0.2.0 

func CloseUpstream() error

func ContinueDownstream added in v0.2.0 

func ContinueDownstream() error

func ContinueUpstream added in v0.2.0 

func ContinueUpstream() error

func DequeueSharedQueue added in v0.0.5 

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

func DeserializeMap 

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

func DispatchHttpCall added in v0.0.5 

func DispatchHttpCall(upstream string,
	headers types.Headers, body string, trailers types.Trailers,
	timeoutMillisecond uint32, callBack HttpCalloutCallBack) (calloutID uint32, err error)

func EnqueueSharedQueue added in v0.0.5 

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

func FinishVMContext added in v0.0.13 

func FinishVMContext()

func GetDownstreamData added in v0.2.0 

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

func GetHttpCallResponseBody added in v0.0.5 

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

func GetHttpCallResponseHeaders added in v0.0.5 

func GetHttpCallResponseHeaders() (types.Headers, error)

func GetHttpCallResponseTrailers added in v0.0.5 

func GetHttpCallResponseTrailers() (types.Trailers, error)

func GetHttpRequestBody added in v0.0.5 

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

func GetHttpRequestHeader added in v0.0.5 

func GetHttpRequestHeader(key string) (string, error)

func GetHttpRequestHeaders added in v0.0.5 

func GetHttpRequestHeaders() (types.Headers, error)

func GetHttpRequestTrailer added in v0.0.5 

func GetHttpRequestTrailer(key string) (string, error)

func GetHttpRequestTrailers added in v0.0.5 

func GetHttpRequestTrailers() (types.Trailers, error)

func GetHttpResponseBody added in v0.0.5 

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

func GetHttpResponseHeader added in v0.0.5 

func GetHttpResponseHeader(key string) (string, error)

func GetHttpResponseHeaders added in v0.0.5 

func GetHttpResponseHeaders() (types.Headers, error)

func GetHttpResponseTrailer added in v0.0.5 

func GetHttpResponseTrailer(key string) (string, error)

func GetHttpResponseTrailers added in v0.0.5 

func GetHttpResponseTrailers() (types.Trailers, error)

func GetPluginConfiguration added in v0.0.5 

func GetPluginConfiguration(size int) ([]byte, error)

func GetProperty added in v0.0.5 

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

func GetSharedData added in v0.0.5 

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

func GetUpstreamData added in v0.0.5 

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

func GetVMConfiguration added in v0.0.5 

func GetVMConfiguration(size int) ([]byte, error)

func LogCritical 

func LogCritical(msg string)

func LogCriticalf added in v0.0.4 

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

func LogDebug 

func LogDebug(msg string)

func LogDebugf added in v0.0.4 

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

func LogError 

func LogError(msg string)

func LogErrorf added in v0.0.4 

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

func LogInfo 

func LogInfo(msg string)

func LogInfof added in v0.0.4 

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

func LogTrace 

func LogTrace(msg string)

func LogTracef added in v0.0.4 

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

func LogWarn 

func LogWarn(msg string)

func LogWarnf added in v0.0.4 

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

func PrependDownstreamData added in v0.2.0 

func PrependDownstreamData(data []byte) error

func PrependHttpRequestBody added in v0.2.0 

func PrependHttpRequestBody(data []byte) error

func PrependHttpResponseBody added in v0.2.0 

func PrependHttpResponseBody(data []byte) error

func PrependUpstreamData added in v0.2.0 

func PrependUpstreamData(data []byte) error

func RawBytePtrToByteSlice 

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

func RawBytePtrToString 

func RawBytePtrToString(raw *byte, size int) string

func RegisterSharedQueue added in v0.0.5 

func RegisterSharedQueue(name string) (uint32, error)

func RemoveHttpRequestHeader added in v0.0.5 

func RemoveHttpRequestHeader(key string) error

func RemoveHttpRequestTrailer added in v0.0.5 

func RemoveHttpRequestTrailer(key string) error

func RemoveHttpResponseHeader added in v0.0.5 

func RemoveHttpResponseHeader(key string) error

func RemoveHttpResponseTrailer added in v0.0.5 

func RemoveHttpResponseTrailer(key string) error

func ReplaceDownstreamData added in v0.2.0 

func ReplaceDownstreamData(data []byte) error

func ReplaceHttpRequestBody added in v0.2.0 

func ReplaceHttpRequestBody(data []byte) error

func ReplaceHttpResponseBody added in v0.2.0 

func ReplaceHttpResponseBody(data []byte) error

func ReplaceUpstreamData added in v0.2.0 

func ReplaceUpstreamData(data []byte) error

func ResolveSharedQueue added in v0.0.5 

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

TODO: not sure if the ABI is correct

func ResumeHttpRequest added in v0.0.5 

func ResumeHttpRequest() error

func ResumeHttpResponse added in v0.0.5 

func ResumeHttpResponse() error

func SendHttpResponse added in v0.0.5 

func SendHttpResponse(statusCode uint32, headers types.Headers, body []byte) error

func SerializeMap 

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

func SerializePropertyPath added in v0.0.3 

func SerializePropertyPath(path []string) []byte

func SetEffectiveContext added in v0.0.5 

func SetEffectiveContext(contextID uint32)

func SetHttpRequestHeader added in v0.0.5 

func SetHttpRequestHeader(key, value string) error

func SetHttpRequestHeaders added in v0.0.5 

func SetHttpRequestHeaders(headers types.Headers) error

func SetHttpRequestTrailer added in v0.0.5 

func SetHttpRequestTrailer(key, value string) error

func SetHttpRequestTrailers added in v0.0.5 

func SetHttpRequestTrailers(trailers types.Trailers) error

func SetHttpResponseHeader added in v0.0.5 

func SetHttpResponseHeader(key, value string) error

func SetHttpResponseHeaders added in v0.0.5 

func SetHttpResponseHeaders(headers types.Headers) error

func SetHttpResponseTrailer added in v0.0.5 

func SetHttpResponseTrailer(key, value string) error

func SetHttpResponseTrailers added in v0.0.5 

func SetHttpResponseTrailers(trailers types.Trailers) error

func SetNewRootContext 

func SetNewRootContext(f func(contextID uint32) RootContext)

func SetProperty added in v0.0.5 

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

func SetSharedData added in v0.0.5 

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

func SetTickPeriodMilliSeconds added in v0.0.5 

func SetTickPeriodMilliSeconds(millSec uint32) error

Types

type DefaultHttpContext added in v0.0.5 

type DefaultHttpContext struct{}

func (*DefaultHttpContext) OnHttpRequestBody added in v0.0.5 

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

func (*DefaultHttpContext) OnHttpRequestHeaders added in v0.0.5 

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

impl HttpContext

func (*DefaultHttpContext) OnHttpRequestTrailers added in v0.0.5 

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

func (*DefaultHttpContext) OnHttpResponseBody added in v0.0.5 

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

func (*DefaultHttpContext) OnHttpResponseHeaders added in v0.0.5 

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

func (*DefaultHttpContext) OnHttpResponseTrailers added in v0.0.5 

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

func (*DefaultHttpContext) OnHttpStreamDone added in v0.0.5 

func (*DefaultHttpContext) OnHttpStreamDone()

func (*DefaultHttpContext) OnLog added in v0.0.13 

func (*DefaultHttpContext) OnLog()

type DefaultRootContext added in v0.0.5 

type DefaultRootContext struct{}

func (*DefaultRootContext) NewHttpContext added in v0.0.15 

func (*DefaultRootContext) NewHttpContext(uint32) HttpContext

func (*DefaultRootContext) NewStreamContext added in v0.0.15 

func (*DefaultRootContext) NewStreamContext(uint32) StreamContext

func (*DefaultRootContext) OnLog added in v0.0.13 

func (*DefaultRootContext) OnLog()

func (*DefaultRootContext) OnPluginDone added in v0.2.0 

func (*DefaultRootContext) OnPluginDone() bool

func (*DefaultRootContext) OnPluginStart added in v0.0.5 

func (*DefaultRootContext) OnPluginStart(int) types.OnPluginStartStatus

func (*DefaultRootContext) OnQueueReady added in v0.0.5 

func (*DefaultRootContext) OnQueueReady(uint32)

impl RootContext

func (*DefaultRootContext) OnTick added in v0.0.5 

func (*DefaultRootContext) OnTick()

func (*DefaultRootContext) OnVMStart added in v0.0.5 

func (*DefaultRootContext) OnVMStart(int) types.OnVMStartStatus

type DefaultStreamContext added in v0.0.5 

type DefaultStreamContext struct{}

func (*DefaultStreamContext) OnDownstreamClose added in v0.0.5 

func (*DefaultStreamContext) OnDownstreamClose(types.PeerType)

func (*DefaultStreamContext) OnDownstreamData added in v0.0.5 

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

impl StreamContext

func (*DefaultStreamContext) OnLog added in v0.0.13 

func (*DefaultStreamContext) OnLog()

func (*DefaultStreamContext) OnNewConnection added in v0.0.5 

func (*DefaultStreamContext) OnNewConnection() types.Action

func (*DefaultStreamContext) OnStreamDone added in v0.0.5 

func (*DefaultStreamContext) OnStreamDone()

func (*DefaultStreamContext) OnUpstreamClose added in v0.0.5 

func (*DefaultStreamContext) OnUpstreamClose(types.PeerType)

func (*DefaultStreamContext) OnUpstreamData added in v0.0.5 

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

type HttpCalloutCallBack added in v0.0.5 

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

type HttpContext 

type HttpContext interface {
	OnHttpRequestHeaders(numHeaders int, endOfStream bool) types.Action
	OnHttpRequestBody(bodySize int, endOfStream bool) types.Action
	OnHttpRequestTrailers(numTrailers int) types.Action
	OnHttpResponseHeaders(numHeaders int, endOfStream bool) types.Action
	OnHttpResponseBody(bodySize int, endOfStream bool) types.Action
	OnHttpResponseTrailers(numTrailers int) types.Action
	OnHttpStreamDone()
	OnLog()
}

type MetricCounter 

type MetricCounter uint32

func DefineCounterMetric 

func DefineCounterMetric(name string) MetricCounter

func (MetricCounter) Get 

func (m MetricCounter) Get() uint64

func (MetricCounter) ID 

func (m MetricCounter) ID() uint32

func (MetricCounter) Increment 

func (m MetricCounter) Increment(offset uint64)

type MetricGauge 

type MetricGauge uint32

func DefineGaugeMetric 

func DefineGaugeMetric(name string) MetricGauge

func (MetricGauge) Add 

func (m MetricGauge) Add(offset int64)

func (MetricGauge) Get 

func (m MetricGauge) Get() int64

func (MetricGauge) ID 

func (m MetricGauge) ID() uint32

type MetricHistogram 

type MetricHistogram uint32

func DefineHistogramMetric 

func DefineHistogramMetric(name string) MetricHistogram

func (MetricHistogram) Get 

func (m MetricHistogram) Get() uint64

func (MetricHistogram) ID 

func (m MetricHistogram) ID() uint32

func (MetricHistogram) Record 

func (m MetricHistogram) Record(value uint64)

type RootContext 

type RootContext interface {
	OnQueueReady(queueID uint32)
	OnTick()
	OnVMStart(vmConfigurationSize int) types.OnVMStartStatus
	OnPluginStart(pluginConfigurationSize int) types.OnPluginStartStatus
	OnPluginDone() bool
	OnLog()

	// Child context factories
	NewStreamContext(contextID uint32) StreamContext
	NewHttpContext(contextID uint32) HttpContext
}

func GetRootContextByID added in v0.0.12 

func GetRootContextByID(rootContextID uint32) (RootContext, error)

type StreamContext 

type StreamContext interface {
	OnDownstreamData(dataSize int, endOfStream bool) types.Action
	OnDownstreamClose(peerType types.PeerType)
	OnNewConnection() types.Action
	OnUpstreamData(dataSize int, endOfStream bool) types.Action
	OnUpstreamClose(peerType types.PeerType)
	OnStreamDone()
	OnLog()
}

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.