types

package
v0.0.0-...-1f47db2 Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2021 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypeObservation              = "minter_observation"
	EventTypeOutgoingBatch            = "minter_outgoing_batch"
	EventTypeMultisigBootstrap        = "minter_multisig_bootstrap"
	EventTypeMultisigUpdateRequest    = "minter_multisig_update_request"
	EventTypeOutgoingBatchCanceled    = "minter_outgoing_batch_canceled"
	EventTypeBridgeWithdrawalReceived = "minter_withdrawal_received"
	EventTypeBridgeDepositReceived    = "minter_deposit_received"
	EventTypeRefund                   = "minter_refund"
	EventTypeWithdrawRequest          = "minter_withdraw"
	EventTypeOutgoingBatchExecuted    = "minter_batch_executed"
	EventTypeProcessAttestation       = "minter_process_attestation"

	AttributeKeyAttestationID   = "attestation_id"
	AttributeKeyMultisigID      = "multisig_id"
	AttributeKeyOutgoingBatchID = "batch_id"
	AttributeKeyOutgoingTXID    = "outgoing_tx_id"
	AttributeKeyAttestationType = "attestation_type"
	AttributeKeyContract        = "bridge_contract"
	AttributeKeyNonce           = "nonce"
	AttributeKeyBridgeChainID   = "bridge_chain_id"
	AttributeKeyTxHash          = "tx_hash"
)
View Source 
const (
	// todo: implement oracle constants as params
	DefaultParamspace = ModuleName
	AttestationPeriod = 24 * time.Hour // TODO: value????
)

DefaultParamspace defines the default auth module parameter subspace

View Source 
const (
	// ModuleName is the name of the module
	ModuleName = "minter"

	// StoreKey to be used when creating the KVStore
	StoreKey = ModuleName

	// RouterKey is the module name router key
	RouterKey = ModuleName

	// QuerierRoute to be used for querierer msgs
	QuerierRoute = ModuleName
)
View Source 
const (
	// PeggyDenomPrefix indicates the prefix for all assests minted by this module
	PeggyDenomPrefix = ModuleName

	// PeggyDenomSeperator is the seperator for peggy denoms
	PeggyDenomSeperator = "/"

	// MinterMultisigAddressLen is the length of multisig address strings
	MinterMultisigAddressLen = 42

	// PeggyDenomLen is the length of the denoms generated by the peggy module
	PeggyDenomLen = len(PeggyDenomPrefix) + len(PeggyDenomSeperator) + MinterMultisigAddressLen
)
View Source 
const (
	// ProposalTypeColdStorageTransfer defines the type for a ColdStorageTransferProposal
	ProposalTypeColdStorageTransfer = "MinterColdStorageTransfer"
)
View Source 
const (
	TypeMsgDepositClaim = "deposit_claim"
)
View Source 
const (
	TypeMsgSendToEthClaim = "send_to_eth_claim"
)
View Source 
const (
	TypeMsgValsetClaim = "valset_claim"
)
View Source 
const (
	TypeMsgWithdrawClaim = "withdraw_claim"
)

Variables

View Source 
var (
	ErrInvalidLengthAttestation        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAttestation          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAttestation = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthBatch        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBatch          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBatch = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInternal                = sdkerrors.Register(ModuleName, 1, "internal")
	ErrDuplicate               = sdkerrors.Register(ModuleName, 2, "duplicate")
	ErrInvalid                 = sdkerrors.Register(ModuleName, 3, "invalid")
	ErrTimeout                 = sdkerrors.Register(ModuleName, 4, "timeout")
	ErrUnknown                 = sdkerrors.Register(ModuleName, 5, "unknown")
	ErrEmpty                   = sdkerrors.Register(ModuleName, 6, "empty")
	ErrOutdated                = sdkerrors.Register(ModuleName, 7, "outdated")
	ErrUnsupported             = sdkerrors.Register(ModuleName, 8, "unsupported")
	ErrNonContiguousEventNonce = sdkerrors.Register(ModuleName, 9, "non contiguous event nonce")
	ErrServiceStopped          = sdkerrors.Register(ModuleName, 10, "service stopped")
)
View Source 
var (
	// AttestationVotesPowerThreshold threshold of votes power to succeed
	AttestationVotesPowerThreshold = sdk.NewInt(66)

	// ParamsStoreKeyPeggyID stores the peggy id
	ParamsStoreKeyPeggyID = []byte("PeggyID")

	// ParamsStoreKeyStartThreshold stores the start threshold
	ParamsStoreKeyStartThreshold = []byte("StartThreshold")

	// ParamsStoreKeyBridgeContractAddress stores the contract address
	ParamsStoreKeyBridgeContractAddress = []byte("BridgeContractAddress")

	// ParamsStoreKeyBridgeContractChainID stores the bridge chain id
	ParamsStoreKeyBridgeContractChainID = []byte("BridgeChainID")

	// ParamsStoreKeySignedValsetsWindow stores the signed blocks window
	ParamsStoreKeySignedValsetsWindow = []byte("SignedValsetsWindow")

	// ParamsStoreKeySignedBatchesWindow stores the signed blocks window
	ParamsStoreKeySignedBatchesWindow = []byte("SignedBatchesWindow")

	// ParamsStoreKeySignedClaimsWindow stores the signed blocks window
	ParamsStoreKeySignedClaimsWindow = []byte("SignedClaimsWindow")

	// ParamsStoreSlashFractionValset stores the slash fraction valset
	ParamsStoreSlashFractionValset = []byte("SlashFractionValset")

	// ParamsStoreSlashFractionBatch stores the slash fraction Batch
	ParamsStoreSlashFractionBatch = []byte("SlashFractionBatch")

	// ParamsStoreSlashFractionClaim stores the slash fraction Claim
	ParamsStoreSlashFractionClaim = []byte("SlashFractionClaim")

	// ParamsStoreSlashFractionConflictingClaim stores the slash fraction ConflictingClaim
	ParamsStoreSlashFractionConflictingClaim = []byte("SlashFractionConflictingClaim")

	ParamsStopped = []byte("Stopped")
)
View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// MinterAddressKey indexes cosmos validator account addresses
	// i.e. cosmos1ahx7f8wyertuus9r20284ej0asrs085case3kn
	MinterAddressKey = []byte{0x1}

	// ValsetRequestKey indexes valset requests by nonce
	ValsetRequestKey = []byte{0x2}

	// ValsetConfirmKey indexes valset confirmations by nonce and the validator account address
	// i.e cosmos1ahx7f8wyertuus9r20284ej0asrs085case3kn
	ValsetConfirmKey = []byte{0x3}

	// OracleClaimKey attestation details by nonce and validator address
	// i.e. cosmosvaloper1ahx7f8wyertuus9r20284ej0asrs085case3kn
	// NOTE: this should be refactored to take a cosmos account address
	OracleClaimKey = []byte{0x4}

	// OutgoingTXPoolKey indexes the last nonce for the outgoing tx pool
	OutgoingTXPoolKey = []byte{0x6}

	// DenomiatorPrefix indexes token contract addresses from ETH on peggy
	DenomiatorPrefix = []byte{0x8}

	// SecondIndexOutgoingTXFeeKey indexes fee amounts by token contract address
	SecondIndexOutgoingTXFeeKey = []byte{0x9}

	// OutgoingTXBatchKey indexes outgoing tx batches under a nonce and token address
	OutgoingTXBatchKey = []byte{0xa}

	// BatchConfirmKey indexes validator confirmations by token contract address
	BatchConfirmKey = []byte{0xe1}

	// SecondIndexNonceByClaimKey indexes latest nonce for a given claim type
	SecondIndexNonceByClaimKey = []byte{0xf}

	// LastEventNonceByValidatorKey indexes lateset event nonce by validator
	LastEventNonceByValidatorKey = []byte{0xf1}

	// LastObservedEventNonceKey indexes the latest event nonce
	LastObservedEventNonceKey = []byte{0xf2}

	// LastValsetKey
	LastValsetKey = []byte{0xf3}

	// SequenceKeyPrefix indexes different txids
	SequenceKeyPrefix = []byte{0x7}

	// KeyLastTXPoolID indexes the lastTxPoolID
	KeyLastTXPoolID = append(SequenceKeyPrefix, []byte("lastTxPoolId")...)

	// KeyLastOutgoingBatchID indexes the lastBatchID
	KeyLastOutgoingBatchID = append(SequenceKeyPrefix, []byte("lastBatchId")...)

	MinterNonce = append(SequenceKeyPrefix, []byte("minterNonce")...)
)
View Source 
var (
	ErrInvalidLengthMsgs        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMsgs          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMsgs = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPool        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPool          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPool = 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 (
	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 ClaimType_name = map[int32]string{
	0: "CLAIM_TYPE_UNKNOWN",
	1: "CLAIM_TYPE_DEPOSIT",
	2: "CLAIM_TYPE_WITHDRAW",
	3: "CLAIM_TYPE_VALSET",
	4: "CLAIM_TYPE_SEND_TO_ETH",
}
View Source 
var ClaimType_value = map[string]int32{
	"CLAIM_TYPE_UNKNOWN":     0,
	"CLAIM_TYPE_DEPOSIT":     1,
	"CLAIM_TYPE_WITHDRAW":    2,
	"CLAIM_TYPE_VALSET":      3,
	"CLAIM_TYPE_SEND_TO_ETH": 4,
}
View Source 
var ModuleCdc = codec.NewLegacyAmino()

ModuleCdc is the codec for the module

View Source 
var SignType_name = map[int32]string{
	0: "SIGN_TYPE_UNKNOWN",
	1: "SIGN_TYPE_ORCHESTRATOR_SIGNED_MULTI_SIG_UPDATE",
	2: "SIGN_TYPE_ORCHESTRATOR_SIGNED_WITHDRAW_BATCH",
}
View Source 
var SignType_value = map[string]int32{
	"SIGN_TYPE_UNKNOWN": 0,
	"SIGN_TYPE_ORCHESTRATOR_SIGNED_MULTI_SIG_UPDATE": 1,
	"SIGN_TYPE_ORCHESTRATOR_SIGNED_WITHDRAW_BATCH":   2,
}

Functions

func GetAttestationKey 

func GetAttestationKey(eventNonce uint64, details MinterClaim) []byte

GetAttestationKey returns the following key format prefix nonce attestation-details-hash [0x6][0 0 0 0 0 0 0 1][fd1af8cec6c67fcf156f1b61fdf91ebc04d05484d007436e75342fc05bbff35a]

func GetBatchConfirmKey 

func GetBatchConfirmKey(batchNonce uint64, validator sdk.AccAddress) []byte

GetBatchConfirmKey returns the following key format prefix eth-contract-address cosmos-address [0xe1][0xc783df8a850f42e7F7e57013759C285caa701eB6][cosmos1ahx7f8wyertuus9r20284ej0asrs085case3kn] MARK finish-batches: take a look at this

func GetClaimKey 

func GetClaimKey(claimType ClaimType, nonce uint64, validator sdk.ValAddress, details MinterClaim) []byte

GetClaimKey returns the following key format prefix type cosmos-validator-address nonce attestation-details-hash [0x0][0 0 0 1][cosmosvaloper1ahx7f8wyertuus9r20284ej0asrs085case3kn][0 0 0 0 0 0 0 1][fd1af8cec6c67fcf156f1b61fdf91ebc04d05484d007436e75342fc05bbff35a] TODO: remove the validator address usage here!

func GetLastEventNonceByValidatorKey 

func GetLastEventNonceByValidatorKey(validator sdk.ValAddress) []byte

GetLastEventNonceByValidatorKey indexes lateset event nonce by validator GetLastEventNonceByValidatorKey returns the following key format prefix cosmos-validator [0x0][cosmos1ahx7f8wyertuus9r20284ej0asrs085case3kn]

func GetMinterAddressKey 

func GetMinterAddressKey(validator sdk.AccAddress) []byte

GetMinterAddressKey returns the following key format prefix cosmos-validator [0x0][cosmos1ahx7f8wyertuus9r20284ej0asrs085case3kn]

func GetOutgoingTxBatchKey 

func GetOutgoingTxBatchKey(nonce uint64) []byte

GetOutgoingTxBatchKey returns the following key format prefix nonce eth-contract-address [0xa][0 0 0 0 0 0 0 1][0xc783df8a850f42e7F7e57013759C285caa701eB6]

func GetOutgoingTxPoolKey 

func GetOutgoingTxPoolKey(id uint64) []byte

GetOutgoingTxPoolKey returns the following key format prefix id [0x6][0 0 0 0 0 0 0 1]

func GetValsetConfirmKey 

func GetValsetConfirmKey(nonce uint64, validator sdk.AccAddress) []byte

GetValsetConfirmKey returns the following key format prefix nonce validator-address [0x0][0 0 0 0 0 0 0 1][cosmos1ahx7f8wyertuus9r20284ej0asrs085case3kn] MARK finish-batches: this is where the key is created in the old (presumed working) code

func GetValsetRequestKey 

func GetValsetRequestKey(nonce uint64) []byte

GetValsetRequestKey returns the following key format prefix nonce [0x0][0 0 0 0 0 0 0 1]

func MinterAddrLessThan 

func MinterAddrLessThan(e, o string) bool

MinterAddrLessThan migrates the Minter address less than function

func NewMinterSignature 

func NewMinterSignature(hash []byte, privateKey *ecdsa.PrivateKey) ([]byte, error)

NewMinterSignature creates a new signuature over a given byte array

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable for auth module

func RegisterCodec 

func RegisterCodec(cdc *codec.LegacyAmino)

RegisterCodec registers concrete types on the Amino codec

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

RegisterInterfaces regiesteres the interfaces for the proto stuff

func RegisterMsgHandler 

func RegisterMsgHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterMsgHandler registers the http handlers for service Msg to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterMsgHandlerClient 

func RegisterMsgHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MsgClient) error

RegisterMsgHandlerClient registers the http handlers for service Msg to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "MsgClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "MsgClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "MsgClient" to call the correct interceptors.

func RegisterMsgHandlerFromEndpoint 

func RegisterMsgHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterMsgHandlerFromEndpoint is same as RegisterMsgHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterMsgHandlerServer 

func RegisterMsgHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MsgServer) error

RegisterMsgHandlerServer registers the http handlers for service Msg to "mux". UnaryRPC :call MsgServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterMsgHandlerFromEndpoint instead.

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQueryHandlerClient 

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.

func RegisterQueryHandlerFromEndpoint 

func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQueryHandlerServer 

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func UInt64Bytes 

func UInt64Bytes(n uint64) []byte

UInt64Bytes uses the SDK byte marshaling to encode a uint64

func UInt64FromBytes 

func UInt64FromBytes(s []byte) uint64

UInt64FromBytes create uint from binary big endian representation

func UInt64FromString 

func UInt64FromString(s string) (uint64, error)

UInt64FromString to parse out a uint64 for a nonce

func ValidateEthAddress 

func ValidateEthAddress(a string) error

func ValidateMinterAddress 

func ValidateMinterAddress(a string) error

ValidateMinterAddress validates the minter address strings

func ValidateMinterSignature 

func ValidateMinterSignature(hash []byte, signature []byte, minterAddress string) error

ValidateMinterSignature takes a message, an associated signature and public key and returns an error if the signature isn't valid

func ValidatePeggyCoin 

func ValidatePeggyCoin(v sdk.Coin, ctx sdk.Context, oracleKeeper oraclekeeper.Keeper) (uint64, error)

ValidatePeggyCoin returns true if a coin is a peggy representation of an Minter Coin

Types

type Attestation 

type Attestation struct {
	EventNonce uint64   `protobuf:"varint,1,opt,name=event_nonce,json=eventNonce,proto3" json:"event_nonce,omitempty"`
	Observed   bool     `protobuf:"varint,2,opt,name=observed,proto3" json:"observed,omitempty"`
	Votes      []string `protobuf:"bytes,3,rep,name=votes,proto3" json:"votes,omitempty"`
}

Attestation is an aggregate of `claims` that eventually becomes `observed` by all orchestrators EVENT_NONCE: EventNonce a nonce provided by the peggy contract that is unique per event fired These event nonces must be relayed in order. This is a correctness issue, if relaying out of order transaction replay attacks become possible OBSERVED: Observed indicates that >67% of validators have attested to the event, and that the event should be executed by the peggy state machine

The actual content of the claims is passed in with the transaction making the claim and then passed through the call stack alongside the attestation while it is processed the key in which the attestation is stored is keyed on the exact details of the claim but there is no reason to store those exact details becuause the next message sender will kindly provide you with them.

func (*Attestation) Descriptor 

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

func (*Attestation) GetEventNonce 

func (m *Attestation) GetEventNonce() uint64

