Versions in this module Expand all Collapse all v1 v1.3.1 Jul 28, 2020 v1.2.1 Jul 7, 2020 Changes in this version + func RunPipelineStmts(conn db.SQLConnector, stmts ...*PipelineStmt) error + func RunPipelineStmtsWithTransactionx(conn db.SQLConnector, stmts ...*PipelineStmt) error + func RunPipelines(conn db.SQLConnector, pipelines ...Pipeline) error + func RunpipelinesWithTransactionx(conn db.SQLConnector, pipelines ...Pipeline) error + type Pipeline interface + Exec func(conn db.SQLConnector) (sql.Result, error) + type PipelineManager struct + func NewPipelineManager(conn db.SQLConnector) *PipelineManager + func (pm *PipelineManager) AddPipe(p Pipeline) + func (pm *PipelineManager) RunPipelines() error + func (pm *PipelineManager) RunPipelinesWithTransactionx() error + type PipelineStmt struct + func NewPipelineStmt(query string, args ...interface{}) *PipelineStmt + func (ps *PipelineStmt) Exec(conn db.SQLConnector) (sql.Result, error)
Go to main page