types

package
v1.4.5-rc0 Latest Latest
Warning

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

 Go to latest Published: Dec 4, 2023 License: Apache-2.0 Imports: 49 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	AttributeValueCategory      = ModuleName
	AttributeKeyProtocolDataKey = "protocoldata_key"

	EventTypeDeleteKeyProposal = "protocoldata_delete"
)
View Source 
const (
	// ModuleName defines the module name.
	ModuleName = "participationrewards"
	// StoreKey defines the primary module store key.
	StoreKey = ModuleName
	// QuerierRoute is the querier route for the participationrewards store.
	QuerierRoute = StoreKey
	// RouterKey is the message route for participationrewards.
	RouterKey = ModuleName

	OsmosisParamsKey  = "osmosisparams"
	UmeeParamsKey     = "umeeparams"
	CrescentParamsKey = "crescentparams"
	ProofTypeBank     = "bank"
	ProofTypeLeverage = "leverage"
	ProofTypeLPFarm   = "lpfarm"
)
View Source 
const (
	PoolTypeBalancer   = "balancer"
	PoolTypeStableSwap = "stableswap"
)
View Source 
const (
	ProposalTypeAddProtocolData = "AddProtocolData"
)
View Source 
const (
	SelfConnection = "local"
)
View Source 
const (
	TypeMsgSubmitClaim = "submitclaim"
)

participationrewars message types.

Variables

View Source 
var (
	ErrUndefinedAttribute            = sdkioerrors.Register(ModuleName, 1, "expected attribute not defined")
	ErrNegativeAttribute             = sdkioerrors.Register(ModuleName, 2, "expected attribute must not be negative")
	ErrNegativeDistributionRatio     = sdkioerrors.Register(ModuleName, 3, "distribution ratio must not be negative")
	ErrInvalidTotalProportions       = sdkioerrors.Register(ModuleName, 4, "total distribution proportions must be 1.0")
	ErrNotPositive                   = sdkioerrors.Register(ModuleName, 5, "expected attribute must be positive")
	ErrUnknownProtocolDataType       = sdkioerrors.Register(ModuleName, 6, "unknown protocol data type")
	ErrUnimplementedProtocolDataType = sdkioerrors.Register(ModuleName, 7, "protocol data type not implemented")
	ErrNothingToAllocate             = sdkioerrors.Register(ModuleName, 9, "balance is zero, nothing to allocate")
	ErrInvalidAssetName              = sdkioerrors.Register(ModuleName, 10, "invalid ibc asset name")
	ErrInvalidChainID                = sdkioerrors.Register(ModuleName, 11, "invalid chain id")
	ErrInvalidDenom                  = sdkioerrors.Register(ModuleName, 12, "invalid denom")
	ErrCannotUnmarshal               = sdkioerrors.Register(ModuleName, 13, "unable to unmarshal")
	ErrInvalidBech32                 = sdkioerrors.Register(ModuleName, 14, "invalid bech32")
)

x/participationrewards module sentinel 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 (
	ErrInvalidLengthMessages        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessages          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessages = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	KeyDistributionProportions = []byte("DistributionProportions")
	KeyClaimsEnabled           = []byte("ClaimsEnabled")

	DefaultValidatorSelectionAllocation = sdk.NewDecWithPrec(34, 2)
	DefaultHoldingsAllocation           = sdk.NewDecWithPrec(33, 2)
	DefaultLockupAllocation             = sdk.NewDecWithPrec(33, 2)
	DefaultClaimsEnabled                = false
)
View Source 
var (
	ErrInvalidLengthParticipationrewards        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParticipationrewards          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParticipationrewards = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthProposals        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowProposals          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupProposals = 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 KeyPrefixProtocolData = []byte{0x00}
View Source 
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)
View Source 
var ProtocolDataType_name = map[int32]string{
	0:  "ProtocolDataTypeUndefined",
	1:  "ProtocolDataTypeConnection",
	2:  "ProtocolDataTypeOsmosisParams",
	3:  "ProtocolDataTypeLiquidToken",
	4:  "ProtocolDataTypeOsmosisPool",
	5:  "ProtocolDataTypeCrescentPool",
	6:  "ProtocolDataTypeSifchainPool",
	7:  "ProtocolDataTypeUmeeParams",
	8:  "ProtocolDataTypeUmeeReserves",
	9:  "ProtocolDataTypeUmeeInterestScalar",
	10: "ProtocolDataTypeUmeeTotalBorrows",
	11: "ProtocolDataTypeUmeeUTokenSupply",
	12: "ProtocolDataTypeUmeeLeverageModuleBalance",
	13: "ProtocolDataTypeCrescentParams",
	14: "ProtocolDataTypeCrescentReserveAddressBalance",
	15: "ProtocolDataTypeCrescentPoolCoinSupply",
}
View Source 
var ProtocolDataType_value = map[string]int32{
	"ProtocolDataTypeUndefined":                     0,
	"ProtocolDataTypeConnection":                    1,
	"ProtocolDataTypeOsmosisParams":                 2,
	"ProtocolDataTypeLiquidToken":                   3,
	"ProtocolDataTypeOsmosisPool":                   4,
	"ProtocolDataTypeCrescentPool":                  5,
	"ProtocolDataTypeSifchainPool":                  6,
	"ProtocolDataTypeUmeeParams":                    7,
	"ProtocolDataTypeUmeeReserves":                  8,
	"ProtocolDataTypeUmeeInterestScalar":            9,
	"ProtocolDataTypeUmeeTotalBorrows":              10,
	"ProtocolDataTypeUmeeUTokenSupply":              11,
	"ProtocolDataTypeUmeeLeverageModuleBalance":     12,
	"ProtocolDataTypeCrescentParams":                13,
	"ProtocolDataTypeCrescentReserveAddressBalance": 14,
	"ProtocolDataTypeCrescentPoolCoinSupply":        15,
}

