Versions in this module Expand all Collapse all v0 v0.21.1 Apr 1, 2019 Changes in this version + const ErrFailedToFetchLogs + const ErrFailedToGetActiveAccounts + const ErrFailedToGetHeaderByNumber + const ErrFailedToParseABI + const ErrFailedToScanRows + const ErrFailedToTraverseAddresses + const ErrFailedToUnpack + const ErrInternal + const ErrUnsupportedTopic + const ErrWrongBlockArgumentType + const ErrWrongNumberOfEventArgs + type Client interface + FilterLogs func(ctx context.Context, q ethereum.FilterQuery) ([]ethtypes.Log, error) + HeaderByNumber func(ctx context.Context, number *big.Int) (*ethtypes.Header, error) + type Config struct + EthCallTimeout uint + InitialBlocks uint64 + QueryPause uint + func NewConfig() *Config + type JobsProducers map[common.Hash]func(*data.JobEthLog, []data.Job) ([]data.Job, error) + type Monitor struct + func NewMonitor(conf *Config, c Client, db *reform.DB, l log.Logger, psc, ptc common.Address, ...) (*Monitor, error) + func (m *Monitor) Start() + func (m *Monitor) Stop() + type Queue interface + Add func(*reform.TX, *data.Job) error