Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for backoff (0.05 sec)

  1. internal/rest/client.go

    func (c *Client) LastError() error {
    	c.RLock()
    	defer c.RUnlock()
    	return fmt.Errorf("[%s] %w", c.lastErrTime.Format(time.RFC3339), c.lastErr)
    }
    
    // computes the exponential backoff duration according to
    // https://www.awsarchitectureblog.com/2015/03/backoff.html
    func exponentialBackoffWait(r *rand.Rand, unit, cap time.Duration) func(uint) time.Duration {
    	if unit > time.Hour {
    		// Protect against integer overflow
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  2. internal/event/target/kafka.go

    	// These settings are needed to ensure that kafka client doesn't hang on brokers
    	// refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355
    	config.Producer.Retry.Max = 2
    	config.Producer.Retry.Backoff = (1 * time.Second)
    	config.Producer.Return.Successes = true
    	config.Producer.Return.Errors = true
    	config.Producer.RequiredAcks = 1
    	config.Producer.Timeout = (5 * time.Second)
    	// Set Producer Compression
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  3. istioctl/pkg/multicluster/remote_secret.go

    	log.Infof("Waiting for data to be populated in %s", secret.Name)
    	err = backoff.Retry(
    		func() error {
    			secret, err = client.Kube().CoreV1().Secrets(secret.Namespace).Get(context.TODO(), secret.Name, metav1.GetOptions{})
    			if err != nil {
    				return err
    			}
    			ca, token, err = tokenDataFromSecret(secret)
    			return err
    		},
    		backoff.WithMaxRetries(backoff.NewConstantBackOff(tokenWaitBackoff), 5))
    	return
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  4. go.mod

    	github.com/AdaLogics/go-fuzz-headers v0.0.0-20240806141605-e8a1dd7889d6
    	github.com/Masterminds/semver/v3 v3.3.0
    	github.com/Masterminds/sprig/v3 v3.3.0
    	github.com/alecholmes/xfccparser v0.4.0
    	github.com/cenkalti/backoff/v4 v4.3.0
    	github.com/cespare/xxhash/v2 v2.3.0
    	github.com/cheggaaa/pb/v3 v3.1.5
    	github.com/cncf/xds/go v0.0.0-20240905190251-b4127c9b8d78
    	github.com/containernetworking/cni v1.2.3
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 06 06:23:25 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  5. internal/logger/target/kafka/kafka.go

    	// These settings are needed to ensure that kafka client doesn't hang on brokers
    	// refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355
    	sconfig.Producer.Retry.Max = 2
    	sconfig.Producer.Retry.Backoff = (10 * time.Second)
    	sconfig.Producer.Return.Successes = true
    	sconfig.Producer.Return.Errors = true
    	sconfig.Producer.RequiredAcks = 1
    	sconfig.Producer.Timeout = (10 * time.Second)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  6. go.sum

    github.com/blang/semver/v4 v4.0.0 h1:1PFHFE6yCCTv8C1TeyNNarDzntLi7wMI5i/pzqYIsAM=
    github.com/blang/semver/v4 v4.0.0/go.mod h1:IbckMUScFkM3pff0VJDNKRiT6TG/YpiHIM2yvyW5YoQ=
    github.com/cenkalti/backoff/v4 v4.3.0 h1:MyRJ/UdXutAwSAT+s3wNd7MfTIcy71VQueUuFK343L8=
    github.com/cenkalti/backoff/v4 v4.3.0/go.mod h1:Y3VNntkOUPxTVeUxJ/G5vcM//AlwfmyYozVcomhLiZE=
    github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU=
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 06 06:23:25 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  7. go.mod

    	github.com/josharian/intern v1.0.0 // indirect
    	github.com/juju/ratelimit v1.0.2 // indirect
    	github.com/kr/fs v0.1.0 // indirect
    	github.com/kylelemons/godebug v1.1.0 // indirect
    	github.com/lestrrat-go/backoff/v2 v2.0.8 // indirect
    	github.com/lestrrat-go/blackmagic v1.0.2 // indirect
    	github.com/lestrrat-go/httpcc v1.0.1 // indirect
    	github.com/lestrrat-go/iter v1.0.2 // indirect
    	github.com/lestrrat-go/jwx v1.2.30 // indirect
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.32.md

    - github.com/klauspost/compress: [v1.17.0](https://github.com/klauspost/compress/tree/v1.17.0)
    - github.com/lestrrat-go/backoff/v2: [v2.0.8](https://github.com/lestrrat-go/backoff/tree/v2.0.8)
    - github.com/lestrrat-go/blackmagic: [v1.0.2](https://github.com/lestrrat-go/blackmagic/tree/v1.0.2)
    - github.com/lestrrat-go/httpcc: [v1.0.1](https://github.com/lestrrat-go/httpcc/tree/v1.0.1)
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Tue Oct 29 20:17:52 UTC 2024
    - 121.6K bytes
    - Viewed (0)
  9. CHANGELOG/CHANGELOG-1.28.md

    Also, Job controller's constants for default backoff and maximal backoff are lowered down to 1s (from 10s) and 1min (from 6min), respectively. These constants are used to determine the backoff delay for the next Job controller sync in case of a request failure. ([#118615](https://github.com/kubernetes/kubernetes/pull/118615), [@mimowo](https://github.com/mimowo)) [SIG...
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Wed Oct 23 04:34:59 UTC 2024
    - 456.9K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.27.md

    - Fix computing backoff delay when using Job pod failure policy, by including in the backoff delay calculation pod failures ignored from the backoffLimit counter.
      
      Also, compute the backoff delay more accurately for deleted pods. ([#119466](https://github.com/kubernetes/kubernetes/pull/119466), [@mimowo](https://github.com/mimowo)) [SIG Apps]
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Wed Jul 17 07:48:22 UTC 2024
    - 466.3K bytes
    - Viewed (0)
Back to top