diff --git a/internal/app/etl/extractor/mssql.go b/internal/app/etl/extractor/mssql.go
index 40da1de..662171c 100644
--- a/internal/app/etl/extractor/mssql.go
+++ b/internal/app/etl/extractor/mssql.go
@@ -21,7 +21,7 @@ type MssqlExtractor struct {
 	db *sql.DB
 }
 
-func NewMssqlExtractor(db *sql.DB) *MssqlExtractor {
+func NewMssqlExtractor(db *sql.DB) Extractor {
 	return &MssqlExtractor{db: db}
 }
 
diff --git a/internal/app/etl/extractor/postgres.go b/internal/app/etl/extractor/postgres.go
index 86f0a2b..489da10 100644
--- a/internal/app/etl/extractor/postgres.go
+++ b/internal/app/etl/extractor/postgres.go
@@ -19,7 +19,7 @@ type PostgresExtractor struct {
 	db *pgxpool.Pool
 }
 
-func NewPostgresExtractor(pool *pgxpool.Pool) *PostgresExtractor {
+func NewPostgresExtractor(pool *pgxpool.Pool) Extractor {
 	return &PostgresExtractor{db: pool}
 }
 
diff --git a/internal/app/etl/transformer/mssql.go b/internal/app/etl/transformer/mssql.go
index ef6dc0a..213e6f0 100644
--- a/internal/app/etl/transformer/mssql.go
+++ b/internal/app/etl/transformer/mssql.go
@@ -12,7 +12,7 @@ import (
 
 type MssqlTransformer struct{}
 
-func NewMssqlTransformer() *MssqlTransformer {
+func NewMssqlTransformer() Transformer {
 	return &MssqlTransformer{}
 }