types

package
v16.1.2 Latest Latest
Warning

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

Go to latest
Published: Jul 31, 2023 License: Apache-2.0 Imports: 35 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"
	AttributeLockedDenom = "denom"
	AttributeReceiver    = "receiver"
	AttributeAmount      = "amount"
)

Incentive module event types.

View Source
const (
	TypeMsgCreateGauge = "create_gauge"
	TypeMsgAddToGauge  = "add_to_gauge"
)
View Source
const DefaultIndex uint64 = 1

DefaultIndex is the default incentive module's global index.

Variables

View Source
var (
	BaseGasFeeForCreateGauge      = 10_000
	BaseGasFeeForAddRewardToGauge = 10_000
	// We set the default value to 1ns, as this is the only uptime we support as long as charging is disabled (or
	// until more supported uptimes are authorized by governance).
	DefaultConcentratedUptime = time.Nanosecond
)
View Source
var (
	// CreateGaugeFee is the fee required to create a new gauge.
	CreateGaugeFee = sdk.NewInt(50 * 1_000_000)
	// AddToGagugeFee is the fee required to add to gauge.
	AddToGaugeFee = sdk.NewInt(25 * 1_000_000)
)
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}

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

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

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

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

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

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

	// KeyIndexSeparator defines key for merging bytes.
	KeyIndexSeparator = []byte{0x07}

	// LockableDurationsKey defines key for storing valid durations for giving incentives.
	LockableDurationsKey = []byte("lockable_durations")

	NoLockInternalPrefix = "no-lock/i/"
	NoLockExternalPrefix = "no-lock/e/"
)
View Source
var (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	KeyDistrEpochIdentifier = []byte("DistrEpochIdentifier")
)

Incentives parameters key store.

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

Functions

func KeyPrefix

func KeyPrefix(p string) []byte

func NoLockExternalGaugeDenom

func NoLockExternalGaugeDenom(poolId uint64) string

NoLockExternalGaugeDenom returns the gauge denom for the no-lock external gauge for the given pool ID.

func NoLockInternalGaugeDenom

func NoLockInternalGaugeDenom(poolId uint64) string

NoLockInternalGaugeDenom returns the gauge denom for the no-lock internal gauge for the given pool ID.

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 AccountKeeper

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

type ActiveGaugesPerDenomRequest

type ActiveGaugesPerDenomRequest struct {
	// Desired denom when querying active gagues
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
	// Pagination defines pagination for the request
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*ActiveGaugesPerDenomRequest) Descriptor

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

func (*ActiveGaugesPerDenomRequest) GetDenom

func (m *ActiveGaugesPerDenomRequest) GetDenom() string

func (*ActiveGaugesPerDenomRequest) GetPagination

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

func (*ActiveGaugesPerDenomRequest) Marshal

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

func (*ActiveGaugesPerDenomRequest) MarshalTo

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

func (*ActiveGaugesPerDenomRequest) MarshalToSizedBuffer

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

func (*ActiveGaugesPerDenomRequest) ProtoMessage

func (*ActiveGaugesPerDenomRequest) ProtoMessage()

func (*ActiveGaugesPerDenomRequest) Reset

func (m *ActiveGaugesPerDenomRequest) Reset()

func (*ActiveGaugesPerDenomRequest) Size

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

func (*ActiveGaugesPerDenomRequest) String

func (m *ActiveGaugesPerDenomRequest) String() string

func (*ActiveGaugesPerDenomRequest) Unmarshal

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

func (*ActiveGaugesPerDenomRequest) XXX_DiscardUnknown

func (m *ActiveGaugesPerDenomRequest) XXX_DiscardUnknown()

func (*ActiveGaugesPerDenomRequest) XXX_Marshal

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

func (*ActiveGaugesPerDenomRequest) XXX_Merge

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

func (*ActiveGaugesPerDenomRequest) XXX_Size

func (m *ActiveGaugesPerDenomRequest) XXX_Size() int

func (*ActiveGaugesPerDenomRequest) XXX_Unmarshal

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

type ActiveGaugesPerDenomResponse

type ActiveGaugesPerDenomResponse struct {
	// Active gagues that match denom in query
	Data []Gauge `protobuf:"bytes,1,rep,name=data,proto3" json:"data"`
	// Pagination defines pagination for the response
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*ActiveGaugesPerDenomResponse) Descriptor

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

func (*ActiveGaugesPerDenomResponse) GetData

func (m *ActiveGaugesPerDenomResponse) GetData() []Gauge

func (*ActiveGaugesPerDenomResponse) GetPagination

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

func (*ActiveGaugesPerDenomResponse) Marshal

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

func (*ActiveGaugesPerDenomResponse) MarshalTo

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

func (*ActiveGaugesPerDenomResponse) MarshalToSizedBuffer

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

func (*ActiveGaugesPerDenomResponse) ProtoMessage

func (*ActiveGaugesPerDenomResponse) ProtoMessage()

func (*ActiveGaugesPerDenomResponse) Reset

func (m *ActiveGaugesPerDenomResponse) Reset()

func (*ActiveGaugesPerDenomResponse) Size

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

func (*ActiveGaugesPerDenomResponse) String

func (*ActiveGaugesPerDenomResponse) Unmarshal

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

