4
4
"testing"
5
5
6
6
"github.com/grafana/grafana/pkg/services/alerting/alertstates"
7
+ "github.com/grafana/grafana/pkg/services/alerting/transformers"
7
8
"github.com/grafana/grafana/pkg/tsdb"
8
9
. "github.com/smartystreets/goconvey/convey"
9
10
)
@@ -16,7 +17,7 @@ func TestAlertingExecutor(t *testing.T) {
16
17
Convey ("Show return ok since avg is above 2" , func () {
17
18
rule := & AlertRule {
18
19
Critical : Level {Level : 10 , Operator : ">" },
19
- Transformer : & AggregationTransformer { Method : "avg" } ,
20
+ Transformer : transformers . NewAggregationTransformer ( "avg" ) ,
20
21
}
21
22
22
23
timeSeries := []* tsdb.TimeSeries {
@@ -30,7 +31,7 @@ func TestAlertingExecutor(t *testing.T) {
30
31
Convey ("Show return critical since below 2" , func () {
31
32
rule := & AlertRule {
32
33
Critical : Level {Level : 10 , Operator : "<" },
33
- Transformer : & AggregationTransformer { Method : "avg" } ,
34
+ Transformer : transformers . NewAggregationTransformer ( "avg" ) ,
34
35
}
35
36
36
37
timeSeries := []* tsdb.TimeSeries {
@@ -44,7 +45,7 @@ func TestAlertingExecutor(t *testing.T) {
44
45
Convey ("Show return critical since sum is above 10" , func () {
45
46
rule := & AlertRule {
46
47
Critical : Level {Level : 10 , Operator : ">" },
47
- Transformer : & AggregationTransformer { Method : "sum" } ,
48
+ Transformer : transformers . NewAggregationTransformer ( "sum" ) ,
48
49
}
49
50
50
51
timeSeries := []* tsdb.TimeSeries {
@@ -58,7 +59,7 @@ func TestAlertingExecutor(t *testing.T) {
58
59
Convey ("Show return ok since avg is below 10" , func () {
59
60
rule := & AlertRule {
60
61
Critical : Level {Level : 10 , Operator : ">" },
61
- Transformer : & AggregationTransformer { Method : "avg" } ,
62
+ Transformer : transformers . NewAggregationTransformer ( "avg" ) ,
62
63
}
63
64
64
65
timeSeries := []* tsdb.TimeSeries {
@@ -72,7 +73,7 @@ func TestAlertingExecutor(t *testing.T) {
72
73
Convey ("Show return ok since min is below 10" , func () {
73
74
rule := & AlertRule {
74
75
Critical : Level {Level : 10 , Operator : ">" },
75
- Transformer : & AggregationTransformer { Method : "avg" } ,
76
+ Transformer : transformers . NewAggregationTransformer ( "avg" ) ,
76
77
}
77
78
78
79
timeSeries := []* tsdb.TimeSeries {
@@ -86,7 +87,7 @@ func TestAlertingExecutor(t *testing.T) {
86
87
Convey ("Show return ok since max is above 10" , func () {
87
88
rule := & AlertRule {
88
89
Critical : Level {Level : 10 , Operator : ">" },
89
- Transformer : & AggregationTransformer { Method : "max" } ,
90
+ Transformer : transformers . NewAggregationTransformer ( "max" ) ,
90
91
}
91
92
92
93
timeSeries := []* tsdb.TimeSeries {
@@ -103,7 +104,7 @@ func TestAlertingExecutor(t *testing.T) {
103
104
Convey ("both are ok" , func () {
104
105
rule := & AlertRule {
105
106
Critical : Level {Level : 10 , Operator : ">" },
106
- Transformer : & AggregationTransformer { Method : "avg" } ,
107
+ Transformer : transformers . NewAggregationTransformer ( "avg" ) ,
107
108
}
108
109
109
110
timeSeries := []* tsdb.TimeSeries {
@@ -118,7 +119,7 @@ func TestAlertingExecutor(t *testing.T) {
118
119
Convey ("first serie is good, second is critical" , func () {
119
120
rule := & AlertRule {
120
121
Critical : Level {Level : 10 , Operator : ">" },
121
- Transformer : & AggregationTransformer { Method : "avg" } ,
122
+ Transformer : transformers . NewAggregationTransformer ( "avg" ) ,
122
123
}
123
124
124
125
timeSeries := []* tsdb.TimeSeries {
0 commit comments