remotedialer

Documentation

Index

• Constants
• Variables
• func ClientConnect(ctx context.Context, wsURL string, headers http.Header, ...) error
• func ConnectToProxy(rootCtx context.Context, proxyURL string, headers http.Header, ...) error
• func DefaultErrorWriter(rw http.ResponseWriter, req *http.Request, code int, err error)
• type Authorizer
• type ConnectAuthorizer
• type Dialer
• type ErrorWriter
• type Server
  • func New(auth Authorizer, errorWriter ErrorWriter) *Server
  • func (s *Server) AddPeer(url, id, token string)
  • func (s *Server) Dialer(clientKey string) Dialer
  • func (s *Server) Disconnect(clientKey string)
  • func (r *Server) GetTransport(clusterCaCert string, clientKey string) (http.RoundTripper, error)
  • func (s *Server) HasSession(clientKey string) bool
  • func (s *Server) RemovePeer(id string)
  • func (s *Server) ServeHTTP(rw http.ResponseWriter, req *http.Request)
• type Session
  • func NewClientSession(auth ConnectAuthorizer, conn *websocket.Conn) *Session
  • func NewClientSessionWithDialer(auth ConnectAuthorizer, conn *websocket.Conn, dialer Dialer) *Session
  • func (s *Session) Close()
  • func (s *Session) CloseImmediately()
  • func (s *Session) Dial(ctx context.Context, proto, address string) (net.Conn, error)
  • func (s *Session) Serve(ctx context.Context) (int, error)

Constants

const (
	Data messageType = iota + 1
	Connect
	Error
	AddClient
	RemoveClient
)

const (
	PingWaitDuration  = 60 * time.Second
	PingWriteInterval = 5 * time.Second
	MaxRead           = 8192
	HandshakeTimeOut  = 10 * time.Second
)

const (
	MaxBuffer = 1 << 20
)

Variables

var (
	Token = "X-API-Tunnel-Token"
	ID    = "X-API-Tunnel-ID"
)

var PrintTunnelData bool

PrintTunnelData No tunnel logging by default

Functions

func ClientConnect

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

ClientConnect connect to WS and wait 5 seconds when error

func ConnectToProxy

func ConnectToProxy(rootCtx context.Context, proxyURL string, headers http.Header, auth ConnectAuthorizer, dialer *websocket.Dialer, onConnect func(context.Context, *Session) error) error

ConnectToProxy connect to websocket server

func DefaultErrorWriter

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

Types

type Authorizer

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

type ConnectAuthorizer

type ConnectAuthorizer func(proto, address string) bool

ConnectAuthorizer custom for authorization

type Dialer

type Dialer func(ctx context.Context, network, address string) (net.Conn, error)

type ErrorWriter

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

type Server

type Server struct {
	PeerID                  string
	PeerToken               string
	ClientConnectAuthorizer ConnectAuthorizer

	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New(auth Authorizer, errorWriter ErrorWriter) *Server

func (*Server) AddPeer

func (s *Server) AddPeer(url, id, token string)

func (*Server) Dialer

func (s *Server) Dialer(clientKey string) Dialer

func (*Server) Disconnect

func (s *Server) Disconnect(clientKey string)

func (*Server) GetTransport

func (r *Server) GetTransport(clusterCaCert string, clientKey string) (http.RoundTripper, error)

func (*Server) HasSession

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

func (*Server) RemovePeer

func (s *Server) RemovePeer(id string)

func (*Server) ServeHTTP

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

type Session

type Session struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewClientSession

func NewClientSession(auth ConnectAuthorizer, conn *websocket.Conn) *Session

func NewClientSessionWithDialer

func NewClientSessionWithDialer(auth ConnectAuthorizer, conn *websocket.Conn, dialer Dialer) *Session

func (*Session) Close

func (s *Session) Close()

func (*Session) CloseImmediately

func (s *Session) CloseImmediately()

func (*Session) Dial

func (s *Session) Dial(ctx context.Context, proto, address string) (net.Conn, error)

func (*Session) Serve

func (s *Session) Serve(ctx context.Context) (int, error)