func (*ActiveGaugesPerDenomResponse) XXX_DiscardUnknown

func (m *ActiveGaugesPerDenomResponse) XXX_DiscardUnknown()

func (*ActiveGaugesPerDenomResponse) XXX_Marshal

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

func (*ActiveGaugesPerDenomResponse) XXX_Merge

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

func (*ActiveGaugesPerDenomResponse) XXX_Size

func (m *ActiveGaugesPerDenomResponse) XXX_Size() int

func (*ActiveGaugesPerDenomResponse) XXX_Unmarshal

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

type ActiveGaugesRequest

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

func (*ActiveGaugesRequest) Descriptor

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

func (*ActiveGaugesRequest) GetPagination

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

func (*ActiveGaugesRequest) Marshal

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

func (*ActiveGaugesRequest) MarshalTo

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

func (*ActiveGaugesRequest) MarshalToSizedBuffer

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

func (*ActiveGaugesRequest) ProtoMessage

func (*ActiveGaugesRequest) ProtoMessage()

func (*ActiveGaugesRequest) Reset

func (m *ActiveGaugesRequest) Reset()

func (*ActiveGaugesRequest) Size

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

func (*ActiveGaugesRequest) String

func (m *ActiveGaugesRequest) String() string

func (*ActiveGaugesRequest) Unmarshal

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

func (*ActiveGaugesRequest) XXX_DiscardUnknown

func (m *ActiveGaugesRequest) XXX_DiscardUnknown()

func (*ActiveGaugesRequest) XXX_Marshal

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

func (*ActiveGaugesRequest) XXX_Merge

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

func (*ActiveGaugesRequest) XXX_Size

func (m *ActiveGaugesRequest) XXX_Size() int

func (*ActiveGaugesRequest) XXX_Unmarshal

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

type ActiveGaugesResponse

type ActiveGaugesResponse struct {
	// Active gagues only
	Data []Gauge `protobuf:"bytes,1,rep,name=data,proto3" json:"data"`
	// Pagination defines pagination for the response
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*ActiveGaugesResponse) Descriptor

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

func (*ActiveGaugesResponse) GetData

func (m *ActiveGaugesResponse) GetData() []Gauge

func (*ActiveGaugesResponse) GetPagination

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

func (*ActiveGaugesResponse) Marshal

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

func (*ActiveGaugesResponse) MarshalTo

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

func (*ActiveGaugesResponse) MarshalToSizedBuffer

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

func (*ActiveGaugesResponse) ProtoMessage

func (*ActiveGaugesResponse) ProtoMessage()

func (*ActiveGaugesResponse) Reset

func (m *ActiveGaugesResponse) Reset()

func (*ActiveGaugesResponse) Size

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

func (*ActiveGaugesResponse) String

func (m *ActiveGaugesResponse) String() string

func (*ActiveGaugesResponse) Unmarshal

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

func (*ActiveGaugesResponse) XXX_DiscardUnknown

func (m *ActiveGaugesResponse) XXX_DiscardUnknown()

func (*ActiveGaugesResponse) XXX_Marshal

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

func (*ActiveGaugesResponse) XXX_Merge

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

func (*ActiveGaugesResponse) XXX_Size

func (m *ActiveGaugesResponse) XXX_Size() int

func (*ActiveGaugesResponse) XXX_Unmarshal

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

type BankKeeper

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

	HasSupply(ctx sdk.Context, denom string) bool

	SendCoinsFromModuleToManyAccounts(
		ctx sdk.Context, senderModule string, recipientAddrs []sdk.AccAddress, amts []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 CommunityPoolKeeper

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

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

type ConcentratedLiquidityKeeper

type ConcentratedLiquidityKeeper interface {
	CreateIncentive(ctx sdk.Context, poolId uint64, sender sdk.AccAddress, incentiveCoin sdk.Coin, emissionRate sdk.Dec, startTime time.Time, minUptime time.Duration) (cltypes.IncentiveRecord, error)
	GetConcentratedPoolById(ctx sdk.Context, poolId uint64) (cltypes.ConcentratedPoolExtension, error)
}

type EpochKeeper

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

EpochKeeper defines the expected interface needed to retrieve epoch info.

type GAMMKeeper

type GAMMKeeper interface {
	GetPoolType(ctx sdk.Context, poolId uint64) (poolmanagertypes.PoolType, error)
}

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"`
	// is_perpetual is a flag to show 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, Intended for use with incentives that get refilled daily.
	IsPerpetual bool `protobuf:"varint,2,opt,name=is_perpetual,json=isPerpetual,proto3" json:"is_perpetual,omitempty"`
	// distribute_to is where the gauge rewards are distributed to.
	// This is queried via lock duration or by timestamp
	DistributeTo types.QueryCondition `protobuf:"bytes,3,opt,name=distribute_to,json=distributeTo,proto3" json:"distribute_to"`
	// coins is the total amount of coins that have been in the gauge
	// Can distribute multiple coin denoms
	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:"start_time"`
	// num_epochs_paid_over is the number of total 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"`
	// filled_epochs is the number of epochs distribution has been completed on
	// already
	FilledEpochs uint64 `protobuf:"varint,7,opt,name=filled_epochs,json=filledEpochs,proto3" json:"filled_epochs,omitempty"`
	// distributed_coins are coins that have been distributed already
	DistributedCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 153-byte string literal not displayed */
}

