pg_models

package
v0.4.68 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 17, 2024 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AccountOnboardingConfig 

type AccountOnboardingConfig struct {
	HasCreatedSourceConnection      bool `json:"hasCreatedSourceConnection"`
	HasCreatedDestinationConnection bool `json:"hasCreatedDestinationConnection"`
	HasCreatedJob                   bool `json:"hasCreatedJob"`
	HasInvitedMembers               bool `json:"hasInvitedMembers"`
}

func (*AccountOnboardingConfig) FromDto 

func (t *AccountOnboardingConfig) FromDto(dto *mgmtv1alpha1.AccountOnboardingConfig)

func (*AccountOnboardingConfig) ToDto 

func (t *AccountOnboardingConfig) ToDto() *mgmtv1alpha1.AccountOnboardingConfig

type ActivityOptions 

type ActivityOptions struct {
	ScheduleToCloseTimeout *int64       `json:"scheduleToCloseTimeout,omitempty"`
	StartToCloseTimeout    *int64       `json:"startToCloseTimeout,omitempty"`
	RetryPolicy            *RetryPolicy `json:"retryPolicy,omitempty"`
}

func (*ActivityOptions) FromDto 

func (a *ActivityOptions) FromDto(dto *mgmtv1alpha1.ActivityOptions)

func (*ActivityOptions) ToDto 

func (a *ActivityOptions) ToDto() *mgmtv1alpha1.ActivityOptions

type AiGenerateSourceOptions 

type AiGenerateSourceOptions struct {
	AiConnectionId       string                          `json:"aiConnectionId"`
	Schemas              []*AiGenerateSourceSchemaOption `json:"schemas"`
	FkSourceConnectionId *string                         `json:"fkSourceConnectionId,omitempty"`
	ModelName            string                          `json:"modelName"`
	UserPrompt           *string                         `json:"userPrompt,omitempty"`
	GenerateBatchSize    *int64                          `json:"generateBatchSize,omitempty"`
}

func (*AiGenerateSourceOptions) FromDto 

func (s *AiGenerateSourceOptions) FromDto(dto *mgmtv1alpha1.AiGenerateSourceOptions)

func (*AiGenerateSourceOptions) ToDto 

func (s *AiGenerateSourceOptions) ToDto() *mgmtv1alpha1.AiGenerateSourceOptions

type AiGenerateSourceSchemaOption 

type AiGenerateSourceSchemaOption struct {
	Schema string                         `json:"schema"`
	Tables []*AiGenerateSourceTableOption `json:"tables"`
}

func FromDtoAiGenerateSourceSchemaOptions 

func FromDtoAiGenerateSourceSchemaOptions(dtos []*mgmtv1alpha1.AiGenerateSourceSchemaOption) []*AiGenerateSourceSchemaOption

type AiGenerateSourceTableOption 

type AiGenerateSourceTableOption struct {
	Table    string `json:"table"`
	RowCount int64  `json:"rowCount,omitempty"`
}

type AwsS3ConnectionConfig 

type AwsS3ConnectionConfig struct {
	BucketArn   string
	Bucket      string
	PathPrefix  *string
	Credentials *AwsS3Credentials
	Region      *string
	Endpoint    *string
}

func (*AwsS3ConnectionConfig) FromDto 

func (a *AwsS3ConnectionConfig) FromDto(dto *mgmtv1alpha1.AwsS3ConnectionConfig) error

func (*AwsS3ConnectionConfig) ToDto 

func (a *AwsS3ConnectionConfig) ToDto() *mgmtv1alpha1.AwsS3ConnectionConfig

type AwsS3Credentials 

type AwsS3Credentials struct {
	Profile         *string `json:"profile,omitempty"`
	AccessKeyId     *string `json:"accessKeyId,omitempty"`
	SecretAccessKey *string `json:"secretAccessKey,omitempty"`
	SessionToken    *string `json:"sessionToken,omitempty"`
	FromEc2Role     *bool   `json:"fromEc2Role,omitempty"`
	RoleArn         *string `json:"roleArn,omitempty"`
	RoleExternalId  *string `json:"roleExternalId,omitempty"`
}

func (*AwsS3Credentials) FromDto 

func (a *AwsS3Credentials) FromDto(dto *mgmtv1alpha1.AwsS3Credentials)

func (*AwsS3Credentials) ToDto 

func (a *AwsS3Credentials) ToDto() *mgmtv1alpha1.AwsS3Credentials

type AwsS3DestinationOptions 

type AwsS3DestinationOptions struct{}

type ClientTls added in v0.4.23 

type ClientTls struct {
	RootCert   *string `json:"rootCert,omitempty"`
	ClientCert *string `json:"clientCert,omitempty"`
	ClientKey  *string `json:"clientKey,omitempty"`
}

func (*ClientTls) FromDto added in v0.4.23 

func (c *ClientTls) FromDto(dto *mgmtv1alpha1.ClientTlsConfig)

func (*ClientTls) ToDto added in v0.4.23 

func (c *ClientTls) ToDto() *mgmtv1alpha1.ClientTlsConfig

type ConnectionConfig 

type ConnectionConfig struct {
	PgConfig              *PostgresConnectionConfig       `json:"pgConfig,omitempty"`
	AwsS3Config           *AwsS3ConnectionConfig          `json:"awsS3Config,omitempty"`
	MysqlConfig           *MysqlConnectionConfig          `json:"mysqlConfig,omitempty"`
	LocalDirectoryConfig  *LocalDirectoryConnectionConfig `json:"localDirConfig,omitempty"`
	OpenAiConfig          *OpenAiConnectionConfig         `json:"openaiConfig,omitempty"`
	MongoConfig           *MongoConnectionConfig          `json:"mongoConfig,omitempty"`
	GcpCloudStorageConfig *GcpCloudStorageConfig          `json:"gcpCloudStorageConfig,omitempty"`
	DynamoDBConfig        *DynamoDBConfig                 `json:"dynamoDBConfig,omitempty"`
	MssqlConfig           *MssqlConfig                    `json:"mssqlConfig,omitempty"`
}

