diff --git a/record_buffer.go b/record_buffer.go index d106a6f..8d02d46 100644 --- a/record_buffer.go +++ b/record_buffer.go @@ -5,6 +5,7 @@ package connector // decides whether a record will be added to the buffer to be emitted. type RecordBuffer struct { NumRecordsToBuffer int + firstSequenceNumber string lastSequenceNumber string recordsInBuffer []Record diff --git a/redis_checkpoint.go b/redis_checkpoint.go index 6a041c5..69e1747 100644 --- a/redis_checkpoint.go +++ b/redis_checkpoint.go @@ -9,8 +9,9 @@ import ( // A Redis implementation of the Checkpont interface. This class is used to enable the Pipeline.ProcessShard // to checkpoint their progress. type RedisCheckpoint struct { - AppName string - StreamName string + AppName string + StreamName string + client redis.Client sequenceNumber string }