- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 75 for ep (0.04 sec)
-
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) -
cmd/endpoint-ellipses.go
func parseEndpointSet(setDriveCount uint64, args ...string) (ep endpointSet, err error) { argPatterns := make([]ellipses.ArgPattern, len(args)) for i, arg := range args { patterns, perr := ellipses.FindEllipsesPatterns(arg) if perr != nil { return endpointSet{}, config.ErrInvalidErasureEndpoints(nil).Msg(perr.Error()) } argPatterns[i] = patterns }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.7K bytes - Viewed (0) -
pilot/pkg/networking/util/util.go
for _, ep := range endpoints { clone := CloneLocalityLbEndpoint(ep) out = append(out, clone) } return out } // return a shallow copy of LocalityLbEndpoints func CloneLocalityLbEndpoint(ep *endpoint.LocalityLbEndpoints) *endpoint.LocalityLbEndpoints { clone := &endpoint.LocalityLbEndpoints{} clone.Locality = ep.Locality clone.LbEndpoints = ep.LbEndpoints
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 28.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/conversion.go
} else { targetPort = serviceEntryPort.Number } ep := workloadInstance.Endpoint.ShallowCopy() ep.ServicePortName = serviceEntryPort.Name ep.LegacyClusterPortKey = int(serviceEntryPort.Number) ep.EndpointPort = targetPort out = append(out, &model.ServiceInstance{ Endpoint: ep, Service: service, ServicePort: convertPort(serviceEntryPort), }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 16.9K bytes - Viewed (0) -
pkg/proxy/endpointslicecache.go
applied: endpointSliceDataByName{}, pending: endpointSliceDataByName{}, } } // standardEndpointInfo is the default makeEndpointFunc. func standardEndpointInfo(ep *BaseEndpointInfo, _ *ServicePortName) Endpoint { return ep } // updatePending updates a pending slice in the cache. func (cache *EndpointSliceCache) updatePending(endpointSlice *discovery.EndpointSlice, remove bool) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:07:21 UTC 2024 - 11.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go
} dbMetricsMonitorsMu.Lock() defer dbMetricsMonitorsMu.Unlock() ctx, cancel := context.WithCancel(context.Background()) for _, ep := range client.Endpoints() { if _, found := dbMetricsMonitors[ep]; found { continue } dbMetricsMonitors[ep] = struct{}{} endpoint := ep klog.V(4).Infof("Start monitoring storage db size metric for endpoint %s with polling interval %v", endpoint, interval)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 07:56:39 UTC 2024 - 15.1K bytes - Viewed (0) -
pkg/apis/core/fuzzer/fuzzer.go
ct.TerminationMessagePolicy = "File" }, func(ep *core.EphemeralContainer, c fuzz.Continue) { c.FuzzNoCustom(ep) // fuzz self without calling this function again ep.EphemeralContainerCommon.TerminationMessagePath = "/" + ep.TerminationMessagePath // Must be non-empty ep.EphemeralContainerCommon.TerminationMessagePolicy = "File" },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 04:32:01 UTC 2024 - 18.5K bytes - Viewed (0) -
pilot/pkg/xds/eds_sh_test.go
} for addr, weight := range expected.weights { var match *endpoint.LbEndpoint for _, ep := range lbEndpoints { if ep.GetEndpoint().Address.GetSocketAddress().Address == addr { match = ep break } } if match == nil { t.Fatalf("couldn't find endpoint with address %s: found %v", addr, getLbEndpointAddrs(lbEndpoints)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 10.8K bytes - Viewed (0)