Documentation
¶
Index ¶
- type Context
- type Worker
- func (w Worker) ExportBlock(b *tmctypes.ResultBlock, r *tmctypes.ResultBlockResults, txs []*types.Tx, ...) error
- func (w Worker) ExportCommit(commit *tmtypes.Commit, vals *tmctypes.ResultValidators) error
- func (w Worker) ExportTxs(txs []*types.Tx) error
- func (w Worker) HandleGenesis(genesisDoc *tmtypes.GenesisDoc, appState map[string]json.RawMessage) error
- func (w Worker) Process(height int64) error
- func (w Worker) ProcessIfNotExists(height int64) error
- func (w Worker) ProcessTransactions(height int64) error
- func (w Worker) SaveValidators(vals []*tmtypes.Validator) error
- func (w Worker) Start()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Context ¶
type Context struct {
EncodingConfig *params.EncodingConfig
Node node.Node
Database database.Database
Logger logging.Logger
Modules []modules.Module
}
Context represents the context that is shared among different workers
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 NewWorker ¶
func NewWorker(ctx *Context, queue types.HeightQueue, index int) Worker
NewWorker allows to create a new Worker implementation.
func (Worker) ExportBlock ¶
func (w Worker) ExportBlock( b *tmctypes.ResultBlock, r *tmctypes.ResultBlockResults, txs []*types.Tx, vals *tmctypes.ResultValidators, ) error
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) ExportCommit ¶
ExportCommit accepts a block commitment and a corresponding set of validators for the commitment and persists them to the database. An error is returned if any write fails or if there is any missing aggregated data.
func (Worker) ExportTxs ¶
ExportTxs accepts a slice of transactions and persists then inside the database. An error is returned if the write fails.
func (Worker) HandleGenesis ¶
func (w Worker) HandleGenesis(genesisDoc *tmtypes.GenesisDoc, appState map[string]json.RawMessage) error
HandleGenesis accepts a GenesisDoc and calls all the registered genesis handlers in the order in which they have been registered.
func (Worker) Process ¶
Process fetches a block for a given height and associated metadata and export it to a database. It returns an error if any export process fails.
func (Worker) ProcessIfNotExists ¶
ProcessIfNotExists defines the job consumer workflow. It will fetch a block for a given height and associated metadata and export it to a database if it does not exist yet. It returns an error if any export process fails.
func (Worker) ProcessTransactions ¶
ProcessTransactions fetches transactions for a given height and stores them into the database. It returns an error if the export process fails.
func (Worker) SaveValidators ¶
SaveValidators persists a list of Tendermint validators with an address and a consensus public key. An error is returned if the public key cannot be Bech32 encoded or if the DB write fails.
Source Files
Directories