Gauge is an object that stores and distributes yields to recipients who satisfy certain conditions. Currently gauges support conditions around the duration for which a given denom is locked.

func NewGauge

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

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

func (*Gauge) Descriptor

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

func (*Gauge) GetCoins

func (*Gauge) GetDistributeTo

func (m *Gauge) GetDistributeTo() types.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) GetStartTime

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

func (Gauge) IsActiveGauge

func (gauge Gauge) IsActiveGauge(curTime 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(curTime 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(curTime 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) 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 GaugeByIDRequest

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

func (*GaugeByIDRequest) Descriptor

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

func (*GaugeByIDRequest) GetId

func (m *GaugeByIDRequest) GetId() uint64

func (*GaugeByIDRequest) Marshal

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

func (*GaugeByIDRequest) MarshalTo

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

func (*GaugeByIDRequest) MarshalToSizedBuffer

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

func (*GaugeByIDRequest) ProtoMessage

func (*GaugeByIDRequest) ProtoMessage()

func (*GaugeByIDRequest) Reset

func (m *GaugeByIDRequest) Reset()

func (*GaugeByIDRequest) Size

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

func (*GaugeByIDRequest) String

func (m *GaugeByIDRequest) String() string

func (*GaugeByIDRequest) Unmarshal

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

func (*GaugeByIDRequest) XXX_DiscardUnknown

func (m *GaugeByIDRequest) XXX_DiscardUnknown()

func (*GaugeByIDRequest) XXX_Marshal

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

func (*GaugeByIDRequest) XXX_Merge

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

func (*GaugeByIDRequest) XXX_Size

func (m *GaugeByIDRequest) XXX_Size() int

func (*GaugeByIDRequest) XXX_Unmarshal

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

type GaugeByIDResponse

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

func (*GaugeByIDResponse) Descriptor

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

func (*GaugeByIDResponse) GetGauge

func (m *GaugeByIDResponse) GetGauge() *Gauge

func (*GaugeByIDResponse) Marshal

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

func (*GaugeByIDResponse) MarshalTo

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

func (*GaugeByIDResponse) MarshalToSizedBuffer

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

func (*GaugeByIDResponse) ProtoMessage

func (*GaugeByIDResponse) ProtoMessage()

func (*GaugeByIDResponse) Reset

func (m *GaugeByIDResponse) Reset()

func (*GaugeByIDResponse) Size

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

func (*GaugeByIDResponse) String

func (m *GaugeByIDResponse) String() string

func (*GaugeByIDResponse) Unmarshal

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

func (*GaugeByIDResponse) XXX_DiscardUnknown

func (m *GaugeByIDResponse) XXX_DiscardUnknown()

func (*GaugeByIDResponse) XXX_Marshal

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

func (*GaugeByIDResponse) XXX_Merge

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

func (*GaugeByIDResponse) XXX_Size

func (m *GaugeByIDResponse) XXX_Size() int

func (*GaugeByIDResponse) XXX_Unmarshal

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

type GaugesRequest

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

func (*GaugesRequest) Descriptor

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

func (*GaugesRequest) GetPagination

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

func (*GaugesRequest) Marshal

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

func (*GaugesRequest) MarshalTo

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

func (*GaugesRequest) MarshalToSizedBuffer

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

func (*GaugesRequest) ProtoMessage

func (*GaugesRequest) ProtoMessage()

func (*GaugesRequest) Reset

func (m *GaugesRequest) Reset()

func (*GaugesRequest) Size

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

func (*GaugesRequest) String

func (m *GaugesRequest) String() string

func (*GaugesRequest) Unmarshal

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

func (*GaugesRequest) XXX_DiscardUnknown

func (m *GaugesRequest) XXX_DiscardUnknown()

func (*GaugesRequest) XXX_Marshal

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

func (*GaugesRequest) XXX_Merge

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

func (*GaugesRequest) XXX_Size

func (m *GaugesRequest) XXX_Size() int

func (*GaugesRequest) XXX_Unmarshal

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

type GaugesResponse

type GaugesResponse struct {
	// Upcoming and active gauges
	Data []Gauge `protobuf:"bytes,1,rep,name=data,proto3" json:"data"`
	// Pagination defines pagination for the response
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*GaugesResponse) Descriptor

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

func (*GaugesResponse) GetData

func (m *GaugesResponse) GetData() []Gauge

func (*GaugesResponse) GetPagination

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

func (*GaugesResponse) Marshal

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

func (*GaugesResponse) MarshalTo

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

func (*GaugesResponse) MarshalToSizedBuffer

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

func (*GaugesResponse) ProtoMessage

func (*GaugesResponse) ProtoMessage()

func (*GaugesResponse) Reset

func (m *GaugesResponse) Reset()

func (*GaugesResponse) Size

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

func (*GaugesResponse) String

func (m *GaugesResponse) String() string

func (*GaugesResponse) Unmarshal

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

func (*GaugesResponse) XXX_DiscardUnknown

func (m *GaugesResponse) XXX_DiscardUnknown()

func (*GaugesResponse) XXX_Marshal

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

func (*GaugesResponse) XXX_Merge

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

func (*GaugesResponse) XXX_Size

func (m *GaugesResponse) XXX_Size() int

func (*GaugesResponse) XXX_Unmarshal

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

type GenesisState

type GenesisState struct {
	// params are all the parameters of the module
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	// gauges are all gauges that should exist at genesis
	Gauges []Gauge `protobuf:"bytes,2,rep,name=gauges,proto3" json:"gauges"`
	// lockable_durations are all lockup durations that gauges can be locked for
	// in order to recieve incentives
	LockableDurations []time.Duration `` /* 140-byte string literal not displayed */
	// last_gauge_id is what the gauge number will increment from when creating
	// the next gauge after genesis
	LastGaugeId uint64 `protobuf:"varint,4,opt,name=last_gauge_id,json=lastGaugeId,proto3" json:"last_gauge_id,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 GetGenesisStateFromAppState

func GetGenesisStateFromAppState(cdc codec.JSONCodec, appState map[string]json.RawMessage) *GenesisState

GetGenesisStateFromAppState returns an incentive module GenesisState given a raw application genesis state.

func (*GenesisState) Descriptor

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

func (*GenesisState) GetGauges

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

func (*GenesisState) GetLastGaugeId

func (m *GenesisState) GetLastGaugeId() uint64

func (*GenesisState) GetLockableDurations

func (m *GenesisState) GetLockableDurations() []time.Duration

func (*GenesisState) GetParams

func (m *GenesisState) GetParams() Params

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

type LockableDurationsInfo

type LockableDurationsInfo struct {
	// List of incentivised durations that gauges will pay out to
	LockableDurations []time.Duration `` /* 140-byte string literal not displayed */
}

func (*LockableDurationsInfo) Descriptor

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

func (*LockableDurationsInfo) GetLockableDurations

func (m *LockableDurationsInfo) GetLockableDurations() []time.Duration

func (*LockableDurationsInfo) Marshal

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

func (*LockableDurationsInfo) MarshalTo

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

func (*LockableDurationsInfo) MarshalToSizedBuffer

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

func (*LockableDurationsInfo) ProtoMessage

func (*LockableDurationsInfo) ProtoMessage()

func (*LockableDurationsInfo) Reset

func (m *LockableDurationsInfo) Reset()

func (*LockableDurationsInfo) Size

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

func (*LockableDurationsInfo) String

func (m *LockableDurationsInfo) String() string

func (*LockableDurationsInfo) Unmarshal

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

func (*LockableDurationsInfo) XXX_DiscardUnknown

func (m *LockableDurationsInfo) XXX_DiscardUnknown()

func (*LockableDurationsInfo) XXX_Marshal

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

func (*LockableDurationsInfo) XXX_Merge

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

func (*LockableDurationsInfo) XXX_Size

func (m *LockableDurationsInfo) XXX_Size() int

func (*LockableDurationsInfo) XXX_Unmarshal

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

type LockupKeeper

type LockupKeeper interface {
	GetLocksLongerThanDurationDenom(ctx sdk.Context, denom string, duration time.Duration) []lockuptypes.PeriodLock
	GetPeriodLocksAccumulation(ctx sdk.Context, query lockuptypes.QueryCondition) sdk.Int
	GetAccountPeriodLocks(ctx sdk.Context, addr sdk.AccAddress) []lockuptypes.PeriodLock
	GetLockByID(ctx sdk.Context, lockID uint64) (*lockuptypes.PeriodLock, error)
}

LockupKeeper defines the expected interface needed to retrieve locks.

type ModuleToDistributeCoinsRequest

type ModuleToDistributeCoinsRequest struct {
}

func (*ModuleToDistributeCoinsRequest) Descriptor

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

func (*ModuleToDistributeCoinsRequest) Marshal

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

func (*ModuleToDistributeCoinsRequest) MarshalTo

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

func (*ModuleToDistributeCoinsRequest) MarshalToSizedBuffer

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

func (*ModuleToDistributeCoinsRequest) ProtoMessage

func (*ModuleToDistributeCoinsRequest) ProtoMessage()

func (*ModuleToDistributeCoinsRequest) Reset

func (m *ModuleToDistributeCoinsRequest) Reset()

func (*ModuleToDistributeCoinsRequest) Size

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

func (*ModuleToDistributeCoinsRequest) String

func (*ModuleToDistributeCoinsRequest) Unmarshal

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

func (*ModuleToDistributeCoinsRequest) XXX_DiscardUnknown

func (m *ModuleToDistributeCoinsRequest) XXX_DiscardUnknown()

func (*ModuleToDistributeCoinsRequest) XXX_Marshal

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

func (*ModuleToDistributeCoinsRequest) XXX_Merge

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

func (*ModuleToDistributeCoinsRequest) XXX_Size

func (m *ModuleToDistributeCoinsRequest) XXX_Size() int

func (*ModuleToDistributeCoinsRequest) XXX_Unmarshal

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

type ModuleToDistributeCoinsResponse

type ModuleToDistributeCoinsResponse struct {
	// Coins that have yet to be distributed
	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 (*ModuleToDistributeCoinsResponse) Descriptor

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

func (*ModuleToDistributeCoinsResponse) GetCoins

func (*ModuleToDistributeCoinsResponse) Marshal

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

func (*ModuleToDistributeCoinsResponse) MarshalTo

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

func (*ModuleToDistributeCoinsResponse) MarshalToSizedBuffer

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

func (*ModuleToDistributeCoinsResponse) ProtoMessage

func (*ModuleToDistributeCoinsResponse) ProtoMessage()

func (*ModuleToDistributeCoinsResponse) Reset

func (*ModuleToDistributeCoinsResponse) Size

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

func (*ModuleToDistributeCoinsResponse) String

func (*ModuleToDistributeCoinsResponse) Unmarshal

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

func (*ModuleToDistributeCoinsResponse) XXX_DiscardUnknown

func (m *ModuleToDistributeCoinsResponse) XXX_DiscardUnknown()

func (*ModuleToDistributeCoinsResponse) XXX_Marshal

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

func (*ModuleToDistributeCoinsResponse) XXX_Merge

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

func (*ModuleToDistributeCoinsResponse) XXX_Size

func (m *ModuleToDistributeCoinsResponse) XXX_Size() int

func (*ModuleToDistributeCoinsResponse) XXX_Unmarshal

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

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 (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 {
	CreateGauge(ctx context.Context, in *MsgCreateGauge, opts ...grpc.CallOption) (*MsgCreateGaugeResponse, error)
	AddToGauge(ctx context.Context, in *MsgAddToGauge, opts ...grpc.CallOption) (*MsgAddToGaugeResponse, 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
	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 types.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"`
	// pool_id is the ID of the pool that the gauge is meant to be associated
	// with. if pool_id is set, then the "QueryCondition.LockQueryType" must be
	// "NoLock" with all other fields of the "QueryCondition.LockQueryType" struct
	// unset, including "QueryCondition.Denom". However, note that, internally,
	// the empty string in "QueryCondition.Denom" ends up being overwritten with
	// incentivestypes.NoLockExternalGaugeDenom(<pool-id>) so that the gauges
	// associated with a pool can be queried by this prefix if needed.
	PoolId uint64 `protobuf:"varint,7,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
}

MsgCreateGauge creates a gague to distribute rewards to users

func NewMsgCreateGauge

func NewMsgCreateGauge(isPerpetual bool, owner sdk.AccAddress, distributeTo lockuptypes.QueryCondition, coins sdk.Coins, startTime time.Time, numEpochsPaidOver uint64, poolId uint64) *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 (*MsgCreateGauge) GetDistributeTo

func (m *MsgCreateGauge) GetDistributeTo() types.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) GetPoolId

func (m *MsgCreateGauge) GetPoolId() uint64

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 {
	CreateGauge(context.Context, *MsgCreateGauge) (*MsgCreateGaugeResponse, error)
	AddToGauge(context.Context, *MsgAddToGauge) (*MsgAddToGaugeResponse, error)
}

MsgServer is the server API for Msg service.

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

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 */
}

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

type PoolIncentiveKeeper interface {
	GetPoolIdFromGaugeId(ctx sdk.Context, gaugeId uint64, lockableDuration time.Duration) (uint64, error)
	SetPoolGaugeIdNoLock(ctx sdk.Context, poolId uint64, gaugeId uint64)
}

type PoolManagerKeeper

type PoolManagerKeeper interface {
	GetPool(ctx sdk.Context, poolId uint64) (poolmanagertypes.PoolI, error)
}

type QueryClient

type QueryClient interface {
	// ModuleToDistributeCoins returns coins that are going to be distributed
	ModuleToDistributeCoins(ctx context.Context, in *ModuleToDistributeCoinsRequest, opts ...grpc.CallOption) (*ModuleToDistributeCoinsResponse, error)
	// GaugeByID returns gauges by their respective ID
	GaugeByID(ctx context.Context, in *GaugeByIDRequest, opts ...grpc.CallOption) (*GaugeByIDResponse, error)
	// Gauges returns both upcoming and active gauges
	Gauges(ctx context.Context, in *GaugesRequest, opts ...grpc.CallOption) (*GaugesResponse, error)
	// ActiveGauges returns active gauges
	ActiveGauges(ctx context.Context, in *ActiveGaugesRequest, opts ...grpc.CallOption) (*ActiveGaugesResponse, error)
	// ActiveGaugesPerDenom returns active gauges by denom
	ActiveGaugesPerDenom(ctx context.Context, in *ActiveGaugesPerDenomRequest, opts ...grpc.CallOption) (*ActiveGaugesPerDenomResponse, error)
	// Returns scheduled gauges that have not yet occured
	UpcomingGauges(ctx context.Context, in *UpcomingGaugesRequest, opts ...grpc.CallOption) (*UpcomingGaugesResponse, error)
	// UpcomingGaugesPerDenom returns scheduled gauges that have not yet occured
	// by denom
	UpcomingGaugesPerDenom(ctx context.Context, in *UpcomingGaugesPerDenomRequest, opts ...grpc.CallOption) (*UpcomingGaugesPerDenomResponse, error)
	// RewardsEst returns an estimate of the rewards from now until a specified
	// time in the future The querier either provides an address or a set of locks
	// for which they want to find the associated rewards
	RewardsEst(ctx context.Context, in *RewardsEstRequest, opts ...grpc.CallOption) (*RewardsEstResponse, error)
	// LockableDurations returns lockable durations that are valid to distribute
	// incentives for
	LockableDurations(ctx context.Context, in *QueryLockableDurationsRequest, opts ...grpc.CallOption) (*QueryLockableDurationsResponse, 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 QueryLockableDurationsRequest

type QueryLockableDurationsRequest struct {
}

func (*QueryLockableDurationsRequest) Descriptor

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

func (*QueryLockableDurationsRequest) Marshal

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

func (*QueryLockableDurationsRequest) MarshalTo

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

func (*QueryLockableDurationsRequest) MarshalToSizedBuffer

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

func (*QueryLockableDurationsRequest) ProtoMessage

func (*QueryLockableDurationsRequest) ProtoMessage()

func (*QueryLockableDurationsRequest) Reset

func (m *QueryLockableDurationsRequest) Reset()

func (*QueryLockableDurationsRequest) Size

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

func (*QueryLockableDurationsRequest) String

func (*QueryLockableDurationsRequest) Unmarshal

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

func (*QueryLockableDurationsRequest) XXX_DiscardUnknown

func (m *QueryLockableDurationsRequest) XXX_DiscardUnknown()

func (*QueryLockableDurationsRequest) XXX_Marshal

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

func (*QueryLockableDurationsRequest) XXX_Merge

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

func (*QueryLockableDurationsRequest) XXX_Size

func (m *QueryLockableDurationsRequest) XXX_Size() int

func (*QueryLockableDurationsRequest) XXX_Unmarshal

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

type QueryLockableDurationsResponse

type QueryLockableDurationsResponse struct {
	// Time durations that users can lock coins for in order to recieve rewards
	LockableDurations []time.Duration `` /* 140-byte string literal not displayed */
}

func (*QueryLockableDurationsResponse) Descriptor

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

func (*QueryLockableDurationsResponse) GetLockableDurations

func (m *QueryLockableDurationsResponse) GetLockableDurations() []time.Duration

func (*QueryLockableDurationsResponse) Marshal

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

func (*QueryLockableDurationsResponse) MarshalTo

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

func (*QueryLockableDurationsResponse) MarshalToSizedBuffer

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

func (*QueryLockableDurationsResponse) ProtoMessage

func (*QueryLockableDurationsResponse) ProtoMessage()

func (*QueryLockableDurationsResponse) Reset

func (m *QueryLockableDurationsResponse) Reset()

func (*QueryLockableDurationsResponse) Size

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

func (*QueryLockableDurationsResponse) String

func (*QueryLockableDurationsResponse) Unmarshal

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

func (*QueryLockableDurationsResponse) XXX_DiscardUnknown

func (m *QueryLockableDurationsResponse) XXX_DiscardUnknown()

func (*QueryLockableDurationsResponse) XXX_Marshal

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

func (*QueryLockableDurationsResponse) XXX_Merge

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

func (*QueryLockableDurationsResponse) XXX_Size

func (m *QueryLockableDurationsResponse) XXX_Size() int

func (*QueryLockableDurationsResponse) XXX_Unmarshal

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

type QueryServer

type QueryServer interface {
	// ModuleToDistributeCoins returns coins that are going to be distributed
	ModuleToDistributeCoins(context.Context, *ModuleToDistributeCoinsRequest) (*ModuleToDistributeCoinsResponse, error)
	// GaugeByID returns gauges by their respective ID
	GaugeByID(context.Context, *GaugeByIDRequest) (*GaugeByIDResponse, error)
	// Gauges returns both upcoming and active gauges
	Gauges(context.Context, *GaugesRequest) (*GaugesResponse, error)
	// ActiveGauges returns active gauges
	ActiveGauges(context.Context, *ActiveGaugesRequest) (*ActiveGaugesResponse, error)
	// ActiveGaugesPerDenom returns active gauges by denom
	ActiveGaugesPerDenom(context.Context, *ActiveGaugesPerDenomRequest) (*ActiveGaugesPerDenomResponse, error)
	// Returns scheduled gauges that have not yet occured
	UpcomingGauges(context.Context, *UpcomingGaugesRequest) (*UpcomingGaugesResponse, error)
	// UpcomingGaugesPerDenom returns scheduled gauges that have not yet occured
	// by denom
	UpcomingGaugesPerDenom(context.Context, *UpcomingGaugesPerDenomRequest) (*UpcomingGaugesPerDenomResponse, error)
	// RewardsEst returns an estimate of the rewards from now until a specified
	// time in the future The querier either provides an address or a set of locks
	// for which they want to find the associated rewards
	RewardsEst(context.Context, *RewardsEstRequest) (*RewardsEstResponse, error)
	// LockableDurations returns lockable durations that are valid to distribute
	// incentives for
	LockableDurations(context.Context, *QueryLockableDurationsRequest) (*QueryLockableDurationsResponse, error)
}

QueryServer is the server API for Query service.

type RewardsEstRequest

type RewardsEstRequest struct {
	// Address that is being queried for future estimated rewards
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty" yaml:"owner"`
	// Lock IDs included in future reward estimation
	LockIds []uint64 `protobuf:"varint,2,rep,packed,name=lock_ids,json=lockIds,proto3" json:"lock_ids,omitempty"`
	// Upper time limit of reward estimation
	// Lower limit is current epoch
	EndEpoch int64 `protobuf:"varint,3,opt,name=end_epoch,json=endEpoch,proto3" json:"end_epoch,omitempty"`
}

func (*RewardsEstRequest) Descriptor

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

func (*RewardsEstRequest) GetEndEpoch

func (m *RewardsEstRequest) GetEndEpoch() int64

func (*RewardsEstRequest) GetLockIds

func (m *RewardsEstRequest) GetLockIds() []uint64

func (*RewardsEstRequest) GetOwner

func (m *RewardsEstRequest) GetOwner() string

func (*RewardsEstRequest) Marshal

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

func (*RewardsEstRequest) MarshalTo

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

func (*RewardsEstRequest) MarshalToSizedBuffer

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

func (*RewardsEstRequest) ProtoMessage

func (*RewardsEstRequest) ProtoMessage()

func (*RewardsEstRequest) Reset

func (m *RewardsEstRequest) Reset()

func (*RewardsEstRequest) Size

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

func (*RewardsEstRequest) String

func (m *RewardsEstRequest) String() string

func (*RewardsEstRequest) Unmarshal

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

func (*RewardsEstRequest) XXX_DiscardUnknown

func (m *RewardsEstRequest) XXX_DiscardUnknown()

func (*RewardsEstRequest) XXX_Marshal

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

func (*RewardsEstRequest) XXX_Merge

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

func (*RewardsEstRequest) XXX_Size

func (m *RewardsEstRequest) XXX_Size() int

func (*RewardsEstRequest) XXX_Unmarshal

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

type RewardsEstResponse

type RewardsEstResponse 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 (*RewardsEstResponse) Descriptor

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

func (*RewardsEstResponse) GetCoins

func (*RewardsEstResponse) Marshal

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

func (*RewardsEstResponse) MarshalTo

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

func (*RewardsEstResponse) MarshalToSizedBuffer

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

func (*RewardsEstResponse) ProtoMessage

func (*RewardsEstResponse) ProtoMessage()

func (*RewardsEstResponse) Reset

func (m *RewardsEstResponse) Reset()

func (*RewardsEstResponse) Size

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

func (*RewardsEstResponse) String

func (m *RewardsEstResponse) String() string

func (*RewardsEstResponse) Unmarshal

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

func (*RewardsEstResponse) XXX_DiscardUnknown

func (m *RewardsEstResponse) XXX_DiscardUnknown()

func (*RewardsEstResponse) XXX_Marshal

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

func (*RewardsEstResponse) XXX_Merge

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

func (*RewardsEstResponse) XXX_Size

func (m *RewardsEstResponse) XXX_Size() int

func (*RewardsEstResponse) XXX_Unmarshal

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

type TxFeesKeeper

type TxFeesKeeper interface {
	GetBaseDenom(ctx sdk.Context) (denom string, err error)
}

TxFeesKeeper defines the expected interface needed to managing transaction fees.

type UnimplementedMsgServer

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) AddToGauge

func (*UnimplementedMsgServer) CreateGauge

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) ActiveGauges

