- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for deletedObjects (0.39 sec)
-
cmd/bucket-handlers_test.go
encodedSuccessResponse0 := encodeResponse(successResponse0) successRequest1 := encodeResponse(requestList[1]) deletedObjects = make([]DeletedObject, len(requestList[1].Objects)) for i := range requestList[1].Objects { var vid string if isDirObject(requestList[0].Objects[i].ObjectName) { vid = "" } deletedObjects[i] = DeletedObject{
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 39.8K bytes - Viewed (0) -
cmd/bucket-handlers.go
deleteResult.delInfo.VersionID = "" } deletedObjects = append(deletedObjects, deleteResult.delInfo) } } response := generateMultiDeleteResponse(deleteObjectsReq.Quiet, deletedObjects, deleteErrors) encodedSuccessResponse := encodeResponse(response) // Write success response. writeSuccessResponseXML(w, encodedSuccessResponse) for _, dobj := range deletedObjects { if dobj.ObjectName == "" { 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/server_test.go
delRespBytes, err = io.ReadAll(response.Body) c.Assert(err, nil) err = xml.Unmarshal(delRespBytes, &deleteResp) c.Assert(err, nil) c.Assert(len(deleteResp.DeletedObjects), len(delObjReq.Objects)) for i := range 10 { c.Assert(deleteResp.DeletedObjects[i], DeletedObject{ ObjectName: delObjReq.Objects[i].ObjectName, VersionID: delObjReq.Objects[i].VersionID, }) } c.Assert(len(deleteResp.Errors), 0) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 118.1K bytes - Viewed (0) -
cmd/erasure-sets.go
} // DeleteObjects - bulk delete of objects // Bulk delete is only possible within one set. For that purpose // objects are group by set first, and then bulk delete is invoked // for each set, the error response of each delete will be returned func (s *erasureSets) DeleteObjects(ctx context.Context, bucket string, objects []ObjectToDelete, opts ObjectOptions) ([]DeletedObject, []error) { type delObj struct {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 37K bytes - Viewed (1) -
cmd/erasure-object.go
if !opts.NoAuditLog { for _, obj := range objects { auditObjectErasureSet(ctx, "DeleteObjects", obj.ObjectName, &er) } } errs := make([]error, len(objects)) dobjects := make([]DeletedObject, len(objects)) writeQuorums := make([]int, len(objects)) storageDisks := er.getDisks() for i := range objects { // Assume (N/2 + 1) quorums for all objects
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-api-interface.go
DeleteObject(ctx context.Context, bucket, object string, opts ObjectOptions) (ObjectInfo, error) DeleteObjects(ctx context.Context, bucket string, objects []ObjectToDelete, opts ObjectOptions) ([]DeletedObject, []error) TransitionObject(ctx context.Context, bucket, object string, opts ObjectOptions) error
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 17.5K bytes - Viewed (0) -
cmd/erasure-server-pool.go
objInfo.Name = decodeDirObject(object) err = derrs[0] return objInfo, err } func (z *erasureServerPools) DeleteObjects(ctx context.Context, bucket string, objects []ObjectToDelete, opts ObjectOptions) ([]DeletedObject, []error) { derrs := make([]error, len(objects)) dobjects := make([]DeletedObject, len(objects)) objSets := set.NewStringSet() for i := range derrs {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 89.1K bytes - Viewed (0) -
cmd/admin-handlers_test.go
func TestTopLockEntries(t *testing.T) { locksHeld := make(map[string][]lockRequesterInfo) var owners []string for i := range 4 { owners = append(owners, fmt.Sprintf("node-%d", i)) } // Simulate DeleteObjects of 10 objects in a single request. i.e same lock // request UID, but 10 different resource names associated with it. var lris []lockRequesterInfo uuid := mustGetUUID() for i := range 10 {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.9K bytes - Viewed (0) -
cmd/bucket-replication-utils.go
} // VersionPurgeStatus returns a composite version purge status across targets func (d *DeletedObject) VersionPurgeStatus() VersionPurgeStatusType { return d.ReplicationState.CompositeVersionPurgeStatus() } // DeleteMarkerReplicationStatus return composite replication status of delete marker across targets func (d *DeletedObject) DeleteMarkerReplicationStatus() replication.StatusType {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 26K bytes - Viewed (0) -
cmd/erasure-object_test.go
names := []ObjectToDelete{ { ObjectV: ObjectV{ ObjectName: objectName, VersionID: vid, }, }, } _, delErrs := obj.DeleteObjects(ctx, bucketName, names, ObjectOptions{ Versioned: true, }) for i := range delErrs { if delErrs[i] != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 38.3K bytes - Viewed (0)