diff --git a/checkpoints.go b/checkpoints.go index 3b4f28a..e9de6fc 100644 --- a/checkpoints.go +++ b/checkpoints.go @@ -9,7 +9,7 @@ import ( type Checkpoint interface { CheckpointExists(streamName string, shardID string) bool SequenceNumber() string - SetCheckpoint(streamName string, shardId string, sequenceNumber string) + SetCheckpoint(streamName string, shardID string, sequenceNumber string) } type RedisCheckpoint struct { @@ -22,8 +22,8 @@ func (c RedisCheckpoint) SequenceNumber() string { return c.sequenceNumber } -func (c *RedisCheckpoint) CheckpointExists(streamName string, shardId string) bool { - key := c.keyGen(streamName, shardId) +func (c *RedisCheckpoint) CheckpointExists(streamName string, shardID string) bool { + key := c.keyGen(streamName, shardID) val, _ := c.client.Get(key) if val != nil { @@ -34,12 +34,12 @@ func (c *RedisCheckpoint) CheckpointExists(streamName string, shardId string) bo } } -func (c *RedisCheckpoint) SetCheckpoint(streamName string, shardId string, sequenceNumber string) { - key := c.keyGen(streamName, shardId) +func (c *RedisCheckpoint) SetCheckpoint(streamName string, shardID string, sequenceNumber string) { + key := c.keyGen(streamName, shardID) c.client.Set(key, []byte(sequenceNumber)) c.sequenceNumber = sequenceNumber } -func (c RedisCheckpoint) keyGen(streamName string, shardId string) string { - return fmt.Sprintf("%v:checkpoint:%v:%v", c.appName, streamName, shardId) +func (c RedisCheckpoint) keyGen(streamName string, shardID string) string { + return fmt.Sprintf("%v:checkpoint:%v:%v", c.appName, streamName, shardID) }