keeper

package

Go to main page

Versions in this module

v1

v1.15.1

Jun 27, 2024

Changes in this version

type Keeper

+ func (k Keeper) AllBridgeTransferLimits(ctx context.Context) ([]*types.BridgeTransferLimit, error)

+ func (k Keeper) BridgeTax(ctx context.Context) (*types.BridgeTax, error)

+ func (k Keeper) BridgeTransferLimit(ctx context.Context, token string) (*types.BridgeTransferLimit, error)

+ func (k Keeper) BridgeTransferUsage(ctx context.Context, token string) (*types.BridgeTransferUsage, error)

+ func (k Keeper) GetBridgeTax(goCtx context.Context, _ *emptypb.Empty) (*types.QueryBridgeTaxResponse, error)

+ func (k Keeper) GetBridgeTransferLimits(goCtx context.Context, _ *emptypb.Empty) (*types.QueryBridgeTransferLimitsResponse, error)

+ func (k Keeper) SetBridgeTax(ctx context.Context, tax *types.BridgeTax) error

+ func (k Keeper) SetBridgeTransferLimit(ctx context.Context, limit *types.BridgeTransferLimit) error

+ func (k Keeper) UpdateBridgeTransferUsageWithLimit(ctx context.Context, sender sdk.AccAddress, coin sdk.Coin) error

type TestInput

+ EvmKeeper evmkeeper.Keeper

v1.15.0

Jun 13, 2024

Changes in this version

type Keeper

+ func (k Keeper) GetLastGravityNonceByValidator(ctx context.Context, validator sdk.ValAddress, chainReferenceID string) (uint64, error)

+ func (k Keeper) GetLastObservedGravityNonce(ctx context.Context, chainReferenceID string) (uint64, error)

+ func (k Keeper) LastObservedGravityBlock(c context.Context, req *types.QueryLastObservedGravityBlockRequest) (*types.QueryLastObservedGravityBlockResponse, error)

+ func (k Keeper) LastObservedGravityNonce(c context.Context, req *types.QueryLastObservedGravityNonceRequest) (*types.QueryLastObservedGravityNonceResponse, error)

+ func (k Keeper) LastObservedGravityNonceByAddr(c context.Context, req *types.QueryLastObservedGravityNonceByAddrRequest) (*types.QueryLastObservedGravityNonceResponse, error)

+ func (k Keeper) SetLastGravityNonceByValidator(ctx context.Context, validator sdk.ValAddress, chainReferenceID string, ...) error

v1.14.0

Jun 7, 2024

Changes in this version

type Keeper

+ func (k Keeper) GetChainsWithTokens(ctx context.Context) []string

v1.14.0-b895c4d

Jun 7, 2024

v1.13.5

Apr 30, 2024

v1.13.4

Apr 25, 2024

v1.13.3

Apr 21, 2024

v1.13.2

Apr 18, 2024

v1.13.1

Apr 9, 2024

v1.13.0

Mar 29, 2024

Changes in this version

type Keeper

+ AddressCodec address.Codec

+ func (k Keeper) GetAuthority() string

+ type Migrator struct

+ func NewMigrator(keeper *Keeper, legacySubspace exported.Subspace) Migrator

+ func (m Migrator) Migrate4to5(ctx sdk.Context) error

v1.12.2

Mar 15, 2024

v1.12.1

Feb 8, 2024

v1.12.0

Feb 2, 2024

v1.11.0

Jan 15, 2024

Changes in this version

type Keeper

+ func (k Keeper) CastAllERC20ToDenoms(ctx sdk.Context) ([]evmtypes.ERC20Record, error)

v1.10.2

Dec 7, 2023

v1.10.1

Nov 28, 2023

v1.10.0

Nov 10, 2023

Changes in this version

type Keeper

+ func (k Keeper) LastEventNonce(c context.Context, req *types.QueryLastEventNonceRequest) (*types.QueryLastEventNonceResponse, error)

v1.9.2

Oct 19, 2023

v1.9.1

Oct 12, 2023

v1.9.0

Sep 28, 2023

v1.8.2

Sep 18, 2023

v1.8.0

Sep 4, 2023

Changes in this version

+ const MERCURY_UPGRADE_HEIGHT

