types

package
v7.1.0 Latest Latest
Warning

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

 Go to latest Published: Aug 12, 2024 License: LGPL-3.0 Imports: 31 Imported by: 0

Documentation

Overview

nolint

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypeSwap            = "swap"
	EventTypeAddLiquidity    = "add_liquidity"
	EventTypeRemoveLiquidity = "remove_liquidity"

	AttributeValueCategory = ModuleName

	AttributeValueAmount     = "amount"
	AttributeValueSender     = "sender"
	AttributeValueRecipient  = "recipient"
	AttributeValueIsBuyOrder = "is_buy_order"
	AttributeValueTokenPair  = "token_pair"
)

coinswap module event types

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

	// RouterKey is the message route for the coinswap module.
	RouterKey = ModuleName

	// StoreKey is the default store key for the coinswap module.
	StoreKey = ModuleName

	// QuerierRoute is the querier route for the coinswap module.
	QuerierRoute = StoreKey

	// KeyNextPoolSequence is the key used to store the next pool sequence in
	// the keeper.
	KeyNextPoolSequence = "nextPoolSequence"

	// KeyPool is the key used to store the pool information  in
	// the keeper.
	KeyPool = "pool"

	// KeyPoolLptDenom is the key used to store the pool information  in
	// the keeper.
	KeyPoolLptDenom = "lptDenom"
)
View Source 
const (
	// LptTokenPrefix defines the prefix of liquidity token
	LptTokenPrefix = "lpt"
	// LptTokenFormat defines the name of liquidity token
	LptTokenFormat = "lpt-%d"

	// TypeMsgAddLiquidity defines the type of MsgAddLiquidity
	TypeMsgAddLiquidity = "add_liquidity"
	// TypeMsgRemoveLiquidity defines the type of MsgRemoveLiquidity
	TypeMsgRemoveLiquidity = "remove_liquidity"
	// TypeMsgSwapOrder defines the type of MsgSwapOrder
	TypeMsgSwapOrder = "swap_order"
)
View Source 
const (
	UsdcIBCDenom = "ibc/17CD484EE7D9723B847D95015FA3EBD1572FD13BC84FB838F55B18A57450F25B"
	UsdtIBCDenom = "ibc/4F6A2DEFEA52CD8D90966ADCB2BD0593D3993AB0DF7F6AEB3EFD6167D79237B0"
	EthIBCDenom  = "ibc/DC186CA7A8C009B43774EBDC825C935CABA9743504CE6037507E6E5CCE12858A"
)
View Source 
const (
	// QueryPool is the liquidity query endpoint supported by the coinswap querier
	QueryPool = "pool"
	// QueryPools is the liquidity query endpoint supported by the coinswap querier
	QueryPools = "pools"
)

Variables

View Source 
var (
	ErrInvalidLengthCoinswap        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCoinswap          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCoinswap = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrReservePoolNotExists    = sdkerrors.Register(ModuleName, 2, "reserve pool not exists")
	ErrEqualDenom              = sdkerrors.Register(ModuleName, 3, "input and output denomination are equal")
	ErrNotContainStandardDenom = sdkerrors.Register(ModuleName, 4, "must have one standard denom")
	ErrMustStandardDenom       = sdkerrors.Register(ModuleName, 5, "must be standard denom")
	ErrInvalidDenom            = sdkerrors.Register(ModuleName, 6, "invalid denom")
	ErrInvalidDeadline         = sdkerrors.Register(ModuleName, 7, "invalid deadline")
	ErrConstraintNotMet        = sdkerrors.Register(ModuleName, 8, "constraint not met")
	ErrInsufficientFunds       = sdkerrors.Register(ModuleName, 9, "insufficient funds")
	ErrMaxedStandardDenom      = sdkerrors.Register(ModuleName, 10, "standard denom amount exceed max list")
)

coinswap module sentinel errors

View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	KeyFee                    = []byte("Fee")                    // fee key
	KeyPoolCreationFee        = []byte("PoolCreationFee")        // fee key
	KeyTaxRate                = []byte("TaxRate")                // fee key
	KeyStandardDenom          = []byte("StandardDenom")          // standard token denom key
	KeyMaxStandardCoinPerPool = []byte("MaxStandardCoinPerPool") // max standard coin amount per pool
	KeyMaxSwapAmount          = []byte("MaxSwapAmount")          // whitelisted denoms

	DefaultFee                    = sdk.NewDecWithPrec(0, 0)
	DefaultPoolCreationFee        = sdk.NewInt64Coin(sdk.DefaultBondDenom, 0)
	DefaultTaxRate                = sdk.NewDecWithPrec(0, 0)
	DefaultMaxStandardCoinPerPool = sdk.NewIntWithDecimal(10000, 18)
	DefaultMaxSwapAmount          = sdk.NewCoins(
		sdk.NewCoin(UsdcIBCDenom, sdk.NewIntWithDecimal(10, 6)),
		sdk.NewCoin(UsdtIBCDenom, sdk.NewIntWithDecimal(10, 6)),
		sdk.NewCoin(EthIBCDenom, sdk.NewIntWithDecimal(1, 16)),
	)
)

