Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

keeper

package

Go to main page

Versions in this module

v12

v12.1.0

Jul 15, 2023

Changes in this version

+ func ClaimCallback(k Keeper, ctx sdk.Context, packet channeltypes.Packet, ...) error

+ func DelegateCallback(k Keeper, ctx sdk.Context, packet channeltypes.Packet, ...) error

+ func RebalanceCallback(k Keeper, ctx sdk.Context, packet channeltypes.Packet, ...) error

+ func RedemptionCallback(k Keeper, ctx sdk.Context, packet channeltypes.Packet, ...) error

+ func ReinvestCallback(k Keeper, ctx sdk.Context, packet channeltypes.Packet, ...) error

+ func UndelegateCallback(k Keeper, ctx sdk.Context, packet channeltypes.Packet, ...) error

+ type ICACallback func(Keeper, sdk.Context, channeltypes.Packet, ...) error

+ type ICACallbacks struct

+ func (c ICACallbacks) AddICACallback(id string, fn interface{}) icacallbackstypes.ICACallbackHandler

+ func (c ICACallbacks) CallICACallback(ctx sdk.Context, id string, packet channeltypes.Packet, ...) error

+ func (c ICACallbacks) HasICACallback(id string) bool

+ func (c ICACallbacks) RegisterICACallbacks() icacallbackstypes.ICACallbackHandler

type Keeper

+ func (k Keeper) ICACallbackHandler() ICACallbacks

v12.1.0-testnet

Jul 27, 2023

v12.0.0

Jul 15, 2023

Changes in this version

+ const ICACallbackID_Claim

+ const ICACallbackID_Delegate

+ const ICACallbackID_Rebalance

+ const ICACallbackID_Redemption

+ const ICACallbackID_Reinvest

+ const ICACallbackID_Undelegate

+ const ICQCallbackID_Delegation

+ const ICQCallbackID_FeeBalance

+ const ICQCallbackID_Validator

+ const ICQCallbackID_WithdrawalBalance

+ func AllInvariants(k Keeper) sdk.Invariant

+ func DelegatorSharesCallback(k Keeper, ctx sdk.Context, args []byte, query icqtypes.Query) error

+ func FeeBalanceCallback(k Keeper, ctx sdk.Context, args []byte, query icqtypes.Query) error

+ func GetValidatorFromAddress(validators []*types.Validator, address string) (val types.Validator, index int64, found bool)

+ func NewMsgServerImpl(keeper Keeper) types.MsgServer

+ func RegisterInvariants(ir sdk.InvariantRegistry, k Keeper)

+ func ValidatorExchangeRateCallback(k Keeper, ctx sdk.Context, args []byte, query icqtypes.Query) error

+ func WithdrawalBalanceCallback(k Keeper, ctx sdk.Context, args []byte, query icqtypes.Query) error

+ type Hooks struct

+ func (h Hooks) AfterEpochEnd(ctx sdk.Context, epochInfo epochstypes.EpochInfo)

+ func (h Hooks) BeforeEpochStart(ctx sdk.Context, epochInfo epochstypes.EpochInfo)

+ type ICQCallback func(Keeper, sdk.Context, []byte, icqtypes.Query) error

+ type ICQCallbacks struct

+ func (c ICQCallbacks) AddICQCallback(id string, fn interface{}) icqtypes.QueryCallbacks

+ func (c ICQCallbacks) CallICQCallback(ctx sdk.Context, id string, args []byte, query icqtypes.Query) error

+ func (c ICQCallbacks) HasICQCallback(id string) bool

+ func (c ICQCallbacks) RegisterICQCallbacks() icqtypes.QueryCallbacks

+ type IcaTx struct

+ Account types.ICAAccount

+ ConnectionId string

+ Msgs []proto.Message

+ Timeout uint64

+ type Keeper struct

+ AccountKeeper types.AccountKeeper

