Documentation
¶
Index ¶
- func PrintAggregatorCheckedNotStored(colorizer aurora.Aurora)
- func PrintAggregatorConsumedNotReadMessages(colorizer aurora.Aurora)
- func PrintAggregatorConsumedNotWhitelisted(colorizer aurora.Aurora)
- func PrintAggregatorMarshalledNotChecked(colorizer aurora.Aurora)
- func PrintAggregatorStatistic(colorizer aurora.Aurora)
- func PrintAggregatorWhitelistedNotMarshalled(colorizer aurora.Aurora)
- func PrintPipelineStatistic(colorizer aurora.Aurora)
- func ReadAggregatorLogFiles() (int, error)
- func ReadPipelineLogFiles() (int, error)
- type AggregatorLogEntry
- type PipelineLogEntry
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PrintAggregatorCheckedNotStored ¶
PrintAggregatorCheckedNotStored function prints all messages that have been checked but not stored into database for whatever reason
func PrintAggregatorConsumedNotReadMessages ¶
PrintAggregatorConsumedNotReadMessages function prints all messages that are consumer (from input) but not read for any reason
func PrintAggregatorConsumedNotWhitelisted ¶
PrintAggregatorConsumedNotWhitelisted function prints all consumed, but not whitelisted messages, ie. messages that have been filtered
func PrintAggregatorMarshalledNotChecked ¶
PrintAggregatorMarshalledNotChecked function prints messages that can be marshalled but are not checked for any reason (improper internal structure etc.)
func PrintAggregatorStatistic ¶
PrintAggregatorStatistic prints statistic gathered from aggregator logs.
func PrintAggregatorWhitelistedNotMarshalled ¶
PrintAggregatorWhitelistedNotMarshalled function prints whitelisted messages (that are supposed to be processed) that can't be marshalled for any reason
func PrintPipelineStatistic ¶
PrintPipelineStatistic prints statistic gathered from CCX data pipeline logs.
func ReadAggregatorLogFiles ¶
ReadAggregatorLogFiles reads all log files gathered from aggregator pods.
func ReadPipelineLogFiles ¶
ReadPipelineLogFiles reads all log files gathered from CCX data pipeline pods.
Types ¶
type AggregatorLogEntry ¶
type AggregatorLogEntry struct {
Level string `json:"level"`
Time string `json:"time"`
Message string `json:"message"`
Type string `json:"type"`
Error string `json:"error"`
Topic string `json:"topic"`
Offset int `json:"offset"`
Group string `json:"group"`
Organization int `json:"organization"`
Cluster string `json:"cluster"`
}
AggregatorLogEntry represents one log entry (record) read from log file.
Source Files