execution

Documentation

Index

• func GenerateChunk(colIndex int, startState, endState flow.StateCommitment, ...) *flow.Chunk
• func GenerateChunkDataPack(chunkID flow.Identifier, startState flow.StateCommitment, ...) *flow.ChunkDataPack
• func GenerateExecutionResultAndChunkDataPacks(metrics module.ExecutionMetrics, prevResultId flow.Identifier, ...) (endState flow.StateCommitment, chdps []*flow.ChunkDataPack, ...)
• func GenerateExecutionResultForBlock(previousErID flow.Identifier, block *flow.Block, chunks []*flow.Chunk, ...) (*flow.ExecutionResult, error)
• type ComputationOrder
• type ComputationResult
  • func NewEmptyComputationResult(block *entity.ExecutableBlock) *ComputationResult
  • func (cr *ComputationResult) AddEvents(chunkIndex int, inp []flow.Event)
  • func (cr *ComputationResult) AddServiceEvents(inp []flow.Event)
  • func (cr *ComputationResult) AddStateSnapshot(inp *delta.SpockSnapshot)
  • func (cr *ComputationResult) AddTransactionResult(inp *flow.TransactionResult)
  • func (cr *ComputationResult) BlockComputationAndMemoryUsed() (uint64, uint64)
  • func (cr *ComputationResult) BlockEventCountsAndSize() (int, int)
  • func (cr *ComputationResult) ChunkComputationAndMemoryUsed(chunkIndex int) (uint64, uint64)
  • func (cr *ComputationResult) ChunkEventCountsAndSize(chunkIndex int) (int, int)
  • func (cr *ComputationResult) MergeComputationEffortVector(computationIntensities meter.MeteredComputationIntensities)
  • func (cr *ComputationResult) UpdateTransactionResultIndex(txCounts int)

Functions

func GenerateChunk

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

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

func GenerateExecutionResultAndChunkDataPacks

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

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

func NewEmptyComputationResult(block *entity.ExecutableBlock) *ComputationResult

func (*ComputationResult) AddEvents

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

func (*ComputationResult) AddServiceEvents

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

func (*ComputationResult) AddStateSnapshot

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

func (*ComputationResult) AddTransactionResult

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

Update this

func (*ComputationResult) BlockComputationAndMemoryUsed

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

func (*ComputationResult) BlockEventCountsAndSize

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

func (*ComputationResult) ChunkComputationAndMemoryUsed

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

func (*ComputationResult) ChunkEventCountsAndSize

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

func (*ComputationResult) MergeComputationEffortVector

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

func (*ComputationResult) UpdateTransactionResultIndex

func (cr *ComputationResult) UpdateTransactionResultIndex(txCounts int)