Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

mysqlproxy

package

Go to main page

Versions in this module

v0

v0.0.6

Jun 8, 2025

v0.0.5

Jun 1, 2025

Changes in this version

+ func CopyDebug(prefix string, dst io.Writer, src io.Reader) (int64, error)

+ func DumpResult(res *mysql.Result, err error)

+ func PrintCapability(capability uint32)

+ type Conn interface

+ SetReadDeadline func(t time.Time) error

+ SetWriteDeadline func(t time.Time) error

+ type DebugConn struct

+ Conn Conn

+ Prefix string

+ func WrapConn(c Conn, prefix string) *DebugConn

+ func (d *DebugConn) Close() error

+ func (d *DebugConn) LocalAddr() net.Addr

+ func (d *DebugConn) Read(b []byte) (int, error)

+ func (d *DebugConn) RemoteAddr() net.Addr

+ func (d *DebugConn) SetDeadline(t time.Time) error

+ func (d *DebugConn) SetReadDeadline(t time.Time) error

+ func (d *DebugConn) SetWriteDeadline(t time.Time) error

+ func (d *DebugConn) Write(b []byte) (int, error)

+ type DebugWriter struct

+ Prefix string

+ W io.Writer

+ func (d *DebugWriter) Write(p []byte) (int, error)

v0.0.4

Jun 25, 2023

v0.0.3

Jun 24, 2023

v0.0.2

Jun 18, 2023

v0.0.1

Jun 17, 2023

Changes in this version

+ type ClientSess struct

+ ClientMysql *server.Conn

+ ProxySrv *ProxySrv

+ TargetAddr string

+ TargetDB string

+ TargetMysql *client.Conn

+ TargetNet string

+ TargetPassword string

+ TargetUser string

+ func (c *ClientSess) ConnectToMySQL(ctx context.Context) error

+ func (c *ClientSess) Proxy(ctx context.Context)

+ type ConfigProvider struct

+ func NewConfigProvider(m userManager) *ConfigProvider

+ func (m *ConfigProvider) CheckUsername(username string) (bool, error)

+ func (m *ConfigProvider) GetCredential(username string) (password string, found bool, err error)

+ type LogWriter interface

+ CloseChannel func()

+ GetSendPacket func() *sendpacket.SendPacket

+ PushToLogChannel func(ctx context.Context, sp *sendpacket.SendPacket) error

+ PutSendPacket func(b *sendpacket.SendPacket)

+ type Provider ConfigProvider

+ type ProxyCfg struct

+ AdminUser string

+ BufSizeMB string

+ BufferFlushTime time.Duration

+ ConTimeout time.Duration

+ Debug bool

+ EncodeType string

+ LogFileName string

+ LogGzip bool

+ ProxyListenAddr string

+ ProxyListentNet string

+ QueueSize int

+ RotateTime time.Duration

+ type ProxySrv struct

+ AuditLogWriter LogWriter

+ Config *ProxyCfg

+ SvConfMng *serverconfig.Manager

+ func (p *ProxySrv) Start(ctx context.Context) error

+ type ProxyUser struct

+ Password string

+ Username string

+ type SendTask struct

+ Addr string

+ Config *ProxyCfg

+ ConnID uint32

+ DB string

+ Reader net.Conn

+ User string

+ Writer io.Writer

+ func (st *SendTask) Worker(ctx context.Context) error