Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 64 for ParseDuration (0.35 sec)

  1. src/flag/example_test.go

    	//	-deltaT 10s -deltaT 15s
    	// and other combinations.
    	if len(*i) > 0 {
    		return errors.New("interval flag already set")
    	}
    	for _, dt := range strings.Split(value, ",") {
    		duration, err := time.ParseDuration(dt)
    		if err != nil {
    			return err
    		}
    		*i = append(*i, duration)
    	}
    	return nil
    }
    
    // Define a flag to accumulate durations. Because it has a special type,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Oct 26 18:59:00 UTC 2022
    - 2.8K bytes
    - Viewed (0)
  2. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  3. samples/jwt-server/src/main.go

    	// Add artificious delay based on delay query
    	delayParam := request.URL.Query().Get("delay")
    	if delayParam != "" {
    		delayDuration, err := time.ParseDuration(delayParam)
    		if err != nil {
    			// Handle invalid delay parameter
    			response.WriteHeader(http.StatusBadRequest)
    			response.Write([]byte("Invalid delay parameter"))
    			return
    		}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 16 23:56:50 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  4. pkg/util/coverage/coverage.go

    	fmt.Println("Dumping coverage information to " + coverageFile)
    
    	flushInterval := 5 * time.Second
    	requestedInterval := os.Getenv("KUBE_COVERAGE_FLUSH_INTERVAL")
    	if requestedInterval != "" {
    		if duration, err := time.ParseDuration(requestedInterval); err == nil {
    			flushInterval = duration
    		} else {
    			panic("Invalid KUBE_COVERAGE_FLUSH_INTERVAL value; try something like '30s'.")
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 05 21:00:21 UTC 2022
    - 3.2K bytes
    - Viewed (0)
  5. src/cmd/trace/tasks.go

    			return !task.Complete()
    		})
    	}
    	if lat, err := time.ParseDuration(r.FormValue("latmin")); err == nil {
    		name = append(name, fmt.Sprintf("latency >= %s", lat))
    		conditions = append(conditions, func(t *parsedTrace, task *trace.UserTaskSummary) bool {
    			return task.Complete() && taskInterval(t, task).duration() >= lat
    		})
    	}
    	if lat, err := time.ParseDuration(r.FormValue("latmax")); err == nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/validation/formats.go

    	"password",     // any kind of string
    	"date",         // a date string like "2006-01-02" as defined by full-date in RFC3339
    	"duration",     // a duration string like "22 ns" as parsed by Golang time.ParseDuration or compatible with Scala duration format
    	"datetime",     // a date time string like "2014-12-15T19:30:20.000Z" as defined by date-time in RFC3339
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 09 09:26:38 UTC 2020
    - 3.3K bytes
    - Viewed (0)
  7. pkg/test/csrctrl/controllers/csr_controller.go

    			return nil
    		}
    
    		requestedLifeTime := signer.CertTTL
    		requestedDuration, ok := csr.Annotations[RequestLifeTimeAnnotationForCertManager]
    		if ok {
    			duration, err := time.ParseDuration(requestedDuration)
    			if err == nil {
    				requestedLifeTime = duration
    			}
    		}
    		cert, err := signer.Sign(x509cr, csr.Spec.Usages, requestedLifeTime, false)
    		if err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 24 17:36:41 UTC 2023
    - 3.9K bytes
    - Viewed (0)
  8. src/time/time_test.go

    }
    
    func TestParseDurationErrors(t *testing.T) {
    	for _, tc := range parseDurationErrorTests {
    		_, err := ParseDuration(tc.in)
    		if err == nil {
    			t.Errorf("ParseDuration(%q) = _, nil, want _, non-nil", tc.in)
    		} else if !strings.Contains(err.Error(), tc.expect) {
    			t.Errorf("ParseDuration(%q) = _, %q, error does not contain %q", tc.in, err, tc.expect)
    		}
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:13:47 UTC 2024
    - 56.5K bytes
    - Viewed (0)
  9. pilot/pkg/networking/core/networkfilter.go

    	includeMx bool,
    ) []*listener.Filter {
    	idleTimeout := destinationRule.GetTrafficPolicy().GetConnectionPool().GetTcp().GetIdleTimeout()
    	if idleTimeout == nil {
    		idleTimeout = parseDuration(lb.node.Metadata.IdleTimeout)
    	}
    	tcpProxy := &tcp.TcpProxy{
    		StatPrefix:                      statPrefix,
    		ClusterSpecifier:                &tcp.TcpProxy_Cluster{Cluster: clusterName},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  10. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.9K bytes
    - Viewed (0)
Back to top