Documentation ¶
Index ¶
- func BatchIndexBlockByChunkID(blockID, chunkID flow.Identifier) func(batch *badger.WriteBatch) error
- func BatchIndexExecutionReceipts(blockID, receiptID flow.Identifier) func(batch *badger.WriteBatch) error
- func BatchIndexExecutionResult(blockID flow.Identifier, resultID flow.Identifier) func(batch *badger.WriteBatch) error
- func BatchIndexOwnExecutionReceipt(blockID flow.Identifier, receiptID flow.Identifier) func(batch *badger.WriteBatch) error
- func BatchIndexStateCommitment(blockID flow.Identifier, commit flow.StateCommitment) func(batch *badger.WriteBatch) error
- func BatchIndexTransactionResult(blockID flow.Identifier, txIndex uint32, ...) func(batch *badger.WriteBatch) error
- func BatchInsertChunkDataPack(c *badgermodel.StoredChunkDataPack) func(batch *badger.WriteBatch) error
- func BatchInsertEvent(blockID flow.Identifier, event flow.Event) func(batch *badger.WriteBatch) error
- func BatchInsertExecutionReceiptMeta(receiptID flow.Identifier, meta *flow.ExecutionReceiptMeta) func(batch *badger.WriteBatch) error
- func BatchInsertExecutionResult(result *flow.ExecutionResult) func(batch *badger.WriteBatch) error
- func BatchInsertServiceEvent(blockID flow.Identifier, event flow.Event) func(batch *badger.WriteBatch) error
- func BatchInsertTransactionResult(blockID flow.Identifier, transactionResult *flow.TransactionResult) func(batch *badger.WriteBatch) error
- func BatchRemoveBlockIDByChunkID(chunkID flow.Identifier) func(batch *badger.WriteBatch) error
- func BatchRemoveChunkDataPack(chunkID flow.Identifier) func(batch *badger.WriteBatch) error
- func BatchRemoveEventsByBlockID(blockID flow.Identifier, batch *badger.WriteBatch) func(*badger.Txn) error
- func BatchRemoveExecutionResultIndex(blockID flow.Identifier) func(*badger.WriteBatch) error
- func BatchRemoveOwnExecutionReceipt(blockID flow.Identifier) func(batch *badger.WriteBatch) error
- func BatchRemoveServiceEventsByBlockID(blockID flow.Identifier, batch *badger.WriteBatch) func(*badger.Txn) error
- func BatchRemoveStateCommitment(blockID flow.Identifier) func(batch *badger.WriteBatch) error
- func BatchRemoveTransactionResultsByBlockID(blockID flow.Identifier, batch *badger.WriteBatch) func(*badger.Txn) error
- func CheckEpochEmergencyFallbackTriggered(triggered *bool) func(*badger.Txn) error
- func EnsurePublicDB(db *badger.DB) error
- func EnsureSecretDB(db *badger.DB) error
- func Fail(err error) func(*badger.Txn) error
- func FindHeaders(filter func(header *flow.Header) bool, found *[]flow.Header) func(*badger.Txn) error
- func GetBlockIDsByStatus(blockIDs *[]flow.Identifier, targetUploadStatus bool) func(*badger.Txn) error
- func GetComputationResultUploadStatus(blockID flow.Identifier, wasUploadCompleted *bool) func(*badger.Txn) error
- func IndexBlockHeight(height uint64, blockID flow.Identifier) func(*badger.Txn) error
- func IndexBlockIDByChunkID(chunkID, blockID flow.Identifier) func(*badger.Txn) error
- func IndexClusterBlockByReferenceHeight(refHeight uint64, clusterBlockID 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 IndexExecutionReceipts(blockID, receiptID flow.Identifier) func(*badger.Txn) error
- func IndexExecutionResult(blockID flow.Identifier, resultID flow.Identifier) func(*badger.Txn) error
- func IndexFinalizedSealByBlockID(sealedBlockID flow.Identifier, sealID flow.Identifier) func(*badger.Txn) error
- func IndexLatestSealAtBlock(blockID flow.Identifier, sealID flow.Identifier) func(*badger.Txn) error
- func IndexOwnExecutionReceipt(blockID flow.Identifier, receiptID flow.Identifier) func(*badger.Txn) error
- func IndexPayloadGuarantees(blockID flow.Identifier, guarIDs []flow.Identifier) func(*badger.Txn) error
- func IndexPayloadReceipts(blockID flow.Identifier, receiptIDs []flow.Identifier) func(*badger.Txn) error
- func IndexPayloadResults(blockID flow.Identifier, resultIDs []flow.Identifier) func(*badger.Txn) error
- func IndexPayloadSeals(blockID flow.Identifier, sealIDs []flow.Identifier) func(*badger.Txn) error
- func IndexReferenceBlockByClusterBlock(clusterBlockID, refID flow.Identifier) func(*badger.Txn) error
- func IndexResultApproval(resultID flow.Identifier, chunkIndex uint64, approvalID flow.Identifier) func(*badger.Txn) error
- func IndexStateCommitment(blockID flow.Identifier, commit flow.StateCommitment) func(*badger.Txn) error
- func InitJobLatestIndex(queue string, index uint64) func(*badger.Txn) error
- func InitMax(tx *badger.Txn) error
- func InsertBlockChildren(blockID flow.Identifier, childrenIDs flow.IdentifierList) func(*badger.Txn) error
- func InsertBlockValidity(blockID flow.Identifier, valid bool) func(*badger.Txn) error
- func InsertChunkDataPack(c *badgermodel.StoredChunkDataPack) func(*badger.Txn) error
- func InsertChunkLocator(locator *chunks.Locator) 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 InsertComputationResultUploadStatus(blockID flow.Identifier, wasUploadCompleted bool) func(*badger.Txn) error
- func InsertDKGEndStateForEpoch(epochCounter uint64, endState flow.DKGEndState) func(*badger.Txn) error
- func InsertDKGStartedForEpoch(epochCounter uint64) 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 InsertJobAtIndex(queue string, index uint64, entity flow.Identifier) func(*badger.Txn) error
- func InsertLastCompleteBlockHeight(height uint64) func(*badger.Txn) error
- func InsertLastCompleteBlockHeightIfNotExists(height uint64) func(*badger.Txn) error
- func InsertMyBeaconPrivateKey(epochCounter uint64, info *encodable.RandomBeaconPrivKey) func(*badger.Txn) error
- func InsertProcessedIndex(jobName string, processed uint64) func(*badger.Txn) error
- func InsertProtocolVersion(version uint) func(*badger.Txn) error
- func InsertPublicDBMarker(txn *badger.Txn) error
- func InsertResultApproval(approval *flow.ResultApproval) func(*badger.Txn) error
- func InsertRootHeight(height uint64) func(*badger.Txn) error
- func InsertRootQuorumCertificate(qc *flow.QuorumCertificate) func(txn *badger.Txn) error
- func InsertSeal(sealID flow.Identifier, seal *flow.Seal) func(*badger.Txn) error
- func InsertSealedHeight(height uint64) func(*badger.Txn) error
- func InsertSecretDBMarker(txn *badger.Txn) error
- func InsertServiceEvent(blockID flow.Identifier, event flow.Event) func(*badger.Txn) error
- func InsertSporkID(sporkID flow.Identifier) 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 LookupBlockIDByChunkID(chunkID flow.Identifier, blockID *flow.Identifier) func(*badger.Txn) error
- func LookupBySealedBlockID(sealedBlockID flow.Identifier, sealID *flow.Identifier) func(*badger.Txn) error
- func LookupClusterBlockHeight(clusterID flow.ChainID, number uint64, blockID *flow.Identifier) func(*badger.Txn) error
- func LookupClusterBlocksByReferenceHeightRange(start, end uint64, clusterBlockIDs *[]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 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 LookupExecutionReceipts(blockID flow.Identifier, receiptIDs *[]flow.Identifier) func(*badger.Txn) error
- func LookupExecutionResult(blockID flow.Identifier, resultID *flow.Identifier) func(*badger.Txn) error
- func LookupLatestSealAtBlock(blockID flow.Identifier, sealID *flow.Identifier) func(*badger.Txn) error
- func LookupOwnExecutionReceipt(blockID flow.Identifier, receiptID *flow.Identifier) func(*badger.Txn) error
- func LookupPayloadGuarantees(blockID flow.Identifier, guarIDs *[]flow.Identifier) func(*badger.Txn) error
- func LookupPayloadReceipts(blockID flow.Identifier, receiptIDs *[]flow.Identifier) func(*badger.Txn) error
- func LookupPayloadResults(blockID flow.Identifier, resultIDs *[]flow.Identifier) func(*badger.Txn) error
- func LookupPayloadSeals(blockID flow.Identifier, sealIDs *[]flow.Identifier) func(*badger.Txn) error
- func LookupReferenceBlockByClusterBlock(clusterBlockID flow.Identifier, refID *flow.Identifier) func(*badger.Txn) error
- func LookupResultApproval(resultID flow.Identifier, chunkIndex uint64, approvalID *flow.Identifier) func(*badger.Txn) error
- func LookupServiceEventsByBlockID(blockID flow.Identifier, events *[]flow.Event) 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 LookupTransactionResultsByBlockIDUsingIndex(blockID flow.Identifier, txResults *[]flow.TransactionResult) func(*badger.Txn) error
- func PersistBlocklist(blocklist map[flow.Identifier]struct{}) func(*badger.Txn) error
- func PurgeBlocklist() func(*badger.Txn) error
- func ReindexExecutionResult(blockID flow.Identifier, resultID flow.Identifier) func(*badger.Txn) error
- func RemoveBlockIDByChunkID(chunkID flow.Identifier) func(*badger.Txn) error
- func RemoveChunkDataPack(chunkID flow.Identifier) func(*badger.Txn) error
- func RemoveCollection(collID flow.Identifier) func(*badger.Txn) error
- func RemoveComputationResultUploadStatus(blockID flow.Identifier) func(*badger.Txn) error
- func RemoveEventsByBlockID(blockID flow.Identifier) func(*badger.Txn) error
- func RemoveExecutionForkEvidence() func(*badger.Txn) error
- func RemoveExecutionResultIndex(blockID flow.Identifier) func(*badger.Txn) error
- func RemoveOwnExecutionReceipt(blockID flow.Identifier) func(*badger.Txn) error
- func RemoveServiceEventsByBlockID(blockID flow.Identifier) func(*badger.Txn) error
- func RemoveStateCommitment(blockID flow.Identifier) func(*badger.Txn) error
- func RemoveTransactionResultsByBlockID(blockID flow.Identifier) func(*badger.Txn) error
- func RetrieveBlockChildren(blockID flow.Identifier, childrenIDs *flow.IdentifierList) func(*badger.Txn) error
- func RetrieveBlockValidity(blockID flow.Identifier, valid *bool) func(*badger.Txn) error
- func RetrieveBlocklist(blocklist *map[flow.Identifier]struct{}) func(*badger.Txn) error
- func RetrieveChunkDataPack(chunkID flow.Identifier, c *badgermodel.StoredChunkDataPack) func(*badger.Txn) error
- func RetrieveChunkLocator(locatorID flow.Identifier, locator *chunks.Locator) 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 RetrieveDKGEndStateForEpoch(epochCounter uint64, endState *flow.DKGEndState) func(*badger.Txn) error
- func RetrieveDKGStartedForEpoch(epochCounter uint64, started *bool) func(*badger.Txn) error
- func RetrieveEpochCommit(eventID flow.Identifier, event *flow.EpochCommit) func(*badger.Txn) error
- func RetrieveEpochEmergencyFallbackTriggeredBlockID(blockID *flow.Identifier) 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 RetrieveJobAtIndex(queue string, index uint64, entity *flow.Identifier) func(*badger.Txn) error
- func RetrieveJobLatestIndex(queue string, index *uint64) func(*badger.Txn) error
- func RetrieveLastCompleteBlockHeight(height *uint64) func(*badger.Txn) error
- func RetrieveMyBeaconPrivateKey(epochCounter uint64, info *encodable.RandomBeaconPrivKey) func(*badger.Txn) error
- func RetrieveProcessedIndex(jobName string, processed *uint64) func(*badger.Txn) error
- func RetrieveProtocolVersion(version *uint) func(*badger.Txn) error
- func RetrieveResultApproval(approvalID flow.Identifier, approval *flow.ResultApproval) func(*badger.Txn) error
- func RetrieveRootHeight(height *uint64) func(*badger.Txn) error
- func RetrieveRootQuorumCertificate(qc *flow.QuorumCertificate) func(txn *badger.Txn) error
- func RetrieveSeal(sealID flow.Identifier, seal *flow.Seal) func(*badger.Txn) error
- func RetrieveSealedHeight(height *uint64) func(*badger.Txn) error
- func RetrieveSporkID(sporkID *flow.Identifier) 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 RetrieveTransactionResultByIndex(blockID flow.Identifier, txIndex uint32, ...) 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 RetryOnConflictTx(db *badger.DB, action func(*badger.DB, func(*transaction.Tx) error) error, ...) error
- func SetEpochEmergencyFallbackTriggered(blockID flow.Identifier) func(txn *badger.Txn) error
- func SetJobLatestIndex(queue string, index uint64) func(*badger.Txn) error
- func SetMax(tx storage.Transaction) error
- func SetProcessedIndex(jobName string, processed uint64) func(*badger.Txn) error
- func SkipDuplicates(op func(*badger.Txn) error) func(tx *badger.Txn) error
- func SkipNonExist(op func(*badger.Txn) error) func(tx *badger.Txn) error
- func UpdateBlockChildren(blockID flow.Identifier, childrenIDs flow.IdentifierList) func(*badger.Txn) error
- func UpdateClusterFinalizedHeight(clusterID flow.ChainID, number uint64) func(*badger.Txn) error
- func UpdateComputationResultUploadStatus(blockID flow.Identifier, wasUploadCompleted bool) 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
- func UpsertComputationResultUploadStatus(blockID flow.Identifier, wasUploadCompleted bool) func(*badger.Txn) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BatchIndexBlockByChunkID ¶
func BatchIndexBlockByChunkID(blockID, chunkID flow.Identifier) func(batch *badger.WriteBatch) error
BatchIndexBlockByChunkID indexes blockID by chunkID into a batch
func BatchIndexExecutionReceipts ¶
func BatchIndexExecutionReceipts(blockID, receiptID flow.Identifier) func(batch *badger.WriteBatch) error
BatchIndexExecutionReceipts inserts an execution receipt ID keyed by block ID and receipt ID into a batch
func BatchIndexExecutionResult ¶
func BatchIndexExecutionResult(blockID flow.Identifier, resultID flow.Identifier) func(batch *badger.WriteBatch) error
BatchIndexExecutionResult inserts an execution result ID keyed by block ID into a batch
func BatchIndexOwnExecutionReceipt ¶
func BatchIndexOwnExecutionReceipt(blockID flow.Identifier, receiptID flow.Identifier) func(batch *badger.WriteBatch) error
BatchIndexOwnExecutionReceipt inserts an execution receipt ID keyed by block ID into a batch TODO: rename to BatchUpdate
func BatchIndexStateCommitment ¶
func BatchIndexStateCommitment(blockID flow.Identifier, commit flow.StateCommitment) func(batch *badger.WriteBatch) error
BatchIndexStateCommitment indexes a state commitment into a batch
State commitments are keyed by the block whose execution results in the state with the given commit.
func BatchIndexTransactionResult ¶
func BatchIndexTransactionResult(blockID flow.Identifier, txIndex uint32, transactionResult *flow.TransactionResult) func(batch *badger.WriteBatch) error
func BatchInsertChunkDataPack ¶
func BatchInsertChunkDataPack(c *badgermodel.StoredChunkDataPack) func(batch *badger.WriteBatch) error
BatchInsertChunkDataPack inserts a chunk data pack keyed by chunk ID into a batch
func BatchInsertEvent ¶
func BatchInsertEvent(blockID flow.Identifier, event flow.Event) func(batch *badger.WriteBatch) error
func BatchInsertExecutionReceiptMeta ¶
func BatchInsertExecutionReceiptMeta(receiptID flow.Identifier, meta *flow.ExecutionReceiptMeta) func(batch *badger.WriteBatch) error
BatchInsertExecutionReceiptMeta inserts an execution receipt meta by ID. TODO: rename to BatchUpdate
func BatchInsertExecutionResult ¶
func BatchInsertExecutionResult(result *flow.ExecutionResult) func(batch *badger.WriteBatch) error
BatchInsertExecutionResult inserts an execution result by ID.
func BatchInsertServiceEvent ¶
func BatchInsertServiceEvent(blockID flow.Identifier, event flow.Event) func(batch *badger.WriteBatch) error
func BatchInsertTransactionResult ¶
func BatchInsertTransactionResult(blockID flow.Identifier, transactionResult *flow.TransactionResult) func(batch *badger.WriteBatch) error
func BatchRemoveBlockIDByChunkID ¶
func BatchRemoveBlockIDByChunkID(chunkID flow.Identifier) func(batch *badger.WriteBatch) error
BatchRemoveBlockIDByChunkID removes chunkID-to-blockID index entries keyed by a chunkID in a provided batch. No errors are expected during normal operation, even if no entries are matched. If Badger unexpectedly fails to process the request, the error is wrapped in a generic error and returned.
func BatchRemoveChunkDataPack ¶
func BatchRemoveChunkDataPack(chunkID flow.Identifier) func(batch *badger.WriteBatch) error
BatchRemoveChunkDataPack removes a chunk data pack keyed by chunk ID, in a batch. No errors are expected during normal operation, even if no entries are matched. If Badger unexpectedly fails to process the request, the error is wrapped in a generic error and returned.
func BatchRemoveEventsByBlockID ¶
func BatchRemoveEventsByBlockID(blockID flow.Identifier, batch *badger.WriteBatch) func(*badger.Txn) error
BatchRemoveEventsByBlockID removes all events for the given blockID. No errors are expected during normal operation, even if no entries are matched. If Badger unexpectedly fails to process the request, the error is wrapped in a generic error and returned.
func BatchRemoveExecutionResultIndex ¶
func BatchRemoveExecutionResultIndex(blockID flow.Identifier) func(*badger.WriteBatch) error
BatchRemoveExecutionResultIndex removes blockID-to-resultID index entries keyed by a blockID in a provided batch. No errors are expected during normal operation, even if no entries are matched. If Badger unexpectedly fails to process the request, the error is wrapped in a generic error and returned.
func BatchRemoveOwnExecutionReceipt ¶
func BatchRemoveOwnExecutionReceipt(blockID flow.Identifier) func(batch *badger.WriteBatch) error
BatchRemoveOwnExecutionReceipt removes blockID-to-my-receiptID index entries keyed by a blockID in a provided batch. No errors are expected during normal operation, but it may return generic error if badger fails to process request
func BatchRemoveServiceEventsByBlockID ¶
func BatchRemoveServiceEventsByBlockID(blockID flow.Identifier, batch *badger.WriteBatch) func(*badger.Txn) error
BatchRemoveServiceEventsByBlockID removes all service events for the given blockID. No errors are expected during normal operation, even if no entries are matched. If Badger unexpectedly fails to process the request, the error is wrapped in a generic error and returned.
func BatchRemoveStateCommitment ¶
func BatchRemoveStateCommitment(blockID flow.Identifier) func(batch *badger.WriteBatch) error
BatchRemoveStateCommitment batch removes the state commitment by block ID No errors are expected during normal operation, even if no entries are matched. If Badger unexpectedly fails to process the request, the error is wrapped in a generic error and returned.
func BatchRemoveTransactionResultsByBlockID ¶
func BatchRemoveTransactionResultsByBlockID(blockID flow.Identifier, batch *badger.WriteBatch) func(*badger.Txn) error
BatchRemoveTransactionResultsByBlockID removes transaction results for the given blockID in a provided batch. No errors are expected during normal operation, but it may return generic error if badger fails to process request
func CheckEpochEmergencyFallbackTriggered ¶
CheckEpochEmergencyFallbackTriggered retrieves the value of the flag indicating whether epoch emergency fallback has been triggered. If the key is not set, this results in triggered being set to false.
func EnsurePublicDB ¶
func EnsurePublicDB(db *badger.DB) error
func EnsureSecretDB ¶
func EnsureSecretDB(db *badger.DB) 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 GetBlockIDsByStatus ¶
func GetBlockIDsByStatus(blockIDs *[]flow.Identifier, targetUploadStatus bool) func(*badger.Txn) error
GetBlockIDsByStatus returns all IDs of stored ComputationResult instances.
func GetComputationResultUploadStatus ¶
func GetComputationResultUploadStatus(blockID flow.Identifier, wasUploadCompleted *bool) func(*badger.Txn) error
GetComputationResult returns stored ComputationResult instance with given ID.
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 IndexBlockIDByChunkID ¶
func IndexBlockIDByChunkID(chunkID, blockID flow.Identifier) func(*badger.Txn) error
func IndexClusterBlockByReferenceHeight ¶
func IndexClusterBlockByReferenceHeight(refHeight uint64, clusterBlockID flow.Identifier) func(*badger.Txn) error
IndexClusterBlockByReferenceHeight indexes a cluster block ID by its reference block height. The cluster block ID is included in the key for more efficient traversal. Only finalized cluster blocks should be included in this index. The key looks like: <prefix 0:1><ref_height 1:9><cluster_block_id 9:41>
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 IndexExecutionReceipts ¶
func IndexExecutionReceipts(blockID, receiptID flow.Identifier) func(*badger.Txn) error
IndexExecutionReceipts inserts an execution receipt ID keyed by block ID and receipt ID. one block could have multiple receipts, even if they are from the same executor
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 IndexFinalizedSealByBlockID ¶
func IndexFinalizedSealByBlockID(sealedBlockID flow.Identifier, sealID flow.Identifier) func(*badger.Txn) error
IndexFinalizedSealByBlockID indexes the _finalized_ seal by the sealed block ID. Example: A <- B <- C(SealA) when block C is finalized, we create the index `A.ID->SealA.ID`
func IndexLatestSealAtBlock ¶
func IndexLatestSealAtBlock(blockID flow.Identifier, sealID flow.Identifier) func(*badger.Txn) error
IndexLatestSealAtBlock persists the highest seal that was included in the fork up to (and including) blockID. In most cases, it is the highest seal included in this block's payload. However, if there are no seals in this block, sealID should reference the highest seal in blockID's ancestor.
func IndexOwnExecutionReceipt ¶
func IndexOwnExecutionReceipt(blockID flow.Identifier, receiptID flow.Identifier) func(*badger.Txn) error
IndexOwnExecutionReceipt inserts an execution receipt ID keyed by block ID
func IndexPayloadGuarantees ¶
func IndexPayloadGuarantees(blockID flow.Identifier, guarIDs []flow.Identifier) func(*badger.Txn) error
func IndexPayloadReceipts ¶
func IndexPayloadReceipts(blockID flow.Identifier, receiptIDs []flow.Identifier) func(*badger.Txn) error
func IndexPayloadResults ¶
func IndexPayloadResults(blockID flow.Identifier, resultIDs []flow.Identifier) func(*badger.Txn) error
func IndexPayloadSeals ¶
func IndexPayloadSeals(blockID flow.Identifier, sealIDs []flow.Identifier) func(*badger.Txn) error
func IndexReferenceBlockByClusterBlock ¶
func IndexReferenceBlockByClusterBlock(clusterBlockID, refID flow.Identifier) func(*badger.Txn) error
IndexReferenceBlockByClusterBlock inserts the reference block ID for the given cluster block ID. While each cluster block specifies a reference block in its payload, we maintain this additional lookup for performance reasons.
func IndexResultApproval ¶
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 InitJobLatestIndex ¶
func InitMax ¶
func InitMax(tx *badger.Txn) error
InitMax retrieves the maximum key length to have it internally in the package after restarting. No errors are expected during normal operation.
func InsertBlockChildren ¶
func InsertBlockChildren(blockID flow.Identifier, childrenIDs flow.IdentifierList) 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 *badgermodel.StoredChunkDataPack) func(*badger.Txn) error
InsertChunkDataPack inserts a chunk data pack keyed by chunk ID.
func InsertChunkLocator ¶
func InsertClusterFinalizedHeight ¶
InsertClusterFinalizedHeight inserts the finalized boundary for the given cluster.
func InsertCollection ¶
func InsertCollection(collection *flow.LightCollection) func(*badger.Txn) error
func InsertComputationResultUploadStatus ¶
func InsertComputationResultUploadStatus(blockID flow.Identifier, wasUploadCompleted bool) func(*badger.Txn) error
InsertComputationResult addes given instance of ComputationResult into local BadgerDB.
func InsertDKGEndStateForEpoch ¶
func InsertDKGEndStateForEpoch(epochCounter uint64, endState flow.DKGEndState) func(*badger.Txn) error
InsertDKGEndStateForEpoch stores the DKG end state for the epoch.
func InsertDKGStartedForEpoch ¶
InsertDKGStartedForEpoch stores a flag indicating that the DKG has been started for the given epoch.
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 ¶
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 InsertJobAtIndex ¶
func InsertJobAtIndex(queue string, index uint64, entity flow.Identifier) func(*badger.Txn) error
InsertJobAtIndex insert an entity ID at the given index
func InsertLastCompleteBlockHeightIfNotExists ¶
InsertLastCompleteBlockHeightIfNotExists inserts the last full block height if it is not already set. Calling this function multiple times is a no-op and returns no expected errors.
func InsertMyBeaconPrivateKey ¶
func InsertMyBeaconPrivateKey(epochCounter uint64, info *encodable.RandomBeaconPrivKey) func(*badger.Txn) error
InsertMyBeaconPrivateKey stores the random beacon private key for the given epoch.
CAUTION: This method stores confidential information and should only be used in the context of the secrets database. This is enforced in the above layer (see storage.DKGState).
func InsertProcessedIndex ¶
func InsertProtocolVersion ¶
InsertProtocolVersion inserts the protocol version for the present spork. A single database and protocol state instance spans at most one spork, and a spork has exactly one protocol version for its duration, so this is inserted exactly once, when bootstrapping the state.
func InsertPublicDBMarker ¶
func InsertPublicDBMarker(txn *badger.Txn) error
func InsertResultApproval ¶
func InsertResultApproval(approval *flow.ResultApproval) func(*badger.Txn) error
InsertResultApproval inserts a ResultApproval by ID.
func InsertRootHeight ¶
func InsertRootQuorumCertificate ¶
func InsertRootQuorumCertificate(qc *flow.QuorumCertificate) func(txn *badger.Txn) error
InsertRootQuorumCertificate inserts the root quorum certificate for the local blockchain state. The root quorum certificate certifies the root block and is used to bootstrap HotStuff.
Only the root quorum certificate must be explicitly stored in this way! All other quorum certificates are implicitly included in the child of block they certify in the ParentSigs field.
func InsertSeal ¶
func InsertSeal(sealID flow.Identifier, seal *flow.Seal) func(*badger.Txn) error
func InsertSealedHeight ¶
func InsertSecretDBMarker ¶
func InsertSecretDBMarker(txn *badger.Txn) error
func InsertServiceEvent ¶
func InsertServiceEvent(blockID flow.Identifier, event flow.Event) func(*badger.Txn) error
func InsertSporkID ¶
func InsertSporkID(sporkID flow.Identifier) func(*badger.Txn) error
InsertSporkID inserts the spork ID for the present spork. A single database and protocol state instance spans at most one spork, so this is inserted exactly once, when bootstrapping the state.
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
LookupBlockHeight retrieves finalized blocks by height.
func LookupBlockIDByChunkID ¶
func LookupBlockIDByChunkID(chunkID flow.Identifier, blockID *flow.Identifier) func(*badger.Txn) error
LookupBlockIDByChunkID looks up a block by a collection within that block.
func LookupBySealedBlockID ¶
func LookupBySealedBlockID(sealedBlockID flow.Identifier, sealID *flow.Identifier) func(*badger.Txn) error
LookupBySealedBlockID finds the seal for the given sealed block ID.
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 LookupClusterBlocksByReferenceHeightRange ¶
func LookupClusterBlocksByReferenceHeightRange(start, end uint64, clusterBlockIDs *[]flow.Identifier) func(*badger.Txn) error
LookupClusterBlocksByReferenceHeightRange traverses the ref_height->cluster_block index and returns any finalized cluster blocks which have a reference block with height in the given range. This is used to avoid including duplicate transaction when building or validating a new collection.
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 LookupEventsByBlockID ¶
func LookupEventsByBlockID(blockID flow.Identifier, events *[]flow.Event) func(*badger.Txn) error
func LookupExecutionReceipts ¶
func LookupExecutionReceipts(blockID flow.Identifier, receiptIDs *[]flow.Identifier) func(*badger.Txn) error
LookupExecutionReceipts finds all execution receipts by block ID
func LookupExecutionResult ¶
func LookupExecutionResult(blockID flow.Identifier, resultID *flow.Identifier) func(*badger.Txn) error
LookupExecutionResult finds execution result ID by block
func LookupLatestSealAtBlock ¶
func LookupLatestSealAtBlock(blockID flow.Identifier, sealID *flow.Identifier) func(*badger.Txn) error
LookupLatestSealAtBlock finds the highest seal that was included in the fork up to (and including) blockID. In most cases, it is the highest seal included in this block's payload. However, if there are no seals in this block, sealID should reference the highest seal in blockID's ancestor.
func LookupOwnExecutionReceipt ¶
func LookupOwnExecutionReceipt(blockID flow.Identifier, receiptID *flow.Identifier) func(*badger.Txn) error
LookupOwnExecutionReceipt finds execution receipt ID by block
func LookupPayloadGuarantees ¶
func LookupPayloadGuarantees(blockID flow.Identifier, guarIDs *[]flow.Identifier) func(*badger.Txn) error
func LookupPayloadReceipts ¶
func LookupPayloadReceipts(blockID flow.Identifier, receiptIDs *[]flow.Identifier) func(*badger.Txn) error
func LookupPayloadResults ¶
func LookupPayloadResults(blockID flow.Identifier, resultIDs *[]flow.Identifier) func(*badger.Txn) error
func LookupPayloadSeals ¶
func LookupPayloadSeals(blockID flow.Identifier, sealIDs *[]flow.Identifier) func(*badger.Txn) error
func LookupReferenceBlockByClusterBlock ¶
func LookupReferenceBlockByClusterBlock(clusterBlockID flow.Identifier, refID *flow.Identifier) func(*badger.Txn) error
LookupReferenceBlockByClusterBlock looks up the reference block ID for the given cluster block ID. While each cluster block specifies a reference block in its payload, we maintain this additional lookup for performance reasons.
func LookupResultApproval ¶
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 ¶
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 LookupTransactionResultsByBlockIDUsingIndex ¶
func LookupTransactionResultsByBlockIDUsingIndex(blockID flow.Identifier, txResults *[]flow.TransactionResult) func(*badger.Txn) error
LookupTransactionResultsByBlockIDUsingIndex retrieves all tx results for a block, but using tx_index index. This correctly handles cases of duplicate transactions within block, and should eventually replace uses of LookupTransactionResultsByBlockID
func PersistBlocklist ¶
func PersistBlocklist(blocklist map[flow.Identifier]struct{}) func(*badger.Txn) error
PersistBlocklist writes the set of blocked nodes IDs into the data base. If an entry already exists, it is overwritten; otherwise a new entry is created. No errors are expected during normal operations.
TODO: TEMPORARY manual override for adding node IDs to list of ejected nodes, applies to networking layer only
func PurgeBlocklist ¶
func PurgeBlocklist() func(*badger.Txn) error
PurgeBlocklist removes the set of blocked nodes IDs from the data base. If no corresponding entry exists, this function is a no-op. No errors are expected during normal operations. TODO: TEMPORARY manual override for adding node IDs to list of ejected nodes, applies to networking layer only
func ReindexExecutionResult ¶
func ReindexExecutionResult(blockID flow.Identifier, resultID flow.Identifier) func(*badger.Txn) error
ReindexExecutionResult updates mapping of an execution result ID keyed by block ID
func RemoveBlockIDByChunkID ¶
func RemoveBlockIDByChunkID(chunkID flow.Identifier) func(*badger.Txn) error
RemoveBlockIDByChunkID removes chunkID-blockID index by chunkID
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 RemoveComputationResultUploadStatus ¶
func RemoveComputationResultUploadStatus( blockID flow.Identifier) func(*badger.Txn) error
RemoveComputationResult removes an instance of ComputationResult with given ID.
func RemoveEventsByBlockID ¶
func RemoveEventsByBlockID(blockID flow.Identifier) func(*badger.Txn) error
func RemoveExecutionForkEvidence ¶
func RemoveExecutionForkEvidence() func(*badger.Txn) error
func RemoveExecutionResultIndex ¶
func RemoveExecutionResultIndex(blockID flow.Identifier) func(*badger.Txn) error
RemoveExecutionResultIndex removes execution result indexed by the given blockID
func RemoveOwnExecutionReceipt ¶
func RemoveOwnExecutionReceipt(blockID flow.Identifier) func(*badger.Txn) error
RemoveOwnExecutionReceipt removes own execution receipt index by blockID
func RemoveServiceEventsByBlockID ¶
func RemoveServiceEventsByBlockID(blockID flow.Identifier) func(*badger.Txn) error
func RemoveStateCommitment ¶
func RemoveStateCommitment(blockID flow.Identifier) func(*badger.Txn) error
RemoveStateCommitment removes the state commitment by block ID
func RemoveTransactionResultsByBlockID ¶
func RemoveTransactionResultsByBlockID(blockID flow.Identifier) func(*badger.Txn) error
RemoveTransactionResultsByBlockID removes the transaction results for the given blockID
func RetrieveBlockChildren ¶
func RetrieveBlockChildren(blockID flow.Identifier, childrenIDs *flow.IdentifierList) 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 RetrieveBlocklist ¶
func RetrieveBlocklist(blocklist *map[flow.Identifier]struct{}) func(*badger.Txn) error
RetrieveBlocklist reads the set of blocked node IDs from the data base. Returns `storage.ErrNotFound` error in case no respective data base entry is present.
TODO: TEMPORARY manual override for adding node IDs to list of ejected nodes, applies to networking layer only
func RetrieveChunkDataPack ¶
func RetrieveChunkDataPack(chunkID flow.Identifier, c *badgermodel.StoredChunkDataPack) func(*badger.Txn) error
RetrieveChunkDataPack retrieves a chunk data pack by chunk ID.
func RetrieveChunkLocator ¶
func RetrieveChunkLocator(locatorID flow.Identifier, locator *chunks.Locator) func(*badger.Txn) error
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 RetrieveDKGEndStateForEpoch ¶
func RetrieveDKGEndStateForEpoch(epochCounter uint64, endState *flow.DKGEndState) func(*badger.Txn) error
RetrieveDKGEndStateForEpoch retrieves the DKG end state for the epoch.
func RetrieveDKGStartedForEpoch ¶
RetrieveDKGStartedForEpoch retrieves the DKG started flag for the given epoch. If no flag is set, started is set to false.
func RetrieveEpochCommit ¶
func RetrieveEpochCommit(eventID flow.Identifier, event *flow.EpochCommit) func(*badger.Txn) error
func RetrieveEpochEmergencyFallbackTriggeredBlockID ¶
func RetrieveEpochEmergencyFallbackTriggeredBlockID(blockID *flow.Identifier) func(*badger.Txn) error
RetrieveEpochEmergencyFallbackTriggeredBlockID gets the block ID where epoch emergency was triggered.
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 ¶
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 RetrieveJobAtIndex ¶
func RetrieveJobAtIndex(queue string, index uint64, entity *flow.Identifier) func(*badger.Txn) error
RetrieveJobAtIndex returns the entity at the given index
func RetrieveJobLatestIndex ¶
func RetrieveMyBeaconPrivateKey ¶
func RetrieveMyBeaconPrivateKey(epochCounter uint64, info *encodable.RandomBeaconPrivKey) func(*badger.Txn) error
RetrieveMyBeaconPrivateKey retrieves the random beacon private key for the given epoch.
CAUTION: This method stores confidential information and should only be used in the context of the secrets database. This is enforced in the above layer (see storage.DKGState).
func RetrieveProcessedIndex ¶
RetrieveProcessedIndex returns the processed index for a job consumer
func RetrieveProtocolVersion ¶
RetrieveProtocolVersion retrieves the protocol version for the present spork.
func RetrieveResultApproval ¶
func RetrieveResultApproval(approvalID flow.Identifier, approval *flow.ResultApproval) func(*badger.Txn) error
RetrieveResultApproval retrieves an approval by ID.
func RetrieveRootHeight ¶
func RetrieveRootQuorumCertificate ¶
func RetrieveRootQuorumCertificate(qc *flow.QuorumCertificate) func(txn *badger.Txn) error
func RetrieveSeal ¶
func RetrieveSeal(sealID flow.Identifier, seal *flow.Seal) func(*badger.Txn) error
func RetrieveSealedHeight ¶
func RetrieveSporkID ¶
func RetrieveSporkID(sporkID *flow.Identifier) func(*badger.Txn) error
RetrieveSporkID retrieves the spork ID for the present spork.
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 RetrieveTransactionResultByIndex ¶
func RetrieveTransactionResultByIndex(blockID flow.Identifier, txIndex uint32, transactionResult *flow.TransactionResult) func(*badger.Txn) error
func RetrieveVotedView ¶
RetrieveVotedView retrieves a view from the database.
func RetryOnConflict ¶
func RetryOnConflictTx ¶
func RetryOnConflictTx(db *badger.DB, action func(*badger.DB, func(*transaction.Tx) error) error, op func(*transaction.Tx) error) error
func SetEpochEmergencyFallbackTriggered ¶
func SetEpochEmergencyFallbackTriggered(blockID flow.Identifier) func(txn *badger.Txn) error
SetEpochEmergencyFallbackTriggered sets a flag in the DB indicating that epoch emergency fallback has been triggered, and the block where it was triggered. EECC can be triggered by 2 blocks:
1. The first block of a new epoch, when that epoch has not been set up. 2. The block where an invalid service event is being applied to the state.
Calling this function multiple times is a no-op and returns no expected errors.
func SetJobLatestIndex ¶
func SetMax ¶
func SetMax(tx storage.Transaction) error
SetMax sets the value for the maximum key length used for efficient iteration. No errors are expected during normal operation.
func SetProcessedIndex ¶
SetProcessedIndex updates the processed index for a job consumer with given index
func SkipDuplicates ¶
func SkipNonExist ¶
func UpdateBlockChildren ¶
func UpdateBlockChildren(blockID flow.Identifier, childrenIDs flow.IdentifierList) func(*badger.Txn) error
UpdateBlockChildren updates the children for a block.
func UpdateClusterFinalizedHeight ¶
UpdateClusterFinalizedHeight updates the finalized boundary for the given cluster.
func UpdateComputationResultUploadStatus ¶
func UpdateComputationResultUploadStatus(blockID flow.Identifier, wasUploadCompleted bool) func(*badger.Txn) error
UpdateComputationResult updates given existing instance of ComputationResult in local BadgerDB.
func UpdateExecutedBlock ¶
func UpdateExecutedBlock(blockID flow.Identifier) func(*badger.Txn) error
func UpdateFinalizedHeight ¶
func UpdateSealedHeight ¶
func UpdateStartedView ¶
UpdateStartedView updates the view in the database.
func UpdateVotedView ¶
UpdateVotedView updates the view in the database.
func UpsertComputationResultUploadStatus ¶
func UpsertComputationResultUploadStatus(blockID flow.Identifier, wasUploadCompleted bool) func(*badger.Txn) error
UpsertComputationResult upserts given existing instance of ComputationResult in local BadgerDB.
Types ¶
This section is empty.
Source Files ¶
- approvals.go
- bft.go
- children.go
- chunkDataPacks.go
- chunk_locators.go
- cluster.go
- collections.go
- commits.go
- common.go
- computation_result.go
- dkg.go
- epoch.go
- events.go
- guarantees.go
- headers.go
- heights.go
- init.go
- interactions.go
- jobs.go
- max.go
- modifiers.go
- prefix.go
- receipts.go
- results.go
- root_qc.go
- seals.go
- spork.go
- transaction_results.go
- transactions.go
- views.go