Versions in this module Expand all Collapse all v18 v18.0.0 Jan 27, 2024 Changes in this version + func EmitTransferDeniedEvent(ctx sdk.Context, reason, denom, channelId string, ...) + func GetRateLimitItemKey(denom string, channelId string) []byte + func ParseDenomFromRecvPacket(packet channeltypes.Packet, packetData transfertypes.FungibleTokenPacketData) (denom string) + func ParseDenomFromSendPacket(packet transfertypes.FungibleTokenPacketData) (denom string) + type Hooks struct + func (h Hooks) AfterEpochEnd(ctx sdk.Context, epochInfo epochstypes.EpochInfo) + func (h Hooks) BeforeEpochStart(ctx sdk.Context, epochInfo epochstypes.EpochInfo) + type Keeper struct + func NewKeeper(cdc codec.BinaryCodec, key storetypes.StoreKey, ps paramtypes.Subspace, ...) *Keeper + func (k Keeper) AcknowledgeRateLimitedPacket(ctx sdk.Context, packet channeltypes.Packet, acknowledgement []byte) error + func (k Keeper) AddDenomToBlacklist(ctx sdk.Context, denom string) + func (k Keeper) AfterEpochEnd(ctx sdk.Context, epochInfo epochstypes.EpochInfo) + func (k Keeper) AllBlacklistedDenoms(c context.Context, req *types.QueryAllBlacklistedDenomsRequest) (*types.QueryAllBlacklistedDenomsResponse, error) + func (k Keeper) AllRateLimits(c context.Context, req *types.QueryAllRateLimitsRequest) (*types.QueryAllRateLimitsResponse, error) + func (k Keeper) AllWhitelistedAddresses(c context.Context, req *types.QueryAllWhitelistedAddressesRequest) (*types.QueryAllWhitelistedAddressesResponse, error) + func (k Keeper) BeforeEpochStart(ctx sdk.Context, epochInfo epochstypes.EpochInfo) + func (k Keeper) CheckPacketSentDuringCurrentQuota(ctx sdk.Context, channelId string, sequence uint64) bool + func (k Keeper) CheckRateLimitAndUpdateFlow(ctx sdk.Context, direction types.PacketDirection, ...) (updatedFlow bool, err error) + func (k Keeper) GetAllBlacklistedDenoms(ctx sdk.Context) []string + func (k Keeper) GetAllPendingSendPackets(ctx sdk.Context) []string + func (k Keeper) GetAllRateLimits(ctx sdk.Context) []types.RateLimit + func (k Keeper) GetAllWhitelistedAddressPairs(ctx sdk.Context) []types.WhitelistedAddressPair + func (k Keeper) GetAppVersion(ctx sdk.Context, portID, channelID string) (string, bool) + func (k Keeper) GetChannelValue(ctx sdk.Context, denom string) sdkmath.Int + func (k Keeper) GetParams(ctx sdk.Context) types.Params + func (k Keeper) GetRateLimit(ctx sdk.Context, denom string, channelId string) (rateLimit types.RateLimit, found bool) + func (k Keeper) Hooks() Hooks + func (k Keeper) IsAddressPairWhitelisted(ctx sdk.Context, sender, receiver string) bool + func (k Keeper) IsDenomBlacklisted(ctx sdk.Context, denom string) bool + func (k Keeper) Logger(ctx sdk.Context) log.Logger + func (k Keeper) RateLimit(c context.Context, req *types.QueryRateLimitRequest) (*types.QueryRateLimitResponse, error) + func (k Keeper) RateLimitsByChainId(c context.Context, req *types.QueryRateLimitsByChainIdRequest) (*types.QueryRateLimitsByChainIdResponse, error) + func (k Keeper) RateLimitsByChannelId(c context.Context, req *types.QueryRateLimitsByChannelIdRequest) (*types.QueryRateLimitsByChannelIdResponse, error) + func (k Keeper) ReceiveRateLimitedPacket(ctx sdk.Context, packet channeltypes.Packet) error + func (k Keeper) RemoveAllChannelPendingSendPackets(ctx sdk.Context, channelId string) + func (k Keeper) RemoveDenomFromBlacklist(ctx sdk.Context, denom string) + func (k Keeper) RemovePendingSendPacket(ctx sdk.Context, channelId string, sequence uint64) + func (k Keeper) RemoveRateLimit(ctx sdk.Context, denom string, channelId string) + func (k Keeper) RemoveWhitelistedAddressPair(ctx sdk.Context, sender, receiver string) + func (k Keeper) ResetRateLimit(ctx sdk.Context, denom string, channelId string) error + func (k Keeper) SendPacket(ctx sdk.Context, channelCap *capabilitytypes.Capability, sourcePort string, ...) (sequence uint64, err error) + func (k Keeper) SendRateLimitedPacket(ctx sdk.Context, packet channeltypes.Packet) error + func (k Keeper) SetParams(ctx sdk.Context, params types.Params) + func (k Keeper) SetPendingSendPacket(ctx sdk.Context, channelId string, sequence uint64) + func (k Keeper) SetRateLimit(ctx sdk.Context, rateLimit types.RateLimit) + func (k Keeper) SetWhitelistedAddressPair(ctx sdk.Context, whitelist types.WhitelistedAddressPair) + func (k Keeper) TimeoutRateLimitedPacket(ctx sdk.Context, packet channeltypes.Packet) error + func (k Keeper) UndoSendPacket(ctx sdk.Context, channelId string, sequence uint64, denom string, ...) error + func (k Keeper) UpdateFlow(rateLimit types.RateLimit, direction types.PacketDirection, amount sdkmath.Int) error + func (k Keeper) WriteAcknowledgement(ctx sdk.Context, chanCap *capabilitytypes.Capability, ...) error + type RateLimitedPacketInfo struct + Amount sdkmath.Int + ChannelID string + Denom string + Receiver string + Sender string + func ParsePacketInfo(packet channeltypes.Packet, direction types.PacketDirection) (RateLimitedPacketInfo, error) v18.0.0-testnet Jan 27, 2024 Other modules containing this package github.com/Stride-Labs/stride/v10 github.com/Stride-Labs/stride/v11 github.com/Stride-Labs/stride/v12 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/v7 github.com/Stride-Labs/stride/v8 github.com/Stride-Labs/stride/v9