Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 169 for ep (0.03 sec)

  1. cmd/admin-handlers-pools.go

    	// first node. The following is required to serialize (the effects of)
    	// concurrent rebalance-start commands.
    	if ep := globalEndpoints[0].Endpoints[0]; !ep.IsLocal {
    		for nodeIdx, proxyEp := range globalProxyEndpoints {
    			if proxyEp.Endpoint.Host == ep.Host {
    				if proxyRequestByNodeIndex(ctx, w, r, nodeIdx) {
    					return
    				}
    			}
    		}
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  2. pilot/pkg/networking/grpcgen/grpcecho_test.go

    		})
    		if err != nil {
    			t.Fatal(err)
    		}
    		wg.Add(1)
    		if err := ep.Start(func() {
    			wg.Done()
    		}); err != nil {
    			t.Fatal(err)
    		}
    
    		cfgs = append(cfgs, makeWE(s, ip, ep.GetConfig().Port.Port))
    		cgt.endpoints = append(cgt.endpoints, ep)
    		t.Cleanup(func() {
    			if err := ep.Close(); err != nil {
    				t.Errorf("failed to close endpoint %s: %v", ip, err)
    			}
    		})
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 12 18:20:36 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  3. pilot/pkg/config/kube/ingress/status.go

    	lbi := make([]knetworking.IngressLoadBalancerIngress, 0, len(endpoints))
    	for _, ep := range endpoints {
    		if !netutil.IsValidIPAddress(ep) {
    			lbi = append(lbi, knetworking.IngressLoadBalancerIngress{Hostname: ep})
    		} else {
    			lbi = append(lbi, knetworking.IngressLoadBalancerIngress{IP: ep})
    		}
    	}
    
    	sort.SliceStable(lbi, lessLoadBalancerIngress(lbi))
    	return lbi
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 16:41:38 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/reflect/TypeTokenSubtypeTest.java

      public static void testSubtypeOfStaticAnonymousClass() {
        Class<?> superclass = new Mall<Outdoor>().new Shop<Electronics>() {}.getClass();
        assertTrue(TypeToken.of(superclass).isSubtypeOf(superclass));
        assertFalse(
            TypeToken.of(new Mall<Outdoor>().new Shop<Electronics>() {}.getClass())
                .isSubtypeOf(superclass));
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 20.3K bytes
    - Viewed (0)
  5. cmd/bootstrap-peer-server.go

    		}
    		envValues[envK] = logger.HashString(env.Get(envK, ""))
    	}
    	scfg := &ServerSystemConfig{NEndpoints: globalEndpoints.NEndpoints(), MinioEnv: envValues}
    	var cmdLines []string
    	for _, ep := range globalEndpoints {
    		cmdLines = append(cmdLines, ep.CmdLine)
    	}
    	scfg.CmdLines = cmdLines
    	return scfg
    }
    
    func (s *bootstrapRESTServer) VerifyHandler(params *grid.MSS) (*ServerSystemConfig, *grid.RemoteErr) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/reflect/TypeTokenSubtypeTest.java

      public static void testSubtypeOfStaticAnonymousClass() {
        Class<?> superclass = new Mall<Outdoor>().new Shop<Electronics>() {}.getClass();
        assertTrue(TypeToken.of(superclass).isSubtypeOf(superclass));
        assertFalse(
            TypeToken.of(new Mall<Outdoor>().new Shop<Electronics>() {}.getClass())
                .isSubtypeOf(superclass));
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 20.3K bytes
    - Viewed (0)
  7. pilot/pkg/networking/core/tracing_test.go

    	ep := fakeOpenTelemetryHTTP()
    
    	ep.GetOpentelemetry().ResourceDetectors = &meshconfig.MeshConfig_ExtensionProvider_ResourceDetectors{
    		Environment: &meshconfig.MeshConfig_ExtensionProvider_ResourceDetectors_EnvironmentResourceDetector{},
    		Dynatrace:   &meshconfig.MeshConfig_ExtensionProvider_ResourceDetectors_DynatraceResourceDetector{},
    	}
    
    	return ep
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 20:47:52 UTC 2024
    - 38.6K bytes
    - Viewed (0)
  8. pilot/pkg/serviceregistry/kube/controller/network.go

    		// track endpoints items from this registry are a part of this network
    		fromRegistry := false
    		for _, ep := range v.Endpoints {
    			if ep.GetFromCidr() != "" {
    				_, nw, err := net.ParseCIDR(ep.GetFromCidr())
    				if err != nil {
    					log.Warnf("unable to parse CIDR %q for network %s", ep.GetFromCidr(), id)
    					continue
    				}
    				rangerEntry := namedRangerEntry{
    					name:    network.ID(id),
    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. analysis/analysis-api-platform-interface/src/org/jetbrains/kotlin/analysis/api/platform/utils/utils.kt

    import com.intellij.openapi.project.Project
    import com.intellij.psi.PsiElementFinder
    
    public inline fun forEachNonKotlinPsiElementFinder(project: Project, action: (PsiElementFinder) -> Unit) {
        for (finder in PsiElementFinder.EP.getPoint(project).extensionList) {
            if (finder::class.java.name == KOTLIN_JAVA_ELEMENT_FINDER_CLASS_NAME) {
                continue
            }
            action(finder)
        }
    }
    
    Registered: Wed Jun 12 09:53:16 UTC 2024
    - Last Modified: Thu Jun 06 17:44:50 UTC 2024
    - 798 bytes
    - Viewed (0)
  10. pilot/pkg/xds/eds_test.go

    	region, zone, subzone := items[0], items[1], items[2]
    	for _, ep := range eps {
    		if ep.GetLocality().Region == region {
    			if ep.GetLocality().Zone == zone {
    				if ep.GetLocality().SubZone == subzone {
    					if ep.GetPriority() != 0 {
    						t.Errorf("expected endpoint pool from same locality to have priority of 0, got %v", ep.GetPriority())
    					}
    				} else if ep.GetPriority() != 1 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 02 20:58:47 UTC 2024
    - 39.6K bytes
    - Viewed (0)
Back to top