- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 156 for Dialer (0.12 sec)
-
pkg/test/framework/components/echo/kube/instance.go
filtered = true break } } if !filtered { final = append(final, wl) } } return final, nil } func (c *instance) WorkloadsOrFail(t test.Failer) echo.Workloads { t.Helper() out, err := c.Workloads() if err != nil { t.Fatal(err) } return out } func (c *instance) MustWorkloads() echo.Workloads { out, err := c.Workloads()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 16 18:55:23 UTC 2023 - 9K bytes - Viewed (0) -
src/math/big/prime_test.go
"6084766654921918907427900243509372380954290099172559290432744450051395395951", "84594350493221918389213352992032324280367711247940675652888030554255915464401", "82793403787388584738507275144194252681", // Arnault, "Rabin-Miller Primality Test: Composite Numbers Which Pass It", // Mathematics of Computation, 64(209) (January 1995), pp. 335-361. "1195068768795265792518361315725116351898245581", // strong pseudoprime to prime bases 2 through 29
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 12:54:00 UTC 2019 - 7.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/fake.go
SkipRun bool ConfigCluster bool SystemNamespace string } type FakeController struct { *Controller Endpoints *model.EndpointIndex } func NewFakeControllerWithOptions(t test.Failer, opts FakeControllerOptions) (*FakeController, *xdsfake.Updater) { xdsUpdater := opts.XDSUpdater var endpoints *model.EndpointIndex if xdsUpdater == nil { endpoints = model.NewEndpointIndex(model.DisabledCache{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 4K bytes - Viewed (0) -
cmd/background-heal-ops.go
maxIO, maxWait, _ := globalHealConfig.Clone() waitForLowIO(maxIO, maxWait, currentHTTPIO) } func initBackgroundHealing(ctx context.Context, objAPI ObjectLayer) { bgSeq := newBgHealSequence() // Run the background healer for i := 0; i < globalBackgroundHealRoutine.workers; i++ { go globalBackgroundHealRoutine.AddWorker(ctx, objAPI, bgSeq) } globalBackgroundHealState.LaunchNewHealSequence(bgSeq, objAPI) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/grpc_service.go
c, err := net.DialUnix(unixProtocol, nil, &net.UnixAddr{Name: addr}) if err != nil { klog.ErrorS(err, "failed to create connection to unix socket", "addr", addr) } else { klog.V(4).InfoS("Successfully dialed Unix socket", "addr", addr) } return c, err })) if err != nil { return nil, fmt.Errorf("failed to create connection to %s, error: %v", endpoint, err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 00:47:46 UTC 2023 - 4.4K bytes - Viewed (0) -
pkg/test/framework/components/istioctl/kube.go
scopes.Framework.Infof("istioctl error: %v", strings.TrimSpace(err.String())) } return out.String(), err.String(), fErr } // InvokeOrFail implements Instance func (c *kubeComponent) InvokeOrFail(t test.Failer, args []string) (string, string) { output, stderr, err := c.Invoke(args) if err != nil { t.Logf("Unwanted exception for 'istioctl %s': %v", strings.Join(args, " "), err) t.Logf("Output:\n%v", output)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 29 02:29:02 UTC 2024 - 3.7K bytes - Viewed (0) -
pkg/test/util/yml/apply.go
} return string(resYaml), nil } // MustApplyNamespace applies the given namespaces to the resources in the yamlText if not set. func MustApplyNamespace(t test.Failer, yamlText, ns string) string { y, err := ApplyNamespace(yamlText, ns) if err != nil { t.Fatalf("ApplyNamespace: %v for text %v", err, yamlText) } return y }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 17 07:02:38 UTC 2023 - 3.8K bytes - Viewed (0) -
src/math/big/example_test.go
a.Add(a, b) // Swap a and b so that b is the next number in the sequence. a, b = b, a } fmt.Println(a) // 100-digit Fibonacci number // Test a for primality. // (ProbablyPrimes' argument sets the number of Miller-Rabin // rounds to be performed. 20 is a good value.) fmt.Println(a.ProbablyPrime(20)) // Output: // 1344719667586153181419716641724567886890850696275767987106294472017884974410332069524504824747437757 // false
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Aug 26 16:15:32 UTC 2020 - 4K bytes - Viewed (0) -
pkg/util/filesystem/util_windows.go
klog.V(6).InfoS("Dialing the socket", "filePath", filePath) var c net.Conn c, lastSocketErr = net.Dial("unix", filePath) if lastSocketErr == nil { c.Close() klog.V(6).InfoS("Socket dialed successfully", "filePath", filePath) return true, nil } klog.V(6).InfoS("Failed the current attempt to dial the socket, so pausing before retry", "filePath", filePath, "err", lastSocketErr, "socketDialRetryPeriod",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 10 17:13:59 UTC 2024 - 4K bytes - Viewed (0) -
pkg/test/framework/components/echo/instances.go
return nil, err } out = append(out, ws...) } if len(out) == 0 { return nil, errors.New("got 0 workloads") } return out, nil } func (i Instances) WorkloadsOrFail(t test.Failer) Workloads { t.Helper() out, err := i.Workloads() if err != nil { t.Fatal(err) } return out } func (i Instances) MustWorkloads() Workloads { out, err := i.Workloads()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 25 18:26:17 UTC 2024 - 4.7K bytes - Viewed (0)