- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 343 for clusterIPs (0.15 sec)
-
pkg/api/service/warnings_test.go
service := func(clusterIPs []string) *api.Service { svc := api.Service{ ObjectMeta: metav1.ObjectMeta{ Name: "svc-test", Namespace: "ns", }, Spec: api.ServiceSpec{ Type: api.ServiceTypeClusterIP, }, } if len(clusterIPs) > 0 { svc.Spec.ClusterIP = clusterIPs[0] svc.Spec.ClusterIPs = clusterIPs } return &svc } tests := []struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 26 22:57:57 UTC 2023 - 10.4K bytes - Viewed (0) -
pkg/registry/core/service/storage/alloc.go
// if there is no slice to work with if service.Spec.ClusterIPs == nil { service.Spec.ClusterIPs = make([]string, 0, len(service.Spec.IPFamilies)) } for i, ipFamily := range service.Spec.IPFamilies { if i > (len(service.Spec.ClusterIPs) - 1) { service.Spec.ClusterIPs = append(service.Spec.ClusterIPs, "" /* just a marker */) } toAlloc[ipFamily] = service.Spec.ClusterIPs[i] } // allocate
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:05 UTC 2023 - 37.3K bytes - Viewed (0) -
pkg/registry/core/service/storage/storage.go
return } // This was an update operation // ClusterIPs were cleared by an old client which was trying to patch // some field and didn't provide ClusterIPs if len(oldSvc.Spec.ClusterIPs) > 0 && len(newSvc.Spec.ClusterIPs) == 0 { // if ClusterIP is the same, then it is an old client trying to // patch service and didn't provide ClusterIPs if oldSvc.Spec.ClusterIP == newSvc.Spec.ClusterIP {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 13:09:33 UTC 2024 - 22.3K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repair_test.go
Spec: corev1.ServiceSpec{ ClusterIP: "192.168.1.1", ClusterIPs: []string{"192.168.1.1"}, IPFamilies: []corev1.IPFamily{corev1.IPv4Protocol}, }, }, &corev1.Service{ ObjectMeta: metav1.ObjectMeta{Namespace: "two", Name: "two"}, Spec: corev1.ServiceSpec{ ClusterIP: "192.168.1.100", ClusterIPs: []string{"192.168.1.100"}, IPFamilies: []corev1.IPFamily{corev1.IPv4Protocol},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 21.1K bytes - Viewed (0) -
pkg/proxy/util/utils_test.go
service: v1.Service{ Spec: v1.ServiceSpec{ ClusterIPs: []string{"10.0.0.10"}, IPFamilies: []v1.IPFamily{v1.IPv4Protocol}, }, }, }, { name: "service single stack ipv4. want ipv6", requestFamily: v1.IPv6Protocol, expectedResult: "", service: v1.Service{ Spec: v1.ServiceSpec{ ClusterIPs: []string{"10.0.0.10"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 20 11:57:43 UTC 2024 - 17.1K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip.go
// creating the corresponding IPAddress objects // * IPAddress objects with wrong references or labels // // Logs about: // * ClusterIPs that do not match the currently configured range // // There is a one-to-one relation between Service ClusterIPs and IPAddresses. // The bidirectional relation is achieved using the following fields: // Service.Spec.Cluster == IPAddress.Name AND IPAddress.ParentRef == Service //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repair.go
// and logs any errors, and then sets the compacted and accurate list of all allocated IPs. // // Handles: // * Duplicate ClusterIP assignments caused by operator action or undetected race conditions // * ClusterIPs that do not match the currently configured range // * Allocations to services that were not actually created due to a crash or powerloss // * Migrates old versions of Kubernetes services into the atomic ipallocator model automatically
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 13.8K bytes - Viewed (0) -
pkg/registry/core/service/strategy.go
// If the user is switching to a type that does not need a value in // clusterIP/clusterIPs (even "None" counts as a value), we might be able // to wipe some fields. if needsClusterIP(oldSvc) && !needsClusterIP(newSvc) { if sameClusterIPs(oldSvc, newSvc) { // These will be deallocated later. newSvc.Spec.ClusterIP = "" newSvc.Spec.ClusterIPs = nil } if sameIPFamilies(oldSvc, newSvc) { newSvc.Spec.IPFamilies = nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 13:09:36 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/registry/core/service/strategy_test.go
if result.Spec.ClusterIP != tc.expect.Spec.ClusterIP { t.Errorf("expected clusterIP %q, got %q", tc.expect.Spec.ClusterIP, result.Spec.ClusterIP) } if !reflect.DeepEqual(result.Spec.ClusterIPs, tc.expect.Spec.ClusterIPs) { t.Errorf("expected clusterIPs %q, got %q", tc.expect.Spec.ClusterIP, result.Spec.ClusterIP) } if !reflect.DeepEqual(result.Spec.IPFamilies, tc.expect.Spec.IPFamilies) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 32.4K bytes - Viewed (0) -
pkg/registry/core/rest/storage_core.go
return "start-service-ip-repair-controllers", func(context genericapiserver.PostStartHookContext) error { // We start both repairClusterIPs and repairNodePorts to ensure repair // loops of ClusterIPs and NodePorts. // We run both repair loops using RunUntil public interface. // However, we want to fail liveness/readiness until the first // successful repair loop, so we basically pass appropriate
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:05 UTC 2023 - 19.1K bytes - Viewed (0)