Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for syncPeriod (0.61 sec)

  1. pkg/proxy/apis/config/validation/validation_test.go

    			expectedErrs: field.ErrorList{},
    		},
    		"SyncPeriod must be > 0": {
    			config: kubeproxyconfig.KubeProxyIPTablesConfiguration{
    				MasqueradeAll: true,
    				SyncPeriod:    metav1.Duration{Duration: -5 * time.Second},
    				MinSyncPeriod: metav1.Duration{Duration: 2 * time.Second},
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  2. pkg/proxy/apis/config/validation/validation.go

    	if config.SyncPeriod.Duration <= 0 {
    		allErrs = append(allErrs, field.Invalid(fldPath.Child("SyncPeriod"), config.SyncPeriod, "must be greater than 0"))
    	}
    
    	if config.MinSyncPeriod.Duration < 0 {
    		allErrs = append(allErrs, field.Invalid(fldPath.Child("MinSyncPeriod"), config.MinSyncPeriod, "must be greater than or equal to 0"))
    	}
    
    	if config.MinSyncPeriod.Duration > config.SyncPeriod.Duration {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  3. cmd/kube-proxy/app/server_windows.go

    		proxier, err = winkernel.NewDualStackProxier(
    			config.IPTables.SyncPeriod.Duration,
    			config.IPTables.MinSyncPeriod.Duration,
    			s.Hostname,
    			s.NodeIPs,
    			s.Recorder,
    			s.HealthzServer,
    			config.HealthzBindAddress,
    			config.Winkernel,
    		)
    	} else {
    		proxier, err = winkernel.NewProxier(
    			s.PrimaryIPFamily,
    			config.IPTables.SyncPeriod.Duration,
    			config.IPTables.MinSyncPeriod.Duration,
    			s.Hostname,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  4. pkg/proxy/apis/config/types.go

    	// iptables mode and IPv4; localhost NodePorts are never allowed with other proxy
    	// modes or with IPv6.)
    	LocalhostNodePorts *bool
    	// syncPeriod is an interval (e.g. '5s', '1m', '2h22m') indicating how frequently
    	// various re-synchronizing and cleanup operations are performed. Must be greater
    	// than 0.
    	SyncPeriod metav1.Duration
    	// minSyncPeriod is the minimum period between iptables rule resyncs (e.g. '5s',
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 13K bytes
    - Viewed (0)
  5. 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
    type servicePortInfo struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  6. cmd/kube-proxy/app/server_linux.go

    			// TODO this has side effects that should only happen when Run() is invoked.
    			proxier, err = iptables.NewDualStackProxier(
    				ctx,
    				ipt,
    				utilsysctl.New(),
    				exec.New(),
    				config.IPTables.SyncPeriod.Duration,
    				config.IPTables.MinSyncPeriod.Duration,
    				config.IPTables.MasqueradeAll,
    				*config.IPTables.LocalhostNodePorts,
    				int(*config.IPTables.MasqueradeBit),
    				localDetectors,
    				s.Hostname,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 18.1K bytes
    - Viewed (0)
  7. pkg/proxy/iptables/proxier.go

    			metrics.LocalhostNodePortAcceptedNFAcctCounter:     false,
    		},
    	}
    
    	burstSyncs := 2
    	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.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  8. cmd/kube-proxy/app/server_test.go

    hostnameOverride: "foo"
    iptables:
      masqueradeAll: true
      masqueradeBit: 17
      minSyncPeriod: 10s
      syncPeriod: 60s
      localhostNodePorts: true
    ipvs:
      minSyncPeriod: 10s
      syncPeriod: 60s
      excludeCIDRs:
        - "10.20.30.40/16"
        - "fd00:1::0/64"
    nftables:
      masqueradeAll: true
      masqueradeBit: 18
      minSyncPeriod: 10s
      syncPeriod: 60s
    kind: KubeProxyConfiguration
    metricsBindAddress: "%s"
    mode: "%s"
    oomScoreAdj: 17
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 32.3K bytes
    - Viewed (0)
  9. 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
    }
    
    func filterCIDRs(wantIPv6 bool, cidrs []string) []string {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
  10. 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)
Back to top