Parameter store keys

View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)

Functions

func GetLptDenom 

func GetLptDenom(sequence uint64) string

GetLptDenom returns the pool coin denom by specified sequence.

func GetLptDenomKey 

func GetLptDenomKey(lptDenom string) []byte

GetLptDenomKey return the stored pool key for the given liquidity pool token denom.

func GetPoolId 

func GetPoolId(counterpartyDenom string) string

GetPoolId returns the pool coin denom by specified sequence.

func GetPoolKey 

func GetPoolKey(pooId string) []byte

GetPoolKey return the stored pool key for the given pooId.

func GetReservePoolAddr 

func GetReservePoolAddr(lptDenom string) sdk.AccAddress

GetReservePoolAddr returns the pool address for the provided liquidity denomination.

func GetTokenPairByDenom 

func GetTokenPairByDenom(inputDenom, outputDenom string) string

GetTokenPairByDenom returns the token pair for the provided denominations

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable returns the TypeTable for coinswap module

func ParseLptDenom 

func ParseLptDenom(lptDenom string) (uint64, error)

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec registers concrete types on the codec.

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 (such as grpc.SendHeader, etc) to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func ValidateDeadline 

func ValidateDeadline(deadline int64) error

ValidateDeadline verifies whether the given deadline is legal

func ValidateExactStandardAmt 

func ValidateExactStandardAmt(standardAmt sdk.Int) error

ValidateExactStandardAmt verifies whether the standard token amount is legal

func ValidateGenesis 

func ValidateGenesis(data GenesisState) error

ValidateGenesis validates the given genesis state

func ValidateInput 

func ValidateInput(input Input) error

ValidateInput verifies whether the given input is legal

func ValidateLptDenom 

func ValidateLptDenom(lptDenom string) error

ValidateLptDenom returns nil if the Liquidity pool token denom is valid

func ValidateMaxToken 

func ValidateMaxToken(maxToken sdk.Coin) error

ValidateMaxToken verifies whether the maximum token is legal

func ValidateMinLiquidity 

func ValidateMinLiquidity(minLiquidity sdk.Int) error

ValidateMinLiquidity verifies whether the minimum liquidity is legal

func ValidateMinStandardAmt 

func ValidateMinStandardAmt(minStandardAmt sdk.Int) error

ValidateMinStandardAmt verifies whether the minimum standard amount is legal

func ValidateMinToken 

func ValidateMinToken(minToken sdk.Int) error

ValidateMinToken verifies whether the minimum token amount is legal

func ValidateOutput 

func ValidateOutput(output Output) error

ValidateOutput verifies whether the given output is legal

func ValidateWithdrawLiquidity 

func ValidateWithdrawLiquidity(liquidity sdk.Coin) error

ValidateWithdrawLiquidity verifies whether the given liquidity is legal

Types

type AccountKeeper 

type AccountKeeper interface {
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
	GetModuleAddress(name string) sdk.AccAddress
	IterateAccounts(ctx sdk.Context, cb func(account authtypes.AccountI) (stop bool))
}

AccountKeeper defines the expected account keeper

type BankKeeper 

