rebase

doublecloud · Jul 4, 2024 · 115476a · 115476a
1 parent 4c45296
commit 115476a
Show file tree

Hide file tree

Showing 381 changed files with 944 additions and 999 deletions.
diff --git a/.mapping.json b/.mapping.json
@@ -23,7 +23,6 @@
   "cloud/dataplatform/testcontainer/postgres/postrges.go":"cloud/dataplatform/testcontainer/postgres/postrges.go",
   "cloud/dataplatform/testcontainer/tc_test.go":"cloud/dataplatform/testcontainer/tc_test.go",
   "cloud/dataplatform/testcontainer/temporal/temporal.go":"cloud/dataplatform/testcontainer/temporal/temporal.go",
-  "cmd/transferctl/cobraaux/cobraaux.go":"transfer_manager/go/cmd/transferctl/cobraaux/cobraaux.go",
   "cmd/trcli/activate/activate.go":"transfer_manager/go/cmd/trcli/activate/activate.go",
   "cmd/trcli/activate/tests/ch_init.sql":"transfer_manager/go/cmd/trcli/activate/tests/ch_init.sql",
   "cmd/trcli/activate/tests/dump/pg_init.sql":"transfer_manager/go/cmd/trcli/activate/tests/dump/pg_init.sql",
@@ -36,12 +35,12 @@
   "cmd/trcli/config/config.go":"transfer_manager/go/cmd/trcli/config/config.go",
   "cmd/trcli/config/model.go":"transfer_manager/go/cmd/trcli/config/model.go",
   "cmd/trcli/main.go":"transfer_manager/go/cmd/trcli/main.go",
-  "cmd/trcli/pluginprinter/table.go":"transfer_manager/go/cmd/trcli/pluginprinter/table.go",
   "cmd/trcli/replicate/replicate.go":"transfer_manager/go/cmd/trcli/replicate/replicate.go",
   "cmd/trcli/replicate/tests/ch_init.sql":"transfer_manager/go/cmd/trcli/replicate/tests/ch_init.sql",
   "cmd/trcli/replicate/tests/dump/pg_init.sql":"transfer_manager/go/cmd/trcli/replicate/tests/dump/pg_init.sql",
   "cmd/trcli/replicate/tests/pg2ch_test.go":"transfer_manager/go/cmd/trcli/replicate/tests/pg2ch_test.go",
   "cmd/trcli/replicate/tests/transfer.yaml":"transfer_manager/go/cmd/trcli/replicate/tests/transfer.yaml",
+  "cmd/trcli/upload/tests/ch_init.sql":"transfer_manager/go/cmd/trcli/upload/tests/ch_init.sql",
   "cmd/trcli/upload/tests/dump/pg_init.sql":"transfer_manager/go/cmd/trcli/upload/tests/dump/pg_init.sql",
   "cmd/trcli/upload/tests/pg2pg_test.go":"transfer_manager/go/cmd/trcli/upload/tests/pg2pg_test.go",
   "cmd/trcli/upload/tests/tables.yaml":"transfer_manager/go/cmd/trcli/upload/tests/tables.yaml",
@@ -58,6 +57,8 @@
   "github/Makefile":"transfer_manager/go/github/Makefile",
   "github/go.mod":"transfer_manager/go/github/go.mod",
   "github/go.sum":"transfer_manager/go/github/go.sum",
+  "github/library/go/test/canon/dctest.go":"transfer_manager/go/github/library/go/test/canon/dctest.go",
+  "github/library/go/test/yatest/dctest.go":"transfer_manager/go/github/library/go/test/yatest/dctest.go",
   "go.mod":"transfer_manager/go/github/go.mod",
   "go.sum":"transfer_manager/go/github/go.sum",
   "internal":"library/go",
@@ -1043,6 +1044,7 @@
   "internal/yandex/ydb/internal/cmd/gtrace/writer.go":"library/go/yandex/ydb/internal/cmd/gtrace/writer.go",
   "internal/yandex/ydb/internal/xruntime/namedgoroutine.go":"library/go/yandex/ydb/internal/xruntime/namedgoroutine.go",
   "internal/yandex/ydb/internal/xsync/pool.go":"library/go/yandex/ydb/internal/xsync/pool.go",
+  "internal/yandex/ydb/internal/xtest/manytimes.go":"library/go/yandex/ydb/internal/xtest/manytimes.go",
   "internal/yandex/ydb/log/README.md":"library/go/yandex/ydb/log/README.md",
   "internal/yandex/ydb/log/adapter.go":"library/go/yandex/ydb/log/adapter.go",
   "internal/yandex/ydb/log/fields.go":"library/go/yandex/ydb/log/fields.go",
@@ -1081,6 +1083,7 @@
   "internal/yandex/ydb/ydb-topic-fed-sdk/fedtopicreader/fed_reader_options.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicreader/fed_reader_options.go",
   "internal/yandex/ydb/ydb-topic-fed-sdk/fedtopicreader/fed_topic_reader.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicreader/fed_topic_reader.go",
   "internal/yandex/ydb/ydb-topic-fed-sdk/fedtopicreader/fed_topic_reader_test.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicreader/fed_topic_reader_test.go",
