Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Run ¶
func Run(wg *sync.WaitGroup, events <-chan interface{}, handler EventHandler)
Run will run the node package with the given event handler on the stream of input events.
Types ¶
type EventHandler ¶
EventHandler represents a handler to process events. We could use a function, but using an interface makes mocking for tests easier.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.