type BankKeeper interface {
	SendCoins(ctx sdk.Context, fromAddr sdk.AccAddress, toAddr sdk.AccAddress, amt sdk.Coins) error
	GetAllBalances(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	GetBalance(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin

	GetSupply(ctx sdk.Context, denom string) sdk.Coin
	IterateTotalSupply(ctx sdk.Context, cb func(sdk.Coin) bool)
	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
	SendCoinsFromModuleToModule(ctx sdk.Context, senderModule, recipientModule string, amt sdk.Coins) error
	BurnCoins(ctx sdk.Context, name string, amt sdk.Coins) error
	MintCoins(ctx sdk.Context, name string, amt sdk.Coins) error
	SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
}

BankKeeper defines the expected bank keeper

type GenesisState 

type GenesisState struct {
	Params        Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	StandardDenom string `protobuf:"bytes,2,opt,name=standard_denom,json=standardDenom,proto3" json:"standard_denom,omitempty" yaml:"standard_denom"`
	Pool          []Pool `protobuf:"bytes,3,rep,name=pool,proto3" json:"pool"`
	Sequence      uint64 `protobuf:"varint,4,opt,name=sequence,proto3" json:"sequence,omitempty"`
}

GenesisState defines the coinswap module's genesis state

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

DefaultGenesisState creates a default GenesisState object

func NewGenesisState 

func NewGenesisState(params Params, denom string) *GenesisState

NewGenesisState is the constructor function for GenesisState

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetPool 

func (m *GenesisState) GetPool() []Pool

func (*GenesisState) GetSequence 

func (m *GenesisState) GetSequence() uint64

func (*GenesisState) GetStandardDenom 

func (m *GenesisState) GetStandardDenom() string

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type Input 

type Input struct {
	Address string     `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Coin    types.Coin `protobuf:"bytes,2,opt,name=coin,proto3" json:"coin"`
}

Input defines the properties of order's input

func (*Input) Descriptor 

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

func (*Input) Marshal 

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

func (*Input) MarshalTo 

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

func (*Input) MarshalToSizedBuffer 

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

func (*Input) ProtoMessage 

func (*Input) ProtoMessage()

func (*Input) Reset 

func (m *Input) Reset()

func (*Input) Size 

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

func (*Input) String 

func (m *Input) String() string

func (*Input) Unmarshal 

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

func (*Input) XXX_DiscardUnknown 

func (m *Input) XXX_DiscardUnknown()

func (*Input) XXX_Marshal 

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

func (*Input) XXX_Merge 

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

func (*Input) XXX_Size 

func (m *Input) XXX_Size() int

func (*Input) XXX_Unmarshal 

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

type MsgAddLiquidity 

type MsgAddLiquidity struct {
	MaxToken         types.Coin                             `protobuf:"bytes,1,opt,name=max_token,json=maxToken,proto3" json:"max_token" yaml:"max_token"`
	ExactStandardAmt github_com_cosmos_cosmos_sdk_types.Int `` /* 177-byte string literal not displayed */
	MinLiquidity     github_com_cosmos_cosmos_sdk_types.Int `` /* 158-byte string literal not displayed */
	Deadline         int64                                  `protobuf:"varint,4,opt,name=deadline,proto3" json:"deadline,omitempty"`
	Sender           string                                 `protobuf:"bytes,5,opt,name=sender,proto3" json:"sender,omitempty"`
}

MsgAddLiquidity defines a msg for adding liquidity to a reserve pool

func NewMsgAddLiquidity 

func NewMsgAddLiquidity(
	maxToken sdk.Coin,
	exactStandardAmt sdk.Int,
	minLiquidity sdk.Int,
	deadline int64,
	sender string,
) *MsgAddLiquidity

NewMsgAddLiquidity creates a new MsgAddLiquidity object.

func (*MsgAddLiquidity) Descriptor 

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

func (MsgAddLiquidity) GetSignBytes 

func (msg MsgAddLiquidity) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgAddLiquidity) GetSigners 

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

GetSigners implements Msg.

func (*MsgAddLiquidity) Marshal 

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

func (*MsgAddLiquidity) MarshalTo 

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

func (*MsgAddLiquidity) MarshalToSizedBuffer 

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

func (*MsgAddLiquidity) ProtoMessage 

func (*MsgAddLiquidity) ProtoMessage()

func (*MsgAddLiquidity) Reset 

func (m *MsgAddLiquidity) Reset()

func (MsgAddLiquidity) Route 

func (msg MsgAddLiquidity) Route() string

Route implements Msg.

func (*MsgAddLiquidity) Size 

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

func (*MsgAddLiquidity) String 

func (m *MsgAddLiquidity) String() string

func (MsgAddLiquidity) Type 

func (msg MsgAddLiquidity) Type() string

Type implements Msg.

func (*MsgAddLiquidity) Unmarshal 

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

func (MsgAddLiquidity) ValidateBasic 

func (msg MsgAddLiquidity) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgAddLiquidity) XXX_DiscardUnknown 

func (m *MsgAddLiquidity) XXX_DiscardUnknown()

func (*MsgAddLiquidity) XXX_Marshal 

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

func (*MsgAddLiquidity) XXX_Merge 

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

func (*MsgAddLiquidity) XXX_Size 

func (m *MsgAddLiquidity) XXX_Size() int

func (*MsgAddLiquidity) XXX_Unmarshal 

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

type MsgAddLiquidityResponse 

type MsgAddLiquidityResponse struct {
	MintToken *types.Coin `protobuf:"bytes,1,opt,name=mint_token,json=mintToken,proto3" json:"mint_token,omitempty"`
}

MsgAddLiquidityResponse defines the Msg/AddLiquidity response type

func (*MsgAddLiquidityResponse) Descriptor 

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

func (*MsgAddLiquidityResponse) Marshal 

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

func (*MsgAddLiquidityResponse) MarshalTo 

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

func (*MsgAddLiquidityResponse) MarshalToSizedBuffer 

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

func (*MsgAddLiquidityResponse) ProtoMessage 

func (*MsgAddLiquidityResponse) ProtoMessage()

func (*MsgAddLiquidityResponse) Reset 

func (m *MsgAddLiquidityResponse) Reset()

func (*MsgAddLiquidityResponse) Size 

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

func (*MsgAddLiquidityResponse) String 

func (m *MsgAddLiquidityResponse) String() string

func (*MsgAddLiquidityResponse) Unmarshal 

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

func (*MsgAddLiquidityResponse) XXX_DiscardUnknown 

func (m *MsgAddLiquidityResponse) XXX_DiscardUnknown()

func (*MsgAddLiquidityResponse) XXX_Marshal 

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

func (*MsgAddLiquidityResponse) XXX_Merge 

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

func (*MsgAddLiquidityResponse) XXX_Size 

func (m *MsgAddLiquidityResponse) XXX_Size() int

func (*MsgAddLiquidityResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// AddLiquidity defines a method for depositing some tokens to the liquidity
	// pool
	AddLiquidity(ctx context.Context, in *MsgAddLiquidity, opts ...grpc.CallOption) (*MsgAddLiquidityResponse, error)
	// RemoveLiquidity defines a method for withdraw some tokens from the
	// liquidity pool
	RemoveLiquidity(ctx context.Context, in *MsgRemoveLiquidity, opts ...grpc.CallOption) (*MsgRemoveLiquidityResponse, error)
	// SwapCoin defines a method for swapping a token with the other token from
	// the liquidity pool
	SwapCoin(ctx context.Context, in *MsgSwapOrder, opts ...grpc.CallOption) (*MsgSwapCoinResponse, 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 MsgRemoveLiquidity 

type MsgRemoveLiquidity struct {
	WithdrawLiquidity types.Coin                             `` /* 128-byte string literal not displayed */
	MinToken          github_com_cosmos_cosmos_sdk_types.Int `` /* 142-byte string literal not displayed */
	MinStandardAmt    github_com_cosmos_cosmos_sdk_types.Int `` /* 169-byte string literal not displayed */
	Deadline          int64                                  `protobuf:"varint,4,opt,name=deadline,proto3" json:"deadline,omitempty"`
	Sender            string                                 `protobuf:"bytes,5,opt,name=sender,proto3" json:"sender,omitempty"`
}

MsgRemoveLiquidity defines a msg for removing liquidity from a reserve pool

func NewMsgRemoveLiquidity 

func NewMsgRemoveLiquidity(
	minToken sdk.Int,
	withdrawLiquidity sdk.Coin,
	minStandardAmt sdk.Int,
	deadline int64,
	sender string,
) *MsgRemoveLiquidity

NewMsgRemoveLiquidity creates a new MsgRemoveLiquidity object

func (*MsgRemoveLiquidity) Descriptor 

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

func (MsgRemoveLiquidity) GetSignBytes 

func (msg MsgRemoveLiquidity) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgRemoveLiquidity) GetSigners 

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

GetSigners implements Msg.

func (*MsgRemoveLiquidity) Marshal 

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

func (*MsgRemoveLiquidity) MarshalTo 

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

func (*MsgRemoveLiquidity) MarshalToSizedBuffer 

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

func (*MsgRemoveLiquidity) ProtoMessage 

func (*MsgRemoveLiquidity) ProtoMessage()

func (*MsgRemoveLiquidity) Reset 

func (m *MsgRemoveLiquidity) Reset()

func (MsgRemoveLiquidity) Route 

func (msg MsgRemoveLiquidity) Route() string

Route implements Msg.

func (*MsgRemoveLiquidity) Size 

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

func (*MsgRemoveLiquidity) String 

func (m *MsgRemoveLiquidity) String() string

func (MsgRemoveLiquidity) Type 

func (msg MsgRemoveLiquidity) Type() string

Type implements Msg.

func (*MsgRemoveLiquidity) Unmarshal 

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

func (MsgRemoveLiquidity) ValidateBasic 

func (msg MsgRemoveLiquidity) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgRemoveLiquidity) XXX_DiscardUnknown 

func (m *MsgRemoveLiquidity) XXX_DiscardUnknown()

func (*MsgRemoveLiquidity) XXX_Marshal 

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

func (*MsgRemoveLiquidity) XXX_Merge 

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

func (*MsgRemoveLiquidity) XXX_Size 

func (m *MsgRemoveLiquidity) XXX_Size() int

func (*MsgRemoveLiquidity) XXX_Unmarshal 

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

type MsgRemoveLiquidityResponse 

type MsgRemoveLiquidityResponse struct {
	WithdrawCoins []*types.Coin `protobuf:"bytes,1,rep,name=withdraw_coins,json=withdrawCoins,proto3" json:"withdraw_coins,omitempty"`
}

MsgRemoveLiquidityResponse defines the Msg/RemoveLiquidity response type

func (*MsgRemoveLiquidityResponse) Descriptor 

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

func (*MsgRemoveLiquidityResponse) Marshal 

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

func (*MsgRemoveLiquidityResponse) MarshalTo 

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

func (*MsgRemoveLiquidityResponse) MarshalToSizedBuffer 

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

func (*MsgRemoveLiquidityResponse) ProtoMessage 

func (*MsgRemoveLiquidityResponse) ProtoMessage()

func (*MsgRemoveLiquidityResponse) Reset 

func (m *MsgRemoveLiquidityResponse) Reset()

func (*MsgRemoveLiquidityResponse) Size 

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

func (*MsgRemoveLiquidityResponse) String 

func (m *MsgRemoveLiquidityResponse) String() string

func (*MsgRemoveLiquidityResponse) Unmarshal 

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

func (*MsgRemoveLiquidityResponse) XXX_DiscardUnknown 

func (m *MsgRemoveLiquidityResponse) XXX_DiscardUnknown()

func (*MsgRemoveLiquidityResponse) XXX_Marshal 

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

func (*MsgRemoveLiquidityResponse) XXX_Merge 

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

func (*MsgRemoveLiquidityResponse) XXX_Size 

func (m *MsgRemoveLiquidityResponse) XXX_Size() int

func (*MsgRemoveLiquidityResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// AddLiquidity defines a method for depositing some tokens to the liquidity
	// pool
	AddLiquidity(context.Context, *MsgAddLiquidity) (*MsgAddLiquidityResponse, error)
	// RemoveLiquidity defines a method for withdraw some tokens from the
	// liquidity pool
	RemoveLiquidity(context.Context, *MsgRemoveLiquidity) (*MsgRemoveLiquidityResponse, error)
	// SwapCoin defines a method for swapping a token with the other token from
	// the liquidity pool
	SwapCoin(context.Context, *MsgSwapOrder) (*MsgSwapCoinResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSwapCoinResponse 

type MsgSwapCoinResponse struct {
}

MsgSwapCoinResponse defines the Msg/SwapCoin response type

func (*MsgSwapCoinResponse) Descriptor 

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

func (*MsgSwapCoinResponse) Marshal 

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

func (*MsgSwapCoinResponse) MarshalTo 

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

func (*MsgSwapCoinResponse) MarshalToSizedBuffer 

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

func (*MsgSwapCoinResponse) ProtoMessage 

func (*MsgSwapCoinResponse) ProtoMessage()

func (*MsgSwapCoinResponse) Reset 

func (m *MsgSwapCoinResponse) Reset()

func (*MsgSwapCoinResponse) Size 

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

func (*MsgSwapCoinResponse) String 

func (m *MsgSwapCoinResponse) String() string

func (*MsgSwapCoinResponse) Unmarshal 

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

func (*MsgSwapCoinResponse) XXX_DiscardUnknown 

func (m *MsgSwapCoinResponse) XXX_DiscardUnknown()

func (*MsgSwapCoinResponse) XXX_Marshal 

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

func (*MsgSwapCoinResponse) XXX_Merge 

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

func (*MsgSwapCoinResponse) XXX_Size 

func (m *MsgSwapCoinResponse) XXX_Size() int

func (*MsgSwapCoinResponse) XXX_Unmarshal 

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

type MsgSwapOrder 

type MsgSwapOrder struct {
	Input      Input  `protobuf:"bytes,1,opt,name=input,proto3" json:"input"`
	Output     Output `protobuf:"bytes,2,opt,name=output,proto3" json:"output"`
	Deadline   int64  `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"`
	IsBuyOrder bool   `protobuf:"varint,4,opt,name=is_buy_order,json=isBuyOrder,proto3" json:"is_buy_order,omitempty" yaml:"is_buy_order"`
}

MsgSwapOrder defines a msg for swap order

func NewMsgSwapOrder 

func NewMsgSwapOrder(
	input Input,
	output Output,
	deadline int64,
	isBuyOrder bool,
) *MsgSwapOrder

NewMsgSwapOrder creates a new MsgSwapOrder object.

func (*MsgSwapOrder) Descriptor 

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

func (MsgSwapOrder) GetSignBytes 

func (msg MsgSwapOrder) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgSwapOrder) GetSigners 

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

GetSigners implements Msg.

func (*MsgSwapOrder) Marshal 

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

func (*MsgSwapOrder) MarshalTo 

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

func (*MsgSwapOrder) MarshalToSizedBuffer 

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

func (*MsgSwapOrder) ProtoMessage 

func (*MsgSwapOrder) ProtoMessage()

func (*MsgSwapOrder) Reset 

func (m *MsgSwapOrder) Reset()

func (MsgSwapOrder) Route 

func (msg MsgSwapOrder) Route() string

Route implements Msg.

func (*MsgSwapOrder) Size 

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

func (*MsgSwapOrder) String 

func (m *MsgSwapOrder) String() string

func (MsgSwapOrder) Type 

func (msg MsgSwapOrder) Type() string

Type implements Msg.

func (*MsgSwapOrder) Unmarshal 

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

func (MsgSwapOrder) ValidateBasic 

func (msg MsgSwapOrder) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgSwapOrder) XXX_DiscardUnknown 

