Versions in this module Expand all Collapse all v0 v0.0.1 May 25, 2022 Changes in this version + var Default = New() + var DefaultOptions = Options + var ErrDeliverIsWatching = errors.New("can not set callback when deliver is watching") + var ErrProxyAllreadySettedClient = errors.New("cannot reset producer") + var ErrProxyNotYetSettedClient = errors.New("not set producer yet") + var Logger *log.Log + func AsBatchProducer() optparams.Option[Options] + func WithAcks(acks int) optparams.Option[Options] + func WithParallelCallback() optparams.Option[Options] + func WithProducerSetting(key string, value any) optparams.Option[Options] + func WithQueueBufferingMaxDelay(delay int) optparams.Option[Options] + func WithoutConfirmDelivery() optparams.Option[Options] + type DeliveryCallback func(evt *kafka.Message) + type DeliveryUnknownEventCallback func(evt kafka.Event) + type Options struct + NotConfirmDelivery bool + ParallelCallback bool + type ProducerProxy struct + Opt Options + func New() *ProducerProxy + func (proxy *ProducerProxy) Close() + func (proxy *ProducerProxy) DeliveredRecords() int64 + func (proxy *ProducerProxy) Init(endpoints string, opts ...optparams.Option[Options]) error + func (proxy *ProducerProxy) IsOk() bool + func (proxy *ProducerProxy) IsWatchingDeliver() bool + func (proxy *ProducerProxy) OnDelivery(cb ...DeliveryCallback) error + func (proxy *ProducerProxy) OnDeliveryError(cb ...DeliveryCallback) error + func (proxy *ProducerProxy) OnDeliveryUnknownEventCallback(cb ...DeliveryUnknownEventCallback) error + func (proxy *ProducerProxy) Regist(cb ...SetConnectCallback) error + func (proxy *ProducerProxy) Send(msg *kafka.Message) + func (proxy *ProducerProxy) SendAndWait(msg *kafka.Message) error + func (proxy *ProducerProxy) SetConnect(cli *kafka.Producer) error + func (proxy *ProducerProxy) StartConfirmDelivery() error + type SetConnectCallback func(cli *kafka.Producer) error
Go to main page