keeper

package
v0.12.0 Latest Latest
Warning

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

 Go to latest Published: May 24, 2024 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MatureCountPerBlock = 100
)

Variables

This section is empty.

Functions

func FilteredPaginate added in v0.8.0 

func FilteredPaginate(cdc codec.Codec,
	prefixStore storetypes.KVStore,
	pageRequest *pagiquery.PageRequest,
	onResult func(key []byte, value []byte, accumulate bool) (bool, error),
) (*pagiquery.PageResponse, error)

func GetIterator added in v0.8.0 

func GetIterator(prefixStore storetypes.KVStore, start []byte, reverse bool) db.Iterator

func NewMsgServerImpl added in v0.8.0 

func NewMsgServerImpl(keeper Keeper) types.MsgServer

NewMsgServerImpl returns an implementation of the bank MsgServer interface for the provided Keeper.

func Paginate added in v0.8.0 

func Paginate(
	prefixStore storetypes.KVStore,
	pageRequest *pagiquery.PageRequest,
	onResult func(key []byte, value []byte) error,
) (*pagiquery.PageResponse, error)

func UnmarshalIndividualReward added in v0.8.0 

func UnmarshalIndividualReward(cdc codec.Codec, value []byte) (v types.Reward, err error)

Types

type Keeper 

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

Keeper of the pot store

func NewKeeper 

func NewKeeper(
	cdc codec.Codec,
	key storetypes.StoreKey,
	accountKeeper types.AccountKeeper,
	bankKeeper types.BankKeeper,
	distrKeeper types.DistrKeeper,
	registerKeeper types.RegisterKeeper,
	stakingKeeper types.StakingKeeper,
	authority string,
) Keeper

NewKeeper creates a pot keeper

func (Keeper) BondDenom 

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

BondDenom - Bondable coin denomination

func (Keeper) CalcCommunityTax added in v0.9.0 

func (k Keeper) CalcCommunityTax(ctx sdk.Context, rewardBeforeTax sdkmath.LegacyDec) (reward sdk.Coin, tax sdkmath.LegacyDec)

func (Keeper) CalcMiningRewardInTotal 

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

CalcMiningRewardInTotal allocate mining reward from foundation account

func (Keeper) CalcRewardForMetaNode added in v0.8.0 

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

CalcRewardForMetaNode Iteration for calculating reward of meta nodes

func (Keeper) CalcRewardForResourceNode 

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

CalcRewardForResourceNode Iteration for calculating reward of resource nodes

func (Keeper) CalcTrafficRewardInTotal 

func (k Keeper) CalcTrafficRewardInTotal(
	ctx sdk.Context, distributeGoal types.DistributeGoal, totalConsumedNoz sdkmath.LegacyDec,
) (types.DistributeGoal, error)

func (Keeper) DistributePotReward 

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

func (Keeper) ExportGenesis added in v0.12.0 

func (k Keeper) ExportGenesis(ctx sdk.Context) (data *types.GenesisState)

ExportGenesis writes the current store values to a genesis file, which can be imported again with InitGenesis

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) GetCirculationSupply added in v0.10.0 

func (k Keeper) GetCirculationSupply(ctx sdk.Context) (circulationSupply sdk.Coins)

func (Keeper) GetCommunityTax added in v0.9.0 

func (k Keeper) GetCommunityTax(ctx sdk.Context) (res sdkmath.LegacyDec)

func (Keeper) GetCurrentNozPrice added in v0.11.0 

func (k Keeper) GetCurrentNozPrice(St, Pt, Lt sdkmath.Int) (currentNozPrice sdkmath.LegacyDec)

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, matureEpoch sdkmath.Int) (value types.Reward, found bool)

func (Keeper) GetLastDistributedEpoch added in v0.10.0 

func (k Keeper) GetLastDistributedEpoch(ctx sdk.Context) (epoch sdkmath.Int)

func (Keeper) GetLegacyTotalReward added in v0.12.0 

func (k Keeper) GetLegacyTotalReward(ctx sdk.Context, epoch sdkmath.Int) (totalReward types.TotalReward)

