relay

May 17, 2024

Changes in this version

+ func IsProxy(r *http.Request) bool

May 17, 2024

Changes in this version

+ var AuthenticatedProxyHandler = ConnectVerbose(ProxyAuthenticate(NewProxyHandler()))

+ func ConnectVerbose(next http.Handler) http.Handler

+ func IsAuthenticatedProxy(r *http.Request) bool

+ func ProxyDispatcher(r *http.Request) http.Handler

May 11, 2024

Changes in this version

+ var AuthenticatedConnectHandler = ProxyAuthenticate(NewConnectHandler())

+ func CheckProxyAuth(user, pass string) bool

+ func ProxyAuthenticate(next http.Handler) http.Handler

May 11, 2024

Changes in this version

+ type DispatcherFunc func(*http.Request) http.Handler

+ func (d DispatcherFunc) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Storage

+ Use func(middlewares ...muxr.Middleware)

May 2, 2024

Changes in this version

+ var ConnectHandler = NewConnectHandler()

+ type Dispatcher interface

+ Dispatch func(r *http.Request) http.Handler

type SessionStore

+ func (s *SessionStore) Dispatch(r *http.Request) http.Handler

type WSServer

+ func (s *WSServer) Dispatch(r *http.Request) http.Handler

type WTServer

+ func (s *WTServer) Dispatch(r *http.Request) http.Handler

May 1, 2024

Changes in this version

type SessionStore

+ func (s *SessionStore) GetRoundTripper(k string) (http.RoundTripper, bool)

type Storage

+ GetRoundTripper func(k string) (http.RoundTripper, bool)

May 1, 2024

Changes in this version

type WebsocketUpgrader

+ HOST string

Apr 30, 2024

Changes in this version

+ func ReadLine(conn io.Reader) (string, error)

+ type GoQuicUpgrader struct

+ HOST string

+ Listener *quic.Endpoint

+ func (s *GoQuicUpgrader) Root() string

+ func (s *GoQuicUpgrader) Upgrade() (*Request, error)

+ type HTTPUpgrader interface

+ type QuicGoUpgrader struct

+ HOST string

+ func (s *QuicGoUpgrader) Root() string

+ func (s *QuicGoUpgrader) Upgrade() (*Request, error)

type Relayer

+ IsUpgrade func(r *http.Request) bool

+ type Request struct

+ Header http.Header

+ Path string

+ RealIP string

+ Session transport.Session

+ Stream transport.Stream

+ Values url.Values

type SessionStore

+ func (s *SessionStore) Subscribe(upgrader Upgrader)

+ type Subscriber interface

+ Subscribe func(upgrader Upgrader)

+ type TcpUpgrader struct

+ HOST string

+ func (s *TcpUpgrader) Root() string

+ func (s *TcpUpgrader) Upgrade() (*Request, error)

type WSServer

+ func (s *WSServer) IsRoot(r *http.Request) bool

+ func (s *WSServer) RecordsHandler(w http.ResponseWriter, r *http.Request)

type WTServer

+ func (s *WTServer) IsRoot(r *http.Request) bool

+ func (s *WTServer) IsUpgrade(r *http.Request) bool

type WebsocketUpgrader

+ func (s *WebsocketUpgrader) ServeHTTP(w http.ResponseWriter, r *http.Request)

type WebtransportUpgrader

+ func (s *WebtransportUpgrader) ServeHTTP(w http.ResponseWriter, r *http.Request)

Apr 28, 2024

Changes in this version

+ func IsConnect(r *http.Request) bool

+ func NewConnectHandler() http.Handler

type WSServer

+ Connect http.Handler

type WTServer

+ Connect http.Handler

+ func (s *WTServer) ConnectHandler(w http.ResponseWriter, r *http.Request)

Apr 26, 2024

Changes in this version

type SessionStore

+ Client *http.Client

+ Webhook string

+ func (s *SessionStore) WebLog(msg string)

Apr 23, 2024

Changes in this version

+ func RoundTripper(tssn transport.Session) http.RoundTripper

type Record

+ func (r *Record) Matches(kvs url.Values) (ok bool)

Apr 19, 2024

Changes in this version

+ func ReverseProxy(tssn transport.Session) *httputil.ReverseProxy

+ func StripPort(hostport string) string

type SessionStore

+ Verbose bool

Apr 18, 2024

Changes in this version

type SessionStore

+ func (s *SessionStore) GetSession(k string) (transport.Session, bool)

+ func (s *SessionStore) Has(k string) bool

