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

v7

v7.5.0

Aug 15, 2024

Changes in this version

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

+ func GetBridgeCallTimeout(params types.Params) uint64

+ func GetExternalBatchTimeout(params types.Params) uint64

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

+ func NewMsgServerImpl(keeper Keeper) types.MsgServer

+ func NewMsgServerRouterImpl(routerKeeper RouterKeeper) types.MsgServer

+ func NewQueryServerImpl(keeper Keeper) types.QueryServer

+ type Keeper struct

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

+ func (k Keeper) AddBridgeToken(ctx sdk.Context, token, denom string)

+ func (k Keeper) AddBridgeTokenExecuted(ctx sdk.Context, claim *types.MsgBridgeTokenClaim) error

+ func (k Keeper) AddOracleSetRequest(ctx sdk.Context, currentOracleSet *types.OracleSet)

+ func (k Keeper) AddOutgoingBridgeCall(ctx sdk.Context, sender, refundAddr common.Address, tokens []types.ERC20Token, ...) (uint64, error)

+ func (k Keeper) AddOutgoingBridgeCallWithoutBuild(ctx sdk.Context, outCall *types.OutgoingBridgeCall) uint64

+ func (k Keeper) AddPendingOutgoingBridgeCall(ctx sdk.Context, sender, refundAddr common.Address, tokens []types.ERC20Token, ...) (uint64, error)

+ func (k Keeper) AddPendingPoolRewards(ctx sdk.Context, nonce uint64, sender sdk.AccAddress, rewards sdk.Coins) error

+ func (k Keeper) AddToOutgoingPendingPool(ctx sdk.Context, sender sdk.AccAddress, receiver string, amount sdk.Coin, ...) (uint64, error)

+ func (k Keeper) AddToOutgoingPool(ctx sdk.Context, sender sdk.AccAddress, receiver string, amount sdk.Coin, ...) (uint64, error)

+ func (k Keeper) AddToOutgoingPoolWithTxId(ctx sdk.Context, sender sdk.AccAddress, receiver string, amount sdk.Coin, ...) error

+ func (k Keeper) AddUnbatchedTx(ctx sdk.Context, outgoingTransferTx *types.OutgoingTransferTx) error

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

+ func (k Keeper) Attest(ctx sdk.Context, oracleAddr sdk.AccAddress, claim types.ExternalClaim) (*types.Attestation, error)

+ func (k Keeper) AttestationHandler(ctx sdk.Context, externalClaim types.ExternalClaim) error

+ func (k Keeper) BridgeCallCoinsToERC20Token(ctx sdk.Context, sender sdk.AccAddress, coins sdk.Coins) ([]types.ERC20Token, sdk.Coins, error)

+ func (k Keeper) BridgeCallEvm(ctx sdk.Context, sender, refundAddr common.Address, coins sdk.Coins, ...) error

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

+ func (k Keeper) BridgeCallResultHandler(ctx sdk.Context, claim *types.MsgBridgeCallResultClaim)

+ func (k Keeper) BridgeCallTransferAndCallEvm(ctx sdk.Context, sender, refundAddr common.Address, tokens []types.ERC20Token, ...) error

+ func (k Keeper) BuildOutgoingBridgeCall(ctx sdk.Context, sender common.Address, refundAddr common.Address, ...) (*types.OutgoingBridgeCall, error)

+ func (k Keeper) BuildOutgoingTxBatch(ctx sdk.Context, tokenContract, feeReceive string, maxElements uint, ...) (*types.OutgoingTxBatch, error)

+ func (k Keeper) CalExternalTimeoutHeight(ctx sdk.Context, getTimeoutCallback func(params types.Params) uint64) uint64

+ func (k Keeper) CancelOutgoingTxBatch(ctx sdk.Context, tokenContract string, batchNonce uint64) error

+ func (k Keeper) CoinsToBridgeCallTokens(ctx sdk.Context, coins sdk.Coins) ([]common.Address, []*big.Int)

+ func (k Keeper) CreateBridgeAccount(ctx sdk.Context, address string)

+ func (k Keeper) DelLastEventNonceByOracle(ctx sdk.Context, oracleAddr sdk.AccAddress)

+ func (k Keeper) DelOracle(ctx sdk.Context, oracleAddr sdk.AccAddress)

+ func (k Keeper) DelOracleAddrByBridgerAddr(ctx sdk.Context, bridgerAddr sdk.AccAddress)

+ func (k Keeper) DelOracleAddrByExternalAddr(ctk sdk.Context, externalAddress string)

+ func (k Keeper) DeleteAttestation(ctx sdk.Context, claim types.ExternalClaim)

+ func (k Keeper) DeleteBatch(ctx sdk.Context, batch *types.OutgoingTxBatch)

