types

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Jul 24, 2023 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	TypeEvtCreateGauge  = "create_gauge"
	TypeEvtAddToGauge   = "add_to_gauge"
	TypeEvtDistribution = "distribution"

	AttributeGaugeID     = "gauge_id"
	AttributeStakedDenom = "denom"
	AttributeReceiver    = "receiver"
	AttributeAmount      = "amount"

	TypeEvtStake   = "stake"
	TypeEvtUnstake = "unstake"

	AttributeStakeID        = "stake_id"
	AttributeStakeOwner     = "owner"
	AttributeStakeAmount    = "amount"
	AttributeStakeStakeTime = "stake_time"
	AttributeUnstakedCoins  = "unstaked_coins"
)

Incentive module event types.

View Source 
const (
	TypeMsgCreateGauge       = "create_gauge"
	TypeMsgAddToGauge        = "add_to_gauge"
	TypeMsgStakeTokens       = "stake_tokens"
	TypeMsgBeginUnstakingAll = "begin_unstaking_all"
	TypeMsgBeginUnstaking    = "begin_unstaking"
	TypeMsgExtendStakeup     = "edit_stakeup"
)
View Source 
const (
	QueryModuleBalance                    = "module_balance"
	QueryModuleStakedAmount               = "module_staked_amount"
	QueryAccountUnstakeableCoins          = "account_unstakeable_coins"
	QueryAccountStakedCoins               = "account_staked_coins"
	QueryAccountStakedPastTime            = "account_staked_pastime"
	QueryAccountUnstakedBeforeTime        = "account_unstaked_beforetime"
	QueryAccountStakedPastTimeDenom       = "account_staked_denom_pastime"
	QueryStakedByID                       = "staked_by_id"
	QueryAccountStakedLongerDuration      = "account_staked_longer_than_duration"
	QueryAccountStakedLongerDurationDenom = "account_staked_longer_than_duration_denom"
	QueryAccountStakedDuration            = "account_staked_duration"
)

query endpoints supported by the stakeup QueryServer.

View Source 
const DefaultIndex uint64 = 1

DefaultIndex is the default incentive module's global index.

Variables

View Source 
var (
	ErrInvalidLengthAccount        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAccount          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAccount = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthAccountHistory        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAccountHistory          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAccountHistory = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrNotStakeOwner = sdkerrors.Register(
		ModuleName,
		1,
		"msg sender is not the owner of specified stake",
	)
	ErrStakeupNotFound = sdkerrors.Register(ModuleName, 2, "stakeup not found")
	ErrGaugeNotActive  = sdkerrors.Register(
		ModuleName,
		3,
		"cannot distribute from gauges when it is not active",
	)
	ErrInvalidGaugeStatus = sdkerrors.Register(
		ModuleName,
		4,
		"Gauge status filter must be one of: ACTIVE_UPCOMING, ACTIVE, UPCOMING, FINISHED",
	)
	ErrMaxGaugesReached = sdkerrors.Register(
		ModuleName,
		5,
		"Gauge limit has been reached; additional gauges may be created once the gauge limit has been raised via governance proposal",
	)
	ErrGaugePricingTickOutOfRange = sdkerrors.Register(
		ModuleName,
		6,
		"cannot use an invalid price tick",
	)
	ErrGaugeDistrToTickOutOfRange = sdkerrors.Register(ModuleName, 7, "cannot use an distrTo tick")
	ErrInvalidSigner              = sdkerrors.Register(
		ModuleName,
		8,
		"owner must be module authority",
	)
)

x/incentives module sentinel errors.

View Source 
var (
	ErrInvalidLengthGauge        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGauge          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGauge = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// ModuleName defines the module name.
	ModuleName = "incentives"

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

	// RouterKey is the message route for slashing.
	RouterKey = ModuleName

	// QuerierRoute defines the module's query routing key.
	QuerierRoute = ModuleName

	// MemStoreKey defines the in-memory store key.
	MemStoreKey = "mem_capability"

	// KeyPrefixTimestamp defines prefix key for timestamp iterator key.
	KeyPrefixTimestamp = []byte{0x01}

	// KeyLastGaugeID defines key for setting last gauge ID.
	KeyLastGaugeID = []byte{0x02}

	// KeyPrefixGauge defines prefix key for storing gauges.
	KeyPrefixGauge = []byte{0x03}

	// KeyPrefixGaugeIndex defines prefix key for storing reference key for all gauges.
	KeyPrefixGaugeIndex = []byte{0x04}

	// KeyPrefixGaugeIndexUpcoming defines prefix key for storing reference key for upcoming gauges.
	KeyPrefixGaugeIndexUpcoming = []byte{0x04, 0x00}

	// KeyPrefixGaugeIndexActive defines prefix key for storing reference key for active gauges.
	KeyPrefixGaugeIndexActive = []byte{0x04, 0x01}

	// KeyPrefixGaugeIndexFinished defines prefix key for storing reference key for finished gauges.
	KeyPrefixGaugeIndexFinished = []byte{0x04, 0x02}

	// KeyPrefixGaugeIndexByPair defines prefix key for storing indexes of gauge IDs by denomination.
	KeyPrefixGaugeIndexByPair = []byte{0x05}

	// KeyLastStakeID defines key to store stake ID used by last.
	KeyLastStakeID = []byte{0x06}

	// KeyPrefixStake defines prefix to store period stake by ID.
	KeyPrefixStake = []byte{0x07}

	// KeyPrefixStakeIndexAccount defines prefix for the iteration of stake IDs by account.
	KeyPrefixStakeIndex = []byte{0x08}

	// KeyPrefixStakeIndexAccount defines prefix for the iteration of stake IDs by account.
	KeyPrefixStakeIndexAccount = []byte{0x09}

	// KeyPrefixStakeIndexDenom defines prefix for the iteration of stake IDs by denom.
	KeyPrefixStakeIndexDenom = []byte{0x0c}

	// KeyPrefixStakeIndexPairTick defines prefix for the iteration of stake IDs by pairId and tick index.
	KeyPrefixStakeIndexPairTick = []byte{0x0d}

	// KeyPrefixStakeIndexAccountDenom defines prefix for the iteration of stake IDs by account, denomination.
	KeyPrefixStakeIndexAccountDenom = []byte{0x0e}

	// KeyPrefixStakeIndexTimestamp defines prefix for the iteration of stake IDs by day epoch integer.
	KeyPrefixStakeIndexPairDistEpoch = []byte{0x0f}

	// KeyPrefixAccountHistory defines the prefix for storing account histories.
	KeyPrefixAccountHistory = []byte{0x10}

	// KeyndexSeparator defines separator between keys when combine, it should be one that is not used in denom expression.
	KeyIndexSeparator = []byte{0xFF}
)
View Source 
var (
	KeyDistrEpochIdentifier = []byte("DistrEpochIdentifier")
	KeyMaxGauges            = []byte("MaxGauges")
)

Incentives parameters key store.

View Source 
var (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthStake        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStake          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupStake = 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 GaugeStatus_name = map[int32]string{
	0: "ACTIVE_UPCOMING",
	1: "ACTIVE",
	2: "UPCOMING",
	3: "FINISHED",
}
View Source 
var GaugeStatus_value = map[string]int32{
	"ACTIVE_UPCOMING": 0,
	"ACTIVE":          1,
	"UPCOMING":        2,
	"FINISHED":        3,
}
View Source 
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)

Functions

func CombineKeys 

func CombineKeys(keys ...[]byte) []byte

combineKeys combine bytes array into a single bytes.

func GetKeyAccountHistory added in v0.3.4 

func GetKeyAccountHistory(address string) []byte

func GetKeyGaugeIndexByPair 

func GetKeyGaugeIndexByPair(pairID string) []byte

gaugePairStoreKey returns the combined byte array (store key) of the provided gauge denom key prefix and the denom itself.

func GetKeyGaugeStore 

func GetKeyGaugeStore(id uint64) []byte

gaugeStoreKey returns the combined byte array (store key) of the provided gauge ID's key prefix and the ID itself.

func GetKeyInt64 added in v0.3.4 

func GetKeyInt64(a int64) []byte

func GetKeyStakeIndexByAccount 

func GetKeyStakeIndexByAccount(account sdk.AccAddress) []byte

func GetKeyStakeIndexByAccountDenom 

func GetKeyStakeIndexByAccountDenom(account sdk.AccAddress, denom string) []byte

func GetKeyStakeIndexByDenom 

func GetKeyStakeIndexByDenom(denom string) []byte

func GetKeyStakeIndexByDistEpoch added in v0.3.4 

func GetKeyStakeIndexByDistEpoch(pairID string, distEpoch int64) []byte

func GetKeyStakeIndexByPairTick 

func GetKeyStakeIndexByPairTick(pairID string, tickIndex int64) []byte

func GetStakeStoreKey 

func GetStakeStoreKey(id uint64) []byte

stakeStoreKey returns action store key from ID.

func GetTimeKey 

func GetTimeKey(timestamp time.Time) []byte

getTimeKey returns the key used for getting a set of period stakes where unstakeTime is after a specific time.

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable returns the key table for the incentive module's parameters.

func RegisterCodec 

func RegisterCodec(cdc *codec.LegacyAmino)

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

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

RegisterInterfaces registers interfaces and implementations of the incentives module.

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)

Types

type Account added in v0.3.4 

type Account struct {
	// the address of this account
	Account string `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
	// coins describes the total amount of coins that have been distributed to this user over time
	Coins github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,2,rep,name=coins,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"coins"`
}

Describes the total distributions to an account over time

func (*Account) Descriptor added in v0.3.4 

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

func (*Account) GetAccount added in v0.3.4 

func (m *Account) GetAccount() string

func (*Account) GetCoins added in v0.3.4 

func (m *Account) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins

func (*Account) Marshal added in v0.3.4 

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

func (*Account) MarshalTo added in v0.3.4 

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

func (*Account) MarshalToSizedBuffer added in v0.3.4 

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

func (*Account) ProtoMessage added in v0.3.4 

func (*Account) ProtoMessage()

func (*Account) Reset added in v0.3.4 

func (m *Account) Reset()

func (*Account) Size added in v0.3.4 

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

func (*Account) String added in v0.3.4 

func (m *Account) String() string

func (*Account) Unmarshal added in v0.3.4 

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

func (*Account) XXX_DiscardUnknown added in v0.3.4 

func (m *Account) XXX_DiscardUnknown()

func (*Account) XXX_Marshal added in v0.3.4 

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

func (*Account) XXX_Merge added in v0.3.4 

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

func (*Account) XXX_Size added in v0.3.4 

func (m *Account) XXX_Size() int

func (*Account) XXX_Unmarshal added in v0.3.4 

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

