Documentation
¶
Index ¶
- Constants
- func MatchesFilter(msg *sarama.ConsumerMessage, filter []byte) bool
- func NewHandler(changesProvider ChangesProvider) libhttp.WithError
- func SendJSONResponse(resp http.ResponseWriter, data interface{}, statusCode int) error
- type ChangesProvider
- type Converter
- type Page
- type Record
- type Records
Constants ¶
View Source
const ContentTypeApplicationJSON = "application/json"
View Source
const ContentTypeField = "Content-Type"
Variables ¶
This section is empty.
Functions ¶
func MatchesFilter ¶ added in v1.3.0
func MatchesFilter(msg *sarama.ConsumerMessage, filter []byte) bool
MatchesFilter checks if a Kafka message matches the given filter bytes. If filter is empty, all messages match. Otherwise, performs exact byte substring search in the raw binary message value.
func NewHandler ¶
func NewHandler( changesProvider ChangesProvider, ) libhttp.WithError
func SendJSONResponse ¶
func SendJSONResponse(resp http.ResponseWriter, data interface{}, statusCode int) error
Types ¶
type ChangesProvider ¶
type ChangesProvider interface {
Changes(
ctx context.Context,
topic libkafka.Topic,
partition libkafka.Partition,
offset libkafka.Offset,
limit uint64,
filter []byte,
) (Records, error)
}
func NewChangesProvider ¶
func NewChangesProvider( sentryClient sentry.Client, saramaClient libkafka.SaramaClient, converter Converter, logSamplerFactory log.SamplerFactory, ) ChangesProvider
type Converter ¶
type Converter interface {
Convert(ctx context.Context, msg *sarama.ConsumerMessage) (*Record, error)
}
func NewConverter ¶
func NewConverter() Converter
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.