computer

Documentation

Index

• Constants
• func GenerateExecutionReceipt(signer module.Local, receiptHasher hash.Hasher, result *flow.ExecutionResult, ...) (*flow.ExecutionReceipt, error)
• func SystemChunkContext(vmCtx fvm.Context, metrics module.ExecutionMetrics) fvm.Context
• type BlockComputer
  • func NewBlockComputer(vm fvm.VM, vmCtx fvm.Context, metrics module.ExecutionMetrics, ...) (BlockComputer, error)
• type TransactionRequest
• type TransactionWriteBehindLogger
• type ViewCommitter

Constants

const (
	SystemChunkEventCollectionMaxSize = 256_000_000 // ~256MB
)

Functions

func GenerateExecutionReceipt

func GenerateExecutionReceipt(
	signer module.Local,
	receiptHasher hash.Hasher,
	result *flow.ExecutionResult,
	spockSignatures []crypto.Signature,
) (
	*flow.ExecutionReceipt,
	error,
)

func SystemChunkContext

func SystemChunkContext(vmCtx fvm.Context, metrics module.ExecutionMetrics) fvm.Context

Types

type BlockComputer

type BlockComputer interface {
	ExecuteBlock(
		ctx context.Context,
		parentBlockExecutionResultID flow.Identifier,
		block *entity.ExecutableBlock,
		snapshot snapshot.StorageSnapshot,
		derivedBlockData *derived.DerivedBlockData,
	) (
		*execution.ComputationResult,
		error,
	)
}

A BlockComputer executes the transactions in a block.

func NewBlockComputer

func NewBlockComputer(
	vm fvm.VM,
	vmCtx fvm.Context,
	metrics module.ExecutionMetrics,
	tracer module.Tracer,
	logger zerolog.Logger,
	committer ViewCommitter,
	signer module.Local,
	executionDataProvider provider.Provider,
	colResCons []result.ExecutedCollectionConsumer,
	state protocol.State,
	maxConcurrency int,
) (BlockComputer, error)

NewBlockComputer creates a new block executor.

type TransactionRequest

type TransactionRequest struct {
	*fvm.TransactionProcedure
	// contains filtered or unexported fields
}

type TransactionWriteBehindLogger

type TransactionWriteBehindLogger interface {
	AddTransactionResult(
		txn TransactionRequest,
		snapshot *snapshot.ExecutionSnapshot,
		output fvm.ProcedureOutput,
		timeSpent time.Duration,
		numTxnConflictRetries int,
	)
}

type ViewCommitter

type ViewCommitter interface {
	// CommitView commits an execution snapshot and collects proofs
	CommitView(
		*snapshot.ExecutionSnapshot,
		execution.ExtendableStorageSnapshot,
	) (
		flow.StateCommitment,
		[]byte,
		*ledger.TrieUpdate,
		execution.ExtendableStorageSnapshot,
		error,
	)
}

ViewCommitter commits execution snapshot to the ledger and collects the proofs