Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for removeObject (0.17 sec)

  1. cmd/sts-handlers_test.go

    	if err = minioClient.RemoveObjectTagging(ctx, bucket, object, minio.RemoveObjectTaggingOptions{}); err != nil {
    		c.Fatalf("user is unable to delete the object tags: %v", err)
    	}
    
    	if err = minioClient.RemoveObject(ctx, bucket, object, minio.RemoveObjectOptions{}); err != nil {
    		c.Fatalf("user is unable to delete the object: %v", err)
    	}
    }
    
    func (s *TestSuiteIAM) TestSTS(c *check) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 85.7K bytes
    - Viewed (0)
  2. cmd/warm-backend-s3.go

    }
    
    func (s3 *warmBackendS3) Remove(ctx context.Context, object string, rv remoteVersionID) error {
    	ropts := minio.RemoveObjectOptions{}
    	if rv != "" {
    		ropts.VersionID = string(rv)
    	}
    	err := s3.client.RemoveObject(ctx, s3.Bucket, s3.getDest(object), ropts)
    	return s3.ToObjectError(err, object)
    }
    
    func (s3 *warmBackendS3) InUse(ctx context.Context) (bool, error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  3. cmd/sftp-server-driver.go

    			}
    			for object := range clnt.ListObjects(cctx, bucket, opts) {
    				if object.Err != nil {
    					return
    				}
    				objectsCh <- object
    			}
    		}()
    
    		// Call RemoveObjects API
    		for err := range clnt.RemoveObjects(context.Background(), bucket, objectsCh, minio.RemoveObjectsOptions{}) {
    			if err.Err != nil {
    				return err.Err
    			}
    		}
    		return err
    
    	case "Remove":
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 12:23:42 GMT 2024
    - 12.9K bytes
    - Viewed (0)
  4. cmd/ftp-server-driver.go

    			Recursive: true,
    		}
    		for object := range clnt.ListObjects(cctx, bucket, opts) {
    			if object.Err != nil {
    				return
    			}
    			objectsCh <- object
    		}
    	}()
    
    	// Call RemoveObjects API
    	for err := range clnt.RemoveObjects(context.Background(), bucket, objectsCh, minio.RemoveObjectsOptions{}) {
    		if err.Err != nil {
    			return err.Err
    		}
    	}
    
    	return nil
    }
    
    // DeleteFile implements ftpDriver
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 12:23:42 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  5. cmd/bucket-replication.go

    			if !rinfo.VersionPurgeStatus.Empty() {
    				rinfo.VersionPurgeStatus = Complete
    				return
    			}
    		case isErrReadQuorum(serr), isErrWriteQuorum(serr):
    			// destination has some quorum issues, perform removeObject() anyways
    			// to complete the operation.
    		default:
    			if err != nil && minio.IsNetworkOrHostDown(err, true) && !globalBucketTargetSys.isOffline(tgt.EndpointURL()) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  6. cmd/batch-handlers.go

    			dmVersionID = srcObjInfo.VersionID
    		}
    		if r.Target.Type == BatchJobReplicateResourceS3 || r.Source.Type == BatchJobReplicateResourceS3 {
    			dmVersionID = ""
    			versionID = ""
    		}
    		return c.RemoveObject(ctx, tgtBucket, pathJoin(tgtPrefix, srcObject), miniogo.RemoveObjectOptions{
    			VersionID: versionID,
    			Internal: miniogo.AdvancedRemoveOptions{
    				ReplicationDeleteMarker: dmVersionID != "",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 55.2K bytes
    - Viewed (0)
Back to top