func (*ConnectionConfig) FromDto 

func (c *ConnectionConfig) FromDto(dto *mgmtv1alpha1.ConnectionConfig) error

func (*ConnectionConfig) ToDto 

func (c *ConnectionConfig) ToDto() (*mgmtv1alpha1.ConnectionConfig, error)

type ConnectionOptions 

type ConnectionOptions struct {
	MaxConnectionLimit *int32 `json:"maxConnectionLimit,omitempty"`
}

func (*ConnectionOptions) FromDto 

func (s *ConnectionOptions) FromDto(dto *mgmtv1alpha1.SqlConnectionOptions)

func (*ConnectionOptions) ToDto 

func (s *ConnectionOptions) ToDto() *mgmtv1alpha1.SqlConnectionOptions

type DynamoDBConfig added in v0.4.48 

type DynamoDBConfig struct {
	Credentials *AwsS3Credentials `json:"Credentials,omitempty"`
	Region      *string           `json:"Region,omitempty"`
	Endpoint    *string           `json:"Endpoint,omitempty"`
}

func (*DynamoDBConfig) FromDto added in v0.4.48 

func (d *DynamoDBConfig) FromDto(dto *mgmtv1alpha1.DynamoDBConnectionConfig) error

func (*DynamoDBConfig) ToDto added in v0.4.48 

func (d *DynamoDBConfig) ToDto() (*mgmtv1alpha1.DynamoDBConnectionConfig, error)

type DynamoDBDestinationOptions added in v0.4.48 

type DynamoDBDestinationOptions struct {
	TableMappings []*DynamoDBDestinationTableMapping `json:"tableMappings"`
}

func (*DynamoDBDestinationOptions) FromDto added in v0.4.48 

func (d *DynamoDBDestinationOptions) FromDto(dto *mgmtv1alpha1.DynamoDBDestinationConnectionOptions)

func (*DynamoDBDestinationOptions) ToDto added in v0.4.48 

func (d *DynamoDBDestinationOptions) ToDto() *mgmtv1alpha1.DynamoDBDestinationConnectionOptions

type DynamoDBDestinationTableMapping added in v0.4.48 

type DynamoDBDestinationTableMapping struct {
	SourceTable      string `json:"sourceTable"`
	DestinationTable string `json:"destinationTable"`
}

func (*DynamoDBDestinationTableMapping) FromDto added in v0.4.48 

func (d *DynamoDBDestinationTableMapping) FromDto(dto *mgmtv1alpha1.DynamoDBDestinationTableMapping)

func (*DynamoDBDestinationTableMapping) ToDto added in v0.4.48 

func (d *DynamoDBDestinationTableMapping) ToDto() *mgmtv1alpha1.DynamoDBDestinationTableMapping

type DynamoDBSourceOptions added in v0.4.48 

type DynamoDBSourceOptions struct {
	ConnectionId         string                                 `json:"connectionId"`
	Tables               []*DynamoDBSourceTableOption           `json:"tables"`
	UnmappedTransforms   *DynamoDBSourceUnmappedTransformConfig `json:"unmappedTransforms"`
	EnableConsistentRead bool                                   `json:"enableConsistentRead"`
}

func (*DynamoDBSourceOptions) FromDto added in v0.4.48 

func (s *DynamoDBSourceOptions) FromDto(dto *mgmtv1alpha1.DynamoDBSourceConnectionOptions) error

func (*DynamoDBSourceOptions) ToDto added in v0.4.48 

func (s *DynamoDBSourceOptions) ToDto() *mgmtv1alpha1.DynamoDBSourceConnectionOptions

type DynamoDBSourceTableOption added in v0.4.49 

type DynamoDBSourceTableOption struct {
	Table       string  `json:"table"`
	WhereClause *string `json:"whereClause,omitempty"`
}

func FromDtoDynamoDBSourceTableOptions added in v0.4.50 

func FromDtoDynamoDBSourceTableOptions(dtos []*mgmtv1alpha1.DynamoDBSourceTableOption) []*DynamoDBSourceTableOption

func (*DynamoDBSourceTableOption) FromDto added in v0.4.49 

func (s *DynamoDBSourceTableOption) FromDto(dto *mgmtv1alpha1.DynamoDBSourceTableOption)

func (*DynamoDBSourceTableOption) ToDto added in v0.4.49 

func (s *DynamoDBSourceTableOption) ToDto() *mgmtv1alpha1.DynamoDBSourceTableOption

type DynamoDBSourceUnmappedTransformConfig added in v0.4.51 

type DynamoDBSourceUnmappedTransformConfig struct {
	B       *JobMappingTransformerModel `json:"b"`
	Boolean *JobMappingTransformerModel `json:"boolean"`
	N       *JobMappingTransformerModel `json:"n"`
	S       *JobMappingTransformerModel `json:"s"`
}

func (*DynamoDBSourceUnmappedTransformConfig) FromDto added in v0.4.51 

func (s *DynamoDBSourceUnmappedTransformConfig) FromDto(dto *mgmtv1alpha1.DynamoDBSourceUnmappedTransformConfig) error

func (*DynamoDBSourceUnmappedTransformConfig) ToDto added in v0.4.51 

func (s *DynamoDBSourceUnmappedTransformConfig) ToDto() *mgmtv1alpha1.DynamoDBSourceUnmappedTransformConfig

type GcpCloudStorageConfig added in v0.4.40 

