Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for ParseDuration (0.13 sec)

  1. internal/config/api/api.go

    		return cfg, errors.New("invalid API max requests value")
    	}
    
    	clusterDeadline, err := time.ParseDuration(env.Get(EnvAPIClusterDeadline, kvs.GetWithDefault(apiClusterDeadline, DefaultKVS)))
    	if err != nil {
    		return cfg, err
    	}
    	cfg.ClusterDeadline = clusterDeadline
    
    	remoteTransportDeadline, err := time.ParseDuration(env.Get(EnvAPIRemoteTransportDeadline, kvs.GetWithDefault(apiRemoteTransportDeadline, DefaultKVS)))
    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. internal/config/batch/batch.go

    	cfg.ExpirationWorkersWait = 0
    
    	rduration, err := time.ParseDuration(env.Get(EnvReplicationWorkersWait, kvs.GetWithDefault(ReplicationWorkersWait, DefaultKVS)))
    	if err != nil {
    		return cfg, err
    	}
    	if rduration < 0 {
    		return cfg, config.ErrInvalidBatchReplicationWorkersWait(nil)
    	}
    
    	kduration, err := time.ParseDuration(env.Get(EnvKeyRotationWorkersWait, kvs.GetWithDefault(KeyRotationWorkersWait, DefaultKVS)))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  3. internal/config/drive/drive.go

    	d := env.Get(EnvMaxDriveTimeout, env.Get(EnvMaxDriveTimeoutLegacy, env.Get(EnvMaxDiskTimeoutLegacy, kvs.GetWithDefault(MaxTimeout, DefaultKVS))))
    	if d == "" {
    		cfg.MaxTimeout = 30 * time.Second
    	} else {
    		dur, _ := time.ParseDuration(d)
    		if dur < time.Second {
    			cfg.MaxTimeout = 30 * time.Second
    		} else {
    			cfg.MaxTimeout = getMaxTimeout(dur)
    		}
    	}
    	return cfg, err
    }
    
    func getMaxTimeout(t time.Duration) time.Duration {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3K bytes
    - Viewed (0)
  4. internal/logger/config.go

    		retryInterval, err := time.ParseDuration(retryIntervalCfgVal)
    		if err != nil {
    			return cfg, err
    		}
    		if retryInterval > time.Minute {
    			return cfg, fmt.Errorf("maximum allowed value for retry interval is '1m': %s", retryIntervalCfgVal)
    		}
    
    		httpTimeoutCfgVal := getCfgVal(EnvAuditWebhookHTTPTimeout, k, kv.Get(httpTimeout))
    		httpTimeout, err := time.ParseDuration(httpTimeoutCfgVal)
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 20 16:02:50 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  5. internal/config/scanner/scanner.go

    		maxWait = env.Get(EnvMaxWait, kvs.GetWithDefault(MaxWait, DefaultKVS))
    	}
    	cfg.MaxWait, err = time.ParseDuration(maxWait)
    	if err != nil {
    		return err
    	}
    	cycle := env.Get(EnvCycle, kvs.GetWithDefault(Cycle, DefaultKVS))
    	if cycle == "" {
    		cycle = "1m"
    	}
    	cfg.Cycle, err = time.ParseDuration(cycle)
    	if err != nil {
    		return err
    	}
    	return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  6. internal/config/callhome/callhome.go

    		return cfg, err
    	}
    
    	cfg.Enable = env.Get(config.EnvMinIOCallhomeEnable,
    		kvs.GetWithDefault(Enable, DefaultKVS)) == config.EnableOn
    	cfg.Frequency, err = time.ParseDuration(env.Get(config.EnvMinIOCallhomeFrequency,
    		kvs.GetWithDefault(Frequency, DefaultKVS)))
    	return cfg, err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  7. internal/config/heal/heal.go

    	if _, err = parseBitrotConfig(bitrot); err != nil {
    		return cfg, fmt.Errorf("'heal:bitrotscan' value invalid: %w", err)
    	}
    
    	cfg.Bitrot = bitrot
    
    	cfg.Sleep, err = time.ParseDuration(env.Get(EnvSleep, kvs.GetWithDefault(Sleep, DefaultKVS)))
    	if err != nil {
    		return cfg, fmt.Errorf("'heal:max_sleep' value invalid: %w", err)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  8. cmd/signature-v4-parser.go

    	if e != nil {
    		return psv, ErrMalformedPresignedDate
    	}
    
    	// Save expires in native time.Duration.
    	preSignV4Values.Expires, e = time.ParseDuration(query.Get(xhttp.AmzExpires) + "s")
    	if e != nil {
    		return psv, ErrMalformedExpires
    	}
    
    	if preSignV4Values.Expires < 0 {
    		return psv, ErrNegativeExpires
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  9. cmd/admin-handlers.go

    	ctx := r.Context()
    
    	objectAPI, _ := validateAdminReq(ctx, w, r, policy.ServerInfoAdminAction)
    	if objectAPI == nil {
    		return
    	}
    	const defaultMetricsInterval = time.Second
    
    	interval, err := time.ParseDuration(r.Form.Get("interval"))
    	if err != nil || interval < time.Second {
    		interval = defaultMetricsInterval
    	}
    
    	n, err := strconv.Atoi(r.Form.Get("n"))
    	if err != nil || n <= 0 {
    		n = math.MaxInt32
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  10. docs/debugging/s3-verify/main.go

    	if err != nil {
    		log.Fatalln(err)
    	}
    	if insecure {
    		// skip TLS verification
    		stransport.TLSClientConfig.InsecureSkipVerify = true
    	}
    
    	ageDelta, err := time.ParseDuration(minimumObjectAge)
    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	maxObjectModTime := time.Now().Add(-ageDelta)
    
    	// Next object is used to ignore new objects in the source & target
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 22 15:12:47 UTC 2022
    - 8.4K bytes
    - Viewed (0)
Back to top