types

package
v0.1.0-merlin.1 Latest Latest
Warning

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

 Go to latest Published: Feb 9, 2023 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	TypeEvtCreatePosition   = "create_position"
	TypeEvtWithdrawPosition = "withdraw_position"
	TypeEvtCollectFees      = "collect_fees"

	AttributeValueCategory = ModuleName
	AttributeKeyPoolId     = "pool_id"
	AttributeAmount0       = "amount0"
	AttributeAmount1       = "amount1"
	AttributeKeySwapFee    = "swap_fee"
	AttributeKeyTokensIn   = "tokens_in"
	AttributeKeyTokensOut  = "tokens_out"
	AttributeLiquidity     = "liquidity"
	AttributeLowerTick     = "lower_tick"
	AttributeUpperTick     = "upper_tick"
	TypeEvtPoolJoined      = "pool_joined"
	TypeEvtPoolExited      = "pool_exited"
	TypeEvtPoolCreated     = "pool_created"
	TypeEvtTokenSwapped    = "token_swapped"
)
View Source 
const (
	ModuleName = "concentratedliquidity"
	RouterKey  = ModuleName

	StoreKey     = ModuleName
	KeySeparator = "|"
)
View Source 
const (
	TypeMsgCreatePosition   = "create-position"
	TypeMsgWithdrawPosition = "withdraw-position"
	TypeMsgCollectFees      = "collect-fees"
)

constants.

Variables

View Source 
var (
	MaxSqrtRatio = sdk.MustNewDecFromStr("18446050711097703529.7763428")
	// TODO: this is a temp value, figure out math for this.
	// we basically want getSqrtRatioAtTick(MIN_TICK)
	MinSqrtRatio              = sdk.MustNewDecFromStr("0")
	ConcentratedGasFeeForSwap = 10_000
	ExponentAtPriceOneMax     = sdk.NewInt(-1)
	ExponentAtPriceOneMin     = sdk.NewInt(-12)
	MaxSpotPrice              = sdk.MustNewDecFromStr("100000000000000000000000000000000000000")
	MinSpotPrice              = sdk.MustNewDecFromStr("0.000000000000000001")
	// Supported uptimes preset to 1 min, 1 hr, 1D, 1W
	SupportedUptimes      = []time.Duration{time.Minute, time.Hour, time.Hour * 24, time.Hour * 24 * 7}
	AuthorizedTickSpacing = []uint64{1, 10, 60, 200}
)
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 (
	TickPrefix     = []byte{0x01}
	PositionPrefix = []byte{0x02}
	PoolPrefix     = []byte{0x03}
)

Key prefixes

View Source 
var (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = 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 (
	KeyAuthorizedTickSpacing = []byte("AuthorizedTickSpacing")
)

Parameter store keys.

View Source 
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)

Functions

func KeyFullPosition 

func KeyFullPosition(poolId uint64, addr sdk.AccAddress, lowerTick, upperTick int64, frozenUntil time.Time) []byte

KeyFullPosition uses pool Id, owner, lower tick, upper tick, and frozenUntil for keys

func KeyPool 

func KeyPool(poolId uint64) []byte

func KeyPosition 

func KeyPosition(poolId uint64, addr sdk.AccAddress, lowerTick, upperTick int64) []byte

KeyPosition uses pool Id, owner, lower tick and upper tick for keys

func KeyTick 

func KeyTick(poolId uint64, tickIndex int64) []byte

KeyTick returns a key for storing a TickInfo object.

func KeyTickPrefix 

func KeyTickPrefix(poolId uint64) []byte

KeyTickPrefix constructs a key prefix for storing a TickInfo object.

func KeyUserPositions 

func KeyUserPositions(addr sdk.AccAddress) []byte

func OrderInitialPoolDenoms 

func OrderInitialPoolDenoms(denom0, denom1 string) (string, string, error)

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamTable for concentrated-liquidity module.

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)

func TickIndexFromBytes 

func TickIndexFromBytes(bz []byte) (int64, error)

TickIndexFromBytes converts an encoded tick index to an int64 value. It returns an error if the encoded tick has invalid length.

func TickIndexToBytes 

func TickIndexToBytes(tickIndex int64) []byte

TickIndexToBytes converts a tick index to a byte slice. Negative tick indexes are prefixed with 0x00 a byte and positive tick indexes are prefixed with a 0x01 byte. We do this because big endian byte encoding does not give us in order iteration in state due to the tick index values being signed integers.

Types

type AmountGreaterThanMaxError 

type AmountGreaterThanMaxError struct {
	TokenAmount sdk.Int
	TokenMax    sdk.Int
}

func (AmountGreaterThanMaxError) Error 

func (e AmountGreaterThanMaxError) Error() string

type AmountLessThanMinError 

type AmountLessThanMinError struct {
	TokenAmount sdk.Int
	TokenMin    sdk.Int
}

func (AmountLessThanMinError) Error 

func (e AmountLessThanMinError) Error() string

type BankKeeper 

type BankKeeper interface {
	GetDenomMetaData(ctx sdk.Context, denom string) (banktypes.Metadata, bool)
	SendCoins(ctx sdk.Context, fromAddr sdk.AccAddress, toAddr sdk.AccAddress, amt sdk.Coins) error
}

BankKeeper defines the banking contract that must be fulfilled when creating a x/concentrated-liquidity keeper.

type ConcentratedPoolExtension 

type ConcentratedPoolExtension interface {
	poolmanagertypes.PoolI

	// TODO: move these to separate interfaces
	GetToken0() string
	GetToken1() string
	GetCurrentSqrtPrice() sdk.Dec
	GetCurrentTick() sdk.Int
	GetPrecisionFactorAtPriceOne() sdk.Int
	GetTickSpacing() uint64
	GetLiquidity() sdk.Dec
	SetCurrentSqrtPrice(newSqrtPrice sdk.Dec)
	SetCurrentTick(newTick sdk.Int)

	UpdateLiquidity(newLiquidity sdk.Dec)
	ApplySwap(newLiquidity sdk.Dec, newCurrentTick sdk.Int, newCurrentSqrtPrice sdk.Dec) error
	CalcActualAmounts(ctx sdk.Context, lowerTick, upperTick int64, sqrtRatioLowerTick, sqrtRatioUpperTick sdk.Dec, liquidityDelta sdk.Dec) (actualAmountDenom0 sdk.Dec, actualAmountDenom1 sdk.Dec)
	UpdateLiquidityIfActivePosition(ctx sdk.Context, lowerTick, upperTick int64, liquidityDelta sdk.Dec) bool
}

