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