Documentation
¶
Index ¶
- type ChainedCommits
- type ChainedEvents
- func (c *ChainedEvents) ByBlockID(blockID flow.Identifier) ([]flow.Event, error)
- func (c *ChainedEvents) ByBlockIDEventType(blockID flow.Identifier, eventType flow.EventType) ([]flow.Event, error)
- func (c *ChainedEvents) ByBlockIDTransactionID(blockID flow.Identifier, transactionID flow.Identifier) ([]flow.Event, error)
- func (c *ChainedEvents) ByBlockIDTransactionIndex(blockID flow.Identifier, txIndex uint32) ([]flow.Event, error)
- type ChainedExecutionResults
- func (c *ChainedExecutionResults) ByBlockID(blockID flow.Identifier) (*flow.ExecutionResult, error)
- func (c *ChainedExecutionResults) ByID(resultID flow.Identifier) (*flow.ExecutionResult, error)
- func (c *ChainedExecutionResults) ByIDTx(resultID flow.Identifier) func(*transaction.Tx) (*flow.ExecutionResult, error)
- type ChainedTransactionResults
- func (c *ChainedTransactionResults) ByBlockID(id flow.Identifier) ([]flow.TransactionResult, error)
- func (c *ChainedTransactionResults) ByBlockIDTransactionID(blockID flow.Identifier, transactionID flow.Identifier) (*flow.TransactionResult, error)
- func (c *ChainedTransactionResults) ByBlockIDTransactionIndex(blockID flow.Identifier, txIndex uint32) (*flow.TransactionResult, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChainedCommits ¶
type ChainedCommits struct {
// contains filtered or unexported fields
}
func NewCommits ¶
func NewCommits(first storage.CommitsReader, second storage.CommitsReader) *ChainedCommits
NewCommits returns a new ChainedCommits commits store, which will handle reads, which only implements read operations for reads, it first query the first database, then the second database, this is useful when migrating data from badger to pebble
func (*ChainedCommits) ByBlockID ¶
func (c *ChainedCommits) ByBlockID(blockID flow.Identifier) (flow.StateCommitment, error)
type ChainedEvents ¶
type ChainedEvents struct {
// contains filtered or unexported fields
}
func NewEvents ¶
func NewEvents(first storage.EventsReader, second storage.EventsReader) *ChainedEvents
NewEvents returns a new ChainedEvents events store, which will handle reads, which only implements read operations for reads, it first query the first database, then the second database, this is useful when migrating data from badger to pebble
func (*ChainedEvents) ByBlockID ¶
func (c *ChainedEvents) ByBlockID(blockID flow.Identifier) ([]flow.Event, error)
func (*ChainedEvents) ByBlockIDEventType ¶
func (c *ChainedEvents) ByBlockIDEventType(blockID flow.Identifier, eventType flow.EventType) ([]flow.Event, error)
func (*ChainedEvents) ByBlockIDTransactionID ¶
func (c *ChainedEvents) ByBlockIDTransactionID(blockID flow.Identifier, transactionID flow.Identifier) ([]flow.Event, error)
func (*ChainedEvents) ByBlockIDTransactionIndex ¶
func (c *ChainedEvents) ByBlockIDTransactionIndex(blockID flow.Identifier, txIndex uint32) ([]flow.Event, error)
type ChainedExecutionResults ¶
type ChainedExecutionResults struct {
// contains filtered or unexported fields
}
func NewExecutionResults ¶
func NewExecutionResults(first storage.ExecutionResultsReader, second storage.ExecutionResultsReader) *ChainedExecutionResults
NewResults returns a new ChainedExecutionResults results store, which will handle reads. which only implements read operations for reads, it first query the first database, then the second database, this is useful when migrating data from badger to pebble
func (*ChainedExecutionResults) ByBlockID ¶
func (c *ChainedExecutionResults) ByBlockID(blockID flow.Identifier) (*flow.ExecutionResult, error)
func (*ChainedExecutionResults) ByID ¶
func (c *ChainedExecutionResults) ByID(resultID flow.Identifier) (*flow.ExecutionResult, error)
func (*ChainedExecutionResults) ByIDTx ¶
func (c *ChainedExecutionResults) ByIDTx(resultID flow.Identifier) func(*transaction.Tx) (*flow.ExecutionResult, error)
type ChainedTransactionResults ¶
type ChainedTransactionResults struct {
// contains filtered or unexported fields
}
func NewTransactionResults ¶
func NewTransactionResults(first storage.TransactionResultsReader, second storage.TransactionResultsReader) *ChainedTransactionResults
NewTransactionResults returns a new ChainedTransactionResults transaction results store, which only implements read operations it first queries the first database, then the second database. this is useful when migrating data from badger to pebble
func (*ChainedTransactionResults) ByBlockID ¶
func (c *ChainedTransactionResults) ByBlockID(id flow.Identifier) ([]flow.TransactionResult, error)
ByBlockID gets all transaction results for a block, ordered by transaction index It returns storage.ErrNotFound if the result is not found any other errors are exceptions
func (*ChainedTransactionResults) ByBlockIDTransactionID ¶
func (c *ChainedTransactionResults) ByBlockIDTransactionID(blockID flow.Identifier, transactionID flow.Identifier) (*flow.TransactionResult, error)
ByBlockIDTransactionID returns the runtime transaction result for the given block ID and transaction ID It returns storage.ErrNotFound if the result is not found any other errors are exceptions
func (*ChainedTransactionResults) ByBlockIDTransactionIndex ¶
func (c *ChainedTransactionResults) ByBlockIDTransactionIndex(blockID flow.Identifier, txIndex uint32) (*flow.TransactionResult, error)
ByBlockIDTransactionIndex returns the runtime transaction result for the given block ID and transaction index It returns storage.ErrNotFound if the result is not found any other errors are exceptions
Source Files