types

package
v3.0.0-rc1 Latest Latest
Warning

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

Go to latest
Published: Sep 7, 2022 License: Apache-2.0 Imports: 40 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source
const (
	EventTypeCreateFixedAmountPlan = "create_fixed_amount_plan"
	EventTypeCreateRatioPlan       = "create_ratio_plan"
	EventTypeStake                 = "stake"
	EventTypeUnstake               = "unstake"
	EventTypeHarvest               = "harvest"
	EventTypeRemovePlan            = "remove_plan"
	EventTypeRewardsWithdrawn      = "rewards_withdrawn"
	EventTypePlanTerminated        = "plan_terminated"
	EventTypeRewardsAllocated      = "rewards_allocated"

	AttributeKeyPlanId             = "plan_id" //nolint:golint
	AttributeKeyPlanName           = "plan_name"
	AttributeKeyFarmingPoolAddress = "farming_pool_address"
	AttributeKeyTerminationAddress = "termination_address"
	AttributeKeyStakingCoins       = "staking_coins"
	AttributeKeyUnstakingCoins     = "unstaking_coins"
	AttributeKeyRewardCoins        = "reward_coins"
	AttributeKeyStartTime          = "start_time"
	AttributeKeyEndTime            = "end_time"
	AttributeKeyEpochAmount        = "epoch_amount"
	AttributeKeyEpochRatio         = "epoch_ratio"
	AttributeKeyFarmer             = "farmer"
	AttributeKeyAmount             = "amount"
	AttributeKeyStakingCoinDenom   = "staking_coin_denom"
	AttributeKeyStakingCoinDenoms  = "staking_coin_denoms"
)

Event types for the farming module.

View Source
const (
	// ModuleName is the name of the farming module
	ModuleName = "farming"

	// RouterKey is the message router key for the farming module
	RouterKey = ModuleName

	// StoreKey is the default store key for the farming module
	StoreKey = ModuleName

	// QuerierRoute is the querier route for the farming module
	QuerierRoute = ModuleName
)
View Source
const (
	TypeMsgCreateFixedAmountPlan = "create_fixed_amount_plan"
	TypeMsgCreateRatioPlan       = "create_ratio_plan"
	TypeMsgStake                 = "stake"
	TypeMsgUnstake               = "unstake"
	TypeMsgHarvest               = "harvest"
	TypeMsgRemovePlan            = "remove_plan"
	TypeMsgAdvanceEpoch          = "advance_epoch"
)

Message types for the farming module

View Source
const (
	// PrivatePlanMaxNumDenoms is the maximum number of denoms in a private plan's
	// staking coin weights and epoch amount.
	PrivatePlanMaxNumDenoms = 50
	// PublicPlanMaxNumDenoms is the maximum number of denoms in a public plan's
	// staking coin weights and epoch amount.
	PublicPlanMaxNumDenoms = 500

	RewardReserveAccName             string = "RewardsReserveAcc"
	UnharvestedRewardsReserveAccName string = "UnharvestedRewardsReserveAcc"
)
View Source
const (
	MaxNameLength                   int    = 140
	PrivatePlanFarmingPoolAccPrefix string = "PrivatePlan"
	StakingReserveAccPrefix         string = "StakingReserveAcc"
	AccNameSplitter                 string = "|"
)
View Source
const Day = 24 * time.Hour
View Source
const (
	ProposalTypePublicPlan string = "PublicPlan"
)

Variables

View Source
var (
	ErrInvalidPlanType                 = sdkerrors.Register(ModuleName, 2, "invalid plan type")
	ErrInvalidPlanName                 = sdkerrors.Register(ModuleName, 3, "invalid plan name")
	ErrInvalidPlanEndTime              = sdkerrors.Register(ModuleName, 4, "invalid plan end time")
	ErrInvalidStakingCoinWeights       = sdkerrors.Register(ModuleName, 5, "invalid staking coin weights")
	ErrInvalidTotalEpochRatio          = sdkerrors.Register(ModuleName, 6, "invalid total epoch ratio")
	ErrStakingNotExists                = sdkerrors.Register(ModuleName, 7, "staking not exists")
	ErrConflictPrivatePlanFarmingPool  = sdkerrors.Register(ModuleName, 8, "the address is already in use, please use a different plan name")
	ErrInvalidStakingReservedAmount    = sdkerrors.Register(ModuleName, 9, "staking reserved amount invariant broken")
	ErrInvalidRemainingRewardsAmount   = sdkerrors.Register(ModuleName, 10, "remaining rewards amount invariant broken")
	ErrInvalidOutstandingRewardsAmount = sdkerrors.Register(ModuleName, 11, "outstanding rewards amount invariant broken")
	ErrNumPrivatePlansLimit            = sdkerrors.Register(ModuleName, 12, "cannot create private plans more than the limit")
	ErrNumMaxDenomsLimit               = sdkerrors.Register(ModuleName, 13, "number of denoms cannot exceed the limit")
	ErrInvalidEpochAmount              = sdkerrors.Register(ModuleName, 14, "invalid epoch amount")
	ErrRatioPlanDisabled               = sdkerrors.Register(ModuleName, 15, "creation of ratio plans is disabled")
	ErrInvalidUnharvestedRewardsAmount = sdkerrors.Register(ModuleName, 16, "invalid unharvested rewards amount")
)

farming module sentinel errors

