persisters

Documentation

Index

• type BlockPersister
  • func NewBlockPersister(log zerolog.Logger, protocolDB storage.DB, lockManager lockctx.Manager, ...) *BlockPersister
  • func (p *BlockPersister) Persist() error
• type RegistersPersister
  • func NewRegistersPersister(inMemoryRegisters *unsynchronized.Registers, ...) *RegistersPersister
  • func (r *RegistersPersister) Persist() error

Types

type BlockPersister

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

BlockPersister handles persisting of execution data for all PersisterStore-s to database. Each BlockPersister instance is created for ONE specific block

func NewBlockPersister

func NewBlockPersister(
	log zerolog.Logger,
	protocolDB storage.DB,
	lockManager lockctx.Manager,
	executionResult *flow.ExecutionResult,
	header *flow.Header,
	persisterStores []stores.PersisterStore,
) *BlockPersister

NewBlockPersister creates a new block persister.

func (*BlockPersister) Persist

func (p *BlockPersister) Persist() error

Persist save data in provided persisted stores and commit updates to the database. No errors are expected during normal operations

type RegistersPersister

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

RegistersPersister handles registers

func NewRegistersPersister

func NewRegistersPersister(
	inMemoryRegisters *unsynchronized.Registers,
	permanentRegisters storage.RegisterIndex,
	height uint64,
) *RegistersPersister

func (*RegistersPersister) Persist

func (r *RegistersPersister) Persist() error

Persist persists registers No errors are expected during normal operations