mysqlproxy

type ClientSess struct {
	ClientMysql    *server.Conn
	TargetMysql    *client.Conn
	ProxySrv       *ProxySrv
	TargetNet      string
	TargetAddr     string
	TargetUser     string
	TargetPassword string
	TargetDB       string
}

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

type LogWriter interface {
	PushToLogChannel(ctx context.Context, sp *sendpacket.SendPacket) error
	PutSendPacket(b *sendpacket.SendPacket)
	GetSendPacket() *sendpacket.SendPacket
	CloseChannel()
}

type Provider ConfigProvider

type ProxyCfg struct {
	ProxyListenAddr string        `default:":3307"` // "localhost:3307"
	ProxyListentNet string        `default:"tcp"`   // tcp or unix
	ConTimeout      time.Duration `default:"300s"`

	LogFileName     string        `default:"mysql-audit.%Y%m%d%H.log.gz"`
	EncodeType      string        `default:"binary"`
	LogGzip         bool          `default:"true"`
	RotateTime      time.Duration `default:"1h"`
	BufSizeMB       string        `default:"32"`
	QueueSize       int           `default:"200"`
	BufferFlushTime time.Duration `default:"1s"`
	AdminUser       string        `default:"admin"`
	Debug           bool          `default:"false"`
}

type ProxySrv struct {
	AuditLogWriter LogWriter
	SvConfMng      *serverconfig.Manager
	Config         *ProxyCfg
	// contains filtered or unexported fields
}

type ProxyUser struct {
	Username string
	Password string
}

type SendTask struct {
	Reader net.Conn
	Writer io.Writer
	User   string
	DB     string
	Addr   string
	ConnID uint32
	Config *ProxyCfg
	LogWriter
}