filter

package
v1.28.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 24, 2024 License: Apache-2.0, MIT Imports: 23 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

Types

type AddressResolver added in v1.26.0 

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

type CollectedEvent 

type CollectedEvent struct {
	Entries     []types.EventEntry
	EmitterAddr address.Address // address of emitter
	EventIdx    int             // index of the event within the list of emitted events in a given tipset
	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 interface {
	Filter

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

type EventFilterManager 

type EventFilterManager struct {
	ChainStore       *cstore.ChainStore
	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,
	keysWithCodec map[string][]types.ActorEventBlock, excludeReverted bool) (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(ctx context.Context, path string, chainStore *store.ChainStore) (*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) GetMaxHeightInIndex added in v1.27.2 

func (ei *EventIndex) GetMaxHeightInIndex(ctx context.Context) (uint64, error)

func (*EventIndex) IsHeightPast added in v1.28.0 

func (ei *EventIndex) IsHeightPast(ctx context.Context, height uint64) (bool, error)

func (*EventIndex) IsTipsetProcessed added in v1.27.2 

func (ei *EventIndex) IsTipsetProcessed(ctx context.Context, tipsetKeyCid []byte) (bool, error)

func (*EventIndex) SubscribeUpdates added in v1.27.2 

func (ei *EventIndex) SubscribeUpdates() (chan EventIndexUpdated, func())

type EventIndexUpdated added in v1.27.2 

type EventIndexUpdated struct{}

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 api.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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.