types

package
v23.0.6 Latest Latest
Warning

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

 Go to latest Published: Mar 14, 2024 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	Phase1Length      uint64 = 365
	ProfitSplitPhase1 int64  = 20
)

Year 1 (20% of total profit)

View Source 
const (
	Phase2Length      uint64 = 730
	ProfitSplitPhase2 int64  = 10
)

Year 2 (10% of total profit)

View Source 
const (
	TypeEvtBackrun = "protorev_backrun"

	AttributeValueCategory               = ModuleName
	AttributeKeyTxHash                   = "tx_hash"
	AttributeKeyUserPoolId               = "user_pool_id"
	AttributeKeyUserDenomIn              = "user_denom_in"
	AttributeKeyUserDenomOut             = "user_denom_out"
	AttributeKeyBlockPoolPointsRemaining = "block_pool_points_remaining"
	AttributeKeyTxPoolPointsRemaining    = "tx_pool_points_remaining"
	AttributeKeyProtorevProfit           = "profit"
	AttributeKeyProtorevAmountIn         = "amount_in"
	AttributeKeyProtorevAmountOut        = "amount_out"
	AttributeKeyProtorevArbDenom         = "arb_denom"
)
View Source 
const (
	ProposalTypeSetProtoRevEnabled      = "SetProtoRevEnabledProposal"
	ProposalTypeSetProtoRevAdminAccount = "SetProtoRevAdminAccountProposal"
)
View Source 
const (
	// ModuleName defines the module name
	ModuleName = "protorev"

	// StoreKey defines the primary module store key
	StoreKey = ModuleName

	// RouterKey defines the module's message routing key
	RouterKey = ModuleName
)
View Source 
const (
	TypeMsgSetHotRoutes             = "set_hot_routes"
	TypeMsgSetDeveloperAccount      = "set_developer_account"
	TypeMsgSetMaxPoolPointsPerTx    = "set_max_pool_points_per_tx"
	TypeMsgSetMaxPoolPointsPerBlock = "set_max_pool_points_per_block"
	TypeMsgSetPoolTypeInfo          = "set_info_by_pool_type"
	TypeMsgSetBaseDenoms            = "set_base_denoms"
)
View Source 
const MaxIterations int = 17

Max iterations for binary search (log2(131_072) = 17)

View Source 
const MaxPoolPointsPerBlock uint64 = 200

Max number of pool points that can be consumed per block (default of 100). This roughly corresponds to the maximum execution time (in ms) of protorev per block

View Source 
const MaxPoolPointsPerTx uint64 = 50

Max number of pool points that can be consumed per tx. This roughly corresponds to the maximum execution time (in ms) of protorev per tx

View Source 
const MaxTicksCrossed uint64 = 10

Max number of ticks we can move in a concentrated pool swap.

View Source 
const ProfitSplitPhase3 int64 = 5

All other years (5% of total profit)

Variables

View Source 
var (
	// Configuration of the default genesis state for the module.
	DefaultTokenPairArbRoutes = []TokenPairArbRoutes{}
	// Configure the initial base denoms used for cyclic route building. The order of the list of base
	// denoms is the order in which routes will be prioritized i.e. routes will be built and simulated in a
	// first come first serve basis that is based on the order of the base denoms.
	DefaultBaseDenoms = []BaseDenom{
		{
			Denom:    OsmosisDenomination,
			StepSize: osmomath.NewInt(1_000_000),
		},
	}
	DefaultPoolTypeInfo = InfoByPoolType{
		Balancer: BalancerPoolInfo{
			Weight: 2,
		},
		Stable: StablePoolInfo{
			Weight: 5,
		},
		Concentrated: ConcentratedPoolInfo{
			Weight:          7,
			MaxTicksCrossed: 5,
		},
		Cosmwasm: CosmwasmPoolInfo{},
	}
	DefaultDaysSinceModuleGenesis    = uint64(0)
	DefaultDeveloperFees             = []sdk.Coin{}
	DefaultLatestBlockHeight         = uint64(0)
	DefaultDeveloperAddress          = ""
	DefaultMaxPoolPointsPerBlock     = uint64(100)
	DefaultMaxPoolPointsPerTx        = uint64(18)
	DefaultPoolPointsConsumedInBlock = uint64(0)
	DefaultProfits                   = []sdk.Coin{}
	DefaultCyclicArbTracker          = CyclicArbTracker{
		CyclicArb:                  sdk.Coins(nil),
		HeightAccountingStartsFrom: 0,
	}
)
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 (
	// -------------- Keys for trading stores -------------- //
	// KeyPrefixTokenPairRoutes is the prefix for the TokenPairArbRoutes store
	KeyPrefixTokenPairRoutes = []byte{prefixTokenPairRoutes}

	// KeyPrefixDenomPairToPool is the prefix that is used to store the pool id for a given denom pair (baseDenom, otherDenom)
	KeyPrefixDenomPairToPool = []byte{prefixDenomPairToPool}

	// KeyPrefixBaseDenoms is the prefix that is used to store the base denoms that are used to create cyclic arbitrage routes
	KeyPrefixBaseDenoms = []byte{prefixBaseDenoms}

	// -------------- Keys for statistics stores -------------- //
	// KeyPrefixNumberOfTrades is the prefix for the store that keeps track of the number of trades executed
	KeyPrefixNumberOfTrades = []byte{prefixNumberOfTrades}

	// KeyPrefixProfitByDenom is the prefix for the store that keeps track of the profits
	KeyPrefixProfitByDenom = []byte{prefixProfitsByDenom}

	// KeyPrefixTradesByRoute is the prefix for the store that keeps track of the number of trades executed by route
	KeyPrefixTradesByRoute = []byte{prefixTradesByRoute}

	// KeyPrefixProfitsByRoute is the prefix for the store that keeps track of the profits made by route
	KeyPrefixProfitsByRoute = []byte{prefixProfitsByRoute}

	// -------------- Keys for configuration/admin stores -------------- //
	// KeyPrefixDeveloperAccount is the prefix for store that keeps track of the developer account
	KeyPrefixDeveloperAccount = []byte{prefixDeveloperAccount}

	// KeyPrefixDaysSinceGenesis is the prefix for store that keeps track of the number of days since genesis
	KeyPrefixDaysSinceGenesis = []byte{prefixDaysSinceGenesis}

	// KeyPrefixDeveloperFees is the prefix for store that keeps track of the developer fees
	KeyPrefixDeveloperFees = []byte{prefixDeveloperFees}

	// KeyPrefixMaxPointsPerTx is the prefix for store that keeps track of the max number of pool points that can be consumed per tx
	KeyPrefixMaxPointsPerTx = []byte{prefixMaxPoolPointsPerTx}

	// KeyPrefixMaxPointsPerBlock is the prefix for store that keeps track of the max number of pool points that can be consumed per block
	KeyPrefixMaxPointsPerBlock = []byte{prefixMaxPoolPointsPerBlock}

	// KeyPrefixPointCountForBlock is the prefix for store that keeps track of the number of pool points that have been consumed in the current block
	KeyPrefixPointCountForBlock = []byte{prefixPoolPointCountForBlock}

	// KeyPrefixLatestBlockHeight is the prefix for store that keeps track of the latest recorded block height
	KeyPrefixLatestBlockHeight = []byte{prefixLatestBlockHeight}

	// KeyPrefixInfoByPoolType is the prefix for store that keeps track of the pool type info
	KeyPrefixInfoByPoolType = []byte{prefixInfoByPoolType}

	// KeyPrefixSwapsToBackrun is the prefix for store that keeps track of the swaps that need to be backrun for a given tx
	KeyPrefixSwapsToBackrun = []byte{prefixSwapsToBackrun}

	// KeyCyclicArbTracker is the prefix for store that keeps track of the profits made by cyclic arbitrage
	KeyCyclicArbTracker = []byte{prefixcyclicArbTracker}

	// KeyCyclicArbTracker is the prefix for store that keeps track of the height we began tracking cyclic arbitrage
	KeyCyclicArbTrackerStartHeight = []byte{prefixcyclicArbTrackerStartHeight}
)
View Source 
var (
	DefaultEnableModule = true
	// Currently configured to be the Skip dev team's address
	// See https://github.com/osmosis-labs/osmosis/issues/4349 for more details
	// Note that governance has full ability to change this live on-chain, and this admin can at most prevent protorev from working.
	// All the settings manager's controls have limits, so it can't lead to a chain halt, excess processing time or prevention of swaps.
	DefaultAdminAccount = "osmo17nv67dvc7f8yr00rhgxd688gcn9t9wvhn783z4"

	ParamStoreKeyEnableModule = []byte("EnableProtoRevModule")
	ParamStoreKeyAdminAccount = []byte("AdminAccount")
)
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 (
	ErrInvalidLengthProtorev        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowProtorev          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupProtorev = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ErrRouteDoubleContainsPool = fmt.Errorf("cannot be trading on the same pool twice")
View Source 
var ExtendedMaxInputAmount = osmomath.NewInt(131_072)

ExtendedMaxInputAmount is the upper bound index for finding the optimal in amount when determining route profitability for an arb that's above the default range (2 ^ 17) = 131,072

View Source 
var MaxInputAmount = osmomath.NewInt(16_384)

MaxInputAmount is the upper bound index for finding the optimal in amount when determining route profitability (2 ^ 14) = 16,384

View Source 
var (
	ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry())
)
View Source 
var OsmosisDenomination string = "uosmo"

OsmosisDenomination stores the native denom name for Osmosis on chain used for route building

Functions

func CreateRouteFromKey 

func CreateRouteFromKey(key []byte) ([]uint64, error)

createRouteFromKey creates a route from a key. converts a string separated by a pipe to a slice of uint64 []byte("1|2|3|4") -> {1,2,3,4}

func CreateRouteKey 

func CreateRouteKey(route []uint64) []byte

createRouteKey creates a key for the given route. converts a slice of uint64 to a string separated by a pipe {1,2,3,4} -> []byte("1|2|3|4")

func GetKeyPrefixBaseDenom 

func GetKeyPrefixBaseDenom(priority uint64) []byte

Returns the key needed to fetch info about base denoms

func GetKeyPrefixDenomPairToPool 

func GetKeyPrefixDenomPairToPool(baseDenom, matchDenom string) []byte

Returns the key needed to fetch the pool id for a given denom

func GetKeyPrefixDeveloperFees 

func GetKeyPrefixDeveloperFees(denom string) []byte

Returns the key needed to fetch the developer fees by coin

func GetKeyPrefixProfitByDenom 

func GetKeyPrefixProfitByDenom(denom string) []byte

Returns the key needed to fetch the profit by coin

func GetKeyPrefixProfitsByRoute 

func GetKeyPrefixProfitsByRoute(route []uint64, denom string) []byte

Returns the key needed to fetch the profits by route

func GetKeyPrefixRouteForTokenPair 

func GetKeyPrefixRouteForTokenPair(tokenA, tokenB string) []byte

Returns the key needed to fetch the tokenPair routes for a given pair of tokens

func GetKeyPrefixTradesByRoute 

func GetKeyPrefixTradesByRoute(route []uint64) []byte

Returns the key needed to fetch the number of trades by route

func NewSetProtoRevAdminAccountProposal 

func NewSetProtoRevAdminAccountProposal(title, description string, account string) govtypesv1.Content

---------------- Interface for SetProtoRevAdminAccountProposal ---------------- //

func NewSetProtoRevEnabledProposal 

func NewSetProtoRevEnabledProposal(title, description string, enabled bool) govtypesv1.Content

---------------- Interface for SetProtoRevEnabledProposal ---------------- //

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable the param key table for launch module

func RegisterCodec 

func RegisterCodec(cdc *codec.LegacyAmino)

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterMsgHandler 

func RegisterMsgHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterMsgHandler registers the http handlers for service Msg to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterMsgHandlerClient 

func RegisterMsgHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MsgClient) error

RegisterMsgHandlerClient registers the http handlers for service Msg to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "MsgClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "MsgClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "MsgClient" to call the correct interceptors.

func RegisterMsgHandlerFromEndpoint 

func RegisterMsgHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterMsgHandlerFromEndpoint is same as RegisterMsgHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterMsgHandlerServer 

func RegisterMsgHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MsgServer) error

RegisterMsgHandlerServer registers the http handlers for service Msg to "mux". UnaryRPC :call MsgServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterMsgHandlerFromEndpoint instead.

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQueryHandlerClient 

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.

func RegisterQueryHandlerFromEndpoint 

func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQueryHandlerServer 

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func ValidateAccount 

func ValidateAccount(i interface{}) error

func ValidateBaseDenoms 

func ValidateBaseDenoms(denoms []BaseDenom) error

ValidateBaseDenoms validates the base denoms that are used to generate highest liquidity routes.

func ValidateBoolean 

func ValidateBoolean(i interface{}) error

func ValidateDeveloperFees 

func ValidateDeveloperFees(fees []sdk.Coin) error

---------------------- DeveloperFee Validation ---------------------- // ValidateDeveloperFees does some basic validation on the developer fees passed into the module genesis.

func ValidateMaxPoolPointsPerBlock 

func ValidateMaxPoolPointsPerBlock(points uint64) error

---------------------- Pool Point Validation ---------------------- // ValidateMaxPoolPointsPerBlock validates the max pool points per block.

func ValidateMaxPoolPointsPerTx 

func ValidateMaxPoolPointsPerTx(points uint64) error

ValidateMaxPoolPointsPerTx validates the max pool points per tx.

func ValidateTokenPairArbRoutes 

func ValidateTokenPairArbRoutes(tokenPairArbRoutes []TokenPairArbRoutes) error

Types

type AccountKeeper 

type AccountKeeper interface {
	GetModuleAddress(moduleName string) sdk.AccAddress
}

AccountKeeper defines the account contract that must be fulfilled when creating a x/protorev keeper.

type AllProtocolRevenue 

type AllProtocolRevenue struct {
	TakerFeesTracker types1.TakerFeesTracker `` /* 127-byte string literal not displayed */
	CyclicArbTracker CyclicArbTracker        `` /* 127-byte string literal not displayed */
}

func (*AllProtocolRevenue) Descriptor 

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

func (*AllProtocolRevenue) GetCyclicArbTracker 

func (m *AllProtocolRevenue) GetCyclicArbTracker() CyclicArbTracker

func (*AllProtocolRevenue) GetTakerFeesTracker 

func (m *AllProtocolRevenue) GetTakerFeesTracker() types1.TakerFeesTracker

func (*AllProtocolRevenue) Marshal 

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

func (*AllProtocolRevenue) MarshalTo 

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

func (*AllProtocolRevenue) MarshalToSizedBuffer 

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

func (*AllProtocolRevenue) ProtoMessage 

func (*AllProtocolRevenue) ProtoMessage()

func (*AllProtocolRevenue) Reset 

func (m *AllProtocolRevenue) Reset()

func (*AllProtocolRevenue) Size 

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

func (*AllProtocolRevenue) String 

func (m *AllProtocolRevenue) String() string

func (*AllProtocolRevenue) Unmarshal 

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

func (*AllProtocolRevenue) XXX_DiscardUnknown 

func (m *AllProtocolRevenue) XXX_DiscardUnknown()

func (*AllProtocolRevenue) XXX_Marshal 

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

func (*AllProtocolRevenue) XXX_Merge 

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

func (*AllProtocolRevenue) XXX_Size 

func (m *AllProtocolRevenue) XXX_Size() int

func (*AllProtocolRevenue) XXX_Unmarshal 

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

type BalancerPoolInfo 

type BalancerPoolInfo struct {
	// The weight of a balancer pool
	Weight uint64 `protobuf:"varint,1,opt,name=weight,proto3" json:"weight,omitempty" yaml:"weight"`
}

BalancerPoolInfo contains meta data pertaining to a balancer pool type.

func (*BalancerPoolInfo) Descriptor 

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

func (*BalancerPoolInfo) GetWeight 

func (m *BalancerPoolInfo) GetWeight() uint64

func (*BalancerPoolInfo) Marshal 

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

func (*BalancerPoolInfo) MarshalTo 

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

func (*BalancerPoolInfo) MarshalToSizedBuffer 

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

func (*BalancerPoolInfo) ProtoMessage 

func (*BalancerPoolInfo) ProtoMessage()

func (*BalancerPoolInfo) Reset 

func (m *BalancerPoolInfo) Reset()

func (*BalancerPoolInfo) Size 

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

func (*BalancerPoolInfo) String 

func (m *BalancerPoolInfo) String() string

func (*BalancerPoolInfo) Unmarshal 

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

func (*BalancerPoolInfo) Validate 

func (b *BalancerPoolInfo) Validate() error

Validates balancer pool information.

func (*BalancerPoolInfo) XXX_DiscardUnknown 

func (m *BalancerPoolInfo) XXX_DiscardUnknown()

func (*BalancerPoolInfo) XXX_Marshal 

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

func (*BalancerPoolInfo) XXX_Merge 

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

func (*BalancerPoolInfo) XXX_Size 

func (m *BalancerPoolInfo) XXX_Size() int

func (*BalancerPoolInfo) XXX_Unmarshal 

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

type BankKeeper 

type BankKeeper interface {
	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	MintCoins(ctx sdk.Context, moduleName string, amt sdk.Coins) error
	BurnCoins(ctx sdk.Context, name string, amt sdk.Coins) error
}

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

type BaseDenom 

type BaseDenom struct {
	// The denom i.e. name of the base denom (ex. uosmo)
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty" yaml:"denom"`
	// The step size of the binary search that is used to find the optimal swap
	// amount
	StepSize cosmossdk_io_math.Int `protobuf:"bytes,2,opt,name=step_size,json=stepSize,proto3,customtype=cosmossdk.io/math.Int" json:"step_size" yaml:"step_size"`
}

BaseDenom represents a single base denom that the module uses for its arbitrage trades. It contains the denom name alongside the step size of the binary search that is used to find the optimal swap amount

func (*BaseDenom) Descriptor 

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

func (*BaseDenom) GetDenom 

func (m *BaseDenom) GetDenom() string

func (*BaseDenom) Marshal 

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

func (*BaseDenom) MarshalTo 

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

func (*BaseDenom) MarshalToSizedBuffer 

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

func (*BaseDenom) ProtoMessage 

func (*BaseDenom) ProtoMessage()

func (*BaseDenom) Reset 

func (m *BaseDenom) Reset()

func (*BaseDenom) Size 

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

func (*BaseDenom) String 

func (m *BaseDenom) String() string

func (*BaseDenom) Unmarshal 

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

func (*BaseDenom) Validate 

func (base *BaseDenom) Validate() error

---------------------- BaseDenom Validation ---------------------- // Validates the base denoms that are used to generate highest liquidity routes.

func (*BaseDenom) XXX_DiscardUnknown 

func (m *BaseDenom) XXX_DiscardUnknown()

func (*BaseDenom) XXX_Marshal 

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

func (*BaseDenom) XXX_Merge 

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

func (*BaseDenom) XXX_Size 

func (m *BaseDenom) XXX_Size() int

func (*BaseDenom) XXX_Unmarshal 

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

type ConcentratedLiquidityKeeper 

type ConcentratedLiquidityKeeper interface {
	ComputeMaxInAmtGivenMaxTicksCrossed(
		ctx sdk.Context,
		poolId uint64,
		tokenInDenom string,
		maxTicksCrossed uint64,
	) (maxTokenIn, resultingTokenOut sdk.Coin, err error)
}

ConcentratedLiquidityKeeper defines the ConcentratedLiquidity contract that must be fulfilled when creating a x/protorev keeper.

type ConcentratedPoolInfo 

type ConcentratedPoolInfo struct {
	// The weight of a concentrated pool
	Weight uint64 `protobuf:"varint,1,opt,name=weight,proto3" json:"weight,omitempty" yaml:"weight"`
	// The maximum number of ticks we can move when rebalancing
	MaxTicksCrossed uint64 `` /* 134-byte string literal not displayed */
}

ConcentratedPoolInfo contains meta data pertaining to a concentrated pool type.

