Perform non-rate-limited migration

kubernetes · Apr 7, 2023 · e1c4c67 · e1c4c67
1 parent 29f654d
commit e1c4c67
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/pkg/neg/syncers/transaction.go b/pkg/neg/syncers/transaction.go
@@ -290,7 +290,12 @@ func (s *transactionSyncer) syncInternalImpl() error {
 		// Identification of migration endpoints should happen before we filter out
 		// the transaction endpoints. Not doing so could result in an attempt to
 		// attach an endpoint which is still undergoing detachment-due-to-migration.
-		findAndFilterMigrationEndpoints(addEndpoints, removeEndpoints)
+		_, migratingEndpointsInRemoveSet := findAndFilterMigrationEndpoints(addEndpoints, removeEndpoints)
+
+		// TODO(gauravkghildiyal): Implement rate limited migration-detachment.
+		for zone, endpointSet := range migratingEndpointsInRemoveSet {
+			removeEndpoints[zone] = removeEndpoints[zone].Union(endpointSet)
+		}
 	}
 
 	// Filter out the endpoints with existing transaction