Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for filterIndex (0.1 sec)

  1. 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)
  2. 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)
Back to top