+ func (k Keeper) DeleteBatchConfirm(ctx sdk.Context, batchNonce uint64, tokenContract string)

+ func (k Keeper) DeleteBridgeCallConfirm(ctx sdk.Context, nonce uint64)

+ func (k Keeper) DeleteBridgeCallFromMsg(ctx sdk.Context, txID uint64)

+ func (k Keeper) DeleteOracleSet(ctx sdk.Context, nonce uint64)

+ func (k Keeper) DeleteOracleSetConfirm(ctx sdk.Context, nonce uint64)

+ func (k Keeper) DeleteOutgoingBridgeCall(ctx sdk.Context, nonce uint64)

+ func (k Keeper) DeleteOutgoingBridgeCallRecord(ctx sdk.Context, bridgeCallNonce uint64)

+ func (k Keeper) DeletePendingExecuteClaim(ctx sdk.Context, eventNonce uint64)

+ func (k Keeper) DeletePendingOutgoingBridgeCall(ctx sdk.Context, nonce uint64)

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

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

+ func (k Keeper) GetAllBatchFees(ctx sdk.Context, maxElements uint, minBatchFees []types.MinBatchFee) (batchFees []*types.BatchFees)

+ func (k Keeper) GetAllOracles(ctx sdk.Context, isOnline bool) (oracles types.Oracles)

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

+ func (k Keeper) GetAuthority() string

+ func (k Keeper) GetBatchConfirm(ctx sdk.Context, tokenContract string, batchNonce uint64, ...) *types.MsgConfirmBatch

+ func (k Keeper) GetBatchFeesByTokenType(ctx sdk.Context, tokenContract string, maxElements uint, baseFee sdkmath.Int) *types.BatchFees

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

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

+ func (k Keeper) GetBridgeTokenDenom(ctx sdk.Context, tokenContract string) *types.BridgeToken

+ func (k Keeper) GetCallbackFrom() common.Address

+ func (k Keeper) GetCurrentOracleSet(ctx sdk.Context) *types.OracleSet

+ func (k Keeper) GetDenomBridgeToken(ctx sdk.Context, denom string) *types.BridgeToken

+ func (k Keeper) GetGravityID(ctx sdk.Context) string

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

+ func (k Keeper) GetLastEventBlockHeightByOracle(ctx sdk.Context, oracleAddr sdk.AccAddress) uint64

+ func (k Keeper) GetLastEventNonceByOracle(ctx sdk.Context, oracleAddr sdk.AccAddress) uint64

+ func (k Keeper) GetLastObservedBlockHeight(ctx sdk.Context) types.LastObservedBlockHeight

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

+ func (k Keeper) GetLastObservedOracleSet(ctx sdk.Context) *types.OracleSet

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

+ func (k Keeper) GetLastOutgoingBatchByToken(ctx sdk.Context, token string) *types.OutgoingTxBatch

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

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

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

+ func (k Keeper) GetLastTotalPower(ctx sdk.Context) sdkmath.Int

+ func (k Keeper) GetLatestOracleSet(ctx sdk.Context) *types.OracleSet

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

+ func (k Keeper) GetOracle(ctx sdk.Context, oracleAddr sdk.AccAddress) (oracle types.Oracle, found bool)

+ func (k Keeper) GetOracleAddrByBridgerAddr(ctx sdk.Context, bridgerAddr sdk.AccAddress) (sdk.AccAddress, bool)

+ func (k Keeper) GetOracleAddrByExternalAddr(ctx sdk.Context, externalAddress string) (sdk.AccAddress, bool)

+ func (k Keeper) GetOracleDelegateMultiple(ctx sdk.Context) int64

+ func (k Keeper) GetOracleDelegateThreshold(ctx sdk.Context) sdk.Coin

+ func (k Keeper) GetOracleDelegateToken(ctx sdk.Context, delegateAddr sdk.AccAddress, valAddr sdk.ValAddress) (sdkmath.Int, error)

+ func (k Keeper) GetOracleSet(ctx sdk.Context, nonce uint64) *types.OracleSet

+ func (k Keeper) GetOracleSetConfirm(ctx sdk.Context, nonce uint64, oracleAddr sdk.AccAddress) *types.MsgOracleSetConfirm

+ func (k Keeper) GetOracleSetUpdatePowerChangePercent(ctx sdk.Context) sdk.Dec

+ func (k Keeper) GetOracleSets(ctx sdk.Context) (oracleSets types.OracleSets)

+ func (k Keeper) GetOutgoingBridgeCallByNonce(ctx sdk.Context, nonce uint64) (*types.OutgoingBridgeCall, bool)

+ func (k Keeper) GetOutgoingTxBatch(ctx sdk.Context, tokenContract string, batchNonce uint64) *types.OutgoingTxBatch

