Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

filters

package

Go to main page

Versions in this module

v0

v0.1.5

Jul 17, 2023

v0.1.4

Jul 17, 2023

v0.1.3

Jul 17, 2023

v0.1.2

Jul 17, 2023

Changes in this version

+ type Backend interface

+ BloomStatus func() (uint64, uint64)

+ ChainDb func() ethdb.Database

+ GetLogs func(ctx context.Context, blockHash common.Hash, number uint64) ([][]*types.Log, error)

+ GetMaxBlocksPerRequest func() int64

+ GetReceipts func(ctx context.Context, blockHash common.Hash) (types.Receipts, error)

+ GetVMConfig func() *vm.Config

+ HeaderByHash func(ctx context.Context, blockHash common.Hash) (*types.Header, error)

+ HeaderByNumber func(ctx context.Context, blockNr rpc.BlockNumber) (*types.Header, error)

+ LastAcceptedBlock func() *types.Block

+ ServiceFilter func(ctx context.Context, session *bloombits.MatcherSession)

+ SubscribeAcceptedLogsEvent func(ch chan<- []*types.Log) event.Subscription

+ SubscribeAcceptedTransactionEvent func(ch chan<- core.NewTxsEvent) event.Subscription

+ SubscribeChainAcceptedEvent func(ch chan<- core.ChainEvent) event.Subscription

+ SubscribeChainEvent func(ch chan<- core.ChainEvent) event.Subscription

+ SubscribeLogsEvent func(ch chan<- []*types.Log) event.Subscription

+ SubscribeNewTxsEvent func(chan<- core.NewTxsEvent) event.Subscription

+ SubscribePendingLogsEvent func(ch chan<- []*types.Log) event.Subscription

+ SubscribeRemovedLogsEvent func(ch chan<- core.RemovedLogsEvent) event.Subscription

+ type Config struct

+ Timeout time.Duration

+ type EventSystem struct

+ func NewEventSystem(sys *FilterSystem, lightMode bool) *EventSystem

+ func (es *EventSystem) SubscribeAcceptedHeads(headers chan *types.Header) *Subscription

+ func (es *EventSystem) SubscribeAcceptedLogs(crit interfaces.FilterQuery, logs chan []*types.Log) (*Subscription, error)

+ func (es *EventSystem) SubscribeAcceptedTxs(hashes chan []common.Hash) *Subscription

+ func (es *EventSystem) SubscribeLogs(crit interfaces.FilterQuery, logs chan []*types.Log) (*Subscription, error)

+ func (es *EventSystem) SubscribeNewHeads(headers chan *types.Header) *Subscription

+ func (es *EventSystem) SubscribePendingTxs(hashes chan []common.Hash) *Subscription

+ type Filter struct

+ func (f *Filter) Logs(ctx context.Context) ([]*types.Log, error)

+ type FilterAPI struct

+ func NewFilterAPI(system *FilterSystem, lightMode bool) *FilterAPI

+ func (api *FilterAPI) GetFilterChanges(id rpc.ID) (interface{}, error)

+ func (api *FilterAPI) GetFilterLogs(ctx context.Context, id rpc.ID) ([]*types.Log, error)

+ func (api *FilterAPI) GetLogs(ctx context.Context, crit FilterCriteria) ([]*types.Log, error)

+ func (api *FilterAPI) Logs(ctx context.Context, crit FilterCriteria) (*rpc.Subscription, error)

+ func (api *FilterAPI) NewAcceptedTransactions(ctx context.Context) (*rpc.Subscription, error)

+ func (api *FilterAPI) NewBlockFilter() rpc.ID

+ func (api *FilterAPI) NewFilter(crit FilterCriteria) (rpc.ID, error)

+ func (api *FilterAPI) NewHeads(ctx context.Context) (*rpc.Subscription, error)

+ func (api *FilterAPI) NewPendingTransactionFilter() rpc.ID

+ func (api *FilterAPI) NewPendingTransactions(ctx context.Context) (*rpc.Subscription, error)

+ func (api *FilterAPI) UninstallFilter(id rpc.ID) bool

+ type FilterCriteria interfaces.FilterQuery

+ func (args *FilterCriteria) UnmarshalJSON(data []byte) error

+ type FilterSystem struct

+ func NewFilterSystem(backend Backend, config Config) *FilterSystem

+ func (sys *FilterSystem) NewBlockFilter(block common.Hash, addresses []common.Address, topics [][]common.Hash) *Filter

+ func (sys *FilterSystem) NewRangeFilter(begin, end int64, addresses []common.Address, topics [][]common.Hash) (*Filter, error)

+ type Subscription struct

+ ID rpc.ID

+ func (sub *Subscription) Err() <-chan error

+ func (sub *Subscription) Unsubscribe()

+ type Type byte

+ const AcceptedBlocksSubscription

+ const AcceptedLogsSubscription

+ const AcceptedTransactionsSubscription

+ const BlocksSubscription

+ const LastIndexSubscription

+ const LogsSubscription

+ const MinedAndPendingLogsSubscription

+ const PendingLogsSubscription

+ const PendingTransactionsSubscription

+ const UnknownSubscription