- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 30 for Try (0.12 sec)
-
internal/s3select/errors.go
statusCode: 400, cause: err, } } func errInvalidScanRangeParameter(err error) *s3Error { return &s3Error{ code: "InvalidRequestParameter", message: "The value of a parameter in ScanRange element is invalid. Check the service API documentation and try again.", statusCode: 400, cause: err, } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 14 16:48:36 GMT 2022 - 4.3K bytes - Viewed (0) -
cmd/dynamic-timeouts_test.go
} } } func TestDynamicTimeoutAdjustExponential(t *testing.T) { timeout := newDynamicTimeout(time.Minute, time.Second) rand.Seed(0) initial := timeout.Timeout() for try := 0; try < 10; try++ { testDynamicTimeoutAdjust(t, timeout, rand.ExpFloat64) } adjusted := timeout.Timeout() if initial <= adjusted {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Oct 14 10:08:40 GMT 2022 - 5.4K bytes - Viewed (0) -
docs/debugging/inspect/utils.go
func bytesToPrivateKey(priv []byte) (*rsa.PrivateKey, error) { // Try PEM if block, _ := pem.Decode(priv); block != nil { return x509.ParsePKCS1PrivateKey(block.Bytes) } // Try base 64 dst := make([]byte, base64.StdEncoding.DecodedLen(len(priv))) if n, err := base64.StdEncoding.Decode(dst, priv); err == nil { return x509.ParsePKCS1PrivateKey(dst[:n]) } // Try Raw, return error return x509.ParsePKCS1PrivateKey(priv) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Nov 02 20:36:38 GMT 2022 - 1.4K bytes - Viewed (0) -
internal/config/heal/heal.go
} const minimumBitrotCycleInMonths = 1 func parseBitrotConfig(s string) (time.Duration, error) { // Try to parse as a boolean enabled, err := config.ParseBool(s) if err == nil { switch enabled { case true: return 0, nil case false: return -1, nil } } // Try to parse as a number of months if !strings.HasSuffix(s, "m") { return -1, errors.New("unknown format") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 4.9K bytes - Viewed (0) -
cmd/typed-errors.go
var errDataTooSmall = errors.New("Object size smaller than expected") // errServerNotInitialized - server not initialized. var errServerNotInitialized = errors.New("Server not initialized, please try again") // errRPCAPIVersionUnsupported - unsupported rpc API version. var errRPCAPIVersionUnsupported = errors.New("Unsupported rpc API version") // errServerTimeMismatch - server times are too far apart.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.3K bytes - Viewed (0) -
cmd/sts-errors.go
}, ErrSTSNotInitialized: { Code: "STSNotInitialized", Description: "STS API not initialized, please try again.", HTTPStatusCode: http.StatusServiceUnavailable, }, ErrSTSIAMNotInitialized: { Code: "STSIAMNotInitialized", Description: "STS IAM not initialized, please try again.", HTTPStatusCode: http.StatusServiceUnavailable, }, ErrSTSUpstreamError: { Code: "InternalError",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.8K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
pod, ).Return(nil) fakeClientSet := fake.NewSimpleClientset() m := meshDataplane{ kubeClient: fakeClientSet, netServer: server, } // pod is not in fake client, so if this will try to remove annotation, it will fail. err := m.DelPodFromMesh(fakeCtx, pod) assert.NoError(t, err) } func TestMeshDataplaneDelPodErrorDoesntPatchPod(t *testing.T) { pod := podWithAnnotation()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
internal/lsync/lrwmutex.go
const ( lockRetryInterval = 50 * time.Millisecond ) // lockLoop will acquire either a read or a write lock // // The call will block until the lock is granted using a built-in // timing randomized back-off algorithm to try again until successful func (lm *LRWMutex) lockLoop(ctx context.Context, id, source string, timeout time.Duration, isWriteLock bool) (locked bool) { r := rand.New(rand.NewSource(time.Now().UnixNano()))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Viewed (0) -
internal/cachevalue/cache.go
// even if updating the value errors out. // Returns the last good value AND the error. ReturnLastGood bool // If CacheError is set, errors will be cached as well // and not continuously try to update. // Should not be combined with ReturnLastGood. CacheError bool // If NoWait is set, Get() will return the last good value, // if TTL has expired but 2x TTL has not yet passed,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 16:00:42 GMT 2024 - 4.2K bytes - Viewed (0) -
cmd/metacache-manager.go
m.init.Do(m.initManager) m.mu.Lock() b, ok := m.buckets[bucket] if !ok { m.mu.Unlock() return } delete(m.buckets, bucket) m.mu.Unlock() // Since deletes may take some time we try to do it without // holding lock to m all the time. b.mu.Lock() defer b.mu.Unlock() for k, v := range b.caches { if time.Since(v.lastUpdate) > metacacheMaxRunningAge { v.delete(context.Background())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 5.2K bytes - Viewed (0)