Documentation ¶
Index ¶
- type LogPoller
- func (_m *LogPoller) Close() error
- func (_m *LogPoller) GetBlocksRange(ctx context.Context, numbers []uint64, qopts ...pg.QOpt) ([]logpoller.LogPollerBlock, error)
- func (_m *LogPoller) HealthReport() map[string]error
- func (_m *LogPoller) IndexedLogs(eventSig common.Hash, address common.Address, topicIndex int, ...) ([]logpoller.Log, error)
- func (_m *LogPoller) IndexedLogsByBlockRange(start int64, end int64, eventSig common.Hash, address common.Address, ...) ([]logpoller.Log, error)
- func (_m *LogPoller) IndexedLogsTopicGreaterThan(eventSig common.Hash, address common.Address, topicIndex int, ...) ([]logpoller.Log, error)
- func (_m *LogPoller) IndexedLogsTopicRange(eventSig common.Hash, address common.Address, topicIndex int, ...) ([]logpoller.Log, error)
- func (_m *LogPoller) IndexedLogsWithSigsExcluding(address common.Address, eventSigA common.Hash, eventSigB common.Hash, ...) ([]logpoller.Log, error)
- func (_m *LogPoller) LatestBlock(qopts ...pg.QOpt) (int64, error)
- func (_m *LogPoller) LatestLogByEventSigWithConfs(eventSig common.Hash, address common.Address, confs int, qopts ...pg.QOpt) (*logpoller.Log, error)
- func (_m *LogPoller) LatestLogEventSigsAddrsWithConfs(fromBlock int64, eventSigs []common.Hash, addresses []common.Address, ...) ([]logpoller.Log, error)
- func (_m *LogPoller) Logs(start int64, end int64, eventSig common.Hash, address common.Address, ...) ([]logpoller.Log, error)
- func (_m *LogPoller) LogsDataWordGreaterThan(eventSig common.Hash, address common.Address, wordIndex int, ...) ([]logpoller.Log, error)
- func (_m *LogPoller) LogsDataWordRange(eventSig common.Hash, address common.Address, wordIndex int, ...) ([]logpoller.Log, error)
- func (_m *LogPoller) LogsWithSigs(start int64, end int64, eventSigs []common.Hash, address common.Address, ...) ([]logpoller.Log, error)
- func (_m *LogPoller) Name() string
- func (_m *LogPoller) Ready() error
- func (_m *LogPoller) RegisterFilter(filter logpoller.Filter) error
- func (_m *LogPoller) Replay(ctx context.Context, fromBlock int64) error
- func (_m *LogPoller) ReplayAsync(fromBlock int64)
- func (_m *LogPoller) Start(_a0 context.Context) error
- func (_m *LogPoller) UnregisterFilter(name string, q pg.Queryer) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LogPoller ¶
LogPoller is an autogenerated mock type for the LogPoller type
func NewLogPoller ¶
func NewLogPoller(t mockConstructorTestingTNewLogPoller) *LogPoller
NewLogPoller creates a new instance of LogPoller. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*LogPoller) GetBlocksRange ¶
func (_m *LogPoller) GetBlocksRange(ctx context.Context, numbers []uint64, qopts ...pg.QOpt) ([]logpoller.LogPollerBlock, error)
GetBlocksRange provides a mock function with given fields: ctx, numbers, qopts
func (*LogPoller) HealthReport ¶
HealthReport provides a mock function with given fields:
func (*LogPoller) IndexedLogs ¶
func (_m *LogPoller) IndexedLogs(eventSig common.Hash, address common.Address, topicIndex int, topicValues []common.Hash, confs int, qopts ...pg.QOpt) ([]logpoller.Log, error)
IndexedLogs provides a mock function with given fields: eventSig, address, topicIndex, topicValues, confs, qopts
func (*LogPoller) IndexedLogsByBlockRange ¶
func (_m *LogPoller) IndexedLogsByBlockRange(start int64, end int64, eventSig common.Hash, address common.Address, topicIndex int, topicValues []common.Hash, qopts ...pg.QOpt) ([]logpoller.Log, error)
IndexedLogsByBlockRange provides a mock function with given fields: start, end, eventSig, address, topicIndex, topicValues, qopts
func (*LogPoller) IndexedLogsTopicGreaterThan ¶
func (_m *LogPoller) IndexedLogsTopicGreaterThan(eventSig common.Hash, address common.Address, topicIndex int, topicValueMin common.Hash, confs int, qopts ...pg.QOpt) ([]logpoller.Log, error)
IndexedLogsTopicGreaterThan provides a mock function with given fields: eventSig, address, topicIndex, topicValueMin, confs, qopts
func (*LogPoller) IndexedLogsTopicRange ¶
func (_m *LogPoller) IndexedLogsTopicRange(eventSig common.Hash, address common.Address, topicIndex int, topicValueMin common.Hash, topicValueMax common.Hash, confs int, qopts ...pg.QOpt) ([]logpoller.Log, error)
IndexedLogsTopicRange provides a mock function with given fields: eventSig, address, topicIndex, topicValueMin, topicValueMax, confs, qopts
func (*LogPoller) IndexedLogsWithSigsExcluding ¶ added in v2.1.0
func (_m *LogPoller) IndexedLogsWithSigsExcluding(address common.Address, eventSigA common.Hash, eventSigB common.Hash, topicIndex int, fromBlock int64, toBlock int64, confs int, qopts ...pg.QOpt) ([]logpoller.Log, error)
IndexedLogsWithSigsExcluding provides a mock function with given fields: address, eventSigA, eventSigB, topicIndex, fromBlock, toBlock, confs, qopts
func (*LogPoller) LatestBlock ¶
LatestBlock provides a mock function with given fields: qopts
func (*LogPoller) LatestLogByEventSigWithConfs ¶
func (_m *LogPoller) LatestLogByEventSigWithConfs(eventSig common.Hash, address common.Address, confs int, qopts ...pg.QOpt) (*logpoller.Log, error)
LatestLogByEventSigWithConfs provides a mock function with given fields: eventSig, address, confs, qopts
func (*LogPoller) LatestLogEventSigsAddrsWithConfs ¶
func (_m *LogPoller) LatestLogEventSigsAddrsWithConfs(fromBlock int64, eventSigs []common.Hash, addresses []common.Address, confs int, qopts ...pg.QOpt) ([]logpoller.Log, error)
LatestLogEventSigsAddrsWithConfs provides a mock function with given fields: fromBlock, eventSigs, addresses, confs, qopts
func (*LogPoller) Logs ¶
func (_m *LogPoller) Logs(start int64, end int64, eventSig common.Hash, address common.Address, qopts ...pg.QOpt) ([]logpoller.Log, error)
Logs provides a mock function with given fields: start, end, eventSig, address, qopts
func (*LogPoller) LogsDataWordGreaterThan ¶
func (_m *LogPoller) LogsDataWordGreaterThan(eventSig common.Hash, address common.Address, wordIndex int, wordValueMin common.Hash, confs int, qopts ...pg.QOpt) ([]logpoller.Log, error)
LogsDataWordGreaterThan provides a mock function with given fields: eventSig, address, wordIndex, wordValueMin, confs, qopts
func (*LogPoller) LogsDataWordRange ¶
func (_m *LogPoller) LogsDataWordRange(eventSig common.Hash, address common.Address, wordIndex int, wordValueMin common.Hash, wordValueMax common.Hash, confs int, qopts ...pg.QOpt) ([]logpoller.Log, error)
LogsDataWordRange provides a mock function with given fields: eventSig, address, wordIndex, wordValueMin, wordValueMax, confs, qopts
func (*LogPoller) LogsWithSigs ¶
func (_m *LogPoller) LogsWithSigs(start int64, end int64, eventSigs []common.Hash, address common.Address, qopts ...pg.QOpt) ([]logpoller.Log, error)
LogsWithSigs provides a mock function with given fields: start, end, eventSigs, address, qopts
func (*LogPoller) RegisterFilter ¶
RegisterFilter provides a mock function with given fields: filter
func (*LogPoller) ReplayAsync ¶ added in v2.1.0
ReplayAsync provides a mock function with given fields: fromBlock