claims

Documentation

Index

• type BondClaimMetrics
• type BondClaimScheduler
  • func NewBondClaimScheduler(logger log.Logger, metrics BondClaimSchedulerMetrics, claimer BondClaimer) *BondClaimScheduler
  • func (s *BondClaimScheduler) Close() error
  • func (s *BondClaimScheduler) Schedule(blockNumber uint64, games []types.GameMetadata) error
  • func (s *BondClaimScheduler) Start(ctx context.Context)
• type BondClaimSchedulerMetrics
• type BondClaimer
• type BondContract
• type BondContractCreator
• type Claimer
  • func NewBondClaimer(l log.Logger, m BondClaimMetrics, contractCreator BondContractCreator, ...) *Claimer
  • func (c *Claimer) ClaimBonds(ctx context.Context, games []types.GameMetadata) (err error)
• type TxSender

Types

type BondClaimMetrics

type BondClaimMetrics interface {
	RecordBondClaimed(amount uint64)
}

type BondClaimScheduler

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

func NewBondClaimScheduler

func NewBondClaimScheduler(logger log.Logger, metrics BondClaimSchedulerMetrics, claimer BondClaimer) *BondClaimScheduler

func (*BondClaimScheduler) Close

func (s *BondClaimScheduler) Close() error

func (*BondClaimScheduler) Schedule

func (s *BondClaimScheduler) Schedule(blockNumber uint64, games []types.GameMetadata) error

func (*BondClaimScheduler) Start

func (s *BondClaimScheduler) Start(ctx context.Context)

type BondClaimSchedulerMetrics

type BondClaimSchedulerMetrics interface {
	RecordBondClaimFailed()
}

type BondClaimer

type BondClaimer interface {
	ClaimBonds(ctx context.Context, games []types.GameMetadata) error
}

type BondContract

type BondContract interface {
	GetCredit(ctx context.Context, recipient common.Address) (*big.Int, types.GameStatus, error)
	ClaimCreditTx(ctx context.Context, recipient common.Address) (txmgr.TxCandidate, error)
}

type BondContractCreator

type BondContractCreator func(game types.GameMetadata) (BondContract, error)

type Claimer

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

func NewBondClaimer

func NewBondClaimer(l log.Logger, m BondClaimMetrics, contractCreator BondContractCreator, txSender TxSender, claimants ...common.Address) *Claimer

func (*Claimer) ClaimBonds

func (c *Claimer) ClaimBonds(ctx context.Context, games []types.GameMetadata) (err error)

type TxSender

type TxSender interface {
	SendAndWaitSimple(txPurpose string, txs ...txmgr.TxCandidate) error
}