- Sort Score
- Result 10 results
- Languages All
Results 21 - 26 of 26 for GetMatches (0.14 sec)
-
tests/integration/ambient/baseline_test.go
Never := func(echo.Instance, echo.CallOptions) bool { return false } SameNetwork := func(from echo.Instance, to echo.Target) echo.Instances { return match.Network(from.Config().Cluster.NetworkName()).GetMatches(to.Instances()) } SupportsHBone := func(from echo.Instance, opts echo.CallOptions) bool { if !from.Config().IsUncaptured() && !opts.To.Config().IsUncaptured() { return true }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 00:07:28 UTC 2024 - 78.4K bytes - Viewed (0) -
tests/integration/pilot/common/routing.go
for _, tt := range svcCases { tt, client := tt, client aInCluster := match.Cluster(client.Config().Cluster).GetMatches(t.Apps.A) if len(aInCluster) == 0 { // The cluster doesn't contain A, but connects to a cluster containing A aInCluster = match.Cluster(client.Config().Cluster.Config()).GetMatches(t.Apps.A) } address := aInCluster[0].Config().ClusterLocalFQDN() + "?" if tt.protocol != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 21:52:51 UTC 2024 - 135.9K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/internal/component/model/MultipleCandidateMatcher.java
this.compatible = new BitSet(candidates.size()); compatible.set(0, candidates.size()); } public int[] getMatches() { findCompatibleCandidates(); if (compatible.cardinality() <= 1) { return getCandidates(compatible); } if (longestMatchIsSuperSetOfAllOthers()) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 19.4K bytes - Viewed (0) -
pkg/workloadapi/security/authorization.pb.go
} // Deprecated: Use Rules.ProtoReflect.Descriptor instead. func (*Rules) Descriptor() ([]byte, []int) { return file_workloadapi_security_authorization_proto_rawDescGZIP(), []int{2} } func (x *Rules) GetMatches() []*Match { if x != nil { return x.Matches } return nil } type Match struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 02:27:10 UTC 2024 - 29.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 70.2K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/testing/testing.go
*volume.Spec.VolumeMode = v1.PersistentVolumeFilesystem } // Store the updated object to appropriate places. r.volumes[volume.Name] = volume for _, w := range r.getWatches(action.GetResource(), action.GetNamespace()) { w.Add(volume) } r.changedObjects = append(r.changedObjects, volume) r.changedSinceLastSync++ logger.V(4).Info("Created volume", "volumeName", volume.Name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 20.1K bytes - Viewed (0)