Versions in this module Expand all Collapse all v0 v0.2.5 Nov 28, 2024 v0.2.4 Nov 11, 2024 v0.2.3 Oct 20, 2024 Changes in this version type Connection + Account string + Role string + Schema string + Warehouse string v0.2.2 Oct 9, 2024 v0.2.1 Oct 4, 2024 v0.2.0 Sep 27, 2024 Changes in this version + const Version + func BuildMetadata(sc *SourceConfig, mc *ModelConfig) error + func BuildModels(sc *SourceConfig, mc *ModelConfig) error + func ConfirmInsert(modelName string, dc chan []int64, rowsExpected int64) + func Debug(args ...interface{}) + func Debugf(format string, args ...interface{}) + func Error(args ...interface{}) + func Errorf(format string, args ...interface{}) + func Fatal(args ...interface{}) + func Fatalf(format string, args ...interface{}) + func GetConfig(modelTarget string) (*SourceConfig, *ModelConfig, error) + func GetMysqlPoolFromSource(source Source) (*sql.DB, error) + func Info(args ...interface{}) + func Infof(format string, args ...interface{}) + func Initialize(logLevels ...string) error + func Insert(modelName ModelName, ic <-chan []driver.Value, dc chan<- []int64) + func IsValidLogLevel(logLevel string) error + func ParseModelColumns(mc *ModelConfig, columnMetadata ColumnMetadata) error + func ParseModelTables(mc *ModelConfig) error + func PrintPrettyJSON(data []map[string]interface{}) error + func PrintPrettyStruct(v interface{}) error + func ReadRows(rows *sql.Rows, c chan map[string]any) error + func Retrieve(sc *SourceConfig, mc *ModelConfig) error + func ValidateConfigs(sc *SourceConfig, mc *ModelConfig) error + func Warn(args ...interface{}) + func Warnf(format string, args ...interface{}) + func WithError(err error) *logrus.Entry + func WithFields(fields logrus.Fields) *logrus.Entry + func WriteToTable(rows []map[string]any, columns []string, outputFormat string) error + type Column struct + Alias string + FuncName FuncName + IsJoin bool + ModelName ModelName + Position int + TableName *TableName + type ColumnMetadata map[TableName]map[ColumnName]ColumnType + func BuildColumnMetadata() (ColumnMetadata, error) + type ColumnName string + type ColumnType struct + MajorityType MajorityType + Types []string + type Connection struct + AuthSource string + BucketName string + Database string + Host string + Password string + Port int + Region string + Username string + type Env struct + LicenseKey string + PreenConfigPath string + PreenModelsPath string + func EnvInit() (*Env, error) + type Fields = logrus.Fields + type FuncName string + type MajorityType string + type Model struct + Collection string + Columns map[TableName]map[ColumnName]Column + DDLString string + FilePatterns *[]string + Format string + Name ModelName + Options Options + Parsed sqlparser.Statement + Query string + TableMap TableMap + TableSet TableSet + Type string + type ModelConfig struct + Env *Env + Models []*Model + func GetModelConfigs(modelTarget string) (*ModelConfig, error) + type ModelName string + type Options struct + AllVarchar *bool + AllowQuotedNulls *bool + AutoDetect *bool + AutoTypeCandidates *[]string + Columns *[]Type + Compression *string + DateFormat *string + DecimalSeparator *string + Delim *string + Escape *string + FileName *bool + ForceNotNull *[]string + Header *bool + HivePartitioning *bool + IgnoreErrors *bool + MaxLineSize *int64 + Names *[]string + NewLine *string + NormalizeNames *bool + NullPadding *bool + NullString *[]string + Parallel *bool + Quote *string + SampleSize *int64 + Skip *int64 + TimestampFormat *string + Types *[]Type + UnionByName *bool + type QueryResult struct + Columns []string + Rows []map[string]any + type QueryResults struct + Columns []string + ResultsChan chan map[string]any + Rows []map[string]any + func Execute(statement string) (*QueryResults, error) + type Retriever struct + Collection string + FilePatterns *[]string + Format string + ModelName string + Options Options + Query string + Source Source + TableName string + type Source struct + Connection Connection + Engine string + Models []string + Name string + type SourceConfig struct + Env *Env + Sources []Source + func GetSourceConfig() (*SourceConfig, error) + type TableAlias string + type TableMap map[TableAlias]TableName + type TableName string + type TableSet []TableName + type Type struct + Name string + Type string
Go to main page