Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ParseDuration (0.12 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/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)
  3. internal/config/notify/parse.go

    		}
    		reconnectInterval, err := time.ParseDuration(env.Get(reconnectIntervalEnv,
    			kv.Get(target.MqttReconnectInterval)))
    		if err != nil {
    			return nil, err
    		}
    
    		keepAliveIntervalEnv := target.EnvMQTTKeepAliveInterval
    		if k != config.Default {
    			keepAliveIntervalEnv = keepAliveIntervalEnv + config.Default + k
    		}
    		keepAliveInterval, err := time.ParseDuration(env.Get(keepAliveIntervalEnv,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  4. internal/config/identity/openid/openid.go

    // GetDefaultExpiration - returns the expiration seconds expected.
    func GetDefaultExpiration(dsecs string) (time.Duration, error) {
    	timeout := env.Get(config.EnvMinioStsDuration, "")
    	defaultExpiryDuration, err := time.ParseDuration(timeout)
    	if err != nil {
    		defaultExpiryDuration = time.Hour
    	}
    	if timeout == "" && dsecs != "" {
    		expirySecs, err := strconv.ParseInt(dsecs, 10, 64)
    		if err != nil {
    			return 0, auth.ErrInvalidDuration
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 10 20:16:44 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  5. cmd/bucket-replication-handlers.go

    	resetID := r.URL.Query().Get("reset-id")
    	if resetID == "" {
    		resetID = mustGetUUID()
    	}
    	var (
    		days time.Duration
    		err  error
    	)
    	if durationStr != "" {
    		days, err = time.ParseDuration(durationStr)
    		if err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, InvalidArgument{
    				Bucket: bucket,
    				Err:    fmt.Errorf("invalid query parameter older-than %s for %s : %w", durationStr, bucket, err),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  6. cmd/admin-handlers-site-replication.go

    // [POST] /minio/admin/v3/site-replication/netperf
    func (a adminAPIHandlers) SiteReplicationNetPerf(w http.ResponseWriter, r *http.Request) {
    	durationStr := r.Form.Get(peerRESTDuration)
    	duration, _ := time.ParseDuration(durationStr)
    	if duration < globalNetPerfMinDuration {
    		duration = globalNetPerfMinDuration
    	}
    	result := siteNetperf(r.Context(), duration)
    	adminLogIf(r.Context(), gob.NewEncoder(w).Encode(result))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 19.4K bytes
    - Viewed (0)
Back to top