types

package
v15.4.0 Latest Latest
Warning

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

 Go to latest Published: Apr 8, 2023 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// Precomputed values for min and max ticks
	MinTickNegTwelve, MaxTickNegTwelve int64 = -162000000000000, 342000000000000
	MinTickNegEleven, MaxTickNegEleven int64 = -16200000000000, 34200000000000
	MinTickNegTen, MaxTickNegTen       int64 = -1620000000000, 3420000000000
	MinTickNegNine, MaxTickNegNine     int64 = -162000000000, 342000000000
	MinTickNegEight, MaxTickNegEight   int64 = -16200000000, 34200000000
	MinTickNegSeven, MaxTickNegSeven   int64 = -1620000000, 3420000000
	MinTickNegSix, MaxTickNegSix       int64 = -162000000, 342000000
	MinTickNegFive, MaxTickNegFive     int64 = -16200000, 34200000
	MinTickNegFour, MaxTickNegFour     int64 = -1620000, 3420000
	MinTickNegThree, MaxTickNegThree   int64 = -162000, 342000
	MinTickNegTwo, MaxTickNegTwo       int64 = -16200, 34200
	MinTickNegOne, MaxTickNegOne       int64 = -1620, 3420
)
View Source 
const (
	TypeEvtCreatePosition         = "create_position"
	TypeEvtWithdrawPosition       = "withdraw_position"
	TypeEvtTotalCollectFees       = "total_collect_fees"
	TypeEvtCollectFees            = "collect_fees"
	TypeEvtTotalCollectIncentives = "total_collect_incentives"
	TypeEvtCollectIncentives      = "collect_incentives"
	TypeEvtCreateIncentive        = "create_incentive"

	AttributeValueCategory         = ModuleName
	AttributeKeyPositionId         = "position_id"
	AttributeKeyPoolId             = "pool_id"
	AttributeAmount0               = "amount0"
	AttributeAmount1               = "amount1"
	AttributeKeySwapFee            = "swap_fee"
	AttributeKeyTokensIn           = "tokens_in"
	AttributeKeyTokensOut          = "tokens_out"
	AttributeLiquidity             = "liquidity"
	AttributeJoinTime              = "join_time"
	AttributeLowerTick             = "lower_tick"
	AttributeUpperTick             = "upper_tick"
	TypeEvtPoolJoined              = "pool_joined"
	TypeEvtPoolExited              = "pool_exited"
	TypeEvtPoolCreated             = "pool_created"
	TypeEvtTokenSwapped            = "token_swapped"
	AttributeIncentiveDenom        = "incentive_denom"
	AttributeIncentiveAmount       = "incentive_amount"
	AttributeIncentiveEmissionRate = "incentive_emission_rate"
	AttributeIncentiveStartTime    = "incentive_start_time"
	AttributeIncentiveMinUptime    = "incentive_min_uptime"
)
View Source 
const (
	ModuleName = "concentratedliquidity"
	RouterKey  = ModuleName

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

constants.

Variables

View Source 
var (
	ConcentratedGasFeeForSwap = 10_000
	ExponentAtPriceOneMax     = sdk.NewInt(-1)
	ExponentAtPriceOneMin     = sdk.NewInt(-12)
	MaxSpotPrice              = sdk.MustNewDecFromStr("100000000000000000000000000000000000000")
	MinSpotPrice              = sdk.MustNewDecFromStr("0.000000000000000001")
	MaxSqrtPrice, _           = MaxSpotPrice.ApproxRoot(2)
	MinSqrtPrice, _           = MinSpotPrice.ApproxRoot(2)
	// Supported uptimes preset to 1 ns, 1 min, 1 hr, 1D, 1W
	SupportedUptimes          = []time.Duration{time.Nanosecond, time.Minute, time.Hour, time.Hour * 24, time.Hour * 24 * 7}
	AuthorizedTickSpacing     = []uint64{1, 10, 60, 200}
	BaseGasFeeForNewIncentive = 10_000
)
View Source 
var (
	ErrKeyNotFound = errors.New("key not found")
	ErrValueParse  = errors.New("value parse error")
)
View Source 
var (
	ErrInvalidLengthIncentiveRecord        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowIncentiveRecord          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupIncentiveRecord = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	TickPrefix                   = []byte{0x01}
	PositionPrefix               = []byte{0x02}
	PoolPrefix                   = []byte{0x03}
	IncentivePrefix              = []byte{0x04}
	PositionIdPrefix             = []byte{0x08}
	PoolPositionPrefix           = []byte{0x09}
	FeePositionAccumulatorPrefix = []byte{0x0A}
	PoolFeeAccumulatorPrefix     = []byte{0x0B}
	UptimeAccumulatorPrefix      = []byte{0x0C}

	// n.b. we negative prefix must be less than the positive prefix for proper iteration
	TickNegativePrefix = []byte{0x05}
	TickPositivePrefix = []byte{0x06}

	KeyNextGlobalPositionId = []byte{0x07}

	// prefix, pool id, sign byte, tick index
	TickKeyLengthBytes = len(TickPrefix) + uint64ByteSize + 1 + uint64ByteSize
)

Key prefixes

View Source 
var (
	KeyAuthorizedTickSpacing = []byte("AuthorizedTickSpacing")
	KeyAuthorizedSwapFees    = []byte("AuthorizedSwapFees")
)

Parameter store keys.

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

func KeyAddressAndPoolId(addr sdk.AccAddress, poolId uint64) []byte

func KeyAddressPoolIdPositionId 

func KeyAddressPoolIdPositionId(addr sdk.AccAddress, poolId uint64, positionId uint64) []byte

func KeyFeePoolAccumulator 

func KeyFeePoolAccumulator(poolId uint64) string

func KeyFeePositionAccumulator 

func KeyFeePositionAccumulator(positionId uint64) string

func KeyIncentiveRecord 

func KeyIncentiveRecord(poolId uint64, minUptimeIndex int, denom string, addr sdk.AccAddress) []byte

func KeyPool 

func KeyPool(poolId uint64) []byte

func KeyPoolIncentiveRecords 

func KeyPoolIncentiveRecords(poolId uint64) []byte

func KeyPoolPosition 

func KeyPoolPosition(poolId uint64) []byte

func KeyPoolPositionPositionId 

func KeyPoolPositionPositionId(poolId uint64, positionId uint64) []byte

func KeyPositionId 

func KeyPositionId(positionId uint64) []byte

func KeyTick 

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

KeyTick generates a tick key for a given pool and tick index by concatenating the tick prefix key (generated using keyTickPrefixByPoolIdPrealloc) with the KeySeparator and the tick index bytes. This function is used to create unique keys for ticks within a pool.

Parameters: - poolId (uint64): The pool id for which the tick key is to be generated. - tickIndex (int64): The tick index for which the tick key is to be generated.

Returns: - []byte: A byte slice representing the generated tick key.

func KeyTickPrefixByPoolId 

func KeyTickPrefixByPoolId(poolId uint64) []byte

KeyTickPrefixByPoolId generates a tick prefix key for a given pool by calling the keyTickPrefixByPoolIdPrealloc function with the appropriate pre-allocated memory size. The resulting tick prefix key is used as a base for generating unique tick keys within a pool.

Parameters: - poolId (uint64): The pool id for which the tick prefix key is to be generated.

Returns: - []byte: A byte slice representing the generated tick prefix key.

func KeyUptimeAccumulator 

func KeyUptimeAccumulator(poolId uint64, uptimeIndex uint64) string

func KeyUptimeIncentiveRecords 

func KeyUptimeIncentiveRecords(poolId uint64, minUptimeIndex int) []byte

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 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 AddressPoolPositionIdNotFoundError 

type AddressPoolPositionIdNotFoundError struct {
	PositionId uint64
	Owner      string
	PoolId     uint64
}

func (AddressPoolPositionIdNotFoundError) Error 

func (e AddressPoolPositionIdNotFoundError) Error() string

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 {
	GetAllBalances(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	GetDenomMetaData(ctx sdk.Context, denom string) (banktypes.Metadata, bool)
	SendCoins(ctx sdk.Context, fromAddr sdk.AccAddress, toAddr sdk.AccAddress, amt sdk.Coins) error
	HasBalance(ctx sdk.Context, addr sdk.AccAddress, amt sdk.Coin) bool
}

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

type ConcentratedPoolExtension 

type ConcentratedPoolExtension interface {
	poolmanagertypes.PoolI

	GetIncentivesAddress() sdk.AccAddress
	GetToken0() string
	GetToken1() string
	GetCurrentSqrtPrice() sdk.Dec
	GetCurrentTick() sdk.Int
	GetExponentAtPriceOne() sdk.Int
	GetTickSpacing() uint64
	GetLiquidity() sdk.Dec
	GetLastLiquidityUpdate() time.Time
	SetCurrentSqrtPrice(newSqrtPrice sdk.Dec)
	SetCurrentTick(newTick sdk.Int)
	SetLastLiquidityUpdate(newTime time.Time)

	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 IncentiveInsufficientBalanceError 

type IncentiveInsufficientBalanceError struct {
	PoolId          uint64
	IncentiveDenom  string
	IncentiveAmount sdk.Int
}

func (IncentiveInsufficientBalanceError) Error 

func (e IncentiveInsufficientBalanceError) Error() string

type IncentiveRecord 

type IncentiveRecord struct {
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// incentive_denom is the denom of the token being distributed as part of this
	// incentive record
	IncentiveDenom string `` /* 126-byte string literal not displayed */
	// incentiveCreator is the address that created the incentive record. This
	// address does not have any special privileges – it is only kept to keep
	// incentive records created by different addresses separate.
	IncentiveCreatorAddr string `` /* 153-byte string literal not displayed */
	// incentive record body holds necessary
	IncentiveRecordBody IncentiveRecordBody `` /* 139-byte string literal not displayed */
	// min_uptime is the minimum uptime required for liquidity to qualify for this
	// incentive. It should be always be one of the supported uptimes in
	// types.SupportedUptimes
	MinUptime time.Duration `protobuf:"bytes,5,opt,name=min_uptime,json=minUptime,proto3,stdduration" json:"min_uptime" yaml:"min_uptime"`
}

IncentiveRecord is the high-level struct we use to deal with an independent incentive being distributed on a pool. Note that PoolId, Denom, and MinUptime are included in the key so we avoid storing them in state, hence the distinction between IncentiveRecord and IncentiveRecordBody.

func (*IncentiveRecord) Descriptor 

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

func (*IncentiveRecord) GetIncentiveCreatorAddr 

func (m *IncentiveRecord) GetIncentiveCreatorAddr() string

func (*IncentiveRecord) GetIncentiveDenom 

func (m *IncentiveRecord) GetIncentiveDenom() string

func (*IncentiveRecord) GetIncentiveRecordBody 

func (m *IncentiveRecord) GetIncentiveRecordBody() IncentiveRecordBody

func (*IncentiveRecord) GetMinUptime 

func (m *IncentiveRecord) GetMinUptime() time.Duration

func (*IncentiveRecord) GetPoolId 

func (m *IncentiveRecord) GetPoolId() uint64

func (*IncentiveRecord) Marshal 

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

func (*IncentiveRecord) MarshalTo 

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

func (*IncentiveRecord) MarshalToSizedBuffer 

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

func (*IncentiveRecord) ProtoMessage 

func (*IncentiveRecord) ProtoMessage()

func (*IncentiveRecord) Reset 

func (m *IncentiveRecord) Reset()

func (*IncentiveRecord) Size 

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

func (*IncentiveRecord) String 

func (m *IncentiveRecord) String() string

func (*IncentiveRecord) Unmarshal 

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

func (*IncentiveRecord) XXX_DiscardUnknown 

func (m *IncentiveRecord) XXX_DiscardUnknown()

func (*IncentiveRecord) XXX_Marshal 

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

func (*IncentiveRecord) XXX_Merge 

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

func (*IncentiveRecord) XXX_Size 

func (m *IncentiveRecord) XXX_Size() int

func (*IncentiveRecord) XXX_Unmarshal 

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

type IncentiveRecordBody 

type IncentiveRecordBody struct {
	// remaining_amount is the total amount of incentives to be distributed
	RemainingAmount github_com_cosmos_cosmos_sdk_types.Dec `` /* 170-byte string literal not displayed */
	// emission_rate is the incentive emission rate per second
	EmissionRate github_com_cosmos_cosmos_sdk_types.Dec `` /* 153-byte string literal not displayed */
	// start_time is the time when the incentive starts distributing
	StartTime time.Time `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time" yaml:"start_time"`
}

IncentiveRecordBody represents the body stored in state for each individual record.

func (*IncentiveRecordBody) Descriptor 

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

func (*IncentiveRecordBody) GetStartTime 

func (m *IncentiveRecordBody) GetStartTime() time.Time

func (*IncentiveRecordBody) Marshal 

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

func (*IncentiveRecordBody) MarshalTo 

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

func (*IncentiveRecordBody) MarshalToSizedBuffer 

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

func (*IncentiveRecordBody) ProtoMessage 

func (*IncentiveRecordBody) ProtoMessage()

func (*IncentiveRecordBody) Reset 

func (m *IncentiveRecordBody) Reset()

func (*IncentiveRecordBody) Size 

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

func (*IncentiveRecordBody) String 

func (m *IncentiveRecordBody) String() string

func (*IncentiveRecordBody) Unmarshal 

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

func (*IncentiveRecordBody) XXX_DiscardUnknown 

func (m *IncentiveRecordBody) XXX_DiscardUnknown()

func (*IncentiveRecordBody) XXX_Marshal 

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

func (*IncentiveRecordBody) XXX_Merge 

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

func (*IncentiveRecordBody) XXX_Size 

func (m *IncentiveRecordBody) XXX_Size() int

func (*IncentiveRecordBody) XXX_Unmarshal 

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

type IncentiveRecordNotFoundError 

type IncentiveRecordNotFoundError struct {
	PoolId              uint64
	IncentiveDenom      string
	MinUptime           time.Duration
	IncentiveCreatorStr string
}

func (IncentiveRecordNotFoundError) Error 

func (e IncentiveRecordNotFoundError) Error() string

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 InsufficientPoolBalanceError 

type InsufficientPoolBalanceError struct {
	Err error
}

func (InsufficientPoolBalanceError) Error 

func (e InsufficientPoolBalanceError) Error() string

func (*InsufficientPoolBalanceError) Unwrap 

func (e *InsufficientPoolBalanceError) Unwrap() error

type InsufficientUserBalanceError 

type InsufficientUserBalanceError struct {
	Err error
}

func (InsufficientUserBalanceError) Error 

func (e InsufficientUserBalanceError) Error() string

func (*InsufficientUserBalanceError) Unwrap 

func (e *InsufficientUserBalanceError) Unwrap() error

type InvalidAmountCalculatedError 

type InvalidAmountCalculatedError struct {
	Amount sdk.Int
}

func (InvalidAmountCalculatedError) Error 

func (e InvalidAmountCalculatedError) Error() string

type InvalidDirectionError 

type InvalidDirectionError struct {
	PoolTick   int64
	TargetTick int64
	ZeroForOne bool
}

func (InvalidDirectionError) Error 

func (e InvalidDirectionError) Error() string

type InvalidKeyComponentError 

type InvalidKeyComponentError struct {
	KeyStr                string
	KeySeparator          string
	NumComponentsExpected int
	ComponentsExpectedStr string
}

func (InvalidKeyComponentError) Error 

func (e InvalidKeyComponentError) 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 InvalidMinUptimeError 

type InvalidMinUptimeError struct {
	PoolId           uint64
	MinUptime        time.Duration
	SupportedUptimes []time.Duration
}

func (InvalidMinUptimeError) Error 

func (e InvalidMinUptimeError) Error() string

type InvalidNextPositionIdError 

type InvalidNextPositionIdError struct {
	NextPositionId uint64
}

func (InvalidNextPositionIdError) Error 

func (e InvalidNextPositionIdError) Error() string

type InvalidPrefixError 

type InvalidPrefixError struct {
	Actual   string
	Expected string
}

func (InvalidPrefixError) Error 

func (e InvalidPrefixError) 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 InvalidTickIndexEncodingError 

type InvalidTickIndexEncodingError struct {
	Length int
}

func (InvalidTickIndexEncodingError) Error 

func (e InvalidTickIndexEncodingError) Error() string

type InvalidTickKeyByteLengthError 

type InvalidTickKeyByteLengthError struct {
	Length int
}

func (InvalidTickKeyByteLengthError) Error 

func (e InvalidTickKeyByteLengthError) Error() string

type InvalidUptimeIndexError 

type InvalidUptimeIndexError struct {
	MinUptime        time.Duration
	SupportedUptimes []time.Duration
}

func (InvalidUptimeIndexError) Error 

func (e InvalidUptimeIndexError) Error() string

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)
	CollectIncentives(ctx context.Context, in *MsgCollectIncentives, opts ...grpc.CallOption) (*MsgCollectIncentivesResponse, 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 {
	PositionIds []uint64 `protobuf:"varint,1,rep,packed,name=position_ids,json=positionIds,proto3" json:"position_ids,omitempty" yaml:"position_ids"`
	Sender      string   `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
}

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

func (*MsgCollectFees) Descriptor 

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

func (*MsgCollectFees) GetPositionIds 

func (m *MsgCollectFees) GetPositionIds() []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) 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 {
	CollectedFees []types.Coin `protobuf:"bytes,1,rep,name=collected_fees,json=collectedFees,proto3" json:"collected_fees" yaml:"collected_fees"`
}

func (*MsgCollectFeesResponse) Descriptor 

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

func (*MsgCollectFeesResponse) GetCollectedFees 

func (m *MsgCollectFeesResponse) GetCollectedFees() []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 MsgCollectIncentives 

type MsgCollectIncentives struct {
	PositionIds []uint64 `protobuf:"varint,1,rep,packed,name=position_ids,json=positionIds,proto3" json:"position_ids,omitempty" yaml:"position_ids"`
	Sender      string   `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
}

===================== MsgCollectIncentives

func (*MsgCollectIncentives) Descriptor 

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

func (*MsgCollectIncentives) GetPositionIds 

func (m *MsgCollectIncentives) GetPositionIds() []uint64

func (*MsgCollectIncentives) GetSender 

func (m *MsgCollectIncentives) GetSender() string

func (MsgCollectIncentives) GetSignBytes 

func (msg MsgCollectIncentives) GetSignBytes() []byte

func (MsgCollectIncentives) GetSigners 

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

func (*MsgCollectIncentives) Marshal 

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

func (*MsgCollectIncentives) MarshalTo 

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

func (*MsgCollectIncentives) MarshalToSizedBuffer 

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

func (*MsgCollectIncentives) ProtoMessage 

func (*MsgCollectIncentives) ProtoMessage()

func (*MsgCollectIncentives) Reset 

func (m *MsgCollectIncentives) Reset()

func (MsgCollectIncentives) Route 

func (msg MsgCollectIncentives) Route() string

func (*MsgCollectIncentives) Size 

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

func (*MsgCollectIncentives) String 

func (m *MsgCollectIncentives) String() string

func (MsgCollectIncentives) Type 

func (msg MsgCollectIncentives) Type() string

func (*MsgCollectIncentives) Unmarshal 

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

func (MsgCollectIncentives) ValidateBasic 

func (msg MsgCollectIncentives) ValidateBasic() error

func (*MsgCollectIncentives) XXX_DiscardUnknown 

func (m *MsgCollectIncentives) XXX_DiscardUnknown()

func (*MsgCollectIncentives) XXX_Marshal 

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

func (*MsgCollectIncentives) XXX_Merge 

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

func (*MsgCollectIncentives) XXX_Size 

func (m *MsgCollectIncentives) XXX_Size() int

func (*MsgCollectIncentives) XXX_Unmarshal 

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

type MsgCollectIncentivesResponse 

type MsgCollectIncentivesResponse struct {
	CollectedIncentives []types.Coin `` /* 136-byte string literal not displayed */
}

func (*MsgCollectIncentivesResponse) Descriptor 

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

func (*MsgCollectIncentivesResponse) GetCollectedIncentives 

func (m *MsgCollectIncentivesResponse) GetCollectedIncentives() []types.Coin

func (*MsgCollectIncentivesResponse) Marshal 

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

func (*MsgCollectIncentivesResponse) MarshalTo 

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

func (*MsgCollectIncentivesResponse) MarshalToSizedBuffer 

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

func (*MsgCollectIncentivesResponse) ProtoMessage 

func (*MsgCollectIncentivesResponse) ProtoMessage()

func (*MsgCollectIncentivesResponse) Reset 

func (m *MsgCollectIncentivesResponse) Reset()

func (*MsgCollectIncentivesResponse) Size 

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

func (*MsgCollectIncentivesResponse) String 

func (m *MsgCollectIncentivesResponse) String() string

func (*MsgCollectIncentivesResponse) Unmarshal 

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

func (*MsgCollectIncentivesResponse) XXX_DiscardUnknown 

func (m *MsgCollectIncentivesResponse) XXX_DiscardUnknown()

func (*MsgCollectIncentivesResponse) XXX_Marshal 

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

func (*MsgCollectIncentivesResponse) XXX_Merge 

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

func (*MsgCollectIncentivesResponse) XXX_Size 

func (m *MsgCollectIncentivesResponse) XXX_Size() int

func (*MsgCollectIncentivesResponse) XXX_Unmarshal 

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

type MsgCreateIncentive 

type MsgCreateIncentive 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"`
	IncentiveDenom  string                                 `protobuf:"bytes,3,opt,name=incentive_denom,json=incentiveDenom,proto3" json:"incentive_denom,omitempty"`
	IncentiveAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 170-byte string literal not displayed */
	EmissionRate    github_com_cosmos_cosmos_sdk_types.Dec `` /* 158-byte string literal not displayed */
	StartTime       time.Time                              `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time" yaml:"start_time"`
	MinUptime       time.Duration                          `protobuf:"bytes,7,opt,name=min_uptime,json=minUptime,proto3,stdduration" json:"duration,omitempty" yaml:"min_uptime"`
}

===================== MsgCreateIncentive

func (*MsgCreateIncentive) Descriptor 

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

func (*MsgCreateIncentive) GetIncentiveDenom 

func (m *MsgCreateIncentive) GetIncentiveDenom() string

func (*MsgCreateIncentive) GetMinUptime 

func (m *MsgCreateIncentive) GetMinUptime() time.Duration

func (*MsgCreateIncentive) GetPoolId 

func (m *MsgCreateIncentive) GetPoolId() uint64

func (*MsgCreateIncentive) GetSender 

func (m *MsgCreateIncentive) GetSender() string

func (MsgCreateIncentive) GetSignBytes 

func (msg MsgCreateIncentive) GetSignBytes() []byte

func (MsgCreateIncentive) GetSigners 

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

func (*MsgCreateIncentive) GetStartTime 

func (m *MsgCreateIncentive) GetStartTime() time.Time

func (*MsgCreateIncentive) Marshal 

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

func (*MsgCreateIncentive) MarshalTo 

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

func (*MsgCreateIncentive) MarshalToSizedBuffer 

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

func (*MsgCreateIncentive) ProtoMessage 

func (*MsgCreateIncentive) ProtoMessage()

func (*MsgCreateIncentive) Reset 

func (m *MsgCreateIncentive) Reset()

func (MsgCreateIncentive) Route 

func (msg MsgCreateIncentive) Route() string

func (*MsgCreateIncentive) Size 

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

func (*MsgCreateIncentive) String 

func (m *MsgCreateIncentive) String() string

func (MsgCreateIncentive) Type 

func (msg MsgCreateIncentive) Type() string

func (*MsgCreateIncentive) Unmarshal 

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

func (MsgCreateIncentive) ValidateBasic 

func (msg MsgCreateIncentive) ValidateBasic() error

func (*MsgCreateIncentive) XXX_DiscardUnknown 

func (m *MsgCreateIncentive) XXX_DiscardUnknown()

func (*MsgCreateIncentive) XXX_Marshal 

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

func (*MsgCreateIncentive) XXX_Merge 

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

func (*MsgCreateIncentive) XXX_Size 

func (m *MsgCreateIncentive) XXX_Size() int

func (*MsgCreateIncentive) XXX_Unmarshal 

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

type MsgCreateIncentiveResponse 

type MsgCreateIncentiveResponse struct {
	IncentiveDenom  string                                 `protobuf:"bytes,1,opt,name=incentive_denom,json=incentiveDenom,proto3" json:"incentive_denom,omitempty"`
	IncentiveAmount github_com_cosmos_cosmos_sdk_types.Dec `` /* 170-byte string literal not displayed */
	EmissionRate    github_com_cosmos_cosmos_sdk_types.Dec `` /* 158-byte string literal not displayed */
	StartTime       time.Time                              `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time" yaml:"start_time"`
	MinUptime       time.Duration                          `protobuf:"bytes,5,opt,name=min_uptime,json=minUptime,proto3,stdduration" json:"duration,omitempty" yaml:"min_uptime"`
}

func (*MsgCreateIncentiveResponse) Descriptor 

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

func (*MsgCreateIncentiveResponse) GetIncentiveDenom 

func (m *MsgCreateIncentiveResponse) GetIncentiveDenom() string

func (*MsgCreateIncentiveResponse) GetMinUptime 

func (m *MsgCreateIncentiveResponse) GetMinUptime() time.Duration

func (*MsgCreateIncentiveResponse) GetStartTime 

func (m *MsgCreateIncentiveResponse) GetStartTime() time.Time

func (*MsgCreateIncentiveResponse) Marshal 

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

func (*MsgCreateIncentiveResponse) MarshalTo 

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

func (*MsgCreateIncentiveResponse) MarshalToSizedBuffer 

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

func (*MsgCreateIncentiveResponse) ProtoMessage 

func (*MsgCreateIncentiveResponse) ProtoMessage()

func (*MsgCreateIncentiveResponse) Reset 

func (m *MsgCreateIncentiveResponse) Reset()

func (*MsgCreateIncentiveResponse) Size 

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

func (*MsgCreateIncentiveResponse) String 

func (m *MsgCreateIncentiveResponse) String() string

func (*MsgCreateIncentiveResponse) Unmarshal 

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

func (*MsgCreateIncentiveResponse) XXX_DiscardUnknown 

func (m *MsgCreateIncentiveResponse) XXX_DiscardUnknown()

func (*MsgCreateIncentiveResponse) XXX_Marshal 

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

func (*MsgCreateIncentiveResponse) XXX_Merge 

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

func (*MsgCreateIncentiveResponse) XXX_Size 

func (m *MsgCreateIncentiveResponse) XXX_Size() int

func (*MsgCreateIncentiveResponse) XXX_Unmarshal 

func (m *MsgCreateIncentiveResponse) 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 */
}

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

func (*MsgCreatePosition) Descriptor 

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

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 {
	PositionId       uint64                                 `protobuf:"varint,1,opt,name=position_id,json=positionId,proto3" json:"position_id,omitempty" yaml:"position_id"`
	Amount0          github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,2,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,3,opt,name=amount1,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount1" yaml:"amount1"`
	JoinTime         time.Time                              `protobuf:"bytes,4,opt,name=join_time,json=joinTime,proto3,stdtime" json:"join_time" yaml:"join_time"`
	LiquidityCreated github_com_cosmos_cosmos_sdk_types.Dec `` /* 174-byte string literal not displayed */
}

func (*MsgCreatePositionResponse) Descriptor 

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

func (*MsgCreatePositionResponse) GetJoinTime 

func (m *MsgCreatePositionResponse) GetJoinTime() time.Time

func (*MsgCreatePositionResponse) GetPositionId 

func (m *MsgCreatePositionResponse) GetPositionId() uint64

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)
	CollectIncentives(context.Context, *MsgCollectIncentives) (*MsgCollectIncentivesResponse, error)
}

