Versions in this module Expand all Collapse all v0 v0.18.15 May 17, 2022 Changes in this version + func FilterLogs(logs []*types.Log, fromBlock, toBlock *big.Int, addresses []common.Address, ...) []*types.Log + type EventSystem struct + func NewEventSystem(eventBus *tmtypes.EventBus) *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(blockStore *store.BlockStore, block common.Hash, addresses []common.Address, ...) *Filter + func NewRangeFilter(blockStore *store.BlockStore, begin, end int64, addresses []common.Address, ...) *Filter + func (f *Filter) BloomStatus() (uint64, uint64) + func (f *Filter) Logs() ([]*ethtypes.Log, error) + type PublicFilterAPI struct + func NewPublicFilterAPI(blockStore *store.BlockStore, eventBus *tmtypes.EventBus) *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) Syncing() (*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
Go to main page