basic

Documentation

Index

• type BalanceFetcher
• type EstimationFetcher
• type IncomeSettlementContext
  • func NewIncomeSettlementContext(p *IncomeSettlementContextPrms) *IncomeSettlementContext
  • func (inc *IncomeSettlementContext) Collect()
  • func (inc *IncomeSettlementContext) Distribute()
• type IncomeSettlementContextPrms
• type NodeSizeTable
  • func NewNodeSizeTable() *NodeSizeTable
  • func (t *NodeSizeTable) Iterate(f func([]byte, *big.Int))
  • func (t *NodeSizeTable) Put(id []byte, avg uint64)
  • func (t *NodeSizeTable) Total() *big.Int
• type RateFetcher

Types

type BalanceFetcher

type BalanceFetcher interface {
	Balance(id user.ID) (*big.Int, error)
}

BalanceFetcher uses NEP-17 compatible balance contract.

type EstimationFetcher

type EstimationFetcher interface {
	Estimations(uint64) (map[cid.ID]*container.Estimations, error)
}

type IncomeSettlementContext

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

func NewIncomeSettlementContext

func NewIncomeSettlementContext(p *IncomeSettlementContextPrms) *IncomeSettlementContext

func (*IncomeSettlementContext) Collect

func (inc *IncomeSettlementContext) Collect()

func (*IncomeSettlementContext) Distribute

func (inc *IncomeSettlementContext) Distribute()

type IncomeSettlementContextPrms

type IncomeSettlementContextPrms struct {
	Log         *zap.Logger
	Epoch       uint64
	Rate        RateFetcher
	Estimations EstimationFetcher
	Balances    BalanceFetcher
	Container   common.ContainerStorage
	Placement   common.PlacementCalculator
	Exchange    common.Exchanger
	Accounts    common.AccountStorage
}

type NodeSizeTable

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

NodeSizeTable is not thread safe, make sure it is accessed with external locks or in single routine.

func NewNodeSizeTable

func NewNodeSizeTable() *NodeSizeTable

func (*NodeSizeTable) Iterate

func (t *NodeSizeTable) Iterate(f func([]byte, *big.Int))

func (*NodeSizeTable) Put

func (t *NodeSizeTable) Put(id []byte, avg uint64)

func (*NodeSizeTable) Total

func (t *NodeSizeTable) Total() *big.Int

type RateFetcher

type RateFetcher interface {
	BasicRate() (uint64, error)
}