luciano/amazon-kinesis-client-go
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Made constructors of private structs private

Browse source
This commit is contained in:
Xavi Ramirez 2017-08-10 19:21:46 +00:00
parent 1632c81fc7
commit 27cce44140
3 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
batchconsumer/batchermanager.go
View file

@ -31,7 +31,7 @@ type batcherManager struct {
shutdown chan chan<- struct{} shutdown chan chan<- struct{}
} }
func NewBatcherManager( func newBatcherManager(
sender Sender, chkpntManager *checkpointManager, config Config, log kv.KayveeLogger, sender Sender, chkpntManager *checkpointManager, config Config, log kv.KayveeLogger,
) *batcherManager { ) *batcherManager {
bm := &batcherManager{ bm := &batcherManager{

2
batchconsumer/checkpointmanager.go
View file

@ -18,7 +18,7 @@ type checkpointManager struct {
shutdown chan chan<- struct{} shutdown chan chan<- struct{}
} }
func NewCheckpointManager( func newCheckpointManager(
checkpointer kcl.Checkpointer, config Config, log kv.KayveeLogger, checkpointer kcl.Checkpointer, config Config, log kv.KayveeLogger,
) *checkpointManager { ) *checkpointManager {
cm := &checkpointManager{ cm := &checkpointManager{

4
batchconsumer/writer.go
View file

@ -43,8 +43,8 @@ func NewBatchedWriter(config Config, sender Sender, log kv.KayveeLogger) *batche
func (b *batchedWriter) Initialize(shardID string, checkpointer kcl.Checkpointer) error { func (b *batchedWriter) Initialize(shardID string, checkpointer kcl.Checkpointer) error {
b.shardID = shardID b.shardID = shardID
b.chkpntManager = NewCheckpointManager(checkpointer, b.config, b.log) b.chkpntManager = newCheckpointManager(checkpointer, b.config, b.log)
b.batcherManager = NewBatcherManager(b.sender, b.chkpntManager, b.config, b.log) b.batcherManager = newBatcherManager(b.sender, b.chkpntManager, b.config, b.log)
return nil return nil
} }