types

package
v1.0.14-beta.rc1 Latest Latest
Warning

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

 Go to latest Published: Oct 19, 2022 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// FlagEthereumChainID flag for passing the Ethereum chain id field
	FlagEthereumChainID string = "ethereum-chain-id"
	// FlagTokenContractAddr flag for passing the token contract address field
	FlagTokenContractAddr string = "token-contract-address"
)
View Source 
const (
	// ModuleName is the name of the ethereum bridge module
	ModuleName = "ethbridge"

	// StoreKey is the string store representation
	StoreKey = ModuleName

	// QuerierRoute is the querier route for the ethereum bridge module
	QuerierRoute = ModuleName

	// RouterKey is the msg router key for the ethereum bridge module
	RouterKey = ModuleName

	// PeggyTokenKey is the key for peggy token list
	PeggyTokenKey = StoreKey + "PeggyToken"

	// ceth symbol
	CethSymbol = "ceth"
)
View Source 
const (
	QueryEthProphecy = "prophecies"
	QueryBlacklist   = "blacklist"
)

query endpoints supported by the oracle Querier

View Source 
const (
	TestEthereumChainID       = 3
	TestBridgeContractAddress = "0xC4cE93a5699c68241fc2fB503Fb0f21724A624BB"
	TestAddress               = "cosmos1gn8409qq9hnrxde37kuxwx5hrxpfpv8426szuv"
	TestValidator             = "cosmos1xdp5tvt7lxh8rf9xx07wy2xlagzhq24ha48xtq"
	TestNonce                 = 0
	TestTokenContractAddress  = "0x0000000000000000000000000000000000000000"
	TestEthereumAddress       = "0x7B95B6EC7EbD73572298cEf32Bb54FA408207359"
	AltTestEthereumAddress    = "0x7B95B6EC7EbD73572298cEf32Bb54FA408207344"
	Alt2TestEthereumAddress   = "0x7B95B6EC7EbD73572298cEf32Bb54FA408207333"
	TestCoinsSymbol           = "eth"
	TestCoinsLockedSymbol     = "ceth"
	AltTestCoinsAmount        = 12
	AltTestCoinsSymbol        = "eth"
	TestCoinIntAmount         = 10
)
View Source 
const PeggedCoinPrefix = "c"

Variables

View Source 
var (
	ErrInvalidEthNonce   = sdkerrors.Register(ModuleName, 1, "invalid ethereum nonce provided, must be >= 0")
	ErrInvalidEthAddress = sdkerrors.Register(ModuleName, 2,
		"invalid ethereum address provided, must be a valid hex-encoded Ethereum address")
	ErrJSONMarshalling  = sdkerrors.Register(ModuleName, 3, "error marshalling JSON for this claim")
	ErrInvalidEthSymbol = sdkerrors.Register(ModuleName, 4,
		"invalid symbol provided, symbol 'eth' must have null address set as token contract address")
	ErrInvalidClaimType       = sdkerrors.Register(ModuleName, 5, "invalid claim type provided")
	ErrInvalidEthereumChainID = sdkerrors.Register(ModuleName, 6, "invalid ethereum chain id")
	ErrInvalidAmount          = sdkerrors.Register(ModuleName, 7, "amount must be a valid integer > 0")
	ErrInvalidSymbol          = sdkerrors.Register(ModuleName, 8, "symbol must be 1 character or more")
	ErrInvalidBurnSymbol      = sdkerrors.Register(ModuleName, 9,
		fmt.Sprintf("symbol of token to burn must be in the form %v{ethereumSymbol}", PeggedCoinPrefix))
	ErrCethAmount = sdkerrors.Register(ModuleName, 10, "not enough ceth provided")
)
View Source 
var (
	EventTypeCreateClaim              = "create_claim"
	EventTypeProphecyStatus           = "prophecy_status"
	EventTypeBurn                     = "burn"
	EventTypeLock                     = "lock"
	EventTypeUpdateWhiteListValidator = "update_whitelist_validator"

	AttributeKeyEthereumSender      = "ethereum_sender"
	AttributeKeyEthereumSenderNonce = "ethereum_sender_nonce"
	AttributeKeyCosmosReceiver      = "cosmos_receiver"
	AttributeKeyAmount              = "amount"
	AttributeKeyCethAmount          = "ceth_amount"
	AttributeKeySymbol              = "symbol"
	AttributeKeyCoins               = "coins"
	AttributeKeyStatus              = "status"
	AttributeKeyClaimType           = "claim_type"
	AttributeKeyValidator           = "validator"
	AttributeKeyOperationType       = "operation_type"
	AttributeKeyCethReceiverAccount = "ceth_receiver_account"

	AttributeKeyEthereumChainID      = "ethereum_chain_id"
	AttributeKeyTokenContract        = "token_contract_address"
	AttributeKeyCosmosSender         = "cosmos_sender"
	AttributeKeyCosmosSenderSequence = "cosmos_sender_sequence"
	AttributeKeyEthereumReceiver     = "ethereum_receiver"

	AttributeValueCategory = ModuleName
)

Ethbridge module event types

View Source 
var (
	PeggyTokenKeyPrefix       = []byte{0x00}
	CethReceiverAccountPrefix = []byte{0x01}
	BlacklistPrefix           = []byte{0x02}
)
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 (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var AltTestCoinsAmountSDKInt = sdk.NewInt(12)
View Source 
var ClaimType_name = map[int32]string{
	0: "CLAIM_TYPE_UNSPECIFIED",
	1: "CLAIM_TYPE_BURN",
	2: "CLAIM_TYPE_LOCK",
}
View Source 
var ClaimType_value = map[string]int32{
	"CLAIM_TYPE_UNSPECIFIED": 0,
	"CLAIM_TYPE_BURN":        1,
	"CLAIM_TYPE_LOCK":        2,
}
View Source 
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)
View Source 
var TestCoinsAmount = sdk.NewInt(10)

Functions

func CreateOracleClaimFromEthClaim 

func CreateOracleClaimFromEthClaim(ethClaim *EthBridgeClaim) (oracletypes.Claim, error)

CreateOracleClaimFromEthClaim converts a specific ethereum bridge claim to a general oracle claim to be used by the oracle module. The oracle module expects every claim for a particular prophecy to have the same id, so this id must be created in a deterministic way that all validators can follow. For this, we use the Nonce an Ethereum Sender provided, as all validators will see this same data from the smart contract.

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec registers concrete types on the Amino codec

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type AccountKeeper 

type AccountKeeper interface {
	GetAccount(sdk.Context, sdk.AccAddress) authtypes.AccountI
	SetModuleAccount(sdk.Context, authtypes.ModuleAccountI)
}

AccountKeeper defines the expected account keeper

type AdminKeeper added in v0.13.4 

type AdminKeeper interface {
	IsAdminAccount(ctx sdk.Context, moduleName admintypes.AdminType, adminAccount sdk.AccAddress) bool
}

type BankKeeper 

type BankKeeper interface {
	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
	MintCoins(ctx sdk.Context, name string, amt sdk.Coins) error
	BurnCoins(ctx sdk.Context, name string, amt sdk.Coins) error
	SendCoins(ctx sdk.Context, fromAddr sdk.AccAddress, toAddr sdk.AccAddress, amt sdk.Coins) error
}

BankKeeper defines the expected supply keeper

type ClaimType 

type ClaimType int32

Claim type enum 

const (
	// Unspecified claim type
	ClaimType_CLAIM_TYPE_UNSPECIFIED ClaimType = 0
	// Burn claim type
	ClaimType_CLAIM_TYPE_BURN ClaimType = 1
	// Lock claim type
	ClaimType_CLAIM_TYPE_LOCK ClaimType = 2
)

func (ClaimType) EnumDescriptor 

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

func (ClaimType) String 

func (x ClaimType) String() string

type EthBridgeClaim 