type DenomDuplicatedError 

type DenomDuplicatedError struct {
	TokenInDenom  string
	TokenOutDenom string
}

func (DenomDuplicatedError) Error 

func (e DenomDuplicatedError) Error() string

type ExponentAtPriceOneError 

type ExponentAtPriceOneError struct {
	ProvidedExponentAtPriceOne  sdk.Int
	PrecisionValueAtPriceOneMin sdk.Int
	PrecisionValueAtPriceOneMax sdk.Int
}

func (ExponentAtPriceOneError) Error 

func (e ExponentAtPriceOneError) Error() string

type FullPositionByOwnerResult 

type FullPositionByOwnerResult struct {
	PoolId      uint64                                 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty" yaml:"pool_id"`
	LowerTick   int64                                  `protobuf:"varint,2,opt,name=lower_tick,json=lowerTick,proto3" json:"lower_tick,omitempty"`
	UpperTick   int64                                  `protobuf:"varint,3,opt,name=upper_tick,json=upperTick,proto3" json:"upper_tick,omitempty"`
	FrozenUntil time.Time                              `protobuf:"bytes,4,opt,name=frozen_until,json=frozenUntil,proto3,stdtime" json:"frozen_until" yaml:"frozen_until"`
	Liquidity   github_com_cosmos_cosmos_sdk_types.Dec `` /* 128-byte string literal not displayed */
}

func (*FullPositionByOwnerResult) Descriptor 

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

func (*FullPositionByOwnerResult) GetFrozenUntil 

func (m *FullPositionByOwnerResult) GetFrozenUntil() time.Time

func (*FullPositionByOwnerResult) GetLowerTick 

func (m *FullPositionByOwnerResult) GetLowerTick() int64

func (*FullPositionByOwnerResult) GetPoolId 

func (m *FullPositionByOwnerResult) GetPoolId() uint64

func (*FullPositionByOwnerResult) GetUpperTick 

func (m *FullPositionByOwnerResult) GetUpperTick() int64

func (*FullPositionByOwnerResult) Marshal 

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

func (*FullPositionByOwnerResult) MarshalTo 

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

func (*FullPositionByOwnerResult) MarshalToSizedBuffer 

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

func (*FullPositionByOwnerResult) ProtoMessage 

func (*FullPositionByOwnerResult) ProtoMessage()

func (*FullPositionByOwnerResult) Reset 

func (m *FullPositionByOwnerResult) Reset()

func (*FullPositionByOwnerResult) Size 

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

func (*FullPositionByOwnerResult) String 

func (m *FullPositionByOwnerResult) String() string

func (*FullPositionByOwnerResult) Unmarshal 

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

func (*FullPositionByOwnerResult) XXX_DiscardUnknown 

func (m *FullPositionByOwnerResult) XXX_DiscardUnknown()

func (*FullPositionByOwnerResult) XXX_Marshal 

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

func (*FullPositionByOwnerResult) XXX_Merge 

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

func (*FullPositionByOwnerResult) XXX_Size 

func (m *FullPositionByOwnerResult) XXX_Size() int

func (*FullPositionByOwnerResult) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	// params are all the parameters of the module
	Params Params       `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	Pools  []*types.Any `protobuf:"bytes,2,rep,name=pools,proto3" json:"pools,omitempty"`
}

GenesisState defines the concentrated liquidity module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default GenesisState for the concentrated-liquidity module.

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetPools 

func (m *GenesisState) GetPools() []*types.Any

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

func (gs GenesisState) Validate() error

Validate performs basic genesis state validation returning an error upon any failure.

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 InitialLiquidityZeroError 

type InitialLiquidityZeroError struct {
	Amount0 sdk.Int
	Amount1 sdk.Int
}

func (InitialLiquidityZeroError) Error 

func (e InitialLiquidityZeroError) Error() string

type InsufficientLiquidityCreatedError 

type InsufficientLiquidityCreatedError struct {
	Actual      sdk.Int
	Minimum     sdk.Int
	IsTokenZero bool
}

func (InsufficientLiquidityCreatedError) Error 

func (e InsufficientLiquidityCreatedError) Error() string

type InsufficientLiquidityError 

type InsufficientLiquidityError struct {
	Actual    sdk.Dec
	Available sdk.Dec
}

func (InsufficientLiquidityError) Error 

func (e InsufficientLiquidityError) Error() string

type InvalidLowerUpperTickError 

type InvalidLowerUpperTickError struct {
	LowerTick int64
	UpperTick int64
}

x/concentrated-liquidity module sentinel errors.

func (InvalidLowerUpperTickError) Error 

func (e InvalidLowerUpperTickError) Error() string

type InvalidPriceLimitError 

type InvalidPriceLimitError struct {
	SqrtPriceLimit sdk.Dec
	LowerBound     sdk.Dec
	UpperBound     sdk.Dec
}

func (InvalidPriceLimitError) Error 

func (e InvalidPriceLimitError) Error() string

type InvalidSwapFeeError 

type InvalidSwapFeeError struct {
	ActualFee sdk.Dec
}

func (InvalidSwapFeeError) Error 

func (e InvalidSwapFeeError) Error() string

type InvalidTickError 

type InvalidTickError struct {
	Tick    int64
	IsLower bool
	MinTick int64
	MaxTick int64
}

func (InvalidTickError) Error 

func (e InvalidTickError) Error() string

type LiquidityDepth 

type LiquidityDepth struct {
	LiquidityNet github_com_cosmos_cosmos_sdk_types.Dec `` /* 158-byte string literal not displayed */
	TickIndex    github_com_cosmos_cosmos_sdk_types.Int `` /* 140-byte string literal not displayed */
}

func (*LiquidityDepth) Descriptor 

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

func (*LiquidityDepth) Marshal 

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

func (*LiquidityDepth) MarshalTo 

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

func (*LiquidityDepth) MarshalToSizedBuffer 

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

func (*LiquidityDepth) ProtoMessage 

func (*LiquidityDepth) ProtoMessage()

func (*LiquidityDepth) Reset 

func (m *LiquidityDepth) Reset()

func (*LiquidityDepth) Size 

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

func (*LiquidityDepth) String 

func (m *LiquidityDepth) String() string

func (*LiquidityDepth) Unmarshal 

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

func (*LiquidityDepth) XXX_DiscardUnknown 

func (m *LiquidityDepth) XXX_DiscardUnknown()

func (*LiquidityDepth) XXX_Marshal 

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

func (*LiquidityDepth) XXX_Merge 

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

func (*LiquidityDepth) XXX_Size 

func (m *LiquidityDepth) XXX_Size() int

func (*LiquidityDepth) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	CreatePosition(ctx context.Context, in *MsgCreatePosition, opts ...grpc.CallOption) (*MsgCreatePositionResponse, error)
	WithdrawPosition(ctx context.Context, in *MsgWithdrawPosition, opts ...grpc.CallOption) (*MsgWithdrawPositionResponse, error)
	CollectFees(ctx context.Context, in *MsgCollectFees, opts ...grpc.CallOption) (*MsgCollectFeesResponse, 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 MsgCollectFees 

type MsgCollectFees struct {
	PoolId    uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty" yaml:"pool_id"`
	Sender    string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	LowerTick int64  `protobuf:"varint,3,opt,name=lower_tick,json=lowerTick,proto3" json:"lower_tick,omitempty" yaml:"lower_tick"`
	UpperTick int64  `protobuf:"varint,4,opt,name=upper_tick,json=upperTick,proto3" json:"upper_tick,omitempty" yaml:"upper_tick"`
}

