generated from kyma-project/template-repository
-
Notifications
You must be signed in to change notification settings - Fork 9
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
<!-- Thank you for your contribution. Before you submit the pull request: 1. Follow contributing guidelines, templates, the recommended Git workflow, and any related documentation. 2. Read and submit the required Contributor Licence Agreements (https://github.com/kyma-project/community/blob/main/CONTRIBUTING.md#agreements-and-licenses). 3. Test your changes and attach their results to the pull request. 4. Update the relevant documentation. If the pull request requires a decision, follow the [decision-making process](https://github.com/kyma-project/community/blob/main/governance.md) and replace the PR template with the [decision record template](https://github.com/kyma-project/community/blob/main/.github/ISSUE_TEMPLATE/decision-record.md). --> **Description** Changes proposed in this pull request: - Add statuses - Refactor **Related issue(s)** <!-- If you refer to a particular issue, provide its number. For example, `Resolves #123`, `Fixes #43`, or `See also #33`. --> #28
- Loading branch information
Showing
5 changed files
with
95 additions
and
49 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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,43 +1,84 @@ | ||
| package metrics | ||
|
|
||
| import ( | ||
| s "github.com/kyma-project/compass-manager/controllers/status" | ||
| "github.com/prometheus/client_golang/prometheus" | ||
| "sigs.k8s.io/controller-runtime/pkg/metrics" | ||
| ) | ||
|
|
||
| const ( | ||
| MetricState = "cm_states" | ||
| MetricActions = "cm_actions" | ||
|
|
||
| LabelState = "state" | ||
| LabelName = "kyma_name" | ||
| LabelAction = "action" | ||
|
|
||
| ActionRegister = "register" | ||
| ActionConfigure = "configure" | ||
| ActionUnregister = "unregister" | ||
| ) | ||
|
|
||
| type Metrics struct { | ||
| configured prometheus.Counter | ||
| registered prometheus.Counter | ||
| unregistered prometheus.Counter | ||
| states *prometheus.GaugeVec | ||
| actions *prometheus.CounterVec | ||
| } | ||
|
|
||
| func NewMetrics() Metrics { | ||
| m := Metrics{ | ||
| configured: prometheus.NewCounter(prometheus.CounterOpts{ | ||
| Name: "configure_counter", | ||
| Help: "Number of cluster configured", | ||
| }), | ||
| registered: prometheus.NewCounter(prometheus.CounterOpts{ | ||
| Name: "register_counter", | ||
| Help: "Number of cluster registered", | ||
| }), | ||
| unregistered: prometheus.NewCounter(prometheus.CounterOpts{ | ||
| Name: "unregister_counter", | ||
| Help: "Number of cluster unregistered", | ||
| }), | ||
| states: prometheus.NewGaugeVec(prometheus.GaugeOpts{ | ||
| Name: MetricState, | ||
| Help: "Indicates the Status.state for Compass Mappings", | ||
| }, []string{LabelName, LabelState}), | ||
|
|
||
| actions: prometheus.NewCounterVec(prometheus.CounterOpts{ | ||
| Name: MetricActions, | ||
| Help: "Number of <action> performed on Kymas", | ||
| }, []string{LabelName, LabelAction}), | ||
| } | ||
| metrics.Registry.MustRegister(m.configured, m.registered, m.unregistered) | ||
| metrics.Registry.MustRegister(m.states, m.actions) | ||
| return m | ||
| } | ||
|
|
||
| func (m Metrics) IncConfigure() { | ||
| m.configured.Inc() | ||
| func (m Metrics) IncConfigure(kymaName string) { | ||
| m.actions.With(prometheus.Labels{ | ||
| LabelName: kymaName, | ||
| LabelAction: ActionConfigure, | ||
| }).Inc() | ||
| } | ||
|
|
||
| func (m Metrics) IncRegister() { | ||
| m.registered.Inc() | ||
| func (m Metrics) IncRegister(kymaName string) { | ||
| m.actions.With(prometheus.Labels{ | ||
| LabelName: kymaName, | ||
| LabelAction: ActionRegister, | ||
| }).Inc() | ||
| } | ||
|
|
||
| func (m Metrics) IncUnregister() { | ||
| m.unregistered.Inc() | ||
| func (m Metrics) IncUnregister(kymaName string) { | ||
| m.actions.With(prometheus.Labels{ | ||
| LabelName: kymaName, | ||
| LabelAction: ActionUnregister, | ||
| }).Inc() | ||
| } | ||
|
|
||
| func (m Metrics) UpdateState(kymaName string, status s.Status) { | ||
| if status == s.Empty { | ||
| m.setModuleStateGauge(kymaName, "") | ||
| return | ||
| } | ||
| state := s.StateText(status) | ||
| m.setModuleStateGauge(kymaName, state) | ||
| } | ||
|
|
||
| func (m Metrics) setModuleStateGauge(kymaName, state string) { | ||
| for _, s := range []string{s.ReadyState, s.FailedState, s.ProcessingState} { | ||
| val := 0.0 | ||
| if s == state { | ||
| val = 1 | ||
| } | ||
| m.states.With(prometheus.Labels{ | ||
| LabelName: kymaName, | ||
| LabelState: s, | ||
| }).Set(val) | ||
| } | ||
| } |
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