operation

package
v0.14.9-error-printing Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2021 License: AGPL-3.0 Imports: 10 Imported by: 13

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Fail 

func Fail(err error) func(*badger.Txn) error

Fail returns a DB operation function that always fails with the given error.

func FindHeaders 

func FindHeaders(filter func(header *flow.Header) bool, found *[]flow.Header) func(*badger.Txn) error

FindHeaders iterates through all headers, calling `filter` on each, and adding them to the `found` slice if `filter` returned true

func IndexBlockHeight 

func IndexBlockHeight(height uint64, blockID flow.Identifier) func(*badger.Txn) error

IndexBlockHeight indexes the height of a block. It should only be called on finalized blocks.

func IndexBlockSeal 

func IndexBlockSeal(blockID flow.Identifier, sealID flow.Identifier) func(*badger.Txn) error

func IndexClusterBlockHeight 

func IndexClusterBlockHeight(clusterID flow.ChainID, number uint64, blockID flow.Identifier) func(*badger.Txn) error

IndexClusterBlockHeight inserts a block number to block ID mapping for the given cluster.

func IndexCollectionBlock 

func IndexCollectionBlock(collID flow.Identifier, blockID flow.Identifier) func(*badger.Txn) error

IndexCollectionBlock indexes a block by a collection within that block.

func IndexCollectionByTransaction 

func IndexCollectionByTransaction(txID flow.Identifier, collectionID flow.Identifier) func(*badger.Txn) error

IndexCollectionByTransaction inserts a collection id keyed by a transaction id

func IndexCollectionPayload 

func IndexCollectionPayload(blockID flow.Identifier, txIDs []flow.Identifier) func(*badger.Txn) error

IndexCollectionPayload indexes the transactions within the collection payload of a cluster block.

func IndexCollectionReference 

func IndexCollectionReference(clusterBlockID, refID flow.Identifier) func(*badger.Txn) error

IndexCollectionReference inserts the reference block ID for a cluster block payload (ie. collection) keyed by the cluster block ID

func IndexExecutionReceipt 

func IndexExecutionReceipt(blockID flow.Identifier, receiptID flow.Identifier) func(*badger.Txn) error

IndexExecutionReceipt inserts an execution receipt ID keyed by block ID

func IndexExecutionReceiptByBlockIDExecutionID added in v0.14.0 

func IndexExecutionReceiptByBlockIDExecutionID(blockID, executorID, receiptID flow.Identifier) func(*badger.Txn) error

IndexExecutionReceipt inserts an execution receipt ID keyed by block ID and execution ID

func IndexExecutionResult 

func IndexExecutionResult(blockID flow.Identifier, resultID flow.Identifier) func(*badger.Txn) error

IndexExecutionResult inserts an execution result ID keyed by block ID

func IndexPayloadGuarantees 

func IndexPayloadGuarantees(blockID flow.Identifier, guarIDs []flow.Identifier) func(*badger.Txn) error

func IndexPayloadReceipts added in v0.14.0 

func IndexPayloadReceipts(blockID flow.Identifier, receiptIDs []flow.Identifier) func(*badger.Txn) error

func IndexPayloadSeals 

func IndexPayloadSeals(blockID flow.Identifier, sealIDs []flow.Identifier) func(*badger.Txn) error

func IndexResultApproval added in v0.14.0 

func IndexResultApproval(resultID flow.Identifier, chunkIndex uint64, approvalID flow.Identifier) func(*badger.Txn) error

IndexResultApproval inserts a ResultApproval ID keyed by ExecutionResult ID and chunk index. If a value for this key exists, a storage.ErrAlreadyExists error is returned. This operation is only used by the ResultApprovals store, which is only used within a Verification node, where it is assumed that there is only one approval per chunk.

func IndexStateCommitment 

func IndexStateCommitment(blockID flow.Identifier, commit flow.StateCommitment) func(*badger.Txn) error

IndexStateCommitment indexes a state commitment.

