remove pipeline mocks, rename NOOPProcessor to NoOpProcessor

.gitignore

@@ -21,4 +21,4 @@
 go.work
 
 # Generated files
-mocks
+mocks/

backup_handlers.go

@@ -77,7 +77,7 @@ func (bh *backupHandler) run(writers []*WriteWorker[*models.Token]) error {
 
 	processorWorkers := make([]pipeline.Worker[*models.Token], bh.config.Parallel)
 	for i := 0; i < bh.config.Parallel; i++ {
-		processor := NewNOOPProcessor()
+		processor := NewNoOpProcessor()
 		processorWorkers[i] = NewProcessorWorker(processor)
 	}
 

processors.go

@@ -82,20 +82,18 @@ func (w *ProcessorWorker[T]) Run(ctx context.Context) error {
 	}
 }
 
-// **** NOOP Processor ****
+// **** NoOp Processor ****
 
-// NOOPProcessor satisfies the DataProcessor interface
+// NoOpProcessor satisfies the DataProcessor interface
 // It does nothing to the data
-type NOOPProcessor struct{}
+type NoOpProcessor struct{}
 
-// NewNOOPProcessor creates a new NOOPProcessor
-func NewNOOPProcessor() *NOOPProcessor {
-	return &NOOPProcessor{}
+// NewNoOpProcessor creates a new NOOPProcessor
+func NewNoOpProcessor() *NoOpProcessor {
+	return &NoOpProcessor{}
 }
 
 // Process processes the data
-func (p *NOOPProcessor) Process(data *models.Token) (*models.Token, error) {
+func (p *NoOpProcessor) Process(data *models.Token) (*models.Token, error) {
 	return data, nil
 }
-
-type NOOPProcessorFactory struct{}

processors_test.go

@@ -170,7 +170,7 @@ func (suite *proccessorTestSuite) TestProcessorWorkerProcessFailed() {
 }
 
 func (suite *proccessorTestSuite) TestNOOPProcessor() {
-	noop := NewNOOPProcessor()
+	noop := NewNoOpProcessor()
 	suite.NotNil(noop)
 
 	data := &models.Token{

restore_handlers.go

@@ -61,7 +61,7 @@ func (rh *restoreHandler) run(readers []*ReadWorker[*models.Token]) error {
 
 	processorWorkers := make([]pipeline.Worker[*models.Token], rh.config.Parallel)
 	for i := 0; i < rh.config.Parallel; i++ {
-		processor := NewNOOPProcessor()
+		processor := NewNoOpProcessor()
 		processorWorkers[i] = NewProcessorWorker(processor)
 	}