- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 64 for ParseDuration (0.35 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)