a go library for consuming loggregator streams