listener

Documentation

Index

• type BeaconProvider
• type BlockStorer
• type EVMListener
  • func NewEVMListener(beaconProvider BeaconProvider, eventHandlers []EventHandler, domainID uint8, ...) *EVMListener
  • func (l *EVMListener) ListenToEvents(ctx context.Context, epoch *big.Int)
• type EventHandler

Types

type BeaconProvider

type BeaconProvider interface {
	Finality(ctx context.Context, opts *api.FinalityOpts) (*api.Response[*apiv1.Finality], error)
}

type BlockStorer

type BlockStorer interface {
	StoreBlock(epoch *big.Int, domainID uint8) error
}

type EVMListener

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

func NewEVMListener

func NewEVMListener(
	beaconProvider BeaconProvider,
	eventHandlers []EventHandler,
	domainID uint8,
	retryInterval time.Duration,
) *EVMListener

NewEVMListener creates an EVMListener that listens to deposit events on chain and calls event handler when one occurs

func (*EVMListener) ListenToEvents

func (l *EVMListener) ListenToEvents(ctx context.Context, epoch *big.Int)

ListenToEvents waits for new finality checkpoints and calls event handlers with the finalized epoch block range

type EventHandler

type EventHandler interface {
	HandleEvents(checkpoint *apiv1.Finality) error
}