+ func (s *SessionStore) RemoveSession(tssn transport.Session)

+ func (s *SessionStore) Upsert(k string, tssn transport.Session, tstm transport.Stream, r *http.Request)

type Storage

+ GetSession func(k string) (transport.Session, bool)

+ Has func(k string) bool

+ RemoveSession func(tssn transport.Session)

+ Upsert func(k string, tssn transport.Session, tstm transport.Stream, r *http.Request)

Apr 15, 2024

Changes in this version

+ func YamuxReverseGender(conn io.ReadWriteCloser, config *yamux.Config, r *http.Request) (string, *yamux.Session, error)

Apr 15, 2024

Changes in this version

+ func RealIP(r *http.Request) (realIP string)

type Record

+ Header tags.Tags

+ IP string

Apr 15, 2024

Changes in this version

+ func Transport(tssn transport.Session) *http.Transport

Apr 14, 2024

Changes in this version

type WSServer

+ PostUpgrade http.Handler

+ func (s *WSServer) WithPostUpgrade(h http.Handler) *WSServer

type WTServer

+ func (s *WTServer) WithPostUpgrade(h http.Handler) *WTServer

Apr 14, 2024

Changes in this version

type WTServer

+ func (s *WTServer) WithAddr(a string) *WTServer

+ func (s *WTServer) WithHandler(h http.Handler) *WTServer

+ func (s *WTServer) WithTLSConfig(tlsConfig *tls.Config) *WTServer

Apr 14, 2024

Changes in this version

+ type Relayer interface

type SessionStore

+ func (sm *SessionStore) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Upgrader

+ IsRoot func(r *http.Request) bool

+ Root func() string

+ type WTServer struct

+ HOST string

+ PostUpgrade http.Handler

+ func NewWTServer(host, port string, store Storage, tlsConfig *tls.Config) *WTServer

