types

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Sep 17, 2021 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypeCreateFixedAmountPlan = "create_fixed_amount_plan"
	EventTypeCreateRatioPlan       = "create_ratio_plan"
	EventTypeStake                 = "stake"
	EventTypeUnstake               = "unstake"
	EventTypeHarvest               = "harvest"
	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"
)

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"
	TypeMsgAdvanceEpoch          = "advance_epoch"
)

Message types for the farming module

View Source 
const (
	MaxNameLength                    int    = 140
	PrivatePlanFarmingPoolAddrPrefix string = "PrivatePlan"
	PoolAddrSplitter                 string = "|"
)
View Source 
const (
	ProposalTypePublicPlan string = "PublicPlan"
)

Variables

View Source 
var (
	ErrPlanNotExists                  = sdkerrors.Register(ModuleName, 2, "plan does not exist")
	ErrInvalidPlanType                = sdkerrors.Register(ModuleName, 3, "invalid plan type")
	ErrInvalidPlanEndTime             = sdkerrors.Register(ModuleName, 4, "invalid plan end time")
	ErrStakingNotExists               = sdkerrors.Register(ModuleName, 5, "staking not exists")
	ErrRewardNotExists                = sdkerrors.Register(ModuleName, 6, "reward not exists")
	ErrFeeCollectionFailure           = sdkerrors.Register(ModuleName, 7, "fee collection failure")
	ErrInvalidPlanNameLength          = sdkerrors.Register(ModuleName, 8, "invalid plan name length")
	ErrDuplicatePlanName              = sdkerrors.Register(ModuleName, 9, "duplicate plan name")
	ErrInvalidPlanName                = sdkerrors.Register(ModuleName, 10, "invalid plan name")
	ErrConflictPrivatePlanFarmingPool = sdkerrors.Register(ModuleName, 11, "the address is already in use, please use a different plan name")
	ErrInvalidStakingReservedAmount   = sdkerrors.Register(ModuleName, 12, "staking reserved amount invariant broken")
	ErrInvalidRemainingRewardsAmount  = sdkerrors.Register(ModuleName, 13, "remaining rewards amount invariant broken")
)

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

keys for farming store prefixes

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

	DefaultPrivatePlanCreationFee = sdk.NewCoins(sdk.NewCoin(sdk.DefaultBondDenom, sdk.NewInt(100_000_000)))
	DefaultCurrentEpochDays       = uint32(1)
	DefaultNextEpochDays          = uint32(1)
	DefaultFarmingFeeCollector    = sdk.AccAddress(address.Module(ModuleName, []byte("FarmingFeeCollectorAcc"))).String()
	StakingReserveAcc             = sdk.AccAddress(address.Module(ModuleName, []byte("StakingReserveAcc")))
	RewardsReserveAcc             = sdk.AccAddress(address.Module(ModuleName, []byte("RewardsReserveAcc")))
)

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

func GetCurrentEpochKey(stakingCoinDenom string) []byte

func GetHistoricalRewardsKey 

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

func GetOutstandingRewardsKey 

func GetOutstandingRewardsKey(stakingCoinDenom string) []byte

func GetPlanKey 

func GetPlanKey(planID uint64) []byte

GetPlanKey returns kv indexing key of the plan

func GetQueuedStakingByFarmerPrefix 

func GetQueuedStakingByFarmerPrefix(farmerAcc sdk.AccAddress) []byte

func GetQueuedStakingIndexKey 

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

func GetQueuedStakingKey 

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

func GetStakingIndexKey 

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

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

func GetTotalStakingsKey 

func GetTotalStakingsKey(stakingCoinDenom string) []byte

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 is LengthPrefix for string.

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)

func ParseHistoricalRewardsKey 

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

func ParseOutstandingRewardsKey 

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

func ParseQueuedStakingIndexKey 

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

func ParseQueuedStakingKey 

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

func ParseStakingIndexKey 

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

func ParseStakingKey 

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

func ParseTime 

func ParseTime(s string) time.Time

ParseTime parses string time to time in RFC3339 format.

func PrivatePlanFarmingPoolAddress 

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

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

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

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 ValidateGenesis 