State commitments are keyed by the block whose execution results in the state with the given commit.

func InitMax 

func InitMax(tx *badger.Txn) error

InitMax retrieves the maximum key length to have it interally in the package after restarting.

func InsertBlockChildren 

func InsertBlockChildren(blockID flow.Identifier, childrenIDs []flow.Identifier) func(*badger.Txn) error

InsertBlockChildren insert an index to lookup the direct child of a block by its ID

func InsertBlockValidity 

func InsertBlockValidity(blockID flow.Identifier, valid bool) func(*badger.Txn) error

InsertBlockValidity marks a block as valid or invalid, defined by the consensus algorithm.

func InsertChunkDataPack 

func InsertChunkDataPack(c *flow.ChunkDataPack) func(*badger.Txn) error

InsertChunkDataPack inserts a chunk data pack keyed by chunk ID.

func InsertClusterFinalizedHeight 

func InsertClusterFinalizedHeight(clusterID flow.ChainID, number uint64) func(*badger.Txn) error

InsertClusterFinalizedHeight inserts the finalized boundary for the given cluster.

func InsertCollection 

func InsertCollection(collection *flow.LightCollection) func(*badger.Txn) error

func InsertEpochCommit 

func InsertEpochCommit(eventID flow.Identifier, event *flow.EpochCommit) func(*badger.Txn) error

func InsertEpochSetup 

func InsertEpochSetup(eventID flow.Identifier, event *flow.EpochSetup) func(*badger.Txn) error

func InsertEpochStatus 

func InsertEpochStatus(blockID flow.Identifier, status *flow.EpochStatus) func(*badger.Txn) error

func InsertEvent 

func InsertEvent(blockID flow.Identifier, event flow.Event) func(*badger.Txn) error

func InsertExecutedBlock 

func InsertExecutedBlock(blockID flow.Identifier) func(*badger.Txn) error

func InsertExecutionForkEvidence added in v0.13.0 

func InsertExecutionForkEvidence(conflictingSeals []*flow.IncorporatedResultSeal) func(*badger.Txn) error

func InsertExecutionReceiptMeta 

func InsertExecutionReceiptMeta(receiptID flow.Identifier, meta *flow.ExecutionReceiptMeta) func(*badger.Txn) error

InsertExecutionReceiptMeta inserts an execution receipt meta by ID.

func InsertExecutionResult 

func InsertExecutionResult(result *flow.ExecutionResult) func(*badger.Txn) error

InsertExecutionResult inserts an execution result by ID.

func InsertExecutionStateInteractions 

func InsertExecutionStateInteractions(blockID flow.Identifier, interactions []*delta.Snapshot) func(*badger.Txn) error

func InsertFinalizedHeight 

func InsertFinalizedHeight(height uint64) func(*badger.Txn) error

func InsertGuarantee 

func InsertGuarantee(collID flow.Identifier, guarantee *flow.CollectionGuarantee) func(*badger.Txn) error

func InsertHeader 

func InsertHeader(headerID flow.Identifier, header *flow.Header) func(*badger.Txn) error

func InsertLastCompleteBlockHeight 

func InsertLastCompleteBlockHeight(height uint64) func(*badger.Txn) error

func InsertResultApproval added in v0.14.0 

func InsertResultApproval(approval *flow.ResultApproval) func(*badger.Txn) error

InsertResultApproval inserts a ResultApproval by ID.

func InsertRootHeight 

func InsertRootHeight(height uint64) func(*badger.Txn) error

func InsertSeal 

func InsertSeal(sealID flow.Identifier, seal *flow.Seal) func(*badger.Txn) error

func InsertSealedHeight 

func InsertSealedHeight(height uint64) func(*badger.Txn) error

func InsertServiceEvent added in v0.14.0 

func InsertServiceEvent(blockID flow.Identifier, event flow.Event) func(*badger.Txn) error

func InsertStartedView 

