From 27cce441400022a2334356172687b67ca21495b6 Mon Sep 17 00:00:00 2001
From: Xavi Ramirez <xavi.ramirez@clever.com>
Date: Thu, 10 Aug 2017 19:21:46 +0000
Subject: [PATCH] Made constructors of private structs private

---
 batchconsumer/batchermanager.go    | 2 +-
 batchconsumer/checkpointmanager.go | 2 +-
 batchconsumer/writer.go            | 4 ++--
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/batchconsumer/batchermanager.go b/batchconsumer/batchermanager.go
index 8b469c3..1cbe54b 100644
--- a/batchconsumer/batchermanager.go
+++ b/batchconsumer/batchermanager.go
@@ -31,7 +31,7 @@ type batcherManager struct {
 	shutdown      chan chan<- struct{}
 }
 
-func NewBatcherManager(
+func newBatcherManager(
 	sender Sender, chkpntManager *checkpointManager, config Config, log kv.KayveeLogger,
 ) *batcherManager {
 	bm := &batcherManager{
diff --git a/batchconsumer/checkpointmanager.go b/batchconsumer/checkpointmanager.go
index 752fe85..a76fd0c 100644
--- a/batchconsumer/checkpointmanager.go
+++ b/batchconsumer/checkpointmanager.go
@@ -18,7 +18,7 @@ type checkpointManager struct {
 	shutdown   chan chan<- struct{}
 }
 
-func NewCheckpointManager(
+func newCheckpointManager(
 	checkpointer kcl.Checkpointer, config Config, log kv.KayveeLogger,
 ) *checkpointManager {
 	cm := &checkpointManager{
diff --git a/batchconsumer/writer.go b/batchconsumer/writer.go
index b0fd89e..a4e2d7d 100644
--- a/batchconsumer/writer.go
+++ b/batchconsumer/writer.go
@@ -43,8 +43,8 @@ func NewBatchedWriter(config Config, sender Sender, log kv.KayveeLogger) *batche
 func (b *batchedWriter) Initialize(shardID string, checkpointer kcl.Checkpointer) error {
 	b.shardID = shardID
 
-	b.chkpntManager = NewCheckpointManager(checkpointer, b.config, b.log)
-	b.batcherManager = NewBatcherManager(b.sender, b.chkpntManager, b.config, b.log)
+	b.chkpntManager = newCheckpointManager(checkpointer, b.config, b.log)
+	b.batcherManager = newBatcherManager(b.sender, b.chkpntManager, b.config, b.log)
 
 	return nil
 }