- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for SyncPeriod (0.28 sec)
-
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) -
pkg/proxy/apis/config/scheme/testdata/KubeProxyConfiguration/roundtrip/default/v1alpha1.yaml
healthzBindAddress: 0.0.0.0:10256 hostnameOverride: "" iptables: localhostNodePorts: true masqueradeAll: false masqueradeBit: 14 minSyncPeriod: 1s syncPeriod: 30s ipvs: excludeCIDRs: null minSyncPeriod: 0s scheduler: "" strictARP: false syncPeriod: 30s tcpFinTimeout: 0s tcpTimeout: 0s udpTimeout: 0s kind: KubeProxyConfiguration logging: flushFrequency: 5s format: text options:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 17 12:50:03 UTC 2024 - 1.4K bytes - Viewed (0) -
pkg/proxy/apis/config/v1alpha1/defaults_test.go
MasqueradeBit: ptr.To[int32](14), MasqueradeAll: false, LocalhostNodePorts: ptr.To(true), SyncPeriod: metav1.Duration{Duration: 30 * time.Second}, MinSyncPeriod: metav1.Duration{Duration: 1 * time.Second}, }, IPVS: kubeproxyconfigv1alpha1.KubeProxyIPVSConfiguration{ SyncPeriod: metav1.Duration{Duration: 30 * time.Second}, }, NFTables: kubeproxyconfigv1alpha1.KubeProxyNFTablesConfiguration{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:33:53 UTC 2023 - 5.1K bytes - Viewed (0) -
pkg/proxy/apis/config/v1alpha1/zz_generated.conversion.go
out.MasqueradeBit = (*int32)(unsafe.Pointer(in.MasqueradeBit)) out.MasqueradeAll = in.MasqueradeAll out.LocalhostNodePorts = (*bool)(unsafe.Pointer(in.LocalhostNodePorts)) out.SyncPeriod = in.SyncPeriod out.MinSyncPeriod = in.MinSyncPeriod return nil } // Convert_v1alpha1_KubeProxyIPTablesConfiguration_To_config_KubeProxyIPTablesConfiguration is an autogenerated conversion function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:33:53 UTC 2023 - 22.3K bytes - Viewed (0) -
pkg/proxy/apis/config/scheme/testdata/KubeProxyConfiguration/after/v1alpha1.yaml
healthzBindAddress: 0.0.0.0:10256 hostnameOverride: "" iptables: localhostNodePorts: true masqueradeAll: false masqueradeBit: 14 minSyncPeriod: 1s syncPeriod: 30s ipvs: excludeCIDRs: null minSyncPeriod: 0s scheduler: "" strictARP: false syncPeriod: 30s tcpFinTimeout: 0s tcpTimeout: 0s udpTimeout: 0s kind: KubeProxyConfiguration logging: flushFrequency: 5s format: text options:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 17 12:50:03 UTC 2024 - 1.4K bytes - Viewed (0) -
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) -
pkg/proxy/winkernel/proxier_test.go
proxier.endpointsChanges = endpointsChangeTracker proxier.serviceChanges = serviceChanges return proxier } func TestCreateServiceVip(t *testing.T) { syncPeriod := 30 * time.Second proxier := NewFakeProxier(syncPeriod, syncPeriod, "testhost", netutils.ParseIPSloppy("10.0.0.1"), NETWORK_TYPE_OVERLAY) if proxier == nil { t.Error() } svcIP := "10.20.30.41" svcPort := 80 svcNodePort := 3001
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 28 14:30:51 UTC 2024 - 30.2K bytes - Viewed (0) -
pkg/proxy/apis/config/v1alpha1/defaults.go
obj.OOMScoreAdj = &temp } if obj.IPTables.SyncPeriod.Duration == 0 { obj.IPTables.SyncPeriod = metav1.Duration{Duration: 30 * time.Second} } if obj.IPTables.MinSyncPeriod.Duration == 0 { obj.IPTables.MinSyncPeriod = metav1.Duration{Duration: 1 * time.Second} } if obj.IPTables.LocalhostNodePorts == nil { obj.IPTables.LocalhostNodePorts = ptr.To(true) } if obj.IPVS.SyncPeriod.Duration == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:33:53 UTC 2023 - 5.2K bytes - Viewed (0) -
pkg/kubelet/cloudresource/cloud_request_manager_test.go
func TestNodeAddressesDelay(t *testing.T) { syncPeriod := 100 * time.Millisecond cloud := &fake.Cloud{ Addresses: createNodeInternalIPAddress("10.0.1.12"), // Set the request delay so the manager timeouts and collects the node addresses later RequestDelay: 200 * time.Millisecond, } stopCh := make(chan struct{}) defer close(stopCh) manager := NewSyncManager(cloud, "defaultNode", syncPeriod).(*cloudResourceSyncManager)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:48:03 UTC 2023 - 4.2K bytes - Viewed (0) -
pkg/kubelet/cloudresource/cloud_request_manager.go
// cloud provider through requests that are sensitive to timeouts and hanging func NewSyncManager(cloud cloudprovider.Interface, nodeName types.NodeName, syncPeriod time.Duration) SyncManager { return &cloudResourceSyncManager{ cloud: cloud, syncPeriod: syncPeriod, nodeName: nodeName, // nodeAddressesMonitor is a monitor that guards a result (nodeAddresses,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 05 18:29:23 UTC 2021 - 4.5K bytes - Viewed (0)