diff --git a/e2e_cleanup/go.mod b/e2e_cleanup/go.mod index 93dcaac087..2f4c073701 100644 --- a/e2e_cleanup/go.mod +++ b/e2e_cleanup/go.mod @@ -1,4 +1,4 @@ -module github.com/PeerDB-io/peer-flow-cleanup +module github.com/PeerDB-io/peerdb/e2e_cleanup go 1.23.0 diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go index af18ba5661..7febb04d96 100644 --- a/flow/activities/flowable.go +++ b/flow/activities/flowable.go @@ -17,18 +17,18 @@ import ( "golang.org/x/sync/errgroup" "google.golang.org/protobuf/proto" - "github.com/PeerDB-io/peer-flow/alerting" - "github.com/PeerDB-io/peer-flow/connectors" - connmetadata "github.com/PeerDB-io/peer-flow/connectors/external_metadata" - connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/connectors/utils/monitoring" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/otel_metrics" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/pua" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/alerting" + "github.com/PeerDB-io/peerdb/flow/connectors" + connmetadata "github.com/PeerDB-io/peerdb/flow/connectors/external_metadata" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/connectors/utils/monitoring" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/otel_metrics" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/pua" + "github.com/PeerDB-io/peerdb/flow/shared" ) // CheckConnectionResult is the result of a CheckConnection call. diff --git a/flow/activities/flowable_core.go b/flow/activities/flowable_core.go index 32b4048914..c2ce678c58 100644 --- a/flow/activities/flowable_core.go +++ b/flow/activities/flowable_core.go @@ -17,14 +17,14 @@ import ( "golang.org/x/sync/errgroup" "google.golang.org/protobuf/proto" - "github.com/PeerDB-io/peer-flow/connectors" - connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres" - "github.com/PeerDB-io/peer-flow/connectors/utils/monitoring" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/otel_metrics" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + "github.com/PeerDB-io/peerdb/flow/connectors/utils/monitoring" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/otel_metrics" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) type PeerType string diff --git a/flow/activities/maintenance_activity.go b/flow/activities/maintenance_activity.go index be42cc8e56..a2ecfc21df 100644 --- a/flow/activities/maintenance_activity.go +++ b/flow/activities/maintenance_activity.go @@ -12,12 +12,12 @@ import ( "go.temporal.io/sdk/client" "google.golang.org/protobuf/types/known/timestamppb" - "github.com/PeerDB-io/peer-flow/alerting" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" - "github.com/PeerDB-io/peer-flow/shared/telemetry" + "github.com/PeerDB-io/peerdb/flow/alerting" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" + "github.com/PeerDB-io/peerdb/flow/shared/telemetry" ) const ( diff --git a/flow/activities/snapshot_activity.go b/flow/activities/snapshot_activity.go index 01c9e748e6..3df7926ea6 100644 --- a/flow/activities/snapshot_activity.go +++ b/flow/activities/snapshot_activity.go @@ -11,11 +11,11 @@ import ( "github.com/jackc/pgx/v5/pgxpool" "go.temporal.io/sdk/activity" - "github.com/PeerDB-io/peer-flow/alerting" - "github.com/PeerDB-io/peer-flow/connectors" - connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/alerting" + "github.com/PeerDB-io/peerdb/flow/connectors" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/shared" ) type SlotSnapshotState struct { diff --git a/flow/alerting/alerting.go b/flow/alerting/alerting.go index 535f6276ad..0daf72731b 100644 --- a/flow/alerting/alerting.go +++ b/flow/alerting/alerting.go @@ -18,11 +18,11 @@ import ( "go.temporal.io/sdk/log" "golang.org/x/crypto/ssh" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" - "github.com/PeerDB-io/peer-flow/shared/telemetry" - "github.com/PeerDB-io/peer-flow/tags" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" + "github.com/PeerDB-io/peerdb/flow/shared/telemetry" + "github.com/PeerDB-io/peerdb/flow/tags" ) // alerting service, no cool name :( diff --git a/flow/alerting/email_alert_sender.go b/flow/alerting/email_alert_sender.go index cc8acd7171..81b0bd5143 100644 --- a/flow/alerting/email_alert_sender.go +++ b/flow/alerting/email_alert_sender.go @@ -8,9 +8,9 @@ import ( "github.com/aws/aws-sdk-go-v2/service/ses" "github.com/aws/aws-sdk-go-v2/service/ses/types" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" - "github.com/PeerDB-io/peer-flow/shared/aws_common" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" + "github.com/PeerDB-io/peerdb/flow/shared/aws_common" ) type EmailAlertSender struct { diff --git a/flow/cmd/alerts.go b/flow/cmd/alerts.go index 93026652f8..04eed1fb41 100644 --- a/flow/cmd/alerts.go +++ b/flow/cmd/alerts.go @@ -5,9 +5,9 @@ import ( "github.com/jackc/pgx/v5" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) func (h *FlowRequestHandler) GetAlertConfigs(ctx context.Context, req *protos.GetAlertConfigsRequest) (*protos.GetAlertConfigsResponse, error) { diff --git a/flow/cmd/api.go b/flow/cmd/api.go index f81f9d923d..90be0503c5 100644 --- a/flow/cmd/api.go +++ b/flow/cmd/api.go @@ -23,11 +23,11 @@ import ( "google.golang.org/grpc/health/grpc_health_v1" "google.golang.org/grpc/reflection" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/middleware" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" - peerflow "github.com/PeerDB-io/peer-flow/workflows" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/middleware" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" + peerflow "github.com/PeerDB-io/peerdb/flow/workflows" ) type APIServerParams struct { diff --git a/flow/cmd/cert.go b/flow/cmd/cert.go index 60c36c8dfa..80e82b064f 100644 --- a/flow/cmd/cert.go +++ b/flow/cmd/cert.go @@ -5,7 +5,7 @@ import ( "crypto/tls" "fmt" - "github.com/PeerDB-io/peer-flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" ) func parseTemporalCertAndKey(ctx context.Context) ([]tls.Certificate, error) { diff --git a/flow/cmd/custom_sync.go b/flow/cmd/custom_sync.go index 968783f27a..6415ac34d8 100644 --- a/flow/cmd/custom_sync.go +++ b/flow/cmd/custom_sync.go @@ -6,8 +6,8 @@ import ( "fmt" "log/slog" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" ) const ( diff --git a/flow/cmd/handler.go b/flow/cmd/handler.go index 6caefaf47e..1a67ae5c49 100644 --- a/flow/cmd/handler.go +++ b/flow/cmd/handler.go @@ -14,14 +14,14 @@ import ( "go.temporal.io/sdk/client" "google.golang.org/protobuf/proto" - "github.com/PeerDB-io/peer-flow/alerting" - "github.com/PeerDB-io/peer-flow/connectors" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" - peerflow "github.com/PeerDB-io/peer-flow/workflows" + "github.com/PeerDB-io/peerdb/flow/alerting" + "github.com/PeerDB-io/peerdb/flow/connectors" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" + peerflow "github.com/PeerDB-io/peerdb/flow/workflows" ) // grpc server implementation diff --git a/flow/cmd/maintenance.go b/flow/cmd/maintenance.go index 474a67db37..fa1084f0e6 100644 --- a/flow/cmd/maintenance.go +++ b/flow/cmd/maintenance.go @@ -18,10 +18,10 @@ import ( "k8s.io/client-go/kubernetes" "k8s.io/client-go/rest" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" - peerflow "github.com/PeerDB-io/peer-flow/workflows" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" + peerflow "github.com/PeerDB-io/peerdb/flow/workflows" ) type MaintenanceCLIParams struct { diff --git a/flow/cmd/mirror_status.go b/flow/cmd/mirror_status.go index 156185054c..42a0241857 100644 --- a/flow/cmd/mirror_status.go +++ b/flow/cmd/mirror_status.go @@ -14,10 +14,10 @@ import ( "google.golang.org/protobuf/proto" "google.golang.org/protobuf/types/known/timestamppb" - "github.com/PeerDB-io/peer-flow/connectors" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/shared" - peerflow "github.com/PeerDB-io/peer-flow/workflows" + "github.com/PeerDB-io/peerdb/flow/connectors" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/shared" + peerflow "github.com/PeerDB-io/peerdb/flow/workflows" ) func (h *FlowRequestHandler) ListMirrors( diff --git a/flow/cmd/peer_data.go b/flow/cmd/peer_data.go index b821075011..a410f94fea 100644 --- a/flow/cmd/peer_data.go +++ b/flow/cmd/peer_data.go @@ -14,11 +14,11 @@ import ( "google.golang.org/protobuf/reflect/protoreflect" "google.golang.org/protobuf/types/descriptorpb" - "github.com/PeerDB-io/peer-flow/connectors" - connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) func redactProto(message proto.Message) { diff --git a/flow/cmd/scripts.go b/flow/cmd/scripts.go index a86118bff1..6e202d9f7a 100644 --- a/flow/cmd/scripts.go +++ b/flow/cmd/scripts.go @@ -6,7 +6,7 @@ import ( "github.com/jackc/pgx/v5" - "github.com/PeerDB-io/peer-flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/generated/protos" ) func (h *FlowRequestHandler) GetScripts(ctx context.Context, req *protos.GetScriptsRequest) (*protos.GetScriptsResponse, error) { diff --git a/flow/cmd/settings.go b/flow/cmd/settings.go index b2be7a1ba6..78c2dc2fc3 100644 --- a/flow/cmd/settings.go +++ b/flow/cmd/settings.go @@ -7,9 +7,9 @@ import ( "github.com/jackc/pgx/v5" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) func (h *FlowRequestHandler) GetDynamicSettings( diff --git a/flow/cmd/snapshot_worker.go b/flow/cmd/snapshot_worker.go index 5c274a9d4d..fc99796322 100644 --- a/flow/cmd/snapshot_worker.go +++ b/flow/cmd/snapshot_worker.go @@ -10,11 +10,11 @@ import ( "go.temporal.io/sdk/client" "go.temporal.io/sdk/worker" - "github.com/PeerDB-io/peer-flow/activities" - "github.com/PeerDB-io/peer-flow/alerting" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" - peerflow "github.com/PeerDB-io/peer-flow/workflows" + "github.com/PeerDB-io/peerdb/flow/activities" + "github.com/PeerDB-io/peerdb/flow/alerting" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" + peerflow "github.com/PeerDB-io/peerdb/flow/workflows" ) type SnapshotWorkerOptions struct { diff --git a/flow/cmd/tags_handler.go b/flow/cmd/tags_handler.go index ddd362c3e4..ccb50d390d 100644 --- a/flow/cmd/tags_handler.go +++ b/flow/cmd/tags_handler.go @@ -5,8 +5,8 @@ import ( "fmt" "log/slog" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/tags" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/tags" ) func (h *FlowRequestHandler) flowExists(ctx context.Context, flowName string) (bool, error) { diff --git a/flow/cmd/validate_mirror.go b/flow/cmd/validate_mirror.go index 83c9d2a073..fe94e9ff94 100644 --- a/flow/cmd/validate_mirror.go +++ b/flow/cmd/validate_mirror.go @@ -9,13 +9,13 @@ import ( "github.com/jackc/pgx/v5/pgtype" - "github.com/PeerDB-io/peer-flow/connectors" - connclickhouse "github.com/PeerDB-io/peer-flow/connectors/clickhouse" - connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared/telemetry" + "github.com/PeerDB-io/peerdb/flow/connectors" + connclickhouse "github.com/PeerDB-io/peerdb/flow/connectors/clickhouse" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared/telemetry" ) var ( diff --git a/flow/cmd/validate_peer.go b/flow/cmd/validate_peer.go index 44b675ed90..1057383eb0 100644 --- a/flow/cmd/validate_peer.go +++ b/flow/cmd/validate_peer.go @@ -6,11 +6,11 @@ import ( "log/slog" "time" - "github.com/PeerDB-io/peer-flow/connectors" - connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/shared" - "github.com/PeerDB-io/peer-flow/shared/telemetry" + "github.com/PeerDB-io/peerdb/flow/connectors" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/shared" + "github.com/PeerDB-io/peerdb/flow/shared/telemetry" ) func (h *FlowRequestHandler) ValidatePeer( diff --git a/flow/cmd/version.go b/flow/cmd/version.go index 577ab44994..5b66849f6a 100644 --- a/flow/cmd/version.go +++ b/flow/cmd/version.go @@ -3,8 +3,8 @@ package cmd import ( "context" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" ) func (h *FlowRequestHandler) GetVersion( diff --git a/flow/cmd/worker.go b/flow/cmd/worker.go index cfb4f0e049..6ca50d65eb 100644 --- a/flow/cmd/worker.go +++ b/flow/cmd/worker.go @@ -14,12 +14,12 @@ import ( temporalotel "go.temporal.io/sdk/contrib/opentelemetry" "go.temporal.io/sdk/worker" - "github.com/PeerDB-io/peer-flow/activities" - "github.com/PeerDB-io/peer-flow/alerting" - "github.com/PeerDB-io/peer-flow/otel_metrics" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" - peerflow "github.com/PeerDB-io/peer-flow/workflows" + "github.com/PeerDB-io/peerdb/flow/activities" + "github.com/PeerDB-io/peerdb/flow/alerting" + "github.com/PeerDB-io/peerdb/flow/otel_metrics" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" + peerflow "github.com/PeerDB-io/peerdb/flow/workflows" ) type WorkerSetupOptions struct { diff --git a/flow/connectors/bigquery/bigquery.go b/flow/connectors/bigquery/bigquery.go index ffe0016445..a0d0339369 100644 --- a/flow/connectors/bigquery/bigquery.go +++ b/flow/connectors/bigquery/bigquery.go @@ -16,12 +16,12 @@ import ( "go.temporal.io/sdk/log" "google.golang.org/api/iterator" - metadataStore "github.com/PeerDB-io/peer-flow/connectors/external_metadata" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + metadataStore "github.com/PeerDB-io/peerdb/flow/connectors/external_metadata" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) const ( diff --git a/flow/connectors/bigquery/clustering.go b/flow/connectors/bigquery/clustering.go index 6a5456ff49..c8c926f20d 100644 --- a/flow/connectors/bigquery/clustering.go +++ b/flow/connectors/bigquery/clustering.go @@ -3,7 +3,7 @@ package connbigquery import ( "cloud.google.com/go/bigquery" - "github.com/PeerDB-io/peer-flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/generated/protos" ) // Columns in BigQuery which are supported for clustering of tables diff --git a/flow/connectors/bigquery/merge_stmt_generator.go b/flow/connectors/bigquery/merge_stmt_generator.go index 3acf864785..e82878c763 100644 --- a/flow/connectors/bigquery/merge_stmt_generator.go +++ b/flow/connectors/bigquery/merge_stmt_generator.go @@ -4,9 +4,9 @@ import ( "fmt" "strings" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/shared" ) type mergeStmtGenerator struct { diff --git a/flow/connectors/bigquery/merge_stmt_generator_test.go b/flow/connectors/bigquery/merge_stmt_generator_test.go index 7d1e9969b0..bb38a737f3 100644 --- a/flow/connectors/bigquery/merge_stmt_generator_test.go +++ b/flow/connectors/bigquery/merge_stmt_generator_test.go @@ -4,8 +4,8 @@ import ( "reflect" "testing" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" ) func TestGenerateUpdateStatement(t *testing.T) { diff --git a/flow/connectors/bigquery/qrep.go b/flow/connectors/bigquery/qrep.go index a6d5c35d7a..b4a471d2a2 100644 --- a/flow/connectors/bigquery/qrep.go +++ b/flow/connectors/bigquery/qrep.go @@ -8,11 +8,11 @@ import ( "cloud.google.com/go/bigquery" - "github.com/PeerDB-io/peer-flow/datatypes" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/datatypes" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/shared" ) func (c *BigQueryConnector) SyncQRepRecords( diff --git a/flow/connectors/bigquery/qrep_avro_sync.go b/flow/connectors/bigquery/qrep_avro_sync.go index 07285eb997..95d5ffb9e5 100644 --- a/flow/connectors/bigquery/qrep_avro_sync.go +++ b/flow/connectors/bigquery/qrep_avro_sync.go @@ -12,11 +12,11 @@ import ( "cloud.google.com/go/bigquery" - avro "github.com/PeerDB-io/peer-flow/connectors/utils/avro" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/shared" + avro "github.com/PeerDB-io/peerdb/flow/connectors/utils/avro" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/shared" ) type QRepAvroSyncMethod struct { diff --git a/flow/connectors/bigquery/qvalue_convert.go b/flow/connectors/bigquery/qvalue_convert.go index 2ce0f6333e..b77496c298 100644 --- a/flow/connectors/bigquery/qvalue_convert.go +++ b/flow/connectors/bigquery/qvalue_convert.go @@ -5,9 +5,9 @@ import ( "cloud.google.com/go/bigquery" - "github.com/PeerDB-io/peer-flow/datatypes" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/datatypes" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" ) func qValueKindToBigQueryType(columnDescription *protos.FieldDescription, nullableEnabled bool) bigquery.FieldSchema { diff --git a/flow/connectors/clickhouse/cdc.go b/flow/connectors/clickhouse/cdc.go index 5dc4a53dd3..6442f7d1dc 100644 --- a/flow/connectors/clickhouse/cdc.go +++ b/flow/connectors/clickhouse/cdc.go @@ -10,11 +10,11 @@ import ( "github.com/ClickHouse/clickhouse-go/v2" _ "github.com/ClickHouse/clickhouse-go/v2/lib/driver" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/shared" ) const ( diff --git a/flow/connectors/clickhouse/clickhouse.go b/flow/connectors/clickhouse/clickhouse.go index ff77a74ba5..97978373fe 100644 --- a/flow/connectors/clickhouse/clickhouse.go +++ b/flow/connectors/clickhouse/clickhouse.go @@ -19,13 +19,13 @@ import ( "github.com/aws/aws-sdk-go-v2/aws" "go.temporal.io/sdk/log" - metadataStore "github.com/PeerDB-io/peer-flow/connectors/external_metadata" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" - chvalidate "github.com/PeerDB-io/peer-flow/shared/clickhouse" + metadataStore "github.com/PeerDB-io/peerdb/flow/connectors/external_metadata" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" + chvalidate "github.com/PeerDB-io/peerdb/flow/shared/clickhouse" ) type ClickHouseConnector struct { diff --git a/flow/connectors/clickhouse/normalize.go b/flow/connectors/clickhouse/normalize.go index 26e0cf9162..3483c4be88 100644 --- a/flow/connectors/clickhouse/normalize.go +++ b/flow/connectors/clickhouse/normalize.go @@ -15,10 +15,10 @@ import ( "github.com/ClickHouse/clickhouse-go/v2" "golang.org/x/sync/errgroup" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" ) const ( diff --git a/flow/connectors/clickhouse/qrep.go b/flow/connectors/clickhouse/qrep.go index 376d05e7ae..e011c7a31e 100644 --- a/flow/connectors/clickhouse/qrep.go +++ b/flow/connectors/clickhouse/qrep.go @@ -10,10 +10,10 @@ import ( "github.com/aws/aws-sdk-go-v2/aws" "github.com/aws/aws-sdk-go-v2/service/s3" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/shared" ) func (*ClickHouseConnector) SetupQRepMetadataTables(_ context.Context, _ *protos.QRepConfig) error { diff --git a/flow/connectors/clickhouse/qrep_avro_sync.go b/flow/connectors/clickhouse/qrep_avro_sync.go index 030de782f4..9492397e62 100644 --- a/flow/connectors/clickhouse/qrep_avro_sync.go +++ b/flow/connectors/clickhouse/qrep_avro_sync.go @@ -9,12 +9,12 @@ import ( "github.com/ClickHouse/clickhouse-go/v2/lib/driver" - "github.com/PeerDB-io/peer-flow/connectors/utils" - avro "github.com/PeerDB-io/peer-flow/connectors/utils/avro" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + avro "github.com/PeerDB-io/peerdb/flow/connectors/utils/avro" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/shared" ) type ClickHouseAvroSyncMethod struct { diff --git a/flow/connectors/clickhouse/s3_stage.go b/flow/connectors/clickhouse/s3_stage.go index 5f5eb899a4..5d9a3509a6 100644 --- a/flow/connectors/clickhouse/s3_stage.go +++ b/flow/connectors/clickhouse/s3_stage.go @@ -7,8 +7,8 @@ import ( "github.com/jackc/pgx/v5" - utils "github.com/PeerDB-io/peer-flow/connectors/utils/avro" - "github.com/PeerDB-io/peer-flow/peerdbenv" + utils "github.com/PeerDB-io/peerdb/flow/connectors/utils/avro" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" ) func SetAvroStage( diff --git a/flow/connectors/core.go b/flow/connectors/core.go index 8a52b01c31..0e1081dec5 100644 --- a/flow/connectors/core.go +++ b/flow/connectors/core.go @@ -9,23 +9,23 @@ import ( "github.com/jackc/pgx/v5/pgxpool" "google.golang.org/protobuf/proto" - "github.com/PeerDB-io/peer-flow/alerting" - connbigquery "github.com/PeerDB-io/peer-flow/connectors/bigquery" - connclickhouse "github.com/PeerDB-io/peer-flow/connectors/clickhouse" - connelasticsearch "github.com/PeerDB-io/peer-flow/connectors/elasticsearch" - conneventhub "github.com/PeerDB-io/peer-flow/connectors/eventhub" - connkafka "github.com/PeerDB-io/peer-flow/connectors/kafka" - connmysql "github.com/PeerDB-io/peer-flow/connectors/mysql" - connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres" - connpubsub "github.com/PeerDB-io/peer-flow/connectors/pubsub" - conns3 "github.com/PeerDB-io/peer-flow/connectors/s3" - connsnowflake "github.com/PeerDB-io/peer-flow/connectors/snowflake" - connsqlserver "github.com/PeerDB-io/peer-flow/connectors/sqlserver" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/otel_metrics" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/alerting" + connbigquery "github.com/PeerDB-io/peerdb/flow/connectors/bigquery" + connclickhouse "github.com/PeerDB-io/peerdb/flow/connectors/clickhouse" + connelasticsearch "github.com/PeerDB-io/peerdb/flow/connectors/elasticsearch" + conneventhub "github.com/PeerDB-io/peerdb/flow/connectors/eventhub" + connkafka "github.com/PeerDB-io/peerdb/flow/connectors/kafka" + connmysql "github.com/PeerDB-io/peerdb/flow/connectors/mysql" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + connpubsub "github.com/PeerDB-io/peerdb/flow/connectors/pubsub" + conns3 "github.com/PeerDB-io/peerdb/flow/connectors/s3" + connsnowflake "github.com/PeerDB-io/peerdb/flow/connectors/snowflake" + connsqlserver "github.com/PeerDB-io/peerdb/flow/connectors/sqlserver" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/otel_metrics" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) type Connector interface { diff --git a/flow/connectors/elasticsearch/elasticsearch.go b/flow/connectors/elasticsearch/elasticsearch.go index 30279fd74e..c87bb53986 100644 --- a/flow/connectors/elasticsearch/elasticsearch.go +++ b/flow/connectors/elasticsearch/elasticsearch.go @@ -19,13 +19,13 @@ import ( "github.com/elastic/go-elasticsearch/v8/esutil" "go.temporal.io/sdk/log" - metadataStore "github.com/PeerDB-io/peer-flow/connectors/external_metadata" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + metadataStore "github.com/PeerDB-io/peerdb/flow/connectors/external_metadata" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) const ( diff --git a/flow/connectors/elasticsearch/qrep.go b/flow/connectors/elasticsearch/qrep.go index 1206438d5f..8d018c4476 100644 --- a/flow/connectors/elasticsearch/qrep.go +++ b/flow/connectors/elasticsearch/qrep.go @@ -14,10 +14,10 @@ import ( "github.com/elastic/go-elasticsearch/v8/esutil" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/shared" ) func (esc *ElasticsearchConnector) SetupQRepMetadataTables(ctx context.Context, diff --git a/flow/connectors/eventhub/eventhub.go b/flow/connectors/eventhub/eventhub.go index 0f175233ef..153f57c5d9 100644 --- a/flow/connectors/eventhub/eventhub.go +++ b/flow/connectors/eventhub/eventhub.go @@ -12,13 +12,13 @@ import ( lua "github.com/yuin/gopher-lua" "go.temporal.io/sdk/log" - metadataStore "github.com/PeerDB-io/peer-flow/connectors/external_metadata" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/pua" - "github.com/PeerDB-io/peer-flow/shared" + metadataStore "github.com/PeerDB-io/peerdb/flow/connectors/external_metadata" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/pua" + "github.com/PeerDB-io/peerdb/flow/shared" ) type EventHubConnector struct { diff --git a/flow/connectors/eventhub/hub_batches.go b/flow/connectors/eventhub/hub_batches.go index e6c3e0bfac..8370f81742 100644 --- a/flow/connectors/eventhub/hub_batches.go +++ b/flow/connectors/eventhub/hub_batches.go @@ -10,7 +10,7 @@ import ( azeventhubs "github.com/Azure/azure-sdk-for-go/sdk/messaging/azeventhubs" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/shared" ) // multimap from ScopedEventhub to *azeventhubs.EventDataBatch diff --git a/flow/connectors/eventhub/hubmanager.go b/flow/connectors/eventhub/hubmanager.go index 5515eae880..525810f820 100644 --- a/flow/connectors/eventhub/hubmanager.go +++ b/flow/connectors/eventhub/hubmanager.go @@ -14,9 +14,9 @@ import ( "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" cmap "github.com/orcaman/concurrent-map/v2" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) type EventHubManager struct { diff --git a/flow/connectors/external_metadata/store.go b/flow/connectors/external_metadata/store.go index a87f1af481..d6ddcec4a2 100644 --- a/flow/connectors/external_metadata/store.go +++ b/flow/connectors/external_metadata/store.go @@ -13,10 +13,10 @@ import ( "go.temporal.io/sdk/log" "google.golang.org/protobuf/encoding/protojson" - "github.com/PeerDB-io/peer-flow/connectors/utils/monitoring" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors/utils/monitoring" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) const ( diff --git a/flow/connectors/kafka/kafka.go b/flow/connectors/kafka/kafka.go index ee78093fe6..2944a0e8c7 100644 --- a/flow/connectors/kafka/kafka.go +++ b/flow/connectors/kafka/kafka.go @@ -18,13 +18,13 @@ import ( lua "github.com/yuin/gopher-lua" "go.temporal.io/sdk/log" - metadataStore "github.com/PeerDB-io/peer-flow/connectors/external_metadata" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/pua" - "github.com/PeerDB-io/peer-flow/shared" + metadataStore "github.com/PeerDB-io/peerdb/flow/connectors/external_metadata" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/pua" + "github.com/PeerDB-io/peerdb/flow/shared" ) type KafkaConnector struct { diff --git a/flow/connectors/kafka/qrep.go b/flow/connectors/kafka/qrep.go index c6b60a564d..18f4b53b30 100644 --- a/flow/connectors/kafka/qrep.go +++ b/flow/connectors/kafka/qrep.go @@ -9,10 +9,10 @@ import ( "github.com/twmb/franz-go/pkg/kgo" lua "github.com/yuin/gopher-lua" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/pua" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/pua" + "github.com/PeerDB-io/peerdb/flow/shared" ) func (*KafkaConnector) SetupQRepMetadataTables(_ context.Context, _ *protos.QRepConfig) error { diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go index be93ecaa25..6a575f37fd 100644 --- a/flow/connectors/postgres/cdc.go +++ b/flow/connectors/postgres/cdc.go @@ -19,14 +19,14 @@ import ( "go.opentelemetry.io/otel/metric" "go.temporal.io/sdk/activity" - connmetadata "github.com/PeerDB-io/peer-flow/connectors/external_metadata" - "github.com/PeerDB-io/peer-flow/connectors/utils" - geo "github.com/PeerDB-io/peer-flow/datatypes" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/otel_metrics" - "github.com/PeerDB-io/peer-flow/shared" + connmetadata "github.com/PeerDB-io/peerdb/flow/connectors/external_metadata" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + geo "github.com/PeerDB-io/peerdb/flow/datatypes" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/otel_metrics" + "github.com/PeerDB-io/peerdb/flow/shared" ) type PostgresCDCSource struct { diff --git a/flow/connectors/postgres/client.go b/flow/connectors/postgres/client.go index 4816f1dd4d..1d7d7d589f 100644 --- a/flow/connectors/postgres/client.go +++ b/flow/connectors/postgres/client.go @@ -15,11 +15,11 @@ import ( "github.com/jackc/pgx/v5/pgtype" "github.com/lib/pq/oid" - "github.com/PeerDB-io/peer-flow/connectors/utils" - numeric "github.com/PeerDB-io/peer-flow/datatypes" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + numeric "github.com/PeerDB-io/peerdb/flow/datatypes" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/shared" ) const ( diff --git a/flow/connectors/postgres/normalize_stmt_generator.go b/flow/connectors/postgres/normalize_stmt_generator.go index 936911dd57..3ed24c31ec 100644 --- a/flow/connectors/postgres/normalize_stmt_generator.go +++ b/flow/connectors/postgres/normalize_stmt_generator.go @@ -8,10 +8,10 @@ import ( "go.temporal.io/sdk/log" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/shared" ) type normalizeStmtGenerator struct { diff --git a/flow/connectors/postgres/normalize_stmt_generator_test.go b/flow/connectors/postgres/normalize_stmt_generator_test.go index 342230ca00..f1c7e9f4ca 100644 --- a/flow/connectors/postgres/normalize_stmt_generator_test.go +++ b/flow/connectors/postgres/normalize_stmt_generator_test.go @@ -4,8 +4,8 @@ import ( "reflect" "testing" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" ) func TestGenerateMergeUpdateStatement(t *testing.T) { diff --git a/flow/connectors/postgres/postgres.go b/flow/connectors/postgres/postgres.go index 7f3005134b..7648a5479a 100644 --- a/flow/connectors/postgres/postgres.go +++ b/flow/connectors/postgres/postgres.go @@ -23,15 +23,15 @@ import ( "go.temporal.io/sdk/log" "go.temporal.io/sdk/temporal" - "github.com/PeerDB-io/peer-flow/alerting" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/connectors/utils/monitoring" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/otel_metrics" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/alerting" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/connectors/utils/monitoring" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/otel_metrics" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) type PostgresConnector struct { diff --git a/flow/connectors/postgres/postgres_schema_delta_test.go b/flow/connectors/postgres/postgres_schema_delta_test.go index 0b6668a5a2..0bfe553050 100644 --- a/flow/connectors/postgres/postgres_schema_delta_test.go +++ b/flow/connectors/postgres/postgres_schema_delta_test.go @@ -9,11 +9,11 @@ import ( "github.com/jackc/pgx/v5" "github.com/stretchr/testify/require" - "github.com/PeerDB-io/peer-flow/e2eshared" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/e2eshared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) type PostgresSchemaDeltaTestSuite struct { diff --git a/flow/connectors/postgres/qrep.go b/flow/connectors/postgres/qrep.go index 05aa492baa..ec45e98839 100644 --- a/flow/connectors/postgres/qrep.go +++ b/flow/connectors/postgres/qrep.go @@ -17,11 +17,11 @@ import ( "go.temporal.io/sdk/log" "google.golang.org/protobuf/encoding/protojson" - "github.com/PeerDB-io/peer-flow/connectors/utils" - partition_utils "github.com/PeerDB-io/peer-flow/connectors/utils/partition" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + partition_utils "github.com/PeerDB-io/peerdb/flow/connectors/utils/partition" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/shared" ) const qRepMetadataTableName = "_peerdb_query_replication_metadata" diff --git a/flow/connectors/postgres/qrep_bench_test.go b/flow/connectors/postgres/qrep_bench_test.go index 777faf6e6f..28d4853257 100644 --- a/flow/connectors/postgres/qrep_bench_test.go +++ b/flow/connectors/postgres/qrep_bench_test.go @@ -6,7 +6,7 @@ import ( "github.com/stretchr/testify/require" - "github.com/PeerDB-io/peer-flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" ) func BenchmarkQRepQueryExecutor(b *testing.B) { diff --git a/flow/connectors/postgres/qrep_partition_test.go b/flow/connectors/postgres/qrep_partition_test.go index a81df27698..0c89b378db 100644 --- a/flow/connectors/postgres/qrep_partition_test.go +++ b/flow/connectors/postgres/qrep_partition_test.go @@ -12,9 +12,9 @@ import ( "github.com/stretchr/testify/assert" "go.temporal.io/sdk/log" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) type testCase struct { diff --git a/flow/connectors/postgres/qrep_query_executor.go b/flow/connectors/postgres/qrep_query_executor.go index b8c14ee2e7..935ebe0ee5 100644 --- a/flow/connectors/postgres/qrep_query_executor.go +++ b/flow/connectors/postgres/qrep_query_executor.go @@ -10,10 +10,10 @@ import ( "github.com/jackc/pgx/v5/pgtype" "go.temporal.io/sdk/log" - "github.com/PeerDB-io/peer-flow/datatypes" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/datatypes" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/shared" ) type QRepQueryExecutor struct { diff --git a/flow/connectors/postgres/qrep_query_executor_test.go b/flow/connectors/postgres/qrep_query_executor_test.go index 78f82b07ea..e25c66d4f2 100644 --- a/flow/connectors/postgres/qrep_query_executor_test.go +++ b/flow/connectors/postgres/qrep_query_executor_test.go @@ -11,7 +11,7 @@ import ( "github.com/shopspring/decimal" "github.com/stretchr/testify/require" - "github.com/PeerDB-io/peer-flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" ) func setupDB(t *testing.T) (*PostgresConnector, string) { diff --git a/flow/connectors/postgres/qvalue_convert.go b/flow/connectors/postgres/qvalue_convert.go index 9e8f758489..158411687d 100644 --- a/flow/connectors/postgres/qvalue_convert.go +++ b/flow/connectors/postgres/qvalue_convert.go @@ -14,9 +14,9 @@ import ( "github.com/lib/pq/oid" "github.com/shopspring/decimal" - datatypes "github.com/PeerDB-io/peer-flow/datatypes" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/shared" + datatypes "github.com/PeerDB-io/peerdb/flow/datatypes" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/shared" ) func (c *PostgresConnector) postgresOIDToName(recvOID uint32) string { diff --git a/flow/connectors/postgres/schema_delta_test_constants.go b/flow/connectors/postgres/schema_delta_test_constants.go index 68750f436f..242940e814 100644 --- a/flow/connectors/postgres/schema_delta_test_constants.go +++ b/flow/connectors/postgres/schema_delta_test_constants.go @@ -1,8 +1,8 @@ package connpostgres import ( - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" ) var AddAllColumnTypesFields = []*protos.FieldDescription{ diff --git a/flow/connectors/postgres/sink_pg.go b/flow/connectors/postgres/sink_pg.go index cf62840925..784505eb85 100644 --- a/flow/connectors/postgres/sink_pg.go +++ b/flow/connectors/postgres/sink_pg.go @@ -9,8 +9,8 @@ import ( "github.com/jackc/pgx/v5" - "github.com/PeerDB-io/peer-flow/connectors/postgres/sanitize" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors/postgres/sanitize" + "github.com/PeerDB-io/peerdb/flow/shared" ) type PgCopyShared struct { diff --git a/flow/connectors/postgres/sink_q.go b/flow/connectors/postgres/sink_q.go index 648280e220..03de9c49e8 100644 --- a/flow/connectors/postgres/sink_q.go +++ b/flow/connectors/postgres/sink_q.go @@ -8,8 +8,8 @@ import ( "github.com/jackc/pgx/v5" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/shared" ) type RecordStreamSink struct { diff --git a/flow/connectors/postgres/ssh_wrapped_pool.go b/flow/connectors/postgres/ssh_wrapped_pool.go index ec90f4667b..09f394f83a 100644 --- a/flow/connectors/postgres/ssh_wrapped_pool.go +++ b/flow/connectors/postgres/ssh_wrapped_pool.go @@ -11,10 +11,10 @@ import ( "go.temporal.io/sdk/log" "golang.org/x/crypto/ssh" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) type SSHTunnel struct { diff --git a/flow/connectors/postgres/validate.go b/flow/connectors/postgres/validate.go index 1c700e7203..26ed27e882 100644 --- a/flow/connectors/postgres/validate.go +++ b/flow/connectors/postgres/validate.go @@ -8,8 +8,8 @@ import ( "github.com/jackc/pgx/v5" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/shared" ) func (c *PostgresConnector) CheckSourceTables(ctx context.Context, diff --git a/flow/connectors/pubsub/pubsub.go b/flow/connectors/pubsub/pubsub.go index 537cda7241..25b6e006b5 100644 --- a/flow/connectors/pubsub/pubsub.go +++ b/flow/connectors/pubsub/pubsub.go @@ -12,13 +12,13 @@ import ( lua "github.com/yuin/gopher-lua" "go.temporal.io/sdk/log" - metadataStore "github.com/PeerDB-io/peer-flow/connectors/external_metadata" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/pua" - "github.com/PeerDB-io/peer-flow/shared" + metadataStore "github.com/PeerDB-io/peerdb/flow/connectors/external_metadata" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/pua" + "github.com/PeerDB-io/peerdb/flow/shared" ) type PubSubConnector struct { diff --git a/flow/connectors/pubsub/qrep.go b/flow/connectors/pubsub/qrep.go index 5d84f6c22e..13e857559e 100644 --- a/flow/connectors/pubsub/qrep.go +++ b/flow/connectors/pubsub/qrep.go @@ -9,9 +9,9 @@ import ( "cloud.google.com/go/pubsub" lua "github.com/yuin/gopher-lua" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/pua" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/pua" ) func (*PubSubConnector) SetupQRepMetadataTables(_ context.Context, _ *protos.QRepConfig) error { diff --git a/flow/connectors/s3/qrep.go b/flow/connectors/s3/qrep.go index 41e1c7d05c..007ed88266 100644 --- a/flow/connectors/s3/qrep.go +++ b/flow/connectors/s3/qrep.go @@ -4,11 +4,11 @@ import ( "context" "fmt" - "github.com/PeerDB-io/peer-flow/connectors/utils" - avro "github.com/PeerDB-io/peer-flow/connectors/utils/avro" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + avro "github.com/PeerDB-io/peerdb/flow/connectors/utils/avro" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" ) func (c *S3Connector) SyncQRepRecords( diff --git a/flow/connectors/s3/s3.go b/flow/connectors/s3/s3.go index 7d16a20af0..e990820e88 100644 --- a/flow/connectors/s3/s3.go +++ b/flow/connectors/s3/s3.go @@ -9,11 +9,11 @@ import ( "github.com/aws/aws-sdk-go-v2/service/s3" "go.temporal.io/sdk/log" - metadataStore "github.com/PeerDB-io/peer-flow/connectors/external_metadata" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/shared" + metadataStore "github.com/PeerDB-io/peerdb/flow/connectors/external_metadata" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/shared" ) type S3Connector struct { diff --git a/flow/connectors/snowflake/avro_file_writer_test.go b/flow/connectors/snowflake/avro_file_writer_test.go index fbf86fc4c7..fad1bebd62 100644 --- a/flow/connectors/snowflake/avro_file_writer_test.go +++ b/flow/connectors/snowflake/avro_file_writer_test.go @@ -11,10 +11,10 @@ import ( "github.com/shopspring/decimal" "github.com/stretchr/testify/require" - avro "github.com/PeerDB-io/peer-flow/connectors/utils/avro" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" + avro "github.com/PeerDB-io/peerdb/flow/connectors/utils/avro" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" ) // createQValue creates a QValue of the appropriate kind for a given placeholder. diff --git a/flow/connectors/snowflake/client.go b/flow/connectors/snowflake/client.go index 72415403e6..4f162bff02 100644 --- a/flow/connectors/snowflake/client.go +++ b/flow/connectors/snowflake/client.go @@ -10,11 +10,11 @@ import ( "github.com/jmoiron/sqlx" "github.com/snowflakedb/gosnowflake" - peersql "github.com/PeerDB-io/peer-flow/connectors/sql" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/shared" + peersql "github.com/PeerDB-io/peerdb/flow/connectors/sql" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/shared" ) type SnowflakeClient struct { diff --git a/flow/connectors/snowflake/get_schema_for_tests.go b/flow/connectors/snowflake/get_schema_for_tests.go index 2f68cdaedf..1b7c0ba37b 100644 --- a/flow/connectors/snowflake/get_schema_for_tests.go +++ b/flow/connectors/snowflake/get_schema_for_tests.go @@ -3,9 +3,9 @@ package connsnowflake import ( "context" - "github.com/PeerDB-io/peer-flow/datatypes" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/datatypes" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" ) func (c *SnowflakeConnector) getTableSchemaForTable(ctx context.Context, tableName string) (*protos.TableSchema, error) { diff --git a/flow/connectors/snowflake/merge_stmt_generator.go b/flow/connectors/snowflake/merge_stmt_generator.go index d87d3004f7..141bd1a385 100644 --- a/flow/connectors/snowflake/merge_stmt_generator.go +++ b/flow/connectors/snowflake/merge_stmt_generator.go @@ -5,11 +5,11 @@ import ( "fmt" "strings" - "github.com/PeerDB-io/peer-flow/connectors/utils" - numeric "github.com/PeerDB-io/peer-flow/datatypes" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + numeric "github.com/PeerDB-io/peerdb/flow/datatypes" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/shared" ) type mergeStmtGenerator struct { diff --git a/flow/connectors/snowflake/merge_stmt_generator_test.go b/flow/connectors/snowflake/merge_stmt_generator_test.go index 5e36db8dce..12ccf3c1ea 100644 --- a/flow/connectors/snowflake/merge_stmt_generator_test.go +++ b/flow/connectors/snowflake/merge_stmt_generator_test.go @@ -4,8 +4,8 @@ import ( "reflect" "testing" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" ) func TestGenerateUpdateStatement(t *testing.T) { diff --git a/flow/connectors/snowflake/qrep.go b/flow/connectors/snowflake/qrep.go index 5566276999..82af865e83 100644 --- a/flow/connectors/snowflake/qrep.go +++ b/flow/connectors/snowflake/qrep.go @@ -11,10 +11,10 @@ import ( "github.com/aws/aws-sdk-go-v2/service/s3" "github.com/jackc/pgx/v5/pgtype" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/shared" ) type SnowflakeTableColumn struct { diff --git a/flow/connectors/snowflake/qrep_avro_consolidate.go b/flow/connectors/snowflake/qrep_avro_consolidate.go index a4a8d1a285..1e6b614d1e 100644 --- a/flow/connectors/snowflake/qrep_avro_consolidate.go +++ b/flow/connectors/snowflake/qrep_avro_consolidate.go @@ -8,9 +8,9 @@ import ( "strings" "time" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" ) type SnowflakeAvroConsolidateHandler struct { diff --git a/flow/connectors/snowflake/qrep_avro_sync.go b/flow/connectors/snowflake/qrep_avro_sync.go index dcaa28911a..b722422b7b 100644 --- a/flow/connectors/snowflake/qrep_avro_sync.go +++ b/flow/connectors/snowflake/qrep_avro_sync.go @@ -11,12 +11,12 @@ import ( _ "github.com/snowflakedb/gosnowflake" - "github.com/PeerDB-io/peer-flow/connectors/utils" - avro "github.com/PeerDB-io/peer-flow/connectors/utils/avro" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + avro "github.com/PeerDB-io/peerdb/flow/connectors/utils/avro" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/shared" ) type SnowflakeAvroSyncHandler struct { diff --git a/flow/connectors/snowflake/qvalue_convert.go b/flow/connectors/snowflake/qvalue_convert.go index 87a026a68b..df86b32b15 100644 --- a/flow/connectors/snowflake/qvalue_convert.go +++ b/flow/connectors/snowflake/qvalue_convert.go @@ -3,7 +3,7 @@ package connsnowflake import ( "fmt" - "github.com/PeerDB-io/peer-flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" ) var snowflakeTypeToQValueKindMap = map[string]qvalue.QValueKind{ diff --git a/flow/connectors/snowflake/snowflake.go b/flow/connectors/snowflake/snowflake.go index 9bb66e5922..04840dd165 100644 --- a/flow/connectors/snowflake/snowflake.go +++ b/flow/connectors/snowflake/snowflake.go @@ -17,13 +17,13 @@ import ( "go.temporal.io/sdk/log" "golang.org/x/sync/errgroup" - metadataStore "github.com/PeerDB-io/peer-flow/connectors/external_metadata" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + metadataStore "github.com/PeerDB-io/peerdb/flow/connectors/external_metadata" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) const ( diff --git a/flow/connectors/sql/query_executor.go b/flow/connectors/sql/query_executor.go index b110aa76ed..cbf644d293 100644 --- a/flow/connectors/sql/query_executor.go +++ b/flow/connectors/sql/query_executor.go @@ -15,8 +15,8 @@ import ( "github.com/shopspring/decimal" "go.temporal.io/sdk/log" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" ) //nolint:iface diff --git a/flow/connectors/sqlserver/qrep.go b/flow/connectors/sqlserver/qrep.go index a725fd0102..6212a85ab0 100644 --- a/flow/connectors/sqlserver/qrep.go +++ b/flow/connectors/sqlserver/qrep.go @@ -13,9 +13,9 @@ import ( "github.com/jmoiron/sqlx" "go.temporal.io/sdk/log" - utils "github.com/PeerDB-io/peer-flow/connectors/utils/partition" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" + utils "github.com/PeerDB-io/peerdb/flow/connectors/utils/partition" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" ) func (c *SQLServerConnector) GetQRepPartitions( diff --git a/flow/connectors/sqlserver/qvalue_convert.go b/flow/connectors/sqlserver/qvalue_convert.go index 57f2d90fb9..4dbf9e8c7e 100644 --- a/flow/connectors/sqlserver/qvalue_convert.go +++ b/flow/connectors/sqlserver/qvalue_convert.go @@ -1,6 +1,6 @@ package connsqlserver -import "github.com/PeerDB-io/peer-flow/model/qvalue" +import "github.com/PeerDB-io/peerdb/flow/model/qvalue" var qValueKindToSQLServerTypeMap = map[qvalue.QValueKind]string{ qvalue.QValueKindBoolean: "BIT", diff --git a/flow/connectors/sqlserver/sqlserver.go b/flow/connectors/sqlserver/sqlserver.go index 7017c81505..199cf054dd 100644 --- a/flow/connectors/sqlserver/sqlserver.go +++ b/flow/connectors/sqlserver/sqlserver.go @@ -8,9 +8,9 @@ import ( _ "github.com/microsoft/go-mssqldb" "go.temporal.io/sdk/log" - peersql "github.com/PeerDB-io/peer-flow/connectors/sql" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/shared" + peersql "github.com/PeerDB-io/peerdb/flow/connectors/sql" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/shared" ) type SQLServerConnector struct { diff --git a/flow/connectors/utils/avro/avro_writer.go b/flow/connectors/utils/avro/avro_writer.go index 277e0be44c..451f1cc809 100644 --- a/flow/connectors/utils/avro/avro_writer.go +++ b/flow/connectors/utils/avro/avro_writer.go @@ -20,11 +20,11 @@ import ( "github.com/klauspost/compress/zstd" "github.com/linkedin/goavro/v2" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) type ( diff --git a/flow/connectors/utils/aws.go b/flow/connectors/utils/aws.go index a9b212517b..c6265b4ebe 100644 --- a/flow/connectors/utils/aws.go +++ b/flow/connectors/utils/aws.go @@ -19,7 +19,7 @@ import ( smithyendpoints "github.com/aws/smithy-go/endpoints" "github.com/google/uuid" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/shared" ) const ( diff --git a/flow/connectors/utils/cdc_store.go b/flow/connectors/utils/cdc_store.go index d3e9d27f8d..a97ecbee01 100644 --- a/flow/connectors/utils/cdc_store.go +++ b/flow/connectors/utils/cdc_store.go @@ -16,10 +16,10 @@ import ( "github.com/shopspring/decimal" "go.temporal.io/sdk/log" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) func encVal(val any) ([]byte, error) { diff --git a/flow/connectors/utils/cdc_store_test.go b/flow/connectors/utils/cdc_store_test.go index 4bf149236f..208a28488e 100644 --- a/flow/connectors/utils/cdc_store_test.go +++ b/flow/connectors/utils/cdc_store_test.go @@ -10,8 +10,8 @@ import ( "github.com/shopspring/decimal" "github.com/stretchr/testify/require" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" ) func getTimeForTesting(t *testing.T) time.Time { diff --git a/flow/connectors/utils/gcp.go b/flow/connectors/utils/gcp.go index 4320e886a2..8839e7fe33 100644 --- a/flow/connectors/utils/gcp.go +++ b/flow/connectors/utils/gcp.go @@ -11,7 +11,7 @@ import ( "cloud.google.com/go/storage" "google.golang.org/api/option" - "github.com/PeerDB-io/peer-flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/generated/protos" ) type GcpServiceAccount struct { diff --git a/flow/connectors/utils/lua.go b/flow/connectors/utils/lua.go index bf77717f6e..a01bd47c4a 100644 --- a/flow/connectors/utils/lua.go +++ b/flow/connectors/utils/lua.go @@ -9,9 +9,9 @@ import ( "github.com/PeerDB-io/gluaflatbuffers" "github.com/PeerDB-io/gluajson" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/pua" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/pua" + "github.com/PeerDB-io/peerdb/flow/shared" ) func LVAsReadOnlyBytes(ls *lua.LState, v lua.LValue) ([]byte, error) { diff --git a/flow/connectors/utils/monitoring/monitoring.go b/flow/connectors/utils/monitoring/monitoring.go index 98a62ec65b..043bf08cc8 100644 --- a/flow/connectors/utils/monitoring/monitoring.go +++ b/flow/connectors/utils/monitoring/monitoring.go @@ -11,9 +11,9 @@ import ( "github.com/jackc/pgx/v5/pgtype" "github.com/jackc/pgx/v5/pgxpool" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/shared" ) type CDCBatchInfo struct { diff --git a/flow/connectors/utils/partition/partition.go b/flow/connectors/utils/partition/partition.go index 279be70e2e..a8e5bfac16 100644 --- a/flow/connectors/utils/partition/partition.go +++ b/flow/connectors/utils/partition/partition.go @@ -10,7 +10,7 @@ import ( "github.com/jackc/pgx/v5/pgtype" "google.golang.org/protobuf/types/known/timestamppb" - "github.com/PeerDB-io/peer-flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/generated/protos" ) // Function to compare two values diff --git a/flow/connectors/utils/partition_hash.go b/flow/connectors/utils/partition_hash.go index 3c6d8ee457..a018c2e42b 100644 --- a/flow/connectors/utils/partition_hash.go +++ b/flow/connectors/utils/partition_hash.go @@ -4,7 +4,7 @@ import ( "hash/fnv" "strconv" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/shared" ) func hashString(s string) uint32 { diff --git a/flow/connectors/utils/peers.go b/flow/connectors/utils/peers.go index dd050b50ff..3c4de232a0 100644 --- a/flow/connectors/utils/peers.go +++ b/flow/connectors/utils/peers.go @@ -8,8 +8,8 @@ import ( "github.com/jackc/pgx/v5/pgxpool" "google.golang.org/protobuf/proto" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" ) func CreatePeerNoValidate( diff --git a/flow/connectors/utils/ssh.go b/flow/connectors/utils/ssh.go index b3576ba486..3cae8109b6 100644 --- a/flow/connectors/utils/ssh.go +++ b/flow/connectors/utils/ssh.go @@ -7,7 +7,7 @@ import ( "golang.org/x/crypto/ssh" - "github.com/PeerDB-io/peer-flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/generated/protos" ) // getSSHClientConfig returns an *ssh.ClientConfig based on provided credentials. diff --git a/flow/connectors/utils/stream.go b/flow/connectors/utils/stream.go index c920366756..02f8abdc59 100644 --- a/flow/connectors/utils/stream.go +++ b/flow/connectors/utils/stream.go @@ -6,9 +6,9 @@ import ( "github.com/google/uuid" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" ) func RecordsToRawTableStream[Items model.Items](req *model.RecordsToStreamRequest[Items]) (*model.QRecordStream, error) { diff --git a/flow/e2e/bigquery/bigquery.go b/flow/e2e/bigquery/bigquery.go index dc0414115e..0acb08dee9 100644 --- a/flow/e2e/bigquery/bigquery.go +++ b/flow/e2e/bigquery/bigquery.go @@ -8,12 +8,12 @@ import ( "github.com/jackc/pgx/v5" - "github.com/PeerDB-io/peer-flow/connectors" - connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres" - "github.com/PeerDB-io/peer-flow/e2e" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + "github.com/PeerDB-io/peerdb/flow/e2e" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/shared" ) type PeerFlowE2ETestSuiteBQ struct { diff --git a/flow/e2e/bigquery/bigquery_helper.go b/flow/e2e/bigquery/bigquery_helper.go index ee33f2bfc3..25dbfd6003 100644 --- a/flow/e2e/bigquery/bigquery_helper.go +++ b/flow/e2e/bigquery/bigquery_helper.go @@ -17,11 +17,11 @@ import ( "github.com/shopspring/decimal" "google.golang.org/api/iterator" - peer_bq "github.com/PeerDB-io/peer-flow/connectors/bigquery" - "github.com/PeerDB-io/peer-flow/e2eshared" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" + peer_bq "github.com/PeerDB-io/peerdb/flow/connectors/bigquery" + "github.com/PeerDB-io/peerdb/flow/e2eshared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" ) type BigQueryTestHelper struct { diff --git a/flow/e2e/bigquery/peer_flow_bq_test.go b/flow/e2e/bigquery/peer_flow_bq_test.go index 8fcb263694..8fae1c40f4 100644 --- a/flow/e2e/bigquery/peer_flow_bq_test.go +++ b/flow/e2e/bigquery/peer_flow_bq_test.go @@ -12,12 +12,12 @@ import ( "github.com/jackc/pgerrcode" "github.com/stretchr/testify/require" - "github.com/PeerDB-io/peer-flow/e2e" - "github.com/PeerDB-io/peer-flow/e2eshared" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/shared" - peerflow "github.com/PeerDB-io/peer-flow/workflows" + "github.com/PeerDB-io/peerdb/flow/e2e" + "github.com/PeerDB-io/peerdb/flow/e2eshared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/shared" + peerflow "github.com/PeerDB-io/peerdb/flow/workflows" ) func TestPeerFlowE2ETestSuiteBQ(t *testing.T) { diff --git a/flow/e2e/bigquery/qrep_flow_bq_test.go b/flow/e2e/bigquery/qrep_flow_bq_test.go index d52fffb724..44d620bd53 100644 --- a/flow/e2e/bigquery/qrep_flow_bq_test.go +++ b/flow/e2e/bigquery/qrep_flow_bq_test.go @@ -8,7 +8,7 @@ import ( "github.com/stretchr/testify/require" - "github.com/PeerDB-io/peer-flow/e2e" + "github.com/PeerDB-io/peerdb/flow/e2e" ) func (s PeerFlowE2ETestSuiteBQ) setupSourceTable(tableName string, rowCount int) { diff --git a/flow/e2e/clickhouse/clickhouse.go b/flow/e2e/clickhouse/clickhouse.go index 916f0606fd..d45df68730 100644 --- a/flow/e2e/clickhouse/clickhouse.go +++ b/flow/e2e/clickhouse/clickhouse.go @@ -12,15 +12,15 @@ import ( "github.com/shopspring/decimal" "github.com/stretchr/testify/require" - "github.com/PeerDB-io/peer-flow/connectors" - connclickhouse "github.com/PeerDB-io/peer-flow/connectors/clickhouse" - connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres" - "github.com/PeerDB-io/peer-flow/e2e" - e2e_s3 "github.com/PeerDB-io/peer-flow/e2e/s3" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors" + connclickhouse "github.com/PeerDB-io/peerdb/flow/connectors/clickhouse" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + "github.com/PeerDB-io/peerdb/flow/e2e" + e2e_s3 "github.com/PeerDB-io/peerdb/flow/e2e/s3" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/shared" ) type ClickHouseSuite struct { diff --git a/flow/e2e/clickhouse/peer_flow_ch_test.go b/flow/e2e/clickhouse/peer_flow_ch_test.go index beaae5ceaf..2564deab40 100644 --- a/flow/e2e/clickhouse/peer_flow_ch_test.go +++ b/flow/e2e/clickhouse/peer_flow_ch_test.go @@ -13,14 +13,14 @@ import ( "github.com/shopspring/decimal" "github.com/stretchr/testify/require" - connclickhouse "github.com/PeerDB-io/peer-flow/connectors/clickhouse" - "github.com/PeerDB-io/peer-flow/e2e" - "github.com/PeerDB-io/peer-flow/e2eshared" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/shared" - peerflow "github.com/PeerDB-io/peer-flow/workflows" + connclickhouse "github.com/PeerDB-io/peerdb/flow/connectors/clickhouse" + "github.com/PeerDB-io/peerdb/flow/e2e" + "github.com/PeerDB-io/peerdb/flow/e2eshared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/shared" + peerflow "github.com/PeerDB-io/peerdb/flow/workflows" ) //go:embed test_data/* diff --git a/flow/e2e/congen.go b/flow/e2e/congen.go index 91c5817d40..110220cfe4 100644 --- a/flow/e2e/congen.go +++ b/flow/e2e/congen.go @@ -10,10 +10,10 @@ import ( "github.com/jackc/pgx/v5" "github.com/stretchr/testify/require" - connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" ) func cleanPostgres(conn *pgx.Conn, suffix string) error { diff --git a/flow/e2e/elasticsearch/elasticsearch.go b/flow/e2e/elasticsearch/elasticsearch.go index 720cfdd62a..9b2dd3cc9c 100644 --- a/flow/e2e/elasticsearch/elasticsearch.go +++ b/flow/e2e/elasticsearch/elasticsearch.go @@ -9,11 +9,11 @@ import ( "github.com/elastic/go-elasticsearch/v8" "github.com/stretchr/testify/require" - connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres" - "github.com/PeerDB-io/peer-flow/e2e" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + "github.com/PeerDB-io/peerdb/flow/e2e" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) type elasticsearchSuite struct { diff --git a/flow/e2e/elasticsearch/peer_flow_es_test.go b/flow/e2e/elasticsearch/peer_flow_es_test.go index a019ba4300..d7f471dde6 100644 --- a/flow/e2e/elasticsearch/peer_flow_es_test.go +++ b/flow/e2e/elasticsearch/peer_flow_es_test.go @@ -7,8 +7,8 @@ import ( "github.com/stretchr/testify/require" - "github.com/PeerDB-io/peer-flow/e2e" - peerflow "github.com/PeerDB-io/peer-flow/workflows" + "github.com/PeerDB-io/peerdb/flow/e2e" + peerflow "github.com/PeerDB-io/peerdb/flow/workflows" ) func (s elasticsearchSuite) Test_Simple_PKey_CDC_Mirror() { diff --git a/flow/e2e/elasticsearch/qrep_flow_es_test.go b/flow/e2e/elasticsearch/qrep_flow_es_test.go index 2839d60270..9b4ffdd0a2 100644 --- a/flow/e2e/elasticsearch/qrep_flow_es_test.go +++ b/flow/e2e/elasticsearch/qrep_flow_es_test.go @@ -8,9 +8,9 @@ import ( "github.com/stretchr/testify/require" - "github.com/PeerDB-io/peer-flow/e2e" - "github.com/PeerDB-io/peer-flow/e2eshared" - "github.com/PeerDB-io/peer-flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/e2e" + "github.com/PeerDB-io/peerdb/flow/e2eshared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" ) func Test_Elasticsearch(t *testing.T) { diff --git a/flow/e2e/eventhub/eventhub.go b/flow/e2e/eventhub/eventhub.go index fec1559c17..d046c2b4bf 100644 --- a/flow/e2e/eventhub/eventhub.go +++ b/flow/e2e/eventhub/eventhub.go @@ -9,7 +9,7 @@ import ( "github.com/Azure/azure-sdk-for-go/sdk/messaging/azeventhubs" "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/eventhub/armeventhub" - "github.com/PeerDB-io/peer-flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/generated/protos" ) // consume all messages from the eventhub with the given name“. diff --git a/flow/e2e/eventhub/peer_flow_eh_test.go b/flow/e2e/eventhub/peer_flow_eh_test.go index 5f946cde76..e48f959395 100644 --- a/flow/e2e/eventhub/peer_flow_eh_test.go +++ b/flow/e2e/eventhub/peer_flow_eh_test.go @@ -13,12 +13,12 @@ import ( "github.com/jackc/pgx/v5" "github.com/stretchr/testify/require" - connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres" - "github.com/PeerDB-io/peer-flow/e2e" - "github.com/PeerDB-io/peer-flow/e2eshared" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/shared" - peerflow "github.com/PeerDB-io/peer-flow/workflows" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + "github.com/PeerDB-io/peerdb/flow/e2e" + "github.com/PeerDB-io/peerdb/flow/e2eshared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/shared" + peerflow "github.com/PeerDB-io/peerdb/flow/workflows" ) type EventhubsSuite struct { diff --git a/flow/e2e/generic/generic_test.go b/flow/e2e/generic/generic_test.go index a56bcae476..3dd5af3397 100644 --- a/flow/e2e/generic/generic_test.go +++ b/flow/e2e/generic/generic_test.go @@ -7,16 +7,16 @@ import ( "github.com/stretchr/testify/require" - "github.com/PeerDB-io/peer-flow/connectors" - "github.com/PeerDB-io/peer-flow/e2e" - e2e_bigquery "github.com/PeerDB-io/peer-flow/e2e/bigquery" - e2e_clickhouse "github.com/PeerDB-io/peer-flow/e2e/clickhouse" - e2e_postgres "github.com/PeerDB-io/peer-flow/e2e/postgres" - e2e_snowflake "github.com/PeerDB-io/peer-flow/e2e/snowflake" - "github.com/PeerDB-io/peer-flow/e2eshared" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model/qvalue" - peerflow "github.com/PeerDB-io/peer-flow/workflows" + "github.com/PeerDB-io/peerdb/flow/connectors" + "github.com/PeerDB-io/peerdb/flow/e2e" + e2e_bigquery "github.com/PeerDB-io/peerdb/flow/e2e/bigquery" + e2e_clickhouse "github.com/PeerDB-io/peerdb/flow/e2e/clickhouse" + e2e_postgres "github.com/PeerDB-io/peerdb/flow/e2e/postgres" + e2e_snowflake "github.com/PeerDB-io/peerdb/flow/e2e/snowflake" + "github.com/PeerDB-io/peerdb/flow/e2eshared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + peerflow "github.com/PeerDB-io/peerdb/flow/workflows" ) func TestGenericPG(t *testing.T) { diff --git a/flow/e2e/kafka/kafka_test.go b/flow/e2e/kafka/kafka_test.go index 1d29a28c1d..e6246b280f 100644 --- a/flow/e2e/kafka/kafka_test.go +++ b/flow/e2e/kafka/kafka_test.go @@ -11,12 +11,12 @@ import ( "github.com/stretchr/testify/require" "github.com/twmb/franz-go/pkg/kgo" - connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres" - "github.com/PeerDB-io/peer-flow/e2e" - "github.com/PeerDB-io/peer-flow/e2eshared" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/shared" - peerflow "github.com/PeerDB-io/peer-flow/workflows" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + "github.com/PeerDB-io/peerdb/flow/e2e" + "github.com/PeerDB-io/peerdb/flow/e2eshared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/shared" + peerflow "github.com/PeerDB-io/peerdb/flow/workflows" ) type KafkaSuite struct { diff --git a/flow/e2e/postgres/peer_flow_pg_test.go b/flow/e2e/postgres/peer_flow_pg_test.go index 4dedbe13b6..994e612bde 100644 --- a/flow/e2e/postgres/peer_flow_pg_test.go +++ b/flow/e2e/postgres/peer_flow_pg_test.go @@ -12,11 +12,11 @@ import ( "github.com/stretchr/testify/assert" "github.com/stretchr/testify/require" - "github.com/PeerDB-io/peer-flow/e2e" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/shared" - peerflow "github.com/PeerDB-io/peer-flow/workflows" + "github.com/PeerDB-io/peerdb/flow/e2e" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/shared" + peerflow "github.com/PeerDB-io/peerdb/flow/workflows" ) func (s PeerFlowE2ETestSuitePG) attachSchemaSuffix(tableName string) string { diff --git a/flow/e2e/postgres/postgres.go b/flow/e2e/postgres/postgres.go index ea43648f7c..4491c91a42 100644 --- a/flow/e2e/postgres/postgres.go +++ b/flow/e2e/postgres/postgres.go @@ -9,12 +9,12 @@ import ( "github.com/jackc/pgx/v5" "github.com/stretchr/testify/require" - "github.com/PeerDB-io/peer-flow/connectors" - connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres" - "github.com/PeerDB-io/peer-flow/e2e" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + "github.com/PeerDB-io/peerdb/flow/e2e" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/shared" ) type PeerFlowE2ETestSuitePG struct { diff --git a/flow/e2e/postgres/qrep_flow_pg_test.go b/flow/e2e/postgres/qrep_flow_pg_test.go index 7142b91761..875e8a0fd6 100644 --- a/flow/e2e/postgres/qrep_flow_pg_test.go +++ b/flow/e2e/postgres/qrep_flow_pg_test.go @@ -12,12 +12,12 @@ import ( "github.com/jackc/pgx/v5/pgtype" "github.com/stretchr/testify/require" - connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres" - "github.com/PeerDB-io/peer-flow/e2e" - "github.com/PeerDB-io/peer-flow/e2eshared" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/shared" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + "github.com/PeerDB-io/peerdb/flow/e2e" + "github.com/PeerDB-io/peerdb/flow/e2eshared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/shared" ) func TestPeerFlowE2ETestSuitePG(t *testing.T) { diff --git a/flow/e2e/pubsub/pubsub_test.go b/flow/e2e/pubsub/pubsub_test.go index d4920553d8..53ea57c32d 100644 --- a/flow/e2e/pubsub/pubsub_test.go +++ b/flow/e2e/pubsub/pubsub_test.go @@ -14,14 +14,14 @@ import ( "github.com/jackc/pgx/v5" "github.com/stretchr/testify/require" - peer_bq "github.com/PeerDB-io/peer-flow/connectors/bigquery" - connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/e2e" - "github.com/PeerDB-io/peer-flow/e2eshared" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/shared" - peerflow "github.com/PeerDB-io/peer-flow/workflows" + peer_bq "github.com/PeerDB-io/peerdb/flow/connectors/bigquery" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/e2e" + "github.com/PeerDB-io/peerdb/flow/e2eshared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/shared" + peerflow "github.com/PeerDB-io/peerdb/flow/workflows" ) type PubSubSuite struct { diff --git a/flow/e2e/s3/cdc_s3_test.go b/flow/e2e/s3/cdc_s3_test.go index c954d02b50..05e6964cad 100644 --- a/flow/e2e/s3/cdc_s3_test.go +++ b/flow/e2e/s3/cdc_s3_test.go @@ -7,8 +7,8 @@ import ( "github.com/stretchr/testify/require" - "github.com/PeerDB-io/peer-flow/e2e" - peerflow "github.com/PeerDB-io/peer-flow/workflows" + "github.com/PeerDB-io/peerdb/flow/e2e" + peerflow "github.com/PeerDB-io/peerdb/flow/workflows" ) func (s PeerFlowE2ETestSuiteS3) attachSchemaSuffix(tableName string) string { diff --git a/flow/e2e/s3/qrep_flow_s3_test.go b/flow/e2e/s3/qrep_flow_s3_test.go index c52fca7a38..f8e886073a 100644 --- a/flow/e2e/s3/qrep_flow_s3_test.go +++ b/flow/e2e/s3/qrep_flow_s3_test.go @@ -9,11 +9,11 @@ import ( "github.com/stretchr/testify/require" - connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres" - "github.com/PeerDB-io/peer-flow/e2e" - "github.com/PeerDB-io/peer-flow/e2eshared" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/shared" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + "github.com/PeerDB-io/peerdb/flow/e2e" + "github.com/PeerDB-io/peerdb/flow/e2eshared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/shared" ) type PeerFlowE2ETestSuiteS3 struct { diff --git a/flow/e2e/s3/s3_helper.go b/flow/e2e/s3/s3_helper.go index af6be64f94..61163ee3dd 100644 --- a/flow/e2e/s3/s3_helper.go +++ b/flow/e2e/s3/s3_helper.go @@ -11,10 +11,10 @@ import ( "github.com/aws/aws-sdk-go-v2/service/s3" s3types "github.com/aws/aws-sdk-go-v2/service/s3/types" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/e2eshared" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/e2eshared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/shared" ) type S3TestHelper struct { diff --git a/flow/e2e/snowflake/peer_flow_sf_test.go b/flow/e2e/snowflake/peer_flow_sf_test.go index e030d796b8..e0bf746a8b 100644 --- a/flow/e2e/snowflake/peer_flow_sf_test.go +++ b/flow/e2e/snowflake/peer_flow_sf_test.go @@ -10,11 +10,11 @@ import ( "github.com/jackc/pgerrcode" "github.com/stretchr/testify/require" - "github.com/PeerDB-io/peer-flow/e2e" - "github.com/PeerDB-io/peer-flow/e2eshared" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/shared" - peerflow "github.com/PeerDB-io/peer-flow/workflows" + "github.com/PeerDB-io/peerdb/flow/e2e" + "github.com/PeerDB-io/peerdb/flow/e2eshared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/shared" + peerflow "github.com/PeerDB-io/peerdb/flow/workflows" ) func TestPeerFlowE2ETestSuiteSF(t *testing.T) { diff --git a/flow/e2e/snowflake/qrep_flow_sf_test.go b/flow/e2e/snowflake/qrep_flow_sf_test.go index 0f86ce7670..8835761659 100644 --- a/flow/e2e/snowflake/qrep_flow_sf_test.go +++ b/flow/e2e/snowflake/qrep_flow_sf_test.go @@ -7,8 +7,8 @@ import ( "github.com/google/uuid" "github.com/stretchr/testify/require" - "github.com/PeerDB-io/peer-flow/e2e" - "github.com/PeerDB-io/peer-flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/e2e" + "github.com/PeerDB-io/peerdb/flow/generated/protos" ) //nolint:unparam diff --git a/flow/e2e/snowflake/snowflake.go b/flow/e2e/snowflake/snowflake.go index 97b7451f54..35fac5f2a8 100644 --- a/flow/e2e/snowflake/snowflake.go +++ b/flow/e2e/snowflake/snowflake.go @@ -10,13 +10,13 @@ import ( "github.com/jackc/pgx/v5" "github.com/stretchr/testify/require" - "github.com/PeerDB-io/peer-flow/connectors" - connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres" - connsnowflake "github.com/PeerDB-io/peer-flow/connectors/snowflake" - "github.com/PeerDB-io/peer-flow/e2e" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + connsnowflake "github.com/PeerDB-io/peerdb/flow/connectors/snowflake" + "github.com/PeerDB-io/peerdb/flow/e2e" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/shared" ) type PeerFlowE2ETestSuiteSF struct { diff --git a/flow/e2e/snowflake/snowflake_helper.go b/flow/e2e/snowflake/snowflake_helper.go index 7e2943e3bc..0c6decdc8b 100644 --- a/flow/e2e/snowflake/snowflake_helper.go +++ b/flow/e2e/snowflake/snowflake_helper.go @@ -9,11 +9,11 @@ import ( "os" "testing" - connsnowflake "github.com/PeerDB-io/peer-flow/connectors/snowflake" - "github.com/PeerDB-io/peer-flow/e2eshared" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" + connsnowflake "github.com/PeerDB-io/peerdb/flow/connectors/snowflake" + "github.com/PeerDB-io/peerdb/flow/e2eshared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" ) type SnowflakeTestHelper struct { diff --git a/flow/e2e/snowflake/snowflake_schema_delta_test.go b/flow/e2e/snowflake/snowflake_schema_delta_test.go index ada2b10f6a..392f89a1e8 100644 --- a/flow/e2e/snowflake/snowflake_schema_delta_test.go +++ b/flow/e2e/snowflake/snowflake_schema_delta_test.go @@ -7,10 +7,10 @@ import ( "github.com/stretchr/testify/require" - connsnowflake "github.com/PeerDB-io/peer-flow/connectors/snowflake" - "github.com/PeerDB-io/peer-flow/e2eshared" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model/qvalue" + connsnowflake "github.com/PeerDB-io/peerdb/flow/connectors/snowflake" + "github.com/PeerDB-io/peerdb/flow/e2eshared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" ) const ( diff --git a/flow/e2e/sqlserver/qrep_flow_sqlserver_test.go b/flow/e2e/sqlserver/qrep_flow_sqlserver_test.go index aa059c0492..cdf89da88b 100644 --- a/flow/e2e/sqlserver/qrep_flow_sqlserver_test.go +++ b/flow/e2e/sqlserver/qrep_flow_sqlserver_test.go @@ -13,12 +13,12 @@ import ( "github.com/jackc/pgx/v5/pgtype" "github.com/stretchr/testify/require" - "github.com/PeerDB-io/peer-flow/connectors/postgres" - "github.com/PeerDB-io/peer-flow/e2e" - "github.com/PeerDB-io/peer-flow/e2eshared" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/shared" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + "github.com/PeerDB-io/peerdb/flow/e2e" + "github.com/PeerDB-io/peerdb/flow/e2eshared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/shared" ) type PeerFlowE2ETestSuiteSQLServer struct { diff --git a/flow/e2e/sqlserver/sqlserver_helper.go b/flow/e2e/sqlserver/sqlserver_helper.go index 154ffbea5e..e6f0e52f4d 100644 --- a/flow/e2e/sqlserver/sqlserver_helper.go +++ b/flow/e2e/sqlserver/sqlserver_helper.go @@ -7,9 +7,9 @@ import ( "os" "strconv" - connsqlserver "github.com/PeerDB-io/peer-flow/connectors/sqlserver" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model/qvalue" + connsqlserver "github.com/PeerDB-io/peerdb/flow/connectors/sqlserver" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" ) type SQLServerHelper struct { diff --git a/flow/e2e/test_utils.go b/flow/e2e/test_utils.go index b6f5130745..11e6c7bc8c 100644 --- a/flow/e2e/test_utils.go +++ b/flow/e2e/test_utils.go @@ -21,16 +21,16 @@ import ( "go.temporal.io/sdk/converter" "go.temporal.io/sdk/temporal" - "github.com/PeerDB-io/peer-flow/connectors" - connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres" - connsnowflake "github.com/PeerDB-io/peer-flow/connectors/snowflake" - "github.com/PeerDB-io/peer-flow/e2eshared" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" - peerflow "github.com/PeerDB-io/peer-flow/workflows" + "github.com/PeerDB-io/peerdb/flow/connectors" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + connsnowflake "github.com/PeerDB-io/peerdb/flow/connectors/snowflake" + "github.com/PeerDB-io/peerdb/flow/e2eshared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" + peerflow "github.com/PeerDB-io/peerdb/flow/workflows" ) func init() { diff --git a/flow/e2eshared/e2eshared.go b/flow/e2eshared/e2eshared.go index 9b63b41286..0819fd2047 100644 --- a/flow/e2eshared/e2eshared.go +++ b/flow/e2eshared/e2eshared.go @@ -8,8 +8,8 @@ import ( "strings" "testing" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" ) type Suite interface { diff --git a/flow/go.mod b/flow/go.mod index 33563f10c4..89de6a3c76 100644 --- a/flow/go.mod +++ b/flow/go.mod @@ -1,4 +1,4 @@ -module github.com/PeerDB-io/peer-flow +module github.com/PeerDB-io/peerdb/flow go 1.23.1 diff --git a/flow/main.go b/flow/main.go index 613c426340..ee6948acf2 100644 --- a/flow/main.go +++ b/flow/main.go @@ -13,8 +13,8 @@ import ( "go.temporal.io/sdk/worker" _ "go.uber.org/automaxprocs" - "github.com/PeerDB-io/peer-flow/cmd" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/cmd" + "github.com/PeerDB-io/peerdb/flow/shared" ) func main() { diff --git a/flow/middleware/logging.go b/flow/middleware/logging.go index 51932700fe..405de27af0 100644 --- a/flow/middleware/logging.go +++ b/flow/middleware/logging.go @@ -6,7 +6,7 @@ import ( "google.golang.org/grpc" - "github.com/PeerDB-io/peer-flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" ) func RequestLoggingMiddleWare() grpc.UnaryServerInterceptor { diff --git a/flow/middleware/oauth.go b/flow/middleware/oauth.go index 52bbc03672..60e965fe6f 100644 --- a/flow/middleware/oauth.go +++ b/flow/middleware/oauth.go @@ -16,7 +16,7 @@ import ( "google.golang.org/grpc/metadata" "google.golang.org/grpc/status" - "github.com/PeerDB-io/peer-flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" ) //nolint:lll diff --git a/flow/model/cdc_stream.go b/flow/model/cdc_stream.go index 14daa9fd8f..6184fcc5b7 100644 --- a/flow/model/cdc_stream.go +++ b/flow/model/cdc_stream.go @@ -6,8 +6,8 @@ import ( "sync/atomic" "time" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/shared" ) type CDCStream[T Items] struct { diff --git a/flow/model/conversion_avro.go b/flow/model/conversion_avro.go index b4cab1613a..7bf463d179 100644 --- a/flow/model/conversion_avro.go +++ b/flow/model/conversion_avro.go @@ -7,9 +7,9 @@ import ( "go.temporal.io/sdk/log" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" ) type QRecordAvroConverter struct { diff --git a/flow/model/model.go b/flow/model/model.go index 5a9d7b76cc..f5fdb54fab 100644 --- a/flow/model/model.go +++ b/flow/model/model.go @@ -8,7 +8,7 @@ import ( "github.com/jackc/pglogrepl" - "github.com/PeerDB-io/peer-flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/generated/protos" ) type NameAndExclude struct { diff --git a/flow/model/pg_items.go b/flow/model/pg_items.go index 4fc87cbff2..d01c6abd69 100644 --- a/flow/model/pg_items.go +++ b/flow/model/pg_items.go @@ -4,7 +4,7 @@ import ( "encoding/json" "fmt" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/shared" ) // encoding/gob cannot encode unexported fields diff --git a/flow/model/qrecord_batch.go b/flow/model/qrecord_batch.go index 4b7b1072c6..ad8ff25607 100644 --- a/flow/model/qrecord_batch.go +++ b/flow/model/qrecord_batch.go @@ -1,7 +1,7 @@ package model import ( - "github.com/PeerDB-io/peer-flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" ) // QRecordBatch holds a batch of []QValue slices diff --git a/flow/model/qrecord_copy_from_source.go b/flow/model/qrecord_copy_from_source.go index e98adea90f..65707c1761 100644 --- a/flow/model/qrecord_copy_from_source.go +++ b/flow/model/qrecord_copy_from_source.go @@ -10,8 +10,8 @@ import ( "github.com/google/uuid" "github.com/jackc/pgx/v5/pgtype" - geo "github.com/PeerDB-io/peer-flow/datatypes" - "github.com/PeerDB-io/peer-flow/model/qvalue" + geo "github.com/PeerDB-io/peerdb/flow/datatypes" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" ) func constructArray[T any](qValue qvalue.QValue, typeName string) (*pgtype.Array[T], error) { diff --git a/flow/model/qrecord_stream.go b/flow/model/qrecord_stream.go index eeca424b35..27215c62dc 100644 --- a/flow/model/qrecord_stream.go +++ b/flow/model/qrecord_stream.go @@ -1,7 +1,7 @@ package model import ( - "github.com/PeerDB-io/peer-flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" ) type QRecordStream struct { diff --git a/flow/model/qrecord_test.go b/flow/model/qrecord_test.go index a373452b9e..3af119ef32 100644 --- a/flow/model/qrecord_test.go +++ b/flow/model/qrecord_test.go @@ -7,8 +7,8 @@ import ( "github.com/shopspring/decimal" "github.com/stretchr/testify/assert" - "github.com/PeerDB-io/peer-flow/e2eshared" - "github.com/PeerDB-io/peer-flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/e2eshared" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" ) func TestEquals(t *testing.T) { diff --git a/flow/model/qvalue/avro_converter.go b/flow/model/qvalue/avro_converter.go index d860b5be70..a215ad1118 100644 --- a/flow/model/qvalue/avro_converter.go +++ b/flow/model/qvalue/avro_converter.go @@ -15,9 +15,9 @@ import ( "github.com/shopspring/decimal" "go.temporal.io/sdk/log" - "github.com/PeerDB-io/peer-flow/datatypes" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/datatypes" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" ) type AvroSchemaField struct { diff --git a/flow/model/qvalue/dwh.go b/flow/model/qvalue/dwh.go index b2d085acb4..97ad0e9158 100644 --- a/flow/model/qvalue/dwh.go +++ b/flow/model/qvalue/dwh.go @@ -5,8 +5,8 @@ import ( "go.temporal.io/sdk/log" - "github.com/PeerDB-io/peer-flow/datatypes" - "github.com/PeerDB-io/peer-flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/datatypes" + "github.com/PeerDB-io/peerdb/flow/generated/protos" ) func DetermineNumericSettingForDWH(precision int16, scale int16, dwh protos.DBType) (int16, int16) { diff --git a/flow/model/qvalue/equals.go b/flow/model/qvalue/equals.go index 744a4838a2..7e062b7bc5 100644 --- a/flow/model/qvalue/equals.go +++ b/flow/model/qvalue/equals.go @@ -13,7 +13,7 @@ import ( "github.com/shopspring/decimal" geom "github.com/twpayne/go-geos" - "github.com/PeerDB-io/peer-flow/datatypes" + "github.com/PeerDB-io/peerdb/flow/datatypes" ) func valueEmpty(value any) bool { diff --git a/flow/model/qvalue/kind.go b/flow/model/qvalue/kind.go index 10b7db4629..7097f5a305 100644 --- a/flow/model/qvalue/kind.go +++ b/flow/model/qvalue/kind.go @@ -5,9 +5,9 @@ import ( "fmt" "strings" - "github.com/PeerDB-io/peer-flow/datatypes" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/datatypes" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" ) type QValueKind string diff --git a/flow/model/qvalue/qschema.go b/flow/model/qvalue/qschema.go index 9e778e4f85..5761660024 100644 --- a/flow/model/qvalue/qschema.go +++ b/flow/model/qvalue/qschema.go @@ -5,9 +5,9 @@ import ( "fmt" "strings" - "github.com/PeerDB-io/peer-flow/datatypes" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/datatypes" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" ) type QField struct { diff --git a/flow/model/qvalue/qvalue.go b/flow/model/qvalue/qvalue.go index 9e81c080d6..18de0a90e8 100644 --- a/flow/model/qvalue/qvalue.go +++ b/flow/model/qvalue/qvalue.go @@ -9,7 +9,7 @@ import ( lua "github.com/yuin/gopher-lua" "github.com/PeerDB-io/glua64" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/shared" ) // if new types are added, register them in gob - cdc_store.go diff --git a/flow/model/record.go b/flow/model/record.go index b06a53fbf7..644d83844f 100644 --- a/flow/model/record.go +++ b/flow/model/record.go @@ -3,7 +3,7 @@ package model import ( "time" - "github.com/PeerDB-io/peer-flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/generated/protos" ) type Record[T Items] interface { diff --git a/flow/model/record_items.go b/flow/model/record_items.go index 33c2ac4941..94c16303ff 100644 --- a/flow/model/record_items.go +++ b/flow/model/record_items.go @@ -5,8 +5,8 @@ import ( "fmt" "math" - "github.com/PeerDB-io/peer-flow/datatypes" - "github.com/PeerDB-io/peer-flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/datatypes" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" ) type Items interface { diff --git a/flow/model/signals.go b/flow/model/signals.go index 17ee7d102a..bd0a010797 100644 --- a/flow/model/signals.go +++ b/flow/model/signals.go @@ -8,7 +8,7 @@ import ( "go.temporal.io/sdk/log" "go.temporal.io/sdk/workflow" - "github.com/PeerDB-io/peer-flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/generated/protos" ) // typed wrapper around temporal signals diff --git a/flow/otel_metrics/otel_manager.go b/flow/otel_metrics/otel_manager.go index 1681e5217f..5849e6d390 100644 --- a/flow/otel_metrics/otel_manager.go +++ b/flow/otel_metrics/otel_manager.go @@ -14,7 +14,7 @@ import ( "go.opentelemetry.io/otel/sdk/resource" semconv "go.opentelemetry.io/otel/semconv/v1.26.0" - "github.com/PeerDB-io/peer-flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" ) const ( diff --git a/flow/peerdbenv/catalog.go b/flow/peerdbenv/catalog.go index f0d80b50c0..db81f77c88 100644 --- a/flow/peerdbenv/catalog.go +++ b/flow/peerdbenv/catalog.go @@ -7,8 +7,8 @@ import ( "github.com/jackc/pgx/v5/pgxpool" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/shared" ) var ( diff --git a/flow/peerdbenv/config.go b/flow/peerdbenv/config.go index 79be60ae40..be30bf3a78 100644 --- a/flow/peerdbenv/config.go +++ b/flow/peerdbenv/config.go @@ -9,8 +9,8 @@ import ( "strings" "time" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/shared" ) // This file contains functions to get the values of various peerdb environment diff --git a/flow/peerdbenv/dynamicconf.go b/flow/peerdbenv/dynamicconf.go index 147afd1174..24151d7fe9 100644 --- a/flow/peerdbenv/dynamicconf.go +++ b/flow/peerdbenv/dynamicconf.go @@ -15,8 +15,8 @@ import ( "github.com/jackc/pgx/v5/pgxpool" "golang.org/x/exp/constraints" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/shared" ) var DynamicSettings = [...]*protos.DynamicSetting{ diff --git a/flow/pua/peerdb.go b/flow/pua/peerdb.go index b437232b97..72e5202e6e 100644 --- a/flow/pua/peerdb.go +++ b/flow/pua/peerdb.go @@ -17,10 +17,10 @@ import ( "github.com/PeerDB-io/gluajson" "github.com/PeerDB-io/gluamsgpack" "github.com/PeerDB-io/gluautf8" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) var ( diff --git a/flow/pua/peerdb_test.go b/flow/pua/peerdb_test.go index d08c9b4db6..d55b75ec42 100644 --- a/flow/pua/peerdb_test.go +++ b/flow/pua/peerdb_test.go @@ -3,10 +3,10 @@ package pua import ( "testing" - "github.com/yuin/gopher-lua" + lua "github.com/yuin/gopher-lua" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/model/qvalue" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/model/qvalue" ) func assert(t *testing.T, ls *lua.LState, source string) { diff --git a/flow/pua/stream_adapter.go b/flow/pua/stream_adapter.go index 9f6f3f8d3e..7f4c5ffcfc 100644 --- a/flow/pua/stream_adapter.go +++ b/flow/pua/stream_adapter.go @@ -5,7 +5,7 @@ import ( lua "github.com/yuin/gopher-lua" - "github.com/PeerDB-io/peer-flow/model" + "github.com/PeerDB-io/peerdb/flow/model" ) func AttachToStream(ls *lua.LState, lfn *lua.LFunction, stream *model.QRecordStream) *model.QRecordStream { diff --git a/flow/shared/postgres.go b/flow/shared/postgres.go index 121fb73bf4..b1022fd7bd 100644 --- a/flow/shared/postgres.go +++ b/flow/shared/postgres.go @@ -16,7 +16,7 @@ import ( "go.temporal.io/sdk/log" "google.golang.org/protobuf/proto" - "github.com/PeerDB-io/peer-flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/generated/protos" ) type PGVersion int32 diff --git a/flow/shared/schema_helpers.go b/flow/shared/schema_helpers.go index 7f48d3cbb5..2ff36924fa 100644 --- a/flow/shared/schema_helpers.go +++ b/flow/shared/schema_helpers.go @@ -7,7 +7,7 @@ import ( "go.temporal.io/sdk/log" - "github.com/PeerDB-io/peer-flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/generated/protos" ) func AdditionalTablesHasOverlap(currentTableMappings []*protos.TableMapping, diff --git a/flow/shared/telemetry/incidentio_message_sender.go b/flow/shared/telemetry/incidentio_message_sender.go index dbcbf80b0d..fb314b3c73 100644 --- a/flow/shared/telemetry/incidentio_message_sender.go +++ b/flow/shared/telemetry/incidentio_message_sender.go @@ -15,7 +15,7 @@ import ( "go.temporal.io/sdk/activity" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/shared" ) type IncidentIoAlert struct { diff --git a/flow/shared/telemetry/sns_message_sender.go b/flow/shared/telemetry/sns_message_sender.go index 2a4798e3ed..6b668006f7 100644 --- a/flow/shared/telemetry/sns_message_sender.go +++ b/flow/shared/telemetry/sns_message_sender.go @@ -12,7 +12,7 @@ import ( "github.com/aws/aws-sdk-go-v2/service/sns/types" "go.temporal.io/sdk/activity" - "github.com/PeerDB-io/peer-flow/shared/aws_common" + "github.com/PeerDB-io/peerdb/flow/shared/aws_common" ) type SNSMessageSender struct { diff --git a/flow/shared/workflow.go b/flow/shared/workflow.go index 4dfb192511..ffff98c028 100644 --- a/flow/shared/workflow.go +++ b/flow/shared/workflow.go @@ -8,7 +8,7 @@ import ( "go.temporal.io/sdk/client" "go.temporal.io/sdk/workflow" - "github.com/PeerDB-io/peer-flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/generated/protos" ) func GetWorkflowStatus(ctx context.Context, temporalClient client.Client, workflowID string) (protos.FlowStatus, error) { diff --git a/flow/workflows/activities.go b/flow/workflows/activities.go index 5fe699419c..16405ed0a1 100644 --- a/flow/workflows/activities.go +++ b/flow/workflows/activities.go @@ -1,6 +1,6 @@ package peerflow -import "github.com/PeerDB-io/peer-flow/activities" +import "github.com/PeerDB-io/peerdb/flow/activities" var ( flowable *activities.FlowableActivity diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go index 4526cf2b4f..1d55fa7975 100644 --- a/flow/workflows/cdc_flow.go +++ b/flow/workflows/cdc_flow.go @@ -15,10 +15,10 @@ import ( "go.temporal.io/sdk/temporal" "go.temporal.io/sdk/workflow" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) type CDCFlowWorkflowState struct { diff --git a/flow/workflows/drop_flow.go b/flow/workflows/drop_flow.go index 93086157d8..829fbe7606 100644 --- a/flow/workflows/drop_flow.go +++ b/flow/workflows/drop_flow.go @@ -8,8 +8,8 @@ import ( "go.temporal.io/sdk/converter" "go.temporal.io/sdk/workflow" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/shared" ) func executeCDCDropActivities(ctx workflow.Context, input *protos.DropFlowInput) error { diff --git a/flow/workflows/local_activities.go b/flow/workflows/local_activities.go index 923bcaea58..8b5bd1f42f 100644 --- a/flow/workflows/local_activities.go +++ b/flow/workflows/local_activities.go @@ -9,10 +9,10 @@ import ( "go.temporal.io/sdk/log" "go.temporal.io/sdk/workflow" - "github.com/PeerDB-io/peer-flow/connectors" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/connectors" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) func getQRepOverwriteFullRefreshMode(wCtx workflow.Context, logger log.Logger, env map[string]string) bool { diff --git a/flow/workflows/maintenance_flow.go b/flow/workflows/maintenance_flow.go index c48750a807..f42455f7cd 100644 --- a/flow/workflows/maintenance_flow.go +++ b/flow/workflows/maintenance_flow.go @@ -10,9 +10,9 @@ import ( "go.temporal.io/sdk/log" "go.temporal.io/sdk/workflow" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) func getMaintenanceWorkflowOptions(workflowIDPrefix string, taskQueueId shared.TaskQueueID) client.StartWorkflowOptions { diff --git a/flow/workflows/qrep_flow.go b/flow/workflows/qrep_flow.go index f862b4f3d6..87555371a7 100644 --- a/flow/workflows/qrep_flow.go +++ b/flow/workflows/qrep_flow.go @@ -11,9 +11,9 @@ import ( "go.temporal.io/sdk/temporal" "go.temporal.io/sdk/workflow" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/shared" ) type QRepFlowExecution struct { diff --git a/flow/workflows/setup_flow.go b/flow/workflows/setup_flow.go index e3fff0413e..0a8a7d4f31 100644 --- a/flow/workflows/setup_flow.go +++ b/flow/workflows/setup_flow.go @@ -10,9 +10,9 @@ import ( "go.temporal.io/sdk/log" "go.temporal.io/sdk/workflow" - "github.com/PeerDB-io/peer-flow/activities" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/activities" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/shared" ) // SetupFlow is the workflow that is responsible for ensuring all the diff --git a/flow/workflows/snapshot_flow.go b/flow/workflows/snapshot_flow.go index 1db3b6d60b..b452921553 100644 --- a/flow/workflows/snapshot_flow.go +++ b/flow/workflows/snapshot_flow.go @@ -11,12 +11,12 @@ import ( "go.temporal.io/sdk/temporal" "go.temporal.io/sdk/workflow" - "github.com/PeerDB-io/peer-flow/activities" - connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres" - "github.com/PeerDB-io/peer-flow/connectors/utils" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/peerdbenv" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/activities" + connpostgres "github.com/PeerDB-io/peerdb/flow/connectors/postgres" + "github.com/PeerDB-io/peerdb/flow/connectors/utils" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/peerdbenv" + "github.com/PeerDB-io/peerdb/flow/shared" ) type snapshotType int8 diff --git a/flow/workflows/xmin_flow.go b/flow/workflows/xmin_flow.go index b0ce09d604..898d67c669 100644 --- a/flow/workflows/xmin_flow.go +++ b/flow/workflows/xmin_flow.go @@ -9,9 +9,9 @@ import ( "github.com/google/uuid" "go.temporal.io/sdk/workflow" - "github.com/PeerDB-io/peer-flow/generated/protos" - "github.com/PeerDB-io/peer-flow/model" - "github.com/PeerDB-io/peer-flow/shared" + "github.com/PeerDB-io/peerdb/flow/generated/protos" + "github.com/PeerDB-io/peerdb/flow/model" + "github.com/PeerDB-io/peerdb/flow/shared" ) func XminFlowWorkflow(