optimistic_sync

Sep 16, 2025

Changes in this version

+ const DefaultTxResultErrMsgsRequestTimeout

+ var ErrInvalidTransition = errors.New("invalid state transition")

+ func NewMockStateConsumer() *mockStateConsumer

+ func NewMockStateProvider() *mockStateProvider

+ type Core interface

+ Abandon func() error

+ Download func(ctx context.Context) error

+ Index func() error

+ Persist func() error

+ type CoreFactory interface

+ NewCore func(result *flow.ExecutionResult) Core

+ type CoreImpl struct

+ func NewCoreImpl(logger zerolog.Logger, executionResult *flow.ExecutionResult, ...) *CoreImpl

+ func (c *CoreImpl) Abandon() error

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

+ func (c *CoreImpl) Index() error

+ func (c *CoreImpl) Persist() error

+ type Criteria struct

+ AgreeingExecutorsCount uint

+ RequiredExecutors flow.IdentifierList

+ func (c *Criteria) OverrideWith(override Criteria) Criteria

+ type ExecutionResultQueryProvider interface

+ ExecutionResultQuery func(blockID flow.Identifier, criteria Criteria) (*Query, error)

+ type ExecutionStateCache interface

+ Snapshot func(executionResultID flow.Identifier) (Snapshot, error)

+ type Pipeline interface

+ Abandon func()

+ OnParentStateUpdated func(parentState State)

+ Run func(ctx context.Context, core Core, parentState State) error

+ SetSealed func()

+ type PipelineFactory interface

+ NewPipeline func(result *flow.ExecutionResult, isSealed bool) Pipeline

+ type PipelineImpl struct

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

+ func (p *PipelineImpl) Abandon()

+ func (p *PipelineImpl) GetState() State

+ func (p *PipelineImpl) OnParentStateUpdated(parentState State)

+ func (p *PipelineImpl) Run(ctx context.Context, core Core, parentState State) error

+ func (p *PipelineImpl) SetSealed()

+ type PipelineStateConsumer interface

+ OnStateUpdated func(newState State)

+ type PipelineStateProvider interface

+ GetState func() State

+ type Query struct

+ ExecutionNodes flow.IdentitySkeletonList

+ ExecutionResult *flow.ExecutionResult

+ type Snapshot interface

+ Collections func() storage.CollectionsReader

+ Events func() storage.EventsReader

+ LightTransactionResults func() storage.LightTransactionResultsReader

+ Registers func() storage.RegisterIndexReader

+ TransactionResultErrorMessages func() storage.TransactionResultErrorMessagesReader

+ Transactions func() storage.TransactionsReader

+ type State int32

+ const StateAbandoned

+ const StateComplete

+ const StatePending

+ const StateProcessing

+ const StateWaitingPersist

+ func (s State) IsTerminal() bool

+ func (s State) String() string