Skip to content

Commit

Permalink
remove ycdbaas
Browse files Browse the repository at this point in the history
  • Loading branch information
laskoviymishka committed Jul 4, 2024
1 parent e6c8d4f commit baef91e
Show file tree
Hide file tree
Showing 19 changed files with 44 additions and 871 deletions.
15 changes: 1 addition & 14 deletions .mapping.json
Original file line number Diff line number Diff line change
Expand Up @@ -3253,20 +3253,6 @@
"pkg/dbaas/host_port.go":"transfer_manager/go/pkg/dbaas/host_port.go",
"pkg/dbaas/init.go":"transfer_manager/go/pkg/dbaas/init.go",
"pkg/dbaas/roles.go":"transfer_manager/go/pkg/dbaas/roles.go",
"pkg/dbaas/ycdbaas/api.go":"transfer_manager/go/pkg/dbaas/ycdbaas/api.go",
"pkg/dbaas/ycdbaas/api_test.go":"transfer_manager/go/pkg/dbaas/ycdbaas/api_test.go",
"pkg/dbaas/ycdbaas/client.go":"transfer_manager/go/pkg/dbaas/ycdbaas/client.go",
"pkg/dbaas/ycdbaas/client_test.go":"transfer_manager/go/pkg/dbaas/ycdbaas/client_test.go",
"pkg/dbaas/ycdbaas/config.go":"transfer_manager/go/pkg/dbaas/ycdbaas/config.go",
"pkg/dbaas/ycdbaas/gp.go":"transfer_manager/go/pkg/dbaas/ycdbaas/gp.go",
"pkg/dbaas/ycdbaas/iam.go":"transfer_manager/go/pkg/dbaas/ycdbaas/iam.go",
"pkg/dbaas/ycdbaas/mdb_clickhouse.go":"transfer_manager/go/pkg/dbaas/ycdbaas/mdb_clickhouse.go",
"pkg/dbaas/ycdbaas/mdb_generic.go":"transfer_manager/go/pkg/dbaas/ycdbaas/mdb_generic.go",
"pkg/dbaas/ycdbaas/mdb_kafka.go":"transfer_manager/go/pkg/dbaas/ycdbaas/mdb_kafka.go",
"pkg/dbaas/ycdbaas/mdb_mongo.go":"transfer_manager/go/pkg/dbaas/ycdbaas/mdb_mongo.go",
"pkg/dbaas/ycdbaas/pg.go":"transfer_manager/go/pkg/dbaas/ycdbaas/pg.go",
"pkg/dbaas/ycdbaas/provider.go":"transfer_manager/go/pkg/dbaas/ycdbaas/provider.go",
"pkg/dbaas/ycdbaas/spaces.go":"transfer_manager/go/pkg/dbaas/ycdbaas/spaces.go",
"pkg/debezium/bench/main.go":"transfer_manager/go/pkg/debezium/bench/main.go",
"pkg/debezium/bench/stat.go":"transfer_manager/go/pkg/debezium/bench/stat.go",
"pkg/debezium/common/debezium_schema.go":"transfer_manager/go/pkg/debezium/common/debezium_schema.go",
Expand Down Expand Up @@ -3400,6 +3386,7 @@
"pkg/grpcutil/connection_options.go":"transfer_manager/go/pkg/grpcutil/connection_options.go",
"pkg/grpcutil/headers.go":"transfer_manager/go/pkg/grpcutil/headers.go",
"pkg/grpcutil/interceptor.go":"transfer_manager/go/pkg/grpcutil/interceptor.go",
"pkg/ha/pg.go":"transfer_manager/go/pkg/ha/pg.go",
"pkg/instanceutil/job_index.go":"transfer_manager/go/pkg/instanceutil/job_index.go",
"pkg/instanceutil/metadata_service.go":"transfer_manager/go/pkg/instanceutil/metadata_service.go",
"pkg/kv/yt_dyn_table_kv_wrapper.go":"transfer_manager/go/pkg/kv/yt_dyn_table_kv_wrapper.go",
Expand Down
7 changes: 3 additions & 4 deletions cmd/trcli/config/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@ import (
"github.com/doublecloud/tross/internal/core/xerrors"
"github.com/doublecloud/tross/pkg/abstract"
"github.com/doublecloud/tross/pkg/abstract/model"
server "github.com/doublecloud/tross/pkg/abstract/model"
"gopkg.in/yaml.v2"
)

Expand Down Expand Up @@ -92,14 +91,14 @@ func target(tr *TransferYamlView) (model.Destination, error) {
return model.NewDestination(tr.Dst.Type, tr.Dst.Params)
}

func transfer(source server.Source, target server.Destination, tr *TransferYamlView) *model.Transfer {
func transfer(source model.Source, target model.Destination, tr *TransferYamlView) *model.Transfer {
rt, _ := abstract.NewRuntime("local", "{}")
transfer := new(server.Transfer)
transfer := new(model.Transfer)
transfer.ID = tr.ID
transfer.TransferName = tr.TransferName
transfer.Description = tr.Description
transfer.Labels = tr.Labels
transfer.Status = server.New
transfer.Status = model.New
transfer.Type = tr.Type
transfer.FolderID = tr.FolderID
transfer.Runtime = rt
Expand Down
9 changes: 9 additions & 0 deletions pkg/dbaas/abstract.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,15 @@ type HostResolver interface {
ResolveHosts() ([]ClusterHost, error)
}

type MasterAndReplica struct {
Master string
Replica string
}

type MasterReplicaResolver interface {
ResolveMasterReplica() (*MasterAndReplica, error)
}

type PasswordResolver interface {
ResolvePassword() (string, error)
}
Expand Down
217 changes: 0 additions & 217 deletions pkg/dbaas/ycdbaas/api.go

This file was deleted.

25 changes: 0 additions & 25 deletions pkg/dbaas/ycdbaas/api_test.go

This file was deleted.

Loading

0 comments on commit baef91e

Please sign in to comment.