func (Keeper) GetMatureTotalReward 

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

func (Keeper) GetMaturedEpoch added in v0.10.0 

func (k Keeper) GetMaturedEpoch(ctx sdk.Context) (epoch sdkmath.Int)

func (Keeper) GetMetrics added in v0.11.3 

func (k Keeper) GetMetrics(ctx sdk.Context) types.Metrics

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) (p types.Params)

GetParams returns the params from the store

func (Keeper) GetPrepayAmount added in v0.11.0 

func (k Keeper) GetPrepayAmount(Lt, tokenAmount, St, Pt sdkmath.Int) (purchaseNoz, remainingNoz sdkmath.Int, err error)

func (Keeper) GetSupply added in v0.10.0 

func (k Keeper) GetSupply(ctx sdk.Context) (totalSupply sdk.Coin)

func (Keeper) GetTotalConsumedNoz added in v0.9.0 

func (k Keeper) GetTotalConsumedNoz(trafficList []types.SingleWalletVolume) sdkmath.Int

GetTotalConsumedNoz Iteration for getting total consumed OZ from traffic

func (Keeper) GetTotalMinedTokens 

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

func (Keeper) GetTotalMining added in v0.11.3 

func (k Keeper) GetTotalMining(ctx sdk.Context) sdk.Coin

func (Keeper) GetTotalReward added in v0.11.0 

func (k Keeper) GetTotalReward(ctx sdk.Context, epoch sdkmath.Int) (totalReward types.TotalReward)

func (Keeper) GetTrafficReward added in v0.7.0 

func (k Keeper) GetTrafficReward(ctx sdk.Context, totalConsumedNoz sdkmath.LegacyDec) (result sdkmath.LegacyDec)

GetTrafficReward [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 wei 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 sdkmath.Int) (res types.VolumeReportRecord)

func (Keeper) HasReachedThreshold added in v0.10.0 

func (k Keeper) HasReachedThreshold(ctx sdk.Context, pubKeys [][]byte) bool

func (Keeper) InitGenesis added in v0.12.0 

func (k Keeper) InitGenesis(ctx sdk.Context, data *types.GenesisState)

InitGenesis initialize default parameters and the keeper's address to pubkey map

func (Keeper) InitVariable added in v0.9.0 

func (k Keeper) InitVariable(ctx sdk.Context)

func (Keeper) InitialTotalSupply added in v0.10.0 

func (k Keeper) InitialTotalSupply(ctx sdk.Context) (res sdk.Coin)

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

IteratorImmatureTotal Iteration for getting total immature reward

func (Keeper) IteratorIndividualReward added in v0.7.0 

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

IteratorIndividualReward Iteration for getting individual reward of each owner at a specific epoch

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

IteratorMatureTotal Iteration for getting total mature reward

func (Keeper) IteratorTotalReward added in v0.12.0 

func (k Keeper) IteratorTotalReward(ctx sdk.Context, handler func(epoch sdkmath.Int, totalReward types.TotalReward) (stop bool))

IteratorTotalReward Iteration for getting total mature reward

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) NozSupply added in v0.11.0 

func (k Keeper) NozSupply(ctx sdk.Context) (remaining, total sdkmath.Int)

NozSupply calc remaining/total supply for noz

func (Keeper) RemoveIndividualReward added in v0.10.0 

func (k Keeper) RemoveIndividualReward(ctx sdk.Context, individualRewardKey []byte)

func (Keeper) RestoreTotalSupply added in v0.10.0 

func (k Keeper) RestoreTotalSupply(ctx sdk.Context) (minted, burned sdk.Coins)

RestoreTotalSupply Restore total supply to 100M stos

func (Keeper) RewardDenom added in v0.6.0 

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

func (Keeper) RewardMatureAndSubSlashing added in v0.10.0 

func (k Keeper) RewardMatureAndSubSlashing(ctx sdk.Context) error

RewardMatureAndSubSlashing mature rewards and deduct slashing for all nodes

func (Keeper) SafeMintCoins added in v0.10.0 

func (k Keeper) SafeMintCoins(ctx sdk.Context, moduleName string, amt sdk.Coins) error

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, matureEpoch sdkmath.Int, value types.Reward)

