execution

package
v0.29.0-stable-cadence-4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 10, 2022 License: AGPL-3.0 Imports: 8 Imported by: 9

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GenerateChunk added in v0.19.0

func GenerateChunk(colIndex int,
	startState, endState flow.StateCommitment,
	blockID, eventsCollection flow.Identifier, txNumber uint64) *flow.Chunk

GenerateChunk creates a chunk from the provided computation data.

func GenerateChunkDataPack added in v0.19.0

func GenerateChunkDataPack(
	chunkID flow.Identifier,
	startState flow.StateCommitment,
	collection *flow.Collection,
	proof flow.StorageProof,
) *flow.ChunkDataPack

func GenerateExecutionResultAndChunkDataPacks added in v0.19.0

func GenerateExecutionResultAndChunkDataPacks(
	metrics module.ExecutionMetrics,
	prevResultId flow.Identifier,
	startState flow.StateCommitment,
	result *ComputationResult) (
	endState flow.StateCommitment,
	chdps []*flow.ChunkDataPack,
	executionResult *flow.ExecutionResult,
	err error,
)

func GenerateExecutionResultForBlock added in v0.19.0

func GenerateExecutionResultForBlock(
	previousErID flow.Identifier,
	block *flow.Block,
	chunks []*flow.Chunk,
	serviceEvents []flow.Event,
	executionDataID flow.Identifier,
) (*flow.ExecutionResult, error)

GenerateExecutionResultForBlock creates new ExecutionResult for a block from the provided chunk results.

Types

type ComputationOrder

type ComputationOrder struct {
	Block      *entity.ExecutableBlock
	View       *delta.View
	StartState flow.StateCommitment
}

type ComputationResult

type ComputationResult struct {
	ExecutableBlock        *entity.ExecutableBlock
	StateSnapshots         []*delta.SpockSnapshot
	StateCommitments       []flow.StateCommitment
	Proofs                 [][]byte
	Events                 []flow.EventsList
	EventsHashes           []flow.Identifier
	ServiceEvents          flow.EventsList
	TransactionResults     []flow.TransactionResult
	TransactionResultIndex []int
	ComputationIntensities meter.MeteredComputationIntensities
	TrieUpdates            []*ledger.TrieUpdate
	ExecutionDataID        flow.Identifier
}

func NewEmptyComputationResult added in v0.28.7

func NewEmptyComputationResult(block *entity.ExecutableBlock) *ComputationResult

func (*ComputationResult) AddEvents added in v0.16.0

func (cr *ComputationResult) AddEvents(chunkIndex int, inp []flow.Event)

func (*ComputationResult) AddServiceEvents added in v0.16.0

func (cr *ComputationResult) AddServiceEvents(inp []flow.Event)

func (*ComputationResult) AddStateSnapshot added in v0.16.0

func (cr *ComputationResult) AddStateSnapshot(inp *delta.SpockSnapshot)

func (*ComputationResult) AddTransactionResult added in v0.16.0

func (cr *ComputationResult) AddTransactionResult(inp *flow.TransactionResult)

Update this

func (*ComputationResult) BlockComputationAndMemoryUsed added in v0.28.7

func (cr *ComputationResult) BlockComputationAndMemoryUsed() (uint64, uint64)

func (*ComputationResult) BlockEventCountsAndSize added in v0.28.7

func (cr *ComputationResult) BlockEventCountsAndSize() (int, int)

func (*ComputationResult) ChunkComputationAndMemoryUsed added in v0.28.7

func (cr *ComputationResult) ChunkComputationAndMemoryUsed(chunkIndex int) (uint64, uint64)

func (*ComputationResult) ChunkEventCountsAndSize added in v0.28.7

func (cr *ComputationResult) ChunkEventCountsAndSize(chunkIndex int) (int, int)

func (*ComputationResult) MergeComputationEffortVector

func (cr *ComputationResult) MergeComputationEffortVector(
	computationIntensities meter.MeteredComputationIntensities)

func (*ComputationResult) UpdateTransactionResultIndex added in v0.28.7

func (cr *ComputationResult) UpdateTransactionResultIndex(txCounts int)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL