eventdriver

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.CloudEvent, error)

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

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

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