+ func (s *WTServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

type WebsocketUpgrader

+ func (s *WebsocketUpgrader) IsRoot(r *http.Request) (result bool)

+ func (s *WebsocketUpgrader) IsUpgrade(r *http.Request) (result bool)

+ func (s *WebsocketUpgrader) Root() string

+ type WebtransportUpgrader struct

+ func (s *WebtransportUpgrader) IsRoot(r *http.Request) (result bool)

+ func (s *WebtransportUpgrader) IsUpgrade(r *http.Request) (result bool)

+ func (s *WebtransportUpgrader) Root() string

+ func (s *WebtransportUpgrader) Upgrade(w http.ResponseWriter, r *http.Request) (transport.Session, transport.Stream, error)

Apr 14, 2024

Changes in this version

type Record

+ Key string

+ Session transport.Session

+ Since time.Time

type SessionStore

+ Lock *sync.RWMutex

+ PingInterval time.Duration

+ Record map[string]*Record

Apr 14, 2024

Changes in this version

+ func DefaultIndex() http.Handler

+ type IRelay interface

type Relay

+ WSServer *WSServer

+ func (s *Relay) IsIndex(r *http.Request) (result bool)

+ func (s *Relay) IsUpgrade(r *http.Request) (result bool)

+ func (s *Relay) Upgrade(w http.ResponseWriter, r *http.Request) (transport.Session, transport.Stream, error)

+ type SessionStore struct

+ func NewSessionStore() *SessionStore

+ func (sm *SessionStore) Add(k string, tssn transport.Session, tstm transport.Stream, vals url.Values)

+ func (sm *SessionStore) Allocate(r *http.Request, root string) (string, string, error)

+ func (sm *SessionStore) Get(k string) (transport.Session, bool)

+ func (sm *SessionStore) Negotiate(r *http.Request, root string, tssn transport.Session, tstm transport.Stream) (string, error)

+ func (sm *SessionStore) Ping(tssn transport.Session, tstm transport.Stream)

+ func (sm *SessionStore) Records() (all []Record)

+ func (sm *SessionStore) RecordsHandler(w http.ResponseWriter, r *http.Request)

+ func (sm *SessionStore) Remove(ssn transport.Session)

+ func (sm *SessionStore) Scan(tssn transport.Session, tstm transport.Stream)

+ func (sm *SessionStore) Visited(k string)

+ type Storage interface

+ Add func(k string, tssn transport.Session, tstm transport.Stream, vals url.Values)

+ Allocate func(r *http.Request, root string) (key string, hostnamePath string, err error)

+ Get func(k string) (transport.Session, bool)

+ Negotiate func(r *http.Request, root string, tssn transport.Session, tstm transport.Stream) (key string, err error)

+ Records func() []Record

+ RecordsHandler func(w http.ResponseWriter, r *http.Request)

+ Remove func(transport.Session)

+ Visited func(k string)

+ type Upgrader interface

+ IsIndex func(r *http.Request) bool

+ IsUpgrade func(r *http.Request) bool

+ Upgrade func(w http.ResponseWriter, r *http.Request) (transport.Session, transport.Stream, error)

+ type WSServer struct

+ HOST string

+ Proxy http.Handler

+ func NewWSServer(host string, store Storage) *WSServer

+ func (sm *WSServer) ConnectHandler(w http.ResponseWriter, r *http.Request)

+ func (sm *WSServer) IndexHandler(w http.ResponseWriter, r *http.Request)

+ func (sm *WSServer) IsIndex(r *http.Request) (result bool)

+ func (sm *WSServer) IsUpgrade(r *http.Request) (result bool)

+ func (sm *WSServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type WebsocketUpgrader struct

+ func (*WebsocketUpgrader) Upgrade(w http.ResponseWriter, r *http.Request) (tssn transport.Session, tstm transport.Stream, err error)

Apr 13, 2024

Changes in this version

type SessionManager

+ func (sm *SessionManager) IsWebsocketUpgrade(r *http.Request) (result bool)

Mar 26, 2024

Changes in this version

type Relay

+ WTServer *webtransportGo.Server

+ type WebtransportUpgraderFunc func(http.ResponseWriter, *http.Request) (*webtransportGo.Session, error)

Mar 26, 2024

Changes in this version

+ var PingInterval = 5 * time.Second

+ func Index() http.Handler

+ func IsWebsocketUpgrade(r *http.Request) (result bool)

+ func IsWebtransportUpgrade(r *http.Request) (result bool)

+ func NewProxyHandler() http.Handler

+ func ProxyBasicAuth(r *http.Request) (username, password string, ok bool)

+ func UpgradeWebsocketSession(w http.ResponseWriter, r *http.Request) (tssn transport.Session, tstm transport.Stream, err error)

+ type ExpVarStruct struct

+ WebteleportRelaySessionsAccepted *expvar.Int

+ WebteleportRelaySessionsClosed *expvar.Int

+ WebteleportRelayStreamsClosed *expvar.Int

+ WebteleportRelayStreamsSpawned *expvar.Int

+ func NewExpVarStruct() *ExpVarStruct

+ type Record struct

+ CreatedAt time.Time

+ Host string

+ Tags tags.Tags

+ Visited int

type Relay

+ SessionManager *SessionManager

+ func (s *Relay) UpgradeWebtransportHandler() http.Handler

+ type SessionManager struct

+ HOST string

+ func NewSessionManager(host string) *SessionManager

+ func (sm *SessionManager) Add(k string, tssn transport.Session, vals url.Values) error

+ func (sm *SessionManager) AddSession(r *http.Request, tssn transport.Session, tstm transport.Stream)

+ func (sm *SessionManager) ApiSessionsHandler(w http.ResponseWriter, r *http.Request)

+ func (sm *SessionManager) ConnectHandler(w http.ResponseWriter, r *http.Request)

+ func (sm *SessionManager) DelSession(ssn transport.Session)

+ func (sm *SessionManager) Get(k string) (transport.Session, bool)

+ func (sm *SessionManager) IncrementVisit(k string)

+ func (sm *SessionManager) IndexHandler(w http.ResponseWriter, r *http.Request)

+ func (sm *SessionManager) Lease(r *http.Request, tssn transport.Session, tstm transport.Stream) error

+ func (sm *SessionManager) Ping(tssn transport.Session, tstm transport.Stream)

+ func (sm *SessionManager) Scan(tssn transport.Session, tstm transport.Stream)

+ func (sm *SessionManager) ServeHTTP(w http.ResponseWriter, r *http.Request)

Feb 1, 2024

Changes in this version

type Relay

+ func (s *Relay) IsWebsocketUpgrade(r *http.Request) (result bool)

+ func (s *Relay) IsWebtransportUpgrade(r *http.Request) (result bool)

Jan 1, 2024

Changes in this version

+ type Relay struct

+ HOST string

+ Next http.Handler

+ func New(host, port string, next http.Handler, tlsConfig *tls.Config) *Relay

+ func (s *Relay) IsWebTeleportRequest(r *http.Request) bool

+ func (s *Relay) ServeHTTP(w http.ResponseWriter, r *http.Request)