workqueue

Documentation

Index

• func ExportBlockSignatures(ctx context.Context, commit *tmtypes.Commit, ...) error
• func ExportValidator(ctx context.Context, val *tmtypes.Validator, db *sql.DB) error
• func SetBlockSignature(ctx context.Context, commit *tmtypes.Commit, sig tmtypes.CommitSig, ...) error
• type Worker
  • func NewWorker(cdc codec.Marshaler, amino *codec.LegacyAmino, queue <-chan int64, db *sql.DB, ...) *Worker
  • func (w *Worker) ExportBlock(ctx context.Context, b *tmctypes.ResultBlock, txs []*sdk.TxResponse, ...) error
  • func (w *Worker) Start(ctx context.Context)
  • func (w *Worker) WithGenesisHeight(height int64)

Functions

func ExportBlockSignatures

func ExportBlockSignatures(ctx context.Context, commit *tmtypes.Commit, validators *tmctypes.ResultValidators, db *sql.DB) error

ExportBlockSignatures ...

func ExportValidator

func ExportValidator(ctx context.Context, val *tmtypes.Validator, db *sql.DB) error

ExportValidator exports validator

func SetBlockSignature

func SetBlockSignature(ctx context.Context, commit *tmtypes.Commit, sig tmtypes.CommitSig, vp, pp int64, db *sql.DB) error

SetBlockSignature stores a block prevote

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) Start

func (w *Worker) Start(ctx context.Context)

Start runs the listener that process blocks.

func (*Worker) WithGenesisHeight

func (w *Worker) WithGenesisHeight(height int64)

WithGenesisHeight sets the first block height