diff options
author | Shalini Shivam <ss00765416@techmahindra.com> | 2024-12-13 15:56:10 +0100 |
---|---|---|
committer | Shalini Shivam <ss00765416@techmahindra.com> | 2024-12-16 11:09:20 +0100 |
commit | 83f8646f702f9cffbd25d8124476465ee8f94af0 (patch) | |
tree | 7ff6b73eaf973a16bdbc9f6b5fa33d2a2d9727f5 /pkg/metrics/counters.go | |
parent | d2d039fc4525943ea0d16e49e77c830a8e5c0ecc (diff) |
Support Output response to OPA query
Description : For details refer https://lf-onap.atlassian.net/wiki/spaces/DW/pages/51150925/OPA+PDP
Issue-ID: POLICY-5204
Change-Id: Id6d51fa83957fb560afec2d85cc0d45d6dda6900
Signed-off-by: Shalini Shivam <ss00765416@techmahindra.com>
Diffstat (limited to 'pkg/metrics/counters.go')
-rw-r--r-- | pkg/metrics/counters.go | 53 |
1 files changed, 52 insertions, 1 deletions
diff --git a/pkg/metrics/counters.go b/pkg/metrics/counters.go index 2fc9539..bbf148b 100644 --- a/pkg/metrics/counters.go +++ b/pkg/metrics/counters.go @@ -1,12 +1,33 @@ +// - +// ========================LICENSE_START================================= +// Copyright (C) 2024: 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 +// global counter variables var IndeterminantDecisionsCount int64 var PermitDecisionsCount int64 var DenyDecisionsCount int64 var TotalErrorCount int64 +var QuerySuccessCount int64 +var QueryFailureCount int64 var mu sync.Mutex // Increment counter @@ -64,3 +85,33 @@ func TotalErrorCountRef() *int64 { defer mu.Unlock() return &TotalErrorCount } + +// Increment counter +func IncrementQuerySuccessCount() { + mu.Lock() + QuerySuccessCount++ + mu.Unlock() +} + +// returns pointer to the counter +func TotalQuerySuccessCountRef() *int64 { + mu.Lock() + defer mu.Unlock() + return &QuerySuccessCount + +} + +// Increment counter +func IncrementQueryFailureCount() { + mu.Lock() + QueryFailureCount++ + mu.Unlock() +} + +// returns pointer to the counter +func TotalQueryFailureCountRef() *int64 { + mu.Lock() + defer mu.Unlock() + return &QueryFailureCount + +} |