+  "internal/yandex/ydb/ydb-topic-fed-sdk/fedtopicreader/integration_test/fed_reader_integration_test.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicreader/integration_test/fed_reader_integration_test.go",
   "internal/yandex/ydb/ydb-topic-fed-sdk/fedtopicwriter/fed_topic_writer.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicwriter/fed_topic_writer.go",
   "internal/yandex/ydb/ydb-topic-fed-sdk/fedtopicwriter/fed_topic_writer_option.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicwriter/fed_topic_writer_option.go",
   "internal/yandex/ydb/ydb-topic-fed-sdk/fedtopicwriter/fed_topic_writer_test.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicwriter/fed_topic_writer_test.go",
@@ -1096,6 +1099,7 @@
   "internal/yandex/ydb/ydb-topic-fed-sdk/internal/grpcauth.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/internal/grpcauth.go",
   "internal/yandex/ydb/ydb-topic-fed-sdk/internal/grpcwrap/federation.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/internal/grpcwrap/federation.go",
   "internal/yandex/ydb/ydb-topic-fed-sdk/internal/testhelpers/dbconnect.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/internal/testhelpers/dbconnect.go",
+  "internal/yandex/ydb/ydb-topic-fed-sdk/internal/testhelpers/fedfixtures/fed_driver.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/internal/testhelpers/fedfixtures/fed_driver.go",
   "internal/yandex/ydb/ydb-topic-fed-sdk/internal/testhelpers/logger.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/internal/testhelpers/logger.go",
   "internal/yandex/ydb/ydb-topic-fed-sdk/internal/testhelpers/randstring.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/internal/testhelpers/randstring.go",
   "internal/yandex/ydb/ydb-topic-fed-sdk/options.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/options.go",
@@ -2127,6 +2131,7 @@
   "library/go/test/assertpb/assert.go":"library/go/test/assertpb/assert.go",
   "library/go/test/assertpb/assert_test.go":"library/go/test/assertpb/assert_test.go",
   "library/go/test/canon/canon.go":"library/go/test/canon/canon.go",
+  "library/go/test/canon/dctest.go":"transfer_manager/go/github/library/go/test/canon/dctest.go",
   "library/go/test/canon/gotest.go":"library/go/test/canon/gotest.go",
   "library/go/test/checks/yofix/README.md":"library/go/test/checks/yofix/README.md",
   "library/go/test/checks/yofix/run.go":"library/go/test/checks/yofix/run.go",
@@ -2164,6 +2169,7 @@
   "library/go/test/testhelpers/remove_lines_test.go":"library/go/test/testhelpers/remove_lines_test.go",
   "library/go/test/uuidtest/mock_generator.go":"library/go/test/uuidtest/mock_generator.go",
   "library/go/test/yatest/arcadia.go":"library/go/test/yatest/arcadia.go",
+  "library/go/test/yatest/dctest.go":"transfer_manager/go/github/library/go/test/yatest/dctest.go",
   "library/go/test/yatest/env.go":"library/go/test/yatest/env.go",
   "library/go/test/yatest/env_test.go":"library/go/test/yatest/env_test.go",
   "library/go/test/yatest/go.go":"library/go/test/yatest/go.go",
@@ -2681,6 +2687,7 @@
   "library/go/yandex/ydb/internal/cmd/gtrace/writer.go":"library/go/yandex/ydb/internal/cmd/gtrace/writer.go",
   "library/go/yandex/ydb/internal/xruntime/namedgoroutine.go":"library/go/yandex/ydb/internal/xruntime/namedgoroutine.go",
   "library/go/yandex/ydb/internal/xsync/pool.go":"library/go/yandex/ydb/internal/xsync/pool.go",
+  "library/go/yandex/ydb/internal/xtest/manytimes.go":"library/go/yandex/ydb/internal/xtest/manytimes.go",
   "library/go/yandex/ydb/log/README.md":"library/go/yandex/ydb/log/README.md",
   "library/go/yandex/ydb/log/adapter.go":"library/go/yandex/ydb/log/adapter.go",
   "library/go/yandex/ydb/log/fields.go":"library/go/yandex/ydb/log/fields.go",
@@ -2719,6 +2726,7 @@
   "library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicreader/fed_reader_options.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicreader/fed_reader_options.go",
   "library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicreader/fed_topic_reader.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicreader/fed_topic_reader.go",
   "library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicreader/fed_topic_reader_test.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicreader/fed_topic_reader_test.go",
+  "library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicreader/integration_test/fed_reader_integration_test.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicreader/integration_test/fed_reader_integration_test.go",
   "library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicwriter/fed_topic_writer.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicwriter/fed_topic_writer.go",
   "library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicwriter/fed_topic_writer_option.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicwriter/fed_topic_writer_option.go",
   "library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicwriter/fed_topic_writer_test.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/fedtopicwriter/fed_topic_writer_test.go",