+ func (k Keeper) GetOutgoingTxBatches(ctx sdk.Context) (out []*types.OutgoingTxBatch)

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

+ func (k Keeper) GetPendingExecuteClaim(ctx sdk.Context, eventNonce uint64) (types.ExternalClaim, bool)

+ func (k Keeper) GetPendingOutgoingBridgeCallByNonce(ctx sdk.Context, nonce uint64) (*types.PendingOutgoingBridgeCall, bool)

+ func (k Keeper) GetPendingPoolTxById(ctx sdk.Context, txId uint64) (*types.PendingOutgoingTransferTx, bool)

+ func (k Keeper) GetProposalOracle(ctx sdk.Context) (proposalOracle types.ProposalOracle, found bool)

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

+ func (k Keeper) GetSlashFraction(ctx sdk.Context) sdk.Dec

+ func (k Keeper) GetUnSlashedBatches(ctx sdk.Context, maxHeight uint64) (outgoingTxBatches types.OutgoingTxBatches)

+ func (k Keeper) GetUnSlashedBridgeCalls(ctx sdk.Context, height uint64) []types.OutgoingBridgeCall

+ func (k Keeper) GetUnSlashedOracleSets(ctx sdk.Context, maxHeight uint64) (oracleSets types.OracleSets)

+ func (k Keeper) GetUnbatchedTransactions(ctx sdk.Context) []*types.OutgoingTransferTx

+ func (k Keeper) GetUnbatchedTxByFeeAndId(ctx sdk.Context, fee types.ERC20Token, txID uint64) (*types.OutgoingTransferTx, error)

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

+ func (k Keeper) HandleAddPendingBridgeCallRewards(ctx sdk.Context, nonce uint64, reward sdk.Coin) (success bool)

+ func (k Keeper) HandleAddPendingPoolReward(ctx sdk.Context, id uint64, reward sdk.Coin) (success bool)

+ func (k Keeper) HandleCancelPendingOutgoingBridgeCall(ctx sdk.Context, nonce uint64, sender sdk.AccAddress) (sdk.Coins, error)

+ func (k Keeper) HandleOutgoingBridgeCallRefund(ctx sdk.Context, data *types.OutgoingBridgeCall) sdk.Coins

+ func (k Keeper) HandlePendingOutgoingBridgeCall(ctx sdk.Context, liquidityProvider []byte, eventNonce uint64, ...)

+ func (k Keeper) HandlePendingOutgoingTx(ctx sdk.Context, liquidityProvider sdk.AccAddress, eventNonce uint64, ...)

+ func (k Keeper) HasBridgeCallConfirm(ctx sdk.Context, nonce uint64, oracleAddr sdk.AccAddress) bool

+ func (k Keeper) HasBridgeCallFromMsg(ctx sdk.Context, txID uint64) bool

+ func (k Keeper) HasBridgeToken(ctx sdk.Context, tokenContract string) bool

+ func (k Keeper) HasOracle(ctx sdk.Context, oracleAddr sdk.AccAddress) (found bool)

+ func (k Keeper) HasOracleAddrByBridgerAddr(ctx sdk.Context, bridgerAddr sdk.AccAddress) bool

+ func (k Keeper) HasOracleAddrByExternalAddr(ctx sdk.Context, externalAddress string) bool

+ func (k Keeper) HasOracleSetRequest(ctx sdk.Context, nonce uint64) bool

+ func (k Keeper) HasOutgoingBridgeCall(ctx sdk.Context, nonce uint64) bool

+ func (k Keeper) HasOutgoingBridgeCallAddressAndNonce(ctx sdk.Context, sender string, nonce uint64) bool

+ func (k Keeper) IsProposalOracle(ctx sdk.Context, oracleAddr string) bool

+ func (k Keeper) IterBridgeCallConfirmByNonce(ctx sdk.Context, nonce uint64, cb func(msg *types.MsgBridgeCallConfirm) bool)

+ func (k Keeper) IterateAttestationAndClaim(ctx sdk.Context, cb func(*types.Attestation, types.ExternalClaim) bool)

+ func (k Keeper) IterateAttestations(ctx sdk.Context, cb func(*types.Attestation) bool)

+ func (k Keeper) IterateBatchByBlockHeight(ctx sdk.Context, start uint64, end uint64, ...)

+ func (k Keeper) IterateBatchConfirmByNonceAndTokenContract(ctx sdk.Context, batchNonce uint64, tokenContract string, ...)

+ func (k Keeper) IterateBridgeTokenToDenom(ctx sdk.Context, cb func(*types.BridgeToken) bool)

+ func (k Keeper) IterateOracle(ctx sdk.Context, cb func(oracle types.Oracle) bool)

