Documentation
¶
Index ¶
- Constants
- Variables
- type 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
- type Truncator
Constants ¶
View Source
const ShardsTruncationLeeway = 5
Variables ¶
View Source
var CompletedError = fmt.Errorf("batch completed")
Functions ¶
This section is empty.
Types ¶
type Indexer ¶
type Indexer struct { *shutter.Shutter StartBlockNum uint64 StopBlockNum uint64 Verbose bool // contains filtered or unexported fields }
func NewIndexer ¶
func (*Indexer) BuildBatchPipeline ¶
func (*Indexer) BuildLivePipeline ¶
func (*Indexer) Check ¶
func (i *Indexer) Check(ctx context.Context, in *pbhealth.HealthCheckRequest) (*pbhealth.HealthCheckResponse, error)
func (*Indexer) NextBaseBlockAfter ¶
type Pipeline ¶
type Pipeline struct {
// contains filtered or unexported fields
}
func (*Pipeline) ProcessBlock ¶
func (*Pipeline) SetCatchUpMode ¶
func (pipe *Pipeline) SetCatchUpMode()
func (*Pipeline) WaitOnUploads ¶
func (p *Pipeline) WaitOnUploads()
Click to show internal directories.
Click to hide internal directories.