proxywasm

package

v0.0.1 Latest Latest Go to latest Published: Sep 17, 2020 License: Apache-2.0 Imports: 7 Imported by: 92

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/tetratelabs/proxy-wasm-go-sdk

Links

Open Source Insights

Documentation ¶

Index ¶

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
type DefaultContext
- 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
type MetricCounter
- 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
- 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
- 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
type StreamContext

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DeserializeMap ¶

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

func HostCallAddHttpRequestHeader ¶

func HostCallAddHttpRequestHeader(key, value string) error

func HostCallAddHttpRequestTrailer ¶

func HostCallAddHttpRequestTrailer(key, value string) error

func HostCallAddHttpResponseHeader ¶

func HostCallAddHttpResponseHeader(key, value string) error

func HostCallAddHttpResponseTrailer ¶

func HostCallAddHttpResponseTrailer(key, value string) error

func HostCallDequeueSharedQueue ¶

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

func HostCallDispatchHttpCall ¶

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

func HostCallDone ¶

func HostCallDone()

func HostCallEnqueueSharedQueue ¶

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

func HostCallGetCurrentTime ¶

func HostCallGetCurrentTime() int64

func HostCallGetDownStreamData ¶

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

func HostCallGetHttpCallResponseBody ¶

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

func HostCallGetHttpCallResponseHeaders ¶

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

func HostCallGetHttpCallResponseTrailers ¶

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

func HostCallGetHttpRequestBody ¶

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

func HostCallGetHttpRequestHeader ¶

func HostCallGetHttpRequestHeader(key string) (string, error)

func HostCallGetHttpRequestHeaders ¶

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

func HostCallGetHttpRequestTrailer ¶

func HostCallGetHttpRequestTrailer(key string) (string, error)

func HostCallGetHttpRequestTrailers ¶

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

func HostCallGetHttpResponseBody ¶

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

func HostCallGetHttpResponseHeader ¶

func HostCallGetHttpResponseHeader(key string) (string, error)

func HostCallGetHttpResponseHeaders ¶

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

func HostCallGetHttpResponseTrailer ¶

func HostCallGetHttpResponseTrailer(key string) (string, error)

func HostCallGetHttpResponseTrailers ¶

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

func HostCallGetPluginConfiguration ¶

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

func HostCallGetSharedData ¶

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

func HostCallGetUpstreamData ¶

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

func HostCallGetVMConfiguration ¶

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

func HostCallRegisterSharedQueue ¶

func HostCallRegisterSharedQueue(name string) (uint32, error)

func HostCallRemoveHttpRequestHeader ¶

func HostCallRemoveHttpRequestHeader(key string) error

func HostCallRemoveHttpRequestTrailer ¶

func HostCallRemoveHttpRequestTrailer(key string) error

func HostCallRemoveHttpResponseHeader ¶

func HostCallRemoveHttpResponseHeader(key string) error

func HostCallRemoveHttpResponseTrailer ¶

func HostCallRemoveHttpResponseTrailer(key string) error

func HostCallResolveSharedQueue ¶

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

TODO: not sure if the ABI is correct

func HostCallResumeHttpRequest ¶

func HostCallResumeHttpRequest() error

func HostCallResumeHttpResponse ¶

func HostCallResumeHttpResponse() error

func HostCallSendHttpResponse ¶

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

func HostCallSetHttpRequestHeader ¶

func HostCallSetHttpRequestHeader(key, value string) error

func HostCallSetHttpRequestHeaders ¶

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

func HostCallSetHttpRequestTrailer ¶

func HostCallSetHttpRequestTrailer(key, value string) error

func HostCallSetHttpRequestTrailers ¶

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

func HostCallSetHttpResponseHeader ¶

func HostCallSetHttpResponseHeader(key, value string) error

func HostCallSetHttpResponseHeaders ¶

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

func HostCallSetHttpResponseTrailer ¶

func HostCallSetHttpResponseTrailer(key, value string) error

func HostCallSetHttpResponseTrailers ¶

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

func HostCallSetSharedData ¶

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

func HostCallSetTickPeriodMilliSeconds ¶

func HostCallSetTickPeriodMilliSeconds(millSec uint32) error

func LogCritical ¶

