From 47645c5b49e9f242201859544648e433ec5e4802 Mon Sep 17 00:00:00 2001 From: Rafael Jesus Date: Tue, 6 Mar 2018 16:12:45 +0100 Subject: [PATCH] not so short name for timeout --- pkg/reader/mysql/reader.go | 4 ++-- pkg/reader/postgres/reader.go | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/pkg/reader/mysql/reader.go b/pkg/reader/mysql/reader.go index 3f74fdd..27af88a 100644 --- a/pkg/reader/mysql/reader.go +++ b/pkg/reader/mysql/reader.go @@ -17,8 +17,8 @@ type storage struct { } // NewStorage ... -func NewStorage(conn *sql.DB, t time.Duration) reader.Reader { - return generic.NewSqlReader(&storage{conn}, t) +func NewStorage(conn *sql.DB, timeout time.Duration) reader.Reader { + return generic.NewSqlReader(&storage{conn}, timeout) } // GetConnection return the connection diff --git a/pkg/reader/postgres/reader.go b/pkg/reader/postgres/reader.go index 371eab8..026d291 100644 --- a/pkg/reader/postgres/reader.go +++ b/pkg/reader/postgres/reader.go @@ -18,12 +18,12 @@ type storage struct { } // NewStorage ... -func NewStorage(conn *sql.DB, dumper PgDump, t time.Duration) reader.Reader { +func NewStorage(conn *sql.DB, dumper PgDump, timeout time.Duration) reader.Reader { s := &storage{ PgDump: dumper, connection: conn, } - return generic.NewSqlReader(s, t) + return generic.NewSqlReader(s, timeout) } func (s *storage) GetConnection() *sql.DB {