+ func (k Keeper) IterateOracleSetByNonce(ctx sdk.Context, startNonce uint64, cb func(*types.OracleSet) bool)

+ func (k Keeper) IterateOracleSetConfirmByNonce(ctx sdk.Context, nonce uint64, cb func(*types.MsgOracleSetConfirm) bool)

+ func (k Keeper) IterateOracleSets(ctx sdk.Context, reverse bool, cb func(*types.OracleSet) bool)

+ func (k Keeper) IterateOutgoingBridgeCallByNonce(ctx sdk.Context, startNonce uint64, ...)

+ func (k Keeper) IterateOutgoingBridgeCalls(ctx sdk.Context, cb func(outCall *types.OutgoingBridgeCall) bool)

+ func (k Keeper) IterateOutgoingBridgeCallsByAddress(ctx sdk.Context, senderAddr string, ...)

+ func (k Keeper) IterateOutgoingTxBatches(ctx sdk.Context, cb func(batch *types.OutgoingTxBatch) bool)

+ func (k Keeper) IteratePendingOutgoingBridgeCallsByAddress(ctx sdk.Context, senderAddr string, ...)

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

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

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

+ func (k Keeper) IteratorPendingOutgoingTxByBridgeTokenContractAddr(ctx sdk.Context, tokenContract string, ...)

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

+ func (k Keeper) ModuleName() string

+ func (k Keeper) OutgoingTxBatchExecuted(ctx sdk.Context, tokenContract string, batchNonce uint64)

+ func (k Keeper) PrecompileAddPendingPoolRewards(ctx sdk.Context, txID uint64, sender sdk.AccAddress, reward sdk.Coin) error

+ func (k Keeper) PrecompileBridgeCall(ctx sdk.Context, sender, refund common.Address, coins sdk.Coins, ...) (nonce uint64, err error)

+ func (k Keeper) PrecompileCancelPendingBridgeCall(ctx sdk.Context, nonce uint64, sender sdk.AccAddress) (sdk.Coins, error)

+ func (k Keeper) PrecompileCancelSendToExternal(ctx sdk.Context, txID uint64, sender sdk.AccAddress) (sdk.Coin, error)

+ func (k Keeper) PrecompileIncreaseBridgeFee(ctx sdk.Context, txID uint64, sender sdk.AccAddress, addBridgeFee sdk.Coin) error

+ func (k Keeper) RelayTransferHandler(ctx sdk.Context, eventNonce uint64, targetHex string, receiver sdk.AccAddress, ...) error

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

+ func (k Keeper) RemovePendingOutgoingTx(context sdk.Context, tokenContract string, txId uint64)

+ func (k Keeper) SavePendingExecuteClaim(ctx sdk.Context, claim types.ExternalClaim)

+ func (k Keeper) SendToFxExecuted(ctx sdk.Context, claim *types.MsgSendToFxClaim) error

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

+ func (k Keeper) SetBatchConfirm(ctx sdk.Context, oracleAddr sdk.AccAddress, batch *types.MsgConfirmBatch)

+ func (k Keeper) SetBridgeCallConfirm(ctx sdk.Context, oracleAddr sdk.AccAddress, msg *types.MsgBridgeCallConfirm)

+ func (k Keeper) SetBridgeCallFromMsg(ctx sdk.Context, txID uint64)

+ func (k Keeper) SetIbcDenomTrace(ctx sdk.Context, token, channelIBC string) (string, error)

+ func (k Keeper) SetLastEventBlockHeightByOracle(ctx sdk.Context, oracleAddr sdk.AccAddress, blockHeight uint64)

+ func (k Keeper) SetLastEventNonceByOracle(ctx sdk.Context, oracleAddr sdk.AccAddress, eventNonce uint64)

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

+ func (k Keeper) SetLastObservedEventNonce(ctx sdk.Context, eventNonce uint64)

+ func (k Keeper) SetLastObservedOracleSet(ctx sdk.Context, oracleSet *types.OracleSet)

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

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

+ func (k Keeper) SetLastSlashedBridgeCallNonce(ctx sdk.Context, nonce uint64)

+ func (k Keeper) SetLastSlashedOracleSetNonce(ctx sdk.Context, nonce uint64)

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

+ func (k Keeper) SetLatestOracleSetNonce(ctx sdk.Context, nonce uint64)

+ func (k Keeper) SetOracle(ctx sdk.Context, oracle types.Oracle)

+ func (k Keeper) SetOracleAddrByBridgerAddr(ctx sdk.Context, bridgerAddr, oracleAddr sdk.AccAddress)

+ func (k Keeper) SetOracleAddrByExternalAddr(ctx sdk.Context, externalAddress string, oracleAddr sdk.AccAddress)

