group

package
v0.22.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 9, 2018 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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")
)

Functions

This section is empty.

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)

Jump to

Keyboard shortcuts

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