Skip to content

Commit

Permalink
not so short name for timeout
Browse files Browse the repository at this point in the history
  • Loading branch information
rafaeljesus committed Mar 6, 2018
1 parent 807e0c0 commit 47645c5
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions pkg/reader/mysql/reader.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
4 changes: 2 additions & 2 deletions pkg/reader/postgres/reader.go
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down

0 comments on commit 47645c5

Please sign in to comment.