- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 20 for isErrObjectNotFound (0.12 sec)
-
cmd/object-api-errors.go
func isErrWriteQuorum(err error) bool { var rquorum InsufficientWriteQuorum return errors.As(err, &rquorum) } // isErrObjectNotFound - Check if error type is ObjectNotFound. func isErrObjectNotFound(err error) bool { if errors.Is(err, errFileNotFound) { return true } var objNotFound ObjectNotFound return errors.As(err, &objNotFound) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 09 02:05:14 UTC 2024 - 22.1K bytes - Viewed (0) -
cmd/erasure-object.go
if err != nil && !isErrVersionNotFound(err) && !isErrObjectNotFound(err) && !isErrReadQuorum(err) { return objInfo, err } // if object doesn't exist and not a replication request return error for If-Match conditional requests // If-None-Match should be allowed to proceed for non-existent objects if err != nil && !opts.ReplicationRequest && opts.HasIfMatch && (isErrObjectNotFound(err) || isErrVersionNotFound(err)) {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 80.4K bytes - Viewed (0) -
cmd/object-handlers.go
var proxy proxyResult gr, err := getObjectNInfo(ctx, bucket, object, rs, r.Header, opts) if err != nil { var ( reader *GetObjectReader perr error ) if (isErrObjectNotFound(err) || isErrVersionNotFound(err) || isErrReadQuorum(err)) && (gr == nil || !gr.ObjInfo.DeleteMarker) { proxytgts := getProxyTargets(ctx, bucket, object, opts) if !proxytgts.Empty() {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 120.6K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
if !oi.TransitionedObject.FreeVersion { // nothing to be done continue } ignoreNotFoundErr := func(err error) error { switch { case isErrVersionNotFound(err), isErrObjectNotFound(err): return nil } return err } // Remove the remote object
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 33.7K bytes - Viewed (0) -
cmd/object_api_suite_test.go
} _, err = obj.GetObjectInfo(context.Background(), "bucket", "dir1", ObjectOptions{}) if err == nil { t.Fatalf("%s: Expected error but found nil", instanceType) } if isErrObjectNotFound(err) { if err.Error() != "Object not found: bucket/dir1" { t.Errorf("%s: Expected the Error message to be `%s`, but instead found `%s`", instanceType, "Object not found: bucket/dir1", err.Error()) } } else {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 34.5K bytes - Viewed (0) -
cmd/bucket-replication.go
// delete marker already replicated if dobj.VersionID == "" && rinfo.VersionPurgeStatus.Empty() { rinfo.ReplicationStatus = replication.Completed return } case isErrObjectNotFound(serr), isErrVersionNotFound(serr): // version being purged is already not found on target. if !rinfo.VersionPurgeStatus.Empty() { rinfo.VersionPurgeStatus = replication.VersionPurgeComplete return
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 118K bytes - Viewed (0) -
cmd/server-main.go
errors.Is(err, errErasureWriteQuorum) || errors.Is(err, errErasureReadQuorum) || errors.Is(err, io.ErrUnexpectedEOF) || errors.As(err, &rquorum) || errors.As(err, &wquorum) || isErrObjectNotFound(err) || isErrBucketNotFound(err) || errors.Is(err, os.ErrDeadlineExceeded) || notInitialized } func bootstrapTraceMsg(msg string) { info := madmin.TraceInfo{
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue May 27 15:18:36 UTC 2025 - 35.9K bytes - Viewed (4) -
cmd/erasure-healing_test.go
ScanMode: madmin.HealDeepScan, }) // since majority of xl.meta's are not available, object quorum // can't be read properly will be deleted automatically and // err is nil if !isErrObjectNotFound(err) { t.Fatal(err) } } // Tests healing of empty directories func TestHealEmptyDirectoryErasure(t *testing.T) { ctx, cancel := context.WithCancel(t.Context()) defer cancel()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 48.5K bytes - Viewed (0) -
cmd/bucket-handlers.go
ReplicateDecisionStr: dObjects[i].ReplicationState.ReplicateDecisionStr, } dindex := objectsToDelete[objToDel] if errs[i] == nil || isErrObjectNotFound(errs[i]) || isErrVersionNotFound(errs[i]) { if replicateDeletes { dObjects[i].ReplicationState = deleteList[i].ReplicationState() } deleteResults[dindex].delInfo = dObjects[i] continue }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 63.9K bytes - Viewed (0) -
cmd/object-api-listobjects_test.go
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 76.1K bytes - Viewed (0)