profiles

type DataShard struct {
	DataShardId          string                `json:"dataShardId"`
	SrcConnectionProfile DatastreamConnProfile `json:"srcConnectionProfile"`
	DstConnectionProfile DatastreamConnProfile `json:"dstConnectionProfile"`
	DataflowConfig       DataflowConfig        `json:"dataflowConfig"`
	TmpDir               string                `json:"tmpDir"`
	StreamLocation       string                `json:"streamLocation"`
	LogicalShards        []LogicalShard        `json:"databases"`
}

type DataflowConfig struct {
	Location            string `json:"location"`
	Network             string `json:"network"`
	Subnetwork          string `json:"subnetwork"`
	HostProjectId       string `json:"hostProjectId"`
	MaxWorkers          string `json:"maxWorkers"`
	NumWorkers          string `json:"numWorkers"`
	ServiceAccountEmail string `json:"serviceAccountEmail"`
}

type DatastreamConnProfile struct {
	Name     string `json:"name"`
	Location string `json:"location"`
}

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 LogicalShard struct {
	DbName         string `json:"dbName"`
	LogicalShardId string `json:"databaseId"`
	RefDataShardId string `json:"refDataShardId"`
}

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

type ShardConfigurationDMS struct {
}

type ShardConfigurationDataflow struct {
	SchemaSource   DirectConnectionConfig `json:"schemaSource"`
	DataShards     []*DataShard           `json:"dataShards"`
	DataflowConfig DataflowConfig         `json:"dataflowConfig"`
}

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

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

type SourceProfileConnection struct {
	Ty        SourceProfileConnectionType
	Streaming bool
	Mysql     SourceProfileConnectionMySQL
	Pg        SourceProfileConnectionPostgreSQL
	Dydb      SourceProfileConnectionDynamoDB
	SqlServer SourceProfileConnectionSqlServer
	Oracle    SourceProfileConnectionOracle
}

type SourceProfileConnectionDynamoDB struct {
	// These connection params are not used currently because the SDK reads directly from the env variables.
	// These are still kept around as reference when we refactor passing
	// SourceProfile instead of sqlConnectionStr around.
	AwsAccessKeyID     string // Same as AWS_ACCESS_KEY_ID environment variable
	AwsSecretAccessKey string // Same as AWS_SECRET_ACCESS_KEY environment variable
	AwsRegion          string // Same as AWS_REGION environment variable
	DydbEndpoint       string // Same as DYNAMODB_ENDPOINT_OVERRIDE environment variable
	SchemaSampleSize   int64  // Number of rows to use for inferring schema (default 100,000)
	// contains filtered or unexported fields
}

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
	StreamingConfig string
}

type SourceProfileConnectionOracle struct {
	Host            string
	Port            string
	User            string
	Db              string
	Pwd             string
	StreamingConfig 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
	StreamingConfig string
}

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

type SourceProfileConnectionType int

type SourceProfileCsv struct {
	Manifest  string
	Delimiter string
	NullStr   string
}

type SourceProfileFile struct {
	Path   string
	Format string
}

type SourceProfileType int

type TargetProfile struct {
	Ty   TargetProfileType
	Conn TargetProfileConnection
}

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
}

type TargetProfileConnectionType int

type TargetProfileType int