types

package
v14.0.0-rc1 Latest Latest
Warning

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

 Go to latest Published: Jan 10, 2023 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	ProposalTypeUpdatePoolIncentives  = "UpdatePoolIncentives"
	ProposalTypeReplacePoolIncentives = "ReplacePoolIncentives"
)
View Source 
const (
	ModuleName = "poolincentives"

	StoreKey = ModuleName

	RouterKey = ModuleName

	QuerierRoute = ModuleName
)

Variables

View Source 
var (
	ErrNoGaugeIdExist                = sdkerrors.Register(ModuleName, 1, "no gauge id exist")
	ErrDistrRecordNotPositiveWeight  = sdkerrors.Register(ModuleName, 2, "weight in record should be positive")
	ErrDistrRecordNotRegisteredGauge = sdkerrors.Register(ModuleName, 3, "gauge was not registered")
	ErrDistrRecordRegisteredGauge    = sdkerrors.Register(ModuleName, 4, "gauge was already registered")
	ErrDistrRecordNotSorted          = sdkerrors.Register(ModuleName, 5, "gauges are not sorted")

	ErrEmptyProposalRecords  = sdkerrors.Register(ModuleName, 10, "records are empty")
	ErrEmptyProposalGaugeIds = sdkerrors.Register(ModuleName, 11, "gauge ids are empty")
)

The following regiisters various pool-incentives errors.

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 (
	ErrInvalidLengthGov        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGov          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGov = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthIncentives        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowIncentives          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupIncentives = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	LockableDurationsKey = []byte("lockable_durations")
	DistrInfoKey         = []byte("distr_info")
)
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 KeyMintedDenom = []byte("MintedDenom")

Functions

func GetPoolGaugeIdStoreKey 

func GetPoolGaugeIdStoreKey(poolId uint64, duration time.Duration) []byte

GetPoolGaugeIdStoreKey returns a StoreKey with pool ID and its duration as inputs

func GetPoolIdFromGaugeIdStoreKey 

func GetPoolIdFromGaugeIdStoreKey(gaugeId uint64, duration time.Duration) []byte

GetPoolIdFromGaugeIdStoreKey returns a StoreKey from the given gaugeID and duration.

func NewReplacePoolIncentivesProposal 

func NewReplacePoolIncentivesProposal(title, description string, records []DistrRecord) govtypes.Content

NewReplacePoolIncentivesProposal returns a new instance of a replace pool incentives proposal struct.

func NewUpdatePoolIncentivesProposal 

func NewUpdatePoolIncentivesProposal(title, description string, records []DistrRecord) govtypes.Content

NewReplacePoolIncentivesProposal returns a new instance of a replace pool incentives proposal struct.

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

func RegisterQueryHandler 

func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQueryHandlerClient 

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.

func RegisterQueryHandlerFromEndpoint 

func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQueryHandlerServer 

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func ValidateGenesis 

func ValidateGenesis(data *GenesisState) error

ValidateGenesis validates the provided pool-yield genesis state to ensure the expected invariants holds. (i.e. params in correct bounds).

Types

type AccountKeeper 

type AccountKeeper interface {
	GetModuleAddress(name string) sdk.AccAddress
	GetModuleAccount(ctx sdk.Context, name string) authtypes.ModuleAccountI
}

AccountKeeper interface contains functions for getting accounts and the module address

type BankKeeper 

