ws

Documentation

Index

• Variables
• func BuildNewTunnel(addr string)
• func CompressByGzip(in []byte) ([]byte, error)
• func DecompressByGzip(in []byte) ([]byte, error)
• func Decrypt(key, input []byte) ([]byte, error)
• func DirectRequest(req *http.Request, target *url.URL)
• func Encrypt(key, input []byte) ([]byte, error)
• func Forward(target string, rw http.ResponseWriter, req *http.Request)
• func NewDefaultHub() *hub
• func ServeWS(w http.ResponseWriter, r *http.Request)
• type Client
  • func NewClient(addr string) *Client
  • func (c *Client) Dial() error
  • func (c *Client) Run()
  • func (c *Client) SendPacket(pkt *packet.Packet, rsper *Responser) error
• type Messager
• type Responser

Variables

var Hub *hub

Functions

func BuildNewTunnel

func BuildNewTunnel(addr string)

func CompressByGzip

func CompressByGzip(in []byte) ([]byte, error)

func DecompressByGzip

func DecompressByGzip(in []byte) ([]byte, error)

func Decrypt

func Decrypt(key, input []byte) ([]byte, error)

func DirectRequest

func DirectRequest(req *http.Request, target *url.URL)

DirectRequest routes URLs to the scheme, host, and base path provided in target. If the target's path is "/base" and the incoming request was for "/dir", the target request will be for /base/dir. Learn NewSingleHostReverseProxy from https://golang.org/src/net/http/httputil/reverseproxy.go

func Encrypt

func Encrypt(key, input []byte) ([]byte, error)

refer: https://golang.org/pkg/crypto/cipher/#example_NewCFBDecrypter

func Forward

func Forward(target string, rw http.ResponseWriter, req *http.Request)

func NewDefaultHub

func NewDefaultHub() *hub

func ServeWS

func ServeWS(w http.ResponseWriter, r *http.Request)

serveWS handles websocket requests from the peer.

Types

type Client

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

Client is a middleman between the websocket connection and the hub.

func NewClient

func NewClient(addr string) *Client

func (*Client) Dial

func (c *Client) Dial() error

func (*Client) Run

func (c *Client) Run()

func (*Client) SendPacket

func (c *Client) SendPacket(pkt *packet.Packet, rsper *Responser) error

type Messager

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

Messager is messager for client and msg pair.

type Responser

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