+ func (k Keeper) SetOracleSetConfirm(ctx sdk.Context, oracleAddr sdk.AccAddress, ...)

+ func (k Keeper) SetOutgoingBridgeCall(ctx sdk.Context, outCall *types.OutgoingBridgeCall)

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

+ func (k Keeper) SetPendingOutgoingBridgeCall(ctx sdk.Context, pendingOutCall *types.PendingOutgoingBridgeCall)

+ func (k Keeper) SetPendingOutgoingBridgeCallWithoutNotLiquidCoins(ctx sdk.Context, pendingOutCall *types.PendingOutgoingBridgeCall)

+ func (k Keeper) SetPendingTx(ctx sdk.Context, outgoing *types.PendingOutgoingTransferTx)

+ func (k Keeper) SetProposalOracle(ctx sdk.Context, proposalOracle *types.ProposalOracle)

+ func (k Keeper) SlashOracle(ctx sdk.Context, oracleAddrStr string)

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

+ func (k Keeper) StoreOracleSet(ctx sdk.Context, oracleSet *types.OracleSet)

+ func (k Keeper) TransferAfter(ctx sdk.Context, sender sdk.AccAddress, receive string, amount, fee sdk.Coin, ...) error

+ func (k Keeper) TransferBridgeCoinToExternal(ctx sdk.Context, sender sdk.AccAddress, targetCoin sdk.Coin) error

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

+ func (k Keeper) UnbondedOracleFromProposal(ctx sdk.Context, oracle types.Oracle) error

+ func (k Keeper) UpdateChainOraclesProposal(ctx sdk.Context, proposal *types.UpdateChainOraclesProposal) error

+ func (k Keeper) UpdateOracleSetExecuted(ctx sdk.Context, claim *types.MsgOracleSetUpdatedClaim) error

+ func (k Keeper) UpdateProposalOracles(ctx sdk.Context, oracles []string) error

+ type Migrator struct

+ func NewMigrator(k Keeper) Migrator

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

+ type ModuleHandler struct

+ MsgServer types.MsgServer

+ ProposalServer proposalServer

+ QueryServer types.QueryServer

+ func NewModuleHandler(keeper Keeper) *ModuleHandler

+ type MsgServer struct

+ func (s MsgServer) AddDelegate(c context.Context, msg *types.MsgAddDelegate) (*types.MsgAddDelegateResponse, error)

+ func (s MsgServer) AddPendingPoolRewards(c context.Context, msg *types.MsgAddPendingPoolRewards) (*types.MsgAddPendingPoolRewardsResponse, error)

+ func (s MsgServer) BondedOracle(c context.Context, msg *types.MsgBondedOracle) (*types.MsgBondedOracleResponse, error)

+ func (s MsgServer) BridgeCall(c context.Context, msg *types.MsgBridgeCall) (*types.MsgBridgeCallResponse, error)

+ func (s MsgServer) BridgeCallClaim(c context.Context, msg *types.MsgBridgeCallClaim) (*types.MsgBridgeCallClaimResponse, error)

+ func (s MsgServer) BridgeCallConfirm(c context.Context, msg *types.MsgBridgeCallConfirm) (*types.MsgBridgeCallConfirmResponse, error)

+ func (s MsgServer) BridgeCallResultClaim(c context.Context, msg *types.MsgBridgeCallResultClaim) (*types.MsgBridgeCallResultClaimResponse, error)

+ func (s MsgServer) BridgeTokenClaim(c context.Context, msg *types.MsgBridgeTokenClaim) (*types.MsgBridgeTokenClaimResponse, error)

+ func (s MsgServer) CancelPendingBridgeCall(c context.Context, msg *types.MsgCancelPendingBridgeCall) (*types.MsgCancelPendingBridgeCallResponse, error)

+ func (s MsgServer) CancelSendToExternal(c context.Context, msg *types.MsgCancelSendToExternal) (*types.MsgCancelSendToExternalResponse, error)

+ func (s MsgServer) ConfirmBatch(c context.Context, msg *types.MsgConfirmBatch) (*types.MsgConfirmBatchResponse, error)

+ func (s MsgServer) EditBridger(c context.Context, msg *types.MsgEditBridger) (*types.MsgEditBridgerResponse, error)

+ func (s MsgServer) IncreaseBridgeFee(c context.Context, msg *types.MsgIncreaseBridgeFee) (*types.MsgIncreaseBridgeFeeResponse, error)

+ func (s MsgServer) OracleSetConfirm(c context.Context, msg *types.MsgOracleSetConfirm) (*types.MsgOracleSetConfirmResponse, error)

+ func (s MsgServer) OracleSetUpdateClaim(c context.Context, msg *types.MsgOracleSetUpdatedClaim) (*types.MsgOracleSetUpdatedClaimResponse, error)

