errors

package

v0.5.2 Latest Latest Go to latest Published: Nov 1, 2025 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Pipeline struct {
	// contains filtered or unexported fields
}

Pipeline 使用 errgroup 的链式管道多错误处理

func NewPipeline() *Pipeline

func NewPipelineWithContext(ctx context.Context) *Pipeline

func (p *Pipeline) Context() context.Context

Context 获取上下文

func (p *Pipeline) Execute() error

Execute 顺序执行所有函数（遇到错误立即停止）

func (p *Pipeline) ExecuteParallel() error

ExecuteParallel 并发执行所有函数

func (p *Pipeline) ExecuteParallelWithLimit(limit int) error

ExecuteParallelWithLimit 限制并发数量执行

func (p *Pipeline) Then(fn ...func() error) *Pipeline

Then 添加一个函数到管道中