Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for onServiceDelete (0.71 sec)

  1. pkg/proxy/iptables/proxier.go

    	if proxier.serviceChanges.Update(oldService, service) && proxier.isInitialized() {
    		proxier.Sync()
    	}
    }
    
    // OnServiceDelete is called whenever deletion of an existing service
    // object is observed.
    func (proxier *Proxier) OnServiceDelete(service *v1.Service) {
    	proxier.OnServiceUpdate(service, nil)
    
    }
    
    // OnServiceSynced is called once all the initial event handlers were
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  2. pkg/proxy/ipvs/proxier_test.go

    		svc.Spec.Ports = addTestPort(svc.Spec.Ports, "somethingelse", "UDP", 1235, 5321, 0)
    	})
    
    	fp.OnServiceUpdate(services[0], oneService)
    	fp.OnServiceDelete(services[1])
    	fp.OnServiceDelete(services[2])
    	fp.OnServiceDelete(services[3])
    
    	result = fp.svcPortMap.Update(fp.serviceChanges)
    	if len(fp.svcPortMap) != 1 {
    		t.Errorf("expected service map length 1, got %v", fp.svcPortMap)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 186.8K bytes
    - Viewed (0)
  3. pkg/proxy/iptables/proxier_test.go

    		svc.Spec.Ports = addTestPort(svc.Spec.Ports, "somethingelse", "UDP", 1235, 5321, 0)
    	})
    
    	fp.OnServiceUpdate(services[0], oneService)
    	fp.OnServiceDelete(services[1])
    	fp.OnServiceDelete(services[2])
    	fp.OnServiceDelete(services[3])
    
    	result = fp.svcPortMap.Update(fp.serviceChanges)
    	if len(fp.svcPortMap) != 1 {
    		t.Errorf("expected service map length 1, got %v", fp.svcPortMap)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 249.9K bytes
    - Viewed (0)
  4. pkg/proxy/ipvs/proxier.go

    	if proxier.serviceChanges.Update(oldService, service) && proxier.isInitialized() {
    		proxier.Sync()
    	}
    }
    
    // OnServiceDelete is called whenever deletion of an existing service object is observed.
    func (proxier *Proxier) OnServiceDelete(service *v1.Service) {
    	proxier.OnServiceUpdate(service, nil)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
  5. pkg/proxy/nftables/proxier_test.go

    		svc.Spec.Ports = addTestPort(svc.Spec.Ports, "somethingelse", "UDP", 1235, 5321, 0)
    	})
    
    	fp.OnServiceUpdate(services[0], oneService)
    	fp.OnServiceDelete(services[1])
    	fp.OnServiceDelete(services[2])
    	fp.OnServiceDelete(services[3])
    
    	result = fp.svcPortMap.Update(fp.serviceChanges)
    	if len(fp.svcPortMap) != 1 {
    		t.Errorf("expected service map length 1, got %v", fp.svcPortMap)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 173.5K bytes
    - Viewed (0)
  6. pkg/controller/endpoint/endpoints_controller_test.go

    	waitForChanReceive(t, 1*time.Second, blockNextAction, "Service Add should have caused a request to be sent to the test server")
    
    	controller.serviceStore.Delete(svc)
    	controller.onServiceDelete(svc)
    	waitForChanReceive(t, 1*time.Second, blockNextAction, "Service Delete should have caused a request to be sent to the test server")
    
    	// If endpoints cache has not updated before service update is registered
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 87.7K bytes
    - Viewed (0)
Back to top