type GcpCloudStorageConfig struct {
	Bucket     string  `json:"bucket"`
	PathPrefix *string `json:"pathPrefix,omitempty"`

	ServiceAccountCredentials *string `json:"serviceAccountCredentials,omitempty"`
}

func (*GcpCloudStorageConfig) FromDto added in v0.4.40 

func (g *GcpCloudStorageConfig) FromDto(dto *mgmtv1alpha1.GcpCloudStorageConnectionConfig) error

func (*GcpCloudStorageConfig) ToDto added in v0.4.40 

func (g *GcpCloudStorageConfig) ToDto() (*mgmtv1alpha1.GcpCloudStorageConnectionConfig, error)

type GcpCloudStorageDestinationOptions added in v0.4.40 

type GcpCloudStorageDestinationOptions struct{}

type GenerateBoolConfig 

type GenerateBoolConfig struct{}

type GenerateCardNumberConfig 

type GenerateCardNumberConfig struct {
	ValidLuhn bool `json:"validLuhn"`
}

type GenerateCategoricalConfig 

type GenerateCategoricalConfig struct {
	Categories string `json:"categories"`
}

type GenerateCityConfig 

type GenerateCityConfig struct{}

type GenerateCountryConfig added in v0.4.59 

type GenerateCountryConfig struct {
	GenerateFullName bool `json:"generateFullName"`
}

type GenerateDefaultConfig 

type GenerateDefaultConfig struct{}

type GenerateE164PhoneNumberConfig 

type GenerateE164PhoneNumberConfig struct {
	Min int64 `json:"min"`
	Max int64 `json:"max"`
}

type GenerateEmailConfig 

type GenerateEmailConfig struct {
	EmailType *int32 `json:"emailType,omitempty"`
}

type GenerateFirstNameConfig 

type GenerateFirstNameConfig struct{}

type GenerateFloat64Config 

type GenerateFloat64Config struct {
	RandomizeSign bool    `json:"randomizeSign"`
	Min           float64 `json:"min"`
	Max           float64 `json:"max"`
	Precision     int64   `json:"precision"`
}

type GenerateFullAddressConfig 

type GenerateFullAddressConfig struct{}

type GenerateFullNameConfig 

type GenerateFullNameConfig struct{}

type GenerateGenderConfig 

type GenerateGenderConfig struct {
	Abbreviate bool `json:"abbreviate"`
}

type GenerateInt64Config 

type GenerateInt64Config struct {
	RandomizeSign bool  `json:"randomizeSign"`
	Min           int64 `json:"min"`
	Max           int64 `json:"max"`
}

type GenerateInt64PhoneNumberConfig 

type GenerateInt64PhoneNumberConfig struct{}

type GenerateJavascript 

type GenerateJavascript struct {
	Code string `json:"code"`
}

type GenerateLastNameConfig 

type GenerateLastNameConfig struct{}

type GenerateSha256HashConfig 

type GenerateSha256HashConfig struct{}

type GenerateSourceOptions 

type GenerateSourceOptions struct {
	Schemas              []*GenerateSourceSchemaOption `json:"schemas"`
	FkSourceConnectionId *string                       `json:"fkSourceConnectionId,omitempty"`
}

func (*GenerateSourceOptions) FromDto 

func (s *GenerateSourceOptions) FromDto(dto *mgmtv1alpha1.GenerateSourceOptions)

func (*GenerateSourceOptions) ToDto 

func (s *GenerateSourceOptions) ToDto() *mgmtv1alpha1.GenerateSourceOptions

type GenerateSourceSchemaOption 

type GenerateSourceSchemaOption struct {
	Schema string                       `json:"schema"`
	Tables []*GenerateSourceTableOption `json:"tables"`
}

func FromDtoGenerateSourceSchemaOptions 

func FromDtoGenerateSourceSchemaOptions(dtos []*mgmtv1alpha1.GenerateSourceSchemaOption) []*GenerateSourceSchemaOption

type GenerateSourceTableOption 

type GenerateSourceTableOption struct {
	Table    string `json:"table"`
	RowCount int64  `json:"rowCount,omitempty"`
}

type GenerateSsnConfig 

type GenerateSsnConfig struct{}

type GenerateStateConfig 

type GenerateStateConfig struct {
	GenerateFullName bool `json:"generateFullName"`
}

type GenerateStreetAddressConfig 

type GenerateStreetAddressConfig struct{}

type GenerateStringConfig 

type GenerateStringConfig struct {
	Min int64 `json:"min"`
	Max int64 `json:"max"`
}

type GenerateStringPhoneNumberConfig 

type GenerateStringPhoneNumberConfig struct {
	Min int64 `json:"min"`
	Max int64 `json:"max"`
}

type GenerateUnixTimestampConfig 

type GenerateUnixTimestampConfig struct{}

type GenerateUsernameConfig 

type GenerateUsernameConfig struct{}

type GenerateUtcTimestampConfig 

type GenerateUtcTimestampConfig struct{}

type GenerateUuidConfig 

type GenerateUuidConfig struct {
	IncludeHyphens bool `json:"includeHyphens"`
}

type GenerateZipcodeConfig 

type GenerateZipcodeConfig struct{}

type JobDestinationOptions 

type JobDestinationOptions struct {
	PostgresOptions        *PostgresDestinationOptions        `json:"postgresOptions,omitempty"`
	AwsS3Options           *AwsS3DestinationOptions           `json:"awsS3Options,omitempty"`
	MysqlOptions           *MysqlDestinationOptions           `json:"mysqlOptions,omitempty"`
	MongoOptions           *MongoDestinationOptions           `json:"mongoOptions,omitempty"`
	GcpCloudStorageOptions *GcpCloudStorageDestinationOptions `json:"gcpCloudStorageOptions,omitempty"`
	DynamoDBOptions        *DynamoDBDestinationOptions        `json:"dynamoDBOptions,omitempty"`
	MssqlOptions           *MssqlDestinationOptions           `json:"mssqlOptions,omitempty"`
}

