Versions in this module Expand all Collapse all v1 v1.1.0 Dec 14, 2018 Changes in this version + type Sink interface + Connect func(src <-chan deps.Dep) (err error) + Init func(conf *config.Config)