feat: update extractor and transformer constructors to return Extractor interface
This commit is contained in:
@@ -21,7 +21,7 @@ type MssqlExtractor struct {
|
|||||||
db *sql.DB
|
db *sql.DB
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewMssqlExtractor(db *sql.DB) *MssqlExtractor {
|
func NewMssqlExtractor(db *sql.DB) Extractor {
|
||||||
return &MssqlExtractor{db: db}
|
return &MssqlExtractor{db: db}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -19,7 +19,7 @@ type PostgresExtractor struct {
|
|||||||
db *pgxpool.Pool
|
db *pgxpool.Pool
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewPostgresExtractor(pool *pgxpool.Pool) *PostgresExtractor {
|
func NewPostgresExtractor(pool *pgxpool.Pool) Extractor {
|
||||||
return &PostgresExtractor{db: pool}
|
return &PostgresExtractor{db: pool}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -12,7 +12,7 @@ import (
|
|||||||
|
|
||||||
type MssqlTransformer struct{}
|
type MssqlTransformer struct{}
|
||||||
|
|
||||||
func NewMssqlTransformer() *MssqlTransformer {
|
func NewMssqlTransformer() Transformer {
|
||||||
return &MssqlTransformer{}
|
return &MssqlTransformer{}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user