Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ExportBlockSignatures ¶
func ExportBlockSignatures(ctx context.Context, commit *tmtypes.Commit, validators *tmctypes.ResultValidators, db *sql.DB) error
ExportBlockSignatures ...
func ExportValidator ¶
ExportValidator exports validator
Types ¶
type Worker ¶
type Worker struct {
// contains filtered or unexported fields
}
Worker is the queue processor.
func NewWorker ¶
func NewWorker(cdc codec.Marshaler, amino *codec.LegacyAmino, queue <-chan int64, db *sql.DB, cp *client.Proxy) *Worker
NewWorker returns an intialized worker
func (*Worker) ExportBlock ¶
func (w *Worker) ExportBlock(ctx context.Context, b *tmctypes.ResultBlock, txs []*sdk.TxResponse, validators *tmctypes.ResultValidators, db *sql.DB) error
ExportBlock exports a block by processing it.
func (*Worker) WithGenesisHeight ¶
WithGenesisHeight sets the first block height
Click to show internal directories.
Click to hide internal directories.