feat(clickhouse): add StagingStore abstraction for GCS staging support#4200

Merged

whites11 merged 27 commits into

mainfrom

feat/gcs-staging-store

May 7, 2026

Commits on May 5, 2026

feat(clickhouse): add StagingStore abstraction for cloud-agnostic staging

whites11
and
claude
committed
fix(staging): address golangci-lint issues in staging store

whites11
and
claude
committed
fix(staging): remove trailing blank line flagged by gci

whites11
and
claude
committed
feat(clickhouse): add unified PEERDB_CLICKHOUSE_STAGING_BUCKET_NAME env var

whites11
and
claude
committed
fix(staging): rename duplicate WriteRecordsToS3 to WriteRecordsToStaging
whites11
committed
refactor(clickhouse): extract staging store setup into staging.go
whites11
committed
refactor(clickhouse): move S3 session-token version check into createS3StagingStore
whites11
committed
refactor(clickhouse): inline staging upload instead of WriteRecordsToStaging
whites11
committed
fix(staging): return StagingStore interface from constructors to satisfy iface linter
whites11
committed
fix(staging): use interface methods in tests instead of S3-specific accessors
whites11
committed
fix(staging): revert to concrete return types, add interface conformance checks
whites11
committed
refactor(staging): move S3 bucket name fallback into PeerDBClickHouseStagingBucketName
whites11
committed
refactor(staging): remove unused PeerDBClickHouseAWSS3BucketName
whites11
committed
fix(staging): remove unused env param from createS3StagingStore
whites11
committed
refactor(staging): address review comments
whites11
committed

Commits on May 6, 2026

Commits on May 7, 2026

address review: keep panic stacktrace in WriteOCF, drop unused ClickHouseS3Credentials
whites11
committed