Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 6 of 6 for transitionWorkers (0.07 seconds)

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

  1. internal/config/ilm/ilm.go

    var DefaultKVS = config.KVS{
    	config.KV{
    		Key:   transitionWorkers,
    		Value: "100",
    	},
    	config.KV{
    		Key:   expirationWorkers,
    		Value: "100",
    	},
    }
    
    // Config represents the different configuration values for ILM subsystem
    type Config struct {
    	TransitionWorkers int
    	ExpirationWorkers int
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 1.9K bytes
    - Click Count (0)
  2. 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 == "" {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.5K bytes
    - Click Count (1)
  3. cmd/ilm-config.go

    package cmd
    
    import (
    	"sync"
    
    	"github.com/minio/minio/internal/config/ilm"
    )
    
    var globalILMConfig = ilmConfig{
    	cfg: ilm.Config{
    		ExpirationWorkers: 100,
    		TransitionWorkers: 100,
    	},
    }
    
    type ilmConfig struct {
    	mu  sync.RWMutex
    	cfg ilm.Config
    }
    
    func (c *ilmConfig) getExpirationWorkers() int {
    	c.mu.RLock()
    	defer c.mu.RUnlock()
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Mar 05 02:50:24 GMT 2024
    - 1.3K bytes
    - Click Count (0)
  4. 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
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  5. 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)
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 33.7K bytes
    - Click Count (0)
  6. cmd/testdata/undeleteable-object.tgz

    l","value":""}]},"identity_plugin":{"_":[{"key":"url","value":""},{"key":"auth_token","value":""},{"key":"role_policy","value":""},{"key":"role_id","value":""}]},"identity_tls":{"_":[{"key":"skip_verify","value":"off"}]},"ilm":{"_":[{"key":"transition_workers","value":"100"},{"key":"expiration_workers","value":"100"}]},"lambda_webhook":{"_":[{"key":"enable","value":"off"},{"key":"endpoint","value":""},{"key":"auth_token","value":""},{"key":"client_cert","value":""},{"key":"client_key","value":""...
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 26 00:31:12 GMT 2024
    - 8.7M bytes
    - Click Count (0)
Back to Top