func (*Attestation) GetObserved 

func (m *Attestation) GetObserved() bool

func (*Attestation) GetVotes 

func (m *Attestation) GetVotes() []string

func (*Attestation) Marshal 

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

func (*Attestation) MarshalTo 

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

func (*Attestation) MarshalToSizedBuffer 

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

func (*Attestation) ProtoMessage 

func (*Attestation) ProtoMessage()

func (*Attestation) Reset 

func (m *Attestation) Reset()

func (*Attestation) Size 

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

func (*Attestation) String 

func (m *Attestation) String() string

func (*Attestation) Unmarshal 

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

func (*Attestation) XXX_DiscardUnknown 

func (m *Attestation) XXX_DiscardUnknown()

func (*Attestation) XXX_Marshal 

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

func (*Attestation) XXX_Merge 

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

func (*Attestation) XXX_Size 

func (m *Attestation) XXX_Size() int

func (*Attestation) XXX_Unmarshal 

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

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
}

BankKeeper defines the expected bank keeper methods

type BridgeValidator 

type BridgeValidator struct {
	Power         uint64 `protobuf:"varint,1,opt,name=power,proto3" json:"power,omitempty"`
	MinterAddress string `protobuf:"bytes,2,opt,name=minter_address,json=minterAddress,proto3" json:"minter_address,omitempty"`
}

BridgeValidator represents a validator's ETH address and its power

func (*BridgeValidator) Descriptor 

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

func (*BridgeValidator) GetMinterAddress 

func (m *BridgeValidator) GetMinterAddress() string

func (*BridgeValidator) GetPower 

func (m *BridgeValidator) GetPower() uint64

func (*BridgeValidator) Marshal 

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

func (*BridgeValidator) MarshalTo 

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

func (*BridgeValidator) MarshalToSizedBuffer 

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

func (*BridgeValidator) ProtoMessage 

func (*BridgeValidator) ProtoMessage()

func (*BridgeValidator) Reset 

func (m *BridgeValidator) Reset()

func (*BridgeValidator) Size 

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

func (*BridgeValidator) String 

func (m *BridgeValidator) String() string

func (*BridgeValidator) Unmarshal 

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

func (*BridgeValidator) ValidateBasic 

func (b *BridgeValidator) ValidateBasic() error

ValidateBasic performs stateless checks on validity

func (*BridgeValidator) XXX_DiscardUnknown 

func (m *BridgeValidator) XXX_DiscardUnknown()

func (*BridgeValidator) XXX_Marshal 

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

func (*BridgeValidator) XXX_Merge 

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

func (*BridgeValidator) XXX_Size 

func (m *BridgeValidator) XXX_Size() int

func (*BridgeValidator) XXX_Unmarshal 

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

type BridgeValidators 

type BridgeValidators []*BridgeValidator

BridgeValidators is the sorted set of validator data for Ethereum bridge MultiSig set

func (BridgeValidators) GetPowers 

func (b BridgeValidators) GetPowers() []uint64

GetPowers returns only the power values for all members

func (BridgeValidators) HasDuplicates 

func (b BridgeValidators) HasDuplicates() bool

HasDuplicates returns true if there are duplicates in the set

func (BridgeValidators) PowerDiff 

func (b BridgeValidators) PowerDiff(c BridgeValidators) float64

PowerDiff returns the difference in power between two bridge validator sets TODO: this needs to be potentially refactored

func (BridgeValidators) Sort 

func (b BridgeValidators) Sort()

Sort sorts the validators by power

func (BridgeValidators) TotalPower 

func (b BridgeValidators) TotalPower() (out uint64)

TotalPower returns the total power in the bridge validator set

func (BridgeValidators) ValidateBasic 

func (b BridgeValidators) ValidateBasic() error

ValidateBasic performs stateless checks

type ClaimType 

type ClaimType int32

ClaimType is the cosmos type of an event from the counterpart chain that can be handled 

const (
	CLAIM_TYPE_UNKNOWN     ClaimType = 0
	CLAIM_TYPE_DEPOSIT     ClaimType = 1
	CLAIM_TYPE_WITHDRAW    ClaimType = 2
	CLAIM_TYPE_VALSET      ClaimType = 3
	CLAIM_TYPE_SEND_TO_ETH ClaimType = 4
)

func (ClaimType) EnumDescriptor 

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

func (ClaimType) String 

func (x ClaimType) String() string

type ColdStorageTransferProposal 

type ColdStorageTransferProposal struct {
	Amount github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,1,rep,name=amount,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"amount"`
}

func NewColdStorageTransferProposal 

func NewColdStorageTransferProposal(amount sdk.Coins) *ColdStorageTransferProposal

func (*ColdStorageTransferProposal) Descriptor 

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

func (*ColdStorageTransferProposal) GetDescription 

func (csp *ColdStorageTransferProposal) GetDescription() string

GetDescription returns the description of a community pool spend proposal.

func (*ColdStorageTransferProposal) GetTitle 

func (csp *ColdStorageTransferProposal) GetTitle() string

GetTitle returns the title of a community pool spend proposal.

func (*ColdStorageTransferProposal) Marshal 

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

func (*ColdStorageTransferProposal) MarshalTo 

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

func (*ColdStorageTransferProposal) MarshalToSizedBuffer 

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

func (*ColdStorageTransferProposal) ProposalRoute 

func (csp *ColdStorageTransferProposal) ProposalRoute() string

GetDescription returns the routing key of a community pool spend proposal.

func (*ColdStorageTransferProposal) ProposalType 

func (csp *ColdStorageTransferProposal) ProposalType() string

ProposalType returns the type of a community pool spend proposal.

func (*ColdStorageTransferProposal) ProtoMessage 

func (*ColdStorageTransferProposal) ProtoMessage()

func (*ColdStorageTransferProposal) Reset 

func (m *ColdStorageTransferProposal) Reset()

func (*ColdStorageTransferProposal) Size 

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

func (ColdStorageTransferProposal) String 

func (csp ColdStorageTransferProposal) String() string

String implements the Stringer interface.

func (*ColdStorageTransferProposal) Unmarshal 

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

func (*ColdStorageTransferProposal) ValidateBasic 

func (csp *ColdStorageTransferProposal) ValidateBasic() error

ValidateBasic runs basic stateless validity checks

func (*ColdStorageTransferProposal) XXX_DiscardUnknown 

func (m *ColdStorageTransferProposal) XXX_DiscardUnknown()

func (*ColdStorageTransferProposal) XXX_Marshal 

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

func (*ColdStorageTransferProposal) XXX_Merge 

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

func (*ColdStorageTransferProposal) XXX_Size 

func (m *ColdStorageTransferProposal) XXX_Size() int

func (*ColdStorageTransferProposal) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	Params           *Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
	StartMinterNonce uint64  `protobuf:"varint,2,opt,name=start_minter_nonce,json=startMinterNonce,proto3" json:"start_minter_nonce,omitempty"`
}

GenesisState struct

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

DefaultGenesisState returns empty genesis state TODO: set some better defaults here

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() *Params

func (*GenesisState) GetStartMinterNonce 

func (m *GenesisState) GetStartMinterNonce() uint64

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

func (s GenesisState) ValidateBasic() error

ValidateBasic validates genesis state by looping through the params and calling their validation functions

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 IDSet 

type IDSet struct {
	Ids []uint64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"`
}

IDSet represents a set of IDs

func (*IDSet) Descriptor 

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

func (*IDSet) GetIds 

func (m *IDSet) GetIds() []uint64

func (*IDSet) Marshal 

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

func (*IDSet) MarshalTo 

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

func (*IDSet) MarshalToSizedBuffer 

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

func (*IDSet) ProtoMessage 

func (*IDSet) ProtoMessage()

func (*IDSet) Reset 

func (m *IDSet) Reset()

func (*IDSet) Size 

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

func (*IDSet) String 

func (m *IDSet) String() string

func (*IDSet) Unmarshal 

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

func (*IDSet) XXX_DiscardUnknown 

func (m *IDSet) XXX_DiscardUnknown()

func (*IDSet) XXX_Marshal 

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

func (*IDSet) XXX_Merge 

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

func (*IDSet) XXX_Size 

func (m *IDSet) XXX_Size() int

func (*IDSet) XXX_Unmarshal 

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

type MinterClaim 

type MinterClaim interface {
	GetEventNonce() uint64
	GetType() ClaimType
	ValidateBasic() error
	ClaimHash() []byte
}

MinterClaim represents a claim on ethereum state

type MinterCoin 

type MinterCoin struct {
	Amount github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,1,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount"`
	CoinId uint64                                 `protobuf:"varint,2,opt,name=coinId,proto3" json:"coinId,omitempty"`
}

ERC20Token unique identifier for an Ethereum ERC20 token. CONTRACT: The contract address on ETH of the token (note: developers should look up the token symbol using the address on ETH to display for UI)

func MinterCoinFromPeggyCoin 

func MinterCoinFromPeggyCoin(v sdk.Coin, ctx sdk.Context, oracleKeeper oraclekeeper.Keeper) (*MinterCoin, error)

MinterCoinFromPeggyCoin returns the ERC20 representation of a given peggy coin

func NewMinterCoin 

func NewMinterCoin(amount sdk.Int, coinId uint64) *MinterCoin

NewMinterCoin returns a new instance of an ERC20

func (*MinterCoin) Add 

func (e *MinterCoin) Add(o *MinterCoin) *MinterCoin

Add adds one ERC20 to another TODO: make this return errors instead

func (*MinterCoin) Descriptor 

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

func (*MinterCoin) GetCoinId 

func (m *MinterCoin) GetCoinId() uint64

func (*MinterCoin) Marshal 

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

func (*MinterCoin) MarshalTo 

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

func (*MinterCoin) MarshalToSizedBuffer 

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

func (*MinterCoin) PeggyCoin 

func (e *MinterCoin) PeggyCoin(ctx sdk.Context, oracleKeeper oraclekeeper.Keeper) sdk.Coin

PeggyCoin returns the peggy representation of the ERC20

func (*MinterCoin) ProtoMessage 

func (*MinterCoin) ProtoMessage()

func (*MinterCoin) Reset 

func (m *MinterCoin) Reset()

func (*MinterCoin) Size 

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

func (*MinterCoin) String 

func (m *MinterCoin) String() string

func (*MinterCoin) Unmarshal 

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

func (*MinterCoin) ValidateBasic 

func (e *MinterCoin) ValidateBasic() error

ValidateBasic permforms stateless validation

func (*MinterCoin) XXX_DiscardUnknown 

func (m *MinterCoin) XXX_DiscardUnknown()

func (*MinterCoin) XXX_Marshal 

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

func (*MinterCoin) XXX_Merge 

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

func (*MinterCoin) XXX_Size 

func (m *MinterCoin) XXX_Size() int

