storage

package
v1.4.8 Latest Latest
Warning

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

 Go to latest Published: Oct 28, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PrefixFirst = 1
	PrefixLast  = 2

	PrefixHeightForBlock       = 7
	PrefixHeightForTransaction = 16

	PrefixCommit  = 4
	PrefixHeader  = 3
	PrefixEvents  = 5
	PrefixPayload = 6

	PrefixTransaction = 8
	PrefixCollection  = 10
	PrefixGuarantee   = 17

	PrefixTransactionsForHeight     = 9
	PrefixTransactionsForCollection = 12
	PrefixCollectionsForHeight      = 11
	PrefixResults                   = 13

	PrefixSeal           = 14
	PrefixSealsForHeight = 15
)

Variables

This section is empty.

Functions

func Combine 

func Combine(ops ...func(*badger.Txn) error) func(*badger.Txn) error

Combine goes through the provided operations until one of them fails. When the first one fails, the related error is returned.

func EncodeKey added in v1.4.7 

func EncodeKey(prefix uint8, segments ...interface{}) []byte

func Fallback 

func Fallback(ops ...func(*badger.Txn) error) func(*badger.Txn) error

Fallback goes through the provided operations until one of them succeeds. If all of them fail, a multi-error with all errors is returned.

Types

type Library 

type Library struct {
	// contains filtered or unexported fields
}

Library is the storage library.

func New 

func New(codec dps.Codec) *Library

New returns a new storage library using the given codec.

func (*Library) IndexCollectionsForHeight 

func (l *Library) IndexCollectionsForHeight(height uint64, collIDs []flow.Identifier) func(*badger.Txn) error

IndexCollectionsForHeight is an operation that indexes the height of a slice of collection identifiers.

func (*Library) IndexHeightForBlock 

func (l *Library) IndexHeightForBlock(blockID flow.Identifier, height uint64) func(*badger.Txn) error

IndexHeightForBlock is an operation that indexes the given height for its block identifier.

func (*Library) IndexHeightForTransaction added in v1.1.0 

func (l *Library) IndexHeightForTransaction(txID flow.Identifier, height uint64) func(*badger.Txn) error

IndexHeightForTransaction is an operation that writes the height a transaction identifier.

func (*Library) IndexSealsForHeight added in v1.1.0 

func (l *Library) IndexSealsForHeight(height uint64, sealIDs []flow.Identifier) func(*badger.Txn) error

IndexSealsForHeight is an operation that indexes the height of a slice of seal identifiers.

func (*Library) IndexTransactionsForCollection 

func (l *Library) IndexTransactionsForCollection(collID flow.Identifier, txIDs []flow.Identifier) func(*badger.Txn) error

IndexTransactionsForCollection is an operation that indexes the collection identifier to which a slice of transactions belongs.

func (*Library) IndexTransactionsForHeight 

func (l *Library) IndexTransactionsForHeight(height uint64, txIDs []flow.Identifier) func(*badger.Txn) error

IndexTransactionsForHeight is an operation that indexes the height of a slice of transaction identifiers.

func (*Library) IterateLedger added in v1.4.0 

func (l *Library) IterateLedger(exclude func(height uint64) bool, process func(path ledger.Path, payload *ledger.Payload) error) func(*badger.Txn) error

IterateLedger steps through the entire ledger for ledger keys and payloads and call the given callback for each of them.

func (*Library) LookupCollectionsForHeight 

func (l *Library) LookupCollectionsForHeight(height uint64, collIDs *[]flow.Identifier) func(*badger.Txn) error

LookupCollectionsForHeight retrieves the identifiers of collections at the given height.

func (*Library) LookupHeightForBlock 

func (l *Library) LookupHeightForBlock(blockID flow.Identifier, height *uint64) func(*badger.Txn) error

LookupHeightForBlock retrieves the height of the given block identifier.

func (*Library) LookupHeightForTransaction added in v1.1.0 

func (l *Library) LookupHeightForTransaction(txID flow.Identifier, height *uint64) func(*badger.Txn) error

LookupHeightForTransaction retrieves the height of the transaction with the given identifier.

func (*Library) LookupSealsForHeight added in v1.1.0 

func (l *Library) LookupSealsForHeight(height uint64, sealIDs *[]flow.Identifier) func(*badger.Txn) error

LookupSealsForHeight retrieves the identifiers of seals at the given height.

func (*Library) LookupTransactionsForCollection 

func (l *Library) LookupTransactionsForCollection(collID flow.Identifier, txIDs *[]flow.Identifier) func(*badger.Txn) error

LookupTransactionsForCollection retrieves the identifiers of transactions within the collection with the given identifier.

func (*Library) LookupTransactionsForHeight 

