tcp

Documentation

Index

• Variables
• type Binder
  • func (binder Binder) Start(ws *websocket.Conn, store *service.SessionStore) error
• type Service
  • func NewService(conf config.Server) Service
  • func (serv Service) GetBinder(key string, port int) (service.Binder, error)
• type Session
  • func NewSession(conn *net.TCPConn) *Session
  • func (sess Session) Close() error
  • func (sess Session) PeerAddr() net.Addr
  • func (sess Session) Start(ws *websocket.Conn) error

Variables

var ErrUnauthorizedKey = errors.New("unauthorized key")

ErrUnauthorizedKey is returned when a key is not authorized.

var ErrUnauthorizedPort = errors.New("unauthorized port")

ErrUnauthorizedPort is returned when a key is not allowed to bind to a requested port.

Types

type Binder

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

Binder implements service.Binder for TCP tunneling service.

func (Binder) Start

func (binder Binder) Start(ws *websocket.Conn, store *service.SessionStore) error

Start binds to a TCP port and creates tcp.Session for each client connection.

type Service

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

Service implements service.Service for TCP tunneling service.

func NewService

func NewService(conf config.Server) Service

NewService creates a tcp.Service with given server configuration.

func (Service) GetBinder

func (serv Service) GetBinder(key string, port int) (service.Binder, error)

GetBinder returns a tcp.Binder for an agent with given authorization key and given TCP port.

type Session

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

Session implements service.Session for TCP tunneling.

func NewSession

func NewSession(conn *net.TCPConn) *Session

NewSession creates a Session for tunneling given TCP connection.

func (Session) Close

func (sess Session) Close() error

Close closes client connection.

func (Session) PeerAddr

func (sess Session) PeerAddr() net.Addr

PeerAddr returns the address of the connected client.

func (Session) Start

func (sess Session) Start(ws *websocket.Conn) error

Start starts tunneling TCP packets through given websocket channel.