@@ -2734,6 +2742,7 @@
   "library/go/yandex/ydb/ydb-topic-fed-sdk/internal/grpcauth.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/internal/grpcauth.go",
   "library/go/yandex/ydb/ydb-topic-fed-sdk/internal/grpcwrap/federation.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/internal/grpcwrap/federation.go",
   "library/go/yandex/ydb/ydb-topic-fed-sdk/internal/testhelpers/dbconnect.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/internal/testhelpers/dbconnect.go",
+  "library/go/yandex/ydb/ydb-topic-fed-sdk/internal/testhelpers/fedfixtures/fed_driver.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/internal/testhelpers/fedfixtures/fed_driver.go",
   "library/go/yandex/ydb/ydb-topic-fed-sdk/internal/testhelpers/logger.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/internal/testhelpers/logger.go",
   "library/go/yandex/ydb/ydb-topic-fed-sdk/internal/testhelpers/randstring.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/internal/testhelpers/randstring.go",
   "library/go/yandex/ydb/ydb-topic-fed-sdk/options.go":"library/go/yandex/ydb/ydb-topic-fed-sdk/options.go",
@@ -3181,6 +3190,7 @@
   "pkg/base/types/uint8.go":"transfer_manager/go/pkg/base/types/uint8.go",
   "pkg/buildinfo/version.go":"transfer_manager/go/pkg/buildinfo/version.go",
   "pkg/cleanup/closeable.go":"transfer_manager/go/pkg/cleanup/closeable.go",
+  "pkg/cobraaux/cobraaux.go":"transfer_manager/go/pkg/cobraaux/cobraaux.go",
   "pkg/config/aws_creds.go":"transfer_manager/go/pkg/config/aws_creds.go",
   "pkg/config/cloud_creds.go":"transfer_manager/go/pkg/config/cloud_creds.go",
   "pkg/config/config.go":"transfer_manager/go/pkg/config/config.go",
@@ -3962,10 +3972,7 @@
   "pkg/providers/mysql/sync_binlog_position.go":"transfer_manager/go/pkg/providers/mysql/sync_binlog_position.go",
   "pkg/providers/mysql/table_progress.go":"transfer_manager/go/pkg/providers/mysql/table_progress.go",
   "pkg/providers/mysql/tasks.go":"transfer_manager/go/pkg/providers/mysql/tasks.go",
-  "pkg/providers/mysql/tracker_abstract.go":"transfer_manager/go/pkg/providers/mysql/tracker_abstract.go",
-  "pkg/providers/mysql/tracker_embed.go":"transfer_manager/go/pkg/providers/mysql/tracker_embed.go",
-  "pkg/providers/mysql/tracker_internal.go":"transfer_manager/go/pkg/providers/mysql/tracker_internal.go",
-  "pkg/providers/mysql/tracker_null.go":"transfer_manager/go/pkg/providers/mysql/tracker_null.go",
+  "pkg/providers/mysql/tracker.go":"transfer_manager/go/pkg/providers/mysql/tracker.go",
   "pkg/providers/mysql/typesystem.go":"transfer_manager/go/pkg/providers/mysql/typesystem.go",
   "pkg/providers/mysql/typesystem.md":"transfer_manager/go/pkg/providers/mysql/typesystem.md",
   "pkg/providers/mysql/typesystem_test.go":"transfer_manager/go/pkg/providers/mysql/typesystem_test.go",

diff --git a/cloud/bitbucket/common-api/yandex/cloud/api/operation.pb.go b/cloud/bitbucket/common-api/yandex/cloud/api/operation.pb.go
diff --git a/cloud/bitbucket/common-api/yandex/cloud/api/tools/options.pb.go b/cloud/bitbucket/common-api/yandex/cloud/api/tools/options.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/access/access.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/access/access.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/dynamicform/v1/dynamicform.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/dynamicform/v1/dynamicform.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/restriction.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/restriction.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/access_binding_service.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/access_binding_service.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/api_key.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/api_key.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/api_key_service.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/api_key_service.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/gizmo_service.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/gizmo_service.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/iam_cookie_service.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/iam_cookie_service.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/iam_credential_service.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/iam_credential_service.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/iam_session_token_service.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/iam_session_token_service.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/iam_token_service.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/iam_token_service.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/key.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/key.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/key_service.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/key_service.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/membership_service.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/membership_service.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/oauth_client.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/oauth_client.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/oauth_client_service.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/oauth_client_service.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/oauth_scope.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/oauth_scope.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/oauth_scope_service.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/oauth_scope_service.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/operation_service.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/operation_service.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/os_login.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/os_login.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/os_login_service.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/os_login_service.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/permission.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/permission.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/permission_service.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/permission_service.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/permission_stage.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/permission_stage.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/permission_stage_service.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/permission_stage_service.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/quota_limit_service.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/quota_limit_service.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/quota_service.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/quota_service.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/refresh_token_issue_service.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/refresh_token_issue_service.pb.go
diff --git a/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/refresh_token_service.pb.go b/cloud/bitbucket/private-api/yandex/cloud/priv/iam/v1/refresh_token_service.pb.go