Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for path2BucketObject (0.25 sec)

  1. cmd/sftp-server-driver.go

    			}
    		}
    		return err
    
    	case "Remove":
    		bucket, object := path2BucketObject(r.Filepath)
    		if bucket == "" {
    			return errors.New("bucket name cannot be empty")
    		}
    
    		return clnt.RemoveObject(context.Background(), bucket, object, minio.RemoveObjectOptions{})
    
    	case "Mkdir":
    		bucket, prefix := path2BucketObject(r.Filepath)
    		if bucket == "" {
    			return errors.New("bucket name cannot be empty")
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 12:23:42 GMT 2024
    - 12.9K bytes
    - Viewed (0)
  2. cmd/ftp-server-driver.go

    	defer stopFn(err)
    
    	if objPath == SlashSeparator {
    		return &minioFileInfo{
    			p:     SlashSeparator,
    			isDir: true,
    		}, nil
    	}
    
    	bucket, object := path2BucketObject(objPath)
    	if bucket == "" {
    		return nil, errors.New("bucket name cannot be empty")
    	}
    
    	clnt, err := driver.getMinIOClient(ctx)
    	if err != nil {
    		return nil, err
    	}
    
    	if object == "" {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 12:23:42 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  3. cmd/generic-handlers.go

    // browser requests.
    func getRedirectLocation(r *http.Request) *xnet.URL {
    	resource, err := getResource(r.URL.Path, r.Host, globalDomainNames)
    	if err != nil {
    		return nil
    	}
    	bucket, _ := path2BucketObject(resource)
    	_, redirect := redirectPrefixes[path.Clean(bucket)]
    	if redirect || resource == slashSeparator {
    		if globalBrowserRedirectURL != nil {
    			return globalBrowserRedirectURL
    		}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 11 01:08:52 GMT 2024
    - 20.7K bytes
    - Viewed (0)
  4. cmd/utils_test.go

    			bucket: "",
    			object: "",
    		},
    	}
    
    	// Validate all test cases.
    	for _, testCase := range testCases {
    		testCase := testCase
    		t.Run("", func(t *testing.T) {
    			bucketName, objectName := path2BucketObject(testCase.path)
    			if bucketName != testCase.bucket {
    				t.Errorf("failed expected bucket name \"%s\", got \"%s\"", testCase.bucket, bucketName)
    			}
    			if objectName != testCase.object {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Feb 23 21:28:14 GMT 2024
    - 10.2K bytes
    - Viewed (0)
  5. cmd/global-heal.go

    			case <-ctx.Done():
    				return
    			case results <- healEntryDone(entry.name):
    			}
    
    			// Wait and proceed if there are active requests
    			waitForLowHTTPReq()
    		}
    
    		actualBucket, prefix := path2BucketObject(bucket)
    
    		// How to resolve partial results.
    		resolver := metadataResolutionParams{
    			dirQuorum: 1,
    			objQuorum: 1,
    			bucket:    actualBucket,
    		}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 08 09:22:13 GMT 2024
    - 14.2K bytes
    - Viewed (1)
  6. cmd/utils.go

    func request2BucketObjectName(r *http.Request) (bucketName, objectName string) {
    	path, err := getResource(r.URL.Path, r.Host, globalDomainNames)
    	if err != nil {
    		logger.CriticalIf(GlobalContext, err)
    	}
    
    	return path2BucketObject(path)
    }
    
    // path2BucketObjectWithBasePath returns bucket and prefix, if any,
    // of a 'path'. basePath is trimmed from the front of the 'path'.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 32K bytes
    - Viewed (0)
  7. cmd/handler-utils.go

    			apiErr.Description = fmt.Sprintf("%s: %v", apiErr.Description, err)
    
    			writeErrorResponse(r.Context(), w, apiErr, r.URL)
    			return
    		}
    
    		bucket, _ := path2BucketObject(resource)
    
    		meta, err := globalBucketMetadataSys.Get(bucket) // check if this bucket exists.
    		countBktStat := bucket != "" && bucket != minioReservedBucket && err == nil && !meta.Created.IsZero()
    		if countBktStat {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.5K bytes
    - Viewed (3)
  8. cmd/erasure-server-pool-decom.go

    		// Decommission not in progress.
    		return nil
    	}
    
    	decomBuckets := make([]decomBucketInfo, len(p.Pools[idx].Decommission.QueuedBuckets))
    	for i := range decomBuckets {
    		bucket, prefix := path2BucketObject(p.Pools[idx].Decommission.QueuedBuckets[i])
    		decomBuckets[i] = decomBucketInfo{
    			Name:   bucket,
    			Prefix: prefix,
    		}
    	}
    
    	return decomBuckets
    }
    
    //msgp:ignore decomBucketInfo
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 40.4K bytes
    - Viewed (1)
  9. cmd/object-multipart-handlers.go

    	if u, err := url.Parse(cpSrcPath); err == nil {
    		vid = strings.TrimSpace(u.Query().Get(xhttp.VersionID))
    		// Note that url.Parse does the unescaping
    		cpSrcPath = u.Path
    	}
    
    	srcBucket, srcObject := path2BucketObject(cpSrcPath)
    	// If source object is empty or bucket is empty, reply back invalid copy source.
    	if srcObject == "" || srcBucket == "" {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidCopySource), r.URL)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  10. cmd/data-scanner.go

    			objQuorum: f.disksQuorum,
    			bucket:    "",
    			strict:    false,
    		}
    
    		healObjectsPrefix := color.Green("healObjects:")
    		for k := range abandonedChildren {
    			bucket, prefix := path2BucketObject(k)
    			stopFn := globalScannerMetrics.time(scannerMetricCheckMissing)
    			f.updateCurrentPath(k)
    
    			if bucket != resolver.bucket {
    				// Bucket might be missing as well with abandoned children.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 15 09:40:19 GMT 2024
    - 46.9K bytes
    - Viewed (0)
Back to top