types

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

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

 Go to latest Published: May 24, 2023 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypeRegisterSourceChain = "register_source_chain"
	EventTypeDelegate            = "delegate"
	EventTypeUndelegate          = "undelegate"

	AttributeKeySourceChainID = "source_chain_id"
	AttributeKeyDelegator     = "delegator"
	AttributeKeyValidators    = "source_chain_validators"
	AttributeKeyWeights       = "source_chain_validator_weights"
	AttributeKeyEpoch         = "epcoh_number"
	AttributeKeyDelegateAmt   = "delegate_amount"
	AttributeKeyRedeemAmt     = "redeem_amount"
	AttributeKeyUnbondAmt     = "unbond_amount"
	AttributeKeyClaimAmt      = "unbond_amount"
)

liquidstake module event types

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

	// StoreKey is the string store representation
	StoreKey = ModuleName

	// RouterKey is the msg router key for the liquid stake module
	RouterKey = ModuleName

	QuerierRoute = ModuleName
)
View Source 
const (
	MinValidatorWeight = uint64(1000)
	MinValidators      = 1

	// WithdrawAddressSuffix used for generate liquidstake withdraw address
	WithdrawAddressSuffix = "withdraw"
	// DelegationAddressSuffix used for generate liquidstake delegateion address
	DelegationAddressSuffix = "delegate"
	// UnboundingAddressSuffix used for generate liquidstake unbond address
	UnboundAddressSuffix = "unbounding"
)

Variables

View Source 
var (
	ErrInvalidLengthCallback        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCallback          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCallback = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrSourceChainExist         = sdkioerrors.Register(ModuleName, 1, "source chain already exist")
	ErrBannedIBCTransfer        = sdkioerrors.Register(ModuleName, 2, "ibc transfer is banned")
	ErrSourceChainParameter     = sdkioerrors.Register(ModuleName, 3, "add source chain parameter has error")
	ErrUnknownEpoch             = sdkioerrors.Register(ModuleName, 4, "unknown epoch")
	ErrNoExistProxyDelegation   = sdkioerrors.Register(ModuleName, 5, "delegation record don't exist")
	ErrUnknownSourceChain       = sdkioerrors.Register(ModuleName, 6, "source chain is not exist")
	ErrRepeatUndelegate         = sdkioerrors.Register(ModuleName, 7, "repeattly delegate in a epoch")
	ErrInternalError            = sdkioerrors.Register(ModuleName, 8, "internal error")
	ErrInsufficientFunds        = sdkioerrors.Register(ModuleName, 9, "insufficient funds to support the current transaction")
	ErrEpochUnbondingNotExist   = sdkioerrors.Register(ModuleName, 10, "unbondings not found for specific epoch")
	ErrCallbackNotExist         = sdkioerrors.Register(ModuleName, 11, "callback not find")
	ErrIBCQueryNotExist         = sdkioerrors.Register(ModuleName, 12, "ibcquery not exist")
	ErrICANotFound              = sdkioerrors.Register(ModuleName, 13, "can not find interchain account address")
	ErrUserUndelegationNotExist = sdkioerrors.Register(ModuleName, 14, "the undelegation is not exist")
	ErrUserUndelegationWatting  = sdkioerrors.Register(ModuleName, 15, "the undelegation is waitting")
	ErrCallbackMismatch         = sdkioerrors.Register(ModuleName, 16, "mismatch callback")
)
View Source 
var (
	EpochKey = []byte{0x10}

	// Prefix for source chain
	SouceChainKeyPrefix = []byte{0x11}

	// Key for delegation record ID.
	ProxyDelegationIDKey = []byte{0x20}

	// Prefix for key which used in `{epoch + ChainID}=> ProxyDelegationID`
	ProxyDelegationIDPrefix = []byte{0x21}

	// Prefix for ProxyDelegation `ID => ProxyDelegation`
	ProxyDelegationPrefix = []byte{0x22}

	// Prefix for key `{channel + port + sequence} => ProxyDelegationID`
	IBCCallbackPrefix = []byte{0x23}

	// Prefix for key `{chainID + epoch + delegator}` => UnProxyDelegation
	UndelegationRecrodPrefix = []byte{0x31}

	EpochUnbondingsPrefix = []byte{0x32}

	IBCQueryKey = []byte{0x41}
)

Keys for store prefixes

View Source 
var (
	DefaultIBCTransferTimeoutNanos int64 = 1800000000000
	DefaultICATimeoutNanos         int64 = 1800000000000
)
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 (
	ErrInvalidLengthSourceChain        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSourceChain          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSourceChain = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthStake        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStake          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupStake = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)

Functions

func AssembleUserUnbondingID 

func AssembleUserUnbondingID(chainID string, epoch uint64, delegator string) string

func GetChainProxyDelegationIDForEpochKey 

func GetChainProxyDelegationIDForEpochKey(epoch uint64, chainID []byte) []byte

GetChainProxyDelegationIDForEpochKey return , `SouceChainKeyPrefix + len(chainID)+chainID`

func GetEpochUnbondingsKey 

func GetEpochUnbondingsKey(epoch uint64) []byte

func GetIBCCallbackKey 

func GetIBCCallbackKey(channel []byte, port []byte, sequence uint64) []byte

func GetProxyDelegationKey 

func GetProxyDelegationKey(id uint64) []byte

func GetSourceChainKey 

func GetSourceChainKey(chainID []byte) []byte

GetSourceChainKey return key for source chain, `SouceChainKeyPrefix + len(chainID)+chainID`

func GetUndelegationRecordKeyFromID 

func GetUndelegationRecordKeyFromID(id string) string

func GetUserUnbondingKey 

func GetUserUnbondingKey(chainID string, epoch uint64, delegator string) string

func IsProxyDelegationProcessing 

func IsProxyDelegationProcessing(status ProxyDelegationStatus) bool

func RegisterCodec 

func RegisterCodec(cdc *codec.LegacyAmino)

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

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)

Types

type AccountKeeper 

type AccountKeeper interface {
	NewAccount(ctx sdk.Context, acc authtypes.AccountI) authtypes.AccountI
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
	SetAccount(ctx sdk.Context, acc authtypes.AccountI)
	GetModuleAccount(ctx sdk.Context, name string) authtypes.ModuleAccountI
	GetModuleAddress(name string) sdk.AccAddress
}

AccountKeeper defines the expected account keeper

type BankKeeper 

