keeper

package
v0.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 21, 2022 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	QueryVolumeReport            = "query_volume_report"
	QueryPotRewardsByReportEpoch = "query_pot_rewards_by_report_epoch"
	QueryPotRewardsByWalletAddr  = "query_pot_rewards_by_wallet_address"
	QueryPotSlashingByWalletAddr = "query_pot_slashing_by_wallet_address"
	QueryDefaultLimit            = 100
)

Variables

This section is empty.

Functions

func MakeTestCodec 

func MakeTestCodec() *codec.Codec

create a codec used only for testing

func NewQuerier 

func NewQuerier(k Keeper) sdk.Querier

NewQuerier creates a new querier for pot clients.

func TestMain added in v0.7.0 

func TestMain(m *testing.M)

Types

type Keeper 

type Keeper struct {
	BankKeeper     bank.Keeper
	SupplyKeeper   supply.Keeper
	AccountKeeper  auth.AccountKeeper
	StakingKeeper  staking.Keeper
	RegisterKeeper register.Keeper
	// contains filtered or unexported fields
}

Keeper of the pot store

func CreateTestInput 

func CreateTestInput(t *testing.T, isCheckTx bool) (
	sdk.Context, auth.AccountKeeper, bank.Keeper, Keeper, staking.Keeper, params.Keeper, supply.Keeper, register.Keeper)

func NewKeeper 

func NewKeeper(cdc *codec.Codec, key sdk.StoreKey, paramSpace params.Subspace, feeCollectorName string,
	bankKeeper bank.Keeper, supplyKeeper supply.Keeper, accountKeeper auth.AccountKeeper, stakingKeeper staking.Keeper,
	registerKeeper register.Keeper,
) Keeper

NewKeeper creates a pot keeper

func (Keeper) BondDenom 

func (k Keeper) BondDenom(ctx sdk.Context) (res string)

BondDenom - Bondable coin denomination

func (Keeper) CalcMiningRewardInTotal 

func (k Keeper) CalcMiningRewardInTotal(ctx sdk.Context, distributeGoal types.DistributeGoal) (types.DistributeGoal, error)

allocate mining reward from foundation account

func (Keeper) CalcMiningRewardInTotalForTestnet added in v0.6.0 

func (k Keeper) CalcMiningRewardInTotalForTestnet(ctx sdk.Context, distributeGoal types.DistributeGoal) (
	types.DistributeGoal, []regtypes.IndexingNode, []regtypes.ResourceNode, error)

allocate mining reward from foundation account

func (Keeper) CalcRewardForIndexingNode 

func (k Keeper) CalcRewardForIndexingNode(ctx sdk.Context, distributeGoal types.DistributeGoal, rewardDetailMap map[string]types.Reward,
) (map[string]types.Reward, types.DistributeGoal)

func (Keeper) CalcRewardForIndexingNodeForTestnet added in v0.6.0 

func (k Keeper) CalcRewardForIndexingNodeForTestnet(ctx sdk.Context, distributeGoal types.DistributeGoal,
	rewardDetailMap map[string]types.Reward, indexNodes []regtypes.IndexingNode,
) (map[string]types.Reward, types.DistributeGoal)

func (Keeper) CalcRewardForResourceNode 

func (k Keeper) CalcRewardForResourceNode(ctx sdk.Context, trafficList []types.SingleWalletVolume,
	distributeGoal types.DistributeGoal, rewardDetailMap map[string]types.Reward,
) (map[string]types.Reward, types.DistributeGoal)

func (Keeper) CalcRewardForResourceNodeForTestnet added in v0.6.0 

func (k Keeper) CalcRewardForResourceNodeForTestnet(ctx sdk.Context, trafficList []types.SingleWalletVolume,
	distributeGoal types.DistributeGoal, rewardDetailMap map[string]types.Reward, resourceNodes []regtypes.ResourceNode,
) (map[string]types.Reward, types.DistributeGoal)

func (Keeper) CalcTrafficRewardInTotal 

func (k Keeper) CalcTrafficRewardInTotal(
	ctx sdk.Context, trafficList []types.SingleWalletVolume, distributeGoal types.DistributeGoal,
) (sdk.Dec, types.DistributeGoal, error)

func (Keeper) DistributePotReward 

func (k Keeper) DistributePotReward(ctx sdk.Context, trafficList []types.SingleWalletVolume, epoch sdk.Int) (totalConsumedOzone sdk.Dec, err error)

func (Keeper) DistributePotRewardForTestnet added in v0.6.0 

func (k Keeper) DistributePotRewardForTestnet(ctx sdk.Context, trafficList []types.SingleWalletVolume, epoch sdk.Int) (totalConsumedOzone sdk.Dec, err error)

func (Keeper) FoundationDeposit added in v0.5.0 

func (k Keeper) FoundationDeposit(ctx sdk.Context, amount sdk.Coins, from sdk.AccAddress) (err error)

func (Keeper) GetImmatureTotalReward 

func (k Keeper) GetImmatureTotalReward(ctx sdk.Context, walletAddress sdk.AccAddress) (value sdk.Coins)

func (Keeper) GetIndividualReward 

func (k Keeper) GetIndividualReward(ctx sdk.Context, walletAddress sdk.AccAddress, epoch sdk.Int) (value types.Reward, found bool)

func (Keeper) GetLastReportedEpoch added in v0.5.0 

func (k Keeper) GetLastReportedEpoch(ctx sdk.Context) (epoch sdk.Int)

func (Keeper) GetMatureTotalReward 

func (k Keeper) GetMatureTotalReward(ctx sdk.Context, walletAddress sdk.AccAddress) (value sdk.Coins)

