mysql

Documentation

Index

• type Proxy
  • func New(listenAddr, upstreamAddr string) *Proxy
  • func (p *Proxy) Close() error
  • func (p *Proxy) Events() <-chan proxy.Event
  • func (p *Proxy) ListenAndServe(ctx context.Context) error

Types

type Proxy

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

Proxy is a TCP proxy that sits between a MySQL client and server, capturing query events from the wire protocol.

func New

func New(listenAddr, upstreamAddr string) *Proxy

New creates a new MySQL proxy.

func (*Proxy) Close

func (p *Proxy) Close() error

Close stops the proxy and waits for all connections to finish.

func (*Proxy) Events

func (p *Proxy) Events() <-chan proxy.Event

Events returns the channel of captured events.

func (*Proxy) ListenAndServe

func (p *Proxy) ListenAndServe(ctx context.Context) error

ListenAndServe starts accepting client connections and relaying them to MySQL.