Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 133 for ep (0.02 sec)

  1. pkg/proxy/topology.go

    	for _, ep := range clusterEndpoints {
    		endpointsMap[ep.String()] = ep
    	}
    	for _, ep := range localEndpoints {
    		endpointsMap[ep.String()] = ep
    	}
    	allReachableEndpoints = make([]Endpoint, 0, len(endpointsMap))
    	for _, ep := range endpointsMap {
    		allReachableEndpoints = append(allReachableEndpoints, ep)
    	}
    
    	return
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 06:46:03 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  2. src/os/executable_darwin.go

    func executable() (string, error) {
    	ep := executablePath
    	if len(ep) == 0 {
    		return ep, errors.New("cannot find executable path")
    	}
    	if ep[0] != '/' {
    		if initCwdErr != nil {
    			return ep, initCwdErr
    		}
    		if len(ep) > 2 && ep[0:2] == "./" {
    			// skip "./"
    			ep = ep[2:]
    		}
    		ep = initCwd + "/" + ep
    	}
    	return ep, nil
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 19:57:43 UTC 2024
    - 675 bytes
    - Viewed (0)
  3. pilot/test/xdstest/endpoints.go

    		return addrI < addrJ
    	})
    
    	for i, ep := range got {
    		if len(ep.LbEndpoints) != len(want[i].LbEps) {
    			return fmt.Errorf("unexpected number of LB endpoints within endpoint %d: %v, want %v",
    				i, getLbEndpointAddrs(ep), want[i].GetAddrs())
    		}
    
    		if ep.LoadBalancingWeight.GetValue() != want[i].Weight {
    			return fmt.Errorf("unexpected weight for endpoint %d: got %v, want %v", i, ep.LoadBalancingWeight.GetValue(), want[i].Weight)
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 01:17:58 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/envoy/configdump/endpoint.go

    		return false
    	}
    	status := retrieveEndpointStatus(ep)
    	if e.Status != "" && !strings.EqualFold(core.HealthStatus_name[int32(status)], e.Status) {
    		return false
    	}
    	return true
    }
    
    func retrieveEndpointStatus(ep *endpoint.LbEndpoint) core.HealthStatus {
    	return ep.GetHealthStatus()
    }
    
    func retrieveEndpointPort(ep *endpoint.LbEndpoint) uint32 {
    	return ep.GetEndpoint().GetAddress().GetSocketAddress().GetPortValue()
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 21 17:42:54 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. pilot/pkg/serviceregistry/kube/controller/serviceexportcache_test.go

    	ep := ec.getEndpoint(endpoints)
    	if ep == nil {
    		return fmt.Errorf("expected an endpoint, found none")
    	}
    	return ec.checkEndpoint(exported, ep)
    }
    
    func (ec *serviceExportCacheImpl) checkEndpoint(exported bool, ep *model.IstioEndpoint) error {
    	// Should always be discoverable from the same cluster.
    	if err := ec.checkDiscoverableFromSameCluster(ep); err != nil {
    		return err
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Aug 14 18:50:38 UTC 2023
    - 9.1K bytes
    - Viewed (0)
  8. 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)
  9. pilot/pkg/xds/endpoints/ep_filters.go

    	}
    	return gws
    }
    
    func (b *EndpointBuilder) scaleEndpointLBWeight(ep *endpoint.LbEndpoint, scaleFactor uint32) uint32 {
    	if ep.GetLoadBalancingWeight() == nil || ep.GetLoadBalancingWeight().Value == 0 {
    		return scaleFactor
    	}
    	weight := uint32(math.MaxUint32)
    	if ep.GetLoadBalancingWeight().Value < math.MaxUint32/scaleFactor {
    		weight = ep.GetLoadBalancingWeight().Value * scaleFactor
    	}
    	return weight
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 01:17:58 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  10. 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)
Back to top