watcher

Jun 8, 2020

Changes in this version

+ var ErrWatchServiceClosed = errors.New("Watch service closed")

+ var ErrWatcherTimeout = errors.New("Watcher timeout")

+ type LogEventID struct

+ BlockNumber uint64

+ Index int64

+ type Watch struct

+ func (w *Watch) Ack() error

+ func (w *Watch) Close()

+ func (w *Watch) Next() (types.Log, error)

+ type WatchClient interface

+ FilterLogs func(ctx context.Context, q ethereum.FilterQuery) ([]types.Log, error)

+ HeaderByNumber func(ctx context.Context, number *big.Int) (*types.Header, error)

+ type WatchDAL interface

+ GetMonitorBlock func(event string) (uint64, int64, bool, error)

+ InsertMonitor func(event string, blockNum uint64, blockIdx int64, restart bool) error

+ UpdateMonitorBlock func(event string, blockNum uint64, blockIdx int64) error

+ UpsertMonitorBlock func(event string, blockNum uint64, blockIdx int64, restart bool) error

+ type WatchService struct

+ func NewWatchService(client WatchClient, dal WatchDAL, polling uint64) *WatchService

+ func (ws *WatchService) Close()

+ func (ws *WatchService) GetBlockNumber() uint64

+ func (ws *WatchService) GetCurrentBlockNumber() *big.Int

+ func (ws *WatchService) MakeFilterQuery(addr common.Address, rawABI string, eventName string, startBlock *big.Int) (ethereum.FilterQuery, error)

+ func (ws *WatchService) NewWatch(name string, query ethereum.FilterQuery, blkDelay, checkInterval uint64, ...) (*Watch, error)