Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for OnServiceCIDRsChanged (0.31 sec)

  1. pkg/proxy/metaproxier/meta_proxier.go

    	proxier.ipv6Proxier.OnNodeSynced()
    }
    
    // OnServiceCIDRsChanged is called whenever a change is observed
    // in any of the ServiceCIDRs, and provides complete list of service cidrs.
    func (proxier *metaProxier) OnServiceCIDRsChanged(cidrs []string) {
    	proxier.ipv4Proxier.OnServiceCIDRsChanged(cidrs)
    	proxier.ipv6Proxier.OnServiceCIDRsChanged(cidrs)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 21 14:28:37 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  2. pkg/proxy/config/config.go

    // notifications about ServiceCIDR object changes.
    type ServiceCIDRHandler interface {
    	// OnServiceCIDRsChanged is called whenever a change is observed
    	// in any of the ServiceCIDRs, and provides complete list of service cidrs.
    	OnServiceCIDRsChanged(cidrs []string)
    }
    
    // ServiceCIDRConfig tracks a set of service configurations.
    type ServiceCIDRConfig struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  3. pkg/proxy/kubemark/hollow_proxy.go

    func (*FakeProxier) OnEndpointSliceDelete(slice *discoveryv1.EndpointSlice)           {}
    func (*FakeProxier) OnEndpointSlicesSynced()                                          {}
    func (*FakeProxier) OnServiceCIDRsChanged(_ []string)                                 {}
    
    func NewHollowProxy(
    	nodeName string,
    	client clientset.Interface,
    	eventClient v1core.EventsGetter,
    	broadcaster events.EventBroadcaster,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  4. pkg/proxy/nftables/proxier.go

    // called and the state is fully propagated to local cache.
    func (proxier *Proxier) OnNodeSynced() {
    }
    
    // OnServiceCIDRsChanged is called whenever a change is observed
    // in any of the ServiceCIDRs, and provides complete list of service cidrs.
    func (proxier *Proxier) OnServiceCIDRsChanged(cidrs []string) {
    	proxier.mu.Lock()
    	defer proxier.mu.Unlock()
    
    	cidrsForProxier := make([]string, 0)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  5. pkg/proxy/winkernel/proxier.go

    	proxier.mu.Unlock()
    
    	// Sync unconditionally - this is called once per lifetime.
    	proxier.syncProxyRules()
    }
    
    // OnServiceCIDRsChanged is called whenever a change is observed
    // in any of the ServiceCIDRs, and provides complete list of service cidrs.
    func (proxier *Proxier) OnServiceCIDRsChanged(_ []string) {}
    
    func (proxier *Proxier) cleanupAllPolicies() {
    	for svcName, svc := range proxier.svcPortMap {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  6. pkg/proxy/iptables/proxier.go

    // called and the state is fully propagated to local cache.
    func (proxier *Proxier) OnNodeSynced() {
    }
    
    // OnServiceCIDRsChanged is called whenever a change is observed
    // in any of the ServiceCIDRs, and provides complete list of service cidrs.
    func (proxier *Proxier) OnServiceCIDRsChanged(_ []string) {}
    
    // portProtoHash takes the ServicePortName and protocol for a service
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  7. pkg/proxy/nftables/proxier_test.go

    func TestProxier_OnServiceCIDRsChanged(t *testing.T) {
    	var proxier *Proxier
    
    	proxier = &Proxier{ipFamily: v1.IPv4Protocol}
    	proxier.OnServiceCIDRsChanged([]string{"172.30.0.0/16", "fd00:10:96::/112"})
    	assert.Equal(t, proxier.serviceCIDRs, "172.30.0.0/16")
    
    	proxier.OnServiceCIDRsChanged([]string{"172.30.0.0/16", "172.50.0.0/16", "fd00:10:96::/112", "fd00:172:30::/112"})
    	assert.Equal(t, proxier.serviceCIDRs, "172.30.0.0/16,172.50.0.0/16")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 173.5K bytes
    - Viewed (0)
  8. pkg/proxy/ipvs/proxier.go

    // called and the state is fully propagated to local cache.
    func (proxier *Proxier) OnNodeSynced() {
    }
    
    // OnServiceCIDRsChanged is called whenever a change is observed
    // in any of the ServiceCIDRs, and provides complete list of service cidrs.
    func (proxier *Proxier) OnServiceCIDRsChanged(_ []string) {}
    
    // This is where all of the ipvs calls happen.
    func (proxier *Proxier) syncProxyRules() {
    	proxier.mu.Lock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
Back to top