Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 2 of 2 for Walk (0.03 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/erasure-server-pool.go

    	// .metadata.bin healing is not needed here, it is automatically healed via read() call.
    	return z.s3Peer.HealBucket(ctx, bucket, opts)
    }
    
    // Walk a bucket, optionally prefix recursively, until we have returned
    // all the contents of the provided bucket+prefix.
    func (z *erasureServerPools) Walk(ctx context.Context, bucket, prefix string, results chan<- itemOrErr[ObjectInfo], opts WalkOptions) error {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  2. cmd/batch-handlers.go

    			prefixes := r.Source.Prefix.F()
    			if len(prefixes) == 0 {
    				prefixes = []string{""}
    			}
    			for _, prefix := range prefixes {
    				prefixWalkCh := make(chan itemOrErr[ObjectInfo], 100)
    				if err := api.Walk(ctx, r.Source.Bucket, prefix, prefixWalkCh, WalkOptions{
    					Marker:   lastObject,
    					Filter:   selectObj,
    					AskDisks: walkQuorum,
    				}); err != nil {
    					cancelCause(err)
    					xioutil.SafeClose(walkCh)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 63.5K bytes
    - Click Count (1)
Back to Top