filters

Documentation

Index

• Variables
• type Backend
• type EventSystem
  • func NewEventSystem(mux *event.TypeMux, backend Backend, lightMode bool) *EventSystem
  • func (es *EventSystem) SubscribeLogs(crit neatio.FilterQuery, 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
  • func New(backend Backend, begin, end int64, addresses []common.Address, ...) *Filter
  • func (f *Filter) Logs(ctx context.Context) ([]*types.Log, error)
• type FilterCriteria
  • func (args *FilterCriteria) UnmarshalJSON(data []byte) error
• type PublicFilterAPI
  • 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
  • func (sub *Subscription) Err() <-chan error
  • func (sub *Subscription) Unsubscribe()
• type Type

Variables

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

Types

type Backend

type Backend interface {
	ChainDb() neatdb.Database
	EventMux() *event.TypeMux
	HeaderByNumber(ctx context.Context, blockNr rpc.BlockNumber) (*types.Header, error)
	GetReceipts(ctx context.Context, blockHash common.Hash) (types.Receipts, error)
	GetLogs(ctx context.Context, blockHash common.Hash) ([][]*types.Log, error)

	SubscribeTxPreEvent(chan<- core.TxPreEvent) event.Subscription
	SubscribeChainEvent(ch chan<- core.ChainEvent) event.Subscription
	SubscribeRemovedLogsEvent(ch chan<- core.RemovedLogsEvent) event.Subscription
	SubscribeLogsEvent(ch chan<- []*types.Log) event.Subscription

	BloomStatus() (uint64, uint64)
	ServiceFilter(ctx context.Context, session *bloombits.MatcherSession)
}

type EventSystem

type EventSystem struct {
	// contains filtered or unexported fields
}

func NewEventSystem

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

func (*EventSystem) SubscribeLogs

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

func (*EventSystem) SubscribeNewHeads

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

func (*EventSystem) SubscribePendingTxEvents

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

type Filter

type Filter struct {
	// contains filtered or unexported fields
}

func New

func New(backend Backend, begin, end int64, addresses []common.Address, topics [][]common.Hash) *Filter

func (*Filter) Logs

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

type FilterCriteria

type FilterCriteria struct {
	FromBlock *big.Int
	ToBlock   *big.Int
	Addresses []common.Address
	Topics    [][]common.Hash
}

func (*FilterCriteria) UnmarshalJSON

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

type PublicFilterAPI

type PublicFilterAPI struct {
	// contains filtered or unexported fields
}

func NewPublicFilterAPI

func NewPublicFilterAPI(backend Backend, lightMode bool) *PublicFilterAPI

func (*PublicFilterAPI) GetFilterChanges

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

func (*PublicFilterAPI) GetFilterLogs

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

func (*PublicFilterAPI) GetLogs

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

func (*PublicFilterAPI) Logs

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

func (*PublicFilterAPI) NewBlockFilter

func (api *PublicFilterAPI) NewBlockFilter() rpc.ID

func (*PublicFilterAPI) NewFilter

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

func (*PublicFilterAPI) NewHeads

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

func (*PublicFilterAPI) NewPendingTransactionFilter

func (api *PublicFilterAPI) NewPendingTransactionFilter() rpc.ID

func (*PublicFilterAPI) NewPendingTransactions

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

func (*PublicFilterAPI) UninstallFilter

func (api *PublicFilterAPI) UninstallFilter(id rpc.ID) bool

type Subscription

type Subscription struct {
	ID rpc.ID
	// contains filtered or unexported fields
}

func (*Subscription) Err

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

func (*Subscription) Unsubscribe

func (sub *Subscription) Unsubscribe()

type Type

type Type byte

const (
	UnknownSubscription Type = iota

	LogsSubscription

	PendingLogsSubscription

	MinedAndPendingLogsSubscription

	PendingTransactionsSubscription

	BlocksSubscription

	LastIndexSubscription
)