Standardize naming for NotificationQueue(r)

Author: Christian Wygoda

driver/sql/projection_notification_processor.go

@@ -19,7 +19,7 @@ type (
 		logger  goengine.Logger
 		metrics Metrics
 
-		notificationQueue NotificationQueueInterface
+		notificationQueue NotificationQueuer
 	}
 
 	// ProcessHandler is a func used to trigger a notification but with the addition of providing a Trigger func so
@@ -34,7 +34,7 @@ func NewBackgroundProcessor(
 	logger goengine.Logger,
 	metrics Metrics,
 	retryDelay time.Duration,
-	notificationQueue NotificationQueueInterface,
+	notificationQueue NotificationQueuer,
 ) (*ProjectionNotificationProcessor, error) {
 	if queueProcessors <= 0 {
 		return nil, errors.New("queueProcessors must be greater then zero")

driver/sql/projection_notification_processor_test.go

@@ -52,7 +52,7 @@ func TestStartProcessor(t *testing.T) {
 		t.Run(testCase.title, func(t *testing.T) {
 			ctrl := gomock.NewController(t)
 
-			nqMock := mocks.NewMockNotificationQueueInterface(ctrl)
+			nqMock := mocks.NewNotificationQueuer(ctrl)
 			ctx := context.Background()
 			notification := testCase.notification()
 

driver/sql/projection_notification_queue.go

@@ -13,8 +13,8 @@ var _ ProjectionTrigger = (&NotificationQueue{}).Queue
 var _ ProjectionTrigger = (&NotificationQueue{}).ReQueue
 
 type (
-	// NotificationQueueInterface describes a smart queue for projection notifications
-	NotificationQueueInterface interface {
+	// NotificationQueuer describes a smart queue for projection notifications
+	NotificationQueuer interface {
 		Channel() chan *ProjectionNotification
 		Close()
 		Empty() bool

mocks/driver/sql/notification_queue.go

@@ -22,6 +22,7 @@ import (
 //go:generate go run ../vendor/github.com/golang/mock/mockgen/ -package=sql -destination driver/sql/persistence_strategy.go -mock_names PersistenceStrategy=PersistenceStrategy github.com/hellofresh/goengine/driver/sql PersistenceStrategy
 //go:generate go run ../vendor/github.com/golang/mock/mockgen/ -package=sql -destination driver/sql/projection_state_serialization.go -mock_names ProjectionStateSerialization=ProjectionStateSerialization github.com/hellofresh/goengine/driver/sql ProjectionStateSerialization
 //go:generate go run ../vendor/github.com/golang/mock/mockgen/ -package=sql -destination driver/sql/message_factory.go -mock_names MessageFactory=MessageFactory github.com/hellofresh/goengine/driver/sql MessageFactory
+//go:generate go run ../vendor/github.com/golang/mock/mockgen/ -package sql -destination driver/sql/notification_queue.go -mock_names NotificationQueuer=NotificationQueuer github.com/hellofresh/goengine/driver/sql NotificationQueuer
 
 var _ goengine.Message = &DummyMessage{}