forwarder

Documentation

Index

• Constants
• func TCP(s *stack.Stack, nat map[tcpip.Address]tcpip.Address, natLock *sync.Mutex) *tcp.Forwarder
• func UDP(s *stack.Stack, nat map[tcpip.Address]tcpip.Address, natLock *sync.Mutex) *udp.Forwarder
• type CloseWrapper
  • func (w CloseWrapper) Close() error
• type PortsForwarder
  • func NewPortsForwarder(s *stack.Stack) *PortsForwarder
  • func (f *PortsForwarder) Expose(protocol types.TransportProtocol, local, remote string) error
  • func (f *PortsForwarder) Mux() http.Handler
  • func (f *PortsForwarder) Unexpose(protocol types.TransportProtocol, local string) error
• type UDPProxy
  • func NewUDPProxy(listener udpConn, dialer func() (net.Conn, error)) (*UDPProxy, error)
  • func (proxy *UDPProxy) Close() error
  • func (proxy *UDPProxy) Run()

Constants

const (
	// UDPConnTrackTimeout is the timeout used for UDP connection tracking
	UDPConnTrackTimeout = 90 * time.Second
	// UDPBufSize is the buffer size for the UDP proxy
	UDPBufSize = 65507
)

Functions

func TCP

func TCP(s *stack.Stack, nat map[tcpip.Address]tcpip.Address, natLock *sync.Mutex) *tcp.Forwarder

func UDP

func UDP(s *stack.Stack, nat map[tcpip.Address]tcpip.Address, natLock *sync.Mutex) *udp.Forwarder

Types

type CloseWrapper

type CloseWrapper func() error

func (CloseWrapper) Close

func (w CloseWrapper) Close() error

type PortsForwarder

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

func NewPortsForwarder

func NewPortsForwarder(s *stack.Stack) *PortsForwarder

func (*PortsForwarder) Expose

func (f *PortsForwarder) Expose(protocol types.TransportProtocol, local, remote string) error

func (*PortsForwarder) Mux

func (f *PortsForwarder) Mux() http.Handler

func (*PortsForwarder) Unexpose

func (f *PortsForwarder) Unexpose(protocol types.TransportProtocol, local string) error

type UDPProxy

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

UDPProxy is proxy for which handles UDP datagrams. It implements the Proxy interface to handle UDP traffic forwarding between the frontend and backend addresses.

func NewUDPProxy

func NewUDPProxy(listener udpConn, dialer func() (net.Conn, error)) (*UDPProxy, error)

NewUDPProxy creates a new UDPProxy.

func (*UDPProxy) Close

func (proxy *UDPProxy) Close() error

Close stops forwarding the traffic.

func (*UDPProxy) Run

func (proxy *UDPProxy) Run()

Run starts forwarding the traffic using UDP.