registry

package

v0.0.4-beta1 Latest Latest Go to latest Published: Apr 25, 2021 License: Apache-2.0 Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type HttpProps struct {
	Host string
}

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

func (t *HttpsTunnel) GetSession() *yamux.Session

func (t *HttpsTunnel) Match(req http.Header) bool

type Protocol string

const (
	HttpProtocol Protocol = "http"
	TlsProtocol  Protocol = "tls"
)

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

type TlsProps struct {
	Sni string
}

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

func (t *TlsTunnel) GetSession() *yamux.Session

func (t *TlsTunnel) Match(clientHello *tls.ClientHelloInfo) bool

type Tunnel interface {
	GetSession() *yamux.Session
	Match(req *http.Request, clientHello *tls.ClientHelloInfo) bool
}

type TunnelCtx struct {
	DestConn        net.Conn
	Reader          *bufio.Reader
	Conn            net.Conn
	ClientHelloInfo *tls.ClientHelloInfo
}

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

func NewTunnelRegistry(db *gorm.DB) *TunnelRegistry

func (r *TunnelRegistry) GetHttpSession(req http.Header) (*yamux.Session, *db.Tunnel, error)

func (r *TunnelRegistry) GetHttpTunnels() (map[string]*HttpsTunnel, error)

func (r *TunnelRegistry) GetTLSSession(clientHello *tls.ClientHelloInfo) (*yamux.Session, *db.Tunnel, error)

func (r *TunnelRegistry) GetTLSTunnels() (map[string]*TlsTunnel, error)

func (r *TunnelRegistry) RemoveSession(tunn *db.Tunnel) error

func (r *TunnelRegistry) StoreSession(
	sess *yamux.Session,
) (*db.Tunnel, error)