sling

Feb 1, 2025

Changes in this version

+ var HookRunReplication func(string, *Config, ...string) error

type Hook

+ Data func() map[string]any

+ SetExtra func(map[string]any)

+ type HookKind string

+ const HookKindHook

+ const HookKindStep

+ type OnFailType string

+ type Pipeline struct

+ Env map[string]any

+ Steps Hooks

+ func LoadPipelineConfig(content string) (pipeline *Pipeline, err error)

+ func LoadPipelineConfigFromFile(cfgPath string) (pipeline *Pipeline, err error)

+ func (pl *Pipeline) Execute() (err error)

+ func (pl *Pipeline) RuntimeState() (_ *PipelineState, err error)

+ type PipelineState struct

+ Env map[string]any

+ Run *RunState

+ Runs map[string]*RunState

+ State map[string]map[string]any

+ Timestamp DateTimeState

+ func (ps *PipelineState) Marshall() string

+ func (ps *PipelineState) SetStateData(id string, data map[string]any)

+ func (ps *PipelineState) SetStateKeyValue(id, key string, value any)

+ func (ps *PipelineState) TaskExecution() *TaskExecution

+ type PipelineStep struct

+ type PipelineSteps []PipelineStep

type ReplicationConfig

+ func (rd *ReplicationConfig) ProcessChunks() (err error)

+ type ReplicationState struct

+ Env map[string]any

+ Execution ExecutionState

+ Object *ObjectState

+ Run *RunState

+ Runs map[string]*RunState

+ Source ConnState

+ State map[string]map[string]any

+ Stream *StreamState

+ Target ConnState

+ Timestamp DateTimeState

+ func (rs *ReplicationState) Marshall() string

+ func (rs *ReplicationState) SetStateData(id string, data map[string]any)

+ func (rs *ReplicationState) SetStateKeyValue(id, key string, value any)

+ func (rs *ReplicationState) TaskExecution() *TaskExecution

type RuntimeState

+ Marshall func() string

+ SetStateData func(id string, data map[string]any)

+ SetStateKeyValue func(id, key string, value any)

+ TaskExecution func() *TaskExecution

type SourceOptions

+ ChunkSize any

+ func (so *SourceOptions) RangeStartEnd() (start, end string)

type StreamState

+ SchemaLower string

+ SchemaUpper string

+ TableLower string

+ TableUpper string

Jan 22, 2025

Changes in this version

type Config

+ func (cfg *Config) IsFileStreamWithStateAndParts() bool

+ type ExecutionState struct

+ Duration int64

+ EndTime *time.Time

+ Error *string

+ FilePath string

+ ID string

+ StartTime *time.Time

+ Status StatusMap

+ TotalBytes uint64

+ TotalRows uint64

type ReplicationConfig

+ Hooks HookMap

+ func (rd *ReplicationConfig) ParseReplicationHook(stage HookStage) (hooks Hooks, err error)

type ReplicationStreamConfig

+ ID string

type RunState

+ Duration int64

+ ID string

+ TotalRows uint64

type RuntimeState

+ Env map[string]any

+ Execution ExecutionState

+ type StatusMap struct

+ Cancelled int

+ Count int

+ Error int

+ Running int

+ Skipped int

+ Success int

+ Warning int

Jan 15, 2025

Changes in this version

+ func StateSet(t *TaskExecution)

+ type ConnState struct

+ Account string

+ Bucket string

+ Container string

+ Database string

+ Host string

+ Instance string

+ Kind dbio.Kind

+ Name string

+ Schema string

+ Type dbio.Type

+ User string

+ type DateTimeState struct

+ DD string

+ DDD string

+ Date string

+ Datetime string

+ FileName string

+ HH string

+ MM string

+ MMM string

+ Rfc3339 string

+ Timestamp time.Time

+ Unix int64

+ YY string

+ YYYY string

+ func (dts *DateTimeState) Update()

type Hook

+ Stage func() HookStage

+ type HookMap struct

+ End []any

+ Post []any

+ Pre []any

+ Start []any

+ type HookStage string

+ const HookStageEnd

+ const HookStagePost

+ const HookStagePre

+ const HookStageStart

type Hooks

+ func (hs Hooks) Execute() (err error)

+ type ObjectState struct

+ FullName string

+ Name string

+ Schema string

+ Table string

+ type ParseOptions struct

type ReplicationConfig

+ func (rd *ReplicationConfig) ParseDefaultHook(stage HookStage) (hooks Hooks, err error)

