Documentation ¶
Index ¶
- Constants
- func New(configuration librepo.Configuration, customConfig config.CustomConfiguration, ...) repository.Kafka
- type Impl
- func (r *Impl) ConnectProducer(ctx context.Context) error
- func (r *Impl) Disconnect(ctx context.Context) error
- func (r *Impl) IsKafka() bool
- func (r *Impl) Send(ctx context.Context, event repository.UpdateEvent) error
- func (r *Impl) Setup() error
- func (r *Impl) StartReceiveLoop(ctx context.Context) error
- func (r *Impl) SubscribeIncoming(ctx context.Context, callback repository.ReceiverCallback) error
- func (r *Impl) Teardown()
Constants ¶
View Source
const MetadataChangeEventsTopicKey = "metadata-change-events"
Variables ¶
This section is empty.
Functions ¶
func New ¶
func New( configuration librepo.Configuration, customConfig config.CustomConfiguration, logging librepo.Logging, hostIP repository.HostIP, ) repository.Kafka
Types ¶
type Impl ¶
type Impl struct { Configuration librepo.Configuration CustomConfiguration config.CustomConfiguration Logging librepo.Logging HostIP repository.HostIP Callback repository.ReceiverCallback KafkaProducer *kafka.SyncProducer[repository.UpdateEvent] KafkaConsumer *kafka.Consumer[repository.UpdateEvent] }
func (*Impl) ConnectProducer ¶ added in v0.36.0
func (*Impl) Send ¶
func (r *Impl) Send(ctx context.Context, event repository.UpdateEvent) error
func (*Impl) SubscribeIncoming ¶
func (r *Impl) SubscribeIncoming(ctx context.Context, callback repository.ReceiverCallback) error
Click to show internal directories.
Click to hide internal directories.