- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 153 for ep (0.76 sec)
-
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) -
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) -
pkg/proxy/winkernel/testing/hcnutils_mock.go
for _, ep := range endpointMap { hcnEPList = append(hcnEPList, *ep) } return hcnEPList, nil } func (hcnObj HcnMock) ListEndpointsOfNetwork(networkId string) ([]hcn.HostComputeEndpoint, error) { var hcnEPList []hcn.HostComputeEndpoint for _, ep := range endpointMap { if ep.HostComputeNetwork == networkId { hcnEPList = append(hcnEPList, *ep) } } return hcnEPList, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 18 06:29:01 UTC 2023 - 6.2K bytes - Viewed (0) -
src/vendor/golang.org/x/net/lif/link.go
} defer func() { for _, ep := range eps { ep.close() } }() return links(eps, name) } func links(eps []endpoint, name string) ([]Link, error) { var lls []Link lifn := lifnum{Flags: sysLIFC_NOXMIT | sysLIFC_TEMPORARY | sysLIFC_ALLZONES | sysLIFC_UNDER_IPMP} lifc := lifconf{Flags: sysLIFC_NOXMIT | sysLIFC_TEMPORARY | sysLIFC_ALLZONES | sysLIFC_UNDER_IPMP} for _, ep := range eps { lifn.Family = uint16(ep.af)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 3.7K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier.go
serving: true, terminating: false, } ep, err := hns.createEndpoint(hnsEndpoint, network) return ep, err } func (ep *endpointInfo) DecrementRefCount() { klog.V(3).InfoS("Decrementing Endpoint RefCount", "endpointInfo", ep) if !ep.IsLocal() && ep.refCount != nil && *ep.refCount > 0 { *ep.refCount-- } } func (ep *endpointInfo) Cleanup() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K 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) -
src/os/executable_test.go
func TestExecutable(t *testing.T) { testenv.MustHaveExec(t) t.Parallel() ep, err := os.Executable() if err != nil { t.Fatalf("Executable failed: %v", err) } // we want fn to be of the form "dir/prog" dir := filepath.Dir(filepath.Dir(ep)) fn, err := filepath.Rel(dir, ep) if err != nil { t.Fatalf("filepath.Rel: %v", err) } cmd := testenv.Command(t, fn, "-test.run=^$")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 05 23:35:32 UTC 2023 - 3.4K bytes - Viewed (0) -
src/syscall/lsf_linux.go
copy(ifl.name[:], []byte(name)) _, _, ep := Syscall(SYS_IOCTL, uintptr(s), SIOCGIFFLAGS, uintptr(unsafe.Pointer(&ifl))) if ep != 0 { return Errno(ep) } if m { ifl.flags |= uint16(IFF_PROMISC) } else { ifl.flags &^= uint16(IFF_PROMISC) } _, _, ep = Syscall(SYS_IOCTL, uintptr(s), SIOCSIFFLAGS, uintptr(unsafe.Pointer(&ifl))) if ep != 0 { return Errno(ep) } return nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Aug 19 16:27:36 UTC 2022 - 2.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/feature/feature_support_checker.go
f.lock.Lock() defer f.lock.Unlock() for _, ep := range c.Endpoints() { if _, found := f.checkingEndpoint[ep]; found { continue } f.checkingEndpoint[ep] = struct{}{} go func(ep string) { defer runtime.HandleCrash() err := delayFunc.Until(ctx, true, true, func(ctx context.Context) (done bool, err error) { internalErr := f.clientSupportsRequestWatchProgress(ctx, c, ep) return internalErr == nil, nil })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 6.2K bytes - Viewed (0)