tunnelproxy

Documentation

Overview

Package tunnelproxy implements a reverse-proxy for kites behind firewall or NAT.

Index

• Constants
• Variables
• func JoinStreams(local, remote io.ReadWriteCloser) chan error
• type PrivateKite
• type Proxy
  • func New(conf *config.Config, version, pubKey, privKey string) *Proxy
  • func (p *Proxy) Close()
  • func (s *Proxy) CloseNotify() chan bool
  • func (s *Proxy) ReadyNotify() chan bool
  • func (p *Proxy) Run()
  • func (p *Proxy) Start()
• type SessionReadWriteCloser
  • func (s SessionReadWriteCloser) Close() error
  • func (s SessionReadWriteCloser) Read(b []byte) (int, error)
  • func (s SessionReadWriteCloser) Write(b []byte) (int, error)
• type Tunnel
  • func (t *Tunnel) Close()
  • func (t *Tunnel) CloseNotify() chan bool
  • func (t *Tunnel) Run(remoteConn sockjs.Session)
  • func (t *Tunnel) StartNotify() chan bool

Constants

const (
	ProxyVersion = "0.0.2"
)

Variables

var (
	DefaultPort       = 3999
	DefaultPublicHost = "localhost:3999"
)

Functions

func JoinStreams

func JoinStreams(local, remote io.ReadWriteCloser) chan error

Types

type PrivateKite

type PrivateKite struct {
	*kite.Client
	// contains filtered or unexported fields
}

type Proxy

type Proxy struct {
	Kite *kite.Kite

	TLSConfig *tls.Config

	// If givent it must match the domain in certificate.
	PublicHost string

	RegisterToKontrol bool
	// contains filtered or unexported fields
}

func New

func New(conf *config.Config, version, pubKey, privKey string) *Proxy

func (*Proxy) Close

func (p *Proxy) Close()

func (*Proxy) CloseNotify

func (s *Proxy) CloseNotify() chan bool

func (*Proxy) ReadyNotify

func (s *Proxy) ReadyNotify() chan bool

func (*Proxy) Run

func (p *Proxy) Run()

func (*Proxy) Start

func (p *Proxy) Start()

type SessionReadWriteCloser

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

func (SessionReadWriteCloser) Close

func (s SessionReadWriteCloser) Close() error

func (SessionReadWriteCloser) Read

func (s SessionReadWriteCloser) Read(b []byte) (int, error)

func (SessionReadWriteCloser) Write

func (s SessionReadWriteCloser) Write(b []byte) (int, error)

type Tunnel

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

func (*Tunnel) Close

func (t *Tunnel) Close()

func (*Tunnel) CloseNotify

func (t *Tunnel) CloseNotify() chan bool

func (*Tunnel) Run

func (t *Tunnel) Run(remoteConn sockjs.Session)

func (*Tunnel) StartNotify

func (t *Tunnel) StartNotify() chan bool