- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,963 for watt (0.09 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) -
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) -
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/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/storagebackend/factory/factory_test.go
healthcheck, err := CreateHealthCheck(tc.cfg, stop) if err != nil { t.Fatal(err) } // Wait for healthcheck to establish connection <-ready got := healthcheck() if !errors.Is(got, tc.want) { t.Errorf("healthcheck() missmatch want %v got %v", tc.want, got) } }) } } func TestCreateReadycheck(t *testing.T) { etcdConfig := testserver.NewTestConfig(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 29 15:58:10 UTC 2022 - 12.1K bytes - Viewed (0) -
src/net/lookup_test.go
defer dnsWaitGroup.Wait() txts, err := LookupTXT("golang.rsc.io") if err != nil { t.Fatal(err) } slices.Sort(txts) want := []string{ strings.Repeat("abcdefghijklmnopqrstuvwxyABCDEFGHJIKLMNOPQRSTUVWXY", 10), "gophers rule", } if !reflect.DeepEqual(txts, want) { t.Fatalf("LookupTXT golang.rsc.io incorrect\nhave %q\nwant %q", txts, want) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 41.4K bytes - Viewed (0) -
src/vendor/golang.org/x/net/nettest/conntest.go
f(t, c1, c2) } // testBasicIO tests that the data sent on c1 is properly received on c2. func testBasicIO(t *testing.T, c1, c2 net.Conn) { want := make([]byte, 1<<20) rand.New(rand.NewSource(0)).Read(want) dataCh := make(chan []byte) go func() { rd := bytes.NewReader(want) if err := chunkedCopy(c1, rd); err != nil { t.Errorf("unexpected c1.Write error: %v", err) } if err := c1.Close(); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 12.2K bytes - Viewed (0) -
src/cmd/go/internal/script/engine.go
// This error was surfaced from a background process by a call to Wait. // Add a call frame for Wait itself, but ignore its "want" field. // (Wait itself cannot fail to wait on commands or else it would leak // processes and/or goroutines — so a negative assertion for it would be at // best ambiguous.) return cmdError(cmd, err) } if cmd.want == success { return cmdError(cmd, err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 27 01:16:19 UTC 2023 - 22.2K bytes - Viewed (0) -
src/net/sendfile_test.go
c, err := Dial("tcp", ln.Addr().String()) if err != nil { t.Fatal(err) } defer c.Close() buf := new(bytes.Buffer) buf.ReadFrom(c) if want, have := "Produced ", buf.String(); have != want { t.Errorf("unexpected server reply %q, want %q", have, want) } for err := range errc { t.Error(err) } } func TestSendfileSeeked(t *testing.T) { ln := newLocalListener(t, "tcp")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 12.1K bytes - Viewed (0)