func (*JobDestinationOptions) FromDto 

func (j *JobDestinationOptions) FromDto(dto *mgmtv1alpha1.JobDestinationOptions) error

func (*JobDestinationOptions) ToDto 

func (j *JobDestinationOptions) ToDto() *mgmtv1alpha1.JobDestinationOptions

type JobMapping 

type JobMapping struct {
	Schema                string                      `json:"schema"`
	Table                 string                      `json:"table"`
	Column                string                      `json:"column"`
	JobMappingTransformer *JobMappingTransformerModel `json:"jobMappingTransformerModel,omitempty"`
}

func (*JobMapping) FromDto 

func (jm *JobMapping) FromDto(dto *mgmtv1alpha1.JobMapping) error

func (*JobMapping) ToDto 

func (jm *JobMapping) ToDto() *mgmtv1alpha1.JobMapping

type JobMappingTransformerModel 

type JobMappingTransformerModel struct {
	Source int32               `json:"source"`
	Config *TransformerConfigs `json:"config,omitempty"`
}

func (*JobMappingTransformerModel) FromTransformerDto 

func (t *JobMappingTransformerModel) FromTransformerDto(tr *mgmtv1alpha1.JobMappingTransformer) error

from API -> DB

func (*JobMappingTransformerModel) ToTransformerDto 

func (t *JobMappingTransformerModel) ToTransformerDto() *mgmtv1alpha1.JobMappingTransformer

DB -> API

type JobSourceOptions 

type JobSourceOptions struct {
	PostgresOptions   *PostgresSourceOptions   `json:"postgresOptions,omitempty"`
	MysqlOptions      *MysqlSourceOptions      `json:"mysqlOptions,omitempty"`
	GenerateOptions   *GenerateSourceOptions   `json:"generateOptions,omitempty"`
	AiGenerateOptions *AiGenerateSourceOptions `json:"aiGenerateOptions,omitempty"`
	MongoDbOptions    *MongoDbSourceOptions    `json:"mongoOptions,omitempty"`
	DynamoDBOptions   *DynamoDBSourceOptions   `json:"dynamoDBOptions,omitempty"`
	MssqlOptions      *MssqlSourceOptions      `json:"mssqlOptions,omitempty"`
}

func (*JobSourceOptions) FromDto 

func (j *JobSourceOptions) FromDto(dto *mgmtv1alpha1.JobSourceOptions) error

func (*JobSourceOptions) ToDto 

func (j *JobSourceOptions) ToDto() *mgmtv1alpha1.JobSourceOptions

type LocalDirectoryConnectionConfig 

type LocalDirectoryConnectionConfig struct {
	Path string `json:"path"`
}

func (*LocalDirectoryConnectionConfig) FromDto 

func (l *LocalDirectoryConnectionConfig) FromDto(dto *mgmtv1alpha1.LocalDirectoryConnectionConfig)

func (*LocalDirectoryConnectionConfig) ToDto 

func (l *LocalDirectoryConnectionConfig) ToDto() *mgmtv1alpha1.LocalDirectoryConnectionConfig

type MongoConnectionConfig added in v0.4.26 

type MongoConnectionConfig struct {
	Url       *string    `json:"url,omitempty"`
	SSHTunnel *SSHTunnel `json:"sshTunnel,omitempty"`
	ClientTls *ClientTls `json:"clientTls,omitempty"`
}

func (*MongoConnectionConfig) FromDto added in v0.4.26 

func (m *MongoConnectionConfig) FromDto(dto *mgmtv1alpha1.MongoConnectionConfig) error

func (*MongoConnectionConfig) ToDto added in v0.4.26 

func (m *MongoConnectionConfig) ToDto() (*mgmtv1alpha1.MongoConnectionConfig, error)

type MongoDbSourceOptions added in v0.4.26 

type MongoDbSourceOptions struct {
	ConnectionId string `json:"connectionId"`
}

func (*MongoDbSourceOptions) FromDto added in v0.4.26 

func (s *MongoDbSourceOptions) FromDto(dto *mgmtv1alpha1.MongoDBSourceConnectionOptions)

func (*MongoDbSourceOptions) ToDto added in v0.4.26 

func (s *MongoDbSourceOptions) ToDto() *mgmtv1alpha1.MongoDBSourceConnectionOptions

type MongoDestinationOptions added in v0.4.26 

type MongoDestinationOptions struct{}

type MssqlConfig added in v0.4.52 

type MssqlConfig struct {
	Url               *string            `json:"url,omitempty"`
	ConnectionOptions *ConnectionOptions `json:"connectionOptions,omitempty"`
	SSHTunnel         *SSHTunnel         `json:"sshTunnel,omitempty"`
}

func (*MssqlConfig) FromDto added in v0.4.52 

func (d *MssqlConfig) FromDto(dto *mgmtv1alpha1.MssqlConnectionConfig) error

func (*MssqlConfig) ToDto added in v0.4.52 

func (d *MssqlConfig) ToDto() (*mgmtv1alpha1.MssqlConnectionConfig, error)

type MssqlDestinationOptions added in v0.4.52 

type MssqlDestinationOptions struct {
	TruncateTableConfig      *MssqlTruncateTableConfig `json:"truncateTableConfig,omitempty"`
	InitTableSchema          bool                      `json:"initTableSchema"`
	OnConflictConfig         *MssqlOnConflictConfig    `json:"onConflict,omitempty"`
	SkipForeignKeyViolations bool                      `json:"skipForeignKeyViolations"`
}

