proxy

package

v0.29.33 Latest Latest Go to latest Published: Jul 7, 2025 License: GPL-3.0 Imports: 35 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/djylb/nps

Links

Open Source Insights

Documentation ¶

Rendered for

Index ¶

Constants
func HandleTrans(c *conn.Conn, s *TunnelModeServer) error
func IsGlobalBlackIp(ipPort string) bool
func ProcessHttp(c *conn.Conn, s *TunnelModeServer) error
func ProcessMix(c *conn.Conn, s *TunnelModeServer) error
func ProcessTunnel(c *conn.Conn, s *TunnelModeServer) error
type BaseServer
- func NewBaseServer(bridge NetBridge, task *file.Tunnel) *BaseServer
- func (s *BaseServer) CheckFlowAndConnNum(client *file.Client) error
- func (s *BaseServer) DealClient(c *conn.Conn, client *file.Client, addr string, rb []byte, tp string, f func(), ...) error
- func (s *BaseServer) FlowAdd(in, out int64)
- func (s *BaseServer) FlowAddHost(host *file.Host, in, out int64)
type Http3Server
- func NewHttp3Server(httpsSrv *HttpsServer, udpConn net.PacketConn) *Http3Server
- func (h3 *Http3Server) Close() error
- func (h3 *Http3Server) Start() error
type HttpServer
- func NewHttp(bridge NetBridge, task *file.Tunnel, httpPort, httpsPort, http3Port int, ...) *HttpServer
- func (s *HttpServer) Close() error
- func (s *HttpServer) DialContext(ctx context.Context, network, addr string) (net.Conn, error)
- func (s *HttpServer) DialTlsContext(ctx context.Context, network, addr string) (net.Conn, error)
- func (s *HttpServer) NewServer(port int, scheme string) *http.Server
- func (s *HttpServer) Start() error
type HttpsListener
- func NewHttpsListener(l net.Listener) *HttpsListener
- func (httpsListener *HttpsListener) Accept() (net.Conn, error)
- func (httpsListener *HttpsListener) Addr() net.Addr
- func (httpsListener *HttpsListener) Close() error
type HttpsServer
- func NewHttpsServer(l net.Listener, bridge NetBridge, task *file.Tunnel, srv *http.Server, ...) *HttpsServer
- func (https *HttpsServer) Close() error
- func (https *HttpsServer) Start() error
type NetBridge
type P2PServer
- func NewP2PServer(p2pPort int) *P2PServer
- func (s *P2PServer) Start() error
type Service
type TunnelModeServer
- func NewTunnelModeServer(process process, bridge NetBridge, task *file.Tunnel) *TunnelModeServer
- func (s *TunnelModeServer) Auth(c net.Conn) error
- func (s *TunnelModeServer) Close() error
- func (s *TunnelModeServer) Start() error
type UdpModeServer
- func NewUdpModeServer(bridge NetBridge, task *file.Tunnel) *UdpModeServer
- func (s *UdpModeServer) Close() error
- func (s *UdpModeServer) Start() error
type WebServer
- func NewWebServer(bridge *bridge.Bridge) *WebServer
- func (s *WebServer) Close() error
- func (s *WebServer) Start() error

Constants ¶

View Source

const (
	UserPassAuth = uint8(2)
)

Variables ¶

This section is empty.

Functions ¶

func HandleTrans ¶

func HandleTrans(c *conn.Conn, s *TunnelModeServer) error

func IsGlobalBlackIp ¶

func IsGlobalBlackIp(ipPort string) bool

func ProcessHttp ¶

func ProcessHttp(c *conn.Conn, s *TunnelModeServer) error

http proxy

func ProcessMix ¶ added in v0.29.0

func ProcessMix(c *conn.Conn, s *TunnelModeServer) error

func ProcessTunnel ¶

func ProcessTunnel(c *conn.Conn, s *TunnelModeServer) error

tcp proxy

Types ¶

type BaseServer ¶

type BaseServer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

BaseServer struct

func NewBaseServer ¶

func NewBaseServer(bridge NetBridge, task *file.Tunnel) *BaseServer

func (*BaseServer) CheckFlowAndConnNum ¶

func (s *BaseServer) CheckFlowAndConnNum(client *file.Client) error

check flow limit of the client ,and decrease the allow num of client

func (*BaseServer) DealClient ¶

func (s *BaseServer) DealClient(c *conn.Conn, client *file.Client, addr string,
	rb []byte, tp string, f func(), flows []*file.Flow, proxyProtocol int, localProxy bool, task *file.Tunnel) error

func (*BaseServer) FlowAdd ¶

func (s *BaseServer) FlowAdd(in, out int64)

