vodfka

Jan 7, 2022

Changes in this version

+ func Run()

type Core

+ Wg sync.WaitGroup

Jan 1, 2022

Changes in this version

+ func Consume(topic string, consumerGroup string, handler HandlerFunc)

+ func Default()

+ func With(config Config)

+ type Config struct

+ KafkaBroker string

+ Logger *zap.SugaredLogger

+ Retries int

+ type Context interface

+ BindJSON func(interface{}) error

+ type Core struct

+ KafkaBroker string

+ Logger *zap.SugaredLogger

+ Producer Producer

+ Retries int

+ type HandlerFunc func(Context) error

+ type Producer interface

+ SendJSON func(topic string, key string, obj interface{}) error

+ func GetProducer() Producer