Use errors.New instead of fmt.Errorf
This commit is contained in:
parent
dd9da85055
commit
1632c81fc7
1 changed files with 2 additions and 2 deletions
|
|
@ -1,13 +1,13 @@
|
||||||
package batchconsumer
|
package batchconsumer
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
"errors"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/Clever/amazon-kinesis-client-go/kcl"
|
"github.com/Clever/amazon-kinesis-client-go/kcl"
|
||||||
)
|
)
|
||||||
|
|
||||||
var ErrBatchFull = fmt.Errorf("The batch is full")
|
var ErrBatchFull = errors.New("The batch is full")
|
||||||
|
|
||||||
type batcher struct {
|
type batcher struct {
|
||||||
flushCount int
|
flushCount int
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue