Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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.CloudEvent, error) // Topics() returns list of available topics. Topics() []string // Close() Should be called to stop consuming events. Close() error }
Consumer consumes events from 3rd party systems.
Click to show internal directories.
Click to hide internal directories.