NewLiveStats creates a new LiveStats instance and starts the main progress printing loop.

Digger is a struct that digs through JSON or proto formatted message streams.

FileConsumer is a Consumer implementation that reads from local files.

KafkaConsumer is a Consumer implementation that reads messages from a Kafka topic.

LiveStats is a processor that calculates and displays stats based on a structured message stream.

LiveStatsConfig stores the inputs for a LiveStats processor.

S3Consumer is a Consumer implementation that reads from one or more prefixes in an S3 bucket.

Consumer is an interface for types that consume messages from a source and feed them into a channel for downstream processing.

Processor is an interface that can process and summarize messages.