mon2

Apr 15, 2022

Changes in this version

type Monitor

+ func (m *Monitor) StopMon()

Apr 9, 2022

Changes in this version

type PerAddrCfg

+ Topics [][]common.Hash

Mar 20, 2022

Changes in this version

+ func EventIDMap(abistr string) map[common.Hash]string

+ type DAL interface

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

+ SetMonitorBlock func(key string, blockNum uint64, blockIdx int64) error

+ type EthClient interface

+ BlockNumber func(ctx context.Context) (uint64, error)

+ ChainID func(ctx context.Context) (*big.Int, error)

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

+ type EventCallback func(string, types.Log)

+ type LogEventID struct

+ BlkNum uint64

+ Index int64

+ func (le *LogEventID) CountSkip(logs []types.Log) (skipped int)

+ func (le *LogEventID) ShouldSkip(blknum uint64, idx uint) bool

+ type Monitor struct

+ func NewMonitor(ec EthClient, dal DAL, cfg PerChainCfg) (*Monitor, error)

+ func (m *Monitor) CalcNextFromBlkNum(lastFrom, lastTo uint64) uint64

+ func (m *Monitor) CalcToBlkNum(from uint64) uint64

+ func (m *Monitor) Close()

+ func (m *Monitor) GetBlkNum() uint64

+ func (m *Monitor) MonAddr(cfg PerAddrCfg, cbfn EventCallback)

+ type PerAddrCfg struct

+ AbiStr string

+ Addr common.Address

+ ChkIntv time.Duration

+ FromBlk uint64

+ type PerChainCfg struct

+ BlkDelay uint64

+ BlkIntv time.Duration

+ ForwardBlkDelay uint64

+ MaxBlkDelta uint64