type BankKeeper interface {
	GetAllBalances(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	GetBalance(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin
	LockedCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins

	GetSupply(ctx sdk.Context, denom string) sdk.Coin

	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromModuleToModule(ctx sdk.Context, senderModule, recipientModule string, amt sdk.Coins) error
	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
	DelegateCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error

	BurnCoins(ctx sdk.Context, name string, amt sdk.Coins) error
	MintCoins(ctx sdk.Context, moduleName string, amounts sdk.Coins) error
}

BankKeeper defines the expected interface needed to retrieve account balances.

type CallType 

type CallType uint32
const (
	DelegateTransferCall CallType = iota
	DelegateCall
	UndelegateCall
	WithdrawUnbondCall
	WithdrawDelegateRewardCall
	TransferRewardCall
	SetWithdrawAddressCall
)

Callback type

type Dec 

type Dec = sdk.Dec

type DelegateCallbackArgs 

type DelegateCallbackArgs struct {
	// Validators with delegate funds
	Validators        []Validator `protobuf:"bytes,1,rep,name=validators,proto3" json:"validators"`
	ProxyDelegationID uint64      `protobuf:"varint,2,opt,name=proxyDelegationID,proto3" json:"proxyDelegationID,omitempty"`
}

func (*DelegateCallbackArgs) Descriptor 

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

func (*DelegateCallbackArgs) GetProxyDelegationID 

func (m *DelegateCallbackArgs) GetProxyDelegationID() uint64

func (*DelegateCallbackArgs) GetValidators 

func (m *DelegateCallbackArgs) GetValidators() []Validator

func (*DelegateCallbackArgs) Marshal 

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

func (*DelegateCallbackArgs) MarshalTo 

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

func (*DelegateCallbackArgs) MarshalToSizedBuffer 

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

func (*DelegateCallbackArgs) ProtoMessage 

func (*DelegateCallbackArgs) ProtoMessage()

func (*DelegateCallbackArgs) Reset 

func (m *DelegateCallbackArgs) Reset()

func (*DelegateCallbackArgs) Size 

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

func (*DelegateCallbackArgs) String 

func (m *DelegateCallbackArgs) String() string

func (*DelegateCallbackArgs) Unmarshal 

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

func (*DelegateCallbackArgs) XXX_DiscardUnknown 

func (m *DelegateCallbackArgs) XXX_DiscardUnknown()

func (*DelegateCallbackArgs) XXX_Marshal 

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

func (*DelegateCallbackArgs) XXX_Merge 

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

func (*DelegateCallbackArgs) XXX_Size 

func (m *DelegateCallbackArgs) XXX_Size() int

func (*DelegateCallbackArgs) XXX_Unmarshal 

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

type EpochKeeper 

type EpochKeeper interface {
	GetEpochInfo(ctx sdk.Context, identifier string) (epochstypes.EpochInfo, bool)
}

type EpochProxyUnbonding 

type EpochProxyUnbonding struct {
	// The epoch number.
	Epoch uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	// The unbonding entries.
	Unbondings []ProxyUnbonding `protobuf:"bytes,2,rep,name=unbondings,proto3" json:"unbondings"`
}

Represents a collection of unbonding entries for a given epoch.

func (*EpochProxyUnbonding) Descriptor 

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

func (*EpochProxyUnbonding) GetEpoch 

func (m *EpochProxyUnbonding) GetEpoch() uint64

func (*EpochProxyUnbonding) GetUnbondings 

func (m *EpochProxyUnbonding) GetUnbondings() []ProxyUnbonding

func (*EpochProxyUnbonding) Marshal 

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

func (*EpochProxyUnbonding) MarshalTo 

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

func (*EpochProxyUnbonding) MarshalToSizedBuffer 

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

func (*EpochProxyUnbonding) ProtoMessage 

func (*EpochProxyUnbonding) ProtoMessage()

func (*EpochProxyUnbonding) Reset 

func (m *EpochProxyUnbonding) Reset()

func (*EpochProxyUnbonding) Size 

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

func (*EpochProxyUnbonding) String 

func (m *EpochProxyUnbonding) String() string

func (*EpochProxyUnbonding) Unmarshal 

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

func (*EpochProxyUnbonding) XXX_DiscardUnknown 

func (m *EpochProxyUnbonding) XXX_DiscardUnknown()

func (*EpochProxyUnbonding) XXX_Marshal 

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

func (*EpochProxyUnbonding) XXX_Merge 

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

func (*EpochProxyUnbonding) XXX_Size 

func (m *EpochProxyUnbonding) XXX_Size() int

func (*EpochProxyUnbonding) XXX_Unmarshal 

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

type IBCCallback 

type IBCCallback struct {
	// The type of the callback operation.
	CallType CallType `protobuf:"varint,1,opt,name=callType,proto3,customtype=CallType" json:"callType"`
	// The arguments of the callback, serialized as a string.
	Args string `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty"`
}

As IBC calls are asynchronous and their acknowledgement arrival order cannot be controlled, we need a callback mechanism. Following the IBC communication mechanism, we can save information such as {ibcChannelID+sequence}: IBCCallback. When an IBC ACK is received, deserialize the args based on the CallType and execute the corresponding operation.

func (*IBCCallback) Descriptor 

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

func (*IBCCallback) GetArgs 

func (m *IBCCallback) GetArgs() string

func (*IBCCallback) Marshal 

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

func (*IBCCallback) MarshalTo 

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

func (*IBCCallback) MarshalToSizedBuffer 

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

func (*IBCCallback) ProtoMessage 

func (*IBCCallback) ProtoMessage()

func (*IBCCallback) Reset 

func (m *IBCCallback) Reset()

func (*IBCCallback) Size 

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

func (*IBCCallback) String 

func (m *IBCCallback) String() string

func (*IBCCallback) Unmarshal 

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

func (*IBCCallback) XXX_DiscardUnknown 

func (m *IBCCallback) XXX_DiscardUnknown()

func (*IBCCallback) XXX_Marshal 

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

func (*IBCCallback) XXX_Merge 

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

func (*IBCCallback) XXX_Size 

func (m *IBCCallback) XXX_Size() int

func (*IBCCallback) XXX_Unmarshal 

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

type IBCQuery 

type IBCQuery struct {
	QueryType    string `protobuf:"bytes,1,opt,name=queryType,proto3" json:"queryType,omitempty"`
	QueryPathKey string `protobuf:"bytes,2,opt,name=queryPathKey,proto3" json:"queryPathKey,omitempty"`
	Timeout      uint64 `protobuf:"varint,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	ChainID      string `protobuf:"bytes,4,opt,name=chainID,proto3" json:"chainID,omitempty"`
	ConnectionID string `protobuf:"bytes,5,opt,name=connectionID,proto3" json:"connectionID,omitempty"`
	Epoch        uint64 `protobuf:"varint,6,opt,name=epoch,proto3" json:"epoch,omitempty"`
}

func (*IBCQuery) Descriptor 

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

func (*IBCQuery) GetChainID 

func (m *IBCQuery) GetChainID() string

func (*IBCQuery) GetConnectionID 

func (m *IBCQuery) GetConnectionID() string

func (*IBCQuery) GetEpoch 

func (m *IBCQuery) GetEpoch() uint64

func (*IBCQuery) GetQueryPathKey 

func (m *IBCQuery) GetQueryPathKey() string

func (*IBCQuery) GetQueryType 

func (m *IBCQuery) GetQueryType() string

func (*IBCQuery) GetTimeout 

func (m *IBCQuery) GetTimeout() uint64

func (IBCQuery) ID 

func (q IBCQuery) ID(blockHeight uint64) string

func (*IBCQuery) Marshal 

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

func (*IBCQuery) MarshalTo 

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

func (*IBCQuery) MarshalToSizedBuffer 

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

func (*IBCQuery) ProtoMessage 

func (*IBCQuery) ProtoMessage()

func (*IBCQuery) Reset 

func (m *IBCQuery) Reset()

func (*IBCQuery) Size 

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

func (*IBCQuery) String 

func (m *IBCQuery) String() string

func (*IBCQuery) Unmarshal 

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

func (*IBCQuery) XXX_DiscardUnknown 

func (m *IBCQuery) XXX_DiscardUnknown()

func (*IBCQuery) XXX_Marshal 

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

func (*IBCQuery) XXX_Merge 

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

func (*IBCQuery) XXX_Size 

func (m *IBCQuery) XXX_Size() int

func (*IBCQuery) XXX_Unmarshal 

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

type Int 

type Int = sdkmath.Int

type MsgClaim 

type MsgClaim struct {
	// The chain ID of the source chain to claim from.
	ChainId string `protobuf:"bytes,1,opt,name=ChainId,proto3" json:"ChainId,omitempty"`
	// The delegator address.
	Delegator string `protobuf:"bytes,2,opt,name=delegator,proto3" json:"delegator,omitempty"`
	// The epoch number to claim.
	Epoch uint64 `protobuf:"varint,3,opt,name=epoch,proto3" json:"epoch,omitempty"`
}

MsgClaim defines a message for performing a liquid staking claim.

func (*MsgClaim) Descriptor 

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

func (*MsgClaim) GetChainId 

func (m *MsgClaim) GetChainId() string

func (*MsgClaim) GetDelegator 

func (m *MsgClaim) GetDelegator() string

func (*MsgClaim) GetEpoch 

func (m *MsgClaim) GetEpoch() uint64

func (*MsgClaim) GetSigners 

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

func (*MsgClaim) Marshal 

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

func (*MsgClaim) MarshalTo 

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

func (*MsgClaim) MarshalToSizedBuffer 

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

func (*MsgClaim) ProtoMessage 

func (*MsgClaim) ProtoMessage()

func (*MsgClaim) Reset 

func (m *MsgClaim) Reset()

func (*MsgClaim) Size 

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

func (*MsgClaim) String 

func (m *MsgClaim) String() string

func (*MsgClaim) Unmarshal 

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

func (*MsgClaim) ValidateBasic 

func (*MsgClaim) ValidateBasic() error

ValidateBasic implements types.Msg

func (*MsgClaim) XXX_DiscardUnknown 

func (m *MsgClaim) XXX_DiscardUnknown()

func (*MsgClaim) XXX_Marshal 

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

func (*MsgClaim) XXX_Merge 

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

func (*MsgClaim) XXX_Size 

func (m *MsgClaim) XXX_Size() int

func (*MsgClaim) XXX_Unmarshal 

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

type MsgClaimResponse 

type MsgClaimResponse struct {
}

MsgClaimResponse defines the response type for the MsgClaim message.

func (*MsgClaimResponse) Descriptor 

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

func (*MsgClaimResponse) Marshal 

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

func (*MsgClaimResponse) MarshalTo 

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

func (*MsgClaimResponse) MarshalToSizedBuffer 

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

func (*MsgClaimResponse) ProtoMessage 

func (*MsgClaimResponse) ProtoMessage()

func (*MsgClaimResponse) Reset 

func (m *MsgClaimResponse) Reset()

func (*MsgClaimResponse) Size 

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

func (*MsgClaimResponse) String 

func (m *MsgClaimResponse) String() string

func (*MsgClaimResponse) Unmarshal 

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

func (*MsgClaimResponse) XXX_DiscardUnknown 

func (m *MsgClaimResponse) XXX_DiscardUnknown()

func (*MsgClaimResponse) XXX_Marshal 

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

func (*MsgClaimResponse) XXX_Merge 

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

func (*MsgClaimResponse) XXX_Size 

func (m *MsgClaimResponse) XXX_Size() int

func (*MsgClaimResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// Register a new source chain for liquid stake. At least one correct Validator information must be provided
	RegisterSourceChain(ctx context.Context, in *MsgRegisterSourceChain, opts ...grpc.CallOption) (*MsgRegisterSourceChainResponse, error)
	// Edit the weight of validators for a source chain. Add this validators if they don't exist.
	EditValidators(ctx context.Context, in *MsgEditVadlidators, opts ...grpc.CallOption) (*MsgEditValidatorsResponse, error)
	// Rebalance the amount of delegation funds according to the weight of Validators.
	// Note that this cannot be instant.
	RebalanceValidator(ctx context.Context, in *MsgRebalanceValidators, opts ...grpc.CallOption) (*RebalanceValidatorsResponse, error)
	// Delegate define a method for performing a cross chain delegation of coins.
	Delegate(ctx context.Context, in *MsgDelegate, opts ...grpc.CallOption) (*MsgDelegateResponse, error)
	// Undelegate defines a method for performing an cross chain undelegation from dest chain to source chain.
	Undelegate(ctx context.Context, in *MsgUndelegate, opts ...grpc.CallOption) (*MsgUndelegateResponse, error)
	// Reinvest defines a method for reinvestment which use the reward form delegate.
	Reinvest(ctx context.Context, in *MsgReinvest, opts ...grpc.CallOption) (*MsgReinvestResponse, error)
	// Claim define a method for user claim the reward of delegation.
	Claim(ctx context.Context, in *MsgClaim, opts ...grpc.CallOption) (*MsgClaimResponse, 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 MsgDelegate 

type MsgDelegate struct {
	// The chain ID of the source chain to delegate.
	ChainID string `protobuf:"bytes,1,opt,name=chainID,proto3" json:"chainID,omitempty"`
	// The amount to delegate in string format, encoded as cosmos.Int.
	Amount Int `protobuf:"bytes,2,opt,name=amount,proto3,customtype=Int" json:"amount"`
	// The delegator address.
	Delegator string `protobuf:"bytes,3,opt,name=delegator,proto3" json:"delegator,omitempty"`
}

MsgDelegate define the message to do liquid stake.

func (*MsgDelegate) Descriptor 

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

func (*MsgDelegate) GetChainID 

func (m *MsgDelegate) GetChainID() string

func (*MsgDelegate) GetDelegator 

func (m *MsgDelegate) GetDelegator() string

func (*MsgDelegate) GetSigners 

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

func (*MsgDelegate) Marshal 

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

func (*MsgDelegate) MarshalTo 

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

func (*MsgDelegate) MarshalToSizedBuffer 

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

func (*MsgDelegate) ProtoMessage 

func (*MsgDelegate) ProtoMessage()

func (*MsgDelegate) Reset 

func (m *MsgDelegate) Reset()

func (*MsgDelegate) Size 

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

func (*MsgDelegate) String 

func (m *MsgDelegate) String() string

func (*MsgDelegate) Unmarshal 

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

func (*MsgDelegate) ValidateBasic 

func (*MsgDelegate) ValidateBasic() error

ValidateBasic implements types.Msg

func (*MsgDelegate) XXX_DiscardUnknown 

func (m *MsgDelegate) XXX_DiscardUnknown()

func (*MsgDelegate) XXX_Marshal 

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

func (*MsgDelegate) XXX_Merge 

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

func (*MsgDelegate) XXX_Size 

func (m *MsgDelegate) XXX_Size() int

func (*MsgDelegate) XXX_Unmarshal 

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

type MsgDelegateResponse 

type MsgDelegateResponse struct {
}

MsgDelegateResponse define the MsgDelegate response type.

func (*MsgDelegateResponse) Descriptor 

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

func (*MsgDelegateResponse) Marshal 

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

func (*MsgDelegateResponse) MarshalTo 

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

func (*MsgDelegateResponse) MarshalToSizedBuffer 

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

func (*MsgDelegateResponse) ProtoMessage 

func (*MsgDelegateResponse) ProtoMessage()

func (*MsgDelegateResponse) Reset 

func (m *MsgDelegateResponse) Reset()

func (*MsgDelegateResponse) Size 

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

func (*MsgDelegateResponse) String 

func (m *MsgDelegateResponse) String() string

func (*MsgDelegateResponse) Unmarshal 

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

func (*MsgDelegateResponse) XXX_DiscardUnknown 

func (m *MsgDelegateResponse) XXX_DiscardUnknown()

func (*MsgDelegateResponse) XXX_Marshal 

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

func (*MsgDelegateResponse) XXX_Merge 

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

func (*MsgDelegateResponse) XXX_Size 

func (m *MsgDelegateResponse) XXX_Size() int

func (*MsgDelegateResponse) XXX_Unmarshal 

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

type MsgEditVadlidators 

type MsgEditVadlidators struct {
	// The chain id of source chain.
	ChainID string `protobuf:"bytes,1,opt,name=ChainID,proto3" json:"ChainID,omitempty"`
	// The edited validators.
	Validators []*Validator `protobuf:"bytes,2,rep,name=validators,proto3" json:"validators,omitempty"`
	// The caller of this transaction.
	Caller string `protobuf:"bytes,3,opt,name=caller,proto3" json:"caller,omitempty"`
}

MsgEditValidators define the message to update the validator set of a source chain Validators can be added, removed or updated with new information

func (*MsgEditVadlidators) Descriptor 

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

func (*MsgEditVadlidators) GetCaller 

func (m *MsgEditVadlidators) GetCaller() string

func (*MsgEditVadlidators) GetChainID 

func (m *MsgEditVadlidators) GetChainID() string

func (*MsgEditVadlidators) GetSigners 

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

func (*MsgEditVadlidators) GetValidators 

func (m *MsgEditVadlidators) GetValidators() []*Validator

func (*MsgEditVadlidators) Marshal 

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

func (*MsgEditVadlidators) MarshalTo 

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

func (*MsgEditVadlidators) MarshalToSizedBuffer 

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

func (*MsgEditVadlidators) ProtoMessage 

func (*MsgEditVadlidators) ProtoMessage()

func (*MsgEditVadlidators) Reset 

func (m *MsgEditVadlidators) Reset()

func (*MsgEditVadlidators) Size 

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

func (*MsgEditVadlidators) String 

func (m *MsgEditVadlidators) String() string

func (*MsgEditVadlidators) Unmarshal 

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

func (*MsgEditVadlidators) ValidateBasic 

func (*MsgEditVadlidators) ValidateBasic() error

ValidateBasic implements types.Msg

func (*MsgEditVadlidators) XXX_DiscardUnknown 

func (m *MsgEditVadlidators) XXX_DiscardUnknown()

func (*MsgEditVadlidators) XXX_Marshal 

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

func (*MsgEditVadlidators) XXX_Merge 

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

func (*MsgEditVadlidators) XXX_Size 

func (m *MsgEditVadlidators) XXX_Size() int

func (*MsgEditVadlidators) XXX_Unmarshal 

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

type MsgEditValidatorsResponse 

type MsgEditValidatorsResponse struct {
}

MsgEditValidatorsResponse define the MsgEditVadlidators response type.

func (*MsgEditValidatorsResponse) Descriptor 

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

func (*MsgEditValidatorsResponse) Marshal 

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

func (*MsgEditValidatorsResponse) MarshalTo 

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

func (*MsgEditValidatorsResponse) MarshalToSizedBuffer 

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

func (*MsgEditValidatorsResponse) ProtoMessage 

func (*MsgEditValidatorsResponse) ProtoMessage()

func (*MsgEditValidatorsResponse) Reset 

func (m *MsgEditValidatorsResponse) Reset()

func (*MsgEditValidatorsResponse) Size 

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

func (*MsgEditValidatorsResponse) String 

func (m *MsgEditValidatorsResponse) String() string

func (*MsgEditValidatorsResponse) Unmarshal 

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

func (*MsgEditValidatorsResponse) XXX_DiscardUnknown 

func (m *MsgEditValidatorsResponse) XXX_DiscardUnknown()

func (*MsgEditValidatorsResponse) XXX_Marshal 

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

func (*MsgEditValidatorsResponse) XXX_Merge 

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

func (*MsgEditValidatorsResponse) XXX_Size 

func (m *MsgEditValidatorsResponse) XXX_Size() int

func (*MsgEditValidatorsResponse) XXX_Unmarshal 

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

type MsgRebalanceValidators 

type MsgRebalanceValidators struct {
	// The chain id of source chain.
	ChainID string `protobuf:"bytes,1,opt,name=ChainID,proto3" json:"ChainID,omitempty"`
	// The caller of this transaction. It does not need permission,
	// but should limit the calling frequency
	Caller string `protobuf:"bytes,2,opt,name=caller,proto3" json:"caller,omitempty"`
}

MsgRebalanceValidators define the message to rebalance the amount of delegation funds according to the weight of validators.

func (*MsgRebalanceValidators) Descriptor 

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

func (*MsgRebalanceValidators) GetCaller 

func (m *MsgRebalanceValidators) GetCaller() string

func (*MsgRebalanceValidators) GetChainID 

func (m *MsgRebalanceValidators) GetChainID() string

func (*MsgRebalanceValidators) GetSigners 

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

func (*MsgRebalanceValidators) Marshal 

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

func (*MsgRebalanceValidators) MarshalTo 

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

func (*MsgRebalanceValidators) MarshalToSizedBuffer 

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

func (*MsgRebalanceValidators) ProtoMessage 

func (*MsgRebalanceValidators) ProtoMessage()

func (*MsgRebalanceValidators) Reset 

func (m *MsgRebalanceValidators) Reset()

func (*MsgRebalanceValidators) Size 

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

func (*MsgRebalanceValidators) String 

func (m *MsgRebalanceValidators) String() string

func (*MsgRebalanceValidators) Unmarshal 

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

func (*MsgRebalanceValidators) ValidateBasic 

func (*MsgRebalanceValidators) ValidateBasic() error

ValidateBasic implements types.Msg

func (*MsgRebalanceValidators) XXX_DiscardUnknown 

func (m *MsgRebalanceValidators) XXX_DiscardUnknown()

func (*MsgRebalanceValidators) XXX_Marshal 

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

func (*MsgRebalanceValidators) XXX_Merge 

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

func (*MsgRebalanceValidators) XXX_Size 

func (m *MsgRebalanceValidators) XXX_Size() int

func (*MsgRebalanceValidators) XXX_Unmarshal 

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

type MsgRegisterSourceChain 

type MsgRegisterSourceChain struct {
	// The chain id of registered source chain.
	ChainID string `protobuf:"bytes,1,opt,name=ChainID,proto3" json:"ChainID,omitempty"`
	// The ibc connection id. It will be used for creating interchain account.
	ConnectionID string `protobuf:"bytes,2,opt,name=connectionID,proto3" json:"connectionID,omitempty"`
	// ibc transfer channel id
	TrasnferChannelID string `protobuf:"bytes,3,opt,name=trasnferChannelID,proto3" json:"trasnferChannelID,omitempty"`
	// validator address prefix of source chain.
	Bech32ValidatorAddrPrefix string `protobuf:"bytes,4,opt,name=bech32ValidatorAddrPrefix,proto3" json:"bech32ValidatorAddrPrefix,omitempty"`
	// Validators at the start
	Validators []Validator `protobuf:"bytes,5,rep,name=validators,proto3" json:"validators"`
	// The denom of source chain native token.
	NativeDenom string `protobuf:"bytes,6,opt,name=nativeDenom,proto3" json:"nativeDenom,omitempty"`
	// The denom of derivative token generate by liquid stake
	DerivativeDenom string `protobuf:"bytes,7,opt,name=derivativeDenom,proto3" json:"derivativeDenom,omitempty"`
	// The caller of this transaction. It needs to have certain permissions
	Caller string `protobuf:"bytes,8,opt,name=caller,proto3" json:"caller,omitempty"`
}

MsgRegisterSourceChain define the message for registering a source chain in the LiquidStake module.

func (*MsgRegisterSourceChain) Descriptor 

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

func (*MsgRegisterSourceChain) GetBech32ValidatorAddrPrefix 

func (m *MsgRegisterSourceChain) GetBech32ValidatorAddrPrefix() string

func (*MsgRegisterSourceChain) GetCaller 

func (m *MsgRegisterSourceChain) GetCaller() string

func (*MsgRegisterSourceChain) GetChainID 

func (m *MsgRegisterSourceChain) GetChainID() string

func (*MsgRegisterSourceChain) GetConnectionID 

func (m *MsgRegisterSourceChain) GetConnectionID() string

func (*MsgRegisterSourceChain) GetDerivativeDenom 

func (m *MsgRegisterSourceChain) GetDerivativeDenom() string

func (*MsgRegisterSourceChain) GetNativeDenom 

func (m *MsgRegisterSourceChain) GetNativeDenom() string

func (*MsgRegisterSourceChain) GetSigners 

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

GetSigners implements types.Msg

func (*MsgRegisterSourceChain) GetTrasnferChannelID 

func (m *MsgRegisterSourceChain) GetTrasnferChannelID() string

func (*MsgRegisterSourceChain) GetValidators 

func (m *MsgRegisterSourceChain) GetValidators() []Validator

func (*MsgRegisterSourceChain) Marshal 

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

func (*MsgRegisterSourceChain) MarshalTo 

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

func (*MsgRegisterSourceChain) MarshalToSizedBuffer 

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

func (*MsgRegisterSourceChain) ProtoMessage 

func (*MsgRegisterSourceChain) ProtoMessage()

func (*MsgRegisterSourceChain) Reset 

func (m *MsgRegisterSourceChain) Reset()

func (*MsgRegisterSourceChain) Size 

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

func (*MsgRegisterSourceChain) String 

func (m *MsgRegisterSourceChain) String() string

func (*MsgRegisterSourceChain) Unmarshal 

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

func (*MsgRegisterSourceChain) ValidateBasic 

func (*MsgRegisterSourceChain) ValidateBasic() error

ValidateBasic implements types.Msg

func (*MsgRegisterSourceChain) XXX_DiscardUnknown 

func (m *MsgRegisterSourceChain) XXX_DiscardUnknown()

func (*MsgRegisterSourceChain) XXX_Marshal 

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

func (*MsgRegisterSourceChain) XXX_Merge 

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

func (*MsgRegisterSourceChain) XXX_Size 

func (m *MsgRegisterSourceChain) XXX_Size() int

func (*MsgRegisterSourceChain) XXX_Unmarshal 

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

type MsgRegisterSourceChainResponse 

type MsgRegisterSourceChainResponse struct {
}

MsgRegisterSourceChainResponse define the MsgRegisterSourceChain response type.

func (*MsgRegisterSourceChainResponse) Descriptor 

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

func (*MsgRegisterSourceChainResponse) Marshal 

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

func (*MsgRegisterSourceChainResponse) MarshalTo 

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

func (*MsgRegisterSourceChainResponse) MarshalToSizedBuffer 

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

func (*MsgRegisterSourceChainResponse) ProtoMessage 

func (*MsgRegisterSourceChainResponse) ProtoMessage()

func (*MsgRegisterSourceChainResponse) Reset 

func (m *MsgRegisterSourceChainResponse) Reset()

func (*MsgRegisterSourceChainResponse) Size 

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

func (*MsgRegisterSourceChainResponse) String 

func (m *MsgRegisterSourceChainResponse) String() string

func (*MsgRegisterSourceChainResponse) Unmarshal 

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

func (*MsgRegisterSourceChainResponse) XXX_DiscardUnknown 

func (m *MsgRegisterSourceChainResponse) XXX_DiscardUnknown()

func (*MsgRegisterSourceChainResponse) XXX_Marshal 

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

func (*MsgRegisterSourceChainResponse) XXX_Merge 

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

func (*MsgRegisterSourceChainResponse) XXX_Size 

func (m *MsgRegisterSourceChainResponse) XXX_Size() int

func (*MsgRegisterSourceChainResponse) XXX_Unmarshal 

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

type MsgReinvest 

type MsgReinvest struct {
	// The chain ID of the source chain to reinvest in.
	ChainId string `protobuf:"bytes,1,opt,name=chainId,proto3" json:"chainId,omitempty"`
	// The delegation epoch.
	Epoch uint64 `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	// The funds to reinvest
	Funds *types.Coin `protobuf:"bytes,3,opt,name=funds,proto3" json:"funds,omitempty"`
	// The Merkle proof of the funds.
	FundsProof string `protobuf:"bytes,4,opt,name=fundsProof,proto3" json:"fundsProof,omitempty"`
	// The height at which the Merkle proof is stored.
	ProofHeight uint64 `protobuf:"varint,5,opt,name=proofHeight,proto3" json:"proofHeight,omitempty"`
	// The caller of the transaction.
	Caller string `protobuf:"bytes,6,opt,name=caller,proto3" json:"caller,omitempty"`
}

MsgReinvest define the message to perforing reinvestment.

func (*MsgReinvest) Descriptor 

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

func (*MsgReinvest) GetCaller 

func (m *MsgReinvest) GetCaller() string

func (*MsgReinvest) GetChainId 

func (m *MsgReinvest) GetChainId() string

func (*MsgReinvest) GetEpoch 

func (m *MsgReinvest) GetEpoch() uint64

func (*MsgReinvest) GetFunds 

func (m *MsgReinvest) GetFunds() *types.Coin

func (*MsgReinvest) GetFundsProof 

func (m *MsgReinvest) GetFundsProof() string

func (*MsgReinvest) GetProofHeight 

func (m *MsgReinvest) GetProofHeight() uint64

func (*MsgReinvest) GetSigners 

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

func (*MsgReinvest) Marshal 

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

func (*MsgReinvest) MarshalTo 

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

func (*MsgReinvest) MarshalToSizedBuffer 

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

func (*MsgReinvest) ProtoMessage 

func (*MsgReinvest) ProtoMessage()

func (*MsgReinvest) Reset 

func (m *MsgReinvest) Reset()

func (*MsgReinvest) Size 

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

func (*MsgReinvest) String 

func (m *MsgReinvest) String() string

func (*MsgReinvest) Unmarshal 

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

func (*MsgReinvest) ValidateBasic 

func (*MsgReinvest) ValidateBasic() error

ValidateBasic implements types.Msg

func (*MsgReinvest) XXX_DiscardUnknown 

func (m *MsgReinvest) XXX_DiscardUnknown()

func (*MsgReinvest) XXX_Marshal 

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

func (*MsgReinvest) XXX_Merge 

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

func (*MsgReinvest) XXX_Size 

func (m *MsgReinvest) XXX_Size() int

func (*MsgReinvest) XXX_Unmarshal 

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

type MsgReinvestResponse 

type MsgReinvestResponse struct {
}

MsgReinvestResponse defines the response type for the MsgReinvest message.

func (*MsgReinvestResponse) Descriptor 

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

func (*MsgReinvestResponse) Marshal 

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

func (*MsgReinvestResponse) MarshalTo 

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

func (*MsgReinvestResponse) MarshalToSizedBuffer 

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

func (*MsgReinvestResponse) ProtoMessage 

func (*MsgReinvestResponse) ProtoMessage()

func (*MsgReinvestResponse) Reset 

func (m *MsgReinvestResponse) Reset()

func (*MsgReinvestResponse) Size 

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

func (*MsgReinvestResponse) String 

func (m *MsgReinvestResponse) String() string

func (*MsgReinvestResponse) Unmarshal 

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

func (*MsgReinvestResponse) XXX_DiscardUnknown 

func (m *MsgReinvestResponse) XXX_DiscardUnknown()

func (*MsgReinvestResponse) XXX_Marshal 

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

func (*MsgReinvestResponse) XXX_Merge 

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

func (*MsgReinvestResponse) XXX_Size 

func (m *MsgReinvestResponse) XXX_Size() int

func (*MsgReinvestResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// Register a new source chain for liquid stake. At least one correct Validator information must be provided
	RegisterSourceChain(context.Context, *MsgRegisterSourceChain) (*MsgRegisterSourceChainResponse, error)
	// Edit the weight of validators for a source chain. Add this validators if they don't exist.
	EditValidators(context.Context, *MsgEditVadlidators) (*MsgEditValidatorsResponse, error)
	// Rebalance the amount of delegation funds according to the weight of Validators.
	// Note that this cannot be instant.
	RebalanceValidator(context.Context, *MsgRebalanceValidators) (*RebalanceValidatorsResponse, error)
	// Delegate define a method for performing a cross chain delegation of coins.
	Delegate(context.Context, *MsgDelegate) (*MsgDelegateResponse, error)
	// Undelegate defines a method for performing an cross chain undelegation from dest chain to source chain.
	Undelegate(context.Context, *MsgUndelegate) (*MsgUndelegateResponse, error)
	// Reinvest defines a method for reinvestment which use the reward form delegate.
	Reinvest(context.Context, *MsgReinvest) (*MsgReinvestResponse, error)
	// Claim define a method for user claim the reward of delegation.
	Claim(context.Context, *MsgClaim) (*MsgClaimResponse, error)
}

MsgServer is the server API for Msg service.

type MsgUndelegate 

type MsgUndelegate struct {
	// The chain ID of the source chain to redeem from.
	ChainID string `protobuf:"bytes,1,opt,name=chainID,proto3" json:"chainID,omitempty"`
	// The amount to redeem in string format, encoded as cosmos.Int.
	Amount Int `protobuf:"bytes,2,opt,name=amount,proto3,customtype=Int" json:"amount"`
	// The delegator address.
	Delegator string `protobuf:"bytes,3,opt,name=delegator,proto3" json:"delegator,omitempty"`
}

MsgUndelegate define the message to performing liquid staking redeem.

func (*MsgUndelegate) Descriptor 

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

func (*MsgUndelegate) GetChainID 

func (m *MsgUndelegate) GetChainID() string

func (*MsgUndelegate) GetDelegator 

func (m *MsgUndelegate) GetDelegator() string

func (*MsgUndelegate) GetSigners 

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

func (*MsgUndelegate) Marshal 

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

func (*MsgUndelegate) MarshalTo 

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

func (*MsgUndelegate) MarshalToSizedBuffer 

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

func (*MsgUndelegate) ProtoMessage 

func (*MsgUndelegate) ProtoMessage()

func (*MsgUndelegate) Reset 

func (m *MsgUndelegate) Reset()

func (*MsgUndelegate) Size 

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

func (*MsgUndelegate) String 

func (m *MsgUndelegate) String() string

func (*MsgUndelegate) Unmarshal 

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

func (*MsgUndelegate) ValidateBasic 

func (*MsgUndelegate) ValidateBasic() error

ValidateBasic implements types.Msg

func (*MsgUndelegate) XXX_DiscardUnknown 

func (m *MsgUndelegate) XXX_DiscardUnknown()

func (*MsgUndelegate) XXX_Marshal 

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

func (*MsgUndelegate) XXX_Merge 

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

func (*MsgUndelegate) XXX_Size 

func (m *MsgUndelegate) XXX_Size() int

func (*MsgUndelegate) XXX_Unmarshal 

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

type MsgUndelegateResponse 

type MsgUndelegateResponse struct {
}

MsgUndelegateResponce define the MsgUndelegate response type.

func (*MsgUndelegateResponse) Descriptor 

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

func (*MsgUndelegateResponse) Marshal 

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

func (*MsgUndelegateResponse) MarshalTo 

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

func (*MsgUndelegateResponse) MarshalToSizedBuffer 

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

func (*MsgUndelegateResponse) ProtoMessage 

func (*MsgUndelegateResponse) ProtoMessage()

func (*MsgUndelegateResponse) Reset 

func (m *MsgUndelegateResponse) Reset()

func (*MsgUndelegateResponse) Size 

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

func (*MsgUndelegateResponse) String 

func (m *MsgUndelegateResponse) String() string

func (*MsgUndelegateResponse) Unmarshal 

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

func (*MsgUndelegateResponse) XXX_DiscardUnknown 

func (m *MsgUndelegateResponse) XXX_DiscardUnknown()

func (*MsgUndelegateResponse) XXX_Marshal 

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

func (*MsgUndelegateResponse) XXX_Merge 

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

func (*MsgUndelegateResponse) XXX_Size 

func (m *MsgUndelegateResponse) XXX_Size() int

func (*MsgUndelegateResponse) XXX_Unmarshal 

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

type ProxyDelegation 

type ProxyDelegation struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Users delegated tokens accumulated by the specified epoch
	Coin types.Coin `protobuf:"bytes,2,opt,name=coin,proto3" json:"coin"`
	// Status of the record.
	// A ProxyDelegation goes through the following status:
	//   1) Pending: The epoch he is in is not over yet
	//   2) Transfering: Transferring user-delegated funds back to the source chain.
	//   3) Transferred: Transfer back to source chain successfully.Because the funds
	//      need to be delegated on the source chain immediately, this state will not be saved.
	//   4) Delegating: Cross-chain delegation is being executed through IBC
	//   5) Done: Cross-chain delegation has be done. If this state is reached, then this
	//      record will be deleted, so this state will not be recorded."
	// Above is a successful state, but there are also states that represent failure.
	//   1）TransferFailed: An error occurred during the process of transferring funds back to the source chain.
	//   2) DelegateFailed: An error occurred during the process of delegating in source chain.
	Status ProxyDelegationStatus `protobuf:"varint,3,opt,name=status,proto3,customtype=ProxyDelegationStatus" json:"status"`
	// The number of created epoch
	EpochNumber uint64 `protobuf:"varint,4,opt,name=epochNumber,proto3" json:"epochNumber,omitempty"`
	ChainID     string `protobuf:"bytes,5,opt,name=chainID,proto3" json:"chainID,omitempty"`
	// A portion of the `DelegationCoin` that have been transferred to the source chain.
	// This happens when reinvesting to get back the source chain staking rewards,
	ReinvestAmount Int `protobuf:"bytes,6,opt,name=reinvestAmount,proto3,customtype=Int" json:"reinvestAmount"`
}

The record of source chain delegation in a epoch.

func (*ProxyDelegation) Descriptor 

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

func (*ProxyDelegation) GetChainID 

func (m *ProxyDelegation) GetChainID() string

func (*ProxyDelegation) GetCoin 

func (m *ProxyDelegation) GetCoin() types.Coin

func (*ProxyDelegation) GetEpochNumber 

func (m *ProxyDelegation) GetEpochNumber() uint64

func (*ProxyDelegation) GetId 

func (m *ProxyDelegation) GetId() uint64

func (*ProxyDelegation) Marshal 

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

func (*ProxyDelegation) MarshalTo 

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

func (*ProxyDelegation) MarshalToSizedBuffer 

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

func (*ProxyDelegation) ProtoMessage 

func (*ProxyDelegation) ProtoMessage()

func (*ProxyDelegation) Reset 

func (m *ProxyDelegation) Reset()

func (*ProxyDelegation) Size 

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

func (*ProxyDelegation) String 

func (m *ProxyDelegation) String() string

func (*ProxyDelegation) Unmarshal 

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

func (*ProxyDelegation) XXX_DiscardUnknown 

func (m *ProxyDelegation) XXX_DiscardUnknown()

func (*ProxyDelegation) XXX_Marshal 

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

func (*ProxyDelegation) XXX_Merge 

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

func (*ProxyDelegation) XXX_Size 

func (m *ProxyDelegation) XXX_Size() int

func (*ProxyDelegation) XXX_Unmarshal 

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

type ProxyDelegationStatus 

type ProxyDelegationStatus uint32

ProxyDelegation status 

const (
	ProxyDelegationPending ProxyDelegationStatus = iota
	ProxyDelegationTransferring
	ProxyDelegationTransferred
	ProxyDelegating
	ProxyDelegationDone
	ProxyDelegationTransferFailed
	ProxyDelegationFailed
)

type ProxyUnbonding 

type ProxyUnbonding struct {
	ChainID                string `protobuf:"bytes,1,opt,name=chainID,proto3" json:"chainID,omitempty"`
	BurnedDerivativeAmount Int    `protobuf:"bytes,2,opt,name=burnedDerivativeAmount,proto3,customtype=Int" json:"burnedDerivativeAmount"`
	// The native tokens to be redeemed.
	RedeemNativeToken types.Coin `protobuf:"bytes,3,opt,name=redeemNativeToken,proto3" json:"redeemNativeToken"`
	// The time at which the unbonding will complete and the native tokens will be redeemable.
	UnbondTime uint64 `protobuf:"varint,4,opt,name=unbondTime,proto3" json:"unbondTime,omitempty"`
	// The status of the unbonding.
	// 1) Pending: waiting for the current epoch to end
	// 2) Start: initiated the Unbonding process on the source chain
	// 3) Unbonding: successfully initiated the Unbonding process
	// 4) Transfering: Unbonding period has elapsed, redeeming funds from the source chain
	// 5) Done: funds have been successfully redeemed
	Status ProxyUnbondingStatus `protobuf:"varint,5,opt,name=status,proto3,customtype=ProxyUnbondingStatus" json:"status"`
	// The IDs of the UserUnbonding entries that correspond to this unbonding entry.
	UserUnbondingIds []string `protobuf:"bytes,6,rep,name=UserUnbondingIds,proto3" json:"UserUnbondingIds,omitempty"`
}

Represents a record of an unbonding transaction, which captures the derivative token that was burned and the native token that is to be redeemed.

func (*ProxyUnbonding) Descriptor 

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

func (*ProxyUnbonding) GetChainID 

func (m *ProxyUnbonding) GetChainID() string

func (*ProxyUnbonding) GetRedeemNativeToken 

func (m *ProxyUnbonding) GetRedeemNativeToken() types.Coin

func (*ProxyUnbonding) GetUnbondTime 

func (m *ProxyUnbonding) GetUnbondTime() uint64

func (*ProxyUnbonding) GetUserUnbondingIds 

func (m *ProxyUnbonding) GetUserUnbondingIds() []string

func (*ProxyUnbonding) Marshal 

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

func (*ProxyUnbonding) MarshalTo 

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

func (*ProxyUnbonding) MarshalToSizedBuffer 

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

func (*ProxyUnbonding) ProtoMessage 

func (*ProxyUnbonding) ProtoMessage()

func (*ProxyUnbonding) Reset 

func (m *ProxyUnbonding) Reset()

func (*ProxyUnbonding) Size 

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

func (*ProxyUnbonding) String 

func (m *ProxyUnbonding) String() string

func (*ProxyUnbonding) Unmarshal 

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

func (*ProxyUnbonding) XXX_DiscardUnknown 

func (m *ProxyUnbonding) XXX_DiscardUnknown()

func (*ProxyUnbonding) XXX_Marshal 

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

func (*ProxyUnbonding) XXX_Merge 

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

func (*ProxyUnbonding) XXX_Size 

func (m *ProxyUnbonding) XXX_Size() int

func (*ProxyUnbonding) XXX_Unmarshal 

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

type ProxyUnbondingStatus 

type ProxyUnbondingStatus uint32

Unbonding failed 

const (
	ProxyUnbondingPending ProxyUnbondingStatus = iota
	ProxyUnbondingStart
	ProxyUnbondingWaitting
	ProxyUnbondingWithdraw
	ProxyUnbondingTransferred
	ProxyUnbondingDone
	ProxyUnbondingStartFailed
	ProxyUnbondingTransferFailed
)

type QueryClient 

type QueryClient interface {
	SourceChain(ctx context.Context, in *QuerySourceChainRequest, opts ...grpc.CallOption) (*QuerySourceChainResponse, error)
	ProxyDelegation(ctx context.Context, in *QueryProxyDelegationRequest, opts ...grpc.CallOption) (*QueryProxyDelegationResponse, error)
	EpochProxyUnbonding(ctx context.Context, in *QueryEpochProxyUnbondingRequest, opts ...grpc.CallOption) (*QueryEpochProxyUnbondingResponse, error)
	UserUnbonding(ctx context.Context, in *QueryUserUnbondingRequest, opts ...grpc.CallOption) (*QueryUserUnbondingResponse, 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 QueryEpochProxyUnbondingRequest 

type QueryEpochProxyUnbondingRequest struct {
	Epoch   uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	ChainID string `protobuf:"bytes,2,opt,name=chainID,proto3" json:"chainID,omitempty"`
}

func (*QueryEpochProxyUnbondingRequest) Descriptor 

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

func (*QueryEpochProxyUnbondingRequest) GetChainID 

func (m *QueryEpochProxyUnbondingRequest) GetChainID() string

func (*QueryEpochProxyUnbondingRequest) GetEpoch 

func (m *QueryEpochProxyUnbondingRequest) GetEpoch() uint64

func (*QueryEpochProxyUnbondingRequest) Marshal 

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

func (*QueryEpochProxyUnbondingRequest) MarshalTo 

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

func (*QueryEpochProxyUnbondingRequest) MarshalToSizedBuffer 

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

func (*QueryEpochProxyUnbondingRequest) ProtoMessage 

func (*QueryEpochProxyUnbondingRequest) ProtoMessage()

func (*QueryEpochProxyUnbondingRequest) Reset 

func (m *QueryEpochProxyUnbondingRequest) Reset()

func (*QueryEpochProxyUnbondingRequest) Size 

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

func (*QueryEpochProxyUnbondingRequest) String 

func (m *QueryEpochProxyUnbondingRequest) String() string

func (*QueryEpochProxyUnbondingRequest) Unmarshal 

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

func (*QueryEpochProxyUnbondingRequest) XXX_DiscardUnknown 

func (m *QueryEpochProxyUnbondingRequest) XXX_DiscardUnknown()

func (*QueryEpochProxyUnbondingRequest) XXX_Marshal 

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

func (*QueryEpochProxyUnbondingRequest) XXX_Merge 

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

func (*QueryEpochProxyUnbondingRequest) XXX_Size 

func (m *QueryEpochProxyUnbondingRequest) XXX_Size() int

func (*QueryEpochProxyUnbondingRequest) XXX_Unmarshal 

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

type QueryEpochProxyUnbondingResponse 

type QueryEpochProxyUnbondingResponse struct {
	ChainUnbonding ProxyUnbonding `protobuf:"bytes,1,opt,name=chainUnbonding,proto3" json:"chainUnbonding"`
}

func (*QueryEpochProxyUnbondingResponse) Descriptor 

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

func (*QueryEpochProxyUnbondingResponse) GetChainUnbonding 

func (m *QueryEpochProxyUnbondingResponse) GetChainUnbonding() ProxyUnbonding

func (*QueryEpochProxyUnbondingResponse) Marshal 

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

func (*QueryEpochProxyUnbondingResponse) MarshalTo 

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

func (*QueryEpochProxyUnbondingResponse) MarshalToSizedBuffer 

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

func (*QueryEpochProxyUnbondingResponse) ProtoMessage 

func (*QueryEpochProxyUnbondingResponse) ProtoMessage()

func (*QueryEpochProxyUnbondingResponse) Reset 

func (m *QueryEpochProxyUnbondingResponse) Reset()

func (*QueryEpochProxyUnbondingResponse) Size 

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

func (*QueryEpochProxyUnbondingResponse) String 

func (m *QueryEpochProxyUnbondingResponse) String() string

func (*QueryEpochProxyUnbondingResponse) Unmarshal 

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

func (*QueryEpochProxyUnbondingResponse) XXX_DiscardUnknown 

func (m *QueryEpochProxyUnbondingResponse) XXX_DiscardUnknown()

func (*QueryEpochProxyUnbondingResponse) XXX_Marshal 

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

func (*QueryEpochProxyUnbondingResponse) XXX_Merge 

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

func (*QueryEpochProxyUnbondingResponse) XXX_Size 

func (m *QueryEpochProxyUnbondingResponse) XXX_Size() int

func (*QueryEpochProxyUnbondingResponse) XXX_Unmarshal 

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

type QueryProxyDelegationRequest 

type QueryProxyDelegationRequest struct {
	Epoch   uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	ChainID string `protobuf:"bytes,2,opt,name=chainID,proto3" json:"chainID,omitempty"`
}

func (*QueryProxyDelegationRequest) Descriptor 

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

func (*QueryProxyDelegationRequest) GetChainID 

func (m *QueryProxyDelegationRequest) GetChainID() string

func (*QueryProxyDelegationRequest) GetEpoch 

func (m *QueryProxyDelegationRequest) GetEpoch() uint64

func (*QueryProxyDelegationRequest) Marshal 

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

func (*QueryProxyDelegationRequest) MarshalTo 

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

func (*QueryProxyDelegationRequest) MarshalToSizedBuffer 

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

func (*QueryProxyDelegationRequest) ProtoMessage 

func (*QueryProxyDelegationRequest) ProtoMessage()

func (*QueryProxyDelegationRequest) Reset 

func (m *QueryProxyDelegationRequest) Reset()

func (*QueryProxyDelegationRequest) Size 

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

func (*QueryProxyDelegationRequest) String 

func (m *QueryProxyDelegationRequest) String() string

func (*QueryProxyDelegationRequest) Unmarshal 

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

func (*QueryProxyDelegationRequest) XXX_DiscardUnknown 

func (m *QueryProxyDelegationRequest) XXX_DiscardUnknown()

func (*QueryProxyDelegationRequest) XXX_Marshal 

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

func (*QueryProxyDelegationRequest) XXX_Merge 

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

func (*QueryProxyDelegationRequest) XXX_Size 

func (m *QueryProxyDelegationRequest) XXX_Size() int

func (*QueryProxyDelegationRequest) XXX_Unmarshal 

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

type QueryProxyDelegationResponse 

type QueryProxyDelegationResponse struct {
	Record ProxyDelegation `protobuf:"bytes,1,opt,name=record,proto3" json:"record"`
}

func (*QueryProxyDelegationResponse) Descriptor 

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

func (*QueryProxyDelegationResponse) GetRecord 

func (m *QueryProxyDelegationResponse) GetRecord() ProxyDelegation

func (*QueryProxyDelegationResponse) Marshal 

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

func (*QueryProxyDelegationResponse) MarshalTo 

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

func (*QueryProxyDelegationResponse) MarshalToSizedBuffer 

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

func (*QueryProxyDelegationResponse) ProtoMessage 

func (*QueryProxyDelegationResponse) ProtoMessage()

func (*QueryProxyDelegationResponse) Reset 

func (m *QueryProxyDelegationResponse) Reset()

func (*QueryProxyDelegationResponse) Size 

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

func (*QueryProxyDelegationResponse) String 

func (m *QueryProxyDelegationResponse) String() string

func (*QueryProxyDelegationResponse) Unmarshal 

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

func (*QueryProxyDelegationResponse) XXX_DiscardUnknown 

func (m *QueryProxyDelegationResponse) XXX_DiscardUnknown()

func (*QueryProxyDelegationResponse) XXX_Marshal 

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

func (*QueryProxyDelegationResponse) XXX_Merge 

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

func (*QueryProxyDelegationResponse) XXX_Size 

func (m *QueryProxyDelegationResponse) XXX_Size() int

func (*QueryProxyDelegationResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	SourceChain(context.Context, *QuerySourceChainRequest) (*QuerySourceChainResponse, error)
	ProxyDelegation(context.Context, *QueryProxyDelegationRequest) (*QueryProxyDelegationResponse, error)
	EpochProxyUnbonding(context.Context, *QueryEpochProxyUnbondingRequest) (*QueryEpochProxyUnbondingResponse, error)
	UserUnbonding(context.Context, *QueryUserUnbondingRequest) (*QueryUserUnbondingResponse, error)
}

QueryServer is the server API for Query service.

type QuerySourceChainRequest 

type QuerySourceChainRequest struct {
	ChainID string `protobuf:"bytes,1,opt,name=ChainID,proto3" json:"ChainID,omitempty"`
}

func (*QuerySourceChainRequest) Descriptor 

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

func (*QuerySourceChainRequest) GetChainID 

func (m *QuerySourceChainRequest) GetChainID() string

func (*QuerySourceChainRequest) Marshal 

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

func (*QuerySourceChainRequest) MarshalTo 

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

func (*QuerySourceChainRequest) MarshalToSizedBuffer 

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

func (*QuerySourceChainRequest) ProtoMessage 

func (*QuerySourceChainRequest) ProtoMessage()

func (*QuerySourceChainRequest) Reset 

func (m *QuerySourceChainRequest) Reset()

func (*QuerySourceChainRequest) Size 

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

func (*QuerySourceChainRequest) String 

func (m *QuerySourceChainRequest) String() string

func (*QuerySourceChainRequest) Unmarshal 

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

func (*QuerySourceChainRequest) XXX_DiscardUnknown 

func (m *QuerySourceChainRequest) XXX_DiscardUnknown()

func (*QuerySourceChainRequest) XXX_Marshal 

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

func (*QuerySourceChainRequest) XXX_Merge 

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

func (*QuerySourceChainRequest) XXX_Size 

func (m *QuerySourceChainRequest) XXX_Size() int

func (*QuerySourceChainRequest) XXX_Unmarshal 

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

type QuerySourceChainResponse 

type QuerySourceChainResponse struct {
	SourceChain SourceChain `protobuf:"bytes,1,opt,name=sourceChain,proto3" json:"sourceChain"`
}

func (*QuerySourceChainResponse) Descriptor 

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

func (*QuerySourceChainResponse) GetSourceChain 

func (m *QuerySourceChainResponse) GetSourceChain() SourceChain

func (*QuerySourceChainResponse) Marshal 

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

func (*QuerySourceChainResponse) MarshalTo 

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

func (*QuerySourceChainResponse) MarshalToSizedBuffer 

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

func (*QuerySourceChainResponse) ProtoMessage 

func (*QuerySourceChainResponse) ProtoMessage()

func (*QuerySourceChainResponse) Reset 

func (m *QuerySourceChainResponse) Reset()

func (*QuerySourceChainResponse) Size 

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

func (*QuerySourceChainResponse) String 

func (m *QuerySourceChainResponse) String() string

func (*QuerySourceChainResponse) Unmarshal 

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

func (*QuerySourceChainResponse) XXX_DiscardUnknown 

func (m *QuerySourceChainResponse) XXX_DiscardUnknown()

func (*QuerySourceChainResponse) XXX_Marshal 

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

func (*QuerySourceChainResponse) XXX_Merge 

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

func (*QuerySourceChainResponse) XXX_Size 

func (m *QuerySourceChainResponse) XXX_Size() int

func (*QuerySourceChainResponse) XXX_Unmarshal 

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

type QueryUserUnbondingRequest 

type QueryUserUnbondingRequest struct {
	ChainID string `protobuf:"bytes,1,opt,name=chainID,proto3" json:"chainID,omitempty"`
	User    string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
}

func (*QueryUserUnbondingRequest) Descriptor 

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

func (*QueryUserUnbondingRequest) GetChainID 

func (m *QueryUserUnbondingRequest) GetChainID() string

func (*QueryUserUnbondingRequest) GetUser 

func (m *QueryUserUnbondingRequest) GetUser() string

func (*QueryUserUnbondingRequest) Marshal 

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

func (*QueryUserUnbondingRequest) MarshalTo 

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

func (*QueryUserUnbondingRequest) MarshalToSizedBuffer 

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

func (*QueryUserUnbondingRequest) ProtoMessage 

func (*QueryUserUnbondingRequest) ProtoMessage()

func (*QueryUserUnbondingRequest) Reset 

func (m *QueryUserUnbondingRequest) Reset()

func (*QueryUserUnbondingRequest) Size 

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

func (*QueryUserUnbondingRequest) String 

func (m *QueryUserUnbondingRequest) String() string

func (*QueryUserUnbondingRequest) Unmarshal 

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

func (*QueryUserUnbondingRequest) XXX_DiscardUnknown 

func (m *QueryUserUnbondingRequest) XXX_DiscardUnknown()

func (*QueryUserUnbondingRequest) XXX_Marshal 

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

func (*QueryUserUnbondingRequest) XXX_Merge 

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

func (*QueryUserUnbondingRequest) XXX_Size 

func (m *QueryUserUnbondingRequest) XXX_Size() int

func (*QueryUserUnbondingRequest) XXX_Unmarshal 

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

type QueryUserUnbondingResponse 

type QueryUserUnbondingResponse struct {
	UserUnbondings []UserUnbonding `protobuf:"bytes,1,rep,name=userUnbondings,proto3" json:"userUnbondings"`
}

func (*QueryUserUnbondingResponse) Descriptor 

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

func (*QueryUserUnbondingResponse) GetUserUnbondings 

func (m *QueryUserUnbondingResponse) GetUserUnbondings() []UserUnbonding

func (*QueryUserUnbondingResponse) Marshal 

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

func (*QueryUserUnbondingResponse) MarshalTo 

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

func (*QueryUserUnbondingResponse) MarshalToSizedBuffer 

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

func (*QueryUserUnbondingResponse) ProtoMessage 

func (*QueryUserUnbondingResponse) ProtoMessage()

func (*QueryUserUnbondingResponse) Reset 

func (m *QueryUserUnbondingResponse) Reset()

func (*QueryUserUnbondingResponse) Size 

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

func (*QueryUserUnbondingResponse) String 

func (m *QueryUserUnbondingResponse) String() string

func (*QueryUserUnbondingResponse) Unmarshal 

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

func (*QueryUserUnbondingResponse) XXX_DiscardUnknown 

func (m *QueryUserUnbondingResponse) XXX_DiscardUnknown()

func (*QueryUserUnbondingResponse) XXX_Marshal 

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

func (*QueryUserUnbondingResponse) XXX_Merge 

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

func (*QueryUserUnbondingResponse) XXX_Size 

func (m *QueryUserUnbondingResponse) XXX_Size() int

func (*QueryUserUnbondingResponse) XXX_Unmarshal 

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

type RebalanceValidatorsResponse 

type RebalanceValidatorsResponse struct {
}

RebalanceValidatorsResponse define the MsgRebalanceValidators response type.

func (*RebalanceValidatorsResponse) Descriptor 

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

func (*RebalanceValidatorsResponse) Marshal 

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

func (*RebalanceValidatorsResponse) MarshalTo 

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

func (*RebalanceValidatorsResponse) MarshalToSizedBuffer 

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

func (*RebalanceValidatorsResponse) ProtoMessage 

func (*RebalanceValidatorsResponse) ProtoMessage()

func (*RebalanceValidatorsResponse) Reset 

func (m *RebalanceValidatorsResponse) Reset()

func (*RebalanceValidatorsResponse) Size 

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

func (*RebalanceValidatorsResponse) String 

func (m *RebalanceValidatorsResponse) String() string

func (*RebalanceValidatorsResponse) Unmarshal 

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

func (*RebalanceValidatorsResponse) XXX_DiscardUnknown 

func (m *RebalanceValidatorsResponse) XXX_DiscardUnknown()

func (*RebalanceValidatorsResponse) XXX_Marshal 

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

func (*RebalanceValidatorsResponse) XXX_Merge 

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

func (*RebalanceValidatorsResponse) XXX_Size 

func (m *RebalanceValidatorsResponse) XXX_Size() int

func (*RebalanceValidatorsResponse) XXX_Unmarshal 

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

type SetWithdrawMessageArgs 

type SetWithdrawMessageArgs struct {
	ChainID string `protobuf:"bytes,1,opt,name=chainID,proto3" json:"chainID,omitempty"`
}

func (*SetWithdrawMessageArgs) Descriptor 

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

func (*SetWithdrawMessageArgs) GetChainID 

func (m *SetWithdrawMessageArgs) GetChainID() string

func (*SetWithdrawMessageArgs) Marshal 

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

func (*SetWithdrawMessageArgs) MarshalTo 

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

func (*SetWithdrawMessageArgs) MarshalToSizedBuffer 

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

func (*SetWithdrawMessageArgs) ProtoMessage 

func (*SetWithdrawMessageArgs) ProtoMessage()

func (*SetWithdrawMessageArgs) Reset 

func (m *SetWithdrawMessageArgs) Reset()

func (*SetWithdrawMessageArgs) Size 

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

func (*SetWithdrawMessageArgs) String 

func (m *SetWithdrawMessageArgs) String() string

func (*SetWithdrawMessageArgs) Unmarshal 

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

func (*SetWithdrawMessageArgs) XXX_DiscardUnknown 

func (m *SetWithdrawMessageArgs) XXX_DiscardUnknown()

func (*SetWithdrawMessageArgs) XXX_Marshal 

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

func (*SetWithdrawMessageArgs) XXX_Merge 

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

func (*SetWithdrawMessageArgs) XXX_Size 

func (m *SetWithdrawMessageArgs) XXX_Size() int

func (*SetWithdrawMessageArgs) XXX_Unmarshal 

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

type SourceChain 

type SourceChain struct {
	// The chain id of source chain.
	ChainID string `protobuf:"bytes,1,opt,name=chainID,proto3" json:"chainID,omitempty"`
	// ibc connection id
	ConnectionID string `protobuf:"bytes,2,opt,name=connectionID,proto3" json:"connectionID,omitempty"`
	// ibc transfer channel id
	TransferChannelID string `protobuf:"bytes,3,opt,name=transferChannelID,proto3" json:"transferChannelID,omitempty"`
	// validator address prefix of source chain.
	Bech32ValidatorAddrPrefix string      `protobuf:"bytes,4,opt,name=bech32ValidatorAddrPrefix,proto3" json:"bech32ValidatorAddrPrefix,omitempty"`
	Validators                []Validator `protobuf:"bytes,5,rep,name=validators,proto3" json:"validators"`
	// The address of interchain account for withdraw POS reward
	WithdrawAddress string `protobuf:"bytes,6,opt,name=withdrawAddress,proto3" json:"withdrawAddress,omitempty"`
	// The address of for ecsrow user's token
	EcsrowAddress string `protobuf:"bytes,7,opt,name=ecsrowAddress,proto3" json:"ecsrowAddress,omitempty"`
	// The address of interchain account for delegation
	DelegateAddress string `protobuf:"bytes,8,opt,name=delegateAddress,proto3" json:"delegateAddress,omitempty"`
	// Redemption ratio in the current epoch
	Redemptionratio Dec `protobuf:"bytes,9,opt,name=redemptionratio,proto3,customtype=Dec" json:"redemptionratio"`
	// The denom of cross chain token.
	IbcDenom string `protobuf:"bytes,10,opt,name=ibcDenom,proto3" json:"ibcDenom,omitempty"`
	// The denom of source chain native token.
	NativeDenom string `protobuf:"bytes,11,opt,name=nativeDenom,proto3" json:"nativeDenom,omitempty"`
	// Derivative token denom generated after liquid stake
	DerivativeDenom string `protobuf:"bytes,12,opt,name=derivativeDenom,proto3" json:"derivativeDenom,omitempty"`
	// The amount of staked token.
	StakedAmount Int `protobuf:"bytes,13,opt,name=stakedAmount,proto3,customtype=Int" json:"stakedAmount"`
}

func (SourceChain) AllocateTokenForValidator 

func (s SourceChain) AllocateTokenForValidator(amount math.Int) Validators

func (SourceChain) BasicVerify 

func (s SourceChain) BasicVerify() error

BasicVerify verify SouceChain parameters

func (*SourceChain) Descriptor 

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

func (*SourceChain) GenerateAccounts 

func (s *SourceChain) GenerateAccounts(ctx sdk.Context) (accounts []*authtypes.ModuleAccount)

GenerateAccounts generate the WithdrawAddress/DelegateAddress/UnboudAddress for source chain

func (*SourceChain) GenerateIBCDeonm 

func (s *SourceChain) GenerateIBCDeonm() error

func (*SourceChain) GetBech32ValidatorAddrPrefix 

func (m *SourceChain) GetBech32ValidatorAddrPrefix() string

func (*SourceChain) GetChainID 

func (m *SourceChain) GetChainID() string

func (*SourceChain) GetConnectionID 

func (m *SourceChain) GetConnectionID() string

func (*SourceChain) GetDelegateAddress 

func (m *SourceChain) GetDelegateAddress() string

func (*SourceChain) GetDerivativeDenom 

func (m *SourceChain) GetDerivativeDenom() string

func (*SourceChain) GetEcsrowAddress 

func (m *SourceChain) GetEcsrowAddress() string

func (*SourceChain) GetIbcDenom 

func (m *SourceChain) GetIbcDenom() string

func (*SourceChain) GetNativeDenom 

func (m *SourceChain) GetNativeDenom() string

func (*SourceChain) GetTransferChannelID 

func (m *SourceChain) GetTransferChannelID() string

func (*SourceChain) GetValidators 

func (m *SourceChain) GetValidators() []Validator

func (*SourceChain) GetWithdrawAddress 

func (m *SourceChain) GetWithdrawAddress() string

func (*SourceChain) Marshal 

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

func (*SourceChain) MarshalTo 

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

func (*SourceChain) MarshalToSizedBuffer 

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

func (*SourceChain) ProtoMessage 

func (*SourceChain) ProtoMessage()

func (*SourceChain) Reset 

func (m *SourceChain) Reset()

func (*SourceChain) Size 

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

func (*SourceChain) String 

func (m *SourceChain) String() string

func (*SourceChain) Unmarshal 

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

func (*SourceChain) UpdateWithDelegatedValidators 

func (s *SourceChain) UpdateWithDelegatedValidators(vals []Validator)

func (*SourceChain) UpdateWithUnbondingValidators 

func (s *SourceChain) UpdateWithUnbondingValidators(vals []Validator)

func (SourceChain) ValidatorsAddress 

func (s SourceChain) ValidatorsAddress() string

func (SourceChain) ValidatorsWeight 

func (s SourceChain) ValidatorsWeight() string

func (*SourceChain) XXX_DiscardUnknown 

func (m *SourceChain) XXX_DiscardUnknown()

func (*SourceChain) XXX_Marshal 

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

func (*SourceChain) XXX_Merge 

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

func (*SourceChain) XXX_Size 

func (m *SourceChain) XXX_Size() int

func (*SourceChain) XXX_Unmarshal 

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

type TransferRewardCallbackArgs 

type TransferRewardCallbackArgs struct {
	ChainID string `protobuf:"bytes,3,opt,name=chainID,proto3" json:"chainID,omitempty"`
	Amount  Int    `protobuf:"bytes,2,opt,name=amount,proto3,customtype=Int" json:"amount"`
}

func (*TransferRewardCallbackArgs) Descriptor 

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

func (*TransferRewardCallbackArgs) GetChainID 

func (m *TransferRewardCallbackArgs) GetChainID() string

func (*TransferRewardCallbackArgs) Marshal 

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

func (*TransferRewardCallbackArgs) MarshalTo 

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

func (*TransferRewardCallbackArgs) MarshalToSizedBuffer 

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

func (*TransferRewardCallbackArgs) ProtoMessage 

func (*TransferRewardCallbackArgs) ProtoMessage()

func (*TransferRewardCallbackArgs) Reset 

func (m *TransferRewardCallbackArgs) Reset()

func (*TransferRewardCallbackArgs) Size 

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

func (*TransferRewardCallbackArgs) String 

func (m *TransferRewardCallbackArgs) String() string

func (*TransferRewardCallbackArgs) Unmarshal 

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

func (*TransferRewardCallbackArgs) XXX_DiscardUnknown 

func (m *TransferRewardCallbackArgs) XXX_DiscardUnknown()

func (*TransferRewardCallbackArgs) XXX_Marshal 

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

func (*TransferRewardCallbackArgs) XXX_Merge 

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

func (*TransferRewardCallbackArgs) XXX_Size 

func (m *TransferRewardCallbackArgs) XXX_Size() int

func (*TransferRewardCallbackArgs) XXX_Unmarshal 

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

type UnbondCallbackArgs 

type UnbondCallbackArgs struct {
	// Validators with unbond funds
	Validators []Validator `protobuf:"bytes,1,rep,name=validators,proto3" json:"validators"`
	// unbond epoch
	Epoch uint64 `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	// unbond chain ID
	ChainID string `protobuf:"bytes,3,opt,name=chainID,proto3" json:"chainID,omitempty"`
}

func (*UnbondCallbackArgs) Descriptor 

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

func (*UnbondCallbackArgs) GetChainID 

func (m *UnbondCallbackArgs) GetChainID() string

func (*UnbondCallbackArgs) GetEpoch 

func (m *UnbondCallbackArgs) GetEpoch() uint64

func (*UnbondCallbackArgs) GetValidators 

func (m *UnbondCallbackArgs) GetValidators() []Validator

func (*UnbondCallbackArgs) Marshal 

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

func (*UnbondCallbackArgs) MarshalTo 

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

func (*UnbondCallbackArgs) MarshalToSizedBuffer 

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

func (*UnbondCallbackArgs) ProtoMessage 

func (*UnbondCallbackArgs) ProtoMessage()

func (*UnbondCallbackArgs) Reset 

func (m *UnbondCallbackArgs) Reset()

func (*UnbondCallbackArgs) Size 

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

func (*UnbondCallbackArgs) String 

func (m *UnbondCallbackArgs) String() string

func (*UnbondCallbackArgs) Unmarshal 

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

func (*UnbondCallbackArgs) XXX_DiscardUnknown 

func (m *UnbondCallbackArgs) XXX_DiscardUnknown()

func (*UnbondCallbackArgs) XXX_Marshal 

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

func (*UnbondCallbackArgs) XXX_Merge 

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

func (*UnbondCallbackArgs) XXX_Size 

func (m *UnbondCallbackArgs) XXX_Size() int

func (*UnbondCallbackArgs) XXX_Unmarshal 

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

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) Claim 

func (*UnimplementedMsgServer) Claim(ctx context.Context, req *MsgClaim) (*MsgClaimResponse, error)

func (*UnimplementedMsgServer) Delegate 

func (*UnimplementedMsgServer) Delegate(ctx context.Context, req *MsgDelegate) (*MsgDelegateResponse, error)

func (*UnimplementedMsgServer) EditValidators 

func (*UnimplementedMsgServer) EditValidators(ctx context.Context, req *MsgEditVadlidators) (*MsgEditValidatorsResponse, error)

func (*UnimplementedMsgServer) RebalanceValidator 

func (*UnimplementedMsgServer) RebalanceValidator(ctx context.Context, req *MsgRebalanceValidators) (*RebalanceValidatorsResponse, error)

func (*UnimplementedMsgServer) RegisterSourceChain 

func (*UnimplementedMsgServer) RegisterSourceChain(ctx context.Context, req *MsgRegisterSourceChain) (*MsgRegisterSourceChainResponse, error)

func (*UnimplementedMsgServer) Reinvest 

func (*UnimplementedMsgServer) Reinvest(ctx context.Context, req *MsgReinvest) (*MsgReinvestResponse, error)

func (*UnimplementedMsgServer) Undelegate 

func (*UnimplementedMsgServer) Undelegate(ctx context.Context, req *MsgUndelegate) (*MsgUndelegateResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) EpochProxyUnbonding 

func (*UnimplementedQueryServer) EpochProxyUnbonding(ctx context.Context, req *QueryEpochProxyUnbondingRequest) (*QueryEpochProxyUnbondingResponse, error)

func (*UnimplementedQueryServer) ProxyDelegation 

func (*UnimplementedQueryServer) ProxyDelegation(ctx context.Context, req *QueryProxyDelegationRequest) (*QueryProxyDelegationResponse, error)

func (*UnimplementedQueryServer) SourceChain 

func (*UnimplementedQueryServer) SourceChain(ctx context.Context, req *QuerySourceChainRequest) (*QuerySourceChainResponse, error)

func (*UnimplementedQueryServer) UserUnbonding 

func (*UnimplementedQueryServer) UserUnbonding(ctx context.Context, req *QueryUserUnbondingRequest) (*QueryUserUnbondingResponse, error)

type UserUnbonding 

type UserUnbonding struct {
	// Unique identifier for the undelegation record
	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// The chain ID of the source chain where the undelegation was initiated.
	ChainID string `protobuf:"bytes,2,opt,name=chainID,proto3" json:"chainID,omitempty"`
	// The epoch of the undelegation, used to record the time or timestamp of the undelegation
	Epoch uint64 `protobuf:"varint,3,opt,name=epoch,proto3" json:"epoch,omitempty"`
	// The delegator who canceled the delegation, i.e. the user who originally delegated
	Delegator string `protobuf:"bytes,4,opt,name=delegator,proto3" json:"delegator,omitempty"`
	// The recipient account for the redeemed funds.
	Receiver string `protobuf:"bytes,5,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// The amount and type of funds to be redeemed.
	RedeemCoin types.Coin `protobuf:"bytes,6,opt,name=redeemCoin,proto3" json:"redeemCoin"`
	// The redemption status of the undelegation.
	// 1) Pending: The undelegation request has been submitted but not yet processed or completed.
	// 2) Claimable: The undelegation has been processed and the funds are available to be claimed by the delegator.
	// 3) Complete: The funds have been successfully claimed by the delegator.
	CliamStatus UserUnbondingStatus `protobuf:"varint,7,opt,name=cliamStatus,proto3,customtype=UserUnbondingStatus" json:"cliamStatus"`
}

UndelegationRecord represents a record of a delegator's undelegation action.

func (*UserUnbonding) Descriptor 

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

func (*UserUnbonding) GetChainID 

func (m *UserUnbonding) GetChainID() string

func (*UserUnbonding) GetDelegator 

func (m *UserUnbonding) GetDelegator() string

func (*UserUnbonding) GetEpoch 

func (m *UserUnbonding) GetEpoch() uint64

func (*UserUnbonding) GetID 

func (m *UserUnbonding) GetID() string

func (*UserUnbonding) GetReceiver 

func (m *UserUnbonding) GetReceiver() string

func (*UserUnbonding) GetRedeemCoin 

func (m *UserUnbonding) GetRedeemCoin() types.Coin

func (*UserUnbonding) Marshal 

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

func (*UserUnbonding) MarshalTo 

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

func (*UserUnbonding) MarshalToSizedBuffer 

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

func (*UserUnbonding) ProtoMessage 

func (*UserUnbonding) ProtoMessage()

func (*UserUnbonding) Reset 

func (m *UserUnbonding) Reset()

func (*UserUnbonding) Size 

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

func (*UserUnbonding) String 

func (m *UserUnbonding) String() string

func (*UserUnbonding) Unmarshal 

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

func (*UserUnbonding) XXX_DiscardUnknown 

func (m *UserUnbonding) XXX_DiscardUnknown()

func (*UserUnbonding) XXX_Marshal 

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

func (*UserUnbonding) XXX_Merge 

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

func (*UserUnbonding) XXX_Size 

func (m *UserUnbonding) XXX_Size() int

func (*UserUnbonding) XXX_Unmarshal 

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

type UserUnbondingStatus 

type UserUnbondingStatus uint32

UndelegationRecord status 

const (
	UserUnbondingPending UserUnbondingStatus = iota
	UserUnbondingClaimable
	UserUnbondingComplete
)

type Validator 

type Validator struct {
	// The address of source chain validator account.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Total allocated amount.
	TokenAmount Int `protobuf:"bytes,2,opt,name=tokenAmount,proto3,customtype=Int" json:"tokenAmount"`
	// The weight used for distribute delegation funds.
	Weight uint64 `protobuf:"varint,3,opt,name=weight,proto3" json:"weight,omitempty"`
}

func (*Validator) Descriptor 

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

func (*Validator) Equal 

func (this *Validator) Equal(that interface{}) bool

func (*Validator) GetAddress 

func (m *Validator) GetAddress() string

func (*Validator) GetWeight 

func (m *Validator) GetWeight() uint64

func (*Validator) Marshal 

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

func (*Validator) MarshalTo 

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

func (*Validator) MarshalToSizedBuffer 

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

func (*Validator) ProtoMessage 

func (*Validator) ProtoMessage()

func (*Validator) Reset 

func (m *Validator) Reset()

func (*Validator) Size 

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

func (*Validator) String 

func (m *Validator) String() string

func (*Validator) Unmarshal 

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

func (*Validator) XXX_DiscardUnknown 

func (m *Validator) XXX_DiscardUnknown()

func (*Validator) XXX_Marshal 

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

func (*Validator) XXX_Merge 

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

func (*Validator) XXX_Size 

func (m *Validator) XXX_Size() int

func (*Validator) XXX_Unmarshal 

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

type ValidatorFund 

type ValidatorFund struct {
	Address string
	Amount  math.Int
}

type Validators 

type Validators struct {
	Validators []Validator `protobuf:"bytes,1,rep,name=validators,proto3" json:"validators"`
}

func (*Validators) Descriptor 

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

func (*Validators) GetValidators 

func (m *Validators) GetValidators() []Validator

func (*Validators) Marshal 

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

func (*Validators) MarshalTo 

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

func (*Validators) MarshalToSizedBuffer 

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

func (*Validators) ProtoMessage 

func (*Validators) ProtoMessage()

func (*Validators) Reset 

func (m *Validators) Reset()

func (*Validators) Size 

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

func (*Validators) String 

func (m *Validators) String() string

func (*Validators) Unmarshal 

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

func (*Validators) XXX_DiscardUnknown 

func (m *Validators) XXX_DiscardUnknown()

func (*Validators) XXX_Marshal 

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

func (*Validators) XXX_Merge 

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

func (*Validators) XXX_Size 

func (m *Validators) XXX_Size() int

func (*Validators) XXX_Unmarshal 

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

type WithdrawDelegateRewardCallbackArgs 

type WithdrawDelegateRewardCallbackArgs struct {
	ChainID string `protobuf:"bytes,1,opt,name=chainID,proto3" json:"chainID,omitempty"`
}

func (*WithdrawDelegateRewardCallbackArgs) Descriptor 

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

func (*WithdrawDelegateRewardCallbackArgs) GetChainID 

func (m *WithdrawDelegateRewardCallbackArgs) GetChainID() string

func (*WithdrawDelegateRewardCallbackArgs) Marshal 

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

func (*WithdrawDelegateRewardCallbackArgs) MarshalTo 

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

func (*WithdrawDelegateRewardCallbackArgs) MarshalToSizedBuffer 

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

func (*WithdrawDelegateRewardCallbackArgs) ProtoMessage 

func (*WithdrawDelegateRewardCallbackArgs) ProtoMessage()

func (*WithdrawDelegateRewardCallbackArgs) Reset 

func (m *WithdrawDelegateRewardCallbackArgs) Reset()

func (*WithdrawDelegateRewardCallbackArgs) Size 

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

func (*WithdrawDelegateRewardCallbackArgs) String 

func (m *WithdrawDelegateRewardCallbackArgs) String() string

func (*WithdrawDelegateRewardCallbackArgs) Unmarshal 

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

func (*WithdrawDelegateRewardCallbackArgs) XXX_DiscardUnknown 

func (m *WithdrawDelegateRewardCallbackArgs) XXX_DiscardUnknown()

func (*WithdrawDelegateRewardCallbackArgs) XXX_Marshal 

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

func (*WithdrawDelegateRewardCallbackArgs) XXX_Merge 

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

func (*WithdrawDelegateRewardCallbackArgs) XXX_Size 

func (m *WithdrawDelegateRewardCallbackArgs) XXX_Size() int

func (*WithdrawDelegateRewardCallbackArgs) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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