All notable changes to this project will be documented in this file.
The format is based on Keep a Changelog.
This project adheres to Semantic Versioning.
xprom
: Addxprom
package to standardize Prometheus metrics with OTEL conventions. (#55)riverkfq
: Addriverkfq
package to provide async publishing of messages to Kafka. (#47)
xload
: Fixed a collision check regression when a struct pointer is decodable and value for thekey
is missing. (#53)xload
: AddedErrCast
to let caller know whichkey
caused the error. (#52)xpod
: Add errors to log delegate when health change fails. (#50)xload
: AddedErrDecode
to let caller know whichkey
caused the error. (#48)
xkafka
: refactor {Run,Start,Close} methods (#38)xpod
[BREAKING]: rename HealthChecker => Checker (#39)
xkafka
Improved async & sequential consumer implementations. See #26 for more details.xkafka
Upgradedgithub.com/confluentinc/confluent-kafka-go
tov2
xload
xload.Load
supports concurrent loading withxload.Concurrency
option.xmap
Addedxmap.Values
function to get values from a map.
xload
Addedxload
package which is a struct first data loading library.xload/providers/yaml
Addedyaml
provider forxload
package.
xmap
Addedxmap.Merge
function to merge two maps.
xpod
Addedxpod
package which contains utilities that help implement best practices for health checks and more, while building go apps for kubernetes pods.xkafka/middleware
- Added Prometheus middleware for
Consumer
andProducer
implementations. - Added Logging MiddlewareFunc.
- Added Prometheus middleware for
xkafka
Addedxkafka
package withProducer
andConsumer
implementations that support middleware & HTTP-like handlers.
generic/slice
All functions now accept typed slices as input. (#4)