===================== MsgCollectFees

func (*MsgCollectFees) Descriptor 

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

func (*MsgCollectFees) GetLowerTick 

func (m *MsgCollectFees) GetLowerTick() int64

func (*MsgCollectFees) GetPoolId 

func (m *MsgCollectFees) GetPoolId() uint64

func (*MsgCollectFees) GetSender 

func (m *MsgCollectFees) GetSender() string

func (MsgCollectFees) GetSignBytes 

func (msg MsgCollectFees) GetSignBytes() []byte

func (MsgCollectFees) GetSigners 

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

func (*MsgCollectFees) GetUpperTick 

func (m *MsgCollectFees) GetUpperTick() int64

func (*MsgCollectFees) Marshal 

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

func (*MsgCollectFees) MarshalTo 

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

func (*MsgCollectFees) MarshalToSizedBuffer 

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

func (*MsgCollectFees) ProtoMessage 

func (*MsgCollectFees) ProtoMessage()

func (*MsgCollectFees) Reset 

func (m *MsgCollectFees) Reset()

func (MsgCollectFees) Route 

func (msg MsgCollectFees) Route() string

func (*MsgCollectFees) Size 

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

func (*MsgCollectFees) String 

func (m *MsgCollectFees) String() string

func (MsgCollectFees) Type 

func (msg MsgCollectFees) Type() string

func (*MsgCollectFees) Unmarshal 

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

func (MsgCollectFees) ValidateBasic 

func (msg MsgCollectFees) ValidateBasic() error

func (*MsgCollectFees) XXX_DiscardUnknown 

func (m *MsgCollectFees) XXX_DiscardUnknown()

func (*MsgCollectFees) XXX_Marshal 

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

func (*MsgCollectFees) XXX_Merge 

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

func (*MsgCollectFees) XXX_Size 

func (m *MsgCollectFees) XXX_Size() int

func (*MsgCollectFees) XXX_Unmarshal 

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

type MsgCollectFeesResponse 

type MsgCollectFeesResponse struct {
	TokenOut []types.Coin `protobuf:"bytes,1,rep,name=token_out,json=tokenOut,proto3" json:"token_out" yaml:"token_out"`
}

func (*MsgCollectFeesResponse) Descriptor 

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

func (*MsgCollectFeesResponse) GetTokenOut 

func (m *MsgCollectFeesResponse) GetTokenOut() []types.Coin

func (*MsgCollectFeesResponse) Marshal 

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

func (*MsgCollectFeesResponse) MarshalTo 

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

func (*MsgCollectFeesResponse) MarshalToSizedBuffer 

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

func (*MsgCollectFeesResponse) ProtoMessage 

func (*MsgCollectFeesResponse) ProtoMessage()

func (*MsgCollectFeesResponse) Reset 

func (m *MsgCollectFeesResponse) Reset()

func (*MsgCollectFeesResponse) Size 

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

func (*MsgCollectFeesResponse) String 

func (m *MsgCollectFeesResponse) String() string

func (*MsgCollectFeesResponse) Unmarshal 

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

func (*MsgCollectFeesResponse) XXX_DiscardUnknown 

func (m *MsgCollectFeesResponse) XXX_DiscardUnknown()

func (*MsgCollectFeesResponse) XXX_Marshal 

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

func (*MsgCollectFeesResponse) XXX_Merge 

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

func (*MsgCollectFeesResponse) XXX_Size 

func (m *MsgCollectFeesResponse) XXX_Size() int

func (*MsgCollectFeesResponse) XXX_Unmarshal 

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

type MsgCreatePosition 

