extract

Documentation

Index

• Variables
• type BalanceCaller
• type BalanceEnricher
  • func NewBalanceEnricher() *BalanceEnricher
  • func (b *BalanceEnricher) Enrich(ctx context.Context, block rpcblock.Block, caller GameCaller, ...) error
• type BlockFetcher
• type BondCaller
• type BondEnricher
  • func NewBondEnricher() *BondEnricher
  • func (b *BondEnricher) Enrich(ctx context.Context, block rpcblock.Block, caller GameCaller, ...) error
• type CreateGameCaller
• type Enricher
• type Extractor
  • func NewExtractor(logger log.Logger, creator CreateGameCaller, fetchGames FactoryGameFetcher, ...) *Extractor
  • func (e *Extractor) Extract(ctx context.Context, blockHash common.Hash, minTimestamp uint64) ([]*monTypes.EnrichedGameData, error)
• type FactoryGameFetcher
• type GameCaller
• type GameCallerCreator
  • func NewGameCallerCreator(m caching.Metrics, caller *batching.MultiCaller) *GameCallerCreator
  • func (g *GameCallerCreator) CreateContract(game types.GameMetadata) (GameCaller, error)
• type L1HeadBlockNumEnricher
  • func NewL1HeadBlockNumEnricher(client BlockFetcher) *L1HeadBlockNumEnricher
  • func (e *L1HeadBlockNumEnricher) Enrich(ctx context.Context, _ rpcblock.Block, _ GameCaller, ...) error

Variables

var ErrIncorrectCreditCount = errors.New("incorrect credit count")

Types

type BalanceCaller

type BalanceCaller interface {
	GetBalance(context.Context, rpcblock.Block) (*big.Int, common.Address, error)
}

type BalanceEnricher

type BalanceEnricher struct{}

func NewBalanceEnricher

func NewBalanceEnricher() *BalanceEnricher

func (*BalanceEnricher) Enrich

func (b *BalanceEnricher) Enrich(ctx context.Context, block rpcblock.Block, caller GameCaller, game *monTypes.EnrichedGameData) error

type BlockFetcher

type BlockFetcher interface {
	HeaderByHash(ctx context.Context, block common.Hash) (*types.Header, error)
}

type BondCaller

type BondCaller interface {
	GetCredits(context.Context, rpcblock.Block, ...common.Address) ([]*big.Int, error)
}

type BondEnricher

type BondEnricher struct{}

func NewBondEnricher

func NewBondEnricher() *BondEnricher

func (*BondEnricher) Enrich

func (b *BondEnricher) Enrich(ctx context.Context, block rpcblock.Block, caller GameCaller, game *monTypes.EnrichedGameData) error

type CreateGameCaller

type CreateGameCaller func(game gameTypes.GameMetadata) (GameCaller, error)

type Enricher

type Enricher interface {
	Enrich(ctx context.Context, block rpcblock.Block, caller GameCaller, game *monTypes.EnrichedGameData) error
}

type Extractor

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

func NewExtractor

func NewExtractor(logger log.Logger, creator CreateGameCaller, fetchGames FactoryGameFetcher, enrichers ...Enricher) *Extractor

func (*Extractor) Extract

func (e *Extractor) Extract(ctx context.Context, blockHash common.Hash, minTimestamp uint64) ([]*monTypes.EnrichedGameData, error)

type FactoryGameFetcher

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

type GameCaller

type GameCaller interface {
	GetGameMetadata(context.Context, rpcblock.Block) (common.Hash, uint64, common.Hash, types.GameStatus, uint64, error)
	GetAllClaims(context.Context, rpcblock.Block) ([]faultTypes.Claim, error)
	BondCaller
	BalanceCaller
}

type GameCallerCreator

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

func NewGameCallerCreator

func NewGameCallerCreator(m caching.Metrics, caller *batching.MultiCaller) *GameCallerCreator

func (*GameCallerCreator) CreateContract

func (g *GameCallerCreator) CreateContract(game types.GameMetadata) (GameCaller, error)

type L1HeadBlockNumEnricher

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

func NewL1HeadBlockNumEnricher

func NewL1HeadBlockNumEnricher(client BlockFetcher) *L1HeadBlockNumEnricher

func (*L1HeadBlockNumEnricher) Enrich

func (e *L1HeadBlockNumEnricher) Enrich(ctx context.Context, _ rpcblock.Block, _ GameCaller, game *monTypes.EnrichedGameData) error