Documentation ¶
Index ¶
- Constants
- func DelegationAccountBalanceCallback(k Keeper, ctx sdk.Context, data []byte, query icqtypes.Query) error
- func DelegationCallback(k Keeper, ctx sdk.Context, data []byte, query icqtypes.Query) error
- func NewMsgServerImpl(keeper Keeper) types.MsgServer
- func RewardsAccountBalanceCallback(k Keeper, ctx sdk.Context, data []byte, query icqtypes.Query) error
- func ValidatorCallback(k Keeper, ctx sdk.Context, data []byte, query icqtypes.Query) error
- func ValidatorSetCallback(k Keeper, ctx sdk.Context, data []byte, query icqtypes.Query) error
- type CallbackFn
- type Callbacks
- type DelegateAmount
- type EpochsHooks
- type IBCTransferHooks
- func (i IBCTransferHooks) OnAcknowledgementPacket(ctx sdk.Context, packet channeltypes.Packet, acknowledgement []byte, ...) error
- func (i IBCTransferHooks) OnRecvPacket(ctx sdk.Context, packet channeltypes.Packet, relayer sdk.AccAddress, ...) error
- func (i IBCTransferHooks) OnTimeoutPacket(ctx sdk.Context, packet channeltypes.Packet, relayer sdk.AccAddress, ...) error
- type Keeper
- func (k *Keeper) AdjustDepositsForRedemption(ctx sdk.Context, hc *liquidstakeibctypes.HostChain, redeemableAmount sdk.Coin) error
- func (k *Keeper) AfterEpochEnd(ctx sdk.Context, epochIdentifier string, epochNumber int64) error
- func (k *Keeper) BeforeEpochStart(ctx sdk.Context, epochIdentifier string, epochNumber int64) error
- func (k *Keeper) BeginBlock(ctx sdk.Context)
- func (k *Keeper) CallbackHandler() Callbacks
- func (k *Keeper) CreateDeposits(ctx sdk.Context, epoch int64)
- func (k *Keeper) DeleteDeposit(ctx sdk.Context, deposit *liquidstakeibctypes.Deposit)
- func (k *Keeper) DeleteUnbonding(ctx sdk.Context, ub *types.Unbonding)
- func (k *Keeper) DeleteUserUnbonding(ctx sdk.Context, ub *types.UserUnbonding)
- func (k *Keeper) DeleteValidatorUnbonding(ctx sdk.Context, ub *types.ValidatorUnbonding)
- func (k *Keeper) DeleteValidatorUnbondingsForSequenceID(ctx sdk.Context, sequenceID string)
- func (k *Keeper) DepositAccountBalance(goCtx context.Context, request *types.QueryDepositAccountBalanceRequest) (*types.QueryDepositAccountBalanceResponse, error)
- func (k *Keeper) DepositWorkflow(ctx sdk.Context, epoch int64)
- func (k *Keeper) Deposits(goCtx context.Context, request *types.QueryDepositsRequest) (*types.QueryDepositsResponse, error)
- func (k *Keeper) DoClaim(ctx sdk.Context, hc *types.HostChain)
- func (k *Keeper) DoDelegate(ctx sdk.Context, hc *types.HostChain)
- func (k *Keeper) DoProcessMaturedUndelegations(ctx sdk.Context, hc *types.HostChain)
- func (k *Keeper) DoRecreateICA(ctx sdk.Context, hc *types.HostChain)
- func (k *Keeper) DoUpdateValidatorSet(ctx sdk.Context, hc *types.HostChain)
- func (k *Keeper) ExchangeRate(goCtx context.Context, request *types.QueryExchangeRateRequest) (*types.QueryExchangeRateResponse, error)
- func (k *Keeper) FailAllUnbondingsForSequenceID(ctx sdk.Context, sequenceID string)
- func (k *Keeper) FilterUnbondings(ctx sdk.Context, filter func(u types.Unbonding) bool) []*types.Unbonding
- func (k *Keeper) FilterUserUnbondings(ctx sdk.Context, filter func(u types.UserUnbonding) bool) []*types.UserUnbonding
- func (k *Keeper) FilterValidatorUnbondings(ctx sdk.Context, filter func(u types.ValidatorUnbonding) bool) []*types.ValidatorUnbonding
- func (k *Keeper) GenerateAndExecuteICATx(ctx sdk.Context, connectionID string, ownerID string, messages []proto.Message) (string, error)
- func (k *Keeper) GenerateDelegateMessages(hc *types.HostChain, depositAmount sdk.Int) ([]proto.Message, error)
- func (k *Keeper) GenerateUndelegateMessages(hc *types.HostChain, unbondAmount sdk.Int) ([]proto.Message, error)
- func (k *Keeper) GetAllDeposits(ctx sdk.Context) []*liquidstakeibctypes.Deposit
- func (k *Keeper) GetAllHostChains(ctx sdk.Context) []*types.HostChain
- func (k *Keeper) GetAllValidatorUnbondedAmount(ctx sdk.Context, hc *types.HostChain) sdk.Int
- func (k *Keeper) GetChainID(ctx sdk.Context, connectionID string) (string, error)
- func (k *Keeper) GetClientState(ctx sdk.Context, connectionID string) (*ibctmtypes.ClientState, error)
- func (k *Keeper) GetDelegableDepositsForChain(ctx sdk.Context, chainID string) []*liquidstakeibctypes.Deposit
- func (k *Keeper) GetDelegatingDepositsForChain(ctx sdk.Context, chainID string) []*liquidstakeibctypes.Deposit
- func (k *Keeper) GetDepositForChainAndEpoch(ctx sdk.Context, chainID string, epoch int64) (*liquidstakeibctypes.Deposit, bool)
- func (k *Keeper) GetDepositModuleAccount(ctx sdk.Context) authtypes.ModuleAccountI
- func (k *Keeper) GetDepositsForHostChain(ctx sdk.Context, chainID string) []*liquidstakeibctypes.Deposit
- func (k *Keeper) GetDepositsWithSequenceID(ctx sdk.Context, sequenceID string) []*liquidstakeibctypes.Deposit
- func (k *Keeper) GetEpochNumber(ctx sdk.Context, epoch string) int64
- func (k *Keeper) GetHostChain(ctx sdk.Context, chainID string) (*types.HostChain, bool)
- func (k *Keeper) GetHostChainCValue(ctx sdk.Context, hc *types.HostChain) sdk.Dec
- func (k *Keeper) GetHostChainFromDelegatorAddress(ctx sdk.Context, delegatorAddress string) (*types.HostChain, bool)
- func (k *Keeper) GetHostChainFromHostDenom(ctx sdk.Context, hostDenom string) (*types.HostChain, bool)
- func (k *Keeper) GetHostChainFromIbcDenom(ctx sdk.Context, ibcDenom string) (*types.HostChain, bool)
- func (k *Keeper) GetLatestConsensusState(ctx sdk.Context, connectionID string) (*ibctmtypes.ConsensusState, error)
- func (k *Keeper) GetParams(ctx sdk.Context) (params types.Params)
- func (k *Keeper) GetPendingDepositsBeforeEpoch(ctx sdk.Context, epoch int64) []*liquidstakeibctypes.Deposit
- func (k *Keeper) GetPortID(owner string) string
- func (k *Keeper) GetRedeemableDepositsForHostChain(ctx sdk.Context, hc *liquidstakeibctypes.HostChain) ([]*liquidstakeibctypes.Deposit, sdk.Int)
- func (k *Keeper) GetTransactionSequenceID(channelID string, sequence uint64) string
- func (k *Keeper) GetUnbonding(ctx sdk.Context, chainID string, epochNumber int64) (*types.Unbonding, bool)
- func (k *Keeper) GetUndelegationModuleAccount(ctx sdk.Context) authtypes.ModuleAccountI
- func (k *Keeper) GetUserUnbonding(ctx sdk.Context, chainID string, delegatorAddress string, epochNumber int64) (*types.UserUnbonding, bool)
- func (k *Keeper) GetValidatorUnbonding(ctx sdk.Context, chainID string, validatorAddress string, epochNumber int64) (*types.ValidatorUnbonding, bool)
- func (k *Keeper) HandleDelegateResponse(ctx sdk.Context, msg sdk.Msg, channel string, sequence uint64) error
- func (k *Keeper) HandleMsgTransfer(ctx sdk.Context, msg sdk.Msg, resp ibctransfertypes.MsgTransferResponse, ...) error
- func (k *Keeper) HandleUndelegateResponse(ctx sdk.Context, msg sdk.Msg, resp stakingtypes.MsgUndelegateResponse, ...) error
- func (k *Keeper) HostChain(goCtx context.Context, request *types.QueryHostChainRequest) (*types.QueryHostChainResponse, error)
- func (k *Keeper) HostChains(goCtx context.Context, request *types.QueryHostChainsRequest) (*types.QueryHostChainsResponse, error)
- func (k *Keeper) IncreaseUndelegatingAmountForEpoch(ctx sdk.Context, chainID string, epochNumber int64, burnAmount sdk.Coin, ...)
- func (k *Keeper) IncreaseUserUnbondingAmountForEpoch(ctx sdk.Context, chainID string, delegatorAddress string, epochNumber int64, ...)
- func (k *Keeper) IsICAChannelActive(ctx sdk.Context, hc *types.HostChain, owner string) bool
- func (k *Keeper) Logger(ctx sdk.Context) log.Logger
- func (k *Keeper) NewEpochHooks() EpochsHooks
- func (k *Keeper) NewIBCTransferHooks() IBCTransferHooks
- func (k *Keeper) OnAcknowledgementIBCTransferPacket(ctx sdk.Context, packet channeltypes.Packet, acknowledgement []byte, ...) error
- func (k *Keeper) OnAcknowledgementPacket(ctx sdk.Context, packet channeltypes.Packet, acknowledgement []byte, ...) error
- func (k *Keeper) OnChanOpenAck(ctx sdk.Context, portID string, channelID string, counterpartyChannelID string, ...) error
- func (k *Keeper) OnChanOpenInit(ctx sdk.Context, order channeltypes.Order, connectionHops []string, ...) (string, error)
- func (k *Keeper) OnRecvIBCTransferPacket(ctx sdk.Context, packet channeltypes.Packet, relayer sdk.AccAddress, ...) error
- func (k *Keeper) OnTimeoutIBCTransferPacket(ctx sdk.Context, packet channeltypes.Packet, relayer sdk.AccAddress, ...) error
- func (k *Keeper) OnTimeoutPacket(ctx sdk.Context, packet channeltypes.Packet, relayer sdk.AccAddress) error
- func (k *Keeper) Params(goCtx context.Context, request *types.QueryParamsRequest) (*types.QueryParamsResponse, error)
- func (k *Keeper) ProcessHostChainValidatorUpdates(ctx sdk.Context, hc *types.HostChain, validator stakingtypes.Validator) error
- func (k *Keeper) QueryDelegationHostChainAccountBalance(ctx sdk.Context, hc *types.HostChain) error
- func (k *Keeper) QueryHostChainValidator(ctx sdk.Context, hc *types.HostChain, validatorAddress string) error
- func (k *Keeper) QueryHostChainValidators(ctx sdk.Context, hc *types.HostChain, req stakingtypes.QueryValidatorsRequest) error
- func (k *Keeper) QueryRewardsHostChainAccountBalance(ctx sdk.Context, hc *types.HostChain) error
- func (k *Keeper) QueryValidatorDelegation(ctx sdk.Context, hc *types.HostChain, validator *types.Validator) error
- func (k *Keeper) RedistributeValidatorWeight(ctx sdk.Context, hc *types.HostChain, validator *types.Validator)
- func (k *Keeper) RegisterICAAccount(ctx sdk.Context, connectionID, owner string) error
- func (k *Keeper) RevertDepositsState(ctx sdk.Context, deposits []*liquidstakeibctypes.Deposit)
- func (k *Keeper) RevertUnbondingsState(ctx sdk.Context, unbondings []*types.Unbonding)
- func (k *Keeper) RewardsWorkflow(ctx sdk.Context, epoch int64)
- func (k *Keeper) SendICATransfer(ctx sdk.Context, hc *types.HostChain, amount sdk.Coin, sender string, ...) (string, error)
- func (k *Keeper) SendProtocolFee(ctx sdk.Context, protocolFee sdk.Coins, moduleAccount, feeAddress string) error
- func (k *Keeper) SetDeposit(ctx sdk.Context, deposit *liquidstakeibctypes.Deposit)
- func (k *Keeper) SetHostChain(ctx sdk.Context, hc *types.HostChain)
- func (k *Keeper) SetHostChainValidator(ctx sdk.Context, hc *types.HostChain, validator *types.Validator)
- func (k *Keeper) SetParams(ctx sdk.Context, params types.Params)
- func (k *Keeper) SetUnbonding(ctx sdk.Context, ub *types.Unbonding)
- func (k *Keeper) SetUserUnbonding(ctx sdk.Context, ub *types.UserUnbonding)
- func (k *Keeper) SetValidatorUnbonding(ctx sdk.Context, vu *types.ValidatorUnbonding)
- func (k *Keeper) SetWithdrawAddress(ctx sdk.Context, hc *types.HostChain) error
- func (k *Keeper) Unbonding(goCtx context.Context, request *types.QueryUnbondingRequest) (*types.QueryUnbondingResponse, error)
- func (k *Keeper) Unbondings(goCtx context.Context, request *types.QueryUnbondingsRequest) (*types.QueryUnbondingsResponse, error)
- func (k *Keeper) UndelegationWorkflow(ctx sdk.Context, epoch int64)
- func (k *Keeper) UpdateHostChainValidatorWeight(ctx sdk.Context, hc *types.HostChain, address string, weight string) error
- func (k *Keeper) UserUnbondings(goCtx context.Context, request *types.QueryUserUnbondingsRequest) (*types.QueryUserUnbondingsResponse, error)
- func (k *Keeper) ValidatorUnbondings(goCtx context.Context, request *types.QueryValidatorUnbondingRequest) (*types.QueryValidatorUnbondingResponse, error)
- func (k *Keeper) ValidatorUndelegationWorkflow(ctx sdk.Context, epoch int64)
Constants ¶
const ( ValidatorSet = "validatorset" Validator = "validator" RewardAccountBalances = "reward-balances" DelegationAccountBalances = "delegation-balances" Delegation = "validator-delegation" )
const ( KeyValidatorWeight string = "validator_weight" KeyDepositFee string = "deposit_fee" KeyRestakeFee string = "restake_fee" KeyUnstakeFee string = "unstake_fee" KeyRedemptionFee string = "redemption_fee" KeyMinimumDeposit string = "min_deposit" KeyActive string = "active" KeySetWithdrawAddress string = "set_withdraw_address" )
Variables ¶
This section is empty.
Functions ¶
func DelegationCallback ¶
func NewMsgServerImpl ¶
NewMsgServerImpl returns an implementation of the liquidstakeibc MsgServer interface for the provided Keeper.
func ValidatorCallback ¶
Types ¶
type Callbacks ¶
type Callbacks struct {
// contains filtered or unexported fields
}
func (Callbacks) AddCallback ¶
func (c Callbacks) AddCallback(id string, fn interface{}) icqtypes.QueryCallbacks
func (Callbacks) RegisterCallbacks ¶
func (c Callbacks) RegisterCallbacks() icqtypes.QueryCallbacks
type DelegateAmount ¶
type EpochsHooks ¶
type EpochsHooks struct {
// contains filtered or unexported fields
}
func (EpochsHooks) AfterEpochEnd ¶
func (EpochsHooks) BeforeEpochStart ¶
type IBCTransferHooks ¶
type IBCTransferHooks struct {
// contains filtered or unexported fields
}
func (IBCTransferHooks) OnAcknowledgementPacket ¶
func (i IBCTransferHooks) OnAcknowledgementPacket( ctx sdk.Context, packet channeltypes.Packet, acknowledgement []byte, relayer sdk.AccAddress, transferAckErr error, ) error
func (IBCTransferHooks) OnRecvPacket ¶
func (i IBCTransferHooks) OnRecvPacket( ctx sdk.Context, packet channeltypes.Packet, relayer sdk.AccAddress, transferAck ibcexported.Acknowledgement, ) error
func (IBCTransferHooks) OnTimeoutPacket ¶
func (i IBCTransferHooks) OnTimeoutPacket( ctx sdk.Context, packet channeltypes.Packet, relayer sdk.AccAddress, transferTimeoutErr error, ) error
type Keeper ¶
type Keeper struct {
// contains filtered or unexported fields
}
func NewKeeper ¶
func NewKeeper( cdc codec.BinaryCodec, storeKey storetypes.StoreKey, accountKeeper types.AccountKeeper, bankKeeper types.BankKeeper, epochsKeeper types.EpochsKeeper, icaControllerKeeper types.ICAControllerKeeper, ibcKeeper *ibckeeper.Keeper, icqKeeper types.ICQKeeper, paramSpace paramtypes.Subspace, msgRouter *baseapp.MsgServiceRouter, authority string, ) Keeper
func (*Keeper) AdjustDepositsForRedemption ¶
func (*Keeper) AfterEpochEnd ¶
func (*Keeper) BeforeEpochStart ¶
func (*Keeper) BeginBlock ¶
func (*Keeper) CallbackHandler ¶
func (*Keeper) DeleteDeposit ¶
func (k *Keeper) DeleteDeposit(ctx sdk.Context, deposit *liquidstakeibctypes.Deposit)
func (*Keeper) DeleteUnbonding ¶
func (*Keeper) DeleteUserUnbonding ¶
func (k *Keeper) DeleteUserUnbonding(ctx sdk.Context, ub *types.UserUnbonding)
func (*Keeper) DeleteValidatorUnbonding ¶
func (k *Keeper) DeleteValidatorUnbonding(ctx sdk.Context, ub *types.ValidatorUnbonding)
func (*Keeper) DeleteValidatorUnbondingsForSequenceID ¶
func (*Keeper) DepositAccountBalance ¶
func (k *Keeper) DepositAccountBalance( goCtx context.Context, request *types.QueryDepositAccountBalanceRequest, ) (*types.QueryDepositAccountBalanceResponse, error)
func (*Keeper) Deposits ¶
func (k *Keeper) Deposits( goCtx context.Context, request *types.QueryDepositsRequest, ) (*types.QueryDepositsResponse, error)
func (*Keeper) DoProcessMaturedUndelegations ¶
func (*Keeper) DoUpdateValidatorSet ¶
func (*Keeper) ExchangeRate ¶
func (k *Keeper) ExchangeRate( goCtx context.Context, request *types.QueryExchangeRateRequest, ) (*types.QueryExchangeRateResponse, error)
func (*Keeper) FailAllUnbondingsForSequenceID ¶
func (*Keeper) FilterUnbondings ¶
func (*Keeper) FilterUserUnbondings ¶
func (k *Keeper) FilterUserUnbondings(ctx sdk.Context, filter func(u types.UserUnbonding) bool) []*types.UserUnbonding
func (*Keeper) FilterValidatorUnbondings ¶
func (k *Keeper) FilterValidatorUnbondings( ctx sdk.Context, filter func(u types.ValidatorUnbonding) bool, ) []*types.ValidatorUnbonding
func (*Keeper) GenerateAndExecuteICATx ¶
func (*Keeper) GenerateDelegateMessages ¶
func (*Keeper) GenerateUndelegateMessages ¶
func (*Keeper) GetAllDeposits ¶
func (k *Keeper) GetAllDeposits(ctx sdk.Context) []*liquidstakeibctypes.Deposit
func (*Keeper) GetAllHostChains ¶
GetAllHostChains retrieves all registered host chains
func (*Keeper) GetAllValidatorUnbondedAmount ¶
func (*Keeper) GetChainID ¶
GetChainID gets the id of the host chain given a connection id
func (*Keeper) GetClientState ¶
func (k *Keeper) GetClientState(ctx sdk.Context, connectionID string) (*ibctmtypes.ClientState, error)
GetClientState retrieves the client state given a connection id
func (*Keeper) GetDelegableDepositsForChain ¶
func (*Keeper) GetDelegatingDepositsForChain ¶
func (*Keeper) GetDepositForChainAndEpoch ¶
func (*Keeper) GetDepositModuleAccount ¶
func (k *Keeper) GetDepositModuleAccount(ctx sdk.Context) authtypes.ModuleAccountI
GetDepositModuleAccount returns deposit module account interface
func (*Keeper) GetDepositsForHostChain ¶
func (*Keeper) GetDepositsWithSequenceID ¶
func (*Keeper) GetEpochNumber ¶
func (*Keeper) GetHostChain ¶
GetHostChain returns a host chain given its id
func (*Keeper) GetHostChainCValue ¶
GetHostChainCValue calculates the host chain c value
func (*Keeper) GetHostChainFromDelegatorAddress ¶
func (k *Keeper) GetHostChainFromDelegatorAddress(ctx sdk.Context, delegatorAddress string) (*types.HostChain, bool)
GetHostChainFromDelegatorAddress returns a host chain given its delegator address
func (*Keeper) GetHostChainFromHostDenom ¶
func (k *Keeper) GetHostChainFromHostDenom(ctx sdk.Context, hostDenom string) (*types.HostChain, bool)
GetHostChainFromHostDenom returns a host chain given its host denomination
func (*Keeper) GetHostChainFromIbcDenom ¶
func (k *Keeper) GetHostChainFromIbcDenom(ctx sdk.Context, ibcDenom string) (*types.HostChain, bool)
GetHostChainFromIbcDenom returns a host chain given its ibc denomination on Persistence
func (*Keeper) GetLatestConsensusState ¶
func (k *Keeper) GetLatestConsensusState(ctx sdk.Context, connectionID string) (*ibctmtypes.ConsensusState, error)
GetLatestConsensusState retrieves the last tendermint consensus state
func (*Keeper) GetPendingDepositsBeforeEpoch ¶
func (*Keeper) GetRedeemableDepositsForHostChain ¶
func (k *Keeper) GetRedeemableDepositsForHostChain( ctx sdk.Context, hc *liquidstakeibctypes.HostChain, ) ([]*liquidstakeibctypes.Deposit, sdk.Int)
func (*Keeper) GetTransactionSequenceID ¶
func (*Keeper) GetUnbonding ¶
func (*Keeper) GetUndelegationModuleAccount ¶
func (k *Keeper) GetUndelegationModuleAccount(ctx sdk.Context) authtypes.ModuleAccountI
GetUndelegationModuleAccount returns undelegation module account interface
func (*Keeper) GetUserUnbonding ¶
func (*Keeper) GetValidatorUnbonding ¶
func (*Keeper) HandleDelegateResponse ¶
func (*Keeper) HandleMsgTransfer ¶
func (k *Keeper) HandleMsgTransfer( ctx sdk.Context, msg sdk.Msg, resp ibctransfertypes.MsgTransferResponse, channel string, sequence uint64, ) error
func (*Keeper) HandleUndelegateResponse ¶
func (k *Keeper) HandleUndelegateResponse( ctx sdk.Context, msg sdk.Msg, resp stakingtypes.MsgUndelegateResponse, channel string, sequence uint64, ) error
func (*Keeper) HostChain ¶
func (k *Keeper) HostChain( goCtx context.Context, request *types.QueryHostChainRequest, ) (*types.QueryHostChainResponse, error)
func (*Keeper) HostChains ¶
func (k *Keeper) HostChains( goCtx context.Context, request *types.QueryHostChainsRequest, ) (*types.QueryHostChainsResponse, error)
func (*Keeper) IncreaseUndelegatingAmountForEpoch ¶
func (*Keeper) IncreaseUserUnbondingAmountForEpoch ¶
func (*Keeper) IsICAChannelActive ¶
IsICAChannelActive checks if an ICA channel is active
func (*Keeper) NewEpochHooks ¶
func (k *Keeper) NewEpochHooks() EpochsHooks
func (*Keeper) NewIBCTransferHooks ¶
func (k *Keeper) NewIBCTransferHooks() IBCTransferHooks
func (*Keeper) OnAcknowledgementIBCTransferPacket ¶
func (k *Keeper) OnAcknowledgementIBCTransferPacket( ctx sdk.Context, packet channeltypes.Packet, acknowledgement []byte, relayer sdk.AccAddress, transferAckErr error, ) error
func (*Keeper) OnAcknowledgementPacket ¶
func (k *Keeper) OnAcknowledgementPacket( ctx sdk.Context, packet channeltypes.Packet, acknowledgement []byte, relayer sdk.AccAddress, ) error
func (*Keeper) OnChanOpenAck ¶
func (*Keeper) OnChanOpenInit ¶
func (k *Keeper) OnChanOpenInit( ctx sdk.Context, order channeltypes.Order, connectionHops []string, portID string, channelID string, channelCap *capabilitytypes.Capability, counterparty channeltypes.Counterparty, version string, ) (string, error)
func (*Keeper) OnRecvIBCTransferPacket ¶
func (k *Keeper) OnRecvIBCTransferPacket( ctx sdk.Context, packet channeltypes.Packet, relayer sdk.AccAddress, transferAck ibcexported.Acknowledgement, ) error
func (*Keeper) OnTimeoutIBCTransferPacket ¶
func (k *Keeper) OnTimeoutIBCTransferPacket( ctx sdk.Context, packet channeltypes.Packet, relayer sdk.AccAddress, transferTimeoutErr error, ) error
func (*Keeper) OnTimeoutPacket ¶
func (k *Keeper) OnTimeoutPacket( ctx sdk.Context, packet channeltypes.Packet, relayer sdk.AccAddress, ) error
func (*Keeper) Params ¶
func (k *Keeper) Params(goCtx context.Context, request *types.QueryParamsRequest) (*types.QueryParamsResponse, error)
func (*Keeper) ProcessHostChainValidatorUpdates ¶
func (k *Keeper) ProcessHostChainValidatorUpdates( ctx sdk.Context, hc *types.HostChain, validator stakingtypes.Validator, ) error
ProcessHostChainValidatorUpdates processes the new validator set for a host chain
func (*Keeper) QueryDelegationHostChainAccountBalance ¶
func (k *Keeper) QueryDelegationHostChainAccountBalance( ctx sdk.Context, hc *types.HostChain, ) error
QueryDelegationHostChainAccountBalance sends an ICQ query to get the delegation host account balance
func (*Keeper) QueryHostChainValidator ¶
func (k *Keeper) QueryHostChainValidator( ctx sdk.Context, hc *types.HostChain, validatorAddress string, ) error
QueryHostChainValidator sends an ICQ query to retrieve a specific host chain validator
func (*Keeper) QueryHostChainValidators ¶
func (k *Keeper) QueryHostChainValidators( ctx sdk.Context, hc *types.HostChain, req stakingtypes.QueryValidatorsRequest, ) error
QueryHostChainValidators sends an ICQ query to retrieve the host chain validator set
func (*Keeper) QueryRewardsHostChainAccountBalance ¶
QueryRewardsHostChainAccountBalance sends an ICQ query to get the rewards host account balance
func (*Keeper) QueryValidatorDelegation ¶
func (k *Keeper) QueryValidatorDelegation( ctx sdk.Context, hc *types.HostChain, validator *types.Validator, ) error
QueryValidatorDelegation sends an ICQ query to get a validator delegation
func (*Keeper) RedistributeValidatorWeight ¶
func (*Keeper) RegisterICAAccount ¶
RegisterICAAccount registers an ICA
func (*Keeper) RevertDepositsState ¶
func (k *Keeper) RevertDepositsState(ctx sdk.Context, deposits []*liquidstakeibctypes.Deposit)
func (*Keeper) RevertUnbondingsState ¶
func (*Keeper) SendICATransfer ¶
func (*Keeper) SendProtocolFee ¶
func (k *Keeper) SendProtocolFee(ctx sdk.Context, protocolFee sdk.Coins, moduleAccount, feeAddress string) error
SendProtocolFee to the community pool
func (*Keeper) SetDeposit ¶
func (k *Keeper) SetDeposit(ctx sdk.Context, deposit *liquidstakeibctypes.Deposit)
func (*Keeper) SetHostChain ¶
SetHostChain sets a host chain in the store
func (*Keeper) SetHostChainValidator ¶
func (k *Keeper) SetHostChainValidator( ctx sdk.Context, hc *types.HostChain, validator *types.Validator, )
SetHostChainValidator sets a validator on the target host chain
func (*Keeper) SetUserUnbonding ¶
func (k *Keeper) SetUserUnbonding(ctx sdk.Context, ub *types.UserUnbonding)
func (*Keeper) SetValidatorUnbonding ¶
func (k *Keeper) SetValidatorUnbonding(ctx sdk.Context, vu *types.ValidatorUnbonding)
func (*Keeper) SetWithdrawAddress ¶
SetWithdrawAddress sends a MsgSetWithdrawAddress to set the withdrawal address to the rewards account
func (*Keeper) Unbonding ¶
func (k *Keeper) Unbonding( goCtx context.Context, request *types.QueryUnbondingRequest, ) (*types.QueryUnbondingResponse, error)
func (*Keeper) Unbondings ¶
func (k *Keeper) Unbondings( goCtx context.Context, request *types.QueryUnbondingsRequest, ) (*types.QueryUnbondingsResponse, error)
func (*Keeper) UndelegationWorkflow ¶
func (*Keeper) UpdateHostChainValidatorWeight ¶
func (k *Keeper) UpdateHostChainValidatorWeight( ctx sdk.Context, hc *types.HostChain, address string, weight string, ) error
UpdateHostChainValidatorWeight updates a host chain validator weight
func (*Keeper) UserUnbondings ¶
func (k *Keeper) UserUnbondings( goCtx context.Context, request *types.QueryUserUnbondingsRequest, ) (*types.QueryUserUnbondingsResponse, error)
func (*Keeper) ValidatorUnbondings ¶
func (k *Keeper) ValidatorUnbondings( goCtx context.Context, request *types.QueryValidatorUnbondingRequest, ) (*types.QueryValidatorUnbondingResponse, error)