- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 1,299 for endpoints2 (0.17 sec)
-
guava/src/com/google/common/graph/MutableGraph.java
/** * Adds an edge connecting {@code endpoints} (in the order, if any, specified by {@code * endpoints}) if one is not already present. * * <p>If this graph is directed, {@code endpoints} must be ordered and the added edge will be * directed; if it is undirected, the added edge will be undirected. * * <p>If this graph is directed, {@code endpoints} must be ordered. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 26 17:43:39 UTC 2021 - 3.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice.go
if svc != nil { fep := esc.c.collectWorkloadInstanceEndpoints(svc) endpoints = append(endpoints, fep...) } else { log.Debugf("Handle EDS endpoint: skip collecting workload entry endpoints, service %s/ has not been populated", hostname) } } esc.c.opts.XDSUpdater.EDSUpdate(shard, string(hostname), namespace, endpoints) } } // getPod fetches a pod by name or IP address.
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/registry/core/endpoint/strategy.go
} // AllowCreateOnUpdate is true for endpoints. func (endpointsStrategy) AllowCreateOnUpdate() bool { return true } // ValidateUpdate is the default update validation for an end user. func (endpointsStrategy) ValidateUpdate(ctx context.Context, obj, old runtime.Object) field.ErrorList { return validation.ValidateEndpointsUpdate(obj.(*api.Endpoints), old.(*api.Endpoints)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 18 14:42:36 UTC 2021 - 2.7K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/ep_filters_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 01:17:58 UTC 2024 - 26.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice_test.go
} // Create an endpoint that indicates it's an MCS endpoint for the service. svc1Ips := []string{"128.0.0.1"} portNames := []string{"tcp-port"} createEndpoints(t, controller, svcName, ns, portNames, svc1Ips, nil, map[string]string{ mcs.LabelServiceName: svcName, }) fx.AssertEmpty(t, time.Millisecond*50) // Ensure that no endpoint is create endpoints := GetEndpoints(svc, controller.Endpoints)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 4.5K bytes - Viewed (0) -
pkg/proxy/endpointschangetracker.go
} if deleted { klog.V(4).InfoS("Deleted endpoint may have stale conntrack entries", "portName", svcPortName, "endpoint", ep) *deletedUDPEndpoints = append(*deletedUDPEndpoints, ServiceEndpoint{Endpoint: ep.String(), ServicePortName: svcPortName}) } } } // Detect services that have gone from 0 to non-0 ready endpoints. If there were // previously 0 endpoints, but someone tried to connect to it, then a conntrack
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 13.2K bytes - Viewed (0) -
android/guava/src/com/google/common/graph/AbstractBaseGraph.java
public boolean hasEdgeConnecting(EndpointPair<N> endpoints) { checkNotNull(endpoints); if (!isOrderingCompatible(endpoints)) { return false; } N nodeU = endpoints.nodeU(); N nodeV = endpoints.nodeV(); return nodes().contains(nodeU) && successors(nodeU).contains(nodeV); } /** * Throws {@code IllegalArgumentException} if the ordering of {@code endpoints} is not compatible
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jan 22 17:29:38 UTC 2024 - 7.2K bytes - Viewed (0) -
guava/src/com/google/common/graph/ForwardingNetwork.java
public Set<E> edgesConnecting(EndpointPair<N> endpoints) { return delegate().edgesConnecting(endpoints); } @Override public Optional<E> edgeConnecting(N nodeU, N nodeV) { return delegate().edgeConnecting(nodeU, nodeV); } @Override public Optional<E> edgeConnecting(EndpointPair<N> endpoints) { return delegate().edgeConnecting(endpoints); } @Override @CheckForNull
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 26 17:43:39 UTC 2021 - 3.7K bytes - Viewed (0) -
guava/src/com/google/common/graph/AbstractBaseGraph.java
public boolean hasEdgeConnecting(EndpointPair<N> endpoints) { checkNotNull(endpoints); if (!isOrderingCompatible(endpoints)) { return false; } N nodeU = endpoints.nodeU(); N nodeV = endpoints.nodeV(); return nodes().contains(nodeU) && successors(nodeU).contains(nodeV); } /** * Throws {@code IllegalArgumentException} if the ordering of {@code endpoints} is not compatible
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jan 22 17:29:38 UTC 2024 - 7.2K bytes - Viewed (0) -
pkg/controlplane/reconcilers/helpers_test.go
} func makeEndpoints(name string, ips []string, ports []corev1.EndpointPort) *corev1.Endpoints { endpoints := &corev1.Endpoints{ ObjectMeta: metav1.ObjectMeta{ Namespace: metav1.NamespaceDefault, Name: name, Labels: map[string]string{ discoveryv1.LabelSkipMirror: "true", }, }, } if len(ips) > 0 || len(ports) > 0 { endpoints.Subsets = []corev1.EndpointSubset{{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 27 12:46:23 UTC 2022 - 4K bytes - Viewed (0)