Documentation
¶
Index ¶
- Constants
- func NewMsgServerImpl(keeper Keeper) ictxtypes.MsgServer
- func SerializeCosmosTx(cdc codec.BinaryCodec, msgs []*codectypes.Any) (bz []byte, err error)
- type Keeper
- func (k Keeper) ChargeFee(ctx sdk.Context, payer sdk.AccAddress, fee sdk.Coins) error
- func (k Keeper) GetAuthority() string
- func (k Keeper) GetICARegistrationFeeFirstCodeID(ctx sdk.Context) (codeID uint64)
- func (k Keeper) GetParams(ctx sdk.Context) (params types.Params)
- func (k *Keeper) HandleAcknowledgement(ctx sdk.Context, packet channeltypes.Packet, acknowledgement []byte, ...) error
- func (k *Keeper) HandleChanOpenAck(ctx sdk.Context, ...) error
- func (k *Keeper) HandleTimeout(ctx sdk.Context, packet channeltypes.Packet, relayer sdk.AccAddress) error
- func (k Keeper) InterchainAccountAddress(c context.Context, req *types.QueryInterchainAccountAddressRequest) (*types.QueryInterchainAccountAddressResponse, error)
- func (k *Keeper) Logger(ctx sdk.Context) log.Logger
- func (k Keeper) Params(c context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)
- func (k Keeper) RegisterInterchainAccount(goCtx context.Context, msg *ictxtypes.MsgRegisterInterchainAccount) (*ictxtypes.MsgRegisterInterchainAccountResponse, error)
- func (k Keeper) SetParams(ctx sdk.Context, params types.Params) error
- func (k Keeper) SubmitTx(goCtx context.Context, msg *ictxtypes.MsgSubmitTx) (*ictxtypes.MsgSubmitTxResponse, error)
- func (k Keeper) UpdateParams(goCtx context.Context, req *ictxtypes.MsgUpdateParams) (*ictxtypes.MsgUpdateParamsResponse, error)
Constants ¶
const ( LabelSubmitTx = "submit_tx" LabelHandleAcknowledgment = "handle_ack" LabelLabelHandleChanOpenAck = "handle_chan_open_ack" LabelRegisterInterchainAccount = "register_interchain_account" LabelHandleTimeout = "handle_timeout" )
Variables ¶
This section is empty.
Functions ¶
func NewMsgServerImpl ¶
NewMsgServerImpl returns an implementation of the MsgServer interface for the provided Keeper.
func SerializeCosmosTx ¶
func SerializeCosmosTx(cdc codec.BinaryCodec, msgs []*codectypes.Any) (bz []byte, err error)
SerializeCosmosTx serializes a slice of *types.Any messages using the CosmosTx type. The proto marshaled CosmosTx bytes are returned. This differs from icatypes.SerializeCosmosTx in that it does not serialize sdk.Msgs, but simply uses the already serialized values.
Types ¶
type Keeper ¶
type Keeper struct {
Codec codec.BinaryCodec
// contains filtered or unexported fields
}
func NewKeeper ¶
func NewKeeper( cdc codec.BinaryCodec, storeKey, memKey storetypes.StoreKey, channelKeeper types.ChannelKeeper, icaControllerKeeper types.ICAControllerKeeper, sudoKeeper types.WasmKeeper, feeKeeper types.FeeRefunderKeeper, bankKeeper types.BankKeeper, getFeeCollectorAddr types.GetFeeCollectorAddr, authority string, ) *Keeper
func (Keeper) GetAuthority ¶
func (Keeper) GetICARegistrationFeeFirstCodeID ¶
GetICARegistrationFeeFirstCodeID returns code id, starting from which we charge fee for ICA registration
func (*Keeper) HandleAcknowledgement ¶
func (k *Keeper) HandleAcknowledgement(ctx sdk.Context, packet channeltypes.Packet, acknowledgement []byte, relayer sdk.AccAddress) error
HandleAcknowledgement passes the acknowledgement data to the appropriate contract via a sudo call.
func (*Keeper) HandleChanOpenAck ¶
func (k *Keeper) HandleChanOpenAck( ctx sdk.Context, portID, channelID, counterpartyChannelID, counterpartyVersion string, ) error
HandleChanOpenAck passes the data about a successfully created channel to the appropriate contract (== the data about a successfully registered interchain account). Notice that in the case of an ICA channel - it is not yet in OPEN state here the last step of channel opening(confirm) happens on the host chain.
func (*Keeper) HandleTimeout ¶
func (k *Keeper) HandleTimeout(ctx sdk.Context, packet channeltypes.Packet, relayer sdk.AccAddress) error
HandleTimeout passes the timeout data to the appropriate contract via a sudo call. Since all ICA channels are ORDERED, a single timeout shuts down a channel.
func (Keeper) InterchainAccountAddress ¶
func (k Keeper) InterchainAccountAddress(c context.Context, req *types.QueryInterchainAccountAddressRequest) (*types.QueryInterchainAccountAddressResponse, error)
func (Keeper) Params ¶
func (k Keeper) Params(c context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)
func (Keeper) RegisterInterchainAccount ¶
func (k Keeper) RegisterInterchainAccount(goCtx context.Context, msg *ictxtypes.MsgRegisterInterchainAccount) (*ictxtypes.MsgRegisterInterchainAccountResponse, error)
func (Keeper) SubmitTx ¶
func (k Keeper) SubmitTx(goCtx context.Context, msg *ictxtypes.MsgSubmitTx) (*ictxtypes.MsgSubmitTxResponse, error)
func (Keeper) UpdateParams ¶
func (k Keeper) UpdateParams(goCtx context.Context, req *ictxtypes.MsgUpdateParams) (*ictxtypes.MsgUpdateParamsResponse, error)
UpdateParams updates the module parameters
Source Files