func InsertStartedView(chainID flow.ChainID, view uint64) func(*badger.Txn) error

InsertStartedView inserts a view into the database.

func InsertTransaction 

func InsertTransaction(txID flow.Identifier, tx *flow.TransactionBody) func(*badger.Txn) error

InsertTransaction inserts a transaction keyed by transaction fingerprint.

func InsertTransactionResult 

func InsertTransactionResult(blockID flow.Identifier, transactionResult *flow.TransactionResult) func(*badger.Txn) error

func InsertVotedView 

func InsertVotedView(chainID flow.ChainID, view uint64) func(*badger.Txn) error

InsertVotedView inserts a view into the database.

func LookupBlockHeight 

func LookupBlockHeight(height uint64, blockID *flow.Identifier) func(*badger.Txn) error

LookupBlockHeight retrieves finalized blocks by height.

func LookupBlockSeal 

func LookupBlockSeal(blockID flow.Identifier, sealID *flow.Identifier) func(*badger.Txn) error

func LookupClusterBlockHeight 

func LookupClusterBlockHeight(clusterID flow.ChainID, number uint64, blockID *flow.Identifier) func(*badger.Txn) error

LookupClusterBlockHeight retrieves a block ID by number for the given cluster

func LookupCollectionBlock 

func LookupCollectionBlock(collID flow.Identifier, blockID *flow.Identifier) func(*badger.Txn) error

LookupCollectionBlock looks up a block by a collection within that block.

func LookupCollectionPayload 

func LookupCollectionPayload(blockID flow.Identifier, txIDs *[]flow.Identifier) func(*badger.Txn) error

LookupCollection looks up the collection for a given cluster payload.

func LookupCollectionReference 

func LookupCollectionReference(clusterBlockID flow.Identifier, refID *flow.Identifier) func(*badger.Txn) error

LookupCollectionReference looks up the reference block ID for a cluster block payload (ie. collection) keyed by the cluster block ID.

func LookupEventsByBlockID 

func LookupEventsByBlockID(blockID flow.Identifier, events *[]flow.Event) func(*badger.Txn) error

func LookupEventsByBlockIDEventType 

func LookupEventsByBlockIDEventType(blockID flow.Identifier, eventType flow.EventType, events *[]flow.Event) func(*badger.Txn) error

func LookupExecutionReceipt 

func LookupExecutionReceipt(blockID flow.Identifier, receiptID *flow.Identifier) func(*badger.Txn) error

LookupExecutionReceipt finds execution receipt ID by block

func LookupExecutionReceiptByBlockIDAllExecutionIDs added in v0.14.0 

func LookupExecutionReceiptByBlockIDAllExecutionIDs(blockID flow.Identifier, receiptIDs *[]flow.Identifier) func(*badger.Txn) error

LookupExecutionReceipt finds execution receipt ID by block ID for all execution IDs

func LookupExecutionReceiptByBlockIDExecutionID added in v0.14.0 

func LookupExecutionReceiptByBlockIDExecutionID(blockID flow.Identifier, executorID flow.Identifier, receiptID *flow.Identifier) func(*badger.Txn) error

LookupExecutionReceipt finds execution receipt ID by block ID and execution ID

func LookupExecutionResult 

func LookupExecutionResult(blockID flow.Identifier, resultID *flow.Identifier) func(*badger.Txn) error

LookupExecutionResult finds execution result ID by block

func LookupPayloadGuarantees 

func LookupPayloadGuarantees(blockID flow.Identifier, guarIDs *[]flow.Identifier) func(*badger.Txn) error

func LookupPayloadReceipts added in v0.14.0 

func LookupPayloadReceipts(blockID flow.Identifier, receiptIDs *[]flow.Identifier) func(*badger.Txn) error

func LookupPayloadSeals 

func LookupPayloadSeals(blockID flow.Identifier, sealIDs *[]flow.Identifier) func(*badger.Txn) error

func LookupResultApproval added in v0.14.0 

