chore: controller cleanup

Signed-off-by: Shane Utt <[email protected]>

Author: shaneutt

controlplane/src/gateway_controller.rs

@@ -46,6 +46,7 @@ use tracing::{debug, error, info, warn};
 pub async fn reconcile(gateway: Arc<Gateway>, ctx: Arc<Context>) -> Result<Action> {
     let start = Instant::now();
     let client = ctx.client.clone();
+
     let name = gateway
         .metadata
         .name
@@ -222,7 +223,7 @@ pub async fn reconcile(gateway: Arc<Gateway>, ctx: Arc<Context>) -> Result<Actio
 pub async fn controller(ctx: Context) -> Result<()> {
     let gateway = Api::<Gateway>::all(ctx.client.clone());
     gateway
-        .list(&ListParams::default().limit(1))
+        .list(&ListParams::default())
         .await
         .map_err(Error::CRDNotFoundError)?;
 

controlplane/src/gatewayclass_controller.rs

@@ -34,6 +34,7 @@ use tracing::*;
 pub async fn reconcile(gateway_class: Arc<GatewayClass>, ctx: Arc<Context>) -> Result<Action> {
     let start = Instant::now();
     let client = ctx.client.clone();
+
     let name = gateway_class
         .metadata
         .name
@@ -68,7 +69,7 @@ pub async fn reconcile(gateway_class: Arc<GatewayClass>, ctx: Arc<Context>) -> R
 pub async fn controller(ctx: Context) -> Result<()> {
     let gwc_api = Api::<GatewayClass>::all(ctx.client.clone());
     gwc_api
-        .list(&ListParams::default().limit(1))
+        .list(&ListParams::default())
         .await
         .map_err(Error::CRDNotFoundError)?;
 

controlplane/src/main.rs

@@ -13,6 +13,7 @@ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 See the License for the specific language governing permissions and
 limitations under the License.
 */
+
 use controlplane::*;
 use std::net::{IpAddr, Ipv4Addr, SocketAddr, SocketAddrV4, SocketAddrV6};
 

controlplane/src/route_utils.rs

@@ -58,16 +58,6 @@ pub async fn is_route_managed(
             continue;
         }
 
-        if let Some(port) = parent_ref.port
-            && !gateway
-                .spec
-                .listeners
-                .iter()
-                .any(|listener| listener.port == port && listener.protocol == "TCP")
-        {
-            continue;
-        }
-
         return Ok(Some(gateway));
     }