conversion

type ConnectionProfile struct {
	// Project Id of the resource
	ProjectId string
	// Datashard Id for the resource
	DatashardId string
	// Name of connection profile
	Id string
	// If true, don't create resource, only validate if creation is possible. If false, create resource.
	ValidateOnly bool
	// If true, create source connection profile, else create target connection profile and gcs bucket.
	IsSource bool
	// For source connection profile host of MySql instance
	Host string
	// For source connection profile port of MySql instance
	Port string
	// For source connection profile password of MySql instance
	Password string
	// For source connection profile user name of MySql instance
	User string
	// Region of connection profile to be created
	Region string
	// For target connection profile name of gcs bucket to be created
	BucketName string
}

type ConnectionProfileReq struct {
	ConnectionProfile ConnectionProfile
	Error             error
	Ctx               context.Context
}

type ConvImpl struct{}

type ConvInterface interface {
	SchemaConv(migrationProjectId string, sourceProfile profiles.SourceProfile, targetProfile profiles.TargetProfile, ioHelper *utils.IOStreams, schemaFromSource SchemaFromSourceInterface) (*internal.Conv, error)
	DataConv(ctx context.Context, migrationProjectId string, sourceProfile profiles.SourceProfile, targetProfile profiles.TargetProfile, ioHelper *utils.IOStreams, client *sp.Client, conv *internal.Conv, dataOnly bool, writeLimit int64, dataFromSource DataFromSourceInterface) (*writer.BatchWriter, error)
}

type DataFromDatabaseImpl struct{}

type DataFromDatabaseInterface interface {
	// contains filtered or unexported methods
}

type DataFromSourceImpl struct{}

type DataFromSourceInterface interface {
	// contains filtered or unexported methods
}

type GetInfoImpl struct{}

type GetInfoInterface interface {
	GetInfoSchemaFromCloudSQL(migrationProjectId string, sourceProfile profiles.SourceProfile, targetProfile profiles.TargetProfile) (common.InfoSchema, error)
	GetInfoSchema(migrationProjectId string, sourceProfile profiles.SourceProfile, targetProfile profiles.TargetProfile) (common.InfoSchema, error)
	// contains filtered or unexported methods
}

type MockDataFromSource struct {
	mock.Mock
}

type MockGetInfo struct {
	mock.Mock
}

type MockProcessDumpByDialect struct {
	mock.Mock
}

type MockResourceGeneration struct {
	mock.Mock
}

type MockSchemaFromSource struct {
	mock.Mock
}

type MockValidateOrCreateResources struct {
	mock.Mock
}

type MockValidateResources struct {
	mock.Mock
}

type PopulateDataConvImpl struct{}

type PopulateDataConvInterface interface {
	// contains filtered or unexported methods
}

type ProcessDumpByDialectImpl struct {
	ExpressionVerificationAccessor expressions_api.ExpressionVerificationAccessor
	DdlVerifier                    expressions_api.DDLVerifier
}

type ProcessDumpByDialectInterface interface {
	ProcessDump(driver string, conv *internal.Conv, r *internal.Reader) error
}

type ReportImpl struct{}

type ReportInterface interface {
	GenerateReport(driver string, badWrites map[string]int64, BytesRead int64, banner string, conv *internal.Conv, reportFileName string, dbName string, out *os.File)
}

type SchemaFromSourceImpl struct {
	DdlVerifier expressions_api.DDLVerifier
}

type SchemaFromSourceInterface interface {
	SchemaFromDump(SpProjectId string, SpInstanceId string, driver string, spDialect string, ioHelper *utils.IOStreams, processDump ProcessDumpByDialectInterface, defaultIdentityOptions profiles.DefaultIdentityOptions) (*internal.Conv, error)
	// contains filtered or unexported methods
}

type SnapshotMigrationImpl struct{}

type SnapshotMigrationInterface interface {
	// contains filtered or unexported methods
}