bridge

package
v0.31.0 Latest Latest
Warning

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

 Go to latest Published: Aug 7, 2025 License: GPL-3.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ServerTcpEnable  = false
	ServerKcpEnable  = false
	ServerQuicEnable = false
	ServerTlsEnable  = false
	ServerWsEnable   = false
	ServerWssEnable  = false
	ServerSecureMode = false
)
View Source 
var ClientSelectMode = Primary

Functions

func IsReplay added in v0.27.0 

func IsReplay(key string) bool

func SetClientSelectMode added in v0.30.3 

func SetClientSelectMode(v any) error

Types

type Bridge 

type Bridge struct {
	TunnelPort int
	Client     *sync.Map
	Register   *sync.Map

	OpenTask    chan *file.Tunnel
	CloseTask   chan *file.Tunnel
	CloseClient chan int
	SecretChan  chan *conn.Secret
	// contains filtered or unexported fields
}

func NewTunnel 

func NewTunnel(tunnelPort int, tunnelType string, ipVerify bool, runList *sync.Map, disconnectTime int) *Bridge

func (*Bridge) DelClient 

func (s *Bridge) DelClient(id int)

func (*Bridge) GetHealthFromClient 

func (s *Bridge) GetHealthFromClient(id int, c *conn.Conn)

GetHealthFromClient get health information form client

func (*Bridge) IsServer added in v0.30.4 

func (s *Bridge) IsServer() bool

func (*Bridge) SendLinkInfo 

func (s *Bridge) SendLinkInfo(clientId int, link *conn.Link, t *file.Tunnel) (target net.Conn, err error)

func (*Bridge) StartTunnel 

func (s *Bridge) StartTunnel() error

type Client 

type Client struct {
	Id       int
	LastAddr string
	// contains filtered or unexported fields
}

func NewClient 

func NewClient(id int, n *Node) *Client

func (*Client) AddFile added in v0.30.3 

func (c *Client) AddFile(key, addr string) error

func (*Client) AddNode added in v0.30.6 

func (c *Client) AddNode(n *Node)

func (*Client) CheckNode added in v0.30.6 

func (c *Client) CheckNode() *Node

func (*Client) Close added in v0.30.3 

func (c *Client) Close() error

func (*Client) GetNode added in v0.30.6 

func (c *Client) GetNode() *Node

func (*Client) GetNodeByAddr added in v0.30.6 

func (c *Client) GetNodeByAddr(addr string) (*Node, bool)

func (*Client) GetNodeByFile added in v0.30.6 

func (c *Client) GetNodeByFile(key string) (*Node, bool)

func (*Client) IsClosed added in v0.30.3 

func (c *Client) IsClosed() bool

func (*Client) NodeCount added in v0.30.6 

func (c *Client) NodeCount() int

func (*Client) RemoveFile added in v0.30.6 

func (c *Client) RemoveFile(key string)

type Node added in v0.30.6 

type Node struct {
	Client  *Client
	Addr    string
	Version string
	BaseVer int
	// contains filtered or unexported fields
}

func NewNode added in v0.30.6 

func NewNode(addr, vs string, bv int) *Node

func (*Node) AddNode added in v0.30.6 

func (n *Node) AddNode(node *Node)

func (*Node) AddSignal added in v0.30.6 

func (n *Node) AddSignal(signal *conn.Conn)

func (*Node) AddTunnel added in v0.30.6 

func (n *Node) AddTunnel(tunnel any)

func (*Node) Close added in v0.30.6 

func (n *Node) Close() error

func (*Node) GetSignal added in v0.30.6 

func (n *Node) GetSignal() *conn.Conn

func (*Node) GetTunnel added in v0.30.6 

func (n *Node) GetTunnel() any

func (*Node) IsOffline added in v0.30.6 

func (n *Node) IsOffline() bool

func (*Node) IsOnline added in v0.30.6 

func (n *Node) IsOnline() bool

type SelectMode added in v0.30.3 

type SelectMode int32
const (
	Primary SelectMode = iota
	RoundRobin
	Random
)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.