Versions in this module Expand all Collapse all v0 v0.6.0 Nov 8, 2019 v0.5.0 Jun 15, 2018 Changes in this version + type EventBusConsumer interface + SubscribeToTopic func(chan<- *lib.BuildEvent, <-chan struct{}, gocql.UUID) error + type EventBusManager interface + type EventBusProducer interface + PublishEvent func(*lib.BuildEvent) error + type KafkaManager struct + func NewKafkaManager(brokers []string, topic string, maxsends uint, mc metrics.MetricsCollector, ...) (*KafkaManager, error) + func (kp *KafkaManager) PublishEvent(event *lib.BuildEvent) error + func (kp *KafkaManager) SubscribeToTopic(output chan<- *lib.BuildEvent, done <-chan struct{}, buildID gocql.UUID) error
Go to main page