func (l *Library) LookupTransactionsForHeight(height uint64, txIDs *[]flow.Identifier) func(*badger.Txn) error

LookupTransactionsForHeight retrieves the identifiers of transactions at the given height.

func (*Library) RetrieveCollection 

func (l *Library) RetrieveCollection(collectionID flow.Identifier, collection *flow.LightCollection) func(*badger.Txn) error

RetrieveCollection retrieves the collection with the given identifier.

func (*Library) RetrieveCommit 

func (l *Library) RetrieveCommit(height uint64, commit *flow.StateCommitment) func(*badger.Txn) error

RetrieveCommit retrieves the commit at the given height.

func (*Library) RetrieveEvents 

func (l *Library) RetrieveEvents(height uint64, types []flow.EventType, events *[]flow.Event) func(*badger.Txn) error

RetrieveEvents retrieves the events at the given height that match with the specified types. If no types were provided, all events are retrieved.

func (*Library) RetrieveFirst 

func (l *Library) RetrieveFirst(height *uint64) func(*badger.Txn) error

RetrieveFirst retrieves the first indexed height.

func (*Library) RetrieveGuarantee added in v1.1.0 

func (l *Library) RetrieveGuarantee(collectionID flow.Identifier, guarantee *flow.CollectionGuarantee) func(*badger.Txn) error

RetrieveGuarantee retrieves the guarantee with the given collection identifier.

func (*Library) RetrieveHeader 

func (l *Library) RetrieveHeader(height uint64, header *flow.Header) func(*badger.Txn) error

RetrieveHeader retrieves the header at the given height.

func (*Library) RetrieveLast 

func (l *Library) RetrieveLast(height *uint64) func(*badger.Txn) error

RetrieveLast retrieves the last indexed height.

func (*Library) RetrievePayload 

func (l *Library) RetrievePayload(height uint64, path ledger.Path, payload *ledger.Payload) func(*badger.Txn) error

RetrievePayload retrieves the ledger payloads at the given height that match the given path.

func (*Library) RetrieveResult added in v1.1.0 

func (l *Library) RetrieveResult(txID flow.Identifier, result *flow.TransactionResult) func(*badger.Txn) error

RetrieveResult retrieves the result with the given transaction identifier.

func (*Library) RetrieveSeal added in v1.1.0 

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

RetrieveSeal retrieves the seal with the given identifier.

func (*Library) RetrieveTransaction 

func (l *Library) RetrieveTransaction(transactionID flow.Identifier, transaction *flow.TransactionBody) func(*badger.Txn) error

RetrieveTransaction retrieves the transaction with the given identifier.

func (*Library) SaveCollection 

func (l *Library) SaveCollection(collection *flow.LightCollection) func(*badger.Txn) error

SaveCollection is an operation that writes the given collection.

func (*Library) SaveCommit 

func (l *Library) SaveCommit(height uint64, commit flow.StateCommitment) func(*badger.Txn) error

SaveCommit is an operation that writes the height of a state commitment.

func (*Library) SaveEvents 

func (l *Library) SaveEvents(height uint64, typ flow.EventType, events []flow.Event) func(*badger.Txn) error

SaveEvents is an operation that writes the height and type of a slice of events.

func (*Library) SaveFirst 

func (l *Library) SaveFirst(height uint64) func(*badger.Txn) error

SaveFirst is an operation that writes the height of the first indexed block.

func (*Library) SaveGuarantee added in v1.1.0 

func (l *Library) SaveGuarantee(guarantee *flow.CollectionGuarantee) func(*badger.Txn) error

SaveGuarantee is an operation that writes the given guarantee.

func (*Library) SaveHeader 

func (l *Library) SaveHeader(height uint64, header *flow.Header) func(*badger.Txn) error

SaveHeader is an operation that writes the height of a header.

func (*Library) SaveLast 

func (l *Library) SaveLast(height uint64) func(*badger.Txn) error

SaveLast is an operation that writes the height of the last indexed block.

func (*Library) SavePayload 

func (l *Library) SavePayload(height uint64, path ledger.Path, payload *ledger.Payload) func(*badger.Txn) error

SavePayload is an operation that writes the height of a slice of paths and a slice of payloads.

func (*Library) SaveResult added in v1.1.0 

func (l *Library) SaveResult(result *flow.TransactionResult) func(*badger.Txn) error

SaveResult is an operation that writes the given transaction result.

func (*Library) SaveSeal added in v1.1.0 

func (l *Library) SaveSeal(seal *flow.Seal) func(*badger.Txn) error

SaveSeal is an operation that writes the given seal.

func (*Library) SaveTransaction 

func (l *Library) SaveTransaction(transaction *flow.TransactionBody) func(*badger.Txn) error

SaveTransaction is an operation that writes the given transaction.

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.