producer

Documentation

Overview

Package consumer implements producer logic for Apache Kafka

Index

• type LikeProducer
  • func NewLikeProducer(producer *kafka.Producer) *LikeProducer
  • func (lp *LikeProducer) ProduceLikesEvents(likesEvents []broker.LikeEvent) error
• type Producer

Types

type LikeProducer

type LikeProducer struct {
	// contains filtered or unexported fields
}

func NewLikeProducer

func NewLikeProducer(producer *kafka.Producer) *LikeProducer

func (*LikeProducer) ProduceLikesEvents

func (lp *LikeProducer) ProduceLikesEvents(likesEvents []broker.LikeEvent) error

type Producer

type Producer interface {
	ProduceLikesEvents(likesEvents []broker.LikeEvent) error
}