func (*MssqlDestinationOptions) FromDto added in v0.4.52 

func (m *MssqlDestinationOptions) FromDto(dto *mgmtv1alpha1.MssqlDestinationConnectionOptions)

func (*MssqlDestinationOptions) ToDto added in v0.4.52 

func (m *MssqlDestinationOptions) ToDto() *mgmtv1alpha1.MssqlDestinationConnectionOptions

type MssqlOnConflictConfig added in v0.4.52 

type MssqlOnConflictConfig struct {
	DoNothing bool `json:"doNothing"`
}

func (*MssqlOnConflictConfig) FromDto added in v0.4.52 

func (t *MssqlOnConflictConfig) FromDto(dto *mgmtv1alpha1.MssqlOnConflictConfig)

func (*MssqlOnConflictConfig) ToDto added in v0.4.52 

func (t *MssqlOnConflictConfig) ToDto() *mgmtv1alpha1.MssqlOnConflictConfig

type MssqlSourceOptions added in v0.4.52 

type MssqlSourceOptions struct {
	HaltOnNewColumnAddition       bool                       `json:"haltOnNewColumnAddition"`
	SubsetByForeignKeyConstraints bool                       `json:"subsetByForeignKeyConstraints"`
	Schemas                       []*MssqlSourceSchemaOption `json:"schemas"`
	ConnectionId                  string                     `json:"connectionId"`
}

func (*MssqlSourceOptions) FromDto added in v0.4.52 

func (m *MssqlSourceOptions) FromDto(dto *mgmtv1alpha1.MssqlSourceConnectionOptions)

func (*MssqlSourceOptions) ToDto added in v0.4.52 

func (m *MssqlSourceOptions) ToDto() *mgmtv1alpha1.MssqlSourceConnectionOptions

type MssqlSourceSchemaOption added in v0.4.52 

type MssqlSourceSchemaOption struct {
	Schema string                    `json:"schema"`
	Tables []*MssqlSourceTableOption `json:"tables"`
}

func FromDtoMssqlSourceSchemaOptions added in v0.4.52 

func FromDtoMssqlSourceSchemaOptions(dtos []*mgmtv1alpha1.MssqlSourceSchemaOption) []*MssqlSourceSchemaOption

func (*MssqlSourceSchemaOption) FromDto added in v0.4.52 

func (m *MssqlSourceSchemaOption) FromDto(dto *mgmtv1alpha1.MssqlSourceSchemaOption)

func (*MssqlSourceSchemaOption) ToDto added in v0.4.52 

func (m *MssqlSourceSchemaOption) ToDto() *mgmtv1alpha1.MssqlSourceSchemaOption

type MssqlSourceTableOption added in v0.4.52 

type MssqlSourceTableOption struct {
	Table       string  `json:"table"`
	WhereClause *string `json:"whereClause,omitempty"`
}

func FromDtoMssqlSourceTableOption added in v0.4.52 

func FromDtoMssqlSourceTableOption(dtos []*mgmtv1alpha1.MssqlSourceTableOption) []*MssqlSourceTableOption

func (*MssqlSourceTableOption) FromDto added in v0.4.52 

func (m *MssqlSourceTableOption) FromDto(dto *mgmtv1alpha1.MssqlSourceTableOption)

func (*MssqlSourceTableOption) ToDto added in v0.4.52 

func (m *MssqlSourceTableOption) ToDto() *mgmtv1alpha1.MssqlSourceTableOption

type MssqlTruncateTableConfig added in v0.4.52 

type MssqlTruncateTableConfig struct {
	TruncateBeforeInsert bool `json:"truncateBeforeInsert"`
}

func (*MssqlTruncateTableConfig) FromDto added in v0.4.52 

func (t *MssqlTruncateTableConfig) FromDto(dto *mgmtv1alpha1.MssqlTruncateTableConfig)

func (*MssqlTruncateTableConfig) ToDto added in v0.4.52 

func (t *MssqlTruncateTableConfig) ToDto() *mgmtv1alpha1.MssqlTruncateTableConfig

type MysqlConnection 

type MysqlConnection struct {
	User     string `json:"user"`
	Pass     string `json:"pass"`
	Protocol string `json:"protocol"`
	Host     string `json:"host"`
	Port     int32  `json:"port"`
	Name     string `json:"name"`
}

type MysqlConnectionConfig 

type MysqlConnectionConfig struct {
	Connection        *MysqlConnection   `json:"connection,omitempty"`
	Url               *string            `json:"url,omitempty"`
	SSHTunnel         *SSHTunnel         `json:"sshTunnel,omitempty"`
	ConnectionOptions *ConnectionOptions `json:"connectionOptions,omitempty"`
}

type MysqlDestinationOptions 

type MysqlDestinationOptions struct {
	TruncateTableConfig      *MysqlTruncateTableConfig `json:"truncateTableConfig,omitempty"`
	InitTableSchema          bool                      `json:"initTableSchema"`
	OnConflictConfig         *MysqlOnConflictConfig    `json:"onConflict,omitempty"`
	SkipForeignKeyViolations bool                      `json:"skipForeignKeyViolations"`
}

type MysqlOnConflictConfig 

type MysqlOnConflictConfig struct {
	DoNothing bool `json:"doNothing"`
}

func (*MysqlOnConflictConfig) FromDto 

func (t *MysqlOnConflictConfig) FromDto(dto *mgmtv1alpha1.MysqlOnConflictConfig)

func (*MysqlOnConflictConfig) ToDto 

func (t *MysqlOnConflictConfig) ToDto() *mgmtv1alpha1.MysqlOnConflictConfig

type MysqlSourceOptions 