+ const MaxResults

+ const OutgoingTxBatchSize

+ const QUERY_ATTESTATIONS_LIMIT

+ var EthPrivKeys = []*ecdsa.PrivateKey

+ var OrchAddrs = []sdk.AccAddress

+ var OrchPrivKeys = []ccrypto.PrivKey

+ var OrchPubKeys = []ccrypto.PubKey

+ func AllInvariants(k Keeper) sdk.Invariant

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

+ func MakeTestEncodingConfig() gravityparams.EncodingConfig

+ func ModuleBalanceInvariant(k Keeper) sdk.Invariant

+ func NewGravityProposalHandler(k Keeper) govv1beta1types.Handler

+ func StoreValidityInvariant(k Keeper) sdk.Invariant

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

+ type AttestationHandler struct

+ func (a AttestationHandler) Handle(ctx sdk.Context, att types.Attestation, claim types.EthereumClaim) error

+ func (a AttestationHandler) ValidateMembers()

+ type GravityStoreGetter struct

+ func NewGravityStoreGetter(storeKey storetypes.StoreKey) GravityStoreGetter

+ func (gsg GravityStoreGetter) Store(ctx sdk.Context) sdk.KVStore

type Keeper

+ AttestationHandler interface{ ... }

+ DistKeeper types.DistributionKeeper

+ func (k Keeper) AddToOutgoingPool(ctx sdk.Context, sender sdk.AccAddress, counterpartReceiver types.EthAddress, ...) (uint64, error)

+ func (k Keeper) Attest(ctx sdk.Context, claim types.EthereumClaim, anyClaim *codectypes.Any) (*types.Attestation, error)

+ func (k Keeper) BatchConfirms(c context.Context, req *types.QueryBatchConfirmsRequest) (*types.QueryBatchConfirmsResponse, error)

+ func (k Keeper) BatchRequestByNonce(c context.Context, req *types.QueryBatchRequestByNonceRequest) (*types.QueryBatchRequestByNonceResponse, error)

+ func (k Keeper) BuildOutgoingTXBatch(ctx sdk.Context, chainReferenceID string, contract types.EthAddress, ...) (*types.InternalOutgoingTxBatch, error)

+ func (k Keeper) CancelOutgoingTXBatch(ctx sdk.Context, tokenContract types.EthAddress, nonce uint64) error

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

+ func (k Keeper) DeleteAttestation(ctx sdk.Context, att types.Attestation) error

+ func (k Keeper) DeleteBatch(ctx sdk.Context, batch types.InternalOutgoingTxBatch) error

+ func (k Keeper) DeleteBatchConfirms(ctx sdk.Context, batch types.InternalOutgoingTxBatch) error

+ func (k Keeper) DeserializeValidatorIterator(vals []byte) stakingtypes.ValAddresses

+ func (k Keeper) GetAllDenomToERC20s(ctx sdk.Context) ([]*types.ERC20ToDenom, error)

+ func (k Keeper) GetAllERC20ToDenoms(ctx sdk.Context) ([]*types.ERC20ToDenom, error)

+ func (k Keeper) GetAttestation(ctx sdk.Context, eventNonce uint64, claimHash []byte) *types.Attestation

+ func (k Keeper) GetAttestationMapping(ctx sdk.Context) (attestationMapping map[uint64][]types.Attestation, orderedKeys []uint64, ...)

+ func (k Keeper) GetAttestations(c context.Context, req *types.QueryAttestationsRequest) (*types.QueryAttestationsResponse, error)

+ func (k Keeper) GetBatchConfirm(ctx sdk.Context, nonce uint64, tokenContract types.EthAddress, ...) (*types.MsgConfirmBatch, error)

+ func (k Keeper) GetBatchConfirmByNonceAndTokenContract(ctx sdk.Context, nonce uint64, tokenContract types.EthAddress) (out []types.MsgConfirmBatch, err error)

+ func (k Keeper) GetBridgeChainID(ctx sdk.Context) uint64

+ func (k Keeper) GetBridgeContractAddress(ctx sdk.Context) (*types.EthAddress, error)

+ func (k Keeper) GetDenomOfERC20(ctx sdk.Context, chainReferenceId string, tokenContract types.EthAddress) (string, error)

