- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 102 for Retries (0.36 sec)
-
pkg/config/validation/validation.go
return } func validateHTTPRetry(retries *networking.HTTPRetry) (errs error) { if retries == nil { return } if retries.Attempts < 0 { errs = multierror.Append(errs, errors.New("attempts cannot be negative")) } if retries.Attempts == 0 && (retries.PerTryTimeout != nil || retries.RetryOn != "" || retries.RetryRemoteLocalities != nil) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 04:03:33 UTC 2024 - 107.2K bytes - Viewed (0) -
src/net/http/serve_test.go
// // To avoid that problem, we explicitly forbid internal retries by rejecting // them in a Proxy hook in the transport. var retries atomic.Int32 cst.c.Transport.(*Transport).Proxy = func(*Request) (*url.URL, error) { if retries.Add(1) != 1 { return nil, errors.New("too many retries") } return nil, nil } res, err := cst.c.Get(cst.ts.URL) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
operator/cmd/mesh/testdata/manifest-generate/data-snapshot.tar.gz
.Values.telemetry.enabled .Values.telemetry.v2.enabled .Values.telemetry.v2.prometheus.enabled }} {{- end }} {{/* SD has metrics and logging split. Default metrics are enabled if SD is enabled */}} {{ define "default-sd-metrics" }} {{- and (not .Values.meshConfig.defaultProviders) .Values.telemetry.enabled .Values.telemetry.v2.enabled .Values.telemetry.v2.stackdriver.enabled }} {{- end }} {{/* SD has metrics and logging split. */}} {{ define "default-sd-logs" }} {{- and (not .Values.meshConfig.defaultProviders)...
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 10 05:10:03 UTC 2024 - 198.1K bytes - Viewed (0) -
cluster/gce/gci/configure-helper.sh
# Runs: kubectl label --overwrite nodes -l "${1}" "${2}" # Retries on failure # # $1: label selector of nodes # $2: label to apply function update-node-label() { local selector="$1" local label="$2" local retries=5 until (( retries == 0 )); do if kubectl label --overwrite nodes -l "${selector}" "${label}"; then break fi (( retries-- )) sleep 3 done }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 22:07:47 UTC 2024 - 141.1K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector_test.go
absentOwnerCache: []objectReference{pod1ns1}, // missing parent cached }), // 10,11: observe deletion of good child // steady-state is bad cluster child and bad virtual parent coordinates, with no retries processEvent(makeDeleteEvent(pod2ns1, pod1ns1)), assertState(state{ graphNodes: []*node{ makeNode(node1, withOwners(pod1nonamespace)), makeNode(pod1nonamespace, virtual)},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
// Note that the modules here must not depend on modules that are not initialized here. func (kl *Kubelet) initializeModules() error { // Prometheus metrics. metrics.Register( collectors.NewVolumeStatsCollector(kl), collectors.NewLogMetricsCollector(kl.StatsProvider.ListPodStats), ) metrics.SetNodeName(kl.nodeName) servermetrics.Register() // Setup filesystem directories. if err := kl.setupDataDirs(); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
tests/integration/pilot/common/routing.go
}, }, }, workloadAgnostic: true, }) // Retry conditions have been added to just check that config is correct. // Retries are not specifically tested. TODO if we actually test retries, include proxyless t.RunTraffic(TrafficTestCase{ name: "retry conditions", config: ` apiVersion: networking.istio.io/v1alpha3 kind: VirtualService metadata: name: default
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 21:52:51 UTC 2024 - 135.9K bytes - Viewed (0) -
src/net/http/transport_test.go
c := ts.Client() fetch := func(n, retries int) string { condFatalf := func(format string, arg ...any) { if retries <= 0 { t.Fatalf(format, arg...) } t.Logf("retrying shortly after expected error: "+format, arg...) time.Sleep(time.Second / time.Duration(retries)) } for retries >= 0 { retries-- res, err := c.Get(ts.URL) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
cmd/metrics-v2.go
MetricV2{ Description: getMinioProcessIOReadBytesMD(), Value: float64(io.ReadBytes), }) } if io.WriteBytes > 0 { metrics = append(metrics, MetricV2{ Description: getMinioProcessIOWriteBytesMD(), Value: float64(io.WriteBytes), }) } if io.RChar > 0 { metrics = append(metrics, MetricV2{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:54 UTC 2024 - 131.9K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
fakePodControl.Err = errors.New("Controller error") manager.queue.Add(key) manager.processNextWorkItem(context.TODO()) retries := manager.queue.NumRequeues(key) if retries != 1 { t.Fatalf("%s: expected exactly 1 retry, got %d", job.Name, retries) } // await for the actual requeue after processing of the pending queue is done awaitForQueueLen(ctx, t, manager, 1)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0)