broker

Feb 27, 2026

Changes in this version

+ type MetricsRecorder struct

+ func NewMetricsRecorder(component, version string, registerer prometheus.Registerer) *MetricsRecorder

+ func (m *MetricsRecorder) RecordConsumed(topic string)

+ func (m *MetricsRecorder) RecordDuration(topic string, duration time.Duration)

+ func (m *MetricsRecorder) RecordError(topic, errorType string)

+ func (m *MetricsRecorder) RecordPublished(topic string)

Feb 13, 2026

Changes in this version

type Publisher

+ Health func(ctx context.Context) error

Dec 4, 2025

Changes in this version

+ const ErrorChannelBufferSize

type Subscriber

+ Errors func() <-chan *SubscriberError

+ type SubscriberError struct

+ Err error

+ Fatal bool

+ Op string

+ SubscriptionID string

+ Timestamp time.Time

+ Topic string

+ func (e *SubscriberError) Error() string

+ func (e *SubscriberError) Unwrap() error

Nov 19, 2025

Changes in this version

+ const DefaultShutdownTimeout

+ const DefaultSubscriberParallelism

+ const DefaultTestParallelism

+ type HandlerFunc func(ctx context.Context, event *event.Event) error

+ type Publisher interface

+ Close func() error

+ Publish func(topic string, event *event.Event) error

+ func NewPublisher(configMap ...map[string]string) (Publisher, error)

+ type Subscriber interface

+ Close func() error

+ Subscribe func(ctx context.Context, topic string, handler HandlerFunc) error

+ func NewSubscriber(subscriptionID string, configMap ...map[string]string) (Subscriber, error)