kafka

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 8, 2019 License: MIT Imports: 10 Imported by: 13

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EventBusConsumer

type EventBusConsumer interface {
	SubscribeToTopic(chan<- *lib.BuildEvent, <-chan struct{}, gocql.UUID) error
}

EventBusConsumer describes an object cabable of subscribing to events somewhere

type EventBusManager

type EventBusManager interface {
	EventBusProducer
	EventBusConsumer
}

EventBusManager describes an object that can publish and subscribe to events somewhere

type EventBusProducer

type EventBusProducer interface {
	PublishEvent(*lib.BuildEvent) error
}

EventBusProducer describes an object capable of publishing events somewhere

type KafkaManager

type KafkaManager struct {
	// contains filtered or unexported fields
}

KafkaManager handles sending event messages to the configured Kafka topic

func NewKafkaManager

func NewKafkaManager(brokers []string, topic string, maxsends uint, mc metrics.MetricsCollector, logger *log.Logger) (*KafkaManager, error)

NewKafkaManager returns a new Kafka manager object

func (*KafkaManager) PublishEvent

func (kp *KafkaManager) PublishEvent(event *lib.BuildEvent) error

PublishEvent publishes a build event to the configured Kafka topic

func (*KafkaManager) SubscribeToTopic

func (kp *KafkaManager) SubscribeToTopic(output chan<- *lib.BuildEvent, done <-chan struct{}, buildID gocql.UUID) error

SubscribeToTopic listens to the configured topic, filters by build_id and writes the resulting messages to output. When the subscribed build is finished output is closed. done is a signal from the caller to abort the stream subscription

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL