- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 80 for try (0.15 sec)
-
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 Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.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 Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Viewed (0) -
internal/s3select/parquet/errors.go
return err.message } func errParquetParsingError(err error) *s3Error { return &s3Error{ code: "ParquetParsingError", message: "Error parsing Parquet file. Please check the file and try again.", statusCode: 400, cause: err, }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 1.4K bytes - Viewed (0) -
istioctl/cmd/sysexits.go
// limitations under the License. package cmd import ( "strings" "istio.io/istio/istioctl/pkg/analyze" "istio.io/istio/istioctl/pkg/util" ) // Values should try to use sendmail-style values as in <sysexits.h> // See e.g. https://man.openbsd.org/sysexits.3 // or `less /usr/includes/sysexits.h` if you're on Linux // // Picking the right range is tricky--there are a lot of reserved ones (see
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 1.9K bytes - Viewed (0) -
cmd/post-policy-fan-out.go
encrd, objectEncryptionKey, err := newEncryptReader(ctx, hr, opts.Kind, opts.KeyID, opts.Key, bucket, req.Key, userDefined, opts.KmsCtx) if err != nil { errs[idx] = err return } // do not try to verify encrypted content/ hr, err = hash.NewReader(ctx, encrd, -1, "", "", -1) if err != nil { errs[idx] = err return } reader, err = reader.WithEncryption(hr, &objectEncryptionKey)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 3.5K bytes - Viewed (0) -
internal/grid/muxclient.go
// TODO: Not implemented func (m *muxClient) RequestStateless(h HandlerID, req []byte, out chan<- Response) { if m.init { out <- Response{Err: errors.New("mux client already used")} } m.init = true // Try to grab an initial block. m.singleResp = false msg := message{ Op: OpConnectMux, Handler: h, Flags: FlagEOF, Payload: req, DeadlineMS: uint32(m.deadline.Milliseconds()), }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
if err != nil { return fmt.Errorf("could not build port forwarder for %s: %v", flavor, err) } if err = fw.Start(); err != nil { fw.Close() // Try the next port continue } // Close the port forwarder when the command is terminated. ClosePortForwarderOnInterrupt(fw) log.Debugf(fmt.Sprintf("port-forward to %s pod ready", flavor))
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
cmd/common-main.go
} KMS, err := kms.NewWithConfig(kmsConf, KMSLogger{}) if err != nil { logger.Fatal(err, "Unable to initialize a connection to KES as specified by the shell environment") } // Try to generate a data encryption key. Only try to create key if this fails. // This implicitly checks that we can communicate to KES. // We don't treat a policy error as failure condition since MinIO may not have the permission
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 35.5K bytes - Viewed (2) -
cmd/erasure-server-pool-decom.go
auditLogDecom(ctx, "DecomCopyDeleteMarker", bi.Name, version.Name, versionID, err) continue } var failure, ignore bool // gr.Close() is ensured by decommissionObject(). for try := 0; try < 3; try++ { if version.IsRemote() { if err := z.DecomTieredObject(ctx, bi.Name, version.Name, version, ObjectOptions{ VersionID: versionID, MTime: version.ModTime,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.3K bytes - Viewed (1) -
cmd/bucket-object-lock.go
if !ret.RetainUntilDate.Before(t) { return ObjectLocked{} } return nil } // https://docs.aws.amazon.com/AmazonS3/latest/dev/object-lock-overview.html#object-lock-retention-modes // If you try to delete objects protected by governance mode and have s3:BypassGovernanceRetention, the operation will succeed. if checkRequestAuthType(ctx, r, policy.BypassGovernanceRetentionAction, bucket, object.ObjectName) != ErrNone {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 13.2K bytes - Viewed (0)