add afterinit to mysql and file plugin

linyows · Oct 4, 2023 · 73072de · 73072de
1 parent 799f984
commit 73072de
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/plugin/file/main.go b/plugin/file/main.go
@@ -40,6 +40,9 @@ func (f *File) writer() (io.Writer, error) {
 	return f.file, nil
 }
 
+func (f *File) AfterInit() {
+}
+
 func (f *File) AfterComm(d *warp.AfterCommData) {
 	writer, err := f.writer()
 	if err != nil {

diff --git a/plugin/mysql/main.go b/plugin/mysql/main.go
@@ -38,6 +38,9 @@ func (m *Mysql) Conn() (*sql.DB, error) {
 	return m.pool, nil
 }
 
+func (m *Mysql) AfterInit() {
+}
+
 func (m *Mysql) AfterComm(d *warp.AfterCommData) {
 	conn, err := m.Conn()
 	if err != nil {