func (*ConcentratedPoolInfo) Descriptor 

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

func (*ConcentratedPoolInfo) GetMaxTicksCrossed 

func (m *ConcentratedPoolInfo) GetMaxTicksCrossed() uint64

func (*ConcentratedPoolInfo) GetWeight 

func (m *ConcentratedPoolInfo) GetWeight() uint64

func (*ConcentratedPoolInfo) Marshal 

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

func (*ConcentratedPoolInfo) MarshalTo 

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

func (*ConcentratedPoolInfo) MarshalToSizedBuffer 

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

func (*ConcentratedPoolInfo) ProtoMessage 

func (*ConcentratedPoolInfo) ProtoMessage()

func (*ConcentratedPoolInfo) Reset 

func (m *ConcentratedPoolInfo) Reset()

func (*ConcentratedPoolInfo) Size 

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

func (*ConcentratedPoolInfo) String 

func (m *ConcentratedPoolInfo) String() string

func (*ConcentratedPoolInfo) Unmarshal 

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

func (*ConcentratedPoolInfo) Validate 

func (c *ConcentratedPoolInfo) Validate() error

Validates concentrated pool information.

func (*ConcentratedPoolInfo) XXX_DiscardUnknown 

func (m *ConcentratedPoolInfo) XXX_DiscardUnknown()

func (*ConcentratedPoolInfo) XXX_Marshal 

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

func (*ConcentratedPoolInfo) XXX_Merge 

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

func (*ConcentratedPoolInfo) XXX_Size 

func (m *ConcentratedPoolInfo) XXX_Size() int

func (*ConcentratedPoolInfo) XXX_Unmarshal 

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

type CosmwasmPoolInfo 

type CosmwasmPoolInfo struct {
	// The weight of a cosmwasm pool (by contract address)
	WeightMaps []WeightMap `protobuf:"bytes,1,rep,name=weight_maps,json=weightMaps,proto3" json:"weight_maps" yaml:"weight_maps"`
}

CosmwasmPoolInfo contains meta data pertaining to a cosmwasm pool type.

func (*CosmwasmPoolInfo) Descriptor 

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

func (*CosmwasmPoolInfo) GetWeightMaps 

func (m *CosmwasmPoolInfo) GetWeightMaps() []WeightMap

func (*CosmwasmPoolInfo) Marshal 

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

func (*CosmwasmPoolInfo) MarshalTo 

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

func (*CosmwasmPoolInfo) MarshalToSizedBuffer 

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

func (*CosmwasmPoolInfo) ProtoMessage 

func (*CosmwasmPoolInfo) ProtoMessage()

func (*CosmwasmPoolInfo) Reset 

func (m *CosmwasmPoolInfo) Reset()

func (*CosmwasmPoolInfo) Size 

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

func (*CosmwasmPoolInfo) String 

func (m *CosmwasmPoolInfo) String() string

func (*CosmwasmPoolInfo) Unmarshal 

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

func (*CosmwasmPoolInfo) Validate 

func (c *CosmwasmPoolInfo) Validate() error

Validates cosmwasm pool information.

func (*CosmwasmPoolInfo) XXX_DiscardUnknown 

func (m *CosmwasmPoolInfo) XXX_DiscardUnknown()

func (*CosmwasmPoolInfo) XXX_Marshal 

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

func (*CosmwasmPoolInfo) XXX_Merge 

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

func (*CosmwasmPoolInfo) XXX_Size 

func (m *CosmwasmPoolInfo) XXX_Size() int

func (*CosmwasmPoolInfo) XXX_Unmarshal 

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

type CyclicArbTracker 

type CyclicArbTracker struct {
	CyclicArb                  []types.Coin `protobuf:"bytes,1,rep,name=cyclic_arb,json=cyclicArb,proto3" json:"cyclic_arb"`
	HeightAccountingStartsFrom int64        `` /* 181-byte string literal not displayed */
}

func (*CyclicArbTracker) Descriptor 

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

func (*CyclicArbTracker) GetCyclicArb 

func (m *CyclicArbTracker) GetCyclicArb() []types.Coin

func (*CyclicArbTracker) GetHeightAccountingStartsFrom 

func (m *CyclicArbTracker) GetHeightAccountingStartsFrom() int64

func (*CyclicArbTracker) Marshal 

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

func (*CyclicArbTracker) MarshalTo 

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

func (*CyclicArbTracker) MarshalToSizedBuffer 

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

func (*CyclicArbTracker) ProtoMessage 

func (*CyclicArbTracker) ProtoMessage()

func (*CyclicArbTracker) Reset 

func (m *CyclicArbTracker) Reset()

func (*CyclicArbTracker) Size 

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

func (*CyclicArbTracker) String 

func (m *CyclicArbTracker) String() string

func (*CyclicArbTracker) Unmarshal 

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

func (*CyclicArbTracker) XXX_DiscardUnknown 

func (m *CyclicArbTracker) XXX_DiscardUnknown()

func (*CyclicArbTracker) XXX_Marshal 

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

func (*CyclicArbTracker) XXX_Merge 

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

func (*CyclicArbTracker) XXX_Size 

func (m *CyclicArbTracker) XXX_Size() int

func (*CyclicArbTracker) XXX_Unmarshal 

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

type EpochKeeper 

type EpochKeeper interface {
	GetEpochInfo(ctx sdk.Context, identifier string) epochtypes.EpochInfo
}

EpochKeeper defines the Epoch contract that must be fulfilled when creating a x/protorev keeper.

type GAMMKeeper 

type GAMMKeeper interface {
	GetPoolAndPoke(ctx sdk.Context, poolId uint64) (gammtypes.CFMMPoolI, error)
}

GAMMKeeper defines the Gamm contract that must be fulfilled when creating a x/protorev keeper.

type GenesisState 

type GenesisState struct {
	// Parameters for the protorev module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	// Token pair arb routes for the protorev module (hot routes).
	TokenPairArbRoutes []TokenPairArbRoutes `` /* 138-byte string literal not displayed */
	// The base denominations being used to create cyclic arbitrage routes via the
	// highest liquidity method.
	BaseDenoms []BaseDenom `protobuf:"bytes,3,rep,name=base_denoms,json=baseDenoms,proto3" json:"base_denoms" yaml:"base_denoms"`
	// The pool weights that are being used to calculate the weight (compute cost)
	// of each route.
	//
	// DEPRECATED: This field is deprecated and will be removed in the next
	// release. It is replaced by the `info_by_pool_type` field.
	PoolWeights PoolWeights `protobuf:"bytes,4,opt,name=pool_weights,json=poolWeights,proto3" json:"pool_weights" yaml:"pool_weights"`
	// The number of days since module genesis.
	DaysSinceModuleGenesis uint64 `` /* 165-byte string literal not displayed */
	// The fees the developer account has accumulated over time.
	DeveloperFees []types.Coin `protobuf:"bytes,6,rep,name=developer_fees,json=developerFees,proto3" json:"developer_fees" yaml:"developer_fees"`
	// The latest block height that the module has processed.
	LatestBlockHeight uint64 `` /* 142-byte string literal not displayed */
	// The developer account address of the module.
	DeveloperAddress string `` /* 134-byte string literal not displayed */
	// Max pool points per block i.e. the maximum compute time (in ms)
	// that protorev can use per block.
	MaxPoolPointsPerBlock uint64 `` /* 164-byte string literal not displayed */
	// Max pool points per tx i.e. the maximum compute time (in ms) that
	// protorev can use per tx.
	MaxPoolPointsPerTx uint64 `` /* 153-byte string literal not displayed */
	// The number of pool points that have been consumed in the current block.
	PointCountForBlock uint64 `` /* 150-byte string literal not displayed */
	// All of the profits that have been accumulated by the module.
	Profits []types.Coin `protobuf:"bytes,12,rep,name=profits,proto3" json:"profits" yaml:"profits"`
	// Information that is used to estimate execution time / gas
	// consumption of a swap on a given pool type.
	InfoByPoolType   InfoByPoolType    `protobuf:"bytes,13,opt,name=info_by_pool_type,json=infoByPoolType,proto3" json:"info_by_pool_type" yaml:"info_by_pool_type"`
	CyclicArbTracker *CyclicArbTracker `` /* 138-byte string literal not displayed */
}

GenesisState defines the protorev module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default genesis state

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetBaseDenoms 

func (m *GenesisState) GetBaseDenoms() []BaseDenom

func (*GenesisState) GetCyclicArbTracker 

func (m *GenesisState) GetCyclicArbTracker() *CyclicArbTracker

func (*GenesisState) GetDaysSinceModuleGenesis 

func (m *GenesisState) GetDaysSinceModuleGenesis() uint64

func (*GenesisState) GetDeveloperAddress 

func (m *GenesisState) GetDeveloperAddress() string

func (*GenesisState) GetDeveloperFees 

func (m *GenesisState) GetDeveloperFees() []types.Coin

func (*GenesisState) GetInfoByPoolType 

func (m *GenesisState) GetInfoByPoolType() InfoByPoolType

func (*GenesisState) GetLatestBlockHeight 

func (m *GenesisState) GetLatestBlockHeight() uint64

func (*GenesisState) GetMaxPoolPointsPerBlock 

func (m *GenesisState) GetMaxPoolPointsPerBlock() uint64

func (*GenesisState) GetMaxPoolPointsPerTx 

func (m *GenesisState) GetMaxPoolPointsPerTx() uint64

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetPointCountForBlock 

func (m *GenesisState) GetPointCountForBlock() uint64

func (*GenesisState) GetPoolWeights 

func (m *GenesisState) GetPoolWeights() PoolWeights

func (*GenesisState) GetProfits 

func (m *GenesisState) GetProfits() []types.Coin

func (*GenesisState) GetTokenPairArbRoutes 

func (m *GenesisState) GetTokenPairArbRoutes() []TokenPairArbRoutes

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 InfoByPoolType 

type InfoByPoolType struct {
	// The stable pool info
	Stable StablePoolInfo `protobuf:"bytes,1,opt,name=stable,proto3" json:"stable" yaml:"stable"`
	// The balancer pool info
	Balancer BalancerPoolInfo `protobuf:"bytes,2,opt,name=balancer,proto3" json:"balancer" yaml:"balancer"`
	// The concentrated pool info
	Concentrated ConcentratedPoolInfo `protobuf:"bytes,3,opt,name=concentrated,proto3" json:"concentrated" yaml:"concentrated"`
	// The cosmwasm pool info
	Cosmwasm CosmwasmPoolInfo `protobuf:"bytes,4,opt,name=cosmwasm,proto3" json:"cosmwasm" yaml:"cosmwasm"`
}

InfoByPoolType contains information pertaining to how expensive (in terms of gas and time) it is to execute a swap on a given pool type. This distinction is made and necessary because the execution time ranges significantly between the different pool types.

func (*InfoByPoolType) Descriptor 

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

func (*InfoByPoolType) GetBalancer 

func (m *InfoByPoolType) GetBalancer() BalancerPoolInfo

func (*InfoByPoolType) GetConcentrated 

func (m *InfoByPoolType) GetConcentrated() ConcentratedPoolInfo

func (*InfoByPoolType) GetCosmwasm 

func (m *InfoByPoolType) GetCosmwasm() CosmwasmPoolInfo

func (*InfoByPoolType) GetStable 

func (m *InfoByPoolType) GetStable() StablePoolInfo

func (*InfoByPoolType) Marshal 

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

func (*InfoByPoolType) MarshalTo 

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

func (*InfoByPoolType) MarshalToSizedBuffer 

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

func (*InfoByPoolType) ProtoMessage 

func (*InfoByPoolType) ProtoMessage()

func (*InfoByPoolType) Reset 

func (m *InfoByPoolType) Reset()

func (*InfoByPoolType) Size 

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

func (*InfoByPoolType) String 

func (m *InfoByPoolType) String() string

func (*InfoByPoolType) Unmarshal 

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

func (*InfoByPoolType) Validate 

func (info *InfoByPoolType) Validate() error

---------------------- InfoByPoolType Validation ---------------------- // Validates the information about each pool type that is used throughout the module.

func (*InfoByPoolType) XXX_DiscardUnknown 

func (m *InfoByPoolType) XXX_DiscardUnknown()

func (*InfoByPoolType) XXX_Marshal 

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

func (*InfoByPoolType) XXX_Merge 

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

func (*InfoByPoolType) XXX_Size 

func (m *InfoByPoolType) XXX_Size() int

func (*InfoByPoolType) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// SetHotRoutes sets the hot routes that will be explored when creating
	// cyclic arbitrage routes. Can only be called by the admin account.
	SetHotRoutes(ctx context.Context, in *MsgSetHotRoutes, opts ...grpc.CallOption) (*MsgSetHotRoutesResponse, error)
	// SetDeveloperAccount sets the account that can withdraw a portion of the
	// profits from the protorev module. This will be Skip's address.
	SetDeveloperAccount(ctx context.Context, in *MsgSetDeveloperAccount, opts ...grpc.CallOption) (*MsgSetDeveloperAccountResponse, error)
	// SetMaxPoolPointsPerTx sets the maximum number of pool points that can be
	// consumed per transaction. Can only be called by the admin account.
	SetMaxPoolPointsPerTx(ctx context.Context, in *MsgSetMaxPoolPointsPerTx, opts ...grpc.CallOption) (*MsgSetMaxPoolPointsPerTxResponse, error)
	// SetMaxPoolPointsPerBlock sets the maximum number of pool points that can be
	// consumed per block. Can only be called by the admin account.
	SetMaxPoolPointsPerBlock(ctx context.Context, in *MsgSetMaxPoolPointsPerBlock, opts ...grpc.CallOption) (*MsgSetMaxPoolPointsPerBlockResponse, error)
	// SetInfoByPoolType sets the pool type information needed to make smart
	// assumptions about swapping on different pool types
	SetInfoByPoolType(ctx context.Context, in *MsgSetInfoByPoolType, opts ...grpc.CallOption) (*MsgSetInfoByPoolTypeResponse, error)
	// SetBaseDenoms sets the base denoms that will be used to create cyclic
	// arbitrage routes. Can only be called by the admin account.
	SetBaseDenoms(ctx context.Context, in *MsgSetBaseDenoms, opts ...grpc.CallOption) (*MsgSetBaseDenomsResponse, 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 {
	// SetHotRoutes sets the hot routes that will be explored when creating
	// cyclic arbitrage routes. Can only be called by the admin account.
	SetHotRoutes(context.Context, *MsgSetHotRoutes) (*MsgSetHotRoutesResponse, error)
	// SetDeveloperAccount sets the account that can withdraw a portion of the
	// profits from the protorev module. This will be Skip's address.
	SetDeveloperAccount(context.Context, *MsgSetDeveloperAccount) (*MsgSetDeveloperAccountResponse, error)
	// SetMaxPoolPointsPerTx sets the maximum number of pool points that can be
	// consumed per transaction. Can only be called by the admin account.
	SetMaxPoolPointsPerTx(context.Context, *MsgSetMaxPoolPointsPerTx) (*MsgSetMaxPoolPointsPerTxResponse, error)
	// SetMaxPoolPointsPerBlock sets the maximum number of pool points that can be
	// consumed per block. Can only be called by the admin account.
	SetMaxPoolPointsPerBlock(context.Context, *MsgSetMaxPoolPointsPerBlock) (*MsgSetMaxPoolPointsPerBlockResponse, error)
	// SetInfoByPoolType sets the pool type information needed to make smart
	// assumptions about swapping on different pool types
	SetInfoByPoolType(context.Context, *MsgSetInfoByPoolType) (*MsgSetInfoByPoolTypeResponse, error)
	// SetBaseDenoms sets the base denoms that will be used to create cyclic
	// arbitrage routes. Can only be called by the admin account.
	SetBaseDenoms(context.Context, *MsgSetBaseDenoms) (*MsgSetBaseDenomsResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSetBaseDenoms 

type MsgSetBaseDenoms struct {
	// admin is the account that is authorized to set the base denoms.
	Admin string `protobuf:"bytes,1,opt,name=admin,proto3" json:"admin,omitempty" yaml:"admin"`
	// base_denoms is the list of base denoms to set.
	BaseDenoms []BaseDenom `protobuf:"bytes,2,rep,name=base_denoms,json=baseDenoms,proto3" json:"base_denoms" yaml:"base_denoms"`
}

MsgSetBaseDenoms defines the Msg/SetBaseDenoms request type.

func NewMsgSetBaseDenoms 

func NewMsgSetBaseDenoms(admin string, baseDenoms []BaseDenom) *MsgSetBaseDenoms

---------------------- Interface for MsgSetBaseDenoms ---------------------- // NewMsgSetBaseDenoms creates a new MsgSetBaseDenoms instance

func (*MsgSetBaseDenoms) Descriptor 

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

func (*MsgSetBaseDenoms) GetAdmin 

func (m *MsgSetBaseDenoms) GetAdmin() string

func (*MsgSetBaseDenoms) GetBaseDenoms 

func (m *MsgSetBaseDenoms) GetBaseDenoms() []BaseDenom

func (MsgSetBaseDenoms) GetSignBytes 

func (msg MsgSetBaseDenoms) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgSetBaseDenoms) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgSetBaseDenoms) Marshal 

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

func (*MsgSetBaseDenoms) MarshalTo 

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

func (*MsgSetBaseDenoms) MarshalToSizedBuffer 

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

func (*MsgSetBaseDenoms) ProtoMessage 

func (*MsgSetBaseDenoms) ProtoMessage()

func (*MsgSetBaseDenoms) Reset 

func (m *MsgSetBaseDenoms) Reset()

func (MsgSetBaseDenoms) Route 

func (msg MsgSetBaseDenoms) Route() string

Route returns the name of the module

func (*MsgSetBaseDenoms) Size 

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

func (*MsgSetBaseDenoms) String 

func (m *MsgSetBaseDenoms) String() string

func (MsgSetBaseDenoms) Type 

func (msg MsgSetBaseDenoms) Type() string

Type returns the type of the message

func (*MsgSetBaseDenoms) Unmarshal 

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

func (MsgSetBaseDenoms) ValidateBasic 

func (msg MsgSetBaseDenoms) ValidateBasic() error

ValidateBasic validates the MsgSetBaseDenoms

func (*MsgSetBaseDenoms) XXX_DiscardUnknown 

func (m *MsgSetBaseDenoms) XXX_DiscardUnknown()

func (*MsgSetBaseDenoms) XXX_Marshal 

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

func (*MsgSetBaseDenoms) XXX_Merge 

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

func (*MsgSetBaseDenoms) XXX_Size 

func (m *MsgSetBaseDenoms) XXX_Size() int

func (*MsgSetBaseDenoms) XXX_Unmarshal 

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

type MsgSetBaseDenomsResponse 

type MsgSetBaseDenomsResponse struct {
}

MsgSetBaseDenomsResponse defines the Msg/SetBaseDenoms response type.

func (*MsgSetBaseDenomsResponse) Descriptor 

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

func (*MsgSetBaseDenomsResponse) Marshal 

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

func (*MsgSetBaseDenomsResponse) MarshalTo 

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

func (*MsgSetBaseDenomsResponse) MarshalToSizedBuffer 

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

func (*MsgSetBaseDenomsResponse) ProtoMessage 

func (*MsgSetBaseDenomsResponse) ProtoMessage()

func (*MsgSetBaseDenomsResponse) Reset 

func (m *MsgSetBaseDenomsResponse) Reset()

func (*MsgSetBaseDenomsResponse) Size 

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

func (*MsgSetBaseDenomsResponse) String 

func (m *MsgSetBaseDenomsResponse) String() string

func (*MsgSetBaseDenomsResponse) Unmarshal 

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

func (*MsgSetBaseDenomsResponse) XXX_DiscardUnknown 

func (m *MsgSetBaseDenomsResponse) XXX_DiscardUnknown()

func (*MsgSetBaseDenomsResponse) XXX_Marshal 

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

func (*MsgSetBaseDenomsResponse) XXX_Merge 

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

func (*MsgSetBaseDenomsResponse) XXX_Size 

func (m *MsgSetBaseDenomsResponse) XXX_Size() int

func (*MsgSetBaseDenomsResponse) XXX_Unmarshal 

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

type MsgSetDeveloperAccount 

type MsgSetDeveloperAccount struct {
	// admin is the account that is authorized to set the developer account.
	Admin string `protobuf:"bytes,1,opt,name=admin,proto3" json:"admin,omitempty" yaml:"admin"`
	// developer_account is the account that will receive a portion of the profits
	// from the protorev module.
	DeveloperAccount string `` /* 134-byte string literal not displayed */
}

MsgSetDeveloperAccount defines the Msg/SetDeveloperAccount request type.

func NewMsgSetDeveloperAccount 

func NewMsgSetDeveloperAccount(admin string, developerAccount string) *MsgSetDeveloperAccount

---------------------- Interface for MsgSetDeveloperAccount ---------------------- // NewMsgSetDeveloperAccount creates a new MsgSetDeveloperAccount instance

func (*MsgSetDeveloperAccount) Descriptor 

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

func (*MsgSetDeveloperAccount) GetAdmin 

func (m *MsgSetDeveloperAccount) GetAdmin() string

func (*MsgSetDeveloperAccount) GetDeveloperAccount 

func (m *MsgSetDeveloperAccount) GetDeveloperAccount() string

func (MsgSetDeveloperAccount) GetSignBytes 

func (msg MsgSetDeveloperAccount) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgSetDeveloperAccount) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgSetDeveloperAccount) Marshal 

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

