kafka

Documentation

Index

• type Message
• type MessageType
• type Producer
  • func NewProducer(configuration *config.KafkaConfiguration) (Producer, error)

Types

type Message

type Message struct {
	MessageType MessageType
	Value       interface{}
}

Message - message for Kafka

type MessageType

type MessageType int

MessageType - represents type for iota with Create, MultiCreate, Update, Delete operations

const (
	// Ping Producer
	Ping MessageType = iota
	// CreateJourney - Create Journey via Producer
	CreateJourney
	// MultiCreateJourney - Create several Journeys via Producer
	MultiCreateJourney
	// UpdateJourney - Update Journey via Producer
	UpdateJourney
	// DeleteJourney - Delete Journey via Producer
	DeleteJourney
)

type Producer

type Producer interface {
	Send(message Message) error
	Close() error
}

Producer - interface for work with Kafka

func NewProducer

func NewProducer(configuration *config.KafkaConfiguration) (Producer, error)

NewProducer - creates new Producer for work with Kafka