type EthBridgeClaim struct {
	EthereumChainId int64 `` /* 134-byte string literal not displayed */
	// bridge_contract_address is an EthereumAddress
	BridgeContractAddress string `` /* 157-byte string literal not displayed */
	Nonce                 int64  `protobuf:"varint,3,opt,name=nonce,proto3" json:"nonce,omitempty" yaml:"nonce"`
	Symbol                string `protobuf:"bytes,4,opt,name=symbol,proto3" json:"symbol,omitempty" yaml:"symbol"`
	// token_contract_address is an EthereumAddress
	TokenContractAddress string `` /* 153-byte string literal not displayed */
	// ethereum_sender is an EthereumAddress
	EthereumSender string `` /* 126-byte string literal not displayed */
	// cosmos_receiver is an sdk.AccAddress
	CosmosReceiver string `` /* 126-byte string literal not displayed */
	// validator_address is an sdk.ValAddress
	ValidatorAddress string                                 `` /* 134-byte string literal not displayed */
	Amount           github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,9,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount" yaml:"amount"`
	ClaimType        ClaimType                              `` /* 126-byte string literal not displayed */
}

EthBridgeClaim is a structure that contains all the data for a particular bridge claim

func CreateEthClaimFromOracleString 

func CreateEthClaimFromOracleString(
	ethereumChainID int64,
	bridgeContract EthereumAddress,
	nonce int64,
	ethereumAddress EthereumAddress,
	validator sdk.ValAddress,
	oracleClaimString string,
) (*EthBridgeClaim, error)

CreateEthClaimFromOracleString converts a string from any generic claim from the oracle module into an ethereum bridge specific claim.

func CreateTestEthClaim 

func CreateTestEthClaim(
	t *testing.T, testContractAddress EthereumAddress, testTokenAddress EthereumAddress,
	validatorAddress sdk.ValAddress, testEthereumAddress EthereumAddress, amount sdk.Int, symbol string, claimType ClaimType,
) *EthBridgeClaim

func MapOracleClaimsToEthBridgeClaims 

func MapOracleClaimsToEthBridgeClaims(
	ethereumChainID int64,
	bridgeContract EthereumAddress,
	nonce int64,
	symbol string,
	tokenContract EthereumAddress,
	ethereumSender EthereumAddress,
	oracleValidatorClaims map[string]string,
	f func(int64, EthereumAddress, int64, EthereumAddress, sdk.ValAddress, string) (*EthBridgeClaim, error),
) ([]*EthBridgeClaim, error)

MapOracleClaimsToEthBridgeClaims maps a set of generic oracle claim data into EthBridgeClaim objects

func NewEthBridgeClaim 

func NewEthBridgeClaim(
	ethereumChainID int64,
	bridgeContract EthereumAddress,
	nonce int64,
	symbol string,
	tokenContact EthereumAddress,
	ethereumSender EthereumAddress,
	cosmosReceiver sdk.AccAddress,
	validator sdk.ValAddress,
	amount sdk.Int,
	claimType ClaimType,
) *EthBridgeClaim

NewEthBridgeClaim is a constructor function for NewEthBridgeClaim

func (*EthBridgeClaim) Descriptor 

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

func (*EthBridgeClaim) GetBridgeContractAddress 

func (m *EthBridgeClaim) GetBridgeContractAddress() string

func (*EthBridgeClaim) GetClaimType 

func (m *EthBridgeClaim) GetClaimType() ClaimType

func (*EthBridgeClaim) GetCosmosReceiver 

func (m *EthBridgeClaim) GetCosmosReceiver() string

func (*EthBridgeClaim) GetEthereumChainId 

func (m *EthBridgeClaim) GetEthereumChainId() int64

func (*EthBridgeClaim) GetEthereumSender 

func (m *EthBridgeClaim) GetEthereumSender() string

func (*EthBridgeClaim) GetNonce 

func (m *EthBridgeClaim) GetNonce() int64

func (*EthBridgeClaim) GetSymbol 

func (m *EthBridgeClaim) GetSymbol() string

func (*EthBridgeClaim) GetTokenContractAddress 

func (m *EthBridgeClaim) GetTokenContractAddress() string

func (*EthBridgeClaim) GetValidatorAddress 

func (m *EthBridgeClaim) GetValidatorAddress() string

func (*EthBridgeClaim) Marshal 

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

func (*EthBridgeClaim) MarshalTo 

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

func (*EthBridgeClaim) MarshalToSizedBuffer 

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

func (*EthBridgeClaim) ProtoMessage 

func (*EthBridgeClaim) ProtoMessage()

func (*EthBridgeClaim) Reset 

func (m *EthBridgeClaim) Reset()

func (*EthBridgeClaim) Size 

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

func (*EthBridgeClaim) String 

func (m *EthBridgeClaim) String() string

func (*EthBridgeClaim) Unmarshal 

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

func (*EthBridgeClaim) XXX_DiscardUnknown 

func (m *EthBridgeClaim) XXX_DiscardUnknown()

func (*EthBridgeClaim) XXX_Marshal 

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

func (*EthBridgeClaim) XXX_Merge 

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

func (*EthBridgeClaim) XXX_Size 

func (m *EthBridgeClaim) XXX_Size() int

func (*EthBridgeClaim) XXX_Unmarshal 

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

type EthereumAddress 

type EthereumAddress gethCommon.Address

EthereumAddress defines a standard ethereum address

func NewEthereumAddress 

func NewEthereumAddress(address string) EthereumAddress

NewEthereumAddress is a constructor function for EthereumAddress

func (EthereumAddress) MarshalJSON 

func (ethAddr EthereumAddress) MarshalJSON() ([]byte, error)

MarshalJSON marshals the etherum address to JSON

func (EthereumAddress) String 

func (ethAddr EthereumAddress) String() string

Route should return the name of the module

func (*EthereumAddress) UnmarshalJSON 

func (ethAddr *EthereumAddress) UnmarshalJSON(input []byte) error

UnmarshalJSON unmarshals an ethereum address

type GenesisState 

type GenesisState struct {
	CethReceiveAccount string   `protobuf:"bytes,1,opt,name=ceth_receive_account,json=cethReceiveAccount,proto3" json:"ceth_receive_account,omitempty"`
	PeggyTokens        []string `protobuf:"bytes,2,rep,name=peggy_tokens,json=peggyTokens,proto3" json:"peggy_tokens,omitempty"`
}

GenesisState for ethbridge

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetCethReceiveAccount 

func (m *GenesisState) GetCethReceiveAccount() string

func (*GenesisState) GetPeggyTokens 

func (m *GenesisState) GetPeggyTokens() []string

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type MsgBurn 

type MsgBurn struct {
	CosmosSender     string                                 `protobuf:"bytes,1,opt,name=cosmos_sender,json=cosmosSender,proto3" json:"cosmos_sender,omitempty" yaml:"cosmos_sender"`
	Amount           github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,2,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount" yaml:"amount"`
	Symbol           string                                 `protobuf:"bytes,3,opt,name=symbol,proto3" json:"symbol,omitempty" yaml:"symbol"`
	EthereumChainId  int64                                  `` /* 134-byte string literal not displayed */
	EthereumReceiver string                                 `` /* 134-byte string literal not displayed */
	CethAmount       github_com_cosmos_cosmos_sdk_types.Int `` /* 150-byte string literal not displayed */
}

MsgBurn defines a message for burning coins and triggering a related event

func CreateTestBurnMsg 

func CreateTestBurnMsg(t *testing.T, testCosmosSender string, ethereumReceiver EthereumAddress,
	coinsAmount sdk.Int, coinsSymbol string) MsgBurn

func NewMsgBurn 

func NewMsgBurn(
	ethereumChainID int64, cosmosSender sdk.AccAddress,
	ethereumReceiver EthereumAddress, amount sdk.Int, symbol string, cethAmount sdk.Int) MsgBurn