func (*UnimplementedQueryServer) ActiveGaugesPerDenom

func (*UnimplementedQueryServer) GaugeByID

func (*UnimplementedQueryServer) Gauges

func (*UnimplementedQueryServer) LockableDurations

func (*UnimplementedQueryServer) ModuleToDistributeCoins

func (*UnimplementedQueryServer) RewardsEst

func (*UnimplementedQueryServer) UpcomingGauges

func (*UnimplementedQueryServer) UpcomingGaugesPerDenom

type UpcomingGaugesPerDenomRequest

type UpcomingGaugesPerDenomRequest struct {
	// Filter for upcoming gagues that match specific denom
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
	// Pagination defines pagination for the request
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*UpcomingGaugesPerDenomRequest) Descriptor

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

func (*UpcomingGaugesPerDenomRequest) GetDenom

func (m *UpcomingGaugesPerDenomRequest) GetDenom() string

func (*UpcomingGaugesPerDenomRequest) GetPagination

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

func (*UpcomingGaugesPerDenomRequest) Marshal

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

func (*UpcomingGaugesPerDenomRequest) MarshalTo

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

func (*UpcomingGaugesPerDenomRequest) MarshalToSizedBuffer

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

func (*UpcomingGaugesPerDenomRequest) ProtoMessage