+ func (k Keeper) GetERC20OfDenom(ctx sdk.Context, chainReferenceId, denom string) (*types.EthAddress, error)

+ func (k Keeper) GetErc20ToDenoms(c context.Context, denoms *types.QueryErc20ToDenoms) (*types.QueryErc20ToDenomsResponse, error)

+ func (k Keeper) GetEthAddressByValidator(ctx sdk.Context, validator sdk.ValAddress, chainReferenceId string) (ethAddress *types.EthAddress, found bool, err error)

+ func (k Keeper) GetLastEventNonceByValidator(ctx sdk.Context, validator sdk.ValAddress) (uint64, error)

+ func (k Keeper) GetLastObservedEthBlock(c context.Context, req *types.QueryLastObservedEthBlockRequest) (*types.QueryLastObservedEthBlockResponse, error)

+ func (k Keeper) GetLastObservedEthNonce(c context.Context, req *types.QueryLastObservedEthNonceRequest) (*types.QueryLastObservedEthNonceResponse, error)

+ func (k Keeper) GetLastOutgoingBatchByTokenType(ctx sdk.Context, token types.EthAddress) (*types.InternalOutgoingTxBatch, error)

+ func (k Keeper) GetLastSlashedBatchBlock(ctx sdk.Context) (uint64, error)

+ func (k Keeper) GetMostRecentAttestations(ctx sdk.Context, limit uint64) ([]types.Attestation, error)

+ func (k Keeper) GetOrchestratorValidator(ctx sdk.Context, orch sdk.AccAddress) (validator stakingtypes.Validator, found bool, err error)

+ func (k Keeper) GetOutgoingTXBatch(ctx sdk.Context, tokenContract types.EthAddress, nonce uint64) (*types.InternalOutgoingTxBatch, error)

+ func (k Keeper) GetOutgoingTxBatches(ctx sdk.Context) (out []types.InternalOutgoingTxBatch, err error)

+ func (k Keeper) GetOutgoingTxBatchesByNonce(ctx sdk.Context) (map[uint64]types.InternalOutgoingTxBatch, error)

+ func (k Keeper) GetParamsIfSet(ctx sdk.Context) (params types.Params, err error)

+ func (k Keeper) GetPastEthSignatureCheckpoint(ctx sdk.Context, checkpoint []byte) (found bool)

+ func (k Keeper) GetPendingSendToEth(c context.Context, req *types.QueryPendingSendToEth) (*types.QueryPendingSendToEthResponse, error)

+ func (k Keeper) GetStore(ctx sdk.Context) sdk.KVStore

+ func (k Keeper) GetUnSlashedBatches(ctx sdk.Context, maxHeight uint64) (out []types.InternalOutgoingTxBatch, err error)

+ func (k Keeper) GetUnbatchedTransactions(ctx sdk.Context) ([]*types.InternalOutgoingTransferTx, error)

+ func (k Keeper) GetUnbatchedTransactionsByContract(ctx sdk.Context, contractAddress types.EthAddress) ([]*types.InternalOutgoingTransferTx, error)

+ func (k Keeper) GetUnbatchedTxByAmountAndId(ctx sdk.Context, token types.InternalERC20Token, txID uint64) (*types.InternalOutgoingTransferTx, error)

+ func (k Keeper) GetUnbatchedTxById(ctx sdk.Context, txID uint64) (*types.InternalOutgoingTransferTx, error)

+ func (k Keeper) GetValidatorByEthAddress(ctx sdk.Context, ethAddr types.EthAddress, chainReferenceId string) (validator stakingtypes.Validator, found bool, err error)

+ func (k Keeper) HasLastSlashedBatchBlock(ctx sdk.Context) bool

+ func (k Keeper) InvalidSendToEthAddress(ctx sdk.Context, addr types.EthAddress, _erc20Addr types.EthAddress) bool

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

+ func (k Keeper) IterateBatchConfirmByNonceAndTokenContract(ctx sdk.Context, nonce uint64, tokenContract types.EthAddress, ...) error

+ func (k Keeper) IterateBatchConfirms(ctx sdk.Context, cb func([]byte, types.MsgConfirmBatch) (stop bool))