type MysqlSourceOptions struct {
	HaltOnNewColumnAddition       bool                       `json:"haltOnNewColumnAddition"`
	SubsetByForeignKeyConstraints bool                       `json:"subsetByForeignKeyConstraints"`
	Schemas                       []*MysqlSourceSchemaOption `json:"schemas"`
	ConnectionId                  string                     `json:"connectionId"`
}

func (*MysqlSourceOptions) FromDto 

func (s *MysqlSourceOptions) FromDto(dto *mgmtv1alpha1.MysqlSourceConnectionOptions)

func (*MysqlSourceOptions) ToDto 

func (s *MysqlSourceOptions) ToDto() *mgmtv1alpha1.MysqlSourceConnectionOptions

type MysqlSourceSchemaOption 

type MysqlSourceSchemaOption struct {
	Schema string                    `json:"schema"`
	Tables []*MysqlSourceTableOption `json:"tables"`
}

func FromDtoMysqlSourceSchemaOptions 

func FromDtoMysqlSourceSchemaOptions(dtos []*mgmtv1alpha1.MysqlSourceSchemaOption) []*MysqlSourceSchemaOption

type MysqlSourceTableOption 

type MysqlSourceTableOption struct {
	Table       string  `json:"table"`
	WhereClause *string `json:"whereClause,omitempty"`
}

type MysqlTruncateTableConfig 

type MysqlTruncateTableConfig struct {
	TruncateBeforeInsert bool `json:"truncateBeforeInsert"`
}

func (*MysqlTruncateTableConfig) FromDto 

func (t *MysqlTruncateTableConfig) FromDto(dto *mgmtv1alpha1.MysqlTruncateTableConfig)

func (*MysqlTruncateTableConfig) ToDto 

func (t *MysqlTruncateTableConfig) ToDto() *mgmtv1alpha1.MysqlTruncateTableConfig

type NullConfig 

type NullConfig struct{}

type OpenAiConnectionConfig 

type OpenAiConnectionConfig struct {
	ApiUrl string `json:"apiUrl"`
	ApiKey string `json:"apiKey"`
}

func (*OpenAiConnectionConfig) FromDto 

func (o *OpenAiConnectionConfig) FromDto(dto *mgmtv1alpha1.OpenAiConnectionConfig)

func (*OpenAiConnectionConfig) ToDto 

func (o *OpenAiConnectionConfig) ToDto() *mgmtv1alpha1.OpenAiConnectionConfig

type PassthroughConfig 

type PassthroughConfig struct{}

type PostgresConnection 

type PostgresConnection struct {
	Host    string  `json:"host"`
	Port    int32   `json:"port"`
	Name    string  `json:"name"`
	User    string  `json:"user"`
	Pass    string  `json:"pass"`
	SslMode *string `json:"sslMode,omitempty"`
}

type PostgresConnectionConfig 

type PostgresConnectionConfig struct {
	Connection        *PostgresConnection `json:"connection,omitempty"`
	Url               *string             `json:"url,omitempty"`
	SSHTunnel         *SSHTunnel          `json:"sshTunnel,omitempty"`
	ConnectionOptions *ConnectionOptions  `json:"connectionOptions,omitempty"`
	ClientTls         *ClientTls          `json:"clientTls,omitempty"`
}

type PostgresDestinationOptions 

type PostgresDestinationOptions struct {
	TruncateTableConfig      *PostgresTruncateTableConfig `json:"truncateTableconfig,omitempty"`
	InitTableSchema          bool                         `json:"initTableSchema"`
	OnConflictConfig         *PostgresOnConflictConfig    `json:"onConflictConfig,omitempty"`
	SkipForeignKeyViolations bool                         `json:"skipForeignKeyViolations"`
}

type PostgresOnConflictConfig 

type PostgresOnConflictConfig struct {
	DoNothing bool `json:"doNothing"`
}

func (*PostgresOnConflictConfig) FromDto 

func (t *PostgresOnConflictConfig) FromDto(dto *mgmtv1alpha1.PostgresOnConflictConfig)

func (*PostgresOnConflictConfig) ToDto 

func (t *PostgresOnConflictConfig) ToDto() *mgmtv1alpha1.PostgresOnConflictConfig

type PostgresSourceOptions 

type PostgresSourceOptions struct {
	HaltOnNewColumnAddition       bool                          `json:"haltOnNewColumnAddition"`
	SubsetByForeignKeyConstraints bool                          `json:"subsetByForeignKeyConstraints"`
	Schemas                       []*PostgresSourceSchemaOption `json:"schemas"`
	ConnectionId                  string                        `json:"connectionId"`
}

func (*PostgresSourceOptions) FromDto 

func (s *PostgresSourceOptions) FromDto(dto *mgmtv1alpha1.PostgresSourceConnectionOptions)

func (*PostgresSourceOptions) ToDto 

func (s *PostgresSourceOptions) ToDto() *mgmtv1alpha1.PostgresSourceConnectionOptions

type PostgresSourceSchemaOption 

type PostgresSourceSchemaOption struct {
	Schema string                       `json:"schema"`
	Tables []*PostgresSourceTableOption `json:"tables"`
}

func FromDtoPostgresSourceSchemaOptions 

func FromDtoPostgresSourceSchemaOptions(dtos []*mgmtv1alpha1.PostgresSourceSchemaOption) []*PostgresSourceSchemaOption

type PostgresSourceTableOption 

type PostgresSourceTableOption struct {
	Table       string  `json:"table"`
	WhereClause *string `json:"whereClause,omitempty"`
}

type PostgresTruncateTableConfig 

type PostgresTruncateTableConfig struct {
	TruncateBeforeInsert bool `json:"truncateBeforeInsert"`
	TruncateCascade      bool `json:"truncateCascade"`
}

func (*PostgresTruncateTableConfig) FromDto 

