- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for SubsetOf (0.3 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)