APPS-1353 Missing PK in restored records (#272)

* set send key * update lib * use latest lib * go mod tidy * update lib * update lib * update lib * update lib * use latest lib * main lib branch * main lib branch * update mod
aerospike · Dec 1, 2024 · 3aaf279 · 3aaf279
1 parent 2e30ae8
commit 3aaf279
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 6 deletions.
diff --git a/go.mod b/go.mod
@@ -6,9 +6,9 @@ require (
 	cloud.google.com/go/storage v1.47.0
 	github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.8.0
 	github.com/Azure/azure-sdk-for-go/sdk/storage/azblob v1.5.0
-	github.com/aerospike/aerospike-client-go/v7 v7.7.2
+	github.com/aerospike/aerospike-client-go/v7 v7.7.3
 	github.com/aerospike/aerospike-management-lib v1.5.0
-	github.com/aerospike/backup-go v0.2.1-0.20241127094941-e229b058bf78
+	github.com/aerospike/backup-go v0.2.1-0.20241201083923-4f493baae0f0
 	github.com/aws/aws-sdk-go-v2/config v1.28.5
 	github.com/aws/aws-sdk-go-v2/service/s3 v1.69.0
 	github.com/aws/smithy-go v1.22.1

diff --git a/go.sum b/go.sum
@@ -48,12 +48,12 @@ github.com/GoogleCloudPlatform/opentelemetry-operations-go/internal/resourcemapp
 github.com/GoogleCloudPlatform/opentelemetry-operations-go/internal/resourcemapping v0.48.1/go.mod h1:viRWSEhtMZqz1rhwmOVKkWl6SwmVowfL9O2YR5gI2PE=
 github.com/KyleBanks/depth v1.2.1 h1:5h8fQADFrWtarTdtDudMmGsC7GPbOAu6RVB3ffsVFHc=
 github.com/KyleBanks/depth v1.2.1/go.mod h1:jzSb9d0L43HxTQfT+oSA1EEp2q+ne2uh6XgeJcm8brE=
-github.com/aerospike/aerospike-client-go/v7 v7.7.2 h1:RWoeEA4ofk+uDZuArrhmBaBKWw+J9rZLXj9cOrFQcsM=
-github.com/aerospike/aerospike-client-go/v7 v7.7.2/go.mod h1:STlBtOkKT8nmp7iD+sEkr/JGEOu+4e2jGlNN0Jiu2a4=
+github.com/aerospike/aerospike-client-go/v7 v7.7.3 h1:8uU+GvHm6VQ0WaTIUorWTmEPEnZA1XuUdq6zFHCXYL0=
+github.com/aerospike/aerospike-client-go/v7 v7.7.3/go.mod h1:STlBtOkKT8nmp7iD+sEkr/JGEOu+4e2jGlNN0Jiu2a4=
 github.com/aerospike/aerospike-management-lib v1.5.0 h1:uAEaBU+PkzbtwsSrPVokLIUeJaDrFSMtwqeCKba3xIs=
 github.com/aerospike/aerospike-management-lib v1.5.0/go.mod h1:hsEptY/AmTmHoJnItJNmfJ4yCMG8LIB8YPnIpIyvGXI=
-github.com/aerospike/backup-go v0.2.1-0.20241127094941-e229b058bf78 h1:XyLb5XZcBhVd299vcsHedbUHLxdRh5MYWBhgn1EDafU=
-github.com/aerospike/backup-go v0.2.1-0.20241127094941-e229b058bf78/go.mod h1:w+eSQ8fBVp9/VaVsmVVI4ecigBNxXtKApceuRU/vqNI=
+github.com/aerospike/backup-go v0.2.1-0.20241201083923-4f493baae0f0 h1:FJDGBcjb9P5S06z+3hZTy0iqtn9vzkJqmgDJUNyO8pM=
+github.com/aerospike/backup-go v0.2.1-0.20241201083923-4f493baae0f0/go.mod h1:fuXJNxTuAWagsHtJSRqUqhxIkp7xyWhdSMeDzFB8c9o=
 github.com/aws/aws-sdk-go-v2 v1.32.5 h1:U8vdWJuY7ruAkzaOdD7guwJjD06YSKmnKCJs7s3IkIo=
 github.com/aws/aws-sdk-go-v2 v1.32.5/go.mod h1:P5WJBrYqqbWVaOxgH0X/FYYD47/nooaPOZPlQdmiN2U=
 github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.7 h1:lL7IfaFzngfx0ZwUGOZdsFFnQ5uLvR0hWqqhyE7Q9M8=

diff --git a/pkg/service/restore_run.go b/pkg/service/restore_run.go
@@ -106,6 +106,7 @@ func makeRestoreConfig(restoreRequest *model.RestoreRequest,
 func makeWritePolicy(restoreRequest *model.RestoreRequest) *a.WritePolicy {
 	writePolicy := a.NewWritePolicy(0, 0)
 	writePolicy.GenerationPolicy = a.EXPECT_GEN_GT
+	writePolicy.SendKey = true
 	if restoreRequest.Policy.NoGeneration != nil && *restoreRequest.Policy.NoGeneration {
 		writePolicy.GenerationPolicy = a.NONE
 	}