logs

Documentation

Index

• type FilterCriteria
• type IDFilter
  • func NewIDFilter(id common.Hash, criteria FilterCriteria, blocks storage.BlockIndexer, ...) *IDFilter
  • func (i *IDFilter) Match() ([]*gethTypes.Log, error)
• type RangeFilter
  • func NewRangeFilter(start, end big.Int, criteria FilterCriteria, receipts storage.ReceiptIndexer) (*RangeFilter, error)
  • func (r *RangeFilter) Match() ([]*gethTypes.Log, error)
• type StreamFilter
  • func NewStreamFilter(criteria FilterCriteria, receipts chan *gethTypes.Receipt) *StreamFilter
  • func (s *StreamFilter) Match() (<-chan *gethTypes.Log, error)

Types

type FilterCriteria

type FilterCriteria struct {
	Addresses []common.Address
	Topics    [][]common.Hash
}

FilterCriteria for log filtering. Address of the contract emitting the log. Topics that match the log topics, following the format: [] “anything” [A] “A in first position (and anything after)” [null, B] “anything in first position AND B in second position (and anything after)” [A, B] “A in first position AND B in second position (and anything after)” [[A, B], [A, B]] “(A OR B) in first position AND (A OR B) in second position (and anything after)”

type IDFilter

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

IDFilter matches all logs against the criteria found in a single block identified by the provided block ID.

func NewIDFilter

func NewIDFilter(
	id common.Hash,
	criteria FilterCriteria,
	blocks storage.BlockIndexer,
	receipts storage.ReceiptIndexer,
) *IDFilter

func (*IDFilter) Match

func (i *IDFilter) Match() ([]*gethTypes.Log, error)

type RangeFilter

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

RangeFilter matches all the indexed logs within the range defined as start and end block height. The start must be strictly smaller or equal than end value.

func NewRangeFilter

func NewRangeFilter(
	start, end big.Int,
	criteria FilterCriteria,
	receipts storage.ReceiptIndexer,
) (*RangeFilter, error)

func (*RangeFilter) Match

func (r *RangeFilter) Match() ([]*gethTypes.Log, error)

type StreamFilter

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

StreamFilter matches all the logs against the criteria from the receipt channel.

func NewStreamFilter

func NewStreamFilter(criteria FilterCriteria, receipts chan *gethTypes.Receipt) *StreamFilter

func (*StreamFilter) Match

func (s *StreamFilter) Match() (<-chan *gethTypes.Log, error)