types

package
v0.0.0-...-7868e01 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	TypeEvtCreatePot = "create_pot"
	TypeEvtAddToPot  = "add_to_pot"

	AttributePotID = "pot_id"
)

event types

View Source 
const (
	TypeMsgCreatePot = "create_pot"
	TypeMsgAddToPot  = "add_to_pot"
)

constants

View Source 
const DefaultIndex uint64 = 1

DefaultIndex is the default capability global index

Variables

View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// ModuleName defines the module name
	ModuleName = "incentives"

	// StoreKey defines the primary module store key
	StoreKey = ModuleName

	// RouterKey is the message route for slashing
	RouterKey = ModuleName

	// QuerierRoute defines the module's query routing key
	QuerierRoute = ModuleName

	// MemStoreKey defines the in-memory store key
	MemStoreKey = "mem_capability"

	// KeyPrefixTimestamp defines prefix key for timestamp iterator key
	KeyPrefixTimestamp = []byte{0x01}

	// 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}
)
View Source 
var (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPot        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPot          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPot = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	KeyDistrEpochIdentifier = []byte("DistrEpochIdentifier")
)

Parameter store keys

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

Functions

func KeyPrefix 

func KeyPrefix(p string) []byte

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamTable for minting module.

func RegisterCodec 

func RegisterCodec(cdc *codec.LegacyAmino)

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

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

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (GenesisState) Validate 

func (gs GenesisState) Validate() error

Validate performs basic genesis state validation returning an error upon any failure.

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type IncentiveHooks 

type IncentiveHooks interface {
	AfterCreatePot(ctx sdk.Context, potId uint64)
	AfterAddToPot(ctx sdk.Context, potId uint64)
	AfterStartDistribution(ctx sdk.Context, potId uint64)
	AfterFinishDistribution(ctx sdk.Context, potId uint64)
	AfterDistribute(ctx sdk.Context, potId uint64)
}

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

func (m *MsgAddToPot) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *MsgCreatePot) MarshalTo(dAtA []byte) (int, 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 DefaultParams 

func DefaultParams() Params

default minting module parameters

func NewParams 

func NewParams(distrEpochIdentifier string) Params

func (*Params) Descriptor 

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

func (*Params) GetDistrEpochIdentifier 

func (m *Params) GetDistrEpochIdentifier() string

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs

Implements params.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 (m *Params) String() string

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

validate params

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

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

func (*Pot) Descriptor 

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

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 (m *Pot) GetFilledEpochs() uint64

func (*Pot) GetId 

func (m *Pot) GetId() uint64

func (*Pot) GetIsPerpetual 

func (m *Pot) GetIsPerpetual() bool

func (*Pot) GetNumEpochsPaidOver 

func (m *Pot) GetNumEpochsPaidOver() uint64

func (*Pot) GetStartTime 

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

func (Pot) IsActivePot 

func (pot Pot) IsActivePot(curTime time.Time) bool

func (Pot) IsFinishedPot 

func (pot Pot) IsFinishedPot(curTime time.Time) bool

func (Pot) IsUpcomingPot 

func (pot Pot) IsUpcomingPot(curTime time.Time) bool

func (*Pot) Marshal 

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

func (*Pot) MarshalTo 

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

func (*Pot) MarshalToSizedBuffer 

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

func (*Pot) ProtoMessage 

func (*Pot) ProtoMessage()

func (*Pot) Reset 

func (m *Pot) Reset()

func (*Pot) Size 

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

func (*Pot) String 

func (m *Pot) String() string

func (*Pot) Unmarshal 

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

func (*Pot) XXX_DiscardUnknown 

func (m *Pot) XXX_DiscardUnknown()

func (*Pot) XXX_Marshal 

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

func (*Pot) XXX_Merge 

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

func (*Pot) XXX_Size 

func (m *Pot) XXX_Size() int

func (*Pot) XXX_Unmarshal 

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

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

func (m *PotByIDRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *PotByIDResponse) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *PotsRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *PotsResponse) MarshalTo(dAtA []byte) (int, 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

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.