types

package
v21.2.1 Latest Latest
Warning

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

 Go to latest Published: Jan 3, 2024 License: Apache-2.0 Imports: 33 Imported by: 9

Documentation

Index

Constants

View Source 
const (
	AttributeValueCategory       = ModuleName
	TypeEvtPoolCreated           = "pool_created"
	TypeEvtSplitRouteSwapExactIn = "split_route_swap_exact_in"
	AttributeKeyTokensIn         = "tokens_in"
	AttributeKeyTokensOut        = "tokens_out"
	AttributeKeyPoolId           = "pool_id"
	AttributeKeyDenom0           = "denom0"
	AttributeKeyDenom1           = "denom1"
	AttributeKeyTakerFee         = "taker_fee"
)
View Source 
const (
	ModuleName   = "poolmanager"
	KeySeparator = "|"

	StoreKey = ModuleName

	RouterKey = ModuleName
)
View Source 
const (
	TypeMsgSwapExactAmountIn            = "swap_exact_amount_in"
	TypeMsgSwapExactAmountOut           = "swap_exact_amount_out"
	TypeMsgSplitRouteSwapExactAmountIn  = "split_route_swap_exact_amount_in"
	TypeMsgSplitRouteSwapExactAmountOut = "split_route_swap_exact_amount_out"
	TypeMsgSetDenomPairTakerFee         = "set_denom_pair_taker_fee"
)

constants.

View Source 
const (
	ProposalTypeDenomPairTakerFee = "DenomPairTakerFee"
)

Variables

View Source 
var (
	ErrEmptyRoutes               = errors.New("provided empty routes")
	ErrTooFewPoolAssets          = errors.New("pool should have at least 2 assets, as they must be swapping between at least two assets")
	ErrTooManyPoolAssets         = errors.New("pool has too many assets (currently capped at 8 assets per pool)")
	ErrDuplicateRoutesNotAllowed = errors.New("duplicate multihop routes are not allowed")
)
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 (
	ErrInvalidLengthGov        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGov          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGov = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// KeyNextGlobalPoolId defines key to store the next Pool ID to be used.
	KeyNextGlobalPoolId = []byte{0x01}

	// SwapModuleRouterPrefix defines prefix to store pool id to swap module mappings.
	SwapModuleRouterPrefix = []byte{0x02}

	// KeyPoolVolumePrefix defines prefix to store pool volume.
	KeyPoolVolumePrefix = []byte{0x03}

	// DenomTradePairPrefix defines prefix to store denom trade pair for taker fee.
	DenomTradePairPrefix = []byte{0x04}

	// KeyTakerFeeStakersProtoRev defines key to store the taker fee for stakers tracker.
	KeyTakerFeeStakersProtoRev = []byte{0x05}

	// KeyTakerFeeCommunityPoolProtoRev defines key to store the taker fee for community pool tracker.
	KeyTakerFeeCommunityPoolProtoRev = []byte{0x06}

	// KeyTakerFeeProtoRevAccountingHeight defines key to store the accounting height for the above taker fee trackers.
	KeyTakerFeeProtoRevAccountingHeight = []byte{0x07}
)
View Source 
var (
	ErrInvalidLengthModuleRoute        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowModuleRoute          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupModuleRoute = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	KeyPoolCreationFee                                = []byte("PoolCreationFee")
	KeyDefaultTakerFee                                = []byte("DefaultTakerFee")
	KeyOsmoTakerFeeDistribution                       = []byte("OsmoTakerFeeDistribution")
	KeyNonOsmoTakerFeeDistribution                    = []byte("NonOsmoTakerFeeDistribution")
	KeyAdminAddresses                                 = []byte("AdminAddresses")
	KeyCommunityPoolDenomToSwapNonWhitelistedAssetsTo = []byte("CommunityPoolDenomToSwapNonWhitelistedAssetsTo")
	KeyAuthorizedQuoteDenoms                          = []byte("AuthorizedQuoteDenoms")
	KeyReducedTakerFeeByWhitelist                     = []byte("ReducedTakerFeeByWhitelist")
)

Parameter store keys.

View Source 
var (
	ErrInvalidLengthSwapRoute        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSwapRoute          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSwapRoute = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTrackedVolume        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTrackedVolume          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTrackedVolume = 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)
)
View Source 
var PoolType_name = map[int32]string{
	0: "Balancer",
	1: "Stableswap",
	2: "Concentrated",
	3: "CosmWasm",
}
View Source 
var PoolType_value = map[string]int32{
	"Balancer":     0,
	"Stableswap":   1,
	"Concentrated": 2,
	"CosmWasm":     3,
}

Functions

func FormatDenomTradePairKey 

func FormatDenomTradePairKey(denom0, denom1 string) []byte

FormatDenomTradePairKey serializes denom trade pair to bytes. Denom trade pair is automatically sorted lexicographically.

func FormatModuleRouteKey 

func FormatModuleRouteKey(poolId uint64) []byte

ModuleRouteToBytes serializes moduleRoute to bytes.

func KeyPoolVolume 

func KeyPoolVolume(poolId uint64) []byte

KeyPoolVolume returns the key for the pool volume corresponding to the given poolId.

func NewDenomPairTakerFeeProposal 

func NewDenomPairTakerFeeProposal(title, description string, records []DenomPairTakerFee) govtypesv1.Content

NewDenomPairTakerFeeProposal returns a new instance of a denom pair taker fee proposal struct.

func NewPoolAddress 

func NewPoolAddress(poolId uint64) sdk.AccAddress

NewPoolAddress returns an address for a pool from a given id.

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamTable for gamm module.

func ParseDenomTradePairKey 

func ParseDenomTradePairKey(key []byte) (denom0, denom1 string, err error)

ParseDenomTradePairKey parses the raw bytes of the DenomTradePairKey into a denom trade pair.

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec registers the necessary x/gamm interfaces and concrete types on the provided LegacyAmino codec. These types are used for Amino JSON serialization.

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func ValidateSwapAmountInSplitRoute 

func ValidateSwapAmountInSplitRoute(splitRoutes []SwapAmountInSplitRoute) error

ValidateSwapAmountInSplitRoute validates a slice of SwapAmountInSplitRoute.

returns an error if any of the following are true: - the slice is empty - any SwapAmountInRoute in the slice is invalid - the last TokenOutDenom of any SwapAmountInRoute in the slice does not match the TokenOutDenom of the previous SwapAmountInRoute in the slice - there are duplicate SwapAmountInRoutes in the slice

func ValidateSwapAmountOutSplitRoute 

func ValidateSwapAmountOutSplitRoute(splitRoutes []SwapAmountOutSplitRoute) error

ValidateSwapAmountOutSplitRoute validates a slice of SwapAmountOutSplitRoute and returns an error if any of the following are true: - the slice is empty - any SwapAmountOutRoute in the slice is invalid - the first TokenInDenom of any SwapAmountOutRoute in the slice does not match the TokenInDenom of the previous SwapAmountOutRoute in the slice - there are duplicate SwapAmountOutRoutes in the slice

Types

type AccountI 

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

AccountI defines the account contract that must be fulfilled when creating a x/gamm keeper.

type BankI 