func ValidateGenesis(data GenesisState) error

ValidateGenesis validates GenesisState.

func ValidateName 

func ValidateName(i interface{}) error

ValidateName validates duplicate plan name value.

func ValidateStakingCoinTotalWeights 

func ValidateStakingCoinTotalWeights(weights sdk.DecCoins) bool

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

func ValidateTotalEpochRatio 

func ValidateTotalEpochRatio(i interface{}) 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
	GetModuleAccount(ctx sdk.Context, moduleName string) authtypes.ModuleAccountI
	SetModuleAccount(sdk.Context, authtypes.ModuleAccountI)
}

AccountKeeper defines the expected account keeper

type AddRequestProposal 

type AddRequestProposal struct {
	// name specifies the plan name that describes what plan is for
	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 */
}

AddRequestProposal details a proposal for creating a public plan.

func (*AddRequestProposal) Descriptor 

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

func (*AddRequestProposal) GetEndTime 

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

func (*AddRequestProposal) GetEpochAmount 

func (m *AddRequestProposal) GetEpochAmount() github_com_cosmos_cosmos_sdk_types.Coins

func (*AddRequestProposal) GetFarmingPoolAddress 

func (m *AddRequestProposal) GetFarmingPoolAddress() string

func (*AddRequestProposal) GetName 

func (m *AddRequestProposal) GetName() string

func (*AddRequestProposal) GetStakingCoinWeights 

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

func (*AddRequestProposal) GetStartTime 

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

func (*AddRequestProposal) GetTerminationAddress 

func (m *AddRequestProposal) GetTerminationAddress() string

func (*AddRequestProposal) Marshal 

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

func (*AddRequestProposal) MarshalTo 

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

func (*AddRequestProposal) MarshalToSizedBuffer 

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

func (*AddRequestProposal) ProtoMessage 

func (*AddRequestProposal) ProtoMessage()

func (*AddRequestProposal) Reset 

func (m *AddRequestProposal) Reset()

func (*AddRequestProposal) Size 

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

func (*AddRequestProposal) String 

func (m *AddRequestProposal) String() string

func (*AddRequestProposal) Unmarshal 

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

func (*AddRequestProposal) Validate 

func (p *AddRequestProposal) Validate() error

func (*AddRequestProposal) XXX_DiscardUnknown 

func (m *AddRequestProposal) XXX_DiscardUnknown()

func (*AddRequestProposal) XXX_Marshal 

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

func (*AddRequestProposal) XXX_Merge 

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

func (*AddRequestProposal) XXX_Size 

func (m *AddRequestProposal) XXX_Size() int

func (*AddRequestProposal) XXX_Unmarshal 

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

type BankKeeper 

type BankKeeper interface {
	SendCoins(ctx sdk.Context, fromAddr sdk.AccAddress, toAddr sdk.AccAddress, amt sdk.Coins) error
	GetAllBalances(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	//GetBalance(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin
	SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins

	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	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 base 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=cosmos.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 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,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 happened
	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. It contains all the necessary fields for basic farming plan functionality. Any custom farming plan type should extend this type for additional functionality (e.g. 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) 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) GetTerminated 

func (plan *BasePlan) GetTerminated() bool

func (BasePlan) GetTerminationAddress 

func (plan BasePlan) GetTerminationAddress() sdk.AccAddress

func (BasePlan) GetType 

func (plan BasePlan) GetType() PlanType

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

func (plan BasePlan) MarshalYAML() (interface{}, error)

MarshalYAML returns the YAML representation of an Plan.

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 (plan 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"`
}

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

type DeleteRequestProposal 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"`
}

DeleteRequestProposal details a proposal for deleting an existing public plan.

func (*DeleteRequestProposal) Descriptor 

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

func (*DeleteRequestProposal) GetPlanId 

func (m *DeleteRequestProposal) GetPlanId() uint64

func (*DeleteRequestProposal) Marshal 

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

func (*DeleteRequestProposal) MarshalTo 

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

func (*DeleteRequestProposal) MarshalToSizedBuffer 

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