type AccountHistory added in v0.3.4 

type AccountHistory struct {
	// the address of this account
	Account string `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
	// coins describes the total amount of coins that have been distributed to this user over time
	Coins github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,2,rep,name=coins,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"coins"`
}

Describes the total distributions to an account over time

func (*AccountHistory) Descriptor added in v0.3.4 

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

func (*AccountHistory) GetAccount added in v0.3.4 

func (m *AccountHistory) GetAccount() string

func (*AccountHistory) GetCoins added in v0.3.4 

func (m *AccountHistory) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins

func (*AccountHistory) Marshal added in v0.3.4 

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

func (*AccountHistory) MarshalTo added in v0.3.4 

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

func (*AccountHistory) MarshalToSizedBuffer added in v0.3.4 

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

func (*AccountHistory) ProtoMessage added in v0.3.4 

func (*AccountHistory) ProtoMessage()

func (*AccountHistory) Reset added in v0.3.4 

func (m *AccountHistory) Reset()

func (*AccountHistory) Size added in v0.3.4 

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

func (*AccountHistory) String added in v0.3.4 

func (m *AccountHistory) String() string

func (*AccountHistory) Unmarshal added in v0.3.4 

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

func (*AccountHistory) XXX_DiscardUnknown added in v0.3.4 

func (m *AccountHistory) XXX_DiscardUnknown()

func (*AccountHistory) XXX_Marshal added in v0.3.4 

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

func (*AccountHistory) XXX_Merge added in v0.3.4 

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

func (*AccountHistory) XXX_Size added in v0.3.4 

func (m *AccountHistory) XXX_Size() int

func (*AccountHistory) XXX_Unmarshal added in v0.3.4 

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

type AccountKeeper 

type AccountKeeper interface {
	GetAllAccounts(ctx sdk.Context) []authtypes.AccountI
	GetModuleAccount(ctx sdk.Context, moduleName string) authtypes.ModuleAccountI
	GetModuleAddress(moduleName string) sdk.AccAddress
}

type BankKeeper 

