- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 169 for ep (0.03 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)