+ func (s MsgServer) ReDelegate(c context.Context, msg *types.MsgReDelegate) (*types.MsgReDelegateResponse, error)

+ func (s MsgServer) RequestBatch(c context.Context, msg *types.MsgRequestBatch) (*types.MsgRequestBatchResponse, error)

+ func (s MsgServer) SendToExternal(c context.Context, msg *types.MsgSendToExternal) (*types.MsgSendToExternalResponse, error)

+ func (s MsgServer) SendToExternalClaim(c context.Context, msg *types.MsgSendToExternalClaim) (*types.MsgSendToExternalClaimResponse, error)

+ func (s MsgServer) SendToFxClaim(c context.Context, msg *types.MsgSendToFxClaim) (*types.MsgSendToFxClaimResponse, error)

+ func (s MsgServer) UnbondedOracle(c context.Context, msg *types.MsgUnbondedOracle) (*types.MsgUnbondedOracleResponse, error)

+ func (s MsgServer) UpdateChainOracles(c context.Context, req *types.MsgUpdateChainOracles) (*types.MsgUpdateChainOraclesResponse, error)

+ func (s MsgServer) UpdateParams(c context.Context, req *types.MsgUpdateParams) (*types.MsgUpdateParamsResponse, error)

+ func (s MsgServer) WithdrawReward(c context.Context, msg *types.MsgWithdrawReward) (*types.MsgWithdrawRewardResponse, error)

+ type QueryServer struct

+ func (k QueryServer) BatchConfirm(c context.Context, req *types.QueryBatchConfirmRequest) (*types.QueryBatchConfirmResponse, error)

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

+ func (k QueryServer) BatchFees(c context.Context, req *types.QueryBatchFeeRequest) (*types.QueryBatchFeeResponse, error)

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

+ func (k QueryServer) BridgeAddrToOracle(ctx sdk.Context, bridgeAddr string) (types.Oracle, error)

+ func (k QueryServer) BridgeAddrToOracleAddr(ctx sdk.Context, bridgeAddr string) (sdk.AccAddress, error)

+ func (k QueryServer) BridgeCallByNonce(c context.Context, req *types.QueryBridgeCallByNonceRequest) (*types.QueryBridgeCallByNonceResponse, error)

+ func (k QueryServer) BridgeCallBySender(c context.Context, req *types.QueryBridgeCallBySenderRequest) (*types.QueryBridgeCallBySenderResponse, error)

+ func (k QueryServer) BridgeCallConfirmByNonce(c context.Context, req *types.QueryBridgeCallConfirmByNonceRequest) (*types.QueryBridgeCallConfirmByNonceResponse, error)

+ func (k QueryServer) BridgeCalls(c context.Context, req *types.QueryBridgeCallsRequest) (*types.QueryBridgeCallsResponse, error)

+ func (k QueryServer) BridgeChainList(_ context.Context, _ *types.QueryBridgeChainListRequest) (*types.QueryBridgeChainListResponse, error)

+ func (k QueryServer) BridgeCoinByDenom(c context.Context, req *types.QueryBridgeCoinByDenomRequest) (*types.QueryBridgeCoinByDenomResponse, error)

+ func (k QueryServer) BridgeTokens(c context.Context, _ *types.QueryBridgeTokensRequest) (*types.QueryBridgeTokensResponse, error)

+ func (k QueryServer) CurrentOracleSet(c context.Context, _ *types.QueryCurrentOracleSetRequest) (*types.QueryCurrentOracleSetResponse, error)

+ func (k QueryServer) DenomToToken(c context.Context, req *types.QueryDenomToTokenRequest) (*types.QueryDenomToTokenResponse, error)

+ func (k QueryServer) GetOracleByAddr(c context.Context, req *types.QueryOracleByAddrRequest) (*types.QueryOracleResponse, error)

+ func (k QueryServer) GetOracleByBridgerAddr(c context.Context, req *types.QueryOracleByBridgerAddrRequest) (*types.QueryOracleResponse, error)

+ func (k QueryServer) GetOracleByExternalAddr(c context.Context, req *types.QueryOracleByExternalAddrRequest) (*types.QueryOracleResponse, error)

+ func (k QueryServer) GetPendingPoolSendToExternal(c context.Context, req *types.QueryPendingPoolSendToExternalRequest) (*types.QueryPendingPoolSendToExternalResponse, error)

+ func (k QueryServer) GetPendingSendToExternal(c context.Context, req *types.QueryPendingSendToExternalRequest) (*types.QueryPendingSendToExternalResponse, error)

