Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterCodec(cdc *codec.LegacyAmino)
- func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
- func RegisterMsgServer(s grpc1.Server, srv MsgServer)
- type AcknowledgementPacketEvent
- type BankKeeper
- type ChannelCloseConfirmEvent
- type ChannelCloseInitEvent
- type ChannelKeeper
- type ChannelOpenAckEvent
- type ChannelOpenConfirmEvent
- type ChannelOpenInitEvent
- type ChannelOpenTryEvent
- type ClientKeeper
- type ConnectionKeeper
- type IBCModule
- func (im IBCModule) OnAcknowledgementPacket(ctx sdk.Context, packet channeltypes.Packet, acknowledgement []byte, ...) error
- func (im IBCModule) OnChanCloseConfirm(ctx sdk.Context, portID, channelID string) error
- func (im IBCModule) OnChanCloseInit(ctx sdk.Context, portID, channelID string) error
- func (im IBCModule) OnChanOpenAck(ctx sdk.Context, portID, channelID string, counterpartyChannelID string, ...) error
- func (im IBCModule) OnChanOpenConfirm(ctx sdk.Context, portID, channelID string) error
- func (im IBCModule) OnChanOpenInit(ctx sdk.Context, order channeltypes.Order, connectionHops []string, ...) (string, error)
- func (im IBCModule) OnChanOpenTry(ctx sdk.Context, order channeltypes.Order, connectionHops []string, ...) (string, error)
- func (im IBCModule) OnRecvPacket(ctx sdk.Context, packet channeltypes.Packet, relayer sdk.AccAddress) exported.Acknowledgement
- func (im IBCModule) OnTimeoutPacket(ctx sdk.Context, packet channeltypes.Packet, relayer sdk.AccAddress) error
- type IBCModuleImpl
- type MsgClient
- type MsgSendPacket
- func (*MsgSendPacket) Descriptor() ([]byte, []int)
- func (m *MsgSendPacket) GetPacket() types.Packet
- func (m *MsgSendPacket) GetSender() github_com_cosmos_cosmos_sdk_types.AccAddress
- func (msg MsgSendPacket) GetSignBytes() []byte
- func (msg MsgSendPacket) GetSigners() []sdk.AccAddress
- func (m *MsgSendPacket) Marshal() (dAtA []byte, err error)
- func (m *MsgSendPacket) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgSendPacket) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgSendPacket) ProtoMessage()
- func (m *MsgSendPacket) Reset()
- func (msg MsgSendPacket) Route() string
- func (m *MsgSendPacket) Size() (n int)
- func (m *MsgSendPacket) String() string
- func (msg MsgSendPacket) Type() string
- func (m *MsgSendPacket) Unmarshal(dAtA []byte) error
- func (msg MsgSendPacket) ValidateBasic() error
- func (m *MsgSendPacket) XXX_DiscardUnknown()
- func (m *MsgSendPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgSendPacket) XXX_Merge(src proto.Message)
- func (m *MsgSendPacket) XXX_Size() int
- func (m *MsgSendPacket) XXX_Unmarshal(b []byte) error
- type MsgSendPacketResponse
- func (*MsgSendPacketResponse) Descriptor() ([]byte, []int)
- func (m *MsgSendPacketResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgSendPacketResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgSendPacketResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgSendPacketResponse) ProtoMessage()
- func (m *MsgSendPacketResponse) Reset()
- func (m *MsgSendPacketResponse) Size() (n int)
- func (m *MsgSendPacketResponse) String() string
- func (m *MsgSendPacketResponse) Unmarshal(dAtA []byte) error
- func (m *MsgSendPacketResponse) XXX_DiscardUnknown()
- func (m *MsgSendPacketResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgSendPacketResponse) XXX_Merge(src proto.Message)
- func (m *MsgSendPacketResponse) XXX_Size() int
- func (m *MsgSendPacketResponse) XXX_Unmarshal(b []byte) error
- type MsgServer
- type PortKeeper
- type ReceivePacketEvent
- type Receiver
- type ReceiverImpl
- type ScopedKeeper
- type TimeoutPacketEvent
- type UnimplementedMsgServer
Constants ¶
const ( // module name ModuleName = "vibc" // StoreKey to be used when creating the KVStore StoreKey = ModuleName )
const ( // AsyncVersions is a flag that indicates whether the IBC module supports // asynchronous versions. If it does, then the VM must supply an empty // version string to indicate that the VM explicitly (possibly async) // performs the Write* method. // This flag is created in anticipation of ibc-go implementing async versions, // see https://github.com/Agoric/agoric-sdk/issues/9358 for more details. AsyncVersions = false )
const RouterKey = ModuleName // this was defined in your key.go file
Variables ¶
var ( ErrInvalidLengthMsgs = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMsgs = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupMsgs = fmt.Errorf("proto: unexpected end of group") )
var ( // ModuleCdc references the global x/deployment module codec. Note, the codec should // ONLY be used in certain instances of tests and for JSON encoding as Amino is // still used for that purpose. // // The actual codec used for serialization should be provided to x/swingset and // defined at the application level. ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry()) )
Functions ¶
func RegisterCodec ¶
func RegisterCodec(cdc *codec.LegacyAmino)
RegisterCodec registers concrete types on the Amino codec
func RegisterInterfaces ¶
func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
RegisterInterfaces registers the x/swingset interfaces types with the interface registry
func RegisterMsgServer ¶
Types ¶
type AcknowledgementPacketEvent ¶
type AcknowledgementPacketEvent struct { *vm.ActionHeader `actionType:"IBC_EVENT"` Event string `json:"event" default:"acknowledgementPacket"` Target string `json:"target,omitempty"` Packet channeltypes.Packet `json:"packet"` Acknowledgement []byte `json:"acknowledgement"` Relayer sdk.AccAddress `json:"relayer"` }
type BankKeeper ¶
type ChannelCloseInitEvent ¶
type ChannelKeeper ¶
type ChannelKeeper interface { GetAppVersion(ctx sdk.Context, portID, channelID string) (string, bool) GetChannel(ctx sdk.Context, srcPort, srcChan string) (channel channel.Channel, found bool) SendPacket( ctx sdk.Context, channelCap *capability.Capability, sourcePort string, sourceChannel string, timeoutHeight clienttypes.Height, timeoutTimestamp uint64, data []byte, ) (uint64, error) WriteAcknowledgement(ctx sdk.Context, channelCap *capability.Capability, packet ibcexported.PacketI, acknowledgement ibcexported.Acknowledgement) error ChanOpenInit(ctx sdk.Context, order channel.Order, connectionHops []string, portID string, portCap *capability.Capability, counterparty channel.Counterparty, version string) (string, *capability.Capability, error) WriteOpenInitChannel(ctx sdk.Context, portID, channelID string, order channel.Order, connectionHops []string, counterparty channel.Counterparty, version string) WriteOpenTryChannel(ctx sdk.Context, portID, channelID string, order channel.Order, connectionHops []string, counterparty channel.Counterparty, version string) ChanCloseInit(ctx sdk.Context, portID, channelID string, chanCap *capability.Capability) error TimeoutExecuted(ctx sdk.Context, channelCap *capability.Capability, packet ibcexported.PacketI) error }
ChannelKeeper defines the expected IBC channel keeper
type ChannelOpenAckEvent ¶
type ChannelOpenAckEvent struct { *vm.ActionHeader `actionType:"IBC_EVENT"` Event string `json:"event" default:"channelOpenAck"` PortID string `json:"portID"` ChannelID string `json:"channelID"` CounterpartyVersion string `json:"counterpartyVersion"` Counterparty channeltypes.Counterparty `json:"counterparty"` ConnectionHops []string `json:"connectionHops"` }
type ChannelOpenConfirmEvent ¶
type ChannelOpenInitEvent ¶
type ChannelOpenInitEvent struct { *vm.ActionHeader `actionType:"IBC_EVENT"` Event string `json:"event" default:"channelOpenInit"` Target string `json:"target,omitempty"` Order string `json:"order"` ConnectionHops []string `json:"connectionHops"` PortID string `json:"portID"` ChannelID string `json:"channelID"` Counterparty channeltypes.Counterparty `json:"counterparty"` Version string `json:"version"` AsyncVersions bool `json:"asyncVersions"` }
type ChannelOpenTryEvent ¶
type ChannelOpenTryEvent struct { *vm.ActionHeader `actionType:"IBC_EVENT"` Event string `json:"event" default:"channelOpenTry"` Target string `json:"target,omitempty"` Order string `json:"order"` ConnectionHops []string `json:"connectionHops"` PortID string `json:"portID"` ChannelID string `json:"channelID"` Counterparty channeltypes.Counterparty `json:"counterparty"` Version string `json:"version"` AsyncVersions bool `json:"asyncVersions"` }
type ClientKeeper ¶
type ClientKeeper interface {
GetClientConsensusState(ctx sdk.Context, clientID string) (connection ibcexported.ConsensusState, found bool)
}
ClientKeeper defines the expected IBC client keeper
type ConnectionKeeper ¶
type ConnectionKeeper interface {
GetConnection(ctx sdk.Context, connectionID string) (connection connection.ConnectionEnd, found bool)
}
ConnectionKeeper defines the expected IBC connection keeper
type IBCModule ¶
type IBCModule struct {
// contains filtered or unexported fields
}
func NewIBCModule ¶
func NewIBCModule(impl IBCModuleImpl) IBCModule
func (IBCModule) OnAcknowledgementPacket ¶
func (im IBCModule) OnAcknowledgementPacket( ctx sdk.Context, packet channeltypes.Packet, acknowledgement []byte, relayer sdk.AccAddress, ) error
func (IBCModule) OnChanCloseConfirm ¶
func (IBCModule) OnChanCloseInit ¶
func (IBCModule) OnChanOpenAck ¶
func (IBCModule) OnChanOpenConfirm ¶
func (IBCModule) OnChanOpenInit ¶
func (im IBCModule) OnChanOpenInit( ctx sdk.Context, order channeltypes.Order, connectionHops []string, portID string, channelID string, channelCap *capability.Capability, counterparty channeltypes.Counterparty, version string, ) (string, error)
Implement IBCModule callbacks
func (IBCModule) OnChanOpenTry ¶
func (im IBCModule) OnChanOpenTry( ctx sdk.Context, order channeltypes.Order, connectionHops []string, portID, channelID string, channelCap *capability.Capability, counterparty channeltypes.Counterparty, counterpartyVersion string, ) (string, error)
func (IBCModule) OnRecvPacket ¶
func (im IBCModule) OnRecvPacket( ctx sdk.Context, packet channeltypes.Packet, relayer sdk.AccAddress, ) exported.Acknowledgement
func (IBCModule) OnTimeoutPacket ¶
func (im IBCModule) OnTimeoutPacket( ctx sdk.Context, packet channeltypes.Packet, relayer sdk.AccAddress, ) error
type IBCModuleImpl ¶
type MsgClient ¶
type MsgClient interface { // Force sending an arbitrary packet on a channel. SendPacket(ctx context.Context, in *MsgSendPacket, opts ...grpc.CallOption) (*MsgSendPacketResponse, error) }
MsgClient is the client API for Msg service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMsgClient ¶
func NewMsgClient(cc grpc1.ClientConn) MsgClient
type MsgSendPacket ¶
type MsgSendPacket struct { Packet types.Packet `protobuf:"bytes,1,opt,name=packet,proto3" json:"packet" yaml:"packet"` Sender github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 130-byte string literal not displayed */ }
MsgSendPacket is an SDK message for sending an outgoing IBC packet
func NewMsgSendPacket ¶
func NewMsgSendPacket(packet chanTypes.Packet, sender sdk.AccAddress) *MsgSendPacket
NewMsgSendPacket returns a new send request
func (*MsgSendPacket) Descriptor ¶
func (*MsgSendPacket) Descriptor() ([]byte, []int)
func (*MsgSendPacket) GetPacket ¶
func (m *MsgSendPacket) GetPacket() types.Packet
func (*MsgSendPacket) GetSender ¶
func (m *MsgSendPacket) GetSender() github_com_cosmos_cosmos_sdk_types.AccAddress
func (MsgSendPacket) GetSignBytes ¶
func (msg MsgSendPacket) GetSignBytes() []byte
GetSignBytes implements sdk.Msg
func (MsgSendPacket) GetSigners ¶
func (msg MsgSendPacket) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg
func (*MsgSendPacket) Marshal ¶
func (m *MsgSendPacket) Marshal() (dAtA []byte, err error)
func (*MsgSendPacket) MarshalToSizedBuffer ¶
func (m *MsgSendPacket) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgSendPacket) ProtoMessage ¶
func (*MsgSendPacket) ProtoMessage()
func (*MsgSendPacket) Reset ¶
func (m *MsgSendPacket) Reset()
func (*MsgSendPacket) Size ¶
func (m *MsgSendPacket) Size() (n int)
func (*MsgSendPacket) String ¶
func (m *MsgSendPacket) String() string
func (*MsgSendPacket) Unmarshal ¶
func (m *MsgSendPacket) Unmarshal(dAtA []byte) error
func (MsgSendPacket) ValidateBasic ¶
func (msg MsgSendPacket) ValidateBasic() error
ValidateBasic implements sdk.Msg
func (*MsgSendPacket) XXX_DiscardUnknown ¶
func (m *MsgSendPacket) XXX_DiscardUnknown()
func (*MsgSendPacket) XXX_Marshal ¶
func (m *MsgSendPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgSendPacket) XXX_Merge ¶
func (m *MsgSendPacket) XXX_Merge(src proto.Message)
func (*MsgSendPacket) XXX_Size ¶
func (m *MsgSendPacket) XXX_Size() int
func (*MsgSendPacket) XXX_Unmarshal ¶
func (m *MsgSendPacket) XXX_Unmarshal(b []byte) error
type MsgSendPacketResponse ¶
type MsgSendPacketResponse struct { }
Empty response for SendPacket.
func (*MsgSendPacketResponse) Descriptor ¶
func (*MsgSendPacketResponse) Descriptor() ([]byte, []int)
func (*MsgSendPacketResponse) Marshal ¶
func (m *MsgSendPacketResponse) Marshal() (dAtA []byte, err error)
func (*MsgSendPacketResponse) MarshalTo ¶
func (m *MsgSendPacketResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgSendPacketResponse) MarshalToSizedBuffer ¶
func (m *MsgSendPacketResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgSendPacketResponse) ProtoMessage ¶
func (*MsgSendPacketResponse) ProtoMessage()
func (*MsgSendPacketResponse) Reset ¶
func (m *MsgSendPacketResponse) Reset()
func (*MsgSendPacketResponse) Size ¶
func (m *MsgSendPacketResponse) Size() (n int)
func (*MsgSendPacketResponse) String ¶
func (m *MsgSendPacketResponse) String() string
func (*MsgSendPacketResponse) Unmarshal ¶
func (m *MsgSendPacketResponse) Unmarshal(dAtA []byte) error
func (*MsgSendPacketResponse) XXX_DiscardUnknown ¶
func (m *MsgSendPacketResponse) XXX_DiscardUnknown()
func (*MsgSendPacketResponse) XXX_Marshal ¶
func (m *MsgSendPacketResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgSendPacketResponse) XXX_Merge ¶
func (m *MsgSendPacketResponse) XXX_Merge(src proto.Message)
func (*MsgSendPacketResponse) XXX_Size ¶
func (m *MsgSendPacketResponse) XXX_Size() int
func (*MsgSendPacketResponse) XXX_Unmarshal ¶
func (m *MsgSendPacketResponse) XXX_Unmarshal(b []byte) error
type MsgServer ¶
type MsgServer interface { // Force sending an arbitrary packet on a channel. SendPacket(context.Context, *MsgSendPacket) (*MsgSendPacketResponse, error) }
MsgServer is the server API for Msg service.
type PortKeeper ¶
type PortKeeper interface {
BindPort(ctx sdk.Context, portID string) *capability.Capability
}
PortKeeper defines the expected IBC port keeper
type ReceivePacketEvent ¶
type ReceivePacketEvent struct { *vm.ActionHeader `actionType:"IBC_EVENT"` Event string `json:"event" default:"receivePacket"` Target string `json:"target,omitempty"` Packet channeltypes.Packet `json:"packet"` Relayer sdk.AccAddress `json:"relayer"` }
type Receiver ¶
type Receiver struct {
// contains filtered or unexported fields
}
func NewReceiver ¶
func NewReceiver(impl ReceiverImpl) Receiver
type ReceiverImpl ¶
type ReceiverImpl interface { ReceiveSendPacket(ctx sdk.Context, packet exported.PacketI) (uint64, error) ReceiveWriteAcknowledgement(ctx sdk.Context, packet exported.PacketI, ack exported.Acknowledgement) error ReceiveChanOpenInit(ctx sdk.Context, order channeltypes.Order, hops []string, sourcePort, destinationPort, version string) error ReceiveWriteOpenTryChannel(ctx sdk.Context, packet exported.PacketI, order channeltypes.Order, connectionHops []string, version string) error ReceiveChanCloseInit(ctx sdk.Context, sourcePort, sourceChannel string) error ReceiveBindPort(ctx sdk.Context, sourcePort string) error ReceiveTimeoutExecuted(ctx sdk.Context, packet exported.PacketI) error }
type ScopedKeeper ¶
type ScopedKeeper interface { ClaimCapability(ctx sdk.Context, cap *capability.Capability, name string) error GetCapability(ctx sdk.Context, name string) (*capability.Capability, bool) }
ScopedKeeper defines the expected scoped capability keeper
type TimeoutPacketEvent ¶
type TimeoutPacketEvent struct { *vm.ActionHeader `actionType:"IBC_EVENT"` Event string `json:"event" default:"timeoutPacket"` Target string `json:"target,omitempty"` Packet channeltypes.Packet `json:"packet"` Relayer sdk.AccAddress `json:"relayer"` }
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct { }
UnimplementedMsgServer can be embedded to have forward compatible implementations.
func (*UnimplementedMsgServer) SendPacket ¶
func (*UnimplementedMsgServer) SendPacket(ctx context.Context, req *MsgSendPacket) (*MsgSendPacketResponse, error)