manager

Documentation

Index

• Variables
• func AddManagerSession(currentSession Session, r *http.Request)
• func Index() http.Handler
• func IsWebsocketUpgrade(r *http.Request) (result bool)
• func NewProxyHandler() http.Handler
• func ProxyBasicAuth(r *http.Request) (username, password string, ok bool)
• type ExpVarStruct
  • func NewExpVarStruct() *ExpVarStruct
• type Record
• type Session
  • func UpgradeWebsocketSession(w http.ResponseWriter, r *http.Request) (Session, error)
• type SessionManager
  • func (sm *SessionManager) Add(k string, ssn Session) error
  • 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 Session)
  • func (sm *SessionManager) Get(k string) (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, ssn Session, candidates []string, clobber string) error
  • func (sm *SessionManager) Ping(ssn Session)
  • func (sm *SessionManager) Scan(ssn Session)
  • func (sm *SessionManager) ServeHTTP(w http.ResponseWriter, r *http.Request)

Variables

var DefaultSessionManager = &SessionManager{
	HOST:     "<unknown>",
	counter:  0,
	sessions: map[string]Session{},
	ssnstamp: map[string]time.Time{},
	ssn_cntr: map[string]int{},
	slock:    &sync.RWMutex{},
	proxy:    NewProxyHandler(),
}

var PingInterval = 5 * time.Second

Functions

func AddManagerSession

func AddManagerSession(currentSession Session, r *http.Request)

func Index

func Index() http.Handler

func IsWebsocketUpgrade

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

func NewProxyHandler

func NewProxyHandler() http.Handler

func ProxyBasicAuth

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

Types

type ExpVarStruct

type ExpVarStruct struct {
	WebteleportRelayStreamsSpawned   *expvar.Int
	WebteleportRelayStreamsClosed    *expvar.Int
	WebteleportRelaySessionsAccepted *expvar.Int
	WebteleportRelaySessionsClosed   *expvar.Int
}

func NewExpVarStruct

func NewExpVarStruct() *ExpVarStruct

type Record

type Record struct {
	Host      string    `json:"host"`
	CreatedAt time.Time `json:"created_at"`
	Tags      tags.Tags `json:"tags"`
	Visited   int       `json:"visited"`
}

type Session

type Session interface {
	InitController(context.Context) error
	GetController() net.Conn
	GetValues() url.Values
	OpenConn(context.Context) (net.Conn, error)
}

func UpgradeWebsocketSession

func UpgradeWebsocketSession(w http.ResponseWriter, r *http.Request) (Session, error)

type SessionManager

type SessionManager struct {
	HOST string
	// contains filtered or unexported fields
}

func (*SessionManager) Add

func (sm *SessionManager) Add(k string, ssn Session) error

func (*SessionManager) ApiSessionsHandler

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

func (*SessionManager) ConnectHandler

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

func (*SessionManager) DelSession

func (sm *SessionManager) DelSession(ssn Session)

func (*SessionManager) Get

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

func (*SessionManager) IncrementVisit

func (sm *SessionManager) IncrementVisit(k string)

func (*SessionManager) IndexHandler

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

func (*SessionManager) Lease

func (sm *SessionManager) Lease(r *http.Request, ssn Session, candidates []string, clobber string) error

func (*SessionManager) Ping

func (sm *SessionManager) Ping(ssn Session)

func (*SessionManager) Scan

func (sm *SessionManager) Scan(ssn Session)

func (*SessionManager) ServeHTTP

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