Koorous Vargha
12/01/2023, 4:42 AM// Check the migration status for all source and destination cluster stores
Pattern systemStorePattern = Pattern.compile(storeName);
Stream<String> allSrcStoreNames = srcControllerClient.getClusterStores(srcClusterName).stream().filter(srcStoreName -> systemStorePattern.matcher(srcStoreName).matches());
Stream<String> allDestStoreNames = destControllerClient.getClusterStores(destClusterName).stream().filter(destStoreName -> systemStorePattern.matcher(destStoreName).matches());
allSrcStoreNames.forEach(srcStorename -> printMigrationStatus(srcControllerClient, srcStorename));
allDestStoreNames.forEach(destStorename -> printMigrationStatus(destControllerClient, destStorename));