remotedialer

package

v2.0.7+incompatible Latest Latest Go to latest Published: Aug 11, 2018 License: Apache-2.0 Imports: 19 Imported by: 0

Details

View Source

const (
	Data messageType = iota + 1
	Connect
	Error
)

View Source

var (
	PingWaitDuration  = time.Duration(10 * time.Second)
	PingWriteInterval = time.Duration(5 * time.Second)
	MaxRead           = 8192
)

func AlwaysReady() bool

func ClientConnect(wsURL string, headers http.Header, dialer *websocket.Dialer, auth ConnectAuthorizer, onConnect func(context.Context) error)

func DefaultErrorWriter(rw http.ResponseWriter, req *http.Request, code int, err error)

type Authorizer func(req *http.Request) (clientKey string, authed bool, err error)

type ConnectAuthorizer func(proto, address string) bool

type ErrorWriter func(rw http.ResponseWriter, req *http.Request, code int, err error)

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

func New(auth Authorizer, errorWriter ErrorWriter, ready func() bool) *Server

func (s *Server) Dial(clientKey string, deadline time.Duration, proto, address string) (net.Conn, error)

func (s *Server) Dialer(clientKey string, deadline time.Duration) dialer.Dialer

func (s *Server) HasSession(clientKey string) bool

func (s *Server) ServeHTTP(rw http.ResponseWriter, req *http.Request)