type MsgCreatePosition struct {
	PoolId          uint64                                 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty" yaml:"pool_id"`
	Sender          string                                 `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	LowerTick       int64                                  `protobuf:"varint,3,opt,name=lower_tick,json=lowerTick,proto3" json:"lower_tick,omitempty" yaml:"lower_tick"`
	UpperTick       int64                                  `protobuf:"varint,4,opt,name=upper_tick,json=upperTick,proto3" json:"upper_tick,omitempty" yaml:"upper_tick"`
	TokenDesired0   types.Coin                             `protobuf:"bytes,5,opt,name=token_desired0,json=tokenDesired0,proto3" json:"token_desired0" yaml:"token_desired0"`
	TokenDesired1   types.Coin                             `protobuf:"bytes,6,opt,name=token_desired1,json=tokenDesired1,proto3" json:"token_desired1" yaml:"token_desired1"`
	TokenMinAmount0 github_com_cosmos_cosmos_sdk_types.Int `` /* 173-byte string literal not displayed */
	TokenMinAmount1 github_com_cosmos_cosmos_sdk_types.Int `` /* 173-byte string literal not displayed */
	FrozenUntil     time.Time                              `protobuf:"bytes,9,opt,name=frozen_until,json=frozenUntil,proto3,stdtime" json:"frozen_until" yaml:"frozen_until"`
}

===================== MsgCreatePosition

func (*MsgCreatePosition) Descriptor 

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

func (*MsgCreatePosition) GetFrozenUntil 

func (m *MsgCreatePosition) GetFrozenUntil() time.Time

func (*MsgCreatePosition) GetLowerTick 

func (m *MsgCreatePosition) GetLowerTick() int64

func (*MsgCreatePosition) GetPoolId 

func (m *MsgCreatePosition) GetPoolId() uint64

func (*MsgCreatePosition) GetSender 

func (m *MsgCreatePosition) GetSender() string

func (MsgCreatePosition) GetSignBytes 

func (msg MsgCreatePosition) GetSignBytes() []byte

func (MsgCreatePosition) GetSigners 

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

func (*MsgCreatePosition) GetTokenDesired0 

func (m *MsgCreatePosition) GetTokenDesired0() types.Coin

func (*MsgCreatePosition) GetTokenDesired1 

func (m *MsgCreatePosition) GetTokenDesired1() types.Coin

func (*MsgCreatePosition) GetUpperTick 

func (m *MsgCreatePosition) GetUpperTick() int64

func (*MsgCreatePosition) Marshal 

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

func (*MsgCreatePosition) MarshalTo 

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

func (*MsgCreatePosition) MarshalToSizedBuffer 

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

func (*MsgCreatePosition) ProtoMessage 

func (*MsgCreatePosition) ProtoMessage()

func (*MsgCreatePosition) Reset 

func (m *MsgCreatePosition) Reset()

func (MsgCreatePosition) Route 

func (msg MsgCreatePosition) Route() string

func (*MsgCreatePosition) Size 

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

func (*MsgCreatePosition) String 

func (m *MsgCreatePosition) String() string

func (MsgCreatePosition) Type 

func (msg MsgCreatePosition) Type() string

func (*MsgCreatePosition) Unmarshal 

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

func (MsgCreatePosition) ValidateBasic 

func (msg MsgCreatePosition) ValidateBasic() error

func (*MsgCreatePosition) XXX_DiscardUnknown 

func (m *MsgCreatePosition) XXX_DiscardUnknown()

func (*MsgCreatePosition) XXX_Marshal 

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

func (*MsgCreatePosition) XXX_Merge 

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

func (*MsgCreatePosition) XXX_Size 

func (m *MsgCreatePosition) XXX_Size() int

func (*MsgCreatePosition) XXX_Unmarshal 

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

type MsgCreatePositionResponse 

type MsgCreatePositionResponse struct {
	Amount0          github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,1,opt,name=amount0,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount0" yaml:"amount0"`
	Amount1          github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,2,opt,name=amount1,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount1" yaml:"amount1"`
	LiquidityCreated github_com_cosmos_cosmos_sdk_types.Dec `` /* 174-byte string literal not displayed */
}

func (*MsgCreatePositionResponse) Descriptor 

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

func (*MsgCreatePositionResponse) Marshal 

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

func (*MsgCreatePositionResponse) MarshalTo 

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

func (*MsgCreatePositionResponse) MarshalToSizedBuffer 

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

func (*MsgCreatePositionResponse) ProtoMessage 

func (*MsgCreatePositionResponse) ProtoMessage()

func (*MsgCreatePositionResponse) Reset 

func (m *MsgCreatePositionResponse) Reset()

func (*MsgCreatePositionResponse) Size 

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

func (*MsgCreatePositionResponse) String 

func (m *MsgCreatePositionResponse) String() string

func (*MsgCreatePositionResponse) Unmarshal 

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

func (*MsgCreatePositionResponse) XXX_DiscardUnknown 

func (m *MsgCreatePositionResponse) XXX_DiscardUnknown()

func (*MsgCreatePositionResponse) XXX_Marshal 

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

func (*MsgCreatePositionResponse) XXX_Merge 

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

func (*MsgCreatePositionResponse) XXX_Size 

func (m *MsgCreatePositionResponse) XXX_Size() int

func (*MsgCreatePositionResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	CreatePosition(context.Context, *MsgCreatePosition) (*MsgCreatePositionResponse, error)
	WithdrawPosition(context.Context, *MsgWithdrawPosition) (*MsgWithdrawPositionResponse, error)
	CollectFees(context.Context, *MsgCollectFees) (*MsgCollectFeesResponse, error)
}

MsgServer is the server API for Msg service.

type MsgWithdrawPosition 

