Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for retry_interval (0.2 sec)

  1. internal/logger/config.go

    			return cfg, fmt.Errorf("invalid %s max_retry", maxRetryCfgVal)
    		}
    		retryIntervalCfgVal := getCfgVal(EnvLoggerWebhookRetryInterval, k, kv.Get(RetryInterval))
    		retryInterval, err := time.ParseDuration(retryIntervalCfgVal)
    		if err != nil {
    			return cfg, err
    		}
    		if retryInterval > time.Minute {
    			return cfg, fmt.Errorf("maximum allowed value for retry interval is '1m': %s", retryIntervalCfgVal)
    		}
    		cfg.HTTP[k] = http.Config{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 20 16:02:50 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  2. cmd/dynamic-timeouts.go

    	mutex         sync.Mutex
    	retryInterval time.Duration
    }
    
    type dynamicTimeoutOpts struct {
    	timeout       time.Duration
    	minimum       time.Duration
    	retryInterval time.Duration
    }
    
    func newDynamicTimeoutWithOpts(opts dynamicTimeoutOpts) *dynamicTimeout {
    	dt := newDynamicTimeout(opts.timeout, opts.minimum)
    	dt.retryInterval = opts.retryInterval
    	return dt
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Aug 19 23:21:05 UTC 2022
    - 4.5K bytes
    - Viewed (0)
  3. cmd/namespace-lock.go

    	start := UTCNow()
    
    	newCtx, cancel := context.WithCancel(ctx)
    	if !di.rwMutex.GetLock(newCtx, cancel, di.opsID, lockSource, dsync.Options{
    		Timeout:       timeout.Timeout(),
    		RetryInterval: timeout.RetryInterval(),
    	}) {
    		timeout.LogFailure()
    		defer cancel()
    		if err := newCtx.Err(); err == context.Canceled {
    			return LockContext{ctx: ctx, cancel: func() {}}, err
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  4. internal/store/store.go

    package store
    
    import (
    	"context"
    	"errors"
    	"fmt"
    	"strconv"
    	"strings"
    	"time"
    
    	xioutil "github.com/minio/minio/internal/ioutil"
    )
    
    const (
    	retryInterval = 3 * time.Second
    )
    
    type logger = func(ctx context.Context, err error, id string, errKind ...interface{})
    
    // ErrNotConnected - indicates that the target connection is not active.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  5. cmd/shared-lock.go

    package cmd
    
    import (
    	"context"
    	"time"
    )
    
    var sharedLockTimeout = newDynamicTimeoutWithOpts(dynamicTimeoutOpts{
    	timeout:       30 * time.Second,
    	minimum:       10 * time.Second,
    	retryInterval: time.Minute,
    })
    
    type sharedLock struct {
    	lockContext chan LockContext
    }
    
    func (ld sharedLock) backgroundRoutine(ctx context.Context, objAPI ObjectLayer, lockName string) {
    	for {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Feb 13 09:26:38 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  6. internal/logger/help.go

    		config.HelpKV{
    			Key:         MaxRetry,
    			Description: `maximum retry count before we start dropping logged event(s)`,
    			Optional:    true,
    			Type:        "number",
    		},
    		config.HelpKV{
    			Key:         RetryInterval,
    			Description: `sleep between each retries, allowed maximum value is '1m' e.g. '10s'`,
    			Optional:    true,
    			Type:        "duration",
    		},
    		config.HelpKV{
    			Key:         httpTimeout,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  7. internal/dsync/drwmutex.go

    				dm.startContinuousLockRefresh(lockLossCallback, id, source, quorum)
    
    				return locked
    			}
    
    			switch {
    			case opts.RetryInterval < 0:
    				return false
    			case opts.RetryInterval > 0:
    				time.Sleep(opts.RetryInterval)
    			default:
    				attempt++
    				time.Sleep(lockRetryBackOff(dm.rng, attempt))
    			}
    		}
    	}
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  8. cmd/iam.go

    		if err := saveIAMFormat(retryCtx, sys.store); err != nil {
    			if configRetriableErrors(err) {
    				retryInterval := time.Duration(r.Float64() * float64(time.Second))
    				logger.Info("Waiting for all MinIO IAM sub-system to be initialized.. possible cause (%v) (retrying in %s)", err, retryInterval)
    				time.Sleep(retryInterval)
    				continue
    			}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  9. internal/logger/target/http/http.go

    	QueueSize   int               `json:"queueSize"`
    	QueueDir    string            `json:"queueDir"`
    	MaxRetry    int               `json:"maxRetry"`
    	RetryIntvl  time.Duration     `json:"retryInterval"`
    	Proxy       string            `json:"string"`
    	Transport   http.RoundTripper `json:"-"`
    	HTTPTimeout time.Duration     `json:"httpTimeout"`
    
    	// Custom logger
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
Back to top