kubernetes/vendor/github.com/armon/go-socks5/request.go

const ConnectCommand …

const BindCommand …

const AssociateCommand …

const ipv4Address …

const fqdnAddress …

const ipv6Address …

const successReply …

const serverFailure …

const ruleFailure …

const networkUnreachable …

const hostUnreachable …

const connectionRefused …

const ttlExpired …

const commandNotSupported …

const addrTypeNotSupported …

var unrecognizedAddrType …

type AddressRewriter …

type AddrSpec …

func (a *AddrSpec) String() string { … }

// Address returns a string suitable to dial; prefer returning IP-based
// address, fallback to FQDN
func (a AddrSpec) Address() string { … }

type Request …

type conn …

// NewRequest creates a new Request from the tcp connection
func NewRequest(bufConn io.Reader) (*Request, error) { … }

// handleRequest is used for request processing after authentication
func (s *Server) handleRequest(req *Request, conn conn) error { … }

// handleConnect is used to handle a connect command
func (s *Server) handleConnect(ctx context.Context, conn conn, req *Request) error { … }

// handleBind is used to handle a connect command
func (s *Server) handleBind(ctx context.Context, conn conn, req *Request) error { … }

// handleAssociate is used to handle a connect command
func (s *Server) handleAssociate(ctx context.Context, conn conn, req *Request) error { … }

// readAddrSpec is used to read AddrSpec.
// Expects an address type byte, follwed by the address and port
func readAddrSpec(r io.Reader) (*AddrSpec, error) { … }

// sendReply is used to send a reply message
func sendReply(w io.Writer, resp uint8, addr *AddrSpec) error { … }

type closeWriter …

// proxy is used to suffle data from src to destination, and sends errors
// down a dedicated channel
func proxy(dst io.Writer, src io.Reader, errCh chan error) { … }