Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewKafkaConsumerProvider ¶
func NewKafkaConsumerProvider(cfg Config, opts ...Option) messagequeue.ConsumerProvider
NewKafkaConsumerProvider returns a ConsumerProvider backed by Kafka.
func NewKafkaPublisherProvider ¶
func NewKafkaPublisherProvider(cfg Config, opts ...Option) messagequeue.PublisherProvider
NewKafkaPublisherProvider returns a PublisherProvider backed by Kafka.
Types ¶
type Config ¶
type Config struct {
GroupID string `env:"GROUP_ID" json:"groupId" yaml:"groupId"`
Brokers []string `env:"BROKERS" json:"brokers" yaml:"brokers"`
}
Config configures a Kafka-backed message queue.
type Option ¶
type Option func(*options)
Option configures the providers this package constructs. The zero configuration works: absent observability deps are normalized downstream.
func WithMetricsProvider ¶
WithMetricsProvider attaches a metrics provider.
func WithTracerProvider ¶
func WithTracerProvider(tracerProvider tracing.TracerProvider) Option
WithTracerProvider attaches a tracer provider.
Source Files
Click to show internal directories.
Click to hide internal directories.