func (m *MsgSwapOrder) XXX_DiscardUnknown()

func (*MsgSwapOrder) XXX_Marshal 

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

func (*MsgSwapOrder) XXX_Merge 

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

func (*MsgSwapOrder) XXX_Size 

func (m *MsgSwapOrder) XXX_Size() int

func (*MsgSwapOrder) XXX_Unmarshal 

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

type Output 

type Output struct {
	Address string     `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Coin    types.Coin `protobuf:"bytes,2,opt,name=coin,proto3" json:"coin"`
}

Output defines the properties of order's output

func (*Output) Descriptor 

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

func (*Output) Marshal 

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

func (*Output) MarshalTo 

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

func (*Output) MarshalToSizedBuffer 

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

func (*Output) ProtoMessage 

func (*Output) ProtoMessage()

func (*Output) Reset 

func (m *Output) Reset()

func (*Output) Size 

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

func (*Output) String 

func (m *Output) String() string

func (*Output) Unmarshal 

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

func (*Output) XXX_DiscardUnknown 

func (m *Output) XXX_DiscardUnknown()

func (*Output) XXX_Marshal 

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

func (*Output) XXX_Merge 

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

func (*Output) XXX_Size 

func (m *Output) XXX_Size() int

func (*Output) XXX_Unmarshal 

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

type Params 

type Params struct {
	Fee                    github_com_cosmos_cosmos_sdk_types.Dec   `protobuf:"bytes,1,opt,name=fee,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"fee"`
	PoolCreationFee        types.Coin                               `protobuf:"bytes,2,opt,name=pool_creation_fee,json=poolCreationFee,proto3" json:"pool_creation_fee"`
	TaxRate                github_com_cosmos_cosmos_sdk_types.Dec   `protobuf:"bytes,3,opt,name=tax_rate,json=taxRate,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"tax_rate"`
	MaxStandardCoinPerPool github_com_cosmos_cosmos_sdk_types.Int   `` /* 173-byte string literal not displayed */
	MaxSwapAmount          github_com_cosmos_cosmos_sdk_types.Coins `` /* 146-byte string literal not displayed */
}

