code: func NewAggregator() *Aggregator {
  	a := &Aggregator{
  		buffers: make(map[string]*buffer.Buffer),
  		msgc:    make(chan *rfc5424.Message, 1000),
  		pausec:  make(chan struct{}),
  	}
  	go a.run()
  	return a
  }
docs: // NewAggregator creates a new running Aggregator.