PWX-36635: Adds the pod_name field to PureBlockSpec

Signed-off-by: Adam Krpan <[email protected]>
libopenstorage · May 24, 2024 · c83aedf · c83aedf
1 parent 33fdeae
commit c83aedf
Show file tree

Hide file tree

Showing 7 changed files with 5,653 additions and 5,620 deletions.
diff --git a/SDK_CHANGELOG.md b/SDK_CHANGELOG.md
@@ -2,6 +2,10 @@
 
 ## Releases
 
+### v0.185.0 - (05/24/2024)
+
+* Added a parameter for FlashArray Pod names
+
 ### v0.184.0 - (04/30/2024)
 
 * Added new `pure_nfs_endpoint_opt` field to VolumeSpecUpdate message in proto.

diff --git a/api/api.go b/api/api.go
@@ -109,6 +109,7 @@ const (
 	SpecBackendPureFile                     = "pure_file"
 	SpecPureFileExportRules                 = "pure_export_rules"
 	SpecPureNFSEnpoint                      = "pure_nfs_endpoint"
+	SpecPurePodName                         = "pure_fa_pod_name"
 	SpecIoThrottleRdIOPS                    = "io_throttle_rd_iops"
 	SpecIoThrottleWrIOPS                    = "io_throttle_wr_iops"
 	SpecIoThrottleRdBW                      = "io_throttle_rd_bw"

diff --git a/api/api.pb.go b/api/api.pb.go
diff --git a/api/api.proto b/api/api.proto
@@ -409,6 +409,7 @@ message PXDProxySpec {
 message PureBlockSpec {
   string serial_num = 1;
   string full_vol_name = 2;
+  string pod_name = 3;
 }
 
 // PureFileSpec is the spec for proxying a volume on pure_file backends
@@ -5853,7 +5854,7 @@ message SdkVersion {
     // SDK version major value of this specification
     Major = 0;
     // SDK version minor value of this specification
-    Minor = 184;
+    Minor = 185;
     // SDK version patch value of this specification
     Patch = 0;
   }

diff --git a/api/server/sdk/api/api.swagger.json b/api/server/sdk/api/api.swagger.json
diff --git a/api/server/sdk/sdk_test.go b/api/server/sdk/sdk_test.go
@@ -294,10 +294,16 @@ func (s *testServer) Stop() {
 	volumedrivers.Remove("mock")
 
 	// Shutdown servers
-	s.conn.Close()
+	if s.conn != nil {
+		s.conn.Close()
+	}
 	s.m.EXPECT().StopVolumeWatcher().Return().AnyTimes()
-	s.server.Stop()
-	s.gw.Close()
+	if s.server != nil {
+		s.server.Stop()
+	}
+	if s.gw != nil {
+		s.gw.Close()
+	}
 
 	// Check mocks
 	s.mc.Finish()

diff --git a/api/spec/spec_handler.go b/api/spec/spec_handler.go
@@ -1268,6 +1268,14 @@ func (d *specHandler) RestoreSpecFromOpts(
 				spec.ProxySpec.PureFileSpec = &api.PureFileSpec{}
 			}
 			spec.ProxySpec.PureFileSpec.ExportRules = v
+		case api.SpecPurePodName:
+			if spec.ProxySpec == nil {
+				spec.ProxySpec = &api.ProxySpec{}
+			}
+			if spec.ProxySpec.PureBlockSpec == nil {
+				spec.ProxySpec.PureBlockSpec = &api.PureBlockSpec{}
+			}
+			spec.ProxySpec.PureBlockSpec.PodName = v
 		case api.SpecBackendVolName:
 			volName := v
 			pureBackendVolName = &volName