iterator

Documentation

Index

• Variables
• func GetDefaultSlotLocation(forkEpochs state.ForkEpochs, cannonType xatu.CannonType) phase0.Slot
• func NewSlotDefaultsFromForkEpochs(forkEpochs state.ForkEpochs) map[xatu.CannonType]phase0.Slot
• type BlockprintIterator
  • func NewBlockprintIterator(log logrus.FieldLogger, networkName, networkID string, ...) *BlockprintIterator
  • func (c *BlockprintIterator) Next(ctx context.Context) (next *xatu.CannonLocation, lookAhead []*xatu.CannonLocation, err error)
  • func (c *BlockprintIterator) UpdateLocation(ctx context.Context, location *xatu.CannonLocation) error
  • func (c *BlockprintIterator) WithBlockprintClient(client *blockprint.Client)
• type BlockprintMetrics
  • func NewBlockprintMetrics(namespace string) BlockprintMetrics
  • func (s *BlockprintMetrics) SetCurrentSlot(cannonType, network string, current float64)
  • func (s *BlockprintMetrics) SetTargetSlot(cannonType, network string, target float64)
• type CheckpointIterator
  • func NewCheckpointIterator(log logrus.FieldLogger, networkName, networkID string, ...) *CheckpointIterator
  • func (c *CheckpointIterator) Next(ctx context.Context) (next *xatu.CannonLocation, lookAhead []*xatu.CannonLocation, err error)
  • func (c *CheckpointIterator) UpdateLocation(ctx context.Context, location *xatu.CannonLocation) error
• type CheckpointMetrics
  • func NewCheckpointMetrics(namespace string) CheckpointMetrics
  • func (s *CheckpointMetrics) SetCurrentEpoch(cannonType, network, checkpoint string, current float64)
  • func (s *CheckpointMetrics) SetTrailingEpochs(cannonType, network, checkpoint string, trailing float64)
• type Iterator
• type SlotMetrics
  • func NewSlotMetrics(namespace string) SlotMetrics
  • func (s *SlotMetrics) SetCurrentSlot(cannonType, network string, currentSlot float64)
  • func (s *SlotMetrics) SetTrailingSlots(cannonType, network string, trailingSlots float64)

Variables

var (
	ErrLocationUpToDate = errors.New("location up to date")

	SlotZero = phase0.Slot(0)
)

Functions

func GetDefaultSlotLocation

func GetDefaultSlotLocation(forkEpochs state.ForkEpochs, cannonType xatu.CannonType) phase0.Slot

func NewSlotDefaultsFromForkEpochs

func NewSlotDefaultsFromForkEpochs(forkEpochs state.ForkEpochs) map[xatu.CannonType]phase0.Slot

Types

type BlockprintIterator

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

func NewBlockprintIterator

func NewBlockprintIterator(log logrus.FieldLogger, networkName, networkID string, cannonType xatu.CannonType, coordinatorClient *coordinator.Client, metrics *BlockprintMetrics, client *blockprint.Client) *BlockprintIterator

func (*BlockprintIterator) Next

func (c *BlockprintIterator) Next(ctx context.Context) (next *xatu.CannonLocation, lookAhead []*xatu.CannonLocation, err error)

func (*BlockprintIterator) UpdateLocation

func (c *BlockprintIterator) UpdateLocation(ctx context.Context, location *xatu.CannonLocation) error

func (*BlockprintIterator) WithBlockprintClient

func (c *BlockprintIterator) WithBlockprintClient(client *blockprint.Client)

type BlockprintMetrics

type BlockprintMetrics struct {
	Targetslot  *prometheus.GaugeVec
	Currentslot *prometheus.GaugeVec
}

func NewBlockprintMetrics

func NewBlockprintMetrics(namespace string) BlockprintMetrics

func (*BlockprintMetrics) SetCurrentSlot

func (s *BlockprintMetrics) SetCurrentSlot(cannonType, network string, current float64)

func (*BlockprintMetrics) SetTargetSlot

func (s *BlockprintMetrics) SetTargetSlot(cannonType, network string, target float64)

type CheckpointIterator

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

func NewCheckpointIterator

func NewCheckpointIterator(log logrus.FieldLogger, networkName, networkID string, cannonType xatu.CannonType, coordinatorClient *coordinator.Client, wallclock *ethwallclock.EthereumBeaconChain, metrics *CheckpointMetrics, beacon *ethereum.BeaconNode, checkpoint string) *CheckpointIterator

func (*CheckpointIterator) Next

func (c *CheckpointIterator) Next(ctx context.Context) (next *xatu.CannonLocation, lookAhead []*xatu.CannonLocation, err error)

func (*CheckpointIterator) UpdateLocation

func (c *CheckpointIterator) UpdateLocation(ctx context.Context, location *xatu.CannonLocation) error

type CheckpointMetrics

type CheckpointMetrics struct {
	Trailingepochs *prometheus.GaugeVec
	Currentepoch   *prometheus.GaugeVec
}

func NewCheckpointMetrics

func NewCheckpointMetrics(namespace string) CheckpointMetrics

func (*CheckpointMetrics) SetCurrentEpoch

func (s *CheckpointMetrics) SetCurrentEpoch(cannonType, network, checkpoint string, current float64)

func (*CheckpointMetrics) SetTrailingEpochs

func (s *CheckpointMetrics) SetTrailingEpochs(cannonType, network, checkpoint string, trailing float64)

type Iterator

type Iterator interface {
	UpdateLocation(ctx context.Context, location *xatu.CannonLocation) error
	Next(ctx context.Context) (next *xatu.CannonLocation, lookAhead []*xatu.CannonLocation, err error)
}

type SlotMetrics

type SlotMetrics struct {
	TrailingSlots *prometheus.GaugeVec
	CurrentSlot   *prometheus.GaugeVec
}

func NewSlotMetrics

func NewSlotMetrics(namespace string) SlotMetrics

func (*SlotMetrics) SetCurrentSlot

func (s *SlotMetrics) SetCurrentSlot(cannonType, network string, currentSlot float64)

func (*SlotMetrics) SetTrailingSlots

func (s *SlotMetrics) SetTrailingSlots(cannonType, network string, trailingSlots float64)