mon

Documentation

Index

• Constants
• Variables
• func Resolve(tree *monTypes.BidirectionalTree) gameTypes.GameStatus
• type BlockHashFetcher
• type BlockNumberFetcher
• type ClaimMetrics
• type ClaimMonitor
  • func NewClaimMonitor(logger log.Logger, clock RClock, honestActors types.HonestActors, ...) *ClaimMonitor
  • func (c *ClaimMonitor) CheckClaims(games []*types.EnrichedGameData)
• type Extract
• type Forecast
  • func NewForecast(logger log.Logger, metrics ForecastMetrics) *Forecast
  • func (f *Forecast) Forecast(games []*monTypes.EnrichedGameData, ignoredCount, failedCount int)
• type ForecastMetrics
• type ForecastResolution
• type L2ChallengesMetrics
• type L2ChallengesMonitor
  • func NewL2ChallengesMonitor(logger log.Logger, metrics L2ChallengesMetrics) *L2ChallengesMonitor
  • func (m *L2ChallengesMonitor) CheckL2Challenges(games []*types.EnrichedGameData)
• type Monitor
• type MonitorMetrics
• type RClock
• type ResolutionMetrics
• type ResolutionMonitor
  • func NewResolutionMonitor(logger log.Logger, metrics ResolutionMetrics, clock RClock) *ResolutionMonitor
  • func (r *ResolutionMonitor) CheckResolutions(games []*types.EnrichedGameData)
• type Service
  • func NewService(ctx context.Context, logger log.Logger, cfg *config.Config) (*Service, error)
  • func (s *Service) Start(ctx context.Context) error
  • func (s *Service) Stop(ctx context.Context) error
  • func (s *Service) Stopped() bool
• type UpdateTimeMetrics
• type UpdateTimeMonitor
  • func NewUpdateTimeMonitor(cl clock.Clock, metrics UpdateTimeMetrics) *UpdateTimeMonitor
  • func (m *UpdateTimeMonitor) CheckUpdateTimes(games []*types.EnrichedGameData)
• type WithdrawalMetrics
• type WithdrawalMonitor
  • func NewWithdrawalMonitor(logger log.Logger, clock RClock, metrics WithdrawalMetrics, ...) *WithdrawalMonitor
  • func (w *WithdrawalMonitor) CheckWithdrawals(games []*types.EnrichedGameData)

Constants

const MaxResolveDelay = time.Minute

const MaximumResolutionResponseBuffer = time.Minute

Variables

var (
	ErrRootAgreement = errors.New("failed to check root agreement")
)

Functions

func Resolve

func Resolve(tree *monTypes.BidirectionalTree) gameTypes.GameStatus

Resolve iterates backwards over the bidirectional tree, iteratively checking the leftmost counter of each claim, and updating the claim's counter claimant. Once the root claim is reached, the resolution game status is returned.

Types

type BlockHashFetcher

type BlockHashFetcher func(ctx context.Context, number *big.Int) (common.Hash, error)

type BlockNumberFetcher

type BlockNumberFetcher func(ctx context.Context) (uint64, error)

type ClaimMetrics

type ClaimMetrics interface {
	RecordClaims(statuses *metrics.ClaimStatuses)
	RecordHonestActorClaims(address common.Address, data *metrics.HonestActorData)
}

type ClaimMonitor

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

func NewClaimMonitor

func NewClaimMonitor(logger log.Logger, clock RClock, honestActors types.HonestActors, metrics ClaimMetrics) *ClaimMonitor

func (*ClaimMonitor) CheckClaims

func (c *ClaimMonitor) CheckClaims(games []*types.EnrichedGameData)

type Extract

type Extract func(ctx context.Context, blockHash common.Hash, minTimestamp uint64) ([]*types.EnrichedGameData, int, int, error)

type Forecast

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

func NewForecast

func NewForecast(logger log.Logger, metrics ForecastMetrics) *Forecast

func (*Forecast) Forecast

func (f *Forecast) Forecast(games []*monTypes.EnrichedGameData, ignoredCount, failedCount int)

type ForecastMetrics

type ForecastMetrics interface {
	RecordGameAgreement(status metrics.GameAgreementStatus, count int)
	RecordLatestValidProposalL2Block(validL2Block uint64)
	RecordLatestProposals(validTimestamp, invalidTimestamp uint64)
	RecordIgnoredGames(count int)
	RecordFailedGames(count int)
}

type ForecastResolution

type ForecastResolution func(games []*types.EnrichedGameData, ignoredCount, failedCount int)

type L2ChallengesMetrics

type L2ChallengesMetrics interface {
	RecordL2Challenges(agreement bool, count int)
}

type L2ChallengesMonitor

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

func NewL2ChallengesMonitor

func NewL2ChallengesMonitor(logger log.Logger, metrics L2ChallengesMetrics) *L2ChallengesMonitor

func (*L2ChallengesMonitor) CheckL2Challenges

func (m *L2ChallengesMonitor) CheckL2Challenges(games []*types.EnrichedGameData)

type Monitor

type Monitor func(games []*types.EnrichedGameData)

type MonitorMetrics

type MonitorMetrics interface {
	RecordMonitorDuration(dur time.Duration)
}

type RClock

type RClock interface {
	Now() time.Time
}

type ResolutionMetrics

type ResolutionMetrics interface {
	RecordGameResolutionStatus(status metrics.ResolutionStatus, count int)
}

type ResolutionMonitor

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

func NewResolutionMonitor

func NewResolutionMonitor(logger log.Logger, metrics ResolutionMetrics, clock RClock) *ResolutionMonitor

func (*ResolutionMonitor) CheckResolutions

func (r *ResolutionMonitor) CheckResolutions(games []*types.EnrichedGameData)

type Service

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

func NewService

func NewService(ctx context.Context, logger log.Logger, cfg *config.Config) (*Service, error)

NewService creates a new Service.

func (*Service) Start

func (s *Service) Start(ctx context.Context) error

func (*Service) Stop

func (s *Service) Stop(ctx context.Context) error

func (*Service) Stopped

func (s *Service) Stopped() bool

type UpdateTimeMetrics

type UpdateTimeMetrics interface {
	RecordOldestGameUpdateTime(t time.Time)
}

type UpdateTimeMonitor

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

func NewUpdateTimeMonitor

func NewUpdateTimeMonitor(cl clock.Clock, metrics UpdateTimeMetrics) *UpdateTimeMonitor

func (*UpdateTimeMonitor) CheckUpdateTimes

func (m *UpdateTimeMonitor) CheckUpdateTimes(games []*types.EnrichedGameData)

type WithdrawalMetrics

type WithdrawalMetrics interface {
	RecordWithdrawalRequests(delayedWeth common.Address, matches bool, count int)
	RecordHonestWithdrawableAmounts(map[common.Address]*big.Int)
}

type WithdrawalMonitor

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

func NewWithdrawalMonitor

func NewWithdrawalMonitor(logger log.Logger, clock RClock, metrics WithdrawalMetrics, honestActors types.HonestActors) *WithdrawalMonitor

func (*WithdrawalMonitor) CheckWithdrawals

func (w *WithdrawalMonitor) CheckWithdrawals(games []*types.EnrichedGameData)