- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 1,299 for endpoints2 (0.23 sec)
-
internal/kms/kes.go
return map[string]madmin.ItemState{ c.client.Endpoints[0]: madmin.ItemOffline, }, nil } return map[string]madmin.ItemState{ c.client.Endpoints[0]: madmin.ItemOnline, }, nil } type Result struct { Endpoint string ItemState madmin.ItemState } var wg sync.WaitGroup results := make([]Result, len(c.client.Endpoints)) for i := range c.client.Endpoints { wg.Add(1) go func(i int) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 7.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/feature/feature_support_checker_test.go
) type mockEndpointVersion struct { Endpoint string Version string Error error } // MockEtcdClient is a mock implementation of the EtcdClientInterface interface. type MockEtcdClient struct { EndpointVersion []mockEndpointVersion } func (m MockEtcdClient) getEndpoints() []string { var endpoints []string for _, ev := range m.EndpointVersion { endpoints = append(endpoints, ev.Endpoint) } return endpoints }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 8.3K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier.go
// Remove only remote endpoints created by this service if *ep.refCount <= 0 && !ep.IsLocal() { klog.V(4).InfoS("Removing endpoints, since no one is referencing it", "endpoint", ep) err := ep.hns.deleteEndpoint(ep.hnsID) if err == nil { ep.hnsID = "" } else { klog.ErrorS(err, "Endpoint deletion failed", "ip", ep.IP()) } } ep.refCount = nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
guava/src/com/google/common/graph/Network.java
* order, if any, specified by {@code endpoints}). * * <p>The resulting set of edges will be parallel (i.e. have equal {@link * #incidentNodes(Object)}). If this network does not {@link #allowsParallelEdges() allow parallel * edges}, the resulting set will contain at most one edge (equivalent to {@code * edgeConnecting(endpoints).asSet()}). *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jan 22 17:29:38 UTC 2024 - 22.3K bytes - Viewed (0) -
releasenotes/notes/30705.yaml
apiVersion: release-notes/v2 kind: feature area: networking issue: - 28798 releaseNotes: - | **Fixed** When using PeerAuthentication to turn off mTLS while using multi-network, non-mtls endpoints will be
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 30 17:53:03 UTC 2021 - 290 bytes - Viewed (0) -
cluster/addons/calico-policy-controller/globalnetworkpolicy-crd.yaml
from (or terminates at) endpoints within the selected namespaces will be matched. When both NamespaceSelector and Selector are defined on the same rule, then only workload endpoints that are matched by both selectors will be selected
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 07 20:48:43 UTC 2021 - 45.2K bytes - Viewed (0) -
pilot/pkg/model/endpointshards.go
if oldIstioEndpoints == nil { // If there are no old endpoints, we should push with incoming endpoints as there is nothing to compare. needPush = true } else { newIstioEndpoints = make([]*IstioEndpoint, 0, len(istioEndpoints)) // Check if new Endpoints are ready to be pushed. This check // will ensure that if a new pod comes with a non ready endpoint, // we do not unnecessarily push that config to Envoy.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 15.6K bytes - Viewed (0) -
pkg/config/schema/kind/resources.gen.go
case DaemonSet: return "DaemonSet" case Deployment: return "Deployment" case DestinationRule: return "DestinationRule" case EndpointSlice: return "EndpointSlice" case Endpoints: return "Endpoints" case EnvoyFilter: return "EnvoyFilter" case GRPCRoute: return "GRPCRoute" case Gateway: return "Gateway" case GatewayClass: return "GatewayClass" case HTTPRoute:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 27 07:19:38 UTC 2024 - 4.9K bytes - Viewed (0) -
pkg/test/echo/server/instance.go
if s.Metrics > 0 { go s.startMetricsServer() } s.endpoints = make([]endpoint.Instance, 0) for _, p := range s.Ports { ip, err := s.getListenerIP(p) if err != nil { return err } for _, ip := range getBindAddresses(ip) { ep, err := s.newEndpoint(p, ip, "") if err != nil { return err } s.endpoints = append(s.endpoints, ep) } } if len(s.UDSServer) > 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 09 07:54:01 UTC 2023 - 7.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/proxy.go
} svcPort, err := findServicePort(svc, port) if err != nil { return nil, err } eps, err := endpoints.Endpoints(namespace).Get(svc.Name) if err != nil { return nil, err } if len(eps.Subsets) == 0 { return nil, errors.NewServiceUnavailable(fmt.Sprintf("no endpoints available for service %q", svc.Name)) } // Pick a random Subset to start searching from. ssSeed := rand.Intn(len(eps.Subsets))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 19 00:36:22 UTC 2023 - 5.6K bytes - Viewed (0)