func (*MsgSetDeveloperAccount) MarshalTo 

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

func (*MsgSetDeveloperAccount) MarshalToSizedBuffer 

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

func (*MsgSetDeveloperAccount) ProtoMessage 

func (*MsgSetDeveloperAccount) ProtoMessage()

func (*MsgSetDeveloperAccount) Reset 

func (m *MsgSetDeveloperAccount) Reset()

func (MsgSetDeveloperAccount) Route 

func (msg MsgSetDeveloperAccount) Route() string

Route returns the name of the module

func (*MsgSetDeveloperAccount) Size 

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

func (*MsgSetDeveloperAccount) String 

func (m *MsgSetDeveloperAccount) String() string

func (MsgSetDeveloperAccount) Type 

func (msg MsgSetDeveloperAccount) Type() string

Type returns the type of the message

func (*MsgSetDeveloperAccount) Unmarshal 

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

func (MsgSetDeveloperAccount) ValidateBasic 

func (msg MsgSetDeveloperAccount) ValidateBasic() error

ValidateBasic validates the MsgSetDeveloperAccount

func (*MsgSetDeveloperAccount) XXX_DiscardUnknown 

func (m *MsgSetDeveloperAccount) XXX_DiscardUnknown()

func (*MsgSetDeveloperAccount) XXX_Marshal 

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

func (*MsgSetDeveloperAccount) XXX_Merge 

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

func (*MsgSetDeveloperAccount) XXX_Size 

func (m *MsgSetDeveloperAccount) XXX_Size() int

func (*MsgSetDeveloperAccount) XXX_Unmarshal 

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

type MsgSetDeveloperAccountResponse 

type MsgSetDeveloperAccountResponse struct {
}

MsgSetDeveloperAccountResponse defines the Msg/SetDeveloperAccount response type.

func (*MsgSetDeveloperAccountResponse) Descriptor 

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

func (*MsgSetDeveloperAccountResponse) Marshal 

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

func (*MsgSetDeveloperAccountResponse) MarshalTo 

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

func (*MsgSetDeveloperAccountResponse) MarshalToSizedBuffer 

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

func (*MsgSetDeveloperAccountResponse) ProtoMessage 

func (*MsgSetDeveloperAccountResponse) ProtoMessage()

func (*MsgSetDeveloperAccountResponse) Reset 

func (m *MsgSetDeveloperAccountResponse) Reset()

func (*MsgSetDeveloperAccountResponse) Size 

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

func (*MsgSetDeveloperAccountResponse) String 

func (m *MsgSetDeveloperAccountResponse) String() string

func (*MsgSetDeveloperAccountResponse) Unmarshal 

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

func (*MsgSetDeveloperAccountResponse) XXX_DiscardUnknown 

func (m *MsgSetDeveloperAccountResponse) XXX_DiscardUnknown()

func (*MsgSetDeveloperAccountResponse) XXX_Marshal 

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

func (*MsgSetDeveloperAccountResponse) XXX_Merge 

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

func (*MsgSetDeveloperAccountResponse) XXX_Size 

func (m *MsgSetDeveloperAccountResponse) XXX_Size() int

func (*MsgSetDeveloperAccountResponse) XXX_Unmarshal 

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

type MsgSetHotRoutes 

type MsgSetHotRoutes struct {
	// admin is the account that is authorized to set the hot routes.
	Admin string `protobuf:"bytes,1,opt,name=admin,proto3" json:"admin,omitempty" yaml:"admin"`
	// hot_routes is the list of hot routes to set.
	HotRoutes []TokenPairArbRoutes `protobuf:"bytes,2,rep,name=hot_routes,json=hotRoutes,proto3" json:"hot_routes" yaml:"hot_routes"`
}

MsgSetHotRoutes defines the Msg/SetHotRoutes request type.

func NewMsgSetHotRoutes 

func NewMsgSetHotRoutes(admin string, tokenPairArbRoutes []TokenPairArbRoutes) *MsgSetHotRoutes

---------------------- Interface for MsgSetHotRoutes ---------------------- // NewMsgSetHotRoutes creates a new MsgSetHotRoutes instance

func (*MsgSetHotRoutes) Descriptor 

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

func (*MsgSetHotRoutes) GetAdmin 

func (m *MsgSetHotRoutes) GetAdmin() string

func (*MsgSetHotRoutes) GetHotRoutes 

func (m *MsgSetHotRoutes) GetHotRoutes() []TokenPairArbRoutes

func (MsgSetHotRoutes) GetSignBytes 

func (msg MsgSetHotRoutes) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgSetHotRoutes) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgSetHotRoutes) Marshal 

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

func (*MsgSetHotRoutes) MarshalTo 

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

func (*MsgSetHotRoutes) MarshalToSizedBuffer 

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

func (*MsgSetHotRoutes) ProtoMessage 

func (*MsgSetHotRoutes) ProtoMessage()

func (*MsgSetHotRoutes) Reset 

func (m *MsgSetHotRoutes) Reset()

func (MsgSetHotRoutes) Route 

func (msg MsgSetHotRoutes) Route() string

Route returns the name of the module

func (*MsgSetHotRoutes) Size 

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

func (*MsgSetHotRoutes) String 

func (m *MsgSetHotRoutes) String() string

func (MsgSetHotRoutes) Type 

func (msg MsgSetHotRoutes) Type() string

Type returns the type of the message

func (*MsgSetHotRoutes) Unmarshal 

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

func (MsgSetHotRoutes) ValidateBasic 

func (msg MsgSetHotRoutes) ValidateBasic() error

ValidateBasic validates the MsgSetHotRoutes

func (*MsgSetHotRoutes) XXX_DiscardUnknown 

func (m *MsgSetHotRoutes) XXX_DiscardUnknown()

func (*MsgSetHotRoutes) XXX_Marshal 

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

func (*MsgSetHotRoutes) XXX_Merge 

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

func (*MsgSetHotRoutes) XXX_Size 

func (m *MsgSetHotRoutes) XXX_Size() int

func (*MsgSetHotRoutes) XXX_Unmarshal 

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

type MsgSetHotRoutesResponse 

type MsgSetHotRoutesResponse struct {
}

MsgSetHotRoutesResponse defines the Msg/SetHotRoutes response type.

func (*MsgSetHotRoutesResponse) Descriptor 

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

func (*MsgSetHotRoutesResponse) Marshal 

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

func (*MsgSetHotRoutesResponse) MarshalTo 

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

func (*MsgSetHotRoutesResponse) MarshalToSizedBuffer 

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

func (*MsgSetHotRoutesResponse) ProtoMessage 

func (*MsgSetHotRoutesResponse) ProtoMessage()

func (*MsgSetHotRoutesResponse) Reset 

func (m *MsgSetHotRoutesResponse) Reset()

func (*MsgSetHotRoutesResponse) Size 

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

func (*MsgSetHotRoutesResponse) String 

func (m *MsgSetHotRoutesResponse) String() string

func (*MsgSetHotRoutesResponse) Unmarshal 

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

func (*MsgSetHotRoutesResponse) XXX_DiscardUnknown 

func (m *MsgSetHotRoutesResponse) XXX_DiscardUnknown()

func (*MsgSetHotRoutesResponse) XXX_Marshal 

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

func (*MsgSetHotRoutesResponse) XXX_Merge 

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

func (*MsgSetHotRoutesResponse) XXX_Size 

func (m *MsgSetHotRoutesResponse) XXX_Size() int

func (*MsgSetHotRoutesResponse) XXX_Unmarshal 

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

type MsgSetInfoByPoolType 

type MsgSetInfoByPoolType struct {
	// admin is the account that is authorized to set the pool weights.
	Admin string `protobuf:"bytes,1,opt,name=admin,proto3" json:"admin,omitempty" yaml:"admin"`
	// info_by_pool_type contains information about the pool types.
	InfoByPoolType InfoByPoolType `protobuf:"bytes,2,opt,name=info_by_pool_type,json=infoByPoolType,proto3" json:"info_by_pool_type" yaml:"info_by_pool_type"`
}

MsgSetInfoByPoolType defines the Msg/SetInfoByPoolType request type.

func NewMsgSetPoolTypeInfo 

func NewMsgSetPoolTypeInfo(admin string, infoByPoolType InfoByPoolType) *MsgSetInfoByPoolType

---------------------- Interface for MsgSetInfoByPoolType ---------------------- // NewMsgSetPoolTypeInfo creates a new MsgSetInfoByPoolType instance

func (*MsgSetInfoByPoolType) Descriptor 

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

func (*MsgSetInfoByPoolType) GetAdmin 

func (m *MsgSetInfoByPoolType) GetAdmin() string

func (*MsgSetInfoByPoolType) GetInfoByPoolType 

func (m *MsgSetInfoByPoolType) GetInfoByPoolType() InfoByPoolType

func (MsgSetInfoByPoolType) GetSignBytes 

func (msg MsgSetInfoByPoolType) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgSetInfoByPoolType) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgSetInfoByPoolType) Marshal 

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

func (*MsgSetInfoByPoolType) MarshalTo 

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

func (*MsgSetInfoByPoolType) MarshalToSizedBuffer 

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

func (*MsgSetInfoByPoolType) ProtoMessage 

func (*MsgSetInfoByPoolType) ProtoMessage()

func (*MsgSetInfoByPoolType) Reset 

func (m *MsgSetInfoByPoolType) Reset()

func (MsgSetInfoByPoolType) Route 

func (msg MsgSetInfoByPoolType) Route() string

Route returns the name of the module

func (*MsgSetInfoByPoolType) Size 

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

func (*MsgSetInfoByPoolType) String 

func (m *MsgSetInfoByPoolType) String() string

func (MsgSetInfoByPoolType) Type 

func (msg MsgSetInfoByPoolType) Type() string

Type returns the type of the message

func (*MsgSetInfoByPoolType) Unmarshal 

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

func (MsgSetInfoByPoolType) ValidateBasic 

func (msg MsgSetInfoByPoolType) ValidateBasic() error

ValidateBasic validates the MsgSetInfoByPoolType

func (*MsgSetInfoByPoolType) XXX_DiscardUnknown 

func (m *MsgSetInfoByPoolType) XXX_DiscardUnknown()

func (*MsgSetInfoByPoolType) XXX_Marshal 

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

func (*MsgSetInfoByPoolType) XXX_Merge 

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

func (*MsgSetInfoByPoolType) XXX_Size 

func (m *MsgSetInfoByPoolType) XXX_Size() int

func (*MsgSetInfoByPoolType) XXX_Unmarshal 

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

type MsgSetInfoByPoolTypeResponse 

type MsgSetInfoByPoolTypeResponse struct {
}

MsgSetInfoByPoolTypeResponse defines the Msg/SetInfoByPoolType response type.

func (*MsgSetInfoByPoolTypeResponse) Descriptor 

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

func (*MsgSetInfoByPoolTypeResponse) Marshal 

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

func (*MsgSetInfoByPoolTypeResponse) MarshalTo 

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

func (*MsgSetInfoByPoolTypeResponse) MarshalToSizedBuffer 

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

func (*MsgSetInfoByPoolTypeResponse) ProtoMessage 

func (*MsgSetInfoByPoolTypeResponse) ProtoMessage()

func (*MsgSetInfoByPoolTypeResponse) Reset 

func (m *MsgSetInfoByPoolTypeResponse) Reset()

func (*MsgSetInfoByPoolTypeResponse) Size 

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

func (*MsgSetInfoByPoolTypeResponse) String 

func (m *MsgSetInfoByPoolTypeResponse) String() string

func (*MsgSetInfoByPoolTypeResponse) Unmarshal 

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

func (*MsgSetInfoByPoolTypeResponse) XXX_DiscardUnknown 

func (m *MsgSetInfoByPoolTypeResponse) XXX_DiscardUnknown()

func (*MsgSetInfoByPoolTypeResponse) XXX_Marshal 

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

func (*MsgSetInfoByPoolTypeResponse) XXX_Merge 

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

func (*MsgSetInfoByPoolTypeResponse) XXX_Size 

func (m *MsgSetInfoByPoolTypeResponse) XXX_Size() int

func (*MsgSetInfoByPoolTypeResponse) XXX_Unmarshal 

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

type MsgSetMaxPoolPointsPerBlock 

type MsgSetMaxPoolPointsPerBlock struct {
	// admin is the account that is authorized to set the max pool points per
	// block.
	Admin string `protobuf:"bytes,1,opt,name=admin,proto3" json:"admin,omitempty" yaml:"admin"`
	// max_pool_points_per_block is the maximum number of pool points that can be
	// consumed per block.
	MaxPoolPointsPerBlock uint64 `` /* 164-byte string literal not displayed */
}

MsgSetMaxPoolPointsPerBlock defines the Msg/SetMaxPoolPointsPerBlock request type.

func NewMsgSetMaxPoolPointsPerBlock 

func NewMsgSetMaxPoolPointsPerBlock(admin string, maxPoolPointsPerBlock uint64) *MsgSetMaxPoolPointsPerBlock

---------------------- Interface for MsgSetMaxPoolPointsPerBlock ---------------------- // NewMsgSetMaxPoolPointsPerBlock creates a new MsgSetMaxPoolPointsPerBlock instance

func (*MsgSetMaxPoolPointsPerBlock) Descriptor 

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

func (*MsgSetMaxPoolPointsPerBlock) GetAdmin 

func (m *MsgSetMaxPoolPointsPerBlock) GetAdmin() string

func (*MsgSetMaxPoolPointsPerBlock) GetMaxPoolPointsPerBlock 

func (m *MsgSetMaxPoolPointsPerBlock) GetMaxPoolPointsPerBlock() uint64

func (MsgSetMaxPoolPointsPerBlock) GetSignBytes 

func (msg MsgSetMaxPoolPointsPerBlock) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgSetMaxPoolPointsPerBlock) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgSetMaxPoolPointsPerBlock) Marshal 

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

func (*MsgSetMaxPoolPointsPerBlock) MarshalTo 

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

func (*MsgSetMaxPoolPointsPerBlock) MarshalToSizedBuffer 

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

func (*MsgSetMaxPoolPointsPerBlock) ProtoMessage 

func (*MsgSetMaxPoolPointsPerBlock) ProtoMessage()

func (*MsgSetMaxPoolPointsPerBlock) Reset 

func (m *MsgSetMaxPoolPointsPerBlock) Reset()

func (MsgSetMaxPoolPointsPerBlock) Route 

func (msg MsgSetMaxPoolPointsPerBlock) Route() string

Route returns the name of the module

func (*MsgSetMaxPoolPointsPerBlock) Size 

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

func (*MsgSetMaxPoolPointsPerBlock) String 

func (m *MsgSetMaxPoolPointsPerBlock) String() string

func (MsgSetMaxPoolPointsPerBlock) Type 

func (msg MsgSetMaxPoolPointsPerBlock) Type() string

Type returns the type of the message

func (*MsgSetMaxPoolPointsPerBlock) Unmarshal 

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

func (MsgSetMaxPoolPointsPerBlock) ValidateBasic 

func (msg MsgSetMaxPoolPointsPerBlock) ValidateBasic() error

ValidateBasic validates the MsgSetMaxPoolPointsPerBlock

func (*MsgSetMaxPoolPointsPerBlock) XXX_DiscardUnknown 

func (m *MsgSetMaxPoolPointsPerBlock) XXX_DiscardUnknown()

func (*MsgSetMaxPoolPointsPerBlock) XXX_Marshal 

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

func (*MsgSetMaxPoolPointsPerBlock) XXX_Merge 

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

func (*MsgSetMaxPoolPointsPerBlock) XXX_Size 

func (m *MsgSetMaxPoolPointsPerBlock) XXX_Size() int

func (*MsgSetMaxPoolPointsPerBlock) XXX_Unmarshal 

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

type MsgSetMaxPoolPointsPerBlockResponse 

type MsgSetMaxPoolPointsPerBlockResponse struct {
}

MsgSetMaxPoolPointsPerBlockResponse defines the Msg/SetMaxPoolPointsPerBlock response type.

func (*MsgSetMaxPoolPointsPerBlockResponse) Descriptor 

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

func (*MsgSetMaxPoolPointsPerBlockResponse) Marshal 

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

func (*MsgSetMaxPoolPointsPerBlockResponse) MarshalTo 

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

func (*MsgSetMaxPoolPointsPerBlockResponse) MarshalToSizedBuffer 

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

func (*MsgSetMaxPoolPointsPerBlockResponse) ProtoMessage 

func (*MsgSetMaxPoolPointsPerBlockResponse) ProtoMessage()

func (*MsgSetMaxPoolPointsPerBlockResponse) Reset 

func (m *MsgSetMaxPoolPointsPerBlockResponse) Reset()

func (*MsgSetMaxPoolPointsPerBlockResponse) Size 

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

func (*MsgSetMaxPoolPointsPerBlockResponse) String 

func (m *MsgSetMaxPoolPointsPerBlockResponse) String() string

func (*MsgSetMaxPoolPointsPerBlockResponse) Unmarshal 

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

func (*MsgSetMaxPoolPointsPerBlockResponse) XXX_DiscardUnknown 

func (m *MsgSetMaxPoolPointsPerBlockResponse) XXX_DiscardUnknown()

func (*MsgSetMaxPoolPointsPerBlockResponse) XXX_Marshal 

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

func (*MsgSetMaxPoolPointsPerBlockResponse) XXX_Merge 

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

func (*MsgSetMaxPoolPointsPerBlockResponse) XXX_Size 

func (m *MsgSetMaxPoolPointsPerBlockResponse) XXX_Size() int

func (*MsgSetMaxPoolPointsPerBlockResponse) XXX_Unmarshal 

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

type MsgSetMaxPoolPointsPerTx 

type MsgSetMaxPoolPointsPerTx struct {
	// admin is the account that is authorized to set the max pool points per tx.
	Admin string `protobuf:"bytes,1,opt,name=admin,proto3" json:"admin,omitempty" yaml:"admin"`
	// max_pool_points_per_tx is the maximum number of pool points that can be
	// consumed per transaction.
	MaxPoolPointsPerTx uint64 `` /* 152-byte string literal not displayed */
}

MsgSetMaxPoolPointsPerTx defines the Msg/SetMaxPoolPointsPerTx request type.

func NewMsgSetMaxPoolPointsPerTx 

func NewMsgSetMaxPoolPointsPerTx(admin string, maxPoolPointsPerTx uint64) *MsgSetMaxPoolPointsPerTx

---------------------- Interface for MsgSetMaxPoolPointsPerTx ---------------------- // NewMsgSetMaxPoolPointsPerTx creates a new MsgSetMaxPoolPointsPerTx instance

