in metrics/metrics.go [565:602]
func initTissueMetrics(pluggables *[]handlers.Pluggable) error {
subsystem := "tissue"
ampClusters := []string{"cellsdev", "cellsprod"}
patchStatuses := make([]string, 0, len(patch.Statuses))
for _, patchStatus := range patch.Statuses {
patchStatuses = append(patchStatuses, string(patchStatus))
}
patchesGauge, err := metrics.NewGaugeVec(
metrics.WithName("patches_queued_current"),
metrics.WithSubsystem(subsystem),
metrics.WithHelp("Number of patches that are queued up waiting to be processed"),
metrics.WithLabel(labels.FromValues("amp", ampClusters)),
metrics.WithLabel(labels.Integer("ring")),
metrics.WithLabel(labels.FromValues("patch_status", patchStatuses)),
)
if err != nil {
return err
}
*pluggables = append(*pluggables, handlers.NewGauge(patchesGauge))
patchesCounter, err := metrics.NewCounterVec(
metrics.WithName("patches_processed_total"),
metrics.WithSubsystem(subsystem),
metrics.WithHelp("Number of patches processed"),
metrics.WithLabel(labels.FromValues("amp", ampClusters)),
metrics.WithLabel(labels.Integer("ring")),
)
if err != nil {
return err
}
*pluggables = append(*pluggables, handlers.NewCounter(patchesCounter))
return nil
}