keeper

package
v0.0.0-...-3efe840 Latest Latest
Warning

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

 Go to latest Published: Jan 29, 2023 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewLegacyQuerier 

func NewLegacyQuerier(k Keeper, cdc *codec.LegacyAmino) sdk.Querier

func NewMsgServerImpl 

func NewMsgServerImpl(keeper Keeper) types.MsgServer

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

func NewQueryServerImpl 

func NewQueryServerImpl(keeper Keeper) types.QueryServer

Types

type Hooks 

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

func (Hooks) AfterDelegationModified 

func (h Hooks) AfterDelegationModified(ctx sdk.Context, delAddr sdk.AccAddress, valAddr sdk.ValAddress) error

func (Hooks) AfterValidatorBeginUnbonding 

func (h Hooks) AfterValidatorBeginUnbonding(ctx sdk.Context, consAddr sdk.ConsAddress, valAddr sdk.ValAddress) error

func (Hooks) AfterValidatorBonded 

func (h Hooks) AfterValidatorBonded(ctx sdk.Context, consAddr sdk.ConsAddress, valAddr sdk.ValAddress) error

func (Hooks) AfterValidatorCreated 

func (h Hooks) AfterValidatorCreated(ctx sdk.Context, valAddr sdk.ValAddress) error

func (Hooks) AfterValidatorRemoved 

func (h Hooks) AfterValidatorRemoved(ctx sdk.Context, consAddr sdk.ConsAddress, valAddr sdk.ValAddress) error

func (Hooks) BeforeDelegationCreated 

func (h Hooks) BeforeDelegationCreated(ctx sdk.Context, delAddr sdk.AccAddress, valAddr sdk.ValAddress) error

func (Hooks) BeforeDelegationRemoved 

func (h Hooks) BeforeDelegationRemoved(ctx sdk.Context, delAddr sdk.AccAddress, valAddr sdk.ValAddress) error

func (Hooks) BeforeDelegationSharesModified 

func (h Hooks) BeforeDelegationSharesModified(ctx sdk.Context, delAddr sdk.AccAddress, valAddr sdk.ValAddress) error

func (Hooks) BeforeValidatorModified 

func (h Hooks) BeforeValidatorModified(ctx sdk.Context, valAddr sdk.ValAddress) error

func (Hooks) BeforeValidatorSlashed 

func (h Hooks) BeforeValidatorSlashed(ctx sdk.Context, valAddr sdk.ValAddress, fraction sdk.Dec) error

type Keeper 

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

func NewKeeper 

func NewKeeper(
	cdc codec.BinaryCodec,
	storeKey storetypes.StoreKey,
	ps paramtypes.Subspace,
	accountKeeper types.AccountKeeper,
	bankKeeper types.BankKeeper,
	stakingKeeper types.StakingKeeper,
	distributionKeeper types.DistributionKeeper,
) Keeper

func (Keeper) AddAssetsToRewardPool 

func (k Keeper) AddAssetsToRewardPool(ctx sdk.Context, from sdk.AccAddress, val types.DredgerValidator, coins sdk.Coins) error

AddAssetsToRewardPool increments a reward history array. A reward history stores the average reward per token/reward_weight. To calculate the number of rewards claimable, take reward_history * dredger_token_amount * reward_weight

func (Keeper) CalculateDelegationRewards 

func (k Keeper) CalculateDelegationRewards(ctx sdk.Context, delegation types.Delegation, val types.DredgerValidator, asset types.DredgerAsset) (sdk.Coins, types.RewardHistories, error)

CalculateDelegationRewards calculates the rewards that can be claimed for a delegation It takes past reward_rate changes into account by using the RewardRateChangeSnapshot entry

func (Keeper) ClaimDelegationRewards 

func (k Keeper) ClaimDelegationRewards(ctx sdk.Context, delAddr sdk.AccAddress, val types.DredgerValidator, denom string) (sdk.Coins, error)

ClaimDelegationRewards claims delegation rewards and transfers to the delegator account This method updates the delegation so you will need to re-query an updated version from the database

func (Keeper) ClaimValidatorRewards 

func (k Keeper) ClaimValidatorRewards(ctx sdk.Context, val types.DredgerValidator) (sdk.Coins, error)

ClaimValidatorRewards claims the validator rewards (minus commission) from the distribution module This should be called everytime validator delegation changes (e.g. [un/re]delegation) to update the reward claim history

func (Keeper) CompleteRedelegations 

func (k Keeper) CompleteRedelegations(ctx sdk.Context) int

CompleteRedelegations Go through the re-delegations queue and remove all that have passed the completion time

func (Keeper) CompleteUndelegations 

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

CompleteUndelegations Go through all queued undelegations and send the tokens to the delegators

func (Keeper) ConsumeAssetRebalanceEvent 

func (k Keeper) ConsumeAssetRebalanceEvent(ctx sdk.Context) bool

func (Keeper) CreateDredger 

func (k Keeper) CreateDredger(ctx context.Context, req *types.MsgCreateDredgerProposal) error

func (Keeper) DeductAssetsHook 

func (k Keeper) DeductAssetsHook(ctx sdk.Context, assets []*types.DredgerAsset) (sdk.Coins, error)

DeductAssetsHook is called periodically to deduct from an dredger asset (calculated by take_rate). The interval in which assets are deducted is set in module params

func (Keeper) DeductAssetsWithTakeRate 

func (k Keeper) DeductAssetsWithTakeRate(ctx sdk.Context, lastClaim time.Time, assets []*types.DredgerAsset) (sdk.Coins, error)

DeductAssetsWithTakeRate Deducts an dredger asset using the take_rate The deducted asset is distributed to the fee_collector module account to be redistributed to stakers

func (Keeper) Delegate 

func (k Keeper) Delegate(ctx sdk.Context, delAddr sdk.AccAddress, validator types.DredgerValidator, coin sdk.Coin) (*sdk.Dec, error)

Delegate is the entry point for delegators to delegate dredger assets to validators Voting power is not immediately accured to the delegators in this method and a flag is set to rebalance voting power at the end of the block. This improves performance since rebalancing only needs to happen once regardless of how many delegations are made in a single block

func (Keeper) DeleteAsset 

func (k Keeper) DeleteAsset(ctx sdk.Context, denom string)

func (Keeper) DeleteDredger 

func (k Keeper) DeleteDredger(ctx context.Context, req *types.MsgDeleteDredgerProposal) error

func (Keeper) DeleteRedelegation 

func (k Keeper) DeleteRedelegation(ctx sdk.Context, redel types.Redelegation, completion time.Time)

func (Keeper) ExportGenesis 

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

func (Keeper) GetAllAssets 

func (k Keeper) GetAllAssets(ctx sdk.Context) (assets []*types.DredgerAsset)

func (Keeper) GetAllDredgerValidatorInfo 

func (k Keeper) GetAllDredgerValidatorInfo(ctx sdk.Context) []types.DredgerValidatorInfo

func (Keeper) GetAssetByDenom 

func (k Keeper) GetAssetByDenom(ctx sdk.Context, denom string) (asset types.DredgerAsset, found bool)

func (Keeper) GetDelegation 

func (k Keeper) GetDelegation(ctx sdk.Context, delAddr sdk.AccAddress, validator types.DredgerValidator, denom string) (d types.Delegation, found bool)

func (Keeper) GetDredgerBondedAmount 

func (k Keeper) GetDredgerBondedAmount(ctx sdk.Context, delegator sdk.AccAddress) math.Int

GetDredgerBondedAmount returns the total amount of bonded native tokens that are not in the unbonding pool

func (Keeper) GetDredgerValidator 

func (k Keeper) GetDredgerValidator(ctx sdk.Context, valAddr sdk.ValAddress) (types.DredgerValidator, error)

func (Keeper) GetDredgerValidatorInfo 

func (k Keeper) GetDredgerValidatorInfo(ctx sdk.Context, valAddr sdk.ValAddress) (types.DredgerValidatorInfo, bool)

func (Keeper) HasRedelegation 

func (k Keeper) HasRedelegation(ctx sdk.Context, delAddr sdk.AccAddress, dstVal sdk.ValAddress, denom string) bool

func (Keeper) InitGenesis 

func (k Keeper) InitGenesis(ctx sdk.Context, g *types.GenesisState) []abci.ValidatorUpdate

func (Keeper) IterateAllWeightChangeSnapshot 

func (k Keeper) IterateAllWeightChangeSnapshot(ctx sdk.Context, cb func(denom string, valAddr sdk.ValAddress, lastClaimHeight uint64, snapshot types.RewardWeightChangeSnapshot) (stop bool))

func (Keeper) IterateDelegations 

func (k Keeper) IterateDelegations(ctx sdk.Context, cb func(d types.Delegation) (stop bool))

func (Keeper) IterateDredgerValidatorInfo 

func (k Keeper) IterateDredgerValidatorInfo(ctx sdk.Context, cb func(valAddr sdk.ValAddress, info types.DredgerValidatorInfo) (stop bool))