func (t *PostgresTruncateTableConfig) FromDto(dto *mgmtv1alpha1.PostgresTruncateTableConfig)

func (*PostgresTruncateTableConfig) ToDto 

func (t *PostgresTruncateTableConfig) ToDto() *mgmtv1alpha1.PostgresTruncateTableConfig

type RetryPolicy 

type RetryPolicy struct {
	MaximumAttempts *int32 `json:"maximumAttempts,omitempty"`
}

func (*RetryPolicy) FromDto 

func (r *RetryPolicy) FromDto(dto *mgmtv1alpha1.RetryPolicy)

func (*RetryPolicy) ToDto 

func (r *RetryPolicy) ToDto() *mgmtv1alpha1.RetryPolicy

type SSHAuthentication 

type SSHAuthentication struct {
	SSHPassphrase *SSHPassphrase `json:"sshPassphrase,omitempty"`
	SSHPrivateKey *SSHPrivateKey `json:"sshPrivateKey,omitempty"`
}

func (*SSHAuthentication) FromDto 

func (s *SSHAuthentication) FromDto(dto *mgmtv1alpha1.SSHAuthentication)

func (*SSHAuthentication) ToDto 

func (s *SSHAuthentication) ToDto() *mgmtv1alpha1.SSHAuthentication

type SSHPassphrase 

type SSHPassphrase struct {
	Value string `json:"value"`
}

type SSHPrivateKey 

type SSHPrivateKey struct {
	Value      string  `json:"value"`
	Passphrase *string `json:"passphrase,omitempty"`
}

type SSHTunnel 

type SSHTunnel struct {
	Host string `json:"host"`
	Port int32  `json:"port"`
	User string `json:"user"`

	KnownHostPublicKey *string            `json:"knownHostPublicKey,omitempty"`
	SSHAuthentication  *SSHAuthentication `json:"sshAuthentication,omitempty"`
}

func (*SSHTunnel) FromDto 

func (s *SSHTunnel) FromDto(dto *mgmtv1alpha1.SSHTunnel)

func (*SSHTunnel) ToDto 

func (s *SSHTunnel) ToDto() *mgmtv1alpha1.SSHTunnel

type TemporalConfig 

type TemporalConfig struct {
	Namespace        string `json:"namespace"`
	SyncJobQueueName string `json:"syncJobQueueName"`
	Url              string `json:"url"`
}

func (*TemporalConfig) FromDto 

func (t *TemporalConfig) FromDto(dto *mgmtv1alpha1.AccountTemporalConfig)

func (*TemporalConfig) ToDto 

func (t *TemporalConfig) ToDto() *mgmtv1alpha1.AccountTemporalConfig

type TransformCharacterScramble 

type TransformCharacterScramble struct {
	UserProvidedRegex *string `json:"userProvidedRegex,omitempty"`
}

type TransformE164PhoneNumberConfig 

type TransformE164PhoneNumberConfig struct {
	PreserveLength bool `json:"preserveLength"`
}

type TransformEmailConfig 

type TransformEmailConfig struct {
	PreserveLength     bool     `json:"preserveLength"`
	PreserveDomain     bool     `json:"preserveDomain"`
	ExcludedDomains    []string `json:"excludedDomains"`
	EmailType          *int32   `json:"emailType,omitempty"`
	InvalidEmailAction *int32   `json:"invalidEmailAction,omitempty"`
}

type TransformFirstNameConfig 

type TransformFirstNameConfig struct {
	PreserveLength bool `json:"preserveLength"`
}

type TransformFloat64Config 

type TransformFloat64Config struct {
	RandomizationRangeMin float64 `json:"randomizationRangeMin"`
	RandomizationRangeMax float64 `json:"randomizationRangeMax"`
}

type TransformFullNameConfig 

type TransformFullNameConfig struct {
	PreserveLength bool `json:"preserveLength"`
}

type TransformInt64Config 

type TransformInt64Config struct {
	RandomizationRangeMin int64 `json:"randomizationRangeMin"`
	RandomizationRangeMax int64 `json:"randomizationRangeMax"`
}

type TransformInt64PhoneNumberConfig 

type TransformInt64PhoneNumberConfig struct {
	PreserveLength bool `json:"preserveLength"`
}

type TransformJavascriptConfig 

type TransformJavascriptConfig struct {
	Code string `json:"code"`
}

type TransformLastNameConfig 

type TransformLastNameConfig struct {
	PreserveLength bool `json:"preserveLength"`
}

type TransformPhoneNumberConfig 

type TransformPhoneNumberConfig struct {
	PreserveLength bool `json:"preserveLength"`
}

type TransformStringConfig 

type TransformStringConfig struct {
	PreserveLength bool `json:"preserveLength"`
}

type TransformerConfigs 

