types

package
v0.0.0-...-77861b7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 16, 2023 License: GPL-3.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var BridgeType_name = map[int32]string{
	0: "BRIDGE_TYPE_NULL",
	1: "BRIDGE_TYPE_LIQUIDITY",
	2: "BRIDGE_TYPE_PEG_VAULT",
	3: "BRIDGE_TYPE_PEG_BRIDGE",
}
View Source 
var BridgeType_value = map[string]int32{
	"BRIDGE_TYPE_NULL":       0,
	"BRIDGE_TYPE_LIQUIDITY":  1,
	"BRIDGE_TYPE_PEG_VAULT":  2,
	"BRIDGE_TYPE_PEG_BRIDGE": 3,
}
View Source 
var ExecutionStatus_name = map[int32]string{
	0: "EXECUTION_STATUS_NULL",
	1: "EXECUTION_STATUS_SUCCESS",
	2: "EXECUTION_STATUS_FAILURE",
	3: "EXECUTION_STATUS_FALLBACK",
}
View Source 
var ExecutionStatus_value = map[string]int32{
	"EXECUTION_STATUS_NULL":     0,
	"EXECUTION_STATUS_SUCCESS":  1,
	"EXECUTION_STATUS_FAILURE":  2,
	"EXECUTION_STATUS_FALLBACK": 3,
}
View Source 
var MsgType_name = map[int32]string{
	0: "MSG_TYPE_MESSAGE_WITH_TRANSFER",
	1: "MSG_TYPE_MESSAGE",
}
View Source 
var MsgType_value = map[string]int32{
	"MSG_TYPE_MESSAGE_WITH_TRANSFER": 0,
	"MSG_TYPE_MESSAGE":               1,
}
View Source 
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",
}
View Source 
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 ComputeMessageIdFromDstTransfer 

func ComputeMessageIdFromDstTransfer(dstTransferId []byte, dstBridgeAddr eth.Addr) []byte

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) MarshalTo 

func (m *EmptyRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ExecutionContext) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *FeeClaimDetails) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *FeeClaimInfo) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*FeeSplit) GetCelerTreasuryAddr 

func (m *FeeSplit) GetCelerTreasuryAddr() string

func (*FeeSplit) GetCelerTreasuryFeePerc 

func (m *FeeSplit) GetCelerTreasuryFeePerc() uint32

func (*FeeSplit) Marshal 

func (m *FeeSplit) Marshal() (dAtA []byte, err error)

func (*FeeSplit) MarshalTo 

func (m *FeeSplit) MarshalTo(dAtA []byte) (int, error)

func (*FeeSplit) MarshalToSizedBuffer 

func (m *FeeSplit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FeeSplit) ProtoMessage 

func (*FeeSplit) ProtoMessage()

func (*FeeSplit) Reset 

func (m *FeeSplit) Reset()

func (*FeeSplit) Size 

func (m *FeeSplit) Size() (n int)

func (*FeeSplit) String 

func (m *FeeSplit) String() string

func (*FeeSplit) Unmarshal 

func (m *FeeSplit) Unmarshal(dAtA []byte) error

func (*FeeSplit) XXX_DiscardUnknown 

func (m *FeeSplit) XXX_DiscardUnknown()

func (*FeeSplit) XXX_Marshal 

func (m *FeeSplit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FeeSplit) XXX_Merge 

func (m *FeeSplit) XXX_Merge(src proto.Message)

func (*FeeSplit) XXX_Size 

func (m *FeeSplit) XXX_Size() int

func (*FeeSplit) XXX_Unmarshal 

func (m *FeeSplit) XXX_Unmarshal(b []byte) error

type InputData 

type InputData struct {
	// contains filtered or unexported fields
}

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 (m *Message) ComputeMessageIdNoTransfer() []byte

func (*Message) ComputeProxyChainMessageIdNoTransfer 

func (m *Message) ComputeProxyChainMessageIdNoTransfer() []byte

func (*Message) Descriptor 

func (*Message) Descriptor() ([]byte, []int)

func (*Message) GetData 

func (m *Message) GetData() []byte

func (*Message) GetDstChainId 

func (m *Message) GetDstChainId() uint64

func (*Message) GetExecutionStatus 

func (m *Message) GetExecutionStatus() ExecutionStatus

func (*Message) GetFee 

