- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 169 for ep (1.13 sec)
-
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) -
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) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/dsl/dependencies/GradlePluginVariantsSupportTest.groovy
def attributes = AttributeTestUtil.attributesFactory() def objects = TestUtil.objectFactory() def schema = new DefaultAttributesSchema(TestUtil.instantiatorFactory(), SnapshotTestUtil.isolatableFactory()) def ep = Stub(AttributeMatchingExplanationBuilder) def setup() { GradlePluginVariantsSupport.configureSchema(schema) } def "Gradle #currentGradleVersion #acceptsOrRejects 7.0 api"() { given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/registry/discovery/endpointslice/strategy.go
// EndpointSlice. prevNodeNames := getDeprecatedTopologyNodeNames(oldEPS) for i := range newEPS.Endpoints { ep := &newEPS.Endpoints[i] newTopologyNodeName, ok := ep.DeprecatedTopology[corev1.LabelHostname] if ep.NodeName == nil && ok && prevNodeNames.Has(newTopologyNodeName) && len(apivalidation.ValidateNodeName(newTopologyNodeName, false)) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 02 10:00:01 UTC 2023 - 7.6K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/mtls_checker.go
GetMutualTLSModeForPort(ep.EndpointPort) != model.MTLSDisable } func tlsModeForDestinationRule(drc *config.Config, subset string, port int) *networkingapi.ClientTLSSettings_TLSmode { if drc == nil { return nil } dr, ok := drc.Spec.(*networkingapi.DestinationRule) if !ok || dr == nil { return nil } if subset == "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 01 07:32:22 UTC 2023 - 3.3K 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) -
src/vendor/golang.org/x/net/lif/address.go
} defer func() { for _, ep := range eps { ep.close() } }() lls, err := links(eps, name) if len(lls) == 0 { return nil, err } var as []Addr for _, ll := range lls { var lifr lifreq for i := 0; i < len(ll.Name); i++ { lifr.Name[i] = int8(ll.Name[i]) } for _, ep := range eps { ioc := int64(syscall.SIOCGLIFADDR) err := ioctl(ep.s, uintptr(ioc), unsafe.Pointer(&lifr))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 2.5K 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) -
tests/testdata/config/external_services.yaml
name: extsvc-http protocol: HTTP resolution: NONE --- apiVersion: networking.istio.io/v1alpha3 kind: ServiceEntry metadata: name: external-svc-ep namespace: testns spec: hosts: - ep.extsvc.com ports: - number: 8002 name: extsvc-http protocol: HTTP resolution: STATIC endpoints: - address: 127.0.0.2 ports: extsvc-http: 8080
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Jan 19 04:56:49 UTC 2019 - 1.9K bytes - Viewed (0)