Versions in this module Expand all Collapse all v0 v0.0.1 Jun 22, 2020 Changes in this version + const ShardsTruncationLeeway + var CompletedError = fmt.Errorf("batch completed") + type Indexer struct + StartBlockNum uint64 + StopBlockNum uint64 + Verbose bool + func NewIndexer(indexesStore dstore.Store, blocksStore dstore.Store, blockstreamAddr string, ...) *Indexer + func (i *Indexer) Bootstrap(startBlockNum uint64) error + func (i *Indexer) BuildBatchPipeline(targetStartBlockNum, fileSourceStartBlockNum uint64, ...) + func (i *Indexer) BuildLivePipeline(targetStartBlockNum, fileSourceStartBlockNum uint64, ...) + func (i *Indexer) Check(ctx context.Context, in *pbhealth.HealthCheckRequest) (*pbhealth.HealthCheckResponse, error) + func (i *Indexer) Launch() + func (i *Indexer) NextBaseBlockAfter(startBlockNum uint64) (nextStartBlockNum uint64) + type Pipeline struct + func (p *Pipeline) Bootstrap(startBlockNum uint64) error + func (p *Pipeline) Upload(baseIndex uint64, indexPath string) (err error) + func (p *Pipeline) WaitOnUploads() + func (pipe *Pipeline) ProcessBlock(blk *bstream.Block, objWrap interface{}) error + func (pipe *Pipeline) SetCatchUpMode() + type Truncator struct + func NewTruncator(indexer *Indexer, blockCount uint64) *Truncator + func (t *Truncator) Launch()