Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 226 for Backoff (0.12 sec)

  1. pkg/controller/volume/persistentvolume/framework_test.go

    func (r *volumeReactor) waitTest(test controllerTest) error {
    	// start with 10 ms, multiply by 2 each step, 10 steps = 10.23 seconds
    	backoff := wait.Backoff{
    		Duration: 10 * time.Millisecond,
    		Jitter:   0,
    		Factor:   2,
    		Steps:    10,
    	}
    	err := wait.ExponentialBackoff(backoff, func() (done bool, err error) {
    		// Finish all operations that are in progress
    		r.ctrl.runningOperations.WaitForCompletion()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 09:54:00 UTC 2023
    - 38.3K bytes
    - Viewed (0)
  2. pkg/controller/daemon/daemon_controller_test.go

    				t.Errorf("Backoff delay didn't last the whole waitout period.")
    			}
    
    			// Move to the backoff end time
    			fakeClock.Sleep(1 * time.Nanosecond)
    			if manager.failedPodsBackoff.IsInBackOffSinceUpdate(backoffKey, fakeClock.Now()) {
    				t.Fatal("Backoff delay hasn't been reset after the period has passed.")
    			}
    
    			// After backoff time, it will delete the failed pod
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.4K bytes
    - Viewed (0)
  3. pkg/controller/daemon/daemon_controller.go

    				// We need to avoid hot looping and backoff.
    				backoffKey := failedPodsBackoffKey(ds, node.Name)
    
    				now := dsc.failedPodsBackoff.Clock.Now()
    				inBackoff := dsc.failedPodsBackoff.IsInBackOffSinceUpdate(backoffKey, now)
    				if inBackoff {
    					delay := dsc.failedPodsBackoff.Get(backoffKey)
    					logger.V(4).Info("Deleting failed pod on node has been limited by backoff",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  4. pkg/controller/volume/attachdetach/reconciler/reconciler.go

    					logger.V(10).Info("Operation for volume is already running or still in exponential backoff for node. Can't start detach", "node", klog.KRef("", string(attachedVolume.NodeName)), "volumeName", attachedVolume.VolumeName)
    					continue
    				}
    			} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 22 21:02:38 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  5. pkg/controller/namespace/namespace_controller.go

    	namespaceController.listerSynced = namespaceInformer.Informer().HasSynced
    
    	return namespaceController
    }
    
    // nsControllerRateLimiter is tuned for a faster than normal recycle time with default backoff speed and default overall
    // requeing speed.  We do this so that namespace cleanup is reliably faster and we know that the number of namespaces being
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/go.mod

    	github.com/asaskevich/govalidator v0.0.0-20190424111038-f61b66f89f4a // indirect
    	github.com/beorn7/perks v1.0.1 // indirect
    	github.com/blang/semver/v4 v4.0.0 // indirect
    	github.com/cenkalti/backoff/v4 v4.2.1 // indirect
    	github.com/cespare/xxhash/v2 v2.2.0 // indirect
    	github.com/coreos/go-semver v0.3.1 // indirect
    	github.com/coreos/go-systemd/v22 v22.5.0 // indirect
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 21:47:11 UTC 2024
    - 6K bytes
    - Viewed (0)
  7. src/syscall/ztypes_linux_ppc64le.go

    }
    
    type Ucred struct {
    	Pid int32
    	Uid uint32
    	Gid uint32
    }
    
    type TCPInfo struct {
    	State          uint8
    	Ca_state       uint8
    	Retransmits    uint8
    	Probes         uint8
    	Backoff        uint8
    	Options        uint8
    	Pad_cgo_0      [2]byte
    	Rto            uint32
    	Ato            uint32
    	Snd_mss        uint32
    	Rcv_mss        uint32
    	Unacked        uint32
    	Sacked         uint32
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Nov 08 17:55:49 UTC 2023
    - 10.4K bytes
    - Viewed (0)
  8. pkg/kube/controllers/example_test.go

    		fmt.Println("pod has IP", pod.Status.PodIP) // Just for our test, normally use log.Info
    		log.Infof("pod has IP %v", pod.Status.PodIP)
    	}
    	// We never have an error for this controller.
    	// If we did, it would be retried (with backoff), based on our controllers.WithMaxAttempts argument.
    	return nil
    }
    
    // Run is called after New() but before HasSynced(). This separation allows building up the controllers
    // without yet running them.
    // Run should block.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 7K bytes
    - Viewed (0)
  9. src/syscall/ztypes_linux_loong64.go

    }
    
    type Ucred struct {
    	Pid int32
    	Uid uint32
    	Gid uint32
    }
    
    type TCPInfo struct {
    	State          uint8
    	Ca_state       uint8
    	Retransmits    uint8
    	Probes         uint8
    	Backoff        uint8
    	Options        uint8
    	Rto            uint32
    	Ato            uint32
    	Snd_mss        uint32
    	Rcv_mss        uint32
    	Unacked        uint32
    	Sacked         uint32
    	Lost           uint32
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 26 20:15:45 UTC 2022
    - 10.8K bytes
    - Viewed (0)
  10. src/syscall/ztypes_linux_mips64le.go

    }
    
    type Ucred struct {
    	Pid int32
    	Uid uint32
    	Gid uint32
    }
    
    type TCPInfo struct {
    	State          uint8
    	Ca_state       uint8
    	Retransmits    uint8
    	Probes         uint8
    	Backoff        uint8
    	Options        uint8
    	Pad_cgo_0      [2]byte
    	Rto            uint32
    	Ato            uint32
    	Snd_mss        uint32
    	Rcv_mss        uint32
    	Unacked        uint32
    	Sacked         uint32
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Nov 08 17:55:49 UTC 2023
    - 10.1K bytes
    - Viewed (0)
Back to top