Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for transition_workers (0.16 sec)

  1. internal/config/api/api.go

    	}
    
    	cfg.ReplicationMaxLWorkers = replicationMaxLWorkers
    
    	transitionWorkers, err := strconv.Atoi(env.Get(EnvAPITransitionWorkers, kvs.GetWithDefault(apiTransitionWorkers, DefaultKVS)))
    	if err != nil {
    		return cfg, err
    	}
    	cfg.TransitionWorkers = transitionWorkers
    
    	v := env.Get(EnvAPIDeleteCleanupInterval, kvs.Get(apiDeleteCleanupInterval))
    	if v == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 16 08:43:49 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  2. cmd/handler-api.go

    	t.replicationMaxWorkers = cfg.ReplicationMaxWorkers
    	t.replicationMaxLWorkers = cfg.ReplicationMaxLWorkers
    
    	// N B api.transition_workers will be deprecated
    	if globalTransitionState != nil {
    		globalTransitionState.UpdateWorkers(cfg.TransitionWorkers)
    	}
    	t.transitionWorkers = cfg.TransitionWorkers
    
    	t.staleUploadsExpiry = cfg.StaleUploadsExpiry
    	t.deleteCleanupInterval = cfg.DeleteCleanupInterval
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 17:07:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  3. docs/config/README.md

    replication_priority            (string)    set replication priority (default: 'auto')
    replication_max_workers         (number)    set the maximum number of replication workers (default: '500')
    transition_workers              (number)    set the number of transition workers (default: '100')
    stale_uploads_expiry            (duration)  set to expire stale multipart uploads older than this values (default: '24h')
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 16 08:43:49 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  4. cmd/bucket-lifecycle.go

    // of transition workers.
    func (t *transitionState) Init(objAPI ObjectLayer) {
    	n := globalAPIConfig.getTransitionWorkers()
    	// Prefer ilm.transition_workers over now deprecated api.transition_workers
    	if tw := globalILMConfig.getTransitionWorkers(); tw > 0 {
    		n = tw
    	}
    	t.mu.Lock()
    	defer t.mu.Unlock()
    
    	t.objAPI = objAPI
    	t.updateWorkers(n)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  5. cmd/config-current.go

    		if err != nil {
    			errs = append(errs, fmt.Errorf("Unable to apply ilm config: %w", err))
    		} else {
    			if globalTransitionState != nil {
    				globalTransitionState.UpdateWorkers(ilmCfg.TransitionWorkers)
    			}
    			if globalExpiryState != nil {
    				globalExpiryState.ResizeWorkers(ilmCfg.ExpirationWorkers)
    			}
    			globalILMConfig.update(ilmCfg)
    		}
    	}
    	globalServerConfigMu.Lock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 30.1K bytes
    - Viewed (0)
Back to top