kafka

Documentation

Index

• Constants
• type Broker
  • func (b Broker) Close() error
  • func (b Broker) Publish(topic cqrs.RouteKey, messages ...cqrs.Message) error
  • func (b Broker) Subscribe(ctx context.Context, topic cqrs.RouteKey, ackDeadline *time.Duration) (<-chan cqrs.Envelope, error)

Constants

const RetryCountKey = "X-Retry-Count"

const RetryDelayKey = "X-Retry-Delay"

Types

type Broker

type Broker struct {
	Producer       *kafka.Producer
	Consumer       *kafka.Consumer
	PublishTimeout *time.Duration
	Logger         logz.FieldLogger
}

func (Broker) Close

func (b Broker) Close() error

func (Broker) Publish

func (b Broker) Publish(topic cqrs.RouteKey, messages ...cqrs.Message) error

func (Broker) Subscribe

func (b Broker) Subscribe(ctx context.Context, topic cqrs.RouteKey, ackDeadline *time.Duration) (<-chan cqrs.Envelope, error)