a go library for consuming loggregator streams - View it on GitHub