core

Documentation

Index

• Constants
• func GenP256(hosts []string) (key, cert []byte, err error)
• func GenRSA2048(hosts []string) (key, cert []byte, err error)
• type Client
  • func (client *Client) DialMuxConn(host string, conn *net.TCPConn)
  • func (client *Client) DialWSConn(host string, conn *net.TCPConn)
  • func (client *Client) Listen() (err error)
  • func (client *Client) OpenMux() (err error)
• type ClientConfig
• type Message
• type MuxConn
  • func NewMuxConn(muxWS *MuxWebSocket) (conn *MuxConn)
  • func (conn *MuxConn) DialMessage(host string) (err error)
  • func (conn *MuxConn) HandleMessage(m *Message) (err error)
  • func (conn *MuxConn) Read(p []byte) (n int, err error)
  • func (conn *MuxConn) Run(c *net.TCPConn)
  • func (conn *MuxConn) SendMessageID() (id uint64)
  • func (conn *MuxConn) Write(p []byte) (n int, err error)
• type MuxWebSocket
  • func NewMuxWebSocket(ws *WebSocket) (muxWS *MuxWebSocket)
  • func (muxWS *MuxWebSocket) AcceptMuxConn(m *Message) (conn *MuxConn, host string, err error)
  • func (muxWS *MuxWebSocket) ClientListen()
  • func (muxWS *MuxWebSocket) GetMuxConn(connID uint64) (conn *MuxConn)
  • func (muxWS *MuxWebSocket) PutMuxConn(conn *MuxConn)
  • func (muxWS *MuxWebSocket) ReceiveMessage() (m *Message, err error)
  • func (muxWS *MuxWebSocket) SendMessage(m *Message) (err error)
  • func (muxWS *MuxWebSocket) ServerHandleMessage(m *Message)
  • func (muxWS *MuxWebSocket) ServerListen()
• type Server
  • func (server *Server) HandleWebSocket(w http.ResponseWriter, r *http.Request)
  • func (server *Server) Listen() (err error)
• type ServerConfig
• type WebSocket
  • func (ws *WebSocket) Close() (err error)
  • func (ws *WebSocket) Read(p []byte) (n int, err error)
  • func (ws *WebSocket) Write(p []byte) (n int, err error)

Constants

const (
	MessageMethodData = iota
	MessageMethodDial
)

Functions

func GenP256

func GenP256(hosts []string) (key, cert []byte, err error)

Modified https://github.com/Shyp/generate-tls-cert

func GenRSA2048

func GenRSA2048(hosts []string) (key, cert []byte, err error)

Types

type Client

type Client struct {
	*ClientConfig
	LogLevel loggo.Level

	ServerURL  *url.URL
	ListenAddr *net.TCPAddr
	Dialer     *websocket.Dialer

	//statistics
	CreatedAt time.Time
	// contains filtered or unexported fields
}

func (*Client) DialMuxConn

func (client *Client) DialMuxConn(host string, conn *net.TCPConn)

func (*Client) DialWSConn

func (client *Client) DialWSConn(host string, conn *net.TCPConn)

func (*Client) Listen

func (client *Client) Listen() (err error)

func (*Client) OpenMux

func (client *Client) OpenMux() (err error)

type ClientConfig

type ClientConfig struct {
	ListenAddr string
	ServerURL  string

	SNI          string
	InsecureCert bool

	Mux bool
}

type Message

type Message struct {
	Method    byte
	ConnID    uint64
	MessageID uint64
	Data      []byte
}

type MuxConn

type MuxConn struct {
	ID uint64
	// contains filtered or unexported fields
}

func NewMuxConn

func NewMuxConn(muxWS *MuxWebSocket) (conn *MuxConn)

NewMuxConn create new mux connection for client

func (*MuxConn) DialMessage

func (conn *MuxConn) DialMessage(host string) (err error)

client dial remote

func (*MuxConn) HandleMessage

func (conn *MuxConn) HandleMessage(m *Message) (err error)

func (*MuxConn) Read

func (conn *MuxConn) Read(p []byte) (n int, err error)

func (*MuxConn) Run

func (conn *MuxConn) Run(c *net.TCPConn)

func (*MuxConn) SendMessageID

func (conn *MuxConn) SendMessageID() (id uint64)

func (*MuxConn) Write

func (conn *MuxConn) Write(p []byte) (n int, err error)

type MuxWebSocket

type MuxWebSocket struct {
	*WebSocket
	Decoder *gob.Decoder
	Encoder *gob.Encoder
	// contains filtered or unexported fields
}

func NewMuxWebSocket

func NewMuxWebSocket(ws *WebSocket) (muxWS *MuxWebSocket)

func (*MuxWebSocket) AcceptMuxConn

func (muxWS *MuxWebSocket) AcceptMuxConn(m *Message) (conn *MuxConn, host string, err error)

func (*MuxWebSocket) ClientListen

func (muxWS *MuxWebSocket) ClientListen()

func (*MuxWebSocket) GetMuxConn

func (muxWS *MuxWebSocket) GetMuxConn(connID uint64) (conn *MuxConn)

func (*MuxWebSocket) PutMuxConn

func (muxWS *MuxWebSocket) PutMuxConn(conn *MuxConn)

func (*MuxWebSocket) ReceiveMessage

func (muxWS *MuxWebSocket) ReceiveMessage() (m *Message, err error)

func (*MuxWebSocket) SendMessage

func (muxWS *MuxWebSocket) SendMessage(m *Message) (err error)

func (*MuxWebSocket) ServerHandleMessage

func (muxWS *MuxWebSocket) ServerHandleMessage(m *Message)

func (*MuxWebSocket) ServerListen

func (muxWS *MuxWebSocket) ServerListen()

type Server

type Server struct {
	*ServerConfig
	LogLevel loggo.Level

	Upgrader *websocket.Upgrader

	//statistics
	CreatedAt time.Time
	// contains filtered or unexported fields
}

func (*Server) HandleWebSocket

func (server *Server) HandleWebSocket(w http.ResponseWriter, r *http.Request)

func (*Server) Listen

func (server *Server) Listen() (err error)

type ServerConfig

type ServerConfig struct {
	ListenAddr   string
	Pattern      string
	TLS          bool
	CertPath     string
	KeyPath      string
	ReverseProxy string
}

type WebSocket

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

func (*WebSocket) Close

func (ws *WebSocket) Close() (err error)

func (*WebSocket) Read

func (ws *WebSocket) Read(p []byte) (n int, err error)

func (*WebSocket) Write

func (ws *WebSocket) Write(p []byte) (n int, err error)