+ IBCKeeper ibckeeper.Keeper

+ ICACallbacksKeeper icacallbackskeeper.Keeper

+ ICAControllerKeeper icacontrollerkeeper.Keeper

+ InterchainQueryKeeper icqkeeper.Keeper

+ RatelimitKeeper types.RatelimitKeeper

+ RecordsKeeper recordsmodulekeeper.Keeper

+ StakingKeeper stakingkeeper.Keeper

+ func NewKeeper(cdc codec.BinaryCodec, storeKey, memKey storetypes.StoreKey, ...) Keeper

+ func (k *Keeper) GetParam(ctx sdk.Context, key []byte) uint64

+ func (k *Keeper) SetHooks(gh types.StakeIBCHooks) *Keeper

+ func (k Keeper) AddDelegationToValidator(ctx sdk.Context, hostZone types.HostZone, validatorAddress string, ...) (success bool)

+ func (k Keeper) AddValidatorToHostZone(ctx sdk.Context, chainId string, validator types.Validator, ...) error

+ func (k Keeper) AddValidatorsProposal(ctx sdk.Context, msg *types.AddValidatorsProposal) error

+ func (k Keeper) AddressUnbondings(c context.Context, req *types.QueryAddressUnbondings) (*types.QueryAddressUnbondingsResponse, error)

+ func (k Keeper) AfterEpochEnd(ctx sdk.Context, epochInfo epochstypes.EpochInfo)

+ func (k Keeper) AllocateHostZoneReward(ctx sdk.Context)

+ func (k Keeper) BeforeEpochStart(ctx sdk.Context, epochInfo epochstypes.EpochInfo)

+ func (k Keeper) BurnTokens(ctx sdk.Context, hostZone types.HostZone, stTokenBurnAmount sdkmath.Int) error

+ func (k Keeper) Callbacks() icacallbackstypes.ModuleCallbacks

+ func (k Keeper) CheckIsStToken(ctx sdk.Context, denom string) bool

+ func (k Keeper) ClaimCallback(ctx sdk.Context, packet channeltypes.Packet, ...) error

+ func (k Keeper) CleanupEpochUnbondingRecords(ctx sdk.Context, epochNumber uint64) bool

+ func (k Keeper) ConfirmValSetHasSpace(ctx sdk.Context, validators []*types.Validator) error

+ func (k Keeper) CreateDepositRecordsForEpoch(ctx sdk.Context, epochNumber uint64)

+ func (k Keeper) CreateEpochUnbondingRecord(ctx sdk.Context, epochNumber uint64) bool

+ func (k Keeper) DecrementHostZoneUnbonding(ctx sdk.Context, userRedemptionRecord recordstypes.UserRedemptionRecord, ...) error

+ func (k Keeper) DelegateCallback(ctx sdk.Context, packet channeltypes.Packet, ...) error

+ func (k Keeper) DelegateOnHost(ctx sdk.Context, hostZone types.HostZone, amt sdk.Coin, ...) error

+ func (k Keeper) EpochTracker(c context.Context, req *types.QueryGetEpochTrackerRequest) (*types.QueryGetEpochTrackerResponse, error)

+ func (k Keeper) EpochTrackerAll(c context.Context, req *types.QueryAllEpochTrackerRequest) (*types.QueryAllEpochTrackerResponse, error)

+ func (k Keeper) GetAllActiveHostZone(ctx sdk.Context) (list []types.HostZone)

+ func (k Keeper) GetAllEpochTracker(ctx sdk.Context) (list []types.EpochTracker)

+ func (k Keeper) GetAllHostZone(ctx sdk.Context) (list []types.HostZone)

+ func (k Keeper) GetChainID(ctx sdk.Context, connectionID string) (string, error)

+ func (k Keeper) GetClaimableRedemptionRecord(ctx sdk.Context, msg *types.MsgClaimUndelegatedTokens) (*recordstypes.UserRedemptionRecord, error)

