bridge

Documentation

Index

• type Bridge
  • func NewTunnel(tunnelPort int, runList map[int]interface{}, tunnelType string) *Bridge
  • func (s *Bridge) DelClient(id int)
  • func (s *Bridge) GetSignal(id int) (conn *conn.Conn, err error)
  • func (s *Bridge) GetStatus(clientId int)
  • func (s *Bridge) GetTunnel(id int, en, de int, crypt, mux bool) (conn *conn.Conn, err error)
  • func (s *Bridge) SendLinkInfo(clientId int, link *conn.Link) (tunnel *conn.Conn, err error)
  • func (s *Bridge) StartTunnel() error
• type Client
  • func NewClient(t *conn.Conn, s *conn.Conn) *Client

Types

type Bridge

type Bridge struct {
	TunnelPort int //通信隧道端口

	Client  map[int]*Client
	RunList map[int]interface{} //运行中的任务
	// contains filtered or unexported fields
}

func NewTunnel

func NewTunnel(tunnelPort int, runList map[int]interface{}, tunnelType string) *Bridge

func (*Bridge) DelClient

func (s *Bridge) DelClient(id int)

删除通信通道

func (*Bridge) GetSignal

func (s *Bridge) GetSignal(id int) (conn *conn.Conn, err error)

得到一个通信通道

func (*Bridge) GetStatus

func (s *Bridge) GetStatus(clientId int)

func (*Bridge) GetTunnel

func (s *Bridge) GetTunnel(id int, en, de int, crypt, mux bool) (conn *conn.Conn, err error)

得到一个tcp隧道

func (*Bridge) SendLinkInfo

func (s *Bridge) SendLinkInfo(clientId int, link *conn.Link) (tunnel *conn.Conn, err error)

func (*Bridge) StartTunnel

func (s *Bridge) StartTunnel() error

type Client

type Client struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewClient

func NewClient(t *conn.Conn, s *conn.Conn) *Client