func (*MsgSetMaxPoolPointsPerTx) Descriptor 

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

func (*MsgSetMaxPoolPointsPerTx) GetAdmin 

func (m *MsgSetMaxPoolPointsPerTx) GetAdmin() string

func (*MsgSetMaxPoolPointsPerTx) GetMaxPoolPointsPerTx 

func (m *MsgSetMaxPoolPointsPerTx) GetMaxPoolPointsPerTx() uint64

func (MsgSetMaxPoolPointsPerTx) GetSignBytes 

func (msg MsgSetMaxPoolPointsPerTx) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgSetMaxPoolPointsPerTx) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgSetMaxPoolPointsPerTx) Marshal 

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

func (*MsgSetMaxPoolPointsPerTx) MarshalTo 

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

func (*MsgSetMaxPoolPointsPerTx) MarshalToSizedBuffer 

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

func (*MsgSetMaxPoolPointsPerTx) ProtoMessage 

func (*MsgSetMaxPoolPointsPerTx) ProtoMessage()

func (*MsgSetMaxPoolPointsPerTx) Reset 

func (m *MsgSetMaxPoolPointsPerTx) Reset()

func (MsgSetMaxPoolPointsPerTx) Route 

func (msg MsgSetMaxPoolPointsPerTx) Route() string

Route returns the name of the module

func (*MsgSetMaxPoolPointsPerTx) Size 

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

func (*MsgSetMaxPoolPointsPerTx) String 

func (m *MsgSetMaxPoolPointsPerTx) String() string

func (MsgSetMaxPoolPointsPerTx) Type 

func (msg MsgSetMaxPoolPointsPerTx) Type() string

Type returns the type of the message

func (*MsgSetMaxPoolPointsPerTx) Unmarshal 

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

func (MsgSetMaxPoolPointsPerTx) ValidateBasic 

func (msg MsgSetMaxPoolPointsPerTx) ValidateBasic() error

ValidateBasic validates the MsgSetMaxPoolPointsPerTx

func (*MsgSetMaxPoolPointsPerTx) XXX_DiscardUnknown 

func (m *MsgSetMaxPoolPointsPerTx) XXX_DiscardUnknown()

func (*MsgSetMaxPoolPointsPerTx) XXX_Marshal 

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

func (*MsgSetMaxPoolPointsPerTx) XXX_Merge 

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

func (*MsgSetMaxPoolPointsPerTx) XXX_Size 

func (m *MsgSetMaxPoolPointsPerTx) XXX_Size() int

func (*MsgSetMaxPoolPointsPerTx) XXX_Unmarshal 

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

type MsgSetMaxPoolPointsPerTxResponse 

type MsgSetMaxPoolPointsPerTxResponse struct {
}

MsgSetMaxPoolPointsPerTxResponse defines the Msg/SetMaxPoolPointsPerTx response type.

func (*MsgSetMaxPoolPointsPerTxResponse) Descriptor 

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

func (*MsgSetMaxPoolPointsPerTxResponse) Marshal 

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

func (*MsgSetMaxPoolPointsPerTxResponse) MarshalTo 

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

func (*MsgSetMaxPoolPointsPerTxResponse) MarshalToSizedBuffer 

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

func (*MsgSetMaxPoolPointsPerTxResponse) ProtoMessage 

func (*MsgSetMaxPoolPointsPerTxResponse) ProtoMessage()

func (*MsgSetMaxPoolPointsPerTxResponse) Reset 

func (m *MsgSetMaxPoolPointsPerTxResponse) Reset()

func (*MsgSetMaxPoolPointsPerTxResponse) Size 

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

func (*MsgSetMaxPoolPointsPerTxResponse) String 

func (m *MsgSetMaxPoolPointsPerTxResponse) String() string

func (*MsgSetMaxPoolPointsPerTxResponse) Unmarshal 

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

func (*MsgSetMaxPoolPointsPerTxResponse) XXX_DiscardUnknown 

func (m *MsgSetMaxPoolPointsPerTxResponse) XXX_DiscardUnknown()

func (*MsgSetMaxPoolPointsPerTxResponse) XXX_Marshal 

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

func (*MsgSetMaxPoolPointsPerTxResponse) XXX_Merge 

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

func (*MsgSetMaxPoolPointsPerTxResponse) XXX_Size 

func (m *MsgSetMaxPoolPointsPerTxResponse) XXX_Size() int

func (*MsgSetMaxPoolPointsPerTxResponse) XXX_Unmarshal 

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

type NoPoolForDenomPairError 

type NoPoolForDenomPairError struct {
	BaseDenom  string
	MatchDenom string
}

func (NoPoolForDenomPairError) Error 

func (e NoPoolForDenomPairError) Error() string

type Params 

type Params struct {
	// Boolean whether the protorev module is enabled.
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty" yaml:"enabled"`
	// The admin account (settings manager) of the protorev module.
	Admin string `protobuf:"bytes,2,opt,name=admin,proto3" json:"admin,omitempty" yaml:"admin"`
}

Params defines the parameters for the module.

func DefaultParams 

func DefaultParams() Params

DefaultParams returns a default set of parameters

func NewParams 

func NewParams(enable bool, admin string) Params

NewParams creates a new Params instance

func (*Params) Descriptor 

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

func (*Params) GetAdmin 

func (m *Params) GetAdmin() string

func (*Params) GetEnabled 

func (m *Params) GetEnabled() bool

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

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

ParamSetPairs get the 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 validates the set of 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 {
	RouteExactAmountIn(
		ctx sdk.Context,
		sender sdk.AccAddress,
		routes []poolmanagertypes.SwapAmountInRoute,
		tokenIn sdk.Coin,
		tokenOutMinAmount osmomath.Int) (tokenOutAmount osmomath.Int, err error)

	MultihopEstimateOutGivenExactAmountIn(
		ctx sdk.Context,
		routes []poolmanagertypes.SwapAmountInRoute,
		tokenIn sdk.Coin,
	) (tokenOutAmount osmomath.Int, err error)

	MultihopEstimateInGivenExactAmountOut(
		ctx sdk.Context,
		routes []poolmanagertypes.SwapAmountOutRoute,
		tokenOut sdk.Coin) (tokenInAmount osmomath.Int, err error)

	AllPools(
		ctx sdk.Context,
	) ([]poolmanagertypes.PoolI, error)
	GetPool(
		ctx sdk.Context,
		poolId uint64,
	) (poolmanagertypes.PoolI, error)
	GetPoolModule(ctx sdk.Context, poolId uint64) (poolmanagertypes.PoolModuleI, error)
	GetTotalPoolLiquidity(ctx sdk.Context, poolId uint64) (sdk.Coins, error)
	RouteGetPoolDenoms(ctx sdk.Context, poolId uint64) ([]string, error)
	GetTakerFeeTrackerForStakers(ctx sdk.Context) []sdk.Coin
	GetTakerFeeTrackerForCommunityPool(ctx sdk.Context) []sdk.Coin
	GetTakerFeeTrackerStartHeight(ctx sdk.Context) int64
}

PoolManagerKeeper defines the PoolManager contract that must be fulfilled when creating a x/protorev keeper.

type PoolWeights 

type PoolWeights struct {
	// The weight of a stableswap pool
	StableWeight uint64 `protobuf:"varint,1,opt,name=stable_weight,json=stableWeight,proto3" json:"stable_weight,omitempty" yaml:"stable_weight"`
	// The weight of a balancer pool
	BalancerWeight uint64 `` /* 127-byte string literal not displayed */
	// The weight of a concentrated pool
	ConcentratedWeight uint64 `` /* 143-byte string literal not displayed */
	// The weight of a cosmwasm pool
	CosmwasmWeight uint64 `` /* 127-byte string literal not displayed */
}

PoolWeights contains the weights of all of the different pool types. This distinction is made and necessary because the execution time ranges significantly between the different pool types. Each weight roughly corresponds to the amount of time (in ms) it takes to execute a swap on that pool type.

DEPRECATED: This field is deprecated and will be removed in the next release. It is replaced by the `info_by_pool_type` field.

func (*PoolWeights) Descriptor 

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

func (*PoolWeights) GetBalancerWeight 

func (m *PoolWeights) GetBalancerWeight() uint64

func (*PoolWeights) GetConcentratedWeight 

func (m *PoolWeights) GetConcentratedWeight() uint64

func (*PoolWeights) GetCosmwasmWeight 

func (m *PoolWeights) GetCosmwasmWeight() uint64

func (*PoolWeights) GetStableWeight 

func (m *PoolWeights) GetStableWeight() uint64

func (*PoolWeights) Marshal 

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

func (*PoolWeights) MarshalTo 

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

func (*PoolWeights) MarshalToSizedBuffer 

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

func (*PoolWeights) ProtoMessage 

func (*PoolWeights) ProtoMessage()

func (*PoolWeights) Reset 

func (m *PoolWeights) Reset()

func (*PoolWeights) Size 

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

func (*PoolWeights) String 

func (m *PoolWeights) String() string

func (*PoolWeights) Unmarshal 

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

func (*PoolWeights) XXX_DiscardUnknown 

func (m *PoolWeights) XXX_DiscardUnknown()

func (*PoolWeights) XXX_Marshal 

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

func (*PoolWeights) XXX_Merge 

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

func (*PoolWeights) XXX_Size 

func (m *PoolWeights) XXX_Size() int

func (*PoolWeights) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Params queries the parameters of the module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// GetProtoRevNumberOfTrades queries the number of arbitrage trades the module
	// has executed
	GetProtoRevNumberOfTrades(ctx context.Context, in *QueryGetProtoRevNumberOfTradesRequest, opts ...grpc.CallOption) (*QueryGetProtoRevNumberOfTradesResponse, error)
	// GetProtoRevProfitsByDenom queries the profits of the module by denom
	GetProtoRevProfitsByDenom(ctx context.Context, in *QueryGetProtoRevProfitsByDenomRequest, opts ...grpc.CallOption) (*QueryGetProtoRevProfitsByDenomResponse, error)
	// GetProtoRevAllProfits queries all of the profits from the module
	GetProtoRevAllProfits(ctx context.Context, in *QueryGetProtoRevAllProfitsRequest, opts ...grpc.CallOption) (*QueryGetProtoRevAllProfitsResponse, error)
	// GetProtoRevStatisticsByRoute queries the number of arbitrages and profits
	// that have been executed for a given route
	GetProtoRevStatisticsByRoute(ctx context.Context, in *QueryGetProtoRevStatisticsByRouteRequest, opts ...grpc.CallOption) (*QueryGetProtoRevStatisticsByRouteResponse, error)
	// GetProtoRevAllRouteStatistics queries all of routes that the module has
	// arbitraged against and the number of trades and profits that have been
	// accumulated for each route
	GetProtoRevAllRouteStatistics(ctx context.Context, in *QueryGetProtoRevAllRouteStatisticsRequest, opts ...grpc.CallOption) (*QueryGetProtoRevAllRouteStatisticsResponse, error)
	// GetProtoRevTokenPairArbRoutes queries all of the hot routes that the module
	// is currently arbitraging
	GetProtoRevTokenPairArbRoutes(ctx context.Context, in *QueryGetProtoRevTokenPairArbRoutesRequest, opts ...grpc.CallOption) (*QueryGetProtoRevTokenPairArbRoutesResponse, error)
	// GetProtoRevAdminAccount queries the admin account of the module
	GetProtoRevAdminAccount(ctx context.Context, in *QueryGetProtoRevAdminAccountRequest, opts ...grpc.CallOption) (*QueryGetProtoRevAdminAccountResponse, error)
	// GetProtoRevDeveloperAccount queries the developer account of the module
	GetProtoRevDeveloperAccount(ctx context.Context, in *QueryGetProtoRevDeveloperAccountRequest, opts ...grpc.CallOption) (*QueryGetProtoRevDeveloperAccountResponse, error)
	// GetProtoRevInfoByPoolType queries pool type information that is currently
	// being utilized by the module
	GetProtoRevInfoByPoolType(ctx context.Context, in *QueryGetProtoRevInfoByPoolTypeRequest, opts ...grpc.CallOption) (*QueryGetProtoRevInfoByPoolTypeResponse, error)
	// GetProtoRevMaxPoolPointsPerTx queries the maximum number of pool points
	// that can be consumed per transaction
	GetProtoRevMaxPoolPointsPerTx(ctx context.Context, in *QueryGetProtoRevMaxPoolPointsPerTxRequest, opts ...grpc.CallOption) (*QueryGetProtoRevMaxPoolPointsPerTxResponse, error)
	// GetProtoRevMaxPoolPointsPerBlock queries the maximum number of pool points
	// that can consumed per block
	GetProtoRevMaxPoolPointsPerBlock(ctx context.Context, in *QueryGetProtoRevMaxPoolPointsPerBlockRequest, opts ...grpc.CallOption) (*QueryGetProtoRevMaxPoolPointsPerBlockResponse, error)
	// GetProtoRevBaseDenoms queries the base denoms that the module is currently
	// utilizing for arbitrage
	GetProtoRevBaseDenoms(ctx context.Context, in *QueryGetProtoRevBaseDenomsRequest, opts ...grpc.CallOption) (*QueryGetProtoRevBaseDenomsResponse, error)
	// GetProtoRevEnabled queries whether the module is enabled or not
	GetProtoRevEnabled(ctx context.Context, in *QueryGetProtoRevEnabledRequest, opts ...grpc.CallOption) (*QueryGetProtoRevEnabledResponse, error)
	// GetProtoRevPool queries the pool id used via the highest liquidity method
	// for arbitrage route building given a pair of denominations
	GetProtoRevPool(ctx context.Context, in *QueryGetProtoRevPoolRequest, opts ...grpc.CallOption) (*QueryGetProtoRevPoolResponse, error)
	// GetAllProtocolRevenue queries all of the protocol revenue that has been
	// accumulated by any module
	GetAllProtocolRevenue(ctx context.Context, in *QueryGetAllProtocolRevenueRequest, opts ...grpc.CallOption) (*QueryGetAllProtocolRevenueResponse, error)
}

QueryClient is the client API for Query service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryClient 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryGetAllProtocolRevenueRequest 

type QueryGetAllProtocolRevenueRequest struct {
}

func (*QueryGetAllProtocolRevenueRequest) Descriptor 

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

func (*QueryGetAllProtocolRevenueRequest) Marshal 

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

func (*QueryGetAllProtocolRevenueRequest) MarshalTo 

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

func (*QueryGetAllProtocolRevenueRequest) MarshalToSizedBuffer 

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

func (*QueryGetAllProtocolRevenueRequest) ProtoMessage 

func (*QueryGetAllProtocolRevenueRequest) ProtoMessage()

func (*QueryGetAllProtocolRevenueRequest) Reset 

func (m *QueryGetAllProtocolRevenueRequest) Reset()

func (*QueryGetAllProtocolRevenueRequest) Size 

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

func (*QueryGetAllProtocolRevenueRequest) String 

func (m *QueryGetAllProtocolRevenueRequest) String() string

func (*QueryGetAllProtocolRevenueRequest) Unmarshal 

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

func (*QueryGetAllProtocolRevenueRequest) XXX_DiscardUnknown 

func (m *QueryGetAllProtocolRevenueRequest) XXX_DiscardUnknown()

func (*QueryGetAllProtocolRevenueRequest) XXX_Marshal 

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

func (*QueryGetAllProtocolRevenueRequest) XXX_Merge 

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

func (*QueryGetAllProtocolRevenueRequest) XXX_Size 

func (m *QueryGetAllProtocolRevenueRequest) XXX_Size() int

func (*QueryGetAllProtocolRevenueRequest) XXX_Unmarshal 

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

type QueryGetAllProtocolRevenueResponse 

type QueryGetAllProtocolRevenueResponse struct {
	AllProtocolRevenue AllProtocolRevenue `` /* 135-byte string literal not displayed */
}

func (*QueryGetAllProtocolRevenueResponse) Descriptor 

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

func (*QueryGetAllProtocolRevenueResponse) GetAllProtocolRevenue 

func (m *QueryGetAllProtocolRevenueResponse) GetAllProtocolRevenue() AllProtocolRevenue

func (*QueryGetAllProtocolRevenueResponse) Marshal 

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

func (*QueryGetAllProtocolRevenueResponse) MarshalTo 

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

func (*QueryGetAllProtocolRevenueResponse) MarshalToSizedBuffer 

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

func (*QueryGetAllProtocolRevenueResponse) ProtoMessage 

func (*QueryGetAllProtocolRevenueResponse) ProtoMessage()

func (*QueryGetAllProtocolRevenueResponse) Reset 

func (m *QueryGetAllProtocolRevenueResponse) Reset()

func (*QueryGetAllProtocolRevenueResponse) Size 

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

func (*QueryGetAllProtocolRevenueResponse) String 

func (m *QueryGetAllProtocolRevenueResponse) String() string

func (*QueryGetAllProtocolRevenueResponse) Unmarshal 

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

func (*QueryGetAllProtocolRevenueResponse) XXX_DiscardUnknown 

func (m *QueryGetAllProtocolRevenueResponse) XXX_DiscardUnknown()

func (*QueryGetAllProtocolRevenueResponse) XXX_Marshal 

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

func (*QueryGetAllProtocolRevenueResponse) XXX_Merge 

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

func (*QueryGetAllProtocolRevenueResponse) XXX_Size 

func (m *QueryGetAllProtocolRevenueResponse) XXX_Size() int

func (*QueryGetAllProtocolRevenueResponse) XXX_Unmarshal 

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

type QueryGetProtoRevAdminAccountRequest 

type QueryGetProtoRevAdminAccountRequest struct {
}

QueryGetProtoRevAdminAccountRequest is request type for the Query/GetProtoRevAdminAccount RPC method.

func (*QueryGetProtoRevAdminAccountRequest) Descriptor 

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

func (*QueryGetProtoRevAdminAccountRequest) Marshal 

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

func (*QueryGetProtoRevAdminAccountRequest) MarshalTo 

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

func (*QueryGetProtoRevAdminAccountRequest) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevAdminAccountRequest) ProtoMessage 

func (*QueryGetProtoRevAdminAccountRequest) ProtoMessage()

func (*QueryGetProtoRevAdminAccountRequest) Reset 

func (m *QueryGetProtoRevAdminAccountRequest) Reset()

func (*QueryGetProtoRevAdminAccountRequest) Size 

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

func (*QueryGetProtoRevAdminAccountRequest) String 

func (m *QueryGetProtoRevAdminAccountRequest) String() string

func (*QueryGetProtoRevAdminAccountRequest) Unmarshal 

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

func (*QueryGetProtoRevAdminAccountRequest) XXX_DiscardUnknown 

func (m *QueryGetProtoRevAdminAccountRequest) XXX_DiscardUnknown()

func (*QueryGetProtoRevAdminAccountRequest) XXX_Marshal 

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

func (*QueryGetProtoRevAdminAccountRequest) XXX_Merge 

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

func (*QueryGetProtoRevAdminAccountRequest) XXX_Size 

func (m *QueryGetProtoRevAdminAccountRequest) XXX_Size() int

func (*QueryGetProtoRevAdminAccountRequest) XXX_Unmarshal 

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

type QueryGetProtoRevAdminAccountResponse 

type QueryGetProtoRevAdminAccountResponse struct {
	// admin_account is the admin account of the module
	AdminAccount string `protobuf:"bytes,1,opt,name=admin_account,json=adminAccount,proto3" json:"admin_account,omitempty" yaml:"admin_account"`
}

QueryGetProtoRevAdminAccountResponse is response type for the Query/GetProtoRevAdminAccount RPC method.

func (*QueryGetProtoRevAdminAccountResponse) Descriptor 

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

func (*QueryGetProtoRevAdminAccountResponse) GetAdminAccount 

func (m *QueryGetProtoRevAdminAccountResponse) GetAdminAccount() string

func (*QueryGetProtoRevAdminAccountResponse) Marshal 

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

func (*QueryGetProtoRevAdminAccountResponse) MarshalTo 

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

