state

Documentation

Index

• type BlockState
  • func NewBlockState(block *models.Block, chainID flowGo.ChainID, store *pebble.Storage, ...) (*BlockState, error)
  • func (s *BlockState) Call(from common.Address, data []byte) (*types.Result, error)
  • func (s *BlockState) Execute(tx models.Transaction) error
• type Engine
  • func NewStateEngine(chainID flowGo.ChainID, blockPublisher *models.Publisher, ...) *Engine
  • func (e *Engine) Done() <-chan struct{}
  • func (e *Engine) Error() <-chan error
  • func (e *Engine) ID() uuid.UUID
  • func (e *Engine) Notify(data any)
  • func (e *Engine) Ready() <-chan struct{}
  • func (e *Engine) Run(ctx context.Context) error
  • func (e *Engine) Stop()

Types

type BlockState

type BlockState struct {
	types.StateDB // todo change to types.ReadOnlyView
	// contains filtered or unexported fields
}

func NewBlockState

func NewBlockState(
	block *models.Block,
	chainID flowGo.ChainID,
	store *pebble.Storage,
	blocks storage.BlockIndexer,
	receipts storage.ReceiptIndexer,
	logger zerolog.Logger,
) (*BlockState, error)

func (*BlockState) Call

func (s *BlockState) Call(from common.Address, data []byte) (*types.Result, error)

func (*BlockState) Execute

func (s *BlockState) Execute(tx models.Transaction) error

type Engine

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

func NewStateEngine

func NewStateEngine(
	chainID flowGo.ChainID,
	blockPublisher *models.Publisher,
	store *pebble.Storage,
	blocks storage.BlockIndexer,
	transactions storage.TransactionIndexer,
	receipts storage.ReceiptIndexer,
	logger zerolog.Logger,
) *Engine

func (*Engine) Done

func (e *Engine) Done() <-chan struct{}

func (*Engine) Error

func (e *Engine) Error() <-chan error

func (*Engine) ID

func (e *Engine) ID() uuid.UUID

func (*Engine) Notify

func (e *Engine) Notify(data any)

func (*Engine) Ready

func (e *Engine) Ready() <-chan struct{}

func (*Engine) Run

func (e *Engine) Run(ctx context.Context) error

func (*Engine) Stop

func (e *Engine) Stop()