consumer

Documentation

Index

• func ConsumerManagerFactory(c interface{}, callbacks capi.FilterCallbackHandler) capi.StreamFilter
• type ConsumerManagerConfigParser
  • func (p *ConsumerManagerConfigParser) Merge(parent interface{}, child interface{}) interface{}
  • func (p *ConsumerManagerConfigParser) Parse(any *anypb.Any, callbacks capi.ConfigCallbackHandler) (interface{}, error)

Functions

func ConsumerManagerFactory

func ConsumerManagerFactory(c interface{}, callbacks capi.FilterCallbackHandler) capi.StreamFilter

Types

type ConsumerManagerConfigParser

type ConsumerManagerConfigParser struct {
}

func (*ConsumerManagerConfigParser) Merge

func (p *ConsumerManagerConfigParser) Merge(parent interface{}, child interface{}) interface{}

func (*ConsumerManagerConfigParser) Parse

func (p *ConsumerManagerConfigParser) Parse(any *anypb.Any, callbacks capi.ConfigCallbackHandler) (interface{}, error)