- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for retryInterval (0.2 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/FaultTolerantClient.java
this.maxRetryCount = maxRetryCount; } public long getRetryInterval() { return retryInterval; } public void setRetryInterval(final long retryInterval) { this.retryInterval = retryInterval; } public RequestListener getRequestListener() { return listener; }
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 4.4K bytes - Viewed (0) -
security/pkg/k8s/controller/casecret.go
namespace, secretName) return caSecret, scrtErr } time.Sleep(retryInterval) } } // UpdateCASecretWithRetry updates CA secret with retries until timeout. func (csc *CaSecretController) UpdateCASecretWithRetry(caSecret *v1.Secret, retryInterval, timeout time.Duration, ) error { start := time.Now() for {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.6K bytes - Viewed (0) -
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 Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Aug 19 23:21:05 UTC 2022 - 4.5K bytes - Viewed (0) -
internal/store/store.go
package store import ( "context" "errors" "fmt" "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 Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Mar 25 16:44:20 UTC 2024 - 3.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 Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 05 23:56:35 UTC 2023 - 9.2K bytes - Viewed (0) -
pkg/util/async/bounded_frequency_runner.go
return } // Timer wants an interval not an absolute time, so convert retryTime back now retryInterval := bfr.retryTime.Sub(bfr.timer.Now()) bfr.retryTime = time.Time{} if retryInterval < bfr.timer.Remaining() { klog.V(3).Infof("%s: retrying in %v", bfr.name, retryInterval) bfr.timer.Stop() bfr.timer.Reset(retryInterval) } } // assumes the lock is not held func (bfr *BoundedFrequencyRunner) tryRun() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 15 09:36:26 UTC 2022 - 9.4K bytes - Viewed (0) -
fess-crawler-lasta/src/main/resources/crawler/client.xml
class="org.codelibs.fess.crawler.client.FaultTolerantClient" instance="prototype"> <property name="crawlerClient">internalHttpClient</property> <property name="maxRetryCount">5</property> <property name="retryInterval">500</property> </component> <component name="fsClient" class="org.codelibs.fess.crawler.client.fs.FileSystemClient" instance="prototype"> <property name="charset">"UTF-8"</property> </component>
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Tue Aug 08 12:54:47 UTC 2023 - 2.8K 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 Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 13 09:26:38 UTC 2023 - 2.3K bytes - Viewed (0)