profiles

type DatabaseAdminClient interface {
	GetDatabase(ctx context.Context, req *adminpb.GetDatabaseRequest, opts ...gax.CallOption) (*adminpb.Database, error)
	Close() error
}

type DefaultIdentityOptions struct {
	SkipRangeMin     string
	SkipRangeMax     string
	StartCounterWith string
}

type DirectConnectionConfig struct {
	DataShardId string `json:"dataShardId"`
	Host        string `json:"host"`
	User        string `json:"user"`
	Password    string `json:"password"`
	Port        string `json:"port"`
	DbName      string `json:"dbName"`
}

type NewSourceProfileImpl struct{}

type NewSourceProfileInterface interface {
	NewSourceProfileFile(params map[string]string) SourceProfileFile
	NewSourceProfileConfig(source string, path string) (SourceProfileConfig, error)
	NewSourceProfileConnectionCloudSQL(source string, params map[string]string, s SourceProfileDialectInterface) (SourceProfileConnectionCloudSQL, error)
	NewSourceProfileConnection(source string, params map[string]string, s SourceProfileDialectInterface) (SourceProfileConnection, error)
}

type ShardConfigurationBulk struct {
	SchemaSource DirectConnectionConfig   `json:"schemaSource"`
	DataShards   []DirectConnectionConfig `json:"dataShards"`
}

type ShardConfigurationDMS struct {
}

type SourceProfile struct {
	Driver       string
	Ty           SourceProfileType
	File         SourceProfileFile
	Conn         SourceProfileConnection
	ConnCloudSQL SourceProfileConnectionCloudSQL
	Config       SourceProfileConfig
	Csv          SourceProfileCsv
}

type SourceProfileConfig struct {
	ConfigType             string                 `json:"configType"`
	ShardConfigurationBulk ShardConfigurationBulk `json:"shardConfigurationBulk"`
	ShardConfigurationDMS  ShardConfigurationDMS  `json:"shardConfigurationDMS"`
}

type SourceProfileConnection struct {
	Ty        SourceProfileConnectionType
	Mysql     SourceProfileConnectionMySQL
	Pg        SourceProfileConnectionPostgreSQL
	SqlServer SourceProfileConnectionSqlServer
	Oracle    SourceProfileConnectionOracle
	Cassandra SourceProfileConnectionCassandra
}

type SourceProfileConnectionCassandra struct {
	Host       string
	Port       string
	User       string
	Pwd        string
	Keyspace   string
	DataCenter string // Cassandra 4.x requires data center information for connection
}

type SourceProfileConnectionCloudSQL struct {
	Ty    SourceProfileConnectionTypeCloudSQL
	Mysql SourceProfileConnectionCloudSQLMySQL
	Pg    SourceProfileConnectionCloudSQLPostgreSQL
}

type SourceProfileConnectionCloudSQLMySQL struct {
	User         string
	Db           string
	InstanceName string
	Project      string
	Region       string
	Pwd          string
}

type SourceProfileConnectionCloudSQLPostgreSQL struct {
	User         string
	Db           string
	InstanceName string
	Project      string
	Region       string
	Pwd          string
}

type SourceProfileConnectionMySQL struct {
	Host string // Same as MYSQLHOST environment variable
	Port string // Same as MYSQLPORT environment variable
	User string // Same as MYSQLUSER environment variable
	Db   string // Same as MYSQLDATABASE environment variable
	Pwd  string // Same as MYSQLPWD environment variable
}

type SourceProfileConnectionOracle struct {
	Host string
	Port string
	User string
	Db   string
	Pwd  string
}

type SourceProfileConnectionPostgreSQL struct {
	Host string // Same as PGHOST environment variable
	Port string // Same as PGPORT environment variable
	User string // Same as PGUSER environment variable
	Db   string // Same as PGDATABASE environment variable
	Pwd  string // Same as PGPASSWORD environment variable
}

type SourceProfileConnectionSqlServer struct {
	Host string
	Port string
	User string
	Db   string
	Pwd  string
}

type SourceProfileConnectionType int

type SourceProfileConnectionTypeCloudSQL int

type SourceProfileCsv struct {
	Manifest  string
	Delimiter string
	NullStr   string
}

type SourceProfileDialectImpl struct{}

type SourceProfileDialectInterface interface {
	NewSourceProfileConnectionCloudSQLMySQL(params map[string]string, g utils.GetUtilInfoInterface) (SourceProfileConnectionCloudSQLMySQL, error)
	NewSourceProfileConnectionMySQL(params map[string]string, g utils.GetUtilInfoInterface) (SourceProfileConnectionMySQL, error)
	NewSourceProfileConnectionCloudSQLPostgreSQL(params map[string]string, g utils.GetUtilInfoInterface) (SourceProfileConnectionCloudSQLPostgreSQL, error)
	NewSourceProfileConnectionPostgreSQL(params map[string]string, g utils.GetUtilInfoInterface) (SourceProfileConnectionPostgreSQL, error)
	NewSourceProfileConnectionSqlServer(params map[string]string, g utils.GetUtilInfoInterface) (SourceProfileConnectionSqlServer, error)
	NewSourceProfileConnectionOracle(params map[string]string, g utils.GetUtilInfoInterface) (SourceProfileConnectionOracle, error)
	NewSourceProfileConnectionCassandra(params map[string]string, g utils.GetUtilInfoInterface) (SourceProfileConnectionCassandra, error)
}

type SourceProfileFile struct {
	Path   string
	Format string
}

type SourceProfileType int

type TargetProfile struct {
	Ty                     TargetProfileType
	Conn                   TargetProfileConnection
	DefaultIdentityOptions DefaultIdentityOptions
}

type TargetProfileConnection struct {
	Ty TargetProfileConnectionType
	Sp TargetProfileConnectionSpanner
}

type TargetProfileConnectionSpanner struct {
	Endpoint        string // Same as SPANNER_API_ENDPOINT environment variable
	Project         string // Same as GCLOUD_PROJECT environment variable
	Instance        string
	Dbname          string
	Dialect         string
	DefaultTimezone string
}

type TargetProfileConnectionType int

type TargetProfileType int