Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for expiry_workers (0.09 sec)

  1. internal/config/api/api.go

    	deprecatedKeys := []string{
    		apiReadyDeadline,
    		apiRequestsDeadline,
    		"extend_list_cache_life",
    		apiReplicationWorkers,
    		apiReplicationFailedWorkers,
    		"expiry_workers",
    	}
    
    	disableODirect := env.Get(EnvAPIDisableODirect, kvs.Get(apiDisableODirect)) == config.EnableOn
    	enableODirect := env.Get(EnvAPIODirect, kvs.Get(apiODirect)) == config.EnableOn
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.5K bytes
    - Viewed (1)
  2. cmd/data-scanner_test.go

    					Bucket: "dest-bucket",
    				},
    			},
    		},
    	}
    	lr := objectlock.Retention{
    		Mode:        objectlock.RetCompliance,
    		Validity:    12 * time.Hour,
    		LockEnabled: true,
    	}
    
    	expiryWorker := func(wg *sync.WaitGroup, readyCh chan<- struct{}, taskCh <-chan expiryOp, gotExpired *[]ObjectToDelete) {
    		defer wg.Done()
    		// signal the calling goroutine that the worker is ready tor receive tasks
    		close(readyCh)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
Back to top