View Source
var (
	ErrInvalidLengthFarming        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFarming          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupFarming = 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 (
	GlobalPlanIdKey     = []byte("globalPlanId")
	LastEpochTimeKey    = []byte("lastEpochTime")
	CurrentEpochDaysKey = []byte("currentEpochDays")

	PlanKeyPrefix = []byte{0x11}

	StakingKeyPrefix            = []byte{0x21}
	StakingIndexKeyPrefix       = []byte{0x22}
	QueuedStakingKeyPrefix      = []byte{0x23}
	QueuedStakingIndexKeyPrefix = []byte{0x24}
	TotalStakingKeyPrefix       = []byte{0x25}

	HistoricalRewardsKeyPrefix  = []byte{0x31}
	CurrentEpochKeyPrefix       = []byte{0x32}
	OutstandingRewardsKeyPrefix = []byte{0x33}
	UnharvestedRewardsKeyPrefix = []byte{0x34}
)

keys for farming store prefixes

View Source
var (
	KeyPrivatePlanCreationFee = []byte("PrivatePlanCreationFee")
	KeyNextEpochDays          = []byte("NextEpochDays")
	KeyFarmingFeeCollector    = []byte("FarmingFeeCollector")
	KeyDelayedStakingGasFee   = []byte("DelayedStakingGasFee")
	KeyMaxNumPrivatePlans     = []byte("MaxNumPrivatePlans")

	DefaultPrivatePlanCreationFee = sdk.NewCoins(sdk.NewCoin(sdk.DefaultBondDenom, sdk.NewInt(1_000_000_000)))
	DefaultCurrentEpochDays       = uint32(1)
	DefaultNextEpochDays          = uint32(1)
	DefaultFarmingFeeCollector    = sdk.AccAddress(address.Module(ModuleName, []byte("FarmingFeeCollectorAcc")))
	DefaultDelayedStakingGasFee   = sdk.Gas(60000) // See https://github.com/tendermint/farming/issues/102 for details.
	DefaultMaxNumPrivatePlans     = uint32(10000)

	// ReserveAddressType is an address type of reserve accounts for staking or rewards.
	// The module uses the address type of 32 bytes length, but it can be changed depending on Cosmos SDK's direction.
	// The discussion around this issue can be found in this link.
	// https://github.com/tendermint/farming/issues/200
	ReserveAddressType           = AddressType32Bytes
	RewardsReserveAcc            = DeriveAddress(ReserveAddressType, ModuleName, RewardReserveAccName)
	UnharvestedRewardsReserveAcc = DeriveAddress(ReserveAddressType, ModuleName, UnharvestedRewardsReserveAccName)
)

Parameter store keys

View Source
var (
	ErrInvalidLengthProposal        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowProposal          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupProposal = 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 AddressType_name = map[int32]string{
	0: "ADDRESS_TYPE_32_BYTES",
	1: "ADDRESS_TYPE_20_BYTES",
}
View Source
var AddressType_value = map[string]int32{
	"ADDRESS_TYPE_32_BYTES": 0,
	"ADDRESS_TYPE_20_BYTES": 1,
}
View Source
var (

	// ModuleCdc references the global x/farming module codec. Note, the codec
	// should ONLY be used in certain instances of tests and for JSON encoding as Amino
	// is still used for that purpose.
	//
	// The actual codec used for serialization should be provided to x/farming and
	// defined at the application level.
	ModuleCdc = codec.NewAminoCodec(amino)
)
View Source
var PlanType_name = map[int32]string{
	0: "PLAN_TYPE_UNSPECIFIED",
	1: "PLAN_TYPE_PUBLIC",
	2: "PLAN_TYPE_PRIVATE",
}
View Source
var PlanType_value = map[string]int32{
	"PLAN_TYPE_UNSPECIFIED": 0,
	"PLAN_TYPE_PUBLIC":      1,
	"PLAN_TYPE_PRIVATE":     2,
}

Functions

func DateRangeIncludes

func DateRangeIncludes(startTime, endTime, targetTime time.Time) bool

DateRangeIncludes returns true if the target date included on the start, end time range. End time is exclusive and start time is inclusive.

func DeriveAddress

func DeriveAddress(addressType AddressType, moduleName, name string) sdk.AccAddress

DeriveAddress derives an address with the given address length type, module name, and address derivation name. It is used to derive private plan farming pool address, and staking reserve address.

func GetCurrentEpochKey

func GetCurrentEpochKey(stakingCoinDenom string) []byte

GetCurrentEpochKey returns a key for a current epoch info.

func GetHistoricalRewardsKey

func GetHistoricalRewardsKey(stakingCoinDenom string, epoch uint64) []byte

GetHistoricalRewardsKey returns a key for a historical rewards record.

func GetHistoricalRewardsPrefix

func GetHistoricalRewardsPrefix(stakingCoinDenom string) []byte

GetHistoricalRewardsPrefix returns a key prefix used to iterate historical rewards by a staking coin denom.

func GetOutstandingRewardsKey

func GetOutstandingRewardsKey(stakingCoinDenom string) []byte

GetOutstandingRewardsKey returns a key for an outstanding rewards record.

func GetPlanKey

func GetPlanKey(planID uint64) []byte

GetPlanKey returns kv indexing key of the plan

func GetQueuedStakingEndBytes

func GetQueuedStakingEndBytes(endTime time.Time) []byte

GetQueuedStakingEndBytes returns end bytes for iteration of queued stakings. The returned end bytes should be used directly, not through sdk.InclusiveEndBytes. The range this end bytes form includes queued stakings with same endTime.

func GetQueuedStakingIndexKey

func GetQueuedStakingIndexKey(farmerAcc sdk.AccAddress, stakingCoinDenom string, endTime time.Time) []byte

GetQueuedStakingIndexKey returns an indexing key for a queued staking.

func GetQueuedStakingKey

func GetQueuedStakingKey(endTime time.Time, stakingCoinDenom string, farmerAcc sdk.AccAddress) []byte

GetQueuedStakingKey returns a key for a queued staking.

func GetQueuedStakingsByFarmerAndDenomPrefix

func GetQueuedStakingsByFarmerAndDenomPrefix(farmerAcc sdk.AccAddress, stakingCoinDenom string) []byte

GetQueuedStakingsByFarmerAndDenomPrefix returns a key prefix used to iterate queued stakings by farmer address and staking coin denom.

func GetQueuedStakingsByFarmerPrefix

func GetQueuedStakingsByFarmerPrefix(farmerAcc sdk.AccAddress) []byte

GetQueuedStakingsByFarmerPrefix returns a key prefix used to iterate queued stakings by a farmer.

func GetStakingIndexKey

func GetStakingIndexKey(farmerAcc sdk.AccAddress, stakingCoinDenom string) []byte

GetStakingIndexKey returns an indexing key for a staking.

func GetStakingKey

func GetStakingKey(stakingCoinDenom string, farmerAcc sdk.AccAddress) []byte

GetStakingKey returns a key for staking of corresponding the id

func GetStakingsByFarmerPrefix

func GetStakingsByFarmerPrefix(farmerAcc sdk.AccAddress) []byte

GetStakingsByFarmerPrefix returns a key prefix used to iterate stakings by a farmer.

func GetTotalStakingsKey

func GetTotalStakingsKey(stakingCoinDenom string) []byte

GetTotalStakingsKey returns a key for a total stakings info.

func GetUnharvestedRewardsKey

func GetUnharvestedRewardsKey(farmerAcc sdk.AccAddress, stakingCoinDenom string) []byte

GetUnharvestedRewardsKey returns a key for unharvested rewards.

func GetUnharvestedRewardsPrefix

func GetUnharvestedRewardsPrefix(farmerAcc sdk.AccAddress) []byte

GetUnharvestedRewardsPrefix returns a key to iterate unharvested rewards by a farmer.

func IsPlanActiveAt

func IsPlanActiveAt(plan PlanI, t time.Time) bool

IsPlanActiveAt returns if the plan is active at given time t.

func LengthPrefixString

func LengthPrefixString(s string) []byte

LengthPrefixString returns length-prefixed bytes representation of a string.

func LengthPrefixTimeBytes

func LengthPrefixTimeBytes(t time.Time) []byte

LengthPrefixTimeBytes returns length-prefixed bytes representation of time.Time.

func PackPlan

func PackPlan(plan PlanI) (*codectypes.Any, error)

PackPlan converts PlanI to Any

func ParamKeyTable

func ParamKeyTable() paramstypes.KeyTable

ParamKeyTable returns the parameter key table.

func ParseCurrentEpochKey

func ParseCurrentEpochKey(key []byte) (stakingCoinDenom string)

ParseCurrentEpochKey parses a current epoch key.

func ParseHistoricalRewardsKey

func ParseHistoricalRewardsKey(key []byte) (stakingCoinDenom string, epoch uint64)

ParseHistoricalRewardsKey parses a historical rewards key.

func ParseOutstandingRewardsKey

func ParseOutstandingRewardsKey(key []byte) (stakingCoinDenom string)

ParseOutstandingRewardsKey parses an outstanding rewards key.

func ParseQueuedStakingIndexKey

func ParseQueuedStakingIndexKey(key []byte) (farmerAcc sdk.AccAddress, stakingCoinDenom string, endTime time.Time)

ParseQueuedStakingIndexKey parses a queued staking index key.

func ParseQueuedStakingKey

func ParseQueuedStakingKey(key []byte) (endTime time.Time, stakingCoinDenom string, farmerAcc sdk.AccAddress)

ParseQueuedStakingKey parses a queued staking key.

func ParseStakingIndexKey

func ParseStakingIndexKey(key []byte) (farmerAcc sdk.AccAddress, stakingCoinDenom string)

ParseStakingIndexKey parses a staking index key.

func ParseStakingKey

func ParseStakingKey(key []byte) (stakingCoinDenom string, farmerAcc sdk.AccAddress)

ParseStakingKey parses a staking key.

func ParseTime

func ParseTime(s string) time.Time

ParseTime parses string time to time in RFC3339 format. This is used only for internal testing purpose.

func ParseTotalStakingsKey

func ParseTotalStakingsKey(key []byte) (stakingCoinDenom string)

ParseTotalStakingsKey parses a total stakings key.

func ParseUnharvestedRewardsKey

func ParseUnharvestedRewardsKey(key []byte) (farmerAcc sdk.AccAddress, stakingCoinDenom string)

func PrivatePlanFarmingPoolAcc

func PrivatePlanFarmingPoolAcc(name string, planId uint64) sdk.AccAddress

PrivatePlanFarmingPoolAcc returns a unique farming pool address for a newly created plan.

func RegisterInterfaces

func RegisterInterfaces(registry types.InterfaceRegistry)

RegisterInterfaces registers the x/farming interfaces types with the interface registry

func RegisterLegacyAminoCodec

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

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

func RegisterMsgServer

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func 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 (such as grpc.SendHeader, etc) to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func StakingReserveAcc

func StakingReserveAcc(stakingCoinDenom string) sdk.AccAddress

StakingReserveAcc returns module account for the staking reserve pool account by staking coin denom and type.

func ValidateEpochAmount

func ValidateEpochAmount(epochAmount sdk.Coins) error

ValidateEpochAmount validate a epoch amount that must be valid coins.

func ValidateEpochRatio

func ValidateEpochRatio(epochRatio sdk.Dec) error

ValidateEpochRatio validate a epoch ratio that must be positive and less than 1.

func ValidateGenesis

func ValidateGenesis(data GenesisState) error

ValidateGenesis validates GenesisState.

func ValidatePlanName

func ValidatePlanName(name string) error

ValidatePlanName validates a plan name.

func ValidateStakingCoinTotalWeights

func ValidateStakingCoinTotalWeights(weights sdk.DecCoins) error

ValidateStakingCoinTotalWeights validates the total staking coin weights must be equal to 1.

func ValidateTotalEpochRatio

func ValidateTotalEpochRatio(plans []PlanI) error

ValidateTotalEpochRatio validates a farmer's total epoch ratio that must be equal to 1.

Types

type AccountKeeper

type AccountKeeper interface {
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
	GetModuleAddress(name string) sdk.AccAddress
}

AccountKeeper defines the expected account keeper

type AddPlanRequest

type AddPlanRequest struct {
	// name specifies the plan name for display
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// farming_pool_address defines the bech32-encoded address of the farming pool
	FarmingPoolAddress string `` /* 145-byte string literal not displayed */
	// termination_address defines the bech32-encoded address that terminates plan
	// when the plan ends after the end time, the balance of farming pool address
	// is transferred to the termination address
	TerminationAddress string `` /* 142-byte string literal not displayed */
	// staking_coin_weights specifies coin weights for the plan
	StakingCoinWeights github_com_cosmos_cosmos_sdk_types.DecCoins `` /* 192-byte string literal not displayed */
	// start_time specifies the start time of the plan
	StartTime time.Time `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time" yaml:"start_time"`
	// end_time specifies the end time of the plan
	EndTime time.Time `protobuf:"bytes,6,opt,name=end_time,json=endTime,proto3,stdtime" json:"end_time" yaml:"end_time"`
	// epoch_amount specifies the distributing amount for each epoch
	EpochAmount github_com_cosmos_cosmos_sdk_types.Coins `` /* 158-byte string literal not displayed */
	// epoch_ratio specifies the distributing amount by ratio
	EpochRatio github_com_cosmos_cosmos_sdk_types.Dec `` /* 150-byte string literal not displayed */
}

AddPlanRequest details a proposal for creating a public plan.

func NewAddPlanRequest

func NewAddPlanRequest(
	name string,
	farmingPoolAddr string,
	terminationAddr string,
	stakingCoinWeights sdk.DecCoins,
	startTime time.Time,
	endTime time.Time,
	epochAmount sdk.Coins,
	epochRatio sdk.Dec,
) AddPlanRequest

NewAddPlanRequest creates a new AddPlanRequest object

func (*AddPlanRequest) Descriptor

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

func (*AddPlanRequest) GetEndTime

func (m *AddPlanRequest) GetEndTime() time.Time

func (*AddPlanRequest) GetEpochAmount

func (*AddPlanRequest) GetFarmingPoolAddress

func (m *AddPlanRequest) GetFarmingPoolAddress() string

func (*AddPlanRequest) GetName

func (m *AddPlanRequest) GetName() string

func (*AddPlanRequest) GetStakingCoinWeights

func (m *AddPlanRequest) GetStakingCoinWeights() github_com_cosmos_cosmos_sdk_types.DecCoins

func (*AddPlanRequest) GetStartTime

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

func (*AddPlanRequest) GetTerminationAddress

func (m *AddPlanRequest) GetTerminationAddress() string

func (*AddPlanRequest) IsForFixedAmountPlan

func (p *AddPlanRequest) IsForFixedAmountPlan() bool

IsForFixedAmountPlan returns true if the request is for fixed amount plan. It checks if EpochAmount is not zero.

func (*AddPlanRequest) IsForRatioPlan

func (p *AddPlanRequest) IsForRatioPlan() bool

IsForRatioPlan returns true if the request is for ratio plan. It checks if EpochRatio is not zero.

func (*AddPlanRequest) Marshal

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

func (*AddPlanRequest) MarshalTo

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

func (*AddPlanRequest) MarshalToSizedBuffer

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

func (*AddPlanRequest) ProtoMessage

func (*AddPlanRequest) ProtoMessage()

func (*AddPlanRequest) Reset

func (m *AddPlanRequest) Reset()

func (*AddPlanRequest) Size

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

func (*AddPlanRequest) String

func (m *AddPlanRequest) String() string

func (*AddPlanRequest) Unmarshal

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

func (*AddPlanRequest) Validate

func (p *AddPlanRequest) Validate() error

Validate validates AddPlanRequest.

func (*AddPlanRequest) XXX_DiscardUnknown

func (m *AddPlanRequest) XXX_DiscardUnknown()

func (*AddPlanRequest) XXX_Marshal

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

func (*AddPlanRequest) XXX_Merge

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

func (*AddPlanRequest) XXX_Size

func (m *AddPlanRequest) XXX_Size() int

func (*AddPlanRequest) XXX_Unmarshal

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

type AddressType

type AddressType int32

AddressType enumerates the available types of a address.

const (
	// the 32 bytes length address type of ADR 028.
	AddressType32Bytes AddressType = 0
	// the default 20 bytes length address type.
	AddressType20Bytes AddressType = 1
)

func (AddressType) EnumDescriptor

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

func (AddressType) String

func (x AddressType) String() string

type BankKeeper

type BankKeeper interface {
	SendCoins(ctx sdk.Context, fromAddr sdk.AccAddress, toAddr sdk.AccAddress, amt sdk.Coins) error
	GetSupply(ctx sdk.Context, denom string) sdk.Coin
	GetAllBalances(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	InputOutputCoins(ctx sdk.Context, inputs []banktypes.Input, outputs []banktypes.Output) error
	BlockedAddr(ctx sdk.Context, addr sdk.AccAddress) bool
	AddBlockedAddr(ctx sdk.Context, addr sdk.AccAddress)
	RemoveBlockedAddr(ctx sdk.Context, addr sdk.AccAddress)
	// MintCoins is used only for simulation test codes
	MintCoins(ctx sdk.Context, name string, amt sdk.Coins) error
}

BankKeeper defines the expected bank send keeper

type BasePlan

type BasePlan struct {
	// id specifies index of the farming plan
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// name specifies the name for the plan
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// type specifies the plan type; type 0 is public and 1 is private
	// public plan must be created through governance proposal and private plan is
	// created by account
	Type PlanType `protobuf:"varint,3,opt,name=type,proto3,enum=crescent.farming.v1beta1.PlanType" json:"type,omitempty"`
	// farming_pool_address defines the bech32-encoded address of the farming pool
	FarmingPoolAddress string `` /* 145-byte string literal not displayed */
	// termination_address defines the Bech32-encoded address that terminates the plan
	// when the plan ends after the end time, the balance of the farming pool address
	// is transferred to the termination address
	TerminationAddress string `` /* 142-byte string literal not displayed */
	// staking_coin_weights specifies the coin weights for the plan
	StakingCoinWeights github_com_cosmos_cosmos_sdk_types.DecCoins `` /* 192-byte string literal not displayed */
	// start_time specifies the start time of the plan
	StartTime time.Time `protobuf:"bytes,7,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time" yaml:"start_time"`
	// end_time specifies the end time of the plan
	EndTime time.Time `protobuf:"bytes,8,opt,name=end_time,json=endTime,proto3,stdtime" json:"end_time" yaml:"end_time"`
	// terminated indicates whether the plan has been terminated or not
	Terminated bool `protobuf:"varint,9,opt,name=terminated,proto3" json:"terminated,omitempty"`
	// last_distribution_time specifies the last time a distribution occurred
	LastDistributionTime *time.Time `` /* 162-byte string literal not displayed */
	// distributed_coins specifies the total coins distributed by this plan
	DistributedCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 179-byte string literal not displayed */
}

BasePlan defines a base plan type and contains the required fields for basic farming plan functionality. Any custom farming plan type must extend this type for additional functionality (for example, fixed amount plan, ratio plan).

func NewBasePlan

func NewBasePlan(id uint64, name string, typ PlanType, farmingPoolAddr, terminationAddr string, coinWeights sdk.DecCoins, startTime, endTime time.Time) *BasePlan

NewBasePlan creates a new BasePlan object

func (*BasePlan) Descriptor

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

func (BasePlan) GetBasePlan

func (plan BasePlan) GetBasePlan() *BasePlan

func (*BasePlan) GetDistributedCoins

func (plan *BasePlan) GetDistributedCoins() sdk.Coins

func (BasePlan) GetEndTime

func (plan BasePlan) GetEndTime() time.Time

func (BasePlan) GetFarmingPoolAddress

func (plan BasePlan) GetFarmingPoolAddress() sdk.AccAddress

func (BasePlan) GetId

func (plan BasePlan) GetId() uint64

func (*BasePlan) GetLastDistributionTime

func (plan *BasePlan) GetLastDistributionTime() *time.Time

func (BasePlan) GetName

func (plan BasePlan) GetName() string

func (BasePlan) GetStakingCoinWeights

func (plan BasePlan) GetStakingCoinWeights() sdk.DecCoins

func (BasePlan) GetStartTime

func (plan BasePlan) GetStartTime() time.Time

func (BasePlan) GetTerminationAddress

func (plan BasePlan) GetTerminationAddress() sdk.AccAddress

func (BasePlan) GetType

func (plan BasePlan) GetType() PlanType

func (*BasePlan) IsTerminated

func (plan *BasePlan) IsTerminated() bool

func (*BasePlan) Marshal

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

func (*BasePlan) MarshalTo

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

func (*BasePlan) MarshalToSizedBuffer

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

func (*BasePlan) ProtoMessage

func (*BasePlan) ProtoMessage()

func (*BasePlan) Reset

func (m *BasePlan) Reset()

func (*BasePlan) SetDistributedCoins

func (plan *BasePlan) SetDistributedCoins(distributedCoins sdk.Coins) error

func (*BasePlan) SetEndTime

func (plan *BasePlan) SetEndTime(t time.Time) error

func (*BasePlan) SetFarmingPoolAddress

func (plan *BasePlan) SetFarmingPoolAddress(addr sdk.AccAddress) error

func (*BasePlan) SetId

func (plan *BasePlan) SetId(id uint64) error

func (*BasePlan) SetLastDistributionTime

func (plan *BasePlan) SetLastDistributionTime(t *time.Time) error

func (*BasePlan) SetName

func (plan *BasePlan) SetName(name string) error

func (*BasePlan) SetStakingCoinWeights

func (plan *BasePlan) SetStakingCoinWeights(coinWeights sdk.DecCoins) error

func (*BasePlan) SetStartTime

func (plan *BasePlan) SetStartTime(t time.Time) error

func (*BasePlan) SetTerminated

func (plan *BasePlan) SetTerminated(terminated bool) error

func (*BasePlan) SetTerminationAddress

func (plan *BasePlan) SetTerminationAddress(addr sdk.AccAddress) error

func (*BasePlan) SetType

func (plan *BasePlan) SetType(typ PlanType) error

func (*BasePlan) Size

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

func (*BasePlan) String

func (m *BasePlan) String() string

func (*BasePlan) Unmarshal

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

func (BasePlan) Validate

func (plan BasePlan) Validate() error

Validate checks for errors on the Plan fields

func (*BasePlan) XXX_DiscardUnknown

func (m *BasePlan) XXX_DiscardUnknown()

func (*BasePlan) XXX_Marshal

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

func (*BasePlan) XXX_Merge

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

func (*BasePlan) XXX_Size

func (m *BasePlan) XXX_Size() int

func (*BasePlan) XXX_Unmarshal

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

type CurrentEpochRecord

type CurrentEpochRecord struct {
	StakingCoinDenom string `` /* 137-byte string literal not displayed */
	CurrentEpoch     uint64 `protobuf:"varint,2,opt,name=current_epoch,json=currentEpoch,proto3" json:"current_epoch,omitempty" yaml:"current_epoch"`
}

CurrentEpochRecord is used for import/export via genesis json.

func (*CurrentEpochRecord) Descriptor

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

func (*CurrentEpochRecord) Marshal

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

func (*CurrentEpochRecord) MarshalTo

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

func (*CurrentEpochRecord) MarshalToSizedBuffer

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

func (*CurrentEpochRecord) ProtoMessage

func (*CurrentEpochRecord) ProtoMessage()

func (*CurrentEpochRecord) Reset

func (m *CurrentEpochRecord) Reset()

func (*CurrentEpochRecord) Size

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

func (*CurrentEpochRecord) String

func (m *CurrentEpochRecord) String() string

func (*CurrentEpochRecord) Unmarshal

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

func (CurrentEpochRecord) Validate

func (record CurrentEpochRecord) Validate() error

Validate validates CurrentEpochRecord.

func (*CurrentEpochRecord) XXX_DiscardUnknown

func (m *CurrentEpochRecord) XXX_DiscardUnknown()

func (*CurrentEpochRecord) XXX_Marshal

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

func (*CurrentEpochRecord) XXX_Merge

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

func (*CurrentEpochRecord) XXX_Size

func (m *CurrentEpochRecord) XXX_Size() int

func (*CurrentEpochRecord) XXX_Unmarshal

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

type DeletePlanRequest

type DeletePlanRequest struct {
	// plan_id specifies index of the farming plan
	PlanId uint64 `protobuf:"varint,1,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty"`
}

DeletePlanRequest details a proposal for deleting an existing public plan.

func NewDeletePlanRequest

func NewDeletePlanRequest(id uint64) DeletePlanRequest

NewDeletePlanRequest creates a new DeletePlanRequest object.

func (*DeletePlanRequest) Descriptor

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

func (*DeletePlanRequest) GetPlanId

func (m *DeletePlanRequest) GetPlanId() uint64

func (*DeletePlanRequest) Marshal

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

func (*DeletePlanRequest) MarshalTo

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

func (*DeletePlanRequest) MarshalToSizedBuffer

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

func (*DeletePlanRequest) ProtoMessage

func (*DeletePlanRequest) ProtoMessage()

func (*DeletePlanRequest) Reset

func (m *DeletePlanRequest) Reset()

func (*DeletePlanRequest) Size

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

func (*DeletePlanRequest) String

func (m *DeletePlanRequest) String() string

func (*DeletePlanRequest) Unmarshal

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

func (*DeletePlanRequest) Validate

func (p *DeletePlanRequest) Validate() error

Validate validates DeletePlanRequest.

func (*DeletePlanRequest) XXX_DiscardUnknown

func (m *DeletePlanRequest) XXX_DiscardUnknown()

func (*DeletePlanRequest) XXX_Marshal

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

func (*DeletePlanRequest) XXX_Merge

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

func (*DeletePlanRequest) XXX_Size

func (m *DeletePlanRequest) XXX_Size() int

func (*DeletePlanRequest) XXX_Unmarshal

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

type FixedAmountPlan

type FixedAmountPlan struct {
	*BasePlan `protobuf:"bytes,1,opt,name=base_plan,json=basePlan,proto3,embedded=base_plan" json:"base_plan,omitempty" yaml:"base_plan"`
	// epoch_amount specifies the distributing amount for each epoch
	EpochAmount github_com_cosmos_cosmos_sdk_types.Coins `` /* 158-byte string literal not displayed */
}

FixedAmountPlan defines a fixed amount plan that distributes a fixed amount of coins for every epoch.

func NewFixedAmountPlan

func NewFixedAmountPlan(basePlan *BasePlan, epochAmount sdk.Coins) *FixedAmountPlan

NewFixedAmountPlan returns a new fixed amount plan.

func (*FixedAmountPlan) Descriptor

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

func (*FixedAmountPlan) Marshal

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

func (*FixedAmountPlan) MarshalTo

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

func (*FixedAmountPlan) MarshalToSizedBuffer

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

func (*FixedAmountPlan) ProtoMessage

func (*FixedAmountPlan) ProtoMessage()

func (*FixedAmountPlan) Reset

func (m *FixedAmountPlan) Reset()

func (*FixedAmountPlan) Size

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

func (*FixedAmountPlan) String

func (m *FixedAmountPlan) String() string

func (*FixedAmountPlan) Unmarshal

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

func (*FixedAmountPlan) XXX_DiscardUnknown

func (m *FixedAmountPlan) XXX_DiscardUnknown()

func (*FixedAmountPlan) XXX_Marshal

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

func (*FixedAmountPlan) XXX_Merge

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

func (*FixedAmountPlan) XXX_Size

func (m *FixedAmountPlan) XXX_Size() int

func (*FixedAmountPlan) XXX_Unmarshal

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

type GenesisState

type GenesisState struct {
	// params defines all the parameters for the farming module
	Params       Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	GlobalPlanId uint64 `protobuf:"varint,2,opt,name=global_plan_id,json=globalPlanId,proto3" json:"global_plan_id,omitempty" yaml:"global_plan_id"`
	// plan_records defines the plan records used for genesis state
	PlanRecords               []PlanRecord               `protobuf:"bytes,3,rep,name=plan_records,json=planRecords,proto3" json:"plan_records" yaml:"plan_records"`
	StakingRecords            []StakingRecord            `protobuf:"bytes,4,rep,name=staking_records,json=stakingRecords,proto3" json:"staking_records" yaml:"staking_records"`
	QueuedStakingRecords      []QueuedStakingRecord      `` /* 143-byte string literal not displayed */
	HistoricalRewardsRecords  []HistoricalRewardsRecord  `` /* 159-byte string literal not displayed */
	OutstandingRewardsRecords []OutstandingRewardsRecord `` /* 163-byte string literal not displayed */
	UnharvestedRewardsRecords []UnharvestedRewardsRecord `` /* 163-byte string literal not displayed */
	CurrentEpochRecords       []CurrentEpochRecord       `` /* 139-byte string literal not displayed */
	TotalStakingsRecords      []TotalStakingsRecord      `` /* 144-byte string literal not displayed */
	// reward_pool_coins specifies balance of the reward pool to be distributed in the plans
	// this param is needed for import/export validation
	RewardPoolCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 178-byte string literal not displayed */
	// last_epoch_time specifies the last executed epoch time of the plans
	LastEpochTime *time.Time `` /* 134-byte string literal not displayed */
	// current_epoch_days specifies the epoch used when allocating farming rewards in end blocker
	CurrentEpochDays uint32 `protobuf:"varint,13,opt,name=current_epoch_days,json=currentEpochDays,proto3" json:"current_epoch_days,omitempty"`
}

GenesisState defines the farming module's genesis state.

func DefaultGenesisState

func DefaultGenesisState() *GenesisState

DefaultGenesisState returns the default genesis state.

func NewGenesisState

func NewGenesisState(
	params Params, globalPlanId uint64, plans []PlanRecord,
	stakings []StakingRecord, queuedStakings []QueuedStakingRecord, totalStakings []TotalStakingsRecord,
	historicalRewards []HistoricalRewardsRecord, outstandingRewards []OutstandingRewardsRecord,
	unharvestedRewards []UnharvestedRewardsRecord, currentEpochs []CurrentEpochRecord,
	rewardPoolCoins sdk.Coins, lastEpochTime *time.Time, currentEpochDays uint32,
) *GenesisState

NewGenesisState returns new GenesisState.

func (*GenesisState) Descriptor

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

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

type HistoricalRewards struct {
	CumulativeUnitRewards github_com_cosmos_cosmos_sdk_types.DecCoins `` /* 204-byte string literal not displayed */
}

HistoricalRewards defines the cumulative unit rewards for a given staking coin denom and an epoch number.

func (*HistoricalRewards) Descriptor

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

func (*HistoricalRewards) Marshal

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

func (*HistoricalRewards) MarshalTo

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

func (*HistoricalRewards) MarshalToSizedBuffer

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

func (*HistoricalRewards) ProtoMessage

func (*HistoricalRewards) ProtoMessage()

func (*HistoricalRewards) Reset

func (m *HistoricalRewards) Reset()

func (*HistoricalRewards) Size

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

func (*HistoricalRewards) String

func (m *HistoricalRewards) String() string

func (*HistoricalRewards) Unmarshal

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

func (*HistoricalRewards) XXX_DiscardUnknown

func (m *HistoricalRewards) XXX_DiscardUnknown()

func (*HistoricalRewards) XXX_Marshal

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

func (*HistoricalRewards) XXX_Merge

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

func (*HistoricalRewards) XXX_Size

func (m *HistoricalRewards) XXX_Size() int

func (*HistoricalRewards) XXX_Unmarshal

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

type HistoricalRewardsRecord

type HistoricalRewardsRecord struct {
	StakingCoinDenom  string            `` /* 137-byte string literal not displayed */
	Epoch             uint64            `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	HistoricalRewards HistoricalRewards `` /* 128-byte string literal not displayed */
}

HistoricalRewardsRecord is used for import/export via genesis json.

func (*HistoricalRewardsRecord) Descriptor

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

func (*HistoricalRewardsRecord) Marshal

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

func (*HistoricalRewardsRecord) MarshalTo

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

func (*HistoricalRewardsRecord) MarshalToSizedBuffer

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

func (*HistoricalRewardsRecord) ProtoMessage

func (*HistoricalRewardsRecord) ProtoMessage()

func (*HistoricalRewardsRecord) Reset

func (m *HistoricalRewardsRecord) Reset()

func (*HistoricalRewardsRecord) Size

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

func (*HistoricalRewardsRecord) String

func (m *HistoricalRewardsRecord) String() string

func (*HistoricalRewardsRecord) Unmarshal

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

func (HistoricalRewardsRecord) Validate

func (record HistoricalRewardsRecord) Validate() error

Validate validates HistoricalRewardsRecord.

func (*HistoricalRewardsRecord) XXX_DiscardUnknown

func (m *HistoricalRewardsRecord) XXX_DiscardUnknown()

func (*HistoricalRewardsRecord) XXX_Marshal

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

func (*HistoricalRewardsRecord) XXX_Merge

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

func (*HistoricalRewardsRecord) XXX_Size

func (m *HistoricalRewardsRecord) XXX_Size() int

func (*HistoricalRewardsRecord) XXX_Unmarshal

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

type HistoricalRewardsResponse

type HistoricalRewardsResponse struct {
	Epoch                 uint64                                      `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	CumulativeUnitRewards github_com_cosmos_cosmos_sdk_types.DecCoins `` /* 173-byte string literal not displayed */
}

func (*HistoricalRewardsResponse) Descriptor

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

func (*HistoricalRewardsResponse) GetCumulativeUnitRewards

func (*HistoricalRewardsResponse) GetEpoch

func (m *HistoricalRewardsResponse) GetEpoch() uint64

func (*HistoricalRewardsResponse) Marshal

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

func (*HistoricalRewardsResponse) MarshalTo

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

func (*HistoricalRewardsResponse) MarshalToSizedBuffer

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

func (*HistoricalRewardsResponse) ProtoMessage

func (*HistoricalRewardsResponse) ProtoMessage()

func (*HistoricalRewardsResponse) Reset

func (m *HistoricalRewardsResponse) Reset()

func (*HistoricalRewardsResponse) Size

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

func (*HistoricalRewardsResponse) String

func (m *HistoricalRewardsResponse) String() string

func (*HistoricalRewardsResponse) Unmarshal

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

func (*HistoricalRewardsResponse) XXX_DiscardUnknown

func (m *HistoricalRewardsResponse) XXX_DiscardUnknown()

func (*HistoricalRewardsResponse) XXX_Marshal

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

func (*HistoricalRewardsResponse) XXX_Merge

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

func (*HistoricalRewardsResponse) XXX_Size

func (m *HistoricalRewardsResponse) XXX_Size() int

func (*HistoricalRewardsResponse) XXX_Unmarshal

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

type ModifyPlanRequest

type ModifyPlanRequest struct {
	// plan_id specifies index of the farming plan
	PlanId uint64 `protobuf:"varint,1,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty"`
	// name specifies the plan name for display
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// farming_pool_address defines the bech32-encoded address of the farming pool
	FarmingPoolAddress string `` /* 145-byte string literal not displayed */
	// termination_address defines the bech32-encoded address that terminates plan
	// when the plan ends after the end time, the balance of farming pool address
	// is transferred to the termination address
	TerminationAddress string `` /* 142-byte string literal not displayed */
	// staking_coin_weights specifies coin weights for the plan
	StakingCoinWeights github_com_cosmos_cosmos_sdk_types.DecCoins `` /* 192-byte string literal not displayed */
	// start_time specifies the start time of the plan
	StartTime *time.Time `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time,omitempty" yaml:"start_time"`
	// end_time specifies the end time of the plan
	EndTime *time.Time `protobuf:"bytes,7,opt,name=end_time,json=endTime,proto3,stdtime" json:"end_time,omitempty" yaml:"end_time"`
	// epoch_amount specifies the distributing amount for each epoch
	EpochAmount github_com_cosmos_cosmos_sdk_types.Coins `` /* 158-byte string literal not displayed */
	// epoch_ratio specifies the distributing amount by ratio
	EpochRatio github_com_cosmos_cosmos_sdk_types.Dec `` /* 150-byte string literal not displayed */
}

ModifyPlanRequest details a proposal for modifying the existing public plan.

func NewModifyPlanRequest

func NewModifyPlanRequest(
	id uint64,
	name string,
	farmingPoolAddr string,
	terminationAddr string,
	stakingCoinWeights sdk.DecCoins,
	startTime time.Time,
	endTime time.Time,
	epochAmount sdk.Coins,
	epochRatio sdk.Dec,
) ModifyPlanRequest

NewModifyPlanRequest creates a new ModifyPlanRequest object.

func (*ModifyPlanRequest) Descriptor

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

func (*ModifyPlanRequest) GetEndTime

func (m *ModifyPlanRequest) GetEndTime() *time.Time

func (*ModifyPlanRequest) GetEpochAmount

func (*ModifyPlanRequest) GetFarmingPoolAddress

func (m *ModifyPlanRequest) GetFarmingPoolAddress() string

func (*ModifyPlanRequest) GetName

func (m *ModifyPlanRequest) GetName() string

func (*ModifyPlanRequest) GetPlanId

func (m *ModifyPlanRequest) GetPlanId() uint64

func (*ModifyPlanRequest) GetStakingCoinWeights

func (*ModifyPlanRequest) GetStartTime

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

func (*ModifyPlanRequest) GetTerminationAddress

func (m *ModifyPlanRequest) GetTerminationAddress() string

func (*ModifyPlanRequest) IsForFixedAmountPlan

func (p *ModifyPlanRequest) IsForFixedAmountPlan() bool

IsForFixedAmountPlan returns true if the request is for fixed amount plan. It checks if EpochAmount is not zero.

func (*ModifyPlanRequest) IsForRatioPlan

func (p *ModifyPlanRequest) IsForRatioPlan() bool

IsForRatioPlan returns true if the request is for ratio plan. It checks if EpochRatio is not zero.

func (*ModifyPlanRequest) Marshal

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

func (*ModifyPlanRequest) MarshalTo

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

func (*ModifyPlanRequest) MarshalToSizedBuffer

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

func (*ModifyPlanRequest) ProtoMessage

func (*ModifyPlanRequest) ProtoMessage()

func (*ModifyPlanRequest) Reset

func (m *ModifyPlanRequest) Reset()

func (*ModifyPlanRequest) Size

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

func (*ModifyPlanRequest) String

func (m *ModifyPlanRequest) String() string

func (*ModifyPlanRequest) Unmarshal

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

func (*ModifyPlanRequest) Validate

func (p *ModifyPlanRequest) Validate() error

Validate validates ModifyPlanRequest.

func (*ModifyPlanRequest) XXX_DiscardUnknown

func (m *ModifyPlanRequest) XXX_DiscardUnknown()

func (*ModifyPlanRequest) XXX_Marshal

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

func (*ModifyPlanRequest) XXX_Merge

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

func (*ModifyPlanRequest) XXX_Size

func (m *ModifyPlanRequest) XXX_Size() int

func (*ModifyPlanRequest) XXX_Unmarshal

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

type MsgAdvanceEpoch

type MsgAdvanceEpoch struct {
	// requester defines the bech32-encoded address of the requester
	Requester string `protobuf:"bytes,1,opt,name=requester,proto3" json:"requester,omitempty"`
}

MsgAdvanceEpoch defines a message to advance epoch by one.

func NewMsgAdvanceEpoch

func NewMsgAdvanceEpoch(requesterAcc sdk.AccAddress) *MsgAdvanceEpoch

NewMsgAdvanceEpoch creates a new MsgAdvanceEpoch.

func (*MsgAdvanceEpoch) Descriptor

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

func (MsgAdvanceEpoch) GetSignBytes

func (msg MsgAdvanceEpoch) GetSignBytes() []byte

func (MsgAdvanceEpoch) GetSigners

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

func (*MsgAdvanceEpoch) Marshal

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

func (*MsgAdvanceEpoch) MarshalTo

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

func (*MsgAdvanceEpoch) MarshalToSizedBuffer

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

func (*MsgAdvanceEpoch) ProtoMessage

func (*MsgAdvanceEpoch) ProtoMessage()

func (*MsgAdvanceEpoch) Reset

func (m *MsgAdvanceEpoch) Reset()

func (MsgAdvanceEpoch) Route

func (msg MsgAdvanceEpoch) Route() string

func (*MsgAdvanceEpoch) Size

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

func (*MsgAdvanceEpoch) String

func (m *MsgAdvanceEpoch) String() string

func (MsgAdvanceEpoch) Type

func (msg MsgAdvanceEpoch) Type() string

func (*MsgAdvanceEpoch) Unmarshal

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

func (MsgAdvanceEpoch) ValidateBasic

func (msg MsgAdvanceEpoch) ValidateBasic() error

func (*MsgAdvanceEpoch) XXX_DiscardUnknown

func (m *MsgAdvanceEpoch) XXX_DiscardUnknown()

func (*MsgAdvanceEpoch) XXX_Marshal

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

func (*MsgAdvanceEpoch) XXX_Merge

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

func (*MsgAdvanceEpoch) XXX_Size

func (m *MsgAdvanceEpoch) XXX_Size() int

func (*MsgAdvanceEpoch) XXX_Unmarshal

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

type MsgAdvanceEpochResponse

type MsgAdvanceEpochResponse struct {
}

MsgAdvanceEpochResponse defines the Msg/AdvanceEpoch response type.

func (*MsgAdvanceEpochResponse) Descriptor

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

func (*MsgAdvanceEpochResponse) Marshal

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

func (*MsgAdvanceEpochResponse) MarshalTo

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

func (*MsgAdvanceEpochResponse) MarshalToSizedBuffer

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

func (*MsgAdvanceEpochResponse) ProtoMessage

func (*MsgAdvanceEpochResponse) ProtoMessage()

func (*MsgAdvanceEpochResponse) Reset

func (m *MsgAdvanceEpochResponse) Reset()

func (*MsgAdvanceEpochResponse) Size

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

func (*MsgAdvanceEpochResponse) String

func (m *MsgAdvanceEpochResponse) String() string

func (*MsgAdvanceEpochResponse) Unmarshal

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

func (*MsgAdvanceEpochResponse) XXX_DiscardUnknown

func (m *MsgAdvanceEpochResponse) XXX_DiscardUnknown()

func (*MsgAdvanceEpochResponse) XXX_Marshal

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

func (*MsgAdvanceEpochResponse) XXX_Merge

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

func (*MsgAdvanceEpochResponse) XXX_Size

func (m *MsgAdvanceEpochResponse) XXX_Size() int

func (*MsgAdvanceEpochResponse) XXX_Unmarshal

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

type MsgClient

type MsgClient interface {
	// CreateFixedAmountPlan defines a method for creating a new fixed amount
	// farming plan
	CreateFixedAmountPlan(ctx context.Context, in *MsgCreateFixedAmountPlan, opts ...grpc.CallOption) (*MsgCreateFixedAmountPlanResponse, error)
	// CreateRatioPlan defines a method for creating a new ratio farming plan
	CreateRatioPlan(ctx context.Context, in *MsgCreateRatioPlan, opts ...grpc.CallOption) (*MsgCreateRatioPlanResponse, error)
	// Stake defines a method for staking coins into the farming plan
	Stake(ctx context.Context, in *MsgStake, opts ...grpc.CallOption) (*MsgStakeResponse, error)
	// Unstake defines a method for unstaking coins from the farming plan
	Unstake(ctx context.Context, in *MsgUnstake, opts ...grpc.CallOption) (*MsgUnstakeResponse, error)
	// Harvest defines a method for claiming farming rewards
	Harvest(ctx context.Context, in *MsgHarvest, opts ...grpc.CallOption) (*MsgHarvestResponse, error)
	// RemovePlan defines a method for removing a terminated plan.
	RemovePlan(ctx context.Context, in *MsgRemovePlan, opts ...grpc.CallOption) (*MsgRemovePlanResponse, error)
	// AdvanceEpoch defines a method for advancing epoch by one, just for testing purpose
	// and shouldn't be used in real world
	AdvanceEpoch(ctx context.Context, in *MsgAdvanceEpoch, opts ...grpc.CallOption) (*MsgAdvanceEpochResponse, 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 MsgCreateFixedAmountPlan

type MsgCreateFixedAmountPlan struct {
	// name specifies the name for the plan
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// creator defines the bech32-encoded address of the creator for the private plan, termination address is also set to
	// this creator.
	Creator string `protobuf:"bytes,2,opt,name=creator,proto3" json:"creator,omitempty"`
	// staking_coin_weights specifies coins weight for the plan
	StakingCoinWeights github_com_cosmos_cosmos_sdk_types.DecCoins `` /* 192-byte string literal not displayed */
	// start_time specifies the start time of the plan
	StartTime time.Time `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time" yaml:"start_time"`
	// end_time specifies the end time of the plan
	EndTime time.Time `protobuf:"bytes,5,opt,name=end_time,json=endTime,proto3,stdtime" json:"end_time" yaml:"end_time"`
	// epoch_amount specifies the distributing amount for each epoch
	EpochAmount github_com_cosmos_cosmos_sdk_types.Coins `` /* 158-byte string literal not displayed */
}

MsgCreateFixedAmountPlan defines a SDK message for creating a new fixed amount farming plan.

func NewMsgCreateFixedAmountPlan

func NewMsgCreateFixedAmountPlan(
	name string,
	creatorAcc sdk.AccAddress,
	stakingCoinWeights sdk.DecCoins,
	startTime time.Time,
	endTime time.Time,
	epochAmount sdk.Coins,
) *MsgCreateFixedAmountPlan

NewMsgCreateFixedAmountPlan creates a new MsgCreateFixedAmountPlan.

func (*MsgCreateFixedAmountPlan) Descriptor

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

func (MsgCreateFixedAmountPlan) GetCreator

func (msg MsgCreateFixedAmountPlan) GetCreator() sdk.AccAddress

func (MsgCreateFixedAmountPlan) GetSignBytes

func (msg MsgCreateFixedAmountPlan) GetSignBytes() []byte

func (MsgCreateFixedAmountPlan) GetSigners

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

func (*MsgCreateFixedAmountPlan) Marshal

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

func (*MsgCreateFixedAmountPlan) MarshalTo

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

func (*MsgCreateFixedAmountPlan) MarshalToSizedBuffer

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

func (*MsgCreateFixedAmountPlan) ProtoMessage

func (*MsgCreateFixedAmountPlan) ProtoMessage()

func (*MsgCreateFixedAmountPlan) Reset

func (m *MsgCreateFixedAmountPlan) Reset()

func (MsgCreateFixedAmountPlan) Route

func (msg MsgCreateFixedAmountPlan) Route() string

func (*MsgCreateFixedAmountPlan) Size

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

func (*MsgCreateFixedAmountPlan) String

func (m *MsgCreateFixedAmountPlan) String() string

func (MsgCreateFixedAmountPlan) Type

func (msg MsgCreateFixedAmountPlan) Type() string

func (*MsgCreateFixedAmountPlan) Unmarshal

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

func (MsgCreateFixedAmountPlan) ValidateBasic

func (msg MsgCreateFixedAmountPlan) ValidateBasic() error

func (*MsgCreateFixedAmountPlan) XXX_DiscardUnknown

func (m *MsgCreateFixedAmountPlan) XXX_DiscardUnknown()

func (*MsgCreateFixedAmountPlan) XXX_Marshal

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

func (*MsgCreateFixedAmountPlan) XXX_Merge

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

func (*MsgCreateFixedAmountPlan) XXX_Size

func (m *MsgCreateFixedAmountPlan) XXX_Size() int

func (*MsgCreateFixedAmountPlan) XXX_Unmarshal

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

type MsgCreateFixedAmountPlanResponse

type MsgCreateFixedAmountPlanResponse struct {
}

MsgCreateFixedAmountPlanResponse defines the MsgCreateFixedAmountPlanResponse response type.

func (*MsgCreateFixedAmountPlanResponse) Descriptor

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

func (*MsgCreateFixedAmountPlanResponse) Marshal

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

func (*MsgCreateFixedAmountPlanResponse) MarshalTo

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

func (*MsgCreateFixedAmountPlanResponse) MarshalToSizedBuffer

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

func (*MsgCreateFixedAmountPlanResponse) ProtoMessage

func (*MsgCreateFixedAmountPlanResponse) ProtoMessage()

func (*MsgCreateFixedAmountPlanResponse) Reset

func (*MsgCreateFixedAmountPlanResponse) Size

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

func (*MsgCreateFixedAmountPlanResponse) String

func (*MsgCreateFixedAmountPlanResponse) Unmarshal

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

func (*MsgCreateFixedAmountPlanResponse) XXX_DiscardUnknown

func (m *MsgCreateFixedAmountPlanResponse) XXX_DiscardUnknown()

func (*MsgCreateFixedAmountPlanResponse) XXX_Marshal

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

func (*MsgCreateFixedAmountPlanResponse) XXX_Merge

func (*MsgCreateFixedAmountPlanResponse) XXX_Size

func (m *MsgCreateFixedAmountPlanResponse) XXX_Size() int

func (*MsgCreateFixedAmountPlanResponse) XXX_Unmarshal

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

type MsgCreateRatioPlan

type MsgCreateRatioPlan struct {
	// name specifies the name for the plan
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// creator defines the bech32-encoded address of the creator for the private plan, termination address is also set to
	// this creator.
	Creator string `protobuf:"bytes,2,opt,name=creator,proto3" json:"creator,omitempty"`
	// staking_coin_weights specifies coins weight for the plan
	StakingCoinWeights github_com_cosmos_cosmos_sdk_types.DecCoins `` /* 192-byte string literal not displayed */
	// start_time specifies the start time of the plan
	StartTime time.Time `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time" yaml:"start_time"`
	// end_time specifies the end time of the plan
	EndTime time.Time `protobuf:"bytes,5,opt,name=end_time,json=endTime,proto3,stdtime" json:"end_time" yaml:"end_time"`
	// epoch_ratio specifies the distributing amount by ratio
	EpochRatio github_com_cosmos_cosmos_sdk_types.Dec `` /* 150-byte string literal not displayed */
}

MsgCreateRatioPlan defines a SDK message for creating a new ratio farming plan.

func NewMsgCreateRatioPlan

func NewMsgCreateRatioPlan(
	name string,
	creatorAcc sdk.AccAddress,
	stakingCoinWeights sdk.DecCoins,
	startTime time.Time,
	endTime time.Time,
	epochRatio sdk.Dec,
) *MsgCreateRatioPlan

NewMsgCreateRatioPlan creates a new MsgCreateRatioPlan.

func (*MsgCreateRatioPlan) Descriptor

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

func (MsgCreateRatioPlan) GetCreator

func (msg MsgCreateRatioPlan) GetCreator() sdk.AccAddress

func (MsgCreateRatioPlan) GetSignBytes

func (msg MsgCreateRatioPlan) GetSignBytes() []byte

func (MsgCreateRatioPlan) GetSigners

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

func (*MsgCreateRatioPlan) Marshal

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

func (*MsgCreateRatioPlan) MarshalTo

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

func (*MsgCreateRatioPlan) MarshalToSizedBuffer

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

func (*MsgCreateRatioPlan) ProtoMessage

func (*MsgCreateRatioPlan) ProtoMessage()

func (*MsgCreateRatioPlan) Reset

func (m *MsgCreateRatioPlan) Reset()

func (MsgCreateRatioPlan) Route

func (msg MsgCreateRatioPlan) Route() string

func (*MsgCreateRatioPlan) Size

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

func (*MsgCreateRatioPlan) String

func (m *MsgCreateRatioPlan) String() string

func (MsgCreateRatioPlan) Type

func (msg MsgCreateRatioPlan) Type() string

func (*MsgCreateRatioPlan) Unmarshal

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

func (MsgCreateRatioPlan) ValidateBasic

func (msg MsgCreateRatioPlan) ValidateBasic() error

func (*MsgCreateRatioPlan) XXX_DiscardUnknown

func (m *MsgCreateRatioPlan) XXX_DiscardUnknown()

func (*MsgCreateRatioPlan) XXX_Marshal

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

func (*MsgCreateRatioPlan) XXX_Merge

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

func (*MsgCreateRatioPlan) XXX_Size

func (m *MsgCreateRatioPlan) XXX_Size() int

func (*MsgCreateRatioPlan) XXX_Unmarshal

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

type MsgCreateRatioPlanResponse

type MsgCreateRatioPlanResponse struct {
}

MsgCreateRatioPlanResponse defines the Msg/MsgCreateRatioPlanResponse response type.

func (*MsgCreateRatioPlanResponse) Descriptor

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

func (*MsgCreateRatioPlanResponse) Marshal

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

func (*MsgCreateRatioPlanResponse) MarshalTo

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

func (*MsgCreateRatioPlanResponse) MarshalToSizedBuffer

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

func (*MsgCreateRatioPlanResponse) ProtoMessage

func (*MsgCreateRatioPlanResponse) ProtoMessage()

func (*MsgCreateRatioPlanResponse) Reset

func (m *MsgCreateRatioPlanResponse) Reset()

func (*MsgCreateRatioPlanResponse) Size

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

func (*MsgCreateRatioPlanResponse) String

func (m *MsgCreateRatioPlanResponse) String() string

func (*MsgCreateRatioPlanResponse) Unmarshal

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

func (*MsgCreateRatioPlanResponse) XXX_DiscardUnknown

func (m *MsgCreateRatioPlanResponse) XXX_DiscardUnknown()

func (*MsgCreateRatioPlanResponse) XXX_Marshal

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

func (*MsgCreateRatioPlanResponse) XXX_Merge

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

func (*MsgCreateRatioPlanResponse) XXX_Size

func (m *MsgCreateRatioPlanResponse) XXX_Size() int

func (*MsgCreateRatioPlanResponse) XXX_Unmarshal

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

type MsgHarvest

type MsgHarvest struct {
	// farmer defines the bech32-encoded address of the farmer
	Farmer string `protobuf:"bytes,1,opt,name=farmer,proto3" json:"farmer,omitempty"`
	// staking_coin_denoms is the set of denoms of staked coins as a source of the reward for
	// harvesting
	StakingCoinDenoms []string `` /* 141-byte string literal not displayed */
}

MsgHarvest defines a SDK message for claiming rewards from the farming plan.

func NewMsgHarvest

func NewMsgHarvest(
	farmer sdk.AccAddress,
	stakingCoinDenoms []string,
) *MsgHarvest

NewMsgHarvest creates a new MsgHarvest.

func (*MsgHarvest) Descriptor

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

func (MsgHarvest) GetFarmer

func (msg MsgHarvest) GetFarmer() sdk.AccAddress

func (MsgHarvest) GetSignBytes

func (msg MsgHarvest) GetSignBytes() []byte

func (MsgHarvest) GetSigners

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

func (*MsgHarvest) Marshal

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

func (*MsgHarvest) MarshalTo

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

func (*MsgHarvest) MarshalToSizedBuffer

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

func (*MsgHarvest) ProtoMessage

func (*MsgHarvest) ProtoMessage()

func (*MsgHarvest) Reset

func (m *MsgHarvest) Reset()

func (MsgHarvest) Route

func (msg MsgHarvest) Route() string

func (*MsgHarvest) Size

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

func (*MsgHarvest) String

func (m *MsgHarvest) String() string

func (MsgHarvest) Type

func (msg MsgHarvest) Type() string

func (*MsgHarvest) Unmarshal

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

func (MsgHarvest) ValidateBasic

func (msg MsgHarvest) ValidateBasic() error

func (*MsgHarvest) XXX_DiscardUnknown

func (m *MsgHarvest) XXX_DiscardUnknown()

func (*MsgHarvest) XXX_Marshal

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

func (*MsgHarvest) XXX_Merge

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

func (*MsgHarvest) XXX_Size

func (m *MsgHarvest) XXX_Size() int

func (*MsgHarvest) XXX_Unmarshal

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

type MsgHarvestResponse

type MsgHarvestResponse struct {
}

MsgHarvestResponse defines the Msg/MsgHarvestResponse response type.

func (*MsgHarvestResponse) Descriptor

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

func (*MsgHarvestResponse) Marshal

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

func (*MsgHarvestResponse) MarshalTo

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

func (*MsgHarvestResponse) MarshalToSizedBuffer

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

func (*MsgHarvestResponse) ProtoMessage

func (*MsgHarvestResponse) ProtoMessage()

func (*MsgHarvestResponse) Reset

func (m *MsgHarvestResponse) Reset()

func (*MsgHarvestResponse) Size

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

func (*MsgHarvestResponse) String

func (m *MsgHarvestResponse) String() string

func (*MsgHarvestResponse) Unmarshal

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

func (*MsgHarvestResponse) XXX_DiscardUnknown

func (m *MsgHarvestResponse) XXX_DiscardUnknown()

func (*MsgHarvestResponse) XXX_Marshal

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

func (*MsgHarvestResponse) XXX_Merge

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

func (*MsgHarvestResponse) XXX_Size

func (m *MsgHarvestResponse) XXX_Size() int

func (*MsgHarvestResponse) XXX_Unmarshal

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

type MsgRemovePlan

type MsgRemovePlan struct {
	Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"`
	PlanId  uint64 `protobuf:"varint,2,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty" yaml:"plan_id"`
}

MsgRemovePlan defines a message for removing a terminated plan.

func NewMsgRemovePlan

func NewMsgRemovePlan(
	creator sdk.AccAddress,
	planId uint64,
) *MsgRemovePlan

NewMsgRemovePlan creates a new MsgRemovePlan.

func (*MsgRemovePlan) Descriptor

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

func (MsgRemovePlan) GetCreator

func (msg MsgRemovePlan) GetCreator() sdk.AccAddress

func (MsgRemovePlan) GetSignBytes

func (msg MsgRemovePlan) GetSignBytes() []byte

func (MsgRemovePlan) GetSigners

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

func (*MsgRemovePlan) Marshal

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

func (*MsgRemovePlan) MarshalTo

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

func (*MsgRemovePlan) MarshalToSizedBuffer

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

func (*MsgRemovePlan) ProtoMessage

func (*MsgRemovePlan) ProtoMessage()

func (*MsgRemovePlan) Reset

func (m *MsgRemovePlan) Reset()

func (MsgRemovePlan) Route

func (msg MsgRemovePlan) Route() string

func (*MsgRemovePlan) Size

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

func (*MsgRemovePlan) String

func (m *MsgRemovePlan) String() string

func (MsgRemovePlan) Type

func (msg MsgRemovePlan) Type() string

func (*MsgRemovePlan) Unmarshal

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

func (MsgRemovePlan) ValidateBasic

func (msg MsgRemovePlan) ValidateBasic() error

func (*MsgRemovePlan) XXX_DiscardUnknown

func (m *MsgRemovePlan) XXX_DiscardUnknown()

func (*MsgRemovePlan) XXX_Marshal

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

func (*MsgRemovePlan) XXX_Merge

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

func (*MsgRemovePlan) XXX_Size

func (m *MsgRemovePlan) XXX_Size() int

func (*MsgRemovePlan) XXX_Unmarshal

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

type MsgRemovePlanResponse

type MsgRemovePlanResponse struct {
}

MsgRemovePlanResponse defines the Msg/RemovePlan response type.

func (*MsgRemovePlanResponse) Descriptor

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

func (*MsgRemovePlanResponse) Marshal

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

func (*MsgRemovePlanResponse) MarshalTo

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

func (*MsgRemovePlanResponse) MarshalToSizedBuffer

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

func (*MsgRemovePlanResponse) ProtoMessage

func (*MsgRemovePlanResponse) ProtoMessage()

func (*MsgRemovePlanResponse) Reset

func (m *MsgRemovePlanResponse) Reset()

func (*MsgRemovePlanResponse) Size

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

func (*MsgRemovePlanResponse) String

func (m *MsgRemovePlanResponse) String() string

func (*MsgRemovePlanResponse) Unmarshal

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

func (*MsgRemovePlanResponse) XXX_DiscardUnknown

func (m *MsgRemovePlanResponse) XXX_DiscardUnknown()

func (*MsgRemovePlanResponse) XXX_Marshal

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

func (*MsgRemovePlanResponse) XXX_Merge

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

func (*MsgRemovePlanResponse) XXX_Size

func (m *MsgRemovePlanResponse) XXX_Size() int

func (*MsgRemovePlanResponse) XXX_Unmarshal

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

type MsgServer

type MsgServer interface {
	// CreateFixedAmountPlan defines a method for creating a new fixed amount
	// farming plan
	CreateFixedAmountPlan(context.Context, *MsgCreateFixedAmountPlan) (*MsgCreateFixedAmountPlanResponse, error)
	// CreateRatioPlan defines a method for creating a new ratio farming plan
	CreateRatioPlan(context.Context, *MsgCreateRatioPlan) (*MsgCreateRatioPlanResponse, error)
	// Stake defines a method for staking coins into the farming plan
	Stake(context.Context, *MsgStake) (*MsgStakeResponse, error)
	// Unstake defines a method for unstaking coins from the farming plan
	Unstake(context.Context, *MsgUnstake) (*MsgUnstakeResponse, error)
	// Harvest defines a method for claiming farming rewards
	Harvest(context.Context, *MsgHarvest) (*MsgHarvestResponse, error)
	// RemovePlan defines a method for removing a terminated plan.
	RemovePlan(context.Context, *MsgRemovePlan) (*MsgRemovePlanResponse, error)
	// AdvanceEpoch defines a method for advancing epoch by one, just for testing purpose
	// and shouldn't be used in real world
	AdvanceEpoch(context.Context, *MsgAdvanceEpoch) (*MsgAdvanceEpochResponse, error)
}

MsgServer is the server API for Msg service.

type MsgStake

type MsgStake struct {
	// farmer defines the bech32-encoded address of the farmer
	Farmer string `protobuf:"bytes,1,opt,name=farmer,proto3" json:"farmer,omitempty"`
	// staking_coins specifies coins to stake
	StakingCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 162-byte string literal not displayed */
}

MsgStake defines a SDK message for staking coins into the farming plan.

func NewMsgStake

func NewMsgStake(
	farmer sdk.AccAddress,
	stakingCoins sdk.Coins,
) *MsgStake

NewMsgStake creates a new MsgStake.

func (*MsgStake) Descriptor

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

func (MsgStake) GetFarmer

func (msg MsgStake) GetFarmer() sdk.AccAddress

func (MsgStake) GetSignBytes

func (msg MsgStake) GetSignBytes() []byte

func (MsgStake) GetSigners

func (msg 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 (msg MsgStake) Route() string

func (*MsgStake) Size

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

func (*MsgStake) String

func (m *MsgStake) String() string

func (MsgStake) Type

func (msg MsgStake) Type() string

func (*MsgStake) Unmarshal

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

func (MsgStake) ValidateBasic

func (msg 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 {
}

MsgStakeResponse defines the Msg/MsgStakeResponse response type.

func (*MsgStakeResponse) Descriptor

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

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 {
	// farmer defines the bech32-encoded address of the farmer
	Farmer string `protobuf:"bytes,1,opt,name=farmer,proto3" json:"farmer,omitempty"`
	// unstaking_coins specifies coins to stake
	UnstakingCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 170-byte string literal not displayed */
}

MsgUnstake defines a SDK message for performing unstaking of coins from the farming plan.

func NewMsgUnstake

func NewMsgUnstake(
	farmer sdk.AccAddress,
	unstakingCoins sdk.Coins,
) *MsgUnstake

NewMsgUnstake creates a new MsgUnstake.

func (*MsgUnstake) Descriptor

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

func (MsgUnstake) GetFarmer

func (msg MsgUnstake) GetFarmer() sdk.AccAddress

func (MsgUnstake) GetSignBytes

func (msg MsgUnstake) GetSignBytes() []byte

func (MsgUnstake) GetSigners

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

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 (msg MsgUnstake) Route() string

func (*MsgUnstake) Size

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

func (*MsgUnstake) String

func (m *MsgUnstake) String() string

func (MsgUnstake) Type

func (msg MsgUnstake) Type() string

func (*MsgUnstake) Unmarshal

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

func (MsgUnstake) ValidateBasic

func (msg 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 {
}

MsgUnstakeResponse defines the Msg/MsgUnstakeResponse response type.

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 OutstandingRewards

type OutstandingRewards struct {
	Rewards github_com_cosmos_cosmos_sdk_types.DecCoins `protobuf:"bytes,1,rep,name=rewards,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.DecCoins" json:"rewards"`
}

OutstandingRewards represents outstanding (un-withdrawn) rewards for a staking coin denom.

func (*OutstandingRewards) Descriptor

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

func (*OutstandingRewards) Marshal

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

func (*OutstandingRewards) MarshalTo

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

func (*OutstandingRewards) MarshalToSizedBuffer

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

func (*OutstandingRewards) ProtoMessage

func (*OutstandingRewards) ProtoMessage()

func (*OutstandingRewards) Reset

func (m *OutstandingRewards) Reset()

func (*OutstandingRewards) Size

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

func (*OutstandingRewards) String

func (m *OutstandingRewards) String() string

func (*OutstandingRewards) Unmarshal

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

func (*OutstandingRewards) XXX_DiscardUnknown

func (m *OutstandingRewards) XXX_DiscardUnknown()

func (*OutstandingRewards) XXX_Marshal

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

func (*OutstandingRewards) XXX_Merge

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

func (*OutstandingRewards) XXX_Size

func (m *OutstandingRewards) XXX_Size() int

func (*OutstandingRewards) XXX_Unmarshal

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

type OutstandingRewardsRecord

type OutstandingRewardsRecord struct {
	StakingCoinDenom   string             `` /* 137-byte string literal not displayed */
	OutstandingRewards OutstandingRewards `` /* 132-byte string literal not displayed */
}

OutstandingRewardsRecord is used for import/export via genesis json.

func (*OutstandingRewardsRecord) Descriptor

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

func (*OutstandingRewardsRecord) Marshal

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

func (*OutstandingRewardsRecord) MarshalTo

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

func (*OutstandingRewardsRecord) MarshalToSizedBuffer

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

func (*OutstandingRewardsRecord) ProtoMessage

func (*OutstandingRewardsRecord) ProtoMessage()

func (*OutstandingRewardsRecord) Reset

func (m *OutstandingRewardsRecord) Reset()

func (*OutstandingRewardsRecord) Size

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

func (*OutstandingRewardsRecord) String

func (m *OutstandingRewardsRecord) String() string

func (*OutstandingRewardsRecord) Unmarshal

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

func (OutstandingRewardsRecord) Validate

func (record OutstandingRewardsRecord) Validate() error

Validate validates OutstandingRewardsRecord.

func (*OutstandingRewardsRecord) XXX_DiscardUnknown

func (m *OutstandingRewardsRecord) XXX_DiscardUnknown()

func (*OutstandingRewardsRecord) XXX_Marshal

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

func (*OutstandingRewardsRecord) XXX_Merge

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

func (*OutstandingRewardsRecord) XXX_Size

func (m *OutstandingRewardsRecord) XXX_Size() int

func (*OutstandingRewardsRecord) XXX_Unmarshal

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

type Params

type Params struct {
	// private_plan_creation_fee specifies the fee for plan creation
	// this fee prevents from spamming and is collected in the community pool
	PrivatePlanCreationFee github_com_cosmos_cosmos_sdk_types.Coins `` /* 208-byte string literal not displayed */
	// next_epoch_days is the epoch length in number of days
	// it updates internal state called CurrentEpochDays that is used to process
	// staking and reward distribution in end blocker
	NextEpochDays uint32 `` /* 126-byte string literal not displayed */
	// farming_fee_collector is the module account address to collect fees within the farming module
	FarmingFeeCollector string `` /* 149-byte string literal not displayed */
	// delayed_staking_gas_fee is used to impose gas fee for the delayed staking
	DelayedStakingGasFee github_com_cosmos_cosmos_sdk_types.Gas `` /* 197-byte string literal not displayed */
	// max_num_private_plans is the maximum number of active private plans
	MaxNumPrivatePlans uint32 `` /* 149-byte string literal not displayed */
}

Params defines the set of params for the farming module.

func DefaultParams

func DefaultParams() Params

DefaultParams returns the default farming module parameters.

func (*Params) Descriptor

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

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() paramstypes.ParamSetPairs

ParamSetPairs implements paramstypes.ParamSet.

func (*Params) ProtoMessage

func (*Params) ProtoMessage()

func (*Params) Reset

func (m *Params) Reset()

func (*Params) Size

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

func (Params) String

func (p Params) String() string

String returns a human-readable string representation of the parameters.

func (*Params) Unmarshal

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

func (Params) Validate

func (p Params) Validate() error

Validate validates parameters.

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 PlanI

type PlanI interface {
	proto.Message

	GetId() uint64
	SetId(uint64) error

	GetName() string
	SetName(string) error

	GetType() PlanType
	SetType(PlanType) error

	GetFarmingPoolAddress() sdk.AccAddress
	SetFarmingPoolAddress(sdk.AccAddress) error

	GetTerminationAddress() sdk.AccAddress
	SetTerminationAddress(sdk.AccAddress) error

	GetStakingCoinWeights() sdk.DecCoins
	SetStakingCoinWeights(sdk.DecCoins) error

	GetStartTime() time.Time
	SetStartTime(time.Time) error

	GetEndTime() time.Time
	SetEndTime(time.Time) error

	IsTerminated() bool
	SetTerminated(bool) error

	GetLastDistributionTime() *time.Time
	SetLastDistributionTime(*time.Time) error

	GetDistributedCoins() sdk.Coins
	SetDistributedCoins(sdk.Coins) error

	GetBasePlan() *BasePlan

	Validate() error
}

PlanI represents a farming plan.

func UnpackPlan

func UnpackPlan(any *codectypes.Any) (PlanI, error)

UnpackPlan converts Any to PlanI.

func UnpackPlans

func UnpackPlans(plansAny []*codectypes.Any) ([]PlanI, error)

UnpackPlans converts Any slice to PlanIs.

type PlanRecord

type PlanRecord struct {
	// plan specifies the plan interface; it can be FixedAmountPlan or RatioPlan
	Plan types1.Any `protobuf:"bytes,1,opt,name=plan,proto3" json:"plan"`
	// farming_pool_coins specifies balance of the farming pool for the plan
	// this param is needed for import/export validation
	FarmingPoolCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 181-byte string literal not displayed */
}

PlanRecord is used for import/export via genesis json.

func (*PlanRecord) Descriptor

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

func (*PlanRecord) Marshal

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

func (*PlanRecord) MarshalTo

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

func (*PlanRecord) MarshalToSizedBuffer

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

func (*PlanRecord) ProtoMessage

func (*PlanRecord) ProtoMessage()

func (*PlanRecord) Reset

func (m *PlanRecord) Reset()

func (*PlanRecord) Size

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

func (*PlanRecord) String

func (m *PlanRecord) String() string

func (*PlanRecord) Unmarshal

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

func (PlanRecord) Validate

func (record PlanRecord) Validate() error

Validate validates PlanRecord.

func (*PlanRecord) XXX_DiscardUnknown

func (m *PlanRecord) XXX_DiscardUnknown()

func (*PlanRecord) XXX_Marshal

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

func (*PlanRecord) XXX_Merge

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

func (*PlanRecord) XXX_Size

func (m *PlanRecord) XXX_Size() int

func (*PlanRecord) XXX_Unmarshal

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

type PlanType

type PlanType int32

PlanType enumerates the valid types of a plan.

const (
	// PLAN_TYPE_UNSPECIFIED defines the default plan type.
	PlanTypeNil PlanType = 0
	// PLAN_TYPE_PUBLIC defines the public plan type.
	PlanTypePublic PlanType = 1
	// PLAN_TYPE_PRIVATE defines the private plan type.
	PlanTypePrivate PlanType = 2
)

func (PlanType) EnumDescriptor

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

func (PlanType) String

func (x PlanType) String() string

type PublicPlanProposal

type PublicPlanProposal struct {
	// title specifies the title of the plan
	Title string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	// description specifies the description of the plan
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// add_plan_requests specifies AddPlanRequest object
	AddPlanRequests []AddPlanRequest `protobuf:"bytes,3,rep,name=add_plan_requests,json=addPlanRequests,proto3" json:"add_plan_requests" yaml:"add_plan_requests"`
	// modify_plan_requests specifies ModifyPlanRequest object
	ModifyPlanRequests []ModifyPlanRequest `` /* 135-byte string literal not displayed */
	// delete_plan_requests specifies DeletePlanRequest object
	DeletePlanRequests []DeletePlanRequest `` /* 135-byte string literal not displayed */
}

PublicPlanProposal defines a public farming plan governance proposal that receives one of the following requests: A request that creates a public farming plan, a request that updates the plan, and a request that deletes the plan. For public plan creation, depending on which field is passed, either epoch amount or epoch ratio, it creates a fixed amount plan or ratio plan.

func NewPublicPlanProposal

func NewPublicPlanProposal(
	title string,
	description string,
	addReqs []AddPlanRequest,
	modifyReqs []ModifyPlanRequest,
	deleteReqs []DeletePlanRequest,
) *PublicPlanProposal

NewPublicPlanProposal creates a new PublicPlanProposal object.

func (*PublicPlanProposal) Descriptor

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

func (*PublicPlanProposal) GetDescription

func (p *PublicPlanProposal) GetDescription() string

func (*PublicPlanProposal) GetTitle

func (p *PublicPlanProposal) GetTitle() string

func (*PublicPlanProposal) Marshal

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

func (*PublicPlanProposal) MarshalTo

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

func (*PublicPlanProposal) MarshalToSizedBuffer

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

func (*PublicPlanProposal) ProposalRoute

func (p *PublicPlanProposal) ProposalRoute() string

func (*PublicPlanProposal) ProposalType

func (p *PublicPlanProposal) ProposalType() string

func (*PublicPlanProposal) ProtoMessage

func (*PublicPlanProposal) ProtoMessage()

func (*PublicPlanProposal) Reset

func (m *PublicPlanProposal) Reset()

func (*PublicPlanProposal) Size

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

func (PublicPlanProposal) String

func (p PublicPlanProposal) String() string

func (*PublicPlanProposal) Unmarshal

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

func (*PublicPlanProposal) ValidateBasic

func (p *PublicPlanProposal) ValidateBasic() error

func (*PublicPlanProposal) XXX_DiscardUnknown

func (m *PublicPlanProposal) XXX_DiscardUnknown()

func (*PublicPlanProposal) XXX_Marshal

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

func (*PublicPlanProposal) XXX_Merge

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

func (*PublicPlanProposal) XXX_Size

func (m *PublicPlanProposal) XXX_Size() int

func (*PublicPlanProposal) XXX_Unmarshal

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

type QueryClient

type QueryClient interface {
	// Params returns parameters of the farming module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// Plans returns all plans.
	Plans(ctx context.Context, in *QueryPlansRequest, opts ...grpc.CallOption) (*QueryPlansResponse, error)
	// Plan returns a specific plan.
	Plan(ctx context.Context, in *QueryPlanRequest, opts ...grpc.CallOption) (*QueryPlanResponse, error)
	Position(ctx context.Context, in *QueryPositionRequest, opts ...grpc.CallOption) (*QueryPositionResponse, error)
	// Stakings returns all stakings by a farmer.
	Stakings(ctx context.Context, in *QueryStakingsRequest, opts ...grpc.CallOption) (*QueryStakingsResponse, error)
	// QueryStakings returns all queued stakings by a farmer.
	QueuedStakings(ctx context.Context, in *QueryQueuedStakingsRequest, opts ...grpc.CallOption) (*QueryQueuedStakingsResponse, error)
	// TotalStakings returns total staking amount for a staking coin denom
	TotalStakings(ctx context.Context, in *QueryTotalStakingsRequest, opts ...grpc.CallOption) (*QueryTotalStakingsResponse, error)
	// Rewards returns rewards for a farmer
	Rewards(ctx context.Context, in *QueryRewardsRequest, opts ...grpc.CallOption) (*QueryRewardsResponse, error)
	// UnharvestedRewards returns unharvested rewards for a farmer
	UnharvestedRewards(ctx context.Context, in *QueryUnharvestedRewardsRequest, opts ...grpc.CallOption) (*QueryUnharvestedRewardsResponse, error)
	// CurrentEpochDays returns current epoch days.
	CurrentEpochDays(ctx context.Context, in *QueryCurrentEpochDaysRequest, opts ...grpc.CallOption) (*QueryCurrentEpochDaysResponse, error)
	// HistoricalRewards returns HistoricalRewards records for a staking coin denom.
	HistoricalRewards(ctx context.Context, in *QueryHistoricalRewardsRequest, opts ...grpc.CallOption) (*QueryHistoricalRewardsResponse, 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 QueryCurrentEpochDaysRequest

type QueryCurrentEpochDaysRequest struct {
}

QueryCurrentEpochDaysRequest is the request type for the Query/CurrentEpochDays RPC method.

func (*QueryCurrentEpochDaysRequest) Descriptor

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

func (*QueryCurrentEpochDaysRequest) Marshal

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

func (*QueryCurrentEpochDaysRequest) MarshalTo

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

func (*QueryCurrentEpochDaysRequest) MarshalToSizedBuffer

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

func (*QueryCurrentEpochDaysRequest) ProtoMessage

func (*QueryCurrentEpochDaysRequest) ProtoMessage()

func (*QueryCurrentEpochDaysRequest) Reset

func (m *QueryCurrentEpochDaysRequest) Reset()

func (*QueryCurrentEpochDaysRequest) Size

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

func (*QueryCurrentEpochDaysRequest) String

func (*QueryCurrentEpochDaysRequest) Unmarshal

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

func (*QueryCurrentEpochDaysRequest) XXX_DiscardUnknown

func (m *QueryCurrentEpochDaysRequest) XXX_DiscardUnknown()

func (*QueryCurrentEpochDaysRequest) XXX_Marshal

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

func (*QueryCurrentEpochDaysRequest) XXX_Merge

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

func (*QueryCurrentEpochDaysRequest) XXX_Size

func (m *QueryCurrentEpochDaysRequest) XXX_Size() int

func (*QueryCurrentEpochDaysRequest) XXX_Unmarshal

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

type QueryCurrentEpochDaysResponse

type QueryCurrentEpochDaysResponse struct {
	CurrentEpochDays uint32 `protobuf:"varint,1,opt,name=current_epoch_days,json=currentEpochDays,proto3" json:"current_epoch_days,omitempty"`
}

QueryCurrentEpochDaysResponse is the response type for the Query/CurrentEpochDays RPC method.

func (*QueryCurrentEpochDaysResponse) Descriptor

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

func (*QueryCurrentEpochDaysResponse) GetCurrentEpochDays

func (m *QueryCurrentEpochDaysResponse) GetCurrentEpochDays() uint32

func (*QueryCurrentEpochDaysResponse) Marshal

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

func (*QueryCurrentEpochDaysResponse) MarshalTo

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

func (*QueryCurrentEpochDaysResponse) MarshalToSizedBuffer

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

func (*QueryCurrentEpochDaysResponse) ProtoMessage

func (*QueryCurrentEpochDaysResponse) ProtoMessage()

func (*QueryCurrentEpochDaysResponse) Reset

func (m *QueryCurrentEpochDaysResponse) Reset()

func (*QueryCurrentEpochDaysResponse) Size

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

func (*QueryCurrentEpochDaysResponse) String

func (*QueryCurrentEpochDaysResponse) Unmarshal

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

func (*QueryCurrentEpochDaysResponse) XXX_DiscardUnknown

func (m *QueryCurrentEpochDaysResponse) XXX_DiscardUnknown()

func (*QueryCurrentEpochDaysResponse) XXX_Marshal

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

func (*QueryCurrentEpochDaysResponse) XXX_Merge

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

func (*QueryCurrentEpochDaysResponse) XXX_Size

func (m *QueryCurrentEpochDaysResponse) XXX_Size() int

func (*QueryCurrentEpochDaysResponse) XXX_Unmarshal

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

type QueryHistoricalRewardsRequest

type QueryHistoricalRewardsRequest struct {
	StakingCoinDenom string             `protobuf:"bytes,1,opt,name=staking_coin_denom,json=stakingCoinDenom,proto3" json:"staking_coin_denom,omitempty"`
	Pagination       *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryHistoricalRewardsRequest is the request type for the Query/HistoricalRewards RPC method.

func (*QueryHistoricalRewardsRequest) Descriptor

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

func (*QueryHistoricalRewardsRequest) GetPagination

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

func (*QueryHistoricalRewardsRequest) GetStakingCoinDenom

func (m *QueryHistoricalRewardsRequest) GetStakingCoinDenom() string

func (*QueryHistoricalRewardsRequest) Marshal

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

func (*QueryHistoricalRewardsRequest) MarshalTo

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

func (*QueryHistoricalRewardsRequest) MarshalToSizedBuffer

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

func (*QueryHistoricalRewardsRequest) ProtoMessage

func (*QueryHistoricalRewardsRequest) ProtoMessage()

func (*QueryHistoricalRewardsRequest) Reset

func (m *QueryHistoricalRewardsRequest) Reset()

func (*QueryHistoricalRewardsRequest) Size

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

func (*QueryHistoricalRewardsRequest) String

func (*QueryHistoricalRewardsRequest) Unmarshal

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

func (*QueryHistoricalRewardsRequest) XXX_DiscardUnknown

func (m *QueryHistoricalRewardsRequest) XXX_DiscardUnknown()

func (*QueryHistoricalRewardsRequest) XXX_Marshal

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

func (*QueryHistoricalRewardsRequest) XXX_Merge

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

func (*QueryHistoricalRewardsRequest) XXX_Size

func (m *QueryHistoricalRewardsRequest) XXX_Size() int

func (*QueryHistoricalRewardsRequest) XXX_Unmarshal

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

type QueryHistoricalRewardsResponse

type QueryHistoricalRewardsResponse struct {
	HistoricalRewards []HistoricalRewardsResponse `protobuf:"bytes,1,rep,name=historical_rewards,json=historicalRewards,proto3" json:"historical_rewards"`
	Pagination        *query.PageResponse         `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryHistoricalRewardsResponse is the response type for the Query/HistoricalRewards RPC method.

func (*QueryHistoricalRewardsResponse) Descriptor

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

func (*QueryHistoricalRewardsResponse) GetHistoricalRewards

func (m *QueryHistoricalRewardsResponse) GetHistoricalRewards() []HistoricalRewardsResponse

func (*QueryHistoricalRewardsResponse) GetPagination

func (*QueryHistoricalRewardsResponse) Marshal

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

func (*QueryHistoricalRewardsResponse) MarshalTo

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

func (*QueryHistoricalRewardsResponse) MarshalToSizedBuffer

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

func (*QueryHistoricalRewardsResponse) ProtoMessage

func (*QueryHistoricalRewardsResponse) ProtoMessage()

func (*QueryHistoricalRewardsResponse) Reset

func (m *QueryHistoricalRewardsResponse) Reset()

func (*QueryHistoricalRewardsResponse) Size

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

func (*QueryHistoricalRewardsResponse) String

func (*QueryHistoricalRewardsResponse) Unmarshal

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

func (*QueryHistoricalRewardsResponse) XXX_DiscardUnknown

func (m *QueryHistoricalRewardsResponse) XXX_DiscardUnknown()

func (*QueryHistoricalRewardsResponse) XXX_Marshal

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

func (*QueryHistoricalRewardsResponse) XXX_Merge

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

func (*QueryHistoricalRewardsResponse) XXX_Size

func (m *QueryHistoricalRewardsResponse) XXX_Size() int

func (*QueryHistoricalRewardsResponse) XXX_Unmarshal

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

type QueryParamsRequest

type QueryParamsRequest struct {
}

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

func (*QueryParamsRequest) Descriptor

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

func (*QueryParamsRequest) Marshal

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

func (*QueryParamsRequest) MarshalTo

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

func (*QueryParamsRequest) MarshalToSizedBuffer

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

func (*QueryParamsRequest) ProtoMessage

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size

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

func (*QueryParamsRequest) String

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal

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

func (*QueryParamsRequest) XXX_DiscardUnknown

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal

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

func (*QueryParamsRequest) XXX_Merge

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

func (*QueryParamsRequest) XXX_Size

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal

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

type QueryParamsResponse

type QueryParamsResponse struct {
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

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

func (*QueryParamsResponse) Descriptor

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

func (*QueryParamsResponse) GetParams

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal

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

func (*QueryParamsResponse) MarshalTo

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

func (*QueryParamsResponse) MarshalToSizedBuffer

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

func (*QueryParamsResponse) ProtoMessage

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size

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

func (*QueryParamsResponse) String

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal

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

func (*QueryParamsResponse) XXX_DiscardUnknown

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal

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

func (*QueryParamsResponse) XXX_Merge

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

func (*QueryParamsResponse) XXX_Size

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal

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

type QueryPlanRequest

type QueryPlanRequest struct {
	PlanId uint64 `protobuf:"varint,1,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty"`
}

QueryPlanRequest is the request type for the Query/Plan RPC method.

func (*QueryPlanRequest) Descriptor

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

func (*QueryPlanRequest) GetPlanId

func (m *QueryPlanRequest) GetPlanId() uint64

func (*QueryPlanRequest) Marshal

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

func (*QueryPlanRequest) MarshalTo

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

func (*QueryPlanRequest) MarshalToSizedBuffer

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

func (*QueryPlanRequest) ProtoMessage

func (*QueryPlanRequest) ProtoMessage()

func (*QueryPlanRequest) Reset

func (m *QueryPlanRequest) Reset()

func (*QueryPlanRequest) Size

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

func (*QueryPlanRequest) String

func (m *QueryPlanRequest) String() string

func (*QueryPlanRequest) Unmarshal

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

func (*QueryPlanRequest) XXX_DiscardUnknown

func (m *QueryPlanRequest) XXX_DiscardUnknown()

func (*QueryPlanRequest) XXX_Marshal

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

func (*QueryPlanRequest) XXX_Merge

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

func (*QueryPlanRequest) XXX_Size

func (m *QueryPlanRequest) XXX_Size() int

func (*QueryPlanRequest) XXX_Unmarshal

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

type QueryPlanResponse

type QueryPlanResponse struct {
	Plan *types.Any `protobuf:"bytes,1,opt,name=plan,proto3" json:"plan,omitempty"`
}

QueryPlanResponse is the response type for the Query/Plan RPC method.

func (*QueryPlanResponse) Descriptor

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

func (*QueryPlanResponse) GetPlan

func (m *QueryPlanResponse) GetPlan() *types.Any

func (*QueryPlanResponse) Marshal

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

func (*QueryPlanResponse) MarshalTo

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

func (*QueryPlanResponse) MarshalToSizedBuffer

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

func (*QueryPlanResponse) ProtoMessage

func (*QueryPlanResponse) ProtoMessage()

func (*QueryPlanResponse) Reset

func (m *QueryPlanResponse) Reset()

func (*QueryPlanResponse) Size

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

func (*QueryPlanResponse) String

func (m *QueryPlanResponse) String() string

func (*QueryPlanResponse) Unmarshal

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

func (*QueryPlanResponse) XXX_DiscardUnknown

func (m *QueryPlanResponse) XXX_DiscardUnknown()

func (*QueryPlanResponse) XXX_Marshal

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

func (*QueryPlanResponse) XXX_Merge

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

func (*QueryPlanResponse) XXX_Size

func (m *QueryPlanResponse) XXX_Size() int

func (*QueryPlanResponse) XXX_Unmarshal

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

type QueryPlansRequest

type QueryPlansRequest struct {
	Type               string             `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	FarmingPoolAddress string             `protobuf:"bytes,2,opt,name=farming_pool_address,json=farmingPoolAddress,proto3" json:"farming_pool_address,omitempty"`
	TerminationAddress string             `protobuf:"bytes,3,opt,name=termination_address,json=terminationAddress,proto3" json:"termination_address,omitempty"`
	StakingCoinDenom   string             `protobuf:"bytes,4,opt,name=staking_coin_denom,json=stakingCoinDenom,proto3" json:"staking_coin_denom,omitempty"`
	Terminated         string             `protobuf:"bytes,5,opt,name=terminated,proto3" json:"terminated,omitempty"`
	Pagination         *query.PageRequest `protobuf:"bytes,6,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryPlansRequest is the request type for the Query/Plans RPC method.

func (*QueryPlansRequest) Descriptor

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

func (*QueryPlansRequest) GetFarmingPoolAddress

func (m *QueryPlansRequest) GetFarmingPoolAddress() string

func (*QueryPlansRequest) GetPagination

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

func (*QueryPlansRequest) GetStakingCoinDenom

func (m *QueryPlansRequest) GetStakingCoinDenom() string

func (*QueryPlansRequest) GetTerminated

func (m *QueryPlansRequest) GetTerminated() string

func (*QueryPlansRequest) GetTerminationAddress

func (m *QueryPlansRequest) GetTerminationAddress() string

func (*QueryPlansRequest) GetType

func (m *QueryPlansRequest) GetType() string

func (*QueryPlansRequest) Marshal

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

func (*QueryPlansRequest) MarshalTo

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

func (*QueryPlansRequest) MarshalToSizedBuffer

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

func (*QueryPlansRequest) ProtoMessage

func (*QueryPlansRequest) ProtoMessage()

func (*QueryPlansRequest) Reset

func (m *QueryPlansRequest) Reset()

func (*QueryPlansRequest) Size

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

func (*QueryPlansRequest) String

func (m *QueryPlansRequest) String() string

func (*QueryPlansRequest) Unmarshal

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

func (*QueryPlansRequest) XXX_DiscardUnknown

func (m *QueryPlansRequest) XXX_DiscardUnknown()

func (*QueryPlansRequest) XXX_Marshal

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

func (*QueryPlansRequest) XXX_Merge

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

func (*QueryPlansRequest) XXX_Size

func (m *QueryPlansRequest) XXX_Size() int

func (*QueryPlansRequest) XXX_Unmarshal

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

type QueryPlansResponse

type QueryPlansResponse struct {
	// plans are the existing plans
	Plans []*types.Any `protobuf:"bytes,1,rep,name=plans,proto3" json:"plans,omitempty"`
	// pagination defines the pagination in the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryPlansResponse is the response type for the Query/Plans RPC method.

func (*QueryPlansResponse) Descriptor

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

func (*QueryPlansResponse) GetPagination

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

func (*QueryPlansResponse) GetPlans

func (m *QueryPlansResponse) GetPlans() []*types.Any

func (*QueryPlansResponse) Marshal

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

func (*QueryPlansResponse) MarshalTo

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

func (*QueryPlansResponse) MarshalToSizedBuffer

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

func (*QueryPlansResponse) ProtoMessage

func (*QueryPlansResponse) ProtoMessage()

func (*QueryPlansResponse) Reset

func (m *QueryPlansResponse) Reset()

func (*QueryPlansResponse) Size

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

func (*QueryPlansResponse) String

func (m *QueryPlansResponse) String() string

func (*QueryPlansResponse) Unmarshal

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

func (*QueryPlansResponse) XXX_DiscardUnknown

func (m *QueryPlansResponse) XXX_DiscardUnknown()

func (*QueryPlansResponse) XXX_Marshal

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

func (*QueryPlansResponse) XXX_Merge

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

func (*QueryPlansResponse) XXX_Size

func (m *QueryPlansResponse) XXX_Size() int

func (*QueryPlansResponse) XXX_Unmarshal

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

type QueryPositionRequest

type QueryPositionRequest struct {
	Farmer           string `protobuf:"bytes,1,opt,name=farmer,proto3" json:"farmer,omitempty"`
	StakingCoinDenom string `protobuf:"bytes,2,opt,name=staking_coin_denom,json=stakingCoinDenom,proto3" json:"staking_coin_denom,omitempty"`
}

QueryPositionRequest is the request type for the Query/Position RPC method.

func (*QueryPositionRequest) Descriptor

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

func (*QueryPositionRequest) GetFarmer

func (m *QueryPositionRequest) GetFarmer() string

func (*QueryPositionRequest) GetStakingCoinDenom

func (m *QueryPositionRequest) GetStakingCoinDenom() string

func (*QueryPositionRequest) Marshal

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

func (*QueryPositionRequest) MarshalTo

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

func (*QueryPositionRequest) MarshalToSizedBuffer

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

func (*QueryPositionRequest) ProtoMessage

func (*QueryPositionRequest) ProtoMessage()

func (*QueryPositionRequest) Reset

func (m *QueryPositionRequest) Reset()

func (*QueryPositionRequest) Size

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

func (*QueryPositionRequest) String

func (m *QueryPositionRequest) String() string

func (*QueryPositionRequest) Unmarshal

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

func (*QueryPositionRequest) XXX_DiscardUnknown

func (m *QueryPositionRequest) XXX_DiscardUnknown()

func (*QueryPositionRequest) XXX_Marshal

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

func (*QueryPositionRequest) XXX_Merge

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

func (*QueryPositionRequest) XXX_Size

func (m *QueryPositionRequest) XXX_Size() int

func (*QueryPositionRequest) XXX_Unmarshal

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

type QueryPositionResponse

type QueryPositionResponse struct {
	StakedCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 138-byte string literal not displayed */
	QueuedCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 138-byte string literal not displayed */
	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"`
}

QueryPositionResponse is the response type for the Query/Position RPC method.

func (*QueryPositionResponse) Descriptor

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

func (*QueryPositionResponse) GetQueuedCoins

func (*QueryPositionResponse) GetRewards

func (*QueryPositionResponse) GetStakedCoins

func (*QueryPositionResponse) Marshal

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

func (*QueryPositionResponse) MarshalTo

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

func (*QueryPositionResponse) MarshalToSizedBuffer

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

func (*QueryPositionResponse) ProtoMessage

func (*QueryPositionResponse) ProtoMessage()

func (*QueryPositionResponse) Reset

func (m *QueryPositionResponse) Reset()

func (*QueryPositionResponse) Size

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

func (*QueryPositionResponse) String

func (m *QueryPositionResponse) String() string

func (*QueryPositionResponse) Unmarshal

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

func (*QueryPositionResponse) XXX_DiscardUnknown

func (m *QueryPositionResponse) XXX_DiscardUnknown()

func (*QueryPositionResponse) XXX_Marshal

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

func (*QueryPositionResponse) XXX_Merge

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

func (*QueryPositionResponse) XXX_Size

func (m *QueryPositionResponse) XXX_Size() int

func (*QueryPositionResponse) XXX_Unmarshal

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

type QueryQueuedStakingsRequest

type QueryQueuedStakingsRequest struct {
	Farmer           string             `protobuf:"bytes,1,opt,name=farmer,proto3" json:"farmer,omitempty"`
	StakingCoinDenom string             `protobuf:"bytes,2,opt,name=staking_coin_denom,json=stakingCoinDenom,proto3" json:"staking_coin_denom,omitempty"`
	Pagination       *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryQueuedStakingsRequest is the request type for the Query/QueuedStakings RPC method.

func (*QueryQueuedStakingsRequest) Descriptor

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

func (*QueryQueuedStakingsRequest) GetFarmer

func (m *QueryQueuedStakingsRequest) GetFarmer() string

func (*QueryQueuedStakingsRequest) GetPagination

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

func (*QueryQueuedStakingsRequest) GetStakingCoinDenom

func (m *QueryQueuedStakingsRequest) GetStakingCoinDenom() string

func (*QueryQueuedStakingsRequest) Marshal

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

func (*QueryQueuedStakingsRequest) MarshalTo

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

func (*QueryQueuedStakingsRequest) MarshalToSizedBuffer

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

func (*QueryQueuedStakingsRequest) ProtoMessage

func (*QueryQueuedStakingsRequest) ProtoMessage()

func (*QueryQueuedStakingsRequest) Reset

func (m *QueryQueuedStakingsRequest) Reset()

func (*QueryQueuedStakingsRequest) Size

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

func (*QueryQueuedStakingsRequest) String

func (m *QueryQueuedStakingsRequest) String() string

func (*QueryQueuedStakingsRequest) Unmarshal

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

func (*QueryQueuedStakingsRequest) XXX_DiscardUnknown

func (m *QueryQueuedStakingsRequest) XXX_DiscardUnknown()

func (*QueryQueuedStakingsRequest) XXX_Marshal

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

func (*QueryQueuedStakingsRequest) XXX_Merge

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

func (*QueryQueuedStakingsRequest) XXX_Size

func (m *QueryQueuedStakingsRequest) XXX_Size() int

func (*QueryQueuedStakingsRequest) XXX_Unmarshal

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

type QueryQueuedStakingsResponse

type QueryQueuedStakingsResponse struct {
	QueuedStakings []QueuedStakingResponse `protobuf:"bytes,1,rep,name=queued_stakings,json=queuedStakings,proto3" json:"queued_stakings"`
	Pagination     *query.PageResponse     `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryQueuedStakingsResponse is the response type for the Query/QueuedStakings RPC method.

func (*QueryQueuedStakingsResponse) Descriptor

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

func (*QueryQueuedStakingsResponse) GetPagination

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

func (*QueryQueuedStakingsResponse) GetQueuedStakings

func (m *QueryQueuedStakingsResponse) GetQueuedStakings() []QueuedStakingResponse

func (*QueryQueuedStakingsResponse) Marshal

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

func (*QueryQueuedStakingsResponse) MarshalTo

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

func (*QueryQueuedStakingsResponse) MarshalToSizedBuffer

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

func (*QueryQueuedStakingsResponse) ProtoMessage

func (*QueryQueuedStakingsResponse) ProtoMessage()

func (*QueryQueuedStakingsResponse) Reset

func (m *QueryQueuedStakingsResponse) Reset()

func (*QueryQueuedStakingsResponse) Size

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

func (*QueryQueuedStakingsResponse) String

func (m *QueryQueuedStakingsResponse) String() string

func (*QueryQueuedStakingsResponse) Unmarshal

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

func (*QueryQueuedStakingsResponse) XXX_DiscardUnknown

func (m *QueryQueuedStakingsResponse) XXX_DiscardUnknown()

func (*QueryQueuedStakingsResponse) XXX_Marshal

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

func (*QueryQueuedStakingsResponse) XXX_Merge

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

func (*QueryQueuedStakingsResponse) XXX_Size

func (m *QueryQueuedStakingsResponse) XXX_Size() int

func (*QueryQueuedStakingsResponse) XXX_Unmarshal

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

type QueryRewardsRequest

type QueryRewardsRequest struct {
	Farmer           string             `protobuf:"bytes,1,opt,name=farmer,proto3" json:"farmer,omitempty"`
	StakingCoinDenom string             `protobuf:"bytes,2,opt,name=staking_coin_denom,json=stakingCoinDenom,proto3" json:"staking_coin_denom,omitempty"`
	Pagination       *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryRewardsRequest is the request type for the Query/Rewards RPC method.

func (*QueryRewardsRequest) Descriptor

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

func (*QueryRewardsRequest) GetFarmer

func (m *QueryRewardsRequest) GetFarmer() string

func (*QueryRewardsRequest) GetPagination

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

func (*QueryRewardsRequest) GetStakingCoinDenom

func (m *QueryRewardsRequest) GetStakingCoinDenom() string

func (*QueryRewardsRequest) Marshal

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

func (*QueryRewardsRequest) MarshalTo

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

func (*QueryRewardsRequest) MarshalToSizedBuffer

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

func (*QueryRewardsRequest) ProtoMessage

func (*QueryRewardsRequest) ProtoMessage()

func (*QueryRewardsRequest) Reset

func (m *QueryRewardsRequest) Reset()

func (*QueryRewardsRequest) Size

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

func (*QueryRewardsRequest) String

func (m *QueryRewardsRequest) String() string

func (*QueryRewardsRequest) Unmarshal

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

func (*QueryRewardsRequest) XXX_DiscardUnknown

func (m *QueryRewardsRequest) XXX_DiscardUnknown()

func (*QueryRewardsRequest) XXX_Marshal

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

func (*QueryRewardsRequest) XXX_Merge

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

func (*QueryRewardsRequest) XXX_Size

func (m *QueryRewardsRequest) XXX_Size() int

func (*QueryRewardsRequest) XXX_Unmarshal

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

type QueryRewardsResponse

type QueryRewardsResponse struct {
	Rewards    []RewardsResponse   `protobuf:"bytes,1,rep,name=rewards,proto3" json:"rewards"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryRewardsResponse is the response type for the Query/Rewards RPC method.

func (*QueryRewardsResponse) Descriptor

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

func (*QueryRewardsResponse) GetPagination

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

func (*QueryRewardsResponse) GetRewards

func (m *QueryRewardsResponse) GetRewards() []RewardsResponse

func (*QueryRewardsResponse) Marshal

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

func (*QueryRewardsResponse) MarshalTo

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

func (*QueryRewardsResponse) MarshalToSizedBuffer

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

func (*QueryRewardsResponse) ProtoMessage

func (*QueryRewardsResponse) ProtoMessage()

func (*QueryRewardsResponse) Reset

func (m *QueryRewardsResponse) Reset()

func (*QueryRewardsResponse) Size

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

func (*QueryRewardsResponse) String

func (m *QueryRewardsResponse) String() string

func (*QueryRewardsResponse) Unmarshal

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

func (*QueryRewardsResponse) XXX_DiscardUnknown

func (m *QueryRewardsResponse) XXX_DiscardUnknown()

func (*QueryRewardsResponse) XXX_Marshal

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

func (*QueryRewardsResponse) XXX_Merge

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

func (*QueryRewardsResponse) XXX_Size

func (m *QueryRewardsResponse) XXX_Size() int

func (*QueryRewardsResponse) XXX_Unmarshal

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

type QueryServer

type QueryServer interface {
	// Params returns parameters of the farming module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// Plans returns all plans.
	Plans(context.Context, *QueryPlansRequest) (*QueryPlansResponse, error)
	// Plan returns a specific plan.
	Plan(context.Context, *QueryPlanRequest) (*QueryPlanResponse, error)
	Position(context.Context, *QueryPositionRequest) (*QueryPositionResponse, error)
	// Stakings returns all stakings by a farmer.
	Stakings(context.Context, *QueryStakingsRequest) (*QueryStakingsResponse, error)
	// QueryStakings returns all queued stakings by a farmer.
	QueuedStakings(context.Context, *QueryQueuedStakingsRequest) (*QueryQueuedStakingsResponse, error)
	// TotalStakings returns total staking amount for a staking coin denom
	TotalStakings(context.Context, *QueryTotalStakingsRequest) (*QueryTotalStakingsResponse, error)
	// Rewards returns rewards for a farmer
	Rewards(context.Context, *QueryRewardsRequest) (*QueryRewardsResponse, error)
	// UnharvestedRewards returns unharvested rewards for a farmer
	UnharvestedRewards(context.Context, *QueryUnharvestedRewardsRequest) (*QueryUnharvestedRewardsResponse, error)
	// CurrentEpochDays returns current epoch days.
	CurrentEpochDays(context.Context, *QueryCurrentEpochDaysRequest) (*QueryCurrentEpochDaysResponse, error)
	// HistoricalRewards returns HistoricalRewards records for a staking coin denom.
	HistoricalRewards(context.Context, *QueryHistoricalRewardsRequest) (*QueryHistoricalRewardsResponse, error)
}

QueryServer is the server API for Query service.

type QueryStakingsRequest

type QueryStakingsRequest struct {
	Farmer           string             `protobuf:"bytes,1,opt,name=farmer,proto3" json:"farmer,omitempty"`
	StakingCoinDenom string             `protobuf:"bytes,2,opt,name=staking_coin_denom,json=stakingCoinDenom,proto3" json:"staking_coin_denom,omitempty"`
	Pagination       *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryStakingsRequest is the request type for the Query/Stakings RPC method.

func (*QueryStakingsRequest) Descriptor

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

func (*QueryStakingsRequest) GetFarmer

func (m *QueryStakingsRequest) GetFarmer() string

func (*QueryStakingsRequest) GetPagination

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

func (*QueryStakingsRequest) GetStakingCoinDenom

func (m *QueryStakingsRequest) GetStakingCoinDenom() string

func (*QueryStakingsRequest) Marshal

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

func (*QueryStakingsRequest) MarshalTo

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

func (*QueryStakingsRequest) MarshalToSizedBuffer

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

func (*QueryStakingsRequest) ProtoMessage

func (*QueryStakingsRequest) ProtoMessage()

func (*QueryStakingsRequest) Reset

func (m *QueryStakingsRequest) Reset()

func (*QueryStakingsRequest) Size

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

func (*QueryStakingsRequest) String

func (m *QueryStakingsRequest) String() string

func (*QueryStakingsRequest) Unmarshal

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

func (*QueryStakingsRequest) XXX_DiscardUnknown

func (m *QueryStakingsRequest) XXX_DiscardUnknown()

func (*QueryStakingsRequest) XXX_Marshal

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

func (*QueryStakingsRequest) XXX_Merge

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

func (*QueryStakingsRequest) XXX_Size

func (m *QueryStakingsRequest) XXX_Size() int

func (*QueryStakingsRequest) XXX_Unmarshal

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

type QueryStakingsResponse

type QueryStakingsResponse struct {
	Stakings   []StakingResponse   `protobuf:"bytes,1,rep,name=stakings,proto3" json:"stakings"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryStakingsResponse is the response type for the Query/Stakings RPC method.

func (*QueryStakingsResponse) Descriptor

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

func (*QueryStakingsResponse) GetPagination

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

func (*QueryStakingsResponse) GetStakings

func (m *QueryStakingsResponse) GetStakings() []StakingResponse

func (*QueryStakingsResponse) Marshal

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

func (*QueryStakingsResponse) MarshalTo

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

func (*QueryStakingsResponse) MarshalToSizedBuffer

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

func (*QueryStakingsResponse) ProtoMessage

func (*QueryStakingsResponse) ProtoMessage()

func (*QueryStakingsResponse) Reset

func (m *QueryStakingsResponse) Reset()

func (*QueryStakingsResponse) Size

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

func (*QueryStakingsResponse) String

func (m *QueryStakingsResponse) String() string

func (*QueryStakingsResponse) Unmarshal

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

func (*QueryStakingsResponse) XXX_DiscardUnknown

func (m *QueryStakingsResponse) XXX_DiscardUnknown()

func (*QueryStakingsResponse) XXX_Marshal

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

func (*QueryStakingsResponse) XXX_Merge

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

func (*QueryStakingsResponse) XXX_Size

func (m *QueryStakingsResponse) XXX_Size() int

func (*QueryStakingsResponse) XXX_Unmarshal

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

type QueryTotalStakingsRequest

type QueryTotalStakingsRequest struct {
	StakingCoinDenom string `protobuf:"bytes,1,opt,name=staking_coin_denom,json=stakingCoinDenom,proto3" json:"staking_coin_denom,omitempty"`
}

QueryTotalStakingsRequest is the request type for the Query/TotalStakings RPC method.

func (*QueryTotalStakingsRequest) Descriptor

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

func (*QueryTotalStakingsRequest) GetStakingCoinDenom

func (m *QueryTotalStakingsRequest) GetStakingCoinDenom() string

func (*QueryTotalStakingsRequest) Marshal

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

func (*QueryTotalStakingsRequest) MarshalTo

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

func (*QueryTotalStakingsRequest) MarshalToSizedBuffer

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

func (*QueryTotalStakingsRequest) ProtoMessage

func (*QueryTotalStakingsRequest) ProtoMessage()

func (*QueryTotalStakingsRequest) Reset

func (m *QueryTotalStakingsRequest) Reset()

func (*QueryTotalStakingsRequest) Size

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

func (*QueryTotalStakingsRequest) String

func (m *QueryTotalStakingsRequest) String() string

func (*QueryTotalStakingsRequest) Unmarshal

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

func (*QueryTotalStakingsRequest) XXX_DiscardUnknown

func (m *QueryTotalStakingsRequest) XXX_DiscardUnknown()

func (*QueryTotalStakingsRequest) XXX_Marshal

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

func (*QueryTotalStakingsRequest) XXX_Merge

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

func (*QueryTotalStakingsRequest) XXX_Size

func (m *QueryTotalStakingsRequest) XXX_Size() int

func (*QueryTotalStakingsRequest) XXX_Unmarshal

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

type QueryTotalStakingsResponse

type QueryTotalStakingsResponse struct {
	Amount github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,1,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount"`
}

QueryTotalStakingsResponse is the response type for the Query/TotalStakings RPC method.

func (*QueryTotalStakingsResponse) Descriptor

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

func (*QueryTotalStakingsResponse) Marshal

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

func (*QueryTotalStakingsResponse) MarshalTo

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

func (*QueryTotalStakingsResponse) MarshalToSizedBuffer

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

func (*QueryTotalStakingsResponse) ProtoMessage

func (*QueryTotalStakingsResponse) ProtoMessage()

func (*QueryTotalStakingsResponse) Reset

func (m *QueryTotalStakingsResponse) Reset()

func (*QueryTotalStakingsResponse) Size

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

func (*QueryTotalStakingsResponse) String

func (m *QueryTotalStakingsResponse) String() string

func (*QueryTotalStakingsResponse) Unmarshal

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

func (*QueryTotalStakingsResponse) XXX_DiscardUnknown

func (m *QueryTotalStakingsResponse) XXX_DiscardUnknown()

func (*QueryTotalStakingsResponse) XXX_Marshal

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

func (*QueryTotalStakingsResponse) XXX_Merge

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

func (*QueryTotalStakingsResponse) XXX_Size

func (m *QueryTotalStakingsResponse) XXX_Size() int

func (*QueryTotalStakingsResponse) XXX_Unmarshal

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

type QueryUnharvestedRewardsRequest

type QueryUnharvestedRewardsRequest struct {
	Farmer           string             `protobuf:"bytes,1,opt,name=farmer,proto3" json:"farmer,omitempty"`
	StakingCoinDenom string             `protobuf:"bytes,2,opt,name=staking_coin_denom,json=stakingCoinDenom,proto3" json:"staking_coin_denom,omitempty"`
	Pagination       *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryUnharvestedRewardsRequest is the request type for the Query/UnharvestedRewards RPC method.

func (*QueryUnharvestedRewardsRequest) Descriptor

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

func (*QueryUnharvestedRewardsRequest) GetFarmer

func (m *QueryUnharvestedRewardsRequest) GetFarmer() string

func (*QueryUnharvestedRewardsRequest) GetPagination

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

func (*QueryUnharvestedRewardsRequest) GetStakingCoinDenom

func (m *QueryUnharvestedRewardsRequest) GetStakingCoinDenom() string

func (*QueryUnharvestedRewardsRequest) Marshal

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

func (*QueryUnharvestedRewardsRequest) MarshalTo

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

func (*QueryUnharvestedRewardsRequest) MarshalToSizedBuffer

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

func (*QueryUnharvestedRewardsRequest) ProtoMessage

func (*QueryUnharvestedRewardsRequest) ProtoMessage()

func (*QueryUnharvestedRewardsRequest) Reset

func (m *QueryUnharvestedRewardsRequest) Reset()

func (*QueryUnharvestedRewardsRequest) Size

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

func (*QueryUnharvestedRewardsRequest) String

func (*QueryUnharvestedRewardsRequest) Unmarshal

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

func (*QueryUnharvestedRewardsRequest) XXX_DiscardUnknown

func (m *QueryUnharvestedRewardsRequest) XXX_DiscardUnknown()

func (*QueryUnharvestedRewardsRequest) XXX_Marshal

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

func (*QueryUnharvestedRewardsRequest) XXX_Merge

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

func (*QueryUnharvestedRewardsRequest) XXX_Size

func (m *QueryUnharvestedRewardsRequest) XXX_Size() int

func (*QueryUnharvestedRewardsRequest) XXX_Unmarshal

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

type QueryUnharvestedRewardsResponse

type QueryUnharvestedRewardsResponse struct {
	UnharvestedRewards []UnharvestedRewardsResponse `protobuf:"bytes,1,rep,name=unharvested_rewards,json=unharvestedRewards,proto3" json:"unharvested_rewards"`
	Pagination         *query.PageResponse          `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryUnharvestedRewardsResponse is the response type for the Query/UnharvestedRewards RPC method.

func (*QueryUnharvestedRewardsResponse) Descriptor

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

func (*QueryUnharvestedRewardsResponse) GetPagination

func (*QueryUnharvestedRewardsResponse) GetUnharvestedRewards

func (m *QueryUnharvestedRewardsResponse) GetUnharvestedRewards() []UnharvestedRewardsResponse

func (*QueryUnharvestedRewardsResponse) Marshal

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

func (*QueryUnharvestedRewardsResponse) MarshalTo

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

func (*QueryUnharvestedRewardsResponse) MarshalToSizedBuffer

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

func (*QueryUnharvestedRewardsResponse) ProtoMessage

func (*QueryUnharvestedRewardsResponse) ProtoMessage()

func (*QueryUnharvestedRewardsResponse) Reset

func (*QueryUnharvestedRewardsResponse) Size

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

func (*QueryUnharvestedRewardsResponse) String

func (*QueryUnharvestedRewardsResponse) Unmarshal

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

func (*QueryUnharvestedRewardsResponse) XXX_DiscardUnknown

func (m *QueryUnharvestedRewardsResponse) XXX_DiscardUnknown()

func (*QueryUnharvestedRewardsResponse) XXX_Marshal

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

func (*QueryUnharvestedRewardsResponse) XXX_Merge

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

func (*QueryUnharvestedRewardsResponse) XXX_Size

func (m *QueryUnharvestedRewardsResponse) XXX_Size() int

func (*QueryUnharvestedRewardsResponse) XXX_Unmarshal

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

type QueuedStaking

type QueuedStaking struct {
	Amount github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,1,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount"`
}

QueuedStaking defines staking that is waiting in a queue.

func (*QueuedStaking) Descriptor

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

func (*QueuedStaking) Marshal

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

func (*QueuedStaking) MarshalTo

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

func (*QueuedStaking) MarshalToSizedBuffer

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

func (*QueuedStaking) ProtoMessage

func (*QueuedStaking) ProtoMessage()

func (*QueuedStaking) Reset

func (m *QueuedStaking) Reset()

func (*QueuedStaking) Size

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

func (*QueuedStaking) String

func (m *QueuedStaking) String() string

func (*QueuedStaking) Unmarshal

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

func (*QueuedStaking) XXX_DiscardUnknown

func (m *QueuedStaking) XXX_DiscardUnknown()

func (*QueuedStaking) XXX_Marshal

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

func (*QueuedStaking) XXX_Merge

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

func (*QueuedStaking) XXX_Size

func (m *QueuedStaking) XXX_Size() int

func (*QueuedStaking) XXX_Unmarshal

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

type QueuedStakingRecord

type QueuedStakingRecord struct {
	EndTime          time.Time     `protobuf:"bytes,1,opt,name=end_time,json=endTime,proto3,stdtime" json:"end_time" yaml:"end_time"`
	StakingCoinDenom string        `` /* 137-byte string literal not displayed */
	Farmer           string        `protobuf:"bytes,3,opt,name=farmer,proto3" json:"farmer,omitempty"`
	QueuedStaking    QueuedStaking `protobuf:"bytes,4,opt,name=queued_staking,json=queuedStaking,proto3" json:"queued_staking" yaml:"queued_staking"`
}

QueuedStakingRecord is used for import/export via genesis json.

func (*QueuedStakingRecord) Descriptor

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

func (*QueuedStakingRecord) Marshal

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

func (*QueuedStakingRecord) MarshalTo

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

func (*QueuedStakingRecord) MarshalToSizedBuffer

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

func (*QueuedStakingRecord) ProtoMessage

func (*QueuedStakingRecord) ProtoMessage()

func (*QueuedStakingRecord) Reset

func (m *QueuedStakingRecord) Reset()

func (*QueuedStakingRecord) Size

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

func (*QueuedStakingRecord) String

func (m *QueuedStakingRecord) String() string

func (*QueuedStakingRecord) Unmarshal

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

func (QueuedStakingRecord) Validate

func (record QueuedStakingRecord) Validate() error

Validate validates QueuedStakingRecord.

func (*QueuedStakingRecord) XXX_DiscardUnknown

func (m *QueuedStakingRecord) XXX_DiscardUnknown()

func (*QueuedStakingRecord) XXX_Marshal

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

func (*QueuedStakingRecord) XXX_Merge

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

func (*QueuedStakingRecord) XXX_Size

func (m *QueuedStakingRecord) XXX_Size() int

func (*QueuedStakingRecord) XXX_Unmarshal

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

type QueuedStakingResponse

type QueuedStakingResponse struct {
	StakingCoinDenom string                                 `protobuf:"bytes,1,opt,name=staking_coin_denom,json=stakingCoinDenom,proto3" json:"staking_coin_denom,omitempty"`
	Amount           github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,2,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount"`
	EndTime          time.Time                              `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3,stdtime" json:"end_time"`
}

func (*QueuedStakingResponse) Descriptor

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

func (*QueuedStakingResponse) GetEndTime

func (m *QueuedStakingResponse) GetEndTime() time.Time

func (*QueuedStakingResponse) GetStakingCoinDenom

func (m *QueuedStakingResponse) GetStakingCoinDenom() string

func (*QueuedStakingResponse) Marshal

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

func (*QueuedStakingResponse) MarshalTo

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

func (*QueuedStakingResponse) MarshalToSizedBuffer

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

func (*QueuedStakingResponse) ProtoMessage

func (*QueuedStakingResponse) ProtoMessage()

func (*QueuedStakingResponse) Reset

func (m *QueuedStakingResponse) Reset()

func (*QueuedStakingResponse) Size

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

func (*QueuedStakingResponse) String

func (m *QueuedStakingResponse) String() string

func (*QueuedStakingResponse) Unmarshal

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

func (*QueuedStakingResponse) XXX_DiscardUnknown

func (m *QueuedStakingResponse) XXX_DiscardUnknown()

func (*QueuedStakingResponse) XXX_Marshal

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

func (*QueuedStakingResponse) XXX_Merge

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

func (*QueuedStakingResponse) XXX_Size

func (m *QueuedStakingResponse) XXX_Size() int

func (*QueuedStakingResponse) XXX_Unmarshal

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

type RatioPlan

type RatioPlan struct {
	*BasePlan `protobuf:"bytes,1,opt,name=base_plan,json=basePlan,proto3,embedded=base_plan" json:"base_plan,omitempty" yaml:"base_plan"`
	// epoch_ratio specifies the distributing amount by ratio
	EpochRatio github_com_cosmos_cosmos_sdk_types.Dec `` /* 150-byte string literal not displayed */
}

RatioPlan defines a plan that distributes to farmers by ratio distribution for every epoch day.

func NewRatioPlan

func NewRatioPlan(basePlan *BasePlan, epochRatio sdk.Dec) *RatioPlan

NewRatioPlan returns a new ratio plan.

func (*RatioPlan) Descriptor

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

func (*RatioPlan) Marshal

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

func (*RatioPlan) MarshalTo

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

func (*RatioPlan) MarshalToSizedBuffer

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

func (*RatioPlan) ProtoMessage

func (*RatioPlan) ProtoMessage()

func (*RatioPlan) Reset

func (m *RatioPlan) Reset()

func (*RatioPlan) Size

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

func (*RatioPlan) String

func (m *RatioPlan) String() string

func (*RatioPlan) Unmarshal

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

func (*RatioPlan) XXX_DiscardUnknown

func (m *RatioPlan) XXX_DiscardUnknown()

func (*RatioPlan) XXX_Marshal

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

func (*RatioPlan) XXX_Merge

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

func (*RatioPlan) XXX_Size

func (m *RatioPlan) XXX_Size() int

func (*RatioPlan) XXX_Unmarshal

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

type RewardsResponse

type RewardsResponse struct {
	StakingCoinDenom string                                   `protobuf:"bytes,1,opt,name=staking_coin_denom,json=stakingCoinDenom,proto3" json:"staking_coin_denom,omitempty"`
	Rewards          github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,2,rep,name=rewards,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"rewards"`
}

func (*RewardsResponse) Descriptor

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

func (*RewardsResponse) GetRewards

func (*RewardsResponse) GetStakingCoinDenom

func (m *RewardsResponse) GetStakingCoinDenom() string

func (*RewardsResponse) Marshal

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

func (*RewardsResponse) MarshalTo

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

func (*RewardsResponse) MarshalToSizedBuffer

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

func (*RewardsResponse) ProtoMessage

func (*RewardsResponse) ProtoMessage()

func (*RewardsResponse) Reset

func (m *RewardsResponse) Reset()

func (*RewardsResponse) Size

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

func (*RewardsResponse) String

func (m *RewardsResponse) String() string

func (*RewardsResponse) Unmarshal

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

func (*RewardsResponse) XXX_DiscardUnknown

func (m *RewardsResponse) XXX_DiscardUnknown()

func (*RewardsResponse) XXX_Marshal

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

func (*RewardsResponse) XXX_Merge

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

func (*RewardsResponse) XXX_Size

func (m *RewardsResponse) XXX_Size() int

func (*RewardsResponse) XXX_Unmarshal

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

type Staking

type Staking struct {
	Amount        github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,1,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount"`
	StartingEpoch uint64                                 `protobuf:"varint,2,opt,name=starting_epoch,json=startingEpoch,proto3" json:"starting_epoch,omitempty" yaml:"starting_epoch"`
}

Staking defines a farmer's staking information.

func (*Staking) Descriptor

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

func (*Staking) Marshal

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

func (*Staking) MarshalTo

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

func (*Staking) MarshalToSizedBuffer

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

func (*Staking) ProtoMessage

func (*Staking) ProtoMessage()

func (*Staking) Reset

func (m *Staking) Reset()

func (*Staking) Size

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

func (*Staking) String

func (m *Staking) String() string

func (*Staking) Unmarshal

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

func (*Staking) XXX_DiscardUnknown

func (m *Staking) XXX_DiscardUnknown()

func (*Staking) XXX_Marshal

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

func (*Staking) XXX_Merge

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

func (*Staking) XXX_Size

func (m *Staking) XXX_Size() int

func (*Staking) XXX_Unmarshal

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

type StakingRecord

type StakingRecord struct {
	StakingCoinDenom string  `` /* 137-byte string literal not displayed */
	Farmer           string  `protobuf:"bytes,2,opt,name=farmer,proto3" json:"farmer,omitempty"`
	Staking          Staking `protobuf:"bytes,3,opt,name=staking,proto3" json:"staking"`
}

StakingRecord is used for import/export via genesis json.

func (*StakingRecord) Descriptor

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

func (*StakingRecord) Marshal

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

func (*StakingRecord) MarshalTo

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

func (*StakingRecord) MarshalToSizedBuffer

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

func (*StakingRecord) ProtoMessage

func (*StakingRecord) ProtoMessage()

func (*StakingRecord) Reset

func (m *StakingRecord) Reset()

func (*StakingRecord) Size

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

func (*StakingRecord) String

func (m *StakingRecord) String() string

func (*StakingRecord) Unmarshal

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

func (StakingRecord) Validate

func (record StakingRecord) Validate() error

Validate validates StakingRecord.

func (*StakingRecord) XXX_DiscardUnknown

func (m *StakingRecord) XXX_DiscardUnknown()

func (*StakingRecord) XXX_Marshal

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

func (*StakingRecord) XXX_Merge

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

func (*StakingRecord) XXX_Size

func (m *StakingRecord) XXX_Size() int

func (*StakingRecord) XXX_Unmarshal

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

type StakingResponse

type StakingResponse struct {
	StakingCoinDenom string                                 `protobuf:"bytes,1,opt,name=staking_coin_denom,json=stakingCoinDenom,proto3" json:"staking_coin_denom,omitempty"`
	Amount           github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,2,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount"`
	StartingEpoch    uint64                                 `protobuf:"varint,3,opt,name=starting_epoch,json=startingEpoch,proto3" json:"starting_epoch,omitempty"`
}

func (*StakingResponse) Descriptor

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

func (*StakingResponse) GetStakingCoinDenom

func (m *StakingResponse) GetStakingCoinDenom() string

func (*StakingResponse) GetStartingEpoch

func (m *StakingResponse) GetStartingEpoch() uint64

func (*StakingResponse) Marshal

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

func (*StakingResponse) MarshalTo

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

func (*StakingResponse) MarshalToSizedBuffer

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

func (*StakingResponse) ProtoMessage

func (*StakingResponse) ProtoMessage()

func (*StakingResponse) Reset

func (m *StakingResponse) Reset()

func (*StakingResponse) Size

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

func (*StakingResponse) String

func (m *StakingResponse) String() string

func (*StakingResponse) Unmarshal

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

func (*StakingResponse) XXX_DiscardUnknown

func (m *StakingResponse) XXX_DiscardUnknown()

func (*StakingResponse) XXX_Marshal

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

func (*StakingResponse) XXX_Merge

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

func (*StakingResponse) XXX_Size

func (m *StakingResponse) XXX_Size() int

func (*StakingResponse) XXX_Unmarshal

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

type TotalStakings

type TotalStakings struct {
	Amount github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,1,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount"`
}

TotalStakings defines the total staking amount for a staking coin denom.

func (*TotalStakings) Descriptor

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

func (*TotalStakings) Marshal

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

func (*TotalStakings) MarshalTo

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

func (*TotalStakings) MarshalToSizedBuffer

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

func (*TotalStakings) ProtoMessage

func (*TotalStakings) ProtoMessage()

func (*TotalStakings) Reset

func (m *TotalStakings) Reset()

func (*TotalStakings) Size

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

func (*TotalStakings) String

func (m *TotalStakings) String() string

func (*TotalStakings) Unmarshal

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

func (*TotalStakings) XXX_DiscardUnknown

func (m *TotalStakings) XXX_DiscardUnknown()

func (*TotalStakings) XXX_Marshal

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

func (*TotalStakings) XXX_Merge

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

func (*TotalStakings) XXX_Size

func (m *TotalStakings) XXX_Size() int

func (*TotalStakings) XXX_Unmarshal

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

type TotalStakingsRecord

type TotalStakingsRecord struct {
	StakingCoinDenom string `` /* 137-byte string literal not displayed */
	// amount specifies total amount of the staking for the staking coin denom except queued staking
	Amount github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,2,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount"`
	// staking_reserve_coins specifies balance of the staking reserve account where staking and queued staking for the
	// staking coin denom is stored this param is needed for import/export validation
	StakingReserveCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 193-byte string literal not displayed */
}

TotalStakingsRecord is used for import/export via genesis json.

func (*TotalStakingsRecord) Descriptor

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

func (*TotalStakingsRecord) Marshal

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

func (*TotalStakingsRecord) MarshalTo

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

func (*TotalStakingsRecord) MarshalToSizedBuffer

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

func (*TotalStakingsRecord) ProtoMessage

func (*TotalStakingsRecord) ProtoMessage()

func (*TotalStakingsRecord) Reset

func (m *TotalStakingsRecord) Reset()

func (*TotalStakingsRecord) Size

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

func (*TotalStakingsRecord) String

func (m *TotalStakingsRecord) String() string

func (*TotalStakingsRecord) Unmarshal

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

func (TotalStakingsRecord) Validate

func (record TotalStakingsRecord) Validate() error

Validate validates StakingRecord.

func (*TotalStakingsRecord) XXX_DiscardUnknown

func (m *TotalStakingsRecord) XXX_DiscardUnknown()

func (*TotalStakingsRecord) XXX_Marshal

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

func (*TotalStakingsRecord) XXX_Merge

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

func (*TotalStakingsRecord) XXX_Size

func (m *TotalStakingsRecord) XXX_Size() int

func (*TotalStakingsRecord) XXX_Unmarshal

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

type UnharvestedRewards

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

UnharvestedRewards represents unharvested rewards of a farmer for a staking coin denom, which increases when there was an automatic withdrawal of rewards due to changes in staked coin amount.

func (*UnharvestedRewards) Descriptor

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

func (*UnharvestedRewards) Marshal

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

func (*UnharvestedRewards) MarshalTo

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

func (*UnharvestedRewards) MarshalToSizedBuffer

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

func (*UnharvestedRewards) ProtoMessage

func (*UnharvestedRewards) ProtoMessage()

func (*UnharvestedRewards) Reset

func (m *UnharvestedRewards) Reset()

func (*UnharvestedRewards) Size

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

func (*UnharvestedRewards) String

func (m *UnharvestedRewards) String() string

func (*UnharvestedRewards) Unmarshal

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

func (*UnharvestedRewards) XXX_DiscardUnknown

func (m *UnharvestedRewards) XXX_DiscardUnknown()

func (*UnharvestedRewards) XXX_Marshal

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

func (*UnharvestedRewards) XXX_Merge

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

func (*UnharvestedRewards) XXX_Size

func (m *UnharvestedRewards) XXX_Size() int

func (*UnharvestedRewards) XXX_Unmarshal

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

type UnharvestedRewardsRecord

type UnharvestedRewardsRecord struct {
	Farmer             string             `protobuf:"bytes,1,opt,name=farmer,proto3" json:"farmer,omitempty"`
	StakingCoinDenom   string             `` /* 137-byte string literal not displayed */
	UnharvestedRewards UnharvestedRewards `` /* 132-byte string literal not displayed */
}

func (*UnharvestedRewardsRecord) Descriptor

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

func (*UnharvestedRewardsRecord) Marshal

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

func (*UnharvestedRewardsRecord) MarshalTo

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

func (*UnharvestedRewardsRecord) MarshalToSizedBuffer

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

func (*UnharvestedRewardsRecord) ProtoMessage

func (*UnharvestedRewardsRecord) ProtoMessage()

func (*UnharvestedRewardsRecord) Reset

func (m *UnharvestedRewardsRecord) Reset()

func (*UnharvestedRewardsRecord) Size

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

func (*UnharvestedRewardsRecord) String

func (m *UnharvestedRewardsRecord) String() string

func (*UnharvestedRewardsRecord) Unmarshal

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

func (UnharvestedRewardsRecord) Validate

func (record UnharvestedRewardsRecord) Validate() error

Validate validates UnharvestedRewardsRecord.

func (*UnharvestedRewardsRecord) XXX_DiscardUnknown

func (m *UnharvestedRewardsRecord) XXX_DiscardUnknown()

func (*UnharvestedRewardsRecord) XXX_Marshal

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

func (*UnharvestedRewardsRecord) XXX_Merge

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

func (*UnharvestedRewardsRecord) XXX_Size

func (m *UnharvestedRewardsRecord) XXX_Size() int

func (*UnharvestedRewardsRecord) XXX_Unmarshal

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

type UnharvestedRewardsResponse

type UnharvestedRewardsResponse struct {
	StakingCoinDenom string                                   `protobuf:"bytes,1,opt,name=staking_coin_denom,json=stakingCoinDenom,proto3" json:"staking_coin_denom,omitempty"`
	Rewards          github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,2,rep,name=rewards,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"rewards"`
}

func (*UnharvestedRewardsResponse) Descriptor

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

func (*UnharvestedRewardsResponse) GetRewards

func (*UnharvestedRewardsResponse) GetStakingCoinDenom

func (m *UnharvestedRewardsResponse) GetStakingCoinDenom() string

func (*UnharvestedRewardsResponse) Marshal

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

func (*UnharvestedRewardsResponse) MarshalTo

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

func (*UnharvestedRewardsResponse) MarshalToSizedBuffer

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

func (*UnharvestedRewardsResponse) ProtoMessage

func (*UnharvestedRewardsResponse) ProtoMessage()

func (*UnharvestedRewardsResponse) Reset

func (m *UnharvestedRewardsResponse) Reset()

func (*UnharvestedRewardsResponse) Size

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

func (*UnharvestedRewardsResponse) String

func (m *UnharvestedRewardsResponse) String() string

func (*UnharvestedRewardsResponse) Unmarshal

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

func (*UnharvestedRewardsResponse) XXX_DiscardUnknown

func (m *UnharvestedRewardsResponse) XXX_DiscardUnknown()

func (*UnharvestedRewardsResponse) XXX_Marshal

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

func (*UnharvestedRewardsResponse) XXX_Merge

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

func (*UnharvestedRewardsResponse) XXX_Size

func (m *UnharvestedRewardsResponse) XXX_Size() int

func (*UnharvestedRewardsResponse) XXX_Unmarshal

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

type UnimplementedMsgServer

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) AdvanceEpoch

func (*UnimplementedMsgServer) CreateFixedAmountPlan

func (*UnimplementedMsgServer) CreateRatioPlan

func (*UnimplementedMsgServer) Harvest

func (*UnimplementedMsgServer) RemovePlan

func (*UnimplementedMsgServer) Stake

func (*UnimplementedMsgServer) Unstake

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) CurrentEpochDays

func (*UnimplementedQueryServer) HistoricalRewards

func (*UnimplementedQueryServer) Params

func (*UnimplementedQueryServer) Plan

func (*UnimplementedQueryServer) Plans

func (*UnimplementedQueryServer) Position

func (*UnimplementedQueryServer) QueuedStakings

func (*UnimplementedQueryServer) Rewards

func (*UnimplementedQueryServer) Stakings

func (*UnimplementedQueryServer) TotalStakings

func (*UnimplementedQueryServer) UnharvestedRewards

Jump to

Keyboard shortcuts

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