Made "NewBatch" function to maintain consistency

Author: markdicksonjr

batch.go

@@ -45,6 +45,12 @@ type BytesSource interface {
 
 type BatchHandler func([]interface{}) error
 
+func NewBatch(batchSize int, pushHandler BatchHandler, flushHandler ...BatchHandler) *Batch {
+	b := Batch{}
+	b.Init(batchSize,  pushHandler, flushHandler...)
+	return &b
+}
+
 func (b *Batch) Init(batchSize int, pushHandler BatchHandler, flushHandler ...BatchHandler) {
 	b.batchPosition = 0
 

batch_test.go

@@ -6,6 +6,15 @@ import (
 	"testing"
 )
 
+func TestNewBatch(t *testing.T) {
+	b1 := NewBatch(100, func(i []interface{}) error {
+		return nil
+	})
+	if b1 == nil {
+		t.Fatal("new batch is nil")
+	}
+}
+
 func TestBatch_PushSingleItemBatch(t *testing.T) {
 	b1 := Batch{}
 	singleItemBatchCallCount := 0