pipeline

May 29, 2025

Changes in this version

+ type Core interface

+ Download func(ctx context.Context) error

+ Index func(ctx context.Context) error

+ Persist func(ctx context.Context) error

+ type Pipeline struct

+ func NewPipeline(logger zerolog.Logger, isSealed bool, executionResult *flow.ExecutionResult, ...) *Pipeline

+ func (p *Pipeline) GetState() State

+ func (p *Pipeline) Run(parentCtx context.Context) error

+ func (p *Pipeline) SetSealed()

+ func (p *Pipeline) UpdateState(update StateUpdate)

+ type State int

+ const StateCanceled

+ const StateComplete

+ const StateDownloading

+ const StateIndexing

+ const StatePersisting

+ const StateReady

+ const StateWaitingPersist

+ func (s State) String() string

+ type StateUpdate struct

+ DescendsFromLastPersistedSealed bool

+ ParentState State

+ type StateUpdatePublisher func(update StateUpdate)