proxywasm

Documentation

Index

• Constants
• type Filter
  • func NewFilter(ctx context.Context, pluginName string, rootContextID int32, ...) *Filter
  • func (f *Filter) Append(ctx context.Context, headers api.HeaderMap, buf buffer.IoBuffer, ...) api.StreamFilterStatus
  • func (f *Filter) OnDestroy()
  • func (f *Filter) OnReceive(ctx context.Context, headers api.HeaderMap, buf buffer.IoBuffer, ...) api.StreamFilterStatus
  • func (f *Filter) SetReceiveFilterHandler(handler api.StreamReceiverFilterHandler)
  • func (f *Filter) SetSenderFilterHandler(handler api.StreamSenderFilterHandler)
• type FilterConfigFactory
  • func (f *FilterConfigFactory) CreateFilterChain(context context.Context, callbacks api.StreamFilterChainFactoryCallbacks)
  • func (f *FilterConfigFactory) GetPluginConfig() common.IoBuffer
  • func (f *FilterConfigFactory) GetVmConfig() common.IoBuffer
  • func (f *FilterConfigFactory) OnConfigUpdate(config v2.WasmPluginConfig)
  • func (f *FilterConfigFactory) OnPluginDestroy(plugin types.WasmPlugin)
  • func (f *FilterConfigFactory) OnPluginStart(plugin types.WasmPlugin)

Constants

const ProxyWasm = "proxywasm"

Types

type Filter

type Filter struct {
	// contains filtered or unexported fields
}

func NewFilter

func NewFilter(ctx context.Context, pluginName string, rootContextID int32, factory *FilterConfigFactory) *Filter

func (*Filter) Append

func (f *Filter) Append(ctx context.Context, headers api.HeaderMap, buf buffer.IoBuffer, trailers api.HeaderMap) api.StreamFilterStatus

func (*Filter) OnDestroy

func (f *Filter) OnDestroy()

func (*Filter) OnReceive

func (f *Filter) OnReceive(ctx context.Context, headers api.HeaderMap, buf buffer.IoBuffer, trailers api.HeaderMap) api.StreamFilterStatus

func (*Filter) SetReceiveFilterHandler

func (f *Filter) SetReceiveFilterHandler(handler api.StreamReceiverFilterHandler)

func (*Filter) SetSenderFilterHandler

func (f *Filter) SetSenderFilterHandler(handler api.StreamSenderFilterHandler)

type FilterConfigFactory

type FilterConfigFactory struct {
	// contains filtered or unexported fields
}

func (*FilterConfigFactory) CreateFilterChain

func (f *FilterConfigFactory) CreateFilterChain(context context.Context, callbacks api.StreamFilterChainFactoryCallbacks)

func (*FilterConfigFactory) GetPluginConfig

func (f *FilterConfigFactory) GetPluginConfig() common.IoBuffer

func (*FilterConfigFactory) GetVmConfig

func (f *FilterConfigFactory) GetVmConfig() common.IoBuffer

func (*FilterConfigFactory) OnConfigUpdate

func (f *FilterConfigFactory) OnConfigUpdate(config v2.WasmPluginConfig)

func (*FilterConfigFactory) OnPluginDestroy

func (f *FilterConfigFactory) OnPluginDestroy(plugin types.WasmPlugin)

func (*FilterConfigFactory) OnPluginStart

func (f *FilterConfigFactory) OnPluginStart(plugin types.WasmPlugin)