flow

package module

Go to main page

Versions in this module

v1

v1.2.18

Aug 30, 2026

v1.2.17

Aug 30, 2026

v1.2.16

Aug 30, 2026

Changes in this version

+ type PipelineConfig struct

+ Databases []DatabaseConfig

+ FlowNodes []PipelineNode

+ PreflightNodes []PipelineNode

+ Variables []VariableConfig

v1.2.15

Aug 28, 2026

Changes in this version

+ type AssertElement struct

+ Equals string

+ FailVal string

+ FailVar string

+ FailureNodes []PipelineNode

+ ID string

+ Message string

+ OnFailure string

+ Operator string

+ Value string

+ Var string

type NodeKind

+ const NodeAssert

type PipelineNode

+ Assert *AssertElement

v1.2.14

Aug 26, 2026

Changes in this version

type NodeKind

+ const NodeSQL

+ const NodeSQLBulk

v1.2.13

Aug 26, 2026

Changes in this version

+ type ExcelReadElement struct

+ File string

+ Header *bool

+ ID string

+ OutputVar string

+ Sheet string

+ Var string

+ func (e *ExcelReadElement) GetOutputVar() string

+ type ExcelWriteElement struct

+ DBName string

+ File string

+ ID string

+ Query string

+ Sheet string

+ Var string

+ type FileReadElement struct

+ File string

+ Filename string

+ ID string

+ OutVar string

+ OutputVar string

+ OutputVariable string

+ Path string

+ Var string

+ Variable string

+ func (f *FileReadElement) GetFilePath() string

+ func (f *FileReadElement) GetOutputVar() string

+ type FileSaveElement struct

+ Append *bool

+ Content string

+ File string

+ Filename string

+ ID string

+ Path string

+ Var string

+ Variable string

+ func (f *FileSaveElement) GetFilePath() string

+ func (f *FileSaveElement) GetInputVar() string

+ type JsonPathElement struct

+ Content string

+ File string

+ ID string

+ JSONPath string

+ Mode string

+ OutVar string

+ OutputVar string

+ Path string

+ Var string

+ func (j *JsonPathElement) GetJSONPath() string

+ func (j *JsonPathElement) GetOutputVar() string

type NodeKind

+ const NodeExcelRead

+ const NodeExcelWrite

+ const NodeFileRead

+ const NodeFileSave

+ const NodeJSONPath

+ const NodeTemplate

+ const NodeXMLXPath

+ const NodeYAMLPath

type PipelineNode

+ ExcelRead *ExcelReadElement

+ ExcelWrite *ExcelWriteElement

+ FileRead *FileReadElement

+ FileSave *FileSaveElement

+ JsonPath *JsonPathElement

+ Template *TemplateElement

+ XmlXPath *XmlXPathElement

+ YamlPath *YamlPathElement

+ type TemplateElement struct

+ Content string

+ Engine string

+ File string

+ ID string

+ Name string

+ OutputVar string

+ Var string

+ func (t *TemplateElement) GetOutputVar() string

+ type XmlXPathElement struct

+ Content string

+ File string

+ ID string

+ Mode string

+ OutputVar string

+ Var string

+ XPath string

+ func (x *XmlXPathElement) GetXPath() string

+ type YamlPathElement struct

+ Content string

+ File string

+ ID string

+ Mode string

+ OutVar string

+ OutputVar string

+ Path string

+ Var string

+ YAMLPath string

+ func (y *YamlPathElement) GetOutputVar() string

+ func (y *YamlPathElement) GetYAMLPath() string

v1.2.12

Aug 24, 2026

v1.2.11

Aug 24, 2026

Changes in this version

+ func BuildClientAndRequest(elem HTTPClientElement) (*http.Client, *http.Request, error)

+ type HTTPClientElement struct

+ BodyContent string

+ ContentType string

+ CookieJar *bool

+ Data string

+ DisableCompression *bool

+ DisableKeepAlives *bool

+ ExpectContinueTimeout string

+ FollowRedirects *bool

+ ForceAttemptHTTP2 *bool

+ Headers string

+ ID string

+ IdleConnTimeout string

+ MaxConnsPerHost *int

+ MaxIdleConns *int

+ MaxIdleConnsPerHost *int

+ MaxRedirects *int

+ MaxResponseHeaderBytes *int64

+ Method string

+ OutVar string

+ OutputVar string

+ OutputVariable string

+ Proxy string

+ ReadBufferSize *int

+ ResponseHeaderTimeout string

+ StatusCodeVar string

+ StatusCodeVariable string

+ StatusVar string

