-
Notifications
You must be signed in to change notification settings - Fork 3.4k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'main' into bring-back-check-format
- Loading branch information
Showing
52 changed files
with
1,672 additions
and
314 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,96 @@ | ||
| package metrics | ||
|
|
||
| import ( | ||
| "context" | ||
|
|
||
| "github.com/go-logr/logr" | ||
| "github.com/prometheus/client_golang/prometheus" | ||
| metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" | ||
| "sigs.k8s.io/controller-runtime/pkg/client" | ||
|
|
||
| lokiv1 "github.com/grafana/loki/operator/apis/loki/v1" | ||
| ) | ||
|
|
||
| const ( | ||
| metricsPrefix = "lokistack_" | ||
| ) | ||
|
|
||
| var ( | ||
| metricsCommonLabels = []string{ | ||
| "stack_namespace", | ||
| "stack_name", | ||
| "size", | ||
| } | ||
|
|
||
| lokiStackInfoDesc = prometheus.NewDesc( | ||
| metricsPrefix+"info", | ||
| "Information about deployed LokiStack instances. Value is always 1.", | ||
| metricsCommonLabels, nil, | ||
| ) | ||
|
|
||
| lokiStackConditionsCountDesc = prometheus.NewDesc( | ||
| metricsPrefix+"status_condition", | ||
| "Counts the current status conditions of the LokiStack.", | ||
| append(metricsCommonLabels, "condition", "reason", "status"), nil, | ||
| ) | ||
| ) | ||
|
|
||
| func RegisterLokiStackCollector(log logr.Logger, k8sClient client.Client, registry prometheus.Registerer) error { | ||
| metrics := &lokiStackCollector{ | ||
| log: log, | ||
| k8sClient: k8sClient, | ||
| } | ||
|
|
||
| return registry.Register(metrics) | ||
| } | ||
|
|
||
| type lokiStackCollector struct { | ||
| log logr.Logger | ||
| k8sClient client.Client | ||
| } | ||
|
|
||
| func (l *lokiStackCollector) Describe(ch chan<- *prometheus.Desc) { | ||
| ch <- lokiStackInfoDesc | ||
| ch <- lokiStackConditionsCountDesc | ||
| } | ||
|
|
||
| func (l *lokiStackCollector) Collect(m chan<- prometheus.Metric) { | ||
| ctx := context.TODO() | ||
|
|
||
| stackList := &lokiv1.LokiStackList{} | ||
| err := l.k8sClient.List(ctx, stackList) | ||
| if err != nil { | ||
| l.log.Error(err, "failed to get list of LokiStacks for metrics") | ||
| return | ||
| } | ||
|
|
||
| for _, stack := range stackList.Items { | ||
| labels := []string{ | ||
| stack.Namespace, | ||
| stack.Name, | ||
| string(stack.Spec.Size), | ||
| } | ||
|
|
||
| m <- prometheus.MustNewConstMetric(lokiStackInfoDesc, prometheus.GaugeValue, 1.0, labels...) | ||
|
|
||
| for _, c := range stack.Status.Conditions { | ||
| activeValue := 0.0 | ||
| if c.Status == metav1.ConditionTrue { | ||
| activeValue = 1.0 | ||
| } | ||
|
|
||
| // This mirrors the behavior of kube_state_metrics, which creates two metrics for each condition, | ||
| // one for each status (true/false). | ||
| m <- prometheus.MustNewConstMetric( | ||
| lokiStackConditionsCountDesc, | ||
| prometheus.GaugeValue, activeValue, | ||
| append(labels, c.Type, c.Reason, "true")..., | ||
| ) | ||
| m <- prometheus.MustNewConstMetric( | ||
| lokiStackConditionsCountDesc, | ||
| prometheus.GaugeValue, 1.0-activeValue, | ||
| append(labels, c.Type, c.Reason, "false")..., | ||
| ) | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.