Documentation ¶
Overview ¶
Package types is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func KeyInitiateTxState() []byte
- func KeyPrefixBytes(prefix uint8) []byte
- func MakeCallResultKey(callInfo txtypes.ContractCallInfo, signers []authtypes.Account) []byte
- func MakeTxID(msg *MsgInitiateTx) crosstypes.TxID
- func RegisterInterfaces(registry codectypes.InterfaceRegistry)
- func RegisterMsgServer(s grpc1.Server, srv MsgServer)
- func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
- func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
- func RegisterQueryServer(s grpc1.Server, srv QueryServer)
- type ChannelKeeper
- type ClientKeeper
- type ConnectionKeeper
- type ContractTransaction
- func (*ContractTransaction) Descriptor() ([]byte, []int)
- func (tx ContractTransaction) GetCrossChainChannel(m codec.Codec) (xcctypes.XCC, error)
- func (m *ContractTransaction) Marshal() (dAtA []byte, err error)
- func (m *ContractTransaction) MarshalTo(dAtA []byte) (int, error)
- func (m *ContractTransaction) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ContractTransaction) ProtoMessage()
- func (m *ContractTransaction) Reset()
- func (m *ContractTransaction) Size() (n int)
- func (m *ContractTransaction) String() string
- func (m *ContractTransaction) Unmarshal(dAtA []byte) error
- func (tx *ContractTransaction) UnpackInterfaces(unpacker codectypes.AnyUnpacker) error
- func (tx ContractTransaction) ValidateBasic() error
- func (m *ContractTransaction) XXX_DiscardUnknown()
- func (m *ContractTransaction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ContractTransaction) XXX_Merge(src proto.Message)
- func (m *ContractTransaction) XXX_Size() int
- func (m *ContractTransaction) XXX_Unmarshal(b []byte) error
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)
- func (m *GenesisState) Marshal() (dAtA []byte, err error)
- func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)
- func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GenesisState) ProtoMessage()
- func (m *GenesisState) Reset()
- func (m *GenesisState) Size() (n int)
- func (m *GenesisState) String() string
- func (m *GenesisState) Unmarshal(dAtA []byte) error
- func (gs GenesisState) Validate() error
- func (m *GenesisState) XXX_DiscardUnknown()
- func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GenesisState) XXX_Merge(src proto.Message)
- func (m *GenesisState) XXX_Size() int
- func (m *GenesisState) XXX_Unmarshal(b []byte) error
- type InitiateTxState
- func (*InitiateTxState) Descriptor() ([]byte, []int)
- func (state InitiateTxState) IsVerified() bool
- func (m *InitiateTxState) Marshal() (dAtA []byte, err error)
- func (m *InitiateTxState) MarshalTo(dAtA []byte) (int, error)
- func (m *InitiateTxState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*InitiateTxState) ProtoMessage()
- func (m *InitiateTxState) Reset()
- func (m *InitiateTxState) Size() (n int)
- func (m *InitiateTxState) String() string
- func (m *InitiateTxState) Unmarshal(dAtA []byte) error
- func (m *InitiateTxState) XXX_DiscardUnknown()
- func (m *InitiateTxState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InitiateTxState) XXX_Merge(src proto.Message)
- func (m *InitiateTxState) XXX_Size() int
- func (m *InitiateTxState) XXX_Unmarshal(b []byte) error
- type InitiateTxStatus
- type Link
- func (*Link) Descriptor() ([]byte, []int)
- func (lk Link) GetSrcIndex() crosstypes.TxIndex
- func (m *Link) Marshal() (dAtA []byte, err error)
- func (m *Link) MarshalTo(dAtA []byte) (int, error)
- func (m *Link) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Link) ProtoMessage()
- func (m *Link) Reset()
- func (m *Link) Size() (n int)
- func (m *Link) String() string
- func (m *Link) Unmarshal(dAtA []byte) error
- func (lk Link) ValidateBasic() error
- func (m *Link) XXX_DiscardUnknown()
- func (m *Link) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Link) XXX_Merge(src proto.Message)
- func (m *Link) XXX_Size() int
- func (m *Link) XXX_Unmarshal(b []byte) error
- type Linker
- type MsgClient
- type MsgInitiateTx
- func (*MsgInitiateTx) Descriptor() ([]byte, []int)
- func (msg MsgInitiateTx) GetRequiredAccounts() []authtypes.Account
- func (msg MsgInitiateTx) GetSignBytes() []byte
- func (msg MsgInitiateTx) GetSignerAccounts() []authtypes.Account
- func (msg MsgInitiateTx) GetSigners() []sdk.AccAddress
- func (m *MsgInitiateTx) Marshal() (dAtA []byte, err error)
- func (m *MsgInitiateTx) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgInitiateTx) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgInitiateTx) ProtoMessage()
- func (m *MsgInitiateTx) Reset()
- func (MsgInitiateTx) Route() string
- func (m *MsgInitiateTx) Size() (n int)
- func (m *MsgInitiateTx) String() string
- func (MsgInitiateTx) Type() string
- func (m *MsgInitiateTx) Unmarshal(dAtA []byte) error
- func (msg *MsgInitiateTx) UnpackInterfaces(unpacker codectypes.AnyUnpacker) error
- func (msg MsgInitiateTx) ValidateBasic() error
- func (m *MsgInitiateTx) XXX_DiscardUnknown()
- func (m *MsgInitiateTx) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgInitiateTx) XXX_Merge(src proto.Message)
- func (m *MsgInitiateTx) XXX_Size() int
- func (m *MsgInitiateTx) XXX_Unmarshal(b []byte) error
- type MsgInitiateTxResponse
- func (*MsgInitiateTxResponse) Descriptor() ([]byte, []int)
- func (m *MsgInitiateTxResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgInitiateTxResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgInitiateTxResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgInitiateTxResponse) ProtoMessage()
- func (m *MsgInitiateTxResponse) Reset()
- func (m *MsgInitiateTxResponse) Size() (n int)
- func (m *MsgInitiateTxResponse) String() string
- func (m *MsgInitiateTxResponse) Unmarshal(dAtA []byte) error
- func (m *MsgInitiateTxResponse) XXX_DiscardUnknown()
- func (m *MsgInitiateTxResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgInitiateTxResponse) XXX_Merge(src proto.Message)
- func (m *MsgInitiateTxResponse) XXX_Size() int
- func (m *MsgInitiateTxResponse) XXX_Unmarshal(b []byte) error
- type MsgServer
- type PortKeeper
- type QueryClient
- type QuerySelfXCCRequest
- func (*QuerySelfXCCRequest) Descriptor() ([]byte, []int)
- func (m *QuerySelfXCCRequest) Marshal() (dAtA []byte, err error)
- func (m *QuerySelfXCCRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QuerySelfXCCRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QuerySelfXCCRequest) ProtoMessage()
- func (m *QuerySelfXCCRequest) Reset()
- func (m *QuerySelfXCCRequest) Size() (n int)
- func (m *QuerySelfXCCRequest) String() string
- func (m *QuerySelfXCCRequest) Unmarshal(dAtA []byte) error
- func (m *QuerySelfXCCRequest) XXX_DiscardUnknown()
- func (m *QuerySelfXCCRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QuerySelfXCCRequest) XXX_Merge(src proto.Message)
- func (m *QuerySelfXCCRequest) XXX_Size() int
- func (m *QuerySelfXCCRequest) XXX_Unmarshal(b []byte) error
- type QuerySelfXCCResponse
- func (*QuerySelfXCCResponse) Descriptor() ([]byte, []int)
- func (m *QuerySelfXCCResponse) GetXcc() *types.Any
- func (m *QuerySelfXCCResponse) Marshal() (dAtA []byte, err error)
- func (m *QuerySelfXCCResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QuerySelfXCCResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QuerySelfXCCResponse) ProtoMessage()
- func (m *QuerySelfXCCResponse) Reset()
- func (m *QuerySelfXCCResponse) Size() (n int)
- func (m *QuerySelfXCCResponse) String() string
- func (m *QuerySelfXCCResponse) Unmarshal(dAtA []byte) error
- func (m *QuerySelfXCCResponse) XXX_DiscardUnknown()
- func (m *QuerySelfXCCResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QuerySelfXCCResponse) XXX_Merge(src proto.Message)
- func (m *QuerySelfXCCResponse) XXX_Size() int
- func (m *QuerySelfXCCResponse) XXX_Unmarshal(b []byte) error
- type QueryServer
- type UnimplementedMsgServer
- type UnimplementedQueryServer
Constants ¶
const (
KeyInitiateTxStatePrefix uint8 = iota
)
const SubModuleName = "initiator"
const (
TypeInitiateTx = "InitiateTx"
)
msg types
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 ( ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthState = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowState = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupState = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthTypes = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTypes = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group") )
var InitiateTxStatus_name = map[int32]string{
0: "INITIATE_TX_STATUS_UNKNOWN",
1: "INITIATE_TX_STATUS_PENDING",
2: "INITIATE_TX_STATUS_VERIFIED",
}
var InitiateTxStatus_value = map[string]int32{
"INITIATE_TX_STATUS_UNKNOWN": 0,
"INITIATE_TX_STATUS_PENDING": 1,
"INITIATE_TX_STATUS_VERIFIED": 2,
}
var ( // ModuleCdc references the global x/ibc-transfer module codec. Note, the codec // should ONLY be used in certain instances of tests and for JSON encoding. // // The actual codec used for serialization should be provided to x/ibc-transfer and // defined at the application level. ModuleCdc = codec.NewProtoCodec(codectypes.NewInterfaceRegistry()) )
Functions ¶
func KeyInitiateTxState ¶
func KeyInitiateTxState() []byte
func KeyPrefixBytes ¶
KeyPrefixBytes return the key prefix bytes from a URL string format
func MakeCallResultKey ¶ added in v0.2.1
func MakeCallResultKey(callInfo txtypes.ContractCallInfo, signers []authtypes.Account) []byte
MakeCallResultKey returns a key that can be used to identify a contract call
func MakeTxID ¶
func MakeTxID(msg *MsgInitiateTx) crosstypes.TxID
MakeTxID generates TxID with a given msg
func RegisterInterfaces ¶
func RegisterInterfaces(registry codectypes.InterfaceRegistry)
RegisterInterfaces register the ibc transfer module interfaces to protobuf Any.
func RegisterMsgServer ¶
func RegisterQueryHandler ¶
RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterQueryHandlerClient ¶
func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.
func RegisterQueryHandlerFromEndpoint ¶
func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterQueryHandlerServer ¶
func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features (such as grpc.SendHeader, etc) to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.
func RegisterQueryServer ¶
func RegisterQueryServer(s grpc1.Server, srv QueryServer)
Types ¶
type ChannelKeeper ¶
type ChannelKeeper interface { GetChannel(ctx sdk.Context, srcPort, srcChan string) (channel channeltypes.Channel, found bool) GetNextSequenceSend(ctx sdk.Context, portID, channelID string) (uint64, bool) SendPacket(ctx sdk.Context, channelCap *capabilitytypes.Capability, packet ibcexported.PacketI) error ChanCloseInit(ctx sdk.Context, portID, channelID string, chanCap *capabilitytypes.Capability) error }
ChannelKeeper defines the expected IBC channel keeper
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 connectiontypes.ConnectionEnd, found bool)
}
ConnectionKeeper defines the expected IBC connection keeper
type ContractTransaction ¶
type ContractTransaction struct { CrossChainChannel *types.Any `protobuf:"bytes,1,opt,name=cross_chain_channel,json=crossChainChannel,proto3" json:"cross_chain_channel,omitempty"` Signers []types1.Account `protobuf:"bytes,2,rep,name=signers,proto3" json:"signers"` CallInfo github_com_datachainlab_cross_x_core_tx_types.ContractCallInfo `` /* 157-byte string literal not displayed */ ReturnValue *types2.ReturnValue `protobuf:"bytes,4,opt,name=return_value,json=returnValue,proto3" json:"return_value,omitempty"` Links []Link `protobuf:"bytes,5,rep,name=links,proto3" json:"links"` }
func (*ContractTransaction) Descriptor ¶
func (*ContractTransaction) Descriptor() ([]byte, []int)
func (ContractTransaction) GetCrossChainChannel ¶
func (*ContractTransaction) Marshal ¶
func (m *ContractTransaction) Marshal() (dAtA []byte, err error)
func (*ContractTransaction) MarshalTo ¶
func (m *ContractTransaction) MarshalTo(dAtA []byte) (int, error)
func (*ContractTransaction) MarshalToSizedBuffer ¶
func (m *ContractTransaction) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ContractTransaction) ProtoMessage ¶
func (*ContractTransaction) ProtoMessage()
func (*ContractTransaction) Reset ¶
func (m *ContractTransaction) Reset()
func (*ContractTransaction) Size ¶
func (m *ContractTransaction) Size() (n int)
func (*ContractTransaction) String ¶
func (m *ContractTransaction) String() string
func (*ContractTransaction) Unmarshal ¶
func (m *ContractTransaction) Unmarshal(dAtA []byte) error
func (*ContractTransaction) UnpackInterfaces ¶ added in v0.2.0
func (tx *ContractTransaction) UnpackInterfaces(unpacker codectypes.AnyUnpacker) error
func (ContractTransaction) ValidateBasic ¶
func (tx ContractTransaction) ValidateBasic() error
func (*ContractTransaction) XXX_DiscardUnknown ¶
func (m *ContractTransaction) XXX_DiscardUnknown()
func (*ContractTransaction) XXX_Marshal ¶
func (m *ContractTransaction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ContractTransaction) XXX_Merge ¶
func (m *ContractTransaction) XXX_Merge(src proto.Message)
func (*ContractTransaction) XXX_Size ¶
func (m *ContractTransaction) XXX_Size() int
func (*ContractTransaction) XXX_Unmarshal ¶
func (m *ContractTransaction) XXX_Unmarshal(b []byte) error
type GenesisState ¶
type GenesisState struct { }
func DefaultGenesis ¶
func DefaultGenesis() *GenesisState
DefaultGenesis returns a GenesisState instance
func NewGenesisState ¶
func NewGenesisState() *GenesisState
NewGenesisState creates a new cross module GenesisState instance.
func (*GenesisState) Descriptor ¶
func (*GenesisState) Descriptor() ([]byte, []int)
func (*GenesisState) Marshal ¶
func (m *GenesisState) Marshal() (dAtA []byte, err error)
func (*GenesisState) MarshalToSizedBuffer ¶
func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GenesisState) ProtoMessage ¶
func (*GenesisState) ProtoMessage()
func (*GenesisState) Reset ¶
func (m *GenesisState) Reset()
func (*GenesisState) Size ¶
func (m *GenesisState) Size() (n int)
func (*GenesisState) String ¶
func (m *GenesisState) String() string
func (*GenesisState) Unmarshal ¶
func (m *GenesisState) Unmarshal(dAtA []byte) error
func (GenesisState) Validate ¶
func (gs GenesisState) Validate() error
Validate performs basic genesis state validation returning an error upon any failure.
func (*GenesisState) XXX_DiscardUnknown ¶
func (m *GenesisState) XXX_DiscardUnknown()
func (*GenesisState) XXX_Marshal ¶
func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GenesisState) XXX_Merge ¶
func (m *GenesisState) XXX_Merge(src proto.Message)
func (*GenesisState) XXX_Size ¶
func (m *GenesisState) XXX_Size() int
func (*GenesisState) XXX_Unmarshal ¶
func (m *GenesisState) XXX_Unmarshal(b []byte) error
type InitiateTxState ¶
type InitiateTxState struct { Status InitiateTxStatus `protobuf:"varint,1,opt,name=status,proto3,enum=cross.core.initiator.InitiateTxStatus" json:"status,omitempty"` Msg MsgInitiateTx `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg"` }
func NewInitiateTxState ¶
func NewInitiateTxState(msg MsgInitiateTx) InitiateTxState
NewInitiateTxState creates an new instance of InitiateTxState
func (*InitiateTxState) Descriptor ¶
func (*InitiateTxState) Descriptor() ([]byte, []int)
func (InitiateTxState) IsVerified ¶
func (state InitiateTxState) IsVerified() bool
func (*InitiateTxState) Marshal ¶
func (m *InitiateTxState) Marshal() (dAtA []byte, err error)
func (*InitiateTxState) MarshalToSizedBuffer ¶
func (m *InitiateTxState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*InitiateTxState) ProtoMessage ¶
func (*InitiateTxState) ProtoMessage()
func (*InitiateTxState) Reset ¶
func (m *InitiateTxState) Reset()
func (*InitiateTxState) Size ¶
func (m *InitiateTxState) Size() (n int)
func (*InitiateTxState) String ¶
func (m *InitiateTxState) String() string
func (*InitiateTxState) Unmarshal ¶
func (m *InitiateTxState) Unmarshal(dAtA []byte) error
func (*InitiateTxState) XXX_DiscardUnknown ¶
func (m *InitiateTxState) XXX_DiscardUnknown()
func (*InitiateTxState) XXX_Marshal ¶
func (m *InitiateTxState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InitiateTxState) XXX_Merge ¶
func (m *InitiateTxState) XXX_Merge(src proto.Message)
func (*InitiateTxState) XXX_Size ¶
func (m *InitiateTxState) XXX_Size() int
func (*InitiateTxState) XXX_Unmarshal ¶
func (m *InitiateTxState) XXX_Unmarshal(b []byte) error
type InitiateTxStatus ¶
type InitiateTxStatus int32
const ( INITIATE_TX_STATUS_UNKNOWN InitiateTxStatus = 0 INITIATE_TX_STATUS_PENDING InitiateTxStatus = 1 INITIATE_TX_STATUS_VERIFIED InitiateTxStatus = 2 )
func (InitiateTxStatus) EnumDescriptor ¶
func (InitiateTxStatus) EnumDescriptor() ([]byte, []int)
func (InitiateTxStatus) String ¶
func (x InitiateTxStatus) String() string
type Link ¶
type Link struct {
SrcIndex uint32 `protobuf:"varint,1,opt,name=src_index,json=srcIndex,proto3" json:"src_index,omitempty"`
}
func (*Link) Descriptor ¶
func (Link) GetSrcIndex ¶
func (lk Link) GetSrcIndex() crosstypes.TxIndex
func (*Link) ProtoMessage ¶
func (*Link) ProtoMessage()
func (Link) ValidateBasic ¶
func (*Link) XXX_DiscardUnknown ¶
func (m *Link) XXX_DiscardUnknown()
func (*Link) XXX_Unmarshal ¶
type Linker ¶
type Linker struct {
// contains filtered or unexported fields
}
Linker resolves links that each ContractTransaction has.
func MakeLinker ¶
func MakeLinker(cdc codec.Codec, xccResolver xcctypes.XCCResolver, txs []ContractTransaction) (*Linker, error)
MakeLinker returns Linker
type MsgClient ¶
type MsgClient interface { // InitiateTx defines a rpc handler method for MsgInitiateTx. InitiateTx(ctx context.Context, in *MsgInitiateTx, opts ...grpc.CallOption) (*MsgInitiateTxResponse, 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 MsgInitiateTx ¶
type MsgInitiateTx struct { ChainId string `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` Nonce uint64 `protobuf:"varint,2,opt,name=nonce,proto3" json:"nonce,omitempty"` CommitProtocol types.CommitProtocol `` /* 138-byte string literal not displayed */ ContractTransactions []ContractTransaction `protobuf:"bytes,4,rep,name=contract_transactions,json=contractTransactions,proto3" json:"contract_transactions"` Signers []types1.Account `protobuf:"bytes,5,rep,name=signers,proto3" json:"signers"` // Timeout height relative to the current block height. // The timeout is disabled when set to 0. TimeoutHeight types2.Height `protobuf:"bytes,6,opt,name=timeout_height,json=timeoutHeight,proto3" json:"timeout_height" yaml:"timeout_height"` // Timeout timestamp (in nanoseconds) relative to the current block timestamp. // The timeout is disabled when set to 0. TimeoutTimestamp uint64 `` /* 135-byte string literal not displayed */ }
func NewMsgInitiateTx ¶
func NewMsgInitiateTx( signers []authtypes.Account, chainID string, nonce uint64, commitProtocol txtypes.CommitProtocol, ctxs []ContractTransaction, timeoutHeight clienttypes.Height, timeoutTimestamp uint64, ) *MsgInitiateTx
NewMsgInitiateTx creates a new MsgInitiateTx instance
func (*MsgInitiateTx) Descriptor ¶
func (*MsgInitiateTx) Descriptor() ([]byte, []int)
func (MsgInitiateTx) GetRequiredAccounts ¶
func (msg MsgInitiateTx) GetRequiredAccounts() []authtypes.Account
func (MsgInitiateTx) GetSignBytes ¶
func (msg MsgInitiateTx) GetSignBytes() []byte
GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which IBC does not support.
func (MsgInitiateTx) GetSignerAccounts ¶ added in v0.2.0
func (msg MsgInitiateTx) GetSignerAccounts() []authtypes.Account
GetSignerAccounts implements authtypes.ExtAuthMsg
func (MsgInitiateTx) GetSigners ¶
func (msg MsgInitiateTx) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg GetSigners returns the addresses that must sign the transaction. Addresses are returned in a deterministic order. Duplicate addresses will be omitted.
func (*MsgInitiateTx) Marshal ¶
func (m *MsgInitiateTx) Marshal() (dAtA []byte, err error)
func (*MsgInitiateTx) MarshalToSizedBuffer ¶
func (m *MsgInitiateTx) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgInitiateTx) ProtoMessage ¶
func (*MsgInitiateTx) ProtoMessage()
func (*MsgInitiateTx) Reset ¶
func (m *MsgInitiateTx) Reset()
func (*MsgInitiateTx) Size ¶
func (m *MsgInitiateTx) Size() (n int)
func (*MsgInitiateTx) String ¶
func (m *MsgInitiateTx) String() string
func (*MsgInitiateTx) Unmarshal ¶
func (m *MsgInitiateTx) Unmarshal(dAtA []byte) error
func (*MsgInitiateTx) UnpackInterfaces ¶ added in v0.2.0
func (msg *MsgInitiateTx) UnpackInterfaces(unpacker codectypes.AnyUnpacker) error
UnpackInterfaces implements UnpackInterfacesMessage
func (MsgInitiateTx) ValidateBasic ¶
func (msg MsgInitiateTx) ValidateBasic() error
ValidateBasic performs a basic check of the MsgInitiateTx fields. NOTE: timeout height or timestamp values can be 0 to disable the timeout.
func (*MsgInitiateTx) XXX_DiscardUnknown ¶
func (m *MsgInitiateTx) XXX_DiscardUnknown()
func (*MsgInitiateTx) XXX_Marshal ¶
func (m *MsgInitiateTx) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgInitiateTx) XXX_Merge ¶
func (m *MsgInitiateTx) XXX_Merge(src proto.Message)
func (*MsgInitiateTx) XXX_Size ¶
func (m *MsgInitiateTx) XXX_Size() int
func (*MsgInitiateTx) XXX_Unmarshal ¶
func (m *MsgInitiateTx) XXX_Unmarshal(b []byte) error
type MsgInitiateTxResponse ¶
type MsgInitiateTxResponse struct { TxID github_com_datachainlab_cross_x_core_types.TxID `protobuf:"bytes,1,opt,name=txID,proto3,casttype=github.com/datachainlab/cross/x/core/types.TxID" json:"txID,omitempty"` Status InitiateTxStatus `protobuf:"varint,2,opt,name=status,proto3,enum=cross.core.initiator.InitiateTxStatus" json:"status,omitempty"` }
MsgInitiateTxResponse defines the Msg/InitiateTx response type.
func (*MsgInitiateTxResponse) Descriptor ¶
func (*MsgInitiateTxResponse) Descriptor() ([]byte, []int)
func (*MsgInitiateTxResponse) Marshal ¶
func (m *MsgInitiateTxResponse) Marshal() (dAtA []byte, err error)
func (*MsgInitiateTxResponse) MarshalTo ¶
func (m *MsgInitiateTxResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgInitiateTxResponse) MarshalToSizedBuffer ¶
func (m *MsgInitiateTxResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgInitiateTxResponse) ProtoMessage ¶
func (*MsgInitiateTxResponse) ProtoMessage()
func (*MsgInitiateTxResponse) Reset ¶
func (m *MsgInitiateTxResponse) Reset()
func (*MsgInitiateTxResponse) Size ¶
func (m *MsgInitiateTxResponse) Size() (n int)
func (*MsgInitiateTxResponse) String ¶
func (m *MsgInitiateTxResponse) String() string
func (*MsgInitiateTxResponse) Unmarshal ¶
func (m *MsgInitiateTxResponse) Unmarshal(dAtA []byte) error
func (*MsgInitiateTxResponse) XXX_DiscardUnknown ¶
func (m *MsgInitiateTxResponse) XXX_DiscardUnknown()
func (*MsgInitiateTxResponse) XXX_Marshal ¶
func (m *MsgInitiateTxResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgInitiateTxResponse) XXX_Merge ¶
func (m *MsgInitiateTxResponse) XXX_Merge(src proto.Message)
func (*MsgInitiateTxResponse) XXX_Size ¶
func (m *MsgInitiateTxResponse) XXX_Size() int
func (*MsgInitiateTxResponse) XXX_Unmarshal ¶
func (m *MsgInitiateTxResponse) XXX_Unmarshal(b []byte) error
type MsgServer ¶
type MsgServer interface { // InitiateTx defines a rpc handler method for MsgInitiateTx. InitiateTx(context.Context, *MsgInitiateTx) (*MsgInitiateTxResponse, error) }
MsgServer is the server API for Msg service.
type PortKeeper ¶
type PortKeeper interface {
BindPort(ctx sdk.Context, portID string) *capabilitytypes.Capability
}
PortKeeper defines the expected IBC port keeper
type QueryClient ¶
type QueryClient interface {
SelfXCC(ctx context.Context, in *QuerySelfXCCRequest, opts ...grpc.CallOption) (*QuerySelfXCCResponse, error)
}
QueryClient is the client API for Query service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewQueryClient ¶
func NewQueryClient(cc grpc1.ClientConn) QueryClient
type QuerySelfXCCRequest ¶
type QuerySelfXCCRequest struct { }
func (*QuerySelfXCCRequest) Descriptor ¶
func (*QuerySelfXCCRequest) Descriptor() ([]byte, []int)
func (*QuerySelfXCCRequest) Marshal ¶
func (m *QuerySelfXCCRequest) Marshal() (dAtA []byte, err error)
func (*QuerySelfXCCRequest) MarshalTo ¶
func (m *QuerySelfXCCRequest) MarshalTo(dAtA []byte) (int, error)
func (*QuerySelfXCCRequest) MarshalToSizedBuffer ¶
func (m *QuerySelfXCCRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QuerySelfXCCRequest) ProtoMessage ¶
func (*QuerySelfXCCRequest) ProtoMessage()
func (*QuerySelfXCCRequest) Reset ¶
func (m *QuerySelfXCCRequest) Reset()
func (*QuerySelfXCCRequest) Size ¶
func (m *QuerySelfXCCRequest) Size() (n int)
func (*QuerySelfXCCRequest) String ¶
func (m *QuerySelfXCCRequest) String() string
func (*QuerySelfXCCRequest) Unmarshal ¶
func (m *QuerySelfXCCRequest) Unmarshal(dAtA []byte) error
func (*QuerySelfXCCRequest) XXX_DiscardUnknown ¶
func (m *QuerySelfXCCRequest) XXX_DiscardUnknown()
func (*QuerySelfXCCRequest) XXX_Marshal ¶
func (m *QuerySelfXCCRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QuerySelfXCCRequest) XXX_Merge ¶
func (m *QuerySelfXCCRequest) XXX_Merge(src proto.Message)
func (*QuerySelfXCCRequest) XXX_Size ¶
func (m *QuerySelfXCCRequest) XXX_Size() int
func (*QuerySelfXCCRequest) XXX_Unmarshal ¶
func (m *QuerySelfXCCRequest) XXX_Unmarshal(b []byte) error
type QuerySelfXCCResponse ¶
type QuerySelfXCCResponse struct {
Xcc *types.Any `protobuf:"bytes,1,opt,name=xcc,proto3" json:"xcc,omitempty"`
}
func (*QuerySelfXCCResponse) Descriptor ¶
func (*QuerySelfXCCResponse) Descriptor() ([]byte, []int)
func (*QuerySelfXCCResponse) GetXcc ¶
func (m *QuerySelfXCCResponse) GetXcc() *types.Any
func (*QuerySelfXCCResponse) Marshal ¶
func (m *QuerySelfXCCResponse) Marshal() (dAtA []byte, err error)
func (*QuerySelfXCCResponse) MarshalTo ¶
func (m *QuerySelfXCCResponse) MarshalTo(dAtA []byte) (int, error)
func (*QuerySelfXCCResponse) MarshalToSizedBuffer ¶
func (m *QuerySelfXCCResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QuerySelfXCCResponse) ProtoMessage ¶
func (*QuerySelfXCCResponse) ProtoMessage()
func (*QuerySelfXCCResponse) Reset ¶
func (m *QuerySelfXCCResponse) Reset()
func (*QuerySelfXCCResponse) Size ¶
func (m *QuerySelfXCCResponse) Size() (n int)
func (*QuerySelfXCCResponse) String ¶
func (m *QuerySelfXCCResponse) String() string
func (*QuerySelfXCCResponse) Unmarshal ¶
func (m *QuerySelfXCCResponse) Unmarshal(dAtA []byte) error
func (*QuerySelfXCCResponse) XXX_DiscardUnknown ¶
func (m *QuerySelfXCCResponse) XXX_DiscardUnknown()
func (*QuerySelfXCCResponse) XXX_Marshal ¶
func (m *QuerySelfXCCResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QuerySelfXCCResponse) XXX_Merge ¶
func (m *QuerySelfXCCResponse) XXX_Merge(src proto.Message)
func (*QuerySelfXCCResponse) XXX_Size ¶
func (m *QuerySelfXCCResponse) XXX_Size() int
func (*QuerySelfXCCResponse) XXX_Unmarshal ¶
func (m *QuerySelfXCCResponse) XXX_Unmarshal(b []byte) error
type QueryServer ¶
type QueryServer interface {
SelfXCC(context.Context, *QuerySelfXCCRequest) (*QuerySelfXCCResponse, error)
}
QueryServer is the server API for Query service.
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct { }
UnimplementedMsgServer can be embedded to have forward compatible implementations.
func (*UnimplementedMsgServer) InitiateTx ¶
func (*UnimplementedMsgServer) InitiateTx(ctx context.Context, req *MsgInitiateTx) (*MsgInitiateTxResponse, error)
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct { }
UnimplementedQueryServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryServer) SelfXCC ¶
func (*UnimplementedQueryServer) SelfXCC(ctx context.Context, req *QuerySelfXCCRequest) (*QuerySelfXCCResponse, error)