Skip to content

Commit 1b23aa5

Browse files
timmilesdwtimmilesdw
committed
fix tests
Signed-off-by: Timur Tuktamyshev <timur.tuktamyshev@flant.com>
1 parent 18a103f commit 1b23aa5

File tree

1 file changed

+13
-13
lines changed

1 file changed

+13
-13
lines changed

‎pkg/addon-operator/queue_test.go‎

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ func Test_ModuleEnsureCRDsTasksInQueueAfterId(t *testing.T) {
2525
queue: func() *queue.TaskQueue {
2626
metricStorage := metric.NewStorageMock(t)
2727
metricStorage.HistogramObserveMock.Set(func(_ string, _ float64, _ map[string]string, _ []float64) {})
28-
metricStorage.GaugeSetMock.Set(func(_ string, _ float64, _ map[string]string) {})
28+
metricStorage.GaugeSetMock.Optional().Set(func(_ string, _ float64, _ map[string]string) {})
2929

3030
q := queue.NewTasksQueue("test", metricStorage)
3131

@@ -47,7 +47,7 @@ func Test_ModuleEnsureCRDsTasksInQueueAfterId(t *testing.T) {
4747
queue: func() *queue.TaskQueue {
4848
metricStorage := metric.NewStorageMock(t)
4949
metricStorage.HistogramObserveMock.Set(func(_ string, _ float64, _ map[string]string, _ []float64) {})
50-
metricStorage.GaugeSetMock.Set(func(_ string, _ float64, _ map[string]string) {})
50+
metricStorage.GaugeSetMock.Optional().Set(func(_ string, _ float64, _ map[string]string) {})
5151

5252
q := queue.NewTasksQueue("test", metricStorage)
5353

@@ -68,7 +68,7 @@ func Test_ModuleEnsureCRDsTasksInQueueAfterId(t *testing.T) {
6868
queue: func() *queue.TaskQueue {
6969
metricStorage := metric.NewStorageMock(t)
7070
metricStorage.HistogramObserveMock.Set(func(_ string, _ float64, _ map[string]string, _ []float64) {})
71-
metricStorage.GaugeSetMock.Set(func(_ string, _ float64, _ map[string]string) {})
71+
metricStorage.GaugeSetMock.Optional().Set(func(_ string, _ float64, _ map[string]string) {})
7272

7373
q := queue.NewTasksQueue("test", metricStorage)
7474

@@ -105,7 +105,7 @@ func Test_QueueHasPendingModuleRunTask(t *testing.T) {
105105
queue: func() *queue.TaskQueue {
106106
metricStorage := metric.NewStorageMock(t)
107107
metricStorage.HistogramObserveMock.Set(func(_ string, _ float64, _ map[string]string, _ []float64) {})
108-
metricStorage.GaugeSetMock.Set(func(_ string, _ float64, _ map[string]string) {})
108+
metricStorage.GaugeSetMock.Optional().Set(func(_ string, _ float64, _ map[string]string) {})
109109

110110
q := queue.NewTasksQueue("test", metricStorage)
111111

@@ -126,7 +126,7 @@ func Test_QueueHasPendingModuleRunTask(t *testing.T) {
126126
queue: func() *queue.TaskQueue {
127127
metricStorage := metric.NewStorageMock(t)
128128
metricStorage.HistogramObserveMock.Set(func(_ string, _ float64, _ map[string]string, _ []float64) {})
129-
metricStorage.GaugeSetMock.Set(func(_ string, _ float64, _ map[string]string) {})
129+
metricStorage.GaugeSetMock.Optional().Set(func(_ string, _ float64, _ map[string]string) {})
130130

131131
q := queue.NewTasksQueue("test", metricStorage)
132132

@@ -150,7 +150,7 @@ func Test_QueueHasPendingModuleRunTask(t *testing.T) {
150150
queue: func() *queue.TaskQueue {
151151
metricStorage := metric.NewStorageMock(t)
152152
metricStorage.HistogramObserveMock.Set(func(_ string, _ float64, _ map[string]string, _ []float64) {})
153-
metricStorage.GaugeSetMock.Set(func(_ string, _ float64, _ map[string]string) {})
153+
metricStorage.GaugeSetMock.Optional().Set(func(_ string, _ float64, _ map[string]string) {})
154154

155155
q := queue.NewTasksQueue("test", metricStorage)
156156

@@ -171,7 +171,7 @@ func Test_QueueHasPendingModuleRunTask(t *testing.T) {
171171
queue: func() *queue.TaskQueue {
172172
metricStorage := metric.NewStorageMock(t)
173173
metricStorage.HistogramObserveMock.Set(func(_ string, _ float64, _ map[string]string, _ []float64) {})
174-
metricStorage.GaugeSetMock.Set(func(_ string, _ float64, _ map[string]string) {})
174+
metricStorage.GaugeSetMock.Optional().Set(func(_ string, _ float64, _ map[string]string) {})
175175

176176
q := queue.NewTasksQueue("test", metricStorage)
177177

@@ -292,7 +292,7 @@ func Test_RemoveAdjacentConvergeModules(t *testing.T) {
292292
t.Run(tt.name, func(t *testing.T) {
293293
metricStorage := metric.NewStorageMock(t)
294294
metricStorage.HistogramObserveMock.Set(func(_ string, _ float64, _ map[string]string, _ []float64) {})
295-
metricStorage.GaugeSetMock.Set(func(_ string, _ float64, _ map[string]string) {})
295+
metricStorage.GaugeSetMock.Optional().Set(func(_ string, _ float64, _ map[string]string) {})
296296

297297
q := queue.NewTasksQueue("test", metricStorage)
298298

@@ -383,7 +383,7 @@ func Test_ModulesWithPendingModuleRun(t *testing.T) {
383383
t.Run(tt.name, func(t *testing.T) {
384384
metricStorage := metric.NewStorageMock(t)
385385
metricStorage.HistogramObserveMock.Set(func(_ string, _ float64, _ map[string]string, _ []float64) {})
386-
metricStorage.GaugeSetMock.Set(func(_ string, _ float64, _ map[string]string) {})
386+
metricStorage.GaugeSetMock.Optional().Set(func(_ string, _ float64, _ map[string]string) {})
387387

388388
q := queue.NewTasksQueue("test", metricStorage)
389389

@@ -664,7 +664,7 @@ func Test_RemoveCurrentConvergeTasksFromId(t *testing.T) {
664664
t.Run(tt.name, func(t *testing.T) {
665665
metricStorage := metric.NewStorageMock(t)
666666
metricStorage.HistogramObserveMock.Set(func(_ string, _ float64, _ map[string]string, _ []float64) {})
667-
metricStorage.GaugeSetMock.Set(func(_ string, _ float64, _ map[string]string) {})
667+
metricStorage.GaugeSetMock.Optional().Set(func(_ string, _ float64, _ map[string]string) {})
668668

669669
q := queue.NewTasksQueue("test", metricStorage)
670670

@@ -713,7 +713,7 @@ func Test_ConvergeModulesInQueue(t *testing.T) {
713713
queue: func() *queue.TaskQueue {
714714
metricStorage := metric.NewStorageMock(t)
715715
metricStorage.HistogramObserveMock.Set(func(_ string, _ float64, _ map[string]string, _ []float64) {})
716-
metricStorage.GaugeSetMock.Set(func(_ string, _ float64, _ map[string]string) {})
716+
metricStorage.GaugeSetMock.Optional().Set(func(_ string, _ float64, _ map[string]string) {})
717717

718718
q := queue.NewTasksQueue("test", metricStorage)
719719

@@ -734,7 +734,7 @@ func Test_ConvergeModulesInQueue(t *testing.T) {
734734
queue: func() *queue.TaskQueue {
735735
metricStorage := metric.NewStorageMock(t)
736736
metricStorage.HistogramObserveMock.Set(func(_ string, _ float64, _ map[string]string, _ []float64) {})
737-
metricStorage.GaugeSetMock.Set(func(_ string, _ float64, _ map[string]string) {})
737+
metricStorage.GaugeSetMock.Optional().Set(func(_ string, _ float64, _ map[string]string) {})
738738

739739
q := queue.NewTasksQueue("test", metricStorage)
740740

@@ -762,7 +762,7 @@ func Test_ConvergeModulesInQueue(t *testing.T) {
762762
queue: func() *queue.TaskQueue {
763763
metricStorage := metric.NewStorageMock(t)
764764
metricStorage.HistogramObserveMock.Set(func(_ string, _ float64, _ map[string]string, _ []float64) {})
765-
metricStorage.GaugeSetMock.Set(func(_ string, _ float64, _ map[string]string) {})
765+
metricStorage.GaugeSetMock.Optional().Set(func(_ string, _ float64, _ map[string]string) {})
766766

767767
q := queue.NewTasksQueue("test", metricStorage)
768768

0 commit comments

Comments
 (0)