type TransformerConfigs struct {
	GenerateEmail              *GenerateEmailConfig             `json:"generateEmailConfig,omitempty"`
	TransformEmail             *TransformEmailConfig            `json:"transformEmail,omitempty"`
	GenerateBool               *GenerateBoolConfig              `json:"generateBool,omitempty"`
	GenerateCardNumber         *GenerateCardNumberConfig        `json:"generateCardNumber,omitempty"`
	GenerateCity               *GenerateCityConfig              `json:"generateCity,omitempty"`
	GenerateDefault            *GenerateDefaultConfig           `json:"generateDefault,omitempty"`
	GenerateE164PhoneNumber    *GenerateE164PhoneNumberConfig   `json:"generateE164PhoneNumber,omitempty"`
	GenerateFirstName          *GenerateFirstNameConfig         `json:"generateFirstName,omitempty"`
	GenerateFloat64            *GenerateFloat64Config           `json:"generateFloat64,omitempty"`
	GenerateFullAddress        *GenerateFullAddressConfig       `json:"generateFullAddress,omitempty"`
	GenerateFullName           *GenerateFullNameConfig          `json:"generateFullName,omitempty"`
	GenerateGender             *GenerateGenderConfig            `json:"generateGender,omitempty"`
	GenerateInt64PhoneNumber   *GenerateInt64PhoneNumberConfig  `json:"generateInt64PhoneNumber,omitempty"`
	GenerateInt64              *GenerateInt64Config             `json:"GenerateInt64,omitempty"`
	GenerateLastName           *GenerateLastNameConfig          `json:"generateLastName,omitempty"`
	GenerateSha256Hash         *GenerateSha256HashConfig        `json:"generateSha256Hash,omitempty"`
	GenerateSsn                *GenerateSsnConfig               `json:"generateSsnConfig,omitempty"`
	GenerateState              *GenerateStateConfig             `json:"generateStateConfig,omitempty"`
	GenerateStreetAddress      *GenerateStreetAddressConfig     `json:"generateStreetAddressConfig,omitempty"`
	GenerateStringPhoneNumber  *GenerateStringPhoneNumberConfig `json:"generateStringPhoneNumber,omitempty"`
	GenerateString             *GenerateStringConfig            `json:"generateString,omitempty"`
	GenerateUnixTimestamp      *GenerateUnixTimestampConfig     `json:"generateUnixTimestamp,omitempty"`
	GenerateUsername           *GenerateUsernameConfig          `json:"generateUsername,omitempty"`
	GenerateUtcTimestamp       *GenerateUtcTimestampConfig      `json:"generateUtcTimestamp,omitempty"`
	GenerateUuid               *GenerateUuidConfig              `json:"generateUuid,omitempty"`
	GenerateZipcode            *GenerateZipcodeConfig           `json:"generateZipcode,omitempty"`
	TransformE164PhoneNumber   *TransformE164PhoneNumberConfig  `json:"transformE164PhoneNumber,omitempty"`
	TransformFirstname         *TransformFirstNameConfig        `json:"transformFirstName,omitempty"`
	TransformFloat64           *TransformFloat64Config          `json:"transformFloat64,omitempty"`
	TransformFullName          *TransformFullNameConfig         `json:"transformFullName,,omitempty"`
	TransformInt64PhoneNumber  *TransformInt64PhoneNumberConfig `json:"transformInt64PhoneNumber,omitempty"`
	TransformInt64             *TransformInt64Config            `json:"transformInt64,omitempty"`
	TransformLastName          *TransformLastNameConfig         `json:"transformLastName,omitempty"`
	TransformPhoneNumber       *TransformPhoneNumberConfig      `json:"transformPhoneNumber,omitempty"`
	TransformString            *TransformStringConfig           `json:"transformString,omitempty"`
	Passthrough                *PassthroughConfig               `json:"passthrough,omitempty"`
	Null                       *NullConfig                      `json:"null,omitempty"`
	UserDefinedTransformer     *UserDefinedTransformerConfig    `json:"userDefinedTransformer,omitempty"`
	TransformJavascript        *TransformJavascriptConfig       `json:"transformJavascript,omitempty"`
	GenerateCategorical        *GenerateCategoricalConfig       `json:"generateCategorical,omitempty"`
	TransformCharacterScramble *TransformCharacterScramble      `json:"transformCharacterScramble,omitempty"`
	GenerateJavascript         *GenerateJavascript              `json:"generateJavascript,omitempty"`
	GenerateCountry            *GenerateCountryConfig           `json:"generateCountryConfig,omitempty"`
}

func (*TransformerConfigs) FromTransformerConfigDto 

func (t *TransformerConfigs) FromTransformerConfigDto(tr *mgmtv1alpha1.TransformerConfig) error

func (*TransformerConfigs) ToTransformerConfigDto 

func (t *TransformerConfigs) ToTransformerConfigDto() *mgmtv1alpha1.TransformerConfig

type UserDefinedTransformerConfig 

type UserDefinedTransformerConfig struct {
	Id string `json:"id"`
}

type VirtualForeignConstraint added in v0.4.39 

type VirtualForeignConstraint struct {
	Schema     string             `json:"schema"`
	Table      string             `json:"table"`
	Columns    []string           `json:"columns"`
	ForeignKey *VirtualForeignKey `json:"ForeignKeyModel,omitempty"`
}

func (*VirtualForeignConstraint) FromDto added in v0.4.39 

func (v *VirtualForeignConstraint) FromDto(dto *mgmtv1alpha1.VirtualForeignConstraint) error

func (*VirtualForeignConstraint) ToDto added in v0.4.39 

func (v *VirtualForeignConstraint) ToDto() *mgmtv1alpha1.VirtualForeignConstraint

type VirtualForeignKey added in v0.4.39 

type VirtualForeignKey struct {
	Schema  string   `json:"schema"`
	Table   string   `json:"table"`
	Columns []string `json:"columns"`
}

func (*VirtualForeignKey) FromDto added in v0.4.39 

func (v *VirtualForeignKey) FromDto(dto *mgmtv1alpha1.VirtualForeignKey) error

func (*VirtualForeignKey) ToDto added in v0.4.39 

func (v *VirtualForeignKey) ToDto() *mgmtv1alpha1.VirtualForeignKey

type WorkflowOptions 

type WorkflowOptions struct {
	RunTimeout *int64 `json:"runTimeout,omitempty"`
}

func (*WorkflowOptions) FromDto 

func (a *WorkflowOptions) FromDto(dto *mgmtv1alpha1.WorkflowOptions)

func (*WorkflowOptions) ToDto 

func (a *WorkflowOptions) ToDto() *mgmtv1alpha1.WorkflowOptions

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.