Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for SubsetOf (0.3 sec)

  1. pkg/kube/krt/filter.go

    			if log.DebugEnabled() {
    				log.Debugf("no match index")
    			}
    			return false
    		}
    	}
    
    	// Rest is expensive
    	if f.selects != nil && !labels.Instance(getLabelSelector(object)).SubsetOf(f.selects) {
    		if log.DebugEnabled() {
    			log.Debugf("no match selects: %q vs %q", f.selects, getLabelSelector(object))
    		}
    		return false
    	}
    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. src/cmd/compile/internal/types2/typeset.go

    // hasTerms reports whether the type set has specific type terms.
    func (s *_TypeSet) hasTerms() bool { return !s.terms.isEmpty() && !s.terms.isAll() }
    
    // subsetOf reports whether s1 ⊆ s2.
    func (s1 *_TypeSet) subsetOf(s2 *_TypeSet) bool { return s1.terms.subsetOf(s2.terms) }
    
    // TODO(gri) TypeSet.is and TypeSet.underIs should probably also go into termlist.go
    
    // is calls f with the specific type terms of s and reports whether
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  3. src/go/types/typeset.go

    // hasTerms reports whether the type set has specific type terms.
    func (s *_TypeSet) hasTerms() bool { return !s.terms.isEmpty() && !s.terms.isAll() }
    
    // subsetOf reports whether s1 ⊆ s2.
    func (s1 *_TypeSet) subsetOf(s2 *_TypeSet) bool { return s1.terms.subsetOf(s2.terms) }
    
    // TODO(gri) TypeSet.is and TypeSet.underIs should probably also go into termlist.go
    
    // is calls f with the specific type terms of s and reports whether
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  4. pilot/pkg/model/policyattachment.go

    	}
    
    	return gwName, exists
    }
    
    func (p WorkloadPolicyMatcher) isSelected(policy TargetablePolicy) bool {
    	selector := policy.GetSelector()
    	return selector == nil || labels.Instance(selector.GetMatchLabels()).SubsetOf(p.WorkloadLabels)
    }
    
    // GetTargetRefs returns the list of targetRefs, taking into account the legacy targetRef
    func GetTargetRefs(p TargetablePolicy) []*v1beta1.PolicyTargetReference {
    	targetRefs := p.GetTargetRefs()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  5. pilot/pkg/controllers/untaint/nodeuntainter.go

    	readyCniPods := krt.NewCollection(pods, func(ctx krt.HandlerContext, p *v1.Pod) *v1.Pod {
    		log.Debugf("cniPods event: %s", p.Name)
    		if p.Namespace != n.ourNs {
    			return nil
    		}
    		if !n.cnilabels.SubsetOf(p.ObjectMeta.Labels) {
    			return nil
    		}
    		if !IsPodReadyConditionTrue(p.Status) {
    			return nil
    		}
    		log.Debugf("pod %s on node %s ready!", p.Name, p.Spec.NodeName)
    		return p
    	}, krt.WithStop(stop))
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Apr 13 00:50:31 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  6. pilot/pkg/model/authentication.go

    					if should {
    						configs = append(configs, cfg)
    					}
    				case gvk.PeerAuthentication:
    					selector := labels.Instance(cfg.Spec.(*v1beta1.PeerAuthentication).GetSelector().GetMatchLabels())
    					if selector.SubsetOf(workloadLabels) {
    						configs = append(configs, cfg)
    					}
    				default:
    					log.Warnf("Not support authentication type %q", cfg.GroupVersionKind)
    					continue
    				}
    			}
    		}
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  7. pilot/pkg/model/sidecar.go

    		// In this scenario it should be determined by exact lookup.
    		if !hIsWildCarded && !importedHost.IsWildCarded() {
    			continue
    		}
    		// Check if the hostnames match per usual hostname matching rules
    		if h.SubsetOf(importedHost) {
    			return true
    		}
    	}
    	return false
    }
    
    // VSMatches checks if the hostClassification(sidecar egress hosts) matches the VirtualService's host
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 20:32:23 UTC 2024
    - 38.4K bytes
    - Viewed (0)
  8. pilot/pkg/serviceregistry/kube/controller/network.go

    		c.RLock()
    		nodeSelector := c.nodeSelectorsForServices[svc.Hostname]
    		c.RUnlock()
    		// update external address
    		var nodeAddresses []string
    		for _, n := range c.nodeInfoMap {
    			if nodeSelector.SubsetOf(n.labels) {
    				nodeAddresses = append(nodeAddresses, n.address)
    			}
    		}
    		if svc.Attributes.ClusterExternalAddresses == nil {
    			svc.Attributes.ClusterExternalAddresses = &model.AddressMap{}
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 22:23:22 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  9. src/cmd/compile/internal/types2/instantiate.go

    	// of T types (i.e., the V type set must be a subset of the T type set).
    	// Interfaces V with empty type sets were already excluded above.
    	if Vi != nil {
    		if !Vi.typeSet().subsetOf(Ti.typeSet()) {
    			// TODO(gri) report which type is missing
    			if cause != nil {
    				*cause = check.sprintf("%s does not %s %s", V, verb, T)
    			}
    			return false
    		}
    		return checkComparability()
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:01:18 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  10. pilot/pkg/serviceregistry/kube/controller/ambient/workloads.go

    		}
    		if pol.Namespace != ns {
    			return false
    		}
    		sel := pol.Spec.Selector
    		if sel == nil {
    			return true // No selector matches everything
    		}
    		return labels.Instance(sel.MatchLabels).SubsetOf(matchLabels)
    	}))
    }
    
    func constructServicesFromWorkloadEntry(p *networkingv1alpha3.WorkloadEntry, services []model.ServiceInfo) map[string]*workloadapi.PortList {
    	res := map[string]*workloadapi.PortList{}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 16:51:29 UTC 2024
    - 20.9K bytes
    - Viewed (0)
Back to top