Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 26 of 26 for GetMatches (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go

    			if waypointPolicy == nil {
    				return nil
    			}
    			match := waypointPolicy.Authorization.GetGroups()[0].GetRules()[0].GetMatches()[0]
    			return slices.Map(match.Principals, func(sm *security.StringMatch) string {
    				return sm.GetExact()
    			})
    		}, []string{
    			"cluster.local/ns/ns1/sa/namespace-wide",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 01:04:50 UTC 2024
    - 70.2K bytes
    - Viewed (0)
  6. 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)
Back to top