Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventBus ¶
type EventBus interface {
// PublishScrapingComplete emits a "scraping complete" message for the given provider
PublishScrapingComplete(provider string)
// SubscribeScrapingComplete
SubscribeScrapingComplete(provider string, callback interface{})
}
func NewDefaultEventBus ¶
func NewDefaultEventBus(_ emperror.ErrorHandler) EventBus
NewDefaultEventBus creates an event bus backed by https://github.com/asaskevich/EventBus
Source Files
Click to show internal directories.
Click to hide internal directories.