markedconn

Documentation

Index

• func DialMarkedTCP(network string, laddr, raddr *net.TCPAddr, mark int) (net.Conn, error)
• func GetOriginalDestination(conn net.Conn) (net.Conn, net.IP, int, error)
• func MarkConnection(conn net.Conn, mark int) error
• func SocketListener(port string, mark int) (net.Listener, error)
• type ProxiedConnection
  • func (p *ProxiedConnection) Close() error
  • func (p *ProxiedConnection) GetOriginalDestination() (net.IP, int)
  • func (p *ProxiedConnection) GetTCPConnection() *net.TCPConn
  • func (p *ProxiedConnection) LocalAddr() net.Addr
  • func (p *ProxiedConnection) Read(b []byte) (n int, err error)
  • func (p *ProxiedConnection) RemoteAddr() net.Addr
  • func (p *ProxiedConnection) SetDeadline(t time.Time) error
  • func (p *ProxiedConnection) SetReadDeadline(t time.Time) error
  • func (p *ProxiedConnection) SetWriteDeadline(t time.Time) error
  • func (p *ProxiedConnection) Write(b []byte) (n int, err error)
• type ProxiedListener
  • func (l ProxiedListener) Accept() (c net.Conn, err error)
  • func (l ProxiedListener) Addr() net.Addr
  • func (l ProxiedListener) Close() error

Functions

func DialMarkedTCP

func DialMarkedTCP(network string, laddr, raddr *net.TCPAddr, mark int) (net.Conn, error)

DialMarkedTCP creates a new TCP connection and marks it with the provided mark.

func GetOriginalDestination

func GetOriginalDestination(conn net.Conn) (net.Conn, net.IP, int, error)

GetOriginalDestination -- Func to get original destination a connection

func MarkConnection

func MarkConnection(conn net.Conn, mark int) error

MarkConnection marks an existing connection with a mark

func SocketListener

func SocketListener(port string, mark int) (net.Listener, error)

SocketListener creates a TCP listener through system calls giving us more control over the specific parameters that we need.

Types

type ProxiedConnection

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

ProxiedConnection is a proxied connection where we can recover the original destination.

func (*ProxiedConnection) Close

func (p *ProxiedConnection) Close() error

Close closes the connection.

func (*ProxiedConnection) GetOriginalDestination

func (p *ProxiedConnection) GetOriginalDestination() (net.IP, int)

GetOriginalDestination sets the original destination of the connection.

func (*ProxiedConnection) GetTCPConnection

func (p *ProxiedConnection) GetTCPConnection() *net.TCPConn

GetTCPConnection returns the TCP connection object.

func (*ProxiedConnection) LocalAddr

func (p *ProxiedConnection) LocalAddr() net.Addr

LocalAddr implements the corresponding method of net.Conn, but returns the original address.

func (*ProxiedConnection) Read

func (p *ProxiedConnection) Read(b []byte) (n int, err error)

Read reads data from the connection.

func (*ProxiedConnection) RemoteAddr

func (p *ProxiedConnection) RemoteAddr() net.Addr

RemoteAddr returns the remote address

func (*ProxiedConnection) SetDeadline

func (p *ProxiedConnection) SetDeadline(t time.Time) error

SetDeadline passes the read deadline to the original TCP connection.

func (*ProxiedConnection) SetReadDeadline

func (p *ProxiedConnection) SetReadDeadline(t time.Time) error

SetReadDeadline implements the call by passing it to the original connection.

func (*ProxiedConnection) SetWriteDeadline

func (p *ProxiedConnection) SetWriteDeadline(t time.Time) error

SetWriteDeadline implements the call by passing it to the original connection.

func (*ProxiedConnection) Write

func (p *ProxiedConnection) Write(b []byte) (n int, err error)

Write writes data to the connection.

type ProxiedListener

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

ProxiedListener is a proxied listener that uses proxied connections.

func (ProxiedListener) Accept

func (l ProxiedListener) Accept() (c net.Conn, err error)

Accept implements the accept method of the interface.

func (ProxiedListener) Addr

func (l ProxiedListener) Addr() net.Addr

Addr implements the Addr method of net.Listener.

func (ProxiedListener) Close

func (l ProxiedListener) Close() error

Close implements the Close method of the net.Listener.