+ func (k Keeper) GetConnectionId(ctx sdk.Context, portId string) (string, error)

+ func (k Keeper) GetCounterpartyChainId(ctx sdk.Context, connectionID string) (string, error)

+ func (k Keeper) GetEpochTracker(ctx sdk.Context, epochIdentifier string) (val types.EpochTracker, found bool)

+ func (k Keeper) GetHostZone(ctx sdk.Context, chain_id string) (val types.HostZone, found bool)

+ func (k Keeper) GetHostZoneFromHostDenom(ctx sdk.Context, denom string) (*types.HostZone, error)

+ func (k Keeper) GetHostZoneFromIBCDenom(ctx sdk.Context, denom string) (*types.HostZone, error)

+ func (k Keeper) GetHostZoneFromTransferChannelID(ctx sdk.Context, channelID string) (hostZone types.HostZone, found bool)

+ func (k Keeper) GetHostZoneUnbondingMsgs(ctx sdk.Context, hostZone types.HostZone) (msgs []proto.Message, totalAmountToUnbond sdkmath.Int, ...)

+ func (k Keeper) GetICATimeoutNanos(ctx sdk.Context, epochType string) (uint64, error)

+ func (k Keeper) GetLatestCompletionTime(ctx sdk.Context, msgResponses [][]byte) (*time.Time, error)

+ func (k Keeper) GetLightClientHeightSafely(ctx sdk.Context, connectionID string) (uint64, error)

+ func (k Keeper) GetLightClientTimeSafely(ctx sdk.Context, connectionID string) (uint64, error)

+ func (k Keeper) GetModuleAccountBalance(hostZone types.HostZone, depositRecords []recordstypes.DepositRecord) sdkmath.Int

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

+ func (k Keeper) GetRedemptionAccount(ctx sdk.Context, hostZone types.HostZone) (*types.ICAAccount, bool)

+ func (k Keeper) GetRedemptionTransferMsg(ctx sdk.Context, userRedemptionRecord *recordstypes.UserRedemptionRecord, ...) (*IcaTx, error)

+ func (k Keeper) GetStartTimeNextEpoch(ctx sdk.Context, epochType string) (uint64, error)

+ func (k Keeper) GetStrideEpochElapsedShare(ctx sdk.Context) (sdk.Dec, error)

+ func (k Keeper) GetTargetValAmtsForHostZone(ctx sdk.Context, hostZone types.HostZone, finalDelegation sdkmath.Int) (map[string]sdkmath.Int, error)

+ func (k Keeper) GetTotalValidatorDelegations(hostZone types.HostZone) sdkmath.Int

+ func (k Keeper) GetTotalValidatorWeight(hostZone types.HostZone) uint64

+ func (k Keeper) GetUndelegatedBalance(hostZone types.HostZone, depositRecords []recordstypes.DepositRecord) sdkmath.Int

+ func (k Keeper) GetValidatorDelegationAmtDifferences(ctx sdk.Context, hostZone types.HostZone) (map[string]sdkmath.Int, error)

+ func (k Keeper) Hooks() Hooks

+ func (k Keeper) HostZone(c context.Context, req *types.QueryGetHostZoneRequest) (*types.QueryGetHostZoneResponse, error)

+ func (k Keeper) HostZoneAll(c context.Context, req *types.QueryAllHostZoneRequest) (*types.QueryAllHostZoneResponse, error)

+ func (k Keeper) ICQCallbackHandler() ICQCallbacks

+ func (k Keeper) InitiateAllHostZoneUnbondings(ctx sdk.Context, dayNumber uint64) (success bool, successfulUnbondings []string, failedUnbondings []string)

+ func (k Keeper) InterchainAccountFromAddress(goCtx context.Context, req *types.QueryInterchainAccountFromAddressRequest) (*types.QueryInterchainAccountFromAddressResponse, error)

