tcp

Documentation

Index

• func IsSocketClosed(err error) bool
• type ConnState
• type Modifier
• type Proxy
  • func (p *Proxy) AddDomainHandler(domain, target string, modifier *Modifier)
  • func (p *Proxy) RemoveDomainHandler(domain string)
  • func (p *Proxy) Serve(l net.Listener) error
  • func (p *Proxy) Swap(new *Proxy)
• type Stat
  • func (s *Stat) Flush() Stat

Functions

func IsSocketClosed

func IsSocketClosed(err error) bool

IsSocketClosed returns true if err is a result of reading from closed network connection

Types

type ConnState

type ConnState uint

const (
	Active ConnState = iota
	Open
	Closed
)

type Modifier

type Modifier struct {
	ModifyRequest  func(src, dst net.Conn, data []byte) ([]byte, error)
	ModifyResponse func(src, dst net.Conn, data []byte) ([]byte, error)
}

Modifier define rules for tranforming incoming and outcoming TCP messages To filter response set data to empty To close connection, return error

type Proxy

type Proxy struct {
	sync.RWMutex

	DialTLS         func(network, addr string) (net.Conn, error)
	Dial            func(network, addr string) (net.Conn, error)
	TLSConfigTarget *tls.Config

	ReadTimeout  time.Duration
	WriteTimeout time.Duration

	SyncStats func(Stat)
	// Duration in which connection stats will be flushed. Defaults to one second.
	StatsSyncInterval time.Duration
	// contains filtered or unexported fields
}

func (*Proxy) AddDomainHandler

func (p *Proxy) AddDomainHandler(domain, target string, modifier *Modifier)

func (*Proxy) RemoveDomainHandler

func (p *Proxy) RemoveDomainHandler(domain string)

func (*Proxy) Serve

func (p *Proxy) Serve(l net.Listener) error

func (*Proxy) Swap

func (p *Proxy) Swap(new *Proxy)

type Stat

type Stat struct {
	State    ConnState
	BytesIn  int64
	BytesOut int64
}

Stat defines basic statistics about a tcp connection

func (*Stat) Flush

func (s *Stat) Flush() Stat