Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for WaitForStop (0.22 sec)

  1. istioctl/pkg/cli/mock_client.go

    	return "localhost:3456"
    }
    
    func (m MockPortForwarder) Close() {
    }
    
    func (m MockPortForwarder) ErrChan() <-chan error {
    	return make(chan error)
    }
    
    func (m MockPortForwarder) WaitForStop() {
    }
    
    var _ kube.PortForwarder = MockPortForwarder{}
    
    type MockClient struct {
    	// Results is a map of podName to the results of the expected test on the pod
    	Results map[string][]byte
    	kube.CLIClient
    }
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Mar 08 08:38:19 GMT 2024
    - 2.1K bytes
    - Viewed (0)
  2. 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 Apr 24 22:53:08 GMT 2024
    - Last Modified: Mon Apr 15 01:29:35 GMT 2024
    - 20.5K bytes
    - Viewed (0)
  3. istioctl/pkg/kubeinject/kubeinject.go

    				return nil, err
    			}
    			if err := f.Start(); err != nil {
    				return nil, err
    			}
    			address = fmt.Sprintf("https://%s%s", f.Address(), *cc.Service.Path)
    			defer func() {
    				f.Close()
    				f.WaitForStop()
    			}()
    		}
    		tlsClientConfig.ServerName = fmt.Sprintf("%s.%s.%s", cc.Service.Name, cc.Service.Namespace, "svc")
    	} else if isMCPAddr(address) {
    		var err error
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Mar 29 02:29:02 GMT 2024
    - 21.6K bytes
    - Viewed (0)
Back to top