MsgServer is the server API for Msg service.

type MsgWithdrawPosition 

type MsgWithdrawPosition struct {
	PositionId      uint64                                 `protobuf:"varint,1,opt,name=position_id,json=positionId,proto3" json:"position_id,omitempty" yaml:"position_id"`
	Sender          string                                 `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	LiquidityAmount github_com_cosmos_cosmos_sdk_types.Dec `` /* 170-byte string literal not displayed */
}

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

func (*MsgWithdrawPosition) Descriptor 

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

func (*MsgWithdrawPosition) GetPositionId 

func (m *MsgWithdrawPosition) GetPositionId() 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) 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 NegativeDurationError 

type NegativeDurationError struct {
	Duration time.Duration
}

func (NegativeDurationError) Error 

func (e NegativeDurationError) Error() string

type NegativeLiquidityError 

type NegativeLiquidityError struct {
	Liquidity sdk.Dec
}

func (NegativeLiquidityError) Error 

func (e NegativeLiquidityError) Error() string

type NonPositiveEmissionRateError 

type NonPositiveEmissionRateError struct {
	PoolId       uint64
	EmissionRate sdk.Dec
}

func (NonPositiveEmissionRateError) Error 

func (e NonPositiveEmissionRateError) Error() string

type NonPositiveIncentiveAmountError 

type NonPositiveIncentiveAmountError struct {
	PoolId          uint64
	IncentiveAmount sdk.Dec
}

func (NonPositiveIncentiveAmountError) Error 

func (e NonPositiveIncentiveAmountError) 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 */
	AuthorizedSwapFees    []github_com_cosmos_cosmos_sdk_types.Dec `` /* 185-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/osmosis-labs/osmosis/issues/3684

func NewParams 

func NewParams(authorizedTickSpacing []uint64, authorizedSwapFees []sdk.Dec) 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 PoolPositionIdNotFoundError 

type PoolPositionIdNotFoundError struct {
	PositionId uint64
	PoolId     uint64
}

func (PoolPositionIdNotFoundError) Error 

func (e PoolPositionIdNotFoundError) Error() string

type PositionAlreadyExistsError 

type PositionAlreadyExistsError struct {
	PoolId    uint64
	LowerTick int64
	UpperTick int64
	JoinTime  time.Time
}

func (PositionAlreadyExistsError) Error 

func (e PositionAlreadyExistsError) Error() string

type PositionIdNotFoundError 

type PositionIdNotFoundError struct {
	PositionId uint64
}

func (PositionIdNotFoundError) Error 

func (e PositionIdNotFoundError) Error() string

type PositionNotFoundError 

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

func (PositionNotFoundError) Error 

func (e PositionNotFoundError) 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 QueryRangeUnsupportedError 

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

func (QueryRangeUnsupportedError) Error 

func (e QueryRangeUnsupportedError) Error() string

type SpotPriceNegativeError 

type SpotPriceNegativeError struct {
	ProvidedPrice sdk.Dec
}

func (SpotPriceNegativeError) Error 

func (e SpotPriceNegativeError) Error() string

type SqrtPriceNegativeError 

type SqrtPriceNegativeError struct {
	ProvidedSqrtPrice sdk.Dec
}

func (SqrtPriceNegativeError) Error 

func (e SqrtPriceNegativeError) Error() string

type StartTimeTooEarlyError 

type StartTimeTooEarlyError struct {
	PoolId           uint64
	CurrentBlockTime time.Time
	StartTime        time.Time
}

func (StartTimeTooEarlyError) Error 

func (e StartTimeTooEarlyError) Error() string

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 TickIndexNotWithinBoundariesError 

type TickIndexNotWithinBoundariesError struct {
	MaxTick  int64
	MinTick  int64
	WantTick int64
}

func (TickIndexNotWithinBoundariesError) Error 

func (e TickIndexNotWithinBoundariesError) Error() string

type TickNotFoundError 

type TickNotFoundError struct {
	Tick int64
}

func (TickNotFoundError) Error 

func (e TickNotFoundError) 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) CollectIncentives 

func (*UnimplementedMsgServer) CollectIncentives(ctx context.Context, req *MsgCollectIncentives) (*MsgCollectIncentivesResponse, 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 ValueNotFoundForKeyError 

type ValueNotFoundForKeyError struct {
	Key []byte
}

func (ValueNotFoundForKeyError) Error 

func (e ValueNotFoundForKeyError) Error() string

type ValueParseError 

type ValueParseError struct {
	Wrapped error
}

func (ValueParseError) Error 

func (e ValueParseError) Error() string

func (ValueParseError) Unwrap 

func (e ValueParseError) Unwrap() error

Source Files

View all Source files

Directories

Path Synopsis
Package query is a reverse proxy.
 Package query is a reverse proxy.

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.