Documentation ¶
Index ¶
- type Config
- type Worker
- func (w Worker) ExportBlock(b *flow.Block) error
- func (w Worker) ExportCollection(block *flow.Block) ([]types.Collection, error)
- func (w Worker) ExportTransactionResult(txids []flow.Identifier, height int64) error
- func (w Worker) ExportTx(txs *types.Txs) error
- func (w Worker) HandleGenesis(block *flow.Block) error
- func (w Worker) Start()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Worker ¶
type Worker struct {
// contains filtered or unexported fields
}
Worker defines a job consumer that is responsible for getting and aggregating block and associated data and exporting it to a database.
func (Worker) ExportBlock ¶
ExportBlock accepts a finalized block and a corresponding set of transactions and persists them to the database along with attributable metadata. An error is returned if the write fails.
func (Worker) ExportCollection ¶
func (w Worker) ExportCollection(block *flow.Block) ([]types.Collection, error)
func (Worker) ExportTransactionResult ¶
func (Worker) ExportTx ¶
ExportTxs accepts a slice of transactions and persists then inside the database. An error is returned if the write fails.
func (Worker) HandleGenesis ¶
HandleGenesis accepts a GenesisDoc and calls all the registered genesis handlers in the order in which they have been registered.
Click to show internal directories.
Click to hide internal directories.