socks5

package

v0.17.0 Latest Latest Go to latest Published: Apr 24, 2026 License: MPL-2.0 Imports: 10 Imported by: 0

Details

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

Repository

github.com/anywherelan/awl

Links

Open Source Insights

Documentation ¶

Index ¶

func NewRulePermitAll() socks5.RuleSet
type Client
- func NewClient(listenAddr string) (*Client, error)
- func (c *Client) Close() error
- func (c *Client) ConnsChan() <-chan net.Conn
- func (c *Client) HandleLocalAuth(conn net.Conn) error
type Logger
- func NewLogger() *Logger
- func (l *Logger) Printf(format string, v ...interface{})
type ReadWriterConnWrapper
- func (c ReadWriterConnWrapper) LocalAddr() net.Addr
- func (c ReadWriterConnWrapper) RemoteAddr() net.Addr
- func (c ReadWriterConnWrapper) SetDeadline(time.Time) error
- func (c ReadWriterConnWrapper) SetReadDeadline(time.Time) error
- func (c ReadWriterConnWrapper) SetWriteDeadline(time.Time) error
type RuleDenyLocalhost
- func NewRuleDenyLocalhost() *RuleDenyLocalhost
- func (r *RuleDenyLocalhost) Allow(ctx context.Context, req *socks5.Request) (context.Context, bool)
type Server
- func NewServer() *Server
- func (s *Server) SendServerFailureReply(conn io.ReadWriter) error
- func (s *Server) ServeConn(ioConn io.ReadWriteCloser) error
- func (s *Server) ServeStreamConn(stream network.Stream) error
- func (s *Server) ServeStreamConnNoAuth(stream network.Stream) error
- func (s *Server) SetRules(rule socks5.RuleSet)
type StreamConnWrapper
- func (c StreamConnWrapper) Close() error
- func (c StreamConnWrapper) LocalAddr() net.Addr
- func (c StreamConnWrapper) RemoteAddr() net.Addr
type UpdatableRule
- func NewUpdatableRule(rule socks5.RuleSet) *UpdatableRule
- func (r *UpdatableRule) Allow(ctx context.Context, req *socks5.Request) (context.Context, bool)
- func (r *UpdatableRule) SetRule(rule socks5.RuleSet)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewRulePermitAll ¶

func NewRulePermitAll() socks5.RuleSet

Types ¶

type Client ¶

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

func NewClient ¶

func NewClient(listenAddr string) (*Client, error)

func (*Client) Close ¶

func (c *Client) Close() error

func (*Client) ConnsChan ¶

func (c *Client) ConnsChan() <-chan net.Conn

func (*Client) HandleLocalAuth ¶ added in v0.17.0

func (c *Client) HandleLocalAuth(conn net.Conn) error

HandleLocalAuth performs the SOCKS5 auth negotiation locally, responding with NoAuth. This avoids sending the auth handshake over the network to the remote peer.

type Logger ¶

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

func NewLogger ¶

func NewLogger() *Logger

func (*Logger) Printf ¶

func (l *Logger) Printf(format string, v ...interface{})

type ReadWriterConnWrapper ¶

type ReadWriterConnWrapper struct {
	io.ReadWriteCloser
}

ReadWriterConnWrapper is used for socks5

func (ReadWriterConnWrapper) LocalAddr ¶

func (c ReadWriterConnWrapper) LocalAddr() net.Addr

func (ReadWriterConnWrapper) RemoteAddr ¶

func (c ReadWriterConnWrapper) RemoteAddr() net.Addr

func (ReadWriterConnWrapper) SetDeadline ¶

func (c ReadWriterConnWrapper) SetDeadline(time.Time) error

func (ReadWriterConnWrapper) SetReadDeadline ¶

func (c ReadWriterConnWrapper) SetReadDeadline(time.Time) error

func (ReadWriterConnWrapper) SetWriteDeadline ¶

func (c ReadWriterConnWrapper) SetWriteDeadline(time.Time) error

type RuleDenyLocalhost ¶

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

func NewRuleDenyLocalhost ¶

func NewRuleDenyLocalhost() *RuleDenyLocalhost

func (*RuleDenyLocalhost) Allow ¶

func (r *RuleDenyLocalhost) Allow(ctx context.Context, req *socks5.Request) (context.Context, bool)

type Server ¶

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

func NewServer ¶

func NewServer() *Server

func (*Server) SendServerFailureReply ¶

func (s *Server) SendServerFailureReply(conn io.ReadWriter) error

func (*Server) ServeConn ¶

func (s *Server) ServeConn(ioConn io.ReadWriteCloser) error

ServeConn is only used in tests. TODO: refactor tests

func (*Server) ServeStreamConn ¶

func (s *Server) ServeStreamConn(stream network.Stream) error

func (*Server) ServeStreamConnNoAuth ¶ added in v0.17.0

func (s *Server) ServeStreamConnNoAuth(stream network.Stream) error

func (*Server) SetRules ¶

func (s *Server) SetRules(rule socks5.RuleSet)

SetRules is created for tests and not intended for real usage.

type StreamConnWrapper ¶

type StreamConnWrapper struct {
	network.Stream
}

StreamConnWrapper is used for socks5

func (StreamConnWrapper) Close ¶

func (c StreamConnWrapper) Close() error

func (StreamConnWrapper) LocalAddr ¶

func (c StreamConnWrapper) LocalAddr() net.Addr

func (StreamConnWrapper) RemoteAddr ¶

func (c StreamConnWrapper) RemoteAddr() net.Addr

type UpdatableRule ¶

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

func NewUpdatableRule ¶

func NewUpdatableRule(rule socks5.RuleSet) *UpdatableRule

func (*UpdatableRule) Allow ¶

func (r *UpdatableRule) Allow(ctx context.Context, req *socks5.Request) (context.Context, bool)

func (*UpdatableRule) SetRule ¶

func (r *UpdatableRule) SetRule(rule socks5.RuleSet)

Source Files ¶

View all Source files

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