dsl

Documentation

Index

• func CreateDSLFilterFactory(conf map[string]interface{}) (api.StreamFilterChainFactory, error)
• type DSL
• type DSLFilter
  • func NewDSLFilter(ctx context.Context, dsl *DSL) *DSLFilter
  • func (f *DSLFilter) Append(ctx context.Context, headers api.HeaderMap, buf buffer.IoBuffer, ...) api.StreamFilterStatus
  • func (f *DSLFilter) Log(ctx context.Context, reqHeaders api.HeaderMap, respHeaders api.HeaderMap, ...)
  • func (f *DSLFilter) OnDestroy()
  • func (f *DSLFilter) OnReceive(ctx context.Context, headers api.HeaderMap, buf buffer.IoBuffer, ...) api.StreamFilterStatus
  • func (f *DSLFilter) SetReceiveFilterHandler(handler api.StreamReceiverFilterHandler)
  • func (f *DSLFilter) SetSenderFilterHandler(handler api.StreamSenderFilterHandler)
• type FilterConfigFactory
  • func (f *FilterConfigFactory) CreateFilterChain(context context.Context, callbacks api.StreamFilterChainFactoryCallbacks)

Functions

func CreateDSLFilterFactory

func CreateDSLFilterFactory(conf map[string]interface{}) (api.StreamFilterChainFactory, error)

CreateDSLFilterFactory for create dsl filter factory

Types

type DSL

type DSL struct {
	BeforeRouterDSL  attribute.Expression
	AfterRouterDSL   attribute.Expression
	AfterBalancerDSL attribute.Expression
	SendFilterDSL    attribute.Expression
	LogDSL           attribute.Expression
}

type DSLFilter

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

func NewDSLFilter

func NewDSLFilter(ctx context.Context, dsl *DSL) *DSLFilter

NewDSLFilter used to create new dsl filter

func (*DSLFilter) Append

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

func (*DSLFilter) Log

func (f *DSLFilter) Log(ctx context.Context, reqHeaders api.HeaderMap, respHeaders api.HeaderMap, requestInfo api.RequestInfo)

func (*DSLFilter) OnDestroy

func (f *DSLFilter) OnDestroy()

func (*DSLFilter) OnReceive

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

func (*DSLFilter) SetReceiveFilterHandler

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

func (*DSLFilter) SetSenderFilterHandler

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

type FilterConfigFactory

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

FilterConfigFactory filter config factory

func (*FilterConfigFactory) CreateFilterChain

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

CreateFilterChain for create dsl filter