Documentation ¶
Index ¶
- type Keeper
- func (k *Keeper) Acknowledgement(goCtx context.Context, msg *channeltypes.MsgAcknowledgement) (*channeltypes.MsgAcknowledgementResponse, error)
- func (k *Keeper) ChannelCloseConfirm(goCtx context.Context, msg *channeltypes.MsgChannelCloseConfirm) (*channeltypes.MsgChannelCloseConfirmResponse, error)
- func (k *Keeper) ChannelCloseInit(goCtx context.Context, msg *channeltypes.MsgChannelCloseInit) (*channeltypes.MsgChannelCloseInitResponse, error)
- func (k *Keeper) ChannelOpenAck(goCtx context.Context, msg *channeltypes.MsgChannelOpenAck) (*channeltypes.MsgChannelOpenAckResponse, error)
- func (k *Keeper) ChannelOpenConfirm(goCtx context.Context, msg *channeltypes.MsgChannelOpenConfirm) (*channeltypes.MsgChannelOpenConfirmResponse, error)
- func (k *Keeper) ChannelOpenInit(goCtx context.Context, msg *channeltypes.MsgChannelOpenInit) (*channeltypes.MsgChannelOpenInitResponse, error)
- func (k *Keeper) ChannelOpenTry(goCtx context.Context, msg *channeltypes.MsgChannelOpenTry) (*channeltypes.MsgChannelOpenTryResponse, error)
- func (k *Keeper) ChannelUpgradeAck(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeAck) (*channeltypes.MsgChannelUpgradeAckResponse, error)
- func (k *Keeper) ChannelUpgradeCancel(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeCancel) (*channeltypes.MsgChannelUpgradeCancelResponse, error)
- func (k *Keeper) ChannelUpgradeConfirm(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeConfirm) (*channeltypes.MsgChannelUpgradeConfirmResponse, error)
- func (k *Keeper) ChannelUpgradeInit(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeInit) (*channeltypes.MsgChannelUpgradeInitResponse, error)
- func (k *Keeper) ChannelUpgradeOpen(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeOpen) (*channeltypes.MsgChannelUpgradeOpenResponse, error)
- func (k *Keeper) ChannelUpgradeTimeout(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeTimeout) (*channeltypes.MsgChannelUpgradeTimeoutResponse, error)
- func (k *Keeper) ChannelUpgradeTry(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeTry) (*channeltypes.MsgChannelUpgradeTryResponse, error)
- func (k *Keeper) Codec() codec.BinaryCodec
- func (k *Keeper) ConnectionOpenAck(goCtx context.Context, msg *connectiontypes.MsgConnectionOpenAck) (*connectiontypes.MsgConnectionOpenAckResponse, error)
- func (k *Keeper) ConnectionOpenConfirm(goCtx context.Context, msg *connectiontypes.MsgConnectionOpenConfirm) (*connectiontypes.MsgConnectionOpenConfirmResponse, error)
- func (k *Keeper) ConnectionOpenInit(goCtx context.Context, msg *connectiontypes.MsgConnectionOpenInit) (*connectiontypes.MsgConnectionOpenInitResponse, error)
- func (k *Keeper) ConnectionOpenTry(goCtx context.Context, msg *connectiontypes.MsgConnectionOpenTry) (*connectiontypes.MsgConnectionOpenTryResponse, error)
- func (k *Keeper) CreateClient(goCtx context.Context, msg *clienttypes.MsgCreateClient) (*clienttypes.MsgCreateClientResponse, error)
- func (k *Keeper) GetAuthority() string
- func (k *Keeper) IBCSoftwareUpgrade(goCtx context.Context, msg *clienttypes.MsgIBCSoftwareUpgrade) (*clienttypes.MsgIBCSoftwareUpgradeResponse, error)
- func (k *Keeper) PruneAcknowledgements(goCtx context.Context, msg *channeltypes.MsgPruneAcknowledgements) (*channeltypes.MsgPruneAcknowledgementsResponse, error)
- func (k *Keeper) RecoverClient(goCtx context.Context, msg *clienttypes.MsgRecoverClient) (*clienttypes.MsgRecoverClientResponse, error)
- func (k *Keeper) RecvPacket(goCtx context.Context, msg *channeltypes.MsgRecvPacket) (*channeltypes.MsgRecvPacketResponse, error)
- func (k *Keeper) SetRouter(rtr *porttypes.Router)
- func (k *Keeper) SubmitMisbehaviour(goCtx context.Context, msg *clienttypes.MsgSubmitMisbehaviour) (*clienttypes.MsgSubmitMisbehaviourResponse, error)
- func (k *Keeper) Timeout(goCtx context.Context, msg *channeltypes.MsgTimeout) (*channeltypes.MsgTimeoutResponse, error)
- func (k *Keeper) TimeoutOnClose(goCtx context.Context, msg *channeltypes.MsgTimeoutOnClose) (*channeltypes.MsgTimeoutOnCloseResponse, error)
- func (k *Keeper) UpdateChannelParams(goCtx context.Context, msg *channeltypes.MsgUpdateParams) (*channeltypes.MsgUpdateParamsResponse, error)
- func (k *Keeper) UpdateClient(goCtx context.Context, msg *clienttypes.MsgUpdateClient) (*clienttypes.MsgUpdateClientResponse, error)
- func (k *Keeper) UpdateClientParams(goCtx context.Context, msg *clienttypes.MsgUpdateParams) (*clienttypes.MsgUpdateParamsResponse, error)
- func (k *Keeper) UpdateConnectionParams(goCtx context.Context, msg *connectiontypes.MsgUpdateParams) (*connectiontypes.MsgUpdateParamsResponse, error)
- func (k *Keeper) UpgradeClient(goCtx context.Context, msg *clienttypes.MsgUpgradeClient) (*clienttypes.MsgUpgradeClientResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Keeper ¶
type Keeper struct { ClientKeeper *clientkeeper.Keeper ConnectionKeeper *connectionkeeper.Keeper ChannelKeeper *channelkeeper.Keeper PortKeeper *portkeeper.Keeper // contains filtered or unexported fields }
Keeper defines each ICS keeper for IBC
func NewKeeper ¶
func NewKeeper( cdc codec.BinaryCodec, key storetypes.StoreKey, paramSpace types.ParamSubspace, upgradeKeeper clienttypes.UpgradeKeeper, scopedKeeper capabilitykeeper.ScopedKeeper, authority string, ) *Keeper
NewKeeper creates a new ibc Keeper
func (*Keeper) Acknowledgement ¶
func (k *Keeper) Acknowledgement(goCtx context.Context, msg *channeltypes.MsgAcknowledgement) (*channeltypes.MsgAcknowledgementResponse, error)
Acknowledgement defines a rpc handler method for MsgAcknowledgement.
func (*Keeper) ChannelCloseConfirm ¶
func (k *Keeper) ChannelCloseConfirm(goCtx context.Context, msg *channeltypes.MsgChannelCloseConfirm) (*channeltypes.MsgChannelCloseConfirmResponse, error)
ChannelCloseConfirm defines a rpc handler method for MsgChannelCloseConfirm.
func (*Keeper) ChannelCloseInit ¶
func (k *Keeper) ChannelCloseInit(goCtx context.Context, msg *channeltypes.MsgChannelCloseInit) (*channeltypes.MsgChannelCloseInitResponse, error)
ChannelCloseInit defines a rpc handler method for MsgChannelCloseInit.
func (*Keeper) ChannelOpenAck ¶
func (k *Keeper) ChannelOpenAck(goCtx context.Context, msg *channeltypes.MsgChannelOpenAck) (*channeltypes.MsgChannelOpenAckResponse, error)
ChannelOpenAck defines a rpc handler method for MsgChannelOpenAck. ChannelOpenAck will perform 04-channel checks, route to the application callback, and write an OpenAck channel into state upon successful execution.
func (*Keeper) ChannelOpenConfirm ¶
func (k *Keeper) ChannelOpenConfirm(goCtx context.Context, msg *channeltypes.MsgChannelOpenConfirm) (*channeltypes.MsgChannelOpenConfirmResponse, error)
ChannelOpenConfirm defines a rpc handler method for MsgChannelOpenConfirm. ChannelOpenConfirm will perform 04-channel checks, route to the application callback, and write an OpenConfirm channel into state upon successful execution.
func (*Keeper) ChannelOpenInit ¶
func (k *Keeper) ChannelOpenInit(goCtx context.Context, msg *channeltypes.MsgChannelOpenInit) (*channeltypes.MsgChannelOpenInitResponse, error)
ChannelOpenInit defines a rpc handler method for MsgChannelOpenInit. ChannelOpenInit will perform 04-channel checks, route to the application callback, and write an OpenInit channel into state upon successful execution.
func (*Keeper) ChannelOpenTry ¶
func (k *Keeper) ChannelOpenTry(goCtx context.Context, msg *channeltypes.MsgChannelOpenTry) (*channeltypes.MsgChannelOpenTryResponse, error)
ChannelOpenTry defines a rpc handler method for MsgChannelOpenTry. ChannelOpenTry will perform 04-channel checks, route to the application callback, and write an OpenTry channel into state upon successful execution.
func (*Keeper) ChannelUpgradeAck ¶
func (k *Keeper) ChannelUpgradeAck(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeAck) (*channeltypes.MsgChannelUpgradeAckResponse, error)
ChannelUpgradeAck defines a rpc handler method for MsgChannelUpgradeAck.
func (*Keeper) ChannelUpgradeCancel ¶
func (k *Keeper) ChannelUpgradeCancel(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeCancel) (*channeltypes.MsgChannelUpgradeCancelResponse, error)
ChannelUpgradeCancel defines a rpc handler method for MsgChannelUpgradeCancel.
func (*Keeper) ChannelUpgradeConfirm ¶
func (k *Keeper) ChannelUpgradeConfirm(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeConfirm) (*channeltypes.MsgChannelUpgradeConfirmResponse, error)
ChannelUpgradeConfirm defines a rpc handler method for MsgChannelUpgradeConfirm.
func (*Keeper) ChannelUpgradeInit ¶
func (k *Keeper) ChannelUpgradeInit(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeInit) (*channeltypes.MsgChannelUpgradeInitResponse, error)
ChannelUpgradeInit defines a rpc handler method for MsgChannelUpgradeInit.
func (*Keeper) ChannelUpgradeOpen ¶
func (k *Keeper) ChannelUpgradeOpen(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeOpen) (*channeltypes.MsgChannelUpgradeOpenResponse, error)
ChannelUpgradeOpen defines a rpc handler method for MsgChannelUpgradeOpen.
func (*Keeper) ChannelUpgradeTimeout ¶
func (k *Keeper) ChannelUpgradeTimeout(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeTimeout) (*channeltypes.MsgChannelUpgradeTimeoutResponse, error)
ChannelUpgradeTimeout defines a rpc handler method for MsgChannelUpgradeTimeout.
func (*Keeper) ChannelUpgradeTry ¶
func (k *Keeper) ChannelUpgradeTry(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeTry) (*channeltypes.MsgChannelUpgradeTryResponse, error)
ChannelUpgradeTry defines a rpc handler method for MsgChannelUpgradeTry.
func (*Keeper) Codec ¶
func (k *Keeper) Codec() codec.BinaryCodec
Codec returns the IBC module codec.
func (*Keeper) ConnectionOpenAck ¶
func (k *Keeper) ConnectionOpenAck(goCtx context.Context, msg *connectiontypes.MsgConnectionOpenAck) (*connectiontypes.MsgConnectionOpenAckResponse, error)
ConnectionOpenAck defines a rpc handler method for MsgConnectionOpenAck.
func (*Keeper) ConnectionOpenConfirm ¶
func (k *Keeper) ConnectionOpenConfirm(goCtx context.Context, msg *connectiontypes.MsgConnectionOpenConfirm) (*connectiontypes.MsgConnectionOpenConfirmResponse, error)
ConnectionOpenConfirm defines a rpc handler method for MsgConnectionOpenConfirm.
func (*Keeper) ConnectionOpenInit ¶
func (k *Keeper) ConnectionOpenInit(goCtx context.Context, msg *connectiontypes.MsgConnectionOpenInit) (*connectiontypes.MsgConnectionOpenInitResponse, error)
ConnectionOpenInit defines a rpc handler method for MsgConnectionOpenInit.
func (*Keeper) ConnectionOpenTry ¶
func (k *Keeper) ConnectionOpenTry(goCtx context.Context, msg *connectiontypes.MsgConnectionOpenTry) (*connectiontypes.MsgConnectionOpenTryResponse, error)
ConnectionOpenTry defines a rpc handler method for MsgConnectionOpenTry.
func (*Keeper) CreateClient ¶
func (k *Keeper) CreateClient(goCtx context.Context, msg *clienttypes.MsgCreateClient) (*clienttypes.MsgCreateClientResponse, error)
CreateClient defines a rpc handler method for MsgCreateClient. NOTE: The raw bytes of the concrete types encoded into protobuf.Any is passed to the client keeper. The 02-client handler will route to the appropriate light client module based on client type and it is the responsibility of the light client module to unmarshal and interpret the proto encoded bytes. Backwards compatibility with older versions of ibc-go is maintained through the light client module reconstructing and encoding the expected concrete type to the protobuf.Any for proof verification.
func (*Keeper) GetAuthority ¶
GetAuthority returns the ibc module's authority.
func (*Keeper) IBCSoftwareUpgrade ¶
func (k *Keeper) IBCSoftwareUpgrade(goCtx context.Context, msg *clienttypes.MsgIBCSoftwareUpgrade) (*clienttypes.MsgIBCSoftwareUpgradeResponse, error)
IBCSoftwareUpgrade defines a rpc handler method for MsgIBCSoftwareUpgrade.
func (*Keeper) PruneAcknowledgements ¶
func (k *Keeper) PruneAcknowledgements(goCtx context.Context, msg *channeltypes.MsgPruneAcknowledgements) (*channeltypes.MsgPruneAcknowledgementsResponse, error)
PruneAcknowledgements defines a rpc handler method for MsgPruneAcknowledgements.
func (*Keeper) RecoverClient ¶
func (k *Keeper) RecoverClient(goCtx context.Context, msg *clienttypes.MsgRecoverClient) (*clienttypes.MsgRecoverClientResponse, error)
RecoverClient defines a rpc handler method for MsgRecoverClient.
func (*Keeper) RecvPacket ¶
func (k *Keeper) RecvPacket(goCtx context.Context, msg *channeltypes.MsgRecvPacket) (*channeltypes.MsgRecvPacketResponse, error)
RecvPacket defines a rpc handler method for MsgRecvPacket.
func (*Keeper) SetRouter ¶
SetRouter sets the Router in IBC Keeper and seals it. The method panics if there is an existing router that's already sealed.
func (*Keeper) SubmitMisbehaviour ¶
func (k *Keeper) SubmitMisbehaviour(goCtx context.Context, msg *clienttypes.MsgSubmitMisbehaviour) (*clienttypes.MsgSubmitMisbehaviourResponse, error)
SubmitMisbehaviour defines a rpc handler method for MsgSubmitMisbehaviour. Warning: DEPRECATED This handler is redundant as `MsgUpdateClient` is now capable of handling both a Header and a Misbehaviour
func (*Keeper) Timeout ¶
func (k *Keeper) Timeout(goCtx context.Context, msg *channeltypes.MsgTimeout) (*channeltypes.MsgTimeoutResponse, error)
Timeout defines a rpc handler method for MsgTimeout.
func (*Keeper) TimeoutOnClose ¶
func (k *Keeper) TimeoutOnClose(goCtx context.Context, msg *channeltypes.MsgTimeoutOnClose) (*channeltypes.MsgTimeoutOnCloseResponse, error)
TimeoutOnClose defines a rpc handler method for MsgTimeoutOnClose.
func (*Keeper) UpdateChannelParams ¶
func (k *Keeper) UpdateChannelParams(goCtx context.Context, msg *channeltypes.MsgUpdateParams) (*channeltypes.MsgUpdateParamsResponse, error)
UpdateChannelParams defines a rpc handler method for MsgUpdateParams.
func (*Keeper) UpdateClient ¶
func (k *Keeper) UpdateClient(goCtx context.Context, msg *clienttypes.MsgUpdateClient) (*clienttypes.MsgUpdateClientResponse, error)
UpdateClient defines a rpc handler method for MsgUpdateClient.
func (*Keeper) UpdateClientParams ¶
func (k *Keeper) UpdateClientParams(goCtx context.Context, msg *clienttypes.MsgUpdateParams) (*clienttypes.MsgUpdateParamsResponse, error)
UpdateClientParams defines a rpc handler method for MsgUpdateParams.
func (*Keeper) UpdateConnectionParams ¶
func (k *Keeper) UpdateConnectionParams(goCtx context.Context, msg *connectiontypes.MsgUpdateParams) (*connectiontypes.MsgUpdateParamsResponse, error)
UpdateConnectionParams defines a rpc handler method for MsgUpdateParams for the 03-connection submodule.
func (*Keeper) UpgradeClient ¶
func (k *Keeper) UpgradeClient(goCtx context.Context, msg *clienttypes.MsgUpgradeClient) (*clienttypes.MsgUpgradeClientResponse, error)
UpgradeClient defines a rpc handler method for MsgUpgradeClient. NOTE: The raw bytes of the concrete types encoded into protobuf.Any is passed to the client keeper. The 02-client handler will route to the appropriate light client module based on client identifier and it is the responsibility of the light client module to unmarshal and interpret the proto encoded bytes. Backwards compatibility with older versions of ibc-go is maintained through the light client module reconstructing and encoding the expected concrete type to the protobuf.Any for proof verification.