+ func (k QueryServer) LastEventBlockHeightByAddr(c context.Context, req *types.QueryLastEventBlockHeightByAddrRequest) (*types.QueryLastEventBlockHeightByAddrResponse, error)

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

+ func (k QueryServer) LastObservedBlockHeight(c context.Context, _ *types.QueryLastObservedBlockHeightRequest) (*types.QueryLastObservedBlockHeightResponse, error)

+ func (k QueryServer) LastOracleSetRequests(c context.Context, _ *types.QueryLastOracleSetRequestsRequest) (*types.QueryLastOracleSetRequestsResponse, error)

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

+ func (k QueryServer) LastPendingBridgeCallByAddr(c context.Context, req *types.QueryLastPendingBridgeCallByAddrRequest) (*types.QueryLastPendingBridgeCallByAddrResponse, error)

+ func (k QueryServer) LastPendingOracleSetRequestByAddr(c context.Context, req *types.QueryLastPendingOracleSetRequestByAddrRequest) (*types.QueryLastPendingOracleSetRequestByAddrResponse, error)

+ func (k QueryServer) OracleSetConfirm(c context.Context, req *types.QueryOracleSetConfirmRequest) (*types.QueryOracleSetConfirmResponse, error)

+ func (k QueryServer) OracleSetConfirmsByNonce(c context.Context, req *types.QueryOracleSetConfirmsByNonceRequest) (*types.QueryOracleSetConfirmsByNonceResponse, error)

+ func (k QueryServer) OracleSetRequest(c context.Context, req *types.QueryOracleSetRequestRequest) (*types.QueryOracleSetRequestResponse, error)

+ func (k QueryServer) Oracles(c context.Context, _ *types.QueryOraclesRequest) (*types.QueryOraclesResponse, error)

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

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

+ func (k QueryServer) PendingBridgeCallByNonce(c context.Context, req *types.QueryPendingBridgeCallByNonceRequest) (*types.QueryPendingBridgeCallByNonceResponse, error)

+ func (k QueryServer) PendingBridgeCalls(c context.Context, req *types.QueryPendingBridgeCallsRequest) (*types.QueryPendingBridgeCallsResponse, error)

+ func (k QueryServer) PendingExecuteClaim(c context.Context, req *types.QueryPendingExecuteClaimRequest) (*types.QueryPendingExecuteClaimResponse, error)

+ func (k QueryServer) ProjectedBatchTimeoutHeight(c context.Context, _ *types.QueryProjectedBatchTimeoutHeightRequest) (*types.QueryProjectedBatchTimeoutHeightResponse, error)

+ func (k QueryServer) TokenToDenom(c context.Context, req *types.QueryTokenToDenomRequest) (*types.QueryTokenToDenomResponse, error)

+ type Router interface

+ AddRoute func(name string, moduleHandler *ModuleHandler) (router Router)

+ GetRoute func(name string) (moduleHandler *ModuleHandler)

+ HasRoute func(name string) bool

+ Seal func()

+ func NewRouter() Router

+ type RouterKeeper struct

+ func NewRouterKeeper(rtr Router) RouterKeeper

+ func (k RouterKeeper) BatchConfirm(c context.Context, req *types.QueryBatchConfirmRequest) (*types.QueryBatchConfirmResponse, error)

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

+ func (k RouterKeeper) BatchFees(c context.Context, req *types.QueryBatchFeeRequest) (*types.QueryBatchFeeResponse, error)

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

+ func (k RouterKeeper) BridgeCallByNonce(c context.Context, req *types.QueryBridgeCallByNonceRequest) (*types.QueryBridgeCallByNonceResponse, error)

+ func (k RouterKeeper) BridgeCallBySender(c context.Context, req *types.QueryBridgeCallBySenderRequest) (*types.QueryBridgeCallBySenderResponse, error)

+ func (k RouterKeeper) BridgeCallConfirmByNonce(c context.Context, req *types.QueryBridgeCallConfirmByNonceRequest) (*types.QueryBridgeCallConfirmByNonceResponse, error)

+ func (k RouterKeeper) BridgeCalls(c context.Context, req *types.QueryBridgeCallsRequest) (*types.QueryBridgeCallsResponse, error)

+ func (k RouterKeeper) BridgeChainList(c context.Context, req *types.QueryBridgeChainListRequest) (*types.QueryBridgeChainListResponse, error)

+ func (k RouterKeeper) BridgeCoinByDenom(c context.Context, req *types.QueryBridgeCoinByDenomRequest) (*types.QueryBridgeCoinByDenomResponse, error)

+ func (k RouterKeeper) BridgeTokens(c context.Context, req *types.QueryBridgeTokensRequest) (*types.QueryBridgeTokensResponse, error)

+ func (k RouterKeeper) CurrentOracleSet(c context.Context, req *types.QueryCurrentOracleSetRequest) (*types.QueryCurrentOracleSetResponse, error)

