func AggregateLogEntries(ch chan *LogEntry, importantDomains []string) Aggregation {
	aggregation := make(Aggregation)

	for entry := range ch {
		// Potentially Slow?
		if sliceutil.Contains(importantDomains, entry.Host) {
			aggregation.updateEntry(entry.Host, entry)
		}
		aggregation.updateEntry("total", entry)
	}

	return aggregation
}
// AggregateLogEntries consumes the channel and provides an aggregated result
AggregateLogEntries consumes the channel and provides an aggregated result
// AggregateLogEntries consumes the channel and provides an aggregated result
func AggregateLogEntries(ch chan *LogEntry, importantDomains []string) Aggregation {
	aggregation := make(Aggregation)
	for entry := range ch {
		if sliceutil.Contains(importantDomains, entry.Host) {
			aggregation.updateEntry(entry.Host, entry)
		}
		aggregation.updateEntry("total", entry)
	}
	return aggregation
}
func AggregateLogEntries ( ch chan * LogEntry , importantDomains [ ] string ) Aggregation { aggregation := make ( Aggregation ) for entry := range ch { if sliceutil . Contains ( importantDomains , entry . Host ) { aggregation . updateEntry ( entry . Host , entry ) } aggregation . updateEntry ( " " , entry ) } return aggregation }
AggregateLogEntries consumes the channel and provides an aggregated result
AggregateLogEntries consumes the channel and provides an aggregated result
// Potentially Slow?