+ func (k Keeper) IsRedemptionRateWithinSafetyBounds(ctx sdk.Context, zone types.HostZone) (bool, error)

+ func (k Keeper) IsWithinBufferWindow(ctx sdk.Context) (bool, error)

+ func (k Keeper) IterateHostZones(ctx sdk.Context, ...)

+ func (k Keeper) LiquidStakeRewardCollectorBalance(ctx sdk.Context, msgSvr types.MsgServer) bool

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

+ func (k Keeper) MarshalClaimCallbackArgs(ctx sdk.Context, claimCallback types.ClaimCallback) ([]byte, error)

+ func (k Keeper) MarshalDelegateCallbackArgs(ctx sdk.Context, delegateCallback types.DelegateCallback) ([]byte, error)

+ func (k Keeper) MarshalRebalanceCallbackArgs(ctx sdk.Context, rebalanceCallback types.RebalanceCallback) ([]byte, error)

+ func (k Keeper) MarshalRedemptionCallbackArgs(ctx sdk.Context, redemptionCallback types.RedemptionCallback) ([]byte, error)

+ func (k Keeper) MarshalReinvestCallbackArgs(ctx sdk.Context, reinvestCallback types.ReinvestCallback) ([]byte, error)

+ func (k Keeper) MarshalUndelegateCallbackArgs(ctx sdk.Context, undelegateCallback types.UndelegateCallback) ([]byte, error)

+ func (k Keeper) ModuleAddress(goCtx context.Context, req *types.QueryModuleAddressRequest) (*types.QueryModuleAddressResponse, error)

+ func (k Keeper) NextPacketSequence(c context.Context, req *types.QueryGetNextPacketSequenceRequest) (*types.QueryGetNextPacketSequenceResponse, error)

+ func (k Keeper) Params(c context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)

+ func (k Keeper) QueryDelegationsIcq(ctx sdk.Context, hostZone types.HostZone, valoper string) error

+ func (k Keeper) QueryValidatorExchangeRate(ctx sdk.Context, msg *types.MsgUpdateValidatorSharesExchRate) (*types.MsgUpdateValidatorSharesExchRateResponse, error)

+ func (k Keeper) RebalanceCallback(ctx sdk.Context, packet channeltypes.Packet, ...) error

+ func (k Keeper) RedemptionCallback(ctx sdk.Context, packet channeltypes.Packet, ...) error

+ func (k Keeper) ReinvestCallback(ctx sdk.Context, packet channeltypes.Packet, ...) error

+ func (k Keeper) ReinvestRewards(ctx sdk.Context)

+ func (k Keeper) RemoveEpochTracker(ctx sdk.Context, epochIdentifier string)

+ func (k Keeper) RemoveHostZone(ctx sdk.Context, chain_id string)

+ func (k Keeper) RemoveValidatorFromHostZone(ctx sdk.Context, chainId string, validatorAddress string) error

+ func (k Keeper) SetEpochTracker(ctx sdk.Context, epochTracker types.EpochTracker)

+ func (k Keeper) SetHostZone(ctx sdk.Context, hostZone types.HostZone)

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

+ func (k Keeper) SetWithdrawalAddress(ctx sdk.Context)

+ func (k Keeper) SetWithdrawalAddressOnHost(ctx sdk.Context, hostZone types.HostZone) error

+ func (k Keeper) StakeExistingDepositsOnHostZones(ctx sdk.Context, epochNumber uint64, ...)

+ func (k Keeper) SubmitHostZoneUnbondingMsg(ctx sdk.Context, msgs []proto.Message, totalAmtToUnbond sdkmath.Int, ...) error

+ func (k Keeper) SubmitTxs(ctx sdk.Context, connectionId string, msgs []proto.Message, ...) (uint64, error)

+ func (k Keeper) SubmitTxsDayEpoch(ctx sdk.Context, connectionId string, msgs []proto.Message, ...) (uint64, error)

