- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for retry_interval (0.16 sec)
-
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) -
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) -
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) -
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) -
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)