storageincentives

Documentation

Index

• Constants
• type Agent
  • func New(overlay swarm.Address, ethAddress common.Address, backend ChainBackend, ...) (*Agent, error)
  • func (a *Agent) Close() error
  • func (a *Agent) HasEnoughFundsToPlay(ctx context.Context) (bool, error)
  • func (a *Agent) Metrics() []prometheus.Collector
  • func (a *Agent) Status() (*Status, error)
• type ChainBackend
• type Monitor
• type PhaseType
  • func (p PhaseType) String() string
• type RedistributionState
  • func NewRedistributionState(logger log.Logger, ethAddress common.Address, stateStore storage.StateStorer, ...) (*RedistributionState, error)
  • func (r *RedistributionState) AddFee(ctx context.Context, txHash common.Hash)
  • func (r *RedistributionState) CalculateWinnerReward(ctx context.Context) error
  • func (r *RedistributionState) IsFullySynced(isSynced bool)
  • func (r *RedistributionState) SetBalance(ctx context.Context) error
  • func (r *RedistributionState) SetCurrentEvent(phase PhaseType, round uint64, block uint64)
  • func (r *RedistributionState) SetFrozen(isFrozen bool, round uint64)
  • func (r *RedistributionState) SetLastPlayedRound(round uint64)
  • func (r *RedistributionState) SetLastWonRound(round uint64)
  • func (r *RedistributionState) Status() (*Status, error)
• type Status

Constants

const (
	DefaultBlocksPerRound = 152
	DefaultBlocksPerPhase = DefaultBlocksPerRound / 4
)

Types

type Agent

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

func New

func New(overlay swarm.Address, ethAddress common.Address, backend ChainBackend, logger log.Logger, monitor Monitor, contract redistribution.Contract, batchExpirer postagecontract.PostageBatchExpirer, redistributionStatuser staking.RedistributionStatuser, radius postage.RadiusChecker, sampler storage.Sampler, blockTime time.Duration, blocksPerRound, blocksPerPhase uint64, stateStore storage.StateStorer, erc20Service erc20.Service, tranService transaction.Service) (*Agent, error)

func (*Agent) Close

func (a *Agent) Close() error

func (*Agent) HasEnoughFundsToPlay

func (a *Agent) HasEnoughFundsToPlay(ctx context.Context) (bool, error)

func (*Agent) Metrics

func (a *Agent) Metrics() []prometheus.Collector

TODO: register metric

func (*Agent) Status

func (a *Agent) Status() (*Status, error)

Status returns the node status

type ChainBackend

type ChainBackend interface {
	BlockNumber(context.Context) (uint64, error)
	HeaderByNumber(context.Context, *big.Int) (*types.Header, error)
	BalanceAt(ctx context.Context, address common.Address, block *big.Int) (*big.Int, error)
	SuggestGasPrice(ctx context.Context) (*big.Int, error)
}

type Monitor

type Monitor interface {
	IsFullySynced() bool
}

type PhaseType

type PhaseType int

func (PhaseType) String

func (p PhaseType) String() string

type RedistributionState

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

func NewRedistributionState

func NewRedistributionState(logger log.Logger, ethAddress common.Address, stateStore storage.StateStorer, erc20Service erc20.Service, contract transaction.Service) (*RedistributionState, error)

func (*RedistributionState) AddFee

func (r *RedistributionState) AddFee(ctx context.Context, txHash common.Hash)

AddFee sets the internal node status

func (*RedistributionState) CalculateWinnerReward

func (r *RedistributionState) CalculateWinnerReward(ctx context.Context) error

CalculateWinnerReward calculates the reward for the winner

func (*RedistributionState) IsFullySynced

func (r *RedistributionState) IsFullySynced(isSynced bool)

func (*RedistributionState) SetBalance

func (r *RedistributionState) SetBalance(ctx context.Context) error

func (*RedistributionState) SetCurrentEvent

func (r *RedistributionState) SetCurrentEvent(phase PhaseType, round uint64, block uint64)

func (*RedistributionState) SetFrozen

func (r *RedistributionState) SetFrozen(isFrozen bool, round uint64)

func (*RedistributionState) SetLastPlayedRound

func (r *RedistributionState) SetLastPlayedRound(round uint64)

func (*RedistributionState) SetLastWonRound

func (r *RedistributionState) SetLastWonRound(round uint64)

func (*RedistributionState) Status

func (r *RedistributionState) Status() (*Status, error)

Status returns the node status

type Status

type Status struct {
	Phase           PhaseType
	IsFrozen        bool
	IsFullySynced   bool
	Round           uint64
	LastWonRound    uint64
	LastPlayedRound uint64
	LastFrozenRound uint64
	Block           uint64
	Reward          *big.Int
	Fees            *big.Int
}

Status provide internal status of the nodes in the redistribution game