func (*UpcomingGaugesPerDenomRequest) ProtoMessage()

func (*UpcomingGaugesPerDenomRequest) Reset

func (m *UpcomingGaugesPerDenomRequest) Reset()

func (*UpcomingGaugesPerDenomRequest) Size

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

func (*UpcomingGaugesPerDenomRequest) String

func (*UpcomingGaugesPerDenomRequest) Unmarshal

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

func (*UpcomingGaugesPerDenomRequest) XXX_DiscardUnknown

func (m *UpcomingGaugesPerDenomRequest) XXX_DiscardUnknown()

func (*UpcomingGaugesPerDenomRequest) XXX_Marshal

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

func (*UpcomingGaugesPerDenomRequest) XXX_Merge

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

func (*UpcomingGaugesPerDenomRequest) XXX_Size

func (m *UpcomingGaugesPerDenomRequest) XXX_Size() int

func (*UpcomingGaugesPerDenomRequest) XXX_Unmarshal

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

type UpcomingGaugesPerDenomResponse

type UpcomingGaugesPerDenomResponse struct {
	// Upcoming gagues that match denom in query
	UpcomingGauges []Gauge `protobuf:"bytes,1,rep,name=upcoming_gauges,json=upcomingGauges,proto3" json:"upcoming_gauges"`
	// Pagination defines pagination for the response
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*UpcomingGaugesPerDenomResponse) Descriptor

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

