refactor: remove unused LoaderError type and associated file; streamline error handling structure
This commit is contained in:
@@ -112,7 +112,7 @@ func processMigrationJob(
|
|||||||
}
|
}
|
||||||
|
|
||||||
chJobErrors := make(chan custom_errors.JobError, jobErrorsChannelSize)
|
chJobErrors := make(chan custom_errors.JobError, jobErrorsChannelSize)
|
||||||
chPartitions := make(chan models.Partition, job.ExtractorQueueSize)
|
chPartitions := make(chan models.Partition)
|
||||||
chBatchesRaw := make(chan models.Batch, job.ExtractorQueueSize)
|
chBatchesRaw := make(chan models.Batch, job.ExtractorQueueSize)
|
||||||
chBatchesTransformed := make(chan models.Batch, job.TransformerQueueSize)
|
chBatchesTransformed := make(chan models.Batch, job.TransformerQueueSize)
|
||||||
|
|
||||||
|
|||||||
@@ -1,14 +0,0 @@
|
|||||||
package custom_errors
|
|
||||||
|
|
||||||
import (
|
|
||||||
"git.ksdemosapps.com/kylesoda/go-migrate/internal/app/models"
|
|
||||||
)
|
|
||||||
|
|
||||||
type LoaderError struct {
|
|
||||||
Batch models.Batch
|
|
||||||
Msg string
|
|
||||||
}
|
|
||||||
|
|
||||||
func (e *LoaderError) Error() string {
|
|
||||||
return e.Msg
|
|
||||||
}
|
|
||||||
@@ -14,3 +14,12 @@ type ExtractorError struct {
|
|||||||
func (e *ExtractorError) Error() string {
|
func (e *ExtractorError) Error() string {
|
||||||
return e.Msg
|
return e.Msg
|
||||||
}
|
}
|
||||||
|
|
||||||
|
type LoaderError struct {
|
||||||
|
Batch models.Batch
|
||||||
|
Msg string
|
||||||
|
}
|
||||||
|
|
||||||
|
func (e *LoaderError) Error() string {
|
||||||
|
return e.Msg
|
||||||
|
}
|
||||||
@@ -1 +0,0 @@
|
|||||||
package transformers
|
|
||||||
Reference in New Issue
Block a user