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 *aukafka.SyncProducer[repository.UpdateEvent]
KafkaConsumer *aukafka.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
Source Files
Click to show internal directories.
Click to hide internal directories.