libproxy

package

Go to main page

Versions in this module

v0

v0.6.0

Apr 8, 2025

Changes in this version

+ var ErrNotRunning = errors.New("multiplexer is not running")

+ func NewLoopback() *loopback

+ type MultiplexedConn interface

+ SetReadBuffer func(uint) error

+ SetWriteBuffer func(uint) error

v0.5.0

Feb 9, 2021

Changes in this version

type UDPListener

+ LocalAddr func() net.Addr

v0.4.0

Mar 4, 2020

Changes in this version

+ func ProxyStream(client, backend Conn, quit <-chan struct{}) error

+ func SetLogger(l *logrus.Logger)

type Multiplexer

+ DumpState func(w io.Writer)

+ type UDPDialer interface

+ Dial func(*net.UDPAddr) (net.Conn, error)

v0.3.0

Feb 7, 2019

Changes in this version

+ func Forward(conn Conn, destination Destination, quit chan struct{})

+ func HandleUnixConnection(client Conn, backendAddr *net.UnixAddr, quit chan struct{}) error

+ type CloseFrame struct

+ type Command int8

+ const Close

+ const Data

+ const Open

+ const Shutdown

+ const Window

+ type Connection int8

+ const Dedicated

+ const Multiplexed

+ func (c Connection) String() string

+ type DataFrame struct

+ func (d *DataFrame) Size() int

+ func (d *DataFrame) Write(w io.Writer) error

+ type Destination struct

+ IP net.IP

+ Path string

+ Port uint16

+ Proto Proto

+ func (d Destination) Size() int

+ func (d Destination) String() string

+ func (d Destination) Write(w io.Writer) error

+ type Frame struct

+ Command Command

+ ID uint32

+ func NewClose(ID uint32) *Frame

+ func NewData(ID, payloadlen uint32) *Frame

+ func NewOpen(ID uint32, d Destination) *Frame

+ func NewShutdown(ID uint32) *Frame

+ func NewWindow(ID uint32, seq uint64) *Frame

+ func (f *Frame) Data() (*DataFrame, error)

+ func (f *Frame) Open() (*OpenFrame, error)

+ func (f *Frame) Payload() interface{}

+ func (f *Frame) Size() int

+ func (f *Frame) String() string

+ func (f *Frame) Window() (*WindowFrame, error)

+ func (f *Frame) Write(w io.Writer) error

+ type Multiplexer struct

+ func NewMultiplexer(label string, conn io.ReadWriteCloser) *Multiplexer

+ func (m *Multiplexer) Accept() (Conn, *Destination, error)

+ func (m *Multiplexer) Close() error

+ func (m *Multiplexer) Dial(d Destination) (Conn, error)

+ func (m *Multiplexer) IsRunning() bool

+ func (m *Multiplexer) Run()

+ type OpenFrame struct

+ Connection Connection

+ Destination Destination

+ func (o *OpenFrame) Size() int

+ func (o *OpenFrame) Write(w io.Writer) error

+ type Proto uint8

+ const Unix

+ type ShutdownFrame struct

+ type UnixProxy struct

+ func NewUnixProxy(listener net.Listener, backendAddr *net.UnixAddr) (*UnixProxy, error)

+ func (proxy *UnixProxy) BackendAddr() net.Addr

+ func (proxy *UnixProxy) Close()

+ func (proxy *UnixProxy) FrontendAddr() net.Addr

+ func (proxy *UnixProxy) Run()

+ type WindowFrame struct

+ func (win *WindowFrame) Size() int

+ func (win *WindowFrame) Write(w io.Writer) error

v0.2.0

Jan 3, 2018

Changes in this version

+ const TCP

+ const UDP

+ func ExposePort(host net.Addr, container net.Addr) (*os.File, error)

+ func HandleMultiplexedConnections(conn net.Conn, quit chan struct{}) error

type Proxy

+ func NewBestEffortIPProxy(host net.Addr, container net.Addr) (Proxy, error)

v0.1.1

Aug 17, 2017

v0.1.0

Aug 17, 2017

Changes in this version

+ const UDPBufSize

+ const UDPConnTrackTimeout

+ func HandleTCPConnection(client Conn, backendAddr *net.TCPAddr, quit chan bool)

+ type Conn interface

+ CloseRead func() error

+ CloseWrite func() error

+ type Proxy interface

+ BackendAddr func() net.Addr

+ Close func()

+ FrontendAddr func() net.Addr

+ Run func()

+ func NewIPProxy(frontendAddr, backendAddr net.Addr) (Proxy, error)

+ func NewStubProxy(frontendAddr, backendAddr net.Addr) (Proxy, error)

+ func NewVsockProxy(frontendAddr *vsock.VsockAddr, backendAddr net.Addr) (Proxy, error)

+ type StubProxy struct

+ func (p *StubProxy) BackendAddr() net.Addr

+ func (p *StubProxy) Close()

+ func (p *StubProxy) FrontendAddr() net.Addr

+ func (p *StubProxy) Run()

+ type TCPProxy struct

+ func NewTCPProxy(listener net.Listener, backendAddr *net.TCPAddr) (*TCPProxy, error)

+ func (proxy *TCPProxy) BackendAddr() net.Addr

+ func (proxy *TCPProxy) Close()

+ func (proxy *TCPProxy) FrontendAddr() net.Addr

+ func (proxy *TCPProxy) Run()

+ type UDPListener interface

+ Close func() error

+ ReadFromUDP func(b []byte) (int, *net.UDPAddr, error)

+ WriteToUDP func(b []byte, addr *net.UDPAddr) (int, error)

+ func NewUDPConn(conn net.Conn) UDPListener

+ func NewUDPListener(listener net.Listener) UDPListener

+ type UDPProxy struct

+ func NewUDPProxy(frontendAddr net.Addr, listener UDPListener, backendAddr *net.UDPAddr) (*UDPProxy, error)

+ func (proxy *UDPProxy) BackendAddr() net.Addr

+ func (proxy *UDPProxy) Close()

+ func (proxy *UDPProxy) FrontendAddr() net.Addr

+ func (proxy *UDPProxy) Run()

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