Rename consumer field in middlewares

Signed-off-by: dusanb94 <[email protected]>

consumers/api/logging.go

@@ -16,15 +16,15 @@ import (
 var _ consumers.Consumer = (*loggingMiddleware)(nil)
 
 type loggingMiddleware struct {
-	logger log.Logger
-	c      consumers.Consumer
+	logger   log.Logger
+	consumer consumers.Consumer
 }
 
 // LoggingMiddleware adds logging facilities to the adapter.
-func LoggingMiddleware(c consumers.Consumer, logger log.Logger) consumers.Consumer {
+func LoggingMiddleware(consumer consumers.Consumer, logger log.Logger) consumers.Consumer {
 	return &loggingMiddleware{
-		logger: logger,
-		c:      c,
+		logger:   logger,
+		consumer: consumer,
 	}
 }
 
@@ -38,5 +38,5 @@ func (lm *loggingMiddleware) Consume(msgs interface{}) (err error) {
 		lm.logger.Info(fmt.Sprintf("%s without errors.", message))
 	}(time.Now())
 
-	return lm.c.Consume(msgs)
+	return lm.consumer.Consume(msgs)
 }

consumers/api/metrics.go

@@ -13,18 +13,18 @@ import (
 var _ consumers.Consumer = (*metricsMiddleware)(nil)
 
 type metricsMiddleware struct {
-	counter metrics.Counter
-	latency metrics.Histogram
-	c       consumers.Consumer
+	counter  metrics.Counter
+	latency  metrics.Histogram
+	consumer consumers.Consumer
 }
 
 // MetricsMiddleware returns new message repository
 // with Save method wrapped to expose metrics.
-func MetricsMiddleware(c consumers.Consumer, counter metrics.Counter, latency metrics.Histogram) consumers.Consumer {
+func MetricsMiddleware(consumer consumers.Consumer, counter metrics.Counter, latency metrics.Histogram) consumers.Consumer {
 	return &metricsMiddleware{
-		counter: counter,
-		latency: latency,
-		c:       c,
+		counter:  counter,
+		latency:  latency,
+		consumer: consumer,
 	}
 }
 
@@ -33,5 +33,5 @@ func (mm *metricsMiddleware) Consume(msgs interface{}) error {
 		mm.counter.With("method", "consume").Add(1)
 		mm.latency.With("method", "consume").Observe(time.Since(begin).Seconds())
 	}(time.Now())
-	return mm.c.Consume(msgs)
+	return mm.consumer.Consume(msgs)
 }

consumers/consumer.go

@@ -5,7 +5,7 @@ package consumers
 
 // Consumer specifies message writing API.
 type Consumer interface {
-	// MessageConsumer method is used to save published message. A non-nil
-	// error is returned to indicate  operation failure.
+	// Consume method is used to consumed received messages.
+	// A non-nil error is returned to indicate  operation failure.
 	Consume(messages interface{}) error
 }