- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for filterIndex (0.1 sec)
-
pilot/pkg/serviceregistry/kube/controller/ambient/workloads.go
} var waypointAddress *workloadapi.GatewayAddress if waypoint != nil { waypointAddress = a.getWaypointAddress(waypoint) } fo := []krt.FetchOption{krt.FilterIndex(WorkloadServicesNamespaceIndex, wle.Namespace), krt.FilterSelectsNonEmpty(wle.GetLabels())} if !features.EnableK8SServiceSelectWorkloadEntries { fo = append(fo, krt.FilterGeneric(func(a any) bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 20.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/waypoints.go
// ignore Kubernetes Gateways which aren't waypoints return nil } instances := krt.Fetch(ctx, Pods, krt.FilterLabel(map[string]string{ constants.GatewayNameLabel: gateway.Name, }), krt.FilterIndex(podsByNamespace, gateway.Namespace)) serviceAccounts := slices.Map(instances, func(p *v1.Pod) string { return p.Spec.ServiceAccountName })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:28 UTC 2024 - 11.1K bytes - Viewed (0)