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 Conn interface {
	net.Conn
	SetReadDeadline(t time.Time) error  // go-mysql 側で呼ばれることが多いので proxy
	SetWriteDeadline(t time.Time) error // 同上
}

type DebugConn struct {
	Conn   Conn
	Prefix string
	// contains filtered or unexported fields
}

type DebugWriter struct {
	W      io.Writer // 実際に書き込む先
	Prefix string    // 行頭に付けるプレフィックス（例: "clientWrite:"）
	// 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"`
	RotateTime      time.Duration `default:"1h"`
	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
}