Documentation
¶
Index ¶
- func CreatePayloadLimitFilterFactory(conf map[string]interface{}) (api.StreamFilterChainFactory, error)
- func NewFilter(ctx context.Context, cfg *v2.StreamPayloadLimit) api.StreamReceiverFilter
- func ParseStreamPayloadLimitFilter(cfg map[string]interface{}) (*v2.StreamPayloadLimit, error)
- type FilterConfigFactory
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreatePayloadLimitFilterFactory ¶
func CreatePayloadLimitFilterFactory(conf map[string]interface{}) (api.StreamFilterChainFactory, error)
func NewFilter ¶
func NewFilter(ctx context.Context, cfg *v2.StreamPayloadLimit) api.StreamReceiverFilter
func ParseStreamPayloadLimitFilter ¶
func ParseStreamPayloadLimitFilter(cfg map[string]interface{}) (*v2.StreamPayloadLimit, error)
ParseStreamPayloadLimitFilter
Types ¶
type FilterConfigFactory ¶
type FilterConfigFactory struct {
Config *v2.StreamPayloadLimit
}
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.