node

Documentation

Overview

Package node uses the backfiller to get all previous logs, and then listens to the height of the blockchain in order to add new logs as blocks come in.

Index

• func GetBlockHashes(ctx context.Context, backend backfill.ScribeBackend, ...) ([]string, error)
• type Scribe
  • func NewScribe(eventDB db.EventDB, clients map[uint32][]backfill.ScribeBackend, ...) (*Scribe, error)
  • func (s Scribe) Start(ctx context.Context) error

Functions

func GetBlockHashes

func GetBlockHashes(ctx context.Context, backend backfill.ScribeBackend, startBlock, endBlock uint64, getBlockBatchAmount int) ([]string, error)

GetBlockHashes gets an array of block hashes from a range of blocks.

Types

type Scribe

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

Scribe is a live scribe that logs all event data.

func NewScribe

func NewScribe(eventDB db.EventDB, clients map[uint32][]backfill.ScribeBackend, config config.Config, handler metrics.Handler) (*Scribe, error)

NewScribe creates a new scribe.

func (Scribe) Start

func (s Scribe) Start(ctx context.Context) error

Start starts the scribe. This works by starting a backfill and recording what the current block, which it will backfill to. Then, each chain will listen for new block heights and backfill to that height.