- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 75 for ep (0.03 sec)
-
pkg/proxy/winkernel/hns.go
// TODO: Store by IP only and remove any lookups by endpoint ID. endpointInfos[ep.Id] = &endpointInfo{ ip: ep.IpConfigurations[0].IpAddress, isLocal: uint32(ep.Flags&hcn.EndpointFlagsRemoteEndpoint) == 0, macAddress: ep.MacAddress, hnsID: ep.Id, hns: hns, // only ready and not terminating endpoints were added to HNS ready: true,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 09 21:21:12 UTC 2023 - 15K bytes - Viewed (0) -
cmd/endpoint.go
*url.URL IsLocal bool PoolIdx, SetIdx, DiskIdx int } // Equal returns true if endpoint == ep func (endpoint Endpoint) Equal(ep Endpoint) bool { if endpoint.IsLocal == ep.IsLocal && endpoint.PoolIdx == ep.PoolIdx && endpoint.SetIdx == ep.SetIdx && endpoint.DiskIdx == ep.DiskIdx { if endpoint.Path == ep.Path && endpoint.Host == ep.Host { return true } } return false } func (endpoint Endpoint) String() string {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 34.1K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/endpoint_builder.go
// 2. ep.Address can be uds when EndpointPort = 0 if ep.Address != "" && ep.EndpointPort != 0 && !netutil.IsValidIPAddress(ep.Address) { return false } // filter out endpoints that don't match the subset if !b.subsetLabels.SubsetOf(ep.Labels) { return false } return true }) localityLbEndpoints := b.generate(svcEps)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 02:18:19 UTC 2024 - 26.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice.go
} return err.ErrorOrNil() } func (esc *endpointSliceController) onEvent(_, ep *v1.EndpointSlice, event model.Event) error { esc.onEventInternal(nil, ep, event) return nil } func (esc *endpointSliceController) onEventInternal(_, ep *v1.EndpointSlice, event model.Event) { esLabels := ep.GetLabels() if !endpointSliceSelector.Matches(klabels.Set(esLabels)) { return }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 16.9K bytes - Viewed (0) -
pilot/pkg/model/endpointshards.go
for _, v := range es.Shards { for _, ep := range v { // use the port name as the key, unless LegacyClusterPortKey is set and takes precedence // In EDS we match on port *name*. But for historical reasons, we match on port number for CDS. var portNum int if ep.LegacyClusterPortKey != 0 { if !ports.Contains(ep.LegacyClusterPortKey) { continue } portNum = ep.LegacyClusterPortKey } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 15.6K bytes - Viewed (0) -
pilot/pkg/model/service.go
ep.Locality == other.Locality && ep.EndpointPort == other.EndpointPort && ep.LbWeight == other.LbWeight && ep.TLSMode == other.TLSMode && ep.Namespace == other.Namespace && ep.WorkloadName == other.WorkloadName && ep.HostName == other.HostName && ep.SubDomain == other.SubDomain && ep.HealthStatus == other.HealthStatus && ep.NodeName == other.NodeName if !eq { return false }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 46.3K bytes - Viewed (0) -
pilot/pkg/networking/core/loadbalancer/loadbalancer.go
// index -> original weight destLocMap := map[int]uint32{} totalWeight := uint32(0) for i, ep := range loadAssignment.Endpoints { if misMatched.Contains(i) { if util.LocalityMatch(ep.Locality, locality) { delete(misMatched, i) if ep.LoadBalancingWeight != nil { destLocMap[i] = ep.LoadBalancingWeight.Value } else { destLocMap[i] = 1 }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 23 05:38:57 UTC 2024 - 11.8K bytes - Viewed (0) -
pkg/proxy/endpointschangetracker.go
if svcPortName.Protocol != v1.ProtocolUDP { continue } epServing := 0 for _, ep := range epList { if ep.IsServing() { epServing++ } } oldEpServing := 0 for _, ep := range oldEndpointsMap[svcPortName] { if ep.IsServing() { oldEpServing++ } } if epServing > 0 && oldEpServing == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 13.2K bytes - Viewed (0) -
cmd/bucket-targets.go
h.Online = false sys.hc[ep.Host] = h } } func (sys *BucketTargetSys) initHC(ep *url.URL) { sys.hMutex.Lock() sys.hc[ep.Host] = epHealth{ Endpoint: ep.Host, Scheme: ep.Scheme, Online: true, } sys.hMutex.Unlock() } // newHCClient initializes an anonymous client for performing health check on the remote endpoints func newHCClient() *madmin.AnonymousClient {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 01 01:09:56 UTC 2024 - 20.9K bytes - Viewed (0) -
src/runtime/chan.go
// ep may be nil, in which case received data is ignored. // If block == false and no elements are available, returns (false, false). // Otherwise, if c is closed, zeros *ep and returns (true, false). // Otherwise, fills in *ep with an element and returns (true, true). // A non-nil ep must point to the heap or the caller's stack.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0)