producer

Sep 11, 2019

Changes in this version

type Producer

+ func (p Producer) Poll(ctx context.Context)

Sep 6, 2019

Changes in this version

+ type Handler struct

+ func NewHandler(events <-chan kafka.Event, wg *sync.WaitGroup, msgStore store.MsgStore) *Handler

+ func (h *Handler) Handle()

+ type Option func(*Producer)

+ func Register(cb callback.Callback) Option

+ type Producer struct

+ func New(prodCfg config.Producer, mc msgCreator, opts ...Option) (*Producer, error)

+ func (p *Producer) Register(cb callback.Callback)

+ func (p Producer) Close() error

+ func (p Producer) ProduceWorker(ctx context.Context)

+ func (p Producer) Run(ctx context.Context)