+ func (rd *ReplicationConfig) ParseStreamHook(stage HookStage, rs *ReplicationStreamConfig) (hooks Hooks, err error)

+ func (rd *ReplicationConfig) RuntimeState() (_ *RuntimeState, err error)

type ReplicationStreamConfig

+ Where string

+ type RunState struct

+ Config ReplicationStreamConfig

+ EndTime *time.Time

+ Error *string

+ Object *ObjectState

+ RowCount uint64

+ StartTime *time.Time

+ Status ExecStatus

+ Stream *StreamState

+ Task *TaskExecution

+ TotalBytes uint64

+ type RuntimeState struct

+ Hooks map[string]map[string]any

+ Object *ObjectState

+ Run *RunState

+ Runs map[string]*RunState

+ Source ConnState

+ Stream *StreamState

+ Target ConnState

+ Timestamp DateTimeState

type Source

+ Where string

+ type StreamState struct

+ FileExt string

+ FileFolder string

+ FileName string

+ FilePath string

+ FullName string

+ Name string

+ Schema string

+ Table string

Dec 27, 2024

Changes in this version

+ var StoreSet = func(t *TaskExecution) error

type Config

+ IncrementalGTE bool

type ReplicationConfig

+ FailErr string

type ReplicationStreamConfig

+ func (s *ReplicationStreamConfig) ObjectHasStreamVars() bool

type TargetOptions

+ DeleteMissing *string

type TaskExecution

+ func (t *TaskExecution) GetSourceTable() (sTable database.Table, err error)

+ func (t *TaskExecution) GetTargetTable(tempTableSuffix ...string) (tTable database.Table, err error)

Dec 1, 2024

Changes in this version

type Hooks

+ func (hks Hooks) Parse(stage string, te *TaskExecution) (hooks []Hook, err error)

type ReplicationStreamConfig

+ PostHooks Hooks

+ PreHooks Hooks

type Target

+ func (t *Target) ObjectFileFormat() dbio.FileType

Nov 24, 2024

Changes in this version

+ var ParseHook = func(any, *TaskExecution, string) (Hook, error)

type Config

+ MetadataExecID bool

type ExecStatus

+ func (s ExecStatus) IsWarning() bool

+ type Hook interface

+ Execute func(*TaskExecution) error

+ ExecuteOnDone func(error, *TaskExecution) error

+ ID func() string

+ Type func() HookType

+ type HookType string

+ type Hooks struct

+ Post []any

+ Pre []any

+ func (h *Hooks) PostHooks(te *TaskExecution) (hooks []Hook, err error)

+ func (h *Hooks) PreHooks(te *TaskExecution) (hooks []Hook, err error)

type ReplicationStreamConfig

+ Hooks Hooks

type TaskExecution

+ func (t *TaskExecution) ExecuteHooks(stage string) (err error)

+ func (t *TaskExecution) GetStateMap() map[string]any

Oct 21, 2024

Changes in this version

type Config

+ func (cfg *Config) HasIncrementalVal() bool

type ExecStatus

+ const ExecStatusCancelled

type ReplicationConfig

+ Compiled bool

+ Tasks []*Config

type ReplicationStreamConfig

+ Description string

+ Tags []string

type Source

+ Query string

type SourceOptions

+ FileSelect *[]string

+ ParallelChunks *int

+ Quote string

Sep 22, 2024

Changes in this version

type ConfigOptions

+ Dataset bool

type Source

+ SQL string

type TaskExecution

+ func (t *TaskExecution) Data() *iop.Dataset

+ type Wildcard struct

+ NodeMap map[string]filesys.FileNode

+ Pattern string

+ StreamNames []string

+ TableMap map[string]database.Table

+ type Wildcards []*Wildcard

+ func (ws Wildcards) Patterns() []string

Aug 27, 2024

Changes in this version

type Config

+ func (cfg *Config) ColumnsPrepared() (columns iop.Columns)

+ func (cfg *Config) TransformsPrepared() (colTransforms map[string][]string)

type ExecStatus

+ const ExecStatusWarning

Aug 14, 2024

Changes in this version

type Config

+ Transforms any

+ func (cfg *Config) SrcConnMD5() string

+ func (cfg *Config) StreamID() string

+ func (cfg *Config) TgtConnMD5() string

type ReplicationStreamConfig

+ Transforms any

type TaskExecution

+ OutputLines chan *g.LogLine

Jul 25, 2024

Changes in this version

+ func IsJSONorYAML(payload string) bool

type ReplicationConfig

+ func (rd *ReplicationConfig) JSON() string