+ func (k RouterKeeper) DenomToToken(c context.Context, req *types.QueryDenomToTokenRequest) (*types.QueryDenomToTokenResponse, error)

+ func (k RouterKeeper) GetOracleByAddr(c context.Context, req *types.QueryOracleByAddrRequest) (*types.QueryOracleResponse, error)

+ func (k RouterKeeper) GetOracleByBridgerAddr(c context.Context, req *types.QueryOracleByBridgerAddrRequest) (*types.QueryOracleResponse, error)

+ func (k RouterKeeper) GetOracleByExternalAddr(c context.Context, req *types.QueryOracleByExternalAddrRequest) (*types.QueryOracleResponse, error)

+ func (k RouterKeeper) GetPendingPoolSendToExternal(c context.Context, req *types.QueryPendingPoolSendToExternalRequest) (*types.QueryPendingPoolSendToExternalResponse, error)

+ func (k RouterKeeper) GetPendingSendToExternal(c context.Context, req *types.QueryPendingSendToExternalRequest) (*types.QueryPendingSendToExternalResponse, error)

+ func (k RouterKeeper) LastEventBlockHeightByAddr(c context.Context, req *types.QueryLastEventBlockHeightByAddrRequest) (*types.QueryLastEventBlockHeightByAddrResponse, error)

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

+ func (k RouterKeeper) LastObservedBlockHeight(c context.Context, req *types.QueryLastObservedBlockHeightRequest) (*types.QueryLastObservedBlockHeightResponse, error)

+ func (k RouterKeeper) LastOracleSetRequests(c context.Context, req *types.QueryLastOracleSetRequestsRequest) (*types.QueryLastOracleSetRequestsResponse, error)

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

+ func (k RouterKeeper) LastPendingBridgeCallByAddr(c context.Context, req *types.QueryLastPendingBridgeCallByAddrRequest) (*types.QueryLastPendingBridgeCallByAddrResponse, error)

+ func (k RouterKeeper) LastPendingOracleSetRequestByAddr(c context.Context, req *types.QueryLastPendingOracleSetRequestByAddrRequest) (*types.QueryLastPendingOracleSetRequestByAddrResponse, error)

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

+ func (k RouterKeeper) OracleSetConfirm(c context.Context, req *types.QueryOracleSetConfirmRequest) (*types.QueryOracleSetConfirmResponse, error)

+ func (k RouterKeeper) OracleSetConfirmsByNonce(c context.Context, req *types.QueryOracleSetConfirmsByNonceRequest) (*types.QueryOracleSetConfirmsByNonceResponse, error)

+ func (k RouterKeeper) OracleSetRequest(c context.Context, req *types.QueryOracleSetRequestRequest) (*types.QueryOracleSetRequestResponse, error)

+ func (k RouterKeeper) Oracles(c context.Context, req *types.QueryOraclesRequest) (*types.QueryOraclesResponse, error)

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

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

+ func (k RouterKeeper) PendingBridgeCallByNonce(c context.Context, req *types.QueryPendingBridgeCallByNonceRequest) (*types.QueryPendingBridgeCallByNonceResponse, error)

+ func (k RouterKeeper) PendingBridgeCalls(c context.Context, req *types.QueryPendingBridgeCallsRequest) (*types.QueryPendingBridgeCallsResponse, error)

+ func (k RouterKeeper) PendingExecuteClaim(ctx context.Context, req *types.QueryPendingExecuteClaimRequest) (*types.QueryPendingExecuteClaimResponse, error)

+ func (k RouterKeeper) ProjectedBatchTimeoutHeight(c context.Context, req *types.QueryProjectedBatchTimeoutHeightRequest) (*types.QueryProjectedBatchTimeoutHeightResponse, error)

+ func (k RouterKeeper) Router() Router

+ func (k RouterKeeper) TokenToDenom(c context.Context, req *types.QueryTokenToDenomRequest) (*types.QueryTokenToDenomResponse, error)

v7.5.0-rc1

Aug 8, 2024

v7.4.0-rc6

Aug 5, 2024

v7.4.0-rc5

Aug 5, 2024

v7.4.0-rc4

Aug 2, 2024

v7.3.0-rc3

May 31, 2024

v7.2.0-rc2

May 21, 2024

v7.1.0-rc1

May 19, 2024

v7.0.1-rc0

Feb 23, 2024

v7.0.0-rc0

Feb 22, 2024

Other modules containing this package

github.com/functionx/fx-core

github.com/functionx/fx-core/v2

github.com/functionx/fx-core/v3

github.com/functionx/fx-core/v4

github.com/functionx/fx-core/v5

github.com/functionx/fx-core/v6