Functions

func GetPrefixProtocolDataKey 

func GetPrefixProtocolDataKey(pdType ProtocolDataType) []byte

func GetProtocolDataKey 

func GetProtocolDataKey(pdType ProtocolDataType, key []byte) []byte

func GetUnderlyingData 

func GetUnderlyingData[V math.Int | sdk.Dec](upd *UmeeProtocolData) (V, error)

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable for participationrewards module.

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

func RegisterMsgHandler 

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

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

func RegisterMsgHandlerClient 

func RegisterMsgHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MsgClient) error

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

func RegisterMsgHandlerFromEndpoint 

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

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

func RegisterMsgHandlerServer 

func RegisterMsgHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MsgServer) error

RegisterMsgHandlerServer registers the http handlers for service Msg to "mux". UnaryRPC :call MsgServer 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 RegisterMsgHandlerFromEndpoint instead.

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

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

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

func RegisterQueryHandlerClient 

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

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

func RegisterQueryHandlerFromEndpoint 

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

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

func RegisterQueryHandlerServer 

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

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

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type AccountKeeper 

type AccountKeeper interface {
	GetModuleAddress(name string) sdk.AccAddress
	HasAccount(ctx sdk.Context, addr sdk.AccAddress) bool

	SetModuleAccount(sdk.Context, types.ModuleAccountI)
	GetModuleAccount(ctx sdk.Context, moduleName string) types.ModuleAccountI
}

AccountKeeper defines the contract required for account APIs.

type AddProtocolDataProposal 

type AddProtocolDataProposal 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"`
	Type        string                   `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty" yaml:"type"`
	Data        encoding_json.RawMessage `protobuf:"bytes,5,opt,name=data,proto3,casttype=encoding/json.RawMessage" json:"data,omitempty" yaml:"data"`
	Key         string                   `protobuf:"bytes,6,opt,name=key,proto3" json:"key,omitempty" yaml:"key"`
}

func NewAddProtocolDataProposal 

func NewAddProtocolDataProposal(title, description, datatype, _, key string, data json.RawMessage) *AddProtocolDataProposal

func (*AddProtocolDataProposal) Descriptor 

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

func (*AddProtocolDataProposal) GetDescription 

func (m *AddProtocolDataProposal) GetDescription() string

func (*AddProtocolDataProposal) GetTitle 

func (m *AddProtocolDataProposal) GetTitle() string

func (*AddProtocolDataProposal) Marshal 

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

func (*AddProtocolDataProposal) MarshalTo 

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

func (*AddProtocolDataProposal) MarshalToSizedBuffer 

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

func (*AddProtocolDataProposal) ProposalRoute 

func (*AddProtocolDataProposal) ProposalRoute() string

func (*AddProtocolDataProposal) ProposalType 

func (*AddProtocolDataProposal) ProposalType() string

func (*AddProtocolDataProposal) ProtoMessage 

func (*AddProtocolDataProposal) ProtoMessage()

func (*AddProtocolDataProposal) Reset 

func (m *AddProtocolDataProposal) Reset()

func (*AddProtocolDataProposal) Size 

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

func (*AddProtocolDataProposal) String 

func (m *AddProtocolDataProposal) String() string

String implements the Stringer interface.

func (*AddProtocolDataProposal) Unmarshal 

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

func (*AddProtocolDataProposal) ValidateBasic 

func (m *AddProtocolDataProposal) ValidateBasic() error

ValidateBasic runs basic stateless validity checks.

func (*AddProtocolDataProposal) XXX_DiscardUnknown 

func (m *AddProtocolDataProposal) XXX_DiscardUnknown()

func (*AddProtocolDataProposal) XXX_Marshal 

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

func (*AddProtocolDataProposal) XXX_Merge 

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

func (*AddProtocolDataProposal) XXX_Size 

func (m *AddProtocolDataProposal) XXX_Size() int

func (*AddProtocolDataProposal) XXX_Unmarshal 

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

type AddProtocolDataProposalWithDeposit 

type AddProtocolDataProposalWithDeposit 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"`
	Protocol    string                   `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty" yaml:"protocol"`
	Type        string                   `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty" yaml:"type"`
	Key         string                   `protobuf:"bytes,5,opt,name=key,proto3" json:"key,omitempty" yaml:"key"`
	Data        encoding_json.RawMessage `protobuf:"bytes,6,opt,name=data,proto3,casttype=encoding/json.RawMessage" json:"data,omitempty" yaml:"data"`
	Deposit     string                   `protobuf:"bytes,7,opt,name=deposit,proto3" json:"deposit,omitempty" yaml:"deposit"`
}

func (*AddProtocolDataProposalWithDeposit) Descriptor 

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

func (*AddProtocolDataProposalWithDeposit) Marshal 

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

func (*AddProtocolDataProposalWithDeposit) MarshalTo 

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

func (*AddProtocolDataProposalWithDeposit) MarshalToSizedBuffer 

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

func (*AddProtocolDataProposalWithDeposit) ProtoMessage 

func (*AddProtocolDataProposalWithDeposit) ProtoMessage()

func (*AddProtocolDataProposalWithDeposit) Reset 

func (m *AddProtocolDataProposalWithDeposit) Reset()

func (*AddProtocolDataProposalWithDeposit) Size 

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

func (*AddProtocolDataProposalWithDeposit) String 

func (m *AddProtocolDataProposalWithDeposit) String() string

func (*AddProtocolDataProposalWithDeposit) Unmarshal 

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

func (*AddProtocolDataProposalWithDeposit) XXX_DiscardUnknown 

func (m *AddProtocolDataProposalWithDeposit) XXX_DiscardUnknown()

func (*AddProtocolDataProposalWithDeposit) XXX_Marshal 

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

func (*AddProtocolDataProposalWithDeposit) XXX_Merge 

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

