Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 109 for Walker (0.47 sec)

  1. cmd/bucket-replication.go

    	return dsc
    }
    
    // replicate deletes to the designated replication target if replication configuration
    // has delete marker replication or delete replication (MinIO extension to allow deletes where version id
    // is specified) enabled.
    // Similar to bucket replication for PUT operation, soft delete (a.k.a setting delete marker) and
    // permanent deletes (by specifying a version ID in the delete operation) have three states "Pending", "Complete"
    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)
  2. cmd/warm-backend-azure.go

    }
    
    func (az *warmBackendAzure) InUse(ctx context.Context) (bool, error) {
    	containerURL := az.serviceURL.NewContainerURL(az.Bucket)
    	resp, err := containerURL.ListBlobsHierarchySegment(ctx, azblob.Marker{}, "/", azblob.ListBlobsSegmentOptions{
    		Prefix:     az.Prefix,
    		MaxResults: int32(1),
    	})
    	if err != nil {
    		return false, azureToObjectError(err, az.Bucket, az.Prefix)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 05 16:44:08 GMT 2024
    - 7.8K bytes
    - Viewed (1)
  3. cmd/batch-rotate.go

    		return err
    	}
    
    	retryAttempts := ri.RetryAttempts
    	ctx, cancel := context.WithCancel(ctx)
    
    	results := make(chan ObjectInfo, 100)
    	if err := api.Walk(ctx, r.Bucket, r.Prefix, results, WalkOptions{
    		Marker: lastObject,
    		Filter: selectObj,
    	}); err != nil {
    		cancel()
    		// Do not need to retry if we can't list objects on source.
    		return err
    	}
    
    	for result := range results {
    		result := result
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  4. cmd/test-utils_test.go

    	queryValue := url.Values{}
    	queryValue.Set("uploads", "")
    	queryValue.Set("prefix", prefix)
    	queryValue.Set("delimiter", delimiter)
    	queryValue.Set("key-marker", keyMarker)
    	queryValue.Set("upload-id-marker", uploadIDMarker)
    	queryValue.Set("max-uploads", maxUploads)
    	return makeTestTargetURL(endPoint, bucketName, "", queryValue)
    }
    
    // return URL for a listing parts on a given upload id.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  5. cmd/admin-heal-ops.go

    	select {
    	case res := <-task.respCh:
    		if !h.reportProgress {
    			if errors.Is(res.err, errSkipFile) { // this is only sent usually by nopHeal
    				return nil
    			}
    
    			// Report caller of any failure
    			return res.err
    		}
    		res.result.Type = healType
    		if res.err != nil {
    			res.result.Detail = res.err.Error()
    		}
    		return h.pushHealResultItem(res.result)
    	case <-h.ctx.Done():
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  6. cmd/metacache-entries.go

    		// If separator is not found or is last entry, ok.
    		return idx == -1 || idx == len(ext)-len(separator)
    	}
    	return false
    }
    
    // isLatestDeletemarker returns whether the latest version is a delete marker.
    // If metadata is NOT versioned false will always be returned.
    // If v2 and UNABLE to load metadata true will be returned.
    func (e *metaCacheEntry) isLatestDeletemarker() bool {
    	if e.cached != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  7. cmd/storage-datatypes.go

    }
    
    // GetDataDir returns an expected dataDir given FileInfo
    //   - deleteMarker returns "delete-marker"
    //   - returns "legacy" if FileInfo is XLV1 and DataDir is
    //     empty, returns DataDir otherwise
    //   - returns "dataDir"
    func (fi FileInfo) GetDataDir() string {
    	if fi.Deleted {
    		return "delete-marker"
    	}
    	if fi.XLV1 && fi.DataDir == "" {
    		return "legacy"
    	}
    	return fi.DataDir
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 15.3K bytes
    - Viewed (0)
  8. cmd/bucket-object-lock.go

    	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
    			}
    		}
    		if isErrObjectNotFound(gerr) || isErrVersionNotFound(gerr) {
    			return nil
    		}
    		return gerr
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 13.2K bytes
    - Viewed (0)
  9. cmd/object-api-listobjects_test.go

    				t.Log("ListObjectVersions, bucket:", testCase.bucketName, "prefix:",
    					testCase.prefix, "marker:", testCase.marker, "delimiter:",
    					testCase.delimiter, "maxkeys:", testCase.maxKeys)
    
    				resultV, err = obj.ListObjectVersions(context.Background(), testCase.bucketName,
    					testCase.prefix, testCase.marker, "", testCase.delimiter, testCase.maxKeys)
    			} else {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 11:07:40 GMT 2024
    - 73.1K bytes
    - Viewed (0)
  10. cmd/metacache-server-pool.go

    // Other important fields are Limit, Marker.
    // List ID always derived from the Marker.
    func (z *erasureServerPools) listPath(ctx context.Context, o *listPathOptions) (entries metaCacheEntriesSorted, err error) {
    	if err := checkListObjsArgs(ctx, o.Bucket, o.Prefix, o.Marker); err != nil {
    		return entries, err
    	}
    
    	// Marker points to before the prefix, just ignore it.
    	if o.Marker < o.Prefix {
    		o.Marker = ""
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
Back to top