filters

package

Go to main page

Versions in this module

v1

v1.6.5

Jun 1, 2017

v1.6.4

Jun 1, 2017

v1.6.0

Apr 14, 2017

v1.5.8

Feb 1, 2017

Changes in this version

type Filter

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

type Type

+ const LastIndexSubscription

+ const MinedAndPendingLogsSubscription

v1.5.1

Nov 16, 2016

Changes in this version

+ var ErrInvalidSubscriptionID = errors.New("invalid id")

+ type Backend interface

+ ChainDb func() ethdb.Database

+ EventMux func() *event.TypeMux

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

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

+ type EventSystem struct

+ func NewEventSystem(mux *event.TypeMux, backend Backend, lightMode bool) *EventSystem

+ func (es *EventSystem) SubscribeLogs(crit FilterCriteria, logs chan []Log) *Subscription

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

+ func (es *EventSystem) SubscribePendingLogs(crit FilterCriteria, logs chan []Log) *Subscription

+ func (es *EventSystem) SubscribePendingTxEvents(hashes chan common.Hash) *Subscription

+ type FilterCriteria struct

+ Addresses []common.Address

+ FromBlock *big.Int

+ ToBlock *big.Int

+ Topics [][]common.Hash

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

+ type Log struct

+ Removed bool

+ func (l *Log) MarshalJSON() ([]byte, error)

type PublicFilterAPI

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

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

+ type Subscription struct

+ ID rpc.ID

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

+ func (sub *Subscription) Unsubscribe()

+ type Type byte

+ const BlocksSubscription

+ const LogsSubscription

+ const PendingLogsSubscription

+ const PendingTransactionsSubscription

+ const UnknownSubscription

v1.4.5

May 24, 2016

Changes in this version

+ type AccountChange struct

+ Address []byte

+ StateAddress []byte

+ type Filter struct

+ BlockCallback func(*types.Block, vm.Logs)

+ LogCallback func(*vm.Log, bool)

+ TransactionCallback func(*types.Transaction)

+ func New(db ethdb.Database) *Filter

+ func (self *Filter) FilterLogs(logs vm.Logs) vm.Logs

+ func (self *Filter) Find() vm.Logs

+ func (self *Filter) SetAddresses(addr []common.Address)

+ func (self *Filter) SetBeginBlock(begin int64)

+ func (self *Filter) SetEndBlock(end int64)

+ func (self *Filter) SetTopics(topics [][]common.Hash)

+ type FilterSystem struct

+ func NewFilterSystem(mux *event.TypeMux) *FilterSystem

+ func (fs *FilterSystem) Add(filter *Filter, filterType FilterType) (int, error)

+ func (fs *FilterSystem) Get(id int) *Filter

+ func (fs *FilterSystem) Remove(id int)

+ func (fs *FilterSystem) Stop()

+ type FilterType byte

+ const ChainFilter

+ const LogFilter

+ const PendingLogFilter

+ const PendingTxFilter

+ type NewFilterArgs struct

+ Addresses []common.Address

+ FromBlock rpc.BlockNumber

+ ToBlock rpc.BlockNumber

+ Topics [][]common.Hash

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

+ type PublicFilterAPI struct

+ func NewPublicFilterAPI(chainDb ethdb.Database, mux *event.TypeMux) *PublicFilterAPI

+ func (s *PublicFilterAPI) GetFilterChanges(filterId string) interface{}

+ func (s *PublicFilterAPI) GetFilterLogs(filterId string) []vmlog

+ func (s *PublicFilterAPI) GetLogs(args NewFilterArgs) []vmlog

+ func (s *PublicFilterAPI) Logs(ctx context.Context, args NewFilterArgs) (rpc.Subscription, error)

+ func (s *PublicFilterAPI) NewBlockFilter() (string, error)

+ func (s *PublicFilterAPI) NewFilter(args NewFilterArgs) (string, error)

+ func (s *PublicFilterAPI) NewPendingTransactionFilter() (string, error)

+ func (s *PublicFilterAPI) Stop()

+ func (s *PublicFilterAPI) UninstallFilter(filterId string) bool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL