Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for OnServiceCIDRsChanged (0.73 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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