+ StatusVariable string

+ TLSHandshakeTimeout string

+ TLSInsecureSkipVerify *bool

+ TLSMaxVersion string

+ TLSMinVersion string

+ TLSServerName string

+ Timeout string

+ URI string

+ URL string

+ Var string

+ Variable string

+ WriteBufferSize *int

+ XMLName xml.Name

+ func (e *HTTPClientElement) GetOutputVariable() string

+ func (e *HTTPClientElement) GetStatusCodeVariable() string

type NodeKind

+ const NodeHTTPClient

type PipelineNode

+ HTTPClient *HTTPClientElement

v1.2.10

Aug 23, 2026

v1.2.9

Aug 23, 2026

v1.2.8

Aug 22, 2026

Changes in this version

type Registry

+ func (r *Registry) GetVarTime(name string) time.Time

+ func (r *Registry) MergeVariables(src map[string]interface{})

v1.2.7

Aug 21, 2026

v1.2.6

Aug 20, 2026

v1.2.5

Aug 20, 2026

v1.2.4

Aug 19, 2026

Changes in this version

type Executor

+ func (e *Executor) SetInterpHook(hook func(*interp.Options))

v1.2.3

Aug 17, 2026

Changes in this version

type PipelineNode

+ DBName string

+ Transaction bool

v1.2.2

Aug 17, 2026

Changes in this version

type Registry

+ func (r *Registry) Snapshot() *Registry

v1.2.1

Aug 16, 2026

Changes in this version

type Executor

+ func (e *Executor) SetGoPath(goPath string)

v1.2.0

Aug 12, 2026

Changes in this version

+ type ETLOptions struct

+ BatchSize int

+ CheckConstraints bool

+ FireTriggers bool

+ KeepNulls bool

+ Tablock bool

type ScriptItem

+ CheckConstraints bool

+ FireTriggers bool

+ KeepNulls bool

+ Tablock bool

v1.1.0

Aug 12, 2026

Changes in this version

+ func GetSchemaXSD() []byte

type Executor

+ func (e *Executor) SetVerbose(verbose bool)

v1.0.1

Aug 10, 2026

Changes in this version

+ func ParseXMLConfig(xmlData []byte) ([]VariableConfig, []DatabaseConfig, []PipelineNode, error)

+ func StreamETL(r *Registry, srcDBName, queryStr, dstDBName, targetTable string, batchSize int) (int64, error)

+ func ValidateAST(nodes []PipelineNode, registeredDBs []DatabaseConfig) error

+ func ValidateXSD(xmlPath string, xsdPath string) error

+ type DBHandle struct

+ Conn *sql.DB

+ Driver string

+ type DatabaseConfig struct

+ ConnectionString string

+ Driver string

+ Name string

+ type Executor struct

+ func NewExecutor(r *Registry) *Executor

+ func (e *Executor) Execute(nodes []PipelineNode) ([]ScriptResult, error)

+ type NodeKind int

+ const NodeForEach

+ const NodeGroup

+ const NodeIf

+ const NodeParallel

+ const NodeScript

+ const NodeWhile

+ type PipelineNode struct

+ Children []PipelineNode

+ ElseNodes []PipelineNode

+ ForEachScript *ScriptItem

+ GroupID string

+ IfEquals string

+ IfVar string

+ Kind NodeKind

+ MaxIterations int

+ MaxThreads int

+ Script *ScriptItem

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) CloseDatabases()

+ func (r *Registry) CopyVariables() map[string]interface{}

+ func (r *Registry) GetDB(name string) (*sql.DB, error)

+ func (r *Registry) GetDBHandle(name string) (DBHandle, error)

+ func (r *Registry) GetVar(name string) interface{}

+ func (r *Registry) GetVarBool(name string) bool

+ func (r *Registry) GetVarFloat(name string) float64

+ func (r *Registry) GetVarInt(name string) int

+ func (r *Registry) GetVarString(name string) string

+ func (r *Registry) InitDatabases(configs []DatabaseConfig) error

+ func (r *Registry) InitVariables(configs []VariableConfig) error

+ func (r *Registry) SetVar(name string, value interface{})

+ type ScriptItem struct

+ BatchSize int

+ Code string

+ DBName string

+ ID string

+ Language string

+ OutputVar string

+ TargetDB string

+ TargetTable string

+ VarName string

+ type ScriptResult struct

+ Duration string

+ ResultsString string

+ ReturnCode any

+ ScriptID string

+ type VariableConfig struct

+ Name string

+ Type string

+ Value string

v1.0.0

Aug 10, 2026

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL