runner

package
v0.0.0-...-e5308b5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 18, 2024 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrDetectReorg = errors.New("unrecoverable reorg detected")

Functions

This section is empty.

Types

type ErrRecoverable

type ErrRecoverable struct {
	Height uint32
	Depth  uint32
}

func (*ErrRecoverable) Error

func (r *ErrRecoverable) Error() string

type OpFunc

type OpFunc func(*Opts)

func WithClient

func WithClient(client *rpcclient.Client) OpFunc

func WithDB

func WithDB(db *dao.DB) OpFunc

func WithIndexerDB

func WithIndexerDB(db *indexer.DB) OpFunc

func WithStartHeight

func WithStartHeight(height uint32) OpFunc

type Opts

type Opts struct {
	// contains filtered or unexported fields
}

type Runner

type Runner struct {
	Opts
	errgroup.Group
}

func NewRunner

func NewRunner(opts ...OpFunc) *Runner

func (*Runner) BlockParser

func (b *Runner) BlockParser()

func (*Runner) Start

func (b *Runner) Start()

func (*Runner) UpdateRevealTx

func (b *Runner) UpdateRevealTx()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL