api: export cluster name

Signed-off-by: raaizik <[email protected]>

services/provider/interfaces/interfaces.go

@@ -8,11 +8,13 @@ type StorageClientStatus interface {
 	GetOperatorVersion() string
 	GetClusterID() string
 	GetNamespacedName() string
+	GetClusterName() string
 
 	SetPlatformVersion(string) StorageClientStatus
 	SetOperatorVersion(string) StorageClientStatus
 	SetClusterID(string) StorageClientStatus
 	SetNamespacedName(string) StorageClientStatus
+	SetClusterName(string) StorageClientStatus
 }
 
 type StorageClientOnboarding interface {

services/provider/pb/storageclient.go

@@ -35,6 +35,11 @@ func (r *ReportStatusRequest) SetNamespacedName(namespacedName string) ifaces.St
 	return r
 }
 
+func (r *ReportStatusRequest) SetClusterName(clusterName string) ifaces.StorageClientStatus {
+	r.ClusterName = clusterName
+	return r
+}
+
 // ensure OnboardConsumerRequest satisfies StorageClientOnboarding interface
 var _ ifaces.StorageClientOnboarding = &OnboardConsumerRequest{}
 

services/provider/proto/provider.proto

@@ -163,6 +163,8 @@ message ReportStatusRequest{
     string clusterID = 4;
     // NamespacedName is the name and namespace of the StorageClient
     string NamespacedName = 5;
+    // clusterName is the name of the openshift cluster
+    string clusterName = 6;
 }
 
 message ReportStatusResponse{

services/provider/server/consumer.go

@@ -217,6 +217,7 @@ func (c *ocsConsumerManager) UpdateConsumerStatus(ctx context.Context, id string
 	consumerObj.Status.Client.OperatorVersion = status.GetOperatorVersion()
 	consumerObj.Status.Client.ClusterID = status.GetClusterID()
 	consumerObj.Status.Client.NamespacedName = status.GetNamespacedName()
+	consumerObj.Status.Client.ClusterName = status.GetClusterName()
 
 	if err := c.client.Status().Update(ctx, consumerObj); err != nil {
 		return fmt.Errorf("Failed to patch Status for StorageConsumer %v: %v", consumerObj.Name, err)