Documentation
¶
Index ¶
- func CreateFaultInjectFilterFactory(conf map[string]interface{}) (api.StreamFilterChainFactory, error)
- func NewFilter(ctx context.Context, cfg *v2.StreamFaultInject) api.StreamReceiverFilter
- func ParseStreamFaultInjectFilter(cfg map[string]interface{}) (*v2.StreamFaultInject, error)
- type FilterConfigFactory
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateFaultInjectFilterFactory ¶
func CreateFaultInjectFilterFactory(conf map[string]interface{}) (api.StreamFilterChainFactory, error)
func NewFilter ¶
func NewFilter(ctx context.Context, cfg *v2.StreamFaultInject) api.StreamReceiverFilter
func ParseStreamFaultInjectFilter ¶
func ParseStreamFaultInjectFilter(cfg map[string]interface{}) (*v2.StreamFaultInject, error)
ParseStreamFaultInjectFilter
Types ¶
type FilterConfigFactory ¶
type FilterConfigFactory struct {
Config *v2.StreamFaultInject
}
func (*FilterConfigFactory) CreateFilterChain ¶
func (f *FilterConfigFactory) CreateFilterChain(context context.Context, callbacks api.StreamFilterChainFactoryCallbacks)
Source Files
Click to show internal directories.
Click to hide internal directories.