type BankKeeper interface {
	GetBalance(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin
}

BankKeeper sends tokens across modules and is able to get account balances.

type DistrInfo 

type DistrInfo struct {
	TotalWeight github_com_cosmos_cosmos_sdk_types.Int `` /* 154-byte string literal not displayed */
	Records     []DistrRecord                          `protobuf:"bytes,2,rep,name=records,proto3" json:"records"`
}

func (*DistrInfo) Descriptor 

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

func (*DistrInfo) GetRecords 

func (m *DistrInfo) GetRecords() []DistrRecord

func (*DistrInfo) Marshal 

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

func (*DistrInfo) MarshalTo 

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

func (*DistrInfo) MarshalToSizedBuffer 

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

func (*DistrInfo) ProtoMessage 

func (*DistrInfo) ProtoMessage()

func (*DistrInfo) Reset 

func (m *DistrInfo) Reset()

func (*DistrInfo) Size 

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

func (*DistrInfo) String 

func (m *DistrInfo) String() string

func (*DistrInfo) Unmarshal 

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

func (*DistrInfo) XXX_DiscardUnknown 

func (m *DistrInfo) XXX_DiscardUnknown()

func (*DistrInfo) XXX_Marshal 

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

func (*DistrInfo) XXX_Merge 

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

func (*DistrInfo) XXX_Size 

func (m *DistrInfo) XXX_Size() int

func (*DistrInfo) XXX_Unmarshal 

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

type DistrKeeper 

type DistrKeeper interface {
	SetFeePool(ctx sdk.Context, feePool distrtypes.FeePool)
	FundCommunityPool(ctx sdk.Context, amount sdk.Coins, sender sdk.AccAddress) error
}

DistrKeeper handles pool-fees functionality - setting / getting fees and funding the community pool.

type DistrRecord 

type DistrRecord struct {
	GaugeId uint64                                 `protobuf:"varint,1,opt,name=gauge_id,json=gaugeId,proto3" json:"gauge_id,omitempty" yaml:"gauge_id"`
	Weight  github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,2,opt,name=weight,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"weight"`
}

func (*DistrRecord) Descriptor 

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

func (*DistrRecord) Equal 

func (this *DistrRecord) Equal(that interface{}) bool

func (*DistrRecord) GetGaugeId 

func (m *DistrRecord) GetGaugeId() uint64

func (*DistrRecord) Marshal 

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

func (*DistrRecord) MarshalTo 

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

func (*DistrRecord) MarshalToSizedBuffer 

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

func (*DistrRecord) ProtoMessage 

func (*DistrRecord) ProtoMessage()

func (*DistrRecord) Reset 

func (m *DistrRecord) Reset()

func (*DistrRecord) Size 

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

func (*DistrRecord) String 

func (m *DistrRecord) String() string

func (*DistrRecord) Unmarshal 

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

func (DistrRecord) ValidateBasic 

func (r DistrRecord) ValidateBasic() error

ValidateBasic is a basic validation test on recordd distribution gauges' weights.

func (*DistrRecord) XXX_DiscardUnknown 

func (m *DistrRecord) XXX_DiscardUnknown()

func (*DistrRecord) XXX_Marshal 

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

func (*DistrRecord) XXX_Merge 

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

func (*DistrRecord) XXX_Size 

func (m *DistrRecord) XXX_Size() int

func (*DistrRecord) XXX_Unmarshal 

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

type GAMMKeeper 

type GAMMKeeper interface {
	GetNextPoolId(ctx sdk.Context) uint64
}

GAMMKeeper gets the pool interface from poolID.

type GenesisState 

type GenesisState struct {
	// params defines all the paramaters of the module.
	Params            Params          `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	LockableDurations []time.Duration `` /* 140-byte string literal not displayed */
	DistrInfo         *DistrInfo      `protobuf:"bytes,3,opt,name=distr_info,json=distrInfo,proto3" json:"distr_info,omitempty" yaml:"distr_info"`
	PoolToGauges      *PoolToGauges   `protobuf:"bytes,4,opt,name=pool_to_gauges,json=poolToGauges,proto3" json:"pool_to_gauges,omitempty" yaml:"pool_to_gauges"`
}

GenesisState defines the pool incentives module's genesis state.

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

DefaultGenesisState gets the raw genesis raw message for testing.

func GetGenesisStateFromAppState 

func GetGenesisStateFromAppState(cdc codec.JSONCodec, appState map[string]json.RawMessage) *GenesisState

GetGenesisStateFromAppState returns x/pool-yield GenesisState given raw application genesis state.

func NewGenesisState 

func NewGenesisState(params Params, lockableDurations []time.Duration, distrInfo *DistrInfo) *GenesisState

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetDistrInfo 

func (m *GenesisState) GetDistrInfo() *DistrInfo

func (*GenesisState) GetLockableDurations 

func (m *GenesisState) GetLockableDurations() []time.Duration

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetPoolToGauges 

func (m *GenesisState) GetPoolToGauges() *PoolToGauges

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type IncentivesKeeper 

type IncentivesKeeper interface {
	CreateGauge(ctx sdk.Context, isPerpetual bool, owner sdk.AccAddress, coins sdk.Coins, distrTo lockuptypes.QueryCondition, startTime time.Time, numEpochsPaidOver uint64) (uint64, error)
	GetGaugeByID(ctx sdk.Context, gaugeID uint64) (*incentivestypes.Gauge, error)
	GetGauges(ctx sdk.Context) []incentivestypes.Gauge

	AddToGaugeRewards(ctx sdk.Context, owner sdk.AccAddress, coins sdk.Coins, gaugeID uint64) error
}

IncentivesKeeper creates and gets gauges, and also allows additions to gauge rewards.

type IncentivizedPool 

type IncentivizedPool struct {
	PoolId           uint64        `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty" yaml:"pool_id"`
	LockableDuration time.Duration `` /* 136-byte string literal not displayed */
	GaugeId          uint64        `protobuf:"varint,3,opt,name=gauge_id,json=gaugeId,proto3" json:"gauge_id,omitempty" yaml:"gauge_id"`
}

func (*IncentivizedPool) Descriptor 

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

func (*IncentivizedPool) GetGaugeId 

func (m *IncentivizedPool) GetGaugeId() uint64

func (*IncentivizedPool) GetLockableDuration 

func (m *IncentivizedPool) GetLockableDuration() time.Duration

func (*IncentivizedPool) GetPoolId 

func (m *IncentivizedPool) GetPoolId() uint64

func (*IncentivizedPool) Marshal 

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

func (*IncentivizedPool) MarshalTo 

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

func (*IncentivizedPool) MarshalToSizedBuffer 

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

func (*IncentivizedPool) ProtoMessage 

func (*IncentivizedPool) ProtoMessage()

func (*IncentivizedPool) Reset 

func (m *IncentivizedPool) Reset()

func (*IncentivizedPool) Size 

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

func (*IncentivizedPool) String 

func (m *IncentivizedPool) String() string

func (*IncentivizedPool) Unmarshal 

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

func (*IncentivizedPool) XXX_DiscardUnknown 

func (m *IncentivizedPool) XXX_DiscardUnknown()

func (*IncentivizedPool) XXX_Marshal 

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

func (*IncentivizedPool) XXX_Merge 

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

func (*IncentivizedPool) XXX_Size 

func (m *IncentivizedPool) XXX_Size() int

func (*IncentivizedPool) XXX_Unmarshal 

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

type LockableDurationsInfo 

type LockableDurationsInfo struct {
	LockableDurations []time.Duration `` /* 140-byte string literal not displayed */
}

func (*LockableDurationsInfo) Descriptor 

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

func (*LockableDurationsInfo) GetLockableDurations 

func (m *LockableDurationsInfo) GetLockableDurations() []time.Duration

func (*LockableDurationsInfo) Marshal 

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

func (*LockableDurationsInfo) MarshalTo 

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

func (*LockableDurationsInfo) MarshalToSizedBuffer 

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

func (*LockableDurationsInfo) ProtoMessage 

func (*LockableDurationsInfo) ProtoMessage()

func (*LockableDurationsInfo) Reset 

func (m *LockableDurationsInfo) Reset()

func (*LockableDurationsInfo) Size 

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

func (*LockableDurationsInfo) String 

func (m *LockableDurationsInfo) String() string

func (*LockableDurationsInfo) Unmarshal 

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

func (*LockableDurationsInfo) XXX_DiscardUnknown 

func (m *LockableDurationsInfo) XXX_DiscardUnknown()

func (*LockableDurationsInfo) XXX_Marshal 

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

func (*LockableDurationsInfo) XXX_Merge 

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

func (*LockableDurationsInfo) XXX_Size 

func (m *LockableDurationsInfo) XXX_Size() int

func (*LockableDurationsInfo) XXX_Unmarshal 

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

type Params 

type Params struct {
	// minted_denom is the denomination of the coin expected to be minted by the
	// minting module. Pool-incentives module doesn’t actually mint the coin
	// itself, but rather manages the distribution of coins that matches the
	// defined minted_denom.
	MintedDenom string `protobuf:"bytes,1,opt,name=minted_denom,json=mintedDenom,proto3" json:"minted_denom,omitempty" yaml:"minted_denom"`
}

func DefaultParams 

func DefaultParams() Params

DefaultParams is the default parameter configuration for the pool-incentives module.

func NewParams 

func NewParams(mintedDenom string) Params

func (*Params) Descriptor 

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

func (*Params) GetMintedDenom 

func (m *Params) GetMintedDenom() 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

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (Params) String 

func (p Params) String() string

String implements the Stringer interface.

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

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 PoolToGauge 

type PoolToGauge struct {
	PoolId   uint64        `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty" yaml:"pool_id"`
	GaugeId  uint64        `protobuf:"varint,2,opt,name=gauge_id,json=gaugeId,proto3" json:"gauge_id,omitempty" yaml:"gauge"`
	Duration time.Duration `protobuf:"bytes,3,opt,name=duration,proto3,stdduration" json:"duration" yaml:"duration"`
}

func (*PoolToGauge) Descriptor 

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

func (*PoolToGauge) GetDuration 

func (m *PoolToGauge) GetDuration() time.Duration

func (*PoolToGauge) GetGaugeId 

func (m *PoolToGauge) GetGaugeId() uint64

func (*PoolToGauge) GetPoolId 

func (m *PoolToGauge) GetPoolId() uint64

func (*PoolToGauge) Marshal 

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

func (*PoolToGauge) MarshalTo 

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

func (*PoolToGauge) MarshalToSizedBuffer 

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

func (*PoolToGauge) ProtoMessage 

func (*PoolToGauge) ProtoMessage()

func (*PoolToGauge) Reset 

func (m *PoolToGauge) Reset()

func (*PoolToGauge) Size 

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

func (*PoolToGauge) String 

func (m *PoolToGauge) String() string

func (*PoolToGauge) Unmarshal 

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

func (*PoolToGauge) XXX_DiscardUnknown 

func (m *PoolToGauge) XXX_DiscardUnknown()

func (*PoolToGauge) XXX_Marshal 

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

func (*PoolToGauge) XXX_Merge 

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

func (*PoolToGauge) XXX_Size 

func (m *PoolToGauge) XXX_Size() int

func (*PoolToGauge) XXX_Unmarshal 

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

type PoolToGauges 

type PoolToGauges struct {
	PoolToGauge []PoolToGauge `protobuf:"bytes,2,rep,name=pool_to_gauge,json=poolToGauge,proto3" json:"pool_to_gauge"`
}

func (*PoolToGauges) Descriptor 

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

func (*PoolToGauges) GetPoolToGauge 

func (m *PoolToGauges) GetPoolToGauge() []PoolToGauge

func (*PoolToGauges) Marshal 

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

func (*PoolToGauges) MarshalTo 

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

func (*PoolToGauges) MarshalToSizedBuffer 

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

func (*PoolToGauges) ProtoMessage 

func (*PoolToGauges) ProtoMessage()

func (*PoolToGauges) Reset 

func (m *PoolToGauges) Reset()

func (*PoolToGauges) Size 

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

func (*PoolToGauges) String 

func (m *PoolToGauges) String() string

func (*PoolToGauges) Unmarshal 

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

func (*PoolToGauges) XXX_DiscardUnknown 

func (m *PoolToGauges) XXX_DiscardUnknown()

func (*PoolToGauges) XXX_Marshal 

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

func (*PoolToGauges) XXX_Merge 

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

func (*PoolToGauges) XXX_Size 

func (m *PoolToGauges) XXX_Size() int

func (*PoolToGauges) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// GaugeIds takes the pool id and returns the matching gauge ids and durations
	GaugeIds(ctx context.Context, in *QueryGaugeIdsRequest, opts ...grpc.CallOption) (*QueryGaugeIdsResponse, error)
	// DistrInfo returns the pool's matching gauge ids and weights.
	DistrInfo(ctx context.Context, in *QueryDistrInfoRequest, opts ...grpc.CallOption) (*QueryDistrInfoResponse, error)
	// Params returns pool incentives params.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// LockableDurations returns lock durations for pools.
	LockableDurations(ctx context.Context, in *QueryLockableDurationsRequest, opts ...grpc.CallOption) (*QueryLockableDurationsResponse, error)
	// IncentivizedPools returns currently incentivized pools
	IncentivizedPools(ctx context.Context, in *QueryIncentivizedPoolsRequest, opts ...grpc.CallOption) (*QueryIncentivizedPoolsResponse, error)
	// ExternalIncentiveGauges returns external incentive gauges.
	ExternalIncentiveGauges(ctx context.Context, in *QueryExternalIncentiveGaugesRequest, opts ...grpc.CallOption) (*QueryExternalIncentiveGaugesResponse, 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 QueryDistrInfoRequest 

type QueryDistrInfoRequest struct {
}

func (*QueryDistrInfoRequest) Descriptor 

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

func (*QueryDistrInfoRequest) Marshal 

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

func (*QueryDistrInfoRequest) MarshalTo 

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

func (*QueryDistrInfoRequest) MarshalToSizedBuffer 

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

func (*QueryDistrInfoRequest) ProtoMessage 

func (*QueryDistrInfoRequest) ProtoMessage()

func (*QueryDistrInfoRequest) Reset 

func (m *QueryDistrInfoRequest) Reset()

func (*QueryDistrInfoRequest) Size 

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

func (*QueryDistrInfoRequest) String 

func (m *QueryDistrInfoRequest) String() string

func (*QueryDistrInfoRequest) Unmarshal 

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

func (*QueryDistrInfoRequest) XXX_DiscardUnknown 

func (m *QueryDistrInfoRequest) XXX_DiscardUnknown()

func (*QueryDistrInfoRequest) XXX_Marshal 

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

func (*QueryDistrInfoRequest) XXX_Merge 

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

func (*QueryDistrInfoRequest) XXX_Size 

func (m *QueryDistrInfoRequest) XXX_Size() int

func (*QueryDistrInfoRequest) XXX_Unmarshal 

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

type QueryDistrInfoResponse 

type QueryDistrInfoResponse struct {
	DistrInfo DistrInfo `protobuf:"bytes,1,opt,name=distr_info,json=distrInfo,proto3" json:"distr_info" yaml:"distr_info"`
}

func (*QueryDistrInfoResponse) Descriptor 

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

func (*QueryDistrInfoResponse) GetDistrInfo 

func (m *QueryDistrInfoResponse) GetDistrInfo() DistrInfo

func (*QueryDistrInfoResponse) Marshal 

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

func (*QueryDistrInfoResponse) MarshalTo 

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

func (*QueryDistrInfoResponse) MarshalToSizedBuffer 

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

func (*QueryDistrInfoResponse) ProtoMessage 

func (*QueryDistrInfoResponse) ProtoMessage()

func (*QueryDistrInfoResponse) Reset 

func (m *QueryDistrInfoResponse) Reset()

func (*QueryDistrInfoResponse) Size 

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

func (*QueryDistrInfoResponse) String 

func (m *QueryDistrInfoResponse) String() string

func (*QueryDistrInfoResponse) Unmarshal 

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

func (*QueryDistrInfoResponse) XXX_DiscardUnknown 

func (m *QueryDistrInfoResponse) XXX_DiscardUnknown()

func (*QueryDistrInfoResponse) XXX_Marshal 

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

func (*QueryDistrInfoResponse) XXX_Merge 

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

func (*QueryDistrInfoResponse) XXX_Size 

func (m *QueryDistrInfoResponse) XXX_Size() int

func (*QueryDistrInfoResponse) XXX_Unmarshal 

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

type QueryExternalIncentiveGaugesRequest 

type QueryExternalIncentiveGaugesRequest struct {
}

func (*QueryExternalIncentiveGaugesRequest) Descriptor 

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

func (*QueryExternalIncentiveGaugesRequest) Marshal 

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

func (*QueryExternalIncentiveGaugesRequest) MarshalTo 

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

func (*QueryExternalIncentiveGaugesRequest) MarshalToSizedBuffer 

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

func (*QueryExternalIncentiveGaugesRequest) ProtoMessage 

func (*QueryExternalIncentiveGaugesRequest) ProtoMessage()

func (*QueryExternalIncentiveGaugesRequest) Reset 

func (m *QueryExternalIncentiveGaugesRequest) Reset()

func (*QueryExternalIncentiveGaugesRequest) Size 

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

func (*QueryExternalIncentiveGaugesRequest) String 

func (m *QueryExternalIncentiveGaugesRequest) String() string

func (*QueryExternalIncentiveGaugesRequest) Unmarshal 

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

func (*QueryExternalIncentiveGaugesRequest) XXX_DiscardUnknown 

func (m *QueryExternalIncentiveGaugesRequest) XXX_DiscardUnknown()

func (*QueryExternalIncentiveGaugesRequest) XXX_Marshal 

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

func (*QueryExternalIncentiveGaugesRequest) XXX_Merge 

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

func (*QueryExternalIncentiveGaugesRequest) XXX_Size 

func (m *QueryExternalIncentiveGaugesRequest) XXX_Size() int

func (*QueryExternalIncentiveGaugesRequest) XXX_Unmarshal 

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

type QueryExternalIncentiveGaugesResponse 

type QueryExternalIncentiveGaugesResponse struct {
	Data []types1.Gauge `protobuf:"bytes,1,rep,name=data,proto3" json:"data"`
}

func (*QueryExternalIncentiveGaugesResponse) Descriptor 

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

func (*QueryExternalIncentiveGaugesResponse) GetData 

func (m *QueryExternalIncentiveGaugesResponse) GetData() []types1.Gauge

func (*QueryExternalIncentiveGaugesResponse) Marshal 

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

func (*QueryExternalIncentiveGaugesResponse) MarshalTo 

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

func (*QueryExternalIncentiveGaugesResponse) MarshalToSizedBuffer 

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

func (*QueryExternalIncentiveGaugesResponse) ProtoMessage 

func (*QueryExternalIncentiveGaugesResponse) ProtoMessage()

func (*QueryExternalIncentiveGaugesResponse) Reset 

func (m *QueryExternalIncentiveGaugesResponse) Reset()

func (*QueryExternalIncentiveGaugesResponse) Size 

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

func (*QueryExternalIncentiveGaugesResponse) String 

func (m *QueryExternalIncentiveGaugesResponse) String() string

func (*QueryExternalIncentiveGaugesResponse) Unmarshal 

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

func (*QueryExternalIncentiveGaugesResponse) XXX_DiscardUnknown 

func (m *QueryExternalIncentiveGaugesResponse) XXX_DiscardUnknown()

func (*QueryExternalIncentiveGaugesResponse) XXX_Marshal 

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

func (*QueryExternalIncentiveGaugesResponse) XXX_Merge 

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

func (*QueryExternalIncentiveGaugesResponse) XXX_Size 

func (m *QueryExternalIncentiveGaugesResponse) XXX_Size() int

func (*QueryExternalIncentiveGaugesResponse) XXX_Unmarshal 

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

type QueryGaugeIdsRequest 

type QueryGaugeIdsRequest struct {
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty" yaml:"pool_id"`
}

func (*QueryGaugeIdsRequest) Descriptor 

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

func (*QueryGaugeIdsRequest) GetPoolId 

func (m *QueryGaugeIdsRequest) GetPoolId() uint64

func (*QueryGaugeIdsRequest) Marshal 

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

func (*QueryGaugeIdsRequest) MarshalTo 

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

func (*QueryGaugeIdsRequest) MarshalToSizedBuffer 

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

func (*QueryGaugeIdsRequest) ProtoMessage 

func (*QueryGaugeIdsRequest) ProtoMessage()

func (*QueryGaugeIdsRequest) Reset 

func (m *QueryGaugeIdsRequest) Reset()

func (*QueryGaugeIdsRequest) Size 

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

func (*QueryGaugeIdsRequest) String 

func (m *QueryGaugeIdsRequest) String() string

func (*QueryGaugeIdsRequest) Unmarshal 

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

func (*QueryGaugeIdsRequest) XXX_DiscardUnknown 

func (m *QueryGaugeIdsRequest) XXX_DiscardUnknown()

func (*QueryGaugeIdsRequest) XXX_Marshal 

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

func (*QueryGaugeIdsRequest) XXX_Merge 

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

func (*QueryGaugeIdsRequest) XXX_Size 

func (m *QueryGaugeIdsRequest) XXX_Size() int

func (*QueryGaugeIdsRequest) XXX_Unmarshal 

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

type QueryGaugeIdsResponse 

type QueryGaugeIdsResponse struct {
	GaugeIdsWithDuration []*QueryGaugeIdsResponse_GaugeIdWithDuration `` /* 156-byte string literal not displayed */
}

func (*QueryGaugeIdsResponse) Descriptor 

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

func (*QueryGaugeIdsResponse) GetGaugeIdsWithDuration 

func (m *QueryGaugeIdsResponse) GetGaugeIdsWithDuration() []*QueryGaugeIdsResponse_GaugeIdWithDuration

func (*QueryGaugeIdsResponse) Marshal 

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

func (*QueryGaugeIdsResponse) MarshalTo 

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

func (*QueryGaugeIdsResponse) MarshalToSizedBuffer 

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

func (*QueryGaugeIdsResponse) ProtoMessage 

func (*QueryGaugeIdsResponse) ProtoMessage()

func (*QueryGaugeIdsResponse) Reset 

func (m *QueryGaugeIdsResponse) Reset()

func (*QueryGaugeIdsResponse) Size 

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

func (*QueryGaugeIdsResponse) String 

func (m *QueryGaugeIdsResponse) String() string

func (*QueryGaugeIdsResponse) Unmarshal 

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

func (*QueryGaugeIdsResponse) XXX_DiscardUnknown 

func (m *QueryGaugeIdsResponse) XXX_DiscardUnknown()

func (*QueryGaugeIdsResponse) XXX_Marshal 

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

func (*QueryGaugeIdsResponse) XXX_Merge 

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

func (*QueryGaugeIdsResponse) XXX_Size 

func (m *QueryGaugeIdsResponse) XXX_Size() int

func (*QueryGaugeIdsResponse) XXX_Unmarshal 

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

type QueryGaugeIdsResponse_GaugeIdWithDuration 

type QueryGaugeIdsResponse_GaugeIdWithDuration struct {
	GaugeId                  uint64        `protobuf:"varint,1,opt,name=gauge_id,json=gaugeId,proto3" json:"gauge_id,omitempty" yaml:"gauge_id"`
	Duration                 time.Duration `protobuf:"bytes,2,opt,name=duration,proto3,stdduration" json:"duration"`
	GaugeIncentivePercentage string        `` /* 135-byte string literal not displayed */
}

func (*QueryGaugeIdsResponse_GaugeIdWithDuration) Descriptor 

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

func (*QueryGaugeIdsResponse_GaugeIdWithDuration) GetDuration 

func (m *QueryGaugeIdsResponse_GaugeIdWithDuration) GetDuration() time.Duration

func (*QueryGaugeIdsResponse_GaugeIdWithDuration) GetGaugeId 

func (m *QueryGaugeIdsResponse_GaugeIdWithDuration) GetGaugeId() uint64

func (*QueryGaugeIdsResponse_GaugeIdWithDuration) GetGaugeIncentivePercentage 

func (m *QueryGaugeIdsResponse_GaugeIdWithDuration) GetGaugeIncentivePercentage() string

func (*QueryGaugeIdsResponse_GaugeIdWithDuration) Marshal 

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

func (*QueryGaugeIdsResponse_GaugeIdWithDuration) MarshalTo 

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

func (*QueryGaugeIdsResponse_GaugeIdWithDuration) MarshalToSizedBuffer 

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

func (*QueryGaugeIdsResponse_GaugeIdWithDuration) ProtoMessage 

func (*QueryGaugeIdsResponse_GaugeIdWithDuration) ProtoMessage()

func (*QueryGaugeIdsResponse_GaugeIdWithDuration) Reset 

func (m *QueryGaugeIdsResponse_GaugeIdWithDuration) Reset()

func (*QueryGaugeIdsResponse_GaugeIdWithDuration) Size 

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

func (*QueryGaugeIdsResponse_GaugeIdWithDuration) String 

func (m *QueryGaugeIdsResponse_GaugeIdWithDuration) String() string

func (*QueryGaugeIdsResponse_GaugeIdWithDuration) Unmarshal 

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

func (*QueryGaugeIdsResponse_GaugeIdWithDuration) XXX_DiscardUnknown 

func (m *QueryGaugeIdsResponse_GaugeIdWithDuration) XXX_DiscardUnknown()

func (*QueryGaugeIdsResponse_GaugeIdWithDuration) XXX_Marshal 

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

func (*QueryGaugeIdsResponse_GaugeIdWithDuration) XXX_Merge 

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

func (*QueryGaugeIdsResponse_GaugeIdWithDuration) XXX_Size 

func (m *QueryGaugeIdsResponse_GaugeIdWithDuration) XXX_Size() int

func (*QueryGaugeIdsResponse_GaugeIdWithDuration) XXX_Unmarshal 

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

type QueryIncentivizedPoolsRequest 

type QueryIncentivizedPoolsRequest struct {
}

func (*QueryIncentivizedPoolsRequest) Descriptor 

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

func (*QueryIncentivizedPoolsRequest) Marshal 

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

func (*QueryIncentivizedPoolsRequest) MarshalTo 

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

func (*QueryIncentivizedPoolsRequest) MarshalToSizedBuffer 

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

func (*QueryIncentivizedPoolsRequest) ProtoMessage 

func (*QueryIncentivizedPoolsRequest) ProtoMessage()

func (*QueryIncentivizedPoolsRequest) Reset 

func (m *QueryIncentivizedPoolsRequest) Reset()

func (*QueryIncentivizedPoolsRequest) Size 

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

func (*QueryIncentivizedPoolsRequest) String 

func (m *QueryIncentivizedPoolsRequest) String() string

func (*QueryIncentivizedPoolsRequest) Unmarshal 

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

func (*QueryIncentivizedPoolsRequest) XXX_DiscardUnknown 

func (m *QueryIncentivizedPoolsRequest) XXX_DiscardUnknown()

func (*QueryIncentivizedPoolsRequest) XXX_Marshal 

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

func (*QueryIncentivizedPoolsRequest) XXX_Merge 

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

func (*QueryIncentivizedPoolsRequest) XXX_Size 

func (m *QueryIncentivizedPoolsRequest) XXX_Size() int

func (*QueryIncentivizedPoolsRequest) XXX_Unmarshal 

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

type QueryIncentivizedPoolsResponse 

type QueryIncentivizedPoolsResponse struct {
	IncentivizedPools []IncentivizedPool `` /* 128-byte string literal not displayed */
}

func (*QueryIncentivizedPoolsResponse) Descriptor 

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

func (*QueryIncentivizedPoolsResponse) GetIncentivizedPools 

func (m *QueryIncentivizedPoolsResponse) GetIncentivizedPools() []IncentivizedPool

func (*QueryIncentivizedPoolsResponse) Marshal 

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

func (*QueryIncentivizedPoolsResponse) MarshalTo 

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

func (*QueryIncentivizedPoolsResponse) MarshalToSizedBuffer 

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

func (*QueryIncentivizedPoolsResponse) ProtoMessage 

func (*QueryIncentivizedPoolsResponse) ProtoMessage()

func (*QueryIncentivizedPoolsResponse) Reset 

func (m *QueryIncentivizedPoolsResponse) Reset()

func (*QueryIncentivizedPoolsResponse) Size 

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

func (*QueryIncentivizedPoolsResponse) String 

func (m *QueryIncentivizedPoolsResponse) String() string

func (*QueryIncentivizedPoolsResponse) Unmarshal 

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

func (*QueryIncentivizedPoolsResponse) XXX_DiscardUnknown 

func (m *QueryIncentivizedPoolsResponse) XXX_DiscardUnknown()

func (*QueryIncentivizedPoolsResponse) XXX_Marshal 

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

func (*QueryIncentivizedPoolsResponse) XXX_Merge 

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

func (*QueryIncentivizedPoolsResponse) XXX_Size 

func (m *QueryIncentivizedPoolsResponse) XXX_Size() int

func (*QueryIncentivizedPoolsResponse) XXX_Unmarshal 

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

type QueryLockableDurationsRequest 

type QueryLockableDurationsRequest struct {
}

func (*QueryLockableDurationsRequest) Descriptor 

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

func (*QueryLockableDurationsRequest) Marshal 

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

func (*QueryLockableDurationsRequest) MarshalTo 

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

func (*QueryLockableDurationsRequest) MarshalToSizedBuffer 

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

func (*QueryLockableDurationsRequest) ProtoMessage 

func (*QueryLockableDurationsRequest) ProtoMessage()

func (*QueryLockableDurationsRequest) Reset 

func (m *QueryLockableDurationsRequest) Reset()

func (*QueryLockableDurationsRequest) Size 

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

func (*QueryLockableDurationsRequest) String 

func (m *QueryLockableDurationsRequest) String() string

func (*QueryLockableDurationsRequest) Unmarshal 

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

func (*QueryLockableDurationsRequest) XXX_DiscardUnknown 

func (m *QueryLockableDurationsRequest) XXX_DiscardUnknown()

func (*QueryLockableDurationsRequest) XXX_Marshal 

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

func (*QueryLockableDurationsRequest) XXX_Merge 

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

func (*QueryLockableDurationsRequest) XXX_Size 

func (m *QueryLockableDurationsRequest) XXX_Size() int

func (*QueryLockableDurationsRequest) XXX_Unmarshal 

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

type QueryLockableDurationsResponse 

type QueryLockableDurationsResponse struct {
	LockableDurations []time.Duration `` /* 140-byte string literal not displayed */
}

func (*QueryLockableDurationsResponse) Descriptor 

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

func (*QueryLockableDurationsResponse) GetLockableDurations 

func (m *QueryLockableDurationsResponse) GetLockableDurations() []time.Duration

func (*QueryLockableDurationsResponse) Marshal 

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

func (*QueryLockableDurationsResponse) MarshalTo 

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

func (*QueryLockableDurationsResponse) MarshalToSizedBuffer 

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

func (*QueryLockableDurationsResponse) ProtoMessage 

func (*QueryLockableDurationsResponse) ProtoMessage()

func (*QueryLockableDurationsResponse) Reset 

func (m *QueryLockableDurationsResponse) Reset()

func (*QueryLockableDurationsResponse) Size 

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

func (*QueryLockableDurationsResponse) String 

func (m *QueryLockableDurationsResponse) String() string

func (*QueryLockableDurationsResponse) Unmarshal 

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

func (*QueryLockableDurationsResponse) XXX_DiscardUnknown 

func (m *QueryLockableDurationsResponse) XXX_DiscardUnknown()

func (*QueryLockableDurationsResponse) XXX_Marshal 

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

func (*QueryLockableDurationsResponse) XXX_Merge 

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

func (*QueryLockableDurationsResponse) XXX_Size 

func (m *QueryLockableDurationsResponse) XXX_Size() int

func (*QueryLockableDurationsResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

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

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// GaugeIds takes the pool id and returns the matching gauge ids and durations
	GaugeIds(context.Context, *QueryGaugeIdsRequest) (*QueryGaugeIdsResponse, error)
	// DistrInfo returns the pool's matching gauge ids and weights.
	DistrInfo(context.Context, *QueryDistrInfoRequest) (*QueryDistrInfoResponse, error)
	// Params returns pool incentives params.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// LockableDurations returns lock durations for pools.
	LockableDurations(context.Context, *QueryLockableDurationsRequest) (*QueryLockableDurationsResponse, error)
	// IncentivizedPools returns currently incentivized pools
	IncentivizedPools(context.Context, *QueryIncentivizedPoolsRequest) (*QueryIncentivizedPoolsResponse, error)
	// ExternalIncentiveGauges returns external incentive gauges.
	ExternalIncentiveGauges(context.Context, *QueryExternalIncentiveGaugesRequest) (*QueryExternalIncentiveGaugesResponse, error)
}

QueryServer is the server API for Query service.

type ReplacePoolIncentivesProposal 

type ReplacePoolIncentivesProposal struct {
	Title       string        `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Description string        `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Records     []DistrRecord `protobuf:"bytes,3,rep,name=records,proto3" json:"records"`
}

ReplacePoolIncentivesProposal is a gov Content type for updating the pool incentives. If a ReplacePoolIncentivesProposal passes, the proposal’s records override the existing DistrRecords set in the module. Each record has a specified gauge id and weight, and the incentives are distributed to each gauge according to weight/total_weight. The incentives are put in the fee pool and it is allocated to gauges and community pool by the DistrRecords configuration. Note that gaugeId=0 represents the community pool.

func (*ReplacePoolIncentivesProposal) Descriptor 

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

func (*ReplacePoolIncentivesProposal) Equal 

func (this *ReplacePoolIncentivesProposal) Equal(that interface{}) bool

func (*ReplacePoolIncentivesProposal) GetDescription 

func (p *ReplacePoolIncentivesProposal) GetDescription() string

GetDescription gets the description of the proposal

func (*ReplacePoolIncentivesProposal) GetTitle 

func (p *ReplacePoolIncentivesProposal) GetTitle() string

GetTitle gets the title of the proposal

func (*ReplacePoolIncentivesProposal) Marshal 

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

func (*ReplacePoolIncentivesProposal) MarshalTo 

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

func (*ReplacePoolIncentivesProposal) MarshalToSizedBuffer 

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

func (*ReplacePoolIncentivesProposal) ProposalRoute 

func (p *ReplacePoolIncentivesProposal) ProposalRoute() string

ProposalRoute returns the router key for the proposal

func (*ReplacePoolIncentivesProposal) ProposalType 

func (p *ReplacePoolIncentivesProposal) ProposalType() string

ProposalType returns the type of the proposal

func (*ReplacePoolIncentivesProposal) ProtoMessage 

func (*ReplacePoolIncentivesProposal) ProtoMessage()

func (*ReplacePoolIncentivesProposal) Reset 

func (m *ReplacePoolIncentivesProposal) Reset()

func (*ReplacePoolIncentivesProposal) Size 

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

func (ReplacePoolIncentivesProposal) String 

func (p ReplacePoolIncentivesProposal) String() string

String returns a string containing the pool incentives proposal.

func (*ReplacePoolIncentivesProposal) Unmarshal 

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

func (*ReplacePoolIncentivesProposal) ValidateBasic 

func (p *ReplacePoolIncentivesProposal) ValidateBasic() error

ValidateBasic validates a governance proposal's abstract and basic contents

func (*ReplacePoolIncentivesProposal) XXX_DiscardUnknown 

func (m *ReplacePoolIncentivesProposal) XXX_DiscardUnknown()

func (*ReplacePoolIncentivesProposal) XXX_Marshal 

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

func (*ReplacePoolIncentivesProposal) XXX_Merge 

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

func (*ReplacePoolIncentivesProposal) XXX_Size 

func (m *ReplacePoolIncentivesProposal) XXX_Size() int

func (*ReplacePoolIncentivesProposal) XXX_Unmarshal 

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

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) DistrInfo 

func (*UnimplementedQueryServer) DistrInfo(ctx context.Context, req *QueryDistrInfoRequest) (*QueryDistrInfoResponse, error)

func (*UnimplementedQueryServer) ExternalIncentiveGauges 

func (*UnimplementedQueryServer) ExternalIncentiveGauges(ctx context.Context, req *QueryExternalIncentiveGaugesRequest) (*QueryExternalIncentiveGaugesResponse, error)

func (*UnimplementedQueryServer) GaugeIds 

func (*UnimplementedQueryServer) GaugeIds(ctx context.Context, req *QueryGaugeIdsRequest) (*QueryGaugeIdsResponse, error)

func (*UnimplementedQueryServer) IncentivizedPools 

func (*UnimplementedQueryServer) IncentivizedPools(ctx context.Context, req *QueryIncentivizedPoolsRequest) (*QueryIncentivizedPoolsResponse, error)

func (*UnimplementedQueryServer) LockableDurations 

func (*UnimplementedQueryServer) LockableDurations(ctx context.Context, req *QueryLockableDurationsRequest) (*QueryLockableDurationsResponse, error)

func (*UnimplementedQueryServer) Params 

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

type UpdatePoolIncentivesProposal 

type UpdatePoolIncentivesProposal struct {
	Title       string        `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Description string        `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Records     []DistrRecord `protobuf:"bytes,3,rep,name=records,proto3" json:"records"`
}

For example: if the existing DistrRecords were: [(Gauge 0, 5), (Gauge 1, 6), (Gauge 2, 6)] An UpdatePoolIncentivesProposal includes [(Gauge 1, 0), (Gauge 2, 4), (Gauge 3, 10)] This would delete Gauge 1, Edit Gauge 2, and Add Gauge 3 The result DistrRecords in state would be: [(Gauge 0, 5), (Gauge 2, 4), (Gauge 3, 10)]

func (*UpdatePoolIncentivesProposal) Descriptor 

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

func (*UpdatePoolIncentivesProposal) Equal 

func (this *UpdatePoolIncentivesProposal) Equal(that interface{}) bool

func (*UpdatePoolIncentivesProposal) GetDescription 

func (p *UpdatePoolIncentivesProposal) GetDescription() string

GetDescription gets the description of the proposal

func (*UpdatePoolIncentivesProposal) GetTitle 

func (p *UpdatePoolIncentivesProposal) GetTitle() string

GetTitle gets the title of the proposal

func (*UpdatePoolIncentivesProposal) Marshal 

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

func (*UpdatePoolIncentivesProposal) MarshalTo 

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

func (*UpdatePoolIncentivesProposal) MarshalToSizedBuffer 

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

func (*UpdatePoolIncentivesProposal) ProposalRoute 

func (p *UpdatePoolIncentivesProposal) ProposalRoute() string

ProposalRoute returns the router key for the proposal

func (*UpdatePoolIncentivesProposal) ProposalType 

func (p *UpdatePoolIncentivesProposal) ProposalType() string

ProposalType returns the type of the proposal

func (*UpdatePoolIncentivesProposal) ProtoMessage 

func (*UpdatePoolIncentivesProposal) ProtoMessage()

func (*UpdatePoolIncentivesProposal) Reset 

func (m *UpdatePoolIncentivesProposal) Reset()

func (*UpdatePoolIncentivesProposal) Size 

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

func (UpdatePoolIncentivesProposal) String 

func (p UpdatePoolIncentivesProposal) String() string

String returns a string containing the pool incentives proposal.

func (*UpdatePoolIncentivesProposal) Unmarshal 

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

func (*UpdatePoolIncentivesProposal) ValidateBasic 

func (p *UpdatePoolIncentivesProposal) ValidateBasic() error

ValidateBasic validates a governance proposal's abstract and basic contents.

func (*UpdatePoolIncentivesProposal) XXX_DiscardUnknown 

func (m *UpdatePoolIncentivesProposal) XXX_DiscardUnknown()

func (*UpdatePoolIncentivesProposal) XXX_Marshal 

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

func (*UpdatePoolIncentivesProposal) XXX_Merge 

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

func (*UpdatePoolIncentivesProposal) XXX_Size 

func (m *UpdatePoolIncentivesProposal) XXX_Size() int

func (*UpdatePoolIncentivesProposal) XXX_Unmarshal 

func (m *UpdatePoolIncentivesProposal) 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.