refactor: use Transformer.ProcessBatchWith in parsers

pkg/stanza/operator/parser/container/parser.go

@@ -69,11 +69,7 @@ type Parser struct {
 }
 
 func (p *Parser) ProcessBatch(ctx context.Context, entries []*entry.Entry) error {
-	var errs []error
-	for i := range entries {
-		errs = append(errs, p.Process(ctx, entries[i]))
-	}
-	return errors.Join(errs...)
+	return p.ProcessBatchWith(ctx, entries, p.Process)
 }
 
 // Process will parse an entry of Container logs

pkg/stanza/operator/parser/csv/parser.go

@@ -4,7 +4,6 @@ package csv // import "github.com/open-telemetry/opentelemetry-collector-contrib
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"strings"
 
@@ -29,11 +28,7 @@ type Parser struct {
 type parseFunc func(any) (any, error)
 
 func (p *Parser) ProcessBatch(ctx context.Context, entries []*entry.Entry) error {
-	var errs []error
-	for i := range entries {
-		errs = append(errs, p.Process(ctx, entries[i]))
-	}
-	return errors.Join(errs...)
+	return p.ProcessBatchWith(ctx, entries, p.Process)
 }
 
 // Process will parse an entry for csv.

pkg/stanza/operator/parser/json/parser.go

@@ -5,7 +5,6 @@ package json // import "github.com/open-telemetry/opentelemetry-collector-contri
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"strings"
 
@@ -23,11 +22,7 @@ type Parser struct {
 }
 
 func (p *Parser) ProcessBatch(ctx context.Context, entries []*entry.Entry) error {
-	var errs []error
-	for i := range entries {
-		errs = append(errs, p.Process(ctx, entries[i]))
-	}
-	return errors.Join(errs...)
+	return p.ProcessBatchWith(ctx, entries, p.Process)
 }
 
 // Process will parse an entry for JSON.

pkg/stanza/operator/parser/jsonarray/parser.go

@@ -22,11 +22,7 @@ type Parser struct {
 type parseFunc func(any) (any, error)
 
 func (p *Parser) ProcessBatch(ctx context.Context, entries []*entry.Entry) error {
-	var errs []error
-	for i := range entries {
-		errs = append(errs, p.Process(ctx, entries[i]))
-	}
-	return errors.Join(errs...)
+	return p.ProcessBatchWith(ctx, entries, p.Process)
 }
 
 // Process will parse an entry for json array.

pkg/stanza/operator/parser/keyvalue/parser.go

@@ -5,7 +5,6 @@ package keyvalue // import "github.com/open-telemetry/opentelemetry-collector-co
 
 import (
 	"context"
-	"errors"
 	"fmt"
 
 	"github.com/open-telemetry/opentelemetry-collector-contrib/internal/coreinternal/parseutils"
@@ -21,11 +20,7 @@ type Parser struct {
 }
 
 func (p *Parser) ProcessBatch(ctx context.Context, entries []*entry.Entry) error {
-	var errs []error
-	for i := range entries {
-		errs = append(errs, p.Process(ctx, entries[i]))
-	}
-	return errors.Join(errs...)
+	return p.ProcessBatchWith(ctx, entries, p.Process)
 }
 
 // Process will parse an entry for key value pairs.

pkg/stanza/operator/parser/regex/parser.go

@@ -5,7 +5,6 @@ package regex // import "github.com/open-telemetry/opentelemetry-collector-contr
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"regexp"
 
@@ -28,11 +27,7 @@ func (p *Parser) Stop() error {
 }
 
 func (p *Parser) ProcessBatch(ctx context.Context, entries []*entry.Entry) error {
-	var errs []error
-	for i := range entries {
-		errs = append(errs, p.Process(ctx, entries[i]))
-	}
-	return errors.Join(errs...)
+	return p.ProcessBatchWith(ctx, entries, p.Process)
 }
 
 // Process will parse an entry for regex.

pkg/stanza/operator/parser/scope/parser.go

@@ -5,7 +5,6 @@ package scope // import "github.com/open-telemetry/opentelemetry-collector-contr
 
 import (
 	"context"
-	"errors"
 
 	"github.com/open-telemetry/opentelemetry-collector-contrib/pkg/stanza/entry"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/pkg/stanza/operator/helper"
@@ -18,11 +17,7 @@ type Parser struct {
 }
 
 func (p *Parser) ProcessBatch(ctx context.Context, entries []*entry.Entry) error {
-	var errs []error
-	for i := range entries {
-		errs = append(errs, p.Process(ctx, entries[i]))
-	}
-	return errors.Join(errs...)
+	return p.ProcessBatchWith(ctx, entries, p.Process)
 }
 
 // Process will parse logger name from an entry.

pkg/stanza/operator/parser/severity/parser.go

@@ -5,7 +5,6 @@ package severity // import "github.com/open-telemetry/opentelemetry-collector-co
 
 import (
 	"context"
-	"errors"
 
 	"github.com/open-telemetry/opentelemetry-collector-contrib/pkg/stanza/entry"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/pkg/stanza/operator/helper"
@@ -18,11 +17,7 @@ type Parser struct {
 }
 
 func (p *Parser) ProcessBatch(ctx context.Context, entries []*entry.Entry) error {
-	var errs []error
-	for i := range entries {
-		errs = append(errs, p.Process(ctx, entries[i]))
-	}
-	return errors.Join(errs...)
+	return p.ProcessBatchWith(ctx, entries, p.Process)
 }
 
 // Process will parse severity from an entry.

pkg/stanza/operator/parser/syslog/parser.go

@@ -6,7 +6,6 @@ package syslog // import "github.com/open-telemetry/opentelemetry-collector-cont
 import (
 	"bytes"
 	"context"
-	"errors"
 	"fmt"
 	"regexp"
 	"time"
@@ -38,11 +37,7 @@ type Parser struct {
 }
 
 func (p *Parser) ProcessBatch(ctx context.Context, entries []*entry.Entry) error {
-	var errs []error
-	for i := range entries {
-		errs = append(errs, p.Process(ctx, entries[i]))
-	}
-	return errors.Join(errs...)
+	return p.ProcessBatchWith(ctx, entries, p.Process)
 }
 
 // Process will parse an entry field as syslog.

pkg/stanza/operator/parser/time/parser.go

@@ -5,7 +5,6 @@ package time // import "github.com/open-telemetry/opentelemetry-collector-contri
 
 import (
 	"context"
-	"errors"
 
 	"github.com/open-telemetry/opentelemetry-collector-contrib/pkg/stanza/entry"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/pkg/stanza/operator/helper"
@@ -18,11 +17,7 @@ type Parser struct {
 }
 
 func (p *Parser) ProcessBatch(ctx context.Context, entries []*entry.Entry) error {
-	var errs []error
-	for i := range entries {
-		errs = append(errs, p.Process(ctx, entries[i]))
-	}
-	return errors.Join(errs...)
+	return p.ProcessBatchWith(ctx, entries, p.Process)
 }
 
 // Process will parse time from an entry.

pkg/stanza/operator/parser/trace/parser.go

@@ -5,7 +5,6 @@ package trace // import "github.com/open-telemetry/opentelemetry-collector-contr
 
 import (
 	"context"
-	"errors"
 
 	"github.com/open-telemetry/opentelemetry-collector-contrib/pkg/stanza/entry"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/pkg/stanza/operator/helper"
@@ -18,11 +17,7 @@ type Parser struct {
 }
 
 func (p *Parser) ProcessBatch(ctx context.Context, entries []*entry.Entry) error {
-	var errs []error
-	for i := range entries {
-		errs = append(errs, p.Process(ctx, entries[i]))
-	}
-	return errors.Join(errs...)
+	return p.ProcessBatchWith(ctx, entries, p.Process)
 }
 
 // Process will parse traces from an entry.

pkg/stanza/operator/parser/uri/parser.go

@@ -5,7 +5,6 @@ package uri // import "github.com/open-telemetry/opentelemetry-collector-contrib
 
 import (
 	"context"
-	"errors"
 	"fmt"
 
 	"go.opentelemetry.io/collector/featuregate"
@@ -34,11 +33,7 @@ type Parser struct {
 }
 
 func (p *Parser) ProcessBatch(ctx context.Context, entries []*entry.Entry) error {
-	var errs []error
-	for i := range entries {
-		errs = append(errs, p.Process(ctx, entries[i]))
-	}
-	return errors.Join(errs...)
+	return p.ProcessBatchWith(ctx, entries, p.Process)
 }
 
 // Process will parse an entry.