func (*DeleteRequestProposal) ProtoMessage 

func (*DeleteRequestProposal) ProtoMessage()

func (*DeleteRequestProposal) Reset 

func (m *DeleteRequestProposal) Reset()

func (*DeleteRequestProposal) Size 

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

func (*DeleteRequestProposal) String 

func (m *DeleteRequestProposal) String() string

func (*DeleteRequestProposal) Unmarshal 

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

func (*DeleteRequestProposal) Validate 

func (p *DeleteRequestProposal) Validate() error

func (*DeleteRequestProposal) XXX_DiscardUnknown 

func (m *DeleteRequestProposal) XXX_DiscardUnknown()

func (*DeleteRequestProposal) XXX_Marshal 

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

func (*DeleteRequestProposal) XXX_Merge 

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

func (*DeleteRequestProposal) XXX_Size 

func (m *DeleteRequestProposal) XXX_Size() int

func (*DeleteRequestProposal) XXX_Unmarshal 

func (m *DeleteRequestProposal) 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 fixed amount of coins are distributed for every epoch.

func NewFixedAmountPlan 

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

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) 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"`
	// plan_records defines the plan records used for genesis state
	PlanRecords               []PlanRecord               `protobuf:"bytes,2,rep,name=plan_records,json=planRecords,proto3" json:"plan_records" yaml:"plan_records"`
	StakingRecords            []StakingRecord            `protobuf:"bytes,3,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 */
	CurrentEpochRecords       []CurrentEpochRecord       `` /* 139-byte string literal not displayed */
	// staking_reserve_coins specifies balance of the staking reserve pool staked in the plans
	// this param is needed for import/export validation
	StakingReserveCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 193-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 `` /* 177-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,11,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, plans []PlanRecord, stakings []StakingRecord, queuedStakings []QueuedStakingRecord,
	historicalRewards []HistoricalRewardsRecord, outstandingRewards []OutstandingRewardsRecord,
	currentEpochs []CurrentEpochRecord, stakingReserveCoins, 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 */
}

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

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

func (m *OutstandingRewards) GetRewards() github_com_cosmos_cosmos_sdk_types.DecCoins

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

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

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

	GetTerminated() bool
	SetTerminated(bool) error

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

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

	String() string

	Validate() error
}

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 */
	// staking_reserve_coins specifies balance of the staking reserve pool staked
	// in the plan this param is needed for import/export validation
	StakingReserveCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 193-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 Reward.

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_request_proposals specifies AddRequestProposal object
	AddRequestProposals []*AddRequestProposal `` /* 149-byte string literal not displayed */
	// update_request_proposals specifies UpdateRequestProposal object
	UpdateRequestProposals []*UpdateRequestProposal `` /* 161-byte string literal not displayed */
	// delete_request_proposals specifies DeleteRequestProposal object
	DeleteRequestProposals []*DeleteRequestProposal `` /* 161-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,
	addReq []*AddRequestProposal,
	updateReq []*UpdateRequestProposal,
	deleteReq []*DeleteRequestProposal,
) *PublicPlanProposal

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)
	Stakings(ctx context.Context, in *QueryStakingsRequest, opts ...grpc.CallOption) (*QueryStakingsResponse, error)
	TotalStakings(ctx context.Context, in *QueryTotalStakingsRequest, opts ...grpc.CallOption) (*QueryTotalStakingsResponse, error)
	Rewards(ctx context.Context, in *QueryRewardsRequest, opts ...grpc.CallOption) (*QueryRewardsResponse, error)
	// CurrentEpochDays returns current epoch days.
	CurrentEpochDays(ctx context.Context, in *QueryCurrentEpochDaysRequest, opts ...grpc.CallOption) (*QueryCurrentEpochDaysResponse, 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"`
}

QuerCurrentEpochDaysResponse 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 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      []*types.Any        `protobuf:"bytes,1,rep,name=plans,proto3" json:"plans,omitempty"`
	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 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"`
}

func (*QueryRewardsRequest) Descriptor 

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

func (*QueryRewardsRequest) GetFarmer 