func LogCritical(msgs ...string)

func LogDebug ¶

func LogDebug(msgs ...string)

func LogError ¶

func LogError(msgs ...string)

func LogInfo ¶

func LogInfo(msgs ...string)

func LogTrace ¶

func LogTrace(msgs ...string)

func LogWarn ¶

func LogWarn(msgs ...string)

func RawBytePtrToByteSlice ¶

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

func RawBytePtrToString ¶

func RawBytePtrToString(raw *byte, size int) string

func SerializeMap ¶

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

func SetNewHttpContext ¶

func SetNewHttpContext(f func(contextID uint32) HttpContext)

func SetNewRootContext ¶

func SetNewRootContext(f func(contextID uint32) RootContext)

func SetNewStreamContext ¶

func SetNewStreamContext(f func(contextID uint32) StreamContext)

Types ¶

type Context ¶

type Context interface {
	OnDone() bool
	OnHttpCallResponse(numHeaders, bodySize, numTrailers int)
	OnLog()
}

type DefaultContext ¶

type DefaultContext struct{}

func (DefaultContext) OnConfigure ¶

func (d DefaultContext) OnConfigure(int) bool

impl RootContext

func (DefaultContext) OnDone ¶

func (d DefaultContext) OnDone() bool

impl Context

func (DefaultContext) OnDownstreamClose ¶

func (d DefaultContext) OnDownstreamClose(types.PeerType)

func (DefaultContext) OnDownstreamData ¶

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

impl StreamContext

func (DefaultContext) OnHttpCallResponse ¶

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

func (DefaultContext) OnHttpRequestBody ¶

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

func (DefaultContext) OnHttpRequestHeaders ¶

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

impl HttpContext

func (DefaultContext) OnHttpRequestTrailers ¶

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

func (DefaultContext) OnHttpResponseBody ¶

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

func (DefaultContext) OnHttpResponseHeaders ¶

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

func (DefaultContext) OnHttpResponseTrailers ¶

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

func (DefaultContext) OnLog ¶

func (d DefaultContext) OnLog()

func (DefaultContext) OnNewConnection ¶

func (d DefaultContext) OnNewConnection() types.Action

func (DefaultContext) OnQueueReady ¶

func (d DefaultContext) OnQueueReady(uint32)

func (DefaultContext) OnTick ¶

func (d DefaultContext) OnTick()

func (DefaultContext) OnUpstreamClose ¶

func (d DefaultContext) OnUpstreamClose(types.PeerType)

func (DefaultContext) OnUpstreamData ¶

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

func (DefaultContext) OnVMStart ¶

func (d DefaultContext) OnVMStart(int) bool

type HttpContext ¶

type HttpContext interface {
	Context
	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
}

type MetricCounter ¶

type MetricCounter uint32

func DefineCounterMetric ¶

func DefineCounterMetric(name string) (MetricCounter, error)

func (MetricCounter) Get ¶

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

func (MetricCounter) ID ¶

func (m MetricCounter) ID() uint32

func (MetricCounter) Increment ¶

func (m MetricCounter) Increment(offset uint64) error

type MetricGauge ¶

type MetricGauge uint32

func DefineGaugeMetric ¶

func DefineGaugeMetric(name string) (MetricGauge, error)

func (MetricGauge) Add ¶

func (m MetricGauge) Add(offset int64) error

func (MetricGauge) Get ¶

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

func (MetricGauge) ID ¶

func (m MetricGauge) ID() uint32

type MetricHistogram ¶

type MetricHistogram uint32

func DefineHistogramMetric ¶

func DefineHistogramMetric(name string) (MetricHistogram, error)

func (MetricHistogram) Get ¶

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

func (MetricHistogram) ID ¶

func (m MetricHistogram) ID() uint32

func (MetricHistogram) Record ¶

func (m MetricHistogram) Record(value uint64) error

type RootContext ¶

type RootContext interface {
	Context
	OnConfigure(pluginConfigurationSize int) bool
	OnQueueReady(queueID uint32)
	OnTick()
	OnVMStart(vmConfigurationSize int) bool
}

type StreamContext ¶

type StreamContext interface {
	Context
	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)
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
rawhostcall
types

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