+ func (k Keeper) IterateClaims(ctx sdk.Context, reverse bool, claimType types.ClaimType, ...) error

+ func (k Keeper) IterateOutgoingTxBatches(ctx sdk.Context, cb func(key []byte, batch types.InternalOutgoingTxBatch) bool) error

+ func (k Keeper) IteratePastEthSignatureCheckpoints(ctx sdk.Context, cb func(key []byte, value []byte) (stop bool)) error

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

+ func (k Keeper) IterateUnbatchedTransactionsByContract(ctx sdk.Context, contractAddress types.EthAddress, ...) error

+ func (k Keeper) IterateValidatorLastEventNonces(ctx sdk.Context, cb func(key []byte, nonce uint64) (stop bool)) error

+ func (k Keeper) LastEventNonceByAddr(c context.Context, req *types.QueryLastEventNonceByAddrRequest) (*types.QueryLastEventNonceByAddrResponse, error)

+ func (k Keeper) LastPendingBatchRequestByAddr(c context.Context, req *types.QueryLastPendingBatchRequestByAddrRequest) (*types.QueryLastPendingBatchRequestByAddrResponse, error)

+ func (k Keeper) OutgoingTxBatchExecuted(ctx sdk.Context, tokenContract types.EthAddress, ...) error

+ func (k Keeper) OutgoingTxBatches(c context.Context, req *types.QueryOutgoingTxBatchesRequest) (*types.QueryOutgoingTxBatchesResponse, error)

+ func (k Keeper) RemoveFromOutgoingPoolAndRefund(ctx sdk.Context, txId uint64, sender sdk.AccAddress) error

+ func (k Keeper) SendToCommunityPool(ctx sdk.Context, coins sdk.Coins) error

+ func (k Keeper) SetAttestation(ctx sdk.Context, eventNonce uint64, claimHash []byte, att *types.Attestation)

+ func (k Keeper) SetBatchConfirm(ctx sdk.Context, batch *types.MsgConfirmBatch) ([]byte, error)

+ func (k Keeper) SetLastEventNonceByValidator(ctx sdk.Context, validator sdk.ValAddress, nonce uint64) error

+ func (k Keeper) SetLastSlashedBatchBlock(ctx sdk.Context, blockHeight uint64) error

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

+ func (k Keeper) SetPastEthSignatureCheckpoint(ctx sdk.Context, checkpoint []byte)

+ func (k Keeper) StoreBatch(ctx sdk.Context, batch types.InternalOutgoingTxBatch) error

+ func (k Keeper) TryAttestation(ctx sdk.Context, att *types.Attestation) error

+ func (k Keeper) UnpackAttestationClaim(att *types.Attestation) (types.EthereumClaim, error)

type TestInput

+ IbcTransferKeeper ibctransferkeeper.Keeper

+ ValsetKeeper valsetkeeper.Keeper

+ func SetupTestChain(t *testing.T, weights []uint64) (TestInput, sdk.Context)

+ func (t TestInput) AssertInvariants()

v1.7.2

Aug 28, 2023

v1.7.1

Aug 15, 2023

v1.7.0

Aug 11, 2023

v1.6.1

Jul 28, 2023

v1.6.0

Jul 20, 2023

v1.5.0

Jul 13, 2023

Changes in this version

+ const BatchTxSize

+ var AccAddrs = []sdk.AccAddress

+ var AccPrivKeys = []ccrypto.PrivKey

+ var AccPubKeys = []ccrypto.PubKey

+ var ConsPrivKeys = []ccrypto.PrivKey

+ var ConsPubKeys = []ccrypto.PubKey

+ var EthAddrs = []gethcommon.Address

+ var InitCoins = sdk.NewCoins(sdk.NewCoin(TestingStakeParams.BondDenom, InitTokens))

+ var InitTokens = sdk.TokensFromConsensusPower(110, sdk.DefaultPowerReduction)

+ var ModuleBasics = module.NewBasicManager(auth.AppModuleBasic{}, genutil.AppModuleBasic{}, bank.AppModuleBasic{}, ...)

+ var StakingAmount = sdk.TokensFromConsensusPower(10, sdk.DefaultPowerReduction)

