PrintAggregatorCheckedNotStored function prints all messages that have been checked but not stored into database for whatever reason.

PrintAggregatorConsumedNotReadMessages function prints all messages that are consumer (from input) but not read for any reason.

PrintAggregatorConsumedNotWhitelisted function prints all consumed, but not whitelisted messages, ie.

PrintAggregatorMarshalledNotChecked function prints messages that can be marshalled but are not checked for any reason (improper internal structure etc.).

PrintAggregatorStatistic prints statistic gathered from aggregator logs.

PrintAggregatorWhitelistedNotMarshalled function prints whitelisted messages (that are supposed to be processed) that can't be marshalled for any reason.

PrintPipelineStatistic prints statistic gathered from CCX data pipeline logs.

ReadAggregatorLogFiles reads all log files gathered from aggregator pods.

ReadPipelineLogFiles reads all log files gathered from CCX data pipeline pods.

AggregatorLogEntry represents one log entry (record) read from log file.

PipelineLogEntry represents one log entry (record) read from log file.