func (Keeper) IterateRedelegations 

func (k Keeper) IterateRedelegations(ctx sdk.Context, cb func(redelegation types.Redelegation, completionTime time.Time) (stop bool))

func (Keeper) IterateRedelegationsByDelegator 

func (k Keeper) IterateRedelegationsByDelegator(ctx sdk.Context, delAddr sdk.AccAddress) sdk.Iterator

func (Keeper) IterateRedelegationsBySrcValidator 

func (k Keeper) IterateRedelegationsBySrcValidator(ctx sdk.Context, srcValAddr sdk.ValAddress) sdk.Iterator

func (Keeper) IterateUndelegations 

func (k Keeper) IterateUndelegations(ctx sdk.Context, cb func(undelegation types.QueuedUndelegation, completionTime time.Time) (stop bool))

func (Keeper) IterateUndelegationsByCompletionTime 

func (k Keeper) IterateUndelegationsByCompletionTime(ctx sdk.Context, completionTime time.Time) sdk.Iterator

func (Keeper) IterateUndelegationsBySrcValidator 

func (k Keeper) IterateUndelegationsBySrcValidator(ctx sdk.Context, valAddr sdk.ValAddress) sdk.Iterator

func (Keeper) IterateWeightChangeSnapshot 

func (k Keeper) IterateWeightChangeSnapshot(ctx sdk.Context, denom string, valAddr sdk.ValAddress, lastClaimHeight uint64) store.Iterator

func (Keeper) LastRewardClaimTime 

func (k Keeper) LastRewardClaimTime(ctx sdk.Context) (res time.Time)

func (Keeper) Logger 

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

func (Keeper) QueueAssetRebalanceEvent 

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

func (Keeper) RebalanceBondTokenWeights 

func (k Keeper) RebalanceBondTokenWeights(ctx sdk.Context, assets []*types.DredgerAsset) (err error)

RebalanceBondTokenWeights uses asset reward weights to calculate the expected amount of staking token that has to be minted / burned to maintain the right ratio It iterates all validators and calculates the expected staked amount based on delegations and delegates/undelegates the difference.

func (Keeper) RebalanceHook 

func (k Keeper) RebalanceHook(ctx sdk.Context, assets []*types.DredgerAsset) error

func (Keeper) Redelegate 

func (k Keeper) Redelegate(ctx sdk.Context, delAddr sdk.AccAddress, srcVal types.DredgerValidator, dstVal types.DredgerValidator, coin sdk.Coin) (*time.Time, error)

Redelegate from one validator to another

func (Keeper) RewardClaimInterval 

func (k Keeper) RewardClaimInterval(ctx sdk.Context) (res time.Duration)

func (Keeper) RewardDelayTime 

func (k Keeper) RewardDelayTime(ctx sdk.Context) (res time.Duration)

func (Keeper) RewardWeightChangeHook 

func (k Keeper) RewardWeightChangeHook(ctx sdk.Context, assets []*types.DredgerAsset)

func (Keeper) SetAsset 

func (k Keeper) SetAsset(ctx sdk.Context, asset types.DredgerAsset)

SetAsset Does not check if the asset already exists and overwrites it

func (Keeper) SetDelegation 

func (k Keeper) SetDelegation(ctx sdk.Context, delAddr sdk.AccAddress, valAddr sdk.ValAddress, denom string, del types.Delegation)

func (Keeper) SetLastRewardClaimTime 

func (k Keeper) SetLastRewardClaimTime(ctx sdk.Context, lastTime time.Time)

func (Keeper) SetParams 

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

func (Keeper) SetRewardWeightChangeSnapshot 

func (k Keeper) SetRewardWeightChangeSnapshot(ctx sdk.Context, asset types.DredgerAsset, val types.DredgerValidator)

func (Keeper) SetValidator 

func (k Keeper) SetValidator(ctx sdk.Context, val types.DredgerValidator)

func (Keeper) SetValidatorInfo 

func (k Keeper) SetValidatorInfo(ctx sdk.Context, valAddr sdk.ValAddress, val types.DredgerValidatorInfo)

func (Keeper) SlashRedelegations 

func (k Keeper) SlashRedelegations(ctx sdk.Context, valAddr sdk.ValAddress, fraction sdk.Dec) error

func (Keeper) SlashUndelegations 

func (k Keeper) SlashUndelegations(ctx sdk.Context, valAddr sdk.ValAddress, fraction sdk.Dec) error

func (Keeper) SlashValidator 