Params defines token module's parameters

func DefaultParams 

func DefaultParams() Params

DefaultParams returns the default coinswap module parameters

func NewParams 

func NewParams(fee, taxRate sdk.Dec, poolCreationFee sdk.Coin, maxStandardCoinPerPool sdk.Int, maxSwapAmount sdk.Coins) Params

NewParams is the coinswap params constructor

func (*Params) Descriptor 

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

func (*Params) Equal 

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

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

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

ParamSetPairs implements paramtypes.KeyValuePairs

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (Params) String 

func (p Params) String() string

String returns a human readable string representation of the parameters.

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

Validate returns err if Params is invalid

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type Pool 

type Pool struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// denom of base coin of the pool
	StandardDenom string `protobuf:"bytes,2,opt,name=standard_denom,json=standardDenom,proto3" json:"standard_denom,omitempty"`
	// denom of counterparty coin of the pool
	CounterpartyDenom string `protobuf:"bytes,3,opt,name=counterparty_denom,json=counterpartyDenom,proto3" json:"counterparty_denom,omitempty"`
	// escrow account for deposit tokens
	EscrowAddress string `protobuf:"bytes,4,opt,name=escrow_address,json=escrowAddress,proto3" json:"escrow_address,omitempty"`
	// denom of the liquidity pool coin
	LptDenom string `protobuf:"bytes,5,opt,name=lpt_denom,json=lptDenom,proto3" json:"lpt_denom,omitempty"`
}

