diff --git a/redis_checkpoint.go b/redis_checkpoint.go index a4819c8..6a041c5 100644 --- a/redis_checkpoint.go +++ b/redis_checkpoint.go @@ -10,9 +10,9 @@ import ( // to checkpoint their progress. type RedisCheckpoint struct { AppName string + StreamName string client redis.Client sequenceNumber string - StreamName string } // Check whether a checkpoint for a particular Shard exists. Typically used to determine whether we should