producer

Documentation

Index

• type Marshaller
• type Producer
  • func New(kafkaBrokers []string) (*Producer, error)
  • func (p Producer) HealthCheck(_ context.Context) bool
  • func (p *Producer) Send(topic, key string, message interface{}) error

Types

type Marshaller

type Marshaller interface {
	MarshalKFK() ([]byte, error)
}

Marshaller is an interface to serialize messages to kfkTopics.

type Producer

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

Producer.

func New

func New(kafkaBrokers []string) (*Producer, error)

New.

func (Producer) HealthCheck

func (p Producer) HealthCheck(_ context.Context) bool

func (*Producer) Send

func (p *Producer) Send(topic, key string, message interface{}) error

Send a message to a topic to be scattered using the key.