Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BackfillIterator ¶
type BackfillIterator struct {
// contains filtered or unexported fields
}
func NewBackfillIterator ¶
func NewBackfillIterator( log logrus.FieldLogger, networkName, clientName string, relayMonitorType xatu.RelayMonitorType, relayName string, coordinatorClient *coordinator.Client, wallclock *ethwallclock.EthereumBeaconChain, toSlot phase0.Slot, checkInterval time.Duration, ) *BackfillIterator
func (*BackfillIterator) UpdateLocation ¶
type ConsistencyMetrics ¶
type ConsistencyMetrics struct {
// Current slot being processed
CurrentSlot *prometheus.GaugeVec
// Lag (slots behind for forward fill, slots to go for backfill)
Lag *prometheus.GaugeVec
}
func NewConsistencyMetrics ¶
func NewConsistencyMetrics(namespace string) *ConsistencyMetrics
func (*ConsistencyMetrics) SetCurrentSlot ¶
func (m *ConsistencyMetrics) SetCurrentSlot(process, relay, eventType, network string, slot uint64)
func (*ConsistencyMetrics) SetLag ¶
func (m *ConsistencyMetrics) SetLag(process, relay, eventType, network string, lag int64)
type ForwardFillIterator ¶
type ForwardFillIterator struct {
// contains filtered or unexported fields
}
func NewForwardFillIterator ¶
func NewForwardFillIterator( log logrus.FieldLogger, networkName, clientName string, relayMonitorType xatu.RelayMonitorType, relayName string, coordinatorClient *coordinator.Client, wallclock *ethwallclock.EthereumBeaconChain, checkInterval time.Duration, trailDistance uint64, ) *ForwardFillIterator
func (*ForwardFillIterator) UpdateLocation ¶
Source Files
Click to show internal directories.
Click to hide internal directories.