Documentation
¶
Index ¶
- Variables
- type AddressResolver
- type CollectedEvent
- type EventFilter
- 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
- type Filter
- type 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
- type TipSetEvents
- 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
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type AddressResolver ¶ added in v1.15.0
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 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 { 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) 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)
type EventIndex ¶
type EventIndex struct {
// contains filtered or unexported fields
}
func NewEventIndex ¶
func (*EventIndex) Close ¶
func (ei *EventIndex) Close() error
func (*EventIndex) CollectEvents ¶
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) 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) Install ¶
func (m *TipSetFilterManager) Install(ctx context.Context) (*TipSetFilter, error)
Click to show internal directories.
Click to hide internal directories.