feat: process compass sink concurrently

[batrov]

Add concurrent processing during compass sink

[Copilot]

Pull Request Overview

This PR introduces concurrent processing in the Compass sink to handle record sinking concurrently.

• Added sync.WaitGroup and error channel for concurrent error handling
• Wraps record processing in a goroutine for parallel execution

[Copilot]

Pull Request Overview

This PR introduces concurrent processing for sinking records to the compass service. Key changes include:

• Employing golang.org/x/sync/errgroup to process records concurrently.
• Removing error wrapping in favor of returning raw errors.
• Updating the test’s expected error message accordingly.

Reviewed Changes

Copilot reviewed 2 out of 2 changed files in this pull request and generated 2 comments.

File	Description
plugins/sinks/compass/sink_test.go	Updated expected error message to match changes in error propagation.
plugins/sinks/compass/sink.go	Introduced concurrent processing using errgroup and modified error returns.

[Copilot]

Pull Request Overview

Add concurrent processing to the Compass sink using errgroup, update tests for the new error flow, and ensure CI artifacts are uniquely named per job.

• Introduce an errgroup.Group to run send calls in parallel in Sink.
• Simplify error propagation by returning underlying errors directly.
• Parameterize coverage artifact names in the GitHub Actions workflow with ${{ strategy.job-index }}.

Reviewed Changes

Copilot reviewed 3 out of 3 changed files in this pull request and generated 3 comments.

File	Description
plugins/sinks/compass/sink.go	Use errgroup for concurrent sinking and simplify error returns
plugins/sinks/compass/sink_test.go	Adjust expected error message to match the simplified error path
.github/workflows/test.yml	Add job-index suffix to coverage artifact names

Comments suppressed due to low confidence (1)

plugins/sinks/compass/sink.go:99

• [nitpick] The variable name errCh is ambiguous; consider renaming to group or eg to clarify that it’s an errgroup.Group.

errCh := errgroup.Group{}