forward

Documentation

Index

• Variables
• type Forward
  • func NewForward(dst io.ReadWriteCloser, src io.ReadWriteCloser, onError func(error)) *Forward
  • func (f *Forward) SetErrHandle(cb func(error))
  • func (f *Forward) Start()
  • func (f *Forward) Stop()
• type TCPForward
  • func NewTCPForward(listenAddr, hostAddr string, onError func(error)) *TCPForward
  • func (tf *TCPForward) Start() error

Variables

var ErrConnClosed = errors.New("remote connection is closed")

var ErrRWSizeDismatch = errors.New("read size not equal to write size")

Types

type Forward

type Forward struct {
	SrcConn io.ReadWriteCloser
	DstConn io.ReadWriteCloser
	OnError func(error)
}

func NewForward

func NewForward(dst io.ReadWriteCloser, src io.ReadWriteCloser, onError func(error)) *Forward

func (*Forward) SetErrHandle

func (f *Forward) SetErrHandle(cb func(error))

func (*Forward) Start

func (f *Forward) Start()

func (*Forward) Stop

func (f *Forward) Stop()

type TCPForward

type TCPForward struct {
	// addr to listen
	ListenAddr string
	// target host addr
	HostAddr string
	// Error Handle
	OnError func(error)
}

func NewTCPForward

func NewTCPForward(listenAddr, hostAddr string, onError func(error)) *TCPForward

func (*TCPForward) Start

func (tf *TCPForward) Start() error