filter

Documentation

Index

• Variables
• type CollectedEvent
• type EventFilter
  • func (f *EventFilter) ClearSubChannel()
  • func (f *EventFilter) CollectEvents(ctx context.Context, te *TipSetEvents, revert bool, ...) error
  • func (f *EventFilter) ID() types.FilterID
  • func (f *EventFilter) LastTaken() time.Time
  • func (f *EventFilter) SetSubChannel(ch chan<- interface{})
  • func (f *EventFilter) TakeCollectedEvents(ctx context.Context) []*CollectedEvent
• type EventFilterManager
  • func (m *EventFilterManager) Apply(ctx context.Context, from, to *types.TipSet) error
  • func (m *EventFilterManager) Install(ctx context.Context, minHeight, maxHeight abi.ChainEpoch, tipsetCid cid.Cid, ...) (*EventFilter, error)
  • func (m *EventFilterManager) Remove(ctx context.Context, id types.FilterID) error
  • func (m *EventFilterManager) Revert(ctx context.Context, from, to *types.TipSet) error
• type EventIndex
  • func NewEventIndex(path string) (*EventIndex, error)
  • func (ei *EventIndex) Close() error
  • func (ei *EventIndex) CollectEvents(ctx context.Context, te *TipSetEvents, revert bool, ...) error
  • func (ei *EventIndex) PrefillFilter(ctx context.Context, f *EventFilter) error
• type Filter
• type FilterStore
  • func NewMemFilterStore(maxFilters int) FilterStore
• type MemPoolFilter
  • func (f *MemPoolFilter) ClearSubChannel()
  • func (f *MemPoolFilter) CollectMessage(ctx context.Context, msg *types.SignedMessage)
  • func (f *MemPoolFilter) ID() types.FilterID
  • func (f *MemPoolFilter) LastTaken() time.Time
  • func (f *MemPoolFilter) SetSubChannel(ch chan<- interface{})
  • func (f *MemPoolFilter) TakeCollectedMessages(context.Context) []*types.SignedMessage
• type MemPoolFilterManager
  • func (m *MemPoolFilterManager) Install(ctx context.Context) (*MemPoolFilter, error)
  • func (m *MemPoolFilterManager) Remove(ctx context.Context, id types.FilterID) error
  • func (m *MemPoolFilterManager) WaitForMpoolUpdates(ctx context.Context, ch <-chan types.MpoolUpdate)
• type TipSetEvents
  • func (te *TipSetEvents) Cid() (cid.Cid, error)
  • func (te *TipSetEvents) Height() abi.ChainEpoch
• type TipSetFilter
  • func (f *TipSetFilter) ClearSubChannel()
  • func (f *TipSetFilter) CollectTipSet(ctx context.Context, ts *types.TipSet)
  • func (f *TipSetFilter) ID() types.FilterID
  • func (f *TipSetFilter) LastTaken() time.Time
  • func (f *TipSetFilter) SetSubChannel(ch chan<- interface{})
  • func (f *TipSetFilter) TakeCollectedTipSets(context.Context) []types.TipSetKey
• type TipSetFilterManager
  • func (m *TipSetFilterManager) Apply(ctx context.Context, from, to *types.TipSet) error
  • func (m *TipSetFilterManager) Install(ctx context.Context) (*TipSetFilter, error)
  • func (m *TipSetFilterManager) Remove(ctx context.Context, id types.FilterID) error
  • func (m *TipSetFilterManager) Revert(ctx context.Context, from, to *types.TipSet) error

Variables

var (
	ErrFilterAlreadyRegistered = errors.New("filter already registered")
	ErrFilterNotFound          = errors.New("filter not found")
	ErrMaximumNumberOfFilters  = errors.New("maximum number of filters registered")
)

Types

type CollectedEvent

type CollectedEvent struct {
	Entries     []types.EventEntry
	EmitterAddr address.Address // f4 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

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

func (*EventFilter) ClearSubChannel

func (f *EventFilter) ClearSubChannel()

func (*EventFilter) CollectEvents

func (f *EventFilter) CollectEvents(ctx context.Context, te *TipSetEvents, revert bool, resolver func(ctx context.Context, emitter abi.ActorID, ts *types.TipSet) (address.Address, bool)) error

func (*EventFilter) ID

func (f *EventFilter) ID() types.FilterID

func (*EventFilter) LastTaken

func (f *EventFilter) LastTaken() time.Time

func (*EventFilter) SetSubChannel

func (f *EventFilter) SetSubChannel(ch chan<- interface{})

func (*EventFilter) TakeCollectedEvents

func (f *EventFilter) TakeCollectedEvents(ctx context.Context) []*CollectedEvent

type EventFilterManager

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
}

