runner

Documentation

Index

• Variables
• type ErrRecoverable
  • func (r *ErrRecoverable) Error() string
• type OpFunc
  • func WithClient(client *rpcclient.Client) OpFunc
  • func WithDB(db *dao.DB) OpFunc
  • func WithIndexerDB(db *indexer.DB) OpFunc
  • func WithStartHeight(height uint32) OpFunc
• type Opts
• type Runner
  • func NewRunner(opts ...OpFunc) *Runner
  • func (b *Runner) BlockParser()
  • func (b *Runner) Start()
  • func (b *Runner) UpdateRevealTx()

Variables

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

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