producer

package

v0.2.3-0...-5ed8acd Latest Latest Go to latest Published: Apr 26, 2022 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package producer holds interface for publishing messages to required destinations and implementation for sending messages to Kafka.

This section is empty.

This section is empty.

This section is empty.

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

KafkaProducer is a Producer implementation for publishing messages to Kafka

func (p *KafkaProducer) Close() error

Close closes Kafka connection

func (p *KafkaProducer) Publish(msg Message) error

Publish publishes message to Kafka

type Message struct {
	ID    uuid.UUID `json:"id"`
	Body  []byte    `json:"body"`
	Topic string    `json:"topic"`
}

Message struct contains data for message read from RabbitMQ and ready for sending to Kafka

func NewMessage(body []byte, topic string) *Message

NewMessage initializes and instantiates new Message

func (m Message) String() string

String represents message as simple string value

type Producer interface {
	Publish(msg Message) error
	Close() error
}

Producer is an interface for publishing messages service

func NewKafkaProducer(kafkaConfig config.KafkaConfig, statsClient client.Client) (Producer, error)

NewKafkaProducer instantiates and establishes new Kafka connection