mudhorn/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2024-12-24 21:24:05 -08:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

Add license header to fix CI

Browse source 
Signed-off-by: Mustafain Ali Khan <mustalik@amazon.com>
This commit is contained in:
Mustafain Ali Khan 2024-12-12 13:50:47 -08:00
parent 0736877480
commit c432672c14
4 changed files with 32 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
rules/alerting.go
View file

@ -42,6 +42,7 @@ const (
alertMetricName = "ALERTS"
// AlertForStateMetricName is the metric name for 'for' state of alert.
alertForStateMetricName = "ALERTS_FOR_STATE"
// AlertStateLabel is the label name indicating the state of an alert.
alertStateLabel = "alertstate"
)
@ -577,6 +578,8 @@ func (r *AlertingRule) sendAlerts(ctx context.Context, ts time.Time, resendDelay
notifyFunc(ctx, r.vector.String(), alerts...)
}
// Note that changing format of String() changes value of GetFingerprint() leading to loss of persisted state
// when the `alert-state-persistence` feature is enabled.
func (r *AlertingRule) String() string {
ar := rulefmt.Rule{
Alert: r.name,

2
rules/manager.go
View file

@ -129,7 +129,7 @@ type ManagerOptions struct {
RuleDependencyController RuleDependencyController
AlertStore AlertStore
Metrics *Metrics
Metrics *Metrics
}
// NewManager returns an implementation of Manager, ready to be started

15
rules/store.go
View file

@ -1,3 +1,16 @@
// Copyright 2024 The Prometheus Authors
// 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.
package rules
import (
@ -65,9 +78,9 @@ func (s *FileStore) initState(registerer prometheus.Registerer) {
var data *FileData
err = json.NewDecoder(file).Decode(&data)
if err != nil {
data = nil
s.logger.Error("Failed reading alerts state from file", "err", err)
s.storeInitErrors.Inc()
return
}
alertsByRule := make(map[uint64][]*Alert)
if data != nil && data.Alerts != nil {

15
rules/store_test.go
View file

@ -1,3 +1,16 @@
// Copyright 2024 The Prometheus Authors
// 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.
package rules
import (
@ -6,9 +19,9 @@ import (
"time"
"github.com/prometheus/client_golang/prometheus"
"github.com/prometheus/common/promslog"
"github.com/stretchr/testify/require"
"github.com/prometheus/common/promslog"
"github.com/prometheus/prometheus/model/labels"
)