Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for MinSyncPeriod (0.17 sec)

  1. pkg/proxy/nftables/proxier.go

    		logger:              logger,
    	}
    
    	burstSyncs := 2
    	logger.V(2).Info("NFTables sync params", "minSyncPeriod", minSyncPeriod, "syncPeriod", syncPeriod, "burstSyncs", burstSyncs)
    	proxier.syncRunner = async.NewBoundedFrequencyRunner("sync-runner", proxier.syncProxyRules, minSyncPeriod, syncPeriod, burstSyncs)
    
    	return proxier, nil
    }
    
    // internal struct for string service information
    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/ipvs/proxier.go

    	}
    	burstSyncs := 2
    	logger.V(2).Info("ipvs sync params", "minSyncPeriod", minSyncPeriod, "syncPeriod", syncPeriod, "burstSyncs", burstSyncs)
    	proxier.syncRunner = async.NewBoundedFrequencyRunner("sync-runner", proxier.syncProxyRules, minSyncPeriod, syncPeriod, burstSyncs)
    	proxier.gracefuldeleteManager.Run()
    	return proxier, 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)
  3. pkg/proxy/winkernel/proxier.go

    	burstSyncs := 2
    	klog.V(3).InfoS("Record sync param", "minSyncPeriod", minSyncPeriod, "syncPeriod", syncPeriod, "burstSyncs", burstSyncs)
    	proxier.syncRunner = async.NewBoundedFrequencyRunner("sync-runner", proxier.syncProxyRules, minSyncPeriod, syncPeriod, burstSyncs)
    	return proxier, nil
    }
    
    func NewDualStackProxier(
    	syncPeriod time.Duration,
    	minSyncPeriod time.Duration,
    	hostname string,
    	nodeIPs map[v1.IPFamily]net.IP,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  4. pkg/proxy/iptables/proxier.go

    	logger.V(2).Info("Iptables sync params", "minSyncPeriod", minSyncPeriod, "syncPeriod", syncPeriod, "burstSyncs", burstSyncs)
    	// We pass syncPeriod to ipt.Monitor, which will call us only if it needs to.
    	// We need to pass *some* maxInterval to NewBoundedFrequencyRunner anyway though.
    	// time.Hour is arbitrary.
    	proxier.syncRunner = async.NewBoundedFrequencyRunner("sync-runner", proxier.syncProxyRules, minSyncPeriod, time.Hour, burstSyncs)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
Back to top