- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,035 for endpoints1 (0.16 sec)
-
staging/src/k8s.io/api/testdata/v1.30.0/core.v1.Endpoints.yaml
apiVersion: v1 kind: Endpoints metadata: annotations: annotationsKey: annotationsValue creationTimestamp: "2008-01-01T01:01:01Z" deletionGracePeriodSeconds: 10 deletionTimestamp: "2009-01-01T01:01:01Z" finalizers: - finalizersValue generateName: generateNameValue generation: 7 labels: labelsKey: labelsValue managedFields: - apiVersion: apiVersionValue fieldsType: fieldsTypeValue fieldsV1: {}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:52:25 UTC 2024 - 1.5K bytes - Viewed (0) -
pkg/proxy/util/endpoints.go
limitations under the License. */ package util import ( "net" "k8s.io/klog/v2" netutils "k8s.io/utils/net" ) // IPPart returns just the IP part of an IP or IP:port or endpoint string. If the IP // part is an IPv6 address enclosed in brackets (e.g. "[fd00:1::5]:9999"), // then the brackets are stripped as well. func IPPart(s string) string { if ip := netutils.ParseIPSloppy(s); ip != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 20 11:57:43 UTC 2024 - 1.3K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/metrics/cache.go
// Parameters: // * endpointsNN refers to a NamespacedName representing the Endpoints resource. // * epCache refers to a EndpointPortCache for the specified Endpoints reosource. func (c *Cache) UpdateEndpointPortCache(endpointsNN types.NamespacedName, epCache *EndpointPortCache) { c.lock.Lock() defer c.lock.Unlock() prevNumEndpoints := 0 if existingEPCache, ok := c.cache[endpointsNN]; ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 5.2K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/queue/MultiEndPointQueueTest.groovy
def endpoint1 = queue.newEndpoint() def endpoint2 = queue.newEndpoint() and: queue.empty(endpoint1) queue.empty(endpoint2) when: queue.dispatch(message) queue.dispatch(message2) def messages1 = [] endpoint1.take(messages1) def messages2 = [] endpoint2.take(messages2) then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/proxy/endpointslicecache.go
// addEndpoints adds an Endpoint for each unique endpoint. func (cache *EndpointSliceCache) addEndpoints(svcPortName *ServicePortName, portNum int, endpointSet map[string]Endpoint, endpoints []discovery.Endpoint) map[string]Endpoint { if endpointSet == nil { endpointSet = map[string]Endpoint{} } // iterate through endpoints to add them to endpointSet. for _, endpoint := range endpoints { if len(endpoint.Addresses) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:07:21 UTC 2024 - 11.7K bytes - Viewed (0) -
pkg/proxy/conntrack/cleanup.go
if svcInfo, ok := svcPortMap[epSvcPair.ServicePortName]; ok { endpointIP := proxyutil.IPPart(epSvcPair.Endpoint) nodePort := svcInfo.NodePort() var err error if nodePort != 0 { err = ct.ClearEntriesForPortNAT(endpointIP, nodePort, v1.ProtocolUDP) if err != nil { klog.ErrorS(err, "Failed to delete nodeport-related endpoint connections", "servicePortName", epSvcPair.ServicePortName) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 15 18:09:05 UTC 2024 - 5.2K bytes - Viewed (0) -
pkg/controlplane/reconcilers/instancecount.go
corev1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/client-go/util/retry" "k8s.io/klog/v2" endpointsv1 "k8s.io/kubernetes/pkg/api/v1/endpoints" ) // masterCountEndpointReconciler reconciles endpoints based on a specified expected number of // masters. masterCountEndpointReconciler implements EndpointReconciler. type masterCountEndpointReconciler struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 7.2K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/endpoint.go
plugin "k8s.io/kubernetes/pkg/kubelet/cm/devicemanager/plugin/v1beta1" ) // endpoint maps to a single registered device plugin. It is responsible // for managing gRPC communications with the device plugin and caching // device states reported by the device plugin. type endpoint interface { getPreferredAllocation(available, mustInclude []string, size int) (*pluginapi.PreferredAllocationResponse, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 02 11:05:20 UTC 2022 - 3.9K bytes - Viewed (0) -
pkg/proxy/endpointslicecache_test.go
Endpoints: []discovery.Endpoint{endpoint1, endpoint2}, }, expectChanged: false, }, "identical with endpoints out of order": { cache: NewEndpointSliceCache("", v1.IPv4Protocol, nil, nil), initialSlice: &discovery.EndpointSlice{ ObjectMeta: objMeta, Ports: []discovery.EndpointPort{port443}, Endpoints: []discovery.Endpoint{endpoint1, endpoint2}, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:07:21 UTC 2024 - 24.9K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler.go
endpointsNN := types.NamespacedName{Name: endpoints.Name, Namespace: endpoints.Namespace} r.metricsCache.UpdateEndpointPortCache(endpointsNN, epMetrics) return r.finalize(endpoints, slices) } // reconcileByPortMapping compares the endpoints found in existing slices with // the list of desired endpoints and returns lists of slices to create, update, // and delete.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 13.1K bytes - Viewed (0)