- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 110 for ep (0.05 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) -
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) -
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) -
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) -
cmd/admin-heal-ops.go
} func (ahs *allHealState) popHealLocalDisks(healLocalDisks ...Endpoint) { ahs.Lock() defer ahs.Unlock() for _, ep := range healLocalDisks { delete(ahs.healLocalDisks, ep) } for id, disk := range ahs.healStatus { for _, ep := range healLocalDisks { if disk.Endpoint == ep.String() { delete(ahs.healStatus, id) } } } } // updateHealStatus will update the heal status.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 09 18:04:41 UTC 2024 - 25.1K bytes - Viewed (0) -
src/runtime/cgocall.go
case abi.Slice: // Check the slice rather than the pointer. ep = aep t = ep._type case abi.Array: // Check the array rather than the pointer. // Pass top as false since we have a pointer // to the array. ep = aep t = ep._type top = false default: throw("can't happen") } } cgoCheckArg(t, ep.data, t.Kind_&abi.KindDirectIface == 0, top, cgoCheckPointerFail) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:47 UTC 2024 - 24.2K bytes - Viewed (0)