events

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

type BeaconDataProvider interface {
	// GetWallclock returns the wallclock for the beacon chain.
	GetWallclock() *ethwallclock.EthereumBeaconChain
	// GetSlot returns the wallclock slot for a given slot number.
	GetSlot(slot uint64) ethwallclock.Slot
	// GetEpoch returns the wallclock epoch for a given epoch number.
	GetEpoch(epoch uint64) ethwallclock.Epoch
	// GetEpochFromSlot returns the wallclock epoch for a given slot number.
	GetEpochFromSlot(slot uint64) ethwallclock.Epoch
	// Synced returns true if the beacon node is synced.
	Synced(ctx context.Context) error
	// Node returns the underlying beacon node instance.
	Node() beacon.Node
}

type DuplicateCache struct {
	BeaconETHV1EventsBlock               *ttlcache.Cache[string, time.Time]
	BeaconETHV1EventsChainReorg          *ttlcache.Cache[string, time.Time]
	BeaconETHV1EventsFinalizedCheckpoint *ttlcache.Cache[string, time.Time]
	BeaconETHV1EventsHead                *ttlcache.Cache[string, time.Time]
	BeaconETHV1EventsBlobSidecar         *ttlcache.Cache[string, time.Time]
}

type Event interface {
	// Meta returns the metadata of the event.
	Meta() *xatu.Meta
	// Type returns the type of the event.
	Type() string
	// Time returns the time of the event.
	Time() time.Time
	// Data returns the data of the event.
	Data() interface{}
	// Decorated returns the decorated event.
	Decorated() *xatu.DecoratedEvent
	// Ignore returns true if the event should be ignored.
	Ignore(ctx context.Context) (bool, error)
}

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

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