type MsgWithdrawPosition struct {
	PoolId          uint64                                 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty" yaml:"pool_id"`
	Sender          string                                 `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	LowerTick       int64                                  `protobuf:"varint,3,opt,name=lower_tick,json=lowerTick,proto3" json:"lower_tick,omitempty" yaml:"lower_tick"`
	UpperTick       int64                                  `protobuf:"varint,4,opt,name=upper_tick,json=upperTick,proto3" json:"upper_tick,omitempty" yaml:"upper_tick"`
	LiquidityAmount github_com_cosmos_cosmos_sdk_types.Dec `` /* 170-byte string literal not displayed */
	FrozenUntil     time.Time                              `protobuf:"bytes,6,opt,name=frozen_until,json=frozenUntil,proto3,stdtime" json:"frozen_until" yaml:"frozen_until"`
}

===================== MsgWithdrawPosition

func (*MsgWithdrawPosition) Descriptor 

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

func (*MsgWithdrawPosition) GetFrozenUntil 

func (m *MsgWithdrawPosition) GetFrozenUntil() time.Time

func (*MsgWithdrawPosition) GetLowerTick 

func (m *MsgWithdrawPosition) GetLowerTick() int64

func (*MsgWithdrawPosition) GetPoolId 

func (m *MsgWithdrawPosition) GetPoolId() uint64

func (*MsgWithdrawPosition) GetSender 

func (m *MsgWithdrawPosition) GetSender() string

func (MsgWithdrawPosition) GetSignBytes 

func (msg MsgWithdrawPosition) GetSignBytes() []byte

func (MsgWithdrawPosition) GetSigners 

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

func (*MsgWithdrawPosition) GetUpperTick 

func (m *MsgWithdrawPosition) GetUpperTick() int64

func (*MsgWithdrawPosition) Marshal 

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

func (*MsgWithdrawPosition) MarshalTo 

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

func (*MsgWithdrawPosition) MarshalToSizedBuffer 

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

func (*MsgWithdrawPosition) ProtoMessage 

func (*MsgWithdrawPosition) ProtoMessage()

func (*MsgWithdrawPosition) Reset 

func (m *MsgWithdrawPosition) Reset()

func (MsgWithdrawPosition) Route 

func (msg MsgWithdrawPosition) Route() string

func (*MsgWithdrawPosition) Size 

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

func (*MsgWithdrawPosition) String 

func (m *MsgWithdrawPosition) String() string

func (MsgWithdrawPosition) Type 

func (msg MsgWithdrawPosition) Type() string

func (*MsgWithdrawPosition) Unmarshal 

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

func (MsgWithdrawPosition) ValidateBasic 

func (msg MsgWithdrawPosition) ValidateBasic() error

func (*MsgWithdrawPosition) XXX_DiscardUnknown 

func (m *MsgWithdrawPosition) XXX_DiscardUnknown()

func (*MsgWithdrawPosition) XXX_Marshal 

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

func (*MsgWithdrawPosition) XXX_Merge 

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

func (*MsgWithdrawPosition) XXX_Size 

func (m *MsgWithdrawPosition) XXX_Size() int

func (*MsgWithdrawPosition) XXX_Unmarshal 

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

type MsgWithdrawPositionResponse 

type MsgWithdrawPositionResponse struct {
	Amount0 github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,1,opt,name=amount0,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount0" yaml:"amount0"`
	Amount1 github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,2,opt,name=amount1,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount1" yaml:"amount1"`
}

func (*MsgWithdrawPositionResponse) Descriptor 

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

func (*MsgWithdrawPositionResponse) Marshal 

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

func (*MsgWithdrawPositionResponse) MarshalTo 

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

func (*MsgWithdrawPositionResponse) MarshalToSizedBuffer 

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

func (*MsgWithdrawPositionResponse) ProtoMessage 

func (*MsgWithdrawPositionResponse) ProtoMessage()

func (*MsgWithdrawPositionResponse) Reset 

func (m *MsgWithdrawPositionResponse) Reset()

func (*MsgWithdrawPositionResponse) Size 

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

func (*MsgWithdrawPositionResponse) String 

func (m *MsgWithdrawPositionResponse) String() string

func (*MsgWithdrawPositionResponse) Unmarshal 

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

func (*MsgWithdrawPositionResponse) XXX_DiscardUnknown 

func (m *MsgWithdrawPositionResponse) XXX_DiscardUnknown()

func (*MsgWithdrawPositionResponse) XXX_Marshal 

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

func (*MsgWithdrawPositionResponse) XXX_Merge 

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

func (*MsgWithdrawPositionResponse) XXX_Size 

func (m *MsgWithdrawPositionResponse) XXX_Size() int

func (*MsgWithdrawPositionResponse) XXX_Unmarshal 

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

type NegativeLiquidityError 

type NegativeLiquidityError struct {
	Liquidity sdk.Dec
}

func (NegativeLiquidityError) Error 

func (e NegativeLiquidityError) Error() string

type NotPositiveRequireAmountError 

type NotPositiveRequireAmountError struct {
	Amount string
}

func (NotPositiveRequireAmountError) Error 

func (e NotPositiveRequireAmountError) Error() string

type Params 

type Params struct {
	// authorized_tick_spacing is an array of uint64s that represents the tick
	// spacing values concentrated-liquidity pools can be created with. For
	// example, an authorized_tick_spacing of [1, 10, 30] allows for pools
	// to be created with tick spacing of 1, 10, or 30.
	AuthorizedTickSpacing []uint64 `` /* 165-byte string literal not displayed */
}

func DefaultParams 

func DefaultParams() Params

DefaultParams returns default concentrated-liquidity module parameters. TODO: Decide on what these should be initially. https://github.com/merlinslair/merlin/issues/3684

func NewParams 

func NewParams(authorizedTickSpacing []uint64) Params

func (*Params) Descriptor 

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

func (*Params) GetAuthorizedTickSpacing 

func (m *Params) GetAuthorizedTickSpacing() []uint64

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 params.ParamSet.

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

func (p Params) Validate() error

Validate params.

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 PoolManagerKeeper 

type PoolManagerKeeper interface {
	CreatePool(ctx sdk.Context, msg poolmanagertypes.CreatePoolMsg) (uint64, error)
	GetNextPoolId(ctx sdk.Context) uint64
}

PoolManagerKeeper defines the interface needed to be fulfilled for the poolmanager keeper.

type PoolNotFoundError 

type PoolNotFoundError struct {
	PoolId uint64
}

func (PoolNotFoundError) Error 

func (e PoolNotFoundError) Error() string

type PositionNotFoundError 

type PositionNotFoundError struct {
	PoolId      uint64
	LowerTick   int64
	UpperTick   int64
	FrozenUntil time.Time
}

