//
pkg.gl
Category
github.com/cashwagon/qrpc
pkg
drivers
kafka
package
0.1.1
Repository:
https://github.com/cashwagon/qrpc.git
Documentation:
pkg.go.dev
Overview
Versions
1
Dependencies
5
Dependents
2
Files
151 SLOC
#
Functions
NewConsumer
NewConsumer allocates new Consumer object.
NewProducer
NewProducer allocates new Producer object.
#
Structs
Consumer
Consumer represents the wrapper on kafka.Reader.
Producer
Producer represents the wrapper on kafka.Writer.
#
Interfaces
Reader
Reader represents abstract reader interface to wrap kafka.Reader.
Writer
Writer represents abstract writer interface to wrap kafka.Writer.