forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 10:52:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

cmd/utils: startup metrics from config file

Browse source 
Signed-off-by: jsvisa <delweng@gmail.com>
This commit is contained in:
jsvisa 2023-09-13 11:49:13 +08:00
parent ec9ca1c7dc
commit 71905df402
1 changed files with 40 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
cmd/utils/flags.go
View file

@ -2043,6 +2043,46 @@ func SetupMetrics(ctx *cli.Context) {
} }
} }
func SetupMetricsFromConfig(c *metrics.Config) {
if !c.Enabled {
return
}
if err := c.Validate(); err != nil {
Fatalf("Metric in config file contains error: %v", err)
}
log.Info("Enabling metrics collection")
if c.EnableInfluxDB || c.EnableInfluxDBV2 {
var (
tagsMap = SplitTagsFlag(c.InfluxDBTags)
endpoint = c.InfluxDBEndpoint
database = c.InfluxDBDatabase
username = c.InfluxDBUsername
password = c.InfluxDBPassword
token = c.InfluxDBToken
bucket = c.InfluxDBBucket
organization = c.InfluxDBOrganization
)
if c.EnableInfluxDB {
log.Info("Enabling metrics export to InfluxDB")
go influxdb.InfluxDBWithTags(metrics.DefaultRegistry, 10*time.Second, endpoint, database, username, password, "geth.", tagsMap)
} else if c.EnableInfluxDBV2 {
log.Info("Enabling metrics export to InfluxDB (v2)")
go influxdb.InfluxDBV2WithTags(metrics.DefaultRegistry, 10*time.Second, endpoint, token, bucket, organization, "geth.", tagsMap)
}
}
if c.HTTP != "" {
address := net.JoinHostPort(c.HTTP, fmt.Sprintf("%d", c.Port))
log.Info("Enabling stand-alone metrics HTTP endpoint", "address", address)
exp.Setup(address)
} else if c.Port != 0 {
log.Warn("influxdb.port specified without inflxdb.addr, metrics server will not start.")
}
}
func SplitTagsFlag(tagsFlag string) map[string]string { func SplitTagsFlag(tagsFlag string) map[string]string {
tags := strings.Split(tagsFlag, ",") tags := strings.Split(tagsFlag, ",")
tagsMap := map[string]string{} tagsMap := map[string]string{}