func (*Pool) Descriptor 

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

func (*Pool) Marshal 

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

func (*Pool) MarshalTo 

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

func (*Pool) MarshalToSizedBuffer 

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

func (*Pool) ProtoMessage 

func (*Pool) ProtoMessage()

func (*Pool) Reset 

func (m *Pool) Reset()

func (*Pool) Size 

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

func (*Pool) String 

func (m *Pool) String() string

func (*Pool) Unmarshal 

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

func (*Pool) XXX_DiscardUnknown 

func (m *Pool) XXX_DiscardUnknown()

func (*Pool) XXX_Marshal 

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

func (*Pool) XXX_Merge 

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

func (*Pool) XXX_Size 

func (m *Pool) XXX_Size() int

func (*Pool) XXX_Unmarshal 

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

type PoolInfo 

type PoolInfo struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// escrow account for deposit tokens
	EscrowAddress string `protobuf:"bytes,2,opt,name=escrow_address,json=escrowAddress,proto3" json:"escrow_address,omitempty"`
	// main token balance
	Standard types.Coin `protobuf:"bytes,3,opt,name=standard,proto3" json:"standard"`
	// counterparty token balance
	Token types.Coin `protobuf:"bytes,4,opt,name=token,proto3" json:"token"`
	// liquidity token balance
	Lpt types.Coin `protobuf:"bytes,5,opt,name=lpt,proto3" json:"lpt"`
	// liquidity pool fee
	Fee string `protobuf:"bytes,6,opt,name=fee,proto3" json:"fee,omitempty"`
}

func (*PoolInfo) Descriptor 

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

func (*PoolInfo) GetEscrowAddress 

func (m *PoolInfo) GetEscrowAddress() string

func (*PoolInfo) GetFee 

func (m *PoolInfo) GetFee() string

func (*PoolInfo) GetId 

func (m *PoolInfo) GetId() string

func (*PoolInfo) GetLpt 

func (m *PoolInfo) GetLpt() types.Coin

func (*PoolInfo) GetStandard 

func (m *PoolInfo) GetStandard() types.Coin

func (*PoolInfo) GetToken 

func (m *PoolInfo) GetToken() types.Coin

func (*PoolInfo) Marshal 

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

func (*PoolInfo) MarshalTo 

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

func (*PoolInfo) MarshalToSizedBuffer 

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

func (*PoolInfo) ProtoMessage 

func (*PoolInfo) ProtoMessage()

func (*PoolInfo) Reset 

func (m *PoolInfo) Reset()

