faulttolerance

Documentation

Index

• func CreateSendFilterFactory(conf map[string]interface{}) (api.StreamFilterChainFactory, error)
• type SendFilter
  • func NewSendFilter(config *v2.FaultToleranceFilterConfig, ...) *SendFilter
  • func (f *SendFilter) Append(ctx context.Context, headers api.HeaderMap, buf buffer.IoBuffer, ...) api.StreamFilterStatus
  • func (f *SendFilter) IsException(requestInfo api.RequestInfo) bool
  • func (f *SendFilter) OnDestroy()
  • func (f *SendFilter) SetSenderFilterHandler(handler api.StreamSenderFilterHandler)
• type SendFilterFactory
  • func (f *SendFilterFactory) CreateFilterChain(context context.Context, callbacks api.StreamFilterChainFactoryCallbacks)

Functions

func CreateSendFilterFactory

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

Types

type SendFilter

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

func NewSendFilter

func NewSendFilter(config *v2.FaultToleranceFilterConfig, invocationStatFactory *regulator.InvocationStatFactory) *SendFilter

func (*SendFilter) Append

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

func (*SendFilter) IsException

func (f *SendFilter) IsException(requestInfo api.RequestInfo) bool

func (*SendFilter) OnDestroy

func (f *SendFilter) OnDestroy()

func (*SendFilter) SetSenderFilterHandler

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

type SendFilterFactory

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

func (*SendFilterFactory) CreateFilterChain

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