func (Keeper) SetLastDistributedEpoch added in v0.10.0 

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

func (Keeper) SetMatureTotalReward added in v0.7.0 

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

func (Keeper) SetMaturedEpoch added in v0.10.0 

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

func (Keeper) SetParams 

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

SetParams sets the params on the store

func (Keeper) SetTotalMinedTokens added in v0.7.0 

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

func (Keeper) SetTotalReward added in v0.12.0 

func (k Keeper) SetTotalReward(ctx sdk.Context, epoch sdkmath.Int, totalReward types.TotalReward)

func (Keeper) SetVolumeReport 

func (k Keeper) SetVolumeReport(ctx sdk.Context, epoch sdkmath.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,
	nozAmt sdkmath.Int, suspend bool) (tokenAmt sdkmath.Int, nodeType registertypes.NodeType, err error)

SlashingResourceNode This function only record slashing amount.

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

func (Keeper) VolumeReport added in v0.6.0 

func (k Keeper) VolumeReport(ctx sdk.Context, walletVolumes types.WalletVolumes, reporter stratos.SdsAddress,
	epoch sdkmath.Int, reportReference string, txHash string) (err error)

func (Keeper) Withdraw 

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

type Migrator added in v0.8.0 

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

Migrator is a struct for handling in-place store migrations.

func NewMigrator added in v0.8.0 

func NewMigrator(keeper Keeper, legacySubspace types.ParamsSubspace) Migrator

NewMigrator returns a new Migrator.

func (Migrator) Migrate1to2 added in v0.8.0 

func (m Migrator) Migrate1to2(ctx sdk.Context) error

Migrate1to2 migrates from version 1 to 2.

type Querier added in v0.8.0 

type Querier struct {
	Keeper
}

Querier is used as Keeper will have duplicate methods if used directly, and gRPC names take precedence over keeper

func (Querier) CirculationSupply added in v0.10.0 

func (q Querier) CirculationSupply(c context.Context, _ *types.QueryCirculationSupplyRequest) (*types.QueryCirculationSupplyResponse, error)

func (Querier) Metrics added in v0.11.3 

func (q Querier) Metrics(c context.Context, req *types.QueryMetricsRequest) (
	*types.QueryMetricsResponse, error)

func (Querier) Params added in v0.8.0 

func (q Querier) Params(c context.Context, _ *types.QueryParamsRequest) (*types.QueryParamsResponse, error)

func (Querier) RewardsByEpoch added in v0.10.0 

func (q Querier) RewardsByEpoch(c context.Context, req *types.QueryRewardsByEpochRequest) (*types.QueryRewardsByEpochResponse, error)

func (Querier) RewardsByWallet added in v0.12.0 

func (q Querier) RewardsByWallet(c context.Context, req *types.QueryRewardsByWalletRequest) (*types.QueryRewardsByWalletResponse, error)

func (Querier) RewardsByWalletAndEpoch added in v0.12.0 

func (q Querier) RewardsByWalletAndEpoch(c context.Context, req *types.QueryRewardsByWalletAndEpochRequest) (*types.QueryRewardsByWalletAndEpochResponse, error)

func (Querier) SlashingByOwner added in v0.10.0 

func (q Querier) SlashingByOwner(c context.Context, req *types.QuerySlashingByOwnerRequest) (*types.QuerySlashingByOwnerResponse, error)

func (Querier) TotalMinedToken added in v0.10.0 

func (q Querier) TotalMinedToken(c context.Context, _ *types.QueryTotalMinedTokenRequest) (*types.QueryTotalMinedTokenResponse, error)

func (Querier) TotalRewardByEpoch added in v0.11.0 

func (q Querier) TotalRewardByEpoch(c context.Context, req *types.QueryTotalRewardByEpochRequest) (
	*types.QueryTotalRewardByEpochResponse, error)

func (Querier) VolumeReport added in v0.8.0 

func (q Querier) VolumeReport(c context.Context, req *types.QueryVolumeReportRequest) (*types.QueryVolumeReportResponse, 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.