mon

Documentation

Index

• Variables
• func Resolve(claims []faultTypes.Claim) (types.GameStatus, error)
• type BidirectionalClaim
• type BlockHashFetcher
• type BlockNumberFetcher
• type Detect
• type DetectorMetrics
• type FactoryGameFetcher
• type Forecast
• type ForecastMetrics
• type GameCallerCreator
• type OutputRollupClient
• type OutputValidator
• 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

Variables

var (
	ErrContractCreation = errors.New("failed to create contract")
	ErrMetadataFetch    = errors.New("failed to fetch game metadata")
	ErrClaimFetch       = errors.New("failed to fetch game claims")
	ErrResolver         = errors.New("failed to resolve game")
	ErrRootAgreement    = errors.New("failed to check root agreement")
)

Functions

func Resolve

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

Resolve creates the bidirectional tree of claims and then computes the resolved game status.

Types

type BidirectionalClaim

type BidirectionalClaim struct {
	Claim    *faultTypes.Claim
	Children []*BidirectionalClaim
}

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 Detect

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

type DetectorMetrics

type DetectorMetrics interface {
	RecordGameAgreement(status string, count int)
	RecordGamesStatus(inProgress, defenderWon, challengerWon int)
}

type FactoryGameFetcher

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

type Forecast

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

type ForecastMetrics

type ForecastMetrics interface {
	RecordGameAgreement(status string, count int)
}

type GameCallerCreator

type GameCallerCreator interface {
	CreateContract(game types.GameMetadata) (extract.GameCaller, error)
}

type OutputRollupClient

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

type OutputValidator

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

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