Documentation
¶
Index ¶
Constants ¶
View Source
const ( // DSN is the configuration name of the data source name to connect to the Amazon Redshift. DSN = "dsn" // Table is the configuration name of the table name. Table = "table" // KeyColumns is the configuration name of comma-separated column names to build the sdk.Record.Key. KeyColumns = "keyColumns" )
View Source
const ( // OrderingColumn is a config name for the orderingColumn field. OrderingColumn = "orderingColumn" // Snapshot is a config name for the snapshot field. Snapshot = "snapshot" // BatchSize is the config name for a batch size. BatchSize = "batchSize" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Configuration ¶
type Configuration struct {
// DSN is the configuration of the data source name to connect to the Amazon Redshift.
DSN string `key:"dsn" validate:"required"`
// Table is the configuration of the table name.
Table string `key:"table" validate:"required,lowercase,excludesall= ,lte=127"`
// KeyColumns is the configuration of comma-separated column names to build the sdk.Record.Key (for Source).
KeyColumns []string `key:"keyColumns" validate:"omitempty,dive,lowercase,excludesall= ,lte=127"`
}
Configuration contains common for source and destination configurable values.
type Destination ¶
type Destination struct {
Configuration
}
Destination is a destination configuration needed to connect to Redshift database.
func ParseDestination ¶
func ParseDestination(cfg map[string]string) (Destination, error)
ParseDestination parses a destination configuration.
type Source ¶
type Source struct {
Configuration
// OrderingColumn is a name of a column that the connector will use for ordering rows.
OrderingColumn string `key:"orderingColumn" validate:"required,lowercase,excludesall= ,lte=127"`
// Snapshot is the configuration that determines whether the connector
// will take a snapshot of the entire table before starting cdc mode.
Snapshot bool `key:"snapshot"`
// BatchSize is a size of rows batch.
BatchSize int `key:"batchSize" validate:"gte=1,lte=100000"`
}
Source contains source-specific configurable values.
Source Files
Click to show internal directories.
Click to hide internal directories.