type BankKeeper interface {
	GetAllBalances(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	GetBalance(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin

	HasSupply(ctx sdk.Context, denom string) bool
	GetSupply(ctx sdk.Context, denom string) sdk.Coin

	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
}

BankKeeper defines the expected interface needed to retrieve account balances.

type DexKeeper 

type DexKeeper interface {
	GetOrInitPool(ctx sdk.Context, pairID *types.PairID, centerTickIndex int64, fee uint64) (*dextypes.Pool, error)
}

type DistributionSpec 

type DistributionSpec map[string]sdk.Coins

func (*DistributionSpec) Add 

func (spec *DistributionSpec) Add(other DistributionSpec) DistributionSpec

func (DistributionSpec) GetTotal 

func (spec DistributionSpec) GetTotal() sdk.Coins

type EpochKeeper 

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

EpochKeeper defines the expected interface needed to retrieve epoch info.

type Gauge 

type Gauge struct {
	// id is the unique ID of a Gauge
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// There are two kinds of gauges: perpetual and non-perpetual. Perpetual
	// gauges describe an incentivization program for which the token rewards
	// distributed on any given day must be added to the gauge prior to that day's
	// distribution using an AddToGauge message.  When distribute is called on a
	// perpetual gauge, all of the remaining rewards in the gauge are distributed.
	// Because of this, all perpetual gauges must have `num_epochs_paid_over` set
	// to 1.  A non-perpetual gauge by contrast distributes its rewards over a
	// schedule as determined by `num_epochs_paid_over`. If a non-perpetual gauge
	// is created with coins=[100atom] and num_epochs_paid_over=10, this means
	// that for 10 days (10 epochs) the gauge will distribute 10atom each day to
	// the staked LP positions qualifying for the gauge.
	IsPerpetual bool `protobuf:"varint,2,opt,name=is_perpetual,json=isPerpetual,proto3" json:"is_perpetual,omitempty"`
	// distribute_to describes a set of staked LP positions that should be
	// distributed to from this gauge.
	DistributeTo QueryCondition `protobuf:"bytes,3,opt,name=distribute_to,json=distributeTo,proto3" json:"distribute_to"`
	// coins describes the total amount of coins that have been added to this
	// gauge for distribution.
	Coins github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,4,rep,name=coins,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"coins"`
	// start_time describes when this gauge should begin distributing rewards.
	// This allows gauge creators to schedule gauges into the future, in the event
	// that an earlier gauge is expected to expire.
	StartTime time.Time `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time" yaml:"start_time"`
	// num_epochs_paid_over is the number of total epochs (days) the rewards in
	// this gauge will be distributed over.
	NumEpochsPaidOver uint64 `protobuf:"varint,6,opt,name=num_epochs_paid_over,json=numEpochsPaidOver,proto3" json:"num_epochs_paid_over,omitempty"`
	// filled_epochs describes the number of epochs distribution have been completed
	// already
	FilledEpochs uint64 `protobuf:"varint,7,opt,name=filled_epochs,json=filledEpochs,proto3" json:"filled_epochs,omitempty"`
	// distributed_coins describes coins that have been distributed already from
	// this gauge.
	DistributedCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 153-byte string literal not displayed */
	// pricing_tick is necessary for fairly distributing rewards over a range of
	// ticks.  Without pricing_tick, we might naively distribute rewards in
	// proportion to the number of deposit shares staked within the gauge's
	// qualifying tick range.
	//
	// For example, a gauge with a distribute_to tick range of [-10, 10] would
	// distribute to staked LP tokens where both tick-fee and tick+fee are within
	// [-10, 10]. Let's say for pair "tokenA<>tokenB", the current trading tick is
	// 0. If Alice were to LP (10tokenA, 0tokenB) @ tick -8, fee 2, this would
	// mean Alice would be issued 10 shares (10 + 0 * 1.0001^-8), since shares are
	// in terms of token0. Let's further assume Bob LPs (0tokenA, 10tokenB) @ tick
	// 8, fee 2, such that Bob is issued 10.008 shares (0 + 10 * 1.0001^8). Under
	// this naive approach, if Alice and Bob were to stake their shares, Bob would
	// receive more in rewards, purely on the basis of the relative locations of
	// their liquidity.
	//
	// This disparity originates in the fact that LP deposit denominations are not
	// fungible across ticks. To avoid this, we can use a single price throughout
	// the gauge's tick range for relating the relative value of token0 and
	// token1, as specified by pricing_tick.
	//
	// Let's run through the earier example using the more sophisticated approach,
	// where the gauge has pricing_tick set to 0. For the purpose of calculating
	// reward distribution weight, Alice's shares are worth 10 + 0 * 1.0001^0 = 10
	// and Bob's shares are worth 0 + 10 * 1.0001^0 = 10. With the distribution
	// weight of both shares set according to a gauge-specific tick, we do not
	// distribute more or less rewards according to the relative location of
	// liquidity within the gauge's tick range, freeing users to place liquidity
	// whereever they deem most profitable in the gauge's range and still equally
	// qualify for rewards.
	PricingTick int64 `protobuf:"varint,9,opt,name=pricing_tick,json=pricingTick,proto3" json:"pricing_tick,omitempty"`
}

Gauge is an object that describes an LP incentivization plan and its state.

func NewGauge 

func NewGauge(
	id uint64,
	isPerpetual bool,
	distrTo QueryCondition,
	coins sdk.Coins,
	startTime time.Time,
	numEpochsPaidOver uint64,
	filledEpochs uint64,
	distCoins sdk.Coins,
	pricingTick int64,
) Gauge

NewGauge creates a new gauge struct given the required gauge parameters.

func (Gauge) CoinsRemaining 

func (gauge Gauge) CoinsRemaining() sdk.Coins

func (*Gauge) Descriptor 

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

func (Gauge) EpochsRemaining 

func (gauge Gauge) EpochsRemaining() uint64

func (*Gauge) GetCoins 

func (m *Gauge) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins

func (*Gauge) GetDistributeTo 

func (m *Gauge) GetDistributeTo() QueryCondition

func (*Gauge) GetDistributedCoins 

func (m *Gauge) GetDistributedCoins() github_com_cosmos_cosmos_sdk_types.Coins

func (*Gauge) GetFilledEpochs 

func (m *Gauge) GetFilledEpochs() uint64

func (*Gauge) GetId 

func (m *Gauge) GetId() uint64

func (*Gauge) GetIsPerpetual 

func (m *Gauge) GetIsPerpetual() bool

func (*Gauge) GetNumEpochsPaidOver 

func (m *Gauge) GetNumEpochsPaidOver() uint64

func (*Gauge) GetPricingTick 

func (m *Gauge) GetPricingTick() int64

func (*Gauge) GetStartTime 

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

func (Gauge) IsActiveGauge 

func (gauge Gauge) IsActiveGauge(now time.Time) bool

IsActiveGauge returns true if the gauge is in an active state during the provided time.

func (Gauge) IsFinishedGauge 

func (gauge Gauge) IsFinishedGauge(now time.Time) bool

IsFinishedGauge returns true if the gauge is in a finished state during the provided time.

func (Gauge) IsUpcomingGauge 

func (gauge Gauge) IsUpcomingGauge(now time.Time) bool

IsUpcomingGauge returns true if the gauge's distribution start time is after the provided time.

func (*Gauge) Marshal 

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

func (*Gauge) MarshalTo 

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

func (*Gauge) MarshalToSizedBuffer 

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

func (*Gauge) ProtoMessage 

func (*Gauge) ProtoMessage()

func (*Gauge) Reset 

func (m *Gauge) Reset()

func (Gauge) RewardsNextEpoch 

func (gauge Gauge) RewardsNextEpoch() sdk.Coins

func (*Gauge) Size 

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

func (*Gauge) String 

func (m *Gauge) String() string

func (*Gauge) Unmarshal 

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

func (*Gauge) XXX_DiscardUnknown 

func (m *Gauge) XXX_DiscardUnknown()

func (*Gauge) XXX_Marshal 

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

func (*Gauge) XXX_Merge 

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

func (*Gauge) XXX_Size 

func (m *Gauge) XXX_Size() int

func (*Gauge) XXX_Unmarshal 

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

type GaugeStatus 

type GaugeStatus int32
const (
	GaugeStatus_ACTIVE_UPCOMING GaugeStatus = 0
	GaugeStatus_ACTIVE          GaugeStatus = 1
	GaugeStatus_UPCOMING        GaugeStatus = 2
	GaugeStatus_FINISHED        GaugeStatus = 3
)

func (GaugeStatus) EnumDescriptor 

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

func (GaugeStatus) String 

func (x GaugeStatus) String() string

type Gauges 

type Gauges []*Gauge

func (Gauges) GetCoinsDistributed 

func (g Gauges) GetCoinsDistributed() sdk.Coins

func (Gauges) GetCoinsRemaining 

func (g Gauges) GetCoinsRemaining() sdk.Coins

getToDistributeCoinsFromGauges returns coins that have not been distributed yet from the provided gauges

type GenesisState 

type GenesisState struct {
	// params are all the parameters of the module
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	// gauges are all gauges that should exist at genesis
	Gauges []*Gauge `protobuf:"bytes,2,rep,name=gauges,proto3" json:"gauges,omitempty"`
	// last_gauge_id is what the gauge number will increment from when creating
	// the next gauge after genesis
	LastGaugeId      uint64            `protobuf:"varint,3,opt,name=last_gauge_id,json=lastGaugeId,proto3" json:"last_gauge_id,omitempty"`
	LastStakeId      uint64            `protobuf:"varint,4,opt,name=last_stake_id,json=lastStakeId,proto3" json:"last_stake_id,omitempty"`
	Stakes           []*Stake          `protobuf:"bytes,5,rep,name=stakes,proto3" json:"stakes,omitempty"`
	AccountHistories []*AccountHistory `protobuf:"bytes,6,rep,name=accountHistories,proto3" json:"accountHistories,omitempty"`
}

GenesisState defines the incentives module's various parameters when first initialized

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the incentive module's default genesis state.

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetAccountHistories added in v0.3.4 

func (m *GenesisState) GetAccountHistories() []*AccountHistory

func (*GenesisState) GetGauges 

func (m *GenesisState) GetGauges() []*Gauge

func (*GenesisState) GetLastGaugeId 

func (m *GenesisState) GetLastGaugeId() uint64

func (*GenesisState) GetLastStakeId 

func (m *GenesisState) GetLastStakeId() uint64

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetStakes 

func (m *GenesisState) GetStakes() []*Stake

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 GetAccountHistoryRequest added in v0.3.4 

type GetAccountHistoryRequest struct {
	// Address that is being queried for account history
	Account string `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty" yaml:"account"`
}

func (*GetAccountHistoryRequest) Descriptor added in v0.3.4 

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

func (*GetAccountHistoryRequest) GetAccount added in v0.3.4 

func (m *GetAccountHistoryRequest) GetAccount() string

func (*GetAccountHistoryRequest) Marshal added in v0.3.4 

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

func (*GetAccountHistoryRequest) MarshalTo added in v0.3.4 

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

func (*GetAccountHistoryRequest) MarshalToSizedBuffer added in v0.3.4 

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

func (*GetAccountHistoryRequest) ProtoMessage added in v0.3.4 

func (*GetAccountHistoryRequest) ProtoMessage()

func (*GetAccountHistoryRequest) Reset added in v0.3.4 

func (m *GetAccountHistoryRequest) Reset()

func (*GetAccountHistoryRequest) Size added in v0.3.4 

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

func (*GetAccountHistoryRequest) String added in v0.3.4 

func (m *GetAccountHistoryRequest) String() string

func (*GetAccountHistoryRequest) Unmarshal added in v0.3.4 

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

func (*GetAccountHistoryRequest) XXX_DiscardUnknown added in v0.3.4 

func (m *GetAccountHistoryRequest) XXX_DiscardUnknown()

func (*GetAccountHistoryRequest) XXX_Marshal added in v0.3.4 

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

func (*GetAccountHistoryRequest) XXX_Merge added in v0.3.4 

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

func (*GetAccountHistoryRequest) XXX_Size added in v0.3.4 

func (m *GetAccountHistoryRequest) XXX_Size() int

func (*GetAccountHistoryRequest) XXX_Unmarshal added in v0.3.4 

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

type GetAccountHistoryResponse added in v0.3.4 

type GetAccountHistoryResponse struct {
	// Gauge rewards that have been distributed to this address to date
	Coins github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,1,rep,name=coins,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"coins"`
}

func (*GetAccountHistoryResponse) Descriptor added in v0.3.4 

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

func (*GetAccountHistoryResponse) GetCoins added in v0.3.4 

func (m *GetAccountHistoryResponse) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins

func (*GetAccountHistoryResponse) Marshal added in v0.3.4 

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

func (*GetAccountHistoryResponse) MarshalTo added in v0.3.4 

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

func (*GetAccountHistoryResponse) MarshalToSizedBuffer added in v0.3.4 

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

func (*GetAccountHistoryResponse) ProtoMessage added in v0.3.4 

func (*GetAccountHistoryResponse) ProtoMessage()

func (*GetAccountHistoryResponse) Reset added in v0.3.4 

func (m *GetAccountHistoryResponse) Reset()

func (*GetAccountHistoryResponse) Size added in v0.3.4 

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

func (*GetAccountHistoryResponse) String added in v0.3.4 

func (m *GetAccountHistoryResponse) String() string

func (*GetAccountHistoryResponse) Unmarshal added in v0.3.4 

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

func (*GetAccountHistoryResponse) XXX_DiscardUnknown added in v0.3.4 

func (m *GetAccountHistoryResponse) XXX_DiscardUnknown()

func (*GetAccountHistoryResponse) XXX_Marshal added in v0.3.4 

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

func (*GetAccountHistoryResponse) XXX_Merge added in v0.3.4 

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

func (*GetAccountHistoryResponse) XXX_Size added in v0.3.4 

func (m *GetAccountHistoryResponse) XXX_Size() int

func (*GetAccountHistoryResponse) XXX_Unmarshal added in v0.3.4 

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

type GetFutureRewardEstimateRequest 

type GetFutureRewardEstimateRequest struct {
	// Address that is being queried for future estimated rewards
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty" yaml:"owner"`
	// Stake IDs included in future reward estimation
	StakeIds []uint64 `protobuf:"varint,2,rep,packed,name=stake_ids,json=stakeIds,proto3" json:"stake_ids,omitempty"`
	// Determines upper time limit of reward estimation
	// reward estimation goes up to current_epoch + num_epochs
	NumEpochs int64 `protobuf:"varint,3,opt,name=num_epochs,json=numEpochs,proto3" json:"num_epochs,omitempty"`
}

func (*GetFutureRewardEstimateRequest) Descriptor 

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

func (*GetFutureRewardEstimateRequest) GetNumEpochs added in v0.3.0 

func (m *GetFutureRewardEstimateRequest) GetNumEpochs() int64

func (*GetFutureRewardEstimateRequest) GetOwner 

func (m *GetFutureRewardEstimateRequest) GetOwner() string

func (*GetFutureRewardEstimateRequest) GetStakeIds 

func (m *GetFutureRewardEstimateRequest) GetStakeIds() []uint64

func (*GetFutureRewardEstimateRequest) Marshal 

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

func (*GetFutureRewardEstimateRequest) MarshalTo 

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

func (*GetFutureRewardEstimateRequest) MarshalToSizedBuffer 

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

func (*GetFutureRewardEstimateRequest) ProtoMessage 

func (*GetFutureRewardEstimateRequest) ProtoMessage()

func (*GetFutureRewardEstimateRequest) Reset 

func (m *GetFutureRewardEstimateRequest) Reset()

func (*GetFutureRewardEstimateRequest) Size 

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

func (*GetFutureRewardEstimateRequest) String 

func (m *GetFutureRewardEstimateRequest) String() string

func (*GetFutureRewardEstimateRequest) Unmarshal 

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

func (*GetFutureRewardEstimateRequest) XXX_DiscardUnknown 

func (m *GetFutureRewardEstimateRequest) XXX_DiscardUnknown()

func (*GetFutureRewardEstimateRequest) XXX_Marshal 

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

func (*GetFutureRewardEstimateRequest) XXX_Merge 

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

func (*GetFutureRewardEstimateRequest) XXX_Size 

func (m *GetFutureRewardEstimateRequest) XXX_Size() int

func (*GetFutureRewardEstimateRequest) XXX_Unmarshal 

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

type GetFutureRewardEstimateResponse 

type GetFutureRewardEstimateResponse struct {
	// Estimated coin rewards that will be recieved at provided address
	// from specified locks between current time and end epoch
	Coins github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,1,rep,name=coins,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"coins"`
}

func (*GetFutureRewardEstimateResponse) Descriptor 

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

func (*GetFutureRewardEstimateResponse) GetCoins 

func (m *GetFutureRewardEstimateResponse) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins

func (*GetFutureRewardEstimateResponse) Marshal 

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

func (*GetFutureRewardEstimateResponse) MarshalTo 

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

func (*GetFutureRewardEstimateResponse) MarshalToSizedBuffer 

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

func (*GetFutureRewardEstimateResponse) ProtoMessage 

func (*GetFutureRewardEstimateResponse) ProtoMessage()

func (*GetFutureRewardEstimateResponse) Reset 

func (m *GetFutureRewardEstimateResponse) Reset()

func (*GetFutureRewardEstimateResponse) Size 

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

func (*GetFutureRewardEstimateResponse) String 

func (m *GetFutureRewardEstimateResponse) String() string

func (*GetFutureRewardEstimateResponse) Unmarshal 

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

func (*GetFutureRewardEstimateResponse) XXX_DiscardUnknown 

func (m *GetFutureRewardEstimateResponse) XXX_DiscardUnknown()

func (*GetFutureRewardEstimateResponse) XXX_Marshal 

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

func (*GetFutureRewardEstimateResponse) XXX_Merge 

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

func (*GetFutureRewardEstimateResponse) XXX_Size 

func (m *GetFutureRewardEstimateResponse) XXX_Size() int

func (*GetFutureRewardEstimateResponse) XXX_Unmarshal 

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

type GetGaugeByIDRequest 

type GetGaugeByIDRequest struct {
	// Gague ID being queried
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*GetGaugeByIDRequest) Descriptor 

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

func (*GetGaugeByIDRequest) GetId 

func (m *GetGaugeByIDRequest) GetId() uint64

func (*GetGaugeByIDRequest) Marshal 

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

func (*GetGaugeByIDRequest) MarshalTo 

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

func (*GetGaugeByIDRequest) MarshalToSizedBuffer 

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

func (*GetGaugeByIDRequest) ProtoMessage 

func (*GetGaugeByIDRequest) ProtoMessage()

func (*GetGaugeByIDRequest) Reset 

func (m *GetGaugeByIDRequest) Reset()

func (*GetGaugeByIDRequest) Size 

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

func (*GetGaugeByIDRequest) String 

func (m *GetGaugeByIDRequest) String() string

func (*GetGaugeByIDRequest) Unmarshal 

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

func (*GetGaugeByIDRequest) XXX_DiscardUnknown 

func (m *GetGaugeByIDRequest) XXX_DiscardUnknown()

func (*GetGaugeByIDRequest) XXX_Marshal 

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

func (*GetGaugeByIDRequest) XXX_Merge 

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

func (*GetGaugeByIDRequest) XXX_Size 

func (m *GetGaugeByIDRequest) XXX_Size() int

func (*GetGaugeByIDRequest) XXX_Unmarshal 

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

type GetGaugeByIDResponse 

type GetGaugeByIDResponse struct {
	// Gauge that corresponds to provided gague ID
	Gauge *Gauge `protobuf:"bytes,1,opt,name=gauge,proto3" json:"gauge,omitempty"`
}

func (*GetGaugeByIDResponse) Descriptor 

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

func (*GetGaugeByIDResponse) GetGauge 

func (m *GetGaugeByIDResponse) GetGauge() *Gauge

func (*GetGaugeByIDResponse) Marshal 

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

func (*GetGaugeByIDResponse) MarshalTo 

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

func (*GetGaugeByIDResponse) MarshalToSizedBuffer 

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

func (*GetGaugeByIDResponse) ProtoMessage 

func (*GetGaugeByIDResponse) ProtoMessage()

func (*GetGaugeByIDResponse) Reset 

func (m *GetGaugeByIDResponse) Reset()

func (*GetGaugeByIDResponse) Size 

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

func (*GetGaugeByIDResponse) String 

func (m *GetGaugeByIDResponse) String() string

func (*GetGaugeByIDResponse) Unmarshal 

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

func (*GetGaugeByIDResponse) XXX_DiscardUnknown 

func (m *GetGaugeByIDResponse) XXX_DiscardUnknown()

func (*GetGaugeByIDResponse) XXX_Marshal 

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

func (*GetGaugeByIDResponse) XXX_Merge 

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

func (*GetGaugeByIDResponse) XXX_Size 

func (m *GetGaugeByIDResponse) XXX_Size() int

func (*GetGaugeByIDResponse) XXX_Unmarshal 

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

type GetGaugeQualifyingValueRequest added in v0.3.4 

type GetGaugeQualifyingValueRequest struct {
	// Gague ID being queried
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*GetGaugeQualifyingValueRequest) Descriptor added in v0.3.4 

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

func (*GetGaugeQualifyingValueRequest) GetId added in v0.3.4 

func (m *GetGaugeQualifyingValueRequest) GetId() uint64

func (*GetGaugeQualifyingValueRequest) Marshal added in v0.3.4 

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

func (*GetGaugeQualifyingValueRequest) MarshalTo added in v0.3.4 

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

func (*GetGaugeQualifyingValueRequest) MarshalToSizedBuffer added in v0.3.4 

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

func (*GetGaugeQualifyingValueRequest) ProtoMessage added in v0.3.4 

func (*GetGaugeQualifyingValueRequest) ProtoMessage()

func (*GetGaugeQualifyingValueRequest) Reset added in v0.3.4 

func (m *GetGaugeQualifyingValueRequest) Reset()

func (*GetGaugeQualifyingValueRequest) Size added in v0.3.4 

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

func (*GetGaugeQualifyingValueRequest) String added in v0.3.4 

func (m *GetGaugeQualifyingValueRequest) String() string

func (*GetGaugeQualifyingValueRequest) Unmarshal added in v0.3.4 

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

func (*GetGaugeQualifyingValueRequest) XXX_DiscardUnknown added in v0.3.4 

func (m *GetGaugeQualifyingValueRequest) XXX_DiscardUnknown()

func (*GetGaugeQualifyingValueRequest) XXX_Marshal added in v0.3.4 

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

func (*GetGaugeQualifyingValueRequest) XXX_Merge added in v0.3.4 

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

func (*GetGaugeQualifyingValueRequest) XXX_Size added in v0.3.4 

func (m *GetGaugeQualifyingValueRequest) XXX_Size() int

func (*GetGaugeQualifyingValueRequest) XXX_Unmarshal added in v0.3.4 

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

type GetGaugeQualifyingValueResponse added in v0.3.4 

type GetGaugeQualifyingValueResponse struct {
	// The amount of value at the gauge's pricing tick currently qualifying for the gauge.
	QualifyingValue uint64 `protobuf:"varint,1,opt,name=qualifying_value,json=qualifyingValue,proto3" json:"qualifying_value,omitempty"`
}

func (*GetGaugeQualifyingValueResponse) Descriptor added in v0.3.4 

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

func (*GetGaugeQualifyingValueResponse) GetQualifyingValue added in v0.3.4 

func (m *GetGaugeQualifyingValueResponse) GetQualifyingValue() uint64

func (*GetGaugeQualifyingValueResponse) Marshal added in v0.3.4 

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

func (*GetGaugeQualifyingValueResponse) MarshalTo added in v0.3.4 

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

func (*GetGaugeQualifyingValueResponse) MarshalToSizedBuffer added in v0.3.4 

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

func (*GetGaugeQualifyingValueResponse) ProtoMessage added in v0.3.4 

func (*GetGaugeQualifyingValueResponse) ProtoMessage()

func (*GetGaugeQualifyingValueResponse) Reset added in v0.3.4 

func (m *GetGaugeQualifyingValueResponse) Reset()

func (*GetGaugeQualifyingValueResponse) Size added in v0.3.4 

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

func (*GetGaugeQualifyingValueResponse) String added in v0.3.4 

func (m *GetGaugeQualifyingValueResponse) String() string

func (*GetGaugeQualifyingValueResponse) Unmarshal added in v0.3.4 

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

func (*GetGaugeQualifyingValueResponse) XXX_DiscardUnknown added in v0.3.4 

func (m *GetGaugeQualifyingValueResponse) XXX_DiscardUnknown()

func (*GetGaugeQualifyingValueResponse) XXX_Marshal added in v0.3.4 

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

func (*GetGaugeQualifyingValueResponse) XXX_Merge added in v0.3.4 

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

func (*GetGaugeQualifyingValueResponse) XXX_Size added in v0.3.4 

func (m *GetGaugeQualifyingValueResponse) XXX_Size() int

func (*GetGaugeQualifyingValueResponse) XXX_Unmarshal added in v0.3.4 

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

type GetGaugesRequest 

type GetGaugesRequest struct {
	Status GaugeStatus `protobuf:"varint,1,opt,name=status,proto3,enum=dualitylabs.duality.incentives.GaugeStatus" json:"status,omitempty"`
	Denom  string      `protobuf:"bytes,2,opt,name=denom,proto3" json:"denom,omitempty"`
}

func (*GetGaugesRequest) Descriptor 

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

func (*GetGaugesRequest) GetDenom 

func (m *GetGaugesRequest) GetDenom() string

func (*GetGaugesRequest) GetStatus 

func (m *GetGaugesRequest) GetStatus() GaugeStatus

func (*GetGaugesRequest) Marshal 

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

func (*GetGaugesRequest) MarshalTo 

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

func (*GetGaugesRequest) MarshalToSizedBuffer 

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

func (*GetGaugesRequest) ProtoMessage 

func (*GetGaugesRequest) ProtoMessage()

func (*GetGaugesRequest) Reset 

func (m *GetGaugesRequest) Reset()

func (*GetGaugesRequest) Size 

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

func (*GetGaugesRequest) String 

func (m *GetGaugesRequest) String() string

func (*GetGaugesRequest) Unmarshal 

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

func (*GetGaugesRequest) XXX_DiscardUnknown 

func (m *GetGaugesRequest) XXX_DiscardUnknown()

func (*GetGaugesRequest) XXX_Marshal 

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

func (*GetGaugesRequest) XXX_Merge 

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

func (*GetGaugesRequest) XXX_Size 

func (m *GetGaugesRequest) XXX_Size() int

func (*GetGaugesRequest) XXX_Unmarshal 

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

type GetGaugesResponse 

type GetGaugesResponse struct {
	// Upcoming and active gauges
	Gauges []*Gauge `protobuf:"bytes,1,rep,name=gauges,proto3" json:"gauges,omitempty"`
}

func (*GetGaugesResponse) Descriptor 

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

func (*GetGaugesResponse) GetGauges 

func (m *GetGaugesResponse) GetGauges() []*Gauge

func (*GetGaugesResponse) Marshal 

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

func (*GetGaugesResponse) MarshalTo 

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

func (*GetGaugesResponse) MarshalToSizedBuffer 

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

func (*GetGaugesResponse) ProtoMessage 

func (*GetGaugesResponse) ProtoMessage()

func (*GetGaugesResponse) Reset 

func (m *GetGaugesResponse) Reset()

func (*GetGaugesResponse) Size 

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

func (*GetGaugesResponse) String 

func (m *GetGaugesResponse) String() string

func (*GetGaugesResponse) Unmarshal 

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

func (*GetGaugesResponse) XXX_DiscardUnknown 

func (m *GetGaugesResponse) XXX_DiscardUnknown()

func (*GetGaugesResponse) XXX_Marshal 

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

func (*GetGaugesResponse) XXX_Merge 

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

func (*GetGaugesResponse) XXX_Size 

func (m *GetGaugesResponse) XXX_Size() int

func (*GetGaugesResponse) XXX_Unmarshal 

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

type GetModuleStatusRequest 

type GetModuleStatusRequest struct {
}

func (*GetModuleStatusRequest) Descriptor 

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

func (*GetModuleStatusRequest) Marshal 

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

func (*GetModuleStatusRequest) MarshalTo 

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

func (*GetModuleStatusRequest) MarshalToSizedBuffer 

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

func (*GetModuleStatusRequest) ProtoMessage 

func (*GetModuleStatusRequest) ProtoMessage()

func (*GetModuleStatusRequest) Reset 

func (m *GetModuleStatusRequest) Reset()

func (*GetModuleStatusRequest) Size 

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

func (*GetModuleStatusRequest) String 

func (m *GetModuleStatusRequest) String() string

func (*GetModuleStatusRequest) Unmarshal 

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

func (*GetModuleStatusRequest) XXX_DiscardUnknown 

func (m *GetModuleStatusRequest) XXX_DiscardUnknown()

func (*GetModuleStatusRequest) XXX_Marshal 

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

func (*GetModuleStatusRequest) XXX_Merge 

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

func (*GetModuleStatusRequest) XXX_Size 

func (m *GetModuleStatusRequest) XXX_Size() int

func (*GetModuleStatusRequest) XXX_Unmarshal 

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

type GetModuleStatusResponse 

type GetModuleStatusResponse struct {
	// Coins that have yet to be distributed
	RewardCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 138-byte string literal not displayed */
	StakedCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 138-byte string literal not displayed */
	Params      Params                                   `protobuf:"bytes,3,opt,name=params,proto3" json:"params"`
}

func (*GetModuleStatusResponse) Descriptor 

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

func (*GetModuleStatusResponse) GetParams 

func (m *GetModuleStatusResponse) GetParams() Params

func (*GetModuleStatusResponse) GetRewardCoins 

func (m *GetModuleStatusResponse) GetRewardCoins() github_com_cosmos_cosmos_sdk_types.Coins

func (*GetModuleStatusResponse) GetStakedCoins 

func (m *GetModuleStatusResponse) GetStakedCoins() github_com_cosmos_cosmos_sdk_types.Coins

func (*GetModuleStatusResponse) Marshal 

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

func (*GetModuleStatusResponse) MarshalTo 

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

func (*GetModuleStatusResponse) MarshalToSizedBuffer 

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

func (*GetModuleStatusResponse) ProtoMessage 

func (*GetModuleStatusResponse) ProtoMessage()

func (*GetModuleStatusResponse) Reset 

func (m *GetModuleStatusResponse) Reset()

func (*GetModuleStatusResponse) Size 

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

func (*GetModuleStatusResponse) String 

func (m *GetModuleStatusResponse) String() string

func (*GetModuleStatusResponse) Unmarshal 

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

func (*GetModuleStatusResponse) XXX_DiscardUnknown 

func (m *GetModuleStatusResponse) XXX_DiscardUnknown()

func (*GetModuleStatusResponse) XXX_Marshal 

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

func (*GetModuleStatusResponse) XXX_Merge 

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

func (*GetModuleStatusResponse) XXX_Size 

func (m *GetModuleStatusResponse) XXX_Size() int

func (*GetModuleStatusResponse) XXX_Unmarshal 

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

type GetStakeByIDRequest 

type GetStakeByIDRequest struct {
	StakeId uint64 `protobuf:"varint,1,opt,name=stake_id,json=stakeId,proto3" json:"stake_id,omitempty"`
}

func (*GetStakeByIDRequest) Descriptor 

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

func (*GetStakeByIDRequest) GetStakeId 

func (m *GetStakeByIDRequest) GetStakeId() uint64

func (*GetStakeByIDRequest) Marshal 

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

func (*GetStakeByIDRequest) MarshalTo 

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

func (*GetStakeByIDRequest) MarshalToSizedBuffer 

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

func (*GetStakeByIDRequest) ProtoMessage 

func (*GetStakeByIDRequest) ProtoMessage()

func (*GetStakeByIDRequest) Reset 

func (m *GetStakeByIDRequest) Reset()

func (*GetStakeByIDRequest) Size 

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

func (*GetStakeByIDRequest) String 

func (m *GetStakeByIDRequest) String() string

func (*GetStakeByIDRequest) Unmarshal 

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

func (*GetStakeByIDRequest) XXX_DiscardUnknown 

func (m *GetStakeByIDRequest) XXX_DiscardUnknown()

func (*GetStakeByIDRequest) XXX_Marshal 

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

func (*GetStakeByIDRequest) XXX_Merge 

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

func (*GetStakeByIDRequest) XXX_Size 

func (m *GetStakeByIDRequest) XXX_Size() int

func (*GetStakeByIDRequest) XXX_Unmarshal 

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

type GetStakeByIDResponse 

type GetStakeByIDResponse struct {
	Stake *Stake `protobuf:"bytes,1,opt,name=stake,proto3" json:"stake,omitempty"`
}

func (*GetStakeByIDResponse) Descriptor 

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

func (*GetStakeByIDResponse) GetStake 

func (m *GetStakeByIDResponse) GetStake() *Stake

func (*GetStakeByIDResponse) Marshal 

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

func (*GetStakeByIDResponse) MarshalTo 

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

func (*GetStakeByIDResponse) MarshalToSizedBuffer 

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

func (*GetStakeByIDResponse) ProtoMessage 

func (*GetStakeByIDResponse) ProtoMessage()

func (*GetStakeByIDResponse) Reset 

func (m *GetStakeByIDResponse) Reset()

func (*GetStakeByIDResponse) Size 

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

func (*GetStakeByIDResponse) String 

func (m *GetStakeByIDResponse) String() string

func (*GetStakeByIDResponse) Unmarshal 

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

func (*GetStakeByIDResponse) XXX_DiscardUnknown 

func (m *GetStakeByIDResponse) XXX_DiscardUnknown()

func (*GetStakeByIDResponse) XXX_Marshal 

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

func (*GetStakeByIDResponse) XXX_Merge 

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

func (*GetStakeByIDResponse) XXX_Size 

func (m *GetStakeByIDResponse) XXX_Size() int

func (*GetStakeByIDResponse) XXX_Unmarshal 

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

type GetStakesRequest 

type GetStakesRequest struct {
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty" yaml:"owner"`
}

func (*GetStakesRequest) Descriptor 

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

func (*GetStakesRequest) GetOwner 

func (m *GetStakesRequest) GetOwner() string

func (*GetStakesRequest) Marshal 

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

func (*GetStakesRequest) MarshalTo 

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

func (*GetStakesRequest) MarshalToSizedBuffer 

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

func (*GetStakesRequest) ProtoMessage 

func (*GetStakesRequest) ProtoMessage()

func (*GetStakesRequest) Reset 

func (m *GetStakesRequest) Reset()

func (*GetStakesRequest) Size 

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

func (*GetStakesRequest) String 

func (m *GetStakesRequest) String() string

func (*GetStakesRequest) Unmarshal 

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

func (*GetStakesRequest) XXX_DiscardUnknown 

func (m *GetStakesRequest) XXX_DiscardUnknown()

func (*GetStakesRequest) XXX_Marshal 

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

func (*GetStakesRequest) XXX_Merge 

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

func (*GetStakesRequest) XXX_Size 

func (m *GetStakesRequest) XXX_Size() int

func (*GetStakesRequest) XXX_Unmarshal 

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

type GetStakesResponse 

type GetStakesResponse struct {
	Stakes []*Stake `protobuf:"bytes,1,rep,name=stakes,proto3" json:"stakes,omitempty"`
}

func (*GetStakesResponse) Descriptor 

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

func (*GetStakesResponse) GetStakes 

func (m *GetStakesResponse) GetStakes() []*Stake

func (*GetStakesResponse) Marshal 

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

func (*GetStakesResponse) MarshalTo 

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

func (*GetStakesResponse) MarshalToSizedBuffer 

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

func (*GetStakesResponse) ProtoMessage 

func (*GetStakesResponse) ProtoMessage()

func (*GetStakesResponse) Reset 

func (m *GetStakesResponse) Reset()

func (*GetStakesResponse) Size 

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

func (*GetStakesResponse) String 

func (m *GetStakesResponse) String() string

func (*GetStakesResponse) Unmarshal 

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

func (*GetStakesResponse) XXX_DiscardUnknown 

func (m *GetStakesResponse) XXX_DiscardUnknown()

func (*GetStakesResponse) XXX_Marshal 

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

func (*GetStakesResponse) XXX_Merge 

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

func (*GetStakesResponse) XXX_Size 

func (m *GetStakesResponse) XXX_Size() int

func (*GetStakesResponse) XXX_Unmarshal 

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

type IncentiveHooks 

type IncentiveHooks interface {
	AfterCreateGauge(ctx sdk.Context, gaugeId uint64)
	AfterAddToGauge(ctx sdk.Context, gaugeId uint64)
	AfterStartDistribution(ctx sdk.Context, gaugeId uint64)
	AfterFinishDistribution(ctx sdk.Context, gaugeId uint64)
	AfterEpochDistribution(ctx sdk.Context)
	AfterAddTokensToStake(ctx sdk.Context, address sdk.AccAddress, stakeID uint64, amount sdk.Coins)
	OnTokenStaked(ctx sdk.Context, address sdk.AccAddress, stakeID uint64, amount sdk.Coins, unstakeTime time.Time)
	OnTokenUnstaked(ctx sdk.Context, address sdk.AccAddress, stakeID uint64, amount sdk.Coins, unstakeTime time.Time)
}

type MsgAddToGauge 

type MsgAddToGauge struct {
	// owner is the gauge owner's address
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty" yaml:"owner"`
	// gauge_id is the ID of gauge that rewards are getting added to
	GaugeId uint64 `protobuf:"varint,2,opt,name=gauge_id,json=gaugeId,proto3" json:"gauge_id,omitempty"`
	// rewards are the coin(s) to add to gauge
	Rewards github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,3,rep,name=rewards,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"rewards"`
}

MsgAddToGauge adds coins to a previously created gauge

func NewMsgAddToGauge 

func NewMsgAddToGauge(owner sdk.AccAddress, gaugeID uint64, rewards sdk.Coins) *MsgAddToGauge

NewMsgAddToGauge creates a message to add rewards to a specific gauge.

func (*MsgAddToGauge) Descriptor 

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

func (*MsgAddToGauge) GetGaugeId 

func (m *MsgAddToGauge) GetGaugeId() uint64

func (*MsgAddToGauge) GetOwner 

func (m *MsgAddToGauge) GetOwner() string

func (*MsgAddToGauge) GetRewards 

func (m *MsgAddToGauge) GetRewards() github_com_cosmos_cosmos_sdk_types.Coins

func (MsgAddToGauge) GetSignBytes 

func (m MsgAddToGauge) GetSignBytes() []byte

GetSignBytes takes an add to gauge message and turns it into a byte array.

func (MsgAddToGauge) GetSigners 

func (m MsgAddToGauge) GetSigners() []sdk.AccAddress

GetSigners takes an add to gauge message and returns the owner in a byte array.

func (*MsgAddToGauge) Marshal 

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

func (*MsgAddToGauge) MarshalTo 

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

func (*MsgAddToGauge) MarshalToSizedBuffer 

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

func (*MsgAddToGauge) ProtoMessage 

func (*MsgAddToGauge) ProtoMessage()

func (*MsgAddToGauge) Reset 

func (m *MsgAddToGauge) Reset()

func (MsgAddToGauge) Route 

func (m MsgAddToGauge) Route() string

Route takes an add to gauge message, then returns the RouterKey used for slashing.

func (*MsgAddToGauge) Size 

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

func (*MsgAddToGauge) String 

func (m *MsgAddToGauge) String() string

func (MsgAddToGauge) Type 

func (m MsgAddToGauge) Type() string

Type takes an add to gauge message, then returns an add to gauge message type.

func (*MsgAddToGauge) Unmarshal 

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

func (MsgAddToGauge) ValidateBasic 

func (m MsgAddToGauge) ValidateBasic() error

ValidateBasic checks that the add to gauge message is valid.

func (*MsgAddToGauge) XXX_DiscardUnknown 

func (m *MsgAddToGauge) XXX_DiscardUnknown()

func (*MsgAddToGauge) XXX_Marshal 

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

func (*MsgAddToGauge) XXX_Merge 

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

func (*MsgAddToGauge) XXX_Size 

func (m *MsgAddToGauge) XXX_Size() int

func (*MsgAddToGauge) XXX_Unmarshal 

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

type MsgAddToGaugeResponse 

type MsgAddToGaugeResponse struct {
}

func (*MsgAddToGaugeResponse) Descriptor 

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

func (*MsgAddToGaugeResponse) Marshal 

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

func (*MsgAddToGaugeResponse) MarshalTo 

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

func (*MsgAddToGaugeResponse) MarshalToSizedBuffer 

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

func (*MsgAddToGaugeResponse) ProtoMessage 

func (*MsgAddToGaugeResponse) ProtoMessage()

func (*MsgAddToGaugeResponse) Reset 

func (m *MsgAddToGaugeResponse) Reset()

func (*MsgAddToGaugeResponse) Size 

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

func (*MsgAddToGaugeResponse) String 

func (m *MsgAddToGaugeResponse) String() string

func (*MsgAddToGaugeResponse) Unmarshal 

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

func (*MsgAddToGaugeResponse) XXX_DiscardUnknown 

func (m *MsgAddToGaugeResponse) XXX_DiscardUnknown()

func (*MsgAddToGaugeResponse) XXX_Marshal 

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

func (*MsgAddToGaugeResponse) XXX_Merge 

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

func (*MsgAddToGaugeResponse) XXX_Size 

func (m *MsgAddToGaugeResponse) XXX_Size() int

func (*MsgAddToGaugeResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// Create an incentive program
	CreateGauge(ctx context.Context, in *MsgCreateGauge, opts ...grpc.CallOption) (*MsgCreateGaugeResponse, error)
	// Add rewards to an existing incentives program
	AddToGauge(ctx context.Context, in *MsgAddToGauge, opts ...grpc.CallOption) (*MsgAddToGaugeResponse, error)
	// Deposit LP tokens to the module, qualifying for rewards from gauges
	Stake(ctx context.Context, in *MsgStake, opts ...grpc.CallOption) (*MsgStakeResponse, error)
	// Withdraw LP tokens from the module, forfeiting future rewards from gauges
	Unstake(ctx context.Context, in *MsgUnstake, opts ...grpc.CallOption) (*MsgUnstakeResponse, 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 MsgCreateGauge 

type MsgCreateGauge struct {
	// is_perpetual shows if it's a perpetual or non-perpetual gauge
	// Non-perpetual gauges distribute their tokens equally per epoch while the
	// gauge is in the active period. Perpetual gauges distribute all their tokens
	// at a single time and only distribute their tokens again once the gauge is
	// refilled
	IsPerpetual bool `protobuf:"varint,1,opt,name=is_perpetual,json=isPerpetual,proto3" json:"is_perpetual,omitempty"`
	// owner is the address of gauge creator, should be the module authority
	Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty" yaml:"owner"`
	// distribute_to show which lock the gauge should distribute to by time
	// duration or by timestamp
	DistributeTo QueryCondition `protobuf:"bytes,3,opt,name=distribute_to,json=distributeTo,proto3" json:"distribute_to"`
	// coins are coin(s) to be distributed by the gauge
	Coins github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,4,rep,name=coins,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"coins"`
	// start_time is the distribution start time
	StartTime time.Time `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time" yaml:"timestamp"`
	// num_epochs_paid_over is the number of epochs distribution will be completed
	// over
	NumEpochsPaidOver uint64 `protobuf:"varint,6,opt,name=num_epochs_paid_over,json=numEpochsPaidOver,proto3" json:"num_epochs_paid_over,omitempty"`
	// pricing_tick is the price that liquidity within the gauge range will be priced at
	PricingTick int64 `protobuf:"varint,7,opt,name=pricing_tick,json=pricingTick,proto3" json:"pricing_tick,omitempty"`
}

MsgCreateGauge creates a gague to distribute rewards to users

func NewMsgCreateGauge 

func NewMsgCreateGauge(
	isPerpetual bool,
	owner sdk.AccAddress,
	distributeTo QueryCondition,
	coins sdk.Coins,
	startTime time.Time,
	numEpochsPaidOver uint64,
	pricingTick int64,
) *MsgCreateGauge

NewMsgCreateGauge creates a message to create a gauge with the provided parameters.

func (*MsgCreateGauge) Descriptor 

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

func (*MsgCreateGauge) GetCoins 

func (m *MsgCreateGauge) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins

func (*MsgCreateGauge) GetDistributeTo 

func (m *MsgCreateGauge) GetDistributeTo() QueryCondition

func (*MsgCreateGauge) GetIsPerpetual 

func (m *MsgCreateGauge) GetIsPerpetual() bool

func (*MsgCreateGauge) GetNumEpochsPaidOver 

func (m *MsgCreateGauge) GetNumEpochsPaidOver() uint64

func (*MsgCreateGauge) GetOwner 

func (m *MsgCreateGauge) GetOwner() string

func (*MsgCreateGauge) GetPricingTick 

func (m *MsgCreateGauge) GetPricingTick() int64

func (MsgCreateGauge) GetSignBytes 

func (m MsgCreateGauge) GetSignBytes() []byte

GetSignBytes takes a create gauge message and turns it into a byte array.

func (MsgCreateGauge) GetSigners 

func (m MsgCreateGauge) GetSigners() []sdk.AccAddress

GetSigners takes a create gauge message and returns the owner in a byte array.

func (*MsgCreateGauge) GetStartTime 

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

func (*MsgCreateGauge) Marshal 

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

func (*MsgCreateGauge) MarshalTo 

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

func (*MsgCreateGauge) MarshalToSizedBuffer 

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

func (*MsgCreateGauge) ProtoMessage 

func (*MsgCreateGauge) ProtoMessage()

func (*MsgCreateGauge) Reset 

func (m *MsgCreateGauge) Reset()

func (MsgCreateGauge) Route 

func (m MsgCreateGauge) Route() string

Route takes a create gauge message, then returns the RouterKey used for slashing.

func (*MsgCreateGauge) Size 

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

func (*MsgCreateGauge) String 

func (m *MsgCreateGauge) String() string

func (MsgCreateGauge) Type 

func (m MsgCreateGauge) Type() string

Type takes a create gauge message, then returns a create gauge message type.

func (*MsgCreateGauge) Unmarshal 

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

func (MsgCreateGauge) ValidateBasic 

func (m MsgCreateGauge) ValidateBasic() error

ValidateBasic checks that the create gauge message is valid.

func (*MsgCreateGauge) XXX_DiscardUnknown 

func (m *MsgCreateGauge) XXX_DiscardUnknown()

func (*MsgCreateGauge) XXX_Marshal 

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

func (*MsgCreateGauge) XXX_Merge 

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

func (*MsgCreateGauge) XXX_Size 

func (m *MsgCreateGauge) XXX_Size() int

func (*MsgCreateGauge) XXX_Unmarshal 

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

type MsgCreateGaugeResponse 

type MsgCreateGaugeResponse struct {
}

func (*MsgCreateGaugeResponse) Descriptor 

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

func (*MsgCreateGaugeResponse) Marshal 

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

func (*MsgCreateGaugeResponse) MarshalTo 

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

func (*MsgCreateGaugeResponse) MarshalToSizedBuffer 

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

func (*MsgCreateGaugeResponse) ProtoMessage 

func (*MsgCreateGaugeResponse) ProtoMessage()

func (*MsgCreateGaugeResponse) Reset 

func (m *MsgCreateGaugeResponse) Reset()

func (*MsgCreateGaugeResponse) Size 

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

func (*MsgCreateGaugeResponse) String 

func (m *MsgCreateGaugeResponse) String() string

func (*MsgCreateGaugeResponse) Unmarshal 

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

func (*MsgCreateGaugeResponse) XXX_DiscardUnknown 

func (m *MsgCreateGaugeResponse) XXX_DiscardUnknown()

func (*MsgCreateGaugeResponse) XXX_Marshal 

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

func (*MsgCreateGaugeResponse) XXX_Merge 

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

func (*MsgCreateGaugeResponse) XXX_Size 

func (m *MsgCreateGaugeResponse) XXX_Size() int

func (*MsgCreateGaugeResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// Create an incentive program
	CreateGauge(context.Context, *MsgCreateGauge) (*MsgCreateGaugeResponse, error)
	// Add rewards to an existing incentives program
	AddToGauge(context.Context, *MsgAddToGauge) (*MsgAddToGaugeResponse, error)
	// Deposit LP tokens to the module, qualifying for rewards from gauges
	Stake(context.Context, *MsgStake) (*MsgStakeResponse, error)
	// Withdraw LP tokens from the module, forfeiting future rewards from gauges
	Unstake(context.Context, *MsgUnstake) (*MsgUnstakeResponse, error)
}

MsgServer is the server API for Msg service.

type MsgStake 

type MsgStake struct {
	Owner string                                   `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty" yaml:"owner"`
	Coins github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,2,rep,name=coins,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"coins"`
}

func NewMsgSetupStake 

func NewMsgSetupStake(owner sdk.AccAddress, duration time.Duration, coins sdk.Coins) *MsgStake

NewMsgStakeTokens creates a message to stake tokens.

func (*MsgStake) Descriptor 

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

func (*MsgStake) GetCoins 

func (m *MsgStake) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins

func (*MsgStake) GetOwner 

func (m *MsgStake) GetOwner() string

func (MsgStake) GetSignBytes 

func (m MsgStake) GetSignBytes() []byte

func (MsgStake) GetSigners 

func (m MsgStake) GetSigners() []sdk.AccAddress

func (*MsgStake) Marshal 

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

func (*MsgStake) MarshalTo 

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

func (*MsgStake) MarshalToSizedBuffer 

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

func (*MsgStake) ProtoMessage 

func (*MsgStake) ProtoMessage()

func (*MsgStake) Reset 

func (m *MsgStake) Reset()

func (MsgStake) Route 

func (m MsgStake) Route() string

func (*MsgStake) Size 

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

func (*MsgStake) String 

func (m *MsgStake) String() string

func (MsgStake) Type 

func (m MsgStake) Type() string

func (*MsgStake) Unmarshal 

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

func (MsgStake) ValidateBasic 

func (m MsgStake) ValidateBasic() error

func (*MsgStake) XXX_DiscardUnknown 

func (m *MsgStake) XXX_DiscardUnknown()

func (*MsgStake) XXX_Marshal 

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

func (*MsgStake) XXX_Merge 

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

func (*MsgStake) XXX_Size 

func (m *MsgStake) XXX_Size() int

func (*MsgStake) XXX_Unmarshal 

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

type MsgStakeResponse 

type MsgStakeResponse struct {
	ID uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
}

func (*MsgStakeResponse) Descriptor 

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

func (*MsgStakeResponse) GetID 

func (m *MsgStakeResponse) GetID() uint64

func (*MsgStakeResponse) Marshal 

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

func (*MsgStakeResponse) MarshalTo 

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

func (*MsgStakeResponse) MarshalToSizedBuffer 

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

func (*MsgStakeResponse) ProtoMessage 

func (*MsgStakeResponse) ProtoMessage()

func (*MsgStakeResponse) Reset 

func (m *MsgStakeResponse) Reset()

func (*MsgStakeResponse) Size 

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

func (*MsgStakeResponse) String 

func (m *MsgStakeResponse) String() string

func (*MsgStakeResponse) Unmarshal 

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

func (*MsgStakeResponse) XXX_DiscardUnknown 

func (m *MsgStakeResponse) XXX_DiscardUnknown()

func (*MsgStakeResponse) XXX_Marshal 

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

func (*MsgStakeResponse) XXX_Merge 

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

func (*MsgStakeResponse) XXX_Size 

func (m *MsgStakeResponse) XXX_Size() int

func (*MsgStakeResponse) XXX_Unmarshal 

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

type MsgUnstake 

type MsgUnstake struct {
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty" yaml:"owner"`
	// If unstake is left empty, this is interpreted as "unstake all"
	Unstakes []*MsgUnstake_UnstakeDescriptor `protobuf:"bytes,2,rep,name=unstakes,proto3" json:"unstakes,omitempty"`
}

func NewMsgUnstake 

func NewMsgUnstake(owner sdk.AccAddress, unstakes []*MsgUnstake_UnstakeDescriptor) *MsgUnstake

NewMsgUnstake creates a message to unstake the tokens of a set of stake records.

func (*MsgUnstake) Descriptor 

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

func (*MsgUnstake) GetOwner 

func (m *MsgUnstake) GetOwner() string

func (MsgUnstake) GetSignBytes 

func (m MsgUnstake) GetSignBytes() []byte

func (MsgUnstake) GetSigners 

func (m MsgUnstake) GetSigners() []sdk.AccAddress

func (*MsgUnstake) GetUnstakes 

func (m *MsgUnstake) GetUnstakes() []*MsgUnstake_UnstakeDescriptor

func (*MsgUnstake) Marshal 

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

func (*MsgUnstake) MarshalTo 

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

func (*MsgUnstake) MarshalToSizedBuffer 

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

func (*MsgUnstake) ProtoMessage 

func (*MsgUnstake) ProtoMessage()

func (*MsgUnstake) Reset 

func (m *MsgUnstake) Reset()

func (MsgUnstake) Route 

func (m MsgUnstake) Route() string

func (*MsgUnstake) Size 

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

func (*MsgUnstake) String 

func (m *MsgUnstake) String() string

func (MsgUnstake) Type 

func (m MsgUnstake) Type() string

func (*MsgUnstake) Unmarshal 

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

func (MsgUnstake) ValidateBasic 

func (m MsgUnstake) ValidateBasic() error

func (*MsgUnstake) XXX_DiscardUnknown 

func (m *MsgUnstake) XXX_DiscardUnknown()

func (*MsgUnstake) XXX_Marshal 

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

func (*MsgUnstake) XXX_Merge 

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

func (*MsgUnstake) XXX_Size 

func (m *MsgUnstake) XXX_Size() int

func (*MsgUnstake) XXX_Unmarshal 

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

type MsgUnstakeResponse 

type MsgUnstakeResponse struct {
}

func (*MsgUnstakeResponse) Descriptor 

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

func (*MsgUnstakeResponse) Marshal 

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

func (*MsgUnstakeResponse) MarshalTo 

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

func (*MsgUnstakeResponse) MarshalToSizedBuffer 

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

func (*MsgUnstakeResponse) ProtoMessage 

func (*MsgUnstakeResponse) ProtoMessage()

func (*MsgUnstakeResponse) Reset 

func (m *MsgUnstakeResponse) Reset()

func (*MsgUnstakeResponse) Size 

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

func (*MsgUnstakeResponse) String 

func (m *MsgUnstakeResponse) String() string

func (*MsgUnstakeResponse) Unmarshal 

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

func (*MsgUnstakeResponse) XXX_DiscardUnknown 

func (m *MsgUnstakeResponse) XXX_DiscardUnknown()

func (*MsgUnstakeResponse) XXX_Marshal 

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

func (*MsgUnstakeResponse) XXX_Merge 

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

func (*MsgUnstakeResponse) XXX_Size 

func (m *MsgUnstakeResponse) XXX_Size() int

func (*MsgUnstakeResponse) XXX_Unmarshal 

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

type MsgUnstake_UnstakeDescriptor 

type MsgUnstake_UnstakeDescriptor struct {
	ID    uint64                                   `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Coins github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,2,rep,name=coins,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"coins"`
}

func NewMsgUnstakeDescriptor 

func NewMsgUnstakeDescriptor(id uint64, coins sdk.Coins) *MsgUnstake_UnstakeDescriptor

func (*MsgUnstake_UnstakeDescriptor) Descriptor 

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

func (*MsgUnstake_UnstakeDescriptor) GetCoins 

func (m *MsgUnstake_UnstakeDescriptor) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins

func (*MsgUnstake_UnstakeDescriptor) GetID 

func (m *MsgUnstake_UnstakeDescriptor) GetID() uint64

func (*MsgUnstake_UnstakeDescriptor) Marshal 

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

func (*MsgUnstake_UnstakeDescriptor) MarshalTo 

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

func (*MsgUnstake_UnstakeDescriptor) MarshalToSizedBuffer 

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

func (*MsgUnstake_UnstakeDescriptor) ProtoMessage 

func (*MsgUnstake_UnstakeDescriptor) ProtoMessage()

func (*MsgUnstake_UnstakeDescriptor) Reset 

func (m *MsgUnstake_UnstakeDescriptor) Reset()

func (*MsgUnstake_UnstakeDescriptor) Size 

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

func (*MsgUnstake_UnstakeDescriptor) String 

func (m *MsgUnstake_UnstakeDescriptor) String() string

func (*MsgUnstake_UnstakeDescriptor) Unmarshal 

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

func (*MsgUnstake_UnstakeDescriptor) XXX_DiscardUnknown 

func (m *MsgUnstake_UnstakeDescriptor) XXX_DiscardUnknown()

func (*MsgUnstake_UnstakeDescriptor) XXX_Marshal 

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

func (*MsgUnstake_UnstakeDescriptor) XXX_Merge 

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

func (*MsgUnstake_UnstakeDescriptor) XXX_Size 

func (m *MsgUnstake_UnstakeDescriptor) XXX_Size() int

func (*MsgUnstake_UnstakeDescriptor) XXX_Unmarshal 

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

type MultiIncentiveHooks 

type MultiIncentiveHooks []IncentiveHooks

MultiIncentiveHooks combines multiple incentive hooks. All hook functions are run in array sequence.

func NewMultiIncentiveHooks 

func NewMultiIncentiveHooks(hooks ...IncentiveHooks) MultiIncentiveHooks

NewMultiIncentiveHooks combines multiple incentive hooks into a single IncentiveHooks array.

func (MultiIncentiveHooks) AfterAddToGauge 

func (h MultiIncentiveHooks) AfterAddToGauge(ctx sdk.Context, gaugeID uint64)

func (MultiIncentiveHooks) AfterAddTokensToStake 

func (h MultiIncentiveHooks) AfterAddTokensToStake(ctx sdk.Context, address sdk.AccAddress, stakeID uint64, amount sdk.Coins)

func (MultiIncentiveHooks) AfterCreateGauge 

func (h MultiIncentiveHooks) AfterCreateGauge(ctx sdk.Context, gaugeID uint64)

func (MultiIncentiveHooks) AfterEpochDistribution 

func (h MultiIncentiveHooks) AfterEpochDistribution(ctx sdk.Context)

func (MultiIncentiveHooks) AfterFinishDistribution 

func (h MultiIncentiveHooks) AfterFinishDistribution(ctx sdk.Context, gaugeID uint64)

func (MultiIncentiveHooks) AfterStartDistribution 

func (h MultiIncentiveHooks) AfterStartDistribution(ctx sdk.Context, gaugeID uint64)

func (MultiIncentiveHooks) OnTokenStaked 

func (h MultiIncentiveHooks) OnTokenStaked(ctx sdk.Context, address sdk.AccAddress, stakeID uint64, amount sdk.Coins, unstakeTime time.Time)

func (MultiIncentiveHooks) OnTokenUnstaked 

func (h MultiIncentiveHooks) OnTokenUnstaked(ctx sdk.Context, address sdk.AccAddress, stakeID uint64, amount sdk.Coins, unstakeTime time.Time)

type Params 

type Params struct {
	// distr_epoch_identifier is what epoch type distribution will be triggered by
	// (day, week, etc.)
	DistrEpochIdentifier string `` /* 153-byte string literal not displayed */
	MaxGauges            uint64 `protobuf:"varint,2,opt,name=max_gauges,json=maxGauges,proto3" json:"max_gauges,omitempty" yaml:"max_gauges"`
}

Params holds parameters for the incentives module

func DefaultParams 

func DefaultParams() Params

DefaultParams returns the default incentives module parameters.

func NewParams 

func NewParams(distrEpochIdentifier string, maxGauges uint64) Params

NewParams takes an epoch distribution identifier, then returns an incentives Params struct.

func (*Params) Descriptor 

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

func (*Params) GetDistrEpochIdentifier 

func (m *Params) GetDistrEpochIdentifier() string

func (*Params) GetMaxGauges 

func (m *Params) GetMaxGauges() uint64

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

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

ParamSetPairs takes the parameter struct and associates the paramsubspace key and field of the parameters as a KVStore.

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 checks that the incentives module parameters are valid.

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 QueryClient 

type QueryClient interface {
	// GetModuleStatus returns a rundown of coins in the module and their status
	GetModuleStatus(ctx context.Context, in *GetModuleStatusRequest, opts ...grpc.CallOption) (*GetModuleStatusResponse, error)
	// GetGaugeByID returns a gauge by its ID
	GetGaugeByID(ctx context.Context, in *GetGaugeByIDRequest, opts ...grpc.CallOption) (*GetGaugeByIDResponse, error)
	// GetGauges returns gauges according to the filter provided
	GetGauges(ctx context.Context, in *GetGaugesRequest, opts ...grpc.CallOption) (*GetGaugesResponse, error)
	// GetStakeByID returns a stake by its ID
	GetStakeByID(ctx context.Context, in *GetStakeByIDRequest, opts ...grpc.CallOption) (*GetStakeByIDResponse, error)
	// GetStakes returns stakes by the filter provided. At least one filter must be provided.
	GetStakes(ctx context.Context, in *GetStakesRequest, opts ...grpc.CallOption) (*GetStakesResponse, error)
	// GetFutureRewardsEstimate returns an estimate of the rewards from now until a specified
	// time in the future. The requestor either provides an address or a set of locks
	// for which they want to find the associated rewards.
	GetFutureRewardEstimate(ctx context.Context, in *GetFutureRewardEstimateRequest, opts ...grpc.CallOption) (*GetFutureRewardEstimateResponse, error)
	// GetAccountHistory returns the total accumulated rewards per denom for a given user.
	GetAccountHistory(ctx context.Context, in *GetAccountHistoryRequest, opts ...grpc.CallOption) (*GetAccountHistoryResponse, error)
	// Returns the total amount of value currently qualifying for the gauge. This is useful for calculating
	// the prospective future rewards of staking.
	GetGaugeQualifyingValue(ctx context.Context, in *GetGaugeQualifyingValueRequest, opts ...grpc.CallOption) (*GetGaugeQualifyingValueResponse, 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 QueryCondition 

type QueryCondition struct {
	// pairID is the token pair which should be distributed to.
	PairID *types1.PairID `protobuf:"bytes,1,opt,name=pairID,proto3" json:"pairID,omitempty"`
	// start_tick is the inclusive lower bound on the location of LP tokens that
	// qualify for a gauge's distribution.
	StartTick int64 `protobuf:"varint,2,opt,name=startTick,proto3" json:"startTick,omitempty"`
	// end_tick is the inclusive upper bound on the location of LP tokens that
	// qualify for a gauge's distribution.
	EndTick int64 `protobuf:"varint,3,opt,name=endTick,proto3" json:"endTick,omitempty"`
}

QueryCondition describes a set of staked LP positions that a gauge is configured to distribute to. LP tokens qualifying for a given QueryCondition must have both tick-fee and tick+fee fall within the range [startTick, endTick], such that all of the tradable liquidity for the pool is within that range.

func (*QueryCondition) Descriptor 

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

func (*QueryCondition) GetEndTick 

func (m *QueryCondition) GetEndTick() int64

func (*QueryCondition) GetPairID 

func (m *QueryCondition) GetPairID() *types1.PairID

func (*QueryCondition) GetStartTick 

func (m *QueryCondition) GetStartTick() int64

func (*QueryCondition) Marshal 

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

func (*QueryCondition) MarshalTo 

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

func (*QueryCondition) MarshalToSizedBuffer 

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

func (*QueryCondition) ProtoMessage 

func (*QueryCondition) ProtoMessage()

func (*QueryCondition) Reset 

func (m *QueryCondition) Reset()

func (*QueryCondition) Size 

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

func (*QueryCondition) String 

func (m *QueryCondition) String() string

func (QueryCondition) Test 

func (qc QueryCondition) Test(denom string) bool

func (*QueryCondition) Unmarshal 

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

func (*QueryCondition) XXX_DiscardUnknown 

func (m *QueryCondition) XXX_DiscardUnknown()

func (*QueryCondition) XXX_Marshal 

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

func (*QueryCondition) XXX_Merge 

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

func (*QueryCondition) XXX_Size 

func (m *QueryCondition) XXX_Size() int

func (*QueryCondition) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// GetModuleStatus returns a rundown of coins in the module and their status
	GetModuleStatus(context.Context, *GetModuleStatusRequest) (*GetModuleStatusResponse, error)
	// GetGaugeByID returns a gauge by its ID
	GetGaugeByID(context.Context, *GetGaugeByIDRequest) (*GetGaugeByIDResponse, error)
	// GetGauges returns gauges according to the filter provided
	GetGauges(context.Context, *GetGaugesRequest) (*GetGaugesResponse, error)
	// GetStakeByID returns a stake by its ID
	GetStakeByID(context.Context, *GetStakeByIDRequest) (*GetStakeByIDResponse, error)
	// GetStakes returns stakes by the filter provided. At least one filter must be provided.
	GetStakes(context.Context, *GetStakesRequest) (*GetStakesResponse, error)
	// GetFutureRewardsEstimate returns an estimate of the rewards from now until a specified
	// time in the future. The requestor either provides an address or a set of locks
	// for which they want to find the associated rewards.
	GetFutureRewardEstimate(context.Context, *GetFutureRewardEstimateRequest) (*GetFutureRewardEstimateResponse, error)
	// GetAccountHistory returns the total accumulated rewards per denom for a given user.
	GetAccountHistory(context.Context, *GetAccountHistoryRequest) (*GetAccountHistoryResponse, error)
	// Returns the total amount of value currently qualifying for the gauge. This is useful for calculating
	// the prospective future rewards of staking.
	GetGaugeQualifyingValue(context.Context, *GetGaugeQualifyingValueRequest) (*GetGaugeQualifyingValueResponse, error)
}

QueryServer is the server API for Query service.

type Stake 

type Stake struct {
	// ID is the "autoincrementing" id of the stake, assigned at creation.
	ID uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// owner is the account originating the stake. Only the owner can withdraw
	// coins from the stake.
	Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty" yaml:"owner"`
	// start_time is the time at which the coins in the lock were staked.
	StartTime time.Time `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time,omitempty" yaml:"start_time"`
	// coins are the tokens staked, and managed by the module account.
	Coins github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,4,rep,name=coins,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"coins"`
	// start_dist_epoch is the dist epoch (defaulting to the day) at which the
	// coins in the lock were staked. This is used by distribution logic to filter
	// on stakes that have existed for longer than the distribution period (you
	// can only qualify for today's rewards if you staked your LP tokens
	// yesterday). We use int64 instead of uint64 to make testing easier.
	StartDistEpoch int64 `protobuf:"varint,5,opt,name=start_dist_epoch,json=startDistEpoch,proto3" json:"start_dist_epoch,omitempty"`
}

Stake records what coins are staked when by who for the purpose of calculating gauge reward distributions.

func NewStake 

func NewStake(
	id uint64,
	owner sdk.AccAddress,
	coins sdk.Coins,
	startTime time.Time,
	startDistEpoch int64,
) *Stake

NewStake returns a new instance of period stake.

func (Stake) CoinsPassingQueryCondition 

func (p Stake) CoinsPassingQueryCondition(distrTo QueryCondition) sdk.Coins

func (*Stake) Descriptor 

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

func (*Stake) GetCoins 

func (m *Stake) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins

func (*Stake) GetID 

func (m *Stake) GetID() uint64

func (*Stake) GetOwner 

func (m *Stake) GetOwner() string

func (*Stake) GetStartDistEpoch added in v0.3.4 

func (m *Stake) GetStartDistEpoch() int64

func (*Stake) GetStartTime 

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

func (*Stake) Marshal 

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

func (*Stake) MarshalTo 

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

func (*Stake) MarshalToSizedBuffer 

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

func (Stake) OwnerAddress 

func (p Stake) OwnerAddress() sdk.AccAddress

OwnerAddress returns stakes owner address.

func (*Stake) ProtoMessage 

func (*Stake) ProtoMessage()

func (*Stake) Reset 

func (m *Stake) Reset()

func (Stake) SingleCoin 

func (p Stake) SingleCoin() (sdk.Coin, error)

func (*Stake) Size 

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

func (*Stake) String 

func (m *Stake) String() string

func (*Stake) Unmarshal 

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

func (Stake) ValidateBasic 

func (p Stake) ValidateBasic() error

func (*Stake) XXX_DiscardUnknown 

func (m *Stake) XXX_DiscardUnknown()

func (*Stake) XXX_Marshal 

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

func (*Stake) XXX_Merge 

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

func (*Stake) XXX_Size 

func (m *Stake) XXX_Size() int

func (*Stake) XXX_Unmarshal 

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

type StakeI 

type StakeI interface {
	GetOwner() string
	Amount() sdk.Coins
}

type Stakes 

type Stakes []*Stake

func CombineStakes 

func CombineStakes(pl1 Stakes, pl2 Stakes) Stakes

func (Stakes) CoinsByQueryCondition 

func (stakes Stakes) CoinsByQueryCondition(distrTo QueryCondition) sdk.Coins

func (Stakes) GetCoins 

func (stakes Stakes) GetCoins() sdk.Coins

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) AddToGauge 

func (*UnimplementedMsgServer) AddToGauge(ctx context.Context, req *MsgAddToGauge) (*MsgAddToGaugeResponse, error)

func (*UnimplementedMsgServer) CreateGauge 

func (*UnimplementedMsgServer) CreateGauge(ctx context.Context, req *MsgCreateGauge) (*MsgCreateGaugeResponse, error)

func (*UnimplementedMsgServer) Stake 

func (*UnimplementedMsgServer) Stake(ctx context.Context, req *MsgStake) (*MsgStakeResponse, error)

func (*UnimplementedMsgServer) Unstake 

func (*UnimplementedMsgServer) Unstake(ctx context.Context, req *MsgUnstake) (*MsgUnstakeResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) GetAccountHistory added in v0.3.4 

func (*UnimplementedQueryServer) GetAccountHistory(ctx context.Context, req *GetAccountHistoryRequest) (*GetAccountHistoryResponse, error)

func (*UnimplementedQueryServer) GetFutureRewardEstimate 

func (*UnimplementedQueryServer) GetFutureRewardEstimate(ctx context.Context, req *GetFutureRewardEstimateRequest) (*GetFutureRewardEstimateResponse, error)

func (*UnimplementedQueryServer) GetGaugeByID 

func (*UnimplementedQueryServer) GetGaugeByID(ctx context.Context, req *GetGaugeByIDRequest) (*GetGaugeByIDResponse, error)

func (*UnimplementedQueryServer) GetGaugeQualifyingValue added in v0.3.4 

func (*UnimplementedQueryServer) GetGaugeQualifyingValue(ctx context.Context, req *GetGaugeQualifyingValueRequest) (*GetGaugeQualifyingValueResponse, error)

func (*UnimplementedQueryServer) GetGauges 

func (*UnimplementedQueryServer) GetGauges(ctx context.Context, req *GetGaugesRequest) (*GetGaugesResponse, error)

func (*UnimplementedQueryServer) GetModuleStatus 

func (*UnimplementedQueryServer) GetModuleStatus(ctx context.Context, req *GetModuleStatusRequest) (*GetModuleStatusResponse, error)

func (*UnimplementedQueryServer) GetStakeByID 

func (*UnimplementedQueryServer) GetStakeByID(ctx context.Context, req *GetStakeByIDRequest) (*GetStakeByIDResponse, error)

func (*UnimplementedQueryServer) GetStakes 

func (*UnimplementedQueryServer) GetStakes(ctx context.Context, req *GetStakesRequest) (*GetStakesResponse, 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.