mon

Feb 10, 2025

Changes in this version

+ type HeadBlockFetcher func(ctx context.Context) (eth.L1BlockRef, error)

Nov 8, 2024

Changes in this version

+ type UpdateTimeMetrics interface

+ RecordOldestGameUpdateTime func(t time.Time)

+ type UpdateTimeMonitor struct

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

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

Sep 25, 2024

Changes in this version

type WithdrawalMetrics

+ RecordHonestWithdrawableAmounts func(map[common.Address]*big.Int)

Aug 7, 2024

Changes in this version

type ForecastMetrics

+ RecordLatestValidProposalL2Block func(validL2Block uint64)

May 23, 2024

Changes in this version

+ const MaxResolveDelay

+ const MaximumResolutionResponseBuffer

type ClaimMetrics

+ RecordHonestActorClaims func(address common.Address, data *metrics.HonestActorData)

type Forecast

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

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

type ForecastMetrics

+ RecordFailedGames func(count int)

+ RecordIgnoredGames func(count int)

+ RecordLatestProposals func(validTimestamp, invalidTimestamp uint64)

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

+ type L2ChallengesMetrics interface

+ RecordL2Challenges func(agreement bool, count int)

+ type L2ChallengesMonitor struct

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

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

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

+ type MonitorMetrics interface

+ RecordMonitorDuration func(dur time.Duration)

Apr 8, 2024

Changes in this version

+ type ClaimMetrics interface

+ RecordClaims func(status metrics.ClaimStatus, count int)

+ RecordUnexpectedClaimResolution func(address common.Address, count int)

+ type ClaimMonitor struct

+ func NewClaimMonitor(logger log.Logger, clock RClock, honestActors []common.Address, ...) *ClaimMonitor

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

+ type MonitorClaims func(games []*types.EnrichedGameData)

+ type MonitorWithdrawals func(games []*types.EnrichedGameData)

+ type RClock interface

+ Now func() time.Time

+ type ResolutionMetrics interface

+ RecordGameResolutionStatus func(complete bool, maxDurationReached bool, count int)

+ type ResolutionMonitor struct

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

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

+ type Resolutions func(games []*types.EnrichedGameData)

+ type WithdrawalMetrics interface

+ RecordWithdrawalRequests func(delayedWeth common.Address, matches bool, count int)

+ type WithdrawalMonitor struct

+ func NewWithdrawalMonitor(logger log.Logger, metrics WithdrawalMetrics) *WithdrawalMonitor

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

Mar 20, 2024

Changes in this version

+ type Bonds func(games []*types.EnrichedGameData)

type ForecastMetrics

+ RecordClaimResolutionDelayMax func(delay float64)

+ type OutputMetrics interface

+ RecordOutputFetchTime func(float64)

type OutputRollupClient

+ SafeHeadAtL1Block func(ctx context.Context, blockNum uint64) (*eth.SafeHeadResponse, error)

+ type RecordClaimResolutionDelayMax func([]*types.EnrichedGameData)

Feb 22, 2024

Changes in this version

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

Feb 15, 2024

Changes in this version

+ var ErrClaimFetch = errors.New("failed to fetch game claims")

+ var ErrContractCreation = errors.New("failed to create contract")

+ var ErrMetadataFetch = errors.New("failed to fetch game metadata")

+ var ErrResolver = errors.New("failed to resolve game")

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

+ func Resolve(claims []faultTypes.Claim) (types.GameStatus, error)

+ type BidirectionalClaim struct

+ Children []*BidirectionalClaim

+ Claim *faultTypes.Claim

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

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

+ type Detect func(ctx context.Context, games []types.GameMetadata)

+ type DetectorMetrics interface

+ RecordGameAgreement func(status string, count int)

+ RecordGamesStatus func(inProgress, defenderWon, challengerWon int)

+ type FactoryGameFetcher func(ctx context.Context, blockHash common.Hash, earliestTimestamp uint64) ([]types.GameMetadata, error)

+ type Forecast func(ctx context.Context, games []types.GameMetadata)

+ type ForecastMetrics interface

+ RecordGameAgreement func(status string, count int)

+ type GameCallerCreator interface

+ CreateContract func(game types.GameMetadata) (extract.GameCaller, error)

+ type OutputRollupClient interface

+ OutputAtBlock func(ctx context.Context, blockNum uint64) (*eth.OutputResponse, error)

+ type OutputValidator interface

+ CheckRootAgreement func(ctx context.Context, blockNum uint64, root common.Hash) (bool, common.Hash, error)

Feb 8, 2024

Changes in this version

+ func NewMetadataCreator(m caching.Metrics, caller *batching.MultiCaller) *metadataCreator

+ type MetadataCreator interface

+ CreateContract func(game types.GameMetadata) (MetadataLoader, error)

+ type MetadataLoader interface

+ GetGameMetadata func(context.Context) (uint64, common.Hash, types.GameStatus, error)

+ type MonitorMetricer interface

+ RecordGamesStatus func(inProgress, defenderWon, challengerWon int)

+ type Service struct

+ 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