pkg

Jan 27, 2026

Changes in this version

+ type BuildInfoMetrics interface

+ SetBuildInfo func(buildDate *libtime.DateTime)

+ func NewBuildInfoMetrics(registerer prometheus.Registerer, namespace string) BuildInfoMetrics

Oct 13, 2025

Changes in this version

+ const ContentTypeApplicationJSON

Jul 23, 2025

Changes in this version

+ func MatchesFilter(msg *sarama.ConsumerMessage, filter []byte) bool

Jul 23, 2025

Changes in this version

+ const ContentTypeApplicationJson

+ const ContentTypeField

+ func NewHandler(changesProvider ChangesProvider) libhttp.WithError

+ func SendJSONResponse(resp http.ResponseWriter, data interface{}, statusCode int) error

+ type ChangesProvider interface

+ Changes func(ctx context.Context, topic libkafka.Topic, partition libkafka.Partition, ...) (Records, error)

+ func NewChangesProvider(sentryClient sentry.Client, saramaClient libkafka.SaramaClient, ...) ChangesProvider

+ type Converter interface

+ Convert func(ctx context.Context, msg *sarama.ConsumerMessage) (*Record, error)

+ func NewConverter() Converter

+ type Page struct

+ NextOffset *libkafka.Offset

+ Records Records

+ type Record struct

+ Header libkafka.Header

+ Key string

+ Offset libkafka.Offset

+ Partition libkafka.Partition

+ Topic libkafka.Topic

+ Value interface{}

+ type Records []Record