mirror of
https://github.com/crowdsecurity/crowdsec.git
synced 2025-05-17 15:01:20 +02:00
b93b240bd4
* lint: gocritic configuration * lint: octal literals * lint: gocritic (filepath.Join) * ling: gocritic (badRegexp, regexpSimplify) * lint: gocritic (preferStringWriter) * lint: gocritic (emtpyStringTest) * filepath.Clean(a+b) -> filepath.Join(a, b) * gofumpt
44 lines
1.3 KiB
Go
44 lines
1.3 KiB
Go
package climetrics
|
|
|
|
import (
|
|
"io"
|
|
|
|
"github.com/jedib0t/go-pretty/v6/table"
|
|
log "github.com/sirupsen/logrus"
|
|
|
|
"github.com/crowdsecurity/crowdsec/cmd/crowdsec-cli/cstable"
|
|
)
|
|
|
|
type statAcquis map[string]map[string]int
|
|
|
|
func (s statAcquis) Description() (string, string) {
|
|
return "Acquisition Metrics",
|
|
`Measures the lines read, parsed, and unparsed per datasource. ` +
|
|
`Zero read lines indicate a misconfigured or inactive datasource. ` +
|
|
`Zero parsed lines means the parser(s) failed. ` +
|
|
`Non-zero parsed lines are fine as crowdsec selects relevant lines.`
|
|
}
|
|
|
|
func (s statAcquis) Process(source, metric string, val int) {
|
|
if _, ok := s[source]; !ok {
|
|
s[source] = make(map[string]int)
|
|
}
|
|
|
|
s[source][metric] += val
|
|
}
|
|
|
|
func (s statAcquis) Table(out io.Writer, wantColor string, noUnit bool, showEmpty bool) {
|
|
t := cstable.New(out, wantColor).Writer
|
|
t.AppendHeader(table.Row{"Source", "Lines read", "Lines parsed", "Lines unparsed", "Lines poured to bucket", "Lines whitelisted"})
|
|
|
|
keys := []string{"reads", "parsed", "unparsed", "pour", "whitelisted"}
|
|
|
|
if numRows, err := metricsToTable(t, s, keys, noUnit); err != nil {
|
|
log.Warningf("while collecting acquis stats: %s", err)
|
|
} else if numRows > 0 || showEmpty {
|
|
title, _ := s.Description()
|
|
io.WriteString(out, title+":\n")
|
|
io.WriteString(out, t.Render()+"\n")
|
|
io.WriteString(out, "\n")
|
|
}
|
|
}
|