core

Documentation

Index

• Constants
• func GenP256(hosts []string) (key, cert []byte, err error)
• func GenRSA2048(hosts []string) (key, cert []byte, err error)
• func NewHostHeader(host string) (header map[string][]string)
• 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) 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)
• type Stats
  • func NewStats() (stats *Stats)
  • func (stats *Stats) AddDownloaded(downloaded uint64)
  • func (stats *Stats) AddUploaded(uploaded uint64)
• type WebSocket
  • func NewWebSocket(conn *websocket.Conn, stats *Stats) (ws *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)

func NewHostHeader

func NewHostHeader(host string) (header map[string][]string)

Types

type Message

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

type MuxConn

type MuxConn struct {
	ID    uint64
	MuxWS *MuxWebSocket
	// 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) 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)

type Stats

type Stats struct {
	Downloaded    uint64
	DownloadSpeed uint64

	Uploaded    uint64
	UploadSpeed uint64
	// contains filtered or unexported fields
}

func NewStats

func NewStats() (stats *Stats)

func (*Stats) AddDownloaded

func (stats *Stats) AddDownloaded(downloaded uint64)

func (*Stats) AddUploaded

func (stats *Stats) AddUploaded(uploaded uint64)

type WebSocket

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

func NewWebSocket

func NewWebSocket(conn *websocket.Conn, stats *Stats) (ws *WebSocket)

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)