Versions in this module Expand all Collapse all v0 v0.0.12 Feb 24, 2020 Changes in this version + type ConcurrentRouter struct + Router KeyRouter + func (c ConcurrentRouter) Handle(event kafka.Event) + func (c ConcurrentRouter) NewRoute(key catchall.Key, handler Handler) + func (c ConcurrentRouter) Run() (stop chan bool, err error) + type Consumer interface + Run func() (stop chan bool, err error) + type Handler func(event *kafka.Message) error + type JSONProducer interface + ProduceJSONSync func(topic string, partition int32, value interface{}) error + type KeyRouter interface + Handle func(event kafka.Event) + NewRoute func(key catchall.Key, handler Handler) + type LowLevelProducer interface + ProduceSimpleSync func(topic string, partition int32, value []byte) error + ProduceSync func(message *kafka.Message) error + type Producer struct + Producer *kafka.Producer + func NewKafkaProducer(broker string) (*Producer, error) + func (k *Producer) ProduceJSONSync(topic string, partition int32, value interface{}) error + func (k *Producer) ProduceSimpleSync(topic string, partition int32, value []byte) error + func (k *Producer) ProduceSync(message *kafka.Message) error + type TopicRouter struct + Handlers map[catchall.Key]Handler + func NewTopicRouter(consumer *kafka.Consumer) TopicRouter + func (t TopicRouter) Handle(event kafka.Event) + func (t TopicRouter) NewRoute(topic catchall.Key, handler Handler) + func (t TopicRouter) Run() (chan bool, error) + func (t TopicRouter) Topics() []string
Go to main page