Versions in this module Expand all Collapse all v1 v1.0.0 Aug 10, 2019 Changes in this version + type Source struct + Config *config.SourceConfig + IP net.IP + func New(globalConfig *config.Config, Config *config.SourceConfig, errFunc func(error), ...) *Source + func (s *Source) AddMessage(msg *receiver.Message) error + func (s *Source) AddReceiver(r *receiver.Receiver) + func (s *Source) Listen(wg *sync.WaitGroup) error + func (s *Source) Stop()