+ var StakingCoins = sdk.NewCoins(sdk.NewCoin(TestingStakeParams.BondDenom, StakingAmount))

+ var TestingGravityParams = types.Params

+ var TestingStakeParams = stakingtypes.Params

+ var TokenContractAddrs = []string

+ var ValAddrs = []sdk.ValAddress

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

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

+ func MakeTestCodec() *codec.LegacyAmino

+ func MakeTestMarshaler() codec.Codec

+ func MintVouchersFromAir(t *testing.T, ctx sdk.Context, k Keeper, dest sdk.AccAddress, ...) sdk.Coin

+ func NewMsgServerImpl(keeper Keeper) types.MsgServer

+ func NewTestMsgCreateValidator(address sdk.ValAddress, pubKey ccrypto.PubKey, amt sdk.Int) (*stakingtypes.MsgCreateValidator, error)

+ func NewTestMsgUnDelegateValidator(address sdk.ValAddress, amt sdk.Int) *stakingtypes.MsgUndelegate

+ type AlwaysPanicStakingMock struct

+ func (s AlwaysPanicStakingMock) GetBondedValidatorsByPower(ctx sdk.Context) []stakingtypes.Validator

+ func (s AlwaysPanicStakingMock) GetLastTotalPower(ctx sdk.Context) (power sdk.Int)

+ func (s AlwaysPanicStakingMock) GetLastValidatorPower(ctx sdk.Context, operator sdk.ValAddress) int64

+ func (s AlwaysPanicStakingMock) IterateBondedValidatorsByPower(sdk.Context, func(index int64, validator stakingtypes.ValidatorI) (stop bool))

+ func (s AlwaysPanicStakingMock) IterateLastValidators(sdk.Context, func(index int64, validator stakingtypes.ValidatorI) (stop bool))

+ func (s AlwaysPanicStakingMock) IterateValidators(sdk.Context, func(index int64, validator stakingtypes.ValidatorI) (stop bool))

+ func (s AlwaysPanicStakingMock) Jail(sdk.Context, sdk.ConsAddress)

+ func (s AlwaysPanicStakingMock) Slash(sdk.Context, sdk.ConsAddress, int64, int64, sdk.Dec)

+ func (s AlwaysPanicStakingMock) Validator(sdk.Context, sdk.ValAddress) stakingtypes.ValidatorI

+ func (s AlwaysPanicStakingMock) ValidatorByConsAddr(sdk.Context, sdk.ConsAddress) stakingtypes.ValidatorI

+ type Hooks struct

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

+ func (h Hooks) AfterUnbondingInitiated(ctx sdk.Context, id uint64) error

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

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

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

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

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

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

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

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

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

+ type Keeper struct

+ DistributionKeeper types.DistributionKeeper

+ PowerReduction sdk.Int

+ ReceiverModuleAccounts map[string]string

+ SenderModuleAccounts map[string]string

+ SlashingKeeper types.SlashingKeeper

+ StakingKeeper types.StakingKeeper

+ func NewKeeper(cdc codec.Codec, storeKey storetypes.StoreKey, paramSpace paramtypes.Subspace, ...) Keeper

+ func (k *Keeper) SetHooks(sh types.GravityHooks) *Keeper

+ func (k Keeper) AfterBatchExecutedEvent(ctx sdk.Context, event types.BatchExecutedEvent)

+ func (k Keeper) AfterContractCallExecutedEvent(ctx sdk.Context, event types.ContractCallExecutedEvent)

+ func (k Keeper) AfterERC20DeployedEvent(ctx sdk.Context, event types.ERC20DeployedEvent)

+ func (k Keeper) AfterSendToCosmosEvent(ctx sdk.Context, event types.SendToCosmosEvent)

+ func (k Keeper) AfterSignerSetExecutedEvent(ctx sdk.Context, event types.SignerSetTxExecutedEvent)

+ func (k Keeper) BatchTx(c context.Context, req *types.BatchTxRequest) (*types.BatchTxResponse, error)

+ func (k Keeper) BatchTxConfirmations(c context.Context, req *types.BatchTxConfirmationsRequest) (*types.BatchTxConfirmationsResponse, error)

