Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 108 for Walker (0.31 sec)

  1. cmd/erasure-server-pool.go

    	var loi ListObjectsInfo
    	opts := listPathOptions{
    		V1:          v1,
    		Bucket:      bucket,
    		Prefix:      prefix,
    		Separator:   delimiter,
    		Limit:       maxKeysPlusOne(maxKeys, marker != ""),
    		Marker:      marker,
    		InclDeleted: false,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 80.1K bytes
    - Viewed (0)
  2. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 15.3K bytes
    - Viewed (0)
  3. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 13.2K bytes
    - Viewed (0)
  4. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 73.1K bytes
    - Viewed (0)
  5. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  6. cmd/api-response.go

    	// is true), you can use the key name in this field as marker in the subsequent
    	// request to get next set of objects. Server lists objects in alphabetical
    	// order Note: This element is returned only if you have delimiter request parameter
    	// specified. If response does not include the NextMaker and it is truncated,
    	// you can use the value of the last Key in the response as the marker in the
    	// subsequent request to get the next set of object keys.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 33.3K bytes
    - Viewed (2)
  7. cmd/metacache-bucket_test.go

    	}
    	for i := 0; i < elements; i++ {
    		bm.findCache(listPathOptions{
    			ID:           mustGetUUID(),
    			Bucket:       "",
    			BaseDir:      pathNames[i%paths],
    			Prefix:       "",
    			FilterPrefix: "",
    			Marker:       "",
    			Limit:        0,
    			AskDisks:     "strict",
    			Recursive:    false,
    			Separator:    slashSeparator,
    			Create:       true,
    		})
    	}
    	b.ReportAllocs()
    	b.ResetTimer()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Mar 25 23:29:45 GMT 2022
    - 1.8K bytes
    - Viewed (0)
  8. internal/grid/stream.go

    	"errors"
    )
    
    // A Stream is a two-way stream.
    // All responses *must* be read by the caller.
    // If the call is canceled through the context,
    // the appropriate error will be returned.
    type Stream struct {
    	// responses from the remote server.
    	// Channel will be closed after error or when remote closes.
    	// All responses *must* be read by the caller until either an error is returned or the channel is closed.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Feb 28 18:05:18 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  9. internal/bucket/replication/rule.go

    	errPriorityMissing                        = Errorf("Priority must be specified")
    	errInvalidDeleteMarkerReplicationStatus   = Errorf("Delete marker replication status is invalid")
    	errDestinationSourceIdentical             = Errorf("Destination bucket cannot be the same as the source bucket.")
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Jan 24 23:22:20 GMT 2022
    - 8.3K bytes
    - Viewed (0)
  10. cmd/post-policy-fan-out.go

    	Checksum *hash.Checksum
    	MD5Hex   string
    }
    
    // fanOutPutObject takes an input source reader and fans out multiple PUT operations
    // based on the incoming fan-out request, a context cancellation by the caller
    // would ensure all fan-out operations are canceled.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 3.5K bytes
    - Viewed (0)
Back to top