Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for Talk (0.21 sec)

  1. cmd/erasure-server-pool.go

    	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.
    // TODO: Note that most errors will result in a truncated listing.
    func (z *erasureServerPools) Walk(ctx context.Context, bucket, prefix string, results chan<- ObjectInfo, opts WalkOptions) error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  2. cmd/bucket-replication.go

    	}
    	// mark resync status as resync started
    	if !heal {
    		s.markStatus(ResyncStarted, opts, objectAPI)
    	}
    
    	// Walk through all object versions - Walk() is always in ascending order needed to ensure
    	// delete marker replicated to target after object version is first created.
    	if err := objectAPI.Walk(ctx, opts.bucket, "", objInfoCh, WalkOptions{}); err != nil {
    		replLogIf(ctx, err)
    		return
    	}
    
    	s.RLock()
    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)
  3. cmd/object-api-interface.go

    	ListObjectVersions(ctx context.Context, bucket, prefix, marker, versionMarker, delimiter string, maxKeys int) (result ListObjectVersionsInfo, err error)
    	// Walk lists all objects including versions, delete markers.
    	Walk(ctx context.Context, bucket, prefix string, results chan<- ObjectInfo, opts WalkOptions) error
    
    	// Object operations.
    
    	// GetObjectNInfo returns a GetObjectReader that satisfies the
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 17K bytes
    - Viewed (0)
  4. cmd/batch-handlers.go

    	if err != nil {
    		return err
    	}
    
    	wk, err := workers.New(workerSize)
    	if err != nil {
    		// invalid worker size.
    		return err
    	}
    
    	walkQuorum := env.Get("_MINIO_BATCH_REPLICATION_WALK_QUORUM", "strict")
    	if walkQuorum == "" {
    		walkQuorum = "strict"
    	}
    
    	retryAttempts := ri.RetryAttempts
    	retry := false
    	for attempts := 1; attempts <= retryAttempts; attempts++ {
    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)
  5. cmd/main.go

    		sort.Strings(closestCommands)
    		// Suggest other close commands - allow missed, wrongly added and
    		// even transposed characters
    		for _, value := range commandsTree.Walk(commandsTree.Root()) {
    			if sort.SearchStrings(closestCommands, value) < len(closestCommands) {
    				continue
    			}
    			// 2 is arbitrary and represents the max
    			// allowed number of typed errors
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 6.4K bytes
    - Viewed (0)
Back to top