Versions in this module Expand all Collapse all v1 v1.0.0 Mar 26, 2021 Changes in this version + func FilterLogs(logs []*ethtypes.Log, fromBlock, toBlock *big.Int, addresses []common.Address, ...) []*ethtypes.Log + type Backend interface + BloomStatus func() (uint64, uint64) + GetBlockByNumber func(blockNum rpctypes.BlockNumber, fullTx bool) (map[string]interface{}, error) + GetLogs func(blockHash common.Hash) ([][]*ethtypes.Log, error) + GetTransactionLogs func(txHash common.Hash) ([]*ethtypes.Log, error) + HeaderByHash func(blockHash common.Hash) (*ethtypes.Header, error) + HeaderByNumber func(blockNr rpctypes.BlockNumber) (*ethtypes.Header, error) + type EventSystem struct + func NewEventSystem(client rpcclient.Client) *EventSystem + func (es *EventSystem) SubscribeLogs(crit filters.FilterCriteria) (*Subscription, context.CancelFunc, error) + func (es *EventSystem) WithContext(ctx context.Context) + func (es EventSystem) SubscribeNewHeads() (*Subscription, context.CancelFunc, error) + func (es EventSystem) SubscribePendingTxs() (*Subscription, context.CancelFunc, error) + type Filter struct + func NewBlockFilter(backend Backend, criteria filters.FilterCriteria) *Filter + func NewRangeFilter(backend Backend, begin, end int64, addresses []common.Address, ...) *Filter + func (f *Filter) Logs(_ context.Context) ([]*ethtypes.Log, error) + type PublicFilterAPI struct + func NewAPI(clientCtx clientcontext.CLIContext, backend Backend) *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