- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for kuwait (0.17 sec)
-
operator/cmd/mesh/manifest_shared_test.go
// CRDs are not in the prune list, but must be considered for tests. allClusterGVKs = helmreconciler.ClusterResources ) func init() { if kubeBuilderInstalled() { // TestMode is required to not wait in the go client for resources that will never be created in the test server. helmreconciler.TestMode = true // Add install and controller to the list of commands to run tests against.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (1) -
cni/pkg/nodeagent/informers_test.go
constants.DataplaneModeLabel, constants.DataplaneModeAmbient)), metav1.PatchOptions{}) assert.NoError(t, err) // wait for an update event mt.Assert(EventTotals.Name(), map[string]string{"type": "update"}, monitortest.AtLeast(2)) // wait for the pod to be annotated // after Pod annotated, another update event will be triggered. assertPodAnnotated(t, client, pod)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
cni/test/install_cni.go
viper.Set(constants.LogUDSAddress, "") viper.Set(constants.RepairEnabled, false) ctx, cancel := context.WithCancel(context.Background()) wg := sync.WaitGroup{} wg.Add(1) defer func() { cancel() wg.Wait() }() go func() { runInstall(ctx, tempCNIConfDir, tempCNIBinDir, tempK8sSvcAcctDir, envPreconf, filepath.Join(env.IstioSrc, "cni/test/testdata/bindir"), chainedCNIPlugin, t) wg.Done() }()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.4K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
err := z.u.SetWriteDeadline(time.Now().Add(readWriteDeadline)) if err != nil { return nil, err } _, _, err = z.u.WriteMsgUnix(data, rights, nil) if err != nil { return nil, err } // wait for ack return z.readMessage(readWriteDeadline) } func (z *ZtunnelConnection) readMessage(timeout time.Duration) (*zdsapi.WorkloadResponse, error) { m, _, err := readProto[zdsapi.WorkloadResponse](z.u, timeout, nil)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
ClosePortForwarderOnInterrupt(fw) log.Debugf(fmt.Sprintf("port-forward to %s pod ready", flavor)) openBrowser(fmt.Sprintf(urlFormat, fw.Address()), writer, browser) // Wait for stop fw.WaitForStop() return nil } return fmt.Errorf("failure running port forward process: %v", err) } func ClosePortForwarderOnInterrupt(fw kube.PortForwarder) { go func() {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
operator/cmd/mesh/install.go
"istio.io/istio/pkg/kube" ) type InstallArgs struct { // InFilenames is an array of paths to the input IstioOperator CR files. InFilenames []string // ReadinessTimeout is maximum time to wait for all Istio resources to be ready. wait must be true for this setting // to take effect. ReadinessTimeout time.Duration // SkipConfirmation determines whether the user is prompted for confirmation.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 14:30:43 GMT 2024 - 15.5K bytes - Viewed (1) -
istioctl/pkg/admin/istiodconfig.go
wg.Add(1) go func(si *ScopeInfo) { defer wg.Done() err := c.PutScope(si) ch <- struct { err error scopeName string }{err: err, scopeName: si.Name} }(scope) } wg.Wait() close(ch) for result := range ch { if result.err != nil { return fmt.Errorf("failed updating Scope %s: %v", result.scopeName, result.err) } } return nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 13.5K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
Example: ` # Apply a waypoint to the current namespace istioctl x waypoint apply # Apply a waypoint to a specific namespace and wait for it to be ready istioctl x waypoint apply --namespace default --wait`, RunE: func(cmd *cobra.Command, args []string) error { kubeClient, err := ctx.CLIClientWithRevision(revision) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 19:45:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cni/pkg/install/install_test.go
if isReady.Load().(bool) { readyChan <- true } } } }(ctx, ticker.C) // Listen to sleepWatchInstall return value // Should detect a valid configuration and wait indefinitely for a file modification errChan := make(chan error) go func(ctx context.Context) { errChan <- in.sleepWatchInstall(ctx, sets.String{}) }(ctx) select { case <-readyChan:
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 11.1K bytes - Viewed (0)