Merge pull request #2671 from rewantsoni/rpc

Add RPC calls for peering storageCluster

services/provider/api/client/client.go

@@ -211,3 +211,19 @@ func (cc *OCSProviderClient) ReportStatus(ctx context.Context, consumerUUID stri
 
 	return cc.Client.ReportStatus(apiCtx, req)
 }
+
+func (cc *OCSProviderClient) PeerStorageCluster(ctx context.Context, onboardingToken, storageClusterUID string) (*pb.PeerStorageClusterResponse, error) {
+	if cc.Client == nil || cc.clientConn == nil {
+		return nil, fmt.Errorf("OCS client is closed")
+	}
+
+	req := &pb.PeerStorageClusterRequest{
+		OnboardingToken:   onboardingToken,
+		StorageClusterUID: storageClusterUID,
+	}
+
+	apiCtx, cancel := context.WithTimeout(ctx, cc.timeout)
+	defer cancel()
+
+	return cc.Client.PeerStorageCluster(apiCtx, req)
+}

services/provider/proto/provider.proto

@@ -38,6 +38,11 @@ service OCSProvider {
 
   rpc ReportStatus(ReportStatusRequest)
   returns (ReportStatusResponse){}
+
+  // PeerStorageCluster RPC call to Peer the local Storage Cluster to the remote
+  rpc PeerStorageCluster(PeerStorageClusterRequest)
+  returns (PeerStorageClusterResponse) {}
+
 }
 
 // OnboardConsumerRequest holds the required information to validate the consumer and create StorageConsumer
@@ -182,3 +187,17 @@ message ReportStatusResponse{
     string desiredConfigHash = 2;
 
 }
+
+// PeerStorageClusterRequest holds the required information to Peer to remote StorageCluster
+message PeerStorageClusterRequest{
+    // onboardingToken authenticates the StorageCluster
+    string onboardingToken = 1;
+    // storageClusterUID is the k8s UID of the StorageCluster in the same namespace
+    string storageClusterUID = 2;
+}
+
+// PeerStorageClusterResponse holds the response for OnboardStorageClusterPeer API request
+message PeerStorageClusterResponse{
+    // storageClusterUID is the k8s UID of the remote StorageCluster
+    string storageClusterUID = 1;
+}

services/provider/server/server.go

@@ -945,3 +945,7 @@ func extractMonitorIps(data string) ([]string, error) {
 	slices.Sort(ips)
 	return ips, nil
 }
+
+func (s *OCSProviderServer) PeerStorageCluster(_ context.Context, _ *pb.PeerStorageClusterRequest) (*pb.PeerStorageClusterResponse, error) {
+	return &pb.PeerStorageClusterResponse{}, nil
+}