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) (*big.Int, 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) CommitKey(round uint64) ([]byte, bool)
  • func (r *RedistributionState) HasRevealed(round uint64) bool
  • func (r *RedistributionState) IsFullySynced(isSynced bool)
  • func (r *RedistributionState) SampleData(round uint64) (SampleData, bool)
  • func (r *RedistributionState) SetBalance(ctx context.Context) error
  • func (r *RedistributionState) SetCommitKey(round uint64, commitKey []byte)
  • func (r *RedistributionState) SetCurrentEvent(phase PhaseType, round uint64, block uint64)
  • func (r *RedistributionState) SetFrozen(isFrozen bool, round uint64)
  • func (r *RedistributionState) SetHasRevealed(round uint64)
  • func (r *RedistributionState) SetLastPlayedRound(round uint64)
  • func (r *RedistributionState) SetLastWonRound(round uint64)
  • func (r *RedistributionState) SetSampleData(round uint64, sd SampleData)
  • func (r *RedistributionState) Status() (*Status, error)
• type RoundData
• type SampleData
• type Status
  • func NewStatus() *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.Radius, 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) (*big.Int, 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) CommitKey

func (r *RedistributionState) CommitKey(round uint64) ([]byte, bool)

func (*RedistributionState) HasRevealed

func (r *RedistributionState) HasRevealed(round uint64) bool

func (*RedistributionState) IsFullySynced

func (r *RedistributionState) IsFullySynced(isSynced bool)

func (*RedistributionState) SampleData

func (r *RedistributionState) SampleData(round uint64) (SampleData, bool)

func (*RedistributionState) SetBalance

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

func (*RedistributionState) SetCommitKey

func (r *RedistributionState) SetCommitKey(round uint64, commitKey []byte)

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) SetHasRevealed

func (r *RedistributionState) SetHasRevealed(round uint64)

func (*RedistributionState) SetLastPlayedRound

func (r *RedistributionState) SetLastPlayedRound(round uint64)

func (*RedistributionState) SetLastWonRound

func (r *RedistributionState) SetLastWonRound(round uint64)

func (*RedistributionState) SetSampleData

func (r *RedistributionState) SetSampleData(round uint64, sd SampleData)

func (*RedistributionState) Status

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

Status returns the node status

type RoundData

type RoundData struct {
	CommitKey   []byte
	SampleData  *SampleData
	HasRevealed bool
}

type SampleData

type SampleData struct {
	ReserveSample storage.Sample
	StorageRadius uint8
}

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
	RoundData       map[uint64]RoundData
}

Status provide internal status of the nodes in the redistribution game

func NewStatus

func NewStatus() *Status