- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for NewService (0.19 sec)
-
pkg/registry/core/service/ipallocator/controller/repairip_test.go
events: []string{}, }, { name: "no changes needed dual stack", svcs: []*v1.Service{newService("test-svc", []string{"10.0.1.1", "2001:db8::10"})}, ipAddresses: []*networkingv1alpha1.IPAddress{ newIPAddress("10.0.1.1", newService("test-svc", []string{"10.0.1.1"})), newIPAddress("2001:db8::10", newService("test-svc", []string{"2001:db8::10"})), }, cidrs: []*networkingv1alpha1.ServiceCIDR{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:06 UTC 2023 - 20.3K bytes - Viewed (0) -
pkg/quota/v1/install/update_filter.go
case schema.GroupResource{Resource: "services"}: oldService := oldObj.(*v1.Service) newService := newObj.(*v1.Service) return core.GetQuotaServiceType(oldService) != core.GetQuotaServiceType(newService) case schema.GroupResource{Resource: "persistentvolumeclaims"}: oldPVC := oldObj.(*v1.PersistentVolumeClaim) newPVC := newObj.(*v1.PersistentVolumeClaim)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 08 22:39:55 UTC 2022 - 1.7K bytes - Viewed (0) -
pkg/registry/core/service/strategy.go
func (svcStrategy) PrepareForUpdate(ctx context.Context, obj, old runtime.Object) { newService := obj.(*api.Service) oldService := old.(*api.Service) newService.Status = oldService.Status dropServiceDisabledFields(newService, oldService) dropTypeDependentFields(newService, oldService) } // Validate validates a new service.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 13:09:36 UTC 2024 - 14.1K bytes - Viewed (0) -
plugin/pkg/admission/resourcequota/admission_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:28:42 UTC 2024 - 84.1K bytes - Viewed (0) -
pkg/registry/core/service/strategy_test.go
}, } StatusStrategy.PrepareForUpdate(ctx, newService, oldService) if newService.Status.LoadBalancer.Ingress[0].IP != "127.0.0.2" { t.Errorf("Service status updates should allow change of status fields") } if newService.Spec.SessionAffinity != "None" { t.Errorf("PrepareForUpdate should have preserved old spec") } errs := StatusStrategy.ValidateUpdate(ctx, newService, oldService) if len(errs) != 0 {
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/service/storage/alloc.go
oldService, newService := before.Service, after.Service oldNodePortsNumbers := collectServiceNodePorts(oldService) newNodePorts := []ServiceNodePort{} portAllocated := map[int]bool{} for i := range newService.Spec.Ports { servicePort := &newService.Spec.Ports[i] if servicePort.NodePort == 0 && !shouldAllocateNodePorts(newService) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:05 UTC 2023 - 37.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
currConv: newService(visibility.None, []int{80}), expect: false, }, { name: "public visibility, spec change", prevConv: newService(visibility.Public, []int{80}), currConv: newService(visibility.Public, []int{80, 443}), expect: true, }, { name: "none visibility, spec change", prevConv: newService(visibility.None, []int{80}),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pkg/proxy/ipvs/util/ipvs_linux.go
svc, err := toIPVSService(vs) if err != nil { return fmt.Errorf("could not convert local virtual server to IPVS service: %w", err) } runner.mu.Lock() defer runner.mu.Unlock() return runner.ipvsHandle.NewService(svc) } // UpdateVirtualServer is part of ipvs.Interface. func (runner *runner) UpdateVirtualServer(vs *VirtualServer) error { svc, err := toIPVSService(vs) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 9K bytes - Viewed (0) -
pkg/registry/core/service/storage/storage_test.go
} if tc.newService.Spec.ClusterIP != tc.expectedClusterIP { t.Fatalf("expected clusterIP [%v] got [%v]", tc.expectedClusterIP, tc.newService.Spec.ClusterIP) } if len(tc.newService.Spec.ClusterIPs) != len(tc.expectedClusterIPs) { t.Fatalf("expected clusterIPs %v got %v", tc.expectedClusterIPs, tc.newService.Spec.ClusterIPs) } for idx, clusterIP := range tc.newService.Spec.ClusterIPs {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 440.2K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
prevSvcName := prevEndpointSlice.Labels[discovery.LabelServiceName] if svcName != prevSvcName { logger.Info("label changed", "label", discovery.LabelServiceName, "oldService", prevSvcName, "newService", svcName, "endpointslice", klog.KObj(endpointSlice)) c.queueServiceForEndpointSlice(endpointSlice) c.queueServiceForEndpointSlice(prevEndpointSlice) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0)