NewMsgBurn is a constructor function for MsgBurn

func (*MsgBurn) Descriptor 

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

func (*MsgBurn) GetCosmosSender 

func (m *MsgBurn) GetCosmosSender() string

func (*MsgBurn) GetEthereumChainId 

func (m *MsgBurn) GetEthereumChainId() int64

func (*MsgBurn) GetEthereumReceiver 

func (m *MsgBurn) GetEthereumReceiver() string

func (MsgBurn) GetSignBytes 

func (msg MsgBurn) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgBurn) GetSigners 

func (msg MsgBurn) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required

func (*MsgBurn) GetSymbol 

func (m *MsgBurn) GetSymbol() string

func (*MsgBurn) Marshal 

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

func (*MsgBurn) MarshalTo 

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

func (*MsgBurn) MarshalToSizedBuffer 

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

func (*MsgBurn) ProtoMessage 

func (*MsgBurn) ProtoMessage()

func (*MsgBurn) Reset 

func (m *MsgBurn) Reset()

func (MsgBurn) Route 

func (msg MsgBurn) Route() string

Route should return the name of the module

func (*MsgBurn) Size 

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

func (*MsgBurn) String 

func (m *MsgBurn) String() string

func (MsgBurn) Type 

func (msg MsgBurn) Type() string

Type should return the action

func (*MsgBurn) Unmarshal 

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

func (MsgBurn) ValidateBasic 

func (msg MsgBurn) ValidateBasic() error

ValidateBasic runs stateless checks on the message

func (*MsgBurn) XXX_DiscardUnknown 

func (m *MsgBurn) XXX_DiscardUnknown()

func (*MsgBurn) XXX_Marshal 

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

func (*MsgBurn) XXX_Merge 

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

func (*MsgBurn) XXX_Size 

func (m *MsgBurn) XXX_Size() int

func (*MsgBurn) XXX_Unmarshal 

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

type MsgBurnResponse 

type MsgBurnResponse struct {
}

func (*MsgBurnResponse) Descriptor 

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

func (*MsgBurnResponse) Marshal 

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

func (*MsgBurnResponse) MarshalTo 

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

func (*MsgBurnResponse) MarshalToSizedBuffer 

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

func (*MsgBurnResponse) ProtoMessage 

func (*MsgBurnResponse) ProtoMessage()

func (*MsgBurnResponse) Reset 

func (m *MsgBurnResponse) Reset()

func (*MsgBurnResponse) Size 

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

func (*MsgBurnResponse) String 

func (m *MsgBurnResponse) String() string

func (*MsgBurnResponse) Unmarshal 

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

func (*MsgBurnResponse) XXX_DiscardUnknown 

func (m *MsgBurnResponse) XXX_DiscardUnknown()

func (*MsgBurnResponse) XXX_Marshal 

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

func (*MsgBurnResponse) XXX_Merge 

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

func (*MsgBurnResponse) XXX_Size 

func (m *MsgBurnResponse) XXX_Size() int

func (*MsgBurnResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	Lock(ctx context.Context, in *MsgLock, opts ...grpc.CallOption) (*MsgLockResponse, error)
	Burn(ctx context.Context, in *MsgBurn, opts ...grpc.CallOption) (*MsgBurnResponse, error)
	CreateEthBridgeClaim(ctx context.Context, in *MsgCreateEthBridgeClaim, opts ...grpc.CallOption) (*MsgCreateEthBridgeClaimResponse, error)
	UpdateWhiteListValidator(ctx context.Context, in *MsgUpdateWhiteListValidator, opts ...grpc.CallOption) (*MsgUpdateWhiteListValidatorResponse, error)
	UpdateCethReceiverAccount(ctx context.Context, in *MsgUpdateCethReceiverAccount, opts ...grpc.CallOption) (*MsgUpdateCethReceiverAccountResponse, error)
	RescueCeth(ctx context.Context, in *MsgRescueCeth, opts ...grpc.CallOption) (*MsgRescueCethResponse, error)
	SetBlacklist(ctx context.Context, in *MsgSetBlacklist, opts ...grpc.CallOption) (*MsgSetBlacklistResponse, error)
}

MsgClient is the client API for Msg service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMsgClient 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgCreateEthBridgeClaim 

type MsgCreateEthBridgeClaim struct {
	EthBridgeClaim *EthBridgeClaim `` /* 129-byte string literal not displayed */
}

func CreateTestEthMsg 

func CreateTestEthMsg(t *testing.T, validatorAddress sdk.ValAddress, claimType ClaimType) MsgCreateEthBridgeClaim

Ethereum-bridge specific stuff

func NewMsgCreateEthBridgeClaim 

func NewMsgCreateEthBridgeClaim(ethBridgeClaim *EthBridgeClaim) MsgCreateEthBridgeClaim

NewMsgCreateEthBridgeClaim is a constructor function for MsgCreateBridgeClaim

func (*MsgCreateEthBridgeClaim) Descriptor 

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

func (*MsgCreateEthBridgeClaim) GetEthBridgeClaim 

func (m *MsgCreateEthBridgeClaim) GetEthBridgeClaim() *EthBridgeClaim

func (MsgCreateEthBridgeClaim) GetSignBytes 

func (msg MsgCreateEthBridgeClaim) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgCreateEthBridgeClaim) GetSigners 

func (msg MsgCreateEthBridgeClaim) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required

func (*MsgCreateEthBridgeClaim) Marshal 

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

func (*MsgCreateEthBridgeClaim) MarshalTo 

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

func (*MsgCreateEthBridgeClaim) MarshalToSizedBuffer 

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

func (*MsgCreateEthBridgeClaim) ProtoMessage 

func (*MsgCreateEthBridgeClaim) ProtoMessage()

func (*MsgCreateEthBridgeClaim) Reset 

func (m *MsgCreateEthBridgeClaim) Reset()

func (MsgCreateEthBridgeClaim) Route 

func (msg MsgCreateEthBridgeClaim) Route() string

Route should return the name of the module

func (*MsgCreateEthBridgeClaim) Size 

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

func (*MsgCreateEthBridgeClaim) String 

func (m *MsgCreateEthBridgeClaim) String() string

func (MsgCreateEthBridgeClaim) Type 

func (msg MsgCreateEthBridgeClaim) Type() string

Type should return the action

func (*MsgCreateEthBridgeClaim) Unmarshal 

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

func (MsgCreateEthBridgeClaim) ValidateBasic 

func (msg MsgCreateEthBridgeClaim) ValidateBasic() error

ValidateBasic runs stateless checks on the message

func (*MsgCreateEthBridgeClaim) XXX_DiscardUnknown 

func (m *MsgCreateEthBridgeClaim) XXX_DiscardUnknown()

func (*MsgCreateEthBridgeClaim) XXX_Marshal 

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

func (*MsgCreateEthBridgeClaim) XXX_Merge 

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

func (*MsgCreateEthBridgeClaim) XXX_Size 

func (m *MsgCreateEthBridgeClaim) XXX_Size() int

func (*MsgCreateEthBridgeClaim) XXX_Unmarshal 

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

type MsgCreateEthBridgeClaimResponse 

type MsgCreateEthBridgeClaimResponse struct {
}

func (*MsgCreateEthBridgeClaimResponse) Descriptor 

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

func (*MsgCreateEthBridgeClaimResponse) Marshal 

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

func (*MsgCreateEthBridgeClaimResponse) MarshalTo 

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

func (*MsgCreateEthBridgeClaimResponse) MarshalToSizedBuffer 

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

func (*MsgCreateEthBridgeClaimResponse) ProtoMessage 

func (*MsgCreateEthBridgeClaimResponse) ProtoMessage()

func (*MsgCreateEthBridgeClaimResponse) Reset 

func (m *MsgCreateEthBridgeClaimResponse) Reset()

func (*MsgCreateEthBridgeClaimResponse) Size 

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

