gap

Documentation

Index

• type Filler
  • func NewFiller(node lens.API, db *storage.Database, name string, minHeight, maxHeight int64, ...) *Filler
  • func (g *Filler) Done() <-chan struct{}
  • func (g *Filler) Run(ctx context.Context) error
• type Finder
  • func NewFinder(node lens.API, db *storage.Database, name string, minHeight, maxHeight int64, ...) *Finder
  • func (g *Finder) Done() <-chan struct{}
  • func (g *Finder) Find(ctx context.Context) (visor.GapReportList, error)
  • func (g *Finder) Run(ctx context.Context) error
• type Notifier
  • func NewNotifier(node lens.API, db *storage.Database, queue *queue.AsynQ, name string, ...) *Notifier
  • func (g *Notifier) Done() <-chan struct{}
  • func (g *Notifier) Run(ctx context.Context) error
• type TaskHeight

Types

type Filler

type Filler struct {
	DB *storage.Database
	// contains filtered or unexported fields
}

func NewFiller

func NewFiller(node lens.API, db *storage.Database, name string, minHeight, maxHeight int64, tasks []string, r *schedule.Reporter) *Filler

func (*Filler) Done

func (g *Filler) Done() <-chan struct{}

func (*Filler) Run

func (g *Filler) Run(ctx context.Context) error

type Finder

type Finder struct {
	DB *storage.Database
	// contains filtered or unexported fields
}

func NewFinder

func NewFinder(node lens.API, db *storage.Database, name string, minHeight, maxHeight int64, tasks []string) *Finder

func (*Finder) Done

func (g *Finder) Done() <-chan struct{}

func (*Finder) Find

func (g *Finder) Find(ctx context.Context) (visor.GapReportList, error)

func (*Finder) Run

func (g *Finder) Run(ctx context.Context) error

type Notifier

type Notifier struct {
	DB *storage.Database
	// contains filtered or unexported fields
}

func NewNotifier

func NewNotifier(node lens.API, db *storage.Database, queue *queue.AsynQ, name string, minHeight, maxHeight int64, tasks []string) *Notifier

func (*Notifier) Done

func (g *Notifier) Done() <-chan struct{}

func (*Notifier) Run

func (g *Notifier) Run(ctx context.Context) error

type TaskHeight

type TaskHeight struct {
	Task   string
	Height uint64
	Status string
}