func LookupResultApproval(resultID flow.Identifier, chunkIndex uint64, approvalID *flow.Identifier) func(*badger.Txn) error

LookupResultApproval finds a ResultApproval by result ID and chunk index.

func LookupServiceEventsByBlockID added in v0.14.0 

func LookupServiceEventsByBlockID(blockID flow.Identifier, events *[]flow.Event) func(*badger.Txn) error

func LookupStateCommitment 

func LookupStateCommitment(blockID flow.Identifier, commit *flow.StateCommitment) func(*badger.Txn) error

LookupStateCommitment gets a state commitment keyed by block ID

State commitments are keyed by the block whose execution results in the state with the given commit.

func LookupTransactionResultsByBlockID 

func LookupTransactionResultsByBlockID(blockID flow.Identifier, txResults *[]flow.TransactionResult) func(*badger.Txn) error

func RemoveChunkDataPack 

func RemoveChunkDataPack(chunkID flow.Identifier) func(*badger.Txn) error

RemoveChunkDataPack removes the chunk data pack with the given chunk ID.

func RemoveCollection 

func RemoveCollection(collID flow.Identifier) func(*badger.Txn) error

func RemoveExecutionForkEvidence added in v0.13.0 

func RemoveExecutionForkEvidence() func(*badger.Txn) error

func RetrieveBlockChildren 

func RetrieveBlockChildren(blockID flow.Identifier, childrenIDs *[]flow.Identifier) func(*badger.Txn) error

RetrieveBlockChildren the child block ID by parent block ID

func RetrieveBlockValidity 

func RetrieveBlockValidity(blockID flow.Identifier, valid *bool) func(*badger.Txn) error

RetrieveBlockValidity returns a block's validity wrt the consensus algorithm.

func RetrieveChunkDataPack 

func RetrieveChunkDataPack(chunkID flow.Identifier, c *flow.ChunkDataPack) func(*badger.Txn) error

RetrieveChunkDataPack retrieves a chunk data pack by chunk ID.

func RetrieveClusterFinalizedHeight 

func RetrieveClusterFinalizedHeight(clusterID flow.ChainID, number *uint64) func(*badger.Txn) error

RetrieveClusterFinalizedHeight retrieves the finalized boundary for the given cluster.

func RetrieveCollection 

func RetrieveCollection(collID flow.Identifier, collection *flow.LightCollection) func(*badger.Txn) error

func RetrieveCollectionID 

func RetrieveCollectionID(txID flow.Identifier, collectionID *flow.Identifier) func(*badger.Txn) error

LookupCollectionID retrieves a collection id by transaction id

func RetrieveEpochCommit 

func RetrieveEpochCommit(eventID flow.Identifier, event *flow.EpochCommit) func(*badger.Txn) error

func RetrieveEpochSetup 

func RetrieveEpochSetup(eventID flow.Identifier, event *flow.EpochSetup) func(*badger.Txn) error

func RetrieveEpochStatus 

func RetrieveEpochStatus(blockID flow.Identifier, status *flow.EpochStatus) func(*badger.Txn) error

func RetrieveEvents 

func RetrieveEvents(blockID flow.Identifier, transactionID flow.Identifier, events *[]flow.Event) func(*badger.Txn) error

func RetrieveExecutedBlock 

func RetrieveExecutedBlock(blockID *flow.Identifier) func(*badger.Txn) error

func RetrieveExecutionForkEvidence added in v0.13.0 

func RetrieveExecutionForkEvidence(conflictingSeals *[]*flow.IncorporatedResultSeal) func(*badger.Txn) error

func RetrieveExecutionReceiptMeta 

func RetrieveExecutionReceiptMeta(receiptID flow.Identifier, meta *flow.ExecutionReceiptMeta) func(*badger.Txn) error

RetrieveExecutionReceipt retrieves a execution receipt meta by ID.

func RetrieveExecutionResult 

