- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for AsDuration (0.17 sec)
-
src/log/slog/value_access_benchmark_test.go
ii = v } else if v, ok := kv.AsUint64(); ok { u = v } else if v, ok := kv.AsFloat64(); ok { f = v } else if v, ok := kv.AsBool(); ok { bb = v } else if v, ok := kv.AsDuration(); ok { d = v } else if v, ok := kv.AsAny(); ok { a = v } else { panic("bad kind") } } } _ = ii _ = s _ = bb _ = u _ = d _ = f _ = a
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 21 20:55:33 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/config/validation/agent/validation.go
return err } err := ValidateDurationRange(timeout.AsDuration(), connectTimeoutMin, connectTimeoutMax) return err } // ValidateProtocolDetectionTimeout validates the envoy protocol detection timeout func ValidateProtocolDetectionTimeout(timeout *durationpb.Duration) error { dur := timeout.AsDuration() // 0s is a valid value if trying to disable protocol detection timeout
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 30.9K bytes - Viewed (0) -
pilot/pkg/security/authn/policy_applier.go
}, } } else if features.JwksFetchMode == jwt.Hybrid { provider.JwksSourceSpecifier = push.JwtKeyResolver.BuildLocalJwks(jwtRule.JwksUri, jwtRule.Issuer, "", timeout.AsDuration()) } else { model.IncLookupClusterFailures("jwks") // Log error and create remote JWKs with fake cluster authnLog.Errorf("Failed to look up Envoy cluster %v. "+
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 19.2K bytes - Viewed (0) -
pkg/envoy/proxy.go
proxyLocalAddressType := "v4" if network.AllIPv6(e.NodeIPs) { proxyLocalAddressType = "v6" } startupArgs := []string{ "-c", fname, "--drain-time-s", fmt.Sprint(int(e.DrainDuration.AsDuration().Seconds())), "--drain-strategy", "immediate", // Clients are notified as soon as the drain process starts. "--local-address-ip-version", proxyLocalAddressType,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 10:02:56 UTC 2024 - 6.9K bytes - Viewed (0) -
pkg/kube/inject/template.go
func env(key string, def string) string { val := os.Getenv(key) if val == "" { return def } return val } func formatDuration(in *durationpb.Duration) string { return in.AsDuration().String() } func isset(m map[string]string, key string) bool { _, ok := m[key] return ok } func directory(filepath string) string { dir, _ := path.Split(filepath) return dir }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 16 02:12:03 UTC 2023 - 9.9K bytes - Viewed (0) -
pkg/bootstrap/option/convert.go
b, err := json.Marshal(d) return string(b), err } } func durationConverter(value *durationpb.Duration) convertFunc { return func(*instance) (any, error) { return value.AsDuration().String(), nil } } // openCensusAgentContextConverter returns a converter that returns the list of // distributed trace contexts to propagate with envoy.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 00:35:05 UTC 2024 - 10.2K bytes - Viewed (0) -
pkg/wasm/convert.go
// This is always 30s, because the timeout is set by the control plane when converted to WasmPluginWrapper. // see buildDataSource() in pilot/pkg/model/extensions.go timeout = remote.GetHttpUri().Timeout.AsDuration() } f, err := cache.Get(httpURI.GetUri(), GetOptions{ Checksum: remote.Sha256, ResourceName: resourceName, ResourceVersion: resourceVersion, RequestTimeout: timeout,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 13.3K bytes - Viewed (0) -
pilot/pkg/model/telemetry.go
}) for i := range ct.Metrics { if ct.Metrics[i].ReportingInterval != nil && other.Metrics[i].ReportingInterval != nil { if ct.Metrics[i].ReportingInterval.AsDuration() != other.Metrics[i].ReportingInterval.AsDuration() { return false } } if ct.Metrics[i].Providers != nil && other.Metrics[i].Providers != nil { if ct.Metrics[i].Providers[0].Name != other.Metrics[i].Providers[0].Name {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 18:14:09 UTC 2024 - 35.2K bytes - Viewed (0) -
pkg/istio-agent/agent.go
// used. a.envoyOpts.AgentIsRoot = os.Getuid() == 0 && strings.HasSuffix(a.cfg.DNSAddr, ":53") envoyProxy := envoy.NewProxy(a.envoyOpts) drainDuration := a.proxyConfig.TerminationDrainDuration.AsDuration() localHostAddr := localHostIPv4 if a.cfg.IsIPv6 { localHostAddr = localHostIPv6 } a.envoyAgent = envoy.NewAgent(envoyProxy, drainDuration, a.cfg.MinimumDrainDuration, localHostAddr,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 10:02:56 UTC 2024 - 26.7K bytes - Viewed (0) -
pilot/pkg/networking/core/route/route.go
// gRPC requests time out like any other requests using timeout or its default. // Use deprecated value for now as the replacement MaxStreamDuration has some regressions. // nolint: staticcheck if action.Timeout.AsDuration().Nanoseconds() == 0 { action.MaxGrpcTimeout = Notimeout } else { action.MaxGrpcTimeout = action.Timeout } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 56.1K bytes - Viewed (0)