func (*QueryGetProtoRevAdminAccountResponse) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevAdminAccountResponse) ProtoMessage 

func (*QueryGetProtoRevAdminAccountResponse) ProtoMessage()

func (*QueryGetProtoRevAdminAccountResponse) Reset 

func (m *QueryGetProtoRevAdminAccountResponse) Reset()

func (*QueryGetProtoRevAdminAccountResponse) Size 

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

func (*QueryGetProtoRevAdminAccountResponse) String 

func (m *QueryGetProtoRevAdminAccountResponse) String() string

func (*QueryGetProtoRevAdminAccountResponse) Unmarshal 

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

func (*QueryGetProtoRevAdminAccountResponse) XXX_DiscardUnknown 

func (m *QueryGetProtoRevAdminAccountResponse) XXX_DiscardUnknown()

func (*QueryGetProtoRevAdminAccountResponse) XXX_Marshal 

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

func (*QueryGetProtoRevAdminAccountResponse) XXX_Merge 

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

func (*QueryGetProtoRevAdminAccountResponse) XXX_Size 

func (m *QueryGetProtoRevAdminAccountResponse) XXX_Size() int

func (*QueryGetProtoRevAdminAccountResponse) XXX_Unmarshal 

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

type QueryGetProtoRevAllProfitsRequest 

type QueryGetProtoRevAllProfitsRequest struct {
}

QueryGetProtoRevAllProfitsRequest is request type for the Query/GetProtoRevAllProfits RPC method.

func (*QueryGetProtoRevAllProfitsRequest) Descriptor 

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

func (*QueryGetProtoRevAllProfitsRequest) Marshal 

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

func (*QueryGetProtoRevAllProfitsRequest) MarshalTo 

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

func (*QueryGetProtoRevAllProfitsRequest) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevAllProfitsRequest) ProtoMessage 

func (*QueryGetProtoRevAllProfitsRequest) ProtoMessage()

func (*QueryGetProtoRevAllProfitsRequest) Reset 

func (m *QueryGetProtoRevAllProfitsRequest) Reset()

func (*QueryGetProtoRevAllProfitsRequest) Size 

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

func (*QueryGetProtoRevAllProfitsRequest) String 

func (m *QueryGetProtoRevAllProfitsRequest) String() string

func (*QueryGetProtoRevAllProfitsRequest) Unmarshal 

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

func (*QueryGetProtoRevAllProfitsRequest) XXX_DiscardUnknown 

func (m *QueryGetProtoRevAllProfitsRequest) XXX_DiscardUnknown()

func (*QueryGetProtoRevAllProfitsRequest) XXX_Marshal 

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

func (*QueryGetProtoRevAllProfitsRequest) XXX_Merge 

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

func (*QueryGetProtoRevAllProfitsRequest) XXX_Size 

func (m *QueryGetProtoRevAllProfitsRequest) XXX_Size() int

func (*QueryGetProtoRevAllProfitsRequest) XXX_Unmarshal 

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

type QueryGetProtoRevAllProfitsResponse 

type QueryGetProtoRevAllProfitsResponse struct {
	// profits is a list of all of the profits from the module
	Profits []types.Coin `protobuf:"bytes,1,rep,name=profits,proto3" json:"profits" yaml:"profits"`
}

QueryGetProtoRevAllProfitsResponse is response type for the Query/GetProtoRevAllProfits RPC method.

func (*QueryGetProtoRevAllProfitsResponse) Descriptor 

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

func (*QueryGetProtoRevAllProfitsResponse) GetProfits 

func (m *QueryGetProtoRevAllProfitsResponse) GetProfits() []types.Coin

func (*QueryGetProtoRevAllProfitsResponse) Marshal 

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

func (*QueryGetProtoRevAllProfitsResponse) MarshalTo 

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

func (*QueryGetProtoRevAllProfitsResponse) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevAllProfitsResponse) ProtoMessage 

func (*QueryGetProtoRevAllProfitsResponse) ProtoMessage()

func (*QueryGetProtoRevAllProfitsResponse) Reset 

func (m *QueryGetProtoRevAllProfitsResponse) Reset()

func (*QueryGetProtoRevAllProfitsResponse) Size 

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

func (*QueryGetProtoRevAllProfitsResponse) String 

func (m *QueryGetProtoRevAllProfitsResponse) String() string

func (*QueryGetProtoRevAllProfitsResponse) Unmarshal 

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

func (*QueryGetProtoRevAllProfitsResponse) XXX_DiscardUnknown 

func (m *QueryGetProtoRevAllProfitsResponse) XXX_DiscardUnknown()

func (*QueryGetProtoRevAllProfitsResponse) XXX_Marshal 

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

func (*QueryGetProtoRevAllProfitsResponse) XXX_Merge 

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

func (*QueryGetProtoRevAllProfitsResponse) XXX_Size 

func (m *QueryGetProtoRevAllProfitsResponse) XXX_Size() int

func (*QueryGetProtoRevAllProfitsResponse) XXX_Unmarshal 

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

type QueryGetProtoRevAllRouteStatisticsRequest 

type QueryGetProtoRevAllRouteStatisticsRequest struct {
}

QueryGetProtoRevAllRouteStatisticsRequest is request type for the Query/GetProtoRevAllRouteStatistics RPC method.

func (*QueryGetProtoRevAllRouteStatisticsRequest) Descriptor 

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

func (*QueryGetProtoRevAllRouteStatisticsRequest) Marshal 

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

func (*QueryGetProtoRevAllRouteStatisticsRequest) MarshalTo 

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

func (*QueryGetProtoRevAllRouteStatisticsRequest) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevAllRouteStatisticsRequest) ProtoMessage 

func (*QueryGetProtoRevAllRouteStatisticsRequest) ProtoMessage()

func (*QueryGetProtoRevAllRouteStatisticsRequest) Reset 

func (m *QueryGetProtoRevAllRouteStatisticsRequest) Reset()

func (*QueryGetProtoRevAllRouteStatisticsRequest) Size 

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

func (*QueryGetProtoRevAllRouteStatisticsRequest) String 

func (m *QueryGetProtoRevAllRouteStatisticsRequest) String() string

func (*QueryGetProtoRevAllRouteStatisticsRequest) Unmarshal 

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

func (*QueryGetProtoRevAllRouteStatisticsRequest) XXX_DiscardUnknown 

func (m *QueryGetProtoRevAllRouteStatisticsRequest) XXX_DiscardUnknown()

func (*QueryGetProtoRevAllRouteStatisticsRequest) XXX_Marshal 

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

func (*QueryGetProtoRevAllRouteStatisticsRequest) XXX_Merge 

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

func (*QueryGetProtoRevAllRouteStatisticsRequest) XXX_Size 

func (m *QueryGetProtoRevAllRouteStatisticsRequest) XXX_Size() int

func (*QueryGetProtoRevAllRouteStatisticsRequest) XXX_Unmarshal 

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

type QueryGetProtoRevAllRouteStatisticsResponse 

type QueryGetProtoRevAllRouteStatisticsResponse struct {
	// statistics contains the number of trades/profits the module has executed on
	// all routes it has successfully executed a trade on
	Statistics []RouteStatistics `protobuf:"bytes,1,rep,name=statistics,proto3" json:"statistics" yaml:"statistics"`
}

QueryGetProtoRevAllRouteStatisticsResponse is response type for the Query/GetProtoRevAllRouteStatistics RPC method.

func (*QueryGetProtoRevAllRouteStatisticsResponse) Descriptor 

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

func (*QueryGetProtoRevAllRouteStatisticsResponse) GetStatistics 

func (m *QueryGetProtoRevAllRouteStatisticsResponse) GetStatistics() []RouteStatistics

func (*QueryGetProtoRevAllRouteStatisticsResponse) Marshal 

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

func (*QueryGetProtoRevAllRouteStatisticsResponse) MarshalTo 

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

func (*QueryGetProtoRevAllRouteStatisticsResponse) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevAllRouteStatisticsResponse) ProtoMessage 

func (*QueryGetProtoRevAllRouteStatisticsResponse) ProtoMessage()

func (*QueryGetProtoRevAllRouteStatisticsResponse) Reset 

func (m *QueryGetProtoRevAllRouteStatisticsResponse) Reset()

func (*QueryGetProtoRevAllRouteStatisticsResponse) Size 

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

func (*QueryGetProtoRevAllRouteStatisticsResponse) String 

func (m *QueryGetProtoRevAllRouteStatisticsResponse) String() string

func (*QueryGetProtoRevAllRouteStatisticsResponse) Unmarshal 

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

func (*QueryGetProtoRevAllRouteStatisticsResponse) XXX_DiscardUnknown 

func (m *QueryGetProtoRevAllRouteStatisticsResponse) XXX_DiscardUnknown()

func (*QueryGetProtoRevAllRouteStatisticsResponse) XXX_Marshal 

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

func (*QueryGetProtoRevAllRouteStatisticsResponse) XXX_Merge 

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

func (*QueryGetProtoRevAllRouteStatisticsResponse) XXX_Size 

func (m *QueryGetProtoRevAllRouteStatisticsResponse) XXX_Size() int

func (*QueryGetProtoRevAllRouteStatisticsResponse) XXX_Unmarshal 

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

type QueryGetProtoRevBaseDenomsRequest 

type QueryGetProtoRevBaseDenomsRequest struct {
}

QueryGetProtoRevBaseDenomsRequest is request type for the Query/GetProtoRevBaseDenoms RPC method.

func (*QueryGetProtoRevBaseDenomsRequest) Descriptor 

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

func (*QueryGetProtoRevBaseDenomsRequest) Marshal 

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

func (*QueryGetProtoRevBaseDenomsRequest) MarshalTo 

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

func (*QueryGetProtoRevBaseDenomsRequest) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevBaseDenomsRequest) ProtoMessage 

func (*QueryGetProtoRevBaseDenomsRequest) ProtoMessage()

func (*QueryGetProtoRevBaseDenomsRequest) Reset 

func (m *QueryGetProtoRevBaseDenomsRequest) Reset()

func (*QueryGetProtoRevBaseDenomsRequest) Size 

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

func (*QueryGetProtoRevBaseDenomsRequest) String 

func (m *QueryGetProtoRevBaseDenomsRequest) String() string

func (*QueryGetProtoRevBaseDenomsRequest) Unmarshal 

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

func (*QueryGetProtoRevBaseDenomsRequest) XXX_DiscardUnknown 

func (m *QueryGetProtoRevBaseDenomsRequest) XXX_DiscardUnknown()

func (*QueryGetProtoRevBaseDenomsRequest) XXX_Marshal 

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

func (*QueryGetProtoRevBaseDenomsRequest) XXX_Merge 

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

func (*QueryGetProtoRevBaseDenomsRequest) XXX_Size 

func (m *QueryGetProtoRevBaseDenomsRequest) XXX_Size() int

func (*QueryGetProtoRevBaseDenomsRequest) XXX_Unmarshal 

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

type QueryGetProtoRevBaseDenomsResponse 

type QueryGetProtoRevBaseDenomsResponse struct {
	// base_denoms is a list of all of the base denoms and step sizes
	BaseDenoms []BaseDenom `protobuf:"bytes,1,rep,name=base_denoms,json=baseDenoms,proto3" json:"base_denoms" yaml:"base_denoms"`
}

QueryGetProtoRevBaseDenomsResponse is response type for the Query/GetProtoRevBaseDenoms RPC method.

func (*QueryGetProtoRevBaseDenomsResponse) Descriptor 

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

func (*QueryGetProtoRevBaseDenomsResponse) GetBaseDenoms 

func (m *QueryGetProtoRevBaseDenomsResponse) GetBaseDenoms() []BaseDenom

func (*QueryGetProtoRevBaseDenomsResponse) Marshal 

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

func (*QueryGetProtoRevBaseDenomsResponse) MarshalTo 

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

func (*QueryGetProtoRevBaseDenomsResponse) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevBaseDenomsResponse) ProtoMessage 

func (*QueryGetProtoRevBaseDenomsResponse) ProtoMessage()

func (*QueryGetProtoRevBaseDenomsResponse) Reset 

func (m *QueryGetProtoRevBaseDenomsResponse) Reset()

func (*QueryGetProtoRevBaseDenomsResponse) Size 

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

func (*QueryGetProtoRevBaseDenomsResponse) String 

func (m *QueryGetProtoRevBaseDenomsResponse) String() string

func (*QueryGetProtoRevBaseDenomsResponse) Unmarshal 

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

func (*QueryGetProtoRevBaseDenomsResponse) XXX_DiscardUnknown 

func (m *QueryGetProtoRevBaseDenomsResponse) XXX_DiscardUnknown()

func (*QueryGetProtoRevBaseDenomsResponse) XXX_Marshal 

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

func (*QueryGetProtoRevBaseDenomsResponse) XXX_Merge 

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

func (*QueryGetProtoRevBaseDenomsResponse) XXX_Size 

func (m *QueryGetProtoRevBaseDenomsResponse) XXX_Size() int

func (*QueryGetProtoRevBaseDenomsResponse) XXX_Unmarshal 

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

type QueryGetProtoRevDeveloperAccountRequest 

type QueryGetProtoRevDeveloperAccountRequest struct {
}

QueryGetProtoRevDeveloperAccountRequest is request type for the Query/GetProtoRevDeveloperAccount RPC method.

func (*QueryGetProtoRevDeveloperAccountRequest) Descriptor 

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

func (*QueryGetProtoRevDeveloperAccountRequest) Marshal 

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

func (*QueryGetProtoRevDeveloperAccountRequest) MarshalTo 

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

func (*QueryGetProtoRevDeveloperAccountRequest) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevDeveloperAccountRequest) ProtoMessage 

func (*QueryGetProtoRevDeveloperAccountRequest) ProtoMessage()

func (*QueryGetProtoRevDeveloperAccountRequest) Reset 

func (m *QueryGetProtoRevDeveloperAccountRequest) Reset()

func (*QueryGetProtoRevDeveloperAccountRequest) Size 

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

func (*QueryGetProtoRevDeveloperAccountRequest) String 

func (m *QueryGetProtoRevDeveloperAccountRequest) String() string

func (*QueryGetProtoRevDeveloperAccountRequest) Unmarshal 

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

func (*QueryGetProtoRevDeveloperAccountRequest) XXX_DiscardUnknown 

func (m *QueryGetProtoRevDeveloperAccountRequest) XXX_DiscardUnknown()

func (*QueryGetProtoRevDeveloperAccountRequest) XXX_Marshal 

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

func (*QueryGetProtoRevDeveloperAccountRequest) XXX_Merge 

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

func (*QueryGetProtoRevDeveloperAccountRequest) XXX_Size 

func (m *QueryGetProtoRevDeveloperAccountRequest) XXX_Size() int

func (*QueryGetProtoRevDeveloperAccountRequest) XXX_Unmarshal 

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

type QueryGetProtoRevDeveloperAccountResponse 

type QueryGetProtoRevDeveloperAccountResponse struct {
	// developer_account is the developer account of the module
	DeveloperAccount string `` /* 134-byte string literal not displayed */
}

QueryGetProtoRevDeveloperAccountResponse is response type for the Query/GetProtoRevDeveloperAccount RPC method.

func (*QueryGetProtoRevDeveloperAccountResponse) Descriptor 

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

func (*QueryGetProtoRevDeveloperAccountResponse) GetDeveloperAccount 

func (m *QueryGetProtoRevDeveloperAccountResponse) GetDeveloperAccount() string

func (*QueryGetProtoRevDeveloperAccountResponse) Marshal 

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

func (*QueryGetProtoRevDeveloperAccountResponse) MarshalTo 

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

func (*QueryGetProtoRevDeveloperAccountResponse) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevDeveloperAccountResponse) ProtoMessage 

func (*QueryGetProtoRevDeveloperAccountResponse) ProtoMessage()

func (*QueryGetProtoRevDeveloperAccountResponse) Reset 

func (m *QueryGetProtoRevDeveloperAccountResponse) Reset()

func (*QueryGetProtoRevDeveloperAccountResponse) Size 

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

func (*QueryGetProtoRevDeveloperAccountResponse) String 

func (m *QueryGetProtoRevDeveloperAccountResponse) String() string

func (*QueryGetProtoRevDeveloperAccountResponse) Unmarshal 

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

func (*QueryGetProtoRevDeveloperAccountResponse) XXX_DiscardUnknown 

func (m *QueryGetProtoRevDeveloperAccountResponse) XXX_DiscardUnknown()

func (*QueryGetProtoRevDeveloperAccountResponse) XXX_Marshal 

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

func (*QueryGetProtoRevDeveloperAccountResponse) XXX_Merge 

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

func (*QueryGetProtoRevDeveloperAccountResponse) XXX_Size 

func (m *QueryGetProtoRevDeveloperAccountResponse) XXX_Size() int

func (*QueryGetProtoRevDeveloperAccountResponse) XXX_Unmarshal 

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

type QueryGetProtoRevEnabledRequest 

type QueryGetProtoRevEnabledRequest struct {
}

QueryGetProtoRevEnabledRequest is request type for the Query/GetProtoRevEnabled RPC method.

func (*QueryGetProtoRevEnabledRequest) Descriptor 

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

func (*QueryGetProtoRevEnabledRequest) Marshal 

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

func (*QueryGetProtoRevEnabledRequest) MarshalTo 

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

func (*QueryGetProtoRevEnabledRequest) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevEnabledRequest) ProtoMessage 

func (*QueryGetProtoRevEnabledRequest) ProtoMessage()

func (*QueryGetProtoRevEnabledRequest) Reset 

func (m *QueryGetProtoRevEnabledRequest) Reset()

func (*QueryGetProtoRevEnabledRequest) Size 

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

func (*QueryGetProtoRevEnabledRequest) String 

func (m *QueryGetProtoRevEnabledRequest) String() string

func (*QueryGetProtoRevEnabledRequest) Unmarshal 

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

func (*QueryGetProtoRevEnabledRequest) XXX_DiscardUnknown 

func (m *QueryGetProtoRevEnabledRequest) XXX_DiscardUnknown()

func (*QueryGetProtoRevEnabledRequest) XXX_Marshal 

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

func (*QueryGetProtoRevEnabledRequest) XXX_Merge 

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

func (*QueryGetProtoRevEnabledRequest) XXX_Size 

func (m *QueryGetProtoRevEnabledRequest) XXX_Size() int

func (*QueryGetProtoRevEnabledRequest) XXX_Unmarshal 

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

type QueryGetProtoRevEnabledResponse 

type QueryGetProtoRevEnabledResponse struct {
	// enabled is whether the module is enabled
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty" yaml:"enabled"`
}

QueryGetProtoRevEnabledResponse is response type for the Query/GetProtoRevEnabled RPC method.

func (*QueryGetProtoRevEnabledResponse) Descriptor 

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

func (*QueryGetProtoRevEnabledResponse) GetEnabled 

func (m *QueryGetProtoRevEnabledResponse) GetEnabled() bool

func (*QueryGetProtoRevEnabledResponse) Marshal 

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

func (*QueryGetProtoRevEnabledResponse) MarshalTo 

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

func (*QueryGetProtoRevEnabledResponse) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevEnabledResponse) ProtoMessage 

func (*QueryGetProtoRevEnabledResponse) ProtoMessage()

func (*QueryGetProtoRevEnabledResponse) Reset 

func (m *QueryGetProtoRevEnabledResponse) Reset()

func (*QueryGetProtoRevEnabledResponse) Size 

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

func (*QueryGetProtoRevEnabledResponse) String 

func (m *QueryGetProtoRevEnabledResponse) String() string

func (*QueryGetProtoRevEnabledResponse) Unmarshal 

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

func (*QueryGetProtoRevEnabledResponse) XXX_DiscardUnknown 

func (m *QueryGetProtoRevEnabledResponse) XXX_DiscardUnknown()

func (*QueryGetProtoRevEnabledResponse) XXX_Marshal 

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

func (*QueryGetProtoRevEnabledResponse) XXX_Merge 

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

func (*QueryGetProtoRevEnabledResponse) XXX_Size 

