Documentation
¶
Index ¶
- func Fail(err error) func(*badger.Txn) error
- func FindHeaders(filter func(header *flow.Header) bool, found *[]flow.Header) func(*badger.Txn) error
- func IndexBlockHeight(height uint64, blockID flow.Identifier) func(*badger.Txn) error
- func IndexBlockSeal(blockID flow.Identifier, sealID flow.Identifier) func(*badger.Txn) error
- func IndexClusterBlockHeight(clusterID flow.ChainID, number uint64, blockID flow.Identifier) func(*badger.Txn) error
- func IndexCollectionBlock(collID flow.Identifier, blockID flow.Identifier) func(*badger.Txn) error
- func IndexCollectionByTransaction(txID flow.Identifier, collectionID flow.Identifier) func(*badger.Txn) error
- func IndexCollectionPayload(blockID flow.Identifier, txIDs []flow.Identifier) func(*badger.Txn) error
- func IndexCollectionReference(clusterBlockID, refID flow.Identifier) func(*badger.Txn) error
- func IndexExecutionReceipt(blockID flow.Identifier, receiptID flow.Identifier) func(*badger.Txn) error
- func IndexExecutionResult(blockID flow.Identifier, resultID flow.Identifier) func(*badger.Txn) error
- func IndexPayloadGuarantees(blockID flow.Identifier, guarIDs []flow.Identifier) func(*badger.Txn) error
- func IndexPayloadSeals(blockID flow.Identifier, sealIDs []flow.Identifier) func(*badger.Txn) error
- func IndexStateCommitment(blockID flow.Identifier, commit flow.StateCommitment) func(*badger.Txn) error
- func InitMax(tx *badger.Txn) error
- func InsertBlockChildren(blockID flow.Identifier, childrenIDs []flow.Identifier) func(*badger.Txn) error
- func InsertBlockValidity(blockID flow.Identifier, valid bool) func(*badger.Txn) error
- func InsertChunkDataPack(c *flow.ChunkDataPack) func(*badger.Txn) error
- func InsertClusterFinalizedHeight(clusterID flow.ChainID, number uint64) func(*badger.Txn) error
- func InsertCollection(collection *flow.LightCollection) func(*badger.Txn) error
- func InsertEpochCommit(eventID flow.Identifier, event *flow.EpochCommit) func(*badger.Txn) error
- func InsertEpochSetup(eventID flow.Identifier, event *flow.EpochSetup) func(*badger.Txn) error
- func InsertEpochStatus(blockID flow.Identifier, status *flow.EpochStatus) func(*badger.Txn) error
- func InsertEvent(blockID flow.Identifier, event flow.Event) func(*badger.Txn) error
- func InsertExecutedBlock(blockID flow.Identifier) func(*badger.Txn) error
- func InsertExecutionForkEvidence(conflictingSeals []*flow.IncorporatedResultSeal) func(*badger.Txn) error
- func InsertExecutionReceiptMeta(receiptID flow.Identifier, meta *flow.ExecutionReceiptMeta) func(*badger.Txn) error
- func InsertExecutionResult(result *flow.ExecutionResult) func(*badger.Txn) error
- func InsertExecutionStateInteractions(blockID flow.Identifier, interactions []*delta.Snapshot) func(*badger.Txn) error
- func InsertFinalizedHeight(height uint64) func(*badger.Txn) error
- func InsertGuarantee(collID flow.Identifier, guarantee *flow.CollectionGuarantee) func(*badger.Txn) error
- func InsertHeader(headerID flow.Identifier, header *flow.Header) func(*badger.Txn) error
- func InsertLastCompleteBlockHeight(height uint64) func(*badger.Txn) error
- func InsertRootHeight(height uint64) func(*badger.Txn) error
- func InsertSeal(sealID flow.Identifier, seal *flow.Seal) func(*badger.Txn) error
- func InsertSealedHeight(height uint64) func(*badger.Txn) error
- func InsertStartedView(chainID flow.ChainID, view uint64) func(*badger.Txn) error
- func InsertTransaction(txID flow.Identifier, tx *flow.TransactionBody) func(*badger.Txn) error
- func InsertTransactionResult(blockID flow.Identifier, transactionResult *flow.TransactionResult) func(*badger.Txn) error
- func InsertVotedView(chainID flow.ChainID, view uint64) func(*badger.Txn) error
- func LookupBlockHeight(height uint64, blockID *flow.Identifier) func(*badger.Txn) error
- func LookupBlockSeal(blockID flow.Identifier, sealID *flow.Identifier) func(*badger.Txn) error
- func LookupClusterBlockHeight(clusterID flow.ChainID, number uint64, blockID *flow.Identifier) func(*badger.Txn) error
- func LookupCollectionBlock(collID flow.Identifier, blockID *flow.Identifier) func(*badger.Txn) error
- func LookupCollectionPayload(blockID flow.Identifier, txIDs *[]flow.Identifier) func(*badger.Txn) error
- func LookupCollectionReference(clusterBlockID flow.Identifier, refID *flow.Identifier) func(*badger.Txn) error
- func LookupEventsByBlockID(blockID flow.Identifier, events *[]flow.Event) func(*badger.Txn) error
- func LookupEventsByBlockIDEventType(blockID flow.Identifier, eventType flow.EventType, events *[]flow.Event) func(*badger.Txn) error
- func LookupExecutionReceipt(blockID flow.Identifier, receiptID *flow.Identifier) func(*badger.Txn) error
- func LookupExecutionResult(blockID flow.Identifier, resultID *flow.Identifier) func(*badger.Txn) error
- func LookupPayloadGuarantees(blockID flow.Identifier, guarIDs *[]flow.Identifier) func(*badger.Txn) error
- func LookupPayloadSeals(blockID flow.Identifier, sealIDs *[]flow.Identifier) func(*badger.Txn) error
- func LookupStateCommitment(blockID flow.Identifier, commit *flow.StateCommitment) func(*badger.Txn) error
- func LookupTransactionResultsByBlockID(blockID flow.Identifier, txResults *[]flow.TransactionResult) func(*badger.Txn) error
- func RemoveChunkDataPack(chunkID flow.Identifier) func(*badger.Txn) error
- func RemoveCollection(collID flow.Identifier) func(*badger.Txn) error
- func RemoveExecutionForkEvidence() func(*badger.Txn) error
- func RetrieveBlockChildren(blockID flow.Identifier, childrenIDs *[]flow.Identifier) func(*badger.Txn) error
- func RetrieveBlockValidity(blockID flow.Identifier, valid *bool) func(*badger.Txn) error
- func RetrieveChunkDataPack(chunkID flow.Identifier, c *flow.ChunkDataPack) func(*badger.Txn) error
- func RetrieveClusterFinalizedHeight(clusterID flow.ChainID, number *uint64) func(*badger.Txn) error
- func RetrieveCollection(collID flow.Identifier, collection *flow.LightCollection) func(*badger.Txn) error
- func RetrieveCollectionID(txID flow.Identifier, collectionID *flow.Identifier) func(*badger.Txn) error
- func RetrieveEpochCommit(eventID flow.Identifier, event *flow.EpochCommit) func(*badger.Txn) error
- func RetrieveEpochSetup(eventID flow.Identifier, event *flow.EpochSetup) func(*badger.Txn) error
- func RetrieveEpochStatus(blockID flow.Identifier, status *flow.EpochStatus) func(*badger.Txn) error
- func RetrieveEvents(blockID flow.Identifier, transactionID flow.Identifier, events *[]flow.Event) func(*badger.Txn) error
- func RetrieveExecutedBlock(blockID *flow.Identifier) func(*badger.Txn) error
- func RetrieveExecutionForkEvidence(conflictingSeals *[]*flow.IncorporatedResultSeal) func(*badger.Txn) error
- func RetrieveExecutionReceiptMeta(receiptID flow.Identifier, meta *flow.ExecutionReceiptMeta) func(*badger.Txn) error
- func RetrieveExecutionResult(resultID flow.Identifier, result *flow.ExecutionResult) func(*badger.Txn) error
- func RetrieveExecutionStateInteractions(blockID flow.Identifier, interactions *[]*delta.Snapshot) func(*badger.Txn) error
- func RetrieveFinalizedHeight(height *uint64) func(*badger.Txn) error
- func RetrieveGuarantee(collID flow.Identifier, guarantee *flow.CollectionGuarantee) func(*badger.Txn) error
- func RetrieveHeader(blockID flow.Identifier, header *flow.Header) func(*badger.Txn) error
- func RetrieveLastCompleteBlockHeight(height *uint64) func(*badger.Txn) error
- func RetrieveRootHeight(height *uint64) func(*badger.Txn) error
- func RetrieveSeal(sealID flow.Identifier, seal *flow.Seal) func(*badger.Txn) error
- func RetrieveSealedHeight(height *uint64) func(*badger.Txn) error
- func RetrieveStartedView(chainID flow.ChainID, view *uint64) func(*badger.Txn) error
- func RetrieveTransaction(txID flow.Identifier, tx *flow.TransactionBody) func(*badger.Txn) error
- func RetrieveTransactionResult(blockID flow.Identifier, transactionID flow.Identifier, ...) func(*badger.Txn) error
- func RetrieveVotedView(chainID flow.ChainID, view *uint64) func(*badger.Txn) error
- func RetryOnConflict(action func(func(*badger.Txn) error) error, op func(tx *badger.Txn) error) error
- func SetMax(tx *badger.Txn) error
- func SkipDuplicates(op func(*badger.Txn) error) func(tx *badger.Txn) error
- func UpdateBlockChildren(blockID flow.Identifier, childrenIDs []flow.Identifier) func(*badger.Txn) error
- func UpdateClusterFinalizedHeight(clusterID flow.ChainID, number uint64) func(*badger.Txn) error
- func UpdateExecutedBlock(blockID flow.Identifier) func(*badger.Txn) error
- func UpdateFinalizedHeight(height uint64) func(*badger.Txn) error
- func UpdateLastCompleteBlockHeight(height uint64) func(*badger.Txn) error
- func UpdateSealedHeight(height uint64) func(*badger.Txn) error
- func UpdateStartedView(chainID flow.ChainID, view uint64) func(*badger.Txn) error
- func UpdateVotedView(chainID flow.ChainID, view uint64) func(*badger.Txn) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 ¶
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 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 InsertRootHeight ¶
func InsertSeal ¶
func InsertSeal(sealID flow.Identifier, seal *flow.Seal) func(*badger.Txn) error
func InsertSealedHeight ¶
func InsertStartedView ¶
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 ¶
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 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 ¶
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 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 RetrieveRootHeight ¶
func RetrieveSeal ¶
func RetrieveSeal(sealID flow.Identifier, seal *flow.Seal) func(*badger.Txn) error
func RetrieveSealedHeight ¶
func RetrieveStartedView ¶
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 ¶
RetrieveVotedView retrieves a view from the database.
func RetryOnConflict ¶
func SetMax ¶
func SetMax(tx *badger.Txn) error
SetMax sets the value for the maximum key length used for efficient iteration.
func SkipDuplicates ¶
func UpdateBlockChildren ¶
func UpdateBlockChildren(blockID flow.Identifier, childrenIDs []flow.Identifier) func(*badger.Txn) error
UpdateBlockChildren updates the children for a block.
func UpdateClusterFinalizedHeight ¶
UpdateClusterFinalizedHeight updates the finalized boundary for the given cluster.
func UpdateExecutedBlock ¶
func UpdateExecutedBlock(blockID flow.Identifier) func(*badger.Txn) error
func UpdateFinalizedHeight ¶
func UpdateSealedHeight ¶
func UpdateStartedView ¶
UpdateStartedView updates the view in the database.
Types ¶
This section is empty.