func (*PoolInfo) Size 

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

func (*PoolInfo) String 

func (m *PoolInfo) String() string

func (*PoolInfo) Unmarshal 

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

func (*PoolInfo) XXX_DiscardUnknown 

func (m *PoolInfo) XXX_DiscardUnknown()

func (*PoolInfo) XXX_Marshal 

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

func (*PoolInfo) XXX_Merge 

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

func (*PoolInfo) XXX_Size 

func (m *PoolInfo) XXX_Size() int

func (*PoolInfo) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Params returns parameters of the module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// LiquidityPool returns the liquidity pool for the provided
	// lpt_denom
	LiquidityPool(ctx context.Context, in *QueryLiquidityPoolRequest, opts ...grpc.CallOption) (*QueryLiquidityPoolResponse, error)
	// LiquidityPools returns all the liquidity pools available
	LiquidityPools(ctx context.Context, in *QueryLiquidityPoolsRequest, opts ...grpc.CallOption) (*QueryLiquidityPoolsResponse, 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 QueryLiquidityPoolRequest 

type QueryLiquidityPoolRequest struct {
	LptDenom string `protobuf:"bytes,1,opt,name=lpt_denom,json=lptDenom,proto3" json:"lpt_denom,omitempty"`
}

QueryLiquidityPoolRequest is request type for the Query/LiquidityPool RPC method

func (*QueryLiquidityPoolRequest) Descriptor 

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

func (*QueryLiquidityPoolRequest) GetLptDenom 

func (m *QueryLiquidityPoolRequest) GetLptDenom() string

func (*QueryLiquidityPoolRequest) Marshal 

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

func (*QueryLiquidityPoolRequest) MarshalTo 

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

func (*QueryLiquidityPoolRequest) MarshalToSizedBuffer 

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

func (*QueryLiquidityPoolRequest) ProtoMessage 

func (*QueryLiquidityPoolRequest) ProtoMessage()

func (*QueryLiquidityPoolRequest) Reset 

func (m *QueryLiquidityPoolRequest) Reset()

func (*QueryLiquidityPoolRequest) Size 

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

func (*QueryLiquidityPoolRequest) String 

func (m *QueryLiquidityPoolRequest) String() string

func (*QueryLiquidityPoolRequest) Unmarshal 

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

func (*QueryLiquidityPoolRequest) XXX_DiscardUnknown 

func (m *QueryLiquidityPoolRequest) XXX_DiscardUnknown()

func (*QueryLiquidityPoolRequest) XXX_Marshal 

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

func (*QueryLiquidityPoolRequest) XXX_Merge 

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

func (*QueryLiquidityPoolRequest) XXX_Size 

func (m *QueryLiquidityPoolRequest) XXX_Size() int

func (*QueryLiquidityPoolRequest) XXX_Unmarshal 

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

type QueryLiquidityPoolResponse 

type QueryLiquidityPoolResponse struct {
	Pool PoolInfo `protobuf:"bytes,1,opt,name=pool,proto3" json:"pool"`
}

QueryLiquidityPoolResponse is response type for the Query/LiquidityPool RPC method

func (*QueryLiquidityPoolResponse) Descriptor 

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

func (*QueryLiquidityPoolResponse) GetPool 

func (m *QueryLiquidityPoolResponse) GetPool() PoolInfo

func (*QueryLiquidityPoolResponse) Marshal 

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

func (*QueryLiquidityPoolResponse) MarshalTo 

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

func (*QueryLiquidityPoolResponse) MarshalToSizedBuffer 

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

func (*QueryLiquidityPoolResponse) ProtoMessage 

func (*QueryLiquidityPoolResponse) ProtoMessage()

func (*QueryLiquidityPoolResponse) Reset 

func (m *QueryLiquidityPoolResponse) Reset()

func (*QueryLiquidityPoolResponse) Size 

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

func (*QueryLiquidityPoolResponse) String 

func (m *QueryLiquidityPoolResponse) String() string

func (*QueryLiquidityPoolResponse) Unmarshal 

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

func (*QueryLiquidityPoolResponse) XXX_DiscardUnknown 

func (m *QueryLiquidityPoolResponse) XXX_DiscardUnknown()

func (*QueryLiquidityPoolResponse) XXX_Marshal 

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

func (*QueryLiquidityPoolResponse) XXX_Merge 

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

func (*QueryLiquidityPoolResponse) XXX_Size 

func (m *QueryLiquidityPoolResponse) XXX_Size() int

func (*QueryLiquidityPoolResponse) XXX_Unmarshal 

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

type QueryLiquidityPoolsRequest 

type QueryLiquidityPoolsRequest struct {
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryLiquidityPoolsRequest is request type for the Query/LiquidityPools RPC method

func (*QueryLiquidityPoolsRequest) Descriptor 

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

func (*QueryLiquidityPoolsRequest) GetPagination 

func (m *QueryLiquidityPoolsRequest) GetPagination() *query.PageRequest

func (*QueryLiquidityPoolsRequest) Marshal 

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

func (*QueryLiquidityPoolsRequest) MarshalTo 

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

func (*QueryLiquidityPoolsRequest) MarshalToSizedBuffer 

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

func (*QueryLiquidityPoolsRequest) ProtoMessage 

func (*QueryLiquidityPoolsRequest) ProtoMessage()

func (*QueryLiquidityPoolsRequest) Reset 

func (m *QueryLiquidityPoolsRequest) Reset()

func (*QueryLiquidityPoolsRequest) Size 

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

func (*QueryLiquidityPoolsRequest) String 

func (m *QueryLiquidityPoolsRequest) String() string

func (*QueryLiquidityPoolsRequest) Unmarshal 

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

func (*QueryLiquidityPoolsRequest) XXX_DiscardUnknown 

func (m *QueryLiquidityPoolsRequest) XXX_DiscardUnknown()

func (*QueryLiquidityPoolsRequest) XXX_Marshal 

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

func (*QueryLiquidityPoolsRequest) XXX_Merge 

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

func (*QueryLiquidityPoolsRequest) XXX_Size 

func (m *QueryLiquidityPoolsRequest) XXX_Size() int

func (*QueryLiquidityPoolsRequest) XXX_Unmarshal 

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

type QueryLiquidityPoolsResponse 

type QueryLiquidityPoolsResponse struct {
	Pools      []PoolInfo          `protobuf:"bytes,1,rep,name=pools,proto3" json:"pools"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryLiquidityPoolsResponse is response type for the Query/LiquidityPools RPC method

func (*QueryLiquidityPoolsResponse) Descriptor 

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

func (*QueryLiquidityPoolsResponse) GetPagination 

func (m *QueryLiquidityPoolsResponse) GetPagination() *query.PageResponse

func (*QueryLiquidityPoolsResponse) GetPools 

func (m *QueryLiquidityPoolsResponse) GetPools() []PoolInfo

func (*QueryLiquidityPoolsResponse) Marshal 

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

func (*QueryLiquidityPoolsResponse) MarshalTo 

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

func (*QueryLiquidityPoolsResponse) MarshalToSizedBuffer 

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

func (*QueryLiquidityPoolsResponse) ProtoMessage 

func (*QueryLiquidityPoolsResponse) ProtoMessage()

func (*QueryLiquidityPoolsResponse) Reset 

func (m *QueryLiquidityPoolsResponse) Reset()

func (*QueryLiquidityPoolsResponse) Size 

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

func (*QueryLiquidityPoolsResponse) String 

func (m *QueryLiquidityPoolsResponse) String() string

func (*QueryLiquidityPoolsResponse) Unmarshal 

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

func (*QueryLiquidityPoolsResponse) XXX_DiscardUnknown 

func (m *QueryLiquidityPoolsResponse) XXX_DiscardUnknown()

func (*QueryLiquidityPoolsResponse) XXX_Marshal 

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

func (*QueryLiquidityPoolsResponse) XXX_Merge 

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

func (*QueryLiquidityPoolsResponse) XXX_Size 

func (m *QueryLiquidityPoolsResponse) XXX_Size() int

func (*QueryLiquidityPoolsResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest is request type for the Query/Params RPC method.

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

type QueryParamsResponse struct {
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse is response type for the Query/Params RPC method.

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryPoolParams 

type QueryPoolParams struct {
	LptDenom string `json:"lpt-denom" yaml:"lpt-denom"` // same as uniDenom
}

QueryPoolParams is the query parameters for 'custom/swap/liquidity'

type QueryServer 

type QueryServer interface {
	// Params returns parameters of the module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// LiquidityPool returns the liquidity pool for the provided
	// lpt_denom
	LiquidityPool(context.Context, *QueryLiquidityPoolRequest) (*QueryLiquidityPoolResponse, error)
	// LiquidityPools returns all the liquidity pools available
	LiquidityPools(context.Context, *QueryLiquidityPoolsRequest) (*QueryLiquidityPoolsResponse, error)
}

QueryServer is the server API for Query service.

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) AddLiquidity 

func (*UnimplementedMsgServer) AddLiquidity(ctx context.Context, req *MsgAddLiquidity) (*MsgAddLiquidityResponse, error)

func (*UnimplementedMsgServer) RemoveLiquidity 

func (*UnimplementedMsgServer) RemoveLiquidity(ctx context.Context, req *MsgRemoveLiquidity) (*MsgRemoveLiquidityResponse, error)

func (*UnimplementedMsgServer) SwapCoin 

func (*UnimplementedMsgServer) SwapCoin(ctx context.Context, req *MsgSwapOrder) (*MsgSwapCoinResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) LiquidityPool 

func (*UnimplementedQueryServer) LiquidityPool(ctx context.Context, req *QueryLiquidityPoolRequest) (*QueryLiquidityPoolResponse, error)

func (*UnimplementedQueryServer) LiquidityPools 

func (*UnimplementedQueryServer) LiquidityPools(ctx context.Context, req *QueryLiquidityPoolsRequest) (*QueryLiquidityPoolsResponse, error)

func (*UnimplementedQueryServer) Params 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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