func (PositionNotFoundError) Error 

func (e PositionNotFoundError) Error() string

type PositionStillFrozenError 

type PositionStillFrozenError struct {
	FrozenUntil time.Time
}

func (PositionStillFrozenError) Error 

func (e PositionStillFrozenError) Error() string

type PriceBoundError 

type PriceBoundError struct {
	ProvidedPrice sdk.Dec
	MinSpotPrice  sdk.Dec
	MaxSpotPrice  sdk.Dec
}

func (PriceBoundError) Error 

func (e PriceBoundError) Error() string

type QueryClient 

type QueryClient interface {
	// Pools returns all concentrated liquidity pools
	Pools(ctx context.Context, in *QueryPoolsRequest, opts ...grpc.CallOption) (*QueryPoolsResponse, error)
	// Pool returns the Pool specified by the pool id
	Pool(ctx context.Context, in *QueryPoolRequest, opts ...grpc.CallOption) (*QueryPoolResponse, error)
	// Params returns concentrated liquidity module params.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// LiquidityDepthsForRange returns Liqiudity Depths for given range
	LiquidityDepthsForRange(ctx context.Context, in *QueryLiquidityDepthsForRangeRequest, opts ...grpc.CallOption) (*QueryLiquidityDepthsForRangeResponse, error)
	// UserPositions returns all concentrated postitions of some address.
	UserPositions(ctx context.Context, in *QueryUserPositionsRequest, opts ...grpc.CallOption) (*QueryUserPositionsResponse, 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 QueryLiquidityDepthsForRangeRequest 

type QueryLiquidityDepthsForRangeRequest struct {
	PoolId    uint64                                 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty" yaml:"pool_id"`
	LowerTick github_com_cosmos_cosmos_sdk_types.Int `` /* 146-byte string literal not displayed */
	UpperTick github_com_cosmos_cosmos_sdk_types.Int `` /* 146-byte string literal not displayed */
}

=============================== LiquidityDepthsForRange

func (*QueryLiquidityDepthsForRangeRequest) Descriptor 

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

func (*QueryLiquidityDepthsForRangeRequest) GetPoolId 

func (m *QueryLiquidityDepthsForRangeRequest) GetPoolId() uint64

func (*QueryLiquidityDepthsForRangeRequest) Marshal 

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

func (*QueryLiquidityDepthsForRangeRequest) MarshalTo 

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

func (*QueryLiquidityDepthsForRangeRequest) MarshalToSizedBuffer 

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

func (*QueryLiquidityDepthsForRangeRequest) ProtoMessage 

func (*QueryLiquidityDepthsForRangeRequest) ProtoMessage()

func (*QueryLiquidityDepthsForRangeRequest) Reset 

func (m *QueryLiquidityDepthsForRangeRequest) Reset()

func (*QueryLiquidityDepthsForRangeRequest) Size 

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

func (*QueryLiquidityDepthsForRangeRequest) String 

func (m *QueryLiquidityDepthsForRangeRequest) String() string

func (*QueryLiquidityDepthsForRangeRequest) Unmarshal 

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

func (*QueryLiquidityDepthsForRangeRequest) XXX_DiscardUnknown 

func (m *QueryLiquidityDepthsForRangeRequest) XXX_DiscardUnknown()

func (*QueryLiquidityDepthsForRangeRequest) XXX_Marshal 

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

func (*QueryLiquidityDepthsForRangeRequest) XXX_Merge 

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

func (*QueryLiquidityDepthsForRangeRequest) XXX_Size 

func (m *QueryLiquidityDepthsForRangeRequest) XXX_Size() int

func (*QueryLiquidityDepthsForRangeRequest) XXX_Unmarshal 

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

type QueryLiquidityDepthsForRangeResponse 

type QueryLiquidityDepthsForRangeResponse struct {
	LiquidityDepths []LiquidityDepth `protobuf:"bytes,1,rep,name=liquidity_depths,json=liquidityDepths,proto3" json:"liquidity_depths"`
}

func (*QueryLiquidityDepthsForRangeResponse) Descriptor 

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

func (*QueryLiquidityDepthsForRangeResponse) GetLiquidityDepths 

func (m *QueryLiquidityDepthsForRangeResponse) GetLiquidityDepths() []LiquidityDepth

func (*QueryLiquidityDepthsForRangeResponse) Marshal 

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

func (*QueryLiquidityDepthsForRangeResponse) MarshalTo 

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

func (*QueryLiquidityDepthsForRangeResponse) MarshalToSizedBuffer 

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

func (*QueryLiquidityDepthsForRangeResponse) ProtoMessage 

func (*QueryLiquidityDepthsForRangeResponse) ProtoMessage()

func (*QueryLiquidityDepthsForRangeResponse) Reset 

func (m *QueryLiquidityDepthsForRangeResponse) Reset()

func (*QueryLiquidityDepthsForRangeResponse) Size 

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

func (*QueryLiquidityDepthsForRangeResponse) String 

func (m *QueryLiquidityDepthsForRangeResponse) String() string

func (*QueryLiquidityDepthsForRangeResponse) Unmarshal 

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

func (*QueryLiquidityDepthsForRangeResponse) XXX_DiscardUnknown 

func (m *QueryLiquidityDepthsForRangeResponse) XXX_DiscardUnknown()

func (*QueryLiquidityDepthsForRangeResponse) XXX_Marshal 

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

func (*QueryLiquidityDepthsForRangeResponse) XXX_Merge 

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

func (*QueryLiquidityDepthsForRangeResponse) XXX_Size 

func (m *QueryLiquidityDepthsForRangeResponse) XXX_Size() int

func (*QueryLiquidityDepthsForRangeResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

=============================== ModuleParams

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

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

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryPoolRequest 

type QueryPoolRequest struct {
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty" yaml:"pool_id"`
}

=============================== Pool

func (*QueryPoolRequest) Descriptor 

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

func (*QueryPoolRequest) GetPoolId 

func (m *QueryPoolRequest) GetPoolId() uint64

func (*QueryPoolRequest) Marshal 

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

func (*QueryPoolRequest) MarshalTo 

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

func (*QueryPoolRequest) MarshalToSizedBuffer 

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

func (*QueryPoolRequest) ProtoMessage 

func (*QueryPoolRequest) ProtoMessage()

func (*QueryPoolRequest) Reset 

func (m *QueryPoolRequest) Reset()

func (*QueryPoolRequest) Size 

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

func (*QueryPoolRequest) String 

func (m *QueryPoolRequest) String() string

func (*QueryPoolRequest) Unmarshal 

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

func (*QueryPoolRequest) XXX_DiscardUnknown 

func (m *QueryPoolRequest) XXX_DiscardUnknown()

func (*QueryPoolRequest) XXX_Marshal 

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

func (*QueryPoolRequest) XXX_Merge 

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

func (*QueryPoolRequest) XXX_Size 

func (m *QueryPoolRequest) XXX_Size() int

func (*QueryPoolRequest) XXX_Unmarshal 

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

type QueryPoolResponse 

type QueryPoolResponse struct {
	Pool *types1.Any `protobuf:"bytes,1,opt,name=pool,proto3" json:"pool,omitempty"`
}

func (*QueryPoolResponse) Descriptor 

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

func (*QueryPoolResponse) GetPool 

func (m *QueryPoolResponse) GetPool() *types1.Any

func (*QueryPoolResponse) Marshal 

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

func (*QueryPoolResponse) MarshalTo 

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

func (*QueryPoolResponse) MarshalToSizedBuffer 

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

func (*QueryPoolResponse) ProtoMessage 

func (*QueryPoolResponse) ProtoMessage()

func (*QueryPoolResponse) Reset 

func (m *QueryPoolResponse) Reset()

func (*QueryPoolResponse) Size 

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

func (*QueryPoolResponse) String 

func (m *QueryPoolResponse) String() string

func (*QueryPoolResponse) Unmarshal 

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

func (*QueryPoolResponse) XXX_DiscardUnknown 

func (m *QueryPoolResponse) XXX_DiscardUnknown()

func (*QueryPoolResponse) XXX_Marshal 

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

func (*QueryPoolResponse) XXX_Merge 

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

func (*QueryPoolResponse) XXX_Size 

func (m *QueryPoolResponse) XXX_Size() int

func (*QueryPoolResponse) XXX_Unmarshal 

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

type QueryPoolsRequest 

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

=============================== Pools

func (*QueryPoolsRequest) Descriptor 

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

func (*QueryPoolsRequest) GetPagination 

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

func (*QueryPoolsRequest) Marshal 

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

func (*QueryPoolsRequest) MarshalTo 

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

func (*QueryPoolsRequest) MarshalToSizedBuffer 

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

func (*QueryPoolsRequest) ProtoMessage 

func (*QueryPoolsRequest) ProtoMessage()

func (*QueryPoolsRequest) Reset 

func (m *QueryPoolsRequest) Reset()

func (*QueryPoolsRequest) Size 

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

func (*QueryPoolsRequest) String 

func (m *QueryPoolsRequest) String() string

func (*QueryPoolsRequest) Unmarshal 

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

func (*QueryPoolsRequest) XXX_DiscardUnknown 

func (m *QueryPoolsRequest) XXX_DiscardUnknown()

func (*QueryPoolsRequest) XXX_Marshal 

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

func (*QueryPoolsRequest) XXX_Merge 

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

func (*QueryPoolsRequest) XXX_Size 

func (m *QueryPoolsRequest) XXX_Size() int

func (*QueryPoolsRequest) XXX_Unmarshal 

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

type QueryPoolsResponse 

type QueryPoolsResponse struct {
	Pools []*types1.Any `protobuf:"bytes,1,rep,name=pools,proto3" json:"pools,omitempty"`
	// pagination defines the pagination in the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QueryPoolsResponse) Descriptor 

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

func (*QueryPoolsResponse) GetPagination 

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

func (*QueryPoolsResponse) GetPools 

func (m *QueryPoolsResponse) GetPools() []*types1.Any

func (*QueryPoolsResponse) Marshal 

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

func (*QueryPoolsResponse) MarshalTo 

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

func (*QueryPoolsResponse) MarshalToSizedBuffer 

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

func (*QueryPoolsResponse) ProtoMessage 

func (*QueryPoolsResponse) ProtoMessage()

func (*QueryPoolsResponse) Reset 

func (m *QueryPoolsResponse) Reset()

func (*QueryPoolsResponse) Size 

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

func (*QueryPoolsResponse) String 

func (m *QueryPoolsResponse) String() string

func (*QueryPoolsResponse) Unmarshal 

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

func (*QueryPoolsResponse) XXX_DiscardUnknown 

func (m *QueryPoolsResponse) XXX_DiscardUnknown()

func (*QueryPoolsResponse) XXX_Marshal 

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

func (*QueryPoolsResponse) XXX_Merge 

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

func (*QueryPoolsResponse) XXX_Size 

func (m *QueryPoolsResponse) XXX_Size() int

func (*QueryPoolsResponse) XXX_Unmarshal 

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

type QueryRangeUnsupportedError 

type QueryRangeUnsupportedError struct {
	RequestedRange sdk.Int
	MaxRange       sdk.Int
}

func (QueryRangeUnsupportedError) Error 

func (e QueryRangeUnsupportedError) Error() string

type QueryServer 

type QueryServer interface {
	// Pools returns all concentrated liquidity pools
	Pools(context.Context, *QueryPoolsRequest) (*QueryPoolsResponse, error)
	// Pool returns the Pool specified by the pool id
	Pool(context.Context, *QueryPoolRequest) (*QueryPoolResponse, error)
	// Params returns concentrated liquidity module params.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// LiquidityDepthsForRange returns Liqiudity Depths for given range
	LiquidityDepthsForRange(context.Context, *QueryLiquidityDepthsForRangeRequest) (*QueryLiquidityDepthsForRangeResponse, error)
	// UserPositions returns all concentrated postitions of some address.
	UserPositions(context.Context, *QueryUserPositionsRequest) (*QueryUserPositionsResponse, error)
}

QueryServer is the server API for Query service.

type QueryUserPositionsRequest 

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

=============================== Positions

func (*QueryUserPositionsRequest) Descriptor 

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

func (*QueryUserPositionsRequest) GetAddress 

func (m *QueryUserPositionsRequest) GetAddress() string

func (*QueryUserPositionsRequest) Marshal 

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

func (*QueryUserPositionsRequest) MarshalTo 

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

func (*QueryUserPositionsRequest) MarshalToSizedBuffer 

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

func (*QueryUserPositionsRequest) ProtoMessage 

func (*QueryUserPositionsRequest) ProtoMessage()

func (*QueryUserPositionsRequest) Reset 

func (m *QueryUserPositionsRequest) Reset()

func (*QueryUserPositionsRequest) Size 

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

func (*QueryUserPositionsRequest) String 

func (m *QueryUserPositionsRequest) String() string

func (*QueryUserPositionsRequest) Unmarshal 

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

func (*QueryUserPositionsRequest) XXX_DiscardUnknown 

func (m *QueryUserPositionsRequest) XXX_DiscardUnknown()

func (*QueryUserPositionsRequest) XXX_Marshal 

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

func (*QueryUserPositionsRequest) XXX_Merge 

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

func (*QueryUserPositionsRequest) XXX_Size 

func (m *QueryUserPositionsRequest) XXX_Size() int

func (*QueryUserPositionsRequest) XXX_Unmarshal 

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

type QueryUserPositionsResponse 

type QueryUserPositionsResponse struct {
	Positions []FullPositionByOwnerResult `protobuf:"bytes,1,rep,name=positions,proto3" json:"positions"`
}

func (*QueryUserPositionsResponse) Descriptor 

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

func (*QueryUserPositionsResponse) GetPositions 

func (m *QueryUserPositionsResponse) GetPositions() []FullPositionByOwnerResult

func (*QueryUserPositionsResponse) Marshal 

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

func (*QueryUserPositionsResponse) MarshalTo 

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

func (*QueryUserPositionsResponse) MarshalToSizedBuffer 

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

func (*QueryUserPositionsResponse) ProtoMessage 

func (*QueryUserPositionsResponse) ProtoMessage()

func (*QueryUserPositionsResponse) Reset 

func (m *QueryUserPositionsResponse) Reset()

func (*QueryUserPositionsResponse) Size 

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

func (*QueryUserPositionsResponse) String 

func (m *QueryUserPositionsResponse) String() string

func (*QueryUserPositionsResponse) Unmarshal 

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

func (*QueryUserPositionsResponse) XXX_DiscardUnknown 

func (m *QueryUserPositionsResponse) XXX_DiscardUnknown()

func (*QueryUserPositionsResponse) XXX_Marshal 

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

func (*QueryUserPositionsResponse) XXX_Merge 

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

func (*QueryUserPositionsResponse) XXX_Size 

func (m *QueryUserPositionsResponse) XXX_Size() int

func (*QueryUserPositionsResponse) XXX_Unmarshal 

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

type TickIndexMaximumError 

type TickIndexMaximumError struct {
	MaxTick int64
}

func (TickIndexMaximumError) Error 

func (e TickIndexMaximumError) Error() string

type TickIndexMinimumError 

type TickIndexMinimumError struct {
	MinTick int64
}

func (TickIndexMinimumError) Error 

func (e TickIndexMinimumError) Error() string

type TickSpacingBoundaryError 

type TickSpacingBoundaryError struct {
	TickSpacing        uint64
	TickSpacingMinimum uint64
	TickSpacingMaximum uint64
}

func (TickSpacingBoundaryError) Error 

func (e TickSpacingBoundaryError) Error() string

type TickSpacingError 

type TickSpacingError struct {
	TickSpacing uint64
	LowerTick   int64
	UpperTick   int64
}

func (TickSpacingError) Error 

func (e TickSpacingError) Error() string

type TokenInDenomNotInPoolError 

type TokenInDenomNotInPoolError struct {
	TokenInDenom string
}

func (TokenInDenomNotInPoolError) Error 

func (e TokenInDenomNotInPoolError) Error() string

type TokenOutDenomNotInPoolError 

type TokenOutDenomNotInPoolError struct {
	TokenOutDenom string
}

func (TokenOutDenomNotInPoolError) Error 

func (e TokenOutDenomNotInPoolError) Error() string

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) CollectFees 

func (*UnimplementedMsgServer) CollectFees(ctx context.Context, req *MsgCollectFees) (*MsgCollectFeesResponse, error)

func (*UnimplementedMsgServer) CreatePosition 

func (*UnimplementedMsgServer) CreatePosition(ctx context.Context, req *MsgCreatePosition) (*MsgCreatePositionResponse, error)

func (*UnimplementedMsgServer) WithdrawPosition 

func (*UnimplementedMsgServer) WithdrawPosition(ctx context.Context, req *MsgWithdrawPosition) (*MsgWithdrawPositionResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) LiquidityDepthsForRange 

func (*UnimplementedQueryServer) LiquidityDepthsForRange(ctx context.Context, req *QueryLiquidityDepthsForRangeRequest) (*QueryLiquidityDepthsForRangeResponse, error)

func (*UnimplementedQueryServer) Params 

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

func (*UnimplementedQueryServer) Pool 

func (*UnimplementedQueryServer) Pool(ctx context.Context, req *QueryPoolRequest) (*QueryPoolResponse, error)

func (*UnimplementedQueryServer) Pools 

func (*UnimplementedQueryServer) Pools(ctx context.Context, req *QueryPoolsRequest) (*QueryPoolsResponse, error)

func (*UnimplementedQueryServer) UserPositions 

func (*UnimplementedQueryServer) UserPositions(ctx context.Context, req *QueryUserPositionsRequest) (*QueryUserPositionsResponse, 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.