Versions in this module Expand all Collapse all v0 v0.4.0 Jun 7, 2022 Changes in this version + func InvokeCallback(eventSubscriptionMap map[string]map[EventType]EventCallback, messageID string, ...) + type EventCallback func() + type EventType string + const DeliveryAttempt + const DeliveryFailure + const DeliverySuccess + type KafkaProducer struct + func NewKafkaProducer(compressor compressor.Compressor, log logr.Logger, ...) (*KafkaProducer, error) + func (p *KafkaProducer) SendAsync(msg *Message) + func (p *KafkaProducer) Start() + func (p *KafkaProducer) Stop() + func (p *KafkaProducer) Subscribe(messageID string, callbacks map[EventType]EventCallback) + func (p *KafkaProducer) SupportsDeltaBundles() bool + type Message struct + ID string + Key string + MsgType string + Payload []byte + Version string + type Producer interface + SendAsync func(message *Message) + Start func() + Stop func() + Subscribe func(messageID string, callbacks map[EventType]EventCallback) + SupportsDeltaBundles func() bool + type SyncServiceProducer struct + func NewSyncServiceProducer(compressor compressor.Compressor, log logr.Logger, env *helper.ConfigManager) (*SyncServiceProducer, error) + func (s *SyncServiceProducer) SendAsync(message *Message) + func (s *SyncServiceProducer) Start() + func (s *SyncServiceProducer) Stop() + func (s *SyncServiceProducer) Subscribe(messageID string, callbacks map[EventType]EventCallback) + func (s *SyncServiceProducer) SupportsDeltaBundles() bool
Go to main page