Versions in this module Expand all Collapse all v1 v1.1.0 Dec 14, 2018 Changes in this version + type Source struct + Config *config.Config + Exchanges []exchange + func (src *Source) Close() + func (src *Source) Connect() (sink <-chan deps.Dep, err error) + func (src *Source) Init(conf *config.Config)