monitor

Documentation

Index

• Variables
• func BlockProcessor(ctx context.Context, headers <-chan *types.Header, ...) error
• func HeaderListener(ctx context.Context, headers chan<- *types.Header, cc *client.CeloClient, ...) error
• func NewMonitorService(cc *client.CeloClient, db db.RosettaDB) *monitorService
• func ProcessChanges(ctx context.Context, changes <-chan *db.BlockChangeSet, ...) error

Variables

var ErrMultipleGasPriceMinimumUpdates = errors.New("Error multiple GasPriceMinimumUpdated events emitted in same block")

Functions

func BlockProcessor

func BlockProcessor(ctx context.Context, headers <-chan *types.Header, changes chan<- *db.BlockChangeSet, cc *client.CeloClient, db_ db.RosettaDBReader, logger log.Logger) error

func HeaderListener

func HeaderListener(ctx context.Context, headers chan<- *types.Header, cc *client.CeloClient, logger log.Logger, startBlock *big.Int) error

func NewMonitorService

func NewMonitorService(cc *client.CeloClient, db db.RosettaDB) *monitorService

func ProcessChanges

func ProcessChanges(ctx context.Context, changes <-chan *db.BlockChangeSet, dbWriter db.RosettaDBWriter, logger log.Logger) error