netproxy

package

v0.0.0-...-7ca97a9 Latest Latest Go to latest Published: Apr 23, 2024 License: Apache-2.0 Imports: 26 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const (
	DefaultDialTimeout   = 2 * time.Second
	DefaultSocketTimeout = 3 * time.Minute
)

View Source

const (
	HttpProxyAddr = "127.0.0.1:9118"
)

View Source

const (
	Socks5ProxyAddr = "127.0.0.1:9119"
)

View Source

var (
	NETPROXY_ENABLED = os.Getenv("NETPROXY_ENABLED") == "true"
	HttpProxyURL, _  = url.Parse(fmt.Sprintf("http://%s", HttpProxyAddr))
)

View Source

var (
	Socks5ProxyURL, _ = url.Parse(fmt.Sprintf("socks5://%s", Socks5ProxyAddr))
)

func AddHttpProxyHandler(handler HttpHandler)

func AddTcpProxyHandler(handler TcpHandler)

func CreateServerInternalErrorResp(req *http.Request, extra string) *http.Response

func HandleHttpProxy(req *http.Request, ctx *goproxy.ProxyCtx) (*http.Request, *http.Response)

func HandleHttpProxyByExec(pod *cri.Pod, req *http.Request, ctx *goproxy.ProxyCtx) (*http.Request, *http.Response)

func HandleHttpProxyByNsenter(pod *cri.Pod, req *http.Request, forceIp string) (*http.Request, *http.Response)

func TcpProxy(ctx context.Context, i cri.Interface, c *cri.Container, addr string, dialTimeout time.Duration) (net.Conn, error)

type CriHandle struct {
	Cri cri.Interface
	// contains filtered or unexported fields
}

CriHandle implements socks5.Handler interface

func (h *CriHandle) Init()

func (h *CriHandle) TCPHandle(s *socks5.Server, c *net.TCPConn, r *socks5.Request) error

TCPHandle handle tcp socks5 proxy request.

func (h *CriHandle) UDPHandle(s *socks5.Server, addr *net.UDPAddr, d *socks5.Datagram) error

UDPHandle auto handle packet. You may prefer to do yourself.

type HttpHandler func(ctx context.Context, pod *cri.Pod, req *http.Request) (*http.Request, *http.Response, error)

type PortForwardTask struct {
	Addr string
}

func (t *PortForwardTask) Start(ctx context.Context) (string, error)

type TcpHandler func(ctx context.Context, i cri.Interface, c *cri.Container, addr string, dialTimeout time.Duration) (net.Conn, error)