Versions in this module Expand all Collapse all v0 v0.2.0 Feb 26, 2024 Changes in this version + func ConsumerManagerFactory(c interface{}, callbacks capi.FilterCallbackHandler) capi.StreamFilter + func LookupConsumer(ns, pluginName, key string) (api.Consumer, bool) + type Consumer struct + Auth map[string]string + CanSkipMethod map[string]bool + ConsumerConfigs map[string]api.PluginConsumerConfig + FilterConfigs map[string]*model.ParsedFilterConfig + FilterNames []string + FilterWrappers []*model.FilterWrapper + Filters map[string]*model.FilterConfig + func (c *Consumer) InitConfigs() error + func (c *Consumer) Marshal() string + func (c *Consumer) Name() string + func (c *Consumer) PluginConfig(name string) api.PluginConsumerConfig + func (c *Consumer) Unmarshal(s string) error + type ConsumerManagerConfigParser struct + func (p *ConsumerManagerConfigParser) Merge(parent interface{}, child interface{}) interface{} + func (p *ConsumerManagerConfigParser) Parse(any *anypb.Any, callbacks capi.ConfigCallbackHandler) (interface{}, error)
Go to main page