From 73072de15ff053a342be3b9bfbc391ff493c5bfb Mon Sep 17 00:00:00 2001 From: linyows Date: Thu, 5 Oct 2023 00:52:48 +0900 Subject: [PATCH] add afterinit to mysql and file plugin --- plugin/file/main.go | 3 +++ plugin/mysql/main.go | 3 +++ 2 files changed, 6 insertions(+) diff --git a/plugin/file/main.go b/plugin/file/main.go index 7cbda57..becf0a6 100644 --- 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 index eaa7426..ce0a70b 100644 --- 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 {