Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for filterIndex (0.17 sec)

  1. pkg/kube/krt/filter.go

    func FilterSelects(lbls map[string]string) FetchOption {
    	return func(h *dependency) {
    		h.filter.selects = lbls
    	}
    }
    
    // FilterIndex selects only objects matching a key in an index.
    func FilterIndex[I any, K comparable](idx *Index[I, K], k K) FetchOption {
    	return func(h *dependency) {
    		// Index is used to pre-filter on the List, and also to match in Matches. Provide type-erased methods for both
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 10 23:33:56 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  2. pkg/kube/krt/index_test.go

    		return []string{o.IP}
    	})
    	Collection := krt.NewSingleton[string](func(ctx krt.HandlerContext) *string {
    		pods := krt.Fetch(ctx, SimplePods, krt.FilterIndex(IPIndex, "1.2.3.5"))
    		names := slices.Sort(slices.Map(pods, SimplePod.ResourceName))
    		return ptr.Of(strings.Join(names, ","))
    	})
    	Collection.AsCollection().Synced().WaitUntilSynced(stop)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 09 19:55:53 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  3. 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)
  4. pkg/kube/krt/bench_test.go

    	Workloads := krt.NewCollection(Pods, func(ctx krt.HandlerContext, p *v1.Pod) *Workload {
    		if p.Status.PodIP == "" {
    			return nil
    		}
    		services := krt.Fetch(ctx, Services, krt.FilterIndex(ServicesByNamespace, p.Namespace), krt.FilterSelectsNonEmpty(p.GetLabels()))
    		return &Workload{
    			Named:        krt.NewNamed(p),
    			IP:           p.Status.PodIP,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 09 19:55:53 UTC 2024
    - 7K bytes
    - Viewed (0)
  5. 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)
  6. tensorflow/compiler/mlir/quantization/common/quantization_lib/quantization_driver.cc

      if (!mlir::isa<DenseFPElementsAttr>(bias_op.getValue())) return false;
      filter_index = affine_op.GetAffineOperandIndex();
      if (!op->getOperand(filter_index).getDefiningOp<arith::ConstantOp>()) {
        return false;
      }
      if (filter_index == input_indices[0]) {
        input_index = input_indices[1];
      } else if (filter_index == input_indices[1]) {
        input_index = input_indices[0];
      } else {
        return false;
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Apr 25 16:01:03 UTC 2024
    - 38.1K bytes
    - Viewed (0)
Back to top