Documentation ¶
Index ¶
- Variables
- func ComputeMessageIdFromDstTransfer(dstTransferId []byte, dstBridgeAddr eth.Addr) []byte
- func RegisterQueryServer(s grpc1.Server, srv QueryServer)
- type BridgeType
- type EmptyRequest
- func (*EmptyRequest) Descriptor() ([]byte, []int)
- func (m *EmptyRequest) Marshal() (dAtA []byte, err error)
- func (m *EmptyRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *EmptyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EmptyRequest) ProtoMessage()
- func (m *EmptyRequest) Reset()
- func (m *EmptyRequest) Size() (n int)
- func (m *EmptyRequest) String() string
- func (m *EmptyRequest) Unmarshal(dAtA []byte) error
- func (m *EmptyRequest) XXX_DiscardUnknown()
- func (m *EmptyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EmptyRequest) XXX_Merge(src proto.Message)
- func (m *EmptyRequest) XXX_Size() int
- func (m *EmptyRequest) XXX_Unmarshal(b []byte) error
- type ExecutionContext
- func NewMsgPegBurnRefundExecutionContext(ev *eth.MessageBusMessageWithTransfer, mintOnChain pegbrtypes.MintOnChain, ...) *ExecutionContext
- func NewMsgPegDepositRefundExecutionContext(ev *eth.MessageBusMessageWithTransfer, wdOnChain pegbrtypes.WithdrawOnChain, ...) *ExecutionContext
- func NewMsgXferExecutionContext(ev *eth.MessageBusMessageWithTransfer, chainId uint64, dstToken eth.Addr, ...) *ExecutionContext
- func NewMsgXferRefundExecutionContext(ev *eth.MessageBusMessageWithTransfer, wdOnchain *cbrtypes.WithdrawOnchain, ...) *ExecutionContext
- func (c *ExecutionContext) ComputeDstTransferId(dstBridgeAddr eth.Addr) []byte
- func (c *ExecutionContext) ComputeMessageId(bridgeAddr eth.Addr) []byte
- func (c *ExecutionContext) ComputeMessageIdWithTransfer(dstBridgeAddr eth.Addr) []byte
- func (*ExecutionContext) Descriptor() ([]byte, []int)
- func (m *ExecutionContext) GetMessage() Message
- func (m *ExecutionContext) GetMessageId() []byte
- func (m *ExecutionContext) GetTransfer() *Transfer
- func (m *ExecutionContext) Marshal() (dAtA []byte, err error)
- func (m *ExecutionContext) MarshalTo(dAtA []byte) (int, error)
- func (m *ExecutionContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (c *ExecutionContext) MustMarshal() []byte
- func (c *ExecutionContext) PrettyPrint()
- func (*ExecutionContext) ProtoMessage()
- func (m *ExecutionContext) Reset()
- func (m *ExecutionContext) Size() (n int)
- func (m *ExecutionContext) String() string
- func (m *ExecutionContext) Unmarshal(dAtA []byte) error
- func (m *ExecutionContext) XXX_DiscardUnknown()
- func (m *ExecutionContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecutionContext) XXX_Merge(src proto.Message)
- func (m *ExecutionContext) XXX_Size() int
- func (m *ExecutionContext) XXX_Unmarshal(b []byte) error
- type ExecutionStatus
- type FeeClaimDetails
- func (*FeeClaimDetails) Descriptor() ([]byte, []int)
- func (m *FeeClaimDetails) GetChainId() uint64
- func (m *FeeClaimDetails) GetCumulativeFeeAmount() types1.DecCoin
- func (m *FeeClaimDetails) GetSignatures() []types.Signature
- func (m *FeeClaimDetails) Marshal() (dAtA []byte, err error)
- func (m *FeeClaimDetails) MarshalTo(dAtA []byte) (int, error)
- func (m *FeeClaimDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FeeClaimDetails) ProtoMessage()
- func (m *FeeClaimDetails) Reset()
- func (m *FeeClaimDetails) Size() (n int)
- func (m *FeeClaimDetails) String() string
- func (m *FeeClaimDetails) Unmarshal(dAtA []byte) error
- func (m *FeeClaimDetails) XXX_DiscardUnknown()
- func (m *FeeClaimDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FeeClaimDetails) XXX_Merge(src proto.Message)
- func (m *FeeClaimDetails) XXX_Size() int
- func (m *FeeClaimDetails) XXX_Unmarshal(b []byte) error
- type FeeClaimInfo
- func (*FeeClaimInfo) Descriptor() ([]byte, []int)
- func (m *FeeClaimInfo) GetFeeClaimDetailsList() []FeeClaimDetails
- func (m *FeeClaimInfo) GetLastClaimTime() time.Time
- func (m *FeeClaimInfo) GetRecipient() string
- func (m *FeeClaimInfo) Marshal() (dAtA []byte, err error)
- func (m *FeeClaimInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *FeeClaimInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FeeClaimInfo) ProtoMessage()
- func (m *FeeClaimInfo) Reset()
- func (m *FeeClaimInfo) Size() (n int)
- func (m *FeeClaimInfo) String() string
- func (m *FeeClaimInfo) Unmarshal(dAtA []byte) error
- func (m *FeeClaimInfo) XXX_DiscardUnknown()
- func (m *FeeClaimInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FeeClaimInfo) XXX_Merge(src proto.Message)
- func (m *FeeClaimInfo) XXX_Size() int
- func (m *FeeClaimInfo) XXX_Unmarshal(b []byte) error
- type FeeSplit
- func (*FeeSplit) Descriptor() ([]byte, []int)
- func (m *FeeSplit) GetCelerTreasuryAddr() string
- func (m *FeeSplit) GetCelerTreasuryFeePerc() uint32
- func (m *FeeSplit) Marshal() (dAtA []byte, err error)
- func (m *FeeSplit) MarshalTo(dAtA []byte) (int, error)
- func (m *FeeSplit) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FeeSplit) ProtoMessage()
- func (m *FeeSplit) Reset()
- func (m *FeeSplit) Size() (n int)
- func (m *FeeSplit) String() string
- func (m *FeeSplit) Unmarshal(dAtA []byte) error
- func (m *FeeSplit) XXX_DiscardUnknown()
- func (m *FeeSplit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FeeSplit) XXX_Merge(src proto.Message)
- func (m *FeeSplit) XXX_Size() int
- func (m *FeeSplit) XXX_Unmarshal(b []byte) error
- type InputData
- type InputDataRoute
- type IsMessageActiveRequest
- func (*IsMessageActiveRequest) Descriptor() ([]byte, []int)
- func (m *IsMessageActiveRequest) GetMessageId() string
- func (m *IsMessageActiveRequest) Marshal() (dAtA []byte, err error)
- func (m *IsMessageActiveRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *IsMessageActiveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IsMessageActiveRequest) ProtoMessage()
- func (m *IsMessageActiveRequest) Reset()
- func (m *IsMessageActiveRequest) Size() (n int)
- func (m *IsMessageActiveRequest) String() string
- func (m *IsMessageActiveRequest) Unmarshal(dAtA []byte) error
- func (m *IsMessageActiveRequest) XXX_DiscardUnknown()
- func (m *IsMessageActiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IsMessageActiveRequest) XXX_Merge(src proto.Message)
- func (m *IsMessageActiveRequest) XXX_Size() int
- func (m *IsMessageActiveRequest) XXX_Unmarshal(b []byte) error
- type IsMessageActiveResponse
- func (*IsMessageActiveResponse) Descriptor() ([]byte, []int)
- func (m *IsMessageActiveResponse) GetExists() bool
- func (m *IsMessageActiveResponse) Marshal() (dAtA []byte, err error)
- func (m *IsMessageActiveResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *IsMessageActiveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IsMessageActiveResponse) ProtoMessage()
- func (m *IsMessageActiveResponse) Reset()
- func (m *IsMessageActiveResponse) Size() (n int)
- func (m *IsMessageActiveResponse) String() string
- func (m *IsMessageActiveResponse) Unmarshal(dAtA []byte) error
- func (m *IsMessageActiveResponse) XXX_DiscardUnknown()
- func (m *IsMessageActiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IsMessageActiveResponse) XXX_Merge(src proto.Message)
- func (m *IsMessageActiveResponse) XXX_Size() int
- func (m *IsMessageActiveResponse) XXX_Unmarshal(b []byte) error
- type Message
- func (m *Message) ComputeMessageIdNoTransfer() []byte
- func (m *Message) ComputeProxyChainMessageIdNoTransfer() []byte
- func (*Message) Descriptor() ([]byte, []int)
- func (m *Message) GetData() []byte
- func (m *Message) GetDstChainId() uint64
- func (m *Message) GetExecutionStatus() ExecutionStatus
- func (m *Message) GetFee() string
- func (m *Message) GetIsBytesAddr() bool
- func (m *Message) GetLastReqTime() int64
- func (m *Message) GetReceiver() string
- func (m *Message) GetSender() string
- func (m *Message) GetSignatures() []types.Signature
- func (m *Message) GetSrcChainId() uint64
- func (m *Message) GetSrcTxHash() string
- func (m *Message) GetTransferRefId() []byte
- func (m *Message) GetTransferType() TransferType
- func (m *Message) Marshal() (dAtA []byte, err error)
- func (m *Message) MarshalTo(dAtA []byte) (int, error)
- func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Message) PrettyLog() string
- func (m *Message) PrettyPrint()
- func (*Message) ProtoMessage()
- func (m *Message) Reset()
- func (m *Message) Size() (n int)
- func (m *Message) String() string
- func (m *Message) Unmarshal(dAtA []byte) error
- func (m *Message) XXX_DiscardUnknown()
- func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Message) XXX_Merge(src proto.Message)
- func (m *Message) XXX_Size() int
- func (m *Message) XXX_Unmarshal(b []byte) error
- type MessageBusInfo
- func (*MessageBusInfo) Descriptor() ([]byte, []int)
- func (m *MessageBusInfo) GetContractInfo() *types.ContractInfo
- func (m *MessageBusInfo) GetFeeSplitOverride() *FeeSplit
- func (m *MessageBusInfo) GetFeeTokenSymbol() string
- func (m *MessageBusInfo) Marshal() (dAtA []byte, err error)
- func (m *MessageBusInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *MessageBusInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MessageBusInfo) ProtoMessage()
- func (m *MessageBusInfo) Reset()
- func (m *MessageBusInfo) Size() (n int)
- func (m *MessageBusInfo) String() string
- func (m *MessageBusInfo) Unmarshal(dAtA []byte) error
- func (m *MessageBusInfo) XXX_DiscardUnknown()
- func (m *MessageBusInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MessageBusInfo) XXX_Merge(src proto.Message)
- func (m *MessageBusInfo) XXX_Size() int
- func (m *MessageBusInfo) XXX_Unmarshal(b []byte) error
- type MsgProposal
- func (*MsgProposal) Descriptor() ([]byte, []int)
- func (m *MsgProposal) GetDescription() string
- func (m *MsgProposal) GetFeeSplitGlobal() *FeeSplit
- func (m *MsgProposal) GetMessageBuses() []*MessageBusInfo
- func (m *MsgProposal) GetTitle() string
- func (m *MsgProposal) Marshal() (dAtA []byte, err error)
- func (m *MsgProposal) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgProposal) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgProposal) ProtoMessage()
- func (m *MsgProposal) Reset()
- func (m *MsgProposal) Size() (n int)
- func (m *MsgProposal) String() string
- func (m *MsgProposal) Unmarshal(dAtA []byte) error
- func (m *MsgProposal) XXX_DiscardUnknown()
- func (m *MsgProposal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgProposal) XXX_Merge(src proto.Message)
- func (m *MsgProposal) XXX_Size() int
- func (m *MsgProposal) XXX_Unmarshal(b []byte) error
- type MsgType
- type Params
- func (*Params) Descriptor() ([]byte, []int)
- func (m *Params) GetMessageExpiredTime() time.Duration
- func (m *Params) GetTriggerSignCooldown() time.Duration
- func (m *Params) Marshal() (dAtA []byte, err error)
- func (m *Params) MarshalTo(dAtA []byte) (int, error)
- func (m *Params) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Params) ProtoMessage()
- func (m *Params) Reset()
- func (m *Params) Size() (n int)
- func (p Params) String() string
- func (m *Params) Unmarshal(dAtA []byte) error
- func (m *Params) XXX_DiscardUnknown()
- func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Params) XXX_Merge(src proto.Message)
- func (m *Params) XXX_Size() int
- func (m *Params) XXX_Unmarshal(b []byte) error
- type QueryClient
- type QueryExecutionContextByMsgIdRequest
- func (*QueryExecutionContextByMsgIdRequest) Descriptor() ([]byte, []int)
- func (m *QueryExecutionContextByMsgIdRequest) GetIgnoreSigs() bool
- func (m *QueryExecutionContextByMsgIdRequest) GetMessageId() string
- func (m *QueryExecutionContextByMsgIdRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryExecutionContextByMsgIdRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryExecutionContextByMsgIdRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryExecutionContextByMsgIdRequest) ProtoMessage()
- func (m *QueryExecutionContextByMsgIdRequest) Reset()
- func (m *QueryExecutionContextByMsgIdRequest) Size() (n int)
- func (m *QueryExecutionContextByMsgIdRequest) String() string
- func (m *QueryExecutionContextByMsgIdRequest) Unmarshal(dAtA []byte) error
- func (m *QueryExecutionContextByMsgIdRequest) XXX_DiscardUnknown()
- func (m *QueryExecutionContextByMsgIdRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryExecutionContextByMsgIdRequest) XXX_Merge(src proto.Message)
- func (m *QueryExecutionContextByMsgIdRequest) XXX_Size() int
- func (m *QueryExecutionContextByMsgIdRequest) XXX_Unmarshal(b []byte) error
- type QueryExecutionContextByMsgIdResponse
- func (*QueryExecutionContextByMsgIdResponse) Descriptor() ([]byte, []int)
- func (m *QueryExecutionContextByMsgIdResponse) GetChainSigners() *types1.ChainSigners
- func (m *QueryExecutionContextByMsgIdResponse) GetEnoughSigs() [][]byte
- func (m *QueryExecutionContextByMsgIdResponse) GetExecutionContext() *ExecutionContext
- func (m *QueryExecutionContextByMsgIdResponse) GetHasEnoughSigs() bool
- func (m *QueryExecutionContextByMsgIdResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryExecutionContextByMsgIdResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryExecutionContextByMsgIdResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryExecutionContextByMsgIdResponse) ProtoMessage()
- func (m *QueryExecutionContextByMsgIdResponse) Reset()
- func (m *QueryExecutionContextByMsgIdResponse) Size() (n int)
- func (m *QueryExecutionContextByMsgIdResponse) String() string
- func (m *QueryExecutionContextByMsgIdResponse) Unmarshal(dAtA []byte) error
- func (m *QueryExecutionContextByMsgIdResponse) XXX_DiscardUnknown()
- func (m *QueryExecutionContextByMsgIdResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryExecutionContextByMsgIdResponse) XXX_Merge(src proto.Message)
- func (m *QueryExecutionContextByMsgIdResponse) XXX_Size() int
- func (m *QueryExecutionContextByMsgIdResponse) XXX_Unmarshal(b []byte) error
- type QueryExecutionContextBySrcTransferRequest
- func (*QueryExecutionContextBySrcTransferRequest) Descriptor() ([]byte, []int)
- func (m *QueryExecutionContextBySrcTransferRequest) GetCheckSigs() bool
- func (m *QueryExecutionContextBySrcTransferRequest) GetMessageIdOnly() bool
- func (m *QueryExecutionContextBySrcTransferRequest) GetSrcBridgeType() BridgeType
- func (m *QueryExecutionContextBySrcTransferRequest) GetSrcTransferId() string
- func (m *QueryExecutionContextBySrcTransferRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryExecutionContextBySrcTransferRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryExecutionContextBySrcTransferRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryExecutionContextBySrcTransferRequest) ProtoMessage()
- func (m *QueryExecutionContextBySrcTransferRequest) Reset()
- func (m *QueryExecutionContextBySrcTransferRequest) Size() (n int)
- func (m *QueryExecutionContextBySrcTransferRequest) String() string
- func (m *QueryExecutionContextBySrcTransferRequest) Unmarshal(dAtA []byte) error
- func (m *QueryExecutionContextBySrcTransferRequest) XXX_DiscardUnknown()
- func (m *QueryExecutionContextBySrcTransferRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryExecutionContextBySrcTransferRequest) XXX_Merge(src proto.Message)
- func (m *QueryExecutionContextBySrcTransferRequest) XXX_Size() int
- func (m *QueryExecutionContextBySrcTransferRequest) XXX_Unmarshal(b []byte) error
- type QueryExecutionContextBySrcTransferResponse
- func (*QueryExecutionContextBySrcTransferResponse) Descriptor() ([]byte, []int)
- func (m *QueryExecutionContextBySrcTransferResponse) GetExecutionContext() *ExecutionContext
- func (m *QueryExecutionContextBySrcTransferResponse) GetHasEnoughSigs() bool
- func (m *QueryExecutionContextBySrcTransferResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryExecutionContextBySrcTransferResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryExecutionContextBySrcTransferResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryExecutionContextBySrcTransferResponse) ProtoMessage()
- func (m *QueryExecutionContextBySrcTransferResponse) Reset()
- func (m *QueryExecutionContextBySrcTransferResponse) Size() (n int)
- func (m *QueryExecutionContextBySrcTransferResponse) String() string
- func (m *QueryExecutionContextBySrcTransferResponse) Unmarshal(dAtA []byte) error
- func (m *QueryExecutionContextBySrcTransferResponse) XXX_DiscardUnknown()
- func (m *QueryExecutionContextBySrcTransferResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryExecutionContextBySrcTransferResponse) XXX_Merge(src proto.Message)
- func (m *QueryExecutionContextBySrcTransferResponse) XXX_Size() int
- func (m *QueryExecutionContextBySrcTransferResponse) XXX_Unmarshal(b []byte) error
- type QueryExecutionContextsRequest
- func (*QueryExecutionContextsRequest) Descriptor() ([]byte, []int)
- func (m *QueryExecutionContextsRequest) GetAll() bool
- func (m *QueryExecutionContextsRequest) GetContractInfos() []*types.ContractInfo
- func (m *QueryExecutionContextsRequest) GetIgnoreRefundSigs() bool
- func (m *QueryExecutionContextsRequest) GetPagination() *query.PageRequest
- func (m *QueryExecutionContextsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryExecutionContextsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryExecutionContextsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryExecutionContextsRequest) ProtoMessage()
- func (m *QueryExecutionContextsRequest) Reset()
- func (m *QueryExecutionContextsRequest) Size() (n int)
- func (m *QueryExecutionContextsRequest) String() string
- func (m *QueryExecutionContextsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryExecutionContextsRequest) XXX_DiscardUnknown()
- func (m *QueryExecutionContextsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryExecutionContextsRequest) XXX_Merge(src proto.Message)
- func (m *QueryExecutionContextsRequest) XXX_Size() int
- func (m *QueryExecutionContextsRequest) XXX_Unmarshal(b []byte) error
- type QueryExecutionContextsResponse
- func (*QueryExecutionContextsResponse) Descriptor() ([]byte, []int)
- func (m *QueryExecutionContextsResponse) GetExecutionContexts() []ExecutionContext
- func (m *QueryExecutionContextsResponse) GetPagination() *query.PageResponse
- func (m *QueryExecutionContextsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryExecutionContextsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryExecutionContextsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryExecutionContextsResponse) ProtoMessage()
- func (m *QueryExecutionContextsResponse) Reset()
- func (m *QueryExecutionContextsResponse) Size() (n int)
- func (m *QueryExecutionContextsResponse) String() string
- func (m *QueryExecutionContextsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryExecutionContextsResponse) XXX_DiscardUnknown()
- func (m *QueryExecutionContextsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryExecutionContextsResponse) XXX_Merge(src proto.Message)
- func (m *QueryExecutionContextsResponse) XXX_Size() int
- func (m *QueryExecutionContextsResponse) XXX_Unmarshal(b []byte) error
- type QueryFeeClaimInfoRequest
- func (*QueryFeeClaimInfoRequest) Descriptor() ([]byte, []int)
- func (m *QueryFeeClaimInfoRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryFeeClaimInfoRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryFeeClaimInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryFeeClaimInfoRequest) ProtoMessage()
- func (m *QueryFeeClaimInfoRequest) Reset()
- func (m *QueryFeeClaimInfoRequest) Size() (n int)
- func (m *QueryFeeClaimInfoRequest) String() string
- func (m *QueryFeeClaimInfoRequest) Unmarshal(dAtA []byte) error
- func (m *QueryFeeClaimInfoRequest) XXX_DiscardUnknown()
- func (m *QueryFeeClaimInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryFeeClaimInfoRequest) XXX_Merge(src proto.Message)
- func (m *QueryFeeClaimInfoRequest) XXX_Size() int
- func (m *QueryFeeClaimInfoRequest) XXX_Unmarshal(b []byte) error
- type QueryFeeClaimInfoResponse
- func (*QueryFeeClaimInfoResponse) Descriptor() ([]byte, []int)
- func (m *QueryFeeClaimInfoResponse) GetFeeClaimInfo() FeeClaimInfo
- func (m *QueryFeeClaimInfoResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryFeeClaimInfoResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryFeeClaimInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryFeeClaimInfoResponse) ProtoMessage()
- func (m *QueryFeeClaimInfoResponse) Reset()
- func (m *QueryFeeClaimInfoResponse) Size() (n int)
- func (m *QueryFeeClaimInfoResponse) String() string
- func (m *QueryFeeClaimInfoResponse) Unmarshal(dAtA []byte) error
- func (m *QueryFeeClaimInfoResponse) XXX_DiscardUnknown()
- func (m *QueryFeeClaimInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryFeeClaimInfoResponse) XXX_Merge(src proto.Message)
- func (m *QueryFeeClaimInfoResponse) XXX_Size() int
- func (m *QueryFeeClaimInfoResponse) XXX_Unmarshal(b []byte) error
- type QueryFeeSplitGlobalResponse
- func (*QueryFeeSplitGlobalResponse) Descriptor() ([]byte, []int)
- func (m *QueryFeeSplitGlobalResponse) GetFeeSplit() *FeeSplit
- func (m *QueryFeeSplitGlobalResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryFeeSplitGlobalResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryFeeSplitGlobalResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryFeeSplitGlobalResponse) ProtoMessage()
- func (m *QueryFeeSplitGlobalResponse) Reset()
- func (m *QueryFeeSplitGlobalResponse) Size() (n int)
- func (m *QueryFeeSplitGlobalResponse) String() string
- func (m *QueryFeeSplitGlobalResponse) Unmarshal(dAtA []byte) error
- func (m *QueryFeeSplitGlobalResponse) XXX_DiscardUnknown()
- func (m *QueryFeeSplitGlobalResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryFeeSplitGlobalResponse) XXX_Merge(src proto.Message)
- func (m *QueryFeeSplitGlobalResponse) XXX_Size() int
- func (m *QueryFeeSplitGlobalResponse) XXX_Unmarshal(b []byte) error
- type QueryMessageBusRequest
- func (*QueryMessageBusRequest) Descriptor() ([]byte, []int)
- func (m *QueryMessageBusRequest) GetChainId() uint64
- func (m *QueryMessageBusRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryMessageBusRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryMessageBusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryMessageBusRequest) ProtoMessage()
- func (m *QueryMessageBusRequest) Reset()
- func (m *QueryMessageBusRequest) Size() (n int)
- func (m *QueryMessageBusRequest) String() string
- func (m *QueryMessageBusRequest) Unmarshal(dAtA []byte) error
- func (m *QueryMessageBusRequest) XXX_DiscardUnknown()
- func (m *QueryMessageBusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryMessageBusRequest) XXX_Merge(src proto.Message)
- func (m *QueryMessageBusRequest) XXX_Size() int
- func (m *QueryMessageBusRequest) XXX_Unmarshal(b []byte) error
- type QueryMessageBusResponse
- func (*QueryMessageBusResponse) Descriptor() ([]byte, []int)
- func (m *QueryMessageBusResponse) GetMessageBus() MessageBusInfo
- func (m *QueryMessageBusResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryMessageBusResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryMessageBusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryMessageBusResponse) ProtoMessage()
- func (m *QueryMessageBusResponse) Reset()
- func (m *QueryMessageBusResponse) Size() (n int)
- func (m *QueryMessageBusResponse) String() string
- func (m *QueryMessageBusResponse) Unmarshal(dAtA []byte) error
- func (m *QueryMessageBusResponse) XXX_DiscardUnknown()
- func (m *QueryMessageBusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryMessageBusResponse) XXX_Merge(src proto.Message)
- func (m *QueryMessageBusResponse) XXX_Size() int
- func (m *QueryMessageBusResponse) XXX_Unmarshal(b []byte) error
- type QueryMessageExistsRequest
- func (*QueryMessageExistsRequest) Descriptor() ([]byte, []int)
- func (m *QueryMessageExistsRequest) GetMessageId() string
- func (m *QueryMessageExistsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryMessageExistsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryMessageExistsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryMessageExistsRequest) ProtoMessage()
- func (m *QueryMessageExistsRequest) Reset()
- func (m *QueryMessageExistsRequest) Size() (n int)
- func (m *QueryMessageExistsRequest) String() string
- func (m *QueryMessageExistsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryMessageExistsRequest) XXX_DiscardUnknown()
- func (m *QueryMessageExistsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryMessageExistsRequest) XXX_Merge(src proto.Message)
- func (m *QueryMessageExistsRequest) XXX_Size() int
- func (m *QueryMessageExistsRequest) XXX_Unmarshal(b []byte) error
- type QueryMessageExistsResponse
- func (*QueryMessageExistsResponse) Descriptor() ([]byte, []int)
- func (m *QueryMessageExistsResponse) GetExists() bool
- func (m *QueryMessageExistsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryMessageExistsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryMessageExistsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryMessageExistsResponse) ProtoMessage()
- func (m *QueryMessageExistsResponse) Reset()
- func (m *QueryMessageExistsResponse) Size() (n int)
- func (m *QueryMessageExistsResponse) String() string
- func (m *QueryMessageExistsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryMessageExistsResponse) XXX_DiscardUnknown()
- func (m *QueryMessageExistsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryMessageExistsResponse) XXX_Merge(src proto.Message)
- func (m *QueryMessageExistsResponse) XXX_Size() int
- func (m *QueryMessageExistsResponse) XXX_Unmarshal(b []byte) error
- type QueryMessageRequest
- func (*QueryMessageRequest) Descriptor() ([]byte, []int)
- func (m *QueryMessageRequest) GetMessageId() string
- func (m *QueryMessageRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryMessageRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryMessageRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryMessageRequest) ProtoMessage()
- func (m *QueryMessageRequest) Reset()
- func (m *QueryMessageRequest) Size() (n int)
- func (m *QueryMessageRequest) String() string
- func (m *QueryMessageRequest) Unmarshal(dAtA []byte) error
- func (m *QueryMessageRequest) XXX_DiscardUnknown()
- func (m *QueryMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryMessageRequest) XXX_Merge(src proto.Message)
- func (m *QueryMessageRequest) XXX_Size() int
- func (m *QueryMessageRequest) XXX_Unmarshal(b []byte) error
- type QueryMessageResponse
- func (*QueryMessageResponse) Descriptor() ([]byte, []int)
- func (m *QueryMessageResponse) GetMessage() Message
- func (m *QueryMessageResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryMessageResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryMessageResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryMessageResponse) ProtoMessage()
- func (m *QueryMessageResponse) Reset()
- func (m *QueryMessageResponse) Size() (n int)
- func (m *QueryMessageResponse) String() string
- func (m *QueryMessageResponse) Unmarshal(dAtA []byte) error
- func (m *QueryMessageResponse) XXX_DiscardUnknown()
- func (m *QueryMessageResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryMessageResponse) XXX_Merge(src proto.Message)
- func (m *QueryMessageResponse) XXX_Size() int
- func (m *QueryMessageResponse) XXX_Unmarshal(b []byte) error
- type QueryParamsRequest
- func (*QueryParamsRequest) Descriptor() ([]byte, []int)
- func (m *QueryParamsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryParamsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryParamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryParamsRequest) ProtoMessage()
- func (m *QueryParamsRequest) Reset()
- func (m *QueryParamsRequest) Size() (n int)
- func (m *QueryParamsRequest) String() string
- func (m *QueryParamsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryParamsRequest) XXX_DiscardUnknown()
- func (m *QueryParamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryParamsRequest) XXX_Merge(src proto.Message)
- func (m *QueryParamsRequest) XXX_Size() int
- func (m *QueryParamsRequest) XXX_Unmarshal(b []byte) error
- type QueryParamsResponse
- func (*QueryParamsResponse) Descriptor() ([]byte, []int)
- func (m *QueryParamsResponse) GetParams() Params
- func (m *QueryParamsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryParamsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryParamsResponse) ProtoMessage()
- func (m *QueryParamsResponse) Reset()
- func (m *QueryParamsResponse) Size() (n int)
- func (m *QueryParamsResponse) String() string
- func (m *QueryParamsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryParamsResponse) XXX_DiscardUnknown()
- func (m *QueryParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryParamsResponse) XXX_Merge(src proto.Message)
- func (m *QueryParamsResponse) XXX_Size() int
- func (m *QueryParamsResponse) XXX_Unmarshal(b []byte) error
- type QueryServer
- type Transfer
- func (*Transfer) Descriptor() ([]byte, []int)
- func (m *Transfer) GetAmount() string
- func (m *Transfer) GetToken() []byte
- func (m *Transfer) GetWdSeqNum() uint64
- func (m *Transfer) Marshal() (dAtA []byte, err error)
- func (m *Transfer) MarshalTo(dAtA []byte) (int, error)
- func (m *Transfer) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Transfer) ProtoMessage()
- func (m *Transfer) Reset()
- func (m *Transfer) Size() (n int)
- func (m *Transfer) String() string
- func (m *Transfer) Unmarshal(dAtA []byte) error
- func (m *Transfer) XXX_DiscardUnknown()
- func (m *Transfer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Transfer) XXX_Merge(src proto.Message)
- func (m *Transfer) XXX_Size() int
- func (m *Transfer) XXX_Unmarshal(b []byte) error
- type TransferType
- type UnimplementedQueryServer
- func (*UnimplementedQueryServer) ExecutionContextByMsgId(ctx context.Context, req *QueryExecutionContextByMsgIdRequest) (*QueryExecutionContextByMsgIdResponse, error)
- func (*UnimplementedQueryServer) ExecutionContextBySrcTransfer(ctx context.Context, req *QueryExecutionContextBySrcTransferRequest) (*QueryExecutionContextBySrcTransferResponse, error)
- func (*UnimplementedQueryServer) ExecutionContexts(ctx context.Context, req *QueryExecutionContextsRequest) (*QueryExecutionContextsResponse, error)
- func (*UnimplementedQueryServer) FeeClaimInfo(ctx context.Context, req *QueryFeeClaimInfoRequest) (*QueryFeeClaimInfoResponse, error)
- func (*UnimplementedQueryServer) FeeSplitGlobal(ctx context.Context, req *EmptyRequest) (*QueryFeeSplitGlobalResponse, error)
- func (*UnimplementedQueryServer) IsMessageActive(ctx context.Context, req *IsMessageActiveRequest) (*IsMessageActiveResponse, error)
- func (*UnimplementedQueryServer) Message(ctx context.Context, req *QueryMessageRequest) (*QueryMessageResponse, error)
- func (*UnimplementedQueryServer) MessageBus(ctx context.Context, req *QueryMessageBusRequest) (*QueryMessageBusResponse, error)
- func (*UnimplementedQueryServer) MessageExists(ctx context.Context, req *QueryMessageExistsRequest) (*QueryMessageExistsResponse, error)
- func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthMessage = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMessage = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupMessage = 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 BridgeType_name = map[int32]string{
0: "BRIDGE_TYPE_NULL",
1: "BRIDGE_TYPE_LIQUIDITY",
2: "BRIDGE_TYPE_PEG_VAULT",
3: "BRIDGE_TYPE_PEG_BRIDGE",
}
var BridgeType_value = map[string]int32{
"BRIDGE_TYPE_NULL": 0,
"BRIDGE_TYPE_LIQUIDITY": 1,
"BRIDGE_TYPE_PEG_VAULT": 2,
"BRIDGE_TYPE_PEG_BRIDGE": 3,
}
var ExecutionStatus_name = map[int32]string{
0: "EXECUTION_STATUS_NULL",
1: "EXECUTION_STATUS_SUCCESS",
2: "EXECUTION_STATUS_FAILURE",
3: "EXECUTION_STATUS_FALLBACK",
}
var ExecutionStatus_value = map[string]int32{
"EXECUTION_STATUS_NULL": 0,
"EXECUTION_STATUS_SUCCESS": 1,
"EXECUTION_STATUS_FAILURE": 2,
"EXECUTION_STATUS_FALLBACK": 3,
}
var MsgType_name = map[int32]string{
0: "MSG_TYPE_MESSAGE_WITH_TRANSFER",
1: "MSG_TYPE_MESSAGE",
}
var MsgType_value = map[string]int32{
"MSG_TYPE_MESSAGE_WITH_TRANSFER": 0,
"MSG_TYPE_MESSAGE": 1,
}
var TransferType_name = map[int32]string{
0: "TRANSFER_TYPE_NULL",
1: "TRANSFER_TYPE_LIQUIDITY_RELAY",
2: "TRANSFER_TYPE_LIQUIDITY_WITHDRAW",
3: "TRANSFER_TYPE_PEG_MINT",
4: "TRANSFER_TYPE_PEG_WITHDRAW",
5: "TRANSFER_TYPE_PEG_V2_MINT",
6: "TRANSFER_TYPE_PEG_V2_WITHDRAW",
}
var TransferType_value = map[string]int32{
"TRANSFER_TYPE_NULL": 0,
"TRANSFER_TYPE_LIQUIDITY_RELAY": 1,
"TRANSFER_TYPE_LIQUIDITY_WITHDRAW": 2,
"TRANSFER_TYPE_PEG_MINT": 3,
"TRANSFER_TYPE_PEG_WITHDRAW": 4,
"TRANSFER_TYPE_PEG_V2_MINT": 5,
"TRANSFER_TYPE_PEG_V2_WITHDRAW": 6,
}
Functions ¶
func RegisterQueryServer ¶
func RegisterQueryServer(s grpc1.Server, srv QueryServer)
Types ¶
type BridgeType ¶
type BridgeType int32
const ( BRIDGE_TYPE_NULL BridgeType = 0 BRIDGE_TYPE_LIQUIDITY BridgeType = 1 BRIDGE_TYPE_PEG_VAULT BridgeType = 2 BRIDGE_TYPE_PEG_BRIDGE BridgeType = 3 )
func (BridgeType) EnumDescriptor ¶
func (BridgeType) EnumDescriptor() ([]byte, []int)
func (BridgeType) String ¶
func (x BridgeType) String() string
type EmptyRequest ¶
type EmptyRequest struct { }
func (*EmptyRequest) Descriptor ¶
func (*EmptyRequest) Descriptor() ([]byte, []int)
func (*EmptyRequest) Marshal ¶
func (m *EmptyRequest) Marshal() (dAtA []byte, err error)
func (*EmptyRequest) MarshalToSizedBuffer ¶
func (m *EmptyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EmptyRequest) ProtoMessage ¶
func (*EmptyRequest) ProtoMessage()
func (*EmptyRequest) Reset ¶
func (m *EmptyRequest) Reset()
func (*EmptyRequest) Size ¶
func (m *EmptyRequest) Size() (n int)
func (*EmptyRequest) String ¶
func (m *EmptyRequest) String() string
func (*EmptyRequest) Unmarshal ¶
func (m *EmptyRequest) Unmarshal(dAtA []byte) error
func (*EmptyRequest) XXX_DiscardUnknown ¶
func (m *EmptyRequest) XXX_DiscardUnknown()
func (*EmptyRequest) XXX_Marshal ¶
func (m *EmptyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EmptyRequest) XXX_Merge ¶
func (m *EmptyRequest) XXX_Merge(src proto.Message)
func (*EmptyRequest) XXX_Size ¶
func (m *EmptyRequest) XXX_Size() int
func (*EmptyRequest) XXX_Unmarshal ¶
func (m *EmptyRequest) XXX_Unmarshal(b []byte) error
type ExecutionContext ¶
type ExecutionContext struct { // message_id defines the message ID. MessageId []byte `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty" yaml:"message_id"` // message defines the message to be executed, along with the required relayer signatures. Message Message `protobuf:"bytes,2,opt,name=message,proto3" json:"message" yaml:"message"` // transfer defines the optional transfer info associated with the message. // it is not stored in consensus db, but derived from message fields. Transfer *Transfer `protobuf:"bytes,3,opt,name=transfer,proto3" json:"transfer,omitempty" yaml:"transfer"` }
ExecutionContext defines all the info needed for executing a message.
func NewMsgPegBurnRefundExecutionContext ¶
func NewMsgPegBurnRefundExecutionContext( ev *eth.MessageBusMessageWithTransfer, mintOnChain pegbrtypes.MintOnChain, pegBridge eth.Addr, bridgeVersion uint32) *ExecutionContext
func NewMsgPegDepositRefundExecutionContext ¶
func NewMsgPegDepositRefundExecutionContext( ev *eth.MessageBusMessageWithTransfer, wdOnChain pegbrtypes.WithdrawOnChain, pegVault eth.Addr, vaultVersion uint32) *ExecutionContext
func NewMsgXferExecutionContext ¶
func NewMsgXferExecutionContext( ev *eth.MessageBusMessageWithTransfer, chainId uint64, dstToken eth.Addr, dstAmt string, dstBridge eth.Addr, transferType TransferType) *ExecutionContext
func NewMsgXferRefundExecutionContext ¶
func NewMsgXferRefundExecutionContext( ev *eth.MessageBusMessageWithTransfer, wdOnchain *cbrtypes.WithdrawOnchain, nonce uint64, bridge eth.Addr) *ExecutionContext
func (*ExecutionContext) ComputeDstTransferId ¶
func (c *ExecutionContext) ComputeDstTransferId(dstBridgeAddr eth.Addr) []byte
func (*ExecutionContext) ComputeMessageId ¶
func (c *ExecutionContext) ComputeMessageId(bridgeAddr eth.Addr) []byte
func (*ExecutionContext) ComputeMessageIdWithTransfer ¶
func (c *ExecutionContext) ComputeMessageIdWithTransfer(dstBridgeAddr eth.Addr) []byte
func (*ExecutionContext) Descriptor ¶
func (*ExecutionContext) Descriptor() ([]byte, []int)
func (*ExecutionContext) GetMessage ¶
func (m *ExecutionContext) GetMessage() Message
func (*ExecutionContext) GetMessageId ¶
func (m *ExecutionContext) GetMessageId() []byte
func (*ExecutionContext) GetTransfer ¶
func (m *ExecutionContext) GetTransfer() *Transfer
func (*ExecutionContext) Marshal ¶
func (m *ExecutionContext) Marshal() (dAtA []byte, err error)
func (*ExecutionContext) MarshalToSizedBuffer ¶
func (m *ExecutionContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ExecutionContext) MustMarshal ¶
func (c *ExecutionContext) MustMarshal() []byte
func (*ExecutionContext) PrettyPrint ¶
func (c *ExecutionContext) PrettyPrint()
func (*ExecutionContext) ProtoMessage ¶
func (*ExecutionContext) ProtoMessage()
func (*ExecutionContext) Reset ¶
func (m *ExecutionContext) Reset()
func (*ExecutionContext) Size ¶
func (m *ExecutionContext) Size() (n int)
func (*ExecutionContext) String ¶
func (m *ExecutionContext) String() string
func (*ExecutionContext) Unmarshal ¶
func (m *ExecutionContext) Unmarshal(dAtA []byte) error
func (*ExecutionContext) XXX_DiscardUnknown ¶
func (m *ExecutionContext) XXX_DiscardUnknown()
func (*ExecutionContext) XXX_Marshal ¶
func (m *ExecutionContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecutionContext) XXX_Merge ¶
func (m *ExecutionContext) XXX_Merge(src proto.Message)
func (*ExecutionContext) XXX_Size ¶
func (m *ExecutionContext) XXX_Size() int
func (*ExecutionContext) XXX_Unmarshal ¶
func (m *ExecutionContext) XXX_Unmarshal(b []byte) error
type ExecutionStatus ¶
type ExecutionStatus int32
ExecutionStatus defines the on-chain execution status of a message.
const ( // EXECUTION_STATUS_NULL defines the init (non-exist) execution status. EXECUTION_STATUS_NULL ExecutionStatus = 0 // EXECUTION_STATUS_SUCCESS defines the successful on-chain execution status. EXECUTION_STATUS_SUCCESS ExecutionStatus = 1 // EXECUTION_STATUS_FAILURE defines the failed on-chain execution status. EXECUTION_STATUS_FAILURE ExecutionStatus = 2 // EXECUTION_STATUS_FALLBACK defines the fallback on-chain execution status. EXECUTION_STATUS_FALLBACK ExecutionStatus = 3 )
func (ExecutionStatus) EnumDescriptor ¶
func (ExecutionStatus) EnumDescriptor() ([]byte, []int)
func (ExecutionStatus) String ¶
func (x ExecutionStatus) String() string
type FeeClaimDetails ¶
type FeeClaimDetails struct { // chain_id defines the EVM chain ID for the claim. ChainId uint64 `protobuf:"varint,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // cumulative_fee_amount defines the cumulative fees claimable on the EVM chain. CumulativeFeeAmount types1.DecCoin `` /* 139-byte string literal not displayed */ // signatures defines the signatures to be verified on the EVM chain. Signatures []types.Signature `protobuf:"bytes,3,rep,name=signatures,proto3" json:"signatures" yaml:"signatures"` }
FeeClaimDetails describes the fees to be claimed on the EVM chain.
func (*FeeClaimDetails) Descriptor ¶
func (*FeeClaimDetails) Descriptor() ([]byte, []int)
func (*FeeClaimDetails) GetChainId ¶
func (m *FeeClaimDetails) GetChainId() uint64
func (*FeeClaimDetails) GetCumulativeFeeAmount ¶
func (m *FeeClaimDetails) GetCumulativeFeeAmount() types1.DecCoin
func (*FeeClaimDetails) GetSignatures ¶
func (m *FeeClaimDetails) GetSignatures() []types.Signature
func (*FeeClaimDetails) Marshal ¶
func (m *FeeClaimDetails) Marshal() (dAtA []byte, err error)
func (*FeeClaimDetails) MarshalToSizedBuffer ¶
func (m *FeeClaimDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FeeClaimDetails) ProtoMessage ¶
func (*FeeClaimDetails) ProtoMessage()
func (*FeeClaimDetails) Reset ¶
func (m *FeeClaimDetails) Reset()
func (*FeeClaimDetails) Size ¶
func (m *FeeClaimDetails) Size() (n int)
func (*FeeClaimDetails) String ¶
func (m *FeeClaimDetails) String() string
func (*FeeClaimDetails) Unmarshal ¶
func (m *FeeClaimDetails) Unmarshal(dAtA []byte) error
func (*FeeClaimDetails) XXX_DiscardUnknown ¶
func (m *FeeClaimDetails) XXX_DiscardUnknown()
func (*FeeClaimDetails) XXX_Marshal ¶
func (m *FeeClaimDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FeeClaimDetails) XXX_Merge ¶
func (m *FeeClaimDetails) XXX_Merge(src proto.Message)
func (*FeeClaimDetails) XXX_Size ¶
func (m *FeeClaimDetails) XXX_Size() int
func (*FeeClaimDetails) XXX_Unmarshal ¶
func (m *FeeClaimDetails) XXX_Unmarshal(b []byte) error
type FeeClaimInfo ¶
type FeeClaimInfo struct { // recipient defines the Ethereum address of the fee recipient. Recipient string `protobuf:"bytes,1,opt,name=recipient,proto3" json:"recipient,omitempty"` // last_claim_time defines the last time a fee claim was signed by the validators. LastClaimTime time.Time `protobuf:"bytes,2,opt,name=last_claim_time,json=lastClaimTime,proto3,stdtime" json:"last_claim_time" yaml:"last_claim_time"` // fee_claim_details_list defines the list of fee claim details FeeClaimDetailsList []FeeClaimDetails `` /* 142-byte string literal not displayed */ }
FeeClaimInfo describes the fee claim metadata and details for a recipient.
func (*FeeClaimInfo) Descriptor ¶
func (*FeeClaimInfo) Descriptor() ([]byte, []int)
func (*FeeClaimInfo) GetFeeClaimDetailsList ¶
func (m *FeeClaimInfo) GetFeeClaimDetailsList() []FeeClaimDetails
func (*FeeClaimInfo) GetLastClaimTime ¶
func (m *FeeClaimInfo) GetLastClaimTime() time.Time
func (*FeeClaimInfo) GetRecipient ¶
func (m *FeeClaimInfo) GetRecipient() string
func (*FeeClaimInfo) Marshal ¶
func (m *FeeClaimInfo) Marshal() (dAtA []byte, err error)
func (*FeeClaimInfo) MarshalToSizedBuffer ¶
func (m *FeeClaimInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FeeClaimInfo) ProtoMessage ¶
func (*FeeClaimInfo) ProtoMessage()
func (*FeeClaimInfo) Reset ¶
func (m *FeeClaimInfo) Reset()
func (*FeeClaimInfo) Size ¶
func (m *FeeClaimInfo) Size() (n int)
func (*FeeClaimInfo) String ¶
func (m *FeeClaimInfo) String() string
func (*FeeClaimInfo) Unmarshal ¶
func (m *FeeClaimInfo) Unmarshal(dAtA []byte) error
func (*FeeClaimInfo) XXX_DiscardUnknown ¶
func (m *FeeClaimInfo) XXX_DiscardUnknown()
func (*FeeClaimInfo) XXX_Marshal ¶
func (m *FeeClaimInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FeeClaimInfo) XXX_Merge ¶
func (m *FeeClaimInfo) XXX_Merge(src proto.Message)
func (*FeeClaimInfo) XXX_Size ¶
func (m *FeeClaimInfo) XXX_Size() int
func (*FeeClaimInfo) XXX_Unmarshal ¶
func (m *FeeClaimInfo) XXX_Unmarshal(b []byte) error
type FeeSplit ¶
type FeeSplit struct { CelerTreasuryFeePerc uint32 `` /* 126-byte string literal not displayed */ CelerTreasuryAddr string `protobuf:"bytes,2,opt,name=celer_treasury_addr,json=celerTreasuryAddr,proto3" json:"celer_treasury_addr,omitempty"` }
Celer treasury is an EOA or a multi-sig wallet. The treasury will share a portion of the Celer IM msg passing fee if a config exists. Not that celer_treasury_fee_perc should not exceed 100. The left portion is for sgn.
func (*FeeSplit) Descriptor ¶
func (*FeeSplit) GetCelerTreasuryAddr ¶
func (*FeeSplit) GetCelerTreasuryFeePerc ¶
func (*FeeSplit) MarshalToSizedBuffer ¶
func (*FeeSplit) ProtoMessage ¶
func (*FeeSplit) ProtoMessage()
func (*FeeSplit) XXX_DiscardUnknown ¶
func (m *FeeSplit) XXX_DiscardUnknown()
func (*FeeSplit) XXX_Marshal ¶
func (*FeeSplit) XXX_Unmarshal ¶
type InputDataRoute ¶
type InputDataRoute struct {
// contains filtered or unexported fields
}
type IsMessageActiveRequest ¶
type IsMessageActiveRequest struct {
MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
}
IsMessageActiveRequest is request type for the Query/IsMessageActive RPC method.
func (*IsMessageActiveRequest) Descriptor ¶
func (*IsMessageActiveRequest) Descriptor() ([]byte, []int)
func (*IsMessageActiveRequest) GetMessageId ¶
func (m *IsMessageActiveRequest) GetMessageId() string
func (*IsMessageActiveRequest) Marshal ¶
func (m *IsMessageActiveRequest) Marshal() (dAtA []byte, err error)
func (*IsMessageActiveRequest) MarshalTo ¶
func (m *IsMessageActiveRequest) MarshalTo(dAtA []byte) (int, error)
func (*IsMessageActiveRequest) MarshalToSizedBuffer ¶
func (m *IsMessageActiveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*IsMessageActiveRequest) ProtoMessage ¶
func (*IsMessageActiveRequest) ProtoMessage()
func (*IsMessageActiveRequest) Reset ¶
func (m *IsMessageActiveRequest) Reset()
func (*IsMessageActiveRequest) Size ¶
func (m *IsMessageActiveRequest) Size() (n int)
func (*IsMessageActiveRequest) String ¶
func (m *IsMessageActiveRequest) String() string
func (*IsMessageActiveRequest) Unmarshal ¶
func (m *IsMessageActiveRequest) Unmarshal(dAtA []byte) error
func (*IsMessageActiveRequest) XXX_DiscardUnknown ¶
func (m *IsMessageActiveRequest) XXX_DiscardUnknown()
func (*IsMessageActiveRequest) XXX_Marshal ¶
func (m *IsMessageActiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IsMessageActiveRequest) XXX_Merge ¶
func (m *IsMessageActiveRequest) XXX_Merge(src proto.Message)
func (*IsMessageActiveRequest) XXX_Size ¶
func (m *IsMessageActiveRequest) XXX_Size() int
func (*IsMessageActiveRequest) XXX_Unmarshal ¶
func (m *IsMessageActiveRequest) XXX_Unmarshal(b []byte) error
type IsMessageActiveResponse ¶
type IsMessageActiveResponse struct {
Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
}
IsMessageActiveResponse is response type for the Query/IsMessageActive RPC method.
func (*IsMessageActiveResponse) Descriptor ¶
func (*IsMessageActiveResponse) Descriptor() ([]byte, []int)
func (*IsMessageActiveResponse) GetExists ¶
func (m *IsMessageActiveResponse) GetExists() bool
func (*IsMessageActiveResponse) Marshal ¶
func (m *IsMessageActiveResponse) Marshal() (dAtA []byte, err error)
func (*IsMessageActiveResponse) MarshalTo ¶
func (m *IsMessageActiveResponse) MarshalTo(dAtA []byte) (int, error)
func (*IsMessageActiveResponse) MarshalToSizedBuffer ¶
func (m *IsMessageActiveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*IsMessageActiveResponse) ProtoMessage ¶
func (*IsMessageActiveResponse) ProtoMessage()
func (*IsMessageActiveResponse) Reset ¶
func (m *IsMessageActiveResponse) Reset()
func (*IsMessageActiveResponse) Size ¶
func (m *IsMessageActiveResponse) Size() (n int)
func (*IsMessageActiveResponse) String ¶
func (m *IsMessageActiveResponse) String() string
func (*IsMessageActiveResponse) Unmarshal ¶
func (m *IsMessageActiveResponse) Unmarshal(dAtA []byte) error
func (*IsMessageActiveResponse) XXX_DiscardUnknown ¶
func (m *IsMessageActiveResponse) XXX_DiscardUnknown()
func (*IsMessageActiveResponse) XXX_Marshal ¶
func (m *IsMessageActiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IsMessageActiveResponse) XXX_Merge ¶
func (m *IsMessageActiveResponse) XXX_Merge(src proto.Message)
func (*IsMessageActiveResponse) XXX_Size ¶
func (m *IsMessageActiveResponse) XXX_Size() int
func (*IsMessageActiveResponse) XXX_Unmarshal ¶
func (m *IsMessageActiveResponse) XXX_Unmarshal(b []byte) error
type Message ¶
type Message struct { // src_chain_id defines the source chain ID. SrcChainId uint64 `protobuf:"varint,1,opt,name=src_chain_id,json=srcChainId,proto3" json:"src_chain_id,omitempty" yaml:"src_chain_id"` // sender defines the sender address. Sender string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"` // dst_chain_id defines the destination chain ID. DstChainId uint64 `protobuf:"varint,3,opt,name=dst_chain_id,json=dstChainId,proto3" json:"dst_chain_id,omitempty" yaml:"dst_chain_id"` // receiver defines the receiver address. Receiver string `protobuf:"bytes,4,opt,name=receiver,proto3" json:"receiver,omitempty" yaml:"receiver"` // data defines the message data. Data []byte `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty" yaml:"data"` // fee defines the message fee paid to SGN. Fee string `protobuf:"bytes,6,opt,name=fee,proto3" json:"fee,omitempty" yaml:"fee"` // transfer_type defines the associated type of transfer. TransferType TransferType `` /* 152-byte string literal not displayed */ // transfer_ref_id defines the reference ID of the transfer. // For sending via a liquidity bridge, ref_id is the src transfer ID. // For mint / withdrawal via a pegged bridge, ref_id is the reference ID of the pegged transfer. TransferRefId []byte `protobuf:"bytes,11,opt,name=transfer_ref_id,json=transferRefId,proto3" json:"transfer_ref_id,omitempty" yaml:"transfer"` // execution_status defines the on-chain execution status. ExecutionStatus ExecutionStatus `` /* 167-byte string literal not displayed */ // signatures defines the signatures to be verified on MessageBus. Signatures []types.Signature `protobuf:"bytes,9,rep,name=signatures,proto3" json:"signatures" yaml:"signatures"` // last_req_time defines the latest timestamp a signing request was made. // Used for anti-dos. LastReqTime int64 `protobuf:"varint,10,opt,name=last_req_time,json=lastReqTime,proto3" json:"last_req_time,omitempty" yaml:"last_req_time"` // source tx hash of the message SrcTxHash string `protobuf:"bytes,12,opt,name=src_tx_hash,json=srcTxHash,proto3" json:"src_tx_hash,omitempty" yaml:"src_tx_hash"` // v2 message, use bytes Addr IsBytesAddr bool `protobuf:"varint,13,opt,name=is_bytes_addr,json=isBytesAddr,proto3" json:"is_bytes_addr,omitempty" yaml:"is_bytes_addr"` }
Message describes the info of a cross-chain message.
func (*Message) ComputeMessageIdNoTransfer ¶
func (*Message) ComputeProxyChainMessageIdNoTransfer ¶
func (*Message) Descriptor ¶
func (*Message) GetDstChainId ¶
func (*Message) GetExecutionStatus ¶
func (m *Message) GetExecutionStatus() ExecutionStatus
func (*Message) GetIsBytesAddr ¶
func (*Message) GetLastReqTime ¶
func (*Message) GetReceiver ¶
func (*Message) GetSignatures ¶
func (*Message) GetSrcChainId ¶
func (*Message) GetSrcTxHash ¶
func (*Message) GetTransferRefId ¶
func (*Message) GetTransferType ¶
func (m *Message) GetTransferType() TransferType
func (*Message) MarshalToSizedBuffer ¶
func (*Message) PrettyPrint ¶
func (m *Message) PrettyPrint()
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) XXX_DiscardUnknown ¶
func (m *Message) XXX_DiscardUnknown()
func (*Message) XXX_Marshal ¶
func (*Message) XXX_Unmarshal ¶
type MessageBusInfo ¶
type MessageBusInfo struct { // contract_info defines the MessageBus contract info. ContractInfo *types.ContractInfo `protobuf:"bytes,1,opt,name=contract_info,json=contractInfo,proto3" json:"contract_info,omitempty" yaml:"contract_info"` // fee_token_symbol defines the symbol of the native gas token to pay message fees. FeeTokenSymbol string `` /* 129-byte string literal not displayed */ FeeSplitOverride *FeeSplit `` /* 137-byte string literal not displayed */ }
MessageBusInfo defines the info of a MessageBus contract.
func (*MessageBusInfo) Descriptor ¶
func (*MessageBusInfo) Descriptor() ([]byte, []int)
func (*MessageBusInfo) GetContractInfo ¶
func (m *MessageBusInfo) GetContractInfo() *types.ContractInfo
func (*MessageBusInfo) GetFeeSplitOverride ¶
func (m *MessageBusInfo) GetFeeSplitOverride() *FeeSplit
func (*MessageBusInfo) GetFeeTokenSymbol ¶
func (m *MessageBusInfo) GetFeeTokenSymbol() string
func (*MessageBusInfo) Marshal ¶
func (m *MessageBusInfo) Marshal() (dAtA []byte, err error)
func (*MessageBusInfo) MarshalToSizedBuffer ¶
func (m *MessageBusInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MessageBusInfo) ProtoMessage ¶
func (*MessageBusInfo) ProtoMessage()
func (*MessageBusInfo) Reset ¶
func (m *MessageBusInfo) Reset()
func (*MessageBusInfo) Size ¶
func (m *MessageBusInfo) Size() (n int)
func (*MessageBusInfo) String ¶
func (m *MessageBusInfo) String() string
func (*MessageBusInfo) Unmarshal ¶
func (m *MessageBusInfo) Unmarshal(dAtA []byte) error
func (*MessageBusInfo) XXX_DiscardUnknown ¶
func (m *MessageBusInfo) XXX_DiscardUnknown()
func (*MessageBusInfo) XXX_Marshal ¶
func (m *MessageBusInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessageBusInfo) XXX_Merge ¶
func (m *MessageBusInfo) XXX_Merge(src proto.Message)
func (*MessageBusInfo) XXX_Size ¶
func (m *MessageBusInfo) XXX_Size() int
func (*MessageBusInfo) XXX_Unmarshal ¶
func (m *MessageBusInfo) XXX_Unmarshal(b []byte) error
type MsgProposal ¶
type MsgProposal struct { // title defines the title of the proposal. Title string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty" yaml:"title"` // description defines the proposal description. Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty" yaml:"description"` // message_buses defines the list of MessageBus infos to update. MessageBuses []*MessageBusInfo `protobuf:"bytes,3,rep,name=message_buses,json=messageBuses,proto3" json:"message_buses,omitempty" yaml:"message_buses"` FeeSplitGlobal *FeeSplit `` /* 129-byte string literal not displayed */ // deposit defines the amount for MsgSubmitProposal Deposit github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,4,opt,name=deposit,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"deposit" yaml:"deposit"` }
MsgProposal describes a message config proposal, note it must be a whole json
func (*MsgProposal) Descriptor ¶
func (*MsgProposal) Descriptor() ([]byte, []int)
func (*MsgProposal) GetDescription ¶
func (m *MsgProposal) GetDescription() string
func (*MsgProposal) GetFeeSplitGlobal ¶
func (m *MsgProposal) GetFeeSplitGlobal() *FeeSplit
func (*MsgProposal) GetMessageBuses ¶
func (m *MsgProposal) GetMessageBuses() []*MessageBusInfo
func (*MsgProposal) GetTitle ¶
func (m *MsgProposal) GetTitle() string
func (*MsgProposal) Marshal ¶
func (m *MsgProposal) Marshal() (dAtA []byte, err error)
func (*MsgProposal) MarshalToSizedBuffer ¶
func (m *MsgProposal) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgProposal) ProtoMessage ¶
func (*MsgProposal) ProtoMessage()
func (*MsgProposal) Reset ¶
func (m *MsgProposal) Reset()
func (*MsgProposal) Size ¶
func (m *MsgProposal) Size() (n int)
func (*MsgProposal) String ¶
func (m *MsgProposal) String() string
func (*MsgProposal) Unmarshal ¶
func (m *MsgProposal) Unmarshal(dAtA []byte) error
func (*MsgProposal) XXX_DiscardUnknown ¶
func (m *MsgProposal) XXX_DiscardUnknown()
func (*MsgProposal) XXX_Marshal ¶
func (m *MsgProposal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgProposal) XXX_Merge ¶
func (m *MsgProposal) XXX_Merge(src proto.Message)
func (*MsgProposal) XXX_Size ¶
func (m *MsgProposal) XXX_Size() int
func (*MsgProposal) XXX_Unmarshal ¶
func (m *MsgProposal) XXX_Unmarshal(b []byte) error
type MsgType ¶
type MsgType int32
MsgType defines enum in contract MessageReceiver.sol
func (MsgType) EnumDescriptor ¶
type Params ¶
type Params struct { // trigger_sign_cooldown defines the minimal time between two trigger signing requests. TriggerSignCooldown time.Duration `` /* 161-byte string literal not displayed */ // message_expired_time defines the expired time of message MessageExpiredTime time.Duration `` /* 157-byte string literal not displayed */ }
Params defines the parameters for the module.
func (*Params) Descriptor ¶
func (*Params) GetMessageExpiredTime ¶
func (*Params) GetTriggerSignCooldown ¶
func (*Params) MarshalToSizedBuffer ¶
func (*Params) ProtoMessage ¶
func (*Params) ProtoMessage()
func (*Params) XXX_DiscardUnknown ¶
func (m *Params) XXX_DiscardUnknown()
func (*Params) XXX_Marshal ¶
func (*Params) XXX_Unmarshal ¶
type QueryClient ¶
type QueryClient interface { // Params queries the parameters of the module. Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error) // ExecutionContexts returns the execution contexts of all messages that have enough signatures and are ready for execution. // Note that it may return messages that are being or have been executed by an executor. // The SGN will monitor the execution event on-chain. Once it reaches consensus that a message has been executed, the query will stop // returning the info about that particular message. // // The query can be optionally filtered by destination chain IDs and / or destination contract addresses. ExecutionContexts(ctx context.Context, in *QueryExecutionContextsRequest, opts ...grpc.CallOption) (*QueryExecutionContextsResponse, error) ExecutionContextBySrcTransfer(ctx context.Context, in *QueryExecutionContextBySrcTransferRequest, opts ...grpc.CallOption) (*QueryExecutionContextBySrcTransferResponse, error) ExecutionContextByMsgId(ctx context.Context, in *QueryExecutionContextByMsgIdRequest, opts ...grpc.CallOption) (*QueryExecutionContextByMsgIdResponse, error) // Message queries the message details. Message(ctx context.Context, in *QueryMessageRequest, opts ...grpc.CallOption) (*QueryMessageResponse, error) // Message queries whether a message exists. MessageExists(ctx context.Context, in *QueryMessageExistsRequest, opts ...grpc.CallOption) (*QueryMessageExistsResponse, error) // Message queries whether a message is active. IsMessageActive(ctx context.Context, in *IsMessageActiveRequest, opts ...grpc.CallOption) (*IsMessageActiveResponse, error) // MessageBus queries the message bus contract info. MessageBus(ctx context.Context, in *QueryMessageBusRequest, opts ...grpc.CallOption) (*QueryMessageBusResponse, error) FeeSplitGlobal(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*QueryFeeSplitGlobalResponse, error) // FeeClaimInfo queries the info for claiming message fees on-chain. FeeClaimInfo(ctx context.Context, in *QueryFeeClaimInfoRequest, opts ...grpc.CallOption) (*QueryFeeClaimInfoResponse, 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 QueryExecutionContextByMsgIdRequest ¶
type QueryExecutionContextByMsgIdRequest struct { MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"` IgnoreSigs bool `protobuf:"varint,2,opt,name=ignore_sigs,json=ignoreSigs,proto3" json:"ignore_sigs,omitempty"` }
func (*QueryExecutionContextByMsgIdRequest) Descriptor ¶
func (*QueryExecutionContextByMsgIdRequest) Descriptor() ([]byte, []int)
func (*QueryExecutionContextByMsgIdRequest) GetIgnoreSigs ¶
func (m *QueryExecutionContextByMsgIdRequest) GetIgnoreSigs() bool
func (*QueryExecutionContextByMsgIdRequest) GetMessageId ¶
func (m *QueryExecutionContextByMsgIdRequest) GetMessageId() string
func (*QueryExecutionContextByMsgIdRequest) Marshal ¶
func (m *QueryExecutionContextByMsgIdRequest) Marshal() (dAtA []byte, err error)
func (*QueryExecutionContextByMsgIdRequest) MarshalTo ¶
func (m *QueryExecutionContextByMsgIdRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryExecutionContextByMsgIdRequest) MarshalToSizedBuffer ¶
func (m *QueryExecutionContextByMsgIdRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryExecutionContextByMsgIdRequest) ProtoMessage ¶
func (*QueryExecutionContextByMsgIdRequest) ProtoMessage()
func (*QueryExecutionContextByMsgIdRequest) Reset ¶
func (m *QueryExecutionContextByMsgIdRequest) Reset()
func (*QueryExecutionContextByMsgIdRequest) Size ¶
func (m *QueryExecutionContextByMsgIdRequest) Size() (n int)
func (*QueryExecutionContextByMsgIdRequest) String ¶
func (m *QueryExecutionContextByMsgIdRequest) String() string
func (*QueryExecutionContextByMsgIdRequest) Unmarshal ¶
func (m *QueryExecutionContextByMsgIdRequest) Unmarshal(dAtA []byte) error
func (*QueryExecutionContextByMsgIdRequest) XXX_DiscardUnknown ¶
func (m *QueryExecutionContextByMsgIdRequest) XXX_DiscardUnknown()
func (*QueryExecutionContextByMsgIdRequest) XXX_Marshal ¶
func (m *QueryExecutionContextByMsgIdRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryExecutionContextByMsgIdRequest) XXX_Merge ¶
func (m *QueryExecutionContextByMsgIdRequest) XXX_Merge(src proto.Message)
func (*QueryExecutionContextByMsgIdRequest) XXX_Size ¶
func (m *QueryExecutionContextByMsgIdRequest) XXX_Size() int
func (*QueryExecutionContextByMsgIdRequest) XXX_Unmarshal ¶
func (m *QueryExecutionContextByMsgIdRequest) XXX_Unmarshal(b []byte) error
type QueryExecutionContextByMsgIdResponse ¶
type QueryExecutionContextByMsgIdResponse struct { ExecutionContext *ExecutionContext `protobuf:"bytes,1,opt,name=execution_context,json=executionContext,proto3" json:"execution_context,omitempty"` // if the message is ready to be executed HasEnoughSigs bool `protobuf:"varint,2,opt,name=has_enough_sigs,json=hasEnoughSigs,proto3" json:"has_enough_sigs,omitempty"` // if has_enough_sigs is true, enough_sigs returns the minimum sigs to call onchain EnoughSigs [][]byte `protobuf:"bytes,3,rep,name=enough_sigs,json=enoughSigs,proto3" json:"enough_sigs,omitempty"` // current chain signers ChainSigners *types1.ChainSigners `protobuf:"bytes,4,opt,name=chain_signers,json=chainSigners,proto3" json:"chain_signers,omitempty"` }
func (*QueryExecutionContextByMsgIdResponse) Descriptor ¶
func (*QueryExecutionContextByMsgIdResponse) Descriptor() ([]byte, []int)
func (*QueryExecutionContextByMsgIdResponse) GetChainSigners ¶
func (m *QueryExecutionContextByMsgIdResponse) GetChainSigners() *types1.ChainSigners
func (*QueryExecutionContextByMsgIdResponse) GetEnoughSigs ¶
func (m *QueryExecutionContextByMsgIdResponse) GetEnoughSigs() [][]byte
func (*QueryExecutionContextByMsgIdResponse) GetExecutionContext ¶
func (m *QueryExecutionContextByMsgIdResponse) GetExecutionContext() *ExecutionContext
func (*QueryExecutionContextByMsgIdResponse) GetHasEnoughSigs ¶
func (m *QueryExecutionContextByMsgIdResponse) GetHasEnoughSigs() bool
func (*QueryExecutionContextByMsgIdResponse) Marshal ¶
func (m *QueryExecutionContextByMsgIdResponse) Marshal() (dAtA []byte, err error)
func (*QueryExecutionContextByMsgIdResponse) MarshalTo ¶
func (m *QueryExecutionContextByMsgIdResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryExecutionContextByMsgIdResponse) MarshalToSizedBuffer ¶
func (m *QueryExecutionContextByMsgIdResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryExecutionContextByMsgIdResponse) ProtoMessage ¶
func (*QueryExecutionContextByMsgIdResponse) ProtoMessage()
func (*QueryExecutionContextByMsgIdResponse) Reset ¶
func (m *QueryExecutionContextByMsgIdResponse) Reset()
func (*QueryExecutionContextByMsgIdResponse) Size ¶
func (m *QueryExecutionContextByMsgIdResponse) Size() (n int)
func (*QueryExecutionContextByMsgIdResponse) String ¶
func (m *QueryExecutionContextByMsgIdResponse) String() string
func (*QueryExecutionContextByMsgIdResponse) Unmarshal ¶
func (m *QueryExecutionContextByMsgIdResponse) Unmarshal(dAtA []byte) error
func (*QueryExecutionContextByMsgIdResponse) XXX_DiscardUnknown ¶
func (m *QueryExecutionContextByMsgIdResponse) XXX_DiscardUnknown()
func (*QueryExecutionContextByMsgIdResponse) XXX_Marshal ¶
func (m *QueryExecutionContextByMsgIdResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryExecutionContextByMsgIdResponse) XXX_Merge ¶
func (m *QueryExecutionContextByMsgIdResponse) XXX_Merge(src proto.Message)
func (*QueryExecutionContextByMsgIdResponse) XXX_Size ¶
func (m *QueryExecutionContextByMsgIdResponse) XXX_Size() int
func (*QueryExecutionContextByMsgIdResponse) XXX_Unmarshal ¶
func (m *QueryExecutionContextByMsgIdResponse) XXX_Unmarshal(b []byte) error
type QueryExecutionContextBySrcTransferRequest ¶
type QueryExecutionContextBySrcTransferRequest struct { SrcTransferId string `protobuf:"bytes,1,opt,name=src_transfer_id,json=srcTransferId,proto3" json:"src_transfer_id,omitempty"` SrcBridgeType BridgeType `` /* 134-byte string literal not displayed */ MessageIdOnly bool `protobuf:"varint,3,opt,name=message_id_only,json=messageIdOnly,proto3" json:"message_id_only,omitempty"` CheckSigs bool `protobuf:"varint,4,opt,name=check_sigs,json=checkSigs,proto3" json:"check_sigs,omitempty"` }
func (*QueryExecutionContextBySrcTransferRequest) Descriptor ¶
func (*QueryExecutionContextBySrcTransferRequest) Descriptor() ([]byte, []int)
func (*QueryExecutionContextBySrcTransferRequest) GetCheckSigs ¶
func (m *QueryExecutionContextBySrcTransferRequest) GetCheckSigs() bool
func (*QueryExecutionContextBySrcTransferRequest) GetMessageIdOnly ¶
func (m *QueryExecutionContextBySrcTransferRequest) GetMessageIdOnly() bool
func (*QueryExecutionContextBySrcTransferRequest) GetSrcBridgeType ¶
func (m *QueryExecutionContextBySrcTransferRequest) GetSrcBridgeType() BridgeType
func (*QueryExecutionContextBySrcTransferRequest) GetSrcTransferId ¶
func (m *QueryExecutionContextBySrcTransferRequest) GetSrcTransferId() string
func (*QueryExecutionContextBySrcTransferRequest) Marshal ¶
func (m *QueryExecutionContextBySrcTransferRequest) Marshal() (dAtA []byte, err error)
func (*QueryExecutionContextBySrcTransferRequest) MarshalTo ¶
func (m *QueryExecutionContextBySrcTransferRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryExecutionContextBySrcTransferRequest) MarshalToSizedBuffer ¶
func (m *QueryExecutionContextBySrcTransferRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryExecutionContextBySrcTransferRequest) ProtoMessage ¶
func (*QueryExecutionContextBySrcTransferRequest) ProtoMessage()
func (*QueryExecutionContextBySrcTransferRequest) Reset ¶
func (m *QueryExecutionContextBySrcTransferRequest) Reset()
func (*QueryExecutionContextBySrcTransferRequest) Size ¶
func (m *QueryExecutionContextBySrcTransferRequest) Size() (n int)
func (*QueryExecutionContextBySrcTransferRequest) String ¶
func (m *QueryExecutionContextBySrcTransferRequest) String() string
func (*QueryExecutionContextBySrcTransferRequest) Unmarshal ¶
func (m *QueryExecutionContextBySrcTransferRequest) Unmarshal(dAtA []byte) error
func (*QueryExecutionContextBySrcTransferRequest) XXX_DiscardUnknown ¶
func (m *QueryExecutionContextBySrcTransferRequest) XXX_DiscardUnknown()
func (*QueryExecutionContextBySrcTransferRequest) XXX_Marshal ¶
func (m *QueryExecutionContextBySrcTransferRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryExecutionContextBySrcTransferRequest) XXX_Merge ¶
func (m *QueryExecutionContextBySrcTransferRequest) XXX_Merge(src proto.Message)
func (*QueryExecutionContextBySrcTransferRequest) XXX_Size ¶
func (m *QueryExecutionContextBySrcTransferRequest) XXX_Size() int
func (*QueryExecutionContextBySrcTransferRequest) XXX_Unmarshal ¶
func (m *QueryExecutionContextBySrcTransferRequest) XXX_Unmarshal(b []byte) error
type QueryExecutionContextBySrcTransferResponse ¶
type QueryExecutionContextBySrcTransferResponse struct { ExecutionContext *ExecutionContext `protobuf:"bytes,1,opt,name=execution_context,json=executionContext,proto3" json:"execution_context,omitempty"` // votes are only checked if the request is not marked as message_id_only AND // check_votes is set to true in the request HasEnoughSigs bool `protobuf:"varint,2,opt,name=has_enough_sigs,json=hasEnoughSigs,proto3" json:"has_enough_sigs,omitempty"` }
func (*QueryExecutionContextBySrcTransferResponse) Descriptor ¶
func (*QueryExecutionContextBySrcTransferResponse) Descriptor() ([]byte, []int)
func (*QueryExecutionContextBySrcTransferResponse) GetExecutionContext ¶
func (m *QueryExecutionContextBySrcTransferResponse) GetExecutionContext() *ExecutionContext
func (*QueryExecutionContextBySrcTransferResponse) GetHasEnoughSigs ¶
func (m *QueryExecutionContextBySrcTransferResponse) GetHasEnoughSigs() bool
func (*QueryExecutionContextBySrcTransferResponse) Marshal ¶
func (m *QueryExecutionContextBySrcTransferResponse) Marshal() (dAtA []byte, err error)
func (*QueryExecutionContextBySrcTransferResponse) MarshalTo ¶
func (m *QueryExecutionContextBySrcTransferResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryExecutionContextBySrcTransferResponse) MarshalToSizedBuffer ¶
func (m *QueryExecutionContextBySrcTransferResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryExecutionContextBySrcTransferResponse) ProtoMessage ¶
func (*QueryExecutionContextBySrcTransferResponse) ProtoMessage()
func (*QueryExecutionContextBySrcTransferResponse) Reset ¶
func (m *QueryExecutionContextBySrcTransferResponse) Reset()
func (*QueryExecutionContextBySrcTransferResponse) Size ¶
func (m *QueryExecutionContextBySrcTransferResponse) Size() (n int)
func (*QueryExecutionContextBySrcTransferResponse) String ¶
func (m *QueryExecutionContextBySrcTransferResponse) String() string
func (*QueryExecutionContextBySrcTransferResponse) Unmarshal ¶
func (m *QueryExecutionContextBySrcTransferResponse) Unmarshal(dAtA []byte) error
func (*QueryExecutionContextBySrcTransferResponse) XXX_DiscardUnknown ¶
func (m *QueryExecutionContextBySrcTransferResponse) XXX_DiscardUnknown()
func (*QueryExecutionContextBySrcTransferResponse) XXX_Marshal ¶
func (m *QueryExecutionContextBySrcTransferResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryExecutionContextBySrcTransferResponse) XXX_Merge ¶
func (m *QueryExecutionContextBySrcTransferResponse) XXX_Merge(src proto.Message)
func (*QueryExecutionContextBySrcTransferResponse) XXX_Size ¶
func (m *QueryExecutionContextBySrcTransferResponse) XXX_Size() int
func (*QueryExecutionContextBySrcTransferResponse) XXX_Unmarshal ¶
func (m *QueryExecutionContextBySrcTransferResponse) XXX_Unmarshal(b []byte) error
type QueryExecutionContextsRequest ¶
type QueryExecutionContextsRequest struct { // contract_infos filter request by chain IDs and / or contract addresses. ContractInfos []*types.ContractInfo `protobuf:"bytes,1,rep,name=contract_infos,json=contractInfos,proto3" json:"contract_infos,omitempty"` // all indicates a query for all pending execution contexts. All bool `protobuf:"varint,2,opt,name=all,proto3" json:"all,omitempty"` // for pagination Pagination *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"` // return refund msg with incomplete sigs IgnoreRefundSigs bool `protobuf:"varint,4,opt,name=ignore_refund_sigs,json=ignoreRefundSigs,proto3" json:"ignore_refund_sigs,omitempty"` }
QueryExecutionContextsRequest is request type for the Query/ExecutionContexts RPC method.
func (*QueryExecutionContextsRequest) Descriptor ¶
func (*QueryExecutionContextsRequest) Descriptor() ([]byte, []int)
func (*QueryExecutionContextsRequest) GetAll ¶
func (m *QueryExecutionContextsRequest) GetAll() bool
func (*QueryExecutionContextsRequest) GetContractInfos ¶
func (m *QueryExecutionContextsRequest) GetContractInfos() []*types.ContractInfo
func (*QueryExecutionContextsRequest) GetIgnoreRefundSigs ¶
func (m *QueryExecutionContextsRequest) GetIgnoreRefundSigs() bool
func (*QueryExecutionContextsRequest) GetPagination ¶
func (m *QueryExecutionContextsRequest) GetPagination() *query.PageRequest
func (*QueryExecutionContextsRequest) Marshal ¶
func (m *QueryExecutionContextsRequest) Marshal() (dAtA []byte, err error)
func (*QueryExecutionContextsRequest) MarshalTo ¶
func (m *QueryExecutionContextsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryExecutionContextsRequest) MarshalToSizedBuffer ¶
func (m *QueryExecutionContextsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryExecutionContextsRequest) ProtoMessage ¶
func (*QueryExecutionContextsRequest) ProtoMessage()
func (*QueryExecutionContextsRequest) Reset ¶
func (m *QueryExecutionContextsRequest) Reset()
func (*QueryExecutionContextsRequest) Size ¶
func (m *QueryExecutionContextsRequest) Size() (n int)
func (*QueryExecutionContextsRequest) String ¶
func (m *QueryExecutionContextsRequest) String() string
func (*QueryExecutionContextsRequest) Unmarshal ¶
func (m *QueryExecutionContextsRequest) Unmarshal(dAtA []byte) error
func (*QueryExecutionContextsRequest) XXX_DiscardUnknown ¶
func (m *QueryExecutionContextsRequest) XXX_DiscardUnknown()
func (*QueryExecutionContextsRequest) XXX_Marshal ¶
func (m *QueryExecutionContextsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryExecutionContextsRequest) XXX_Merge ¶
func (m *QueryExecutionContextsRequest) XXX_Merge(src proto.Message)
func (*QueryExecutionContextsRequest) XXX_Size ¶
func (m *QueryExecutionContextsRequest) XXX_Size() int
func (*QueryExecutionContextsRequest) XXX_Unmarshal ¶
func (m *QueryExecutionContextsRequest) XXX_Unmarshal(b []byte) error
type QueryExecutionContextsResponse ¶
type QueryExecutionContextsResponse struct { // execution_contexts is the execution contexts. ExecutionContexts []ExecutionContext `protobuf:"bytes,1,rep,name=execution_contexts,json=executionContexts,proto3" json:"execution_contexts"` // pagination defines an pagination for the response. Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
QueryExecutionContextsRequest is response type for the Query/ExecutionContexts RPC method.
func (*QueryExecutionContextsResponse) Descriptor ¶
func (*QueryExecutionContextsResponse) Descriptor() ([]byte, []int)
func (*QueryExecutionContextsResponse) GetExecutionContexts ¶
func (m *QueryExecutionContextsResponse) GetExecutionContexts() []ExecutionContext
func (*QueryExecutionContextsResponse) GetPagination ¶
func (m *QueryExecutionContextsResponse) GetPagination() *query.PageResponse
func (*QueryExecutionContextsResponse) Marshal ¶
func (m *QueryExecutionContextsResponse) Marshal() (dAtA []byte, err error)
func (*QueryExecutionContextsResponse) MarshalTo ¶
func (m *QueryExecutionContextsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryExecutionContextsResponse) MarshalToSizedBuffer ¶
func (m *QueryExecutionContextsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryExecutionContextsResponse) ProtoMessage ¶
func (*QueryExecutionContextsResponse) ProtoMessage()
func (*QueryExecutionContextsResponse) Reset ¶
func (m *QueryExecutionContextsResponse) Reset()
func (*QueryExecutionContextsResponse) Size ¶
func (m *QueryExecutionContextsResponse) Size() (n int)
func (*QueryExecutionContextsResponse) String ¶
func (m *QueryExecutionContextsResponse) String() string
func (*QueryExecutionContextsResponse) Unmarshal ¶
func (m *QueryExecutionContextsResponse) Unmarshal(dAtA []byte) error
func (*QueryExecutionContextsResponse) XXX_DiscardUnknown ¶
func (m *QueryExecutionContextsResponse) XXX_DiscardUnknown()
func (*QueryExecutionContextsResponse) XXX_Marshal ¶
func (m *QueryExecutionContextsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryExecutionContextsResponse) XXX_Merge ¶
func (m *QueryExecutionContextsResponse) XXX_Merge(src proto.Message)
func (*QueryExecutionContextsResponse) XXX_Size ¶
func (m *QueryExecutionContextsResponse) XXX_Size() int
func (*QueryExecutionContextsResponse) XXX_Unmarshal ¶
func (m *QueryExecutionContextsResponse) XXX_Unmarshal(b []byte) error
type QueryFeeClaimInfoRequest ¶
type QueryFeeClaimInfoRequest struct { // address defines the account address to query for. Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` }
QueryFeeClaimInfoRequest is the request type for the Query/FeeClaimInfo RPC method.
func (*QueryFeeClaimInfoRequest) Descriptor ¶
func (*QueryFeeClaimInfoRequest) Descriptor() ([]byte, []int)
func (*QueryFeeClaimInfoRequest) Marshal ¶
func (m *QueryFeeClaimInfoRequest) Marshal() (dAtA []byte, err error)
func (*QueryFeeClaimInfoRequest) MarshalTo ¶
func (m *QueryFeeClaimInfoRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryFeeClaimInfoRequest) MarshalToSizedBuffer ¶
func (m *QueryFeeClaimInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryFeeClaimInfoRequest) ProtoMessage ¶
func (*QueryFeeClaimInfoRequest) ProtoMessage()
func (*QueryFeeClaimInfoRequest) Reset ¶
func (m *QueryFeeClaimInfoRequest) Reset()
func (*QueryFeeClaimInfoRequest) Size ¶
func (m *QueryFeeClaimInfoRequest) Size() (n int)
func (*QueryFeeClaimInfoRequest) String ¶
func (m *QueryFeeClaimInfoRequest) String() string
func (*QueryFeeClaimInfoRequest) Unmarshal ¶
func (m *QueryFeeClaimInfoRequest) Unmarshal(dAtA []byte) error
func (*QueryFeeClaimInfoRequest) XXX_DiscardUnknown ¶
func (m *QueryFeeClaimInfoRequest) XXX_DiscardUnknown()
func (*QueryFeeClaimInfoRequest) XXX_Marshal ¶
func (m *QueryFeeClaimInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryFeeClaimInfoRequest) XXX_Merge ¶
func (m *QueryFeeClaimInfoRequest) XXX_Merge(src proto.Message)
func (*QueryFeeClaimInfoRequest) XXX_Size ¶
func (m *QueryFeeClaimInfoRequest) XXX_Size() int
func (*QueryFeeClaimInfoRequest) XXX_Unmarshal ¶
func (m *QueryFeeClaimInfoRequest) XXX_Unmarshal(b []byte) error
type QueryFeeClaimInfoResponse ¶
type QueryFeeClaimInfoResponse struct { // fee_claim_info defines the fee claim info. FeeClaimInfo FeeClaimInfo `protobuf:"bytes,1,opt,name=fee_claim_info,json=feeClaimInfo,proto3" json:"fee_claim_info"` }
QueryFeeClaimInfoResponse is the response type for the Query/FeeClaimInfo RPC method.
func (*QueryFeeClaimInfoResponse) Descriptor ¶
func (*QueryFeeClaimInfoResponse) Descriptor() ([]byte, []int)
func (*QueryFeeClaimInfoResponse) GetFeeClaimInfo ¶
func (m *QueryFeeClaimInfoResponse) GetFeeClaimInfo() FeeClaimInfo
func (*QueryFeeClaimInfoResponse) Marshal ¶
func (m *QueryFeeClaimInfoResponse) Marshal() (dAtA []byte, err error)
func (*QueryFeeClaimInfoResponse) MarshalTo ¶
func (m *QueryFeeClaimInfoResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryFeeClaimInfoResponse) MarshalToSizedBuffer ¶
func (m *QueryFeeClaimInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryFeeClaimInfoResponse) ProtoMessage ¶
func (*QueryFeeClaimInfoResponse) ProtoMessage()
func (*QueryFeeClaimInfoResponse) Reset ¶
func (m *QueryFeeClaimInfoResponse) Reset()
func (*QueryFeeClaimInfoResponse) Size ¶
func (m *QueryFeeClaimInfoResponse) Size() (n int)
func (*QueryFeeClaimInfoResponse) String ¶
func (m *QueryFeeClaimInfoResponse) String() string
func (*QueryFeeClaimInfoResponse) Unmarshal ¶
func (m *QueryFeeClaimInfoResponse) Unmarshal(dAtA []byte) error
func (*QueryFeeClaimInfoResponse) XXX_DiscardUnknown ¶
func (m *QueryFeeClaimInfoResponse) XXX_DiscardUnknown()
func (*QueryFeeClaimInfoResponse) XXX_Marshal ¶
func (m *QueryFeeClaimInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryFeeClaimInfoResponse) XXX_Merge ¶
func (m *QueryFeeClaimInfoResponse) XXX_Merge(src proto.Message)
func (*QueryFeeClaimInfoResponse) XXX_Size ¶
func (m *QueryFeeClaimInfoResponse) XXX_Size() int
func (*QueryFeeClaimInfoResponse) XXX_Unmarshal ¶
func (m *QueryFeeClaimInfoResponse) XXX_Unmarshal(b []byte) error
type QueryFeeSplitGlobalResponse ¶
type QueryFeeSplitGlobalResponse struct {
FeeSplit *FeeSplit `protobuf:"bytes,1,opt,name=fee_split,json=feeSplit,proto3" json:"fee_split,omitempty"`
}
func (*QueryFeeSplitGlobalResponse) Descriptor ¶
func (*QueryFeeSplitGlobalResponse) Descriptor() ([]byte, []int)
func (*QueryFeeSplitGlobalResponse) GetFeeSplit ¶
func (m *QueryFeeSplitGlobalResponse) GetFeeSplit() *FeeSplit
func (*QueryFeeSplitGlobalResponse) Marshal ¶
func (m *QueryFeeSplitGlobalResponse) Marshal() (dAtA []byte, err error)
func (*QueryFeeSplitGlobalResponse) MarshalTo ¶
func (m *QueryFeeSplitGlobalResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryFeeSplitGlobalResponse) MarshalToSizedBuffer ¶
func (m *QueryFeeSplitGlobalResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryFeeSplitGlobalResponse) ProtoMessage ¶
func (*QueryFeeSplitGlobalResponse) ProtoMessage()
func (*QueryFeeSplitGlobalResponse) Reset ¶
func (m *QueryFeeSplitGlobalResponse) Reset()
func (*QueryFeeSplitGlobalResponse) Size ¶
func (m *QueryFeeSplitGlobalResponse) Size() (n int)
func (*QueryFeeSplitGlobalResponse) String ¶
func (m *QueryFeeSplitGlobalResponse) String() string
func (*QueryFeeSplitGlobalResponse) Unmarshal ¶
func (m *QueryFeeSplitGlobalResponse) Unmarshal(dAtA []byte) error
func (*QueryFeeSplitGlobalResponse) XXX_DiscardUnknown ¶
func (m *QueryFeeSplitGlobalResponse) XXX_DiscardUnknown()
func (*QueryFeeSplitGlobalResponse) XXX_Marshal ¶
func (m *QueryFeeSplitGlobalResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryFeeSplitGlobalResponse) XXX_Merge ¶
func (m *QueryFeeSplitGlobalResponse) XXX_Merge(src proto.Message)
func (*QueryFeeSplitGlobalResponse) XXX_Size ¶
func (m *QueryFeeSplitGlobalResponse) XXX_Size() int
func (*QueryFeeSplitGlobalResponse) XXX_Unmarshal ¶
func (m *QueryFeeSplitGlobalResponse) XXX_Unmarshal(b []byte) error
type QueryMessageBusRequest ¶
type QueryMessageBusRequest struct { // chain_id is the chain id ChainId uint64 `protobuf:"varint,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` }
QueryMessageBusRequest is request type for the Query/MessageBus RPC method.
func (*QueryMessageBusRequest) Descriptor ¶
func (*QueryMessageBusRequest) Descriptor() ([]byte, []int)
func (*QueryMessageBusRequest) GetChainId ¶
func (m *QueryMessageBusRequest) GetChainId() uint64
func (*QueryMessageBusRequest) Marshal ¶
func (m *QueryMessageBusRequest) Marshal() (dAtA []byte, err error)
func (*QueryMessageBusRequest) MarshalTo ¶
func (m *QueryMessageBusRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryMessageBusRequest) MarshalToSizedBuffer ¶
func (m *QueryMessageBusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryMessageBusRequest) ProtoMessage ¶
func (*QueryMessageBusRequest) ProtoMessage()
func (*QueryMessageBusRequest) Reset ¶
func (m *QueryMessageBusRequest) Reset()
func (*QueryMessageBusRequest) Size ¶
func (m *QueryMessageBusRequest) Size() (n int)
func (*QueryMessageBusRequest) String ¶
func (m *QueryMessageBusRequest) String() string
func (*QueryMessageBusRequest) Unmarshal ¶
func (m *QueryMessageBusRequest) Unmarshal(dAtA []byte) error
func (*QueryMessageBusRequest) XXX_DiscardUnknown ¶
func (m *QueryMessageBusRequest) XXX_DiscardUnknown()
func (*QueryMessageBusRequest) XXX_Marshal ¶
func (m *QueryMessageBusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryMessageBusRequest) XXX_Merge ¶
func (m *QueryMessageBusRequest) XXX_Merge(src proto.Message)
func (*QueryMessageBusRequest) XXX_Size ¶
func (m *QueryMessageBusRequest) XXX_Size() int
func (*QueryMessageBusRequest) XXX_Unmarshal ¶
func (m *QueryMessageBusRequest) XXX_Unmarshal(b []byte) error
type QueryMessageBusResponse ¶
type QueryMessageBusResponse struct { // message_bus is the MessageBus info MessageBus MessageBusInfo `protobuf:"bytes,1,opt,name=message_bus,json=messageBus,proto3" json:"message_bus"` }
QueryMessageBusResponse is response type for the Query/MessageBus RPC method.
func (*QueryMessageBusResponse) Descriptor ¶
func (*QueryMessageBusResponse) Descriptor() ([]byte, []int)
func (*QueryMessageBusResponse) GetMessageBus ¶
func (m *QueryMessageBusResponse) GetMessageBus() MessageBusInfo
func (*QueryMessageBusResponse) Marshal ¶
func (m *QueryMessageBusResponse) Marshal() (dAtA []byte, err error)
func (*QueryMessageBusResponse) MarshalTo ¶
func (m *QueryMessageBusResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryMessageBusResponse) MarshalToSizedBuffer ¶
func (m *QueryMessageBusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryMessageBusResponse) ProtoMessage ¶
func (*QueryMessageBusResponse) ProtoMessage()
func (*QueryMessageBusResponse) Reset ¶
func (m *QueryMessageBusResponse) Reset()
func (*QueryMessageBusResponse) Size ¶
func (m *QueryMessageBusResponse) Size() (n int)
func (*QueryMessageBusResponse) String ¶
func (m *QueryMessageBusResponse) String() string
func (*QueryMessageBusResponse) Unmarshal ¶
func (m *QueryMessageBusResponse) Unmarshal(dAtA []byte) error
func (*QueryMessageBusResponse) XXX_DiscardUnknown ¶
func (m *QueryMessageBusResponse) XXX_DiscardUnknown()
func (*QueryMessageBusResponse) XXX_Marshal ¶
func (m *QueryMessageBusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryMessageBusResponse) XXX_Merge ¶
func (m *QueryMessageBusResponse) XXX_Merge(src proto.Message)
func (*QueryMessageBusResponse) XXX_Size ¶
func (m *QueryMessageBusResponse) XXX_Size() int
func (*QueryMessageBusResponse) XXX_Unmarshal ¶
func (m *QueryMessageBusResponse) XXX_Unmarshal(b []byte) error
type QueryMessageExistsRequest ¶
type QueryMessageExistsRequest struct {
MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
}
QueryMessageExistsRequest is request type for the Query/MessageExists RPC method.
func (*QueryMessageExistsRequest) Descriptor ¶
func (*QueryMessageExistsRequest) Descriptor() ([]byte, []int)
func (*QueryMessageExistsRequest) GetMessageId ¶
func (m *QueryMessageExistsRequest) GetMessageId() string
func (*QueryMessageExistsRequest) Marshal ¶
func (m *QueryMessageExistsRequest) Marshal() (dAtA []byte, err error)
func (*QueryMessageExistsRequest) MarshalTo ¶
func (m *QueryMessageExistsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryMessageExistsRequest) MarshalToSizedBuffer ¶
func (m *QueryMessageExistsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryMessageExistsRequest) ProtoMessage ¶
func (*QueryMessageExistsRequest) ProtoMessage()
func (*QueryMessageExistsRequest) Reset ¶
func (m *QueryMessageExistsRequest) Reset()
func (*QueryMessageExistsRequest) Size ¶
func (m *QueryMessageExistsRequest) Size() (n int)
func (*QueryMessageExistsRequest) String ¶
func (m *QueryMessageExistsRequest) String() string
func (*QueryMessageExistsRequest) Unmarshal ¶
func (m *QueryMessageExistsRequest) Unmarshal(dAtA []byte) error
func (*QueryMessageExistsRequest) XXX_DiscardUnknown ¶
func (m *QueryMessageExistsRequest) XXX_DiscardUnknown()
func (*QueryMessageExistsRequest) XXX_Marshal ¶
func (m *QueryMessageExistsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryMessageExistsRequest) XXX_Merge ¶
func (m *QueryMessageExistsRequest) XXX_Merge(src proto.Message)
func (*QueryMessageExistsRequest) XXX_Size ¶
func (m *QueryMessageExistsRequest) XXX_Size() int
func (*QueryMessageExistsRequest) XXX_Unmarshal ¶
func (m *QueryMessageExistsRequest) XXX_Unmarshal(b []byte) error
type QueryMessageExistsResponse ¶
type QueryMessageExistsResponse struct {
Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
}
QueryMessageExistsResponse is response type for the Query/MessageExists RPC method.
func (*QueryMessageExistsResponse) Descriptor ¶
func (*QueryMessageExistsResponse) Descriptor() ([]byte, []int)
func (*QueryMessageExistsResponse) GetExists ¶
func (m *QueryMessageExistsResponse) GetExists() bool
func (*QueryMessageExistsResponse) Marshal ¶
func (m *QueryMessageExistsResponse) Marshal() (dAtA []byte, err error)
func (*QueryMessageExistsResponse) MarshalTo ¶
func (m *QueryMessageExistsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryMessageExistsResponse) MarshalToSizedBuffer ¶
func (m *QueryMessageExistsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryMessageExistsResponse) ProtoMessage ¶
func (*QueryMessageExistsResponse) ProtoMessage()
func (*QueryMessageExistsResponse) Reset ¶
func (m *QueryMessageExistsResponse) Reset()
func (*QueryMessageExistsResponse) Size ¶
func (m *QueryMessageExistsResponse) Size() (n int)
func (*QueryMessageExistsResponse) String ¶
func (m *QueryMessageExistsResponse) String() string
func (*QueryMessageExistsResponse) Unmarshal ¶
func (m *QueryMessageExistsResponse) Unmarshal(dAtA []byte) error
func (*QueryMessageExistsResponse) XXX_DiscardUnknown ¶
func (m *QueryMessageExistsResponse) XXX_DiscardUnknown()
func (*QueryMessageExistsResponse) XXX_Marshal ¶
func (m *QueryMessageExistsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryMessageExistsResponse) XXX_Merge ¶
func (m *QueryMessageExistsResponse) XXX_Merge(src proto.Message)
func (*QueryMessageExistsResponse) XXX_Size ¶
func (m *QueryMessageExistsResponse) XXX_Size() int
func (*QueryMessageExistsResponse) XXX_Unmarshal ¶
func (m *QueryMessageExistsResponse) XXX_Unmarshal(b []byte) error
type QueryMessageRequest ¶
type QueryMessageRequest struct { // message_id is the message id MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"` }
QueryMessageRequest is request type for the Query/Message RPC method.
func (*QueryMessageRequest) Descriptor ¶
func (*QueryMessageRequest) Descriptor() ([]byte, []int)
func (*QueryMessageRequest) GetMessageId ¶
func (m *QueryMessageRequest) GetMessageId() string
func (*QueryMessageRequest) Marshal ¶
func (m *QueryMessageRequest) Marshal() (dAtA []byte, err error)
func (*QueryMessageRequest) MarshalTo ¶
func (m *QueryMessageRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryMessageRequest) MarshalToSizedBuffer ¶
func (m *QueryMessageRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryMessageRequest) ProtoMessage ¶
func (*QueryMessageRequest) ProtoMessage()
func (*QueryMessageRequest) Reset ¶
func (m *QueryMessageRequest) Reset()
func (*QueryMessageRequest) Size ¶
func (m *QueryMessageRequest) Size() (n int)
func (*QueryMessageRequest) String ¶
func (m *QueryMessageRequest) String() string
func (*QueryMessageRequest) Unmarshal ¶
func (m *QueryMessageRequest) Unmarshal(dAtA []byte) error
func (*QueryMessageRequest) XXX_DiscardUnknown ¶
func (m *QueryMessageRequest) XXX_DiscardUnknown()
func (*QueryMessageRequest) XXX_Marshal ¶
func (m *QueryMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryMessageRequest) XXX_Merge ¶
func (m *QueryMessageRequest) XXX_Merge(src proto.Message)
func (*QueryMessageRequest) XXX_Size ¶
func (m *QueryMessageRequest) XXX_Size() int
func (*QueryMessageRequest) XXX_Unmarshal ¶
func (m *QueryMessageRequest) XXX_Unmarshal(b []byte) error
type QueryMessageResponse ¶
type QueryMessageResponse struct { // message is the message queried Message Message `protobuf:"bytes,1,opt,name=message,proto3" json:"message"` }
QueryMessageResponse is response type for the Query/Message RPC method.
func (*QueryMessageResponse) Descriptor ¶
func (*QueryMessageResponse) Descriptor() ([]byte, []int)
func (*QueryMessageResponse) GetMessage ¶
func (m *QueryMessageResponse) GetMessage() Message
func (*QueryMessageResponse) Marshal ¶
func (m *QueryMessageResponse) Marshal() (dAtA []byte, err error)
func (*QueryMessageResponse) MarshalTo ¶
func (m *QueryMessageResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryMessageResponse) MarshalToSizedBuffer ¶
func (m *QueryMessageResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryMessageResponse) ProtoMessage ¶
func (*QueryMessageResponse) ProtoMessage()
func (*QueryMessageResponse) Reset ¶
func (m *QueryMessageResponse) Reset()
func (*QueryMessageResponse) Size ¶
func (m *QueryMessageResponse) Size() (n int)
func (*QueryMessageResponse) String ¶
func (m *QueryMessageResponse) String() string
func (*QueryMessageResponse) Unmarshal ¶
func (m *QueryMessageResponse) Unmarshal(dAtA []byte) error
func (*QueryMessageResponse) XXX_DiscardUnknown ¶
func (m *QueryMessageResponse) XXX_DiscardUnknown()
func (*QueryMessageResponse) XXX_Marshal ¶
func (m *QueryMessageResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryMessageResponse) XXX_Merge ¶
func (m *QueryMessageResponse) XXX_Merge(src proto.Message)
func (*QueryMessageResponse) XXX_Size ¶
func (m *QueryMessageResponse) XXX_Size() int
func (*QueryMessageResponse) XXX_Unmarshal ¶
func (m *QueryMessageResponse) XXX_Unmarshal(b []byte) error
type QueryParamsRequest ¶
type QueryParamsRequest struct { }
QueryParamsRequest is request type for the Query/Params RPC method.
func (*QueryParamsRequest) Descriptor ¶
func (*QueryParamsRequest) Descriptor() ([]byte, []int)
func (*QueryParamsRequest) Marshal ¶
func (m *QueryParamsRequest) Marshal() (dAtA []byte, err error)
func (*QueryParamsRequest) MarshalTo ¶
func (m *QueryParamsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryParamsRequest) MarshalToSizedBuffer ¶
func (m *QueryParamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryParamsRequest) ProtoMessage ¶
func (*QueryParamsRequest) ProtoMessage()
func (*QueryParamsRequest) Reset ¶
func (m *QueryParamsRequest) Reset()
func (*QueryParamsRequest) Size ¶
func (m *QueryParamsRequest) Size() (n int)
func (*QueryParamsRequest) String ¶
func (m *QueryParamsRequest) String() string
func (*QueryParamsRequest) Unmarshal ¶
func (m *QueryParamsRequest) Unmarshal(dAtA []byte) error
func (*QueryParamsRequest) XXX_DiscardUnknown ¶
func (m *QueryParamsRequest) XXX_DiscardUnknown()
func (*QueryParamsRequest) XXX_Marshal ¶
func (m *QueryParamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryParamsRequest) XXX_Merge ¶
func (m *QueryParamsRequest) XXX_Merge(src proto.Message)
func (*QueryParamsRequest) XXX_Size ¶
func (m *QueryParamsRequest) XXX_Size() int
func (*QueryParamsRequest) XXX_Unmarshal ¶
func (m *QueryParamsRequest) XXX_Unmarshal(b []byte) error
type QueryParamsResponse ¶
type QueryParamsResponse struct { // params holds all the parameters of this module. Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"` }
QueryParamsResponse is response type for the Query/Params RPC method.
func (*QueryParamsResponse) Descriptor ¶
func (*QueryParamsResponse) Descriptor() ([]byte, []int)
func (*QueryParamsResponse) GetParams ¶
func (m *QueryParamsResponse) GetParams() Params
func (*QueryParamsResponse) Marshal ¶
func (m *QueryParamsResponse) Marshal() (dAtA []byte, err error)
func (*QueryParamsResponse) MarshalTo ¶
func (m *QueryParamsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryParamsResponse) MarshalToSizedBuffer ¶
func (m *QueryParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryParamsResponse) ProtoMessage ¶
func (*QueryParamsResponse) ProtoMessage()
func (*QueryParamsResponse) Reset ¶
func (m *QueryParamsResponse) Reset()
func (*QueryParamsResponse) Size ¶
func (m *QueryParamsResponse) Size() (n int)
func (*QueryParamsResponse) String ¶
func (m *QueryParamsResponse) String() string
func (*QueryParamsResponse) Unmarshal ¶
func (m *QueryParamsResponse) Unmarshal(dAtA []byte) error
func (*QueryParamsResponse) XXX_DiscardUnknown ¶
func (m *QueryParamsResponse) XXX_DiscardUnknown()
func (*QueryParamsResponse) XXX_Marshal ¶
func (m *QueryParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryParamsResponse) XXX_Merge ¶
func (m *QueryParamsResponse) XXX_Merge(src proto.Message)
func (*QueryParamsResponse) XXX_Size ¶
func (m *QueryParamsResponse) XXX_Size() int
func (*QueryParamsResponse) XXX_Unmarshal ¶
func (m *QueryParamsResponse) XXX_Unmarshal(b []byte) error
type QueryServer ¶
type QueryServer interface { // Params queries the parameters of the module. Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error) // ExecutionContexts returns the execution contexts of all messages that have enough signatures and are ready for execution. // Note that it may return messages that are being or have been executed by an executor. // The SGN will monitor the execution event on-chain. Once it reaches consensus that a message has been executed, the query will stop // returning the info about that particular message. // // The query can be optionally filtered by destination chain IDs and / or destination contract addresses. ExecutionContexts(context.Context, *QueryExecutionContextsRequest) (*QueryExecutionContextsResponse, error) ExecutionContextBySrcTransfer(context.Context, *QueryExecutionContextBySrcTransferRequest) (*QueryExecutionContextBySrcTransferResponse, error) ExecutionContextByMsgId(context.Context, *QueryExecutionContextByMsgIdRequest) (*QueryExecutionContextByMsgIdResponse, error) // Message queries the message details. Message(context.Context, *QueryMessageRequest) (*QueryMessageResponse, error) // Message queries whether a message exists. MessageExists(context.Context, *QueryMessageExistsRequest) (*QueryMessageExistsResponse, error) // Message queries whether a message is active. IsMessageActive(context.Context, *IsMessageActiveRequest) (*IsMessageActiveResponse, error) // MessageBus queries the message bus contract info. MessageBus(context.Context, *QueryMessageBusRequest) (*QueryMessageBusResponse, error) FeeSplitGlobal(context.Context, *EmptyRequest) (*QueryFeeSplitGlobalResponse, error) // FeeClaimInfo queries the info for claiming message fees on-chain. FeeClaimInfo(context.Context, *QueryFeeClaimInfoRequest) (*QueryFeeClaimInfoResponse, error) }
QueryServer is the server API for Query service.
type Transfer ¶
type Transfer struct { // token defines the token address of a transfer. Token []byte `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty" yaml:"token"` // amount defines the amount of a transfer. Amount string `protobuf:"bytes,2,opt,name=amount,proto3" json:"amount,omitempty" yaml:"amount"` // wd_seq_num defines the sequence number required for withdrawals from a liquidity bridge. WdSeqNum uint64 `protobuf:"varint,3,opt,name=wd_seq_num,json=wdSeqNum,proto3" json:"wd_seq_num,omitempty" yaml:"wd_seq_num"` }
Transfer defines the optional transfer info associated with a message. This is not directly stored in consensus db.
func (*Transfer) Descriptor ¶
func (*Transfer) GetWdSeqNum ¶
func (*Transfer) MarshalToSizedBuffer ¶
func (*Transfer) ProtoMessage ¶
func (*Transfer) ProtoMessage()
func (*Transfer) XXX_DiscardUnknown ¶
func (m *Transfer) XXX_DiscardUnknown()
func (*Transfer) XXX_Marshal ¶
func (*Transfer) XXX_Unmarshal ¶
type TransferType ¶
type TransferType int32
TransferType defines the type of a transfer at the receiver side (dst chain) associated with a message, if applicable.
const ( // TRANSFER_TYPE_NULL indicates no transfer association. TRANSFER_TYPE_NULL TransferType = 0 // TRANSFER_TYPE_LIQUIDITY_RELAY defines a relay transfer via a liquidity bridge. TRANSFER_TYPE_LIQUIDITY_RELAY TransferType = 1 // TRANSFER_TYPE_LIQUIDITY_WITHDRAW defines a withdraw transfer from a liquidity bridge. TRANSFER_TYPE_LIQUIDITY_WITHDRAW TransferType = 2 // TRANSFER_TYPE_PEG_MINT defines a mint transfer via a pegged token bridge. TRANSFER_TYPE_PEG_MINT TransferType = 3 // TRANSFER_TYPE_PEG_MINT defines a withdraw transfer from an original token vault. TRANSFER_TYPE_PEG_WITHDRAW TransferType = 4 // TRANSFER_TYPE_PEG_V2_MINT defines a mint transfer via a pegged token bridge v2. TRANSFER_TYPE_PEG_V2_MINT TransferType = 5 // TRANSFER_TYPE_PEG_V2_WITHDRAW defines a withdraw transfer from an original token vault v2. TRANSFER_TYPE_PEG_V2_WITHDRAW TransferType = 6 )
func (TransferType) EnumDescriptor ¶
func (TransferType) EnumDescriptor() ([]byte, []int)
func (TransferType) String ¶
func (x TransferType) String() string
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct { }
UnimplementedQueryServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryServer) ExecutionContextByMsgId ¶
func (*UnimplementedQueryServer) ExecutionContextByMsgId(ctx context.Context, req *QueryExecutionContextByMsgIdRequest) (*QueryExecutionContextByMsgIdResponse, error)
func (*UnimplementedQueryServer) ExecutionContextBySrcTransfer ¶
func (*UnimplementedQueryServer) ExecutionContextBySrcTransfer(ctx context.Context, req *QueryExecutionContextBySrcTransferRequest) (*QueryExecutionContextBySrcTransferResponse, error)
func (*UnimplementedQueryServer) ExecutionContexts ¶
func (*UnimplementedQueryServer) ExecutionContexts(ctx context.Context, req *QueryExecutionContextsRequest) (*QueryExecutionContextsResponse, error)
func (*UnimplementedQueryServer) FeeClaimInfo ¶
func (*UnimplementedQueryServer) FeeClaimInfo(ctx context.Context, req *QueryFeeClaimInfoRequest) (*QueryFeeClaimInfoResponse, error)
func (*UnimplementedQueryServer) FeeSplitGlobal ¶
func (*UnimplementedQueryServer) FeeSplitGlobal(ctx context.Context, req *EmptyRequest) (*QueryFeeSplitGlobalResponse, error)
func (*UnimplementedQueryServer) IsMessageActive ¶
func (*UnimplementedQueryServer) IsMessageActive(ctx context.Context, req *IsMessageActiveRequest) (*IsMessageActiveResponse, error)
func (*UnimplementedQueryServer) Message ¶
func (*UnimplementedQueryServer) Message(ctx context.Context, req *QueryMessageRequest) (*QueryMessageResponse, error)
func (*UnimplementedQueryServer) MessageBus ¶
func (*UnimplementedQueryServer) MessageBus(ctx context.Context, req *QueryMessageBusRequest) (*QueryMessageBusResponse, error)
func (*UnimplementedQueryServer) MessageExists ¶
func (*UnimplementedQueryServer) MessageExists(ctx context.Context, req *QueryMessageExistsRequest) (*QueryMessageExistsResponse, error)
func (*UnimplementedQueryServer) Params ¶
func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)