- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for getObjectInfo (0.12 sec)
-
cmd/s3-zip-handlers.go
return } opts, err := getOpts(ctx, r, bucket, zipPath) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } getObjectInfo := objectAPI.GetObjectInfo // Check for auth type to return S3 compatible error. // type to return the correct error (NoSuchKey vs AccessDenied)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.8K bytes - Viewed (0) -
cmd/object-handlers.go
BucketName: bucket, ConditionValues: getConditionValues(r, "", auth.AnonymousCredentials), IsOwner: false, }) { getObjectInfo := objectAPI.GetObjectInfo _, err = getObjectInfo(ctx, bucket, object, opts) if toAPIError(ctx, err).Code == "NoSuchKey" { s3Error = ErrNoSuchKey } } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 05 05:16:15 UTC 2024 - 117.4K bytes - Viewed (0) -
cmd/object-api-interface.go
type CheckPreconditionFn func(o ObjectInfo) bool // EvalMetadataFn validates input objInfo and GetObjectInfo error and returns an updated metadata and replication decision if any type EvalMetadataFn func(o *ObjectInfo, gerr error) (ReplicateDecision, error) // EvalRetentionBypassFn validates input objInfo and GetObjectInfo error and returns an error if retention bypass is not allowed.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 22 21:57:20 UTC 2024 - 17.3K bytes - Viewed (0) -
cmd/object_api_suite_test.go
t.Fatalf("%s: <ERROR> %s", instanceType, err) } if !bytes.Equal(byteBuffer.Bytes(), value) { t.Errorf("%s: Mismatch of GetObject data with the expected one.", instanceType) } objInfo, err := obj.GetObjectInfo(context.Background(), "bucket", key, opts) if err != nil { t.Fatalf("%s: <ERROR> %s", instanceType, err) } if objInfo.Size != int64(len(value)) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 02 15:13:05 UTC 2024 - 33.3K bytes - Viewed (0) -
cmd/acl-handlers.go
writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } // Before proceeding validate if object exists. _, err = objAPI.GetObjectInfo(ctx, bucket, object, ObjectOptions{}) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } aclHeader := r.Header.Get(xhttp.AmzACL) if aclHeader == "" {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.4K bytes - Viewed (0) -
cmd/erasure-object.go
} // End of read all parts loop. // Return success. return nil } // GetObjectInfo - reads object metadata and replies back ObjectInfo. func (er erasureObjects) GetObjectInfo(ctx context.Context, bucket, object string, opts ObjectOptions) (info ObjectInfo, err error) { if !opts.NoAuditLog { auditObjectErasureSet(ctx, "GetObjectInfo", object, &er) } if !opts.NoLock { // Lock the object before reading.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 78.8K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
holdPerms := isPutActionAllowed(ctx, getRequestAuthType(r), bucket, object, r, policy.PutObjectLegalHoldAction) getObjectInfo := objectAPI.GetObjectInfo retentionMode, retentionDate, legalHold, s3Err := checkPutObjectLockAllowed(ctx, r, bucket, object, getObjectInfo, retPerms, holdPerms) if s3Err == ErrNone && retentionMode.Valid() { metadata[strings.ToLower(xhttp.AmzObjectLockMode)] = string(retentionMode)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Aug 31 18:25:48 UTC 2024 - 39.2K bytes - Viewed (0) -
cmd/erasure-server-pool.go
for _, prefix := range li.Prefixes { objInfo, _ := z.GetObjectInfo(ctx, bucket, pathJoin(prefix, "_SUCCESS"), ObjectOptions{NoLock: true}) if objInfo.IsLatest && objInfo.DeleteMarker { continue } prefixes = append(prefixes, prefix) } if len(prefixes) > 0 { objInfo, _ := z.GetObjectInfo(ctx, bucket, pathJoin(opts.Prefix, "_SUCCESS"), ObjectOptions{NoLock: true})
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 89.8K bytes - Viewed (0) -
cmd/bucket-object-lock.go
func enforceRetentionBypassForDelete(ctx context.Context, r *http.Request, bucket string, object ObjectToDelete, oi ObjectInfo, gerr error) error { if gerr != nil { // error from GetObjectInfo if _, ok := gerr.(MethodNotAllowed); ok { // This happens usually for a delete marker if oi.DeleteMarker || !oi.VersionPurgeStatus.Empty() { // Delete marker should be present and valid. return nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 13.2K bytes - Viewed (0) -
cmd/erasure-sets.go
return set.PutObject(ctx, bucket, object, data, opts) } // GetObjectInfo - reads object metadata from the hashedSet based on the object name. func (s *erasureSets) GetObjectInfo(ctx context.Context, bucket, object string, opts ObjectOptions) (objInfo ObjectInfo, err error) { set := s.getHashedSet(object) return set.GetObjectInfo(ctx, bucket, object, opts) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 27 10:41:37 UTC 2024 - 37K bytes - Viewed (1)