lib

Documentation

Index

• type ClientMapAddr
  • func (addr ClientMapAddr) Network() string
  • func (addr ClientMapAddr) String() string
• type HTTPHandler
  • func (handler *HTTPHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type SnowflakeClientConn
  • func (conn *SnowflakeClientConn) RemoteAddr() net.Addr
• type SnowflakeListener
  • func (l *SnowflakeListener) Accept() (net.Conn, error)
  • func (l *SnowflakeListener) Addr() net.Addr
  • func (l *SnowflakeListener) Close() error
  • func (l *SnowflakeListener) QueueConn(conn net.Conn) error
• type Transport
  • func NewSnowflakeServer(getCertificate func(*tls.ClientHelloInfo) (*tls.Certificate, error)) *Transport
  • func (t *Transport) Listen(addr net.Addr) (*SnowflakeListener, error)

Types

type ClientMapAddr

type ClientMapAddr string

func (ClientMapAddr) Network

func (addr ClientMapAddr) Network() string

func (ClientMapAddr) String

func (addr ClientMapAddr) String() string

type HTTPHandler

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

func (*HTTPHandler) ServeHTTP

func (handler *HTTPHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type SnowflakeClientConn

type SnowflakeClientConn struct {
	net.Conn
	// contains filtered or unexported fields
}

A wrapper for the underlying oneshot or turbotunnel conn because we need to reference our mapping to determine the client address

func (*SnowflakeClientConn) RemoteAddr

func (conn *SnowflakeClientConn) RemoteAddr() net.Addr

type SnowflakeListener

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

func (*SnowflakeListener) Accept

func (l *SnowflakeListener) Accept() (net.Conn, error)

Allows the caller to accept incoming Snowflake connections We accept connections from a queue to accommodate both incoming smux Streams and legacy non-turbotunnel connections

func (*SnowflakeListener) Addr

func (l *SnowflakeListener) Addr() net.Addr

func (*SnowflakeListener) Close

func (l *SnowflakeListener) Close() error

func (*SnowflakeListener) QueueConn

func (l *SnowflakeListener) QueueConn(conn net.Conn) error

type Transport

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

Transport is a structure with methods that conform to the Go PT v2.1 API https://github.com/Pluggable-Transports/Pluggable-Transports-spec/blob/master/releases/PTSpecV2.1/Pluggable%20Transport%20Specification%20v2.1%20-%20Go%20Transport%20API.pdf

func NewSnowflakeServer

func NewSnowflakeServer(getCertificate func(*tls.ClientHelloInfo) (*tls.Certificate, error)) *Transport

func (*Transport) Listen

func (t *Transport) Listen(addr net.Addr) (*SnowflakeListener, error)