func (Keeper) GetMinedTokens 

func (k Keeper) GetMinedTokens(ctx sdk.Context, epoch sdk.Int) (minedToken sdk.Coin)

func (Keeper) GetMiningRewardParamByMinedToken 

func (k Keeper) GetMiningRewardParamByMinedToken(ctx sdk.Context, minedToken sdk.Coin) (types.MiningRewardParam, error)

func (Keeper) GetParams 

func (k Keeper) GetParams(ctx sdk.Context) (params types.Params)

GetParams returns the total set of pot parameters.

func (Keeper) GetTotalConsumedUoz added in v0.6.0 

func (k Keeper) GetTotalConsumedUoz(trafficList []types.SingleWalletVolume) sdk.Int

func (Keeper) GetTotalMinedTokens 

func (k Keeper) GetTotalMinedTokens(ctx sdk.Context) (totalMinedToken sdk.Coin)

func (Keeper) GetTrafficReward added in v0.7.0 

func (k Keeper) GetTrafficReward(ctx sdk.Context, trafficList []types.SingleWalletVolume) (totalConsumedOzone, result sdk.Dec)

[S] is initial genesis deposit by all resource nodes and meta nodes at t=0 The current unissued prepay Volume Pool [pt] is the total remaining prepay uSTOS kept by Stratos Network but not issued to Resource Node as rewards. At time t=0, pt=0 total consumed Ozone is [Y] The remaining total Ozone limit [lt] is the upper bound of total Ozone that users can purchase from Stratos blockchain. the total generated traffic rewards as [R] R = (S + Pt) * Y / (Lt + Y)

func (Keeper) GetVolumeReport 

func (k Keeper) GetVolumeReport(ctx sdk.Context, epoch sdk.Int) (res types.VolumeReportRecord)

func (Keeper) IsSPNode 

func (k Keeper) IsSPNode(ctx sdk.Context, p2pAddr stratos.SdsAddress) (found bool)

func (Keeper) IteratorImmatureTotal added in v0.7.0 

func (k Keeper) IteratorImmatureTotal(ctx sdk.Context, handler func(walletAddress sdk.AccAddress, immatureTotal sdk.Coins) (stop bool))

func (Keeper) IteratorIndividualReward added in v0.7.0 

func (k Keeper) IteratorIndividualReward(ctx sdk.Context, epoch sdk.Int, handler func(walletAddress sdk.AccAddress, individualReward types.Reward) (stop bool))

func (Keeper) IteratorMatureTotal added in v0.7.0 

func (k Keeper) IteratorMatureTotal(ctx sdk.Context, handler func(walletAddress sdk.AccAddress, matureTotal sdk.Coins) (stop bool))

func (Keeper) Logger 

func (k Keeper) Logger(ctx sdk.Context) log.Logger

Logger returns a module-specific logger.

func (Keeper) MatureEpoch 

func (k Keeper) MatureEpoch(ctx sdk.Context) (res int64)

func (Keeper) MiningRewardParams 

func (k Keeper) MiningRewardParams(ctx sdk.Context) (res []types.MiningRewardParam)

func (Keeper) RewardDenom added in v0.6.0 

func (k Keeper) RewardDenom(ctx sdk.Context) (res string)

func (Keeper) SetImmatureTotalReward added in v0.7.0 

func (k Keeper) SetImmatureTotalReward(ctx sdk.Context, walletAddress sdk.AccAddress, value sdk.Coins)

func (Keeper) SetIndividualReward added in v0.7.0 

func (k Keeper) SetIndividualReward(ctx sdk.Context, walletAddress sdk.AccAddress, epoch sdk.Int, value types.Reward)

func (Keeper) SetLastReportedEpoch added in v0.7.0 

func (k Keeper) SetLastReportedEpoch(ctx sdk.Context, epoch sdk.Int)

func (Keeper) SetMatureTotalReward added in v0.7.0 

func (k Keeper) SetMatureTotalReward(ctx sdk.Context, walletAddress sdk.AccAddress, value sdk.Coins)

func (Keeper) SetParams 

func (k Keeper) SetParams(ctx sdk.Context, params types.Params)

SetParams sets the pot parameters to the param space.

func (Keeper) SetTotalMinedTokens added in v0.7.0 

func (k Keeper) SetTotalMinedTokens(ctx sdk.Context, totalMinedToken sdk.Coin)

func (Keeper) SetVolumeReport 

func (k Keeper) SetVolumeReport(ctx sdk.Context, epoch sdk.Int, reportRecord types.VolumeReportRecord)

func (Keeper) SlashingResourceNode added in v0.6.2 

func (k Keeper) SlashingResourceNode(ctx sdk.Context, p2pAddr stratos.SdsAddress, walletAddr sdk.AccAddress,
	ozAmt sdk.Int, suspend bool) (amt sdk.Int, nodeType regtypes.NodeType, err error)

This function only record slashing amount.

Deduct slashing amount when: 1, calculate upcoming mature reward, deduct from mature_total & upcoming mature reward. 2, unstaking indexing node. 3, unstaking resource node.

func (Keeper) VolumeReport added in v0.6.0 

func (k Keeper) VolumeReport(ctx sdk.Context, walletVolumes []types.SingleWalletVolume, reporter stratos.SdsAddress,
	epoch sdk.Int, reportReference string, txHash string) (totalConsumedOzone sdk.Dec, err error)

func (Keeper) Withdraw 

func (k Keeper) Withdraw(ctx sdk.Context, amount sdk.Coins, walletAddress sdk.AccAddress, targetAddress sdk.AccAddress) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.