+ func (k Keeper) SubmitTxsEpoch(ctx sdk.Context, connectionId string, msgs []proto.Message, ...) (uint64, error)

+ func (k Keeper) SubmitTxsStrideEpoch(ctx sdk.Context, connectionId string, msgs []proto.Message, ...) (uint64, error)

+ func (k Keeper) SweepAllUnbondedTokens(ctx sdk.Context) (success bool, successfulSweeps []string, sweepAmounts []sdkmath.Int, ...)

+ func (k Keeper) SweepAllUnbondedTokensForHostZone(ctx sdk.Context, hostZone types.HostZone, ...) (success bool, sweepAmount sdkmath.Int)

+ func (k Keeper) SweepStTokensFromRewardCollToFeeColl(ctx sdk.Context) error

+ func (k Keeper) TransferExistingDepositsToHostZones(ctx sdk.Context, epochNumber uint64, ...)

+ func (k Keeper) UndelegateCallback(ctx sdk.Context, packet channeltypes.Packet, ...) error

+ func (k Keeper) UnmarshalClaimCallbackArgs(ctx sdk.Context, claimCallback []byte) (*types.ClaimCallback, error)

+ func (k Keeper) UnmarshalDelegateCallbackArgs(ctx sdk.Context, delegateCallback []byte) (*types.DelegateCallback, error)

+ func (k Keeper) UnmarshalRebalanceCallbackArgs(ctx sdk.Context, rebalanceCallback []byte) (*types.RebalanceCallback, error)

+ func (k Keeper) UnmarshalRedemptionCallbackArgs(ctx sdk.Context, redemptionCallback []byte) (types.RedemptionCallback, error)

+ func (k Keeper) UnmarshalReinvestCallbackArgs(ctx sdk.Context, reinvestCallback []byte) (*types.ReinvestCallback, error)

+ func (k Keeper) UnmarshalUndelegateCallbackArgs(ctx sdk.Context, undelegateCallback []byte) (types.UndelegateCallback, error)

+ func (k Keeper) UpdateDelegationBalances(ctx sdk.Context, zone types.HostZone, ...) error

+ func (k Keeper) UpdateEpochTracker(ctx sdk.Context, epochInfo epochstypes.EpochInfo) (epochNumber uint64, err error)

+ func (k Keeper) UpdateHostZoneUnbondings(ctx sdk.Context, latestCompletionTime time.Time, chainId string, ...) (stTokenBurnAmount sdkmath.Int, err error)

+ func (k Keeper) UpdateRedemptionRates(ctx sdk.Context, depositRecords []recordstypes.DepositRecord)

+ func (k Keeper) UpdateWithdrawalBalance(ctx sdk.Context, hostZone types.HostZone) error

+ func (k Keeper) Validators(c context.Context, req *types.QueryGetValidatorsRequest) (*types.QueryGetValidatorsResponse, error)

Other modules containing this package

github.com/Stride-Labs/stride

github.com/Stride-Labs/stride/v10

github.com/Stride-Labs/stride/v11

github.com/Stride-Labs/stride/v13

github.com/Stride-Labs/stride/v14

github.com/Stride-Labs/stride/v15

github.com/Stride-Labs/stride/v16

github.com/Stride-Labs/stride/v17

github.com/Stride-Labs/stride/v18

github.com/Stride-Labs/stride/v19

github.com/Stride-Labs/stride/v20

github.com/Stride-Labs/stride/v21

github.com/Stride-Labs/stride/v22

github.com/Stride-Labs/stride/v23

github.com/Stride-Labs/stride/v24

github.com/Stride-Labs/stride/v3

github.com/Stride-Labs/stride/v4

github.com/Stride-Labs/stride/v5

github.com/Stride-Labs/stride/v6

github.com/Stride-Labs/stride/v7

github.com/Stride-Labs/stride/v8

github.com/Stride-Labs/stride/v9