operation

package
v0.13.1 Latest Latest
Warning

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

Go to latest
Published: Dec 15, 2020 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

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 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 IndexPayloadSeals

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

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 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 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

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 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 LookupPayloadSeals

func LookupPayloadSeals(blockID flow.Identifier, sealIDs *[]flow.Identifier) 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 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.

Jump to

Keyboard shortcuts

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