func (*UpcomingGaugesPerDenomResponse) GetPagination

func (*UpcomingGaugesPerDenomResponse) GetUpcomingGauges

func (m *UpcomingGaugesPerDenomResponse) GetUpcomingGauges() []Gauge

func (*UpcomingGaugesPerDenomResponse) Marshal

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

func (*UpcomingGaugesPerDenomResponse) MarshalTo

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

func (*UpcomingGaugesPerDenomResponse) MarshalToSizedBuffer

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

func (*UpcomingGaugesPerDenomResponse) ProtoMessage

func (*UpcomingGaugesPerDenomResponse) ProtoMessage()

func (*UpcomingGaugesPerDenomResponse) Reset

func (m *UpcomingGaugesPerDenomResponse) Reset()

func (*UpcomingGaugesPerDenomResponse) Size

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

func (*UpcomingGaugesPerDenomResponse) String

func (*UpcomingGaugesPerDenomResponse) Unmarshal

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

func (*UpcomingGaugesPerDenomResponse) XXX_DiscardUnknown

func (m *UpcomingGaugesPerDenomResponse) XXX_DiscardUnknown()

func (*UpcomingGaugesPerDenomResponse) XXX_Marshal

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

func (*UpcomingGaugesPerDenomResponse) XXX_Merge

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

