- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 4,315 for watt (0.05 sec)
-
security/pkg/pki/util/keycertbundle_test.go
}, "RSA Success": { caCertFile: certChainFile1, caKeyFile: keyFile1, certChainFile: nil, rootCertFile: rootCertFile1, certOptions: &CertOptions{ Host: "watt", TTL: 100 * 365 * 24 * time.Hour, Org: "Juju org", IsCA: false, RSAKeySize: 2048, }, expectedErr: "", }, "No SAN EC": { caCertFile: ecRootCertFile,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Jan 21 06:07:50 UTC 2024 - 15.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/wait.go
// NeverStop may be passed to Until to make it never stop. var NeverStop <-chan struct{} = make(chan struct{}) // Group allows to start a group of goroutines and wait for their completion. type Group struct { wg sync.WaitGroup } func (g *Group) Wait() { g.wg.Wait() } // StartWithChannel starts f in a new goroutine in the group. // stopCh is passed to f as an argument. f should stop when stopCh is available.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 7.1K bytes - Viewed (0) -
operator/pkg/helmreconciler/wait.go
"k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/client-go/kubernetes" kctldeployment "k8s.io/kubectl/pkg/util/deployment" "istio.io/istio/operator/pkg/name" "istio.io/istio/operator/pkg/object" "istio.io/istio/operator/pkg/util/progress" "istio.io/istio/pkg/kube" ) const ( // defaultWaitResourceTimeout is the maximum wait time for all resources(namespace/deployment/pod) to be created.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 08 03:13:12 UTC 2023 - 13.1K bytes - Viewed (0) -
pilot/cmd/pilot-agent/app/wait.go
waitCmd.PersistentFlags().IntVar(&timeoutSeconds, "timeoutSeconds", 60, "maximum number of seconds to wait for Envoy to be ready") waitCmd.PersistentFlags().IntVar(&requestTimeoutMillis, "requestTimeoutMillis", 500, "number of milliseconds to wait for response") waitCmd.PersistentFlags().IntVar(&periodMillis, "periodMillis", 500, "number of milliseconds to wait between attempts")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.5K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/wait.go
return nil } // WaitForPodsWithLabel will lookup pods with the given label and wait until they are all // reporting status as running. func (w *KubeWaiter) WaitForPodsWithLabel(kvLabel string) error { lastKnownPodNumber := -1 return wait.PollUntilContextTimeout(context.Background(), constants.KubernetesAPICallRetryInterval, w.timeout,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 13.3K bytes - Viewed (0) -
istioctl/pkg/wait/wait.go
istioctl experimental wait --for=distribution virtualservice bookinfo.default # Wait until the bookinfo virtual service has been distributed to a specific proxy istioctl experimental wait --for=distribution virtualservice bookinfo.default --proxy workload-instance.namespace # Wait until 99% of the proxies receive the distribution, timing out after 5 minutes
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 17 12:24:17 UTC 2024 - 10.1K bytes - Viewed (1) -
src/internal/trace/testdata/testprog/wait-on-pipe.go
time.Sleep(100 * time.Millisecond) // Write to the pipe to unblock it. if _, err := syscall.Write(wfd, []byte{10}); err != nil { log.Fatalf("failed to write to pipe: %v", err) } // Wait for the goroutine to unblock and start running. // This is helpful to catch incorrect information written // down for the syscall-blocked goroutine, since it'll start // executing, and that execution information will be
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.6K bytes - Viewed (0) -
releasenotes/notes/wait-when-distribution-tracing-disabled.yaml
apiVersion: release-notes/v2 kind: bug-fix area: istioctl releaseNotes: - |
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 17 03:43:40 UTC 2023 - 212 bytes - Viewed (0) -
src/os/exec/exec_test.go
} cmd = helperCommand(t, "exit", "255") cmd.Run() want = 255 if runtime.GOOS == "plan9" { want = 1 } got = cmd.ProcessState.ExitCode() if want != got { t.Errorf("ExitCode got %d, want %d", got, want) } cmd = helperCommand(t, "cat") cmd.Run() want = 0 got = cmd.ProcessState.ExitCode() if want != got { t.Errorf("ExitCode got %d, want %d", got, want) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:53 UTC 2024 - 48.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress_test.go
}); err != nil { t.Fatalf("Failed to wait progress requests, err: %s, want: %d , got %d", err, wantRequestsSent, requestsSent) } pr.Add() clock.Step(progressRequestPeriod * 2) if err := pollConditionNoChange(pollPeriod, minimalNoChange, pollTimeout, func() bool { requestsSent = pr.progressRequestsSentCount.Load() return requestsSent == wantRequestsSent }); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 11:51:06 UTC 2024 - 4.6K bytes - Viewed (0)