func (*MsgCreateEthBridgeClaimResponse) String 

func (m *MsgCreateEthBridgeClaimResponse) String() string

func (*MsgCreateEthBridgeClaimResponse) Unmarshal 

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

func (*MsgCreateEthBridgeClaimResponse) XXX_DiscardUnknown 

func (m *MsgCreateEthBridgeClaimResponse) XXX_DiscardUnknown()

func (*MsgCreateEthBridgeClaimResponse) XXX_Marshal 

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

func (*MsgCreateEthBridgeClaimResponse) XXX_Merge 

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

func (*MsgCreateEthBridgeClaimResponse) XXX_Size 

func (m *MsgCreateEthBridgeClaimResponse) XXX_Size() int

func (*MsgCreateEthBridgeClaimResponse) XXX_Unmarshal 

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

type MsgLock 

type MsgLock struct {
	CosmosSender     string                                 `protobuf:"bytes,1,opt,name=cosmos_sender,json=cosmosSender,proto3" json:"cosmos_sender,omitempty"`
	Amount           github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,2,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount" yaml:"amount"`
	Symbol           string                                 `protobuf:"bytes,3,opt,name=symbol,proto3" json:"symbol,omitempty" yaml:"symbol"`
	EthereumChainId  int64                                  `` /* 134-byte string literal not displayed */
	EthereumReceiver string                                 `` /* 134-byte string literal not displayed */
	CethAmount       github_com_cosmos_cosmos_sdk_types.Int `` /* 150-byte string literal not displayed */
}

MsgLock defines a message for locking coins and triggering a related event

func CreateTestLockMsg 

func CreateTestLockMsg(t *testing.T, testCosmosSender string, ethereumReceiver EthereumAddress,
	coinsAmount sdk.Int, coinsSymbol string) MsgLock

func NewMsgLock 

func NewMsgLock(
	ethereumChainID int64, cosmosSender sdk.AccAddress,
	ethereumReceiver EthereumAddress, amount sdk.Int, symbol string, cethAmount sdk.Int) MsgLock

NewMsgLock is a constructor function for MsgLock

func (*MsgLock) Descriptor 

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

func (*MsgLock) GetCosmosSender 

func (m *MsgLock) GetCosmosSender() string

func (*MsgLock) GetEthereumChainId 

func (m *MsgLock) GetEthereumChainId() int64

func (*MsgLock) GetEthereumReceiver 

func (m *MsgLock) GetEthereumReceiver() string

func (MsgLock) GetSignBytes 

func (msg MsgLock) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgLock) GetSigners 

func (msg MsgLock) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required

func (*MsgLock) GetSymbol 

func (m *MsgLock) GetSymbol() string

func (*MsgLock) Marshal 

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

func (*MsgLock) MarshalTo 

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

func (*MsgLock) MarshalToSizedBuffer 

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

func (*MsgLock) ProtoMessage 

func (*MsgLock) ProtoMessage()

func (*MsgLock) Reset 

func (m *MsgLock) Reset()

func (MsgLock) Route 

func (msg MsgLock) Route() string

Route should return the name of the module

func (*MsgLock) Size 

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

func (*MsgLock) String 

func (m *MsgLock) String() string

func (MsgLock) Type 

func (msg MsgLock) Type() string

Type should return the action

func (*MsgLock) Unmarshal 

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

func (MsgLock) ValidateBasic 

func (msg MsgLock) ValidateBasic() error

ValidateBasic runs stateless checks on the message

func (*MsgLock) XXX_DiscardUnknown 

func (m *MsgLock) XXX_DiscardUnknown()

func (*MsgLock) XXX_Marshal 

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

func (*MsgLock) XXX_Merge 

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

func (*MsgLock) XXX_Size 

func (m *MsgLock) XXX_Size() int

func (*MsgLock) XXX_Unmarshal 

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

type MsgLockResponse 

type MsgLockResponse struct {
}

func (*MsgLockResponse) Descriptor 

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

func (*MsgLockResponse) Marshal 

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

func (*MsgLockResponse) MarshalTo 

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

func (*MsgLockResponse) MarshalToSizedBuffer 

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

func (*MsgLockResponse) ProtoMessage 

func (*MsgLockResponse) ProtoMessage()

func (*MsgLockResponse) Reset 

func (m *MsgLockResponse) Reset()

func (*MsgLockResponse) Size 

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

func (*MsgLockResponse) String 

func (m *MsgLockResponse) String() string

func (*MsgLockResponse) Unmarshal 

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

func (*MsgLockResponse) XXX_DiscardUnknown 

func (m *MsgLockResponse) XXX_DiscardUnknown()

func (*MsgLockResponse) XXX_Marshal 

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

func (*MsgLockResponse) XXX_Merge 

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

func (*MsgLockResponse) XXX_Size 

func (m *MsgLockResponse) XXX_Size() int

func (*MsgLockResponse) XXX_Unmarshal 

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

type MsgRescueCeth 

type MsgRescueCeth struct {
	CosmosSender   string                                 `protobuf:"bytes,1,opt,name=cosmos_sender,json=cosmosSender,proto3" json:"cosmos_sender,omitempty"`
	CosmosReceiver string                                 `protobuf:"bytes,2,opt,name=cosmos_receiver,json=cosmosReceiver,proto3" json:"cosmos_receiver,omitempty"`
	CethAmount     github_com_cosmos_cosmos_sdk_types.Int `` /* 131-byte string literal not displayed */
}

func CreateTestRescueCethMsg 

func CreateTestRescueCethMsg(t *testing.T, testCosmosSender string, testCethReceiverAccount string, cethAmount sdk.Int) MsgRescueCeth

func NewMsgRescueCeth 

func NewMsgRescueCeth(cosmosSender sdk.AccAddress, cosmosReceiver sdk.AccAddress, cethAmount sdk.Int) MsgRescueCeth

NewMsgRescueCeth is a constructor function for NewMsgRescueCeth

func (*MsgRescueCeth) Descriptor 

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

func (*MsgRescueCeth) GetCosmosReceiver 

func (m *MsgRescueCeth) GetCosmosReceiver() string

func (*MsgRescueCeth) GetCosmosSender 

func (m *MsgRescueCeth) GetCosmosSender() string

func (MsgRescueCeth) GetSignBytes 

func (msg MsgRescueCeth) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgRescueCeth) GetSigners 

func (msg MsgRescueCeth) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required

func (*MsgRescueCeth) Marshal 

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

func (*MsgRescueCeth) MarshalTo 

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

func (*MsgRescueCeth) MarshalToSizedBuffer 

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

func (*MsgRescueCeth) ProtoMessage 

func (*MsgRescueCeth) ProtoMessage()

func (*MsgRescueCeth) Reset 

func (m *MsgRescueCeth) Reset()

func (MsgRescueCeth) Route 

func (msg MsgRescueCeth) Route() string

Route should return the name of the module

func (*MsgRescueCeth) Size 

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

func (*MsgRescueCeth) String 

func (m *MsgRescueCeth) String() string

func (MsgRescueCeth) Type 

func (msg MsgRescueCeth) Type() string

Type should return the action

func (*MsgRescueCeth) Unmarshal 

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

func (MsgRescueCeth) ValidateBasic 

func (msg MsgRescueCeth) ValidateBasic() error

ValidateBasic runs stateless checks on the message

func (*MsgRescueCeth) XXX_DiscardUnknown 

func (m *MsgRescueCeth) XXX_DiscardUnknown()

func (*MsgRescueCeth) XXX_Marshal 

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

func (*MsgRescueCeth) XXX_Merge 

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

func (*MsgRescueCeth) XXX_Size 

func (m *MsgRescueCeth) XXX_Size() int

func (*MsgRescueCeth) XXX_Unmarshal 

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

type MsgRescueCethResponse 

type MsgRescueCethResponse struct {
}

