Versions in this module Expand all Collapse all v1 v1.0.1 Nov 29, 2022 v1.0.0 Nov 29, 2022 Changes in this version + func FilterLogs(logs []*ethtypes.Log, fromBlock, toBlock *big.Int, addresses []common.Address, ...) []*ethtypes.Log + type Backend interface + BlockBloom func(blockRes *coretypes.ResultBlockResults) (ethtypes.Bloom, error) + BloomStatus func() (uint64, uint64) + GetBlockByNumber func(blockNum types.BlockNumber, fullTx bool) (map[string]interface{}, error) + GetLogs func(blockHash common.Hash) ([][]*ethtypes.Log, error) + GetLogsByHeight func(*int64) ([][]*ethtypes.Log, error) + HeaderByHash func(blockHash common.Hash) (*ethtypes.Header, error) + HeaderByNumber func(blockNum types.BlockNumber) (*ethtypes.Header, error) + RPCBlockRangeCap func() int32 + RPCFilterCap func() int32 + RPCLogsCap func() int32 + TendermintBlockByHash func(hash common.Hash) (*coretypes.ResultBlock, error) + TendermintBlockResultByNumber func(height *int64) (*coretypes.ResultBlockResults, error) + type BloomIV struct + I [3]uint + V [3]byte + type EventSystem struct + func NewEventSystem(logger log.Logger, tmWSClient *rpcclient.WSClient) *EventSystem + func (es *EventSystem) SubscribeLogs(crit filters.FilterCriteria) (*Subscription, pubsub.UnsubscribeFunc, error) + func (es *EventSystem) WithContext(ctx context.Context) + func (es EventSystem) SubscribeNewHeads() (*Subscription, pubsub.UnsubscribeFunc, error) + func (es EventSystem) SubscribePendingTxs() (*Subscription, pubsub.UnsubscribeFunc, error) + type Filter struct + func NewBlockFilter(logger log.Logger, backend Backend, criteria filters.FilterCriteria) *Filter + func NewRangeFilter(logger log.Logger, backend Backend, begin, end int64, ...) *Filter + func (f *Filter) Logs(ctx context.Context, logLimit int, blockLimit int64) ([]*ethtypes.Log, error) + type FilterAPI interface + GetFilterChanges func(id rpc.ID) (interface{}, error) + GetFilterLogs func(ctx context.Context, id rpc.ID) ([]*ethtypes.Log, error) + GetLogs func(ctx context.Context, crit filters.FilterCriteria) ([]*ethtypes.Log, error) + NewBlockFilter func() rpc.ID + NewFilter func(criteria filters.FilterCriteria) (rpc.ID, error) + NewPendingTransactionFilter func() rpc.ID + UninstallFilter func(id rpc.ID) bool + type PublicFilterAPI struct + func NewPublicAPI(logger log.Logger, clientCtx client.Context, tmWSClient *rpcclient.WSClient, ...) *PublicFilterAPI + func (api *PublicFilterAPI) GetFilterChanges(id rpc.ID) (interface{}, error) + func (api *PublicFilterAPI) GetFilterLogs(ctx context.Context, id rpc.ID) ([]*ethtypes.Log, error) + func (api *PublicFilterAPI) GetLogs(ctx context.Context, crit filters.FilterCriteria) ([]*ethtypes.Log, error) + func (api *PublicFilterAPI) Logs(ctx context.Context, crit filters.FilterCriteria) (*rpc.Subscription, error) + func (api *PublicFilterAPI) NewBlockFilter() rpc.ID + func (api *PublicFilterAPI) NewFilter(criteria filters.FilterCriteria) (rpc.ID, error) + func (api *PublicFilterAPI) NewHeads(ctx context.Context) (*rpc.Subscription, error) + func (api *PublicFilterAPI) NewPendingTransactionFilter() rpc.ID + func (api *PublicFilterAPI) NewPendingTransactions(ctx context.Context) (*rpc.Subscription, error) + func (api *PublicFilterAPI) UninstallFilter(id rpc.ID) bool + type Subscription struct + func (s *Subscription) Err() <-chan error + func (s *Subscription) Event() <-chan coretypes.ResultEvent + func (s *Subscription) Unsubscribe(es *EventSystem) + func (s Subscription) ID() rpc.ID