func RetrieveExecutionResult(resultID flow.Identifier, result *flow.ExecutionResult) func(*badger.Txn) error

RetrieveExecutionResult retrieves a transaction by fingerprint.

func RetrieveExecutionStateInteractions 

func RetrieveExecutionStateInteractions(blockID flow.Identifier, interactions *[]*delta.Snapshot) func(*badger.Txn) error

func RetrieveFinalizedHeight 

func RetrieveFinalizedHeight(height *uint64) func(*badger.Txn) error

func RetrieveGuarantee 

func RetrieveGuarantee(collID flow.Identifier, guarantee *flow.CollectionGuarantee) func(*badger.Txn) error

func RetrieveHeader 

func RetrieveHeader(blockID flow.Identifier, header *flow.Header) func(*badger.Txn) error

func RetrieveLastCompleteBlockHeight 

func RetrieveLastCompleteBlockHeight(height *uint64) func(*badger.Txn) error

func RetrieveResultApproval added in v0.14.0 

func RetrieveResultApproval(approvalID flow.Identifier, approval *flow.ResultApproval) func(*badger.Txn) error

RetrieveResultApproval retrieves an approval by ID.

func RetrieveRootHeight 

func RetrieveRootHeight(height *uint64) func(*badger.Txn) error

func RetrieveSeal 

func RetrieveSeal(sealID flow.Identifier, seal *flow.Seal) func(*badger.Txn) error

func RetrieveSealedHeight 

func RetrieveSealedHeight(height *uint64) func(*badger.Txn) error

func RetrieveStartedView 

func RetrieveStartedView(chainID flow.ChainID, view *uint64) func(*badger.Txn) error

RetrieveStartedView retrieves a view from the database.

func RetrieveTransaction 

func RetrieveTransaction(txID flow.Identifier, tx *flow.TransactionBody) func(*badger.Txn) error

RetrieveTransaction retrieves a transaction by fingerprint.

func RetrieveTransactionResult 

func RetrieveTransactionResult(blockID flow.Identifier, transactionID flow.Identifier, transactionResult *flow.TransactionResult) func(*badger.Txn) error

func RetrieveVotedView 

func RetrieveVotedView(chainID flow.ChainID, view *uint64) func(*badger.Txn) error

RetrieveVotedView retrieves a view from the database.

func RetryOnConflict 

func RetryOnConflict(action func(func(*badger.Txn) error) error, op func(tx *badger.Txn) error) error

func SetMax 

func SetMax(tx *badger.Txn) error

SetMax sets the value for the maximum key length used for efficient iteration.

func SkipDuplicates 

func SkipDuplicates(op func(*badger.Txn) error) func(tx *badger.Txn) error

func UpdateBlockChildren 

func UpdateBlockChildren(blockID flow.Identifier, childrenIDs []flow.Identifier) func(*badger.Txn) error

UpdateBlockChildren updates the children for a block.

func UpdateClusterFinalizedHeight 

func UpdateClusterFinalizedHeight(clusterID flow.ChainID, number uint64) func(*badger.Txn) error

UpdateClusterFinalizedHeight updates the finalized boundary for the given cluster.

func UpdateExecutedBlock 

func UpdateExecutedBlock(blockID flow.Identifier) func(*badger.Txn) error

func UpdateFinalizedHeight 

func UpdateFinalizedHeight(height uint64) func(*badger.Txn) error

func UpdateLastCompleteBlockHeight 

func UpdateLastCompleteBlockHeight(height uint64) func(*badger.Txn) error

func UpdateSealedHeight 

func UpdateSealedHeight(height uint64) func(*badger.Txn) error

func UpdateStartedView 

func UpdateStartedView(chainID flow.ChainID, view uint64) func(*badger.Txn) error

UpdateStartedView updates the view in the database.

func UpdateVotedView 

func UpdateVotedView(chainID flow.ChainID, view uint64) func(*badger.Txn) error

UpdateVotedView updates the view in the database.

Types

This section is empty.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.