func (*MinterCoin) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	ValsetConfirm(ctx context.Context, in *MsgValsetConfirm, opts ...grpc.CallOption) (*MsgValsetConfirmResponse, error)
	ValsetRequest(ctx context.Context, in *MsgValsetRequest, opts ...grpc.CallOption) (*MsgValsetRequestResponse, error)
	SetMinterAddress(ctx context.Context, in *MsgSetMinterAddress, opts ...grpc.CallOption) (*MsgSetMinterAddressResponse, error)
	SendToEth(ctx context.Context, in *MsgSendToMinter, opts ...grpc.CallOption) (*MsgSendToMinterResponse, error)
	RequestBatch(ctx context.Context, in *MsgRequestBatch, opts ...grpc.CallOption) (*MsgRequestBatchResponse, error)
	ConfirmBatch(ctx context.Context, in *MsgConfirmBatch, opts ...grpc.CallOption) (*MsgConfirmBatchResponse, error)
	DepositClaim(ctx context.Context, in *MsgDepositClaim, opts ...grpc.CallOption) (*MsgDepositClaimResponse, error)
	WithdrawClaim(ctx context.Context, in *MsgWithdrawClaim, opts ...grpc.CallOption) (*MsgWithdrawClaimResponse, error)
	SendToEthClaim(ctx context.Context, in *MsgSendToEthClaim, opts ...grpc.CallOption) (*MsgSendToEthClaimResponse, error)
	ValsetClaim(ctx context.Context, in *MsgValsetClaim, opts ...grpc.CallOption) (*MsgValsetClaimResponse, 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 MsgConfirmBatch 

type MsgConfirmBatch struct {
	Nonce        uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	MinterSigner string `protobuf:"bytes,2,opt,name=minter_signer,json=minterSigner,proto3" json:"minter_signer,omitempty"`
	Validator    string `protobuf:"bytes,3,opt,name=validator,proto3" json:"validator,omitempty"`
	Signature    string `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
}

MsgConfirmBatch When validators observe a MsgRequestBatch they form a batch by ordering transactions currently in the txqueue in order of highest to lowest fee, cutting off when the batch either reaches a hardcoded maximum size (to be decided, probably around 100) or when transactions stop being profitable (TODO determine this without nondeterminism) This message includes the batch as well as an Ethereum signature over this batch by the validator -------------

func (*MsgConfirmBatch) Descriptor 

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

func (*MsgConfirmBatch) GetMinterSigner 

func (m *MsgConfirmBatch) GetMinterSigner() string

func (*MsgConfirmBatch) GetNonce 

func (m *MsgConfirmBatch) GetNonce() uint64

func (MsgConfirmBatch) GetSignBytes 

func (msg MsgConfirmBatch) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (*MsgConfirmBatch) GetSignature 

func (m *MsgConfirmBatch) GetSignature() string

func (MsgConfirmBatch) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgConfirmBatch) GetValidator 

func (m *MsgConfirmBatch) GetValidator() string

func (*MsgConfirmBatch) Marshal 

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

func (*MsgConfirmBatch) MarshalTo 

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

func (*MsgConfirmBatch) MarshalToSizedBuffer 

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

func (*MsgConfirmBatch) ProtoMessage 

func (*MsgConfirmBatch) ProtoMessage()

func (*MsgConfirmBatch) Reset 

func (m *MsgConfirmBatch) Reset()

func (MsgConfirmBatch) Route 

func (msg MsgConfirmBatch) Route() string

Route should return the name of the module

func (*MsgConfirmBatch) Size 

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

func (*MsgConfirmBatch) String 

func (m *MsgConfirmBatch) String() string

func (MsgConfirmBatch) Type 

func (msg MsgConfirmBatch) Type() string

Type should return the action

func (*MsgConfirmBatch) Unmarshal 

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

func (MsgConfirmBatch) ValidateBasic 

func (msg MsgConfirmBatch) ValidateBasic() error

ValidateBasic performs stateless checks

func (*MsgConfirmBatch) XXX_DiscardUnknown 

func (m *MsgConfirmBatch) XXX_DiscardUnknown()

func (*MsgConfirmBatch) XXX_Marshal 

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

func (*MsgConfirmBatch) XXX_Merge 

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

func (*MsgConfirmBatch) XXX_Size 

func (m *MsgConfirmBatch) XXX_Size() int

func (*MsgConfirmBatch) XXX_Unmarshal 

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

type MsgConfirmBatchResponse 

type MsgConfirmBatchResponse struct {
}

TODO: write response data here

func (*MsgConfirmBatchResponse) Descriptor 

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

func (*MsgConfirmBatchResponse) Marshal 

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

func (*MsgConfirmBatchResponse) MarshalTo 

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

func (*MsgConfirmBatchResponse) MarshalToSizedBuffer 

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

func (*MsgConfirmBatchResponse) ProtoMessage 

func (*MsgConfirmBatchResponse) ProtoMessage()

func (*MsgConfirmBatchResponse) Reset 

func (m *MsgConfirmBatchResponse) Reset()

func (*MsgConfirmBatchResponse) Size 

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

func (*MsgConfirmBatchResponse) String 

func (m *MsgConfirmBatchResponse) String() string

func (*MsgConfirmBatchResponse) Unmarshal 

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

func (*MsgConfirmBatchResponse) XXX_DiscardUnknown 

func (m *MsgConfirmBatchResponse) XXX_DiscardUnknown()

func (*MsgConfirmBatchResponse) XXX_Marshal 

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

func (*MsgConfirmBatchResponse) XXX_Merge 

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

func (*MsgConfirmBatchResponse) XXX_Size 

func (m *MsgConfirmBatchResponse) XXX_Size() int

func (*MsgConfirmBatchResponse) XXX_Unmarshal 

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

type MsgDepositClaim 

type MsgDepositClaim struct {
	EventNonce     uint64                                 `protobuf:"varint,1,opt,name=event_nonce,json=eventNonce,proto3" json:"event_nonce,omitempty"`
	CoinId         uint64                                 `protobuf:"varint,2,opt,name=coinId,proto3" json:"coinId,omitempty"`
	Amount         github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,3,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount"`
	MinterSender   string                                 `protobuf:"bytes,4,opt,name=minter_sender,json=minterSender,proto3" json:"minter_sender,omitempty"`
	CosmosReceiver string                                 `protobuf:"bytes,5,opt,name=cosmos_receiver,json=cosmosReceiver,proto3" json:"cosmos_receiver,omitempty"`
	Orchestrator   string                                 `protobuf:"bytes,6,opt,name=orchestrator,proto3" json:"orchestrator,omitempty"`
	TxHash         string                                 `protobuf:"bytes,7,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
}

EthereumBridgeDepositClaim When more than 66% of the active validator set has claimed to have seen the deposit enter the ethereum blockchain coins are issued to the Cosmos address in question -------------

func (*MsgDepositClaim) ClaimHash 

func (msg *MsgDepositClaim) ClaimHash() []byte

Hash implements BridgeDeposit.Hash

func (*MsgDepositClaim) Descriptor 

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

func (*MsgDepositClaim) GetCoinId 

func (m *MsgDepositClaim) GetCoinId() uint64

func (*MsgDepositClaim) GetCosmosReceiver 

func (m *MsgDepositClaim) GetCosmosReceiver() string

func (*MsgDepositClaim) GetEventNonce 

func (m *MsgDepositClaim) GetEventNonce() uint64

func (*MsgDepositClaim) GetMinterSender 

func (m *MsgDepositClaim) GetMinterSender() string

func (*MsgDepositClaim) GetOrchestrator 

func (m *MsgDepositClaim) GetOrchestrator() string

func (MsgDepositClaim) GetSignBytes 

func (msg MsgDepositClaim) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgDepositClaim) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgDepositClaim) GetTxHash 

func (m *MsgDepositClaim) GetTxHash() string

func (*MsgDepositClaim) GetType 

func (msg *MsgDepositClaim) GetType() ClaimType

GetType returns the type of the claim

func (*MsgDepositClaim) Marshal 

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

func (*MsgDepositClaim) MarshalTo 

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

func (*MsgDepositClaim) MarshalToSizedBuffer 

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

func (*MsgDepositClaim) ProtoMessage 

func (*MsgDepositClaim) ProtoMessage()

func (*MsgDepositClaim) Reset 

func (m *MsgDepositClaim) Reset()

func (MsgDepositClaim) Route 

func (msg MsgDepositClaim) Route() string

Route should return the name of the module

func (*MsgDepositClaim) Size 

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

func (*MsgDepositClaim) String 

func (m *MsgDepositClaim) String() string

func (MsgDepositClaim) Type 

func (msg MsgDepositClaim) Type() string

Type should return the action

func (*MsgDepositClaim) Unmarshal 

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

func (*MsgDepositClaim) ValidateBasic 

func (msg *MsgDepositClaim) ValidateBasic() error

ValidateBasic performs stateless checks

func (*MsgDepositClaim) XXX_DiscardUnknown 

func (m *MsgDepositClaim) XXX_DiscardUnknown()

func (*MsgDepositClaim) XXX_Marshal 

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

func (*MsgDepositClaim) XXX_Merge 

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

func (*MsgDepositClaim) XXX_Size 

func (m *MsgDepositClaim) XXX_Size() int

func (*MsgDepositClaim) XXX_Unmarshal 

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

type MsgDepositClaimResponse 

type MsgDepositClaimResponse struct {
}

TODO: write response data here

func (*MsgDepositClaimResponse) Descriptor 

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

func (*MsgDepositClaimResponse) Marshal 

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

func (*MsgDepositClaimResponse) MarshalTo 

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

func (*MsgDepositClaimResponse) MarshalToSizedBuffer 

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

func (*MsgDepositClaimResponse) ProtoMessage 

func (*MsgDepositClaimResponse) ProtoMessage()

func (*MsgDepositClaimResponse) Reset 

func (m *MsgDepositClaimResponse) Reset()

func (*MsgDepositClaimResponse) Size 

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

func (*MsgDepositClaimResponse) String 

func (m *MsgDepositClaimResponse) String() string

func (*MsgDepositClaimResponse) Unmarshal 

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

func (*MsgDepositClaimResponse) XXX_DiscardUnknown 

func (m *MsgDepositClaimResponse) XXX_DiscardUnknown()

func (*MsgDepositClaimResponse) XXX_Marshal 

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

func (*MsgDepositClaimResponse) XXX_Merge 

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

func (*MsgDepositClaimResponse) XXX_Size 

func (m *MsgDepositClaimResponse) XXX_Size() int

func (*MsgDepositClaimResponse) XXX_Unmarshal 

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

type MsgRequestBatch 

type MsgRequestBatch struct {
	Requester string `protobuf:"bytes,1,opt,name=requester,proto3" json:"requester,omitempty"`
}

MsgRequestBatch this is a message anyone can send that requests a batch of transactions to send across the bridge be created for whatever block height this message is included in. This acts as a coordination point, the handler for this message looks at the AddToOutgoingPool tx's in the store and generates a batch, also available in the store tied to this message. The validators then grab this batch, sign it, submit the signatures with a MsgConfirmBatch before a relayer can finally submit the batch -------------

func NewMsgRequestBatch 

func NewMsgRequestBatch(requester sdk.AccAddress) *MsgRequestBatch

NewMsgRequestBatch returns a new msgRequestBatch

func (*MsgRequestBatch) Descriptor 

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

func (*MsgRequestBatch) GetRequester 

func (m *MsgRequestBatch) GetRequester() string

func (MsgRequestBatch) GetSignBytes 

func (msg MsgRequestBatch) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgRequestBatch) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgRequestBatch) Marshal 

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

func (*MsgRequestBatch) MarshalTo 

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

func (*MsgRequestBatch) MarshalToSizedBuffer 

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

func (*MsgRequestBatch) ProtoMessage 

func (*MsgRequestBatch) ProtoMessage()

func (*MsgRequestBatch) Reset 

func (m *MsgRequestBatch) Reset()

func (MsgRequestBatch) Route 

func (msg MsgRequestBatch) Route() string

Route should return the name of the module

func (*MsgRequestBatch) Size 

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

func (*MsgRequestBatch) String 

func (m *MsgRequestBatch) String() string

func (MsgRequestBatch) Type 

func (msg MsgRequestBatch) Type() string

Type should return the action

func (*MsgRequestBatch) Unmarshal 

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

func (MsgRequestBatch) ValidateBasic 

func (msg MsgRequestBatch) ValidateBasic() error

ValidateBasic performs stateless checks

func (*MsgRequestBatch) XXX_DiscardUnknown 

func (m *MsgRequestBatch) XXX_DiscardUnknown()

func (*MsgRequestBatch) XXX_Marshal 

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

func (*MsgRequestBatch) XXX_Merge 

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

func (*MsgRequestBatch) XXX_Size 

func (m *MsgRequestBatch) XXX_Size() int

func (*MsgRequestBatch) XXX_Unmarshal 

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

type MsgRequestBatchResponse 

type MsgRequestBatchResponse struct {
}

TODO: write response data here

func (*MsgRequestBatchResponse) Descriptor 

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

func (*MsgRequestBatchResponse) Marshal 

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

func (*MsgRequestBatchResponse) MarshalTo 

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

func (*MsgRequestBatchResponse) MarshalToSizedBuffer 

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

func (*MsgRequestBatchResponse) ProtoMessage 

func (*MsgRequestBatchResponse) ProtoMessage()

func (*MsgRequestBatchResponse) Reset 

func (m *MsgRequestBatchResponse) Reset()

func (*MsgRequestBatchResponse) Size 

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

func (*MsgRequestBatchResponse) String 

func (m *MsgRequestBatchResponse) String() string

func (*MsgRequestBatchResponse) Unmarshal 

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

func (*MsgRequestBatchResponse) XXX_DiscardUnknown 

func (m *MsgRequestBatchResponse) XXX_DiscardUnknown()

func (*MsgRequestBatchResponse) XXX_Marshal 

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

func (*MsgRequestBatchResponse) XXX_Merge 

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

func (*MsgRequestBatchResponse) XXX_Size 

func (m *MsgRequestBatchResponse) XXX_Size() int

func (*MsgRequestBatchResponse) XXX_Unmarshal 

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

type MsgSendToEthClaim 

type MsgSendToEthClaim struct {
	EventNonce   uint64                                 `protobuf:"varint,1,opt,name=event_nonce,json=eventNonce,proto3" json:"event_nonce,omitempty"`
	CoinId       uint64                                 `protobuf:"varint,2,opt,name=coinId,proto3" json:"coinId,omitempty"`
	Amount       github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,3,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount"`
	Fee          github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,4,opt,name=fee,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"fee"`
	MinterSender string                                 `protobuf:"bytes,5,opt,name=minter_sender,json=minterSender,proto3" json:"minter_sender,omitempty"`
	EthReceiver  string                                 `protobuf:"bytes,6,opt,name=eth_receiver,json=ethReceiver,proto3" json:"eth_receiver,omitempty"`
	Orchestrator string                                 `protobuf:"bytes,7,opt,name=orchestrator,proto3" json:"orchestrator,omitempty"`
	TxHash       string                                 `protobuf:"bytes,8,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
}

func (*MsgSendToEthClaim) ClaimHash 

func (msg *MsgSendToEthClaim) ClaimHash() []byte

Hash implements BridgeDeposit.Hash

func (*MsgSendToEthClaim) Descriptor 

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

func (*MsgSendToEthClaim) GetCoinId 

func (m *MsgSendToEthClaim) GetCoinId() uint64

func (*MsgSendToEthClaim) GetEthReceiver 

func (m *MsgSendToEthClaim) GetEthReceiver() string

func (*MsgSendToEthClaim) GetEventNonce 

func (m *MsgSendToEthClaim) GetEventNonce() uint64

func (*MsgSendToEthClaim) GetMinterSender 

func (m *MsgSendToEthClaim) GetMinterSender() string

func (*MsgSendToEthClaim) GetOrchestrator 

func (m *MsgSendToEthClaim) GetOrchestrator() string

func (MsgSendToEthClaim) GetSignBytes 

func (msg MsgSendToEthClaim) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgSendToEthClaim) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgSendToEthClaim) GetTxHash 

func (m *MsgSendToEthClaim) GetTxHash() string

func (*MsgSendToEthClaim) GetType 

func (msg *MsgSendToEthClaim) GetType() ClaimType

GetType returns the type of the claim

func (*MsgSendToEthClaim) Marshal 

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

func (*MsgSendToEthClaim) MarshalTo 

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

func (*MsgSendToEthClaim) MarshalToSizedBuffer 

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

func (*MsgSendToEthClaim) ProtoMessage 

func (*MsgSendToEthClaim) ProtoMessage()

func (*MsgSendToEthClaim) Reset 

func (m *MsgSendToEthClaim) Reset()

func (MsgSendToEthClaim) Route 

func (msg MsgSendToEthClaim) Route() string

Route should return the name of the module

func (*MsgSendToEthClaim) Size 

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

func (*MsgSendToEthClaim) String 

func (m *MsgSendToEthClaim) String() string

func (MsgSendToEthClaim) Type 

func (msg MsgSendToEthClaim) Type() string

Type should return the action

func (*MsgSendToEthClaim) Unmarshal 

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

func (*MsgSendToEthClaim) ValidateBasic 

func (msg *MsgSendToEthClaim) ValidateBasic() error

ValidateBasic performs stateless checks

func (*MsgSendToEthClaim) XXX_DiscardUnknown 

func (m *MsgSendToEthClaim) XXX_DiscardUnknown()

func (*MsgSendToEthClaim) XXX_Marshal 

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

func (*MsgSendToEthClaim) XXX_Merge 

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

func (*MsgSendToEthClaim) XXX_Size 

func (m *MsgSendToEthClaim) XXX_Size() int

func (*MsgSendToEthClaim) XXX_Unmarshal 

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

type MsgSendToEthClaimResponse 

type MsgSendToEthClaimResponse struct {
}

TODO: write response data here

func (*MsgSendToEthClaimResponse) Descriptor 

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

func (*MsgSendToEthClaimResponse) Marshal 

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

func (*MsgSendToEthClaimResponse) MarshalTo 

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

func (*MsgSendToEthClaimResponse) MarshalToSizedBuffer 

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

func (*MsgSendToEthClaimResponse) ProtoMessage 

func (*MsgSendToEthClaimResponse) ProtoMessage()

func (*MsgSendToEthClaimResponse) Reset 

func (m *MsgSendToEthClaimResponse) Reset()

func (*MsgSendToEthClaimResponse) Size 

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

func (*MsgSendToEthClaimResponse) String 

func (m *MsgSendToEthClaimResponse) String() string

func (*MsgSendToEthClaimResponse) Unmarshal 

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

func (*MsgSendToEthClaimResponse) XXX_DiscardUnknown 

func (m *MsgSendToEthClaimResponse) XXX_DiscardUnknown()

func (*MsgSendToEthClaimResponse) XXX_Marshal 

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

func (*MsgSendToEthClaimResponse) XXX_Merge 

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

func (*MsgSendToEthClaimResponse) XXX_Size 

func (m *MsgSendToEthClaimResponse) XXX_Size() int

func (*MsgSendToEthClaimResponse) XXX_Unmarshal 

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

type MsgSendToMinter 

type MsgSendToMinter struct {
	Sender     string     `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	MinterDest string     `protobuf:"bytes,2,opt,name=minter_dest,json=minterDest,proto3" json:"minter_dest,omitempty"`
	Amount     types.Coin `protobuf:"bytes,3,opt,name=amount,proto3" json:"amount"`
}

MsgSendToEth This is the message that a user calls when they want to bridge an asset it will later be removed when it is included in a batch and successfully submitted tokens are removed from the users balance immediately ------------- AMOUNT: the coin to send across the bridge, note the restriction that this is a single coin not a set of coins that is normal in other Cosmos messages FEE: the fee paid for the bridge, distinct from the fee paid to the chain to actually send this message in the first place. So a successful send has two layers of fees for the user

func NewMsgSendToMinter 

func NewMsgSendToMinter(sender sdk.AccAddress, destAddress string, send sdk.Coin) *MsgSendToMinter

NewMsgSendToMinter returns a new MsgSendToMinter

func (*MsgSendToMinter) Descriptor 

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

func (*MsgSendToMinter) GetAmount 

func (m *MsgSendToMinter) GetAmount() types.Coin

func (*MsgSendToMinter) GetMinterDest 

func (m *MsgSendToMinter) GetMinterDest() string

func (*MsgSendToMinter) GetSender 

func (m *MsgSendToMinter) GetSender() string

func (MsgSendToMinter) GetSignBytes 

func (msg MsgSendToMinter) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgSendToMinter) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgSendToMinter) Marshal 

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

func (*MsgSendToMinter) MarshalTo 

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

func (*MsgSendToMinter) MarshalToSizedBuffer 

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

func (*MsgSendToMinter) ProtoMessage 

func (*MsgSendToMinter) ProtoMessage()

func (*MsgSendToMinter) Reset 

func (m *MsgSendToMinter) Reset()

func (MsgSendToMinter) Route 

func (msg MsgSendToMinter) Route() string

Route should return the name of the module

func (*MsgSendToMinter) Size 

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

func (*MsgSendToMinter) String 

func (m *MsgSendToMinter) String() string

func (MsgSendToMinter) Type 

func (msg MsgSendToMinter) Type() string

Type should return the action

func (*MsgSendToMinter) Unmarshal 

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

func (MsgSendToMinter) ValidateBasic 

func (msg MsgSendToMinter) ValidateBasic() error

ValidateBasic runs stateless checks on the message Checks if the Eth address is valid

func (*MsgSendToMinter) XXX_DiscardUnknown 

func (m *MsgSendToMinter) XXX_DiscardUnknown()

func (*MsgSendToMinter) XXX_Marshal 

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

func (*MsgSendToMinter) XXX_Merge 

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

func (*MsgSendToMinter) XXX_Size 

func (m *MsgSendToMinter) XXX_Size() int

func (*MsgSendToMinter) XXX_Unmarshal 

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

type MsgSendToMinterResponse 

type MsgSendToMinterResponse struct {
}

TODO: write response data here

func (*MsgSendToMinterResponse) Descriptor 

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

func (*MsgSendToMinterResponse) Marshal 

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

func (*MsgSendToMinterResponse) MarshalTo 

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

func (*MsgSendToMinterResponse) MarshalToSizedBuffer 

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

func (*MsgSendToMinterResponse) ProtoMessage 

func (*MsgSendToMinterResponse) ProtoMessage()

func (*MsgSendToMinterResponse) Reset 

func (m *MsgSendToMinterResponse) Reset()

func (*MsgSendToMinterResponse) Size 

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

func (*MsgSendToMinterResponse) String 

func (m *MsgSendToMinterResponse) String() string

func (*MsgSendToMinterResponse) Unmarshal 

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

func (*MsgSendToMinterResponse) XXX_DiscardUnknown 

func (m *MsgSendToMinterResponse) XXX_DiscardUnknown()

func (*MsgSendToMinterResponse) XXX_Marshal 

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

func (*MsgSendToMinterResponse) XXX_Merge 

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

func (*MsgSendToMinterResponse) XXX_Size 

func (m *MsgSendToMinterResponse) XXX_Size() int

func (*MsgSendToMinterResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	ValsetConfirm(context.Context, *MsgValsetConfirm) (*MsgValsetConfirmResponse, error)
	ValsetRequest(context.Context, *MsgValsetRequest) (*MsgValsetRequestResponse, error)
	SetMinterAddress(context.Context, *MsgSetMinterAddress) (*MsgSetMinterAddressResponse, error)
	SendToEth(context.Context, *MsgSendToMinter) (*MsgSendToMinterResponse, error)
	RequestBatch(context.Context, *MsgRequestBatch) (*MsgRequestBatchResponse, error)
	ConfirmBatch(context.Context, *MsgConfirmBatch) (*MsgConfirmBatchResponse, error)
	DepositClaim(context.Context, *MsgDepositClaim) (*MsgDepositClaimResponse, error)
	WithdrawClaim(context.Context, *MsgWithdrawClaim) (*MsgWithdrawClaimResponse, error)
	SendToEthClaim(context.Context, *MsgSendToEthClaim) (*MsgSendToEthClaimResponse, error)
	ValsetClaim(context.Context, *MsgValsetClaim) (*MsgValsetClaimResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSetMinterAddress 

type MsgSetMinterAddress struct {
	Address   string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Validator string `protobuf:"bytes,2,opt,name=validator,proto3" json:"validator,omitempty"`
	Signature string `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
}

