messengers

Documentation

Index

• type Message
• type Messenger
  • func NewKafkaMessenger(ctx context.Context, brokers []string, topic, group string) Messenger

Types

type Message

type Message struct {
	Offset  int64  `json:"offset"`
	Message string `json:"message"`
	Subject string `json:"subject"`
}

Message defines the format of a message.

type Messenger

type Messenger interface {
	// Check if the broker is reacheable.
	CanConnect() bool
	// Send sends a new message.
	Send(messageID, message string) error
	// Receive a new message from a specific subject.
	Receive(out chan<- Message)
}

Messenger is the standard interface for one of our messengers implementation.

func NewKafkaMessenger

func NewKafkaMessenger(ctx context.Context, brokers []string, topic, group string) Messenger

NewKafkaMessenger creates a new Kafka based messenger.