+ func (k Keeper) BatchTxFees(c context.Context, req *types.BatchTxFeesRequest) (*types.BatchTxFeesResponse, error)

+ func (k Keeper) BatchTxs(c context.Context, req *types.BatchTxsRequest) (*types.BatchTxsResponse, error)

+ func (k Keeper) BatchedSendToEthereums(c context.Context, req *types.BatchedSendToEthereumsRequest) (*types.BatchedSendToEthereumsResponse, error)

+ func (k Keeper) CancelBatchTx(ctx sdk.Context, batch *types.BatchTx)

+ func (k Keeper) ContractCallTx(c context.Context, req *types.ContractCallTxRequest) (*types.ContractCallTxResponse, error)

+ func (k Keeper) ContractCallTxConfirmations(c context.Context, req *types.ContractCallTxConfirmationsRequest) (*types.ContractCallTxConfirmationsResponse, error)

+ func (k Keeper) ContractCallTxs(c context.Context, req *types.ContractCallTxsRequest) (*types.ContractCallTxsResponse, error)

+ func (k Keeper) CreateBatchTx(ctx sdk.Context, contractAddress common.Address, maxElements int) *types.BatchTx

+ func (k Keeper) CreateContractCallTx(ctx sdk.Context, invalidationNonce uint64, invalidationScope tmbytes.HexBytes, ...) *types.ContractCallTx

+ func (k Keeper) CreateSignerSetTx(ctx sdk.Context) *types.SignerSetTx

+ func (k Keeper) CurrentSignerSet(ctx sdk.Context) types.EthereumSigners

+ func (k Keeper) DelegateKeys(c context.Context, req *types.DelegateKeysRequest) (*types.DelegateKeysResponse, error)

+ func (k Keeper) DelegateKeysByEthereumSigner(c context.Context, req *types.DelegateKeysByEthereumSignerRequest) (*types.DelegateKeysByEthereumSignerResponse, error)

+ func (k Keeper) DelegateKeysByOrchestrator(c context.Context, req *types.DelegateKeysByOrchestratorRequest) (*types.DelegateKeysByOrchestratorResponse, error)

+ func (k Keeper) DelegateKeysByValidator(c context.Context, req *types.DelegateKeysByValidatorRequest) (*types.DelegateKeysByValidatorResponse, error)

+ func (k Keeper) DeleteOutgoingTx(ctx sdk.Context, storeIndex []byte)

+ func (k Keeper) DenomToERC20(c context.Context, req *types.DenomToERC20Request) (*types.DenomToERC20Response, error)

+ func (k Keeper) DenomToERC20Lookup(ctx sdk.Context, denom string) (bool, common.Address, error)

+ func (k Keeper) DenomToERC20Params(c context.Context, req *types.DenomToERC20ParamsRequest) (*types.DenomToERC20ParamsResponse, error)

+ func (k Keeper) DetectMaliciousSupply(ctx sdk.Context, denom string, amount sdk.Int) (err error)

+ func (k Keeper) ERC20ToDenom(c context.Context, req *types.ERC20ToDenomRequest) (*types.ERC20ToDenomResponse, error)

+ func (k Keeper) ERC20ToDenomLookup(ctx sdk.Context, tokenContract common.Address) (bool, string)

+ func (k Keeper) GetBatchFeesByTokenType(ctx sdk.Context, tokenContractAddr common.Address, maxElements int) sdk.Int

+ func (k Keeper) GetEthereumEventVoteRecord(ctx sdk.Context, eventNonce uint64, claimHash []byte) *types.EthereumEventVoteRecord

+ func (k Keeper) GetEthereumEventVoteRecordMapping(ctx sdk.Context) (out map[uint64][]*types.EthereumEventVoteRecord)

+ func (k Keeper) GetEthereumHeightVote(ctx sdk.Context, valAddress sdk.ValAddress) types.LatestEthereumBlockHeight

+ func (k Keeper) GetEthereumOrchestratorAddress(ctx sdk.Context, ethAddr common.Address) sdk.AccAddress

+ func (k Keeper) GetEthereumSignatures(ctx sdk.Context, storeIndex []byte) map[string][]byte

+ func (k Keeper) GetLastObservedEthereumBlockHeight(ctx sdk.Context) types.LatestEthereumBlockHeight