type Source

+ func (s *Source) Offset() int

type SourceOptions

+ Offset *int

Jun 29, 2024

Changes in this version

+ func ParseMsUUID(sp *iop.StreamProcessor, val string) (string, error)

Jun 4, 2024

Changes in this version

type ReplicationStreamConfig

+ Single *bool

type TargetOptions

+ BatchLimit *int64

May 18, 2024

Changes in this version

+ var AllColumnCasing = []struct{ ... }

+ var AllMode = []struct{ ... }

type Config

+ IncrementalValStr string

+ ReplicationStream *ReplicationStreamConfig

+ func (cfg *Config) IgnoreExisting() bool

type ReplicationConfig

+ func LoadReplicationConfigFromFile(cfgPath string) (config ReplicationConfig, err error)

type Source

+ Type dbio.Type

type Target

+ Type dbio.Type

type TargetOptions

+ IgnoreExisting *bool

Apr 28, 2024

Changes in this version

+ var AllExecStatus = []struct{ ... }

+ var AllJobType = []struct{ ... }

type TaskExecution

+ func (t *TaskExecution) Df() *iop.Dataflow

Apr 13, 2024

Changes in this version

type SourceOptions

+ Escape string

Mar 31, 2024

Changes in this version

type ReplicationConfig

+ func (rd *ReplicationConfig) Compile(cfgOverwrite *Config, selectStreams ...string) (tasks []Config, err error)

type ReplicationStreamConfig

+ State *StreamIncrementalState

+ type StreamIncrementalState struct

+ Files map[string]int64

+ Value int64

Mar 23, 2024

Changes in this version

type JobType

+ const ConnDiscover

+ const ConnExec

type ReplicationConfig

+ func (rd *ReplicationConfig) AddStream(key string, cfg ReplicationStreamConfig)

+ func (rd *ReplicationConfig) DeleteStream(key string)

+ func (rd ReplicationConfig) GetStream(name string) (streamName string, cfg ReplicationStreamConfig, found bool)

+ func (rd ReplicationConfig) MatchStreams(pattern string) (streams map[string]ReplicationStreamConfig)

Mar 14, 2024

Changes in this version

+ func GetSQLText(sqlStringPath string) (string, error)

+ func SHA256(val string) string

+ func SHA512(val string) string

type Config

+ func (cfg *Config) AsReplication() (rc ReplicationConfig)

+ func (cfg *Config) HasWildcard() bool

type ReplicationConfig

+ func (rd ReplicationConfig) Normalize(n string) string

Mar 7, 2024

Changes in this version

+ func NewExecID() string

+ func ParseFIX(sp *iop.StreamProcessor, message string) (string, error)

type SourceOptions

+ FieldsPerRec *int

Feb 26, 2024

Changes in this version

type TaskExecution

+ func (t *TaskExecution) AddCleanupTaskFirst(f func())

+ func (t *TaskExecution) AddCleanupTaskLast(f func())

Feb 19, 2024

Changes in this version

type Config

+ func (cfg *Config) MD5() string

type ReplicationConfig

+ func (rd *ReplicationConfig) MD5() string

type Source

+ func (s *Source) MD5() string

type Target

+ func (t *Target) MD5() string

type TaskExecution

+ Output string

+ func (t *TaskExecution) AppendOutput(text string)

Feb 11, 2024

Changes in this version

type Config

+ MetadataRowID bool

+ MetadataRowNum bool

type TargetOptions

+ TableKeys database.TableKeys

Jan 27, 2024

Changes in this version

type Config

+ StreamName string

Jan 19, 2024

Changes in this version

+ func Replace0x00(sp *iop.StreamProcessor, val string) (string, error)

+ func ReplaceNonPrint(sp *iop.StreamProcessor, val string) (string, error)

Jan 10, 2024

Changes in this version

+ func ParseBit(sp *iop.StreamProcessor, val string) (string, error)

type ReplicationConfig

+ func (rd *ReplicationConfig) ProcessWildcardsDatabase(c connection.ConnEntry, wildcardNames []string) (err error)

+ func (rd *ReplicationConfig) ProcessWildcardsFile(c connection.ConnEntry, wildcardNames []string) (err error)

Dec 28, 2023

Changes in this version

type Mode

+ const BackfillMode

Dec 4, 2023

Changes in this version

+ var StoreInsert func(t *TaskExecution)

+ var StoreUpdate func(t *TaskExecution)

type ReplicationConfig

+ func (rd *ReplicationConfig) OriginalCfg() string

