pipeline

Jan 29, 2026

Changes in this version

+ const DefaultTxResultErrMsgsRequestTimeout

+ func NewMockStateConsumer() *mockStateConsumer

+ func NewMockStateProvider() *mockStateProvider

+ type Core struct

+ func NewCore(logger zerolog.Logger, executionResult *flow.ExecutionResult, ...) (*Core, error)

+ func (c *Core) Abandon()

+ func (c *Core) Download(ctx context.Context) error

+ func (c *Core) Index() error

+ func (c *Core) Persist() error

+ type Pipeline struct

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

+ func (p *Pipeline) Abandon()

+ func (p *Pipeline) GetState() optimistic_sync.State

+ func (p *Pipeline) OnParentStateUpdated(parentState optimistic_sync.State)

+ func (p *Pipeline) Run(ctx context.Context, core optimistic_sync.Core, ...) error

+ func (p *Pipeline) SetSealed()