blob: 09ff4f759c32af5f9484397beb014f9b2013af76 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
|
// -
// ========================LICENSE_START=================================
// Copyright (C) 2024-2025: Deutsche Telekom
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
// SPDX-License-Identifier: Apache-2.0
// ========================LICENSE_END===================================
//
package metrics
import "sync"
// global counter variables
var TotalErrorCount int64
var DecisionSuccessCount int64
var DecisionFailureCount int64
var DeployFailureCount int64
var DeploySuccessCount int64
var UndeployFailureCount int64
var UndeploySuccessCount int64
var TotalPoliciesCount int64
var mu sync.Mutex
// Increment counter
func IncrementTotalErrorCount() {
mu.Lock()
TotalErrorCount++
mu.Unlock()
}
// returns pointer to the counter
func totalErrorCountRef() *int64 {
mu.Lock()
defer mu.Unlock()
return &TotalErrorCount
}
// Increment counter
func IncrementDecisionSuccessCount() {
mu.Lock()
DecisionSuccessCount++
mu.Unlock()
}
// returns pointer to the counter
func totalDecisionSuccessCountRef() *int64 {
mu.Lock()
defer mu.Unlock()
return &DecisionSuccessCount
}
// Increment counter
func IncrementDecisionFailureCount() {
mu.Lock()
DecisionFailureCount++
mu.Unlock()
}
// returns pointer to the counter
func TotalDecisionFailureCountRef() *int64 {
mu.Lock()
defer mu.Unlock()
return &DecisionFailureCount
}
// Increment counter
func IncrementDeploySuccessCount() {
mu.Lock()
DeploySuccessCount++
mu.Unlock()
}
// returns pointer to the counter
func totalDeploySuccessCountRef() *int64 {
mu.Lock()
defer mu.Unlock()
return &DeploySuccessCount
}
// Increment counter
func IncrementDeployFailureCount() {
mu.Lock()
DeployFailureCount++
mu.Unlock()
}
// returns pointer to the counter
func totalDeployFailureCountRef() *int64 {
mu.Lock()
defer mu.Unlock()
return &DeployFailureCount
}
// Increment counter
func IncrementUndeploySuccessCount() {
mu.Lock()
UndeploySuccessCount++
mu.Unlock()
}
// returns pointer to the counter
func totalUndeploySuccessCountRef() *int64 {
mu.Lock()
defer mu.Unlock()
return &UndeploySuccessCount
}
// Increment counter
func IncrementUndeployFailureCount() {
mu.Lock()
UndeployFailureCount++
mu.Unlock()
}
// returns pointer to the counter
func totalUndeployFailureCountRef() *int64 {
mu.Lock()
defer mu.Unlock()
return &UndeployFailureCount
}
// Increment counter
func SetTotalPoliciesCount(newCount int64) {
mu.Lock()
TotalPoliciesCount = newCount
mu.Unlock()
}
// returns pointer to the counter
func totalPoliciesCountRef() *int64 {
mu.Lock()
defer mu.Unlock()
return &TotalPoliciesCount
}
|