func (m *Message) GetFee() string

func (*Message) GetIsBytesAddr 

func (m *Message) GetIsBytesAddr() bool

func (*Message) GetLastReqTime 

func (m *Message) GetLastReqTime() int64

func (*Message) GetReceiver 

func (m *Message) GetReceiver() string

func (*Message) GetSender 

func (m *Message) GetSender() string

func (*Message) GetSignatures 

func (m *Message) GetSignatures() []types.Signature

func (*Message) GetSrcChainId 

func (m *Message) GetSrcChainId() uint64

func (*Message) GetSrcTxHash 

func (m *Message) GetSrcTxHash() string

func (*Message) GetTransferRefId 

func (m *Message) GetTransferRefId() []byte

func (*Message) GetTransferType 

func (m *Message) GetTransferType() TransferType

func (*Message) Marshal 

func (m *Message) Marshal() (dAtA []byte, err error)

func (*Message) MarshalTo 

func (m *Message) MarshalTo(dAtA []byte) (int, error)

func (*Message) MarshalToSizedBuffer 

func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Message) PrettyLog 

func (m *Message) PrettyLog() string

func (*Message) PrettyPrint 

func (m *Message) PrettyPrint()

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) Size 

func (m *Message) Size() (n int)

func (*Message) String 

func (m *Message) String() string

func (*Message) Unmarshal 

func (m *Message) Unmarshal(dAtA []byte) error

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Message) XXX_Merge 

func (m *Message) XXX_Merge(src proto.Message)

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

func (m *Message) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *MessageBusInfo) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *MsgProposal) MarshalTo(dAtA []byte) (int, 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 

const (
	MsgType_MSG_TYPE_MESSAGE_WITH_TRANSFER MsgType = 0
	MsgType_MSG_TYPE_MESSAGE               MsgType = 1
)

func (MsgType) EnumDescriptor 

func (MsgType) EnumDescriptor() ([]byte, []int)

func (MsgType) String 

func (x MsgType) String() string

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) Descriptor() ([]byte, []int)

func (*Params) GetMessageExpiredTime 

func (m *Params) GetMessageExpiredTime() time.Duration

func (*Params) GetTriggerSignCooldown 

func (m *Params) GetTriggerSignCooldown() time.Duration

func (*Params) Marshal 

func (m *Params) Marshal() (dAtA []byte, err error)

func (*Params) MarshalTo 

func (m *Params) MarshalTo(dAtA []byte) (int, error)

func (*Params) MarshalToSizedBuffer 

func (m *Params) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

func (m *Params) Size() (n int)

func (Params) String 

func (p Params) String() string

String implements the Stringer interface.

func (*Params) Unmarshal 

func (m *Params) Unmarshal(dAtA []byte) error

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Params) XXX_Merge 

func (m *Params) XXX_Merge(src proto.Message)

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

func (m *Params) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*Transfer) GetAmount 

func (m *Transfer) GetAmount() string

func (*Transfer) GetToken 

func (m *Transfer) GetToken() []byte

func (*Transfer) GetWdSeqNum 

func (m *Transfer) GetWdSeqNum() uint64

func (*Transfer) Marshal 

func (m *Transfer) Marshal() (dAtA []byte, err error)

func (*Transfer) MarshalTo 

func (m *Transfer) MarshalTo(dAtA []byte) (int, error)

func (*Transfer) MarshalToSizedBuffer 

func (m *Transfer) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Transfer) ProtoMessage 

func (*Transfer) ProtoMessage()

func (*Transfer) Reset 

func (m *Transfer) Reset()

func (*Transfer) Size 

func (m *Transfer) Size() (n int)

func (*Transfer) String 

func (m *Transfer) String() string

func (*Transfer) Unmarshal 

func (m *Transfer) Unmarshal(dAtA []byte) error

func (*Transfer) XXX_DiscardUnknown 

func (m *Transfer) XXX_DiscardUnknown()

func (*Transfer) XXX_Marshal 

func (m *Transfer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Transfer) XXX_Merge 

func (m *Transfer) XXX_Merge(src proto.Message)

func (*Transfer) XXX_Size 

func (m *Transfer) XXX_Size() int

func (*Transfer) XXX_Unmarshal 

func (m *Transfer) XXX_Unmarshal(b []byte) error

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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.