func (m *QueryGetProtoRevEnabledResponse) XXX_Size() int

func (*QueryGetProtoRevEnabledResponse) XXX_Unmarshal 

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

type QueryGetProtoRevInfoByPoolTypeRequest 

type QueryGetProtoRevInfoByPoolTypeRequest struct {
}

QueryGetProtoRevInfoByPoolTypeRequest is request type for the Query/GetProtoRevInfoByPoolType RPC method.

func (*QueryGetProtoRevInfoByPoolTypeRequest) Descriptor 

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

func (*QueryGetProtoRevInfoByPoolTypeRequest) Marshal 

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

func (*QueryGetProtoRevInfoByPoolTypeRequest) MarshalTo 

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

func (*QueryGetProtoRevInfoByPoolTypeRequest) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevInfoByPoolTypeRequest) ProtoMessage 

func (*QueryGetProtoRevInfoByPoolTypeRequest) ProtoMessage()

func (*QueryGetProtoRevInfoByPoolTypeRequest) Reset 

func (m *QueryGetProtoRevInfoByPoolTypeRequest) Reset()

func (*QueryGetProtoRevInfoByPoolTypeRequest) Size 

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

func (*QueryGetProtoRevInfoByPoolTypeRequest) String 

func (m *QueryGetProtoRevInfoByPoolTypeRequest) String() string

func (*QueryGetProtoRevInfoByPoolTypeRequest) Unmarshal 

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

func (*QueryGetProtoRevInfoByPoolTypeRequest) XXX_DiscardUnknown 

func (m *QueryGetProtoRevInfoByPoolTypeRequest) XXX_DiscardUnknown()

func (*QueryGetProtoRevInfoByPoolTypeRequest) XXX_Marshal 

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

func (*QueryGetProtoRevInfoByPoolTypeRequest) XXX_Merge 

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

func (*QueryGetProtoRevInfoByPoolTypeRequest) XXX_Size 

func (m *QueryGetProtoRevInfoByPoolTypeRequest) XXX_Size() int

func (*QueryGetProtoRevInfoByPoolTypeRequest) XXX_Unmarshal 

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

type QueryGetProtoRevInfoByPoolTypeResponse 

type QueryGetProtoRevInfoByPoolTypeResponse struct {
	// InfoByPoolType contains all information pertaining to how different
	// pool types are handled by the module.
	InfoByPoolType InfoByPoolType `protobuf:"bytes,1,opt,name=info_by_pool_type,json=infoByPoolType,proto3" json:"info_by_pool_type" yaml:"info_by_pool_type"`
}

QueryGetProtoRevInfoByPoolTypeResponse is response type for the Query/GetProtoRevInfoByPoolType RPC method.

func (*QueryGetProtoRevInfoByPoolTypeResponse) Descriptor 

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

func (*QueryGetProtoRevInfoByPoolTypeResponse) GetInfoByPoolType 

func (m *QueryGetProtoRevInfoByPoolTypeResponse) GetInfoByPoolType() InfoByPoolType

func (*QueryGetProtoRevInfoByPoolTypeResponse) Marshal 

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

func (*QueryGetProtoRevInfoByPoolTypeResponse) MarshalTo 

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

func (*QueryGetProtoRevInfoByPoolTypeResponse) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevInfoByPoolTypeResponse) ProtoMessage 

func (*QueryGetProtoRevInfoByPoolTypeResponse) ProtoMessage()

func (*QueryGetProtoRevInfoByPoolTypeResponse) Reset 

func (m *QueryGetProtoRevInfoByPoolTypeResponse) Reset()

func (*QueryGetProtoRevInfoByPoolTypeResponse) Size 

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

func (*QueryGetProtoRevInfoByPoolTypeResponse) String 

func (m *QueryGetProtoRevInfoByPoolTypeResponse) String() string

func (*QueryGetProtoRevInfoByPoolTypeResponse) Unmarshal 

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

func (*QueryGetProtoRevInfoByPoolTypeResponse) XXX_DiscardUnknown 

func (m *QueryGetProtoRevInfoByPoolTypeResponse) XXX_DiscardUnknown()

func (*QueryGetProtoRevInfoByPoolTypeResponse) XXX_Marshal 

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

func (*QueryGetProtoRevInfoByPoolTypeResponse) XXX_Merge 

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

func (*QueryGetProtoRevInfoByPoolTypeResponse) XXX_Size 

func (m *QueryGetProtoRevInfoByPoolTypeResponse) XXX_Size() int

func (*QueryGetProtoRevInfoByPoolTypeResponse) XXX_Unmarshal 

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

type QueryGetProtoRevMaxPoolPointsPerBlockRequest 

type QueryGetProtoRevMaxPoolPointsPerBlockRequest struct {
}

QueryGetProtoRevMaxPoolPointsPerBlockRequest is request type for the Query/GetProtoRevMaxPoolPointsPerBlock RPC method.

func (*QueryGetProtoRevMaxPoolPointsPerBlockRequest) Descriptor 

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

func (*QueryGetProtoRevMaxPoolPointsPerBlockRequest) Marshal 

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

func (*QueryGetProtoRevMaxPoolPointsPerBlockRequest) MarshalTo 

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

func (*QueryGetProtoRevMaxPoolPointsPerBlockRequest) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevMaxPoolPointsPerBlockRequest) ProtoMessage 

func (*QueryGetProtoRevMaxPoolPointsPerBlockRequest) ProtoMessage()

func (*QueryGetProtoRevMaxPoolPointsPerBlockRequest) Reset 

func (m *QueryGetProtoRevMaxPoolPointsPerBlockRequest) Reset()

func (*QueryGetProtoRevMaxPoolPointsPerBlockRequest) Size 

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

func (*QueryGetProtoRevMaxPoolPointsPerBlockRequest) String 

func (m *QueryGetProtoRevMaxPoolPointsPerBlockRequest) String() string

func (*QueryGetProtoRevMaxPoolPointsPerBlockRequest) Unmarshal 

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

func (*QueryGetProtoRevMaxPoolPointsPerBlockRequest) XXX_DiscardUnknown 

func (m *QueryGetProtoRevMaxPoolPointsPerBlockRequest) XXX_DiscardUnknown()

func (*QueryGetProtoRevMaxPoolPointsPerBlockRequest) XXX_Marshal 

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

func (*QueryGetProtoRevMaxPoolPointsPerBlockRequest) XXX_Merge 

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

func (*QueryGetProtoRevMaxPoolPointsPerBlockRequest) XXX_Size 

func (m *QueryGetProtoRevMaxPoolPointsPerBlockRequest) XXX_Size() int

func (*QueryGetProtoRevMaxPoolPointsPerBlockRequest) XXX_Unmarshal 

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

type QueryGetProtoRevMaxPoolPointsPerBlockResponse 

type QueryGetProtoRevMaxPoolPointsPerBlockResponse struct {
	// max_pool_points_per_block is the maximum number of pool points that can be
	// consumed per block
	MaxPoolPointsPerBlock uint64 `` /* 164-byte string literal not displayed */
}

QueryGetProtoRevMaxPoolPointsPerBlockResponse is response type for the Query/GetProtoRevMaxPoolPointsPerBlock RPC method.

func (*QueryGetProtoRevMaxPoolPointsPerBlockResponse) Descriptor 

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

func (*QueryGetProtoRevMaxPoolPointsPerBlockResponse) GetMaxPoolPointsPerBlock 

func (m *QueryGetProtoRevMaxPoolPointsPerBlockResponse) GetMaxPoolPointsPerBlock() uint64

func (*QueryGetProtoRevMaxPoolPointsPerBlockResponse) Marshal 

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

func (*QueryGetProtoRevMaxPoolPointsPerBlockResponse) MarshalTo 

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

func (*QueryGetProtoRevMaxPoolPointsPerBlockResponse) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevMaxPoolPointsPerBlockResponse) ProtoMessage 

func (*QueryGetProtoRevMaxPoolPointsPerBlockResponse) ProtoMessage()

func (*QueryGetProtoRevMaxPoolPointsPerBlockResponse) Reset 

func (m *QueryGetProtoRevMaxPoolPointsPerBlockResponse) Reset()

func (*QueryGetProtoRevMaxPoolPointsPerBlockResponse) Size 

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

func (*QueryGetProtoRevMaxPoolPointsPerBlockResponse) String 

func (m *QueryGetProtoRevMaxPoolPointsPerBlockResponse) String() string

func (*QueryGetProtoRevMaxPoolPointsPerBlockResponse) Unmarshal 

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

func (*QueryGetProtoRevMaxPoolPointsPerBlockResponse) XXX_DiscardUnknown 

func (m *QueryGetProtoRevMaxPoolPointsPerBlockResponse) XXX_DiscardUnknown()

func (*QueryGetProtoRevMaxPoolPointsPerBlockResponse) XXX_Marshal 

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

func (*QueryGetProtoRevMaxPoolPointsPerBlockResponse) XXX_Merge 

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

func (*QueryGetProtoRevMaxPoolPointsPerBlockResponse) XXX_Size 

func (m *QueryGetProtoRevMaxPoolPointsPerBlockResponse) XXX_Size() int

func (*QueryGetProtoRevMaxPoolPointsPerBlockResponse) XXX_Unmarshal 

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

type QueryGetProtoRevMaxPoolPointsPerTxRequest 

type QueryGetProtoRevMaxPoolPointsPerTxRequest struct {
}

QueryGetProtoRevMaxPoolPointsPerTxRequest is request type for the Query/GetProtoRevMaxPoolPointsPerTx RPC method.

func (*QueryGetProtoRevMaxPoolPointsPerTxRequest) Descriptor 

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

func (*QueryGetProtoRevMaxPoolPointsPerTxRequest) Marshal 

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

func (*QueryGetProtoRevMaxPoolPointsPerTxRequest) MarshalTo 

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

func (*QueryGetProtoRevMaxPoolPointsPerTxRequest) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevMaxPoolPointsPerTxRequest) ProtoMessage 

func (*QueryGetProtoRevMaxPoolPointsPerTxRequest) ProtoMessage()

func (*QueryGetProtoRevMaxPoolPointsPerTxRequest) Reset 

func (m *QueryGetProtoRevMaxPoolPointsPerTxRequest) Reset()

func (*QueryGetProtoRevMaxPoolPointsPerTxRequest) Size 

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

func (*QueryGetProtoRevMaxPoolPointsPerTxRequest) String 

func (m *QueryGetProtoRevMaxPoolPointsPerTxRequest) String() string

func (*QueryGetProtoRevMaxPoolPointsPerTxRequest) Unmarshal 

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

func (*QueryGetProtoRevMaxPoolPointsPerTxRequest) XXX_DiscardUnknown 

func (m *QueryGetProtoRevMaxPoolPointsPerTxRequest) XXX_DiscardUnknown()

func (*QueryGetProtoRevMaxPoolPointsPerTxRequest) XXX_Marshal 

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

func (*QueryGetProtoRevMaxPoolPointsPerTxRequest) XXX_Merge 

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

func (*QueryGetProtoRevMaxPoolPointsPerTxRequest) XXX_Size 

func (m *QueryGetProtoRevMaxPoolPointsPerTxRequest) XXX_Size() int

func (*QueryGetProtoRevMaxPoolPointsPerTxRequest) XXX_Unmarshal 

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

type QueryGetProtoRevMaxPoolPointsPerTxResponse 

type QueryGetProtoRevMaxPoolPointsPerTxResponse struct {
	// max_pool_points_per_tx is the maximum number of pool points that can be
	// consumed per transaction
	MaxPoolPointsPerTx uint64 `` /* 152-byte string literal not displayed */
}

QueryGetProtoRevMaxPoolPointsPerTxResponse is response type for the Query/GetProtoRevMaxPoolPointsPerTx RPC method.

func (*QueryGetProtoRevMaxPoolPointsPerTxResponse) Descriptor 

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

func (*QueryGetProtoRevMaxPoolPointsPerTxResponse) GetMaxPoolPointsPerTx 

func (m *QueryGetProtoRevMaxPoolPointsPerTxResponse) GetMaxPoolPointsPerTx() uint64

func (*QueryGetProtoRevMaxPoolPointsPerTxResponse) Marshal 

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

func (*QueryGetProtoRevMaxPoolPointsPerTxResponse) MarshalTo 

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

func (*QueryGetProtoRevMaxPoolPointsPerTxResponse) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevMaxPoolPointsPerTxResponse) ProtoMessage 

func (*QueryGetProtoRevMaxPoolPointsPerTxResponse) ProtoMessage()

func (*QueryGetProtoRevMaxPoolPointsPerTxResponse) Reset 

func (m *QueryGetProtoRevMaxPoolPointsPerTxResponse) Reset()

func (*QueryGetProtoRevMaxPoolPointsPerTxResponse) Size 

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

func (*QueryGetProtoRevMaxPoolPointsPerTxResponse) String 

func (m *QueryGetProtoRevMaxPoolPointsPerTxResponse) String() string

func (*QueryGetProtoRevMaxPoolPointsPerTxResponse) Unmarshal 

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

func (*QueryGetProtoRevMaxPoolPointsPerTxResponse) XXX_DiscardUnknown 

func (m *QueryGetProtoRevMaxPoolPointsPerTxResponse) XXX_DiscardUnknown()

func (*QueryGetProtoRevMaxPoolPointsPerTxResponse) XXX_Marshal 

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

func (*QueryGetProtoRevMaxPoolPointsPerTxResponse) XXX_Merge 

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

func (*QueryGetProtoRevMaxPoolPointsPerTxResponse) XXX_Size 

func (m *QueryGetProtoRevMaxPoolPointsPerTxResponse) XXX_Size() int

func (*QueryGetProtoRevMaxPoolPointsPerTxResponse) XXX_Unmarshal 

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

type QueryGetProtoRevNumberOfTradesRequest 

type QueryGetProtoRevNumberOfTradesRequest struct {
}

QueryGetProtoRevNumberOfTradesRequest is request type for the Query/GetProtoRevNumberOfTrades RPC method.

func (*QueryGetProtoRevNumberOfTradesRequest) Descriptor 

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

func (*QueryGetProtoRevNumberOfTradesRequest) Marshal 

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

func (*QueryGetProtoRevNumberOfTradesRequest) MarshalTo 

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

func (*QueryGetProtoRevNumberOfTradesRequest) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevNumberOfTradesRequest) ProtoMessage 

func (*QueryGetProtoRevNumberOfTradesRequest) ProtoMessage()

func (*QueryGetProtoRevNumberOfTradesRequest) Reset 

func (m *QueryGetProtoRevNumberOfTradesRequest) Reset()

func (*QueryGetProtoRevNumberOfTradesRequest) Size 

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

func (*QueryGetProtoRevNumberOfTradesRequest) String 

func (m *QueryGetProtoRevNumberOfTradesRequest) String() string

func (*QueryGetProtoRevNumberOfTradesRequest) Unmarshal 

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

func (*QueryGetProtoRevNumberOfTradesRequest) XXX_DiscardUnknown 

func (m *QueryGetProtoRevNumberOfTradesRequest) XXX_DiscardUnknown()

func (*QueryGetProtoRevNumberOfTradesRequest) XXX_Marshal 

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

func (*QueryGetProtoRevNumberOfTradesRequest) XXX_Merge 

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

func (*QueryGetProtoRevNumberOfTradesRequest) XXX_Size 

func (m *QueryGetProtoRevNumberOfTradesRequest) XXX_Size() int

func (*QueryGetProtoRevNumberOfTradesRequest) XXX_Unmarshal 

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

type QueryGetProtoRevNumberOfTradesResponse 

type QueryGetProtoRevNumberOfTradesResponse struct {
	// number_of_trades is the number of trades the module has executed
	NumberOfTrades cosmossdk_io_math.Int `` /* 152-byte string literal not displayed */
}

QueryGetProtoRevNumberOfTradesResponse is response type for the Query/GetProtoRevNumberOfTrades RPC method.

func (*QueryGetProtoRevNumberOfTradesResponse) Descriptor 

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

func (*QueryGetProtoRevNumberOfTradesResponse) Marshal 

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

func (*QueryGetProtoRevNumberOfTradesResponse) MarshalTo 

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

func (*QueryGetProtoRevNumberOfTradesResponse) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevNumberOfTradesResponse) ProtoMessage 

func (*QueryGetProtoRevNumberOfTradesResponse) ProtoMessage()

func (*QueryGetProtoRevNumberOfTradesResponse) Reset 

func (m *QueryGetProtoRevNumberOfTradesResponse) Reset()

func (*QueryGetProtoRevNumberOfTradesResponse) Size 

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

func (*QueryGetProtoRevNumberOfTradesResponse) String 

func (m *QueryGetProtoRevNumberOfTradesResponse) String() string

func (*QueryGetProtoRevNumberOfTradesResponse) Unmarshal 

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

func (*QueryGetProtoRevNumberOfTradesResponse) XXX_DiscardUnknown 

func (m *QueryGetProtoRevNumberOfTradesResponse) XXX_DiscardUnknown()

func (*QueryGetProtoRevNumberOfTradesResponse) XXX_Marshal 

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

func (*QueryGetProtoRevNumberOfTradesResponse) XXX_Merge 

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

func (*QueryGetProtoRevNumberOfTradesResponse) XXX_Size 

func (m *QueryGetProtoRevNumberOfTradesResponse) XXX_Size() int

func (*QueryGetProtoRevNumberOfTradesResponse) XXX_Unmarshal 

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

type QueryGetProtoRevPoolRequest 

type QueryGetProtoRevPoolRequest struct {
	// base_denom is the base denom set in protorev for the denom pair to pool
	// mapping
	BaseDenom string `protobuf:"bytes,1,opt,name=base_denom,json=baseDenom,proto3" json:"base_denom,omitempty" yaml:"base_denom"`
	// other_denom is the other denom for the denom pair to pool mapping
	OtherDenom string `protobuf:"bytes,2,opt,name=other_denom,json=otherDenom,proto3" json:"other_denom,omitempty" yaml:"other_denom"`
}

QueryGetProtoRevPoolRequest is request type for the Query/GetProtoRevPool RPC method.

func (*QueryGetProtoRevPoolRequest) Descriptor 

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

func (*QueryGetProtoRevPoolRequest) GetBaseDenom 

func (m *QueryGetProtoRevPoolRequest) GetBaseDenom() string

func (*QueryGetProtoRevPoolRequest) GetOtherDenom 

func (m *QueryGetProtoRevPoolRequest) GetOtherDenom() string

func (*QueryGetProtoRevPoolRequest) Marshal 

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

func (*QueryGetProtoRevPoolRequest) MarshalTo 

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

func (*QueryGetProtoRevPoolRequest) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevPoolRequest) ProtoMessage 

func (*QueryGetProtoRevPoolRequest) ProtoMessage()

func (*QueryGetProtoRevPoolRequest) Reset 

func (m *QueryGetProtoRevPoolRequest) Reset()

func (*QueryGetProtoRevPoolRequest) Size 

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

func (*QueryGetProtoRevPoolRequest) String 

func (m *QueryGetProtoRevPoolRequest) String() string

func (*QueryGetProtoRevPoolRequest) Unmarshal 

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

func (*QueryGetProtoRevPoolRequest) XXX_DiscardUnknown 

func (m *QueryGetProtoRevPoolRequest) XXX_DiscardUnknown()

func (*QueryGetProtoRevPoolRequest) XXX_Marshal 

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

func (*QueryGetProtoRevPoolRequest) XXX_Merge 

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

func (*QueryGetProtoRevPoolRequest) XXX_Size 

func (m *QueryGetProtoRevPoolRequest) XXX_Size() int

func (*QueryGetProtoRevPoolRequest) XXX_Unmarshal 

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

type QueryGetProtoRevPoolResponse 

type QueryGetProtoRevPoolResponse struct {
	// pool_id is the pool_id stored for the denom pair
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty" yaml:"pool_id"`
}

QueryGetProtoRevPoolResponse is response type for the Query/GetProtoRevPool RPC method.

func (*QueryGetProtoRevPoolResponse) Descriptor 

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

