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
Constants ¶
This section is empty.
Variables ¶
View Source
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 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
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.