mon

Documentation

Index

• Variables
• type BlockHashFetcher
• type BlockNumberFetcher
• type Bonds
• type ClaimMetrics
• type ClaimMonitor
  • func NewClaimMonitor(logger log.Logger, clock RClock, honestActors []common.Address, ...) *ClaimMonitor
  • func (c *ClaimMonitor) CheckClaims(games []*types.EnrichedGameData)
• type Extract
• type Forecast
• type ForecastMetrics
• type MonitorClaims
• type MonitorWithdrawals
• type OutputMetrics
• type OutputRollupClient
• type OutputValidator
• type RClock
• type RecordClaimResolutionDelayMax
• type ResolutionMetrics
• type ResolutionMonitor
  • func NewResolutionMonitor(logger log.Logger, metrics ResolutionMetrics, clock RClock) *ResolutionMonitor
  • func (r *ResolutionMonitor) CheckResolutions(games []*types.EnrichedGameData)
• type Resolutions
• 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 WithdrawalMetrics
• type WithdrawalMonitor
  • func NewWithdrawalMonitor(logger log.Logger, metrics WithdrawalMetrics) *WithdrawalMonitor
  • func (w *WithdrawalMonitor) CheckWithdrawals(games []*types.EnrichedGameData)

Variables

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

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 Bonds

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

type ClaimMetrics

type ClaimMetrics interface {
	RecordClaims(status metrics.ClaimStatus, count int)
	RecordUnexpectedClaimResolution(address common.Address, count int)
}

type ClaimMonitor

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

func NewClaimMonitor

func NewClaimMonitor(logger log.Logger, clock RClock, honestActors []common.Address, 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, error)

type Forecast

type Forecast func(ctx context.Context, games []*types.EnrichedGameData)

type ForecastMetrics

type ForecastMetrics interface {
	RecordClaimResolutionDelayMax(delay float64)
	RecordGameAgreement(status metrics.GameAgreementStatus, count int)
}

type MonitorClaims

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

type MonitorWithdrawals

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

type OutputMetrics

type OutputMetrics interface {
	RecordOutputFetchTime(float64)
}

type OutputRollupClient

type OutputRollupClient interface {
	OutputAtBlock(ctx context.Context, blockNum uint64) (*eth.OutputResponse, error)
	SafeHeadAtL1Block(ctx context.Context, blockNum uint64) (*eth.SafeHeadResponse, error)
}

type OutputValidator

type OutputValidator interface {
	CheckRootAgreement(ctx context.Context, l1HeadNum uint64, l2BlockNum uint64, root common.Hash) (bool, common.Hash, error)
}

type RClock

type RClock interface {
	Now() time.Time
}

type RecordClaimResolutionDelayMax

type RecordClaimResolutionDelayMax func([]*types.EnrichedGameData)

type ResolutionMetrics

type ResolutionMetrics interface {
	RecordGameResolutionStatus(complete bool, maxDurationReached bool, 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 Resolutions

type Resolutions func(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 WithdrawalMetrics

type WithdrawalMetrics interface {
	RecordWithdrawalRequests(delayedWeth common.Address, matches bool, count int)
}

type WithdrawalMonitor

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

func NewWithdrawalMonitor

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

func (*WithdrawalMonitor) CheckWithdrawals

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