func (*UpcomingGaugesPerDenomResponse) XXX_Size

func (m *UpcomingGaugesPerDenomResponse) XXX_Size() int

func (*UpcomingGaugesPerDenomResponse) XXX_Unmarshal

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

type UpcomingGaugesRequest

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

func (*UpcomingGaugesRequest) Descriptor

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

func (*UpcomingGaugesRequest) GetPagination

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

func (*UpcomingGaugesRequest) Marshal

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

func (*UpcomingGaugesRequest) MarshalTo

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

func (*UpcomingGaugesRequest) MarshalToSizedBuffer

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

func (*UpcomingGaugesRequest) ProtoMessage

func (*UpcomingGaugesRequest) ProtoMessage()

func (*UpcomingGaugesRequest) Reset

func (m *UpcomingGaugesRequest) Reset()

func (*UpcomingGaugesRequest) Size

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

func (*UpcomingGaugesRequest) String

func (m *UpcomingGaugesRequest) String() string

func (*UpcomingGaugesRequest) Unmarshal

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

func (*UpcomingGaugesRequest) XXX_DiscardUnknown

func (m *UpcomingGaugesRequest) XXX_DiscardUnknown()

func (*UpcomingGaugesRequest) XXX_Marshal

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

func (*UpcomingGaugesRequest) XXX_Merge

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

