Versions in this module Expand all Collapse all v0 v0.2.4 Apr 23, 2022 Changes in this version + var ActionFuncs = map[string]map[string]map[string]Action + func ActionLauncher(cfg interface{}, ...) error + func GetHandlerHealth(log logger.Logger) func(w http.ResponseWriter, r *http.Request) + func GetHandlerStopServer(log logger.Logger, chanStop chan string) func(w http.ResponseWriter, r *http.Request) + func GetHandlerTransformLaunch(log logger.Logger, allTransformInfo *transform.SafeMapTransformInfo, ...) func(w http.ResponseWriter, r *http.Request) + func GetHandlerTransformList(log logger.Logger, allTransformInfo *transform.SafeMapTransformInfo) func(w http.ResponseWriter, r *http.Request) + func GetHandlerTransformStats(log logger.Logger, allTransformInfo *transform.SafeMapTransformInfo) func(w http.ResponseWriter, r *http.Request) + func GetHandlerTransformStatus(log logger.Logger, allTransformInfo *transform.SafeMapTransformInfo) func(w http.ResponseWriter, r *http.Request) + func GetHandlerTransformStop(log logger.Logger, allTransformInfo *transform.SafeMapTransformInfo) func(w http.ResponseWriter, r *http.Request) + func GetSupportedCpDeltaConnectionTypes() string + func GetSupportedCpMetaConnectionTypes() string + func GetSupportedCpSnapConnectionTypes() string + func GetSupportedOdbcConnectionTypes() string + func IsSupportedConnectionType(schema string) bool + func RunConnectionAdd(cfg *ConnectionConfig) error + func RunConnectionRemove(cfg *ConnectionConfig) error + func RunCqnOracleSync(cfg interface{}) error + func RunCqnSnowflakeSync(cfg interface{}) error + func RunCreateStage(cfg *CreateStageConfig) error + func RunDefaultAdd(cfg *DefaultAddConfig) error + func RunDefaultRemove(cfg *DefaultRemoveConfig) error + func RunDemoCleanup(cfg *DemoCleanupConfig) error + func RunDemoFullSetup(cfg *DemoSetupConfig) error + func RunDiff(cfg *DiffConfig) error + func RunDsnS3Delta(cfg interface{}) error + func RunDsnS3Snapshot(cfg interface{}) error + func RunDsnSnapshot(cfg interface{}) error + func RunDsnSnowflakeDelta(cfg interface{}) error + func RunDsnSnowflakeSnapshot(cfg interface{}) error + func RunOracleOracleDelta(cfg interface{}) error + func RunOracleOracleSnapshot(cfg interface{}) error + func RunOracleOracleSync(cfg interface{}) error + func RunOracleS3Delta(cfg interface{}) error + func RunOracleS3Snapshot(cfg interface{}) error + func RunOracleSnowflakeSync(cfg interface{}) error + func RunPipeFromFile(pipe *PipeConfig, web *WebServerConfig) error + func RunQuery(cfg *QueryConfig) error + func RunS3SnowflakeDelta(cfg interface{}) error + func RunS3SnowflakeSnapshot(cfg interface{}) error + func RunS3StdoutSnapshot(cfg interface{}) error + func RunSnowflakeDelta(cfg interface{}) error + func RunSnowflakeSnapshot(cfg interface{}) error + func RunTableToSnowflakeDDL(cfg interface{}) error + func RunWebServer(web *WebServerConfig) error + func SetupCpDsnS3Delta(genericCfg interface{}, actionCfg interface{}) error + func SetupCpDsnS3Snap(genericCfg interface{}, actionCfg interface{}) error + func SetupCpDsnSnap(genericCfg interface{}, actionCfg interface{}) error + func SetupCpDsnSnowflakeDelta(genericCfg interface{}, actionCfg interface{}) error + func SetupCpDsnSnowflakeSnap(genericCfg interface{}, actionCfg interface{}) error + func SetupCpMetaToSnowflake(genericCfg interface{}, actionCfg interface{}) error + func SetupCpOraOraDelta(genericCfg interface{}, actionCfg interface{}) error + func SetupCpOraOraSnap(genericCfg interface{}, actionCfg interface{}) error + func SetupCpOraS3Delta(genericCfg interface{}, actionCfg interface{}) error + func SetupCpOraS3Snap(genericCfg interface{}, actionCfg interface{}) error + func SetupCpOraSnowflakeDelta(genericCfg interface{}, actionCfg interface{}) error + func SetupCpOraSnowflakeSnap(genericCfg interface{}, actionCfg interface{}) error + func SetupCpS3SnowflakeDelta(genericCfg interface{}, actionCfg interface{}) error + func SetupCpS3SnowflakeSnap(genericCfg interface{}, actionCfg interface{}) error + func SetupCpS3StdoutSnap(genericCfg interface{}, actionCfg interface{}) error + func SetupCqnToOracleSync(genericCfg interface{}, actionCfg interface{}) error + func SetupCqnToSnowflakeSync(genericCfg interface{}, actionCfg interface{}) error + func SetupOracleToOracleSync(genericCfg interface{}, actionCfg interface{}) error + func SetupOracleToSnowflakeSync(genericCfg interface{}, actionCfg interface{}) error + type Action struct + ActionCfg interface{} + FnAction func(actionCfg interface{}) error + FnSetupCfg func(genericCfg interface{}, actionCfg interface{}) error + func GetCpDeltaAction(sourceType string, targetType string) (Action, error) + func GetCpMetaAction(sourceType string, targetType string) (Action, error) + func GetCpSnapAction(sourceType string, targetType string) (Action, error) + func GetSyncBatchAction(sourceType string, targetType string) (Action, error) + func GetSyncEventsAction(sourceType string, targetType string) (Action, error) + type ConnectionConfig struct + ConfigFile ConnectionGetterSetter + ConnDetails ConnectionValidator + Force bool + LogicalName string + MustUseOdbcScheme bool + Type string + type ConnectionGetterSetter interface + Delete func(key string) error + Get func(key string, out interface{}) error + Set func(key string, val interface{}) error + type ConnectionHandler interface + GetConnectionDetails func(connectionName string) (connectionDetails *shared.ConnectionDetails, err error) + GetConnectionType func(connectionName string) (connectionType string, err error) + type ConnectionLoader interface + LoadConnection func(connectionName string) (shared.ConnectionDetails, error) + type ConnectionObject struct + ConnectionObject string + func (c *ConnectionObject) GetConnectionName() string + func (c *ConnectionObject) GetObject() string + type ConnectionTypesFilter func(subcommand, subCommandFilter, srcType, srcTypePrefix string) (retval bool) + type ConnectionValidator interface + GetMap func(m map[string]string) map[string]string + GetScheme func() (string, error) + Parse func() error + type CpConfig struct + AppendTarget bool + BucketName string + BucketPrefix string + BucketRegion string + CommitBatchSize string + CsvFileNamePrefix string + CsvHeaderFields string + CsvMaxFileBytes string + CsvMaxFileRows string + CsvRegexp string + ExecBatchSize string + ExecuteDDL bool + ExportConfigType string + ExportIncludeConnections bool + LogLevel string + RepeatInterval int + SQLBatchDriverField string + SQLBatchSize string + SQLBatchSizeSeconds string + SQLBatchStartDateTime string + SQLBatchStartSequence int + SQLPrimaryKeyFieldsCsv string + SnowStageName string + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + type CreateStageConfig struct + Connections ConnectionHandler + ExecuteDDL bool + LogLevel string + S3Key string + S3Secret string + S3Url string + SourceString ConnectionObject + StackDumpOnPanic bool + StageName string + TgtConnDetails *shared.ConnectionDetails + type DefaultAddConfig struct + ConfigFile *config.File + Force bool + Key string + Value string + type DefaultRemoveConfig struct + ConfigFile *config.File + Key string + type DemoCleanupConfig struct + ExecuteDDL bool + LogLevel string + OraConnDetails *shared.DsnConnectionDetails + OraSchemaTable rdbms.SchemaTable + SnowConnDetails *shared.DsnConnectionDetails + SnowStageName string + SourceString ConnectionObject + SrcConnDetails *shared.ConnectionDetails + StackDumpOnPanic bool + TargetString ConnectionObject + TgtConnDetails *shared.ConnectionDetails + type DemoSetupConfig struct + ExecuteDDL bool + LogLevel string + OraConnDetails *shared.DsnConnectionDetails + OraSchemaTable rdbms.SchemaTable + SnowConnDetails *shared.DsnConnectionDetails + SnowS3Key string + SnowS3Secret string + SnowS3Url string + SnowStageName string + SourceString ConnectionObject + SrcConnDetails *shared.ConnectionDetails + StackDumpOnPanic bool + TargetString ConnectionObject + TgtConnDetails *shared.ConnectionDetails + type DiffConfig struct + AbortAfterNumRecords int + ExportConfigType string + ExportIncludeConnections bool + LogLevel string + OutputAllDiffFields bool + RepeatInterval int + SQLPrimaryKeyFieldsCsv string + SrcConnDetails *shared.ConnectionDetails + SrcSchemaTable rdbms.SchemaTable + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + TgtConnDetails *shared.ConnectionDetails + TgtSchemaTable rdbms.SchemaTable + type DsnS3DeltaConfig struct + CsvFileNamePrefix string + CsvHeaderFields string + CsvMaxFileBytes string + CsvMaxFileRows string + ExportConfigType string + ExportIncludeConnections bool + LogLevel string + RepeatInterval int + SQLBatchDriverField string + SQLBatchSize string + SQLBatchSizeSeconds string + SQLBatchStartDateTime string + SQLBatchStartSequence string + SourceConnection string + SrcConnDetails *shared.ConnectionDetails + SrcDsnSchemaTable rdbms.SchemaTable + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + TargetConnection string + TgtConnDetails *shared.ConnectionDetails + type DsnS3SnapConfig struct + CsvFileNamePrefix string + CsvHeaderFields string + CsvMaxFileBytes string + CsvMaxFileRows string + ExportConfigType string + ExportIncludeConnections bool + LogLevel string + RepeatInterval int + SourceConnection string + SrcConnDetails *shared.ConnectionDetails + SrcSchemaTable rdbms.SchemaTable + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + TargetConnection string + TgtConnDetails *shared.ConnectionDetails + type DsnSnapConfig struct + AppendTarget bool + CommitBatchSize string + ExportConfigType string + ExportIncludeConnections bool + LogLevel string + RepeatInterval int + SourceConnection string + SrcConnDetails *shared.ConnectionDetails + SrcSchemaTable rdbms.SchemaTable + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + TargetConnection string + TgtConnDetails *shared.ConnectionDetails + TgtSchemaTable rdbms.SchemaTable + type DsnSnowflakeDeltaConfig struct + BucketName string + BucketPrefix string + BucketRegion string + CsvFileNamePrefix string + CsvHeaderFields string + CsvMaxFileBytes string + CsvMaxFileRows string + DsnSchemaTable rdbms.SchemaTable + ExportConfigType string + ExportIncludeConnections bool + LogLevel string + RepeatInterval int + SQLBatchDriverField string + SQLBatchSize string + SQLBatchSizeSeconds string + SQLBatchStartDateTime string + SQLBatchStartSequence string + SQLPrimaryKeyFieldsCsv string + SnowStageName string + SnowTableName string + SourceConnection string + SrcConnDetails *shared.ConnectionDetails + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + TargetConnection string + TgtConnDetails *shared.ConnectionDetails + type DsnSnowflakeSnapConfig struct + AppendTarget bool + BucketName string + BucketPrefix string + BucketRegion string + CsvFileNamePrefix string + CsvHeaderFields string + CsvMaxFileBytes string + CsvMaxFileRows string + DsnSchemaTable rdbms.SchemaTable + ExportConfigType string + ExportIncludeConnections bool + LogLevel string + RepeatInterval int + SnowStageName string + SnowTableName string + SourceConnection string + SrcConnDetails *shared.ConnectionDetails + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + TargetConnection string + TgtConnDetails *shared.ConnectionDetails + type OraOraDeltaConfig struct + CommitBatchSize string + ExecBatchSize string + ExportConfigType string + ExportIncludeConnections bool + LogLevel string + RepeatInterval int + SQLBatchDriverField string + SQLBatchStartDateTime string + SQLBatchStartSequence string + SQLPrimaryKeyFieldsCsv string + SourceConnection string + SrcConnDetails *shared.ConnectionDetails + SrcOraSchemaTable rdbms.SchemaTable + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + TargetConnection string + TgtConnDetails *shared.ConnectionDetails + TgtOraSchemaTable rdbms.SchemaTable + type OraOraSnapConfig struct + AppendTarget bool + CommitBatchSize string + ExportConfigType string + ExportIncludeConnections bool + LogLevel string + RepeatInterval int + SourceConnection string + SrcConnDetails *shared.ConnectionDetails + SrcOraSchemaTable rdbms.SchemaTable + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + TargetConnection string + TgtConnDetails *shared.ConnectionDetails + TgtOraSchemaTable rdbms.SchemaTable + type OraS3DeltaConfig struct + CsvFileNamePrefix string + CsvHeaderFields string + CsvMaxFileBytes string + CsvMaxFileRows string + ExportConfigType string + ExportIncludeConnections bool + LogLevel string + RepeatInterval int + SQLBatchDriverField string + SQLBatchSize string + SQLBatchSizeSeconds string + SQLBatchStartDateTime string + SQLBatchStartSequence string + SourceConnection string + SrcConnDetails *shared.ConnectionDetails + SrcOraSchemaTable rdbms.SchemaTable + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + TargetConnection string + TgtConnDetails *shared.ConnectionDetails + type OraS3SnapConfig struct + CsvFileNamePrefix string + CsvHeaderFields string + CsvMaxFileBytes string + CsvMaxFileRows string + ExportConfigType string + ExportIncludeConnections bool + LogLevel string + RepeatInterval int + SourceConnection string + SrcConnDetails *shared.ConnectionDetails + SrcOraSchemaTable rdbms.SchemaTable + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + TargetConnection string + TgtConnDetails *shared.ConnectionDetails + type OraSchemaTrigger struct + SchemaTrigger string + type OraSnowflakeDeltaConfig struct + BucketName string + BucketPrefix string + BucketRegion string + CsvFileNamePrefix string + CsvHeaderFields string + CsvMaxFileBytes string + CsvMaxFileRows string + ExportConfigType string + ExportIncludeConnections bool + LogLevel string + OraSchemaTable rdbms.SchemaTable + RepeatInterval int + SQLBatchDriverField string + SQLBatchSize string + SQLBatchSizeSeconds string + SQLBatchStartDateTime string + SQLBatchStartSequence string + SQLPrimaryKeyFieldsCsv string + SnowStageName string + SnowTableName string + SourceConnection string + SrcConnDetails *shared.ConnectionDetails + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + TargetConnection string + TgtConnDetails *shared.ConnectionDetails + type OraSnowflakeSnapConfig struct + AppendTarget bool + BucketName string + BucketPrefix string + BucketRegion string + CsvFileNamePrefix string + CsvHeaderFields string + CsvMaxFileBytes string + CsvMaxFileRows string + ExportConfigType string + ExportIncludeConnections bool + LogLevel string + OraSchemaTable rdbms.SchemaTable + RepeatInterval int + SnowStageName string + SnowTableName string + SourceConnection string + SrcConnDetails *shared.ConnectionDetails + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + TargetConnection string + TgtConnDetails *shared.ConnectionDetails + type PipeConfig struct + Connections ConnectionLoader + LogLevel string + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + TransformFile string + WithWebService bool + type QueryConfig struct + Connections ConnectionLoader + DryRun bool + LogLevel string + PrintHeader bool + Query string + SourceString ConnectionObject + StackDumpOnPanic bool + type ResponseSimple struct + ServerStatus WebServerResponse + type ResponseTransformLaunch struct + Message string + Status WebServerResponse + TransformId string + type ResponseTransformList struct + Status WebServerResponse + TransformList []TransformListItem + type ResponseTransformStats struct + Message string + StatsSummary interface{} + Status WebServerResponse + type ResponseTransformStatus struct + Message string + Status WebServerResponse + TransformStatus transform.TransformStatus + type ResponseTransformStop struct + Message string + Status WebServerResponse + TransformId string + type S3SnowflakeDeltaConfig struct + BucketName string + BucketPrefix string + BucketRegion string + CsvFileNamePrefix string + CsvRegexp string + ExportConfigType string + ExportIncludeConnections bool + LogLevel string + RepeatInterval int + SQLBatchDriverField string + SQLBatchStartDateTime string + SQLBatchStartSequence string + SQLPrimaryKeyFieldsCsv string + SnowStageName string + SnowTableName string + SourceConnection string + SrcConnDetails *shared.ConnectionDetails + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + TargetConnection string + TgtConnDetails *shared.ConnectionDetails + type S3SnowflakeSnapConfig struct + AppendTarget bool + BucketName string + BucketPrefix string + BucketRegion string + CsvFileNamePrefix string + CsvRegexp string + ExportConfigType string + ExportIncludeConnections bool + LogLevel string + RepeatInterval int + SnowStageName string + SnowTableName string + SourceConnection string + SrcConnDetails *shared.ConnectionDetails + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + TargetConnection string + TgtConnDetails *shared.ConnectionDetails + type S3StdoutSnapConfig struct + BucketName string + BucketPrefix string + BucketRegion string + CsvFileNamePrefix string + CsvRegexp string + LogLevel string + SourceConnection string + SrcConnDetails *shared.ConnectionDetails + StackDumpOnPanic bool + type SrcAndTgtConnections struct + Connections ConnectionHandler + SourceString ConnectionObject + TargetString ConnectionObject + type StageDDLConfig struct + LogLevel string + type SyncConfig struct + BucketName string + BucketPrefix string + BucketRegion string + CommitBatchSize int + CsvFileNamePrefix string + CsvHeaderFields string + CsvMaxFileBytes int + CsvMaxFileRows int + ExportConfigType string + ExportIncludeConnections bool + LogLevel string + RepeatInterval int + SQLPrimaryKeyFieldsCsv string + SQLTargetTableOriginRowIdFieldName string + SnowStageName string + SnowTableName string + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + TxtBatchNumRows int + type SyncCqnOracleConfig struct + CommitBatchSize int + ExportConfigType string + ExportIncludeConnections bool + LogLevel string + RepeatInterval int + SQLPrimaryKeyFieldsCsv string + SQLTargetTableOriginRowIdFieldName string + SourceConnection string + SrcConnDetails *shared.ConnectionDetails + SrcOraSchemaTable rdbms.SchemaTable + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + TargetConnection string + TgtConnDetails *shared.ConnectionDetails + TgtOraSchemaTable rdbms.SchemaTable + type SyncCqnSnowflakeConfig struct + BucketName string + BucketPrefix string + BucketRegion string + CsvFileNamePrefix string + CsvHeaderFields string + CsvMaxFileBytes int + CsvMaxFileRows int + ExportConfigType string + ExportIncludeConnections bool + LogLevel string + RepeatInterval int + SQLPrimaryKeyFieldsCsv string + SQLTargetTableOriginRowIdFieldName string + SnowStageName string + SourceConnection string + SrcConnDetails *shared.ConnectionDetails + SrcOraSchemaTable rdbms.SchemaTable + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + TargetConnection string + TgtConnDetails *shared.ConnectionDetails + TgtSnowSchemaTable rdbms.SchemaTable + type SyncOracleOracleConfig struct + CommitBatchSize int + ExportConfigType string + ExportIncludeConnections bool + LogLevel string + RepeatInterval int + SQLPrimaryKeyFieldsCsv string + SrcConnDetails *shared.ConnectionDetails + SrcSchemaTable rdbms.SchemaTable + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + TgtConnDetails *shared.ConnectionDetails + TgtSchemaTable rdbms.SchemaTable + type SyncOracleSnowflakeConfig struct + BucketName string + BucketPrefix string + BucketRegion string + CsvFileNamePrefix string + CsvMaxFileBytes int + CsvMaxFileRows int + ExportConfigType string + ExportIncludeConnections bool + LogLevel string + RepeatInterval int + SQLPrimaryKeyFieldsCsv string + SnowStageName string + SourceConnection string + SrcConnDetails *shared.ConnectionDetails + SrcOraSchemaTable rdbms.SchemaTable + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + TargetConnection string + TgtConnDetails *shared.ConnectionDetails + TgtSnowSchemaTable rdbms.SchemaTable + type TableToSnowTableDDLConfig struct + ExecuteDDL bool + LogLevel string + SnowSchemaTable rdbms.SchemaTable + SrcConnDetails *shared.ConnectionDetails + SrcSchemaTable rdbms.SchemaTable + StackDumpOnPanic bool + TgtConnDetails *shared.ConnectionDetails + type TransformListItem struct + TransformDescription string + TransformId string + TransformStatus transform.Status + type TriggerDDLConfig struct + DateColumnName string + LogLevel string + SchemaTable rdbms.SchemaTable + SchemaTrigger OraSchemaTrigger + type WebServerConfig struct + Addr net.IP + Connections ConnectionLoader + LogLevel string + Port int + Scheme string + StackDumpOnPanic bool + StatsDumpFrequencySeconds int + type WebServerResponse uint32 + const Error + const Okay + func (w WebServerResponse) MarshalJSON() ([]byte, error)
Go to main page