+ func (rd ReplicationConfig) HasStream(name string) bool

type ReplicationStreamConfig

+ Select []string

type Source

+ Select []string

type TaskExecution

+ Replication *ReplicationConfig

Nov 27, 2023

Changes in this version

+ func ErrorHelper(err error) (helpString string)

Oct 28, 2023

Changes in this version

+ type ColumnCasing string

+ const SnakeColumnCasing

+ const SourceColumnCasing

+ const TargetColumnCasing

type Source

+ func (s *Source) HasPrimaryKey() bool

+ func (s *Source) HasUpdateKey() bool

type SourceOptions

+ Limit *int

type TargetOptions

+ ColumnCasing *ColumnCasing

Sep 26, 2023

Changes in this version

type ReplicationStreamConfig

+ PrimaryKeyI any

type Source

+ PrimaryKeyI any

Sep 26, 2023

Changes in this version

+ func Decode(sp *iop.StreamProcessor, decoder *encoding.Decoder, val string) (string, error)

+ func ParseUUID(sp *iop.StreamProcessor, val string) (string, error)

type Config

+ func (cfg *Config) GetFormatMap() (m map[string]any, err error)

type SourceOptions

+ func (o *SourceOptions) SetDefaults(sourceOptions SourceOptions)

type TargetOptions

+ func (o *TargetOptions) SetDefaults(targetOptions TargetOptions)

Sep 2, 2023

Changes in this version

type Config

+ MetadataLoadedAt bool

+ MetadataStreamURL bool

type ReplicationConfig

+ Env map[string]any

Sep 2, 2023

Changes in this version

type SourceOptions

+ Transforms []string

Aug 25, 2023

Changes in this version

type ReplicationConfig

+ func (rd ReplicationConfig) StreamsOrdered() []string

Aug 25, 2023

Changes in this version

type SourceOptions

+ Columns map[string]string

Aug 18, 2023

Changes in this version

type SourceOptions

+ Range *string

+ Sheet *string

Feb 20, 2023

Changes in this version

type SourceOptions

+ JmesPath *string

Feb 19, 2023

Changes in this version

type SourceOptions

+ Format *filesys.FileType

type TargetOptions

+ FileMaxBytes int64

+ Format filesys.FileType

Jan 29, 2023

Changes in this version

type Config

+ ReplicationMode bool

Dec 29, 2022

Changes in this version

type ReplicationConfig

+ func (rd *ReplicationConfig) ProcessWildcards() (err error)

Dec 28, 2022

Changes in this version

type ReplicationConfig

+ func LoadReplicationConfig(cfgPath string) (config ReplicationConfig, err error)

Oct 8, 2022

Changes in this version

type TargetOptions

+ AdjustColumnType *bool

Sep 25, 2022

Changes in this version

+ var MetadataLoadedAt = false

+ var MetadataStreamURL = false

Sep 23, 2022

Changes in this version

type ReplicationConfig

+ func UnmarshalReplication(replicYAML string) (config ReplicationConfig, err error)

type ReplicationStreamConfig

+ Object string

Sep 22, 2022

Changes in this version

+ func SetStreamDefaults(stream *ReplicationStreamConfig, replicationCfg ReplicationConfig)

+ type ReplicationConfig struct

+ Defaults ReplicationStreamConfig

+ Source string

+ Streams map[string]*ReplicationStreamConfig

+ Target string

+ func (rd *ReplicationConfig) Scan(value interface{}) error

+ func (rd ReplicationConfig) Value() (driver.Value, error)

+ type ReplicationStreamConfig struct

+ Columns []string

+ Disabled bool

+ Mode Mode

+ ObjectName string

+ PrimaryKey []string

+ SQL string

+ Schedule *string

+ SourceOptions *SourceOptions

+ TargetOptions *TargetOptions

+ UpdateKey string

Aug 26, 2022

Changes in this version

type SourceOptions

+ Flatten *bool

Aug 24, 2022

Changes in this version

type TaskExecution

+ IsCLI bool

Aug 22, 2022

Changes in this version

type Mode

+ const FullRefreshIncrementalMode

Aug 15, 2022

Changes in this version

type Config

+ func (cfg *Config) FormatTargetObjectName() (err error)

Aug 7, 2022

Changes in this version

+ var AddLoadedAtColumn = true

type TargetOptions

+ AddNewColumns bool

Jul 24, 2022

Changes in this version

+ var SourceAPIOptionsDefault = SourceOptions

+ var SourceDBOptionsDefault = SourceOptions

