Versions in this module Expand all Collapse all v1 v1.6.9 May 31, 2018 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 []*types.Log) (*Subscription, error) + func (es *EventSystem) SubscribeNewHeads(headers chan *types.Header) *Subscription + func (es *EventSystem) SubscribePendingTxEvents(hashes chan common.Hash) *Subscription + type Filter struct + func New(backend Backend, useMipMap bool) *Filter + func (f *Filter) Find(ctx context.Context) (logs []*types.Log, err error) + func (f *Filter) FindOnce(ctx context.Context) ([]*types.Log, error) + func (f *Filter) SetAddresses(addr []common.Address) + func (f *Filter) SetBeginBlock(begin int64) + func (f *Filter) SetEndBlock(end int64) + func (f *Filter) SetTopics(topics [][]common.Hash) + type FilterCriteria struct + Addresses []common.Address + FromBlock *big.Int + ToBlock *big.Int + Topics [][]common.Hash + func (args *FilterCriteria) UnmarshalJSON(data []byte) error + type PublicFilterAPI struct + func NewPublicFilterAPI(backend Backend, lightMode bool) *PublicFilterAPI + func (api *PublicFilterAPI) GetFilterChanges(id rpc.ID) (interface{}, error) + func (api *PublicFilterAPI) GetFilterLogs(ctx context.Context, id rpc.ID) ([]*types.Log, error) + func (api *PublicFilterAPI) GetLogs(ctx context.Context, crit FilterCriteria) ([]*types.Log, error) + func (api *PublicFilterAPI) Logs(ctx context.Context, crit FilterCriteria) (*rpc.Subscription, error) + func (api *PublicFilterAPI) NewBlockFilter() rpc.ID + func (api *PublicFilterAPI) NewFilter(crit 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 + ID rpc.ID + func (sub *Subscription) Err() <-chan error + func (sub *Subscription) Unsubscribe() + type Type byte + const BlocksSubscription + const LastIndexSubscription + const LogsSubscription + const MinedAndPendingLogsSubscription + const PendingLogsSubscription + const PendingTransactionsSubscription + const UnknownSubscription
Go to main page