service

Documentation

Index

• type Client
  • func NewClient(nodeInfo *tunnel.NodeInfo, addr string) *Client
  • func (c *Client) Connect(r *connectResp)
  • func (c *Client) ConnectLoop() error
  • func (c *Client) Register() error
  • func (c *Client) Upstream()
• type Tower
  • func New(config *config.Service) (*Tower, error)
  • func (t *Tower) Upstream()

Types

type Client

type Client struct {
	*tunnel.NodeInfo
	// bridge address
	Addr string
	// writer
	Writer io.Writer
	// reader
	Reader *bufio.Reader
	// session for mux
	Session *yamux.Session
	// contains filtered or unexported fields
}

func NewClient

func NewClient(nodeInfo *tunnel.NodeInfo, addr string) *Client

func (*Client) Connect

func (c *Client) Connect(r *connectResp)

Connect event

func (*Client) ConnectLoop

func (c *Client) ConnectLoop() error

Wait a task with loop

func (*Client) Register

func (c *Client) Register() error

Register service

func (*Client) Upstream

func (c *Client) Upstream()

first action upstream

type Tower

type Tower struct {
	*tunnel.NodeInfo
	Clients map[string]*Client
}

func New

func New(config *config.Service) (*Tower, error)

func (*Tower) Upstream

func (t *Tower) Upstream()