add client side implementation for mmode rpc calls

Signed-off-by: Rewant Soni <[email protected]>

services/provider/api/client/client.go

@@ -226,4 +226,50 @@ func (cc *OCSProviderClient) PeerStorageCluster(ctx context.Context, onboardingT
 	defer cancel()
 
 	return cc.Client.PeerStorageCluster(apiCtx, req)
+
+}
+
+func (cc *OCSProviderClient) StartMaintenanceMode(ctx context.Context, consumerUUID string) (*pb.StartMaintenanceModeResponse, error) {
+	if cc.Client == nil || cc.clientConn == nil {
+		return nil, fmt.Errorf("provider client is closed")
+	}
+
+	req := &pb.StartMaintenanceModeRequest{
+		StorageConsumerUUID: consumerUUID,
+	}
+
+	apiCtx, cancel := context.WithTimeout(ctx, cc.timeout)
+	defer cancel()
+
+	return cc.Client.StartMaintenanceMode(apiCtx, req)
+}
+
+func (cc *OCSProviderClient) StopMaintenanceMode(ctx context.Context, consumerUUID, maintenanceModeName string) (*pb.StopMaintenanceModeResponse, error) {
+	if cc.Client == nil || cc.clientConn == nil {
+		return nil, fmt.Errorf("provider client is closed")
+	}
+
+	req := &pb.StopMaintenanceModeRequest{
+		StorageConsumerUUID: consumerUUID,
+	}
+
+	apiCtx, cancel := context.WithTimeout(ctx, cc.timeout)
+	defer cancel()
+
+	return cc.Client.StopMaintenanceMode(apiCtx, req)
+}
+
+func (cc *OCSProviderClient) GetMaintenanceModeStatus(ctx context.Context, consumerUUID, maintenanceModeName string) (*pb.GetMaintenanceModeStatusResponse, error) {
+	if cc.Client == nil || cc.clientConn == nil {
+		return nil, fmt.Errorf("provider client is closed")
+	}
+
+	req := &pb.GetMaintenanceModeStatusRequest{
+		StorageConsumerUUID: consumerUUID,
+	}
+
+	apiCtx, cancel := context.WithTimeout(ctx, cc.timeout)
+	defer cancel()
+
+	return cc.Client.GetMaintenanceModeStatus(apiCtx, req)
 }