feat(writers): Add streamingbatchwriter.Unimplemented* handlers (#1022)

Author: disq

writers/streamingbatchwriter/streamingbatchwriter.go

@@ -384,13 +384,6 @@ func (s *streamingWorkerManager[T]) run(ctx context.Context, wg *sync.WaitGroup,
 	}
 }
 
-// DummyHandler should be used to empty Migration and DeleteStale channels if they are not used.
-func DummyHandler[T message.WriteMessage](ch <-chan T) {
-	// nolint:revive
-	for range ch {
-	}
-}
-
 func timer(timeout time.Duration) <-chan time.Time {
 	if timeout == 0 {
 		return nil

writers/streamingbatchwriter/unimplemented.go

@@ -0,0 +1,27 @@
+package streamingbatchwriter
+
+import (
+	"context"
+
+	"github.com/cloudquery/plugin-sdk/v4/message"
+)
+
+// UnimplementedMigrateTable is a dummy handler to consume WriteMigrateTable messages
+type UnimplementedMigrateTable struct{}
+
+func (UnimplementedMigrateTable) MigrateTable(_ context.Context, ch <-chan *message.WriteMigrateTable) error {
+	// nolint:revive
+	for range ch {
+	}
+	return nil
+}
+
+// UnimplementedDeleteStale is a dummy handler to consume DeleteStale messages
+type UnimplementedDeleteStale struct{}
+
+func (UnimplementedDeleteStale) DeleteStale(_ context.Context, ch <-chan *message.WriteDeleteStale) error {
+	// nolint:revive
+	for range ch {
+	}
+	return nil
+}