eventdriver

Documentation

Index

• type Consumer
• type Driver
  • func New(queue events.Queue, consumer Consumer) (Driver, error)

Types

type Consumer

type Consumer interface {
	// Consume() takes a slice of topics to listen on, and returns a channel which generates events.
	// If len(topics) == 0, consumer should return all/default set of events.
	Consume(topics []string) (<-chan events.Event, error)

	// Topics() returns list of available topics.
	Topics() []string

	// Should be called to stop consuming events.
	Close() error
}

Consumer consumes events from 3rd party systems.

type Driver

type Driver interface {
	Run() error
	Close() error
}

Driver understands 3rd party systems, consumes their events and publishes them to internal queue

func New

func New(queue events.Queue, consumer Consumer) (Driver, error)