Versions in this module Expand all Collapse all v0 v0.7.0 Jul 19, 2023 Changes in this version + const DefaultMessageKBSize + const MaxMessageKBLimit + const MaxMessageSizeLimit + func InvokeCallback(eventSubscriptionMap map[string]map[EventType]EventCallback, messageID string, ...) + func NewGenericProducer(transportConfig *transport.TransportConfig) (transport.Producer, error) + type EventCallback func() + type EventType string + const DeliveryAttempt + const DeliveryFailure + const DeliverySuccess + type GenericProducer struct + func (p *GenericProducer) Send(ctx context.Context, msg *transport.Message) error + type KafkaProducer struct + func NewKafkaProducer(compressor compressor.Compressor, kafkaConfig *transport.KafkaConfig, ...) (*KafkaProducer, error) + func (p *KafkaProducer) Close() + func (p *KafkaProducer) Producer() *kafka.Producer + func (p *KafkaProducer) Send(ctx context.Context, msg *transport.Message) error + func (p *KafkaProducer) SendAsync(msg *transport.Message) + func (p *KafkaProducer) Start(ctx context.Context) error + func (p *KafkaProducer) Subscribe(messageID string, callbacks map[EventType]EventCallback) + func (p *KafkaProducer) SupportsDeltaBundles() bool + type KafkaProducerConfig struct + ProducerID string + ProducerTopic string + type MessageBuilder struct + func NewMessageBuilder(key string, topic *string, partitionID int32, headers []kafka.Header, ...) *MessageBuilder + func (builder *MessageBuilder) Build() *kafka.Message + func (builder *MessageBuilder) Header(header kafka.Header) *MessageBuilder + type Producer interface + SendAsync func(message *transport.Message) + Start func(ctx context.Context) error + Subscribe func(messageID string, callbacks map[EventType]EventCallback) + SupportsDeltaBundles func() bool