Documentation
¶
Index ¶
- func CleanupRunner()
- func ForceCleanup()
- func InitializeFlowpipeDB() error
- func ListExecutionIDs() ([]string, error)
- func OpenFlowpipeDB() (*sql.DB, error)
- func StartPipeline(executionId, pipelineName string) error
- func UpdatePipelineState(executionID, newState string) error
- func UpgradeFlowpipeDB2() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CleanupRunner ¶
func CleanupRunner()
func InitializeFlowpipeDB ¶
func InitializeFlowpipeDB() error
func ListExecutionIDs ¶
func OpenFlowpipeDB ¶
func StartPipeline ¶
func UpdatePipelineState ¶
func UpgradeFlowpipeDB2 ¶ added in v0.7.0
func UpgradeFlowpipeDB2() error
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.