func (k Keeper) SlashValidator(ctx sdk.Context, valAddr sdk.ValAddress, fraction sdk.Dec) error

func (Keeper) StakingHooks 

func (k Keeper) StakingHooks() Hooks

func (Keeper) StoreKey 

func (k Keeper) StoreKey() storetypes.StoreKey

func (Keeper) Undelegate 

func (k Keeper) Undelegate(ctx sdk.Context, delAddr sdk.AccAddress, validator types.DredgerValidator, coin sdk.Coin) (*time.Time, error)

Undelegate from a validator Staked tokens are only distributed to the delegator after the unbonding period

func (Keeper) UpdateDredger 

func (k Keeper) UpdateDredger(ctx context.Context, req *types.MsgUpdateDredgerProposal) error

func (Keeper) UpdateDredgerAsset 

func (k Keeper) UpdateDredgerAsset(ctx sdk.Context, newAsset types.DredgerAsset) error

UpdateDredgerAsset updates the dredger asset with new params Also saves a snapshot whenever rewards weight changes to make sure delegation reward calculation has reference to historical reward rates

func (Keeper) ValidateDelegatedAmount 

func (k Keeper) ValidateDelegatedAmount(delegation types.Delegation, coin sdk.Coin, val types.DredgerValidator, asset types.DredgerAsset) (shares sdk.Dec, err error)

ValidateDelegatedAmount returns the amount of shares for a given coin that is staked Returns the number of shares that represents the amount of staked tokens that was requested

type MsgServer 

type MsgServer struct {
	Keeper
}

func (MsgServer) ClaimDelegationRewards 

func (m MsgServer) ClaimDelegationRewards(ctx context.Context, msg *types.MsgClaimDelegationRewards) (*types.MsgClaimDelegationRewardsResponse, error)

func (MsgServer) Delegate 

func (m MsgServer) Delegate(ctx context.Context, msg *types.MsgDelegate) (*types.MsgDelegateResponse, error)

func (MsgServer) Redelegate 

func (m MsgServer) Redelegate(ctx context.Context, msg *types.MsgRedelegate) (*types.MsgRedelegateResponse, error)

func (MsgServer) Undelegate 

func (m MsgServer) Undelegate(ctx context.Context, msg *types.MsgUndelegate) (*types.MsgUndelegateResponse, error)

type QueryServer 

type QueryServer struct {
	Keeper
}

func (QueryServer) Dredger 

func (k QueryServer) Dredger(c context.Context, req *types.QueryDredgerRequest) (*types.QueryDredgerResponse, error)

func (QueryServer) DredgerDelegation 

func (k QueryServer) DredgerDelegation(c context.Context, req *types.QueryDredgerDelegationRequest) (*types.QueryDredgerDelegationResponse, error)

func (QueryServer) DredgerDelegationRewards 

func (k QueryServer) DredgerDelegationRewards(context context.Context, request *types.QueryDredgerDelegationRewardsRequest) (*types.QueryDredgerDelegationRewardsResponse, error)

func (QueryServer) Dredgers 

func (k QueryServer) Dredgers(c context.Context, req *types.QueryDredgersRequest) (*types.QueryDredgersResponse, error)

func (QueryServer) DredgersDelegation 

func (k QueryServer) DredgersDelegation(c context.Context, req *types.QueryDredgersDelegationsRequest) (*types.QueryDredgersDelegationsResponse, error)

func (QueryServer) DredgersDelegationByValidator 

func (k QueryServer) DredgersDelegationByValidator(c context.Context, req *types.QueryDredgersDelegationByValidatorRequest) (*types.QueryDredgersDelegationsResponse, error)

func (QueryServer) IBCDredger 

func (k QueryServer) IBCDredger(c context.Context, request *types.QueryIBCDredgerRequest) (*types.QueryDredgerResponse, error)

func (QueryServer) IBCDredgerDelegation 

func (k QueryServer) IBCDredgerDelegation(c context.Context, request *types.QueryIBCDredgerDelegationRequest) (*types.QueryDredgerDelegationResponse, error)

func (QueryServer) IBCDredgerDelegationRewards 

func (k QueryServer) IBCDredgerDelegationRewards(context context.Context, request *types.QueryIBCDredgerDelegationRewardsRequest) (*types.QueryDredgerDelegationRewardsResponse, error)

func (QueryServer) Params 

func (k QueryServer) Params(c context.Context, _ *types.QueryParamsRequest) (*types.QueryParamsResponse, error)

type RewardsKeeper 

type RewardsKeeper interface {
}

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.