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

Rename test package to store

Browse source
This commit is contained in:
Andrew S. Brown 2019-09-08 06:52:28 -07:00
parent a74a986cf9
commit cc0fc43a95
1 changed files with 3 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
store/memory/store_test.go
View file

@ -1,13 +1,11 @@
package store_test package store
import ( import (
"testing" "testing"
"github.com/harlow/kinesis-consumer/store/memory"
) )
func Test_CheckpointLifecycle(t *testing.T) { func Test_CheckpointLifecycle(t *testing.T) {
c := store.New() c := New()
// set // set
c.SetCheckpoint("streamName", "shardID", "testSeqNum") c.SetCheckpoint("streamName", "shardID", "testSeqNum")
@ -23,7 +21,7 @@ func Test_CheckpointLifecycle(t *testing.T) {
} }
func Test_SetEmptySeqNum(t *testing.T) { func Test_SetEmptySeqNum(t *testing.T) {
c := store.New() c := New()
err := c.SetCheckpoint("streamName", "shardID", "") err := c.SetCheckpoint("streamName", "shardID", "")
if err == nil || err.Error() != "sequence number should not be empty" { if err == nil || err.Error() != "sequence number should not be empty" {