func (*QueryGetProtoRevPoolResponse) GetPoolId 

func (m *QueryGetProtoRevPoolResponse) GetPoolId() uint64

func (*QueryGetProtoRevPoolResponse) Marshal 

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

func (*QueryGetProtoRevPoolResponse) MarshalTo 

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

func (*QueryGetProtoRevPoolResponse) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevPoolResponse) ProtoMessage 

func (*QueryGetProtoRevPoolResponse) ProtoMessage()

func (*QueryGetProtoRevPoolResponse) Reset 

func (m *QueryGetProtoRevPoolResponse) Reset()

func (*QueryGetProtoRevPoolResponse) Size 

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

func (*QueryGetProtoRevPoolResponse) String 

func (m *QueryGetProtoRevPoolResponse) String() string

func (*QueryGetProtoRevPoolResponse) Unmarshal 

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

func (*QueryGetProtoRevPoolResponse) XXX_DiscardUnknown 

func (m *QueryGetProtoRevPoolResponse) XXX_DiscardUnknown()

func (*QueryGetProtoRevPoolResponse) XXX_Marshal 

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

func (*QueryGetProtoRevPoolResponse) XXX_Merge 

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

func (*QueryGetProtoRevPoolResponse) XXX_Size 

func (m *QueryGetProtoRevPoolResponse) XXX_Size() int

func (*QueryGetProtoRevPoolResponse) XXX_Unmarshal 

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

type QueryGetProtoRevProfitsByDenomRequest 

type QueryGetProtoRevProfitsByDenomRequest struct {
	// denom is the denom to query profits by
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty" yaml:"denom"`
}

QueryGetProtoRevProfitsByDenomRequest is request type for the Query/GetProtoRevProfitsByDenom RPC method.

func (*QueryGetProtoRevProfitsByDenomRequest) Descriptor 

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

func (*QueryGetProtoRevProfitsByDenomRequest) GetDenom 

func (m *QueryGetProtoRevProfitsByDenomRequest) GetDenom() string

func (*QueryGetProtoRevProfitsByDenomRequest) Marshal 

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

func (*QueryGetProtoRevProfitsByDenomRequest) MarshalTo 

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

func (*QueryGetProtoRevProfitsByDenomRequest) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevProfitsByDenomRequest) ProtoMessage 

func (*QueryGetProtoRevProfitsByDenomRequest) ProtoMessage()

func (*QueryGetProtoRevProfitsByDenomRequest) Reset 

func (m *QueryGetProtoRevProfitsByDenomRequest) Reset()

func (*QueryGetProtoRevProfitsByDenomRequest) Size 

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

func (*QueryGetProtoRevProfitsByDenomRequest) String 

func (m *QueryGetProtoRevProfitsByDenomRequest) String() string

func (*QueryGetProtoRevProfitsByDenomRequest) Unmarshal 

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

func (*QueryGetProtoRevProfitsByDenomRequest) XXX_DiscardUnknown 

func (m *QueryGetProtoRevProfitsByDenomRequest) XXX_DiscardUnknown()

func (*QueryGetProtoRevProfitsByDenomRequest) XXX_Marshal 

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

func (*QueryGetProtoRevProfitsByDenomRequest) XXX_Merge 

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

func (*QueryGetProtoRevProfitsByDenomRequest) XXX_Size 

func (m *QueryGetProtoRevProfitsByDenomRequest) XXX_Size() int

func (*QueryGetProtoRevProfitsByDenomRequest) XXX_Unmarshal 

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

type QueryGetProtoRevProfitsByDenomResponse 

type QueryGetProtoRevProfitsByDenomResponse struct {
	// profit is the profits of the module by the selected denom
	Profit *types.Coin `protobuf:"bytes,1,opt,name=profit,proto3" json:"profit,omitempty" yaml:"profit"`
}

QueryGetProtoRevProfitsByDenomResponse is response type for the Query/GetProtoRevProfitsByDenom RPC method.

func (*QueryGetProtoRevProfitsByDenomResponse) Descriptor 

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

func (*QueryGetProtoRevProfitsByDenomResponse) GetProfit 

func (m *QueryGetProtoRevProfitsByDenomResponse) GetProfit() *types.Coin

func (*QueryGetProtoRevProfitsByDenomResponse) Marshal 

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

func (*QueryGetProtoRevProfitsByDenomResponse) MarshalTo 

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

func (*QueryGetProtoRevProfitsByDenomResponse) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevProfitsByDenomResponse) ProtoMessage 

func (*QueryGetProtoRevProfitsByDenomResponse) ProtoMessage()

func (*QueryGetProtoRevProfitsByDenomResponse) Reset 

func (m *QueryGetProtoRevProfitsByDenomResponse) Reset()

func (*QueryGetProtoRevProfitsByDenomResponse) Size 

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

func (*QueryGetProtoRevProfitsByDenomResponse) String 

func (m *QueryGetProtoRevProfitsByDenomResponse) String() string

func (*QueryGetProtoRevProfitsByDenomResponse) Unmarshal 

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

func (*QueryGetProtoRevProfitsByDenomResponse) XXX_DiscardUnknown 

func (m *QueryGetProtoRevProfitsByDenomResponse) XXX_DiscardUnknown()

func (*QueryGetProtoRevProfitsByDenomResponse) XXX_Marshal 

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

func (*QueryGetProtoRevProfitsByDenomResponse) XXX_Merge 

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

func (*QueryGetProtoRevProfitsByDenomResponse) XXX_Size 

func (m *QueryGetProtoRevProfitsByDenomResponse) XXX_Size() int

func (*QueryGetProtoRevProfitsByDenomResponse) XXX_Unmarshal 

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

type QueryGetProtoRevStatisticsByRouteRequest 

type QueryGetProtoRevStatisticsByRouteRequest struct {
	// route is the set of pool ids to query statistics by i.e. 1,2,3
	Route []uint64 `protobuf:"varint,1,rep,packed,name=route,proto3" json:"route,omitempty" yaml:"route"`
}

QueryGetProtoRevStatisticsByPoolRequest is request type for the Query/GetProtoRevStatisticsByRoute RPC method.

func (*QueryGetProtoRevStatisticsByRouteRequest) Descriptor 

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

func (*QueryGetProtoRevStatisticsByRouteRequest) GetRoute 

func (m *QueryGetProtoRevStatisticsByRouteRequest) GetRoute() []uint64

func (*QueryGetProtoRevStatisticsByRouteRequest) Marshal 

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

func (*QueryGetProtoRevStatisticsByRouteRequest) MarshalTo 

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

func (*QueryGetProtoRevStatisticsByRouteRequest) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevStatisticsByRouteRequest) ProtoMessage 

func (*QueryGetProtoRevStatisticsByRouteRequest) ProtoMessage()

func (*QueryGetProtoRevStatisticsByRouteRequest) Reset 

func (m *QueryGetProtoRevStatisticsByRouteRequest) Reset()

func (*QueryGetProtoRevStatisticsByRouteRequest) Size 

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

func (*QueryGetProtoRevStatisticsByRouteRequest) String 

func (m *QueryGetProtoRevStatisticsByRouteRequest) String() string

func (*QueryGetProtoRevStatisticsByRouteRequest) Unmarshal 

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

func (*QueryGetProtoRevStatisticsByRouteRequest) XXX_DiscardUnknown 

func (m *QueryGetProtoRevStatisticsByRouteRequest) XXX_DiscardUnknown()

func (*QueryGetProtoRevStatisticsByRouteRequest) XXX_Marshal 

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

func (*QueryGetProtoRevStatisticsByRouteRequest) XXX_Merge 

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

func (*QueryGetProtoRevStatisticsByRouteRequest) XXX_Size 

func (m *QueryGetProtoRevStatisticsByRouteRequest) XXX_Size() int

func (*QueryGetProtoRevStatisticsByRouteRequest) XXX_Unmarshal 

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

type QueryGetProtoRevStatisticsByRouteResponse 

type QueryGetProtoRevStatisticsByRouteResponse struct {
	// statistics contains the number of trades the module has executed after a
	// swap on a given pool and the profits from the trades
	Statistics RouteStatistics `protobuf:"bytes,1,opt,name=statistics,proto3" json:"statistics" yaml:"statistics"`
}

QueryGetProtoRevStatisticsByRouteResponse is response type for the Query/GetProtoRevStatisticsByRoute RPC method.

func (*QueryGetProtoRevStatisticsByRouteResponse) Descriptor 

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

func (*QueryGetProtoRevStatisticsByRouteResponse) GetStatistics 

func (m *QueryGetProtoRevStatisticsByRouteResponse) GetStatistics() RouteStatistics

func (*QueryGetProtoRevStatisticsByRouteResponse) Marshal 

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

func (*QueryGetProtoRevStatisticsByRouteResponse) MarshalTo 

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

func (*QueryGetProtoRevStatisticsByRouteResponse) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevStatisticsByRouteResponse) ProtoMessage 

func (*QueryGetProtoRevStatisticsByRouteResponse) ProtoMessage()

func (*QueryGetProtoRevStatisticsByRouteResponse) Reset 

func (m *QueryGetProtoRevStatisticsByRouteResponse) Reset()

func (*QueryGetProtoRevStatisticsByRouteResponse) Size 

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

func (*QueryGetProtoRevStatisticsByRouteResponse) String 

func (m *QueryGetProtoRevStatisticsByRouteResponse) String() string

func (*QueryGetProtoRevStatisticsByRouteResponse) Unmarshal 

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

func (*QueryGetProtoRevStatisticsByRouteResponse) XXX_DiscardUnknown 

func (m *QueryGetProtoRevStatisticsByRouteResponse) XXX_DiscardUnknown()

func (*QueryGetProtoRevStatisticsByRouteResponse) XXX_Marshal 

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

func (*QueryGetProtoRevStatisticsByRouteResponse) XXX_Merge 

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

func (*QueryGetProtoRevStatisticsByRouteResponse) XXX_Size 

func (m *QueryGetProtoRevStatisticsByRouteResponse) XXX_Size() int

func (*QueryGetProtoRevStatisticsByRouteResponse) XXX_Unmarshal 

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

type QueryGetProtoRevTokenPairArbRoutesRequest 

type QueryGetProtoRevTokenPairArbRoutesRequest struct {
}

QueryGetProtoRevTokenPairArbRoutesRequest is request type for the Query/GetProtoRevTokenPairArbRoutes RPC method.

func (*QueryGetProtoRevTokenPairArbRoutesRequest) Descriptor 

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

func (*QueryGetProtoRevTokenPairArbRoutesRequest) Marshal 

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

func (*QueryGetProtoRevTokenPairArbRoutesRequest) MarshalTo 

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

func (*QueryGetProtoRevTokenPairArbRoutesRequest) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevTokenPairArbRoutesRequest) ProtoMessage 

func (*QueryGetProtoRevTokenPairArbRoutesRequest) ProtoMessage()

func (*QueryGetProtoRevTokenPairArbRoutesRequest) Reset 

func (m *QueryGetProtoRevTokenPairArbRoutesRequest) Reset()

func (*QueryGetProtoRevTokenPairArbRoutesRequest) Size 

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

func (*QueryGetProtoRevTokenPairArbRoutesRequest) String 

func (m *QueryGetProtoRevTokenPairArbRoutesRequest) String() string

func (*QueryGetProtoRevTokenPairArbRoutesRequest) Unmarshal 

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

func (*QueryGetProtoRevTokenPairArbRoutesRequest) XXX_DiscardUnknown 

func (m *QueryGetProtoRevTokenPairArbRoutesRequest) XXX_DiscardUnknown()

func (*QueryGetProtoRevTokenPairArbRoutesRequest) XXX_Marshal 

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

func (*QueryGetProtoRevTokenPairArbRoutesRequest) XXX_Merge 

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

func (*QueryGetProtoRevTokenPairArbRoutesRequest) XXX_Size 

func (m *QueryGetProtoRevTokenPairArbRoutesRequest) XXX_Size() int

func (*QueryGetProtoRevTokenPairArbRoutesRequest) XXX_Unmarshal 

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

type QueryGetProtoRevTokenPairArbRoutesResponse 

type QueryGetProtoRevTokenPairArbRoutesResponse struct {
	// routes is a list of all of the hot routes that the module is currently
	// arbitraging
	Routes []TokenPairArbRoutes `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes" yaml:"routes"`
}

QueryGetProtoRevTokenPairArbRoutesResponse is response type for the Query/GetProtoRevTokenPairArbRoutes RPC method.

func (*QueryGetProtoRevTokenPairArbRoutesResponse) Descriptor 

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

func (*QueryGetProtoRevTokenPairArbRoutesResponse) GetRoutes 

func (m *QueryGetProtoRevTokenPairArbRoutesResponse) GetRoutes() []TokenPairArbRoutes

func (*QueryGetProtoRevTokenPairArbRoutesResponse) Marshal 

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

func (*QueryGetProtoRevTokenPairArbRoutesResponse) MarshalTo 

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

func (*QueryGetProtoRevTokenPairArbRoutesResponse) MarshalToSizedBuffer 

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

func (*QueryGetProtoRevTokenPairArbRoutesResponse) ProtoMessage 

func (*QueryGetProtoRevTokenPairArbRoutesResponse) ProtoMessage()

func (*QueryGetProtoRevTokenPairArbRoutesResponse) Reset 

func (m *QueryGetProtoRevTokenPairArbRoutesResponse) Reset()

func (*QueryGetProtoRevTokenPairArbRoutesResponse) Size 

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

func (*QueryGetProtoRevTokenPairArbRoutesResponse) String 

func (m *QueryGetProtoRevTokenPairArbRoutesResponse) String() string

func (*QueryGetProtoRevTokenPairArbRoutesResponse) Unmarshal 

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

func (*QueryGetProtoRevTokenPairArbRoutesResponse) XXX_DiscardUnknown 

func (m *QueryGetProtoRevTokenPairArbRoutesResponse) XXX_DiscardUnknown()

func (*QueryGetProtoRevTokenPairArbRoutesResponse) XXX_Marshal 

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

func (*QueryGetProtoRevTokenPairArbRoutesResponse) XXX_Merge 

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

func (*QueryGetProtoRevTokenPairArbRoutesResponse) XXX_Size 

func (m *QueryGetProtoRevTokenPairArbRoutesResponse) XXX_Size() int

func (*QueryGetProtoRevTokenPairArbRoutesResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

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

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

type QueryParamsResponse struct {
	// params holds all the parameters of this module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params" yaml:"params"`
}

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

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Params queries the parameters of the module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// GetProtoRevNumberOfTrades queries the number of arbitrage trades the module
	// has executed
	GetProtoRevNumberOfTrades(context.Context, *QueryGetProtoRevNumberOfTradesRequest) (*QueryGetProtoRevNumberOfTradesResponse, error)
	// GetProtoRevProfitsByDenom queries the profits of the module by denom
	GetProtoRevProfitsByDenom(context.Context, *QueryGetProtoRevProfitsByDenomRequest) (*QueryGetProtoRevProfitsByDenomResponse, error)
	// GetProtoRevAllProfits queries all of the profits from the module
	GetProtoRevAllProfits(context.Context, *QueryGetProtoRevAllProfitsRequest) (*QueryGetProtoRevAllProfitsResponse, error)
	// GetProtoRevStatisticsByRoute queries the number of arbitrages and profits
	// that have been executed for a given route
	GetProtoRevStatisticsByRoute(context.Context, *QueryGetProtoRevStatisticsByRouteRequest) (*QueryGetProtoRevStatisticsByRouteResponse, error)
	// GetProtoRevAllRouteStatistics queries all of routes that the module has
	// arbitraged against and the number of trades and profits that have been
	// accumulated for each route
	GetProtoRevAllRouteStatistics(context.Context, *QueryGetProtoRevAllRouteStatisticsRequest) (*QueryGetProtoRevAllRouteStatisticsResponse, error)
	// GetProtoRevTokenPairArbRoutes queries all of the hot routes that the module
	// is currently arbitraging
	GetProtoRevTokenPairArbRoutes(context.Context, *QueryGetProtoRevTokenPairArbRoutesRequest) (*QueryGetProtoRevTokenPairArbRoutesResponse, error)
	// GetProtoRevAdminAccount queries the admin account of the module
	GetProtoRevAdminAccount(context.Context, *QueryGetProtoRevAdminAccountRequest) (*QueryGetProtoRevAdminAccountResponse, error)
	// GetProtoRevDeveloperAccount queries the developer account of the module
	GetProtoRevDeveloperAccount(context.Context, *QueryGetProtoRevDeveloperAccountRequest) (*QueryGetProtoRevDeveloperAccountResponse, error)
	// GetProtoRevInfoByPoolType queries pool type information that is currently
	// being utilized by the module
	GetProtoRevInfoByPoolType(context.Context, *QueryGetProtoRevInfoByPoolTypeRequest) (*QueryGetProtoRevInfoByPoolTypeResponse, error)
	// GetProtoRevMaxPoolPointsPerTx queries the maximum number of pool points
	// that can be consumed per transaction
	GetProtoRevMaxPoolPointsPerTx(context.Context, *QueryGetProtoRevMaxPoolPointsPerTxRequest) (*QueryGetProtoRevMaxPoolPointsPerTxResponse, error)
	// GetProtoRevMaxPoolPointsPerBlock queries the maximum number of pool points
	// that can consumed per block
	GetProtoRevMaxPoolPointsPerBlock(context.Context, *QueryGetProtoRevMaxPoolPointsPerBlockRequest) (*QueryGetProtoRevMaxPoolPointsPerBlockResponse, error)
	// GetProtoRevBaseDenoms queries the base denoms that the module is currently
	// utilizing for arbitrage
	GetProtoRevBaseDenoms(context.Context, *QueryGetProtoRevBaseDenomsRequest) (*QueryGetProtoRevBaseDenomsResponse, error)
	// GetProtoRevEnabled queries whether the module is enabled or not
	GetProtoRevEnabled(context.Context, *QueryGetProtoRevEnabledRequest) (*QueryGetProtoRevEnabledResponse, error)
	// GetProtoRevPool queries the pool id used via the highest liquidity method
	// for arbitrage route building given a pair of denominations
	GetProtoRevPool(context.Context, *QueryGetProtoRevPoolRequest) (*QueryGetProtoRevPoolResponse, error)
	// GetAllProtocolRevenue queries all of the protocol revenue that has been
	// accumulated by any module
	GetAllProtocolRevenue(context.Context, *QueryGetAllProtocolRevenueRequest) (*QueryGetAllProtocolRevenueResponse, error)
}

QueryServer is the server API for Query service.

type Route 

type Route struct {
	// The pool IDs that are traversed in the directed cyclic graph (traversed
	// left
	// -> right)
	Trades []Trade `protobuf:"bytes,1,rep,name=trades,proto3" json:"trades" yaml:"trades"`
	// The step size that will be used to find the optimal swap amount in the
	// binary search
	StepSize cosmossdk_io_math.Int `protobuf:"bytes,2,opt,name=step_size,json=stepSize,proto3,customtype=cosmossdk.io/math.Int" json:"step_size" yaml:"step_size"`
}

Route is a hot route for a given pair of tokens

func NewRoutes 

func NewRoutes(trades []Trade) Route

func (*Route) Descriptor 

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

func (*Route) Equal 

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

func (*Route) GetTrades 

func (m *Route) GetTrades() []Trade

func (*Route) Marshal 

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

func (*Route) MarshalTo 

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

func (*Route) MarshalToSizedBuffer 

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

func (*Route) ProtoMessage 

func (*Route) ProtoMessage()

func (*Route) Reset 

func (m *Route) Reset()

func (*Route) Size 

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

func (*Route) String 

func (m *Route) String() string

func (*Route) Unmarshal 

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

func (*Route) XXX_DiscardUnknown 

func (m *Route) XXX_DiscardUnknown()

func (*Route) XXX_Marshal 

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

func (*Route) XXX_Merge 

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

func (*Route) XXX_Size 

func (m *Route) XXX_Size() int

func (*Route) XXX_Unmarshal 

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

