mirror of
				https://github.com/k3s-io/kubernetes.git
				synced 2025-10-31 05:40:42 +00:00 
			
		
		
		
	godep restore pushd $GOPATH/src/github.com/appc/spec git co master popd go get go4.org/errorutil rm -rf Godeps godep save ./... git add vendor git add -f $(git ls-files --other vendor/) git co -- Godeps/LICENSES Godeps/.license_file_state Godeps/OWNERS
		
			
				
	
	
		
			52 lines
		
	
	
		
			1.1 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			52 lines
		
	
	
		
			1.1 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
| package sockets
 | |
| 
 | |
| import (
 | |
| 	"net"
 | |
| 	"net/url"
 | |
| 	"os"
 | |
| 	"strings"
 | |
| 
 | |
| 	"golang.org/x/net/proxy"
 | |
| )
 | |
| 
 | |
| // GetProxyEnv allows access to the uppercase and the lowercase forms of
 | |
| // proxy-related variables.  See the Go specification for details on these
 | |
| // variables. https://golang.org/pkg/net/http/
 | |
| func GetProxyEnv(key string) string {
 | |
| 	proxyValue := os.Getenv(strings.ToUpper(key))
 | |
| 	if proxyValue == "" {
 | |
| 		return os.Getenv(strings.ToLower(key))
 | |
| 	}
 | |
| 	return proxyValue
 | |
| }
 | |
| 
 | |
| // DialerFromEnvironment takes in a "direct" *net.Dialer and returns a
 | |
| // proxy.Dialer which will route the connections through the proxy using the
 | |
| // given dialer.
 | |
| func DialerFromEnvironment(direct *net.Dialer) (proxy.Dialer, error) {
 | |
| 	allProxy := GetProxyEnv("all_proxy")
 | |
| 	if len(allProxy) == 0 {
 | |
| 		return direct, nil
 | |
| 	}
 | |
| 
 | |
| 	proxyURL, err := url.Parse(allProxy)
 | |
| 	if err != nil {
 | |
| 		return direct, err
 | |
| 	}
 | |
| 
 | |
| 	proxyFromURL, err := proxy.FromURL(proxyURL, direct)
 | |
| 	if err != nil {
 | |
| 		return direct, err
 | |
| 	}
 | |
| 
 | |
| 	noProxy := GetProxyEnv("no_proxy")
 | |
| 	if len(noProxy) == 0 {
 | |
| 		return proxyFromURL, nil
 | |
| 	}
 | |
| 
 | |
| 	perHost := proxy.NewPerHost(proxyFromURL, direct)
 | |
| 	perHost.AddFromString(noProxy)
 | |
| 
 | |
| 	return perHost, nil
 | |
| }
 |