code: func NewLogWatcher() *LogWatcher {
  	return &LogWatcher{
  		Msg:          make(chan *Message, logWatcherBufferSize),
  		Err:          make(chan error, 1),
  		producerGone: make(chan struct{}),
  		consumerGone: make(chan struct{}),
  	}
  }
docs: // NewLogWatcher returns a new LogWatcher.