simono41/traewelling-exporter
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Zugtyp- und Fahrtart-Informationen direkt in die currentTrainStatuses Metrik zusammengefasst

Browse source
This commit is contained in:
Simon Rieger 2025-03-10 10:44:30 +01:00
parent 62e6dc5ada
commit 51e28e4c32
1 changed files with 4 additions and 32 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
go/main.go
View file

@ -57,21 +57,7 @@ var (
Name: "traewelling_current_train_statuses", Name: "traewelling_current_train_statuses",
Help: "Zeigt an, ob ein Zug aktiv ist (1 = aktiv, 0 = inaktiv)", Help: "Zeigt an, ob ein Zug aktiv ist (1 = aktiv, 0 = inaktiv)",
}, },
[]string{"username", "line_name", "origin", "destination"}, []string{"username", "line_name", "origin", "destination", "train_type", "trip_type"},
)
currentTrainTypes = promauto.NewGaugeVec(
prometheus.GaugeOpts{
Name: "traewelling_current_train_types",
Help: "Typ des aktuellen Zuges",
},
[]string{"username", "line_name", "origin", "destination", "train_type"},
)
currentTripTypes = promauto.NewGaugeVec(
prometheus.GaugeOpts{
Name: "traewelling_current_trip_types",
Help: "Art der Fahrt (0 = privat, 1 = geschäftlich, 2 = Pendelverkehr)",
},
[]string{"username", "line_name", "origin", "destination", "trip_type"},
) )
totalTrainDistance = promauto.NewGaugeVec( totalTrainDistance = promauto.NewGaugeVec(
prometheus.GaugeOpts{ prometheus.GaugeOpts{
@ -201,21 +187,6 @@ func updateMetricsForUser(username string) {
for _, trip := range statusData.Data { for _, trip := range statusData.Data {
active := isTrainActive(trip.Train.Origin.DepartureReal, trip.Train.Destination.ArrivalReal) active := isTrainActive(trip.Train.Origin.DepartureReal, trip.Train.Destination.ArrivalReal)
currentTrainStatuses.WithLabelValues(
username,
trip.Train.LineName,
trip.Train.Origin.Name,
trip.Train.Destination.Name,
).Set(func() float64 { if active { return 1 } else { return 0 } }())
currentTrainTypes.WithLabelValues(
username,
trip.Train.LineName,
trip.Train.Origin.Name,
trip.Train.Destination.Name,
trip.Train.Category,
).Set(1) // Typ des aktuellen Zuges
tripType := "unknown" tripType := "unknown"
switch trip.Train.TripType { switch trip.Train.TripType {
case 0: case 0:
@ -226,13 +197,14 @@ func updateMetricsForUser(username string) {
tripType = "commute" tripType = "commute"
} }
currentTripTypes.WithLabelValues( currentTrainStatuses.WithLabelValues(
username, username,
trip.Train.LineName, trip.Train.LineName,
trip.Train.Origin.Name, trip.Train.Origin.Name,
trip.Train.Destination.Name, trip.Train.Destination.Name,
trip.Train.Category,
tripType, tripType,
).Set(1) // Art der Fahrt ).Set(func() float64 { if active { return 1 } else { return 0 } }())
} }
totalTrainDistance.WithLabelValues(username).Set(float64(userDetails.Data.TrainDistance) / 1000) totalTrainDistance.WithLabelValues(username).Set(float64(userDetails.Data.TrainDistance) / 1000)