func (*AddProtocolDataProposalWithDeposit) XXX_Size 

func (m *AddProtocolDataProposalWithDeposit) XXX_Size() int

func (*AddProtocolDataProposalWithDeposit) XXX_Unmarshal 

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

type BankKeeper 

type BankKeeper interface {
	GetBalance(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin
	GetAllBalances(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	SendCoins(ctx sdk.Context, senderModule sdk.AccAddress, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromModuleToModule(ctx sdk.Context, senderModule, recipientModule string, amt sdk.Coins) error
	MintCoins(ctx sdk.Context, name string, amt sdk.Coins) error
	GetSupply(ctx sdk.Context, denom string) sdk.Coin
}

BankKeeper defines the contract needed to be fulfilled for banking and supply dependencies.

type ClaimsManagerKeeper 

type ClaimsManagerKeeper interface {
	ArchiveAndGarbageCollectClaims(ctx sdk.Context, chainID string)
	IterateClaims(ctx sdk.Context, chainID string, fn func(index int64, data claimsmanagertypes.Claim) (stop bool))
	IterateLastEpochUserClaims(ctx sdk.Context, chainID, address string, fn func(index int64, data claimsmanagertypes.Claim) (stop bool))
	GetSelfConsensusState(ctx sdk.Context, key string) (ibctmtypes.ConsensusState, bool)
	SetClaim(ctx sdk.Context, claim *claimsmanagertypes.Claim)
}

type ConnectionProtocolData 

type ConnectionProtocolData struct {
	ConnectionID string
	ChainID      string
	LastEpoch    int64
	Prefix       string
}

ConnectionProtocolData defines state for connection tracking.

func (ConnectionProtocolData) GenerateKey 

func (cpd ConnectionProtocolData) GenerateKey() []byte

func (*ConnectionProtocolData) ValidateBasic 

func (cpd *ConnectionProtocolData) ValidateBasic() error

ValidateBasic satisfies ProtocolDataI and validates basic stateless data.

type CrescentParamsProtocolData 

type CrescentParamsProtocolData struct {
	ChainID string
}

func (CrescentParamsProtocolData) GenerateKey 

func (CrescentParamsProtocolData) GenerateKey() []byte

func (CrescentParamsProtocolData) ValidateBasic 

func (uppd CrescentParamsProtocolData) ValidateBasic() error

type CrescentPoolCoinSupplyProtocolData 

type CrescentPoolCoinSupplyProtocolData struct {
	PoolCoinDenom string
	Supply        json.RawMessage
	LastUpdated   time.Time
}

func (CrescentPoolCoinSupplyProtocolData) GenerateKey 

func (cpd CrescentPoolCoinSupplyProtocolData) GenerateKey() []byte

func (CrescentPoolCoinSupplyProtocolData) GetSupply 

func (cpd CrescentPoolCoinSupplyProtocolData) GetSupply() (math.Int, error)

func (CrescentPoolCoinSupplyProtocolData) ValidateBasic 

func (cpd CrescentPoolCoinSupplyProtocolData) ValidateBasic() error

type CrescentPoolProtocolData 

type CrescentPoolProtocolData struct {
	PoolID      uint64
	Denom       string
	PoolData    json.RawMessage
	LastUpdated time.Time
}

func (*CrescentPoolProtocolData) GenerateKey 

func (cpd *CrescentPoolProtocolData) GenerateKey() []byte

func (*CrescentPoolProtocolData) GetPool 

func (cpd *CrescentPoolProtocolData) GetPool() (*liquiditytypes.Pool, error)

func (*CrescentPoolProtocolData) ValidateBasic 

func (cpd *CrescentPoolProtocolData) ValidateBasic() error

type CrescentReserveAddressBalanceProtocolData 

type CrescentReserveAddressBalanceProtocolData struct {
	ReserveAddress string
	Denom          string
	Balance        json.RawMessage
	LastUpdated    time.Time
}

func (CrescentReserveAddressBalanceProtocolData) GenerateKey 

func (crd CrescentReserveAddressBalanceProtocolData) GenerateKey() []byte

func (CrescentReserveAddressBalanceProtocolData) GetBalance 

func (crd CrescentReserveAddressBalanceProtocolData) GetBalance() (math.Int, error)

func (CrescentReserveAddressBalanceProtocolData) ValidateBasic 

func (crd CrescentReserveAddressBalanceProtocolData) ValidateBasic() error

type DenomWithZone 

type DenomWithZone struct {
	Denom   string
	ChainID string
}

type DistributionProportions 

type DistributionProportions struct {
	ValidatorSelectionAllocation github_com_cosmos_cosmos_sdk_types.Dec `` /* 187-byte string literal not displayed */
	HoldingsAllocation           github_com_cosmos_cosmos_sdk_types.Dec `` /* 155-byte string literal not displayed */
	LockupAllocation             github_com_cosmos_cosmos_sdk_types.Dec `` /* 149-byte string literal not displayed */
}

DistributionProportions defines the proportions of minted QCK that is to be allocated as participation rewards.

func (*DistributionProportions) Descriptor 

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

func (*DistributionProportions) Marshal 

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

func (*DistributionProportions) MarshalTo 

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

func (*DistributionProportions) MarshalToSizedBuffer 

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

func (*DistributionProportions) ProtoMessage 

func (*DistributionProportions) ProtoMessage()

func (*DistributionProportions) Reset 

func (m *DistributionProportions) Reset()

func (*DistributionProportions) Size 

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

func (*DistributionProportions) String 

func (m *DistributionProportions) String() string

func (*DistributionProportions) Total 

func (dp *DistributionProportions) Total() sdk.Dec

func (*DistributionProportions) Unmarshal 

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

func (*DistributionProportions) ValidateBasic 

func (dp *DistributionProportions) ValidateBasic() error

func (*DistributionProportions) XXX_DiscardUnknown 

func (m *DistributionProportions) XXX_DiscardUnknown()

func (*DistributionProportions) XXX_Marshal 

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

func (*DistributionProportions) XXX_Merge 

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

func (*DistributionProportions) XXX_Size 

func (m *DistributionProportions) XXX_Size() int

func (*DistributionProportions) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	Params       Params               `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	ProtocolData []*KeyedProtocolData `protobuf:"bytes,2,rep,name=protocol_data,json=protocolData,proto3" json:"protocol_data,omitempty"`
}

GenesisState defines the participationrewards module's genesis state.

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

DefaultGenesisState returns the default ics genesis state.

func NewGenesisState 

func NewGenesisState(params Params) *GenesisState

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetProtocolData 

func (m *GenesisState) GetProtocolData() []*KeyedProtocolData

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 validates the provided genesis state to ensure the expected invariants holds.

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 InterchainQueryKeeper 

type InterchainQueryKeeper interface {
	MakeRequest(
		ctx sdk.Context,
		connectionID,
		chainID,
		queryType string,
		request []byte,
		period sdkmath.Int,
		module string,
		callbackID string,
		ttl uint64,
	)
	GetQuery(ctx sdk.Context, id string) (interchainquerytypes.Query, bool)
}

type InterchainStakingKeeper 

type InterchainStakingKeeper interface {
	SubmitTx(ctx sdk.Context, msgs []sdk.Msg, account *interchainstakingtypes.ICAAccount, memo string, messagesPerTx int64) error
	IterateZones(ctx sdk.Context, fn func(index int64, zone *interchainstakingtypes.Zone) (stop bool))
	GetZone(ctx sdk.Context, chainID string) (interchainstakingtypes.Zone, bool)
	SetZone(ctx sdk.Context, zone *interchainstakingtypes.Zone)
	AllDelegatorIntents(ctx sdk.Context, zone *interchainstakingtypes.Zone, snapshot bool) []interchainstakingtypes.DelegatorIntent
	SetDelegatorIntent(ctx sdk.Context, zone *interchainstakingtypes.Zone, intent interchainstakingtypes.DelegatorIntent, snapshot bool)
	GetDelegatedAmount(ctx sdk.Context, zone *interchainstakingtypes.Zone) sdk.Coin
	GetDelegationsInProcess(ctx sdk.Context, chainID string) sdkmath.Int
	IterateDelegatorIntents(ctx sdk.Context, zone *interchainstakingtypes.Zone, snapshot bool, fn func(index int64, intent interchainstakingtypes.DelegatorIntent) (stop bool))
	GetValidators(ctx sdk.Context, chainID string) []interchainstakingtypes.Validator
	SetValidator(ctx sdk.Context, chainID string, val interchainstakingtypes.Validator) error
}

type KeyedProtocolData 

type KeyedProtocolData struct {
	Key          string        `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	ProtocolData *ProtocolData `protobuf:"bytes,2,opt,name=protocol_data,json=protocolData,proto3" json:"protocol_data,omitempty"`
}

func (*KeyedProtocolData) Descriptor 

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

func (*KeyedProtocolData) GetKey 

func (m *KeyedProtocolData) GetKey() string

func (*KeyedProtocolData) GetProtocolData 

func (m *KeyedProtocolData) GetProtocolData() *ProtocolData

func (*KeyedProtocolData) Marshal 

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

func (*KeyedProtocolData) MarshalTo 

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

func (*KeyedProtocolData) MarshalToSizedBuffer 

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

func (*KeyedProtocolData) ProtoMessage 

func (*KeyedProtocolData) ProtoMessage()

func (*KeyedProtocolData) Reset 

func (m *KeyedProtocolData) Reset()

func (*KeyedProtocolData) Size 

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

func (*KeyedProtocolData) String 

func (m *KeyedProtocolData) String() string

func (*KeyedProtocolData) Unmarshal 

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

func (*KeyedProtocolData) ValidateBasic 

func (kpd *KeyedProtocolData) ValidateBasic() error

func (*KeyedProtocolData) XXX_DiscardUnknown 

func (m *KeyedProtocolData) XXX_DiscardUnknown()

func (*KeyedProtocolData) XXX_Marshal 

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

func (*KeyedProtocolData) XXX_Merge 

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

func (*KeyedProtocolData) XXX_Size 

func (m *KeyedProtocolData) XXX_Size() int

func (*KeyedProtocolData) XXX_Unmarshal 

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

type LiquidAllowedDenomProtocolData 

type LiquidAllowedDenomProtocolData struct {
	// The chain on which the qAssets reside currently.
	ChainID string
	// The chain for which the qAssets were issued.
	RegisteredZoneChainID string
	// The IBC denom.
	IbcDenom string
	// The qAsset denom.
	QAssetDenom string
}

LiquidAllowedDenomProtocolData defines protocol state to track off-chain liquid qAssets.

func (*LiquidAllowedDenomProtocolData) GenerateKey 

func (lpd *LiquidAllowedDenomProtocolData) GenerateKey() []byte

func (*LiquidAllowedDenomProtocolData) ValidateBasic 

func (lpd *LiquidAllowedDenomProtocolData) ValidateBasic() error

type MsgClient 

type MsgClient interface {
	SubmitClaim(ctx context.Context, in *MsgSubmitClaim, opts ...grpc.CallOption) (*MsgSubmitClaimResponse, error)
	// SignalIntent defines a method for signalling voting intent for one or more
	// validators.
	GovRemoveProtocolData(ctx context.Context, in *MsgGovRemoveProtocolData, opts ...grpc.CallOption) (*MsgGovRemoveProtocolDataResponse, 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 MsgGovRemoveProtocolData 

type MsgGovRemoveProtocolData 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"`
	Key         string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty" yaml:"key"`
	Authority   string `protobuf:"bytes,4,opt,name=authority,proto3" json:"authority,omitempty"`
}

func NewMsgGovRemoveProtocolData 

func NewMsgGovRemoveProtocolData(key string, fromAddress sdk.Address) *MsgGovRemoveProtocolData

NewMsgGovRemoveProtocolData - construct a governance proposal msg to remove protocoldata by key.

func (*MsgGovRemoveProtocolData) Descriptor 

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

func (MsgGovRemoveProtocolData) GetSignBytes 

func (msg MsgGovRemoveProtocolData) GetSignBytes() []byte

GetSignBytes Implements Msg.

func (MsgGovRemoveProtocolData) GetSigners 

func (msg MsgGovRemoveProtocolData) GetSigners() []sdk.AccAddress

GetSigners Implements Msg.

func (*MsgGovRemoveProtocolData) Marshal 

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

func (*MsgGovRemoveProtocolData) MarshalTo 

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

func (*MsgGovRemoveProtocolData) MarshalToSizedBuffer 

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

func (*MsgGovRemoveProtocolData) ProtoMessage 

func (*MsgGovRemoveProtocolData) ProtoMessage()

func (*MsgGovRemoveProtocolData) Reset 

func (m *MsgGovRemoveProtocolData) Reset()

func (*MsgGovRemoveProtocolData) Size 

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

func (*MsgGovRemoveProtocolData) String 

func (m *MsgGovRemoveProtocolData) String() string

func (*MsgGovRemoveProtocolData) Unmarshal 

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

func (MsgGovRemoveProtocolData) ValidateBasic 

func (msg MsgGovRemoveProtocolData) ValidateBasic() error

Validate.

func (*MsgGovRemoveProtocolData) XXX_DiscardUnknown 

func (m *MsgGovRemoveProtocolData) XXX_DiscardUnknown()

func (*MsgGovRemoveProtocolData) XXX_Marshal 

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

func (*MsgGovRemoveProtocolData) XXX_Merge 

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

func (*MsgGovRemoveProtocolData) XXX_Size 

func (m *MsgGovRemoveProtocolData) XXX_Size() int

func (*MsgGovRemoveProtocolData) XXX_Unmarshal 

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

type MsgGovRemoveProtocolDataResponse 

type MsgGovRemoveProtocolDataResponse struct {
}

MsgGovRemoveProtocolDataResponse defines the MsgGovRemoveProtocolData response type.

func (*MsgGovRemoveProtocolDataResponse) Descriptor 

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

func (*MsgGovRemoveProtocolDataResponse) Marshal 

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

func (*MsgGovRemoveProtocolDataResponse) MarshalTo 

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

func (*MsgGovRemoveProtocolDataResponse) MarshalToSizedBuffer 

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

func (*MsgGovRemoveProtocolDataResponse) ProtoMessage 

func (*MsgGovRemoveProtocolDataResponse) ProtoMessage()

func (*MsgGovRemoveProtocolDataResponse) Reset 

func (m *MsgGovRemoveProtocolDataResponse) Reset()

func (*MsgGovRemoveProtocolDataResponse) Size 

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

func (*MsgGovRemoveProtocolDataResponse) String 

func (m *MsgGovRemoveProtocolDataResponse) String() string

func (*MsgGovRemoveProtocolDataResponse) Unmarshal 

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

func (*MsgGovRemoveProtocolDataResponse) XXX_DiscardUnknown 

func (m *MsgGovRemoveProtocolDataResponse) XXX_DiscardUnknown()

func (*MsgGovRemoveProtocolDataResponse) XXX_Marshal 

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

func (*MsgGovRemoveProtocolDataResponse) XXX_Merge 

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

func (*MsgGovRemoveProtocolDataResponse) XXX_Size 

func (m *MsgGovRemoveProtocolDataResponse) XXX_Size() int

func (*MsgGovRemoveProtocolDataResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	SubmitClaim(context.Context, *MsgSubmitClaim) (*MsgSubmitClaimResponse, error)
	// SignalIntent defines a method for signalling voting intent for one or more
	// validators.
	GovRemoveProtocolData(context.Context, *MsgGovRemoveProtocolData) (*MsgGovRemoveProtocolDataResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSubmitClaim 

type MsgSubmitClaim struct {
	UserAddress string          `protobuf:"bytes,1,opt,name=user_address,proto3" json:"user_address,omitempty"`
	Zone        string          `protobuf:"bytes,2,opt,name=zone,proto3" json:"zone,omitempty"`
	SrcZone     string          `protobuf:"bytes,3,opt,name=src_zone,proto3" json:"src_zone,omitempty"`
	ClaimType   types.ClaimType `protobuf:"varint,4,opt,name=claim_type,proto3,enum=quicksilver.claimsmanager.v1.ClaimType" json:"claim_type,omitempty"`
	Proofs      []*types.Proof  `protobuf:"bytes,5,rep,name=proofs,proto3" json:"proofs,omitempty"`
}

MsgSubmitClaim represents a message type for submitting a participation claim regarding the given zone (chain).

func NewMsgSubmitClaim 

func NewMsgSubmitClaim(
	userAddress sdk.Address,
	srcZone string,
	zone string,
	claimType cmtypes.ClaimType,
	proofs []*cmtypes.Proof,
) *MsgSubmitClaim

NewMsgSubmitClaim - construct a msg to submit a claim.

func (*MsgSubmitClaim) Descriptor 

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

func (MsgSubmitClaim) GetSignBytes 

func (msg MsgSubmitClaim) GetSignBytes() []byte

GetSignBytes implements LegacyMsg.

func (MsgSubmitClaim) GetSigners 

func (msg MsgSubmitClaim) GetSigners() []sdk.AccAddress

GetSigners implements Msg.

func (*MsgSubmitClaim) Marshal 

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

func (*MsgSubmitClaim) MarshalTo 

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

func (*MsgSubmitClaim) MarshalToSizedBuffer 

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

func (*MsgSubmitClaim) ProtoMessage 

func (*MsgSubmitClaim) ProtoMessage()

func (*MsgSubmitClaim) Reset 

func (m *MsgSubmitClaim) Reset()

func (MsgSubmitClaim) Route 

func (MsgSubmitClaim) Route() string

Route implements LegacyMsg.

func (*MsgSubmitClaim) Size 

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

func (*MsgSubmitClaim) String 

func (m *MsgSubmitClaim) String() string

func (MsgSubmitClaim) Type 

func (MsgSubmitClaim) Type() string

Type Implements Msg.

func (*MsgSubmitClaim) Unmarshal 

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

func (MsgSubmitClaim) ValidateBasic 

func (msg MsgSubmitClaim) ValidateBasic() error

ValidateBasic implements Msg: stateless checks.

func (*MsgSubmitClaim) XXX_DiscardUnknown 

func (m *MsgSubmitClaim) XXX_DiscardUnknown()

func (*MsgSubmitClaim) XXX_Marshal 

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

func (*MsgSubmitClaim) XXX_Merge 

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

func (*MsgSubmitClaim) XXX_Size 

func (m *MsgSubmitClaim) XXX_Size() int

func (*MsgSubmitClaim) XXX_Unmarshal 

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

type MsgSubmitClaimResponse 

type MsgSubmitClaimResponse struct {
}

MsgSubmitClaimResponse defines the MsgSubmitClaim response type.

func (*MsgSubmitClaimResponse) Descriptor 

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

func (*MsgSubmitClaimResponse) Marshal 

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

func (*MsgSubmitClaimResponse) MarshalTo 

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

func (*MsgSubmitClaimResponse) MarshalToSizedBuffer 

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

func (*MsgSubmitClaimResponse) ProtoMessage 

func (*MsgSubmitClaimResponse) ProtoMessage()

func (*MsgSubmitClaimResponse) Reset 

func (m *MsgSubmitClaimResponse) Reset()

func (*MsgSubmitClaimResponse) Size 

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

func (*MsgSubmitClaimResponse) String 

func (m *MsgSubmitClaimResponse) String() string

func (*MsgSubmitClaimResponse) Unmarshal 

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

func (*MsgSubmitClaimResponse) XXX_DiscardUnknown 

func (m *MsgSubmitClaimResponse) XXX_DiscardUnknown()

func (*MsgSubmitClaimResponse) XXX_Marshal 

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

func (*MsgSubmitClaimResponse) XXX_Merge 

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

func (*MsgSubmitClaimResponse) XXX_Size 

func (m *MsgSubmitClaimResponse) XXX_Size() int

func (*MsgSubmitClaimResponse) XXX_Unmarshal 

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

type OsmosisParamsProtocolData 

type OsmosisParamsProtocolData struct {
	ChainID   string
	BaseDenom string
	BaseChain string
}

func (*OsmosisParamsProtocolData) GenerateKey 

func (*OsmosisParamsProtocolData) GenerateKey() []byte

func (*OsmosisParamsProtocolData) ValidateBasic 

func (oppd *OsmosisParamsProtocolData) ValidateBasic() error

ValidateBasic satisfies ProtocolDataI and validates basic stateless data. LastUpdated and PoolData requires stateful access of keeper to validate.

type OsmosisPoolProtocolData 

type OsmosisPoolProtocolData struct {
	PoolID         uint64
	PoolName       string
	LastUpdated    time.Time
	PoolData       json.RawMessage
	PoolType       string
	Denoms         map[string]DenomWithZone
	IsIncentivized bool
}

OsmosisPoolProtocolData defines protocol state to track qAssets locked in Osmosis pools.

func (*OsmosisPoolProtocolData) GenerateKey 

func (opd *OsmosisPoolProtocolData) GenerateKey() []byte

func (*OsmosisPoolProtocolData) GetPool 

func (opd *OsmosisPoolProtocolData) GetPool() (gamm.PoolI, error)

func (*OsmosisPoolProtocolData) ValidateBasic 

func (opd *OsmosisPoolProtocolData) ValidateBasic() error

ValidateBasic satisfies ProtocolDataI and validates basic stateless data. LastUpdated and PoolData requires stateful access of keeper to validate.

type Params 

type Params struct {
	// distribution_proportions defines the proportions of the minted
	// participation rewards;
	DistributionProportions DistributionProportions `protobuf:"bytes,1,opt,name=distribution_proportions,json=distributionProportions,proto3" json:"distribution_proportions"`
	ClaimsEnabled           bool                    `protobuf:"varint,2,opt,name=claims_enabled,json=claimsEnabled,proto3" json:"claims_enabled,omitempty"`
}

Params holds parameters for the participationrewards module.

func DefaultParams 

func DefaultParams() Params

DefaultParams default ics params.

func NewParams 

func NewParams(
	validatorSelectionAllocation sdk.Dec,
	holdingsAllocation sdk.Dec,
	lockupAllocation sdk.Dec,
	claimsEnabled bool,
) Params

NewParams creates a new ics Params instance.

func (*Params) Descriptor 

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

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

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

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

Validate performs stateless validity checks on 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 ProtocolData 

type ProtocolData struct {
	Type string                   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Data encoding_json.RawMessage `protobuf:"bytes,2,opt,name=data,proto3,casttype=encoding/json.RawMessage" json:"data,omitempty"`
}

Protocol Data is an arbitrary data type held against a given zone for the determination of rewards.

func NewProtocolData 

func NewProtocolData(datatype string, data json.RawMessage) *ProtocolData

func (*ProtocolData) Descriptor 

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

func (*ProtocolData) GetData 

func (m *ProtocolData) GetData() encoding_json.RawMessage

func (*ProtocolData) GetType 

func (m *ProtocolData) GetType() string

func (*ProtocolData) Marshal 

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

func (*ProtocolData) MarshalTo 

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

func (*ProtocolData) MarshalToSizedBuffer 

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

func (*ProtocolData) ProtoMessage 

func (*ProtocolData) ProtoMessage()

func (*ProtocolData) Reset 

func (m *ProtocolData) Reset()

func (*ProtocolData) Size 

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

func (*ProtocolData) String 

func (m *ProtocolData) String() string

func (*ProtocolData) Unmarshal 

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

func (*ProtocolData) ValidateBasic 

func (pd *ProtocolData) ValidateBasic() error

func (*ProtocolData) XXX_DiscardUnknown 

func (m *ProtocolData) XXX_DiscardUnknown()

func (*ProtocolData) XXX_Marshal 

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

func (*ProtocolData) XXX_Merge 

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

func (*ProtocolData) XXX_Size 

func (m *ProtocolData) XXX_Size() int

func (*ProtocolData) XXX_Unmarshal 

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

type ProtocolDataI 

type ProtocolDataI interface {
	ValidateBasic() error
	GenerateKey() []byte
}

func UnmarshalProtocolData 

func UnmarshalProtocolData(datatype ProtocolDataType, data json.RawMessage) (ProtocolDataI, error)

type ProtocolDataType 

type ProtocolDataType int32
const (
	// Undefined action (per protobuf spec)
	ProtocolDataTypeUndefined                     ProtocolDataType = 0
	ProtocolDataTypeConnection                    ProtocolDataType = 1
	ProtocolDataTypeOsmosisParams                 ProtocolDataType = 2
	ProtocolDataTypeLiquidToken                   ProtocolDataType = 3
	ProtocolDataTypeOsmosisPool                   ProtocolDataType = 4
	ProtocolDataTypeCrescentPool                  ProtocolDataType = 5
	ProtocolDataTypeSifchainPool                  ProtocolDataType = 6
	ProtocolDataTypeUmeeParams                    ProtocolDataType = 7
	ProtocolDataTypeUmeeReserves                  ProtocolDataType = 8
	ProtocolDataTypeUmeeInterestScalar            ProtocolDataType = 9
	ProtocolDataTypeUmeeTotalBorrows              ProtocolDataType = 10
	ProtocolDataTypeUmeeUTokenSupply              ProtocolDataType = 11
	ProtocolDataTypeUmeeLeverageModuleBalance     ProtocolDataType = 12
	ProtocolDataTypeCrescentParams                ProtocolDataType = 13
	ProtocolDataTypeCrescentReserveAddressBalance ProtocolDataType = 14
	ProtocolDataTypeCrescentPoolCoinSupply        ProtocolDataType = 15
)

func (ProtocolDataType) EnumDescriptor 

func (ProtocolDataType) EnumDescriptor() ([]byte, []int)

func (ProtocolDataType) String 

func (x ProtocolDataType) String() string

type QueryClient 

type QueryClient interface {
	// Params returns the total set of participation rewards parameters.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// ProtocolData returns the requested protocol data.
	ProtocolData(ctx context.Context, in *QueryProtocolDataRequest, opts ...grpc.CallOption) (*QueryProtocolDataResponse, 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 QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest is the request type for the Query/Params RPC method.

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

type QueryParamsResponse struct {
	// params defines the parameters of the module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse is the response type for the Query/Params RPC method.

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryProtocolDataRequest 

type QueryProtocolDataRequest struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Key  string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
}

QueryProtocolDataRequest is the request type for querying Protocol Data.

func (*QueryProtocolDataRequest) Descriptor 

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

func (*QueryProtocolDataRequest) GetKey 

func (m *QueryProtocolDataRequest) GetKey() string

func (*QueryProtocolDataRequest) GetType 

func (m *QueryProtocolDataRequest) GetType() string

func (*QueryProtocolDataRequest) Marshal 

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

func (*QueryProtocolDataRequest) MarshalTo 

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

func (*QueryProtocolDataRequest) MarshalToSizedBuffer 

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

func (*QueryProtocolDataRequest) ProtoMessage 

func (*QueryProtocolDataRequest) ProtoMessage()

func (*QueryProtocolDataRequest) Reset 

func (m *QueryProtocolDataRequest) Reset()

func (*QueryProtocolDataRequest) Size 

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

func (*QueryProtocolDataRequest) String 

func (m *QueryProtocolDataRequest) String() string

func (*QueryProtocolDataRequest) Unmarshal 

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

func (*QueryProtocolDataRequest) XXX_DiscardUnknown 

func (m *QueryProtocolDataRequest) XXX_DiscardUnknown()

func (*QueryProtocolDataRequest) XXX_Marshal 

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

func (*QueryProtocolDataRequest) XXX_Merge 

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

func (*QueryProtocolDataRequest) XXX_Size 

func (m *QueryProtocolDataRequest) XXX_Size() int

func (*QueryProtocolDataRequest) XXX_Unmarshal 

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

type QueryProtocolDataResponse 

type QueryProtocolDataResponse struct {
	// data defines the underlying protocol data.
	Data []encoding_json.RawMessage `protobuf:"bytes,1,rep,name=data,proto3,casttype=encoding/json.RawMessage" json:"data,omitempty" yaml:"data"`
}

QueryProtocolDataResponse is the response type for querying Protocol Data.

func (*QueryProtocolDataResponse) Descriptor 

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

func (*QueryProtocolDataResponse) GetData 

func (m *QueryProtocolDataResponse) GetData() []encoding_json.RawMessage

func (*QueryProtocolDataResponse) Marshal 

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

func (*QueryProtocolDataResponse) MarshalTo 

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

func (*QueryProtocolDataResponse) MarshalToSizedBuffer 

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

func (*QueryProtocolDataResponse) ProtoMessage 

func (*QueryProtocolDataResponse) ProtoMessage()

func (*QueryProtocolDataResponse) Reset 

func (m *QueryProtocolDataResponse) Reset()

func (*QueryProtocolDataResponse) Size 

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

func (*QueryProtocolDataResponse) String 

func (m *QueryProtocolDataResponse) String() string

func (*QueryProtocolDataResponse) Unmarshal 

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

func (*QueryProtocolDataResponse) XXX_DiscardUnknown 

func (m *QueryProtocolDataResponse) XXX_DiscardUnknown()

func (*QueryProtocolDataResponse) XXX_Marshal 

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

func (*QueryProtocolDataResponse) XXX_Merge 

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

func (*QueryProtocolDataResponse) XXX_Size 

func (m *QueryProtocolDataResponse) XXX_Size() int

func (*QueryProtocolDataResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Params returns the total set of participation rewards parameters.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// ProtocolData returns the requested protocol data.
	ProtocolData(context.Context, *QueryProtocolDataRequest) (*QueryProtocolDataResponse, error)
}

QueryServer is the server API for Query service.

type RewardsAllocation 

type RewardsAllocation struct {
	ValidatorSelection math.Int
	Holdings           math.Int
	Lockup             math.Int
}

func GetRewardsAllocations 

func GetRewardsAllocations(moduleBalance math.Int, proportions DistributionProportions) (*RewardsAllocation, error)

GetRewardsAllocations returns an instance of rewardsAllocation with values set according to the given moduleBalance and distribution proportions.

type StakingKeeper 

type StakingKeeper interface {
	BondDenom(ctx sdk.Context) string
}

StakingKeeper defines the contract for staking APIs.

type UmeeInterestScalarProtocolData 

type UmeeInterestScalarProtocolData struct {
	UmeeProtocolData
}

func (*UmeeInterestScalarProtocolData) GetInterestScalar 

func (upd *UmeeInterestScalarProtocolData) GetInterestScalar() (sdk.Dec, error)

type UmeeLeverageModuleBalanceProtocolData 

type UmeeLeverageModuleBalanceProtocolData struct {
	UmeeProtocolData
}

func (*UmeeLeverageModuleBalanceProtocolData) GetModuleBalance 

func (upd *UmeeLeverageModuleBalanceProtocolData) GetModuleBalance() (math.Int, error)

type UmeeParamsProtocolData 

type UmeeParamsProtocolData struct {
	ChainID string
}

func (UmeeParamsProtocolData) GenerateKey 

func (UmeeParamsProtocolData) GenerateKey() []byte

func (UmeeParamsProtocolData) ValidateBasic 

func (uppd UmeeParamsProtocolData) ValidateBasic() error

type UmeeProtocolData 

type UmeeProtocolData struct {
	Denom       string
	LastUpdated time.Time
	Data        json.RawMessage
}

func (*UmeeProtocolData) GenerateKey 

func (upd *UmeeProtocolData) GenerateKey() []byte

func (*UmeeProtocolData) ValidateBasic 

func (upd *UmeeProtocolData) ValidateBasic() error

type UmeeReservesProtocolData 

type UmeeReservesProtocolData struct {
	UmeeProtocolData
}

UmeeReservesProtocolData defines protocol state to track qAssets in Umee reserves.

func (*UmeeReservesProtocolData) GetReserveAmount 

func (upd *UmeeReservesProtocolData) GetReserveAmount() (math.Int, error)

type UmeeTotalBorrowsProtocolData 

type UmeeTotalBorrowsProtocolData struct {
	UmeeProtocolData
}

func (*UmeeTotalBorrowsProtocolData) GetTotalBorrows 

func (upd *UmeeTotalBorrowsProtocolData) GetTotalBorrows() (sdk.Dec, error)

type UmeeUTokenSupplyProtocolData 

type UmeeUTokenSupplyProtocolData struct {
	UmeeProtocolData
}

func (*UmeeUTokenSupplyProtocolData) GetUTokenSupply 

func (upd *UmeeUTokenSupplyProtocolData) GetUTokenSupply() (math.Int, error)

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) GovRemoveProtocolData 

func (*UnimplementedMsgServer) GovRemoveProtocolData(ctx context.Context, req *MsgGovRemoveProtocolData) (*MsgGovRemoveProtocolDataResponse, error)

func (*UnimplementedMsgServer) SubmitClaim 

func (*UnimplementedMsgServer) SubmitClaim(ctx context.Context, req *MsgSubmitClaim) (*MsgSubmitClaimResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Params 

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

func (*UnimplementedQueryServer) ProtocolData 

func (*UnimplementedQueryServer) ProtocolData(ctx context.Context, req *QueryProtocolDataRequest) (*QueryProtocolDataResponse, error)

type UserAllocation 

type UserAllocation struct {
	Address string
	Amount  sdk.Coin
}

UserAllocation is an internal keeper struct to track transient state for rewards distribution. It contains the user address and the coins that are allocated to it.

type UserScore 

type UserScore struct {
	Address string
	Score   sdk.Dec
}

UserScore is an internal struct to track transient state for rewards distribution. It contains the user address and individual score.

type Validator 

type Validator struct {
	PowerPercentage   sdk.Dec
	PerformanceScore  sdk.Dec
	DistributionScore sdk.Dec

	*icstypes.Validator
}

Validator is an internal struct to track transient state for the calculation of zone scores. It contains all relevant Validator scoring metrics with a pointer reference to the actual Validator (embedded).

type ZoneScore 

type ZoneScore struct {
	ZoneID           string // chainID
	TotalVotingPower math.Int
	ValidatorScores  map[string]*Validator
}

ZoneScore is an internal struct to track transient state for the calculation of zone scores. It specifically tallies the total zone voting power used in calculations to determine validator voting power percentages.

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.