Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for gatherResults (0.1 sec)

  1. cmd/metacache-server-pool.go

    	// Create output for our results.
    	// Create filter for results.
    	o.debugln("Raw List", o)
    	filterCh := make(chan metaCacheEntry, o.Limit)
    	listCtx, cancelList := context.WithCancel(ctx)
    	filteredResults := o.gatherResults(listCtx, filterCh)
    	var wg sync.WaitGroup
    	wg.Add(1)
    	var listErr error
    
    	go func(o listPathOptions) {
    		defer wg.Done()
    		o.StopDiskAtLimit = true
    		listErr = z.listMerged(listCtx, o, filterCh)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. cmd/metacache-set.go

    		console.Debugln(data...)
    	}
    }
    
    // gatherResults will collect all results on the input channel and filter results according
    // to the options or to the current bucket ILM expiry rules.
    // Caller should close the channel when done.
    // The returned function will return the results once there is enough or input is closed,
    // or the context is canceled.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
Back to top