Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 156 for Dialer (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top