+ var TargetAPIOptionsDefault = TargetOptions

+ var TargetDBOptionsDefault = TargetOptions

Jun 21, 2022

Changes in this version

+ var SourceFileOptionsDefault = SourceOptions

+ var TargetFileOptionsDefault = TargetOptions

Jun 19, 2022

Changes in this version

type Config

+ func (cfg *Config) DetermineType() (Type JobType, err error)

May 20, 2022

Changes in this version

type TaskExecution

+ Context *g.Context

+ func (t *TaskExecution) AddCleanupTask(f func())

+ func (t *TaskExecution) Cleanup()

May 15, 2022

Changes in this version

type Config

+ IncrementalVal string

+ Mode Mode

type Mode

+ const FullRefreshMode

+ const IncrementalMode

May 13, 2022

Changes in this version

type Source

+ PrimaryKey []string

+ UpdateKey string

Apr 9, 2022

Changes in this version

+ var AllowedProps = map[string]string

+ var PermitTableSchemaOptimization = false

+ var ShowProgress = true

+ func ClientDelete(serverURL string, route RouteName, m map[string]interface{}, ...) (respStr string, err error)

+ func ClientGet(serverURL string, route RouteName, m map[string]interface{}, ...) (respStr string, err error)

+ func ClientGetJStream(serverURL string, route RouteName, m map[string]interface{}, ...) (decoder *json.Decoder, err error)

+ func ClientOptions(serverURL string, route RouteName, m map[string]interface{}, ...) (respStr string, err error)

+ func ClientPatch(serverURL string, route RouteName, m map[string]interface{}, ...) (respStr string, err error)

+ func ClientPost(serverURL string, route RouteName, m map[string]interface{}, ...) (respStr string, err error)

+ func ClientPut(serverURL string, route RouteName, m map[string]interface{}, ...) (respStr string, err error)

+ func GetJWTFromKey(masterServerURL, key string) (string, error)

+ func LoadProject(path string)

+ func Sling(cfg *Config) (err error)

+ type Config struct

+ Env map[string]interface{}

+ Options ConfigOptions

+ Prepared bool

+ Source Source

+ SrcConn connection.Connection

+ Target Target

+ TgtConn connection.Connection

+ UpsertVal string

+ func NewConfig(cfgStr string) (cfg *Config, err error)

+ func (cfg *Config) Marshal() (cfgBytes []byte, err error)

+ func (cfg *Config) Prepare() (err error)

+ func (cfg *Config) Scan(value interface{}) error

+ func (cfg *Config) SetDefault()

+ func (cfg *Config) Unmarshal(cfgStr string) error

+ func (cfg Config) Value() (driver.Value, error)

+ type ConfigOptions struct

+ Debug bool

+ ProxyPIDs *string

+ StdIn bool

+ StdOut bool

+ type ExecStatus string

+ const ExecStatusCreated

+ const ExecStatusError

+ const ExecStatusInterrupted

+ const ExecStatusQueued

+ const ExecStatusRunning

+ const ExecStatusSkipped

+ const ExecStatusStalled

+ const ExecStatusStarted

+ const ExecStatusSuccess

+ const ExecStatusTerminated

+ const ExecStatusTimedOut

+ func (s ExecStatus) IsFailure() bool

+ func (s ExecStatus) IsFinished() bool

+ func (s ExecStatus) IsRunning() bool

+ func (s ExecStatus) IsSuccess() bool

+ type ExecutionStatus struct

+ AvgDuration int

+ Bytes uint64

+ Duration *int

+ ExecID int64

+ JobID int

+ Percent int

+ Rows uint64

+ Stalled bool

+ Status ExecStatus

+ Text string

+ type JobType string

+ const APIToDb

+ const APIToFile

+ const ConnTest

+ const DbSQL

+ const DbToDb

+ const DbToFile

+ const FileToDB

+ const FileToFile

+ type Mode string

+ const AppendMode

+ const DropMode

+ const SnapshotMode

+ const TruncateMode

+ const UpsertMode

+ type NotificationConfig struct

+ Emails []string

+ MsTeams bool

+ Name string

+ OnEmpty bool

+ OnFailure bool

+ OnLinger bool

+ OnSuccess bool

+ Slack bool

+ WebhookURLs []string

+ type ProgressBar struct

+ func NewPBar(d time.Duration) *ProgressBar

+ func (pb *ProgressBar) Finish()

+ func (pb *ProgressBar) SetStatus(status string)

+ func (pb *ProgressBar) Start()

+ type Project struct

