filter

type AddressResolver func(context.Context, abi.ActorID, *types.TipSet) (address.Address, bool)

type CollectedEvent struct {
	Entries     []types.EventEntry
	EmitterAddr address.Address // address of emitter
	EventIdx    int             // index of the event within the list of emitted events
	Reverted    bool
	Height      abi.ChainEpoch
	TipSetKey   types.TipSetKey // tipset that contained the message
	MsgIdx      int             // index of the message in the tipset
	MsgCid      cid.Cid         // cid of message that produced event
}

type EventFilter interface {
	Filter

	TakeCollectedEvents(context.Context) []*CollectedEvent
	CollectEvents(context.Context, *TipSetEvents, bool, AddressResolver) error
}

type EventFilterManager struct {
	MessageStore     *chain.MessageStore
	ChainStore       blockstore.Blockstore
	AddressResolver  func(ctx context.Context, emitter abi.ActorID, ts *types.TipSet) (address.Address, bool)
	MaxFilterResults int
	EventIndex       *EventIndex
	// contains filtered or unexported fields
}

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

type Filter interface {
	ID() types.FilterID
	LastTaken() time.Time
	SetSubChannel(chan<- interface{})
	ClearSubChannel()
}

type FilterStore interface {
	Add(context.Context, Filter) error
	Get(context.Context, types.FilterID) (Filter, error)
	Remove(context.Context, types.FilterID) error
	NotTakenSince(when time.Time) []Filter // returns a list of filters that have not had their collected results taken
}

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

type MemPoolFilterManager struct {
	MaxFilterResults int
	// contains filtered or unexported fields
}

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

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

type TipSetFilterManager struct {
	MaxFilterResults int
	// contains filtered or unexported fields
}