Skip to content

Commit

Permalink
Merge pull request #7 from andrewstucki/master
Browse files Browse the repository at this point in the history
Use defaultFlushInterval
  • Loading branch information
a8m authored Oct 16, 2018
2 parents 03228a9 + 375553b commit e2587d7
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions config.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ const (
// it's kinda odd, because the maxAggregationSize is limit to 51200L;
maxAggregationCount = 4294967295
defaultMaxConnections = 24
defaultFlushInterval = time.Second
defaultFlushInterval = 5 * time.Second
)

// Putter is the interface that wraps the KinesisAPI.PutRecords method.
Expand Down Expand Up @@ -93,7 +93,7 @@ func (c *Config) defaults() {
}
falseOrPanic(c.MaxConnections < 1 || c.MaxConnections > 256, "kinesis: MaxConnections must be between 1 and 256")
if c.FlushInterval == 0 {
c.FlushInterval = time.Second * 5
c.FlushInterval = defaultFlushInterval
}
falseOrPanic(len(c.StreamName) == 0, "kinesis: StreamName length must be at least 1")
}
Expand Down

0 comments on commit e2587d7

Please sign in to comment.