fix(staging): return StagingStore interface from constructors to satisfy iface linter

Author: whites11

flow/connectors/clickhouse/staging.go

@@ -7,9 +7,8 @@ import (
 	"net/url"
 	"strings"
 
-	"github.com/aws/aws-sdk-go-v2/aws"
-
 	clickhouseproto "github.com/ClickHouse/clickhouse-go/v2/lib/proto"
+	"github.com/aws/aws-sdk-go-v2/aws"
 
 	"github.com/PeerDB-io/peerdb/flow/connectors/utils"
 	"github.com/PeerDB-io/peerdb/flow/generated/protos"

flow/connectors/utils/staging_gcs.go

@@ -26,7 +26,7 @@ type GCSStagingStore struct {
 	fullPath string
 }
 
-func NewGCSStagingStore(ctx context.Context, bucketPath string) (*GCSStagingStore, error) {
+func NewGCSStagingStore(ctx context.Context, bucketPath string) (StagingStore, error) {
 	// bucketPath is "gcs://bucket/prefix" or just "bucket/prefix"
 	path := strings.TrimPrefix(bucketPath, "gcs://")
 	path = strings.TrimPrefix(path, "gs://")

flow/connectors/utils/staging_s3.go

@@ -24,7 +24,7 @@ type S3StagingStore struct {
 	fullPath string // original "s3://bucket/prefix" for logging
 }
 
-func NewS3StagingStore(bucketPath string, creds AWSCredentialsProvider) (*S3StagingStore, error) {
+func NewS3StagingStore(bucketPath string, creds AWSCredentialsProvider) (StagingStore, error) {
 	s3o, err := NewS3BucketAndPrefix(bucketPath)
 	if err != nil {
 		return nil, fmt.Errorf("failed to parse S3 bucket path: %w", err)