Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for mcpTransport (0.22 sec)

  1. istioctl/pkg/kubeinject/google.go

    )
    
    func isMCPAddr(addr string) bool {
    	// A bit inexact but should be good enough.
    	return strings.Contains(addr, ".googleapis.com/") || strings.Contains(addr, ".googleapis.com:443/")
    }
    
    func mcpTransport(ctx context.Context, tr http.RoundTripper) (http.RoundTripper, error) {
    	creds, err := google.FindDefaultCredentials(ctx, "https://www.googleapis.com/auth/cloud-platform")
    	if err != nil {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Thu Jun 15 15:02:17 GMT 2023
    - 1.2K bytes
    - Viewed (0)
  2. istioctl/pkg/kubeinject/kubeinject.go

    				f.WaitForStop()
    			}()
    		}
    		tlsClientConfig.ServerName = fmt.Sprintf("%s.%s.%s", cc.Service.Name, cc.Service.Namespace, "svc")
    	} else if isMCPAddr(address) {
    		var err error
    		client.Transport, err = mcpTransport(context.TODO(), client.Transport)
    		if err != nil {
    			return nil, err
    		}
    	}
    	podBytes, err := json.Marshal(pod)
    	if pod.Namespace != "" {
    		deploymentNS = pod.Namespace
    	}
    	if err != nil {
    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