group

Documentation

Index

• Variables
• type TcpGroup
  • func NewTcpGroup(ctl *TcpGroupCtl) *TcpGroup
  • func (tg *TcpGroup) Accept() <-chan net.Conn
  • func (tg *TcpGroup) CloseListener(ln *TcpGroupListener)
  • func (tg *TcpGroup) Listen(proxyName string, group string, groupKey string, addr string, port int) (ln *TcpGroupListener, realPort int, err error)
• type TcpGroupCtl
  • func NewTcpGroupCtl(portManager *ports.PortManager) *TcpGroupCtl
  • func (tgc *TcpGroupCtl) Listen(proxyNanme string, group string, groupKey string, addr string, port int) (l net.Listener, realPort int, err error)
  • func (tgc *TcpGroupCtl) RemoveGroup(group string)
• type TcpGroupListener
  • func (ln *TcpGroupListener) Accept() (c net.Conn, err error)
  • func (ln *TcpGroupListener) Addr() net.Addr
  • func (ln *TcpGroupListener) Close() (err error)

Variables

var (
	ErrGroupAuthFailed    = errors.New("group auth failed")
	ErrGroupParamsInvalid = errors.New("group params invalid")
	ErrListenerClosed     = errors.New("group listener closed")
	ErrGroupDifferentPort = errors.New("group should have same remote port")
)

Types

type TcpGroup

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

func NewTcpGroup

func NewTcpGroup(ctl *TcpGroupCtl) *TcpGroup

func (*TcpGroup) Accept

func (tg *TcpGroup) Accept() <-chan net.Conn

func (*TcpGroup) CloseListener

func (tg *TcpGroup) CloseListener(ln *TcpGroupListener)

func (*TcpGroup) Listen

func (tg *TcpGroup) Listen(proxyName string, group string, groupKey string, addr string, port int) (ln *TcpGroupListener, realPort int, err error)

type TcpGroupCtl

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

func NewTcpGroupCtl

func NewTcpGroupCtl(portManager *ports.PortManager) *TcpGroupCtl

func (*TcpGroupCtl) Listen

func (tgc *TcpGroupCtl) Listen(proxyNanme string, group string, groupKey string,
	addr string, port int) (l net.Listener, realPort int, err error)

func (*TcpGroupCtl) RemoveGroup

func (tgc *TcpGroupCtl) RemoveGroup(group string)

type TcpGroupListener

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

func (*TcpGroupListener) Accept

func (ln *TcpGroupListener) Accept() (c net.Conn, err error)

func (*TcpGroupListener) Addr

func (ln *TcpGroupListener) Addr() net.Addr

func (*TcpGroupListener) Close

func (ln *TcpGroupListener) Close() (err error)