actorevent

Documentation

Index

• Variables
• type ActorEventDummy
  • func (a *ActorEventDummy) GetActorEventsRaw(ctx context.Context, filter *types.ActorEventFilter) ([]*types.ActorEvent, error)
  • func (a *ActorEventDummy) SubscribeActorEventsRaw(ctx context.Context, filter *types.ActorEventFilter) (<-chan *types.ActorEvent, error)
• type ActorEventHandler
  • func NewActorEventHandler(chain ChainAccessor, eventFilterManager EventFilterManager, ...) *ActorEventHandler
  • func NewActorEventHandlerWithClock(chain ChainAccessor, eventFilterManager EventFilterManager, ...) *ActorEventHandler
  • func (a *ActorEventHandler) GetActorEventsRaw(ctx context.Context, evtFilter *types.ActorEventFilter) ([]*types.ActorEvent, error)
  • func (a *ActorEventHandler) SubscribeActorEventsRaw(ctx context.Context, evtFilter *types.ActorEventFilter) (<-chan *types.ActorEvent, error)
• type ActorEventSubModule
  • func NewActorEventSubModule(ctx context.Context, cfg *config.Config, chainModule *chain.ChainSubmodule, ...) (*ActorEventSubModule, error)
  • func (aem *ActorEventSubModule) API() v1api.IActorEvent
• type ChainAccessor
• type EventFilterManager

Variables

var ErrActorEventModuleDisabled = errors.New("module disabled, enable with Fevm.EnableActorEventsAPI")

Types

type ActorEventDummy

type ActorEventDummy struct{} // nolint

func (*ActorEventDummy) GetActorEventsRaw

func (a *ActorEventDummy) GetActorEventsRaw(ctx context.Context, filter *types.ActorEventFilter) ([]*types.ActorEvent, error)

func (*ActorEventDummy) SubscribeActorEventsRaw

func (a *ActorEventDummy) SubscribeActorEventsRaw(ctx context.Context, filter *types.ActorEventFilter) (<-chan *types.ActorEvent, error)

type ActorEventHandler

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

func NewActorEventHandler

func NewActorEventHandler(
	chain ChainAccessor,
	eventFilterManager EventFilterManager,
	blockDelay time.Duration,
	maxFilterHeightRange abi.ChainEpoch,
) *ActorEventHandler

func NewActorEventHandlerWithClock

func NewActorEventHandlerWithClock(
	chain ChainAccessor,
	eventFilterManager EventFilterManager,
	blockDelay time.Duration,
	maxFilterHeightRange abi.ChainEpoch,
	clock clock.Clock,
) *ActorEventHandler

func (*ActorEventHandler) GetActorEventsRaw

func (a *ActorEventHandler) GetActorEventsRaw(ctx context.Context, evtFilter *types.ActorEventFilter) ([]*types.ActorEvent, error)

func (*ActorEventHandler) SubscribeActorEventsRaw

func (a *ActorEventHandler) SubscribeActorEventsRaw(ctx context.Context, evtFilter *types.ActorEventFilter) (<-chan *types.ActorEvent, error)

type ActorEventSubModule

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

func NewActorEventSubModule

func NewActorEventSubModule(ctx context.Context,
	cfg *config.Config,
	chainModule *chain.ChainSubmodule,
	ethModule *eth.EthSubModule,
) (*ActorEventSubModule, error)

func (*ActorEventSubModule) API

func (aem *ActorEventSubModule) API() v1api.IActorEvent

type ChainAccessor

type ChainAccessor interface {
	GetHead() *types.TipSet
}

type EventFilterManager

type EventFilterManager interface {
	Install(
		ctx context.Context,
		minHeight, maxHeight abi.ChainEpoch,
		tipsetCid cid.Cid,
		addresses []address.Address,
		keysWithCodec map[string][]types.ActorEventBlock,
		excludeReverted bool,
	) (filter.EventFilter, error)
	Remove(ctx context.Context, id types.FilterID) error
}