coinswap

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Sep 2, 2021 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ModuleName = "coinswap"
)

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 (
	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 (
	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 GetLiquidityDenomFrom 

func GetLiquidityDenomFrom(denom string) (string, error)

func GetTokenDenomFrom 

func GetTokenDenomFrom(liquidityDenom string) (string, error)

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type AddLiquidityRequest 

type AddLiquidityRequest struct {
	MaxToken     sdk.Coin
	BaseAmt      sdk.Int
	MinLiquidity sdk.Int
	Deadline     int64
}

type AddLiquidityResponse 

type AddLiquidityResponse struct {
	TokenAmt  sdk.Int
	BaseAmt   sdk.Int
	Liquidity sdk.Int
	TxHash    string
}

type Client 

type Client interface {
	sdk.Module
	AddLiquidity(request AddLiquidityRequest,
		baseTx sdk.BaseTx) (*AddLiquidityResponse, error)
	RemoveLiquidity(request RemoveLiquidityRequest,
		baseTx sdk.BaseTx) (*RemoveLiquidityResponse, error)
	SwapCoin(request SwapCoinRequest,
		baseTx sdk.BaseTx) (*SwapCoinResponse, error)

	BuyTokenWithAutoEstimate(paidTokenDenom string, boughtCoin sdk.Coin,
		deadline int64,
		baseTx sdk.BaseTx,
	) (res *SwapCoinResponse, err error)
	SellTokenWithAutoEstimate(gotTokenDenom string, soldCoin sdk.Coin,
		deadline int64,
		baseTx sdk.BaseTx,
	) (res *SwapCoinResponse, err error)

	QueryPool(lptDenom string) (*QueryPoolResponse, error)
	QueryAllPools(pageReq sdk.PageRequest) (*QueryAllPoolsResponse, error)

	EstimateTokenForSoldBase(tokenDenom string,
		soldBase sdk.Int,
	) (sdk.Int, error)
	EstimateBaseForSoldToken(soldToken sdk.Coin) (sdk.Int, error)
	EstimateTokenForSoldToken(boughtTokenDenom string,
		soldToken sdk.Coin) (sdk.Int, error)
	EstimateTokenForBoughtBase(soldTokenDenom string,
		boughtBase sdk.Int) (sdk.Int, error)
	EstimateBaseForBoughtToken(boughtToken sdk.Coin) (sdk.Int, error)
	EstimateTokenForBoughtToken(soldTokenDenom string,
		boughtToken sdk.Coin) (sdk.Int, error)
}

expose Record module api for user

func NewClient 

func NewClient(bc sdk.BaseClient, cdc codec.Marshaler, queryTotalSupply totalSupply) Client

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 (*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 (*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 (*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 (*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"`
}

Params defines token module's parameters

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

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal 

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

func (*Params) 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 QueryAllPoolsResponse 

type QueryAllPoolsResponse struct {
	Pools      []sdk.PoolInfo
	Pagination *query.PageResponse
}

type QueryClient 

type QueryClient interface {
	// 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) Convert 

func (m QueryLiquidityPoolResponse) Convert() interface{}

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

func (m QueryLiquidityPoolsResponse) Convert() interface{}

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 QueryPoolResponse 

type QueryPoolResponse struct {
	Pool sdk.PoolInfo
}

type QueryServer 

type QueryServer interface {
	// 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 RemoveLiquidityRequest 

type RemoveLiquidityRequest struct {
	MinTokenAmt sdk.Int
	MinBaseAmt  sdk.Int
	Liquidity   sdk.Coin
	Deadline    int64
}

type RemoveLiquidityResponse 

type RemoveLiquidityResponse struct {
	TokenAmt  sdk.Int
	BaseAmt   sdk.Int
	Liquidity sdk.Coin
	TxHash    string
}

type SwapCoinRequest 

type SwapCoinRequest struct {
	Input      sdk.Coin
	Output     sdk.Coin
	Receiver   string
	Deadline   int64
	IsBuyOrder bool
}

type SwapCoinResponse 

type SwapCoinResponse struct {
	InputAmt  sdk.Int
	OutputAmt sdk.Int
	TxHash    string
}

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)

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.