File tree Expand file tree Collapse file tree 3 files changed +8
-4
lines changed
Expand file tree Collapse file tree 3 files changed +8
-4
lines changed Original file line number Diff line number Diff line change @@ -50,6 +50,9 @@ func NewMetrics() *Metrics {
5050 },
5151 []string {"success" , "retry" },
5252 ),
53+
54+ // notificationStartTimes holds start time for notification queue and processing
55+ notificationStartTimes : make (map [string ]time.Time ),
5356 }
5457}
5558
Original file line number Diff line number Diff line change @@ -5,7 +5,7 @@ var NopMetrics Metrics = &nopMetrics{}
55
66type nopMetrics struct {}
77
8- func (nm * nopMetrics ) ReceivedNotification (isNotification bool ) {}
8+ func (nm * nopMetrics ) ReceivedNotification (isNotification bool ) {}
99func (nm * nopMetrics ) QueueNotification (notification interface {}) {}
1010func (nm * nopMetrics ) StartNotificationProcessing (notification interface {}) {}
1111func (nm * nopMetrics ) FinishNotificationProcessing (notification interface {}, success bool , retry bool ) {
Original file line number Diff line number Diff line change 11package internal
22
33import (
4- "github.com/hellofresh/goengine/extension/prometheus"
54 "testing"
65
7- "github.com/hellofresh/goengine"
8- logWrapper "github.com/hellofresh/goengine/extension/logrus"
96 "github.com/sirupsen/logrus"
107 "github.com/sirupsen/logrus/hooks/test"
118 "github.com/stretchr/testify/suite"
9+
10+ "github.com/hellofresh/goengine"
11+ logWrapper "github.com/hellofresh/goengine/extension/logrus"
12+ "github.com/hellofresh/goengine/extension/prometheus"
1213)
1314
1415// Suite is an extension of github.com/stretchr/testify/suite.Suite
You can’t perform that action at this time.
0 commit comments