proxy

Oct 9, 2018

Changes in this version

type Client

+ func (c *Client) Shutdown(termTimeout time.Duration) error

Sep 29, 2017

Changes in this version

+ const DefaultRefreshCfgThrottle

+ const SQLScope

type Client

+ ConnectionsCounter uint64

+ MaxConnections uint64

Jun 23, 2017

Changes in this version

+ func Dial(instance string) (net.Conn, error)

+ func Init(auth *http.Client, connset *ConnSet, dialer Dialer)

+ func InitClient(c Client)

+ func InitDefault(ctx context.Context) error

+ func NewConnSrc(instance string, l net.Listener) <-chan Conn

+ type CertSource interface

+ Local func(instance string) (tls.Certificate, error)

+ Remote func(instance string) (cert *x509.Certificate, addr, name string, err error)

+ type Client struct

+ Certs CertSource

+ Conns *ConnSet

+ Dialer func(net, addr string) (net.Conn, error)

+ Port int

+ RefreshCfgThrottle time.Duration

+ func (c *Client) Dial(instance string) (net.Conn, error)

+ func (c *Client) Run(connSrc <-chan Conn)

+ type Conn struct

+ Conn net.Conn

+ Instance string

+ type ConnSet struct

+ func NewConnSet() *ConnSet

+ func (c *ConnSet) Add(id string, conn net.Conn)

+ func (c *ConnSet) Close() error

+ func (c *ConnSet) Conns(ids ...string) []net.Conn

+ func (c *ConnSet) IDs() []string

+ func (c *ConnSet) Remove(id string, conn net.Conn) error

+ func (c *ConnSet) String() string

+ type Dialer func(net, addr string) (net.Conn, error)