+ Config ProjectConfig

+ TaskConfigs map[string]Config

+ type ProjectConfig struct

+ Defaults map[string]interface{}

+ NotificationTags map[string]NotificationConfig

+ Project string

+ TaskPaths []string

+ type RouteName string

+ const RouteAPI

+ const RouteAPIAccounts

+ const RouteAPIConnectionTest

+ const RouteAPIConnections

+ const RouteAPIDataRequest

+ const RouteAPIExecutions

+ const RouteAPIJobs

+ const RouteAPIKey

+ const RouteAPILogs

+ const RouteAPIProjects

+ const RouteAPIResetPassword

+ const RouteAPISettings

+ const RouteAPIUsers

+ const RouteAPIWorkers

+ const RouteAlertLog

+ const RouteAppAPIKey

+ const RouteAppIndex

+ const RouteAppLogin

+ const RouteAppLogout

+ const RouteError

+ const RouteForgotPassword

+ const RouteLogin

+ const RouteLogout

+ const RouteMasterDBReset

+ const RouteMasterStatus

+ const RouteNotice

+ const RouteProxy

+ const RouteResetPassword

+ const RouteSignUpUser

+ const RouteStatus

+ const RouteUploads

+ const RouteUser

+ const RouteWs

+ const RouteWsClient

+ const RouteWsWorker

+ type Source struct

+ Columns iop.Columns

+ Conn string

+ Data map[string]interface{}

+ Limit int

+ Options SourceOptions

+ Stream string

+ type SourceOptions struct

+ Compression iop.CompressorType

+ DatetimeFormat string

+ Delimiter string

+ EmptyAsNull bool

+ Header bool

+ MaxDecimals int

+ NullIf string

+ SkipBlankLines bool

+ TrimSpace bool

+ type Target struct

+ Columns iop.Columns

+ Conn string

+ Data map[string]interface{}

+ Mode Mode

+ Object string

+ Options TargetOptions

+ PrimaryKey []string

+ TmpTableCreated bool

+ UpdateKey string

+ type TargetOptions struct

+ Compression iop.CompressorType

+ Concurrency int

+ DatetimeFormat string

+ Delimiter string

+ FileMaxRows int64

+ Header bool

+ MaxDecimals int

+ PostSQL string

+ PreSQL string

+ TableDDL string

+ TableTmp string

+ UseBulk bool

+ type TaskExecution struct

+ Bytes uint64

+ Config *Config

+ Ctx context.Context

+ EndTime *time.Time

+ Err error

+ ExecID int64

+ PBar *ProgressBar

+ ProcStatsStart g.ProcStats

+ Progress string

+ ProgressHist []string

+ StartTime *time.Time

+ Status ExecStatus

+ Type JobType

+ func NewTask(execID int64, cfg *Config) (t *TaskExecution)

+ func (t *TaskExecution) Execute() error

+ func (t *TaskExecution) GetBytes() (inBytes, outBytes uint64)

+ func (t *TaskExecution) GetBytesString() (s string)

+ func (t *TaskExecution) GetCount() (count uint64)

+ func (t *TaskExecution) GetRate(secWindow int) (rowRate, byteRate int64)

+ func (t *TaskExecution) GetTotalBytes() (rcBytes, txBytes uint64)

+ func (t *TaskExecution) IsStalled(window float64) bool

+ func (t *TaskExecution) ReadFromAPI(cfg *Config) (df *iop.Dataflow, err error)

+ func (t *TaskExecution) ReadFromDB(cfg *Config, srcConn database.Connection) (df *iop.Dataflow, err error)

+ func (t *TaskExecution) ReadFromFile(cfg *Config) (df *iop.Dataflow, err error)

+ func (t *TaskExecution) SetProgress(progressText string, args ...interface{})

+ func (t *TaskExecution) WriteToDb(cfg *Config, df *iop.Dataflow, tgtConn database.Connection) (cnt uint64, err error)

+ func (t *TaskExecution) WriteToFile(cfg *Config, df *iop.Dataflow) (cnt uint64, err error)

+ type TaskProcess struct

+ Cmd *exec.Cmd

+ EndTime time.Time

+ Err error

+ ExecID int64

+ ExitCode int

+ JobID int

+ Pid int

+ RowRate int

+ StartTime time.Time

+ Stderr string

+ StderrBuf bytes.Buffer

+ Stdout string

+ StdoutBuf bytes.Buffer

+ Task *TaskExecution

+ func (tp *TaskProcess) ToMap() map[string]interface{}