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 (m *AddPlanRequest) GetEpochAmount() github_com_cosmos_cosmos_sdk_types.Coins

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 (m *HistoricalRewardsResponse) GetCumulativeUnitRewards() github_com_cosmos_cosmos_sdk_types.DecCoins

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 (m *ModifyPlanRequest) GetEpochAmount() github_com_cosmos_cosmos_sdk_types.Coins

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 (m *ModifyPlanRequest) GetStakingCoinWeights() github_com_cosmos_cosmos_sdk_types.DecCoins

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 (m *MsgCreateFixedAmountPlanResponse) Reset()

func (*MsgCreateFixedAmountPlanResponse) Size 

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

func (*MsgCreateFixedAmountPlanResponse) String 

func (m *MsgCreateFixedAmountPlanResponse) String() 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 (m *MsgCreateFixedAmountPlanResponse) XXX_Merge(src proto.Message)

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 (m *QueryCurrentEpochDaysRequest) String() 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 (m *QueryCurrentEpochDaysResponse) String() 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 (m *QueryHistoricalRewardsRequest) String() 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 (m *QueryHistoricalRewardsResponse) GetPagination() *query.PageResponse

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 (m *QueryHistoricalRewardsResponse) String() 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 (m *QueryPositionResponse) GetQueuedCoins() github_com_cosmos_cosmos_sdk_types.Coins

func (*QueryPositionResponse) GetRewards 

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

func (*QueryPositionResponse) GetStakedCoins 

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

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 (m *QueryUnharvestedRewardsRequest) String() 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 (m *QueryUnharvestedRewardsResponse) GetPagination() *query.PageResponse

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 (m *QueryUnharvestedRewardsResponse) Reset()

func (*QueryUnharvestedRewardsResponse) Size 

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

func (*QueryUnharvestedRewardsResponse) String 

func (m *QueryUnharvestedRewardsResponse) String() 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 (m *RewardsResponse) GetRewards() github_com_cosmos_cosmos_sdk_types.Coins

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 (m *UnharvestedRewardsResponse) GetRewards() github_com_cosmos_cosmos_sdk_types.Coins

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) AdvanceEpoch(ctx context.Context, req *MsgAdvanceEpoch) (*MsgAdvanceEpochResponse, error)

func (*UnimplementedMsgServer) CreateFixedAmountPlan 

func (*UnimplementedMsgServer) CreateFixedAmountPlan(ctx context.Context, req *MsgCreateFixedAmountPlan) (*MsgCreateFixedAmountPlanResponse, error)

func (*UnimplementedMsgServer) CreateRatioPlan 

func (*UnimplementedMsgServer) CreateRatioPlan(ctx context.Context, req *MsgCreateRatioPlan) (*MsgCreateRatioPlanResponse, error)

func (*UnimplementedMsgServer) Harvest 

func (*UnimplementedMsgServer) Harvest(ctx context.Context, req *MsgHarvest) (*MsgHarvestResponse, error)

func (*UnimplementedMsgServer) RemovePlan 

func (*UnimplementedMsgServer) RemovePlan(ctx context.Context, req *MsgRemovePlan) (*MsgRemovePlanResponse, error)

func (*UnimplementedMsgServer) Stake 

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

func (*UnimplementedMsgServer) Unstake 

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

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) CurrentEpochDays 

func (*UnimplementedQueryServer) CurrentEpochDays(ctx context.Context, req *QueryCurrentEpochDaysRequest) (*QueryCurrentEpochDaysResponse, error)

func (*UnimplementedQueryServer) HistoricalRewards 

func (*UnimplementedQueryServer) HistoricalRewards(ctx context.Context, req *QueryHistoricalRewardsRequest) (*QueryHistoricalRewardsResponse, error)

func (*UnimplementedQueryServer) Params 

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

func (*UnimplementedQueryServer) Plan 

func (*UnimplementedQueryServer) Plan(ctx context.Context, req *QueryPlanRequest) (*QueryPlanResponse, error)

func (*UnimplementedQueryServer) Plans 

func (*UnimplementedQueryServer) Plans(ctx context.Context, req *QueryPlansRequest) (*QueryPlansResponse, error)

func (*UnimplementedQueryServer) Position 

func (*UnimplementedQueryServer) Position(ctx context.Context, req *QueryPositionRequest) (*QueryPositionResponse, error)

func (*UnimplementedQueryServer) QueuedStakings 

func (*UnimplementedQueryServer) QueuedStakings(ctx context.Context, req *QueryQueuedStakingsRequest) (*QueryQueuedStakingsResponse, error)

func (*UnimplementedQueryServer) Rewards 

func (*UnimplementedQueryServer) Rewards(ctx context.Context, req *QueryRewardsRequest) (*QueryRewardsResponse, error)

func (*UnimplementedQueryServer) Stakings 

func (*UnimplementedQueryServer) Stakings(ctx context.Context, req *QueryStakingsRequest) (*QueryStakingsResponse, error)

func (*UnimplementedQueryServer) TotalStakings 

func (*UnimplementedQueryServer) TotalStakings(ctx context.Context, req *QueryTotalStakingsRequest) (*QueryTotalStakingsResponse, error)

func (*UnimplementedQueryServer) UnharvestedRewards 

func (*UnimplementedQueryServer) UnharvestedRewards(ctx context.Context, req *QueryUnharvestedRewardsRequest) (*QueryUnharvestedRewardsResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.