SetMinterAddress This is used by the validators to set the Minter address that represents them on the Minter side of the bridge. They must sign their Cosmos address using the Minter address they have submitted. Like ValsetResponse this message can in theory be submitted by anyone, but only the current validator sets submissions carry any weight. -------------

func NewMsgSetMinterAddress 

func NewMsgSetMinterAddress(address string, validator sdk.AccAddress, signature string) *MsgSetMinterAddress

NewMsgSetMinterAddress return a new MsgSetMinterAddress TODO: figure out if we need sdk.ValAddress here

func (*MsgSetMinterAddress) Descriptor 

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

func (*MsgSetMinterAddress) GetAddress 

func (m *MsgSetMinterAddress) GetAddress() string

func (MsgSetMinterAddress) GetSignBytes 

func (msg MsgSetMinterAddress) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (*MsgSetMinterAddress) GetSignature 

func (m *MsgSetMinterAddress) GetSignature() string

func (MsgSetMinterAddress) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgSetMinterAddress) GetValidator 

func (m *MsgSetMinterAddress) GetValidator() string

func (*MsgSetMinterAddress) Marshal 

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

func (*MsgSetMinterAddress) MarshalTo 

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

func (*MsgSetMinterAddress) MarshalToSizedBuffer 

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

func (*MsgSetMinterAddress) ProtoMessage 

func (*MsgSetMinterAddress) ProtoMessage()

func (*MsgSetMinterAddress) Reset 

func (m *MsgSetMinterAddress) Reset()

func (MsgSetMinterAddress) Route 

func (msg MsgSetMinterAddress) Route() string

Route should return the name of the module

func (*MsgSetMinterAddress) Size 

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

func (*MsgSetMinterAddress) String 

func (m *MsgSetMinterAddress) String() string

func (MsgSetMinterAddress) Type 

func (msg MsgSetMinterAddress) Type() string

Type should return the action

func (*MsgSetMinterAddress) Unmarshal 

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

func (MsgSetMinterAddress) ValidateBasic 

func (msg MsgSetMinterAddress) ValidateBasic() error

ValidateBasic runs stateless checks on the message Checks if the Eth address is valid, and whether the Eth address has signed the validator address (proving control of the Eth address)

func (*MsgSetMinterAddress) XXX_DiscardUnknown 

func (m *MsgSetMinterAddress) XXX_DiscardUnknown()

func (*MsgSetMinterAddress) XXX_Marshal 

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

func (*MsgSetMinterAddress) XXX_Merge 

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

func (*MsgSetMinterAddress) XXX_Size 

func (m *MsgSetMinterAddress) XXX_Size() int

func (*MsgSetMinterAddress) XXX_Unmarshal 

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

type MsgSetMinterAddressResponse 

type MsgSetMinterAddressResponse struct {
}

TODO: write response data here

func (*MsgSetMinterAddressResponse) Descriptor 

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

func (*MsgSetMinterAddressResponse) Marshal 

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

func (*MsgSetMinterAddressResponse) MarshalTo 

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

func (*MsgSetMinterAddressResponse) MarshalToSizedBuffer 

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

func (*MsgSetMinterAddressResponse) ProtoMessage 

func (*MsgSetMinterAddressResponse) ProtoMessage()

func (*MsgSetMinterAddressResponse) Reset 

func (m *MsgSetMinterAddressResponse) Reset()

func (*MsgSetMinterAddressResponse) Size 

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

func (*MsgSetMinterAddressResponse) String 

func (m *MsgSetMinterAddressResponse) String() string

func (*MsgSetMinterAddressResponse) Unmarshal 

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

func (*MsgSetMinterAddressResponse) XXX_DiscardUnknown 

func (m *MsgSetMinterAddressResponse) XXX_DiscardUnknown()

func (*MsgSetMinterAddressResponse) XXX_Marshal 

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

func (*MsgSetMinterAddressResponse) XXX_Merge 

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

func (*MsgSetMinterAddressResponse) XXX_Size 

func (m *MsgSetMinterAddressResponse) XXX_Size() int

func (*MsgSetMinterAddressResponse) XXX_Unmarshal 

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

type MsgValsetClaim 

type MsgValsetClaim struct {
	EventNonce   uint64 `protobuf:"varint,1,opt,name=event_nonce,json=eventNonce,proto3" json:"event_nonce,omitempty"`
	ValsetNonce  uint64 `protobuf:"varint,2,opt,name=valset_nonce,json=valsetNonce,proto3" json:"valset_nonce,omitempty"`
	Orchestrator string `protobuf:"bytes,3,opt,name=orchestrator,proto3" json:"orchestrator,omitempty"`
}

WithdrawClaim claims that a valset operations on the bridge contract was executed.

func (*MsgValsetClaim) ClaimHash 

func (msg *MsgValsetClaim) ClaimHash() []byte

Hash implements BridgeDeposit.Hash

func (*MsgValsetClaim) Descriptor 

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

func (*MsgValsetClaim) GetEventNonce 

func (m *MsgValsetClaim) GetEventNonce() uint64

func (*MsgValsetClaim) GetOrchestrator 

func (m *MsgValsetClaim) GetOrchestrator() string

func (MsgValsetClaim) GetSignBytes 

func (msg MsgValsetClaim) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgValsetClaim) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgValsetClaim) GetType 

func (msg *MsgValsetClaim) GetType() ClaimType

GetType returns the type of the claim

func (*MsgValsetClaim) GetValsetNonce 

func (m *MsgValsetClaim) GetValsetNonce() uint64

func (*MsgValsetClaim) Marshal 

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

func (*MsgValsetClaim) MarshalTo 

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

func (*MsgValsetClaim) MarshalToSizedBuffer 

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

func (*MsgValsetClaim) ProtoMessage 

func (*MsgValsetClaim) ProtoMessage()

func (*MsgValsetClaim) Reset 

func (m *MsgValsetClaim) Reset()

func (MsgValsetClaim) Route 

func (msg MsgValsetClaim) Route() string

Route should return the name of the module

func (*MsgValsetClaim) Size 

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

func (*MsgValsetClaim) String 

func (m *MsgValsetClaim) String() string

func (MsgValsetClaim) Type 

func (msg MsgValsetClaim) Type() string

Type should return the action

func (*MsgValsetClaim) Unmarshal 

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

func (*MsgValsetClaim) ValidateBasic 

func (msg *MsgValsetClaim) ValidateBasic() error

ValidateBasic performs stateless checks

func (*MsgValsetClaim) XXX_DiscardUnknown 

func (m *MsgValsetClaim) XXX_DiscardUnknown()

func (*MsgValsetClaim) XXX_Marshal 

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

func (*MsgValsetClaim) XXX_Merge 

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

func (*MsgValsetClaim) XXX_Size 

func (m *MsgValsetClaim) XXX_Size() int

func (*MsgValsetClaim) XXX_Unmarshal 

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

type MsgValsetClaimResponse 

type MsgValsetClaimResponse struct {
}

TODO: write response data here

func (*MsgValsetClaimResponse) Descriptor 

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

func (*MsgValsetClaimResponse) Marshal 

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

func (*MsgValsetClaimResponse) MarshalTo 

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

func (*MsgValsetClaimResponse) MarshalToSizedBuffer 

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

func (*MsgValsetClaimResponse) ProtoMessage 

func (*MsgValsetClaimResponse) ProtoMessage()

func (*MsgValsetClaimResponse) Reset 

func (m *MsgValsetClaimResponse) Reset()

func (*MsgValsetClaimResponse) Size 

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

func (*MsgValsetClaimResponse) String 

func (m *MsgValsetClaimResponse) String() string

func (*MsgValsetClaimResponse) Unmarshal 

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

func (*MsgValsetClaimResponse) XXX_DiscardUnknown 

func (m *MsgValsetClaimResponse) XXX_DiscardUnknown()

func (*MsgValsetClaimResponse) XXX_Marshal 

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

func (*MsgValsetClaimResponse) XXX_Merge 

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

func (*MsgValsetClaimResponse) XXX_Size 

func (m *MsgValsetClaimResponse) XXX_Size() int

func (*MsgValsetClaimResponse) XXX_Unmarshal 

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

type MsgValsetConfirm 

type MsgValsetConfirm struct {
	Nonce         uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	Validator     string `protobuf:"bytes,2,opt,name=validator,proto3" json:"validator,omitempty"`
	MinterAddress string `protobuf:"bytes,3,opt,name=minter_address,json=minterAddress,proto3" json:"minter_address,omitempty"`
	Signature     string `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
}

MsgValsetConfirm this is the message sent by the validators when they wish to submit their signatures over the validator set at a given block height. A validator must first call MsgSetEthAddress to set their Ethereum address to be used for signing. Then someone (anyone) must make a ValsetRequest the request is essentially a messaging mechanism to determine which block all validators should submit signatures over. Finally validators sign the validator set, powers, and Ethereum addresses of the entire validator set at the height of a ValsetRequest and submit that signature with this message.

If a sufficient number of validators (66% of voting power) (A) have set Ethereum addresses and (B) submit ValsetConfirm messages with their signatures it is then possible for anyone to view these signatures in the chain store and submit them to Ethereum to update the validator set -------------

func NewMsgValsetConfirm 

func NewMsgValsetConfirm(nonce uint64, minterAddress string, validator sdk.AccAddress, signature string) *MsgValsetConfirm

NewMsgValsetConfirm returns a new msgValsetConfirm

func (*MsgValsetConfirm) Descriptor 

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

func (*MsgValsetConfirm) GetMinterAddress 

func (m *MsgValsetConfirm) GetMinterAddress() string

func (*MsgValsetConfirm) GetNonce 

func (m *MsgValsetConfirm) GetNonce() uint64

func (*MsgValsetConfirm) GetSignBytes 

func (msg *MsgValsetConfirm) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (*MsgValsetConfirm) GetSignature 

func (m *MsgValsetConfirm) GetSignature() string

func (*MsgValsetConfirm) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgValsetConfirm) GetValidator 

func (m *MsgValsetConfirm) GetValidator() string

func (*MsgValsetConfirm) Marshal 

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

func (*MsgValsetConfirm) MarshalTo 

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

func (*MsgValsetConfirm) MarshalToSizedBuffer 

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

func (*MsgValsetConfirm) ProtoMessage 

func (*MsgValsetConfirm) ProtoMessage()

func (*MsgValsetConfirm) Reset 

func (m *MsgValsetConfirm) Reset()

func (*MsgValsetConfirm) Route 

func (msg *MsgValsetConfirm) Route() string

Route should return the name of the module

func (*MsgValsetConfirm) Size 

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

func (*MsgValsetConfirm) String 

func (m *MsgValsetConfirm) String() string

func (*MsgValsetConfirm) Type 

func (msg *MsgValsetConfirm) Type() string

Type should return the action

func (*MsgValsetConfirm) Unmarshal 

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

func (*MsgValsetConfirm) ValidateBasic 

func (msg *MsgValsetConfirm) ValidateBasic() (err error)

ValidateBasic performs stateless checks

func (*MsgValsetConfirm) XXX_DiscardUnknown 

func (m *MsgValsetConfirm) XXX_DiscardUnknown()

func (*MsgValsetConfirm) XXX_Marshal 

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

func (*MsgValsetConfirm) XXX_Merge 

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

func (*MsgValsetConfirm) XXX_Size 

func (m *MsgValsetConfirm) XXX_Size() int

func (*MsgValsetConfirm) XXX_Unmarshal 

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

type MsgValsetConfirmResponse 

type MsgValsetConfirmResponse struct {
}

TODO: write response data here

func (*MsgValsetConfirmResponse) Descriptor 

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

func (*MsgValsetConfirmResponse) Marshal 

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

func (*MsgValsetConfirmResponse) MarshalTo 

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

func (*MsgValsetConfirmResponse) MarshalToSizedBuffer 

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

func (*MsgValsetConfirmResponse) ProtoMessage 

func (*MsgValsetConfirmResponse) ProtoMessage()

func (*MsgValsetConfirmResponse) Reset 

func (m *MsgValsetConfirmResponse) Reset()

func (*MsgValsetConfirmResponse) Size 

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

func (*MsgValsetConfirmResponse) String 

func (m *MsgValsetConfirmResponse) String() string

func (*MsgValsetConfirmResponse) Unmarshal 

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

func (*MsgValsetConfirmResponse) XXX_DiscardUnknown 

func (m *MsgValsetConfirmResponse) XXX_DiscardUnknown()

func (*MsgValsetConfirmResponse) XXX_Marshal 

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

func (*MsgValsetConfirmResponse) XXX_Merge 

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

func (*MsgValsetConfirmResponse) XXX_Size 

func (m *MsgValsetConfirmResponse) XXX_Size() int

func (*MsgValsetConfirmResponse) XXX_Unmarshal 

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

type MsgValsetRequest 

type MsgValsetRequest struct {
	Requester string `protobuf:"bytes,1,opt,name=requester,proto3" json:"requester,omitempty"`
}

ValsetRequest This message starts off the validator set update process by coordinating a block height around which signatures over the validators, powers, and ethereum addresses will be made and submitted using a ValsetConfirm. Anyone can send this message as it is not authenticated except as a valid tx. In theory people could spam it and the validators will have to determine which block to actually coordinate around by looking over the valset requests and seeing which one some other validator has already submitted a ValsetResponse for. -------------

func NewMsgValsetRequest 

func NewMsgValsetRequest(requester sdk.AccAddress) *MsgValsetRequest

NewMsgValsetRequest returns a new msgValsetRequest

func (*MsgValsetRequest) Descriptor 

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

func (*MsgValsetRequest) GetRequester 

func (m *MsgValsetRequest) GetRequester() string

func (MsgValsetRequest) GetSignBytes 

func (msg MsgValsetRequest) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgValsetRequest) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgValsetRequest) Marshal 

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

func (*MsgValsetRequest) MarshalTo 

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

func (*MsgValsetRequest) MarshalToSizedBuffer 

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

func (*MsgValsetRequest) ProtoMessage 

func (*MsgValsetRequest) ProtoMessage()

func (*MsgValsetRequest) Reset 

func (m *MsgValsetRequest) Reset()

func (MsgValsetRequest) Route 

func (msg MsgValsetRequest) Route() string

Route should return the name of the module

func (*MsgValsetRequest) Size 

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

func (*MsgValsetRequest) String 

func (m *MsgValsetRequest) String() string

func (MsgValsetRequest) Type 

func (msg MsgValsetRequest) Type() string

Type should return the action

func (*MsgValsetRequest) Unmarshal 

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

func (MsgValsetRequest) ValidateBasic 

func (msg MsgValsetRequest) ValidateBasic() (err error)

ValidateBasic performs stateless checks

func (*MsgValsetRequest) XXX_DiscardUnknown 

func (m *MsgValsetRequest) XXX_DiscardUnknown()

func (*MsgValsetRequest) XXX_Marshal 

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

func (*MsgValsetRequest) XXX_Merge 

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

func (*MsgValsetRequest) XXX_Size 

func (m *MsgValsetRequest) XXX_Size() int

func (*MsgValsetRequest) XXX_Unmarshal 

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

type MsgValsetRequestResponse 

type MsgValsetRequestResponse struct {
}

TODO: write response data here

func (*MsgValsetRequestResponse) Descriptor 

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

func (*MsgValsetRequestResponse) Marshal 

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

func (*MsgValsetRequestResponse) MarshalTo 

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

func (*MsgValsetRequestResponse) MarshalToSizedBuffer 

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

func (*MsgValsetRequestResponse) ProtoMessage 

func (*MsgValsetRequestResponse) ProtoMessage()

func (*MsgValsetRequestResponse) Reset 

func (m *MsgValsetRequestResponse) Reset()

func (*MsgValsetRequestResponse) Size 

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

func (*MsgValsetRequestResponse) String 

func (m *MsgValsetRequestResponse) String() string

func (*MsgValsetRequestResponse) Unmarshal 

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

func (*MsgValsetRequestResponse) XXX_DiscardUnknown 

func (m *MsgValsetRequestResponse) XXX_DiscardUnknown()

func (*MsgValsetRequestResponse) XXX_Marshal 

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

func (*MsgValsetRequestResponse) XXX_Merge 

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

func (*MsgValsetRequestResponse) XXX_Size 

func (m *MsgValsetRequestResponse) XXX_Size() int

func (*MsgValsetRequestResponse) XXX_Unmarshal 

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

type MsgWithdrawClaim 

type MsgWithdrawClaim struct {
	EventNonce   uint64 `protobuf:"varint,1,opt,name=event_nonce,json=eventNonce,proto3" json:"event_nonce,omitempty"`
	BatchNonce   uint64 `protobuf:"varint,2,opt,name=batch_nonce,json=batchNonce,proto3" json:"batch_nonce,omitempty"`
	Orchestrator string `protobuf:"bytes,4,opt,name=orchestrator,proto3" json:"orchestrator,omitempty"`
	TxHash       string `protobuf:"bytes,5,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
}

WithdrawClaim claims that a batch of withdrawal operations on the bridge contract was executed.

func (*MsgWithdrawClaim) ClaimHash 

func (msg *MsgWithdrawClaim) ClaimHash() []byte

Hash implements WithdrawBatch.Hash

func (*MsgWithdrawClaim) Descriptor 

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

func (*MsgWithdrawClaim) GetBatchNonce 

func (m *MsgWithdrawClaim) GetBatchNonce() uint64

func (*MsgWithdrawClaim) GetEventNonce 

func (m *MsgWithdrawClaim) GetEventNonce() uint64

func (*MsgWithdrawClaim) GetOrchestrator 

func (m *MsgWithdrawClaim) GetOrchestrator() string

func (MsgWithdrawClaim) GetSignBytes 

func (msg MsgWithdrawClaim) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgWithdrawClaim) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgWithdrawClaim) GetTxHash 

func (m *MsgWithdrawClaim) GetTxHash() string

func (*MsgWithdrawClaim) GetType 

func (msg *MsgWithdrawClaim) GetType() ClaimType

GetType returns the claim type

func (*MsgWithdrawClaim) Marshal 

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

func (*MsgWithdrawClaim) MarshalTo 

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

func (*MsgWithdrawClaim) MarshalToSizedBuffer 

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

func (*MsgWithdrawClaim) ProtoMessage 

func (*MsgWithdrawClaim) ProtoMessage()

func (*MsgWithdrawClaim) Reset 

func (m *MsgWithdrawClaim) Reset()

func (MsgWithdrawClaim) Route 

func (msg MsgWithdrawClaim) Route() string

Route should return the name of the module

func (*MsgWithdrawClaim) Size 

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

func (*MsgWithdrawClaim) String 

func (m *MsgWithdrawClaim) String() string

func (MsgWithdrawClaim) Type 

func (msg MsgWithdrawClaim) Type() string

Type should return the action

func (*MsgWithdrawClaim) Unmarshal 

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

func (*MsgWithdrawClaim) ValidateBasic 

func (msg *MsgWithdrawClaim) ValidateBasic() error

ValidateBasic performs stateless checks

func (*MsgWithdrawClaim) XXX_DiscardUnknown 

func (m *MsgWithdrawClaim) XXX_DiscardUnknown()

func (*MsgWithdrawClaim) XXX_Marshal 

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

func (*MsgWithdrawClaim) XXX_Merge 

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

func (*MsgWithdrawClaim) XXX_Size 

func (m *MsgWithdrawClaim) XXX_Size() int

func (*MsgWithdrawClaim) XXX_Unmarshal 

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

type MsgWithdrawClaimResponse 

type MsgWithdrawClaimResponse struct {
}

TODO: write response data here

func (*MsgWithdrawClaimResponse) Descriptor 

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

func (*MsgWithdrawClaimResponse) Marshal 

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

func (*MsgWithdrawClaimResponse) MarshalTo 

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

func (*MsgWithdrawClaimResponse) MarshalToSizedBuffer 

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

func (*MsgWithdrawClaimResponse) ProtoMessage 

func (*MsgWithdrawClaimResponse) ProtoMessage()

func (*MsgWithdrawClaimResponse) Reset 

func (m *MsgWithdrawClaimResponse) Reset()

func (*MsgWithdrawClaimResponse) Size 

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

func (*MsgWithdrawClaimResponse) String 

func (m *MsgWithdrawClaimResponse) String() string

func (*MsgWithdrawClaimResponse) Unmarshal 

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

func (*MsgWithdrawClaimResponse) XXX_DiscardUnknown 

func (m *MsgWithdrawClaimResponse) XXX_DiscardUnknown()

func (*MsgWithdrawClaimResponse) XXX_Marshal 

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

func (*MsgWithdrawClaimResponse) XXX_Merge 

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

func (*MsgWithdrawClaimResponse) XXX_Size 

func (m *MsgWithdrawClaimResponse) XXX_Size() int

func (*MsgWithdrawClaimResponse) XXX_Unmarshal 

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

type OutgoingTransferTx 

type OutgoingTransferTx struct {
	Id          uint64      `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Sender      string      `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
	DestAddress string      `protobuf:"bytes,3,opt,name=dest_address,json=destAddress,proto3" json:"dest_address,omitempty"`
	MinterToken *MinterCoin `protobuf:"bytes,4,opt,name=minter_token,json=minterToken,proto3" json:"minter_token,omitempty"`
	TxHash      string      `protobuf:"bytes,5,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
}

func (*OutgoingTransferTx) Descriptor 

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

func (*OutgoingTransferTx) GetDestAddress 

func (m *OutgoingTransferTx) GetDestAddress() string

func (*OutgoingTransferTx) GetId 

func (m *OutgoingTransferTx) GetId() uint64

func (*OutgoingTransferTx) GetMinterToken 

func (m *OutgoingTransferTx) GetMinterToken() *MinterCoin

func (*OutgoingTransferTx) GetSender 

func (m *OutgoingTransferTx) GetSender() string

func (*OutgoingTransferTx) GetTxHash 

func (m *OutgoingTransferTx) GetTxHash() string

func (*OutgoingTransferTx) Marshal 

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

func (*OutgoingTransferTx) MarshalTo 

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

func (*OutgoingTransferTx) MarshalToSizedBuffer 

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

func (*OutgoingTransferTx) ProtoMessage 

func (*OutgoingTransferTx) ProtoMessage()

func (*OutgoingTransferTx) Reset 

func (m *OutgoingTransferTx) Reset()

func (*OutgoingTransferTx) Size 

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

func (*OutgoingTransferTx) String 

func (m *OutgoingTransferTx) String() string

func (*OutgoingTransferTx) Unmarshal 

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

func (*OutgoingTransferTx) XXX_DiscardUnknown 

func (m *OutgoingTransferTx) XXX_DiscardUnknown()

func (*OutgoingTransferTx) XXX_Marshal 

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

func (*OutgoingTransferTx) XXX_Merge 

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

func (*OutgoingTransferTx) XXX_Size 

func (m *OutgoingTransferTx) XXX_Size() int

func (*OutgoingTransferTx) XXX_Unmarshal 

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

type OutgoingTx 

type OutgoingTx struct {
	Sender   string     `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	DestAddr string     `protobuf:"bytes,2,opt,name=dest_addr,json=destAddr,proto3" json:"dest_addr,omitempty"`
	Amount   types.Coin `protobuf:"bytes,3,opt,name=amount,proto3" json:"amount"`
	TxHash   string     `protobuf:"bytes,7,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
}

OutgoingTx is a withdrawal on the bridged contract TODO: can this type be replaced by outgoing transfer tx

func (*OutgoingTx) Descriptor 

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

func (*OutgoingTx) GetAmount 

func (m *OutgoingTx) GetAmount() types.Coin

func (*OutgoingTx) GetDestAddr 

func (m *OutgoingTx) GetDestAddr() string

func (*OutgoingTx) GetSender 

func (m *OutgoingTx) GetSender() string

func (*OutgoingTx) GetTxHash 

func (m *OutgoingTx) GetTxHash() string

func (*OutgoingTx) Marshal 

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

func (*OutgoingTx) MarshalTo 

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

func (*OutgoingTx) MarshalToSizedBuffer 

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

func (*OutgoingTx) ProtoMessage 

func (*OutgoingTx) ProtoMessage()

func (*OutgoingTx) Reset 

func (m *OutgoingTx) Reset()

func (*OutgoingTx) Size 

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

func (*OutgoingTx) String 

func (m *OutgoingTx) String() string

func (*OutgoingTx) Unmarshal 

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

func (*OutgoingTx) XXX_DiscardUnknown 

func (m *OutgoingTx) XXX_DiscardUnknown()

func (*OutgoingTx) XXX_Marshal 

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

func (*OutgoingTx) XXX_Merge 

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

func (*OutgoingTx) XXX_Size 

func (m *OutgoingTx) XXX_Size() int

func (*OutgoingTx) XXX_Unmarshal 

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

type OutgoingTxBatch 

type OutgoingTxBatch struct {
	BatchNonce   uint64                `protobuf:"varint,1,opt,name=batch_nonce,json=batchNonce,proto3" json:"batch_nonce,omitempty"`
	MinterNonce  uint64                `protobuf:"varint,2,opt,name=minter_nonce,json=minterNonce,proto3" json:"minter_nonce,omitempty"`
	Transactions []*OutgoingTransferTx `protobuf:"bytes,3,rep,name=transactions,proto3" json:"transactions,omitempty"`
}

func (*OutgoingTxBatch) Descriptor 

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

func (*OutgoingTxBatch) GetBatchNonce 

func (m *OutgoingTxBatch) GetBatchNonce() uint64

func (*OutgoingTxBatch) GetMinterNonce 

func (m *OutgoingTxBatch) GetMinterNonce() uint64

func (*OutgoingTxBatch) GetTransactions 

func (m *OutgoingTxBatch) GetTransactions() []*OutgoingTransferTx

func (*OutgoingTxBatch) Marshal 

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

func (*OutgoingTxBatch) MarshalTo 

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

func (*OutgoingTxBatch) MarshalToSizedBuffer 

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

func (*OutgoingTxBatch) ProtoMessage 

func (*OutgoingTxBatch) ProtoMessage()

func (*OutgoingTxBatch) Reset 

func (m *OutgoingTxBatch) Reset()

func (*OutgoingTxBatch) Size 

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

func (*OutgoingTxBatch) String 

func (m *OutgoingTxBatch) String() string

func (*OutgoingTxBatch) Unmarshal 

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

func (*OutgoingTxBatch) XXX_DiscardUnknown 

func (m *OutgoingTxBatch) XXX_DiscardUnknown()

func (*OutgoingTxBatch) XXX_Marshal 

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

func (*OutgoingTxBatch) XXX_Merge 

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

func (*OutgoingTxBatch) XXX_Size 

func (m *OutgoingTxBatch) XXX_Size() int

func (*OutgoingTxBatch) XXX_Unmarshal 

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

type Params 

type Params struct {
	StartThreshold                uint64                                 `protobuf:"varint,1,opt,name=start_threshold,json=startThreshold,proto3" json:"start_threshold,omitempty"`
	MinterAddress                 string                                 `protobuf:"bytes,2,opt,name=minter_address,json=minterAddress,proto3" json:"minter_address,omitempty"`
	BridgeChainId                 uint64                                 `protobuf:"varint,3,opt,name=bridge_chain_id,json=bridgeChainId,proto3" json:"bridge_chain_id,omitempty"`
	SignedValsetsWindow           uint64                                 `protobuf:"varint,4,opt,name=signed_valsets_window,json=signedValsetsWindow,proto3" json:"signed_valsets_window,omitempty"`
	SignedBatchesWindow           uint64                                 `protobuf:"varint,5,opt,name=signed_batches_window,json=signedBatchesWindow,proto3" json:"signed_batches_window,omitempty"`
	SignedClaimsWindow            uint64                                 `protobuf:"varint,6,opt,name=signed_claims_window,json=signedClaimsWindow,proto3" json:"signed_claims_window,omitempty"`
	SlashFractionValset           github_com_cosmos_cosmos_sdk_types.Dec `` /* 160-byte string literal not displayed */
	SlashFractionBatch            github_com_cosmos_cosmos_sdk_types.Dec `` /* 157-byte string literal not displayed */
	SlashFractionClaim            github_com_cosmos_cosmos_sdk_types.Dec `` /* 157-byte string literal not displayed */
	SlashFractionConflictingClaim github_com_cosmos_cosmos_sdk_types.Dec `` /* 193-byte string literal not displayed */
	Stopped                       bool                                   `protobuf:"varint,11,opt,name=stopped,proto3" json:"stopped,omitempty"`
}

func DefaultParams 

func DefaultParams() *Params

DefaultParams returns a copy of the default params

func (*Params) Descriptor 

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

func (Params) Equal 

func (p Params) Equal(p2 Params) bool

Equal returns a boolean determining if two Params types are identical.

func (*Params) GetBridgeChainId 

func (m *Params) GetBridgeChainId() uint64

func (*Params) GetMinterAddress 

func (m *Params) GetMinterAddress() string

func (*Params) GetSignedBatchesWindow 

func (m *Params) GetSignedBatchesWindow() uint64

func (*Params) GetSignedClaimsWindow 

func (m *Params) GetSignedClaimsWindow() uint64

func (*Params) GetSignedValsetsWindow 

func (m *Params) GetSignedValsetsWindow() uint64

func (*Params) GetStartThreshold 

func (m *Params) GetStartThreshold() uint64

func (*Params) GetStopped 

func (m *Params) GetStopped() bool

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

func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs

ParamSetPairs implements the ParamSet interface and returns all the key/value pairs pairs of auth module's parameters.

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 (m *Params) String() string

func (*Params) Unmarshal 

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

func (Params) ValidateBasic 

func (p Params) ValidateBasic() error

ValidateBasic checks that the parameters have valid values.

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 PeggyKeeper 

type PeggyKeeper interface {
	AddToOutgoingPool(ctx sdk.Context, sender sdk.AccAddress, counterpartReceiver string, refundAddr string, txHash string, amount sdk.Coin, fee sdk.Coin) (uint64, error)
}

PeggyKeeper defines the expected peggy keeper methods

type QueryBatchConfirmsRequest 

type QueryBatchConfirmsRequest struct {
	Nonce uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
}

func (*QueryBatchConfirmsRequest) Descriptor 

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

func (*QueryBatchConfirmsRequest) GetNonce 

func (m *QueryBatchConfirmsRequest) GetNonce() uint64

func (*QueryBatchConfirmsRequest) Marshal 

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

func (*QueryBatchConfirmsRequest) MarshalTo 

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

func (*QueryBatchConfirmsRequest) MarshalToSizedBuffer 

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

func (*QueryBatchConfirmsRequest) ProtoMessage 

func (*QueryBatchConfirmsRequest) ProtoMessage()

func (*QueryBatchConfirmsRequest) Reset 

func (m *QueryBatchConfirmsRequest) Reset()

func (*QueryBatchConfirmsRequest) Size 

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

func (*QueryBatchConfirmsRequest) String 

func (m *QueryBatchConfirmsRequest) String() string

func (*QueryBatchConfirmsRequest) Unmarshal 

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

func (*QueryBatchConfirmsRequest) XXX_DiscardUnknown 

func (m *QueryBatchConfirmsRequest) XXX_DiscardUnknown()

func (*QueryBatchConfirmsRequest) XXX_Marshal 

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

func (*QueryBatchConfirmsRequest) XXX_Merge 

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

func (*QueryBatchConfirmsRequest) XXX_Size 

func (m *QueryBatchConfirmsRequest) XXX_Size() int

func (*QueryBatchConfirmsRequest) XXX_Unmarshal 

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

type QueryBatchConfirmsResponse 

type QueryBatchConfirmsResponse struct {
	Confirms []*MsgConfirmBatch `protobuf:"bytes,1,rep,name=confirms,proto3" json:"confirms,omitempty"`
}

func (*QueryBatchConfirmsResponse) Descriptor 

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

func (*QueryBatchConfirmsResponse) GetConfirms 

func (m *QueryBatchConfirmsResponse) GetConfirms() []*MsgConfirmBatch

func (*QueryBatchConfirmsResponse) Marshal 

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

func (*QueryBatchConfirmsResponse) MarshalTo 

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

func (*QueryBatchConfirmsResponse) MarshalToSizedBuffer 

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

func (*QueryBatchConfirmsResponse) ProtoMessage 

func (*QueryBatchConfirmsResponse) ProtoMessage()

func (*QueryBatchConfirmsResponse) Reset 

func (m *QueryBatchConfirmsResponse) Reset()

func (*QueryBatchConfirmsResponse) Size 

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

func (*QueryBatchConfirmsResponse) String 

func (m *QueryBatchConfirmsResponse) String() string

func (*QueryBatchConfirmsResponse) Unmarshal 

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

func (*QueryBatchConfirmsResponse) XXX_DiscardUnknown 

func (m *QueryBatchConfirmsResponse) XXX_DiscardUnknown()

func (*QueryBatchConfirmsResponse) XXX_Marshal 

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

func (*QueryBatchConfirmsResponse) XXX_Merge 

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

func (*QueryBatchConfirmsResponse) XXX_Size 

func (m *QueryBatchConfirmsResponse) XXX_Size() int

func (*QueryBatchConfirmsResponse) XXX_Unmarshal 

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

type QueryBatchRequestByNonceRequest 

type QueryBatchRequestByNonceRequest struct {
	Nonce uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
}

func (*QueryBatchRequestByNonceRequest) Descriptor 

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

func (*QueryBatchRequestByNonceRequest) GetNonce 

func (m *QueryBatchRequestByNonceRequest) GetNonce() uint64

func (*QueryBatchRequestByNonceRequest) Marshal 

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

func (*QueryBatchRequestByNonceRequest) MarshalTo 

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

func (*QueryBatchRequestByNonceRequest) MarshalToSizedBuffer 

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

func (*QueryBatchRequestByNonceRequest) ProtoMessage 

func (*QueryBatchRequestByNonceRequest) ProtoMessage()

func (*QueryBatchRequestByNonceRequest) Reset 

func (m *QueryBatchRequestByNonceRequest) Reset()

func (*QueryBatchRequestByNonceRequest) Size 

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

func (*QueryBatchRequestByNonceRequest) String 

func (m *QueryBatchRequestByNonceRequest) String() string

func (*QueryBatchRequestByNonceRequest) Unmarshal 

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

func (*QueryBatchRequestByNonceRequest) XXX_DiscardUnknown 

func (m *QueryBatchRequestByNonceRequest) XXX_DiscardUnknown()

func (*QueryBatchRequestByNonceRequest) XXX_Marshal 

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

func (*QueryBatchRequestByNonceRequest) XXX_Merge 

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

func (*QueryBatchRequestByNonceRequest) XXX_Size 

func (m *QueryBatchRequestByNonceRequest) XXX_Size() int

func (*QueryBatchRequestByNonceRequest) XXX_Unmarshal 

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

type QueryBatchRequestByNonceResponse 

type QueryBatchRequestByNonceResponse struct {
	Batch *OutgoingTxBatch `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"`
}

func (*QueryBatchRequestByNonceResponse) Descriptor 

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

func (*QueryBatchRequestByNonceResponse) GetBatch 

func (m *QueryBatchRequestByNonceResponse) GetBatch() *OutgoingTxBatch

func (*QueryBatchRequestByNonceResponse) Marshal 

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

func (*QueryBatchRequestByNonceResponse) MarshalTo 

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

func (*QueryBatchRequestByNonceResponse) MarshalToSizedBuffer 

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

func (*QueryBatchRequestByNonceResponse) ProtoMessage 

func (*QueryBatchRequestByNonceResponse) ProtoMessage()

func (*QueryBatchRequestByNonceResponse) Reset 

func (m *QueryBatchRequestByNonceResponse) Reset()

func (*QueryBatchRequestByNonceResponse) Size 

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

func (*QueryBatchRequestByNonceResponse) String 

func (m *QueryBatchRequestByNonceResponse) String() string

func (*QueryBatchRequestByNonceResponse) Unmarshal 

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

func (*QueryBatchRequestByNonceResponse) XXX_DiscardUnknown 

func (m *QueryBatchRequestByNonceResponse) XXX_DiscardUnknown()

func (*QueryBatchRequestByNonceResponse) XXX_Marshal 

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

func (*QueryBatchRequestByNonceResponse) XXX_Merge 

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

func (*QueryBatchRequestByNonceResponse) XXX_Size 

func (m *QueryBatchRequestByNonceResponse) XXX_Size() int

func (*QueryBatchRequestByNonceResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Deployments queries deployments
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	CurrentValset(ctx context.Context, in *QueryCurrentValsetRequest, opts ...grpc.CallOption) (*QueryCurrentValsetResponse, error)
	ValsetRequest(ctx context.Context, in *QueryValsetRequestRequest, opts ...grpc.CallOption) (*QueryValsetRequestResponse, error)
	ValsetConfirm(ctx context.Context, in *QueryValsetConfirmRequest, opts ...grpc.CallOption) (*QueryValsetConfirmResponse, error)
	ValsetConfirmsByNonce(ctx context.Context, in *QueryValsetConfirmsByNonceRequest, opts ...grpc.CallOption) (*QueryValsetConfirmsByNonceResponse, error)
	LastValsetRequests(ctx context.Context, in *QueryLastValsetRequestsRequest, opts ...grpc.CallOption) (*QueryLastValsetRequestsResponse, error)
	LastPendingValsetRequestByAddr(ctx context.Context, in *QueryLastPendingValsetRequestByAddrRequest, opts ...grpc.CallOption) (*QueryLastPendingValsetRequestByAddrResponse, error)
	LastPendingBatchRequestByAddr(ctx context.Context, in *QueryLastPendingBatchRequestByAddrRequest, opts ...grpc.CallOption) (*QueryLastPendingBatchRequestByAddrResponse, error)
	OutgoingTxBatches(ctx context.Context, in *QueryOutgoingTxBatchesRequest, opts ...grpc.CallOption) (*QueryOutgoingTxBatchesResponse, error)
	BatchRequestByNonce(ctx context.Context, in *QueryBatchRequestByNonceRequest, opts ...grpc.CallOption) (*QueryBatchRequestByNonceResponse, error)
	BatchConfirms(ctx context.Context, in *QueryBatchConfirmsRequest, opts ...grpc.CallOption) (*QueryBatchConfirmsResponse, error)
	LastEventNonceByAddr(ctx context.Context, in *QueryLastEventNonceByAddrRequest, opts ...grpc.CallOption) (*QueryLastEventNonceByAddrResponse, error)
	LastValset(ctx context.Context, in *QueryLastValsetRequest, opts ...grpc.CallOption) (*QueryLastValsetResponse, 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 QueryCurrentValsetRequest 

type QueryCurrentValsetRequest struct {
}

func (*QueryCurrentValsetRequest) Descriptor 

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

func (*QueryCurrentValsetRequest) Marshal 

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

func (*QueryCurrentValsetRequest) MarshalTo 

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

func (*QueryCurrentValsetRequest) MarshalToSizedBuffer 

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

func (*QueryCurrentValsetRequest) ProtoMessage 

func (*QueryCurrentValsetRequest) ProtoMessage()

func (*QueryCurrentValsetRequest) Reset 

func (m *QueryCurrentValsetRequest) Reset()

func (*QueryCurrentValsetRequest) Size 

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

func (*QueryCurrentValsetRequest) String 

func (m *QueryCurrentValsetRequest) String() string

func (*QueryCurrentValsetRequest) Unmarshal 

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

func (*QueryCurrentValsetRequest) XXX_DiscardUnknown 

func (m *QueryCurrentValsetRequest) XXX_DiscardUnknown()

func (*QueryCurrentValsetRequest) XXX_Marshal 

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

func (*QueryCurrentValsetRequest) XXX_Merge 

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

func (*QueryCurrentValsetRequest) XXX_Size 

func (m *QueryCurrentValsetRequest) XXX_Size() int

func (*QueryCurrentValsetRequest) XXX_Unmarshal 

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

type QueryCurrentValsetResponse 

type QueryCurrentValsetResponse struct {
	Valset *Valset `protobuf:"bytes,1,opt,name=valset,proto3" json:"valset,omitempty"`
}

func (*QueryCurrentValsetResponse) Descriptor 

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

func (*QueryCurrentValsetResponse) GetValset 

func (m *QueryCurrentValsetResponse) GetValset() *Valset

func (*QueryCurrentValsetResponse) Marshal 

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

func (*QueryCurrentValsetResponse) MarshalTo 

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

func (*QueryCurrentValsetResponse) MarshalToSizedBuffer 

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

func (*QueryCurrentValsetResponse) ProtoMessage 

func (*QueryCurrentValsetResponse) ProtoMessage()

func (*QueryCurrentValsetResponse) Reset 

func (m *QueryCurrentValsetResponse) Reset()

func (*QueryCurrentValsetResponse) Size 

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

func (*QueryCurrentValsetResponse) String 

func (m *QueryCurrentValsetResponse) String() string

func (*QueryCurrentValsetResponse) Unmarshal 

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

func (*QueryCurrentValsetResponse) XXX_DiscardUnknown 

func (m *QueryCurrentValsetResponse) XXX_DiscardUnknown()

func (*QueryCurrentValsetResponse) XXX_Marshal 

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

func (*QueryCurrentValsetResponse) XXX_Merge 

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

func (*QueryCurrentValsetResponse) XXX_Size 

func (m *QueryCurrentValsetResponse) XXX_Size() int

func (*QueryCurrentValsetResponse) XXX_Unmarshal 

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

type QueryLastEventNonceByAddrRequest 

type QueryLastEventNonceByAddrRequest struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
}

func (*QueryLastEventNonceByAddrRequest) Descriptor 

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

func (*QueryLastEventNonceByAddrRequest) GetAddress 

func (m *QueryLastEventNonceByAddrRequest) GetAddress() string

func (*QueryLastEventNonceByAddrRequest) Marshal 

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

func (*QueryLastEventNonceByAddrRequest) MarshalTo 

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

func (*QueryLastEventNonceByAddrRequest) MarshalToSizedBuffer 

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

func (*QueryLastEventNonceByAddrRequest) ProtoMessage 

func (*QueryLastEventNonceByAddrRequest) ProtoMessage()

func (*QueryLastEventNonceByAddrRequest) Reset 

func (m *QueryLastEventNonceByAddrRequest) Reset()

func (*QueryLastEventNonceByAddrRequest) Size 

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

func (*QueryLastEventNonceByAddrRequest) String 

func (m *QueryLastEventNonceByAddrRequest) String() string

func (*QueryLastEventNonceByAddrRequest) Unmarshal 

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

func (*QueryLastEventNonceByAddrRequest) XXX_DiscardUnknown 

func (m *QueryLastEventNonceByAddrRequest) XXX_DiscardUnknown()

func (*QueryLastEventNonceByAddrRequest) XXX_Marshal 

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

func (*QueryLastEventNonceByAddrRequest) XXX_Merge 

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

func (*QueryLastEventNonceByAddrRequest) XXX_Size 

func (m *QueryLastEventNonceByAddrRequest) XXX_Size() int

func (*QueryLastEventNonceByAddrRequest) XXX_Unmarshal 

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

type QueryLastEventNonceByAddrResponse 

type QueryLastEventNonceByAddrResponse struct {
	EventNonce uint64 `protobuf:"varint,1,opt,name=event_nonce,json=eventNonce,proto3" json:"event_nonce,omitempty"`
}

func (*QueryLastEventNonceByAddrResponse) Descriptor 

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

func (*QueryLastEventNonceByAddrResponse) GetEventNonce 

func (m *QueryLastEventNonceByAddrResponse) GetEventNonce() uint64

func (*QueryLastEventNonceByAddrResponse) Marshal 

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

func (*QueryLastEventNonceByAddrResponse) MarshalTo 

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

func (*QueryLastEventNonceByAddrResponse) MarshalToSizedBuffer 

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

func (*QueryLastEventNonceByAddrResponse) ProtoMessage 

func (*QueryLastEventNonceByAddrResponse) ProtoMessage()

func (*QueryLastEventNonceByAddrResponse) Reset 

func (m *QueryLastEventNonceByAddrResponse) Reset()

func (*QueryLastEventNonceByAddrResponse) Size 

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

func (*QueryLastEventNonceByAddrResponse) String 

func (m *QueryLastEventNonceByAddrResponse) String() string

func (*QueryLastEventNonceByAddrResponse) Unmarshal 

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

func (*QueryLastEventNonceByAddrResponse) XXX_DiscardUnknown 

func (m *QueryLastEventNonceByAddrResponse) XXX_DiscardUnknown()

func (*QueryLastEventNonceByAddrResponse) XXX_Marshal 

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

func (*QueryLastEventNonceByAddrResponse) XXX_Merge 

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

func (*QueryLastEventNonceByAddrResponse) XXX_Size 

func (m *QueryLastEventNonceByAddrResponse) XXX_Size() int

func (*QueryLastEventNonceByAddrResponse) XXX_Unmarshal 

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

type QueryLastPendingBatchRequestByAddrRequest 

type QueryLastPendingBatchRequestByAddrRequest struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
}

func (*QueryLastPendingBatchRequestByAddrRequest) Descriptor 

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

func (*QueryLastPendingBatchRequestByAddrRequest) GetAddress 

func (m *QueryLastPendingBatchRequestByAddrRequest) GetAddress() string

func (*QueryLastPendingBatchRequestByAddrRequest) Marshal 

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

func (*QueryLastPendingBatchRequestByAddrRequest) MarshalTo 

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

func (*QueryLastPendingBatchRequestByAddrRequest) MarshalToSizedBuffer 

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

func (*QueryLastPendingBatchRequestByAddrRequest) ProtoMessage 

func (*QueryLastPendingBatchRequestByAddrRequest) ProtoMessage()

func (*QueryLastPendingBatchRequestByAddrRequest) Reset 

func (m *QueryLastPendingBatchRequestByAddrRequest) Reset()

func (*QueryLastPendingBatchRequestByAddrRequest) Size 

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

func (*QueryLastPendingBatchRequestByAddrRequest) String 

func (m *QueryLastPendingBatchRequestByAddrRequest) String() string

func (*QueryLastPendingBatchRequestByAddrRequest) Unmarshal 

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

func (*QueryLastPendingBatchRequestByAddrRequest) XXX_DiscardUnknown 

func (m *QueryLastPendingBatchRequestByAddrRequest) XXX_DiscardUnknown()

func (*QueryLastPendingBatchRequestByAddrRequest) XXX_Marshal 

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

func (*QueryLastPendingBatchRequestByAddrRequest) XXX_Merge 

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

func (*QueryLastPendingBatchRequestByAddrRequest) XXX_Size 

func (m *QueryLastPendingBatchRequestByAddrRequest) XXX_Size() int

func (*QueryLastPendingBatchRequestByAddrRequest) XXX_Unmarshal 

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

type QueryLastPendingBatchRequestByAddrResponse 

type QueryLastPendingBatchRequestByAddrResponse struct {
	Batch *OutgoingTxBatch `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"`
}

func (*QueryLastPendingBatchRequestByAddrResponse) Descriptor 

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

func (*QueryLastPendingBatchRequestByAddrResponse) GetBatch 

func (m *QueryLastPendingBatchRequestByAddrResponse) GetBatch() *OutgoingTxBatch

func (*QueryLastPendingBatchRequestByAddrResponse) Marshal 

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

func (*QueryLastPendingBatchRequestByAddrResponse) MarshalTo 

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

func (*QueryLastPendingBatchRequestByAddrResponse) MarshalToSizedBuffer 

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

func (*QueryLastPendingBatchRequestByAddrResponse) ProtoMessage 

func (*QueryLastPendingBatchRequestByAddrResponse) ProtoMessage()

func (*QueryLastPendingBatchRequestByAddrResponse) Reset 

func (m *QueryLastPendingBatchRequestByAddrResponse) Reset()

func (*QueryLastPendingBatchRequestByAddrResponse) Size 

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

func (*QueryLastPendingBatchRequestByAddrResponse) String 

func (m *QueryLastPendingBatchRequestByAddrResponse) String() string

func (*QueryLastPendingBatchRequestByAddrResponse) Unmarshal 

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

func (*QueryLastPendingBatchRequestByAddrResponse) XXX_DiscardUnknown 

func (m *QueryLastPendingBatchRequestByAddrResponse) XXX_DiscardUnknown()

func (*QueryLastPendingBatchRequestByAddrResponse) XXX_Marshal 

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

func (*QueryLastPendingBatchRequestByAddrResponse) XXX_Merge 

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

func (*QueryLastPendingBatchRequestByAddrResponse) XXX_Size 

func (m *QueryLastPendingBatchRequestByAddrResponse) XXX_Size() int

func (*QueryLastPendingBatchRequestByAddrResponse) XXX_Unmarshal 

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

type QueryLastPendingValsetRequestByAddrRequest 

type QueryLastPendingValsetRequestByAddrRequest struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
}

func (*QueryLastPendingValsetRequestByAddrRequest) Descriptor 

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

func (*QueryLastPendingValsetRequestByAddrRequest) GetAddress 

func (m *QueryLastPendingValsetRequestByAddrRequest) GetAddress() string

func (*QueryLastPendingValsetRequestByAddrRequest) Marshal 

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

func (*QueryLastPendingValsetRequestByAddrRequest) MarshalTo 

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

func (*QueryLastPendingValsetRequestByAddrRequest) MarshalToSizedBuffer 

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

func (*QueryLastPendingValsetRequestByAddrRequest) ProtoMessage 

func (*QueryLastPendingValsetRequestByAddrRequest) ProtoMessage()

func (*QueryLastPendingValsetRequestByAddrRequest) Reset 

func (m *QueryLastPendingValsetRequestByAddrRequest) Reset()

func (*QueryLastPendingValsetRequestByAddrRequest) Size 

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

func (*QueryLastPendingValsetRequestByAddrRequest) String 

func (m *QueryLastPendingValsetRequestByAddrRequest) String() string

func (*QueryLastPendingValsetRequestByAddrRequest) Unmarshal 

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

func (*QueryLastPendingValsetRequestByAddrRequest) XXX_DiscardUnknown 

func (m *QueryLastPendingValsetRequestByAddrRequest) XXX_DiscardUnknown()

func (*QueryLastPendingValsetRequestByAddrRequest) XXX_Marshal 

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

func (*QueryLastPendingValsetRequestByAddrRequest) XXX_Merge 

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

func (*QueryLastPendingValsetRequestByAddrRequest) XXX_Size 

func (m *QueryLastPendingValsetRequestByAddrRequest) XXX_Size() int

func (*QueryLastPendingValsetRequestByAddrRequest) XXX_Unmarshal 

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

type QueryLastPendingValsetRequestByAddrResponse 

type QueryLastPendingValsetRequestByAddrResponse struct {
	Valset *Valset `protobuf:"bytes,1,opt,name=valset,proto3" json:"valset,omitempty"`
}

func (*QueryLastPendingValsetRequestByAddrResponse) Descriptor 

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

func (*QueryLastPendingValsetRequestByAddrResponse) GetValset 

func (m *QueryLastPendingValsetRequestByAddrResponse) GetValset() *Valset

func (*QueryLastPendingValsetRequestByAddrResponse) Marshal 

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

func (*QueryLastPendingValsetRequestByAddrResponse) MarshalTo 

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

func (*QueryLastPendingValsetRequestByAddrResponse) MarshalToSizedBuffer 

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

func (*QueryLastPendingValsetRequestByAddrResponse) ProtoMessage 

func (*QueryLastPendingValsetRequestByAddrResponse) ProtoMessage()

func (*QueryLastPendingValsetRequestByAddrResponse) Reset 

func (m *QueryLastPendingValsetRequestByAddrResponse) Reset()

func (*QueryLastPendingValsetRequestByAddrResponse) Size 

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

func (*QueryLastPendingValsetRequestByAddrResponse) String 

func (m *QueryLastPendingValsetRequestByAddrResponse) String() string

func (*QueryLastPendingValsetRequestByAddrResponse) Unmarshal 

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

func (*QueryLastPendingValsetRequestByAddrResponse) XXX_DiscardUnknown 

func (m *QueryLastPendingValsetRequestByAddrResponse) XXX_DiscardUnknown()

func (*QueryLastPendingValsetRequestByAddrResponse) XXX_Marshal 

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

func (*QueryLastPendingValsetRequestByAddrResponse) XXX_Merge 

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

func (*QueryLastPendingValsetRequestByAddrResponse) XXX_Size 

func (m *QueryLastPendingValsetRequestByAddrResponse) XXX_Size() int

func (*QueryLastPendingValsetRequestByAddrResponse) XXX_Unmarshal 

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

type QueryLastValsetRequest 

type QueryLastValsetRequest struct {
}

func (*QueryLastValsetRequest) Descriptor 

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

func (*QueryLastValsetRequest) Marshal 

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

func (*QueryLastValsetRequest) MarshalTo 

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

func (*QueryLastValsetRequest) MarshalToSizedBuffer 

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

func (*QueryLastValsetRequest) ProtoMessage 

func (*QueryLastValsetRequest) ProtoMessage()

func (*QueryLastValsetRequest) Reset 

func (m *QueryLastValsetRequest) Reset()

func (*QueryLastValsetRequest) Size 

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

func (*QueryLastValsetRequest) String 

func (m *QueryLastValsetRequest) String() string

func (*QueryLastValsetRequest) Unmarshal 

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

func (*QueryLastValsetRequest) XXX_DiscardUnknown 

func (m *QueryLastValsetRequest) XXX_DiscardUnknown()

func (*QueryLastValsetRequest) XXX_Marshal 

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

func (*QueryLastValsetRequest) XXX_Merge 

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

func (*QueryLastValsetRequest) XXX_Size 

func (m *QueryLastValsetRequest) XXX_Size() int

func (*QueryLastValsetRequest) XXX_Unmarshal 

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

type QueryLastValsetRequestsRequest 

type QueryLastValsetRequestsRequest struct {
}

func (*QueryLastValsetRequestsRequest) Descriptor 

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

func (*QueryLastValsetRequestsRequest) Marshal 

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

func (*QueryLastValsetRequestsRequest) MarshalTo 

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

func (*QueryLastValsetRequestsRequest) MarshalToSizedBuffer 

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

func (*QueryLastValsetRequestsRequest) ProtoMessage 

func (*QueryLastValsetRequestsRequest) ProtoMessage()

func (*QueryLastValsetRequestsRequest) Reset 

func (m *QueryLastValsetRequestsRequest) Reset()

func (*QueryLastValsetRequestsRequest) Size 

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

func (*QueryLastValsetRequestsRequest) String 

func (m *QueryLastValsetRequestsRequest) String() string

func (*QueryLastValsetRequestsRequest) Unmarshal 

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

func (*QueryLastValsetRequestsRequest) XXX_DiscardUnknown 

func (m *QueryLastValsetRequestsRequest) XXX_DiscardUnknown()

func (*QueryLastValsetRequestsRequest) XXX_Marshal 

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

func (*QueryLastValsetRequestsRequest) XXX_Merge 

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

func (*QueryLastValsetRequestsRequest) XXX_Size 

func (m *QueryLastValsetRequestsRequest) XXX_Size() int

func (*QueryLastValsetRequestsRequest) XXX_Unmarshal 

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

type QueryLastValsetRequestsResponse 

type QueryLastValsetRequestsResponse struct {
	Valsets []*Valset `protobuf:"bytes,1,rep,name=valsets,proto3" json:"valsets,omitempty"`
}

func (*QueryLastValsetRequestsResponse) Descriptor 

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

func (*QueryLastValsetRequestsResponse) GetValsets 

func (m *QueryLastValsetRequestsResponse) GetValsets() []*Valset

func (*QueryLastValsetRequestsResponse) Marshal 

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

func (*QueryLastValsetRequestsResponse) MarshalTo 

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

func (*QueryLastValsetRequestsResponse) MarshalToSizedBuffer 

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

func (*QueryLastValsetRequestsResponse) ProtoMessage 

func (*QueryLastValsetRequestsResponse) ProtoMessage()

func (*QueryLastValsetRequestsResponse) Reset 

func (m *QueryLastValsetRequestsResponse) Reset()

func (*QueryLastValsetRequestsResponse) Size 

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

func (*QueryLastValsetRequestsResponse) String 

func (m *QueryLastValsetRequestsResponse) String() string

func (*QueryLastValsetRequestsResponse) Unmarshal 

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

func (*QueryLastValsetRequestsResponse) XXX_DiscardUnknown 

func (m *QueryLastValsetRequestsResponse) XXX_DiscardUnknown()

func (*QueryLastValsetRequestsResponse) XXX_Marshal 

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

func (*QueryLastValsetRequestsResponse) XXX_Merge 

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

func (*QueryLastValsetRequestsResponse) XXX_Size 

func (m *QueryLastValsetRequestsResponse) XXX_Size() int

func (*QueryLastValsetRequestsResponse) XXX_Unmarshal 

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

type QueryLastValsetResponse 

type QueryLastValsetResponse struct {
	Valset *Valset `protobuf:"bytes,1,opt,name=valset,proto3" json:"valset,omitempty"`
}

func (*QueryLastValsetResponse) Descriptor 

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

func (*QueryLastValsetResponse) GetValset 

func (m *QueryLastValsetResponse) GetValset() *Valset

func (*QueryLastValsetResponse) Marshal 

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

func (*QueryLastValsetResponse) MarshalTo 

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

func (*QueryLastValsetResponse) MarshalToSizedBuffer 

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

func (*QueryLastValsetResponse) ProtoMessage 

func (*QueryLastValsetResponse) ProtoMessage()

func (*QueryLastValsetResponse) Reset 

func (m *QueryLastValsetResponse) Reset()

func (*QueryLastValsetResponse) Size 

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

func (*QueryLastValsetResponse) String 

func (m *QueryLastValsetResponse) String() string

func (*QueryLastValsetResponse) Unmarshal 

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

func (*QueryLastValsetResponse) XXX_DiscardUnknown 

func (m *QueryLastValsetResponse) XXX_DiscardUnknown()

func (*QueryLastValsetResponse) XXX_Marshal 

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

func (*QueryLastValsetResponse) XXX_Merge 

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

func (*QueryLastValsetResponse) XXX_Size 

func (m *QueryLastValsetResponse) XXX_Size() int

func (*QueryLastValsetResponse) XXX_Unmarshal 

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

type QueryOutgoingTxBatchesRequest 

type QueryOutgoingTxBatchesRequest struct {
}

func (*QueryOutgoingTxBatchesRequest) Descriptor 

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

func (*QueryOutgoingTxBatchesRequest) Marshal 

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

func (*QueryOutgoingTxBatchesRequest) MarshalTo 

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

func (*QueryOutgoingTxBatchesRequest) MarshalToSizedBuffer 

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

func (*QueryOutgoingTxBatchesRequest) ProtoMessage 

func (*QueryOutgoingTxBatchesRequest) ProtoMessage()

func (*QueryOutgoingTxBatchesRequest) Reset 

func (m *QueryOutgoingTxBatchesRequest) Reset()

func (*QueryOutgoingTxBatchesRequest) Size 

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

func (*QueryOutgoingTxBatchesRequest) String 

func (m *QueryOutgoingTxBatchesRequest) String() string

func (*QueryOutgoingTxBatchesRequest) Unmarshal 

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

func (*QueryOutgoingTxBatchesRequest) XXX_DiscardUnknown 

func (m *QueryOutgoingTxBatchesRequest) XXX_DiscardUnknown()

func (*QueryOutgoingTxBatchesRequest) XXX_Marshal 

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

func (*QueryOutgoingTxBatchesRequest) XXX_Merge 

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

func (*QueryOutgoingTxBatchesRequest) XXX_Size 

func (m *QueryOutgoingTxBatchesRequest) XXX_Size() int

func (*QueryOutgoingTxBatchesRequest) XXX_Unmarshal 

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

type QueryOutgoingTxBatchesResponse 

type QueryOutgoingTxBatchesResponse struct {
	Batches []*OutgoingTxBatch `protobuf:"bytes,1,rep,name=batches,proto3" json:"batches,omitempty"`
}

func (*QueryOutgoingTxBatchesResponse) Descriptor 

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

func (*QueryOutgoingTxBatchesResponse) GetBatches 

func (m *QueryOutgoingTxBatchesResponse) GetBatches() []*OutgoingTxBatch

func (*QueryOutgoingTxBatchesResponse) Marshal 

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

func (*QueryOutgoingTxBatchesResponse) MarshalTo 

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

func (*QueryOutgoingTxBatchesResponse) MarshalToSizedBuffer 

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

func (*QueryOutgoingTxBatchesResponse) ProtoMessage 

func (*QueryOutgoingTxBatchesResponse) ProtoMessage()

func (*QueryOutgoingTxBatchesResponse) Reset 

func (m *QueryOutgoingTxBatchesResponse) Reset()

func (*QueryOutgoingTxBatchesResponse) Size 

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

func (*QueryOutgoingTxBatchesResponse) String 

func (m *QueryOutgoingTxBatchesResponse) String() string

func (*QueryOutgoingTxBatchesResponse) Unmarshal 

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

func (*QueryOutgoingTxBatchesResponse) XXX_DiscardUnknown 

func (m *QueryOutgoingTxBatchesResponse) XXX_DiscardUnknown()

func (*QueryOutgoingTxBatchesResponse) XXX_Marshal 

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

func (*QueryOutgoingTxBatchesResponse) XXX_Merge 

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

func (*QueryOutgoingTxBatchesResponse) XXX_Size 

func (m *QueryOutgoingTxBatchesResponse) XXX_Size() int

func (*QueryOutgoingTxBatchesResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

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 Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

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 {
	// Deployments queries deployments
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	CurrentValset(context.Context, *QueryCurrentValsetRequest) (*QueryCurrentValsetResponse, error)
	ValsetRequest(context.Context, *QueryValsetRequestRequest) (*QueryValsetRequestResponse, error)
	ValsetConfirm(context.Context, *QueryValsetConfirmRequest) (*QueryValsetConfirmResponse, error)
	ValsetConfirmsByNonce(context.Context, *QueryValsetConfirmsByNonceRequest) (*QueryValsetConfirmsByNonceResponse, error)
	LastValsetRequests(context.Context, *QueryLastValsetRequestsRequest) (*QueryLastValsetRequestsResponse, error)
	LastPendingValsetRequestByAddr(context.Context, *QueryLastPendingValsetRequestByAddrRequest) (*QueryLastPendingValsetRequestByAddrResponse, error)
	LastPendingBatchRequestByAddr(context.Context, *QueryLastPendingBatchRequestByAddrRequest) (*QueryLastPendingBatchRequestByAddrResponse, error)
	OutgoingTxBatches(context.Context, *QueryOutgoingTxBatchesRequest) (*QueryOutgoingTxBatchesResponse, error)
	BatchRequestByNonce(context.Context, *QueryBatchRequestByNonceRequest) (*QueryBatchRequestByNonceResponse, error)
	BatchConfirms(context.Context, *QueryBatchConfirmsRequest) (*QueryBatchConfirmsResponse, error)
	LastEventNonceByAddr(context.Context, *QueryLastEventNonceByAddrRequest) (*QueryLastEventNonceByAddrResponse, error)
	LastValset(context.Context, *QueryLastValsetRequest) (*QueryLastValsetResponse, error)
}

QueryServer is the server API for Query service.

type QueryValsetConfirmRequest 

type QueryValsetConfirmRequest struct {
	Nonce   uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
}

func (*QueryValsetConfirmRequest) Descriptor 

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

func (*QueryValsetConfirmRequest) GetAddress 

func (m *QueryValsetConfirmRequest) GetAddress() string

func (*QueryValsetConfirmRequest) GetNonce 

func (m *QueryValsetConfirmRequest) GetNonce() uint64

func (*QueryValsetConfirmRequest) Marshal 

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

func (*QueryValsetConfirmRequest) MarshalTo 

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

func (*QueryValsetConfirmRequest) MarshalToSizedBuffer 

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

func (*QueryValsetConfirmRequest) ProtoMessage 

func (*QueryValsetConfirmRequest) ProtoMessage()

func (*QueryValsetConfirmRequest) Reset 

func (m *QueryValsetConfirmRequest) Reset()

func (*QueryValsetConfirmRequest) Size 

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

func (*QueryValsetConfirmRequest) String 

func (m *QueryValsetConfirmRequest) String() string

func (*QueryValsetConfirmRequest) Unmarshal 

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

func (*QueryValsetConfirmRequest) XXX_DiscardUnknown 

func (m *QueryValsetConfirmRequest) XXX_DiscardUnknown()

func (*QueryValsetConfirmRequest) XXX_Marshal 

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

func (*QueryValsetConfirmRequest) XXX_Merge 

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

func (*QueryValsetConfirmRequest) XXX_Size 

func (m *QueryValsetConfirmRequest) XXX_Size() int

func (*QueryValsetConfirmRequest) XXX_Unmarshal 

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

type QueryValsetConfirmResponse 

type QueryValsetConfirmResponse struct {
	Confirm *MsgValsetConfirm `protobuf:"bytes,1,opt,name=confirm,proto3" json:"confirm,omitempty"`
}

func (*QueryValsetConfirmResponse) Descriptor 

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

func (*QueryValsetConfirmResponse) GetConfirm 

func (m *QueryValsetConfirmResponse) GetConfirm() *MsgValsetConfirm

func (*QueryValsetConfirmResponse) Marshal 

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

func (*QueryValsetConfirmResponse) MarshalTo 

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

func (*QueryValsetConfirmResponse) MarshalToSizedBuffer 

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

func (*QueryValsetConfirmResponse) ProtoMessage 

func (*QueryValsetConfirmResponse) ProtoMessage()

func (*QueryValsetConfirmResponse) Reset 

func (m *QueryValsetConfirmResponse) Reset()

func (*QueryValsetConfirmResponse) Size 

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

func (*QueryValsetConfirmResponse) String 

func (m *QueryValsetConfirmResponse) String() string

func (*QueryValsetConfirmResponse) Unmarshal 

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

func (*QueryValsetConfirmResponse) XXX_DiscardUnknown 

func (m *QueryValsetConfirmResponse) XXX_DiscardUnknown()

func (*QueryValsetConfirmResponse) XXX_Marshal 

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

func (*QueryValsetConfirmResponse) XXX_Merge 

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

func (*QueryValsetConfirmResponse) XXX_Size 

func (m *QueryValsetConfirmResponse) XXX_Size() int

func (*QueryValsetConfirmResponse) XXX_Unmarshal 

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

type QueryValsetConfirmsByNonceRequest 

type QueryValsetConfirmsByNonceRequest struct {
	Nonce uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
}

func (*QueryValsetConfirmsByNonceRequest) Descriptor 

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

func (*QueryValsetConfirmsByNonceRequest) GetNonce 

func (m *QueryValsetConfirmsByNonceRequest) GetNonce() uint64

func (*QueryValsetConfirmsByNonceRequest) Marshal 

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

func (*QueryValsetConfirmsByNonceRequest) MarshalTo 

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

func (*QueryValsetConfirmsByNonceRequest) MarshalToSizedBuffer 

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

func (*QueryValsetConfirmsByNonceRequest) ProtoMessage 

func (*QueryValsetConfirmsByNonceRequest) ProtoMessage()

func (*QueryValsetConfirmsByNonceRequest) Reset 

func (m *QueryValsetConfirmsByNonceRequest) Reset()

func (*QueryValsetConfirmsByNonceRequest) Size 

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

func (*QueryValsetConfirmsByNonceRequest) String 

func (m *QueryValsetConfirmsByNonceRequest) String() string

func (*QueryValsetConfirmsByNonceRequest) Unmarshal 

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

func (*QueryValsetConfirmsByNonceRequest) XXX_DiscardUnknown 

func (m *QueryValsetConfirmsByNonceRequest) XXX_DiscardUnknown()

func (*QueryValsetConfirmsByNonceRequest) XXX_Marshal 

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

func (*QueryValsetConfirmsByNonceRequest) XXX_Merge 

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

func (*QueryValsetConfirmsByNonceRequest) XXX_Size 

func (m *QueryValsetConfirmsByNonceRequest) XXX_Size() int

func (*QueryValsetConfirmsByNonceRequest) XXX_Unmarshal 

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

type QueryValsetConfirmsByNonceResponse 

type QueryValsetConfirmsByNonceResponse struct {
	Confirms []*MsgValsetConfirm `protobuf:"bytes,1,rep,name=confirms,proto3" json:"confirms,omitempty"`
}

func (*QueryValsetConfirmsByNonceResponse) Descriptor 

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

func (*QueryValsetConfirmsByNonceResponse) GetConfirms 

func (m *QueryValsetConfirmsByNonceResponse) GetConfirms() []*MsgValsetConfirm

func (*QueryValsetConfirmsByNonceResponse) Marshal 

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

func (*QueryValsetConfirmsByNonceResponse) MarshalTo 

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

func (*QueryValsetConfirmsByNonceResponse) MarshalToSizedBuffer 

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

func (*QueryValsetConfirmsByNonceResponse) ProtoMessage 

func (*QueryValsetConfirmsByNonceResponse) ProtoMessage()

func (*QueryValsetConfirmsByNonceResponse) Reset 

func (m *QueryValsetConfirmsByNonceResponse) Reset()

func (*QueryValsetConfirmsByNonceResponse) Size 

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

func (*QueryValsetConfirmsByNonceResponse) String 

func (m *QueryValsetConfirmsByNonceResponse) String() string

func (*QueryValsetConfirmsByNonceResponse) Unmarshal 

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

func (*QueryValsetConfirmsByNonceResponse) XXX_DiscardUnknown 

func (m *QueryValsetConfirmsByNonceResponse) XXX_DiscardUnknown()

func (*QueryValsetConfirmsByNonceResponse) XXX_Marshal 

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

func (*QueryValsetConfirmsByNonceResponse) XXX_Merge 

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

func (*QueryValsetConfirmsByNonceResponse) XXX_Size 

func (m *QueryValsetConfirmsByNonceResponse) XXX_Size() int

func (*QueryValsetConfirmsByNonceResponse) XXX_Unmarshal 

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

type QueryValsetRequestRequest 

type QueryValsetRequestRequest struct {
	Nonce uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
}

func (*QueryValsetRequestRequest) Descriptor 

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

func (*QueryValsetRequestRequest) GetNonce 

func (m *QueryValsetRequestRequest) GetNonce() uint64

func (*QueryValsetRequestRequest) Marshal 

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

func (*QueryValsetRequestRequest) MarshalTo 

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

func (*QueryValsetRequestRequest) MarshalToSizedBuffer 

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

func (*QueryValsetRequestRequest) ProtoMessage 

func (*QueryValsetRequestRequest) ProtoMessage()

func (*QueryValsetRequestRequest) Reset 

func (m *QueryValsetRequestRequest) Reset()

func (*QueryValsetRequestRequest) Size 

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

func (*QueryValsetRequestRequest) String 

func (m *QueryValsetRequestRequest) String() string

func (*QueryValsetRequestRequest) Unmarshal 

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

func (*QueryValsetRequestRequest) XXX_DiscardUnknown 

func (m *QueryValsetRequestRequest) XXX_DiscardUnknown()

func (*QueryValsetRequestRequest) XXX_Marshal 

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

func (*QueryValsetRequestRequest) XXX_Merge 

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

func (*QueryValsetRequestRequest) XXX_Size 

func (m *QueryValsetRequestRequest) XXX_Size() int

func (*QueryValsetRequestRequest) XXX_Unmarshal 

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

type QueryValsetRequestResponse 

type QueryValsetRequestResponse struct {
	Valset *Valset `protobuf:"bytes,1,opt,name=valset,proto3" json:"valset,omitempty"`
}

func (*QueryValsetRequestResponse) Descriptor 

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

func (*QueryValsetRequestResponse) GetValset 

func (m *QueryValsetRequestResponse) GetValset() *Valset

func (*QueryValsetRequestResponse) Marshal 

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

func (*QueryValsetRequestResponse) MarshalTo 

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

func (*QueryValsetRequestResponse) MarshalToSizedBuffer 

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

func (*QueryValsetRequestResponse) ProtoMessage 

func (*QueryValsetRequestResponse) ProtoMessage()

func (*QueryValsetRequestResponse) Reset 

func (m *QueryValsetRequestResponse) Reset()

func (*QueryValsetRequestResponse) Size 

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

func (*QueryValsetRequestResponse) String 

func (m *QueryValsetRequestResponse) String() string

func (*QueryValsetRequestResponse) Unmarshal 

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

func (*QueryValsetRequestResponse) XXX_DiscardUnknown 

func (m *QueryValsetRequestResponse) XXX_DiscardUnknown()

func (*QueryValsetRequestResponse) XXX_Marshal 

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

func (*QueryValsetRequestResponse) XXX_Merge 

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

func (*QueryValsetRequestResponse) XXX_Size 

func (m *QueryValsetRequestResponse) XXX_Size() int

func (*QueryValsetRequestResponse) XXX_Unmarshal 

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

type SignType 

type SignType int32

SignType defines messages that have been signed by an orchestrator 

const (
	SIGN_TYPE_UNKNOWN                              SignType = 0
	SIGN_TYPE_ORCHESTRATOR_SIGNED_MULTI_SIG_UPDATE SignType = 1
	SIGN_TYPE_ORCHESTRATOR_SIGNED_WITHDRAW_BATCH   SignType = 2
)

func (SignType) EnumDescriptor 

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

type StakingKeeper 

type StakingKeeper interface {
	GetBondedValidatorsByPower(ctx sdk.Context) []stakingtypes.Validator
	GetLastValidatorPower(ctx sdk.Context, operator sdk.ValAddress) int64
	GetLastTotalPower(ctx sdk.Context) (power sdk.Int)
	Jail(sdk.Context, sdk.ConsAddress)
}

StakingKeeper defines the expected staking keeper methods

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) ConfirmBatch 

func (*UnimplementedMsgServer) ConfirmBatch(ctx context.Context, req *MsgConfirmBatch) (*MsgConfirmBatchResponse, error)

func (*UnimplementedMsgServer) DepositClaim 

func (*UnimplementedMsgServer) DepositClaim(ctx context.Context, req *MsgDepositClaim) (*MsgDepositClaimResponse, error)

func (*UnimplementedMsgServer) RequestBatch 

func (*UnimplementedMsgServer) RequestBatch(ctx context.Context, req *MsgRequestBatch) (*MsgRequestBatchResponse, error)

func (*UnimplementedMsgServer) SendToEth 

func (*UnimplementedMsgServer) SendToEth(ctx context.Context, req *MsgSendToMinter) (*MsgSendToMinterResponse, error)

func (*UnimplementedMsgServer) SendToEthClaim 

func (*UnimplementedMsgServer) SendToEthClaim(ctx context.Context, req *MsgSendToEthClaim) (*MsgSendToEthClaimResponse, error)

func (*UnimplementedMsgServer) SetMinterAddress 

func (*UnimplementedMsgServer) SetMinterAddress(ctx context.Context, req *MsgSetMinterAddress) (*MsgSetMinterAddressResponse, error)

func (*UnimplementedMsgServer) ValsetClaim 

func (*UnimplementedMsgServer) ValsetClaim(ctx context.Context, req *MsgValsetClaim) (*MsgValsetClaimResponse, error)

func (*UnimplementedMsgServer) ValsetConfirm 

func (*UnimplementedMsgServer) ValsetConfirm(ctx context.Context, req *MsgValsetConfirm) (*MsgValsetConfirmResponse, error)

func (*UnimplementedMsgServer) ValsetRequest 

func (*UnimplementedMsgServer) ValsetRequest(ctx context.Context, req *MsgValsetRequest) (*MsgValsetRequestResponse, error)

func (*UnimplementedMsgServer) WithdrawClaim 

func (*UnimplementedMsgServer) WithdrawClaim(ctx context.Context, req *MsgWithdrawClaim) (*MsgWithdrawClaimResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) BatchConfirms 

func (*UnimplementedQueryServer) BatchConfirms(ctx context.Context, req *QueryBatchConfirmsRequest) (*QueryBatchConfirmsResponse, error)

func (*UnimplementedQueryServer) BatchRequestByNonce 

func (*UnimplementedQueryServer) BatchRequestByNonce(ctx context.Context, req *QueryBatchRequestByNonceRequest) (*QueryBatchRequestByNonceResponse, error)

func (*UnimplementedQueryServer) CurrentValset 

func (*UnimplementedQueryServer) CurrentValset(ctx context.Context, req *QueryCurrentValsetRequest) (*QueryCurrentValsetResponse, error)

func (*UnimplementedQueryServer) LastEventNonceByAddr 

func (*UnimplementedQueryServer) LastEventNonceByAddr(ctx context.Context, req *QueryLastEventNonceByAddrRequest) (*QueryLastEventNonceByAddrResponse, error)

func (*UnimplementedQueryServer) LastPendingBatchRequestByAddr 

func (*UnimplementedQueryServer) LastPendingBatchRequestByAddr(ctx context.Context, req *QueryLastPendingBatchRequestByAddrRequest) (*QueryLastPendingBatchRequestByAddrResponse, error)

func (*UnimplementedQueryServer) LastPendingValsetRequestByAddr 

func (*UnimplementedQueryServer) LastPendingValsetRequestByAddr(ctx context.Context, req *QueryLastPendingValsetRequestByAddrRequest) (*QueryLastPendingValsetRequestByAddrResponse, error)

func (*UnimplementedQueryServer) LastValset 

func (*UnimplementedQueryServer) LastValset(ctx context.Context, req *QueryLastValsetRequest) (*QueryLastValsetResponse, error)

func (*UnimplementedQueryServer) LastValsetRequests 

func (*UnimplementedQueryServer) LastValsetRequests(ctx context.Context, req *QueryLastValsetRequestsRequest) (*QueryLastValsetRequestsResponse, error)

func (*UnimplementedQueryServer) OutgoingTxBatches 

func (*UnimplementedQueryServer) OutgoingTxBatches(ctx context.Context, req *QueryOutgoingTxBatchesRequest) (*QueryOutgoingTxBatchesResponse, error)

func (*UnimplementedQueryServer) Params 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)

func (*UnimplementedQueryServer) ValsetConfirm 

func (*UnimplementedQueryServer) ValsetConfirm(ctx context.Context, req *QueryValsetConfirmRequest) (*QueryValsetConfirmResponse, error)

func (*UnimplementedQueryServer) ValsetConfirmsByNonce 

func (*UnimplementedQueryServer) ValsetConfirmsByNonce(ctx context.Context, req *QueryValsetConfirmsByNonceRequest) (*QueryValsetConfirmsByNonceResponse, error)

func (*UnimplementedQueryServer) ValsetRequest 

func (*UnimplementedQueryServer) ValsetRequest(ctx context.Context, req *QueryValsetRequestRequest) (*QueryValsetRequestResponse, error)

type Valset 

type Valset struct {
	Nonce       uint64             `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	MinterNonce uint64             `protobuf:"varint,2,opt,name=minter_nonce,json=minterNonce,proto3" json:"minter_nonce,omitempty"`
	Members     []*BridgeValidator `protobuf:"bytes,3,rep,name=members,proto3" json:"members,omitempty"`
}

Valset is the Ethereum Bridge Multsig Set, each peggy validator also maintains an ETH key to sign messages, these are used to check signatures on ETH because of the significant gas savings

func NewValset 

func NewValset(nonce uint64, members BridgeValidators) *Valset

NewValset returns a new valset

func (*Valset) Descriptor 

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

func (*Valset) GetMembers 

func (m *Valset) GetMembers() []*BridgeValidator

func (*Valset) GetMinterNonce 

func (m *Valset) GetMinterNonce() uint64

func (*Valset) GetNonce 

func (m *Valset) GetNonce() uint64

func (*Valset) Marshal 

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

func (*Valset) MarshalTo 

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

func (*Valset) MarshalToSizedBuffer 

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

func (*Valset) ProtoMessage 

func (*Valset) ProtoMessage()

func (*Valset) Reset 

func (m *Valset) Reset()

func (*Valset) Size 

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

func (*Valset) String 

func (m *Valset) String() string

func (*Valset) Unmarshal 

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

func (*Valset) WithoutEmptyMembers 

func (v *Valset) WithoutEmptyMembers() *Valset

WithoutEmptyMembers returns a new Valset without member that have 0 power or an empty Ethereum address.

func (*Valset) XXX_DiscardUnknown 

func (m *Valset) XXX_DiscardUnknown()

func (*Valset) XXX_Marshal 

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

func (*Valset) XXX_Merge 

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

func (*Valset) XXX_Size 

func (m *Valset) XXX_Size() int

func (*Valset) XXX_Unmarshal 

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

type Valsets 

type Valsets []*Valset

Valsets is a collection of valset

func (Valsets) Len 

func (v Valsets) Len() int

func (Valsets) Less 

func (v Valsets) Less(i, j int) bool

func (Valsets) Swap 

func (v Valsets) Swap(i, j int)

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.