Merge branch 'master' into ddb-snapshot

artie-labs · Aug 19, 2024 · 7ebf94a · 7ebf94a
2 parents dd113e2 + 815a516
commit 7ebf94a
Show file tree

Hide file tree

Showing 6 changed files with 2 additions and 2 deletions.
diff --git a/lib/persistedmap/persistedmap.go → lib/storage/persistedmap/persistedmap.go b/lib/persistedmap/persistedmap.go → lib/storage/persistedmap/persistedmap.go
diff --git a/lib/persistedmap/persistedmap_test.go → ...storage/persistedmap/persistedmap_test.go b/lib/persistedmap/persistedmap_test.go → ...storage/persistedmap/persistedmap_test.go
diff --git a/lib/ttlmap/ttlmap.go → lib/storage/ttlmap/ttlmap.go b/lib/ttlmap/ttlmap.go → lib/storage/ttlmap/ttlmap.go
diff --git a/lib/ttlmap/ttlmap_test.go → lib/storage/ttlmap/ttlmap_test.go b/lib/ttlmap/ttlmap_test.go → lib/storage/ttlmap/ttlmap_test.go
diff --git a/sources/dynamodb/offsets/offsets.go b/sources/dynamodb/offsets/offsets.go
@@ -4,7 +4,7 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/artie-labs/reader/lib/ttlmap"
+	"github.com/artie-labs/reader/lib/storage/ttlmap"
 )
 
 // ShardExpirationAndBuffer - Buffer for when a shard is closed as the records have a TTL of 24h. However, garbage collection is async.

diff --git a/sources/mongo/streaming.go b/sources/mongo/streaming.go
@@ -14,7 +14,7 @@ import (
 	"github.com/artie-labs/reader/config"
 	"github.com/artie-labs/reader/lib"
 	"github.com/artie-labs/reader/lib/iterator"
-	"github.com/artie-labs/reader/lib/persistedmap"
+	"github.com/artie-labs/reader/lib/storage/persistedmap"
 )
 
 const offsetKey = "offset"
-Original file line number
+Diff line change
@@ Expand Up / @@ -4,7 +4,7 @@ import ( @@
     	"fmt"
     	"time"
-    	"github.com/artie-labs/reader/lib/ttlmap"
+    	"github.com/artie-labs/reader/lib/storage/ttlmap"
     )
     // ShardExpirationAndBuffer - Buffer for when a shard is closed as the records have a TTL of 24h. However, garbage collection is async.
@@ Expand Down @@