add the flow

func (*BaseServer) FlowAddHost ¶

func (s *BaseServer) FlowAddHost(host *file.Host, in, out int64)

change the flow

type Http3Server ¶ added in v0.29.28

type Http3Server struct {
	*HttpsServer
	// contains filtered or unexported fields
}

func NewHttp3Server ¶ added in v0.29.28

func NewHttp3Server(httpsSrv *HttpsServer, udpConn net.PacketConn) *Http3Server

func (*Http3Server) Close ¶ added in v0.29.28

func (h3 *Http3Server) Close() error

func (*Http3Server) Start ¶ added in v0.29.28

func (h3 *Http3Server) Start() error

type HttpServer ¶ added in v0.29.28

type HttpServer struct {
	BaseServer
	// contains filtered or unexported fields
}

func NewHttp ¶

func NewHttp(bridge NetBridge, task *file.Tunnel, httpPort, httpsPort, http3Port int, httpOnlyPass string, addOrigin bool, httpProxyCache *index.AnyIntIndex) *HttpServer

func (*HttpServer) Close ¶ added in v0.29.28

func (s *HttpServer) Close() error

func (*HttpServer) DialContext ¶ added in v0.29.31

func (s *HttpServer) DialContext(ctx context.Context, network, addr string) (net.Conn, error)

func (*HttpServer) DialTlsContext ¶ added in v0.29.31

func (s *HttpServer) DialTlsContext(ctx context.Context, network, addr string) (net.Conn, error)

func (*HttpServer) NewServer ¶ added in v0.29.28

func (s *HttpServer) NewServer(port int, scheme string) *http.Server

func (*HttpServer) Start ¶ added in v0.29.28

func (s *HttpServer) Start() error

type HttpsListener ¶

type HttpsListener struct {
	// contains filtered or unexported fields
}

HttpsListener wraps a parent listener.

func NewHttpsListener ¶

func NewHttpsListener(l net.Listener) *HttpsListener

func (*HttpsListener) Accept ¶

func (httpsListener *HttpsListener) Accept() (net.Conn, error)

func (*HttpsListener) Addr ¶

func (httpsListener *HttpsListener) Addr() net.Addr

func (*HttpsListener) Close ¶

func (httpsListener *HttpsListener) Close() error

type HttpsServer ¶

type HttpsServer struct {
	HttpServer
	// contains filtered or unexported fields
}

func NewHttpsServer ¶

func NewHttpsServer(l net.Listener, bridge NetBridge, task *file.Tunnel, srv *http.Server, magic *certmagic.Config) *HttpsServer

func (*HttpsServer) Close ¶

func (https *HttpsServer) Close() error

func (*HttpsServer) Start ¶

func (https *HttpsServer) Start() error

type NetBridge ¶

type NetBridge interface {
	SendLinkInfo(clientId int, link *conn.Link, t *file.Tunnel) (target net.Conn, err error)
}

type P2PServer ¶

type P2PServer struct {
	BaseServer
	// contains filtered or unexported fields
}

func NewP2PServer ¶

func NewP2PServer(p2pPort int) *P2PServer

func (*P2PServer) Start ¶

func (s *P2PServer) Start() error

type Service ¶

type Service interface {
	Start() error
	Close() error
}

type TunnelModeServer ¶

type TunnelModeServer struct {
	BaseServer
	// contains filtered or unexported fields
}

func NewTunnelModeServer ¶

func NewTunnelModeServer(process process, bridge NetBridge, task *file.Tunnel) *TunnelModeServer

tcp|host|mixproxy

func (*TunnelModeServer) Auth ¶ added in v0.29.0

func (s *TunnelModeServer) Auth(c net.Conn) error

socks5 auth

func (*TunnelModeServer) Close ¶

func (s *TunnelModeServer) Close() error

func (*TunnelModeServer) Start ¶

func (s *TunnelModeServer) Start() error

type UdpModeServer ¶

type UdpModeServer struct {
	BaseServer
	// contains filtered or unexported fields
}

func NewUdpModeServer ¶

func NewUdpModeServer(bridge NetBridge, task *file.Tunnel) *UdpModeServer

func (*UdpModeServer) Close ¶

func (s *UdpModeServer) Close() error

func (*UdpModeServer) Start ¶

func (s *UdpModeServer) Start() error

type WebServer ¶

type WebServer struct {
	BaseServer
}

func NewWebServer ¶

func NewWebServer(bridge *bridge.Bridge) *WebServer

new

func (*WebServer) Close ¶

func (s *WebServer) Close() error

func (*WebServer) Start ¶

func (s *WebServer) Start() error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL