faultinject

Documentation

Index

• func CreateFaultInjectFilterFactory(conf map[string]interface{}) (types.StreamFilterChainFactory, error)
• func NewFilter(ctx context.Context, cfg *v2.StreamFaultInject) types.StreamReceiverFilter
• type FilterConfigFactory
  • func (f *FilterConfigFactory) CreateFilterChain(context context.Context, callbacks types.StreamFilterChainFactoryCallbacks)

Functions

func CreateFaultInjectFilterFactory

func CreateFaultInjectFilterFactory(conf map[string]interface{}) (types.StreamFilterChainFactory, error)

func NewFilter

func NewFilter(ctx context.Context, cfg *v2.StreamFaultInject) types.StreamReceiverFilter

Types

type FilterConfigFactory

type FilterConfigFactory struct {
	Config *v2.StreamFaultInject
}

func (*FilterConfigFactory) CreateFilterChain

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