type BankI interface {
	SendCoins(ctx sdk.Context, fromAddr sdk.AccAddress, toAddr sdk.AccAddress, amt sdk.Coins) error
	SetDenomMetaData(ctx sdk.Context, denomMetaData banktypes.Metadata)
	GetAllBalances(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
}

BankI defines the banking contract that must be fulfilled when creating a x/gamm keeper.

type CommunityPoolI 

type CommunityPoolI interface {
	FundCommunityPool(ctx sdk.Context, amount sdk.Coins, sender sdk.AccAddress) error
}

CommunityPoolI defines the contract needed to be fulfilled for distribution keeper.

type CreatePoolMsg 

type CreatePoolMsg interface {
	// GetPoolType returns the type of the pool to create.
	GetPoolType() PoolType
	// The creator of the pool, who pays the PoolCreationFee, provides initial liquidity,
	// and gets the initial LP shares.
	PoolCreator() sdk.AccAddress
	// A stateful validation function.
	Validate(ctx sdk.Context) error
	// Initial Liquidity for the pool that the sender is required to send to the pool account
	InitialLiquidity() sdk.Coins
	// CreatePool creates a pool implementing PoolI, using data from the message.
	CreatePool(ctx sdk.Context, poolID uint64) (PoolI, error)
}

CreatePoolMsg defines an interface that every CreatePool transaction should implement. The gamm logic will use this to create a pool.

type DenomPairTakerFee 

type DenomPairTakerFee struct {
	// denom0 and denom1 get automatically lexigographically sorted
	// when being stored, so the order of input here does not matter.
	Denom0   string                      `protobuf:"bytes,1,opt,name=denom0,proto3" json:"denom0,omitempty" yaml:"denom0"`
	Denom1   string                      `protobuf:"bytes,2,opt,name=denom1,proto3" json:"denom1,omitempty" yaml:"denom1"`
	TakerFee cosmossdk_io_math.LegacyDec `` /* 131-byte string literal not displayed */
}

func (*DenomPairTakerFee) Descriptor 

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

func (*DenomPairTakerFee) GetDenom0 

func (m *DenomPairTakerFee) GetDenom0() string

func (*DenomPairTakerFee) GetDenom1 

func (m *DenomPairTakerFee) GetDenom1() string

func (*DenomPairTakerFee) Marshal 

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

func (*DenomPairTakerFee) MarshalTo 

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

func (*DenomPairTakerFee) MarshalToSizedBuffer 

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

func (*DenomPairTakerFee) ProtoMessage 

func (*DenomPairTakerFee) ProtoMessage()

func (*DenomPairTakerFee) Reset 

func (m *DenomPairTakerFee) Reset()

func (*DenomPairTakerFee) Size 

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

func (*DenomPairTakerFee) String 

func (m *DenomPairTakerFee) String() string

func (*DenomPairTakerFee) Unmarshal 

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

func (*DenomPairTakerFee) XXX_DiscardUnknown 

func (m *DenomPairTakerFee) XXX_DiscardUnknown()

func (*DenomPairTakerFee) XXX_Marshal 

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

func (*DenomPairTakerFee) XXX_Merge 

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

func (*DenomPairTakerFee) XXX_Size 

func (m *DenomPairTakerFee) XXX_Size() int

func (*DenomPairTakerFee) XXX_Unmarshal 

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

type DenomPairTakerFeeProposal 

type DenomPairTakerFeeProposal struct {
	Title             string              `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Description       string              `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	DenomPairTakerFee []DenomPairTakerFee `protobuf:"bytes,3,rep,name=denom_pair_taker_fee,json=denomPairTakerFee,proto3" json:"denom_pair_taker_fee"`
}

DenomPairTakerFeeProposal is a type for adding/removing a custom taker fee(s) for one or more denom pairs.

func (*DenomPairTakerFeeProposal) Descriptor 

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

func (*DenomPairTakerFeeProposal) GetDescription 

func (p *DenomPairTakerFeeProposal) GetDescription() string

GetDescription gets the description of the proposal

func (*DenomPairTakerFeeProposal) GetTitle 

func (p *DenomPairTakerFeeProposal) GetTitle() string

func (*DenomPairTakerFeeProposal) Marshal 

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

func (*DenomPairTakerFeeProposal) MarshalTo 

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

func (*DenomPairTakerFeeProposal) MarshalToSizedBuffer 

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

func (*DenomPairTakerFeeProposal) ProposalRoute 

func (p *DenomPairTakerFeeProposal) ProposalRoute() string

ProposalRoute returns the router key for the proposal

func (*DenomPairTakerFeeProposal) ProposalType 

func (p *DenomPairTakerFeeProposal) ProposalType() string

ProposalType returns the type of the proposal

func (*DenomPairTakerFeeProposal) ProtoMessage 

func (*DenomPairTakerFeeProposal) ProtoMessage()

func (*DenomPairTakerFeeProposal) Reset 

func (m *DenomPairTakerFeeProposal) Reset()

func (*DenomPairTakerFeeProposal) Size 

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

func (DenomPairTakerFeeProposal) String 

func (p DenomPairTakerFeeProposal) String() string

String returns a string containing the denom pair taker fee proposal.

func (*DenomPairTakerFeeProposal) Unmarshal 

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

func (*DenomPairTakerFeeProposal) ValidateBasic 

func (p *DenomPairTakerFeeProposal) ValidateBasic() error

ValidateBasic validates a governance proposal's abstract and basic contents

func (*DenomPairTakerFeeProposal) XXX_DiscardUnknown 

func (m *DenomPairTakerFeeProposal) XXX_DiscardUnknown()

func (*DenomPairTakerFeeProposal) XXX_Marshal 

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

func (*DenomPairTakerFeeProposal) XXX_Merge 

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

func (*DenomPairTakerFeeProposal) XXX_Size 

func (m *DenomPairTakerFeeProposal) XXX_Size() int

func (*DenomPairTakerFeeProposal) XXX_Unmarshal 

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

type FailedToFindRouteError 

type FailedToFindRouteError struct {
	PoolId uint64
}

func (FailedToFindRouteError) Error 

func (e FailedToFindRouteError) Error() string

type FinalAmountIsNotPositiveError 

type FinalAmountIsNotPositiveError struct {
	IsAmountOut bool
	Amount      osmomath.Int
}

func (FinalAmountIsNotPositiveError) Error 

func (e FinalAmountIsNotPositiveError) Error() string

type GenesisState 

type GenesisState struct {
	// the next_pool_id
	NextPoolId uint64 `protobuf:"varint,1,opt,name=next_pool_id,json=nextPoolId,proto3" json:"next_pool_id,omitempty"`
	// params is the container of poolmanager parameters.
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
	// pool_routes is the container of the mappings from pool id to pool type.
	PoolRoutes []ModuleRoute `protobuf:"bytes,3,rep,name=pool_routes,json=poolRoutes,proto3" json:"pool_routes"`
	// KVStore state
	TakerFeesTracker       *TakerFeesTracker   `protobuf:"bytes,4,opt,name=taker_fees_tracker,json=takerFeesTracker,proto3" json:"taker_fees_tracker,omitempty"`
	PoolVolumes            []*PoolVolume       `protobuf:"bytes,5,rep,name=pool_volumes,json=poolVolumes,proto3" json:"pool_volumes,omitempty"`
	DenomPairTakerFeeStore []DenomPairTakerFee `protobuf:"bytes,6,rep,name=denom_pair_taker_fee_store,json=denomPairTakerFeeStore,proto3" json:"denom_pair_taker_fee_store"`
}

GenesisState defines the poolmanager module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default poolmanager genesis state.

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetDenomPairTakerFeeStore 

func (m *GenesisState) GetDenomPairTakerFeeStore() []DenomPairTakerFee

func (*GenesisState) GetNextPoolId 

func (m *GenesisState) GetNextPoolId() uint64

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetPoolRoutes 

func (m *GenesisState) GetPoolRoutes() []ModuleRoute

func (*GenesisState) GetPoolVolumes 

func (m *GenesisState) GetPoolVolumes() []*PoolVolume

func (*GenesisState) GetTakerFeesTracker 

func (m *GenesisState) GetTakerFeesTracker() *TakerFeesTracker

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 InactivePoolError 

type InactivePoolError struct {
	PoolId uint64
}

func (InactivePoolError) Error 

func (e InactivePoolError) Error() string

type IncorrectPoolAddressError 

type IncorrectPoolAddressError struct {
	ExpectedPoolAddress string
	ActualPoolAddress   string
}

func (IncorrectPoolAddressError) Error 

func (e IncorrectPoolAddressError) Error() string

type IncorrectPoolIdError 

type IncorrectPoolIdError struct {
	ExpectedPoolId uint64
	ActualPoolId   uint64
}

func (IncorrectPoolIdError) Error 

func (e IncorrectPoolIdError) Error() string

type InvalidFinalTokenOutError 

type InvalidFinalTokenOutError struct {
	TokenOutGivenA string
	TokenOutGivenB string
}

func (InvalidFinalTokenOutError) Error 

func (e InvalidFinalTokenOutError) Error() string

type InvalidPoolCreatorError 

type InvalidPoolCreatorError struct {
	CreatorAddresss string
}

func (InvalidPoolCreatorError) Error 

func (e InvalidPoolCreatorError) Error() string

type InvalidPoolTypeError 

type InvalidPoolTypeError struct {
	PoolType PoolType
}

func (InvalidPoolTypeError) Error 

func (e InvalidPoolTypeError) Error() string

type InvalidSenderError 

type InvalidSenderError struct {
	Sender string
}

func (InvalidSenderError) Error 

func (e InvalidSenderError) Error() string

type ModuleRoute 

type ModuleRoute struct {
	// pool_type specifies the type of the pool
	PoolType PoolType `` /* 128-byte string literal not displayed */
	PoolId   uint64   `protobuf:"varint,2,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty" yaml:"pool_id"`
}

ModuleRouter defines a route encapsulating pool type. It is used as the value of a mapping from pool id to the pool type, allowing the pool manager to know which module to route swaps to given the pool id.

func ParseModuleRouteFromBz 

func ParseModuleRouteFromBz(bz []byte) (ModuleRoute, error)

ParseModuleRouteFromBz parses the raw bytes into ModuleRoute. Returns error if fails to parse or if the bytes are empty.

func (*ModuleRoute) Descriptor 

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

func (*ModuleRoute) GetPoolId 

func (m *ModuleRoute) GetPoolId() uint64

func (*ModuleRoute) GetPoolType 

func (m *ModuleRoute) GetPoolType() PoolType

func (*ModuleRoute) Marshal 

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

func (*ModuleRoute) MarshalTo 

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

func (*ModuleRoute) MarshalToSizedBuffer 

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

func (*ModuleRoute) ProtoMessage 

func (*ModuleRoute) ProtoMessage()

func (*ModuleRoute) Reset 

func (m *ModuleRoute) Reset()

func (*ModuleRoute) Size 

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

func (*ModuleRoute) String 

func (m *ModuleRoute) String() string

func (*ModuleRoute) Unmarshal 

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

func (*ModuleRoute) XXX_DiscardUnknown 

func (m *ModuleRoute) XXX_DiscardUnknown()

func (*ModuleRoute) XXX_Marshal 

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

func (*ModuleRoute) XXX_Merge 

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

func (*ModuleRoute) XXX_Size 

func (m *ModuleRoute) XXX_Size() int

func (*ModuleRoute) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	SwapExactAmountIn(ctx context.Context, in *MsgSwapExactAmountIn, opts ...grpc.CallOption) (*MsgSwapExactAmountInResponse, error)
	SwapExactAmountOut(ctx context.Context, in *MsgSwapExactAmountOut, opts ...grpc.CallOption) (*MsgSwapExactAmountOutResponse, error)
	SplitRouteSwapExactAmountIn(ctx context.Context, in *MsgSplitRouteSwapExactAmountIn, opts ...grpc.CallOption) (*MsgSplitRouteSwapExactAmountInResponse, error)
	SplitRouteSwapExactAmountOut(ctx context.Context, in *MsgSplitRouteSwapExactAmountOut, opts ...grpc.CallOption) (*MsgSplitRouteSwapExactAmountOutResponse, error)
	SetDenomPairTakerFee(ctx context.Context, in *MsgSetDenomPairTakerFee, opts ...grpc.CallOption) (*MsgSetDenomPairTakerFeeResponse, 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 MsgServer 

type MsgServer interface {
	SwapExactAmountIn(context.Context, *MsgSwapExactAmountIn) (*MsgSwapExactAmountInResponse, error)
	SwapExactAmountOut(context.Context, *MsgSwapExactAmountOut) (*MsgSwapExactAmountOutResponse, error)
	SplitRouteSwapExactAmountIn(context.Context, *MsgSplitRouteSwapExactAmountIn) (*MsgSplitRouteSwapExactAmountInResponse, error)
	SplitRouteSwapExactAmountOut(context.Context, *MsgSplitRouteSwapExactAmountOut) (*MsgSplitRouteSwapExactAmountOutResponse, error)
	SetDenomPairTakerFee(context.Context, *MsgSetDenomPairTakerFee) (*MsgSetDenomPairTakerFeeResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSetDenomPairTakerFee 

type MsgSetDenomPairTakerFee struct {
	Sender            string              `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	DenomPairTakerFee []DenomPairTakerFee `` /* 134-byte string literal not displayed */
}

===================== MsgSetDenomPairTakerFee

func (*MsgSetDenomPairTakerFee) Descriptor 

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

func (*MsgSetDenomPairTakerFee) GetDenomPairTakerFee 

func (m *MsgSetDenomPairTakerFee) GetDenomPairTakerFee() []DenomPairTakerFee

func (*MsgSetDenomPairTakerFee) GetSender 

func (m *MsgSetDenomPairTakerFee) GetSender() string

func (MsgSetDenomPairTakerFee) GetSignBytes 

func (msg MsgSetDenomPairTakerFee) GetSignBytes() []byte

func (MsgSetDenomPairTakerFee) GetSigners 

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

func (*MsgSetDenomPairTakerFee) Marshal 

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

func (*MsgSetDenomPairTakerFee) MarshalTo 

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

func (*MsgSetDenomPairTakerFee) MarshalToSizedBuffer 

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

func (*MsgSetDenomPairTakerFee) ProtoMessage 

func (*MsgSetDenomPairTakerFee) ProtoMessage()

func (*MsgSetDenomPairTakerFee) Reset 

func (m *MsgSetDenomPairTakerFee) Reset()

func (MsgSetDenomPairTakerFee) Route 

func (msg MsgSetDenomPairTakerFee) Route() string

func (*MsgSetDenomPairTakerFee) Size 

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

func (*MsgSetDenomPairTakerFee) String 

func (m *MsgSetDenomPairTakerFee) String() string

func (MsgSetDenomPairTakerFee) Type 

func (msg MsgSetDenomPairTakerFee) Type() string

func (*MsgSetDenomPairTakerFee) Unmarshal 

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

func (MsgSetDenomPairTakerFee) ValidateBasic 

func (msg MsgSetDenomPairTakerFee) ValidateBasic() error

func (*MsgSetDenomPairTakerFee) XXX_DiscardUnknown 

func (m *MsgSetDenomPairTakerFee) XXX_DiscardUnknown()

func (*MsgSetDenomPairTakerFee) XXX_Marshal 

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

func (*MsgSetDenomPairTakerFee) XXX_Merge 

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

func (*MsgSetDenomPairTakerFee) XXX_Size 

func (m *MsgSetDenomPairTakerFee) XXX_Size() int

func (*MsgSetDenomPairTakerFee) XXX_Unmarshal 

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

type MsgSetDenomPairTakerFeeResponse 

type MsgSetDenomPairTakerFeeResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
}

func (*MsgSetDenomPairTakerFeeResponse) Descriptor 

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

func (*MsgSetDenomPairTakerFeeResponse) GetSuccess 

func (m *MsgSetDenomPairTakerFeeResponse) GetSuccess() bool

func (*MsgSetDenomPairTakerFeeResponse) Marshal 

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

func (*MsgSetDenomPairTakerFeeResponse) MarshalTo 

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

func (*MsgSetDenomPairTakerFeeResponse) MarshalToSizedBuffer 

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

func (*MsgSetDenomPairTakerFeeResponse) ProtoMessage 

func (*MsgSetDenomPairTakerFeeResponse) ProtoMessage()

func (*MsgSetDenomPairTakerFeeResponse) Reset 

func (m *MsgSetDenomPairTakerFeeResponse) Reset()

func (*MsgSetDenomPairTakerFeeResponse) Size 

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

func (*MsgSetDenomPairTakerFeeResponse) String 

func (m *MsgSetDenomPairTakerFeeResponse) String() string

func (*MsgSetDenomPairTakerFeeResponse) Unmarshal 

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

func (*MsgSetDenomPairTakerFeeResponse) XXX_DiscardUnknown 

func (m *MsgSetDenomPairTakerFeeResponse) XXX_DiscardUnknown()

func (*MsgSetDenomPairTakerFeeResponse) XXX_Marshal 

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

func (*MsgSetDenomPairTakerFeeResponse) XXX_Merge 

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

func (*MsgSetDenomPairTakerFeeResponse) XXX_Size 

func (m *MsgSetDenomPairTakerFeeResponse) XXX_Size() int

func (*MsgSetDenomPairTakerFeeResponse) XXX_Unmarshal 

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

type MsgSplitRouteSwapExactAmountIn 

type MsgSplitRouteSwapExactAmountIn struct {
	Sender            string                   `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	Routes            []SwapAmountInSplitRoute `protobuf:"bytes,2,rep,name=routes,proto3" json:"routes"`
	TokenInDenom      string                   `protobuf:"bytes,3,opt,name=token_in_denom,json=tokenInDenom,proto3" json:"token_in_denom,omitempty" yaml:"token_in_denom"`
	TokenOutMinAmount cosmossdk_io_math.Int    `` /* 167-byte string literal not displayed */
}

===================== MsgSplitRouteSwapExactAmountIn

func (*MsgSplitRouteSwapExactAmountIn) Descriptor 

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

func (*MsgSplitRouteSwapExactAmountIn) GetRoutes 

func (m *MsgSplitRouteSwapExactAmountIn) GetRoutes() []SwapAmountInSplitRoute

func (*MsgSplitRouteSwapExactAmountIn) GetSender 

func (m *MsgSplitRouteSwapExactAmountIn) GetSender() string

func (MsgSplitRouteSwapExactAmountIn) GetSignBytes 

func (msg MsgSplitRouteSwapExactAmountIn) GetSignBytes() []byte

func (MsgSplitRouteSwapExactAmountIn) GetSigners 

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

func (MsgSplitRouteSwapExactAmountIn) GetSwapMsgs 

func (msg MsgSplitRouteSwapExactAmountIn) GetSwapMsgs() []SwapMsgRoute

func (*MsgSplitRouteSwapExactAmountIn) GetTokenInDenom 

func (m *MsgSplitRouteSwapExactAmountIn) GetTokenInDenom() string

func (*MsgSplitRouteSwapExactAmountIn) Marshal 

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

func (*MsgSplitRouteSwapExactAmountIn) MarshalTo 

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

func (*MsgSplitRouteSwapExactAmountIn) MarshalToSizedBuffer 

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

func (*MsgSplitRouteSwapExactAmountIn) ProtoMessage 

func (*MsgSplitRouteSwapExactAmountIn) ProtoMessage()

func (*MsgSplitRouteSwapExactAmountIn) Reset 

func (m *MsgSplitRouteSwapExactAmountIn) Reset()

func (MsgSplitRouteSwapExactAmountIn) Route 

func (msg MsgSplitRouteSwapExactAmountIn) Route() string

func (*MsgSplitRouteSwapExactAmountIn) Size 

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

func (*MsgSplitRouteSwapExactAmountIn) String 

func (m *MsgSplitRouteSwapExactAmountIn) String() string

func (MsgSplitRouteSwapExactAmountIn) Type 

func (msg MsgSplitRouteSwapExactAmountIn) Type() string

func (*MsgSplitRouteSwapExactAmountIn) Unmarshal 

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

func (MsgSplitRouteSwapExactAmountIn) ValidateBasic 

func (msg MsgSplitRouteSwapExactAmountIn) ValidateBasic() error

func (*MsgSplitRouteSwapExactAmountIn) XXX_DiscardUnknown 

func (m *MsgSplitRouteSwapExactAmountIn) XXX_DiscardUnknown()

func (*MsgSplitRouteSwapExactAmountIn) XXX_Marshal 

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

func (*MsgSplitRouteSwapExactAmountIn) XXX_Merge 

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

func (*MsgSplitRouteSwapExactAmountIn) XXX_Size 

func (m *MsgSplitRouteSwapExactAmountIn) XXX_Size() int

func (*MsgSplitRouteSwapExactAmountIn) XXX_Unmarshal 

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

type MsgSplitRouteSwapExactAmountInResponse 

type MsgSplitRouteSwapExactAmountInResponse struct {
	TokenOutAmount cosmossdk_io_math.Int `` /* 152-byte string literal not displayed */
}

func (*MsgSplitRouteSwapExactAmountInResponse) Descriptor 

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

func (*MsgSplitRouteSwapExactAmountInResponse) Marshal 

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

func (*MsgSplitRouteSwapExactAmountInResponse) MarshalTo 

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

func (*MsgSplitRouteSwapExactAmountInResponse) MarshalToSizedBuffer 

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

func (*MsgSplitRouteSwapExactAmountInResponse) ProtoMessage 

func (*MsgSplitRouteSwapExactAmountInResponse) ProtoMessage()

func (*MsgSplitRouteSwapExactAmountInResponse) Reset 

func (m *MsgSplitRouteSwapExactAmountInResponse) Reset()

func (*MsgSplitRouteSwapExactAmountInResponse) Size 

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

func (*MsgSplitRouteSwapExactAmountInResponse) String 

func (m *MsgSplitRouteSwapExactAmountInResponse) String() string

func (*MsgSplitRouteSwapExactAmountInResponse) Unmarshal 

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

func (*MsgSplitRouteSwapExactAmountInResponse) XXX_DiscardUnknown 

func (m *MsgSplitRouteSwapExactAmountInResponse) XXX_DiscardUnknown()

func (*MsgSplitRouteSwapExactAmountInResponse) XXX_Marshal 

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

func (*MsgSplitRouteSwapExactAmountInResponse) XXX_Merge 

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

func (*MsgSplitRouteSwapExactAmountInResponse) XXX_Size 

func (m *MsgSplitRouteSwapExactAmountInResponse) XXX_Size() int

func (*MsgSplitRouteSwapExactAmountInResponse) XXX_Unmarshal 

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

type MsgSplitRouteSwapExactAmountOut 

type MsgSplitRouteSwapExactAmountOut struct {
	Sender           string                    `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	Routes           []SwapAmountOutSplitRoute `protobuf:"bytes,2,rep,name=routes,proto3" json:"routes"`
	TokenOutDenom    string                    `protobuf:"bytes,3,opt,name=token_out_denom,json=tokenOutDenom,proto3" json:"token_out_denom,omitempty" yaml:"token_out_denom"`
	TokenInMaxAmount cosmossdk_io_math.Int     `` /* 163-byte string literal not displayed */
}

===================== MsgSplitRouteSwapExactAmountOut

func (*MsgSplitRouteSwapExactAmountOut) Descriptor 

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

func (*MsgSplitRouteSwapExactAmountOut) GetRoutes 

func (m *MsgSplitRouteSwapExactAmountOut) GetRoutes() []SwapAmountOutSplitRoute

func (*MsgSplitRouteSwapExactAmountOut) GetSender 

func (m *MsgSplitRouteSwapExactAmountOut) GetSender() string

func (MsgSplitRouteSwapExactAmountOut) GetSignBytes 

func (msg MsgSplitRouteSwapExactAmountOut) GetSignBytes() []byte

func (MsgSplitRouteSwapExactAmountOut) GetSigners 

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

func (MsgSplitRouteSwapExactAmountOut) GetSwapMsgs 

func (msg MsgSplitRouteSwapExactAmountOut) GetSwapMsgs() []SwapMsgRoute

func (*MsgSplitRouteSwapExactAmountOut) GetTokenOutDenom 

func (m *MsgSplitRouteSwapExactAmountOut) GetTokenOutDenom() string

func (*MsgSplitRouteSwapExactAmountOut) Marshal 

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

func (*MsgSplitRouteSwapExactAmountOut) MarshalTo 

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

func (*MsgSplitRouteSwapExactAmountOut) MarshalToSizedBuffer 

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

func (*MsgSplitRouteSwapExactAmountOut) ProtoMessage 

func (*MsgSplitRouteSwapExactAmountOut) ProtoMessage()

func (*MsgSplitRouteSwapExactAmountOut) Reset 

func (m *MsgSplitRouteSwapExactAmountOut) Reset()

func (MsgSplitRouteSwapExactAmountOut) Route 

func (msg MsgSplitRouteSwapExactAmountOut) Route() string

func (*MsgSplitRouteSwapExactAmountOut) Size 

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

func (*MsgSplitRouteSwapExactAmountOut) String 

func (m *MsgSplitRouteSwapExactAmountOut) String() string

func (MsgSplitRouteSwapExactAmountOut) Type 

func (msg MsgSplitRouteSwapExactAmountOut) Type() string

func (*MsgSplitRouteSwapExactAmountOut) Unmarshal 

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

func (MsgSplitRouteSwapExactAmountOut) ValidateBasic 

func (msg MsgSplitRouteSwapExactAmountOut) ValidateBasic() error

func (*MsgSplitRouteSwapExactAmountOut) XXX_DiscardUnknown 

func (m *MsgSplitRouteSwapExactAmountOut) XXX_DiscardUnknown()

func (*MsgSplitRouteSwapExactAmountOut) XXX_Marshal 

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

func (*MsgSplitRouteSwapExactAmountOut) XXX_Merge 

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

func (*MsgSplitRouteSwapExactAmountOut) XXX_Size 

func (m *MsgSplitRouteSwapExactAmountOut) XXX_Size() int

func (*MsgSplitRouteSwapExactAmountOut) XXX_Unmarshal 

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

type MsgSplitRouteSwapExactAmountOutResponse 

type MsgSplitRouteSwapExactAmountOutResponse struct {
	TokenInAmount cosmossdk_io_math.Int `` /* 148-byte string literal not displayed */
}

func (*MsgSplitRouteSwapExactAmountOutResponse) Descriptor 

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

func (*MsgSplitRouteSwapExactAmountOutResponse) Marshal 

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

func (*MsgSplitRouteSwapExactAmountOutResponse) MarshalTo 

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

func (*MsgSplitRouteSwapExactAmountOutResponse) MarshalToSizedBuffer 

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

func (*MsgSplitRouteSwapExactAmountOutResponse) ProtoMessage 

func (*MsgSplitRouteSwapExactAmountOutResponse) ProtoMessage()

func (*MsgSplitRouteSwapExactAmountOutResponse) Reset 

func (m *MsgSplitRouteSwapExactAmountOutResponse) Reset()

func (*MsgSplitRouteSwapExactAmountOutResponse) Size 

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

func (*MsgSplitRouteSwapExactAmountOutResponse) String 

func (m *MsgSplitRouteSwapExactAmountOutResponse) String() string

func (*MsgSplitRouteSwapExactAmountOutResponse) Unmarshal 

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

func (*MsgSplitRouteSwapExactAmountOutResponse) XXX_DiscardUnknown 

func (m *MsgSplitRouteSwapExactAmountOutResponse) XXX_DiscardUnknown()

func (*MsgSplitRouteSwapExactAmountOutResponse) XXX_Marshal 

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

func (*MsgSplitRouteSwapExactAmountOutResponse) XXX_Merge 

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

func (*MsgSplitRouteSwapExactAmountOutResponse) XXX_Size 

func (m *MsgSplitRouteSwapExactAmountOutResponse) XXX_Size() int

func (*MsgSplitRouteSwapExactAmountOutResponse) XXX_Unmarshal 

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

type MsgSwapExactAmountIn 

type MsgSwapExactAmountIn struct {
	Sender            string                `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	Routes            []SwapAmountInRoute   `protobuf:"bytes,2,rep,name=routes,proto3" json:"routes"`
	TokenIn           types.Coin            `protobuf:"bytes,3,opt,name=token_in,json=tokenIn,proto3" json:"token_in" yaml:"token_in"`
	TokenOutMinAmount cosmossdk_io_math.Int `` /* 167-byte string literal not displayed */
}

===================== MsgSwapExactAmountIn

func (*MsgSwapExactAmountIn) Descriptor 

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

func (*MsgSwapExactAmountIn) GetRoutes 

func (m *MsgSwapExactAmountIn) GetRoutes() []SwapAmountInRoute

func (*MsgSwapExactAmountIn) GetSender 

func (m *MsgSwapExactAmountIn) GetSender() string

func (MsgSwapExactAmountIn) GetSignBytes 

func (msg MsgSwapExactAmountIn) GetSignBytes() []byte

func (MsgSwapExactAmountIn) GetSigners 

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

func (*MsgSwapExactAmountIn) GetTokenIn 

func (m *MsgSwapExactAmountIn) GetTokenIn() types.Coin

func (*MsgSwapExactAmountIn) Marshal 

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

func (*MsgSwapExactAmountIn) MarshalTo 

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

func (*MsgSwapExactAmountIn) MarshalToSizedBuffer 

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

func (*MsgSwapExactAmountIn) ProtoMessage 

func (*MsgSwapExactAmountIn) ProtoMessage()

func (*MsgSwapExactAmountIn) Reset 

func (m *MsgSwapExactAmountIn) Reset()

func (MsgSwapExactAmountIn) Route 

func (msg MsgSwapExactAmountIn) Route() string

func (*MsgSwapExactAmountIn) Size 

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

func (*MsgSwapExactAmountIn) String 

func (m *MsgSwapExactAmountIn) String() string

func (MsgSwapExactAmountIn) TokenDenomsOnPath 

func (msg MsgSwapExactAmountIn) TokenDenomsOnPath() []string

func (MsgSwapExactAmountIn) TokenInDenom 

func (msg MsgSwapExactAmountIn) TokenInDenom() string

func (MsgSwapExactAmountIn) TokenOutDenom 

func (msg MsgSwapExactAmountIn) TokenOutDenom() string

func (MsgSwapExactAmountIn) Type 

func (msg MsgSwapExactAmountIn) Type() string

func (*MsgSwapExactAmountIn) Unmarshal 

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

func (MsgSwapExactAmountIn) ValidateBasic 

func (msg MsgSwapExactAmountIn) ValidateBasic() error

func (*MsgSwapExactAmountIn) XXX_DiscardUnknown 

func (m *MsgSwapExactAmountIn) XXX_DiscardUnknown()

func (*MsgSwapExactAmountIn) XXX_Marshal 

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

func (*MsgSwapExactAmountIn) XXX_Merge 

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

func (*MsgSwapExactAmountIn) XXX_Size 

func (m *MsgSwapExactAmountIn) XXX_Size() int

func (*MsgSwapExactAmountIn) XXX_Unmarshal 

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

type MsgSwapExactAmountInResponse 

type MsgSwapExactAmountInResponse struct {
	TokenOutAmount cosmossdk_io_math.Int `` /* 152-byte string literal not displayed */
}

func (*MsgSwapExactAmountInResponse) Descriptor 

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

func (*MsgSwapExactAmountInResponse) Marshal 

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

func (*MsgSwapExactAmountInResponse) MarshalTo 

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

func (*MsgSwapExactAmountInResponse) MarshalToSizedBuffer 

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

func (*MsgSwapExactAmountInResponse) ProtoMessage 

func (*MsgSwapExactAmountInResponse) ProtoMessage()

func (*MsgSwapExactAmountInResponse) Reset 

func (m *MsgSwapExactAmountInResponse) Reset()

func (*MsgSwapExactAmountInResponse) Size 

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

func (*MsgSwapExactAmountInResponse) String 

func (m *MsgSwapExactAmountInResponse) String() string

func (*MsgSwapExactAmountInResponse) Unmarshal 

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

func (*MsgSwapExactAmountInResponse) XXX_DiscardUnknown 

func (m *MsgSwapExactAmountInResponse) XXX_DiscardUnknown()

func (*MsgSwapExactAmountInResponse) XXX_Marshal 

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

func (*MsgSwapExactAmountInResponse) XXX_Merge 

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

func (*MsgSwapExactAmountInResponse) XXX_Size 

func (m *MsgSwapExactAmountInResponse) XXX_Size() int

func (*MsgSwapExactAmountInResponse) XXX_Unmarshal 

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

type MsgSwapExactAmountOut 

type MsgSwapExactAmountOut struct {
	Sender           string                `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	Routes           []SwapAmountOutRoute  `protobuf:"bytes,2,rep,name=routes,proto3" json:"routes"`
	TokenInMaxAmount cosmossdk_io_math.Int `` /* 163-byte string literal not displayed */
	TokenOut         types.Coin            `protobuf:"bytes,4,opt,name=token_out,json=tokenOut,proto3" json:"token_out" yaml:"token_out"`
}

===================== MsgSwapExactAmountOut

func (*MsgSwapExactAmountOut) Descriptor 

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

func (*MsgSwapExactAmountOut) GetRoutes 

func (m *MsgSwapExactAmountOut) GetRoutes() []SwapAmountOutRoute

func (*MsgSwapExactAmountOut) GetSender 

func (m *MsgSwapExactAmountOut) GetSender() string

func (MsgSwapExactAmountOut) GetSignBytes 

func (msg MsgSwapExactAmountOut) GetSignBytes() []byte

func (MsgSwapExactAmountOut) GetSigners 

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

func (*MsgSwapExactAmountOut) GetTokenOut 

func (m *MsgSwapExactAmountOut) GetTokenOut() types.Coin

func (*MsgSwapExactAmountOut) Marshal 

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

func (*MsgSwapExactAmountOut) MarshalTo 

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

func (*MsgSwapExactAmountOut) MarshalToSizedBuffer 

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

func (*MsgSwapExactAmountOut) ProtoMessage 

func (*MsgSwapExactAmountOut) ProtoMessage()

func (*MsgSwapExactAmountOut) Reset 

func (m *MsgSwapExactAmountOut) Reset()

func (MsgSwapExactAmountOut) Route 

func (msg MsgSwapExactAmountOut) Route() string

func (*MsgSwapExactAmountOut) Size 

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

func (*MsgSwapExactAmountOut) String 

func (m *MsgSwapExactAmountOut) String() string

func (MsgSwapExactAmountOut) TokenDenomsOnPath 

func (msg MsgSwapExactAmountOut) TokenDenomsOnPath() []string

func (MsgSwapExactAmountOut) TokenInDenom 

func (msg MsgSwapExactAmountOut) TokenInDenom() string

func (MsgSwapExactAmountOut) TokenOutDenom 

func (msg MsgSwapExactAmountOut) TokenOutDenom() string

func (MsgSwapExactAmountOut) Type 

func (msg MsgSwapExactAmountOut) Type() string

func (*MsgSwapExactAmountOut) Unmarshal 

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

func (MsgSwapExactAmountOut) ValidateBasic 

func (msg MsgSwapExactAmountOut) ValidateBasic() error

func (*MsgSwapExactAmountOut) XXX_DiscardUnknown 

func (m *MsgSwapExactAmountOut) XXX_DiscardUnknown()

func (*MsgSwapExactAmountOut) XXX_Marshal 

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

func (*MsgSwapExactAmountOut) XXX_Merge 

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

func (*MsgSwapExactAmountOut) XXX_Size 

func (m *MsgSwapExactAmountOut) XXX_Size() int

func (*MsgSwapExactAmountOut) XXX_Unmarshal 

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

type MsgSwapExactAmountOutResponse 

type MsgSwapExactAmountOutResponse struct {
	TokenInAmount cosmossdk_io_math.Int `` /* 148-byte string literal not displayed */
}

func (*MsgSwapExactAmountOutResponse) Descriptor 

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

func (*MsgSwapExactAmountOutResponse) Marshal 

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

func (*MsgSwapExactAmountOutResponse) MarshalTo 

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

func (*MsgSwapExactAmountOutResponse) MarshalToSizedBuffer 

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

func (*MsgSwapExactAmountOutResponse) ProtoMessage 

func (*MsgSwapExactAmountOutResponse) ProtoMessage()

func (*MsgSwapExactAmountOutResponse) Reset 

func (m *MsgSwapExactAmountOutResponse) Reset()

func (*MsgSwapExactAmountOutResponse) Size 

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

func (*MsgSwapExactAmountOutResponse) String 

func (m *MsgSwapExactAmountOutResponse) String() string

func (*MsgSwapExactAmountOutResponse) Unmarshal 

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

func (*MsgSwapExactAmountOutResponse) XXX_DiscardUnknown 

func (m *MsgSwapExactAmountOutResponse) XXX_DiscardUnknown()

func (*MsgSwapExactAmountOutResponse) XXX_Marshal 

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

func (*MsgSwapExactAmountOutResponse) XXX_Merge 

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

func (*MsgSwapExactAmountOutResponse) XXX_Size 

func (m *MsgSwapExactAmountOutResponse) XXX_Size() int

func (*MsgSwapExactAmountOutResponse) XXX_Unmarshal 

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

type MultiSwapMsgRoute 

type MultiSwapMsgRoute interface {
	GetSwapMsgs() []SwapMsgRoute
}

type MultihopRoute 

type MultihopRoute interface {
	Length() int
	PoolIds() []uint64
	IntermediateDenoms() []string
}

type Params 

type Params struct {
	PoolCreationFee github_com_cosmos_cosmos_sdk_types.Coins `` /* 177-byte string literal not displayed */
	// taker_fee_params is the container of taker fee parameters.
	TakerFeeParams TakerFeeParams `protobuf:"bytes,2,opt,name=taker_fee_params,json=takerFeeParams,proto3" json:"taker_fee_params" yaml:"taker_fee_params"`
	// authorized_quote_denoms is a list of quote denoms that can be used as
	// token1 when creating a concentrated pool. We limit the quote assets to a
	// small set for the purposes of having convinient price increments stemming
	// from tick to price conversion. These increments are in a human readable
	// magnitude only for token1 as a quote. For limit orders in the future, this
	// will be a desirable property in terms of UX as to allow users to set limit
	// orders at prices in terms of token1 (quote asset) that are easy to reason
	// about.
	AuthorizedQuoteDenoms []string `` /* 157-byte string literal not displayed */
}

Params holds parameters for the poolmanager module

func DefaultParams 

func DefaultParams() Params

DefaultParams are the default poolmanager module parameters.

func NewParams 

func NewParams(poolCreationFee sdk.Coins,
	defaultTakerFee osmomath.Dec,
	osmoTakerFeeDistribution, nonOsmoTakerFeeDistribution TakerFeeDistributionPercentage,
	adminAddresses, authorizedQuoteDenoms []string,
	communityPoolDenomToSwapNonWhitelistedAssetsTo string) Params

func (*Params) Descriptor 

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

func (*Params) GetAuthorizedQuoteDenoms 

func (m *Params) GetAuthorizedQuoteDenoms() []string

func (*Params) GetPoolCreationFee 

func (m *Params) GetPoolCreationFee() github_com_cosmos_cosmos_sdk_types.Coins

func (*Params) GetTakerFeeParams 

func (m *Params) GetTakerFeeParams() TakerFeeParams

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

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 PoolI 

type PoolI interface {
	proto.Message

	GetAddress() sdk.AccAddress
	String() string
	GetId() uint64
	// GetSpreadFactor returns the pool's spread factor, based on the current state.
	// Pools may choose to make their spread factors dependent upon state
	// (prior TWAPs, network downtime, other pool states, etc.)
	// hence Context is provided as an argument.
	GetSpreadFactor(ctx sdk.Context) osmomath.Dec
	// Returns whether the pool has swaps enabled at the moment
	IsActive(ctx sdk.Context) bool

	// GetPoolDenoms returns the pool's denoms.
	GetPoolDenoms(sdk.Context) []string

	// Returns the spot price of the 'base asset' in terms of the 'quote asset' in the pool,
	// errors if either baseAssetDenom, or quoteAssetDenom does not exist.
	// For example, if this was a UniV2 50-50 pool, with 2 ETH, and 8000 UST
	// pool.SpotPrice(ctx, "eth", "ust") = 4000.00
	SpotPrice(ctx sdk.Context, quoteAssetDenom string, baseAssetDenom string) (osmomath.BigDec, error)
	// GetType returns the type of the pool (Balancer, Stableswap, Concentrated, etc.)
	GetType() PoolType
	// AsSerializablePool returns the pool in a serializable form (useful when a model wraps the proto)
	AsSerializablePool() PoolI
}

PoolI defines an interface for pools that hold tokens.

type PoolIncentivesKeeperI 

type PoolIncentivesKeeperI interface {
	IsPoolIncentivized(ctx sdk.Context, poolId uint64) (bool, error)
}

type PoolModuleI 

type PoolModuleI interface {
	InitializePool(ctx sdk.Context, pool PoolI, creatorAddress sdk.AccAddress) error

	GetPool(ctx sdk.Context, poolId uint64) (PoolI, error)

	GetPools(ctx sdk.Context) ([]PoolI, error)

	GetPoolDenoms(ctx sdk.Context, poolId uint64) (denoms []string, err error)

	CalculateSpotPrice(
		ctx sdk.Context,
		poolId uint64,
		quoteAssetDenom string,
		baseAssetDenom string,
	) (price osmomath.BigDec, err error)

	SwapExactAmountIn(
		ctx sdk.Context,
		sender sdk.AccAddress,
		pool PoolI,
		tokenIn sdk.Coin,
		tokenOutDenom string,
		tokenOutMinAmount osmomath.Int,
		spreadFactor osmomath.Dec,
	) (osmomath.Int, error)
	// CalcOutAmtGivenIn calculates the amount of tokenOut given tokenIn and the pool's current state.
	// Returns error if the given pool is not a CFMM pool. Returns error on internal calculations.
	CalcOutAmtGivenIn(
		ctx sdk.Context,
		poolI PoolI,
		tokenIn sdk.Coin,
		tokenOutDenom string,
		spreadFactor osmomath.Dec,
	) (tokenOut sdk.Coin, err error)

	SwapExactAmountOut(
		ctx sdk.Context,
		sender sdk.AccAddress,
		pool PoolI,
		tokenInDenom string,
		tokenInMaxAmount osmomath.Int,
		tokenOut sdk.Coin,
		spreadFactor osmomath.Dec,
	) (tokenInAmount osmomath.Int, err error)
	// CalcInAmtGivenOut calculates the amount of tokenIn given tokenOut and the pool's current state.
	// Returns error if the given pool is not a CFMM pool. Returns error on internal calculations.
	CalcInAmtGivenOut(
		ctx sdk.Context,
		poolI PoolI,
		tokenOut sdk.Coin,
		tokenInDenom string,
		spreadFactor osmomath.Dec,
	) (tokenIn sdk.Coin, err error)

	// GetTotalPoolLiquidity returns the coins in the pool owned by all LPs
	GetTotalPoolLiquidity(ctx sdk.Context, poolId uint64) (sdk.Coins, error)

	// GetTotalLiquidity returns the total liquidity of all the pools in the module.
	GetTotalLiquidity(ctx sdk.Context) (sdk.Coins, error)
}

PoolModuleI is the interface that must be fulfillled by the module storing and containing the pools.

type PoolType 

type PoolType int32

PoolType is an enumeration of all supported pool types. 

const (
	// Balancer is the standard xy=k curve. Its pool model is defined in x/gamm.
	Balancer PoolType = 0
	// Stableswap is the Solidly cfmm stable swap curve. Its pool model is defined
	// in x/gamm.
	Stableswap PoolType = 1
	// Concentrated is the pool model specific to concentrated liquidity. It is
	// defined in x/concentrated-liquidity.
	Concentrated PoolType = 2
	// CosmWasm is the pool model specific to CosmWasm. It is defined in
	// x/cosmwasmpool.
	CosmWasm PoolType = 3
)

func (PoolType) EnumDescriptor 

func (PoolType) EnumDescriptor() ([]byte, []int)

func (PoolType) String 

func (x PoolType) String() string

type PoolVolume 

type PoolVolume struct {
	// pool_id is the id of the pool.
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// pool_volume is the cumulative volume of the pool.
	PoolVolume github_com_cosmos_cosmos_sdk_types.Coins `` /* 135-byte string literal not displayed */
}

PoolVolume stores the KVStore entries for each pool's volume, which is used in export/import genesis.

func (*PoolVolume) Descriptor 

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

func (*PoolVolume) GetPoolId 

func (m *PoolVolume) GetPoolId() uint64

func (*PoolVolume) GetPoolVolume 

func (m *PoolVolume) GetPoolVolume() github_com_cosmos_cosmos_sdk_types.Coins

func (*PoolVolume) Marshal 

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

func (*PoolVolume) MarshalTo 

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

func (*PoolVolume) MarshalToSizedBuffer 

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

func (*PoolVolume) ProtoMessage 

func (*PoolVolume) ProtoMessage()

func (*PoolVolume) Reset 

func (m *PoolVolume) Reset()

func (*PoolVolume) Size 

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

func (*PoolVolume) String 

func (m *PoolVolume) String() string

func (*PoolVolume) Unmarshal 

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

func (*PoolVolume) XXX_DiscardUnknown 

func (m *PoolVolume) XXX_DiscardUnknown()

func (*PoolVolume) XXX_Marshal 

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

func (*PoolVolume) XXX_Merge 

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

func (*PoolVolume) XXX_Size 

func (m *PoolVolume) XXX_Size() int

func (*PoolVolume) XXX_Unmarshal 

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

type PriceImpactProtectionExactInError 

type PriceImpactProtectionExactInError struct {
	Actual    osmomath.Int
	MinAmount osmomath.Int
}

func (PriceImpactProtectionExactInError) Error 

func (e PriceImpactProtectionExactInError) Error() string

type PriceImpactProtectionExactOutError 

type PriceImpactProtectionExactOutError struct {
	Actual    osmomath.Int
	MaxAmount osmomath.Int
}

func (PriceImpactProtectionExactOutError) Error 

func (e PriceImpactProtectionExactOutError) Error() string

type ProtorevKeeper 

type ProtorevKeeper interface {
	GetPoolForDenomPair(ctx sdk.Context, baseDenom, denomToMatch string) (uint64, error)
}

type StakingKeeper 

type StakingKeeper interface {
	BondDenom(ctx sdk.Context) string
}

type SwapAmountInRoute 

type SwapAmountInRoute struct {
	PoolId        uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty" yaml:"pool_id"`
	TokenOutDenom string `protobuf:"bytes,2,opt,name=token_out_denom,json=tokenOutDenom,proto3" json:"token_out_denom,omitempty" yaml:"token_out_denom"`
}

func (*SwapAmountInRoute) Descriptor 

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

func (*SwapAmountInRoute) GetPoolId 

func (m *SwapAmountInRoute) GetPoolId() uint64

func (*SwapAmountInRoute) GetTokenOutDenom 

func (m *SwapAmountInRoute) GetTokenOutDenom() string

func (*SwapAmountInRoute) Marshal 

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

func (*SwapAmountInRoute) MarshalTo 

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

func (*SwapAmountInRoute) MarshalToSizedBuffer 

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

func (*SwapAmountInRoute) ProtoMessage 

func (*SwapAmountInRoute) ProtoMessage()

func (*SwapAmountInRoute) Reset 

func (m *SwapAmountInRoute) Reset()

func (*SwapAmountInRoute) Size 

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

func (*SwapAmountInRoute) String 

func (m *SwapAmountInRoute) String() string

func (*SwapAmountInRoute) Unmarshal 

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

func (*SwapAmountInRoute) XXX_DiscardUnknown 

func (m *SwapAmountInRoute) XXX_DiscardUnknown()

func (*SwapAmountInRoute) XXX_Marshal 

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

func (*SwapAmountInRoute) XXX_Merge 

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

func (*SwapAmountInRoute) XXX_Size 

func (m *SwapAmountInRoute) XXX_Size() int

func (*SwapAmountInRoute) XXX_Unmarshal 

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

type SwapAmountInRoutes 

type SwapAmountInRoutes []SwapAmountInRoute

func (SwapAmountInRoutes) IntermediateDenoms 

func (routes SwapAmountInRoutes) IntermediateDenoms() []string

func (SwapAmountInRoutes) Length 

func (routes SwapAmountInRoutes) Length() int

func (SwapAmountInRoutes) PoolIds 

func (routes SwapAmountInRoutes) PoolIds() []uint64

func (SwapAmountInRoutes) Validate 

func (routes SwapAmountInRoutes) Validate() error

type SwapAmountInSplitRoute 

type SwapAmountInSplitRoute struct {
	Pools         []SwapAmountInRoute   `protobuf:"bytes,1,rep,name=pools,proto3" json:"pools" yaml:"pools"`
	TokenInAmount cosmossdk_io_math.Int `` /* 148-byte string literal not displayed */
}

func (*SwapAmountInSplitRoute) Descriptor 

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

func (*SwapAmountInSplitRoute) GetPools 

func (m *SwapAmountInSplitRoute) GetPools() []SwapAmountInRoute

func (*SwapAmountInSplitRoute) Marshal 

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

func (*SwapAmountInSplitRoute) MarshalTo 

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

func (*SwapAmountInSplitRoute) MarshalToSizedBuffer 

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

func (*SwapAmountInSplitRoute) ProtoMessage 

func (*SwapAmountInSplitRoute) ProtoMessage()

func (*SwapAmountInSplitRoute) Reset 

func (m *SwapAmountInSplitRoute) Reset()

func (*SwapAmountInSplitRoute) Size 

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

func (*SwapAmountInSplitRoute) String 

func (m *SwapAmountInSplitRoute) String() string

func (*SwapAmountInSplitRoute) Unmarshal 

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

func (*SwapAmountInSplitRoute) XXX_DiscardUnknown 

func (m *SwapAmountInSplitRoute) XXX_DiscardUnknown()

func (*SwapAmountInSplitRoute) XXX_Marshal 

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

func (*SwapAmountInSplitRoute) XXX_Merge 

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

func (*SwapAmountInSplitRoute) XXX_Size 

func (m *SwapAmountInSplitRoute) XXX_Size() int

func (*SwapAmountInSplitRoute) XXX_Unmarshal 

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

type SwapAmountInSplitRouteWrapper 

type SwapAmountInSplitRouteWrapper struct {
	Pools   []SwapAmountInRoute `json:"pools"`
	InDenom string              `json:"in_denom"`
}

func (SwapAmountInSplitRouteWrapper) TokenDenomsOnPath 

func (msg SwapAmountInSplitRouteWrapper) TokenDenomsOnPath() []string

func (SwapAmountInSplitRouteWrapper) TokenInDenom 

func (msg SwapAmountInSplitRouteWrapper) TokenInDenom() string

func (SwapAmountInSplitRouteWrapper) TokenOutDenom 

func (msg SwapAmountInSplitRouteWrapper) TokenOutDenom() string

type SwapAmountOutRoute 

type SwapAmountOutRoute struct {
	PoolId       uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty" yaml:"pool_id"`
	TokenInDenom string `protobuf:"bytes,2,opt,name=token_in_denom,json=tokenInDenom,proto3" json:"token_in_denom,omitempty" yaml:"token_in_denom"`
}

func (*SwapAmountOutRoute) Descriptor 

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

func (*SwapAmountOutRoute) GetPoolId 

func (m *SwapAmountOutRoute) GetPoolId() uint64

func (*SwapAmountOutRoute) GetTokenInDenom 

func (m *SwapAmountOutRoute) GetTokenInDenom() string

func (*SwapAmountOutRoute) Marshal 

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

func (*SwapAmountOutRoute) MarshalTo 

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

func (*SwapAmountOutRoute) MarshalToSizedBuffer 

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

func (*SwapAmountOutRoute) ProtoMessage 

func (*SwapAmountOutRoute) ProtoMessage()

func (*SwapAmountOutRoute) Reset 

func (m *SwapAmountOutRoute) Reset()

func (*SwapAmountOutRoute) Size 

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

func (*SwapAmountOutRoute) String 

func (m *SwapAmountOutRoute) String() string

func (*SwapAmountOutRoute) Unmarshal 

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

func (*SwapAmountOutRoute) XXX_DiscardUnknown 

func (m *SwapAmountOutRoute) XXX_DiscardUnknown()

func (*SwapAmountOutRoute) XXX_Marshal 

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

func (*SwapAmountOutRoute) XXX_Merge 

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

func (*SwapAmountOutRoute) XXX_Size 

func (m *SwapAmountOutRoute) XXX_Size() int

func (*SwapAmountOutRoute) XXX_Unmarshal 

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

type SwapAmountOutRoutes 

type SwapAmountOutRoutes []SwapAmountOutRoute

func (SwapAmountOutRoutes) IntermediateDenoms 

func (routes SwapAmountOutRoutes) IntermediateDenoms() []string

func (SwapAmountOutRoutes) Length 

func (routes SwapAmountOutRoutes) Length() int

func (SwapAmountOutRoutes) PoolIds 

func (routes SwapAmountOutRoutes) PoolIds() []uint64

func (SwapAmountOutRoutes) Validate 

func (routes SwapAmountOutRoutes) Validate() error

type SwapAmountOutSplitRoute 

type SwapAmountOutSplitRoute struct {
	Pools          []SwapAmountOutRoute  `protobuf:"bytes,1,rep,name=pools,proto3" json:"pools" yaml:"pools"`
	TokenOutAmount cosmossdk_io_math.Int `` /* 152-byte string literal not displayed */
}

func (*SwapAmountOutSplitRoute) Descriptor 

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

func (*SwapAmountOutSplitRoute) GetPools 

func (m *SwapAmountOutSplitRoute) GetPools() []SwapAmountOutRoute

func (*SwapAmountOutSplitRoute) Marshal 

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

func (*SwapAmountOutSplitRoute) MarshalTo 

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

func (*SwapAmountOutSplitRoute) MarshalToSizedBuffer 

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

func (*SwapAmountOutSplitRoute) ProtoMessage 

func (*SwapAmountOutSplitRoute) ProtoMessage()

func (*SwapAmountOutSplitRoute) Reset 

func (m *SwapAmountOutSplitRoute) Reset()

func (*SwapAmountOutSplitRoute) Size 

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

func (*SwapAmountOutSplitRoute) String 

func (m *SwapAmountOutSplitRoute) String() string

func (*SwapAmountOutSplitRoute) Unmarshal 

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

func (*SwapAmountOutSplitRoute) XXX_DiscardUnknown 

func (m *SwapAmountOutSplitRoute) XXX_DiscardUnknown()

func (*SwapAmountOutSplitRoute) XXX_Marshal 

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

func (*SwapAmountOutSplitRoute) XXX_Merge 

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

func (*SwapAmountOutSplitRoute) XXX_Size 

func (m *SwapAmountOutSplitRoute) XXX_Size() int

func (*SwapAmountOutSplitRoute) XXX_Unmarshal 

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

type SwapAmountOutSplitRouteWrapper 

type SwapAmountOutSplitRouteWrapper struct {
	Pools    []SwapAmountOutRoute `json:"pools"`
	OutDenom string               `json:"in_denom"`
}

func (SwapAmountOutSplitRouteWrapper) TokenDenomsOnPath 

func (msg SwapAmountOutSplitRouteWrapper) TokenDenomsOnPath() []string

func (SwapAmountOutSplitRouteWrapper) TokenInDenom 

func (msg SwapAmountOutSplitRouteWrapper) TokenInDenom() string

func (SwapAmountOutSplitRouteWrapper) TokenOutDenom 

func (msg SwapAmountOutSplitRouteWrapper) TokenOutDenom() string

type SwapMsgRoute 

type SwapMsgRoute interface {
	TokenInDenom() string
	TokenOutDenom() string
	TokenDenomsOnPath() []string
}

SwapMsg defines a simple interface for getting the token denoms on a swap message route.

type TakerFeeDistributionPercentage 

type TakerFeeDistributionPercentage struct {
	StakingRewards cosmossdk_io_math.LegacyDec `` /* 155-byte string literal not displayed */
	CommunityPool  cosmossdk_io_math.LegacyDec `` /* 151-byte string literal not displayed */
}

TakerFeeDistributionPercentage defines what percent of the taker fee category gets distributed to the available categories.

func (*TakerFeeDistributionPercentage) Descriptor 

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

func (*TakerFeeDistributionPercentage) Marshal 

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

func (*TakerFeeDistributionPercentage) MarshalTo 

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

func (*TakerFeeDistributionPercentage) MarshalToSizedBuffer 

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

func (*TakerFeeDistributionPercentage) ProtoMessage 

func (*TakerFeeDistributionPercentage) ProtoMessage()

func (*TakerFeeDistributionPercentage) Reset 

func (m *TakerFeeDistributionPercentage) Reset()

func (*TakerFeeDistributionPercentage) Size 

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

func (*TakerFeeDistributionPercentage) String 

func (m *TakerFeeDistributionPercentage) String() string

func (*TakerFeeDistributionPercentage) Unmarshal 

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

func (*TakerFeeDistributionPercentage) XXX_DiscardUnknown 

func (m *TakerFeeDistributionPercentage) XXX_DiscardUnknown()

func (*TakerFeeDistributionPercentage) XXX_Marshal 

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

func (*TakerFeeDistributionPercentage) XXX_Merge 

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

func (*TakerFeeDistributionPercentage) XXX_Size 

func (m *TakerFeeDistributionPercentage) XXX_Size() int

func (*TakerFeeDistributionPercentage) XXX_Unmarshal 

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

type TakerFeeParams 

type TakerFeeParams struct {
	// default_taker_fee is the fee used when creating a new pool that doesn't
	// fall under a custom pool taker fee or stableswap taker fee category.
	DefaultTakerFee cosmossdk_io_math.LegacyDec `` /* 137-byte string literal not displayed */
	// osmo_taker_fee_distribution defines the distribution of taker fees
	// generated in OSMO. As of this writing, it has two catagories:
	// - staking_rewards: the percent of the taker fee that gets distributed to
	//   stakers.
	// - community_pool: the percent of the taker fee that gets sent to the
	//   community pool.
	OsmoTakerFeeDistribution TakerFeeDistributionPercentage `` /* 127-byte string literal not displayed */
	// non_osmo_taker_fee_distribution defines the distribution of taker fees
	// generated in non-OSMO. As of this writing, it has two categories:
	// - staking_rewards: the percent of the taker fee that gets swapped to OSMO
	//   and then distirbuted to stakers.
	// - community_pool: the percent of the taker fee that gets sent to the
	//   community pool. Note: If the non-OSMO asset is an authorized_quote_denom,
	//   that denom is sent directly to the community pool. Otherwise, it is
	//   swapped to the community_pool_denom_to_swap_non_whitelisted_assets_to and
	//   then sent to the community pool as that denom.
	NonOsmoTakerFeeDistribution TakerFeeDistributionPercentage `` /* 138-byte string literal not displayed */
	// admin_addresses is a list of addresses that are allowed to set and remove
	// custom taker fees for denom pairs. Governance also has the ability to set
	// and remove custom taker fees for denom pairs, but with the normal
	// governance delay.
	AdminAddresses []string `` /* 126-byte string literal not displayed */
	// community_pool_denom_to_swap_non_whitelisted_assets_to is the denom that
	// non-whitelisted taker fees will be swapped to before being sent to
	// the community pool.
	CommunityPoolDenomToSwapNonWhitelistedAssetsTo string `` /* 275-byte string literal not displayed */
	// reduced_fee_whitelist is a list of addresses that are
	// allowed to pay a reduce taker fee when performing a swap
	// (i.e. swap without paying the taker fee).
	// It is intended to be used for integrators who meet qualifying factors
	// that are approved by governance.
	// Initially, the taker fee is allowed to be bypassed completely. However
	// In the future, we will charge a reduced taker fee instead of no fee at all.
	ReducedFeeWhitelist []string `` /* 149-byte string literal not displayed */
}

TakerFeeParams consolidates the taker fee parameters for the poolmanager.

func (*TakerFeeParams) Descriptor 

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

func (*TakerFeeParams) GetAdminAddresses 

func (m *TakerFeeParams) GetAdminAddresses() []string

func (*TakerFeeParams) GetCommunityPoolDenomToSwapNonWhitelistedAssetsTo 

func (m *TakerFeeParams) GetCommunityPoolDenomToSwapNonWhitelistedAssetsTo() string

func (*TakerFeeParams) GetNonOsmoTakerFeeDistribution 

func (m *TakerFeeParams) GetNonOsmoTakerFeeDistribution() TakerFeeDistributionPercentage

func (*TakerFeeParams) GetOsmoTakerFeeDistribution 

func (m *TakerFeeParams) GetOsmoTakerFeeDistribution() TakerFeeDistributionPercentage

func (*TakerFeeParams) GetReducedFeeWhitelist 

func (m *TakerFeeParams) GetReducedFeeWhitelist() []string

func (*TakerFeeParams) Marshal 

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

func (*TakerFeeParams) MarshalTo 

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

func (*TakerFeeParams) MarshalToSizedBuffer 

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

func (*TakerFeeParams) ProtoMessage 

func (*TakerFeeParams) ProtoMessage()

func (*TakerFeeParams) Reset 

func (m *TakerFeeParams) Reset()

func (*TakerFeeParams) Size 

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

func (*TakerFeeParams) String 

func (m *TakerFeeParams) String() string

func (*TakerFeeParams) Unmarshal 

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

func (*TakerFeeParams) XXX_DiscardUnknown 

func (m *TakerFeeParams) XXX_DiscardUnknown()

func (*TakerFeeParams) XXX_Marshal 

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

func (*TakerFeeParams) XXX_Merge 

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

func (*TakerFeeParams) XXX_Size 

func (m *TakerFeeParams) XXX_Size() int

func (*TakerFeeParams) XXX_Unmarshal 

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

type TakerFeesTracker 

type TakerFeesTracker struct {
	TakerFeesToStakers         github_com_cosmos_cosmos_sdk_types.Coins `` /* 163-byte string literal not displayed */
	TakerFeesToCommunityPool   github_com_cosmos_cosmos_sdk_types.Coins `` /* 183-byte string literal not displayed */
	HeightAccountingStartsFrom int64                                    `` /* 181-byte string literal not displayed */
}

func (*TakerFeesTracker) Descriptor 

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

func (*TakerFeesTracker) GetHeightAccountingStartsFrom 

func (m *TakerFeesTracker) GetHeightAccountingStartsFrom() int64

func (*TakerFeesTracker) GetTakerFeesToCommunityPool 

func (m *TakerFeesTracker) GetTakerFeesToCommunityPool() github_com_cosmos_cosmos_sdk_types.Coins

func (*TakerFeesTracker) GetTakerFeesToStakers 

func (m *TakerFeesTracker) GetTakerFeesToStakers() github_com_cosmos_cosmos_sdk_types.Coins

func (*TakerFeesTracker) Marshal 

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

func (*TakerFeesTracker) MarshalTo 

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

func (*TakerFeesTracker) MarshalToSizedBuffer 

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

func (*TakerFeesTracker) ProtoMessage 

func (*TakerFeesTracker) ProtoMessage()

func (*TakerFeesTracker) Reset 

func (m *TakerFeesTracker) Reset()

func (*TakerFeesTracker) Size 

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

func (*TakerFeesTracker) String 

func (m *TakerFeesTracker) String() string

func (*TakerFeesTracker) Unmarshal 

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

func (*TakerFeesTracker) XXX_DiscardUnknown 

func (m *TakerFeesTracker) XXX_DiscardUnknown()

func (*TakerFeesTracker) XXX_Marshal 

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

func (*TakerFeesTracker) XXX_Merge 

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

func (*TakerFeesTracker) XXX_Size 

func (m *TakerFeesTracker) XXX_Size() int

func (*TakerFeesTracker) XXX_Unmarshal 

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

type TrackedVolume 

type TrackedVolume struct {
	Amount github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,1,rep,name=amount,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"amount"`
}

func (*TrackedVolume) Descriptor 

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

func (*TrackedVolume) GetAmount 

func (m *TrackedVolume) GetAmount() github_com_cosmos_cosmos_sdk_types.Coins

func (*TrackedVolume) Marshal 

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

func (*TrackedVolume) MarshalTo 

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

func (*TrackedVolume) MarshalToSizedBuffer 

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

func (*TrackedVolume) ProtoMessage 

func (*TrackedVolume) ProtoMessage()

func (*TrackedVolume) Reset 

func (m *TrackedVolume) Reset()

func (*TrackedVolume) Size 

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

func (*TrackedVolume) String 

func (m *TrackedVolume) String() string

func (*TrackedVolume) Unmarshal 

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

func (*TrackedVolume) XXX_DiscardUnknown 

func (m *TrackedVolume) XXX_DiscardUnknown()

func (*TrackedVolume) XXX_Marshal 

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

func (*TrackedVolume) XXX_Merge 

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

func (*TrackedVolume) XXX_Size 

func (m *TrackedVolume) XXX_Size() int

func (*TrackedVolume) XXX_Unmarshal 

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

type UndefinedRouteError 

type UndefinedRouteError struct {
	PoolType PoolType
	PoolId   uint64
}

func (UndefinedRouteError) Error 

func (e UndefinedRouteError) Error() string

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) SetDenomPairTakerFee 

func (*UnimplementedMsgServer) SetDenomPairTakerFee(ctx context.Context, req *MsgSetDenomPairTakerFee) (*MsgSetDenomPairTakerFeeResponse, error)

func (*UnimplementedMsgServer) SplitRouteSwapExactAmountIn 

func (*UnimplementedMsgServer) SplitRouteSwapExactAmountIn(ctx context.Context, req *MsgSplitRouteSwapExactAmountIn) (*MsgSplitRouteSwapExactAmountInResponse, error)

func (*UnimplementedMsgServer) SplitRouteSwapExactAmountOut 

func (*UnimplementedMsgServer) SplitRouteSwapExactAmountOut(ctx context.Context, req *MsgSplitRouteSwapExactAmountOut) (*MsgSplitRouteSwapExactAmountOutResponse, error)

func (*UnimplementedMsgServer) SwapExactAmountIn 

func (*UnimplementedMsgServer) SwapExactAmountIn(ctx context.Context, req *MsgSwapExactAmountIn) (*MsgSwapExactAmountInResponse, error)

func (*UnimplementedMsgServer) SwapExactAmountOut 

func (*UnimplementedMsgServer) SwapExactAmountOut(ctx context.Context, req *MsgSwapExactAmountOut) (*MsgSwapExactAmountOutResponse, 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.