+ func (k Keeper) GetLastObservedEventNonce(ctx sdk.Context) uint64

+ func (k Keeper) GetLastObservedSignerSetTx(ctx sdk.Context) *types.SignerSetTx

+ func (k Keeper) GetLastSlashedOutgoingTxBlockHeight(ctx sdk.Context) uint64

+ func (k Keeper) GetLastUnbondingBlockHeight(ctx sdk.Context) uint64

+ func (k Keeper) GetLatestSignerSetTx(ctx sdk.Context) *types.SignerSetTx

+ func (k Keeper) GetLatestSignerSetTxNonce(ctx sdk.Context) uint64

+ func (k Keeper) GetOrchestratorValidatorAddress(ctx sdk.Context, orchAddr sdk.AccAddress) sdk.ValAddress

+ func (k Keeper) GetOutgoingTx(ctx sdk.Context, storeIndex []byte) (out types.OutgoingTx)

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

+ func (k Keeper) GetSignerSetTxs(ctx sdk.Context) (out []*types.SignerSetTx)

+ func (k Keeper) GetUnSlashedOutgoingTxs(ctx sdk.Context, maxHeight uint64) (out []types.OutgoingTx)

+ func (k Keeper) GetUnbondingvalidators(unbondingVals []byte) stakingtypes.ValAddresses

+ func (k Keeper) GetValidatorEthereumAddress(ctx sdk.Context, valAddr sdk.ValAddress) common.Address

+ func (k Keeper) Handle(ctx sdk.Context, eve types.EthereumEvent) (err error)

+ func (k Keeper) HandleCommunityPoolEthereumSpendProposal(ctx sdk.Context, p *types.CommunityPoolEthereumSpendProposal) error

+ func (k Keeper) Hooks() Hooks

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

+ func (k Keeper) IterateOutgoingTxsByType(ctx sdk.Context, prefixByte byte, ...)

+ func (k Keeper) IterateUnbatchedSendToEthereums(ctx sdk.Context, cb func(*types.SendToEthereum) bool)

+ func (k Keeper) LastObservedEthereumHeight(c context.Context, req *types.LastObservedEthereumHeightRequest) (*types.LastObservedEthereumHeightResponse, error)

+ func (k Keeper) LastSubmittedEthereumEvent(c context.Context, req *types.LastSubmittedEthereumEventRequest) (*types.LastSubmittedEthereumEventResponse, error)

+ func (k Keeper) LatestSignerSetTx(c context.Context, req *types.LatestSignerSetTxRequest) (*types.SignerSetTxResponse, error)

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

+ func (k Keeper) MigrateGravityContract(ctx sdk.Context, newBridgeAddress string, bridgeDeploymentHeight uint64)

+ func (k Keeper) PaginateOutgoingTxsByType(ctx sdk.Context, pageReq *query.PageRequest, prefixByte byte, ...) (*query.PageResponse, error)

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

+ func (k Keeper) SetEthereumHeightVote(ctx sdk.Context, valAddress sdk.ValAddress, ethereumHeight uint64)

+ func (k Keeper) SetEthereumSignature(ctx sdk.Context, sig types.EthereumTxConfirmation, val sdk.ValAddress) []byte

+ func (k Keeper) SetLastObservedEthereumBlockHeight(ctx sdk.Context, ethereumHeight uint64)

+ func (k Keeper) SetLastObservedEthereumBlockHeightWithCosmos(ctx sdk.Context, ethereumHeight uint64, cosmosHeight uint64)

+ func (k Keeper) SetLastSlashedOutgoingTxBlockHeight(ctx sdk.Context, blockHeight uint64)

+ func (k Keeper) SetOrchestratorValidatorAddress(ctx sdk.Context, val sdk.ValAddress, orchAddr sdk.AccAddress)

+ func (k Keeper) SetOutgoingTx(ctx sdk.Context, outgoing types.OutgoingTx)

+ func (k Keeper) SignerSetTx(c context.Context, req *types.SignerSetTxRequest) (*types.SignerSetTxResponse, error)

+ func (k Keeper) SignerSetTxConfirmations(c context.Context, req *types.SignerSetTxConfirmationsRequest) (*types.SignerSetTxConfirmationsResponse, error)

