Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for NewService (0.23 sec)

  1. 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)
  2. 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)
  3. 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)
  4. plugin/pkg/admission/resourcequota/admission_test.go

    	}
    	newService := &api.Service{
    		ObjectMeta: metav1.ObjectMeta{Name: "service", Namespace: "test"},
    		Spec:       api.ServiceSpec{Type: api.ServiceTypeLoadBalancer},
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 84.1K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top