syncer

Documentation

Index

• type HeadSyncer
  • func NewHeadSyncer(o HeadSyncerOpts) (*HeadSyncer, error)
  • func (hs *HeadSyncer) Start(ctx context.Context) error
• type HeadSyncerOpts
• type Janitor
  • func NewJanitor(o JanitorOpts) *Janitor
  • func (j *Janitor) QueueMissingBlocks(ctx context.Context) error
  • func (j *Janitor) Start(ctx context.Context) error
• type JanitorOpts
• type Stats
  • func (s *Stats) GetHeadCursor() uint64
  • func (s *Stats) GetLowerBound() uint64
  • func (s *Stats) UpdateHeadCursor(val uint64)
  • func (s *Stats) UpdateLowerBound(val uint64)

Types

type HeadSyncer

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

func NewHeadSyncer

func NewHeadSyncer(o HeadSyncerOpts) (*HeadSyncer, error)

func (*HeadSyncer) Start

func (hs *HeadSyncer) Start(ctx context.Context) error

Start creates a websocket subscription and actively receives new blocks until stopped or a critical error occurs.

type HeadSyncerOpts

type HeadSyncerOpts struct {
	Logg       logf.Logger
	Pipeline   *pipeline.Pipeline
	Pool       *pond.WorkerPool
	Stats      *Stats
	WsEndpoint string
}

type Janitor

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

func NewJanitor

func NewJanitor(o JanitorOpts) *Janitor

func (*Janitor) QueueMissingBlocks

func (j *Janitor) QueueMissingBlocks(ctx context.Context) error

QueueMissingBlocks searches for missing block and queues the block for processing. It will run twice for a given search range and only after, raise the lower bound.

func (*Janitor) Start

func (j *Janitor) Start(ctx context.Context) error

type JanitorOpts

type JanitorOpts struct {
	BatchSize     uint64
	Logg          logf.Logger
	Pipeline      *pipeline.Pipeline
	Pool          *pond.WorkerPool
	Stats         *Stats
	Store         store.Store[pgx.Rows]
	SweepInterval time.Duration
}

type Stats

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

Stats synchronizes block cursors values across the head and janitor.

func (*Stats) GetHeadCursor

func (s *Stats) GetHeadCursor() uint64

func (*Stats) GetLowerBound

func (s *Stats) GetLowerBound() uint64

func (*Stats) UpdateHeadCursor

func (s *Stats) UpdateHeadCursor(val uint64)

func (*Stats) UpdateLowerBound

func (s *Stats) UpdateLowerBound(val uint64)