+ func (k Keeper) SignerSetTxs(c context.Context, req *types.SignerSetTxsRequest) (*types.SignerSetTxsResponse, error)

+ func (k Keeper) TryEventVoteRecord(ctx sdk.Context, eventVoteRecord *types.EthereumEventVoteRecord)

+ func (k Keeper) UnbatchedSendToEthereums(c context.Context, req *types.UnbatchedSendToEthereumsRequest) (*types.UnbatchedSendToEthereumsResponse, error)

+ func (k Keeper) UnsignedBatchTxs(c context.Context, req *types.UnsignedBatchTxsRequest) (*types.UnsignedBatchTxsResponse, error)

+ func (k Keeper) UnsignedContractCallTxs(c context.Context, req *types.UnsignedContractCallTxsRequest) (*types.UnsignedContractCallTxsResponse, error)

+ func (k Keeper) UnsignedSignerSetTxs(c context.Context, req *types.UnsignedSignerSetTxsRequest) (*types.UnsignedSignerSetTxsResponse, error)

+ type MockStakingValidatorData struct

+ Operator sdk.ValAddress

+ Power int64

+ type StakingKeeperMock struct

+ BondedValidators []stakingtypes.Validator

+ ValidatorPower map[string]int64

+ func NewStakingKeeperMock(operators ...sdk.ValAddress) *StakingKeeperMock

+ func NewStakingKeeperWeightedMock(t ...MockStakingValidatorData) *StakingKeeperMock

+ func (s *StakingKeeperMock) GetBondedValidatorsByPower(ctx sdk.Context) []stakingtypes.Validator

+ func (s *StakingKeeperMock) GetLastTotalPower(ctx sdk.Context) (power sdk.Int)

+ func (s *StakingKeeperMock) GetLastValidatorPower(ctx sdk.Context, operator sdk.ValAddress) int64

+ func (s *StakingKeeperMock) GetParams(ctx sdk.Context) stakingtypes.Params

+ func (s *StakingKeeperMock) GetValidator(ctx sdk.Context, addr sdk.ValAddress) (validator stakingtypes.Validator, found bool)

+ func (s *StakingKeeperMock) IterateBondedValidatorsByPower(ctx sdk.Context, ...)

+ func (s *StakingKeeperMock) IterateLastValidators(ctx sdk.Context, ...)

+ func (s *StakingKeeperMock) IterateValidators(ctx sdk.Context, ...)

+ func (s *StakingKeeperMock) Jail(sdk.Context, sdk.ConsAddress)

+ func (s *StakingKeeperMock) Slash(ctx sdk.Context, consAddr sdk.ConsAddress, infractionHeight int64, power int64, ...) math.Int

+ func (s *StakingKeeperMock) Validator(ctx sdk.Context, addr sdk.ValAddress) stakingtypes.ValidatorI

+ func (s *StakingKeeperMock) ValidatorByConsAddr(ctx sdk.Context, addr sdk.ConsAddress) stakingtypes.ValidatorI

+ func (s *StakingKeeperMock) ValidatorQueueIterator(ctx sdk.Context, endTime time.Time, endHeight int64) sdk.Iterator

+ type TestInput struct

+ AccountKeeper authkeeper.AccountKeeper

+ BankKeeper bankkeeper.BaseKeeper

+ Context sdk.Context

+ DistKeeper distrkeeper.Keeper

+ GovKeeper govkeeper.Keeper

+ GravityKeeper Keeper

+ GravityStoreKey *storetypes.KVStoreKey

+ LegacyAmino *codec.LegacyAmino

+ Marshaler codec.Codec

+ SlashingKeeper slashingkeeper.Keeper

+ StakingKeeper stakingkeeper.Keeper

+ func CreateTestEnv(t *testing.T) TestInput

+ func SetupFiveValChain(t *testing.T) (TestInput, sdk.Context)

+ func (input TestInput) AddBalanceToBank(ctx sdk.Context, addr sdk.AccAddress, balances sdk.Coins) error

+ func (input TestInput) AddSendToEthTxsToPool(t *testing.T, ctx sdk.Context, tokenContract gethcommon.Address, ...)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL