tunnel

Documentation

Index

• Constants
• func ListenAndServe(addr string, handler Handler) error
• func LocalIP() (internet net.IP, intranet net.IP)
• func NewUUID() string
• func SetConnectTimeout(conn net.Conn, readTimeout, writeTimeout time.Duration) net.Conn
• type Handler
• type HandlerFunc
  • func (f HandlerFunc) Serve(conn net.Conn)
• type NodeInfo
  • func ParseUser(str string) (*NodeInfo, error)
  • func (n *NodeInfo) Account() string
  • func (n *NodeInfo) ProxyAuth() (*proxy.Auth, error)
  • func (n *NodeInfo) User() string
• type Request
• type Server
  • func (s *Server) ListenAndServe() error
  • func (s *Server) Serve(l net.Listener) error
• type Session
  • func NewSession(conn net.Conn) (*Session, error)

Constants

const (
	// 注册
	MethodRegister = 1
	// 准备接收任务
	MethodConn = 2
)

const (
	Delim = '\n'
)

Functions

func ListenAndServe

func ListenAndServe(addr string, handler Handler) error

func LocalIP

func LocalIP() (internet net.IP, intranet net.IP)

func NewUUID

func NewUUID() string

func SetConnectTimeout

func SetConnectTimeout(conn net.Conn, readTimeout, writeTimeout time.Duration) net.Conn

Types

type Handler

type Handler interface {
	Serve(conn net.Conn)
}

A Handler of Conn

type HandlerFunc

type HandlerFunc func(conn net.Conn)

For quickly defining Handler

func (HandlerFunc) Serve

func (f HandlerFunc) Serve(conn net.Conn)

Implement Handler

type NodeInfo

type NodeInfo struct {
	Id       string `json:"id"`
	Group    string `json:"group"`
	Name     string `json:"name"`
	Password string `json:"password"`
	Cipher   string `json:"cipher"`
}

func ParseUser

func ParseUser(str string) (*NodeInfo, error)

func (*NodeInfo) Account

func (n *NodeInfo) Account() string

func (*NodeInfo) ProxyAuth

func (n *NodeInfo) ProxyAuth() (*proxy.Auth, error)

func (*NodeInfo) User

func (n *NodeInfo) User() string

type Request

type Request struct {
	ServiceId string `json:"serviceId"`
	// connect | register
	Method     int             `json:"method"`
	Attachment json.RawMessage `json:"attachment"`
}

type Server

type Server struct {
	Addr    string
	Handler Handler
}

func (*Server) ListenAndServe

func (s *Server) ListenAndServe() error

func (*Server) Serve

func (s *Server) Serve(l net.Listener) error

type Session

type Session struct {
	// origin conn
	net.Conn
	// context
	Context context.Context
	// cancel
	Cancel context.CancelFunc
	// request
	*Request
	// serviceInfo
	*NodeInfo
	// logger
	Logger *logrus.Entry
}

func NewSession

func NewSession(conn net.Conn) (*Session, error)