func (m *QueryRewardsRequest) GetFarmer() string

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 github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,1,rep,name=rewards,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"rewards"`
}

func (*QueryRewardsResponse) Descriptor 

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

func (*QueryRewardsResponse) GetRewards 

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

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)
	Stakings(context.Context, *QueryStakingsRequest) (*QueryStakingsResponse, error)
	TotalStakings(context.Context, *QueryTotalStakingsRequest) (*QueryTotalStakingsResponse, error)
	Rewards(context.Context, *QueryRewardsRequest) (*QueryRewardsResponse, error)
	// CurrentEpochDays returns current epoch days.
	CurrentEpochDays(context.Context, *QueryCurrentEpochDaysRequest) (*QueryCurrentEpochDaysResponse, 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"`
}

func (*QueryStakingsRequest) Descriptor 

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

func (*QueryStakingsRequest) GetFarmer 

func (m *QueryStakingsRequest) GetFarmer() string

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

func (*QueryStakingsResponse) Descriptor 

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

func (*QueryStakingsResponse) GetQueuedCoins 

func (m *QueryStakingsResponse) GetQueuedCoins() github_com_cosmos_cosmos_sdk_types.Coins

func (*QueryStakingsResponse) GetStakedCoins 

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

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"`
}

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"`
}

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 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"`
}

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 {
	StakingCoinDenom string        `` /* 137-byte string literal not displayed */
	Farmer           string        `protobuf:"bytes,2,opt,name=farmer,proto3" json:"farmer,omitempty"`
	QueuedStaking    QueuedStaking `protobuf:"bytes,3,opt,name=queued_staking,json=queuedStaking,proto3" json:"queued_staking" yaml:"queued_staking"`
}

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) 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 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 ratio plan that ratio of total coins in farming pool address is distributed for every epoch.

func NewRatioPlan 

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

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

func (s Staking) MarshalYAML() (interface{}, 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 (s 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"`
}

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

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

type UpdateRequestProposal 

type UpdateRequestProposal 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 that describes what plan is for
	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 */
}

UpdateRequestProposal details a proposal for updating an existing public plan.

func (*UpdateRequestProposal) Descriptor 

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

func (*UpdateRequestProposal) GetEndTime 

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

func (*UpdateRequestProposal) GetEpochAmount 

func (m *UpdateRequestProposal) GetEpochAmount() github_com_cosmos_cosmos_sdk_types.Coins

func (*UpdateRequestProposal) GetFarmingPoolAddress 

func (m *UpdateRequestProposal) GetFarmingPoolAddress() string

func (*UpdateRequestProposal) GetName 

func (m *UpdateRequestProposal) GetName() string

func (*UpdateRequestProposal) GetPlanId 

func (m *UpdateRequestProposal) GetPlanId() uint64

func (*UpdateRequestProposal) GetStakingCoinWeights 

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

func (*UpdateRequestProposal) GetStartTime 

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

func (*UpdateRequestProposal) GetTerminationAddress 

func (m *UpdateRequestProposal) GetTerminationAddress() string

func (*UpdateRequestProposal) Marshal 

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

func (*UpdateRequestProposal) MarshalTo 

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

func (*UpdateRequestProposal) MarshalToSizedBuffer 

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

func (*UpdateRequestProposal) ProtoMessage 

func (*UpdateRequestProposal) ProtoMessage()

func (*UpdateRequestProposal) Reset 

func (m *UpdateRequestProposal) Reset()

func (*UpdateRequestProposal) Size 

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

func (*UpdateRequestProposal) String 

func (m *UpdateRequestProposal) String() string

func (*UpdateRequestProposal) Unmarshal 

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

func (*UpdateRequestProposal) Validate 

func (p *UpdateRequestProposal) Validate() error

func (*UpdateRequestProposal) XXX_DiscardUnknown 

func (m *UpdateRequestProposal) XXX_DiscardUnknown()

func (*UpdateRequestProposal) XXX_Marshal 

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

func (*UpdateRequestProposal) XXX_Merge 

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

func (*UpdateRequestProposal) XXX_Size 

func (m *UpdateRequestProposal) XXX_Size() int

func (*UpdateRequestProposal) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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