func (*UpcomingGaugesRequest) XXX_Size

func (m *UpcomingGaugesRequest) XXX_Size() int

func (*UpcomingGaugesRequest) XXX_Unmarshal

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

type UpcomingGaugesResponse

type UpcomingGaugesResponse struct {
	// Gauges whose distribution is upcoming
	Data []Gauge `protobuf:"bytes,1,rep,name=data,proto3" json:"data"`
	// Pagination defines pagination for the response
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*UpcomingGaugesResponse) Descriptor

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

func (*UpcomingGaugesResponse) GetData

func (m *UpcomingGaugesResponse) GetData() []Gauge

func (*UpcomingGaugesResponse) GetPagination

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

func (*UpcomingGaugesResponse) Marshal

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

func (*UpcomingGaugesResponse) MarshalTo

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

func (*UpcomingGaugesResponse) MarshalToSizedBuffer

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

func (*UpcomingGaugesResponse) ProtoMessage

func (*UpcomingGaugesResponse) ProtoMessage()

func (*UpcomingGaugesResponse) Reset

func (m *UpcomingGaugesResponse) Reset()

func (*UpcomingGaugesResponse) Size

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

func (*UpcomingGaugesResponse) String

func (m *UpcomingGaugesResponse) String() string

func (*UpcomingGaugesResponse) Unmarshal

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

func (*UpcomingGaugesResponse) XXX_DiscardUnknown

func (m *UpcomingGaugesResponse) XXX_DiscardUnknown()

func (*UpcomingGaugesResponse) XXX_Marshal

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

func (*UpcomingGaugesResponse) XXX_Merge

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

func (*UpcomingGaugesResponse) XXX_Size

func (m *UpcomingGaugesResponse) XXX_Size() int

func (*UpcomingGaugesResponse) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL