loader

Documentation

Index

• type UnexecutedLoader
  • func NewUnexecutedLoader(log zerolog.Logger, state protocol.State, headers storage.Headers, ...) *UnexecutedLoader
  • func (e *UnexecutedLoader) LoadUnexecuted(ctx context.Context) ([]flow.Identifier, error)
• type UnfinalizedLoader
  • func NewUnfinalizedLoader(log zerolog.Logger, state protocol.State, headers storage.Headers, ...) *UnfinalizedLoader
  • func (e *UnfinalizedLoader) LoadUnexecuted(ctx context.Context) ([]flow.Identifier, error)

Types

type UnexecutedLoader

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

deprecated. Storehouse is going to use unfinalized loader instead

func NewUnexecutedLoader

func NewUnexecutedLoader(
	log zerolog.Logger,
	state protocol.State,
	headers storage.Headers,
	execState state.ExecutionState,
) *UnexecutedLoader

func (*UnexecutedLoader) LoadUnexecuted

func (e *UnexecutedLoader) LoadUnexecuted(ctx context.Context) ([]flow.Identifier, error)

LoadUnexecuted loads all unexecuted and validated blocks any error returned are exceptions

type UnfinalizedLoader

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

func NewUnfinalizedLoader

func NewUnfinalizedLoader(
	log zerolog.Logger,
	state protocol.State,
	headers storage.Headers,
	execState state.FinalizedExecutionState,
) *UnfinalizedLoader

NewUnfinalizedLoader creates a new loader that loads all unfinalized and validated blocks

func (*UnfinalizedLoader) LoadUnexecuted

func (e *UnfinalizedLoader) LoadUnexecuted(ctx context.Context) ([]flow.Identifier, error)

LoadUnexecuted loads all unfinalized and validated blocks any error returned are exceptions