Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions policy-controller/k8s/index/src/outbound/index.rs
Original file line number Diff line number Diff line change
Expand Up @@ -229,7 +229,7 @@ impl kubert::index::IndexNamespacedResource<Service> for Index {
.filter_map(|port| {
port.app_protocol.as_ref().and_then(|p| {
Some((
NonZeroU16::new(port.port as u16)?,
port.port.try_into().ok().and_then(NonZeroU16::new)?,
AppProtocol::from_str(p.as_str()).expect("Infalliable"),
))
})
Expand Down Expand Up @@ -979,7 +979,7 @@ impl Namespace {
} else {
continue;
};
let route_namespace = route.namespace().expect("GrpcRoute must have a namespace");
let route_namespace = route.namespace().expect("TlsRoute must have a namespace");
let parent_namespace = parent_ref.namespace.as_ref().unwrap_or(&route_namespace);
if *parent_namespace != *self.namespace {
continue;
Expand Down Expand Up @@ -1078,7 +1078,7 @@ impl Namespace {
} else {
continue;
};
let route_namespace = route.namespace().expect("GrpcRoute must have a namespace");
let route_namespace = route.namespace().expect("TcpRoute must have a namespace");
let parent_namespace = parent_ref.namespace.as_ref().unwrap_or(&route_namespace);
if *parent_namespace != *self.namespace {
continue;
Expand Down
Loading