Documentation ¶
Index ¶
- Constants
- Variables
- func KeyPrefix(p string) []byte
- func ParamKeyTable() paramtypes.KeyTable
- func RegisterCodec(cdc *codec.LegacyAmino)
- func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
- func RegisterMsgServer(s grpc1.Server, srv MsgServer)
- func RegisterQueryServer(s grpc1.Server, srv QueryServer)
- type ActivePotsRequest
- func (*ActivePotsRequest) Descriptor() ([]byte, []int)
- func (m *ActivePotsRequest) GetPagination() *query.PageRequest
- func (m *ActivePotsRequest) Marshal() (dAtA []byte, err error)
- func (m *ActivePotsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ActivePotsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ActivePotsRequest) ProtoMessage()
- func (m *ActivePotsRequest) Reset()
- func (m *ActivePotsRequest) Size() (n int)
- func (m *ActivePotsRequest) String() string
- func (m *ActivePotsRequest) Unmarshal(dAtA []byte) error
- func (m *ActivePotsRequest) XXX_DiscardUnknown()
- func (m *ActivePotsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ActivePotsRequest) XXX_Merge(src proto.Message)
- func (m *ActivePotsRequest) XXX_Size() int
- func (m *ActivePotsRequest) XXX_Unmarshal(b []byte) error
- type ActivePotsResponse
- func (*ActivePotsResponse) Descriptor() ([]byte, []int)
- func (m *ActivePotsResponse) GetData() []Pot
- func (m *ActivePotsResponse) GetPagination() *query.PageResponse
- func (m *ActivePotsResponse) Marshal() (dAtA []byte, err error)
- func (m *ActivePotsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ActivePotsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ActivePotsResponse) ProtoMessage()
- func (m *ActivePotsResponse) Reset()
- func (m *ActivePotsResponse) Size() (n int)
- func (m *ActivePotsResponse) String() string
- func (m *ActivePotsResponse) Unmarshal(dAtA []byte) error
- func (m *ActivePotsResponse) XXX_DiscardUnknown()
- func (m *ActivePotsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ActivePotsResponse) XXX_Merge(src proto.Message)
- func (m *ActivePotsResponse) XXX_Size() int
- func (m *ActivePotsResponse) XXX_Unmarshal(b []byte) error
- type BankKeeper
- type EpochKeeper
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)
- func (m *GenesisState) GetParams() Params
- func (m *GenesisState) GetPots() []Pot
- func (m *GenesisState) Marshal() (dAtA []byte, err error)
- func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)
- func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GenesisState) ProtoMessage()
- func (m *GenesisState) Reset()
- func (m *GenesisState) Size() (n int)
- func (m *GenesisState) String() string
- func (m *GenesisState) Unmarshal(dAtA []byte) error
- func (gs GenesisState) Validate() error
- func (m *GenesisState) XXX_DiscardUnknown()
- func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GenesisState) XXX_Merge(src proto.Message)
- func (m *GenesisState) XXX_Size() int
- func (m *GenesisState) XXX_Unmarshal(b []byte) error
- type IncentiveHooks
- type LockupKeeper
- type ModuleDistributedCoinsRequest
- func (*ModuleDistributedCoinsRequest) Descriptor() ([]byte, []int)
- func (m *ModuleDistributedCoinsRequest) Marshal() (dAtA []byte, err error)
- func (m *ModuleDistributedCoinsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ModuleDistributedCoinsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ModuleDistributedCoinsRequest) ProtoMessage()
- func (m *ModuleDistributedCoinsRequest) Reset()
- func (m *ModuleDistributedCoinsRequest) Size() (n int)
- func (m *ModuleDistributedCoinsRequest) String() string
- func (m *ModuleDistributedCoinsRequest) Unmarshal(dAtA []byte) error
- func (m *ModuleDistributedCoinsRequest) XXX_DiscardUnknown()
- func (m *ModuleDistributedCoinsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ModuleDistributedCoinsRequest) XXX_Merge(src proto.Message)
- func (m *ModuleDistributedCoinsRequest) XXX_Size() int
- func (m *ModuleDistributedCoinsRequest) XXX_Unmarshal(b []byte) error
- type ModuleDistributedCoinsResponse
- func (*ModuleDistributedCoinsResponse) Descriptor() ([]byte, []int)
- func (m *ModuleDistributedCoinsResponse) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins
- func (m *ModuleDistributedCoinsResponse) Marshal() (dAtA []byte, err error)
- func (m *ModuleDistributedCoinsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ModuleDistributedCoinsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ModuleDistributedCoinsResponse) ProtoMessage()
- func (m *ModuleDistributedCoinsResponse) Reset()
- func (m *ModuleDistributedCoinsResponse) Size() (n int)
- func (m *ModuleDistributedCoinsResponse) String() string
- func (m *ModuleDistributedCoinsResponse) Unmarshal(dAtA []byte) error
- func (m *ModuleDistributedCoinsResponse) XXX_DiscardUnknown()
- func (m *ModuleDistributedCoinsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ModuleDistributedCoinsResponse) XXX_Merge(src proto.Message)
- func (m *ModuleDistributedCoinsResponse) XXX_Size() int
- func (m *ModuleDistributedCoinsResponse) XXX_Unmarshal(b []byte) error
- type ModuleToDistributeCoinsRequest
- func (*ModuleToDistributeCoinsRequest) Descriptor() ([]byte, []int)
- func (m *ModuleToDistributeCoinsRequest) Marshal() (dAtA []byte, err error)
- func (m *ModuleToDistributeCoinsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ModuleToDistributeCoinsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ModuleToDistributeCoinsRequest) ProtoMessage()
- func (m *ModuleToDistributeCoinsRequest) Reset()
- func (m *ModuleToDistributeCoinsRequest) Size() (n int)
- func (m *ModuleToDistributeCoinsRequest) String() string
- func (m *ModuleToDistributeCoinsRequest) Unmarshal(dAtA []byte) error
- func (m *ModuleToDistributeCoinsRequest) XXX_DiscardUnknown()
- func (m *ModuleToDistributeCoinsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ModuleToDistributeCoinsRequest) XXX_Merge(src proto.Message)
- func (m *ModuleToDistributeCoinsRequest) XXX_Size() int
- func (m *ModuleToDistributeCoinsRequest) XXX_Unmarshal(b []byte) error
- type ModuleToDistributeCoinsResponse
- func (*ModuleToDistributeCoinsResponse) Descriptor() ([]byte, []int)
- func (m *ModuleToDistributeCoinsResponse) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins
- func (m *ModuleToDistributeCoinsResponse) Marshal() (dAtA []byte, err error)
- func (m *ModuleToDistributeCoinsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ModuleToDistributeCoinsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ModuleToDistributeCoinsResponse) ProtoMessage()
- func (m *ModuleToDistributeCoinsResponse) Reset()
- func (m *ModuleToDistributeCoinsResponse) Size() (n int)
- func (m *ModuleToDistributeCoinsResponse) String() string
- func (m *ModuleToDistributeCoinsResponse) Unmarshal(dAtA []byte) error
- func (m *ModuleToDistributeCoinsResponse) XXX_DiscardUnknown()
- func (m *ModuleToDistributeCoinsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ModuleToDistributeCoinsResponse) XXX_Merge(src proto.Message)
- func (m *ModuleToDistributeCoinsResponse) XXX_Size() int
- func (m *ModuleToDistributeCoinsResponse) XXX_Unmarshal(b []byte) error
- type MsgAddToPot
- func (*MsgAddToPot) Descriptor() ([]byte, []int)
- func (m *MsgAddToPot) GetOwner() string
- func (m *MsgAddToPot) GetPotId() uint64
- func (m *MsgAddToPot) GetRewards() github_com_cosmos_cosmos_sdk_types.Coins
- func (m MsgAddToPot) GetSignBytes() []byte
- func (m MsgAddToPot) GetSigners() []sdk.AccAddress
- func (m *MsgAddToPot) Marshal() (dAtA []byte, err error)
- func (m *MsgAddToPot) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgAddToPot) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgAddToPot) ProtoMessage()
- func (m *MsgAddToPot) Reset()
- func (m MsgAddToPot) Route() string
- func (m *MsgAddToPot) Size() (n int)
- func (m *MsgAddToPot) String() string
- func (m MsgAddToPot) Type() string
- func (m *MsgAddToPot) Unmarshal(dAtA []byte) error
- func (m MsgAddToPot) ValidateBasic() error
- func (m *MsgAddToPot) XXX_DiscardUnknown()
- func (m *MsgAddToPot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgAddToPot) XXX_Merge(src proto.Message)
- func (m *MsgAddToPot) XXX_Size() int
- func (m *MsgAddToPot) XXX_Unmarshal(b []byte) error
- type MsgAddToPotResponse
- func (*MsgAddToPotResponse) Descriptor() ([]byte, []int)
- func (m *MsgAddToPotResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgAddToPotResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgAddToPotResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgAddToPotResponse) ProtoMessage()
- func (m *MsgAddToPotResponse) Reset()
- func (m *MsgAddToPotResponse) Size() (n int)
- func (m *MsgAddToPotResponse) String() string
- func (m *MsgAddToPotResponse) Unmarshal(dAtA []byte) error
- func (m *MsgAddToPotResponse) XXX_DiscardUnknown()
- func (m *MsgAddToPotResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgAddToPotResponse) XXX_Merge(src proto.Message)
- func (m *MsgAddToPotResponse) XXX_Size() int
- func (m *MsgAddToPotResponse) XXX_Unmarshal(b []byte) error
- type MsgClient
- type MsgCreatePot
- func (*MsgCreatePot) Descriptor() ([]byte, []int)
- func (m *MsgCreatePot) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins
- func (m *MsgCreatePot) GetDistributeTo() types.QueryCondition
- func (m *MsgCreatePot) GetIsPerpetual() bool
- func (m *MsgCreatePot) GetNumEpochsPaidOver() uint64
- func (m *MsgCreatePot) GetOwner() string
- func (m MsgCreatePot) GetSignBytes() []byte
- func (m MsgCreatePot) GetSigners() []sdk.AccAddress
- func (m *MsgCreatePot) GetStartTime() time.Time
- func (m *MsgCreatePot) Marshal() (dAtA []byte, err error)
- func (m *MsgCreatePot) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgCreatePot) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgCreatePot) ProtoMessage()
- func (m *MsgCreatePot) Reset()
- func (m MsgCreatePot) Route() string
- func (m *MsgCreatePot) Size() (n int)
- func (m *MsgCreatePot) String() string
- func (m MsgCreatePot) Type() string
- func (m *MsgCreatePot) Unmarshal(dAtA []byte) error
- func (m MsgCreatePot) ValidateBasic() error
- func (m *MsgCreatePot) XXX_DiscardUnknown()
- func (m *MsgCreatePot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgCreatePot) XXX_Merge(src proto.Message)
- func (m *MsgCreatePot) XXX_Size() int
- func (m *MsgCreatePot) XXX_Unmarshal(b []byte) error
- type MsgCreatePotResponse
- func (*MsgCreatePotResponse) Descriptor() ([]byte, []int)
- func (m *MsgCreatePotResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgCreatePotResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgCreatePotResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgCreatePotResponse) ProtoMessage()
- func (m *MsgCreatePotResponse) Reset()
- func (m *MsgCreatePotResponse) Size() (n int)
- func (m *MsgCreatePotResponse) String() string
- func (m *MsgCreatePotResponse) Unmarshal(dAtA []byte) error
- func (m *MsgCreatePotResponse) XXX_DiscardUnknown()
- func (m *MsgCreatePotResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgCreatePotResponse) XXX_Merge(src proto.Message)
- func (m *MsgCreatePotResponse) XXX_Size() int
- func (m *MsgCreatePotResponse) XXX_Unmarshal(b []byte) error
- type MsgServer
- type MultiIncentiveHooks
- func (h MultiIncentiveHooks) AfterAddToPot(ctx sdk.Context, potId uint64)
- func (h MultiIncentiveHooks) AfterCreatePot(ctx sdk.Context, potId uint64)
- func (h MultiIncentiveHooks) AfterDistribute(ctx sdk.Context, potId uint64)
- func (h MultiIncentiveHooks) AfterFinishDistribution(ctx sdk.Context, potId uint64)
- func (h MultiIncentiveHooks) AfterStartDistribution(ctx sdk.Context, potId uint64)
- type Params
- func (*Params) Descriptor() ([]byte, []int)
- func (m *Params) GetDistrEpochIdentifier() string
- func (m *Params) Marshal() (dAtA []byte, err error)
- func (m *Params) MarshalTo(dAtA []byte) (int, error)
- func (m *Params) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs
- func (*Params) ProtoMessage()
- func (m *Params) Reset()
- func (m *Params) Size() (n int)
- func (m *Params) String() string
- func (m *Params) Unmarshal(dAtA []byte) error
- func (p Params) Validate() error
- func (m *Params) XXX_DiscardUnknown()
- func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Params) XXX_Merge(src proto.Message)
- func (m *Params) XXX_Size() int
- func (m *Params) XXX_Unmarshal(b []byte) error
- type Pot
- func (*Pot) Descriptor() ([]byte, []int)
- func (m *Pot) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins
- func (m *Pot) GetDistributeTo() types.QueryCondition
- func (m *Pot) GetDistributedCoins() github_com_cosmos_cosmos_sdk_types.Coins
- func (m *Pot) GetFilledEpochs() uint64
- func (m *Pot) GetId() uint64
- func (m *Pot) GetIsPerpetual() bool
- func (m *Pot) GetNumEpochsPaidOver() uint64
- func (m *Pot) GetStartTime() time.Time
- func (pot Pot) IsActivePot(curTime time.Time) bool
- func (pot Pot) IsFinishedPot(curTime time.Time) bool
- func (pot Pot) IsUpcomingPot(curTime time.Time) bool
- func (m *Pot) Marshal() (dAtA []byte, err error)
- func (m *Pot) MarshalTo(dAtA []byte) (int, error)
- func (m *Pot) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Pot) ProtoMessage()
- func (m *Pot) Reset()
- func (m *Pot) Size() (n int)
- func (m *Pot) String() string
- func (m *Pot) Unmarshal(dAtA []byte) error
- func (m *Pot) XXX_DiscardUnknown()
- func (m *Pot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Pot) XXX_Merge(src proto.Message)
- func (m *Pot) XXX_Size() int
- func (m *Pot) XXX_Unmarshal(b []byte) error
- type PotByIDRequest
- func (*PotByIDRequest) Descriptor() ([]byte, []int)
- func (m *PotByIDRequest) GetId() uint64
- func (m *PotByIDRequest) Marshal() (dAtA []byte, err error)
- func (m *PotByIDRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *PotByIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PotByIDRequest) ProtoMessage()
- func (m *PotByIDRequest) Reset()
- func (m *PotByIDRequest) Size() (n int)
- func (m *PotByIDRequest) String() string
- func (m *PotByIDRequest) Unmarshal(dAtA []byte) error
- func (m *PotByIDRequest) XXX_DiscardUnknown()
- func (m *PotByIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PotByIDRequest) XXX_Merge(src proto.Message)
- func (m *PotByIDRequest) XXX_Size() int
- func (m *PotByIDRequest) XXX_Unmarshal(b []byte) error
- type PotByIDResponse
- func (*PotByIDResponse) Descriptor() ([]byte, []int)
- func (m *PotByIDResponse) GetPot() *Pot
- func (m *PotByIDResponse) Marshal() (dAtA []byte, err error)
- func (m *PotByIDResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *PotByIDResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PotByIDResponse) ProtoMessage()
- func (m *PotByIDResponse) Reset()
- func (m *PotByIDResponse) Size() (n int)
- func (m *PotByIDResponse) String() string
- func (m *PotByIDResponse) Unmarshal(dAtA []byte) error
- func (m *PotByIDResponse) XXX_DiscardUnknown()
- func (m *PotByIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PotByIDResponse) XXX_Merge(src proto.Message)
- func (m *PotByIDResponse) XXX_Size() int
- func (m *PotByIDResponse) XXX_Unmarshal(b []byte) error
- type PotsRequest
- func (*PotsRequest) Descriptor() ([]byte, []int)
- func (m *PotsRequest) GetPagination() *query.PageRequest
- func (m *PotsRequest) Marshal() (dAtA []byte, err error)
- func (m *PotsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *PotsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PotsRequest) ProtoMessage()
- func (m *PotsRequest) Reset()
- func (m *PotsRequest) Size() (n int)
- func (m *PotsRequest) String() string
- func (m *PotsRequest) Unmarshal(dAtA []byte) error
- func (m *PotsRequest) XXX_DiscardUnknown()
- func (m *PotsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PotsRequest) XXX_Merge(src proto.Message)
- func (m *PotsRequest) XXX_Size() int
- func (m *PotsRequest) XXX_Unmarshal(b []byte) error
- type PotsResponse
- func (*PotsResponse) Descriptor() ([]byte, []int)
- func (m *PotsResponse) GetData() []Pot
- func (m *PotsResponse) GetPagination() *query.PageResponse
- func (m *PotsResponse) Marshal() (dAtA []byte, err error)
- func (m *PotsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *PotsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PotsResponse) ProtoMessage()
- func (m *PotsResponse) Reset()
- func (m *PotsResponse) Size() (n int)
- func (m *PotsResponse) String() string
- func (m *PotsResponse) Unmarshal(dAtA []byte) error
- func (m *PotsResponse) XXX_DiscardUnknown()
- func (m *PotsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PotsResponse) XXX_Merge(src proto.Message)
- func (m *PotsResponse) XXX_Size() int
- func (m *PotsResponse) XXX_Unmarshal(b []byte) error
- type QueryClient
- type QueryServer
- type RewardsEstRequest
- func (*RewardsEstRequest) Descriptor() ([]byte, []int)
- func (m *RewardsEstRequest) GetEndEpoch() int64
- func (m *RewardsEstRequest) GetLocks() []types1.PeriodLock
- func (m *RewardsEstRequest) GetOwner() string
- func (m *RewardsEstRequest) GetPots() []Pot
- func (m *RewardsEstRequest) Marshal() (dAtA []byte, err error)
- func (m *RewardsEstRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *RewardsEstRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RewardsEstRequest) ProtoMessage()
- func (m *RewardsEstRequest) Reset()
- func (m *RewardsEstRequest) Size() (n int)
- func (m *RewardsEstRequest) String() string
- func (m *RewardsEstRequest) Unmarshal(dAtA []byte) error
- func (m *RewardsEstRequest) XXX_DiscardUnknown()
- func (m *RewardsEstRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RewardsEstRequest) XXX_Merge(src proto.Message)
- func (m *RewardsEstRequest) XXX_Size() int
- func (m *RewardsEstRequest) XXX_Unmarshal(b []byte) error
- type RewardsEstResponse
- func (*RewardsEstResponse) Descriptor() ([]byte, []int)
- func (m *RewardsEstResponse) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins
- func (m *RewardsEstResponse) Marshal() (dAtA []byte, err error)
- func (m *RewardsEstResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *RewardsEstResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RewardsEstResponse) ProtoMessage()
- func (m *RewardsEstResponse) Reset()
- func (m *RewardsEstResponse) Size() (n int)
- func (m *RewardsEstResponse) String() string
- func (m *RewardsEstResponse) Unmarshal(dAtA []byte) error
- func (m *RewardsEstResponse) XXX_DiscardUnknown()
- func (m *RewardsEstResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RewardsEstResponse) XXX_Merge(src proto.Message)
- func (m *RewardsEstResponse) XXX_Size() int
- func (m *RewardsEstResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedMsgServer
- type UnimplementedQueryServer
- func (*UnimplementedQueryServer) ActivePots(ctx context.Context, req *ActivePotsRequest) (*ActivePotsResponse, error)
- func (*UnimplementedQueryServer) ModuleDistributedCoins(ctx context.Context, req *ModuleDistributedCoinsRequest) (*ModuleDistributedCoinsResponse, error)
- func (*UnimplementedQueryServer) ModuleToDistributeCoins(ctx context.Context, req *ModuleToDistributeCoinsRequest) (*ModuleToDistributeCoinsResponse, error)
- func (*UnimplementedQueryServer) PotByID(ctx context.Context, req *PotByIDRequest) (*PotByIDResponse, error)
- func (*UnimplementedQueryServer) Pots(ctx context.Context, req *PotsRequest) (*PotsResponse, error)
- func (*UnimplementedQueryServer) RewardsEst(ctx context.Context, req *RewardsEstRequest) (*RewardsEstResponse, error)
- func (*UnimplementedQueryServer) UpcomingPots(ctx context.Context, req *UpcomingPotsRequest) (*UpcomingPotsResponse, error)
- type UpcomingPotsRequest
- func (*UpcomingPotsRequest) Descriptor() ([]byte, []int)
- func (m *UpcomingPotsRequest) GetPagination() *query.PageRequest
- func (m *UpcomingPotsRequest) Marshal() (dAtA []byte, err error)
- func (m *UpcomingPotsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *UpcomingPotsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpcomingPotsRequest) ProtoMessage()
- func (m *UpcomingPotsRequest) Reset()
- func (m *UpcomingPotsRequest) Size() (n int)
- func (m *UpcomingPotsRequest) String() string
- func (m *UpcomingPotsRequest) Unmarshal(dAtA []byte) error
- func (m *UpcomingPotsRequest) XXX_DiscardUnknown()
- func (m *UpcomingPotsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpcomingPotsRequest) XXX_Merge(src proto.Message)
- func (m *UpcomingPotsRequest) XXX_Size() int
- func (m *UpcomingPotsRequest) XXX_Unmarshal(b []byte) error
- type UpcomingPotsResponse
- func (*UpcomingPotsResponse) Descriptor() ([]byte, []int)
- func (m *UpcomingPotsResponse) GetData() []Pot
- func (m *UpcomingPotsResponse) GetPagination() *query.PageResponse
- func (m *UpcomingPotsResponse) Marshal() (dAtA []byte, err error)
- func (m *UpcomingPotsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *UpcomingPotsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpcomingPotsResponse) ProtoMessage()
- func (m *UpcomingPotsResponse) Reset()
- func (m *UpcomingPotsResponse) Size() (n int)
- func (m *UpcomingPotsResponse) String() string
- func (m *UpcomingPotsResponse) Unmarshal(dAtA []byte) error
- func (m *UpcomingPotsResponse) XXX_DiscardUnknown()
- func (m *UpcomingPotsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpcomingPotsResponse) XXX_Merge(src proto.Message)
- func (m *UpcomingPotsResponse) XXX_Size() int
- func (m *UpcomingPotsResponse) XXX_Unmarshal(b []byte) error
Constants ¶
const ( TypeEvtCreatePot = "create_pot" TypeEvtAddToPot = "add_to_pot" AttributePotID = "pot_id" )
event types
const ( TypeMsgCreatePot = "create_pot" TypeMsgAddToPot = "add_to_pot" )
constants
const DefaultIndex uint64 = 1
DefaultIndex is the default capability global index
Variables ¶
var ( ErrInvalidLengthGenesis = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowGenesis = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group") )
var ( // ModuleName defines the module name ModuleName = "incentives" // StoreKey defines the primary module store key StoreKey = ModuleName // RouterKey is the message route for slashing RouterKey = ModuleName // QuerierRoute defines the module's query routing key QuerierRoute = ModuleName // MemStoreKey defines the in-memory store key MemStoreKey = "mem_capability" // KeyPrefixTimestamp defines prefix key for timestamp iterator key KeyPrefixTimestamp = []byte{0x01} // KeyLastPotID defines key for setting last pot ID KeyLastPotID = []byte{0x02} // KeyPrefixPeriodPot defines prefix key for storing pots KeyPrefixPeriodPot = []byte{0x03} // KeyPrefixPots defines prefix key for storing reference key for all pots KeyPrefixPots = []byte{0x04} // KeyPrefixUpcomingPots defines prefix key for storing reference key for upcoming pots KeyPrefixUpcomingPots = []byte{0x04, 0x00} // KeyPrefixActivePots defines prefix key for storing reference key for active pots KeyPrefixActivePots = []byte{0x04, 0x01} // KeyPrefixFinishedPots defines prefix key for storing reference key for finished pots KeyPrefixFinishedPots = []byte{0x04, 0x02} // KeyIndexSeparator defines key for merging bytes KeyIndexSeparator = []byte{0x07} // KeyCurrentEpoch defines key for storing current epoch KeyCurrentEpoch = []byte{0x08} // KeyEpochBeginBlock defines key for storing begin block of current epoch KeyEpochBeginBlock = []byte{0x09} )
var ( ErrInvalidLengthParams = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowParams = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthPot = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPot = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupPot = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthTx = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTx = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group") )
var (
KeyDistrEpochIdentifier = []byte("DistrEpochIdentifier")
)
Parameter store keys
var (
ModuleCdc = codec.NewAminoCodec(amino)
)
Functions ¶
func RegisterCodec ¶
func RegisterCodec(cdc *codec.LegacyAmino)
func RegisterInterfaces ¶
func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
func RegisterMsgServer ¶
func RegisterQueryServer ¶
func RegisterQueryServer(s grpc1.Server, srv QueryServer)
Types ¶
type ActivePotsRequest ¶
type ActivePotsRequest struct { // pagination defines an pagination for the request. Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*ActivePotsRequest) Descriptor ¶
func (*ActivePotsRequest) Descriptor() ([]byte, []int)
func (*ActivePotsRequest) GetPagination ¶
func (m *ActivePotsRequest) GetPagination() *query.PageRequest
func (*ActivePotsRequest) Marshal ¶
func (m *ActivePotsRequest) Marshal() (dAtA []byte, err error)
func (*ActivePotsRequest) MarshalTo ¶
func (m *ActivePotsRequest) MarshalTo(dAtA []byte) (int, error)
func (*ActivePotsRequest) MarshalToSizedBuffer ¶
func (m *ActivePotsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ActivePotsRequest) ProtoMessage ¶
func (*ActivePotsRequest) ProtoMessage()
func (*ActivePotsRequest) Reset ¶
func (m *ActivePotsRequest) Reset()
func (*ActivePotsRequest) Size ¶
func (m *ActivePotsRequest) Size() (n int)
func (*ActivePotsRequest) String ¶
func (m *ActivePotsRequest) String() string
func (*ActivePotsRequest) Unmarshal ¶
func (m *ActivePotsRequest) Unmarshal(dAtA []byte) error
func (*ActivePotsRequest) XXX_DiscardUnknown ¶
func (m *ActivePotsRequest) XXX_DiscardUnknown()
func (*ActivePotsRequest) XXX_Marshal ¶
func (m *ActivePotsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ActivePotsRequest) XXX_Merge ¶
func (m *ActivePotsRequest) XXX_Merge(src proto.Message)
func (*ActivePotsRequest) XXX_Size ¶
func (m *ActivePotsRequest) XXX_Size() int
func (*ActivePotsRequest) XXX_Unmarshal ¶
func (m *ActivePotsRequest) XXX_Unmarshal(b []byte) error
type ActivePotsResponse ¶
type ActivePotsResponse struct { Data []Pot `protobuf:"bytes,1,rep,name=data,proto3" json:"data"` // pagination defines an pagination for the response. Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*ActivePotsResponse) Descriptor ¶
func (*ActivePotsResponse) Descriptor() ([]byte, []int)
func (*ActivePotsResponse) GetData ¶
func (m *ActivePotsResponse) GetData() []Pot
func (*ActivePotsResponse) GetPagination ¶
func (m *ActivePotsResponse) GetPagination() *query.PageResponse
func (*ActivePotsResponse) Marshal ¶
func (m *ActivePotsResponse) Marshal() (dAtA []byte, err error)
func (*ActivePotsResponse) MarshalTo ¶
func (m *ActivePotsResponse) MarshalTo(dAtA []byte) (int, error)
func (*ActivePotsResponse) MarshalToSizedBuffer ¶
func (m *ActivePotsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ActivePotsResponse) ProtoMessage ¶
func (*ActivePotsResponse) ProtoMessage()
func (*ActivePotsResponse) Reset ¶
func (m *ActivePotsResponse) Reset()
func (*ActivePotsResponse) Size ¶
func (m *ActivePotsResponse) Size() (n int)
func (*ActivePotsResponse) String ¶
func (m *ActivePotsResponse) String() string
func (*ActivePotsResponse) Unmarshal ¶
func (m *ActivePotsResponse) Unmarshal(dAtA []byte) error
func (*ActivePotsResponse) XXX_DiscardUnknown ¶
func (m *ActivePotsResponse) XXX_DiscardUnknown()
func (*ActivePotsResponse) XXX_Marshal ¶
func (m *ActivePotsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ActivePotsResponse) XXX_Merge ¶
func (m *ActivePotsResponse) XXX_Merge(src proto.Message)
func (*ActivePotsResponse) XXX_Size ¶
func (m *ActivePotsResponse) XXX_Size() int
func (*ActivePotsResponse) XXX_Unmarshal ¶
func (m *ActivePotsResponse) XXX_Unmarshal(b []byte) error
type BankKeeper ¶
type BankKeeper interface { GetAllBalances(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error }
BankKeeper defines the expected interface needed to retrieve account balances.
type EpochKeeper ¶
type EpochKeeper interface {
GetEpochInfo(ctx sdk.Context, identifier string) epochstypes.EpochInfo
}
type GenesisState ¶
type GenesisState struct { // params defines all the parameters of the module Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"` Pots []Pot `protobuf:"bytes,2,rep,name=pots,proto3" json:"pots"` }
GenesisState defines the incentives module's genesis state.
func DefaultGenesis ¶
func DefaultGenesis() *GenesisState
DefaultGenesis returns the default Capability genesis state
func (*GenesisState) Descriptor ¶
func (*GenesisState) Descriptor() ([]byte, []int)
func (*GenesisState) GetParams ¶
func (m *GenesisState) GetParams() Params
func (*GenesisState) GetPots ¶
func (m *GenesisState) GetPots() []Pot
func (*GenesisState) Marshal ¶
func (m *GenesisState) Marshal() (dAtA []byte, err error)
func (*GenesisState) MarshalToSizedBuffer ¶
func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GenesisState) ProtoMessage ¶
func (*GenesisState) ProtoMessage()
func (*GenesisState) Reset ¶
func (m *GenesisState) Reset()
func (*GenesisState) Size ¶
func (m *GenesisState) Size() (n int)
func (*GenesisState) String ¶
func (m *GenesisState) String() string
func (*GenesisState) Unmarshal ¶
func (m *GenesisState) Unmarshal(dAtA []byte) error
func (GenesisState) Validate ¶
func (gs GenesisState) Validate() error
Validate performs basic genesis state validation returning an error upon any failure.
func (*GenesisState) XXX_DiscardUnknown ¶
func (m *GenesisState) XXX_DiscardUnknown()
func (*GenesisState) XXX_Marshal ¶
func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GenesisState) XXX_Merge ¶
func (m *GenesisState) XXX_Merge(src proto.Message)
func (*GenesisState) XXX_Size ¶
func (m *GenesisState) XXX_Size() int
func (*GenesisState) XXX_Unmarshal ¶
func (m *GenesisState) XXX_Unmarshal(b []byte) error
type IncentiveHooks ¶
type LockupKeeper ¶
type LockupKeeper interface { GetLocksPastTimeDenom(ctx sdk.Context, denom string, timestamp time.Time) []lockuptypes.PeriodLock GetLocksLongerThanDurationDenom(ctx sdk.Context, denom string, duration time.Duration) []lockuptypes.PeriodLock }
LockupKeeper defines the expected interface needed to retrieve locks
type ModuleDistributedCoinsRequest ¶
type ModuleDistributedCoinsRequest struct { }
func (*ModuleDistributedCoinsRequest) Descriptor ¶
func (*ModuleDistributedCoinsRequest) Descriptor() ([]byte, []int)
func (*ModuleDistributedCoinsRequest) Marshal ¶
func (m *ModuleDistributedCoinsRequest) Marshal() (dAtA []byte, err error)
func (*ModuleDistributedCoinsRequest) MarshalTo ¶
func (m *ModuleDistributedCoinsRequest) MarshalTo(dAtA []byte) (int, error)
func (*ModuleDistributedCoinsRequest) MarshalToSizedBuffer ¶
func (m *ModuleDistributedCoinsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ModuleDistributedCoinsRequest) ProtoMessage ¶
func (*ModuleDistributedCoinsRequest) ProtoMessage()
func (*ModuleDistributedCoinsRequest) Reset ¶
func (m *ModuleDistributedCoinsRequest) Reset()
func (*ModuleDistributedCoinsRequest) Size ¶
func (m *ModuleDistributedCoinsRequest) Size() (n int)
func (*ModuleDistributedCoinsRequest) String ¶
func (m *ModuleDistributedCoinsRequest) String() string
func (*ModuleDistributedCoinsRequest) Unmarshal ¶
func (m *ModuleDistributedCoinsRequest) Unmarshal(dAtA []byte) error
func (*ModuleDistributedCoinsRequest) XXX_DiscardUnknown ¶
func (m *ModuleDistributedCoinsRequest) XXX_DiscardUnknown()
func (*ModuleDistributedCoinsRequest) XXX_Marshal ¶
func (m *ModuleDistributedCoinsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ModuleDistributedCoinsRequest) XXX_Merge ¶
func (m *ModuleDistributedCoinsRequest) XXX_Merge(src proto.Message)
func (*ModuleDistributedCoinsRequest) XXX_Size ¶
func (m *ModuleDistributedCoinsRequest) XXX_Size() int
func (*ModuleDistributedCoinsRequest) XXX_Unmarshal ¶
func (m *ModuleDistributedCoinsRequest) XXX_Unmarshal(b []byte) error
type ModuleDistributedCoinsResponse ¶
type ModuleDistributedCoinsResponse struct {
Coins github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,1,rep,name=coins,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"coins"`
}
func (*ModuleDistributedCoinsResponse) Descriptor ¶
func (*ModuleDistributedCoinsResponse) Descriptor() ([]byte, []int)
func (*ModuleDistributedCoinsResponse) GetCoins ¶
func (m *ModuleDistributedCoinsResponse) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins
func (*ModuleDistributedCoinsResponse) Marshal ¶
func (m *ModuleDistributedCoinsResponse) Marshal() (dAtA []byte, err error)
func (*ModuleDistributedCoinsResponse) MarshalTo ¶
func (m *ModuleDistributedCoinsResponse) MarshalTo(dAtA []byte) (int, error)
func (*ModuleDistributedCoinsResponse) MarshalToSizedBuffer ¶
func (m *ModuleDistributedCoinsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ModuleDistributedCoinsResponse) ProtoMessage ¶
func (*ModuleDistributedCoinsResponse) ProtoMessage()
func (*ModuleDistributedCoinsResponse) Reset ¶
func (m *ModuleDistributedCoinsResponse) Reset()
func (*ModuleDistributedCoinsResponse) Size ¶
func (m *ModuleDistributedCoinsResponse) Size() (n int)
func (*ModuleDistributedCoinsResponse) String ¶
func (m *ModuleDistributedCoinsResponse) String() string
func (*ModuleDistributedCoinsResponse) Unmarshal ¶
func (m *ModuleDistributedCoinsResponse) Unmarshal(dAtA []byte) error
func (*ModuleDistributedCoinsResponse) XXX_DiscardUnknown ¶
func (m *ModuleDistributedCoinsResponse) XXX_DiscardUnknown()
func (*ModuleDistributedCoinsResponse) XXX_Marshal ¶
func (m *ModuleDistributedCoinsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ModuleDistributedCoinsResponse) XXX_Merge ¶
func (m *ModuleDistributedCoinsResponse) XXX_Merge(src proto.Message)
func (*ModuleDistributedCoinsResponse) XXX_Size ¶
func (m *ModuleDistributedCoinsResponse) XXX_Size() int
func (*ModuleDistributedCoinsResponse) XXX_Unmarshal ¶
func (m *ModuleDistributedCoinsResponse) XXX_Unmarshal(b []byte) error
type ModuleToDistributeCoinsRequest ¶
type ModuleToDistributeCoinsRequest struct { }
func (*ModuleToDistributeCoinsRequest) Descriptor ¶
func (*ModuleToDistributeCoinsRequest) Descriptor() ([]byte, []int)
func (*ModuleToDistributeCoinsRequest) Marshal ¶
func (m *ModuleToDistributeCoinsRequest) Marshal() (dAtA []byte, err error)
func (*ModuleToDistributeCoinsRequest) MarshalTo ¶
func (m *ModuleToDistributeCoinsRequest) MarshalTo(dAtA []byte) (int, error)
func (*ModuleToDistributeCoinsRequest) MarshalToSizedBuffer ¶
func (m *ModuleToDistributeCoinsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ModuleToDistributeCoinsRequest) ProtoMessage ¶
func (*ModuleToDistributeCoinsRequest) ProtoMessage()
func (*ModuleToDistributeCoinsRequest) Reset ¶
func (m *ModuleToDistributeCoinsRequest) Reset()
func (*ModuleToDistributeCoinsRequest) Size ¶
func (m *ModuleToDistributeCoinsRequest) Size() (n int)
func (*ModuleToDistributeCoinsRequest) String ¶
func (m *ModuleToDistributeCoinsRequest) String() string
func (*ModuleToDistributeCoinsRequest) Unmarshal ¶
func (m *ModuleToDistributeCoinsRequest) Unmarshal(dAtA []byte) error
func (*ModuleToDistributeCoinsRequest) XXX_DiscardUnknown ¶
func (m *ModuleToDistributeCoinsRequest) XXX_DiscardUnknown()
func (*ModuleToDistributeCoinsRequest) XXX_Marshal ¶
func (m *ModuleToDistributeCoinsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ModuleToDistributeCoinsRequest) XXX_Merge ¶
func (m *ModuleToDistributeCoinsRequest) XXX_Merge(src proto.Message)
func (*ModuleToDistributeCoinsRequest) XXX_Size ¶
func (m *ModuleToDistributeCoinsRequest) XXX_Size() int
func (*ModuleToDistributeCoinsRequest) XXX_Unmarshal ¶
func (m *ModuleToDistributeCoinsRequest) XXX_Unmarshal(b []byte) error
type ModuleToDistributeCoinsResponse ¶
type ModuleToDistributeCoinsResponse struct {
Coins github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,1,rep,name=coins,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"coins"`
}
func (*ModuleToDistributeCoinsResponse) Descriptor ¶
func (*ModuleToDistributeCoinsResponse) Descriptor() ([]byte, []int)
func (*ModuleToDistributeCoinsResponse) GetCoins ¶
func (m *ModuleToDistributeCoinsResponse) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins
func (*ModuleToDistributeCoinsResponse) Marshal ¶
func (m *ModuleToDistributeCoinsResponse) Marshal() (dAtA []byte, err error)
func (*ModuleToDistributeCoinsResponse) MarshalTo ¶
func (m *ModuleToDistributeCoinsResponse) MarshalTo(dAtA []byte) (int, error)
func (*ModuleToDistributeCoinsResponse) MarshalToSizedBuffer ¶
func (m *ModuleToDistributeCoinsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ModuleToDistributeCoinsResponse) ProtoMessage ¶
func (*ModuleToDistributeCoinsResponse) ProtoMessage()
func (*ModuleToDistributeCoinsResponse) Reset ¶
func (m *ModuleToDistributeCoinsResponse) Reset()
func (*ModuleToDistributeCoinsResponse) Size ¶
func (m *ModuleToDistributeCoinsResponse) Size() (n int)
func (*ModuleToDistributeCoinsResponse) String ¶
func (m *ModuleToDistributeCoinsResponse) String() string
func (*ModuleToDistributeCoinsResponse) Unmarshal ¶
func (m *ModuleToDistributeCoinsResponse) Unmarshal(dAtA []byte) error
func (*ModuleToDistributeCoinsResponse) XXX_DiscardUnknown ¶
func (m *ModuleToDistributeCoinsResponse) XXX_DiscardUnknown()
func (*ModuleToDistributeCoinsResponse) XXX_Marshal ¶
func (m *ModuleToDistributeCoinsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ModuleToDistributeCoinsResponse) XXX_Merge ¶
func (m *ModuleToDistributeCoinsResponse) XXX_Merge(src proto.Message)
func (*ModuleToDistributeCoinsResponse) XXX_Size ¶
func (m *ModuleToDistributeCoinsResponse) XXX_Size() int
func (*ModuleToDistributeCoinsResponse) XXX_Unmarshal ¶
func (m *ModuleToDistributeCoinsResponse) XXX_Unmarshal(b []byte) error
type MsgAddToPot ¶
type MsgAddToPot struct { Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty" yaml:"owner"` PotId uint64 `protobuf:"varint,2,opt,name=pot_id,json=potId,proto3" json:"pot_id,omitempty"` Rewards github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,3,rep,name=rewards,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"rewards"` }
func NewMsgAddToPot ¶
func NewMsgAddToPot(owner sdk.AccAddress, potId uint64, rewards sdk.Coins) *MsgAddToPot
NewMsgCreatePot creates a message to create a pot
func (*MsgAddToPot) Descriptor ¶
func (*MsgAddToPot) Descriptor() ([]byte, []int)
func (*MsgAddToPot) GetOwner ¶
func (m *MsgAddToPot) GetOwner() string
func (*MsgAddToPot) GetPotId ¶
func (m *MsgAddToPot) GetPotId() uint64
func (*MsgAddToPot) GetRewards ¶
func (m *MsgAddToPot) GetRewards() github_com_cosmos_cosmos_sdk_types.Coins
func (MsgAddToPot) GetSignBytes ¶
func (m MsgAddToPot) GetSignBytes() []byte
func (MsgAddToPot) GetSigners ¶
func (m MsgAddToPot) GetSigners() []sdk.AccAddress
func (*MsgAddToPot) Marshal ¶
func (m *MsgAddToPot) Marshal() (dAtA []byte, err error)
func (*MsgAddToPot) MarshalToSizedBuffer ¶
func (m *MsgAddToPot) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgAddToPot) ProtoMessage ¶
func (*MsgAddToPot) ProtoMessage()
func (*MsgAddToPot) Reset ¶
func (m *MsgAddToPot) Reset()
func (MsgAddToPot) Route ¶
func (m MsgAddToPot) Route() string
func (*MsgAddToPot) Size ¶
func (m *MsgAddToPot) Size() (n int)
func (*MsgAddToPot) String ¶
func (m *MsgAddToPot) String() string
func (MsgAddToPot) Type ¶
func (m MsgAddToPot) Type() string
func (*MsgAddToPot) Unmarshal ¶
func (m *MsgAddToPot) Unmarshal(dAtA []byte) error
func (MsgAddToPot) ValidateBasic ¶
func (m MsgAddToPot) ValidateBasic() error
func (*MsgAddToPot) XXX_DiscardUnknown ¶
func (m *MsgAddToPot) XXX_DiscardUnknown()
func (*MsgAddToPot) XXX_Marshal ¶
func (m *MsgAddToPot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgAddToPot) XXX_Merge ¶
func (m *MsgAddToPot) XXX_Merge(src proto.Message)
func (*MsgAddToPot) XXX_Size ¶
func (m *MsgAddToPot) XXX_Size() int
func (*MsgAddToPot) XXX_Unmarshal ¶
func (m *MsgAddToPot) XXX_Unmarshal(b []byte) error
type MsgAddToPotResponse ¶
type MsgAddToPotResponse struct { }
func (*MsgAddToPotResponse) Descriptor ¶
func (*MsgAddToPotResponse) Descriptor() ([]byte, []int)
func (*MsgAddToPotResponse) Marshal ¶
func (m *MsgAddToPotResponse) Marshal() (dAtA []byte, err error)
func (*MsgAddToPotResponse) MarshalTo ¶
func (m *MsgAddToPotResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgAddToPotResponse) MarshalToSizedBuffer ¶
func (m *MsgAddToPotResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgAddToPotResponse) ProtoMessage ¶
func (*MsgAddToPotResponse) ProtoMessage()
func (*MsgAddToPotResponse) Reset ¶
func (m *MsgAddToPotResponse) Reset()
func (*MsgAddToPotResponse) Size ¶
func (m *MsgAddToPotResponse) Size() (n int)
func (*MsgAddToPotResponse) String ¶
func (m *MsgAddToPotResponse) String() string
func (*MsgAddToPotResponse) Unmarshal ¶
func (m *MsgAddToPotResponse) Unmarshal(dAtA []byte) error
func (*MsgAddToPotResponse) XXX_DiscardUnknown ¶
func (m *MsgAddToPotResponse) XXX_DiscardUnknown()
func (*MsgAddToPotResponse) XXX_Marshal ¶
func (m *MsgAddToPotResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgAddToPotResponse) XXX_Merge ¶
func (m *MsgAddToPotResponse) XXX_Merge(src proto.Message)
func (*MsgAddToPotResponse) XXX_Size ¶
func (m *MsgAddToPotResponse) XXX_Size() int
func (*MsgAddToPotResponse) XXX_Unmarshal ¶
func (m *MsgAddToPotResponse) XXX_Unmarshal(b []byte) error
type MsgClient ¶
type MsgClient interface { CreatePot(ctx context.Context, in *MsgCreatePot, opts ...grpc.CallOption) (*MsgCreatePotResponse, error) AddToPot(ctx context.Context, in *MsgAddToPot, opts ...grpc.CallOption) (*MsgAddToPotResponse, 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 MsgCreatePot ¶
type MsgCreatePot struct { IsPerpetual bool `protobuf:"varint,1,opt,name=is_perpetual,json=isPerpetual,proto3" json:"is_perpetual,omitempty"` // distribution incentives by third party Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty" yaml:"owner"` DistributeTo types.QueryCondition `protobuf:"bytes,3,opt,name=distribute_to,json=distributeTo,proto3" json:"distribute_to"` Coins github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,4,rep,name=coins,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"coins"` // distribution start time StartTime time.Time `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time" yaml:"timestamp"` NumEpochsPaidOver uint64 `protobuf:"varint,6,opt,name=num_epochs_paid_over,json=numEpochsPaidOver,proto3" json:"num_epochs_paid_over,omitempty"` }
func NewMsgCreatePot ¶
func NewMsgCreatePot(isPerpetual bool, owner sdk.AccAddress, distributeTo lockuptypes.QueryCondition, coins sdk.Coins, startTime time.Time, numEpochsPaidOver uint64) *MsgCreatePot
NewMsgCreatePot creates a message to create a pot
func (*MsgCreatePot) Descriptor ¶
func (*MsgCreatePot) Descriptor() ([]byte, []int)
func (*MsgCreatePot) GetCoins ¶
func (m *MsgCreatePot) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins
func (*MsgCreatePot) GetDistributeTo ¶
func (m *MsgCreatePot) GetDistributeTo() types.QueryCondition
func (*MsgCreatePot) GetIsPerpetual ¶
func (m *MsgCreatePot) GetIsPerpetual() bool
func (*MsgCreatePot) GetNumEpochsPaidOver ¶
func (m *MsgCreatePot) GetNumEpochsPaidOver() uint64
func (*MsgCreatePot) GetOwner ¶
func (m *MsgCreatePot) GetOwner() string
func (MsgCreatePot) GetSignBytes ¶
func (m MsgCreatePot) GetSignBytes() []byte
func (MsgCreatePot) GetSigners ¶
func (m MsgCreatePot) GetSigners() []sdk.AccAddress
func (*MsgCreatePot) GetStartTime ¶
func (m *MsgCreatePot) GetStartTime() time.Time
func (*MsgCreatePot) Marshal ¶
func (m *MsgCreatePot) Marshal() (dAtA []byte, err error)
func (*MsgCreatePot) MarshalToSizedBuffer ¶
func (m *MsgCreatePot) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCreatePot) ProtoMessage ¶
func (*MsgCreatePot) ProtoMessage()
func (*MsgCreatePot) Reset ¶
func (m *MsgCreatePot) Reset()
func (MsgCreatePot) Route ¶
func (m MsgCreatePot) Route() string
func (*MsgCreatePot) Size ¶
func (m *MsgCreatePot) Size() (n int)
func (*MsgCreatePot) String ¶
func (m *MsgCreatePot) String() string
func (MsgCreatePot) Type ¶
func (m MsgCreatePot) Type() string
func (*MsgCreatePot) Unmarshal ¶
func (m *MsgCreatePot) Unmarshal(dAtA []byte) error
func (MsgCreatePot) ValidateBasic ¶
func (m MsgCreatePot) ValidateBasic() error
func (*MsgCreatePot) XXX_DiscardUnknown ¶
func (m *MsgCreatePot) XXX_DiscardUnknown()
func (*MsgCreatePot) XXX_Marshal ¶
func (m *MsgCreatePot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCreatePot) XXX_Merge ¶
func (m *MsgCreatePot) XXX_Merge(src proto.Message)
func (*MsgCreatePot) XXX_Size ¶
func (m *MsgCreatePot) XXX_Size() int
func (*MsgCreatePot) XXX_Unmarshal ¶
func (m *MsgCreatePot) XXX_Unmarshal(b []byte) error
type MsgCreatePotResponse ¶
type MsgCreatePotResponse struct { }
func (*MsgCreatePotResponse) Descriptor ¶
func (*MsgCreatePotResponse) Descriptor() ([]byte, []int)
func (*MsgCreatePotResponse) Marshal ¶
func (m *MsgCreatePotResponse) Marshal() (dAtA []byte, err error)
func (*MsgCreatePotResponse) MarshalTo ¶
func (m *MsgCreatePotResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgCreatePotResponse) MarshalToSizedBuffer ¶
func (m *MsgCreatePotResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCreatePotResponse) ProtoMessage ¶
func (*MsgCreatePotResponse) ProtoMessage()
func (*MsgCreatePotResponse) Reset ¶
func (m *MsgCreatePotResponse) Reset()
func (*MsgCreatePotResponse) Size ¶
func (m *MsgCreatePotResponse) Size() (n int)
func (*MsgCreatePotResponse) String ¶
func (m *MsgCreatePotResponse) String() string
func (*MsgCreatePotResponse) Unmarshal ¶
func (m *MsgCreatePotResponse) Unmarshal(dAtA []byte) error
func (*MsgCreatePotResponse) XXX_DiscardUnknown ¶
func (m *MsgCreatePotResponse) XXX_DiscardUnknown()
func (*MsgCreatePotResponse) XXX_Marshal ¶
func (m *MsgCreatePotResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCreatePotResponse) XXX_Merge ¶
func (m *MsgCreatePotResponse) XXX_Merge(src proto.Message)
func (*MsgCreatePotResponse) XXX_Size ¶
func (m *MsgCreatePotResponse) XXX_Size() int
func (*MsgCreatePotResponse) XXX_Unmarshal ¶
func (m *MsgCreatePotResponse) XXX_Unmarshal(b []byte) error
type MsgServer ¶
type MsgServer interface { CreatePot(context.Context, *MsgCreatePot) (*MsgCreatePotResponse, error) AddToPot(context.Context, *MsgAddToPot) (*MsgAddToPotResponse, error) }
MsgServer is the server API for Msg service.
type MultiIncentiveHooks ¶
type MultiIncentiveHooks []IncentiveHooks
combine multiple incentive hooks, all hook functions are run in array sequence
func NewMultiIncentiveHooks ¶
func NewMultiIncentiveHooks(hooks ...IncentiveHooks) MultiIncentiveHooks
func (MultiIncentiveHooks) AfterAddToPot ¶
func (h MultiIncentiveHooks) AfterAddToPot(ctx sdk.Context, potId uint64)
func (MultiIncentiveHooks) AfterCreatePot ¶
func (h MultiIncentiveHooks) AfterCreatePot(ctx sdk.Context, potId uint64)
func (MultiIncentiveHooks) AfterDistribute ¶
func (h MultiIncentiveHooks) AfterDistribute(ctx sdk.Context, potId uint64)
func (MultiIncentiveHooks) AfterFinishDistribution ¶
func (h MultiIncentiveHooks) AfterFinishDistribution(ctx sdk.Context, potId uint64)
func (MultiIncentiveHooks) AfterStartDistribution ¶
func (h MultiIncentiveHooks) AfterStartDistribution(ctx sdk.Context, potId uint64)
type Params ¶
type Params struct { // distribution epoch identifier DistrEpochIdentifier string `` /* 153-byte string literal not displayed */ }
Params holds parameters for the incentives module
func (*Params) Descriptor ¶
func (*Params) GetDistrEpochIdentifier ¶
func (*Params) MarshalToSizedBuffer ¶
func (*Params) ParamSetPairs ¶
func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs
Implements params.ParamSet
func (*Params) ProtoMessage ¶
func (*Params) ProtoMessage()
func (*Params) XXX_DiscardUnknown ¶
func (m *Params) XXX_DiscardUnknown()
func (*Params) XXX_Marshal ¶
func (*Params) XXX_Unmarshal ¶
type Pot ¶
type Pot struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` IsPerpetual bool `protobuf:"varint,2,opt,name=is_perpetual,json=isPerpetual,proto3" json:"is_perpetual,omitempty"` // distribution incentives by third party // Rewards are distributed to lockups that are are returned by at least one of // these queries DistributeTo types.QueryCondition `protobuf:"bytes,3,opt,name=distribute_to,json=distributeTo,proto3" json:"distribute_to"` Coins github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,4,rep,name=coins,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"coins"` // distribution start time StartTime time.Time `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time" yaml:"start_time"` NumEpochsPaidOver uint64 `protobuf:"varint,6,opt,name=num_epochs_paid_over,json=numEpochsPaidOver,proto3" json:"num_epochs_paid_over,omitempty"` FilledEpochs uint64 `protobuf:"varint,7,opt,name=filled_epochs,json=filledEpochs,proto3" json:"filled_epochs,omitempty"` DistributedCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 153-byte string literal not displayed */ }
func (*Pot) Descriptor ¶
func (*Pot) GetCoins ¶
func (m *Pot) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins
func (*Pot) GetDistributeTo ¶
func (m *Pot) GetDistributeTo() types.QueryCondition
func (*Pot) GetDistributedCoins ¶
func (m *Pot) GetDistributedCoins() github_com_cosmos_cosmos_sdk_types.Coins
func (*Pot) GetFilledEpochs ¶
func (*Pot) GetIsPerpetual ¶
func (*Pot) GetNumEpochsPaidOver ¶
func (*Pot) GetStartTime ¶
func (*Pot) ProtoMessage ¶
func (*Pot) ProtoMessage()
func (*Pot) XXX_DiscardUnknown ¶
func (m *Pot) XXX_DiscardUnknown()
func (*Pot) XXX_Unmarshal ¶
type PotByIDRequest ¶
type PotByIDRequest struct {
Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (*PotByIDRequest) Descriptor ¶
func (*PotByIDRequest) Descriptor() ([]byte, []int)
func (*PotByIDRequest) GetId ¶
func (m *PotByIDRequest) GetId() uint64
func (*PotByIDRequest) Marshal ¶
func (m *PotByIDRequest) Marshal() (dAtA []byte, err error)
func (*PotByIDRequest) MarshalToSizedBuffer ¶
func (m *PotByIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PotByIDRequest) ProtoMessage ¶
func (*PotByIDRequest) ProtoMessage()
func (*PotByIDRequest) Reset ¶
func (m *PotByIDRequest) Reset()
func (*PotByIDRequest) Size ¶
func (m *PotByIDRequest) Size() (n int)
func (*PotByIDRequest) String ¶
func (m *PotByIDRequest) String() string
func (*PotByIDRequest) Unmarshal ¶
func (m *PotByIDRequest) Unmarshal(dAtA []byte) error
func (*PotByIDRequest) XXX_DiscardUnknown ¶
func (m *PotByIDRequest) XXX_DiscardUnknown()
func (*PotByIDRequest) XXX_Marshal ¶
func (m *PotByIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PotByIDRequest) XXX_Merge ¶
func (m *PotByIDRequest) XXX_Merge(src proto.Message)
func (*PotByIDRequest) XXX_Size ¶
func (m *PotByIDRequest) XXX_Size() int
func (*PotByIDRequest) XXX_Unmarshal ¶
func (m *PotByIDRequest) XXX_Unmarshal(b []byte) error
type PotByIDResponse ¶
type PotByIDResponse struct {
Pot *Pot `protobuf:"bytes,1,opt,name=pot,proto3" json:"pot,omitempty"`
}
func (*PotByIDResponse) Descriptor ¶
func (*PotByIDResponse) Descriptor() ([]byte, []int)
func (*PotByIDResponse) GetPot ¶
func (m *PotByIDResponse) GetPot() *Pot
func (*PotByIDResponse) Marshal ¶
func (m *PotByIDResponse) Marshal() (dAtA []byte, err error)
func (*PotByIDResponse) MarshalToSizedBuffer ¶
func (m *PotByIDResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PotByIDResponse) ProtoMessage ¶
func (*PotByIDResponse) ProtoMessage()
func (*PotByIDResponse) Reset ¶
func (m *PotByIDResponse) Reset()
func (*PotByIDResponse) Size ¶
func (m *PotByIDResponse) Size() (n int)
func (*PotByIDResponse) String ¶
func (m *PotByIDResponse) String() string
func (*PotByIDResponse) Unmarshal ¶
func (m *PotByIDResponse) Unmarshal(dAtA []byte) error
func (*PotByIDResponse) XXX_DiscardUnknown ¶
func (m *PotByIDResponse) XXX_DiscardUnknown()
func (*PotByIDResponse) XXX_Marshal ¶
func (m *PotByIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PotByIDResponse) XXX_Merge ¶
func (m *PotByIDResponse) XXX_Merge(src proto.Message)
func (*PotByIDResponse) XXX_Size ¶
func (m *PotByIDResponse) XXX_Size() int
func (*PotByIDResponse) XXX_Unmarshal ¶
func (m *PotByIDResponse) XXX_Unmarshal(b []byte) error
type PotsRequest ¶
type PotsRequest struct { // pagination defines an pagination for the request. Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*PotsRequest) Descriptor ¶
func (*PotsRequest) Descriptor() ([]byte, []int)
func (*PotsRequest) GetPagination ¶
func (m *PotsRequest) GetPagination() *query.PageRequest
func (*PotsRequest) Marshal ¶
func (m *PotsRequest) Marshal() (dAtA []byte, err error)
func (*PotsRequest) MarshalToSizedBuffer ¶
func (m *PotsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PotsRequest) ProtoMessage ¶
func (*PotsRequest) ProtoMessage()
func (*PotsRequest) Reset ¶
func (m *PotsRequest) Reset()
func (*PotsRequest) Size ¶
func (m *PotsRequest) Size() (n int)
func (*PotsRequest) String ¶
func (m *PotsRequest) String() string
func (*PotsRequest) Unmarshal ¶
func (m *PotsRequest) Unmarshal(dAtA []byte) error
func (*PotsRequest) XXX_DiscardUnknown ¶
func (m *PotsRequest) XXX_DiscardUnknown()
func (*PotsRequest) XXX_Marshal ¶
func (m *PotsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PotsRequest) XXX_Merge ¶
func (m *PotsRequest) XXX_Merge(src proto.Message)
func (*PotsRequest) XXX_Size ¶
func (m *PotsRequest) XXX_Size() int
func (*PotsRequest) XXX_Unmarshal ¶
func (m *PotsRequest) XXX_Unmarshal(b []byte) error
type PotsResponse ¶
type PotsResponse struct { Data []Pot `protobuf:"bytes,1,rep,name=data,proto3" json:"data"` // pagination defines an pagination for the response. Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*PotsResponse) Descriptor ¶
func (*PotsResponse) Descriptor() ([]byte, []int)
func (*PotsResponse) GetData ¶
func (m *PotsResponse) GetData() []Pot
func (*PotsResponse) GetPagination ¶
func (m *PotsResponse) GetPagination() *query.PageResponse
func (*PotsResponse) Marshal ¶
func (m *PotsResponse) Marshal() (dAtA []byte, err error)
func (*PotsResponse) MarshalToSizedBuffer ¶
func (m *PotsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PotsResponse) ProtoMessage ¶
func (*PotsResponse) ProtoMessage()
func (*PotsResponse) Reset ¶
func (m *PotsResponse) Reset()
func (*PotsResponse) Size ¶
func (m *PotsResponse) Size() (n int)
func (*PotsResponse) String ¶
func (m *PotsResponse) String() string
func (*PotsResponse) Unmarshal ¶
func (m *PotsResponse) Unmarshal(dAtA []byte) error
func (*PotsResponse) XXX_DiscardUnknown ¶
func (m *PotsResponse) XXX_DiscardUnknown()
func (*PotsResponse) XXX_Marshal ¶
func (m *PotsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PotsResponse) XXX_Merge ¶
func (m *PotsResponse) XXX_Merge(src proto.Message)
func (*PotsResponse) XXX_Size ¶
func (m *PotsResponse) XXX_Size() int
func (*PotsResponse) XXX_Unmarshal ¶
func (m *PotsResponse) XXX_Unmarshal(b []byte) error
type QueryClient ¶
type QueryClient interface { // returns coins that is going to be distributed ModuleToDistributeCoins(ctx context.Context, in *ModuleToDistributeCoinsRequest, opts ...grpc.CallOption) (*ModuleToDistributeCoinsResponse, error) // returns coins that are distributed by module so far ModuleDistributedCoins(ctx context.Context, in *ModuleDistributedCoinsRequest, opts ...grpc.CallOption) (*ModuleDistributedCoinsResponse, error) // returns Pot by id PotByID(ctx context.Context, in *PotByIDRequest, opts ...grpc.CallOption) (*PotByIDResponse, error) // returns pots both upcoming and active Pots(ctx context.Context, in *PotsRequest, opts ...grpc.CallOption) (*PotsResponse, error) // returns active pots ActivePots(ctx context.Context, in *ActivePotsRequest, opts ...grpc.CallOption) (*ActivePotsResponse, error) // returns scheduled pots UpcomingPots(ctx context.Context, in *UpcomingPotsRequest, opts ...grpc.CallOption) (*UpcomingPotsResponse, error) // returns rewards estimation at a future specific time RewardsEst(ctx context.Context, in *RewardsEstRequest, opts ...grpc.CallOption) (*RewardsEstResponse, 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 QueryServer ¶
type QueryServer interface { // returns coins that is going to be distributed ModuleToDistributeCoins(context.Context, *ModuleToDistributeCoinsRequest) (*ModuleToDistributeCoinsResponse, error) // returns coins that are distributed by module so far ModuleDistributedCoins(context.Context, *ModuleDistributedCoinsRequest) (*ModuleDistributedCoinsResponse, error) // returns Pot by id PotByID(context.Context, *PotByIDRequest) (*PotByIDResponse, error) // returns pots both upcoming and active Pots(context.Context, *PotsRequest) (*PotsResponse, error) // returns active pots ActivePots(context.Context, *ActivePotsRequest) (*ActivePotsResponse, error) // returns scheduled pots UpcomingPots(context.Context, *UpcomingPotsRequest) (*UpcomingPotsResponse, error) // returns rewards estimation at a future specific time RewardsEst(context.Context, *RewardsEstRequest) (*RewardsEstResponse, error) }
QueryServer is the server API for Query service.
type RewardsEstRequest ¶
type RewardsEstRequest struct { Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty" yaml:"owner"` Locks []types1.PeriodLock `protobuf:"bytes,2,rep,name=locks,proto3" json:"locks"` Pots []Pot `protobuf:"bytes,3,rep,name=pots,proto3" json:"pots"` EndEpoch int64 `protobuf:"varint,4,opt,name=end_epoch,json=endEpoch,proto3" json:"end_epoch,omitempty"` }
func (*RewardsEstRequest) Descriptor ¶
func (*RewardsEstRequest) Descriptor() ([]byte, []int)
func (*RewardsEstRequest) GetEndEpoch ¶
func (m *RewardsEstRequest) GetEndEpoch() int64
func (*RewardsEstRequest) GetLocks ¶
func (m *RewardsEstRequest) GetLocks() []types1.PeriodLock
func (*RewardsEstRequest) GetOwner ¶
func (m *RewardsEstRequest) GetOwner() string
func (*RewardsEstRequest) GetPots ¶
func (m *RewardsEstRequest) GetPots() []Pot
func (*RewardsEstRequest) Marshal ¶
func (m *RewardsEstRequest) Marshal() (dAtA []byte, err error)
func (*RewardsEstRequest) MarshalTo ¶
func (m *RewardsEstRequest) MarshalTo(dAtA []byte) (int, error)
func (*RewardsEstRequest) MarshalToSizedBuffer ¶
func (m *RewardsEstRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RewardsEstRequest) ProtoMessage ¶
func (*RewardsEstRequest) ProtoMessage()
func (*RewardsEstRequest) Reset ¶
func (m *RewardsEstRequest) Reset()
func (*RewardsEstRequest) Size ¶
func (m *RewardsEstRequest) Size() (n int)
func (*RewardsEstRequest) String ¶
func (m *RewardsEstRequest) String() string
func (*RewardsEstRequest) Unmarshal ¶
func (m *RewardsEstRequest) Unmarshal(dAtA []byte) error
func (*RewardsEstRequest) XXX_DiscardUnknown ¶
func (m *RewardsEstRequest) XXX_DiscardUnknown()
func (*RewardsEstRequest) XXX_Marshal ¶
func (m *RewardsEstRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RewardsEstRequest) XXX_Merge ¶
func (m *RewardsEstRequest) XXX_Merge(src proto.Message)
func (*RewardsEstRequest) XXX_Size ¶
func (m *RewardsEstRequest) XXX_Size() int
func (*RewardsEstRequest) XXX_Unmarshal ¶
func (m *RewardsEstRequest) XXX_Unmarshal(b []byte) error
type RewardsEstResponse ¶
type RewardsEstResponse struct {
Coins github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,1,rep,name=coins,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"coins"`
}
func (*RewardsEstResponse) Descriptor ¶
func (*RewardsEstResponse) Descriptor() ([]byte, []int)
func (*RewardsEstResponse) GetCoins ¶
func (m *RewardsEstResponse) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins
func (*RewardsEstResponse) Marshal ¶
func (m *RewardsEstResponse) Marshal() (dAtA []byte, err error)
func (*RewardsEstResponse) MarshalTo ¶
func (m *RewardsEstResponse) MarshalTo(dAtA []byte) (int, error)
func (*RewardsEstResponse) MarshalToSizedBuffer ¶
func (m *RewardsEstResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RewardsEstResponse) ProtoMessage ¶
func (*RewardsEstResponse) ProtoMessage()
func (*RewardsEstResponse) Reset ¶
func (m *RewardsEstResponse) Reset()
func (*RewardsEstResponse) Size ¶
func (m *RewardsEstResponse) Size() (n int)
func (*RewardsEstResponse) String ¶
func (m *RewardsEstResponse) String() string
func (*RewardsEstResponse) Unmarshal ¶
func (m *RewardsEstResponse) Unmarshal(dAtA []byte) error
func (*RewardsEstResponse) XXX_DiscardUnknown ¶
func (m *RewardsEstResponse) XXX_DiscardUnknown()
func (*RewardsEstResponse) XXX_Marshal ¶
func (m *RewardsEstResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RewardsEstResponse) XXX_Merge ¶
func (m *RewardsEstResponse) XXX_Merge(src proto.Message)
func (*RewardsEstResponse) XXX_Size ¶
func (m *RewardsEstResponse) XXX_Size() int
func (*RewardsEstResponse) XXX_Unmarshal ¶
func (m *RewardsEstResponse) XXX_Unmarshal(b []byte) error
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct { }
UnimplementedMsgServer can be embedded to have forward compatible implementations.
func (*UnimplementedMsgServer) AddToPot ¶
func (*UnimplementedMsgServer) AddToPot(ctx context.Context, req *MsgAddToPot) (*MsgAddToPotResponse, error)
func (*UnimplementedMsgServer) CreatePot ¶
func (*UnimplementedMsgServer) CreatePot(ctx context.Context, req *MsgCreatePot) (*MsgCreatePotResponse, error)
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct { }
UnimplementedQueryServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryServer) ActivePots ¶
func (*UnimplementedQueryServer) ActivePots(ctx context.Context, req *ActivePotsRequest) (*ActivePotsResponse, error)
func (*UnimplementedQueryServer) ModuleDistributedCoins ¶
func (*UnimplementedQueryServer) ModuleDistributedCoins(ctx context.Context, req *ModuleDistributedCoinsRequest) (*ModuleDistributedCoinsResponse, error)
func (*UnimplementedQueryServer) ModuleToDistributeCoins ¶
func (*UnimplementedQueryServer) ModuleToDistributeCoins(ctx context.Context, req *ModuleToDistributeCoinsRequest) (*ModuleToDistributeCoinsResponse, error)
func (*UnimplementedQueryServer) PotByID ¶
func (*UnimplementedQueryServer) PotByID(ctx context.Context, req *PotByIDRequest) (*PotByIDResponse, error)
func (*UnimplementedQueryServer) Pots ¶
func (*UnimplementedQueryServer) Pots(ctx context.Context, req *PotsRequest) (*PotsResponse, error)
func (*UnimplementedQueryServer) RewardsEst ¶
func (*UnimplementedQueryServer) RewardsEst(ctx context.Context, req *RewardsEstRequest) (*RewardsEstResponse, error)
func (*UnimplementedQueryServer) UpcomingPots ¶
func (*UnimplementedQueryServer) UpcomingPots(ctx context.Context, req *UpcomingPotsRequest) (*UpcomingPotsResponse, error)
type UpcomingPotsRequest ¶
type UpcomingPotsRequest struct { // pagination defines an pagination for the request. Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*UpcomingPotsRequest) Descriptor ¶
func (*UpcomingPotsRequest) Descriptor() ([]byte, []int)
func (*UpcomingPotsRequest) GetPagination ¶
func (m *UpcomingPotsRequest) GetPagination() *query.PageRequest
func (*UpcomingPotsRequest) Marshal ¶
func (m *UpcomingPotsRequest) Marshal() (dAtA []byte, err error)
func (*UpcomingPotsRequest) MarshalTo ¶
func (m *UpcomingPotsRequest) MarshalTo(dAtA []byte) (int, error)
func (*UpcomingPotsRequest) MarshalToSizedBuffer ¶
func (m *UpcomingPotsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UpcomingPotsRequest) ProtoMessage ¶
func (*UpcomingPotsRequest) ProtoMessage()
func (*UpcomingPotsRequest) Reset ¶
func (m *UpcomingPotsRequest) Reset()
func (*UpcomingPotsRequest) Size ¶
func (m *UpcomingPotsRequest) Size() (n int)
func (*UpcomingPotsRequest) String ¶
func (m *UpcomingPotsRequest) String() string
func (*UpcomingPotsRequest) Unmarshal ¶
func (m *UpcomingPotsRequest) Unmarshal(dAtA []byte) error
func (*UpcomingPotsRequest) XXX_DiscardUnknown ¶
func (m *UpcomingPotsRequest) XXX_DiscardUnknown()
func (*UpcomingPotsRequest) XXX_Marshal ¶
func (m *UpcomingPotsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpcomingPotsRequest) XXX_Merge ¶
func (m *UpcomingPotsRequest) XXX_Merge(src proto.Message)
func (*UpcomingPotsRequest) XXX_Size ¶
func (m *UpcomingPotsRequest) XXX_Size() int
func (*UpcomingPotsRequest) XXX_Unmarshal ¶
func (m *UpcomingPotsRequest) XXX_Unmarshal(b []byte) error
type UpcomingPotsResponse ¶
type UpcomingPotsResponse struct { Data []Pot `protobuf:"bytes,1,rep,name=data,proto3" json:"data"` // pagination defines an pagination for the response. Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*UpcomingPotsResponse) Descriptor ¶
func (*UpcomingPotsResponse) Descriptor() ([]byte, []int)
func (*UpcomingPotsResponse) GetData ¶
func (m *UpcomingPotsResponse) GetData() []Pot
func (*UpcomingPotsResponse) GetPagination ¶
func (m *UpcomingPotsResponse) GetPagination() *query.PageResponse
func (*UpcomingPotsResponse) Marshal ¶
func (m *UpcomingPotsResponse) Marshal() (dAtA []byte, err error)
func (*UpcomingPotsResponse) MarshalTo ¶
func (m *UpcomingPotsResponse) MarshalTo(dAtA []byte) (int, error)
func (*UpcomingPotsResponse) MarshalToSizedBuffer ¶
func (m *UpcomingPotsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UpcomingPotsResponse) ProtoMessage ¶
func (*UpcomingPotsResponse) ProtoMessage()
func (*UpcomingPotsResponse) Reset ¶
func (m *UpcomingPotsResponse) Reset()
func (*UpcomingPotsResponse) Size ¶
func (m *UpcomingPotsResponse) Size() (n int)
func (*UpcomingPotsResponse) String ¶
func (m *UpcomingPotsResponse) String() string
func (*UpcomingPotsResponse) Unmarshal ¶
func (m *UpcomingPotsResponse) Unmarshal(dAtA []byte) error
func (*UpcomingPotsResponse) XXX_DiscardUnknown ¶
func (m *UpcomingPotsResponse) XXX_DiscardUnknown()
func (*UpcomingPotsResponse) XXX_Marshal ¶
func (m *UpcomingPotsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpcomingPotsResponse) XXX_Merge ¶
func (m *UpcomingPotsResponse) XXX_Merge(src proto.Message)
func (*UpcomingPotsResponse) XXX_Size ¶
func (m *UpcomingPotsResponse) XXX_Size() int
func (*UpcomingPotsResponse) XXX_Unmarshal ¶
func (m *UpcomingPotsResponse) XXX_Unmarshal(b []byte) error