Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
SourceConnection string `json:"source"`
TargetConnection string `json:"target"`
SourceTables []string `json:"tables"`
FilteredSourceTables map[string]struct {
Where string `json:"where"`
Wheres []string `json:"wheres"`
Uses []string `json:"uses"`
} `json:"filteredTables"`
UpdateChunkSize uint32 `json:"updateChunkSize"`
DeleteChunkSize uint32 `json:"deleteChunkSize"`
MinDeleteChunkSize uint32 `json:"minDeleteChunkSize"`
ThrottlePercentage float64 `json:"throttlePercentage"`
StateTableName string `json:"stateTable"`
SyncUpdates bool `json:"syncUpdates"`
SyncDeletes bool `json:"syncDeletes"`
ResyncOnSchemaChange bool `json:"resyncOnSchemaChange"`
FullCopyThreshold float64 `json:"fullCopyThreshold"`
WaitBetweenJobs time.Duration `json:"waitBetweenJobs"`
}
Config is the main configuration for SSLR
func LoadConfig ¶
LoadConfig reads a JSON - formatted config file into a Config. The loaded JSON is validated against the expected fields.
type Job ¶
type Job struct {
// contains filtered or unexported fields
}
Job represents an active sync job
type PrimaryKey ¶ added in v1.1.0
type PrimaryKey struct {
// contains filtered or unexported fields
}
PrimaryKey wraps integer and string valued keys
func (*PrimaryKey) Scan ¶ added in v1.1.0
func (pk *PrimaryKey) Scan(value interface{}) error
Scan implements Scanner interface
func (PrimaryKey) String ¶ added in v1.1.0
func (pk PrimaryKey) String() string
type PrimaryKeySet ¶ added in v1.1.0
type PrimaryKeySet []PrimaryKey
PrimaryKeySet is a list of primary key values for a single row
func (PrimaryKeySet) Equals ¶ added in v1.1.0
func (pks PrimaryKeySet) Equals(other PrimaryKeySet) bool
Equals compares two keysets
type PrimaryKeySetSlice ¶ added in v1.1.0
type PrimaryKeySetSlice []PrimaryKeySet
PrimaryKeySetSlice wraps a slice of PrimaryKeySet for easy conversion
func (PrimaryKeySetSlice) Transposed ¶ added in v1.1.0
func (rows PrimaryKeySetSlice) Transposed() []interface{}
Transposed converts a slice of PrimaryKey slices to a slice of string slices. Or - converts N rows of M primary key values into M columns of N single-valued key values. The result is returned as a []interface{} for easy inclusion in queries.
type ValidationStatus ¶ added in v1.1.0
type ValidationStatus int
ValidationStatus is used to track current table validation status
Source Files