func (*MsgRescueCethResponse) Descriptor 

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

func (*MsgRescueCethResponse) Marshal 

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

func (*MsgRescueCethResponse) MarshalTo 

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

func (*MsgRescueCethResponse) MarshalToSizedBuffer 

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

func (*MsgRescueCethResponse) ProtoMessage 

func (*MsgRescueCethResponse) ProtoMessage()

func (*MsgRescueCethResponse) Reset 

func (m *MsgRescueCethResponse) Reset()

func (*MsgRescueCethResponse) Size 

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

func (*MsgRescueCethResponse) String 

func (m *MsgRescueCethResponse) String() string

func (*MsgRescueCethResponse) Unmarshal 

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

func (*MsgRescueCethResponse) XXX_DiscardUnknown 

func (m *MsgRescueCethResponse) XXX_DiscardUnknown()

func (*MsgRescueCethResponse) XXX_Marshal 

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

func (*MsgRescueCethResponse) XXX_Merge 

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

func (*MsgRescueCethResponse) XXX_Size 

func (m *MsgRescueCethResponse) XXX_Size() int

func (*MsgRescueCethResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	Lock(context.Context, *MsgLock) (*MsgLockResponse, error)
	Burn(context.Context, *MsgBurn) (*MsgBurnResponse, error)
	CreateEthBridgeClaim(context.Context, *MsgCreateEthBridgeClaim) (*MsgCreateEthBridgeClaimResponse, error)
	UpdateWhiteListValidator(context.Context, *MsgUpdateWhiteListValidator) (*MsgUpdateWhiteListValidatorResponse, error)
	UpdateCethReceiverAccount(context.Context, *MsgUpdateCethReceiverAccount) (*MsgUpdateCethReceiverAccountResponse, error)
	RescueCeth(context.Context, *MsgRescueCeth) (*MsgRescueCethResponse, error)
	SetBlacklist(context.Context, *MsgSetBlacklist) (*MsgSetBlacklistResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSetBlacklist added in v0.10.1 

type MsgSetBlacklist struct {
	From      string   `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	Addresses []string `protobuf:"bytes,2,rep,name=addresses,proto3" json:"addresses,omitempty"`
}

func (*MsgSetBlacklist) Descriptor added in v0.10.1 

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

func (*MsgSetBlacklist) GetAddresses added in v0.10.1 

func (m *MsgSetBlacklist) GetAddresses() []string

func (*MsgSetBlacklist) GetFrom added in v0.10.1 

func (m *MsgSetBlacklist) GetFrom() string

func (MsgSetBlacklist) GetSignBytes added in v0.10.1 

func (msg MsgSetBlacklist) GetSignBytes() []byte

func (*MsgSetBlacklist) GetSigners added in v0.10.1 

func (msg *MsgSetBlacklist) GetSigners() []sdk.AccAddress

func (*MsgSetBlacklist) Marshal added in v0.10.1 

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

func (*MsgSetBlacklist) MarshalTo added in v0.10.1 

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

func (*MsgSetBlacklist) MarshalToSizedBuffer added in v0.10.1 

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

func (*MsgSetBlacklist) ProtoMessage added in v0.10.1 

func (*MsgSetBlacklist) ProtoMessage()

func (*MsgSetBlacklist) Reset added in v0.10.1 

func (m *MsgSetBlacklist) Reset()

func (MsgSetBlacklist) Route added in v0.10.1 

func (msg MsgSetBlacklist) Route() string

Route should return the name of the module

func (*MsgSetBlacklist) Size added in v0.10.1 

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

func (*MsgSetBlacklist) String added in v0.10.1 

func (m *MsgSetBlacklist) String() string

func (MsgSetBlacklist) Type added in v0.10.1 

func (msg MsgSetBlacklist) Type() string

Type should return the action

func (*MsgSetBlacklist) Unmarshal added in v0.10.1 

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

func (*MsgSetBlacklist) ValidateBasic added in v0.10.1 

func (msg *MsgSetBlacklist) ValidateBasic() error

func (*MsgSetBlacklist) XXX_DiscardUnknown added in v0.10.1 

func (m *MsgSetBlacklist) XXX_DiscardUnknown()

func (*MsgSetBlacklist) XXX_Marshal added in v0.10.1 

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

func (*MsgSetBlacklist) XXX_Merge added in v0.10.1 

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

func (*MsgSetBlacklist) XXX_Size added in v0.10.1 

func (m *MsgSetBlacklist) XXX_Size() int

func (*MsgSetBlacklist) XXX_Unmarshal added in v0.10.1 

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

type MsgSetBlacklistResponse added in v0.10.1 

type MsgSetBlacklistResponse struct {
}

func (*MsgSetBlacklistResponse) Descriptor added in v0.10.1 

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

func (*MsgSetBlacklistResponse) Marshal added in v0.10.1 

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

func (*MsgSetBlacklistResponse) MarshalTo added in v0.10.1 

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

func (*MsgSetBlacklistResponse) MarshalToSizedBuffer added in v0.10.1 

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

func (*MsgSetBlacklistResponse) ProtoMessage added in v0.10.1 

func (*MsgSetBlacklistResponse) ProtoMessage()

func (*MsgSetBlacklistResponse) Reset added in v0.10.1 

func (m *MsgSetBlacklistResponse) Reset()

func (*MsgSetBlacklistResponse) Size added in v0.10.1 

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

func (*MsgSetBlacklistResponse) String added in v0.10.1 

func (m *MsgSetBlacklistResponse) String() string

func (*MsgSetBlacklistResponse) Unmarshal added in v0.10.1 

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

func (*MsgSetBlacklistResponse) XXX_DiscardUnknown added in v0.10.1 

func (m *MsgSetBlacklistResponse) XXX_DiscardUnknown()

func (*MsgSetBlacklistResponse) XXX_Marshal added in v0.10.1 

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

func (*MsgSetBlacklistResponse) XXX_Merge added in v0.10.1 

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

func (*MsgSetBlacklistResponse) XXX_Size added in v0.10.1 

func (m *MsgSetBlacklistResponse) XXX_Size() int

func (*MsgSetBlacklistResponse) XXX_Unmarshal added in v0.10.1 

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

type MsgUpdateCethReceiverAccount 

type MsgUpdateCethReceiverAccount struct {
	CosmosSender        string `protobuf:"bytes,1,opt,name=cosmos_sender,json=cosmosSender,proto3" json:"cosmos_sender,omitempty"`
	CethReceiverAccount string `protobuf:"bytes,2,opt,name=ceth_receiver_account,json=cethReceiverAccount,proto3" json:"ceth_receiver_account,omitempty"`
}

func CreateTestUpdateCethReceiverAccountMsg 

func CreateTestUpdateCethReceiverAccountMsg(t *testing.T, testCosmosSender string, testCethReceiverAccount string) MsgUpdateCethReceiverAccount

func NewMsgUpdateCethReceiverAccount 

func NewMsgUpdateCethReceiverAccount(cosmosSender sdk.AccAddress,
	cethReceiverAccount sdk.AccAddress) MsgUpdateCethReceiverAccount

NewMsgUpdateCethReceiverAccount is a constructor function for MsgUpdateCethReceiverAccount

func (*MsgUpdateCethReceiverAccount) Descriptor 

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

func (*MsgUpdateCethReceiverAccount) GetCethReceiverAccount 

func (m *MsgUpdateCethReceiverAccount) GetCethReceiverAccount() string

func (*MsgUpdateCethReceiverAccount) GetCosmosSender 

func (m *MsgUpdateCethReceiverAccount) GetCosmosSender() string

func (MsgUpdateCethReceiverAccount) GetSignBytes 

func (msg MsgUpdateCethReceiverAccount) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgUpdateCethReceiverAccount) GetSigners 

func (msg MsgUpdateCethReceiverAccount) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required

func (*MsgUpdateCethReceiverAccount) Marshal 

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

func (*MsgUpdateCethReceiverAccount) MarshalTo 

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

func (*MsgUpdateCethReceiverAccount) MarshalToSizedBuffer 

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

func (*MsgUpdateCethReceiverAccount) ProtoMessage 

func (*MsgUpdateCethReceiverAccount) ProtoMessage()

func (*MsgUpdateCethReceiverAccount) Reset 

func (m *MsgUpdateCethReceiverAccount) Reset()

func (MsgUpdateCethReceiverAccount) Route 

func (msg MsgUpdateCethReceiverAccount) Route() string

Route should return the name of the module

func (*MsgUpdateCethReceiverAccount) Size 

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

func (*MsgUpdateCethReceiverAccount) String 

func (m *MsgUpdateCethReceiverAccount) String() string

func (MsgUpdateCethReceiverAccount) Type 

func (msg MsgUpdateCethReceiverAccount) Type() string

Type should return the action

func (*MsgUpdateCethReceiverAccount) Unmarshal 

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

func (MsgUpdateCethReceiverAccount) ValidateBasic 

func (msg MsgUpdateCethReceiverAccount) ValidateBasic() error

ValidateBasic runs stateless checks on the message

func (*MsgUpdateCethReceiverAccount) XXX_DiscardUnknown 

func (m *MsgUpdateCethReceiverAccount) XXX_DiscardUnknown()

func (*MsgUpdateCethReceiverAccount) XXX_Marshal 

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

func (*MsgUpdateCethReceiverAccount) XXX_Merge 

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

func (*MsgUpdateCethReceiverAccount) XXX_Size 

func (m *MsgUpdateCethReceiverAccount) XXX_Size() int

func (*MsgUpdateCethReceiverAccount) XXX_Unmarshal 

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

type MsgUpdateCethReceiverAccountResponse 

type MsgUpdateCethReceiverAccountResponse struct {
}

func (*MsgUpdateCethReceiverAccountResponse) Descriptor 

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

func (*MsgUpdateCethReceiverAccountResponse) Marshal 

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

func (*MsgUpdateCethReceiverAccountResponse) MarshalTo 

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

func (*MsgUpdateCethReceiverAccountResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateCethReceiverAccountResponse) ProtoMessage 

func (*MsgUpdateCethReceiverAccountResponse) ProtoMessage()

func (*MsgUpdateCethReceiverAccountResponse) Reset 

func (m *MsgUpdateCethReceiverAccountResponse) Reset()

func (*MsgUpdateCethReceiverAccountResponse) Size 

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

func (*MsgUpdateCethReceiverAccountResponse) String 

func (m *MsgUpdateCethReceiverAccountResponse) String() string

func (*MsgUpdateCethReceiverAccountResponse) Unmarshal 

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

func (*MsgUpdateCethReceiverAccountResponse) XXX_DiscardUnknown 

func (m *MsgUpdateCethReceiverAccountResponse) XXX_DiscardUnknown()

func (*MsgUpdateCethReceiverAccountResponse) XXX_Marshal 

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

func (*MsgUpdateCethReceiverAccountResponse) XXX_Merge 

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

func (*MsgUpdateCethReceiverAccountResponse) XXX_Size 

func (m *MsgUpdateCethReceiverAccountResponse) XXX_Size() int

func (*MsgUpdateCethReceiverAccountResponse) XXX_Unmarshal 

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

type MsgUpdateWhiteListValidator 

type MsgUpdateWhiteListValidator struct {
	CosmosSender  string `protobuf:"bytes,1,opt,name=cosmos_sender,json=cosmosSender,proto3" json:"cosmos_sender,omitempty" yaml:"cosmos_sender"`
	Validator     string `protobuf:"bytes,2,opt,name=validator,proto3" json:"validator,omitempty" yaml:"validator"`
	OperationType string `protobuf:"bytes,3,opt,name=operation_type,json=operationType,proto3" json:"operation_type,omitempty" yaml:"operation_type"`
}

MsgUpdateWhiteListValidator add or remove validator from whitelist

func CreateTestUpdateWhiteListValidatorMsg 

func CreateTestUpdateWhiteListValidatorMsg(_ *testing.T, sender string, validator string, operation string) MsgUpdateWhiteListValidator

func NewMsgUpdateWhiteListValidator 

func NewMsgUpdateWhiteListValidator(cosmosSender sdk.AccAddress,
	validator sdk.ValAddress, operationType string) MsgUpdateWhiteListValidator

NewMsgUpdateWhiteListValidator is a constructor function for MsgUpdateWhiteListValidator

func (*MsgUpdateWhiteListValidator) Descriptor 

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

func (*MsgUpdateWhiteListValidator) GetCosmosSender 

func (m *MsgUpdateWhiteListValidator) GetCosmosSender() string

func (*MsgUpdateWhiteListValidator) GetOperationType 

func (m *MsgUpdateWhiteListValidator) GetOperationType() string

func (MsgUpdateWhiteListValidator) GetSignBytes 

func (msg MsgUpdateWhiteListValidator) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgUpdateWhiteListValidator) GetSigners 

func (msg MsgUpdateWhiteListValidator) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required

func (*MsgUpdateWhiteListValidator) GetValidator 

func (m *MsgUpdateWhiteListValidator) GetValidator() string

func (*MsgUpdateWhiteListValidator) Marshal 

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

func (*MsgUpdateWhiteListValidator) MarshalTo 

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

func (*MsgUpdateWhiteListValidator) MarshalToSizedBuffer 

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

func (*MsgUpdateWhiteListValidator) ProtoMessage 

func (*MsgUpdateWhiteListValidator) ProtoMessage()

func (*MsgUpdateWhiteListValidator) Reset 

func (m *MsgUpdateWhiteListValidator) Reset()

func (MsgUpdateWhiteListValidator) Route 

func (msg MsgUpdateWhiteListValidator) Route() string

Route should return the name of the module

func (*MsgUpdateWhiteListValidator) Size 

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

func (*MsgUpdateWhiteListValidator) String 

func (m *MsgUpdateWhiteListValidator) String() string

func (MsgUpdateWhiteListValidator) Type 

func (msg MsgUpdateWhiteListValidator) Type() string

Type should return the action

func (*MsgUpdateWhiteListValidator) Unmarshal 

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

func (MsgUpdateWhiteListValidator) ValidateBasic 

func (msg MsgUpdateWhiteListValidator) ValidateBasic() error

ValidateBasic runs stateless checks on the message

func (*MsgUpdateWhiteListValidator) XXX_DiscardUnknown 

func (m *MsgUpdateWhiteListValidator) XXX_DiscardUnknown()

func (*MsgUpdateWhiteListValidator) XXX_Marshal 

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

func (*MsgUpdateWhiteListValidator) XXX_Merge 

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

func (*MsgUpdateWhiteListValidator) XXX_Size 

func (m *MsgUpdateWhiteListValidator) XXX_Size() int

func (*MsgUpdateWhiteListValidator) XXX_Unmarshal 

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

type MsgUpdateWhiteListValidatorResponse 

type MsgUpdateWhiteListValidatorResponse struct {
}

func (*MsgUpdateWhiteListValidatorResponse) Descriptor 

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

func (*MsgUpdateWhiteListValidatorResponse) Marshal 

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

func (*MsgUpdateWhiteListValidatorResponse) MarshalTo 

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

func (*MsgUpdateWhiteListValidatorResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateWhiteListValidatorResponse) ProtoMessage 

func (*MsgUpdateWhiteListValidatorResponse) ProtoMessage()

func (*MsgUpdateWhiteListValidatorResponse) Reset 

func (m *MsgUpdateWhiteListValidatorResponse) Reset()

func (*MsgUpdateWhiteListValidatorResponse) Size 

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

func (*MsgUpdateWhiteListValidatorResponse) String 

func (m *MsgUpdateWhiteListValidatorResponse) String() string

func (*MsgUpdateWhiteListValidatorResponse) Unmarshal 

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

func (*MsgUpdateWhiteListValidatorResponse) XXX_DiscardUnknown 

func (m *MsgUpdateWhiteListValidatorResponse) XXX_DiscardUnknown()

func (*MsgUpdateWhiteListValidatorResponse) XXX_Marshal 

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

func (*MsgUpdateWhiteListValidatorResponse) XXX_Merge 

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

func (*MsgUpdateWhiteListValidatorResponse) XXX_Size 

func (m *MsgUpdateWhiteListValidatorResponse) XXX_Size() int

func (*MsgUpdateWhiteListValidatorResponse) XXX_Unmarshal 

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

type OracleClaimContent 

type OracleClaimContent struct {
	CosmosReceiver       sdk.AccAddress  `json:"cosmos_receiver" yaml:"cosmos_receiver"`
	Amount               sdk.Int         `json:"amount" yaml:"amount"`
	Symbol               string          `json:"symbol" yaml:"symbol"`
	TokenContractAddress EthereumAddress `json:"token_contract_address" yaml:"token_contract_address"`
	ClaimType            ClaimType       `json:"claim_type" yaml:"claim_type"`
}

OracleClaimContent is the details of how the content of the claim for each validator will be stored in the oracle

func CreateOracleClaimFromOracleString 

func CreateOracleClaimFromOracleString(oracleClaimString string) (OracleClaimContent, error)

CreateOracleClaimFromOracleString converts a JSON string into an OracleClaimContent struct used by this module. In general, it is expected that the oracle module will store claims in this JSON format and so this should be used to convert oracle claims.

func NewOracleClaimContent 

func NewOracleClaimContent(
	cosmosReceiver sdk.AccAddress, amount sdk.Int, symbol string, tokenContractAddress EthereumAddress, claimType ClaimType,
) OracleClaimContent

NewOracleClaimContent is a constructor function for OracleClaim

type OracleKeeper 

type OracleKeeper interface {
	ProcessClaim(ctx sdk.Context, claim oracletypes.Claim) (oracletypes.Status, error)
	GetProphecy(ctx sdk.Context, id string) (oracletypes.Prophecy, bool)
	ProcessUpdateWhiteListValidator(ctx sdk.Context, cosmosSender sdk.AccAddress, validator sdk.ValAddress, operationtype string) error
	IsAdminAccount(ctx sdk.Context, cosmosSender sdk.AccAddress) bool
	GetAdminAccount(ctx sdk.Context) sdk.AccAddress
	SetAdminAccount(ctx sdk.Context, cosmosSender sdk.AccAddress)
}

OracleKeeper defines the expected oracle keeper

type PeggyTokens 

type PeggyTokens struct {
	Tokens []string `protobuf:"bytes,1,rep,name=tokens,proto3" json:"tokens,omitempty"`
}

func (*PeggyTokens) Descriptor 

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

func (*PeggyTokens) GetTokens 

func (m *PeggyTokens) GetTokens() []string

func (*PeggyTokens) Marshal 

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

func (*PeggyTokens) MarshalTo 

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

func (*PeggyTokens) MarshalToSizedBuffer 

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

func (*PeggyTokens) ProtoMessage 

func (*PeggyTokens) ProtoMessage()

func (*PeggyTokens) Reset 

func (m *PeggyTokens) Reset()

func (*PeggyTokens) Size 

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

func (*PeggyTokens) String 

func (m *PeggyTokens) String() string

func (*PeggyTokens) Unmarshal 

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

func (*PeggyTokens) XXX_DiscardUnknown 

func (m *PeggyTokens) XXX_DiscardUnknown()

func (*PeggyTokens) XXX_Marshal 

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

func (*PeggyTokens) XXX_Merge 

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

func (*PeggyTokens) XXX_Size 

func (m *PeggyTokens) XXX_Size() int

func (*PeggyTokens) XXX_Unmarshal 

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

type QueryBlacklistRequest added in v0.10.1 

type QueryBlacklistRequest struct {
}

func (*QueryBlacklistRequest) Descriptor added in v0.10.1 

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

func (*QueryBlacklistRequest) Marshal added in v0.10.1 

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

func (*QueryBlacklistRequest) MarshalTo added in v0.10.1 

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

func (*QueryBlacklistRequest) MarshalToSizedBuffer added in v0.10.1 

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

func (*QueryBlacklistRequest) ProtoMessage added in v0.10.1 

func (*QueryBlacklistRequest) ProtoMessage()

func (*QueryBlacklistRequest) Reset added in v0.10.1 

func (m *QueryBlacklistRequest) Reset()

func (*QueryBlacklistRequest) Size added in v0.10.1 

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

func (*QueryBlacklistRequest) String added in v0.10.1 

func (m *QueryBlacklistRequest) String() string

func (*QueryBlacklistRequest) Unmarshal added in v0.10.1 

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

func (*QueryBlacklistRequest) XXX_DiscardUnknown added in v0.10.1 

func (m *QueryBlacklistRequest) XXX_DiscardUnknown()

func (*QueryBlacklistRequest) XXX_Marshal added in v0.10.1 

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

func (*QueryBlacklistRequest) XXX_Merge added in v0.10.1 

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

func (*QueryBlacklistRequest) XXX_Size added in v0.10.1 

func (m *QueryBlacklistRequest) XXX_Size() int

func (*QueryBlacklistRequest) XXX_Unmarshal added in v0.10.1 

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

type QueryBlacklistResponse added in v0.10.1 

type QueryBlacklistResponse struct {
	Addresses []string `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses,omitempty"`
}

func (*QueryBlacklistResponse) Descriptor added in v0.10.1 

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

func (*QueryBlacklistResponse) GetAddresses added in v0.10.1 

func (m *QueryBlacklistResponse) GetAddresses() []string

func (*QueryBlacklistResponse) Marshal added in v0.10.1 

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

func (*QueryBlacklistResponse) MarshalTo added in v0.10.1 

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

func (*QueryBlacklistResponse) MarshalToSizedBuffer added in v0.10.1 

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

func (*QueryBlacklistResponse) ProtoMessage added in v0.10.1 

func (*QueryBlacklistResponse) ProtoMessage()

func (*QueryBlacklistResponse) Reset added in v0.10.1 

func (m *QueryBlacklistResponse) Reset()

func (*QueryBlacklistResponse) Size added in v0.10.1 

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

func (*QueryBlacklistResponse) String added in v0.10.1 

func (m *QueryBlacklistResponse) String() string

func (*QueryBlacklistResponse) Unmarshal added in v0.10.1 

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

func (*QueryBlacklistResponse) XXX_DiscardUnknown added in v0.10.1 

func (m *QueryBlacklistResponse) XXX_DiscardUnknown()

func (*QueryBlacklistResponse) XXX_Marshal added in v0.10.1 

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

func (*QueryBlacklistResponse) XXX_Merge added in v0.10.1 

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

func (*QueryBlacklistResponse) XXX_Size added in v0.10.1 

func (m *QueryBlacklistResponse) XXX_Size() int

func (*QueryBlacklistResponse) XXX_Unmarshal added in v0.10.1 

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

type QueryClient 

type QueryClient interface {
	// EthProphecy queries an EthProphecy
	EthProphecy(ctx context.Context, in *QueryEthProphecyRequest, opts ...grpc.CallOption) (*QueryEthProphecyResponse, error)
	GetBlacklist(ctx context.Context, in *QueryBlacklistRequest, opts ...grpc.CallOption) (*QueryBlacklistResponse, 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 QueryEthProphecyRequest 

type QueryEthProphecyRequest struct {
	EthereumChainId int64 `protobuf:"varint,1,opt,name=ethereum_chain_id,json=ethereumChainId,proto3" json:"ethereum_chain_id,omitempty"`
	// bridge_contract_address is an EthereumAddress
	BridgeContractAddress string `` /* 166-byte string literal not displayed */
	Nonce                 int64  `protobuf:"varint,3,opt,name=nonce,proto3" json:"nonce,omitempty"`
	Symbol                string `protobuf:"bytes,4,opt,name=symbol,proto3" json:"symbol,omitempty"`
	// token_contract_address is an EthereumAddress
	TokenContractAddress string `protobuf:"bytes,5,opt,name=token_contract_address,json=tokenContractAddress,proto3" json:"token_contract_address,omitempty"`
	// ethereum_sender is an EthereumAddress
	EthereumSender string `protobuf:"bytes,6,opt,name=ethereum_sender,json=ethereumSender,proto3" json:"ethereum_sender,omitempty"`
}

QueryEthProphecyRequest payload for EthProphecy rpc query

func NewQueryEthProphecyRequest 

func NewQueryEthProphecyRequest(
	ethereumChainID int64, bridgeContractAddress EthereumAddress, nonce int64, symbol string,
	tokenContractAddress EthereumAddress, ethereumSender EthereumAddress,
) *QueryEthProphecyRequest

NewQueryEthProphecyRequest creates a new QueryEthProphecyParams

func (*QueryEthProphecyRequest) Descriptor 

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

func (*QueryEthProphecyRequest) GetBridgeContractAddress 

func (m *QueryEthProphecyRequest) GetBridgeContractAddress() string

func (*QueryEthProphecyRequest) GetEthereumChainId 

func (m *QueryEthProphecyRequest) GetEthereumChainId() int64

func (*QueryEthProphecyRequest) GetEthereumSender 

func (m *QueryEthProphecyRequest) GetEthereumSender() string

func (*QueryEthProphecyRequest) GetNonce 

func (m *QueryEthProphecyRequest) GetNonce() int64

func (*QueryEthProphecyRequest) GetSymbol 

func (m *QueryEthProphecyRequest) GetSymbol() string

func (*QueryEthProphecyRequest) GetTokenContractAddress 

func (m *QueryEthProphecyRequest) GetTokenContractAddress() string

func (*QueryEthProphecyRequest) Marshal 

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

func (*QueryEthProphecyRequest) MarshalTo 

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

func (*QueryEthProphecyRequest) MarshalToSizedBuffer 

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

func (*QueryEthProphecyRequest) ProtoMessage 

func (*QueryEthProphecyRequest) ProtoMessage()

func (*QueryEthProphecyRequest) Reset 

func (m *QueryEthProphecyRequest) Reset()

func (*QueryEthProphecyRequest) Size 

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

func (*QueryEthProphecyRequest) String 

func (m *QueryEthProphecyRequest) String() string

func (*QueryEthProphecyRequest) Unmarshal 

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

func (*QueryEthProphecyRequest) XXX_DiscardUnknown 

func (m *QueryEthProphecyRequest) XXX_DiscardUnknown()

func (*QueryEthProphecyRequest) XXX_Marshal 

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

func (*QueryEthProphecyRequest) XXX_Merge 

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

func (*QueryEthProphecyRequest) XXX_Size 

func (m *QueryEthProphecyRequest) XXX_Size() int

func (*QueryEthProphecyRequest) XXX_Unmarshal 

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

type QueryEthProphecyResponse 

type QueryEthProphecyResponse struct {
	Id     string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Status *types.Status     `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Claims []*EthBridgeClaim `protobuf:"bytes,3,rep,name=claims,proto3" json:"claims,omitempty"`
}

QueryEthProphecyResponse payload for EthProphecy rpc query

func CreateTestQueryEthProphecyResponse 

func CreateTestQueryEthProphecyResponse(t *testing.T, validatorAddress sdk.ValAddress, claimType ClaimType,
) QueryEthProphecyResponse

func NewQueryEthProphecyResponse 

func NewQueryEthProphecyResponse(id string, status oracletypes.Status, claims []*EthBridgeClaim) QueryEthProphecyResponse

NewQueryEthProphecyResponse creates a new QueryEthProphecyResponse instance

func (*QueryEthProphecyResponse) Descriptor 

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

func (*QueryEthProphecyResponse) GetClaims 

func (m *QueryEthProphecyResponse) GetClaims() []*EthBridgeClaim

func (*QueryEthProphecyResponse) GetId 

func (m *QueryEthProphecyResponse) GetId() string

func (*QueryEthProphecyResponse) GetStatus 

func (m *QueryEthProphecyResponse) GetStatus() *types.Status

func (*QueryEthProphecyResponse) Marshal 

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

func (*QueryEthProphecyResponse) MarshalTo 

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

func (*QueryEthProphecyResponse) MarshalToSizedBuffer 

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

func (*QueryEthProphecyResponse) ProtoMessage 

func (*QueryEthProphecyResponse) ProtoMessage()

func (*QueryEthProphecyResponse) Reset 

func (m *QueryEthProphecyResponse) Reset()

func (*QueryEthProphecyResponse) Size 

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

func (*QueryEthProphecyResponse) String 

func (m *QueryEthProphecyResponse) String() string

func (*QueryEthProphecyResponse) Unmarshal 

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

func (*QueryEthProphecyResponse) XXX_DiscardUnknown 

func (m *QueryEthProphecyResponse) XXX_DiscardUnknown()

func (*QueryEthProphecyResponse) XXX_Marshal 

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

func (*QueryEthProphecyResponse) XXX_Merge 

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

func (*QueryEthProphecyResponse) XXX_Size 

func (m *QueryEthProphecyResponse) XXX_Size() int

func (*QueryEthProphecyResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// EthProphecy queries an EthProphecy
	EthProphecy(context.Context, *QueryEthProphecyRequest) (*QueryEthProphecyResponse, error)
	GetBlacklist(context.Context, *QueryBlacklistRequest) (*QueryBlacklistResponse, error)
}

QueryServer is the server API for Query service.

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) Burn 

func (*UnimplementedMsgServer) Burn(ctx context.Context, req *MsgBurn) (*MsgBurnResponse, error)

func (*UnimplementedMsgServer) CreateEthBridgeClaim 

func (*UnimplementedMsgServer) CreateEthBridgeClaim(ctx context.Context, req *MsgCreateEthBridgeClaim) (*MsgCreateEthBridgeClaimResponse, error)

func (*UnimplementedMsgServer) Lock 

func (*UnimplementedMsgServer) Lock(ctx context.Context, req *MsgLock) (*MsgLockResponse, error)

func (*UnimplementedMsgServer) RescueCeth 

func (*UnimplementedMsgServer) RescueCeth(ctx context.Context, req *MsgRescueCeth) (*MsgRescueCethResponse, error)

func (*UnimplementedMsgServer) SetBlacklist added in v0.10.1 

func (*UnimplementedMsgServer) SetBlacklist(ctx context.Context, req *MsgSetBlacklist) (*MsgSetBlacklistResponse, error)

func (*UnimplementedMsgServer) UpdateCethReceiverAccount 

func (*UnimplementedMsgServer) UpdateCethReceiverAccount(ctx context.Context, req *MsgUpdateCethReceiverAccount) (*MsgUpdateCethReceiverAccountResponse, error)

func (*UnimplementedMsgServer) UpdateWhiteListValidator 

func (*UnimplementedMsgServer) UpdateWhiteListValidator(ctx context.Context, req *MsgUpdateWhiteListValidator) (*MsgUpdateWhiteListValidatorResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) EthProphecy 

func (*UnimplementedQueryServer) EthProphecy(ctx context.Context, req *QueryEthProphecyRequest) (*QueryEthProphecyResponse, error)

func (*UnimplementedQueryServer) GetBlacklist added in v0.10.1 

func (*UnimplementedQueryServer) GetBlacklist(ctx context.Context, req *QueryBlacklistRequest) (*QueryBlacklistResponse, 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.