progress

package

v0.26.0 Latest Latest Go to latest Published: Mar 16, 2026 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

View Source

var ErrPipeline = errors.New("pipeline has encountered an error")

View Source

var ErrPipelineAborted = errors.New("pipeline was aborted")

func EventToPipeline(event *sdk.EventItem, options *Options) (*sdk.WorkflowItem, error)

func Pipeline(pipelineID string, options *Options) error

type Options struct {
	Interval time.Duration
}

func NewOptions() *Options

type PipelineStatus int

const (
	PipelineWorking PipelineStatus = iota
	PipelineFinished
	PipelineFailed
	PipelineAborted
	PipelineUnknownState
)

type PipelineSyncer func() (*sdk.WorkflowItem, error)

type Progress struct {
	Options Options
	// contains filtered or unexported fields
}

func NewPipeline(options Options) *Progress

func (p *Progress) Start()

func (p *Progress) Stop()

func (p *Progress) Update(pipelineSync PipelineSyncer) error

func (p *Progress) UpdatePipeline(workflow *sdk.WorkflowItem) (bool, error)

type UpdateStatus int

const (
	Failed UpdateStatus = iota
	Success

	Synced
)