Documentation
¶
Index ¶
- type BaseVisitor
- type Control
- func (ctl *Control) Close() error
- func (ctl *Control) ClosedDoneCh() <-chan struct{}
- func (ctl *Control) HandleNewProxyResp(inMsg *msg.NewProxyResp)
- func (ctl *Control) HandleReqWorkConn(inMsg *msg.ReqWorkConn)
- func (ctl *Control) ReloadConf(pxyCfgs map[string]config.ProxyConf, visitorCfgs map[string]config.VisitorConf) error
- func (ctl *Control) Run()
- type Service
- type StcpVisitor
- type Visitor
- type VisitorManager
- type XtcpVisitor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BaseVisitor ¶
type BaseVisitor struct {
// contains filtered or unexported fields
}
type Control ¶
type Control struct {
// contains filtered or unexported fields
}
func NewControl ¶
func (*Control) ClosedDoneCh ¶
func (ctl *Control) ClosedDoneCh() <-chan struct{}
ClosedDoneCh returns a channel which will be closed after all resources are released
func (*Control) HandleNewProxyResp ¶
func (ctl *Control) HandleNewProxyResp(inMsg *msg.NewProxyResp)
func (*Control) HandleReqWorkConn ¶
func (ctl *Control) HandleReqWorkConn(inMsg *msg.ReqWorkConn)
func (*Control) ReloadConf ¶
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
Service is a client service.
func NewService ¶
func (*Service) GetController ¶
func (*Service) ReloadConf ¶
type StcpVisitor ¶
type StcpVisitor struct {
*BaseVisitor
// contains filtered or unexported fields
}
func (*StcpVisitor) Close ¶
func (sv *StcpVisitor) Close()
func (*StcpVisitor) Run ¶
func (sv *StcpVisitor) Run() (err error)
type Visitor ¶
type Visitor interface {
Run() error
Close()
}
Visitor is used for forward traffics from local port tot remote service.
func NewVisitor ¶
type VisitorManager ¶
type VisitorManager struct {
// contains filtered or unexported fields
}
func NewVisitorManager ¶
func NewVisitorManager(ctx context.Context, ctl *Control) *VisitorManager
func (*VisitorManager) Close ¶
func (vm *VisitorManager) Close()
func (*VisitorManager) Reload ¶
func (vm *VisitorManager) Reload(cfgs map[string]config.VisitorConf)
func (*VisitorManager) Run ¶
func (vm *VisitorManager) Run()
type XtcpVisitor ¶
type XtcpVisitor struct {
*BaseVisitor
// contains filtered or unexported fields
}
func (*XtcpVisitor) Close ¶
func (sv *XtcpVisitor) Close()
func (*XtcpVisitor) Run ¶
func (sv *XtcpVisitor) Run() (err error)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.