publisher

Aug 16, 2024

Changes in this version

type Publisher

+ Writer *kafka.Writer

Aug 13, 2024

Changes in this version

+ type LogObserver struct

+ func NewLogObserver(ctx context.Context, logger log.Logger, topic string) LogObserver

+ func (l LogObserver) PublisherError(err error)

+ type Middleware func(next RoundTripper) RoundTripper

+ type NoopObserver struct

+ func (n NoopObserver) PublisherError(err error)

+ type Observer interface

+ PublisherError func(err error)

+ type Option func(p *Publisher)

+ func WithMiddlewares(mws ...Middleware) Option

+ func WithObserver(observer Observer) Option

+ type PublishOption = func(*frame.Frame) error

+ type Publisher struct

+ func New(writer *kafka.Writer, topic string, opts ...Option) *Publisher

+ func (p *Publisher) Close() error

+ func (p *Publisher) Healthcheck(_ context.Context) error

+ func (p *Publisher) Publish(ctx context.Context, msgs ...kafka.Message) error

+ type RoundTripper interface

+ Publish func(ctx context.Context, msgs ...kafka.Message) error

+ type RoundTripperFunc func(ctx context.Context, msgs ...kafka.Message) error

+ func (f RoundTripperFunc) Publish(ctx context.Context, msgs ...kafka.Message) error