client

Documentation

Index

• Variables
• func EnsurePort(server string, tp string) string
• func GetTaskStatus(path string)
• func NewConn(tp string, vkey string, server string, connType string, proxyUrl string) (*conn.Conn, error)
• func NewHttpProxyConn(proxyURL *url.URL, remoteAddr string) (net.Conn, error)
• func RegisterLocalIp(server string, vKey string, tp string, proxyUrl string, hour int)
• func StartFromFile(path string)
• func VerifyTLS(connection net.Conn, host string) (fingerprint []byte, verified bool)
• type Closer
• type FileServerManager
  • func NewFileServerManager(parentCtx context.Context) *FileServerManager
  • func (fsm *FileServerManager) CloseAll()
  • func (fsm *FileServerManager) StartFileServer(cfg *config.CommonConfig, t *file.Tunnel, vkey string)
• type HealthChecker
  • func NewHealthChecker(parentCtx context.Context, healths []*file.Health, c *conn.Conn) *HealthChecker
  • func (hc *HealthChecker) Reset()
  • func (hc *HealthChecker) Start()
  • func (hc *HealthChecker) Stop()
• type P2PManager
  • func NewP2PManager(parentCtx context.Context) *P2PManager
  • func (mgr *P2PManager) Close()
  • func (mgr *P2PManager) StartLocalServer(l *config.LocalServer, cfg *config.CommonConfig) error
• type TRPClient
  • func NewRPClient(svraddr string, vKey string, bridgeConnType string, proxyUrl string, ...) *TRPClient
  • func (s *TRPClient) Close()
  • func (s *TRPClient) Start()

Variables

var HasFailed = false

var NowStatus int

var SkipTLSVerify = false

var Ver = version.GetLatestIndex()

Functions

func EnsurePort

func EnsurePort(server string, tp string) string

func GetTaskStatus

func GetTaskStatus(path string)

func NewConn

func NewConn(tp string, vkey string, server string, connType string, proxyUrl string) (*conn.Conn, error)

Create a new connection with the server and verify it

func NewHttpProxyConn

func NewHttpProxyConn(proxyURL *url.URL, remoteAddr string) (net.Conn, error)

http proxy connection

func RegisterLocalIp

func RegisterLocalIp(server string, vKey string, tp string, proxyUrl string, hour int)

func StartFromFile

func StartFromFile(path string)

func VerifyTLS

func VerifyTLS(connection net.Conn, host string) (fingerprint []byte, verified bool)

Types

type Closer

type Closer interface{ Close() error }

type FileServerManager

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

func NewFileServerManager

func NewFileServerManager(parentCtx context.Context) *FileServerManager

func (*FileServerManager) CloseAll

func (fsm *FileServerManager) CloseAll()

func (*FileServerManager) StartFileServer

func (fsm *FileServerManager) StartFileServer(cfg *config.CommonConfig, t *file.Tunnel, vkey string)

type HealthChecker

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

func NewHealthChecker

func NewHealthChecker(parentCtx context.Context, healths []*file.Health, c *conn.Conn) *HealthChecker

func (*HealthChecker) Reset

func (hc *HealthChecker) Reset()

func (*HealthChecker) Start

func (hc *HealthChecker) Start()

func (*HealthChecker) Stop

func (hc *HealthChecker) Stop()

type P2PManager

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

func NewP2PManager

func NewP2PManager(parentCtx context.Context) *P2PManager

func (*P2PManager) Close

func (mgr *P2PManager) Close()

func (*P2PManager) StartLocalServer

func (mgr *P2PManager) StartLocalServer(l *config.LocalServer, cfg *config.CommonConfig) error

type TRPClient

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

func NewRPClient

func NewRPClient(svraddr string, vKey string, bridgeConnType string, proxyUrl string, cnf *config.Config, disconnectTime int) *TRPClient

new client

func (*TRPClient) Close

func (s *TRPClient) Close()

func (*TRPClient) Start

func (s *TRPClient) Start()

start