type RouteStatistics 

type RouteStatistics struct {
	// profits is the total profit from all trades on this route
	Profits []types.Coin `protobuf:"bytes,1,rep,name=profits,proto3" json:"profits" yaml:"profits"`
	// number_of_trades is the number of trades the module has executed using this
	// route
	NumberOfTrades cosmossdk_io_math.Int `` /* 152-byte string literal not displayed */
	// route is the route that was used (pool ids along the arbitrage route)
	Route []uint64 `protobuf:"varint,3,rep,packed,name=route,proto3" json:"route,omitempty" yaml:"route"`
}

RouteStatistics contains the number of trades the module has executed after a swap on a given route and the profits from the trades

func (*RouteStatistics) Descriptor 

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

func (*RouteStatistics) GetProfits 

func (m *RouteStatistics) GetProfits() []types.Coin

func (*RouteStatistics) GetRoute 

func (m *RouteStatistics) GetRoute() []uint64

func (*RouteStatistics) Marshal 

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

func (*RouteStatistics) MarshalTo 

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

func (*RouteStatistics) MarshalToSizedBuffer 

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

func (*RouteStatistics) ProtoMessage 

func (*RouteStatistics) ProtoMessage()

func (*RouteStatistics) Reset 

func (m *RouteStatistics) Reset()

func (*RouteStatistics) Size 

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

func (*RouteStatistics) String 

func (m *RouteStatistics) String() string

func (*RouteStatistics) Unmarshal 

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

func (*RouteStatistics) XXX_DiscardUnknown 

func (m *RouteStatistics) XXX_DiscardUnknown()

func (*RouteStatistics) XXX_Marshal 

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

func (*RouteStatistics) XXX_Merge 

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

func (*RouteStatistics) XXX_Size 

func (m *RouteStatistics) XXX_Size() int

func (*RouteStatistics) XXX_Unmarshal 

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

type SetProtoRevAdminAccountProposal 

type SetProtoRevAdminAccountProposal 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"`
	Account     string `protobuf:"bytes,3,opt,name=account,proto3" json:"account,omitempty"`
}

SetProtoRevAdminAccountProposal is a gov Content type to set the admin account that will receive permissions to alter hot routes and set the developer address that will be receiving a share of profits from the module

func (*SetProtoRevAdminAccountProposal) Descriptor 

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

func (*SetProtoRevAdminAccountProposal) Equal 

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

func (*SetProtoRevAdminAccountProposal) GetDescription 

func (p *SetProtoRevAdminAccountProposal) GetDescription() string

func (*SetProtoRevAdminAccountProposal) GetTitle 

func (p *SetProtoRevAdminAccountProposal) GetTitle() string

func (*SetProtoRevAdminAccountProposal) Marshal 

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

func (*SetProtoRevAdminAccountProposal) MarshalTo 

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

func (*SetProtoRevAdminAccountProposal) MarshalToSizedBuffer 

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

func (*SetProtoRevAdminAccountProposal) ProposalRoute 

func (p *SetProtoRevAdminAccountProposal) ProposalRoute() string

func (*SetProtoRevAdminAccountProposal) ProposalType 

func (p *SetProtoRevAdminAccountProposal) ProposalType() string

func (*SetProtoRevAdminAccountProposal) ProtoMessage 

func (*SetProtoRevAdminAccountProposal) ProtoMessage()

func (*SetProtoRevAdminAccountProposal) Reset 

func (m *SetProtoRevAdminAccountProposal) Reset()

func (*SetProtoRevAdminAccountProposal) Size 

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

func (SetProtoRevAdminAccountProposal) String 

func (p SetProtoRevAdminAccountProposal) String() string

func (*SetProtoRevAdminAccountProposal) Unmarshal 

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

func (*SetProtoRevAdminAccountProposal) ValidateBasic 

func (p *SetProtoRevAdminAccountProposal) ValidateBasic() error

func (*SetProtoRevAdminAccountProposal) XXX_DiscardUnknown 

func (m *SetProtoRevAdminAccountProposal) XXX_DiscardUnknown()

func (*SetProtoRevAdminAccountProposal) XXX_Marshal 

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

func (*SetProtoRevAdminAccountProposal) XXX_Merge 

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

func (*SetProtoRevAdminAccountProposal) XXX_Size 

func (m *SetProtoRevAdminAccountProposal) XXX_Size() int

func (*SetProtoRevAdminAccountProposal) XXX_Unmarshal 

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

type SetProtoRevEnabledProposal 

type SetProtoRevEnabledProposal 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"`
	Enabled     bool   `protobuf:"varint,3,opt,name=enabled,proto3" json:"enabled,omitempty"`
}

SetProtoRevEnabledProposal is a gov Content type to update whether the protorev module is enabled

func (*SetProtoRevEnabledProposal) Descriptor 

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

func (*SetProtoRevEnabledProposal) Equal 

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

func (*SetProtoRevEnabledProposal) GetDescription 

func (p *SetProtoRevEnabledProposal) GetDescription() string

func (*SetProtoRevEnabledProposal) GetTitle 

func (p *SetProtoRevEnabledProposal) GetTitle() string

func (*SetProtoRevEnabledProposal) Marshal 

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

func (*SetProtoRevEnabledProposal) MarshalTo 

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

func (*SetProtoRevEnabledProposal) MarshalToSizedBuffer 

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

func (*SetProtoRevEnabledProposal) ProposalRoute 

func (p *SetProtoRevEnabledProposal) ProposalRoute() string

func (*SetProtoRevEnabledProposal) ProposalType 

func (p *SetProtoRevEnabledProposal) ProposalType() string

func (*SetProtoRevEnabledProposal) ProtoMessage 

func (*SetProtoRevEnabledProposal) ProtoMessage()

func (*SetProtoRevEnabledProposal) Reset 

func (m *SetProtoRevEnabledProposal) Reset()

func (*SetProtoRevEnabledProposal) Size 

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

func (SetProtoRevEnabledProposal) String 

func (p SetProtoRevEnabledProposal) String() string

func (*SetProtoRevEnabledProposal) Unmarshal 

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

func (*SetProtoRevEnabledProposal) ValidateBasic 

func (p *SetProtoRevEnabledProposal) ValidateBasic() error

func (*SetProtoRevEnabledProposal) XXX_DiscardUnknown 

func (m *SetProtoRevEnabledProposal) XXX_DiscardUnknown()

func (*SetProtoRevEnabledProposal) XXX_Marshal 

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

func (*SetProtoRevEnabledProposal) XXX_Merge 

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

func (*SetProtoRevEnabledProposal) XXX_Size 

func (m *SetProtoRevEnabledProposal) XXX_Size() int

func (*SetProtoRevEnabledProposal) XXX_Unmarshal 

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

type StablePoolInfo 

type StablePoolInfo struct {
	// The weight of a stableswap pool
	Weight uint64 `protobuf:"varint,1,opt,name=weight,proto3" json:"weight,omitempty" yaml:"weight"`
}

StablePoolInfo contains meta data pertaining to a stableswap pool type.

func (*StablePoolInfo) Descriptor 

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

func (*StablePoolInfo) GetWeight 

func (m *StablePoolInfo) GetWeight() uint64

func (*StablePoolInfo) Marshal 

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

func (*StablePoolInfo) MarshalTo 

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

func (*StablePoolInfo) MarshalToSizedBuffer 

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

func (*StablePoolInfo) ProtoMessage 

func (*StablePoolInfo) ProtoMessage()

func (*StablePoolInfo) Reset 

func (m *StablePoolInfo) Reset()

func (*StablePoolInfo) Size 

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

func (*StablePoolInfo) String 

func (m *StablePoolInfo) String() string

func (*StablePoolInfo) Unmarshal 

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

func (*StablePoolInfo) Validate 

func (s *StablePoolInfo) Validate() error

Validates stable pool information.

func (*StablePoolInfo) XXX_DiscardUnknown 

func (m *StablePoolInfo) XXX_DiscardUnknown()

func (*StablePoolInfo) XXX_Marshal 

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

func (*StablePoolInfo) XXX_Merge 

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

func (*StablePoolInfo) XXX_Size 

func (m *StablePoolInfo) XXX_Size() int

func (*StablePoolInfo) XXX_Unmarshal 

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

type TokenPairArbRoutes 

type TokenPairArbRoutes struct {
	// Stores all of the possible hot paths for a given pair of tokens
	ArbRoutes []Route `protobuf:"bytes,1,rep,name=arb_routes,json=arbRoutes,proto3" json:"arb_routes" yaml:"arb_routes"`
	// Token denomination of the first asset
	TokenIn string `protobuf:"bytes,2,opt,name=token_in,json=tokenIn,proto3" json:"token_in,omitempty" yaml:"token_in"`
	// Token denomination of the second asset
	TokenOut string `protobuf:"bytes,3,opt,name=token_out,json=tokenOut,proto3" json:"token_out,omitempty" yaml:"token_out"`
}

TokenPairArbRoutes tracks all of the hot routes for a given pair of tokens

func NewTokenPairArbRoutes 

func NewTokenPairArbRoutes(routes []Route, tokenA, tokenB string) TokenPairArbRoutes

Creates a new TokenPairArbRoutes object

func (*TokenPairArbRoutes) Descriptor 

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

func (*TokenPairArbRoutes) Equal 

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

func (*TokenPairArbRoutes) GetArbRoutes 

func (m *TokenPairArbRoutes) GetArbRoutes() []Route

func (*TokenPairArbRoutes) GetTokenIn 

func (m *TokenPairArbRoutes) GetTokenIn() string

func (*TokenPairArbRoutes) GetTokenOut 

func (m *TokenPairArbRoutes) GetTokenOut() string

func (*TokenPairArbRoutes) Marshal 

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

func (*TokenPairArbRoutes) MarshalTo 

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

func (*TokenPairArbRoutes) MarshalToSizedBuffer 

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

func (*TokenPairArbRoutes) ProtoMessage 

func (*TokenPairArbRoutes) ProtoMessage()

func (*TokenPairArbRoutes) Reset 

func (m *TokenPairArbRoutes) Reset()

func (*TokenPairArbRoutes) Size 

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

func (*TokenPairArbRoutes) String 

func (m *TokenPairArbRoutes) String() string

func (*TokenPairArbRoutes) Unmarshal 

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

func (*TokenPairArbRoutes) Validate 

func (tp *TokenPairArbRoutes) Validate() error

func (*TokenPairArbRoutes) XXX_DiscardUnknown 

func (m *TokenPairArbRoutes) XXX_DiscardUnknown()

func (*TokenPairArbRoutes) XXX_Marshal 

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

func (*TokenPairArbRoutes) XXX_Merge 

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

func (*TokenPairArbRoutes) XXX_Size 

func (m *TokenPairArbRoutes) XXX_Size() int

func (*TokenPairArbRoutes) XXX_Unmarshal 

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

type Trade 

type Trade struct {
	// The pool id of the pool that is traded on
	Pool uint64 `protobuf:"varint,1,opt,name=pool,proto3" json:"pool,omitempty" yaml:"pool"`
	// The denom of the token that is traded
	TokenIn string `protobuf:"bytes,2,opt,name=token_in,json=tokenIn,proto3" json:"token_in,omitempty" yaml:"token_in"`
	// The denom of the token that is received
	TokenOut string `protobuf:"bytes,3,opt,name=token_out,json=tokenOut,proto3" json:"token_out,omitempty" yaml:"token_out"`
}

Trade is a single trade in a route

func NewTrade 

func NewTrade(pool uint64, tokenA, tokenB string) Trade

func (*Trade) Descriptor 

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

func (*Trade) Equal 

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

func (*Trade) GetPool 

func (m *Trade) GetPool() uint64

func (*Trade) GetTokenIn 

func (m *Trade) GetTokenIn() string

func (*Trade) GetTokenOut 

func (m *Trade) GetTokenOut() string

func (*Trade) Marshal 

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

func (*Trade) MarshalTo 

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

func (*Trade) MarshalToSizedBuffer 

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

func (*Trade) ProtoMessage 

func (*Trade) ProtoMessage()

func (*Trade) Reset 

func (m *Trade) Reset()

func (*Trade) Size 

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

func (*Trade) String 

func (m *Trade) String() string

func (*Trade) Unmarshal 

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

func (*Trade) XXX_DiscardUnknown 

func (m *Trade) XXX_DiscardUnknown()

func (*Trade) XXX_Marshal 

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

func (*Trade) XXX_Merge 

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

func (*Trade) XXX_Size 

func (m *Trade) XXX_Size() int

func (*Trade) XXX_Unmarshal 

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

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) SetBaseDenoms 

func (*UnimplementedMsgServer) SetBaseDenoms(ctx context.Context, req *MsgSetBaseDenoms) (*MsgSetBaseDenomsResponse, error)

func (*UnimplementedMsgServer) SetDeveloperAccount 

func (*UnimplementedMsgServer) SetDeveloperAccount(ctx context.Context, req *MsgSetDeveloperAccount) (*MsgSetDeveloperAccountResponse, error)

func (*UnimplementedMsgServer) SetHotRoutes 

func (*UnimplementedMsgServer) SetHotRoutes(ctx context.Context, req *MsgSetHotRoutes) (*MsgSetHotRoutesResponse, error)

func (*UnimplementedMsgServer) SetInfoByPoolType 

func (*UnimplementedMsgServer) SetInfoByPoolType(ctx context.Context, req *MsgSetInfoByPoolType) (*MsgSetInfoByPoolTypeResponse, error)

func (*UnimplementedMsgServer) SetMaxPoolPointsPerBlock 

func (*UnimplementedMsgServer) SetMaxPoolPointsPerBlock(ctx context.Context, req *MsgSetMaxPoolPointsPerBlock) (*MsgSetMaxPoolPointsPerBlockResponse, error)

func (*UnimplementedMsgServer) SetMaxPoolPointsPerTx 

func (*UnimplementedMsgServer) SetMaxPoolPointsPerTx(ctx context.Context, req *MsgSetMaxPoolPointsPerTx) (*MsgSetMaxPoolPointsPerTxResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) GetAllProtocolRevenue 

func (*UnimplementedQueryServer) GetAllProtocolRevenue(ctx context.Context, req *QueryGetAllProtocolRevenueRequest) (*QueryGetAllProtocolRevenueResponse, error)

func (*UnimplementedQueryServer) GetProtoRevAdminAccount 

func (*UnimplementedQueryServer) GetProtoRevAdminAccount(ctx context.Context, req *QueryGetProtoRevAdminAccountRequest) (*QueryGetProtoRevAdminAccountResponse, error)

func (*UnimplementedQueryServer) GetProtoRevAllProfits 

func (*UnimplementedQueryServer) GetProtoRevAllProfits(ctx context.Context, req *QueryGetProtoRevAllProfitsRequest) (*QueryGetProtoRevAllProfitsResponse, error)

func (*UnimplementedQueryServer) GetProtoRevAllRouteStatistics 

func (*UnimplementedQueryServer) GetProtoRevAllRouteStatistics(ctx context.Context, req *QueryGetProtoRevAllRouteStatisticsRequest) (*QueryGetProtoRevAllRouteStatisticsResponse, error)

func (*UnimplementedQueryServer) GetProtoRevBaseDenoms 

func (*UnimplementedQueryServer) GetProtoRevBaseDenoms(ctx context.Context, req *QueryGetProtoRevBaseDenomsRequest) (*QueryGetProtoRevBaseDenomsResponse, error)

func (*UnimplementedQueryServer) GetProtoRevDeveloperAccount 

func (*UnimplementedQueryServer) GetProtoRevDeveloperAccount(ctx context.Context, req *QueryGetProtoRevDeveloperAccountRequest) (*QueryGetProtoRevDeveloperAccountResponse, error)

func (*UnimplementedQueryServer) GetProtoRevEnabled 

func (*UnimplementedQueryServer) GetProtoRevEnabled(ctx context.Context, req *QueryGetProtoRevEnabledRequest) (*QueryGetProtoRevEnabledResponse, error)

func (*UnimplementedQueryServer) GetProtoRevInfoByPoolType 

func (*UnimplementedQueryServer) GetProtoRevInfoByPoolType(ctx context.Context, req *QueryGetProtoRevInfoByPoolTypeRequest) (*QueryGetProtoRevInfoByPoolTypeResponse, error)

func (*UnimplementedQueryServer) GetProtoRevMaxPoolPointsPerBlock 

func (*UnimplementedQueryServer) GetProtoRevMaxPoolPointsPerBlock(ctx context.Context, req *QueryGetProtoRevMaxPoolPointsPerBlockRequest) (*QueryGetProtoRevMaxPoolPointsPerBlockResponse, error)

func (*UnimplementedQueryServer) GetProtoRevMaxPoolPointsPerTx 

func (*UnimplementedQueryServer) GetProtoRevMaxPoolPointsPerTx(ctx context.Context, req *QueryGetProtoRevMaxPoolPointsPerTxRequest) (*QueryGetProtoRevMaxPoolPointsPerTxResponse, error)

func (*UnimplementedQueryServer) GetProtoRevNumberOfTrades 

func (*UnimplementedQueryServer) GetProtoRevNumberOfTrades(ctx context.Context, req *QueryGetProtoRevNumberOfTradesRequest) (*QueryGetProtoRevNumberOfTradesResponse, error)

func (*UnimplementedQueryServer) GetProtoRevPool 

func (*UnimplementedQueryServer) GetProtoRevPool(ctx context.Context, req *QueryGetProtoRevPoolRequest) (*QueryGetProtoRevPoolResponse, error)

func (*UnimplementedQueryServer) GetProtoRevProfitsByDenom 

func (*UnimplementedQueryServer) GetProtoRevProfitsByDenom(ctx context.Context, req *QueryGetProtoRevProfitsByDenomRequest) (*QueryGetProtoRevProfitsByDenomResponse, error)

func (*UnimplementedQueryServer) GetProtoRevStatisticsByRoute 

func (*UnimplementedQueryServer) GetProtoRevStatisticsByRoute(ctx context.Context, req *QueryGetProtoRevStatisticsByRouteRequest) (*QueryGetProtoRevStatisticsByRouteResponse, error)

func (*UnimplementedQueryServer) GetProtoRevTokenPairArbRoutes 

func (*UnimplementedQueryServer) GetProtoRevTokenPairArbRoutes(ctx context.Context, req *QueryGetProtoRevTokenPairArbRoutesRequest) (*QueryGetProtoRevTokenPairArbRoutesResponse, error)

func (*UnimplementedQueryServer) Params 

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

type WeightMap 

type WeightMap struct {
	// The weight of a cosmwasm pool (by contract address)
	Weight uint64 `protobuf:"varint,1,opt,name=weight,proto3" json:"weight,omitempty" yaml:"weight"`
	// The contract address
	ContractAddress string `` /* 130-byte string literal not displayed */
}

WeightMap maps a contract address to a weight. The weight of an address corresponds to the amount of ms required to execute a swap on that contract.

func (*WeightMap) Descriptor 

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

func (*WeightMap) GetContractAddress 

func (m *WeightMap) GetContractAddress() string

func (*WeightMap) GetWeight 

func (m *WeightMap) GetWeight() uint64

func (*WeightMap) Marshal 

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

func (*WeightMap) MarshalTo 

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

func (*WeightMap) MarshalToSizedBuffer 

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

func (*WeightMap) ProtoMessage 

func (*WeightMap) ProtoMessage()

func (*WeightMap) Reset 

func (m *WeightMap) Reset()

func (*WeightMap) Size 

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

func (*WeightMap) String 

func (m *WeightMap) String() string

func (*WeightMap) Unmarshal 

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

func (*WeightMap) XXX_DiscardUnknown 

func (m *WeightMap) XXX_DiscardUnknown()

func (*WeightMap) XXX_Marshal 

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

func (*WeightMap) XXX_Merge 

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

func (*WeightMap) XXX_Size 

func (m *WeightMap) XXX_Size() int

func (*WeightMap) XXX_Unmarshal 

func (m *WeightMap) XXX_Unmarshal(b []byte) 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.