func (*EventFilterManager) Apply

func (m *EventFilterManager) Apply(ctx context.Context, from, to *types.TipSet) error

func (*EventFilterManager) Install

func (m *EventFilterManager) Install(ctx context.Context, minHeight, maxHeight abi.ChainEpoch, tipsetCid cid.Cid, addresses []address.Address, keys map[string][][]byte) (*EventFilter, error)

func (*EventFilterManager) Remove

func (m *EventFilterManager) Remove(ctx context.Context, id types.FilterID) error

func (*EventFilterManager) Revert

func (m *EventFilterManager) Revert(ctx context.Context, from, to *types.TipSet) error

type EventIndex

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

func NewEventIndex

func NewEventIndex(path string) (*EventIndex, error)

func (*EventIndex) Close

func (ei *EventIndex) Close() error

func (*EventIndex) CollectEvents

func (ei *EventIndex) CollectEvents(ctx context.Context, te *TipSetEvents, revert bool, resolver func(ctx context.Context, emitter abi.ActorID, ts *types.TipSet) (address.Address, bool)) error

func (*EventIndex) PrefillFilter

func (ei *EventIndex) PrefillFilter(ctx context.Context, f *EventFilter) error

PrefillFilter fills a filter's collection of events from the historic index

type Filter

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

type FilterStore

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
}

func NewMemFilterStore

func NewMemFilterStore(maxFilters int) FilterStore

type MemPoolFilter

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

func (*MemPoolFilter) ClearSubChannel

func (f *MemPoolFilter) ClearSubChannel()

func (*MemPoolFilter) CollectMessage

func (f *MemPoolFilter) CollectMessage(ctx context.Context, msg *types.SignedMessage)

func (*MemPoolFilter) ID

func (f *MemPoolFilter) ID() types.FilterID

func (*MemPoolFilter) LastTaken

func (f *MemPoolFilter) LastTaken() time.Time

func (*MemPoolFilter) SetSubChannel

func (f *MemPoolFilter) SetSubChannel(ch chan<- interface{})

func (*MemPoolFilter) TakeCollectedMessages

func (f *MemPoolFilter) TakeCollectedMessages(context.Context) []*types.SignedMessage

type MemPoolFilterManager

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

func (*MemPoolFilterManager) Install

func (m *MemPoolFilterManager) Install(ctx context.Context) (*MemPoolFilter, error)

func (*MemPoolFilterManager) Remove

func (m *MemPoolFilterManager) Remove(ctx context.Context, id types.FilterID) error

func (*MemPoolFilterManager) WaitForMpoolUpdates

func (m *MemPoolFilterManager) WaitForMpoolUpdates(ctx context.Context, ch <-chan types.MpoolUpdate)

type TipSetEvents

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

func (*TipSetEvents) Cid

func (te *TipSetEvents) Cid() (cid.Cid, error)

func (*TipSetEvents) Height

func (te *TipSetEvents) Height() abi.ChainEpoch

type TipSetFilter

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

func (*TipSetFilter) ClearSubChannel

func (f *TipSetFilter) ClearSubChannel()

func (*TipSetFilter) CollectTipSet

func (f *TipSetFilter) CollectTipSet(ctx context.Context, ts *types.TipSet)

func (*TipSetFilter) ID

func (f *TipSetFilter) ID() types.FilterID

func (*TipSetFilter) LastTaken

func (f *TipSetFilter) LastTaken() time.Time

func (*TipSetFilter) SetSubChannel

func (f *TipSetFilter) SetSubChannel(ch chan<- interface{})

func (*TipSetFilter) TakeCollectedTipSets

func (f *TipSetFilter) TakeCollectedTipSets(context.Context) []types.TipSetKey

type TipSetFilterManager

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

func (*TipSetFilterManager) Apply

func (m *TipSetFilterManager) Apply(ctx context.Context, from, to *types.TipSet) error

func (*TipSetFilterManager) Install

func (m *TipSetFilterManager) Install(ctx context.Context) (*TipSetFilter, error)

func (*TipSetFilterManager) Remove

func (m *TipSetFilterManager) Remove(ctx context.Context, id types.FilterID) error

func (*TipSetFilterManager) Revert

func (m *TipSetFilterManager) Revert(ctx context.Context, from, to *types.TipSet) error