types

package
v0.2.0-rc1 Latest Latest
Warning

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

 Go to latest Published: Aug 16, 2023 License: Apache-2.0 Imports: 45 Imported by: 3

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	OjoDenom        string = appparams.BondDenom
	OjoSymbol       string = "ojo"
	OjoExponent            = uint32(6)
	AtomDenom       string = "ibc/C4CFF46FD6DE35CA4CF4CE031E643C8FDC9BA4B99AE598E9B0ED98FE3A2319F9"
	AtomSymbol      string = "atom"
	AtomExponent           = uint32(6)
	USDDenom        string = "USD"
	BlocksPerMinute        = uint64(10)
	BlocksPerHour          = BlocksPerMinute * 60
	BlocksPerDay           = BlocksPerHour * 24
	BlocksPerWeek          = BlocksPerDay * 7
	BlocksPerMonth         = BlocksPerDay * 30
	BlocksPerYear          = BlocksPerDay * 365
	MicroUnit              = int64(1e6)
)
View Source 
const (
	// ModuleName is the name of the oracle module
	ModuleName = "oracle"

	// StoreKey is the string store representation
	StoreKey = ModuleName

	// RouterKey is the message route
	RouterKey = ModuleName

	// QuerierRoute is the query router key for the oracle module
	QuerierRoute = ModuleName
)
View Source 
const (
	MaxVoteThresholdPrecision  = 2
	MaxVoteThresholdMultiplier = 100 // must be 10^MaxVoteThresholdPrecision
)

maxium number of decimals allowed for VoteThreshold

View Source 
const (
	DefaultVotePeriod               = BlocksPerMinute * 3 / 10 // 18 seconds
	DefaultSlashWindow              = BlocksPerWeek            // window for a week
	DefaultRewardDistributionWindow = BlocksPerYear            // window for a year
	DefaultHistoricStampPeriod      = BlocksPerMinute * 3      // window for 3 minutes
	DefaultMaximumPriceStamps       = 60                       // retain for 3 hours
	DefaultMedianStampPeriod        = BlocksPerHour * 3        // window for 3 hours
	DefaultMaximumMedianStamps      = 24                       // retain for 3 days
)

Default parameter values

Variables

View Source 
var (
	ErrInvalidExchangeRate   = errors.Register(ModuleName, 2, "invalid exchange rate")
	ErrNoPrevote             = errors.Register(ModuleName, 3, "no prevote")
	ErrNoVote                = errors.Register(ModuleName, 4, "no vote")
	ErrNoVotingPermission    = errors.Register(ModuleName, 5, "unauthorized voter")
	ErrInvalidHash           = errors.Register(ModuleName, 6, "invalid hash")
	ErrInvalidHashLength     = errors.Register(ModuleName, 7, fmt.Sprintf("invalid hash length; should equal %d", tmhash.TruncatedSize)) //nolint: lll
	ErrVerificationFailed    = errors.Register(ModuleName, 8, "hash verification failed")
	ErrRevealPeriodMissMatch = errors.Register(ModuleName, 9, "reveal period of submitted vote does not match with registered prevote") //nolint: lll
	ErrInvalidSaltLength     = errors.Register(ModuleName, 10, "invalid salt length; must be 64")
	ErrInvalidSaltFormat     = errors.Register(ModuleName, 11, "invalid salt format")
	ErrNoAggregatePrevote    = errors.Register(ModuleName, 12, "no aggregate prevote")
	ErrNoAggregateVote       = errors.Register(ModuleName, 13, "no aggregate vote")
	ErrUnknownDenom          = errors.Register(ModuleName, 14, "unknown denom")
	ErrNegativeOrZeroRate    = errors.Register(ModuleName, 15, "invalid exchange rate; should be positive")
	ErrExistingPrevote       = errors.Register(ModuleName, 16, "prevote already submitted for this voting period")
	ErrBallotNotSorted       = errors.Register(ModuleName, 17, "ballot must be sorted before this operation")
	ErrInvalidOraclePrice    = errors.Register(ModuleName, 18, "invalid or unavailable oracle price")
	ErrNoHistoricPrice       = errors.Register(ModuleName, 19, "no historic price for this denom at this block")
	ErrNoMedian              = errors.Register(ModuleName, 20, "no median for this denom at this block")
	ErrNoMedianDeviation     = errors.Register(ModuleName, 21, "no median deviation for this denom at this block")
	ErrNoRewardBand          = errors.Register(ModuleName, 22, "unable to find the reward band the given asset")
	ErrNoValidatorRewardSet  = errors.Register(ModuleName, 23, "unable to find the latest validator reward set")
	ErrNoGovAuthority        = errors.Register(ModuleName, 24, "invalid gov authority to perform these changes")
)

Oracle sentinel errors

View Source 
var (
	ErrInvalidLengthEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	KeyPrefixExchangeRate                 = []byte{0x01} // prefix for each key to a rate
	KeyPrefixFeederDelegation             = []byte{0x02} // prefix for each key to a feeder delegation
	KeyPrefixMissCounter                  = []byte{0x03} // prefix for each key to a miss counter
	KeyPrefixAggregateExchangeRatePrevote = []byte{0x04} // prefix for each key to a aggregate prevote
	KeyPrefixAggregateExchangeRateVote    = []byte{0x05} // prefix for each key to a aggregate vote
	KeyPrefixMedian                       = []byte{0x06} // prefix for each key to a price median
	KeyPrefixMedianDeviation              = []byte{0x07} // prefix for each key to a price median standard deviation
	KeyPrefixHistoricPrice                = []byte{0x08} // prefix for each key to a historic price
	KeyPrefixValidatorRewardSet           = []byte{0x09} // prefix for each key to a validator reward set
)

KVStore key prefixes

View Source 
var (
	ErrInvalidLengthOracle        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowOracle          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupOracle = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	KeyVotePeriod               = []byte("VotePeriod")
	KeyVoteThreshold            = []byte("VoteThreshold")
	KeyRewardBands              = []byte("RewardBands")
	KeyRewardDistributionWindow = []byte("RewardDistributionWindow")
	KeyAcceptList               = []byte("AcceptList")
	KeyMandatoryList            = []byte("MandatoryList")
	KeySlashFraction            = []byte("SlashFraction")
	KeySlashWindow              = []byte("SlashWindow")
	KeyMinValidPerWindow        = []byte("MinValidPerWindow")
	KeyHistoricStampPeriod      = []byte("HistoricStampPeriod")
	KeyMedianStampPeriod        = []byte("MedianStampPeriod")
	KeyMaximumPriceStamps       = []byte("MaximumPriceStamps")
	KeyMaximumMedianStamps      = []byte("MaximumMedianStamps")
)

Parameter keys

View Source 
var (
	DefaultVoteThreshold = sdk.NewDecWithPrec(50, 2) // 50%

	DefaultAcceptList = DenomList{
		{
			BaseDenom:   OjoDenom,
			SymbolDenom: OjoSymbol,
			Exponent:    OjoExponent,
		},
		{
			BaseDenom:   AtomDenom,
			SymbolDenom: AtomSymbol,
			Exponent:    AtomExponent,
		},
	}
	DefaultMandatoryList = DenomList{
		{
			BaseDenom:   AtomDenom,
			SymbolDenom: AtomSymbol,
			Exponent:    AtomExponent,
		},
	}
	DefaultSlashFraction     = sdk.NewDecWithPrec(1, 4) // 0.01%
	DefaultMinValidPerWindow = sdk.NewDecWithPrec(5, 2) // 5%
)

Default parameter values

View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (

	// ModuleCdc references the global x/oracle module codec. Note, the codec should
	// ONLY be used in certain instances of tests and for JSON encoding as Amino is
	// still used for that purpose.
	//
	// The actual codec used for serialization should be provided to x/staking and
	// defined at the application level.
	ModuleCdc = codec.NewAminoCodec(amino)
)

Functions

func ClaimMapToSlices added in v0.1.3 

func ClaimMapToSlices(claims map[string]Claim, rewardSet []string) ([]Claim, []Claim)

ClaimMapToSlices returns an array of sorted exchange rate ballots and uses the rewardSet to return a second array of claims that are eligible to earn rewards in the current Slash Window.

func GetAggregateExchangeRatePrevoteKey 

func GetAggregateExchangeRatePrevoteKey(v sdk.ValAddress) (key []byte)

GetAggregateExchangeRatePrevoteKey - stored by *Validator* address

func GetAggregateExchangeRateVoteKey 

func GetAggregateExchangeRateVoteKey(v sdk.ValAddress) (key []byte)

GetAggregateExchangeRateVoteKey - stored by *Validator* address

func GetExchangeRateKey 

func GetExchangeRateKey(denom string) (key []byte)

GetExchangeRateKey - stored by *denom*

func GetFeederDelegationKey 

func GetFeederDelegationKey(v sdk.ValAddress) (key []byte)

GetFeederDelegationKey - stored by *Validator* address

func GetMissCounterKey 

func GetMissCounterKey(v sdk.ValAddress) (key []byte)

GetMissCounterKey - stored by *Validator* address

func KeyHistoricPrice 

func KeyHistoricPrice(denom string, blockNum uint64) (key []byte)

KeyHistoricPrice - stored by *denom* and *block*

func KeyMedian 

func KeyMedian(denom string, blockNum uint64) (key []byte)

KeyMedian - stored by *denom*

func KeyMedianDeviation 

func KeyMedianDeviation(denom string, blockNum uint64) (key []byte)

KeyMedianDeviation - stored by *denom*

func KeyValidatorRewardSet added in v0.1.3 

func KeyValidatorRewardSet() (key []byte)

KeyValidatorRewardSet - stored by *block*

func ParamKeyTable 

func ParamKeyTable() paramstypes.KeyTable

ParamKeyTable returns the parameter key table.

func ParseDenomAndBlockFromKey 

func ParseDenomAndBlockFromKey(key []byte, prefix []byte) (string, uint64)

ParseDenomAndBlockFromKey returns the denom and block contained in the *key* that has a uint64 at the end with a null prefix (length 9).

func ParseExchangeRateDecCoins added in v0.1.2 

func ParseExchangeRateDecCoins(tuplesStr string) (sdk.DecCoins, error)

ParseExchangeRateDecCoins DecCoins parser

func RegisterInterfaces 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

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

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec registers the necessary x/oracle interfaces and concrete types on the provided LegacyAmino codec. These types are used for Amino JSON serialization.

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)

func ValidateGenesis 

func ValidateGenesis(data *GenesisState) error

ValidateGenesis validates the oracle genesis state.

Types

type AccountKeeper 

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

	// only used for simulation
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
}

AccountKeeper defines the expected interface contract defined by the x/auth module.

type AggregateExchangeRatePrevote 

type AggregateExchangeRatePrevote struct {
	Hash        string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty" yaml:"hash"`
	Voter       string `protobuf:"bytes,2,opt,name=voter,proto3" json:"voter,omitempty" yaml:"voter"`
	SubmitBlock uint64 `protobuf:"varint,3,opt,name=submit_block,json=submitBlock,proto3" json:"submit_block,omitempty" yaml:"submit_block"`
}

AggregateExchangeRatePrevote - struct for aggregate prevoting on the ExchangeRateVote. The purpose of aggregate prevote is to hide vote exchange rates with hash which is formatted as hex string in SHA256("{salt}:{exchange rate}{denom},...,{exchange rate}{denom}:{voter}")

func NewAggregateExchangeRatePrevote 

func NewAggregateExchangeRatePrevote(
	hash AggregateVoteHash,
	voter sdk.ValAddress,
	submitBlock uint64,
) AggregateExchangeRatePrevote

func (*AggregateExchangeRatePrevote) Descriptor 

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

func (*AggregateExchangeRatePrevote) Marshal 

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

func (*AggregateExchangeRatePrevote) MarshalTo 

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

func (*AggregateExchangeRatePrevote) MarshalToSizedBuffer 

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

func (*AggregateExchangeRatePrevote) ProtoMessage 

func (*AggregateExchangeRatePrevote) ProtoMessage()

func (*AggregateExchangeRatePrevote) Reset 

func (m *AggregateExchangeRatePrevote) Reset()

func (*AggregateExchangeRatePrevote) Size 

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

func (AggregateExchangeRatePrevote) String 

func (v AggregateExchangeRatePrevote) String() string

String implement stringify

func (*AggregateExchangeRatePrevote) Unmarshal 

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

func (*AggregateExchangeRatePrevote) XXX_DiscardUnknown 

func (m *AggregateExchangeRatePrevote) XXX_DiscardUnknown()

func (*AggregateExchangeRatePrevote) XXX_Marshal 

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

func (*AggregateExchangeRatePrevote) XXX_Merge 

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

func (*AggregateExchangeRatePrevote) XXX_Size 

func (m *AggregateExchangeRatePrevote) XXX_Size() int

func (*AggregateExchangeRatePrevote) XXX_Unmarshal 

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

type AggregateExchangeRateVote 

type AggregateExchangeRateVote struct {
	ExchangeRates github_com_cosmos_cosmos_sdk_types.DecCoins `` /* 147-byte string literal not displayed */
	Voter         string                                      `protobuf:"bytes,2,opt,name=voter,proto3" json:"voter,omitempty" yaml:"voter"`
}

AggregateExchangeRateVote - struct for voting on the exchange rates of USD denominated in various assets.

func NewAggregateExchangeRateVote 

func NewAggregateExchangeRateVote(
	decCoins sdk.DecCoins,
	voter sdk.ValAddress,
) AggregateExchangeRateVote

func (*AggregateExchangeRateVote) Descriptor 

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

func (*AggregateExchangeRateVote) Marshal 

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

func (*AggregateExchangeRateVote) MarshalTo 

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

func (*AggregateExchangeRateVote) MarshalToSizedBuffer 

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

func (*AggregateExchangeRateVote) ProtoMessage 

func (*AggregateExchangeRateVote) ProtoMessage()

func (*AggregateExchangeRateVote) Reset 

func (m *AggregateExchangeRateVote) Reset()

func (*AggregateExchangeRateVote) Size 

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

func (AggregateExchangeRateVote) String 

func (v AggregateExchangeRateVote) String() string

String implement stringify

func (*AggregateExchangeRateVote) Unmarshal 

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

func (*AggregateExchangeRateVote) XXX_DiscardUnknown 

func (m *AggregateExchangeRateVote) XXX_DiscardUnknown()

func (*AggregateExchangeRateVote) XXX_Marshal 

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

func (*AggregateExchangeRateVote) XXX_Merge 

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

func (*AggregateExchangeRateVote) XXX_Size 

func (m *AggregateExchangeRateVote) XXX_Size() int

func (*AggregateExchangeRateVote) XXX_Unmarshal 

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

type AggregateVoteHash 

type AggregateVoteHash []byte

AggregateVoteHash is hash value to hide vote exchange rates which is formatted as a HEX string: SHA256("{salt}:{symbol}:{exchangeRate},...,{symbol}:{exchangeRate}:{voter}")

func AggregateVoteHashFromHexString 

func AggregateVoteHashFromHexString(s string) (AggregateVoteHash, error)

AggregateVoteHashFromHexString convert hex string to AggregateVoteHash.

func GetAggregateVoteHash 

func GetAggregateVoteHash(salt, exchangeRatesStr string, voter sdk.ValAddress) AggregateVoteHash

GetAggregateVoteHash computes hash value of ExchangeRateVote to avoid redundant DecCoins stringify operation.

func (AggregateVoteHash) Bytes 

func (h AggregateVoteHash) Bytes() []byte

Bytes returns the raw address bytes.

func (AggregateVoteHash) Empty 

func (h AggregateVoteHash) Empty() bool

Empty check the name hash has zero length

func (AggregateVoteHash) Equal 

func (h AggregateVoteHash) Equal(h2 AggregateVoteHash) bool

Equal does bytes equal check

func (AggregateVoteHash) Format 

func (h AggregateVoteHash) Format(s fmt.State, verb rune)

Format implements the fmt.Formatter interface.

func (AggregateVoteHash) Marshal 

func (h AggregateVoteHash) Marshal() ([]byte, error)

Marshal returns the raw address bytes. It is needed for protobuf compatibility.

func (AggregateVoteHash) MarshalJSON 

func (h AggregateVoteHash) MarshalJSON() ([]byte, error)

MarshalJSON marshals to JSON using Bech32.

func (AggregateVoteHash) MarshalYAML 

func (h AggregateVoteHash) MarshalYAML() (interface{}, error)

MarshalYAML marshals to YAML using Bech32.

func (AggregateVoteHash) Size 

func (h AggregateVoteHash) Size() int

Size returns the raw address bytes.

func (AggregateVoteHash) String 

func (h AggregateVoteHash) String() string

String implements fmt.Stringer interface

func (*AggregateVoteHash) Unmarshal 

func (h *AggregateVoteHash) Unmarshal(data []byte) error

Unmarshal sets the address to the given data. It is needed for protobuf compatibility.

func (*AggregateVoteHash) UnmarshalJSON 

func (h *AggregateVoteHash) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshals from JSON assuming Bech32 encoding.

type BallotDenom 

type BallotDenom struct {
	Ballot ExchangeRateBallot
	Denom  string
}

BallotDenom is a convenience wrapper for setting rates deterministically.

func BallotMapToSlice 

func BallotMapToSlice(votes map[string]ExchangeRateBallot) []BallotDenom

BallotMapToSlice returns an array of sorted exchange rate ballots.

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
	SendCoinsFromModuleToModule(ctx sdk.Context, senderModule, recipientModule string, amt sdk.Coins) error
	GetDenomMetaData(ctx sdk.Context, denom string) (banktypes.Metadata, bool)
	SetDenomMetaData(ctx sdk.Context, denomMetaData banktypes.Metadata)
}

BankKeeper defines the expected interface contract defined by the x/bank module.

type Claim 

type Claim struct {
	Power             int64
	Weight            int64
	MandatoryWinCount int64
	Recipient         sdk.ValAddress
}

Claim is an interface that directs its rewards to an attached bank account.

func NewClaim 

func NewClaim(power, weight, mandatoryWinCount int64, recipient sdk.ValAddress) Claim

NewClaim generates a Claim instance.

type Denom 

type Denom struct {
	BaseDenom   string `protobuf:"bytes,1,opt,name=base_denom,json=baseDenom,proto3" json:"base_denom,omitempty" yaml:"base_denom"`
	SymbolDenom string `protobuf:"bytes,2,opt,name=symbol_denom,json=symbolDenom,proto3" json:"symbol_denom,omitempty" yaml:"symbol_denom"`
	Exponent    uint32 `protobuf:"varint,3,opt,name=exponent,proto3" json:"exponent,omitempty" yaml:"exponent"`
}

Denom - the object to hold configurations of each denom

func (*Denom) Descriptor 

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

func (Denom) Equal 

func (d Denom) Equal(d1 *Denom) bool

Equal implements equal interface

func (*Denom) Marshal 

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

func (*Denom) MarshalTo 

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

func (*Denom) MarshalToSizedBuffer 

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

func (*Denom) ProtoMessage 

func (*Denom) ProtoMessage()

func (*Denom) Reset 

func (m *Denom) Reset()

func (*Denom) Size 

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

func (Denom) String 

func (d Denom) String() string

String implements fmt.Stringer interface

func (*Denom) Unmarshal 

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

func (*Denom) XXX_DiscardUnknown 

func (m *Denom) XXX_DiscardUnknown()

func (*Denom) XXX_Marshal 

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

func (*Denom) XXX_Merge 

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

func (*Denom) XXX_Size 

func (m *Denom) XXX_Size() int

func (*Denom) XXX_Unmarshal 

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

type DenomList 

type DenomList []Denom

DenomList is array of Denom

func (DenomList) ContainDenoms 

func (dl DenomList) ContainDenoms(d DenomList) bool

ContainDenoms checks if d is a subset of dl

func (DenomList) Contains 

func (dl DenomList) Contains(symbolDenom string) bool

Contains checks whether or not a SymbolDenom (e.g. OJO) is in the DenomList

func (DenomList) Normalize added in v0.1.4 

func (dl DenomList) Normalize() DenomList

Normalize updates all the SymbolDenom strings to use all caps.

func (DenomList) String 

func (dl DenomList) String() (out string)

String implements fmt.Stringer interface

type DistributionKeeper 

type DistributionKeeper interface {
	AllocateTokensToValidator(ctx sdk.Context, val stakingtypes.ValidatorI, tokens sdk.DecCoins)
	GetValidatorOutstandingRewardsCoins(ctx sdk.Context, val sdk.ValAddress) sdk.DecCoins
}

DistributionKeeper defines the expected interface contract defined by the x/distribution module.

type EventDelegateFeedConsent 

type EventDelegateFeedConsent struct {
	// Operator bech32 address who delegates his feed consent
	Operator string `protobuf:"bytes,1,opt,name=operator,proto3" json:"operator,omitempty"`
	// Delegate bech32 address
	Delegate string `protobuf:"bytes,2,opt,name=delegate,proto3" json:"delegate,omitempty"`
}

EventDelegateFeedConsent is emitted on Msg/DelegateFeedConsent

func (*EventDelegateFeedConsent) Descriptor 

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

func (*EventDelegateFeedConsent) Marshal 

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

func (*EventDelegateFeedConsent) MarshalTo 

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

func (*EventDelegateFeedConsent) MarshalToSizedBuffer 

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

func (*EventDelegateFeedConsent) ProtoMessage 

func (*EventDelegateFeedConsent) ProtoMessage()

func (*EventDelegateFeedConsent) Reset 

func (m *EventDelegateFeedConsent) Reset()

func (*EventDelegateFeedConsent) Size 

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

func (*EventDelegateFeedConsent) String 

func (m *EventDelegateFeedConsent) String() string

func (*EventDelegateFeedConsent) Unmarshal 

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

func (*EventDelegateFeedConsent) XXX_DiscardUnknown 

func (m *EventDelegateFeedConsent) XXX_DiscardUnknown()

func (*EventDelegateFeedConsent) XXX_Marshal 

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

func (*EventDelegateFeedConsent) XXX_Merge 

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

func (*EventDelegateFeedConsent) XXX_Size 

func (m *EventDelegateFeedConsent) XXX_Size() int

func (*EventDelegateFeedConsent) XXX_Unmarshal 

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

type EventSetFxRate 

type EventSetFxRate struct {
	// uToken denom
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
	// Exchange rate (based to USD)
	Rate github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,2,opt,name=rate,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"rate"`
}

EventSetFxRate is emitted on exchange rate update

func (*EventSetFxRate) Descriptor 

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

func (*EventSetFxRate) Marshal 

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

func (*EventSetFxRate) MarshalTo 

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

func (*EventSetFxRate) MarshalToSizedBuffer 

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

func (*EventSetFxRate) ProtoMessage 

func (*EventSetFxRate) ProtoMessage()

func (*EventSetFxRate) Reset 

func (m *EventSetFxRate) Reset()

func (*EventSetFxRate) Size 

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

func (*EventSetFxRate) String 

func (m *EventSetFxRate) String() string

func (*EventSetFxRate) Unmarshal 

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

func (*EventSetFxRate) XXX_DiscardUnknown 

func (m *EventSetFxRate) XXX_DiscardUnknown()

func (*EventSetFxRate) XXX_Marshal 

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

func (*EventSetFxRate) XXX_Merge 

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

func (*EventSetFxRate) XXX_Size 

func (m *EventSetFxRate) XXX_Size() int

func (*EventSetFxRate) XXX_Unmarshal 

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

type ExchangeRateBallot 

type ExchangeRateBallot []VoteForTally

ExchangeRateBallot is a convenience wrapper around a ExchangeRateVote slice.

func (ExchangeRateBallot) Len 

func (pb ExchangeRateBallot) Len() int

Len implements sort.Interface

func (ExchangeRateBallot) Less 

func (pb ExchangeRateBallot) Less(i, j int) bool

Less reports whether the element with index i should sort before the element with index j.

func (ExchangeRateBallot) Power 

func (pb ExchangeRateBallot) Power() int64

Power returns the total amount of voting power in the ballot.

func (ExchangeRateBallot) StandardDeviation 

func (pb ExchangeRateBallot) StandardDeviation() (sdk.Dec, error)

StandardDeviation returns the standard deviation by the power of the ExchangeRateVote.

func (ExchangeRateBallot) Swap 

func (pb ExchangeRateBallot) Swap(i, j int)

Swap implements sort.Interface.

func (ExchangeRateBallot) ToMap 

func (pb ExchangeRateBallot) ToMap() map[string]sdk.Dec

ToMap return organized exchange rate map by validator.

func (ExchangeRateBallot) WeightedMedian added in v0.1.3 

func (pb ExchangeRateBallot) WeightedMedian() (sdk.Dec, error)

WeightedMedian returns the median weighted by the power of the ExchangeRateVote. CONTRACT: The ballot must be sorted.

type ExchangeRatePrevote 

type ExchangeRatePrevote struct {
	Hash        VoteHash       `json:"hash"`         // Vote hex hash to protect centralize data source problem
	Denom       string         `json:"denom"`        // Ticker symbol of denomination exchanged against USD
	Voter       sdk.ValAddress `json:"voter"`        // Voter validator address
	SubmitBlock int64          `json:"submit_block"` // Block height at submission
}

ExchangeRatePrevote defines a structure to store a validator's prevote on the rate of USD in the denom asset.

type ExchangeRateVote 

type ExchangeRateVote struct {
	ExchangeRate sdk.Dec        `json:"exchange_rate"` // Exchange rate of a denomination against USD
	Denom        string         `json:"denom"`         // Ticker symbol of denomination exchanged against USD
	Voter        sdk.ValAddress `json:"voter"`         // Voter validator address
}

ExchangeRateVote defines a structure to store a validator's vote on the rate of USD in the denom asset.

type FeederDelegation 

type FeederDelegation struct {
	FeederAddress    string `protobuf:"bytes,1,opt,name=feeder_address,json=feederAddress,proto3" json:"feeder_address,omitempty"`
	ValidatorAddress string `protobuf:"bytes,2,opt,name=validator_address,json=validatorAddress,proto3" json:"validator_address,omitempty"`
}

FeederDelegation is the address for where oracle feeder authority are delegated to. By default this struct is only used at genesis to feed in default feeder addresses.

func (*FeederDelegation) Descriptor 

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

func (*FeederDelegation) Marshal 

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

func (*FeederDelegation) MarshalTo 

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

func (*FeederDelegation) MarshalToSizedBuffer 

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

func (*FeederDelegation) ProtoMessage 

func (*FeederDelegation) ProtoMessage()

func (*FeederDelegation) Reset 

func (m *FeederDelegation) Reset()

func (*FeederDelegation) Size 

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

func (*FeederDelegation) String 

func (m *FeederDelegation) String() string

func (*FeederDelegation) Unmarshal 

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

func (*FeederDelegation) XXX_DiscardUnknown 

func (m *FeederDelegation) XXX_DiscardUnknown()

func (*FeederDelegation) XXX_Marshal 

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

func (*FeederDelegation) XXX_Merge 

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

func (*FeederDelegation) XXX_Size 

func (m *FeederDelegation) XXX_Size() int

func (*FeederDelegation) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	Params                        Params                                      `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	FeederDelegations             []FeederDelegation                          `protobuf:"bytes,2,rep,name=feeder_delegations,json=feederDelegations,proto3" json:"feeder_delegations"`
	ExchangeRates                 github_com_cosmos_cosmos_sdk_types.DecCoins `` /* 147-byte string literal not displayed */
	MissCounters                  []MissCounter                               `protobuf:"bytes,4,rep,name=miss_counters,json=missCounters,proto3" json:"miss_counters"`
	AggregateExchangeRatePrevotes []AggregateExchangeRatePrevote              `` /* 142-byte string literal not displayed */
	AggregateExchangeRateVotes    []AggregateExchangeRateVote                 `` /* 133-byte string literal not displayed */
	Medians                       []PriceStamp                                `protobuf:"bytes,7,rep,name=medians,proto3" json:"medians"`
	HistoricPrices                []PriceStamp                                `protobuf:"bytes,8,rep,name=historic_prices,json=historicPrices,proto3" json:"historic_prices"`
	MedianDeviations              []PriceStamp                                `protobuf:"bytes,9,rep,name=medianDeviations,proto3" json:"medianDeviations"`
}

GenesisState defines the oracle module's genesis state.

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

DefaultGenesisState returns the default genesesis state for the x/oracle module.

func GetGenesisStateFromAppState 

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

GetGenesisStateFromAppState returns x/oracle GenesisState given raw application genesis state.

func NewGenesisState 

func NewGenesisState(
	params Params,
	rates sdk.DecCoins,
	feederDelegations []FeederDelegation,
	missCounters []MissCounter,
	aggregateExchangeRatePrevotes []AggregateExchangeRatePrevote,
	aggregateExchangeRateVotes []AggregateExchangeRateVote,
	historicPrices []PriceStamp,
	medianPrices []PriceStamp,
	medianDeviationPrices []PriceStamp,
) *GenesisState

NewGenesisState creates a new GenesisState object

func (*GenesisState) Descriptor 

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

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type MissCounter 

type MissCounter struct {
	ValidatorAddress string `protobuf:"bytes,1,opt,name=validator_address,json=validatorAddress,proto3" json:"validator_address,omitempty"`
	MissCounter      uint64 `protobuf:"varint,2,opt,name=miss_counter,json=missCounter,proto3" json:"miss_counter,omitempty"`
}

MissCounter defines an miss counter and validator address pair used in oracle module's genesis state

func (*MissCounter) Descriptor 

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

func (*MissCounter) Marshal 

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

func (*MissCounter) MarshalTo 

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

func (*MissCounter) MarshalToSizedBuffer 

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

func (*MissCounter) ProtoMessage 

func (*MissCounter) ProtoMessage()

func (*MissCounter) Reset 

func (m *MissCounter) Reset()

func (*MissCounter) Size 

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

func (*MissCounter) String 

func (m *MissCounter) String() string

func (*MissCounter) Unmarshal 

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

func (*MissCounter) XXX_DiscardUnknown 

func (m *MissCounter) XXX_DiscardUnknown()

func (*MissCounter) XXX_Marshal 

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

func (*MissCounter) XXX_Merge 

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

func (*MissCounter) XXX_Size 

func (m *MissCounter) XXX_Size() int

func (*MissCounter) XXX_Unmarshal 

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

type MsgAggregateExchangeRatePrevote 

type MsgAggregateExchangeRatePrevote struct {
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty" yaml:"hash"`
	// Feeder is the author and the signer of the message.
	Feeder    string `protobuf:"bytes,2,opt,name=feeder,proto3" json:"feeder,omitempty" yaml:"feeder"`
	Validator string `protobuf:"bytes,3,opt,name=validator,proto3" json:"validator,omitempty" yaml:"validator"`
}

MsgAggregateExchangeRatePrevote represents a message to submit an aggregate exchange rate prevote.

func NewMsgAggregateExchangeRatePrevote 

func NewMsgAggregateExchangeRatePrevote(
	hash AggregateVoteHash,
	feeder sdk.AccAddress,
	validator sdk.ValAddress,
) *MsgAggregateExchangeRatePrevote

func (*MsgAggregateExchangeRatePrevote) Descriptor 

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

func (MsgAggregateExchangeRatePrevote) GetSignBytes 

func (msg MsgAggregateExchangeRatePrevote) GetSignBytes() []byte

GetSignBytes implements sdk.Msg

func (MsgAggregateExchangeRatePrevote) GetSigners 

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

GetSigners implements sdk.Msg

func (*MsgAggregateExchangeRatePrevote) Marshal 

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

func (*MsgAggregateExchangeRatePrevote) MarshalTo 

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

func (*MsgAggregateExchangeRatePrevote) MarshalToSizedBuffer 

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

func (*MsgAggregateExchangeRatePrevote) ProtoMessage 

func (*MsgAggregateExchangeRatePrevote) ProtoMessage()

func (*MsgAggregateExchangeRatePrevote) Reset 

func (m *MsgAggregateExchangeRatePrevote) Reset()

func (*MsgAggregateExchangeRatePrevote) Size 

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

func (*MsgAggregateExchangeRatePrevote) String 

func (m *MsgAggregateExchangeRatePrevote) String() string

func (MsgAggregateExchangeRatePrevote) Type 

func (msg MsgAggregateExchangeRatePrevote) Type() string

Type implements LegacyMsg interface

func (*MsgAggregateExchangeRatePrevote) Unmarshal 

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

func (MsgAggregateExchangeRatePrevote) ValidateBasic 

func (msg MsgAggregateExchangeRatePrevote) ValidateBasic() error

ValidateBasic Implements sdk.Msg

func (*MsgAggregateExchangeRatePrevote) XXX_DiscardUnknown 

func (m *MsgAggregateExchangeRatePrevote) XXX_DiscardUnknown()

func (*MsgAggregateExchangeRatePrevote) XXX_Marshal 

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

func (*MsgAggregateExchangeRatePrevote) XXX_Merge 

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

func (*MsgAggregateExchangeRatePrevote) XXX_Size 

func (m *MsgAggregateExchangeRatePrevote) XXX_Size() int

func (*MsgAggregateExchangeRatePrevote) XXX_Unmarshal 

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

type MsgAggregateExchangeRatePrevoteResponse 

type MsgAggregateExchangeRatePrevoteResponse struct {
}

MsgAggregateExchangeRatePrevoteResponse defines the Msg/AggregateExchangeRatePrevote response type.

func (*MsgAggregateExchangeRatePrevoteResponse) Descriptor 

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

func (*MsgAggregateExchangeRatePrevoteResponse) Marshal 

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

func (*MsgAggregateExchangeRatePrevoteResponse) MarshalTo 

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

func (*MsgAggregateExchangeRatePrevoteResponse) MarshalToSizedBuffer 

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

func (*MsgAggregateExchangeRatePrevoteResponse) ProtoMessage 

func (*MsgAggregateExchangeRatePrevoteResponse) ProtoMessage()

func (*MsgAggregateExchangeRatePrevoteResponse) Reset 

func (m *MsgAggregateExchangeRatePrevoteResponse) Reset()

func (*MsgAggregateExchangeRatePrevoteResponse) Size 

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

func (*MsgAggregateExchangeRatePrevoteResponse) String 

func (m *MsgAggregateExchangeRatePrevoteResponse) String() string

func (*MsgAggregateExchangeRatePrevoteResponse) Unmarshal 

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

func (*MsgAggregateExchangeRatePrevoteResponse) XXX_DiscardUnknown 

func (m *MsgAggregateExchangeRatePrevoteResponse) XXX_DiscardUnknown()

func (*MsgAggregateExchangeRatePrevoteResponse) XXX_Marshal 

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

func (*MsgAggregateExchangeRatePrevoteResponse) XXX_Merge 

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

func (*MsgAggregateExchangeRatePrevoteResponse) XXX_Size 

func (m *MsgAggregateExchangeRatePrevoteResponse) XXX_Size() int

func (*MsgAggregateExchangeRatePrevoteResponse) XXX_Unmarshal 

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

type MsgAggregateExchangeRateVote 

type MsgAggregateExchangeRateVote struct {
	Salt          string `protobuf:"bytes,1,opt,name=salt,proto3" json:"salt,omitempty" yaml:"salt"`
	ExchangeRates string `protobuf:"bytes,2,opt,name=exchange_rates,json=exchangeRates,proto3" json:"exchange_rates,omitempty" yaml:"exchange_rates"`
	// Feeder is the author and the signer of the message.
	Feeder    string `protobuf:"bytes,3,opt,name=feeder,proto3" json:"feeder,omitempty" yaml:"feeder"`
	Validator string `protobuf:"bytes,4,opt,name=validator,proto3" json:"validator,omitempty" yaml:"validator"`
}

MsgAggregateExchangeRateVote represents a message to submit anaggregate exchange rate vote.

func NewMsgAggregateExchangeRateVote 

func NewMsgAggregateExchangeRateVote(
	salt string,
	exchangeRates string,
	feeder sdk.AccAddress,
	validator sdk.ValAddress,
) *MsgAggregateExchangeRateVote

func (*MsgAggregateExchangeRateVote) Descriptor 

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

func (MsgAggregateExchangeRateVote) GetSignBytes 

func (msg MsgAggregateExchangeRateVote) GetSignBytes() []byte

GetSignBytes implements sdk.Msg

func (MsgAggregateExchangeRateVote) GetSigners 

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

GetSigners implements sdk.Msg

func (*MsgAggregateExchangeRateVote) Marshal 

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

func (*MsgAggregateExchangeRateVote) MarshalTo 

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

func (*MsgAggregateExchangeRateVote) MarshalToSizedBuffer 

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

func (*MsgAggregateExchangeRateVote) ProtoMessage 

func (*MsgAggregateExchangeRateVote) ProtoMessage()

func (*MsgAggregateExchangeRateVote) Reset 

func (m *MsgAggregateExchangeRateVote) Reset()

func (*MsgAggregateExchangeRateVote) Size 

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

func (*MsgAggregateExchangeRateVote) String 

func (m *MsgAggregateExchangeRateVote) String() string

func (MsgAggregateExchangeRateVote) Type 

func (msg MsgAggregateExchangeRateVote) Type() string

Type implements LegacyMsg interface

func (*MsgAggregateExchangeRateVote) Unmarshal 

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

func (MsgAggregateExchangeRateVote) ValidateBasic 

func (msg MsgAggregateExchangeRateVote) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgAggregateExchangeRateVote) XXX_DiscardUnknown 

func (m *MsgAggregateExchangeRateVote) XXX_DiscardUnknown()

func (*MsgAggregateExchangeRateVote) XXX_Marshal 

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

func (*MsgAggregateExchangeRateVote) XXX_Merge 

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

func (*MsgAggregateExchangeRateVote) XXX_Size 

func (m *MsgAggregateExchangeRateVote) XXX_Size() int

func (*MsgAggregateExchangeRateVote) XXX_Unmarshal 

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

type MsgAggregateExchangeRateVoteResponse 

type MsgAggregateExchangeRateVoteResponse struct {
}

MsgAggregateExchangeRateVoteResponse defines the Msg/AggregateExchangeRateVote response type.

func (*MsgAggregateExchangeRateVoteResponse) Descriptor 

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

func (*MsgAggregateExchangeRateVoteResponse) Marshal 

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

func (*MsgAggregateExchangeRateVoteResponse) MarshalTo 

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

func (*MsgAggregateExchangeRateVoteResponse) MarshalToSizedBuffer 

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

func (*MsgAggregateExchangeRateVoteResponse) ProtoMessage 

func (*MsgAggregateExchangeRateVoteResponse) ProtoMessage()

func (*MsgAggregateExchangeRateVoteResponse) Reset 

func (m *MsgAggregateExchangeRateVoteResponse) Reset()

func (*MsgAggregateExchangeRateVoteResponse) Size 

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

func (*MsgAggregateExchangeRateVoteResponse) String 

func (m *MsgAggregateExchangeRateVoteResponse) String() string

func (*MsgAggregateExchangeRateVoteResponse) Unmarshal 

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

func (*MsgAggregateExchangeRateVoteResponse) XXX_DiscardUnknown 

func (m *MsgAggregateExchangeRateVoteResponse) XXX_DiscardUnknown()

func (*MsgAggregateExchangeRateVoteResponse) XXX_Marshal 

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

func (*MsgAggregateExchangeRateVoteResponse) XXX_Merge 

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

func (*MsgAggregateExchangeRateVoteResponse) XXX_Size 

func (m *MsgAggregateExchangeRateVoteResponse) XXX_Size() int

func (*MsgAggregateExchangeRateVoteResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// AggregateExchangeRatePrevote defines a method for submitting an aggregate
	// exchange rate prevote.
	AggregateExchangeRatePrevote(ctx context.Context, in *MsgAggregateExchangeRatePrevote, opts ...grpc.CallOption) (*MsgAggregateExchangeRatePrevoteResponse, error)
	// AggregateExchangeRateVote defines a method for submitting an aggregate
	// exchange rate vote.
	AggregateExchangeRateVote(ctx context.Context, in *MsgAggregateExchangeRateVote, opts ...grpc.CallOption) (*MsgAggregateExchangeRateVoteResponse, error)
	// DelegateFeedConsent defines a method for setting the feeder delegation.
	DelegateFeedConsent(ctx context.Context, in *MsgDelegateFeedConsent, opts ...grpc.CallOption) (*MsgDelegateFeedConsentResponse, error)
	// GovUpdateParams updates the oracle parameters.
	GovUpdateParams(ctx context.Context, in *MsgGovUpdateParams, opts ...grpc.CallOption) (*MsgGovUpdateParamsResponse, 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 MsgDelegateFeedConsent 

type MsgDelegateFeedConsent struct {
	// Operator is the author and the signer of the message.
	Operator string `protobuf:"bytes,1,opt,name=operator,proto3" json:"operator,omitempty" yaml:"operator"`
	Delegate string `protobuf:"bytes,2,opt,name=delegate,proto3" json:"delegate,omitempty" yaml:"delegate"`
}

MsgDelegateFeedConsent represents a message to delegate oracle voting rights to another address.

func NewMsgDelegateFeedConsent 

func NewMsgDelegateFeedConsent(operatorAddress sdk.ValAddress, feederAddress sdk.AccAddress) *MsgDelegateFeedConsent

NewMsgDelegateFeedConsent creates a MsgDelegateFeedConsent instance

func (*MsgDelegateFeedConsent) Descriptor 

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

func (MsgDelegateFeedConsent) GetSignBytes 

func (msg MsgDelegateFeedConsent) GetSignBytes() []byte

GetSignBytes implements sdk.Msg

func (MsgDelegateFeedConsent) GetSigners 

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

GetSigners implements sdk.Msg

func (*MsgDelegateFeedConsent) Marshal 

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

func (*MsgDelegateFeedConsent) MarshalTo 

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

func (*MsgDelegateFeedConsent) MarshalToSizedBuffer 

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

func (*MsgDelegateFeedConsent) ProtoMessage 

func (*MsgDelegateFeedConsent) ProtoMessage()

func (*MsgDelegateFeedConsent) Reset 

func (m *MsgDelegateFeedConsent) Reset()

func (*MsgDelegateFeedConsent) Size 

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

func (*MsgDelegateFeedConsent) String 

func (m *MsgDelegateFeedConsent) String() string

func (MsgDelegateFeedConsent) Type 

func (msg MsgDelegateFeedConsent) Type() string

Type implements LegacyMsg interface

func (*MsgDelegateFeedConsent) Unmarshal 

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

func (MsgDelegateFeedConsent) ValidateBasic 

func (msg MsgDelegateFeedConsent) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgDelegateFeedConsent) XXX_DiscardUnknown 

func (m *MsgDelegateFeedConsent) XXX_DiscardUnknown()

func (*MsgDelegateFeedConsent) XXX_Marshal 

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

func (*MsgDelegateFeedConsent) XXX_Merge 

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

func (*MsgDelegateFeedConsent) XXX_Size 

func (m *MsgDelegateFeedConsent) XXX_Size() int

func (*MsgDelegateFeedConsent) XXX_Unmarshal 

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

type MsgDelegateFeedConsentResponse 

type MsgDelegateFeedConsentResponse struct {
}

MsgDelegateFeedConsentResponse defines the Msg/DelegateFeedConsent response type.

func (*MsgDelegateFeedConsentResponse) Descriptor 

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

func (*MsgDelegateFeedConsentResponse) Marshal 

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

func (*MsgDelegateFeedConsentResponse) MarshalTo 

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

func (*MsgDelegateFeedConsentResponse) MarshalToSizedBuffer 

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

func (*MsgDelegateFeedConsentResponse) ProtoMessage 

func (*MsgDelegateFeedConsentResponse) ProtoMessage()

func (*MsgDelegateFeedConsentResponse) Reset 

func (m *MsgDelegateFeedConsentResponse) Reset()

func (*MsgDelegateFeedConsentResponse) Size 

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

func (*MsgDelegateFeedConsentResponse) String 

func (m *MsgDelegateFeedConsentResponse) String() string

func (*MsgDelegateFeedConsentResponse) Unmarshal 

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

func (*MsgDelegateFeedConsentResponse) XXX_DiscardUnknown 

func (m *MsgDelegateFeedConsentResponse) XXX_DiscardUnknown()

func (*MsgDelegateFeedConsentResponse) XXX_Marshal 

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

func (*MsgDelegateFeedConsentResponse) XXX_Merge 

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

func (*MsgDelegateFeedConsentResponse) XXX_Size 

func (m *MsgDelegateFeedConsentResponse) XXX_Size() int

func (*MsgDelegateFeedConsentResponse) XXX_Unmarshal 

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

type MsgGovUpdateParams added in v0.1.3 

type MsgGovUpdateParams struct {
	// authority is the address of the governance account.
	Authority   string   `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	Title       string   `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	Description string   `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Keys        []string `protobuf:"bytes,4,rep,name=keys,proto3" json:"keys,omitempty"`
	Changes     Params   `protobuf:"bytes,5,opt,name=changes,proto3" json:"changes"`
}

MsgGovUpdateParams defines the Msg/GovUpdateParams request type.

func NewMsgUpdateParams added in v0.1.3 

func NewMsgUpdateParams(authority, title, description string, keys []string, changes Params) *MsgGovUpdateParams

NewMsgUpdateParams will creates a new MsgUpdateParams instance

func (*MsgGovUpdateParams) Descriptor added in v0.1.3 

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

func (*MsgGovUpdateParams) Equal added in v0.1.3 

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

func (*MsgGovUpdateParams) GetDescription added in v0.1.3 

func (msg *MsgGovUpdateParams) GetDescription() string

GetDescription returns the description of a community pool spend proposal.

func (MsgGovUpdateParams) GetSignBytes added in v0.1.3 

func (msg MsgGovUpdateParams) GetSignBytes() []byte

GetSignBytes implements Msg

func (MsgGovUpdateParams) GetSigners added in v0.1.3 

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

GetSigners implements Msg

func (*MsgGovUpdateParams) GetTitle added in v0.1.3 

func (msg *MsgGovUpdateParams) GetTitle() string

GetTitle returns the title of a community pool spend proposal.

func (*MsgGovUpdateParams) Marshal added in v0.1.3 

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

func (*MsgGovUpdateParams) MarshalTo added in v0.1.3 

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

func (*MsgGovUpdateParams) MarshalToSizedBuffer added in v0.1.3 

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

func (*MsgGovUpdateParams) ProposalRoute added in v0.1.3 

func (msg *MsgGovUpdateParams) ProposalRoute() string

GetDescription returns the routing key of a community pool spend proposal.

func (*MsgGovUpdateParams) ProposalType added in v0.1.3 

func (msg *MsgGovUpdateParams) ProposalType() string

ProposalType returns the type of a community pool spend proposal.

func (*MsgGovUpdateParams) ProtoMessage added in v0.1.3 

func (*MsgGovUpdateParams) ProtoMessage()

func (*MsgGovUpdateParams) Reset added in v0.1.3 

func (m *MsgGovUpdateParams) Reset()

func (*MsgGovUpdateParams) Size added in v0.1.3 

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

func (MsgGovUpdateParams) String added in v0.1.3 

func (msg MsgGovUpdateParams) String() string

String implements the Stringer interface.

func (MsgGovUpdateParams) Type added in v0.1.3 

func (msg MsgGovUpdateParams) Type() string

Type implements Msg interface

func (*MsgGovUpdateParams) Unmarshal added in v0.1.3 

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

func (MsgGovUpdateParams) ValidateBasic added in v0.1.3 

func (msg MsgGovUpdateParams) ValidateBasic() error

ValidateBasic implements Msg and validates params for each param key specified in the proposal. If one param is invalid, the whole proposal will fail to go through.

func (*MsgGovUpdateParams) XXX_DiscardUnknown added in v0.1.3 

func (m *MsgGovUpdateParams) XXX_DiscardUnknown()

func (*MsgGovUpdateParams) XXX_Marshal added in v0.1.3 

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

func (*MsgGovUpdateParams) XXX_Merge added in v0.1.3 

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

func (*MsgGovUpdateParams) XXX_Size added in v0.1.3 

func (m *MsgGovUpdateParams) XXX_Size() int

func (*MsgGovUpdateParams) XXX_Unmarshal added in v0.1.3 

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

type MsgGovUpdateParamsResponse added in v0.1.3 

type MsgGovUpdateParamsResponse struct {
}

MsgGovUpdateParamsResponse defines the Msg/GovUpdateParams response type.

func (*MsgGovUpdateParamsResponse) Descriptor added in v0.1.3 

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

func (*MsgGovUpdateParamsResponse) Marshal added in v0.1.3 

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

func (*MsgGovUpdateParamsResponse) MarshalTo added in v0.1.3 

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

func (*MsgGovUpdateParamsResponse) MarshalToSizedBuffer added in v0.1.3 

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

func (*MsgGovUpdateParamsResponse) ProtoMessage added in v0.1.3 

func (*MsgGovUpdateParamsResponse) ProtoMessage()

func (*MsgGovUpdateParamsResponse) Reset added in v0.1.3 

func (m *MsgGovUpdateParamsResponse) Reset()

func (*MsgGovUpdateParamsResponse) Size added in v0.1.3 

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

func (*MsgGovUpdateParamsResponse) String added in v0.1.3 

func (m *MsgGovUpdateParamsResponse) String() string

func (*MsgGovUpdateParamsResponse) Unmarshal added in v0.1.3 

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

func (*MsgGovUpdateParamsResponse) XXX_DiscardUnknown added in v0.1.3 

func (m *MsgGovUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgGovUpdateParamsResponse) XXX_Marshal added in v0.1.3 

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

func (*MsgGovUpdateParamsResponse) XXX_Merge added in v0.1.3 

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

func (*MsgGovUpdateParamsResponse) XXX_Size added in v0.1.3 

func (m *MsgGovUpdateParamsResponse) XXX_Size() int

func (*MsgGovUpdateParamsResponse) XXX_Unmarshal added in v0.1.3 

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

type MsgServer 

type MsgServer interface {
	// AggregateExchangeRatePrevote defines a method for submitting an aggregate
	// exchange rate prevote.
	AggregateExchangeRatePrevote(context.Context, *MsgAggregateExchangeRatePrevote) (*MsgAggregateExchangeRatePrevoteResponse, error)
	// AggregateExchangeRateVote defines a method for submitting an aggregate
	// exchange rate vote.
	AggregateExchangeRateVote(context.Context, *MsgAggregateExchangeRateVote) (*MsgAggregateExchangeRateVoteResponse, error)
	// DelegateFeedConsent defines a method for setting the feeder delegation.
	DelegateFeedConsent(context.Context, *MsgDelegateFeedConsent) (*MsgDelegateFeedConsentResponse, error)
	// GovUpdateParams updates the oracle parameters.
	GovUpdateParams(context.Context, *MsgGovUpdateParams) (*MsgGovUpdateParamsResponse, error)
}

MsgServer is the server API for Msg service.

type Params 

type Params struct {
	VotePeriod               uint64                                 `protobuf:"varint,1,opt,name=vote_period,json=votePeriod,proto3" json:"vote_period,omitempty" yaml:"vote_period"`
	VoteThreshold            github_com_cosmos_cosmos_sdk_types.Dec `` /* 162-byte string literal not displayed */
	RewardBands              RewardBandList                         `` /* 132-byte string literal not displayed */
	RewardDistributionWindow uint64                                 `` /* 170-byte string literal not displayed */
	AcceptList               DenomList                              `protobuf:"bytes,5,rep,name=accept_list,json=acceptList,proto3,castrepeated=DenomList" json:"accept_list" yaml:"accept_list"`
	SlashFraction            github_com_cosmos_cosmos_sdk_types.Dec `` /* 162-byte string literal not displayed */
	SlashWindow              uint64                                 `protobuf:"varint,7,opt,name=slash_window,json=slashWindow,proto3" json:"slash_window,omitempty" yaml:"slash_window"`
	MinValidPerWindow        github_com_cosmos_cosmos_sdk_types.Dec `` /* 184-byte string literal not displayed */
	MandatoryList            DenomList                              `` /* 135-byte string literal not displayed */
	// Historic Stamp Period represents the amount of blocks the oracle
	// module waits before recording a new historic price.
	HistoricStampPeriod uint64 `protobuf:"varint,10,opt,name=historic_stamp_period,json=historicStampPeriod,proto3" json:"historic_stamp_period,omitempty"`
	// Median Stamp Period represents the amount blocks the oracle module
	// waits between calculating and stamping a new median and standard
	// deviation of that median.
	MedianStampPeriod uint64 `protobuf:"varint,11,opt,name=median_stamp_period,json=medianStampPeriod,proto3" json:"median_stamp_period,omitempty"`
	// Maximum Price Stamps represents the maximum amount of historic prices
	// the oracle module will store before pruning via FIFO.
	MaximumPriceStamps uint64 `protobuf:"varint,12,opt,name=maximum_price_stamps,json=maximumPriceStamps,proto3" json:"maximum_price_stamps,omitempty"`
	// Maximum Median Stamps represents the maximum amount of medians the
	// oracle module will store before pruning via FIFO.
	MaximumMedianStamps uint64 `protobuf:"varint,13,opt,name=maximum_median_stamps,json=maximumMedianStamps,proto3" json:"maximum_median_stamps,omitempty"`
}

Params defines the parameters for the oracle module.

func DefaultParams 

func DefaultParams() Params

DefaultParams creates default oracle module parameters

func (*Params) Descriptor 

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

func (*Params) Equal 

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

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

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

ParamSetPairs implements the ParamSet interface and returns all the key/value pairs pairs of oracle module's parameters.

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 fmt.Stringer interface

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

Validate performs basic validation on oracle parameters.

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type PriceStamp added in v0.1.2 

type PriceStamp struct {
	ExchangeRate *types.DecCoin `protobuf:"bytes,1,opt,name=exchange_rate,json=exchangeRate,proto3" json:"exchange_rate,omitempty"`
	BlockNum     uint64         `protobuf:"varint,2,opt,name=block_num,json=blockNum,proto3" json:"block_num,omitempty"`
}

PriceStamp defines a stamp of a denom's exchange rate at the block number it was calculated in.

func NewPriceStamp added in v0.1.2 

func NewPriceStamp(exchangeRate sdk.Dec, denom string, blockNum uint64) *PriceStamp

func (*PriceStamp) Descriptor added in v0.1.2 

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

func (*PriceStamp) Marshal added in v0.1.2 

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

func (*PriceStamp) MarshalTo added in v0.1.2 

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

func (*PriceStamp) MarshalToSizedBuffer added in v0.1.2 

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

func (*PriceStamp) ProtoMessage added in v0.1.2 

func (*PriceStamp) ProtoMessage()

func (*PriceStamp) Reset added in v0.1.2 

func (m *PriceStamp) Reset()

func (*PriceStamp) Size added in v0.1.2 

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

func (*PriceStamp) String added in v0.1.2 

func (m *PriceStamp) String() string

func (*PriceStamp) Unmarshal added in v0.1.2 

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

func (*PriceStamp) XXX_DiscardUnknown added in v0.1.2 

func (m *PriceStamp) XXX_DiscardUnknown()

func (*PriceStamp) XXX_Marshal added in v0.1.2 

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

func (*PriceStamp) XXX_Merge added in v0.1.2 

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

func (*PriceStamp) XXX_Size added in v0.1.2 

func (m *PriceStamp) XXX_Size() int

func (*PriceStamp) XXX_Unmarshal added in v0.1.2 

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

type PriceStamps added in v0.1.2 

type PriceStamps []PriceStamp

func (*PriceStamps) Decs added in v0.1.2 

func (p *PriceStamps) Decs() []sdk.Dec

Decs returns the exchange rates in sdk.Dec format

func (*PriceStamps) FilterByBlock added in v0.1.2 

func (p *PriceStamps) FilterByBlock(blockNum uint64) *PriceStamps

FilterByBlock filters the PriceStamps by block number

func (*PriceStamps) FilterByDenom added in v0.1.2 

func (p *PriceStamps) FilterByDenom(denom string) *PriceStamps

FilterByDenom filters the PriceStamps by denom

func (*PriceStamps) NewestBlockNum added in v0.1.3 

func (p *PriceStamps) NewestBlockNum() uint64

NewestBlockNum returns the newest block number in the PriceStamps

func (*PriceStamps) NewestPrices added in v0.1.3 

func (p *PriceStamps) NewestPrices() *PriceStamps

NewestPrices returns PriceStamps at the newest block number

func (*PriceStamps) Sort added in v0.1.2 

func (p *PriceStamps) Sort() *PriceStamps

Sort sorts the PriceStamps by block number and denom

type QueryActiveExchangeRates 

type QueryActiveExchangeRates struct {
}

QueryActiveExchangeRates is the request type for the Query/ActiveExchangeRates RPC method.

func (*QueryActiveExchangeRates) Descriptor 

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

func (*QueryActiveExchangeRates) Marshal 

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

func (*QueryActiveExchangeRates) MarshalTo 

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

func (*QueryActiveExchangeRates) MarshalToSizedBuffer 

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

func (*QueryActiveExchangeRates) ProtoMessage 

func (*QueryActiveExchangeRates) ProtoMessage()

func (*QueryActiveExchangeRates) Reset 

func (m *QueryActiveExchangeRates) Reset()

func (*QueryActiveExchangeRates) Size 

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

func (*QueryActiveExchangeRates) String 

func (m *QueryActiveExchangeRates) String() string

func (*QueryActiveExchangeRates) Unmarshal 

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

func (*QueryActiveExchangeRates) XXX_DiscardUnknown 

func (m *QueryActiveExchangeRates) XXX_DiscardUnknown()

func (*QueryActiveExchangeRates) XXX_Marshal 

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

func (*QueryActiveExchangeRates) XXX_Merge 

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

func (*QueryActiveExchangeRates) XXX_Size 

func (m *QueryActiveExchangeRates) XXX_Size() int

func (*QueryActiveExchangeRates) XXX_Unmarshal 

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

type QueryActiveExchangeRatesResponse 

type QueryActiveExchangeRatesResponse struct {
	// activeRates defines a list of the denomination which oracle prices aggreed
	// upon.
	ActiveRates []string `protobuf:"bytes,1,rep,name=active_rates,json=activeRates,proto3" json:"active_rates,omitempty"`
}

QueryActiveExchangeRatesResponse is response type for the Query/ActiveExchangeRates RPC method.

func (*QueryActiveExchangeRatesResponse) Descriptor 

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

func (*QueryActiveExchangeRatesResponse) Marshal 

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

func (*QueryActiveExchangeRatesResponse) MarshalTo 

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

func (*QueryActiveExchangeRatesResponse) MarshalToSizedBuffer 

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

func (*QueryActiveExchangeRatesResponse) ProtoMessage 

func (*QueryActiveExchangeRatesResponse) ProtoMessage()

func (*QueryActiveExchangeRatesResponse) Reset 

func (m *QueryActiveExchangeRatesResponse) Reset()

func (*QueryActiveExchangeRatesResponse) Size 

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

func (*QueryActiveExchangeRatesResponse) String 

func (m *QueryActiveExchangeRatesResponse) String() string

func (*QueryActiveExchangeRatesResponse) Unmarshal 

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

func (*QueryActiveExchangeRatesResponse) XXX_DiscardUnknown 

func (m *QueryActiveExchangeRatesResponse) XXX_DiscardUnknown()

func (*QueryActiveExchangeRatesResponse) XXX_Marshal 

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

func (*QueryActiveExchangeRatesResponse) XXX_Merge 

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

func (*QueryActiveExchangeRatesResponse) XXX_Size 

func (m *QueryActiveExchangeRatesResponse) XXX_Size() int

func (*QueryActiveExchangeRatesResponse) XXX_Unmarshal 

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

type QueryAggregatePrevote 

type QueryAggregatePrevote struct {
	// validator defines the validator address to query for.
	ValidatorAddr string `protobuf:"bytes,1,opt,name=validator_addr,json=validatorAddr,proto3" json:"validator_addr,omitempty"`
}

QueryAggregatePrevote is the request type for the Query/AggregatePrevote RPC method.

func (*QueryAggregatePrevote) Descriptor 

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

func (*QueryAggregatePrevote) Marshal 

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

func (*QueryAggregatePrevote) MarshalTo 

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

func (*QueryAggregatePrevote) MarshalToSizedBuffer 

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

func (*QueryAggregatePrevote) ProtoMessage 

func (*QueryAggregatePrevote) ProtoMessage()

func (*QueryAggregatePrevote) Reset 

func (m *QueryAggregatePrevote) Reset()

func (*QueryAggregatePrevote) Size 

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

func (*QueryAggregatePrevote) String 

func (m *QueryAggregatePrevote) String() string

func (*QueryAggregatePrevote) Unmarshal 

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

func (*QueryAggregatePrevote) XXX_DiscardUnknown 

func (m *QueryAggregatePrevote) XXX_DiscardUnknown()

func (*QueryAggregatePrevote) XXX_Marshal 

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

func (*QueryAggregatePrevote) XXX_Merge 

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

func (*QueryAggregatePrevote) XXX_Size 

func (m *QueryAggregatePrevote) XXX_Size() int

func (*QueryAggregatePrevote) XXX_Unmarshal 

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

type QueryAggregatePrevoteResponse 

type QueryAggregatePrevoteResponse struct {
	// aggregate_prevote defines oracle aggregate prevote submitted by a validator
	// in the current vote period
	AggregatePrevote AggregateExchangeRatePrevote `protobuf:"bytes,1,opt,name=aggregate_prevote,json=aggregatePrevote,proto3" json:"aggregate_prevote"`
}

QueryAggregatePrevoteResponse is response type for the Query/AggregatePrevote RPC method.

func (*QueryAggregatePrevoteResponse) Descriptor 

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

func (*QueryAggregatePrevoteResponse) Marshal 

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

func (*QueryAggregatePrevoteResponse) MarshalTo 

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

func (*QueryAggregatePrevoteResponse) MarshalToSizedBuffer 

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

func (*QueryAggregatePrevoteResponse) ProtoMessage 

func (*QueryAggregatePrevoteResponse) ProtoMessage()

func (*QueryAggregatePrevoteResponse) Reset 

func (m *QueryAggregatePrevoteResponse) Reset()

func (*QueryAggregatePrevoteResponse) Size 

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

func (*QueryAggregatePrevoteResponse) String 

func (m *QueryAggregatePrevoteResponse) String() string

func (*QueryAggregatePrevoteResponse) Unmarshal 

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

func (*QueryAggregatePrevoteResponse) XXX_DiscardUnknown 

func (m *QueryAggregatePrevoteResponse) XXX_DiscardUnknown()

func (*QueryAggregatePrevoteResponse) XXX_Marshal 

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

func (*QueryAggregatePrevoteResponse) XXX_Merge 

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

func (*QueryAggregatePrevoteResponse) XXX_Size 

func (m *QueryAggregatePrevoteResponse) XXX_Size() int

func (*QueryAggregatePrevoteResponse) XXX_Unmarshal 

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

type QueryAggregatePrevotes 

type QueryAggregatePrevotes struct {
}

QueryAggregatePrevotes is the request type for the Query/AggregatePrevotes RPC method.

func (*QueryAggregatePrevotes) Descriptor 

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

func (*QueryAggregatePrevotes) Marshal 

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

func (*QueryAggregatePrevotes) MarshalTo 

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

func (*QueryAggregatePrevotes) MarshalToSizedBuffer 

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

func (*QueryAggregatePrevotes) ProtoMessage 

func (*QueryAggregatePrevotes) ProtoMessage()

func (*QueryAggregatePrevotes) Reset 

func (m *QueryAggregatePrevotes) Reset()

func (*QueryAggregatePrevotes) Size 

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

func (*QueryAggregatePrevotes) String 

func (m *QueryAggregatePrevotes) String() string

func (*QueryAggregatePrevotes) Unmarshal 

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

func (*QueryAggregatePrevotes) XXX_DiscardUnknown 

func (m *QueryAggregatePrevotes) XXX_DiscardUnknown()

func (*QueryAggregatePrevotes) XXX_Marshal 

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

func (*QueryAggregatePrevotes) XXX_Merge 

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

func (*QueryAggregatePrevotes) XXX_Size 

func (m *QueryAggregatePrevotes) XXX_Size() int

func (*QueryAggregatePrevotes) XXX_Unmarshal 

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

type QueryAggregatePrevotesResponse 

type QueryAggregatePrevotesResponse struct {
	// aggregate_prevotes defines all oracle aggregate prevotes submitted in the
	// current vote period
	AggregatePrevotes []AggregateExchangeRatePrevote `protobuf:"bytes,1,rep,name=aggregate_prevotes,json=aggregatePrevotes,proto3" json:"aggregate_prevotes"`
}

QueryAggregatePrevotesResponse is response type for the Query/AggregatePrevotes RPC method.

func (*QueryAggregatePrevotesResponse) Descriptor 

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

func (*QueryAggregatePrevotesResponse) Marshal 

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

func (*QueryAggregatePrevotesResponse) MarshalTo 

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

func (*QueryAggregatePrevotesResponse) MarshalToSizedBuffer 

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

func (*QueryAggregatePrevotesResponse) ProtoMessage 

func (*QueryAggregatePrevotesResponse) ProtoMessage()

func (*QueryAggregatePrevotesResponse) Reset 

func (m *QueryAggregatePrevotesResponse) Reset()

func (*QueryAggregatePrevotesResponse) Size 

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

func (*QueryAggregatePrevotesResponse) String 

func (m *QueryAggregatePrevotesResponse) String() string

func (*QueryAggregatePrevotesResponse) Unmarshal 

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

func (*QueryAggregatePrevotesResponse) XXX_DiscardUnknown 

func (m *QueryAggregatePrevotesResponse) XXX_DiscardUnknown()

func (*QueryAggregatePrevotesResponse) XXX_Marshal 

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

func (*QueryAggregatePrevotesResponse) XXX_Merge 

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

func (*QueryAggregatePrevotesResponse) XXX_Size 

func (m *QueryAggregatePrevotesResponse) XXX_Size() int

func (*QueryAggregatePrevotesResponse) XXX_Unmarshal 

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

type QueryAggregateVote 

type QueryAggregateVote struct {
	// validator defines the validator address to query for.
	ValidatorAddr string `protobuf:"bytes,1,opt,name=validator_addr,json=validatorAddr,proto3" json:"validator_addr,omitempty"`
}

QueryAggregateVote is the request type for the Query/AggregateVote RPC method.

func (*QueryAggregateVote) Descriptor 

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

func (*QueryAggregateVote) Marshal 

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

func (*QueryAggregateVote) MarshalTo 

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

func (*QueryAggregateVote) MarshalToSizedBuffer 

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

func (*QueryAggregateVote) ProtoMessage 

func (*QueryAggregateVote) ProtoMessage()

func (*QueryAggregateVote) Reset 

func (m *QueryAggregateVote) Reset()

func (*QueryAggregateVote) Size 

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

func (*QueryAggregateVote) String 

func (m *QueryAggregateVote) String() string

func (*QueryAggregateVote) Unmarshal 

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

func (*QueryAggregateVote) XXX_DiscardUnknown 

func (m *QueryAggregateVote) XXX_DiscardUnknown()

func (*QueryAggregateVote) XXX_Marshal 

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

func (*QueryAggregateVote) XXX_Merge 

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

func (*QueryAggregateVote) XXX_Size 

func (m *QueryAggregateVote) XXX_Size() int

func (*QueryAggregateVote) XXX_Unmarshal 

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

type QueryAggregateVoteResponse 

type QueryAggregateVoteResponse struct {
	// aggregate_vote defines oracle aggregate vote submitted by a validator in
	// the current vote period
	AggregateVote AggregateExchangeRateVote `protobuf:"bytes,1,opt,name=aggregate_vote,json=aggregateVote,proto3" json:"aggregate_vote"`
}

QueryAggregateVoteResponse is response type for the Query/AggregateVote RPC method.

func (*QueryAggregateVoteResponse) Descriptor 

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

func (*QueryAggregateVoteResponse) Marshal 

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

func (*QueryAggregateVoteResponse) MarshalTo 

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

func (*QueryAggregateVoteResponse) MarshalToSizedBuffer 

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

func (*QueryAggregateVoteResponse) ProtoMessage 

func (*QueryAggregateVoteResponse) ProtoMessage()

func (*QueryAggregateVoteResponse) Reset 

func (m *QueryAggregateVoteResponse) Reset()

func (*QueryAggregateVoteResponse) Size 

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

func (*QueryAggregateVoteResponse) String 

func (m *QueryAggregateVoteResponse) String() string

func (*QueryAggregateVoteResponse) Unmarshal 

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

func (*QueryAggregateVoteResponse) XXX_DiscardUnknown 

func (m *QueryAggregateVoteResponse) XXX_DiscardUnknown()

func (*QueryAggregateVoteResponse) XXX_Marshal 

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

func (*QueryAggregateVoteResponse) XXX_Merge 

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

func (*QueryAggregateVoteResponse) XXX_Size 

func (m *QueryAggregateVoteResponse) XXX_Size() int

func (*QueryAggregateVoteResponse) XXX_Unmarshal 

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

type QueryAggregateVotes 

type QueryAggregateVotes struct {
}

QueryAggregateVotes is the request type for the Query/AggregateVotes RPC method.

func (*QueryAggregateVotes) Descriptor 

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

func (*QueryAggregateVotes) Marshal 

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

func (*QueryAggregateVotes) MarshalTo 

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

func (*QueryAggregateVotes) MarshalToSizedBuffer 

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

func (*QueryAggregateVotes) ProtoMessage 

func (*QueryAggregateVotes) ProtoMessage()

func (*QueryAggregateVotes) Reset 

func (m *QueryAggregateVotes) Reset()

func (*QueryAggregateVotes) Size 

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

func (*QueryAggregateVotes) String 

func (m *QueryAggregateVotes) String() string

func (*QueryAggregateVotes) Unmarshal 

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

func (*QueryAggregateVotes) XXX_DiscardUnknown 

func (m *QueryAggregateVotes) XXX_DiscardUnknown()

func (*QueryAggregateVotes) XXX_Marshal 

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

func (*QueryAggregateVotes) XXX_Merge 

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

func (*QueryAggregateVotes) XXX_Size 

func (m *QueryAggregateVotes) XXX_Size() int

func (*QueryAggregateVotes) XXX_Unmarshal 

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

type QueryAggregateVotesResponse 

type QueryAggregateVotesResponse struct {
	// aggregate_votes defines all oracle aggregate votes submitted in the current
	// vote period
	AggregateVotes []AggregateExchangeRateVote `protobuf:"bytes,1,rep,name=aggregate_votes,json=aggregateVotes,proto3" json:"aggregate_votes"`
}

QueryAggregateVotesResponse is response type for the Query/AggregateVotes RPC method.

func (*QueryAggregateVotesResponse) Descriptor 

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

func (*QueryAggregateVotesResponse) Marshal 

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

func (*QueryAggregateVotesResponse) MarshalTo 

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

func (*QueryAggregateVotesResponse) MarshalToSizedBuffer 

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

func (*QueryAggregateVotesResponse) ProtoMessage 

func (*QueryAggregateVotesResponse) ProtoMessage()

func (*QueryAggregateVotesResponse) Reset 

func (m *QueryAggregateVotesResponse) Reset()

func (*QueryAggregateVotesResponse) Size 

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

func (*QueryAggregateVotesResponse) String 

func (m *QueryAggregateVotesResponse) String() string

func (*QueryAggregateVotesResponse) Unmarshal 

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

func (*QueryAggregateVotesResponse) XXX_DiscardUnknown 

func (m *QueryAggregateVotesResponse) XXX_DiscardUnknown()

func (*QueryAggregateVotesResponse) XXX_Marshal 

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

func (*QueryAggregateVotesResponse) XXX_Merge 

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

func (*QueryAggregateVotesResponse) XXX_Size 

func (m *QueryAggregateVotesResponse) XXX_Size() int

func (*QueryAggregateVotesResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// ExchangeRates returns exchange rates of all denoms,
	// or, if specified, returns a single denom
	ExchangeRates(ctx context.Context, in *QueryExchangeRates, opts ...grpc.CallOption) (*QueryExchangeRatesResponse, error)
	// ActiveExchangeRates returns all active denoms
	ActiveExchangeRates(ctx context.Context, in *QueryActiveExchangeRates, opts ...grpc.CallOption) (*QueryActiveExchangeRatesResponse, error)
	// FeederDelegation returns feeder delegation of a validator
	FeederDelegation(ctx context.Context, in *QueryFeederDelegation, opts ...grpc.CallOption) (*QueryFeederDelegationResponse, error)
	// MissCounter returns oracle miss counter of a validator
	MissCounter(ctx context.Context, in *QueryMissCounter, opts ...grpc.CallOption) (*QueryMissCounterResponse, error)
	// SlashWindow returns slash window information
	SlashWindow(ctx context.Context, in *QuerySlashWindow, opts ...grpc.CallOption) (*QuerySlashWindowResponse, error)
	// AggregatePrevote returns an aggregate prevote of a validator
	AggregatePrevote(ctx context.Context, in *QueryAggregatePrevote, opts ...grpc.CallOption) (*QueryAggregatePrevoteResponse, error)
	// AggregatePrevotes returns aggregate prevotes of all validators
	AggregatePrevotes(ctx context.Context, in *QueryAggregatePrevotes, opts ...grpc.CallOption) (*QueryAggregatePrevotesResponse, error)
	// AggregateVote returns an aggregate vote of a validator
	AggregateVote(ctx context.Context, in *QueryAggregateVote, opts ...grpc.CallOption) (*QueryAggregateVoteResponse, error)
	// AggregateVotes returns aggregate votes of all validators
	AggregateVotes(ctx context.Context, in *QueryAggregateVotes, opts ...grpc.CallOption) (*QueryAggregateVotesResponse, error)
	// Params queries all parameters.
	Params(ctx context.Context, in *QueryParams, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// Medians returns medians of all denoms,
	// or, if specified, returns a single median
	Medians(ctx context.Context, in *QueryMedians, opts ...grpc.CallOption) (*QueryMediansResponse, error)
	// MedianDeviations returns median deviations of all denoms,
	// or, if specified, returns a single median deviation
	MedianDeviations(ctx context.Context, in *QueryMedianDeviations, opts ...grpc.CallOption) (*QueryMedianDeviationsResponse, error)
	// ValidatorRewardSet returns the set of validators that is
	// earning rewards for voting on exchange rates based on their
	// misscounter in a given Slash Window
	ValidatorRewardSet(ctx context.Context, in *QueryValidatorRewardSet, opts ...grpc.CallOption) (*QueryValidatorRewardSetResponse, 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 QueryExchangeRates 

type QueryExchangeRates struct {
	// denom defines the denomination to query for.
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
}

QueryExchangeRates is the request type for the Query/ExchangeRate RPC method.

func (*QueryExchangeRates) Descriptor 

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

func (*QueryExchangeRates) Marshal 

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

func (*QueryExchangeRates) MarshalTo 

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

func (*QueryExchangeRates) MarshalToSizedBuffer 

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

func (*QueryExchangeRates) ProtoMessage 

func (*QueryExchangeRates) ProtoMessage()

func (*QueryExchangeRates) Reset 

func (m *QueryExchangeRates) Reset()

func (*QueryExchangeRates) Size 

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

func (*QueryExchangeRates) String 

func (m *QueryExchangeRates) String() string

func (*QueryExchangeRates) Unmarshal 

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

func (*QueryExchangeRates) XXX_DiscardUnknown 

func (m *QueryExchangeRates) XXX_DiscardUnknown()

func (*QueryExchangeRates) XXX_Marshal 

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

func (*QueryExchangeRates) XXX_Merge 

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

func (*QueryExchangeRates) XXX_Size 

func (m *QueryExchangeRates) XXX_Size() int

func (*QueryExchangeRates) XXX_Unmarshal 

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

type QueryExchangeRatesResponse 

type QueryExchangeRatesResponse struct {
	// exchange_rates defines a list of the exchange rate for all whitelisted
	// denoms.
	ExchangeRates github_com_cosmos_cosmos_sdk_types.DecCoins `` /* 147-byte string literal not displayed */
}

QueryExchangeRatesResponse is response type for the Query/ExchangeRates RPC method.

func (*QueryExchangeRatesResponse) Descriptor 

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

func (*QueryExchangeRatesResponse) Marshal 

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

func (*QueryExchangeRatesResponse) MarshalTo 

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

func (*QueryExchangeRatesResponse) MarshalToSizedBuffer 

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

func (*QueryExchangeRatesResponse) ProtoMessage 

func (*QueryExchangeRatesResponse) ProtoMessage()

func (*QueryExchangeRatesResponse) Reset 

func (m *QueryExchangeRatesResponse) Reset()

func (*QueryExchangeRatesResponse) Size 

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

func (*QueryExchangeRatesResponse) String 

func (m *QueryExchangeRatesResponse) String() string

func (*QueryExchangeRatesResponse) Unmarshal 

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

func (*QueryExchangeRatesResponse) XXX_DiscardUnknown 

func (m *QueryExchangeRatesResponse) XXX_DiscardUnknown()

func (*QueryExchangeRatesResponse) XXX_Marshal 

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

func (*QueryExchangeRatesResponse) XXX_Merge 

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

func (*QueryExchangeRatesResponse) XXX_Size 

func (m *QueryExchangeRatesResponse) XXX_Size() int

func (*QueryExchangeRatesResponse) XXX_Unmarshal 

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

type QueryFeederDelegation 

type QueryFeederDelegation struct {
	// validator defines the validator address to query for.
	ValidatorAddr string `protobuf:"bytes,1,opt,name=validator_addr,json=validatorAddr,proto3" json:"validator_addr,omitempty"`
}

QueryFeederDelegation is the request type for the Query/FeederDelegation RPC method.

func (*QueryFeederDelegation) Descriptor 

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

func (*QueryFeederDelegation) Marshal 

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

func (*QueryFeederDelegation) MarshalTo 

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

func (*QueryFeederDelegation) MarshalToSizedBuffer 

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

func (*QueryFeederDelegation) ProtoMessage 

func (*QueryFeederDelegation) ProtoMessage()

func (*QueryFeederDelegation) Reset 

func (m *QueryFeederDelegation) Reset()

func (*QueryFeederDelegation) Size 

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

func (*QueryFeederDelegation) String 

func (m *QueryFeederDelegation) String() string

func (*QueryFeederDelegation) Unmarshal 

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

func (*QueryFeederDelegation) XXX_DiscardUnknown 

func (m *QueryFeederDelegation) XXX_DiscardUnknown()

func (*QueryFeederDelegation) XXX_Marshal 

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

func (*QueryFeederDelegation) XXX_Merge 

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

func (*QueryFeederDelegation) XXX_Size 

func (m *QueryFeederDelegation) XXX_Size() int

func (*QueryFeederDelegation) XXX_Unmarshal 

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

type QueryFeederDelegationResponse 

type QueryFeederDelegationResponse struct {
	// feeder_addr defines the feeder delegation of a validator
	FeederAddr string `protobuf:"bytes,1,opt,name=feeder_addr,json=feederAddr,proto3" json:"feeder_addr,omitempty"`
}

QueryFeederDelegationResponse is response type for the Query/FeederDelegation RPC method.

func (*QueryFeederDelegationResponse) Descriptor 

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

func (*QueryFeederDelegationResponse) Marshal 

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

func (*QueryFeederDelegationResponse) MarshalTo 

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

func (*QueryFeederDelegationResponse) MarshalToSizedBuffer 

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

func (*QueryFeederDelegationResponse) ProtoMessage 

func (*QueryFeederDelegationResponse) ProtoMessage()

func (*QueryFeederDelegationResponse) Reset 

func (m *QueryFeederDelegationResponse) Reset()

func (*QueryFeederDelegationResponse) Size 

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

func (*QueryFeederDelegationResponse) String 

func (m *QueryFeederDelegationResponse) String() string

func (*QueryFeederDelegationResponse) Unmarshal 

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

func (*QueryFeederDelegationResponse) XXX_DiscardUnknown 

func (m *QueryFeederDelegationResponse) XXX_DiscardUnknown()

func (*QueryFeederDelegationResponse) XXX_Marshal 

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

func (*QueryFeederDelegationResponse) XXX_Merge 

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

func (*QueryFeederDelegationResponse) XXX_Size 

func (m *QueryFeederDelegationResponse) XXX_Size() int

func (*QueryFeederDelegationResponse) XXX_Unmarshal 

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

type QueryMedianDeviations 

type QueryMedianDeviations struct {
	// denom defines the denomination to query for.
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
}

QueryMedianDeviations is the request type for the Query/MedianDeviations RPC Response.

func (*QueryMedianDeviations) Descriptor 

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

func (*QueryMedianDeviations) Marshal 

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

func (*QueryMedianDeviations) MarshalTo 

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

func (*QueryMedianDeviations) MarshalToSizedBuffer 

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

func (*QueryMedianDeviations) ProtoMessage 

func (*QueryMedianDeviations) ProtoMessage()

func (*QueryMedianDeviations) Reset 

func (m *QueryMedianDeviations) Reset()

func (*QueryMedianDeviations) Size 

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

func (*QueryMedianDeviations) String 

func (m *QueryMedianDeviations) String() string

func (*QueryMedianDeviations) Unmarshal 

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

func (*QueryMedianDeviations) XXX_DiscardUnknown 

func (m *QueryMedianDeviations) XXX_DiscardUnknown()

func (*QueryMedianDeviations) XXX_Marshal 

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

func (*QueryMedianDeviations) XXX_Merge 

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

func (*QueryMedianDeviations) XXX_Size 

func (m *QueryMedianDeviations) XXX_Size() int

func (*QueryMedianDeviations) XXX_Unmarshal 

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

type QueryMedianDeviationsResponse 

type QueryMedianDeviationsResponse struct {
	// medians defines a list of the median deviations for all stamped denoms.
	MedianDeviations []PriceStamp `protobuf:"bytes,1,rep,name=medianDeviations,proto3" json:"medianDeviations"`
}

QueryMedianDeviationsResponse is response type for the Query/MedianDeviations RPC method.

func (*QueryMedianDeviationsResponse) Descriptor 

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

func (*QueryMedianDeviationsResponse) Marshal 

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

func (*QueryMedianDeviationsResponse) MarshalTo 

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

func (*QueryMedianDeviationsResponse) MarshalToSizedBuffer 

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

func (*QueryMedianDeviationsResponse) ProtoMessage 

func (*QueryMedianDeviationsResponse) ProtoMessage()

func (*QueryMedianDeviationsResponse) Reset 

func (m *QueryMedianDeviationsResponse) Reset()

func (*QueryMedianDeviationsResponse) Size 

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

func (*QueryMedianDeviationsResponse) String 

func (m *QueryMedianDeviationsResponse) String() string

func (*QueryMedianDeviationsResponse) Unmarshal 

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

func (*QueryMedianDeviationsResponse) XXX_DiscardUnknown 

func (m *QueryMedianDeviationsResponse) XXX_DiscardUnknown()

func (*QueryMedianDeviationsResponse) XXX_Marshal 

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

func (*QueryMedianDeviationsResponse) XXX_Merge 

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

func (*QueryMedianDeviationsResponse) XXX_Size 

func (m *QueryMedianDeviationsResponse) XXX_Size() int

func (*QueryMedianDeviationsResponse) XXX_Unmarshal 

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

type QueryMedians 

type QueryMedians struct {
	// denom defines the denomination to query for.
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
	// numStamps defines the number of median stamps to query for. numStamps
	// must be greater than 0.
	NumStamps uint32 `protobuf:"varint,2,opt,name=numStamps,proto3" json:"numStamps,omitempty"`
}

QueryMedians is the request type for the Query/Medians RPC Response.

func (*QueryMedians) Descriptor 

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

func (*QueryMedians) Marshal 

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

func (*QueryMedians) MarshalTo 

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

func (*QueryMedians) MarshalToSizedBuffer 

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

func (*QueryMedians) ProtoMessage 

func (*QueryMedians) ProtoMessage()

func (*QueryMedians) Reset 

func (m *QueryMedians) Reset()

func (*QueryMedians) Size 

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

func (*QueryMedians) String 

func (m *QueryMedians) String() string

func (*QueryMedians) Unmarshal 

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

func (*QueryMedians) XXX_DiscardUnknown 

func (m *QueryMedians) XXX_DiscardUnknown()

func (*QueryMedians) XXX_Marshal 

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

func (*QueryMedians) XXX_Merge 

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

func (*QueryMedians) XXX_Size 

func (m *QueryMedians) XXX_Size() int

func (*QueryMedians) XXX_Unmarshal 

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

type QueryMediansResponse 

type QueryMediansResponse struct {
	// medians defines a list of the medians for all stamped denoms.
	Medians []PriceStamp `protobuf:"bytes,1,rep,name=medians,proto3" json:"medians"`
}

QueryMediansResponse is response type for the Query/Medians RPC method.

func (*QueryMediansResponse) Descriptor 

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

func (*QueryMediansResponse) Marshal 

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

func (*QueryMediansResponse) MarshalTo 

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

func (*QueryMediansResponse) MarshalToSizedBuffer 

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

func (*QueryMediansResponse) ProtoMessage 

func (*QueryMediansResponse) ProtoMessage()

func (*QueryMediansResponse) Reset 

func (m *QueryMediansResponse) Reset()

func (*QueryMediansResponse) Size 

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

func (*QueryMediansResponse) String 

func (m *QueryMediansResponse) String() string

func (*QueryMediansResponse) Unmarshal 

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

func (*QueryMediansResponse) XXX_DiscardUnknown 

func (m *QueryMediansResponse) XXX_DiscardUnknown()

func (*QueryMediansResponse) XXX_Marshal 

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

func (*QueryMediansResponse) XXX_Merge 

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

func (*QueryMediansResponse) XXX_Size 

func (m *QueryMediansResponse) XXX_Size() int

func (*QueryMediansResponse) XXX_Unmarshal 

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

type QueryMissCounter 

type QueryMissCounter struct {
	// validator defines the validator address to query for.
	ValidatorAddr string `protobuf:"bytes,1,opt,name=validator_addr,json=validatorAddr,proto3" json:"validator_addr,omitempty"`
}

QueryMissCounter is the request type for the Query/MissCounter RPC method.

func (*QueryMissCounter) Descriptor 

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

func (*QueryMissCounter) Marshal 

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

func (*QueryMissCounter) MarshalTo 

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

func (*QueryMissCounter) MarshalToSizedBuffer 

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

func (*QueryMissCounter) ProtoMessage 

func (*QueryMissCounter) ProtoMessage()

func (*QueryMissCounter) Reset 

func (m *QueryMissCounter) Reset()

func (*QueryMissCounter) Size 

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

func (*QueryMissCounter) String 

func (m *QueryMissCounter) String() string

func (*QueryMissCounter) Unmarshal 

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

func (*QueryMissCounter) XXX_DiscardUnknown 

func (m *QueryMissCounter) XXX_DiscardUnknown()

func (*QueryMissCounter) XXX_Marshal 

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

func (*QueryMissCounter) XXX_Merge 

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

func (*QueryMissCounter) XXX_Size 

func (m *QueryMissCounter) XXX_Size() int

func (*QueryMissCounter) XXX_Unmarshal 

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

type QueryMissCounterResponse 

type QueryMissCounterResponse struct {
	// miss_counter defines the oracle miss counter of a validator
	MissCounter uint64 `protobuf:"varint,1,opt,name=miss_counter,json=missCounter,proto3" json:"miss_counter,omitempty"`
}

QueryMissCounterResponse is response type for the Query/MissCounter RPC method.

func (*QueryMissCounterResponse) Descriptor 

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

func (*QueryMissCounterResponse) Marshal 

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

func (*QueryMissCounterResponse) MarshalTo 

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

func (*QueryMissCounterResponse) MarshalToSizedBuffer 

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

func (*QueryMissCounterResponse) ProtoMessage 

func (*QueryMissCounterResponse) ProtoMessage()

func (*QueryMissCounterResponse) Reset 

func (m *QueryMissCounterResponse) Reset()

func (*QueryMissCounterResponse) Size 

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

func (*QueryMissCounterResponse) String 

func (m *QueryMissCounterResponse) String() string

func (*QueryMissCounterResponse) Unmarshal 

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

func (*QueryMissCounterResponse) XXX_DiscardUnknown 

func (m *QueryMissCounterResponse) XXX_DiscardUnknown()

func (*QueryMissCounterResponse) XXX_Marshal 

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

func (*QueryMissCounterResponse) XXX_Merge 

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

func (*QueryMissCounterResponse) XXX_Size 

func (m *QueryMissCounterResponse) XXX_Size() int

func (*QueryMissCounterResponse) XXX_Unmarshal 

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

type QueryParams 

type QueryParams struct {
}

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

func (*QueryParams) Descriptor 

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

func (*QueryParams) Marshal 

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

func (*QueryParams) MarshalTo 

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

func (*QueryParams) MarshalToSizedBuffer 

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

func (*QueryParams) ProtoMessage 

func (*QueryParams) ProtoMessage()

func (*QueryParams) Reset 

func (m *QueryParams) Reset()

func (*QueryParams) Size 

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

func (*QueryParams) String 

func (m *QueryParams) String() string

func (*QueryParams) Unmarshal 

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

func (*QueryParams) XXX_DiscardUnknown 

func (m *QueryParams) XXX_DiscardUnknown()

func (*QueryParams) XXX_Marshal 

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

func (*QueryParams) XXX_Merge 

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

func (*QueryParams) XXX_Size 

func (m *QueryParams) XXX_Size() int

func (*QueryParams) XXX_Unmarshal 

func (m *QueryParams) 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) 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 {
	// ExchangeRates returns exchange rates of all denoms,
	// or, if specified, returns a single denom
	ExchangeRates(context.Context, *QueryExchangeRates) (*QueryExchangeRatesResponse, error)
	// ActiveExchangeRates returns all active denoms
	ActiveExchangeRates(context.Context, *QueryActiveExchangeRates) (*QueryActiveExchangeRatesResponse, error)
	// FeederDelegation returns feeder delegation of a validator
	FeederDelegation(context.Context, *QueryFeederDelegation) (*QueryFeederDelegationResponse, error)
	// MissCounter returns oracle miss counter of a validator
	MissCounter(context.Context, *QueryMissCounter) (*QueryMissCounterResponse, error)
	// SlashWindow returns slash window information
	SlashWindow(context.Context, *QuerySlashWindow) (*QuerySlashWindowResponse, error)
	// AggregatePrevote returns an aggregate prevote of a validator
	AggregatePrevote(context.Context, *QueryAggregatePrevote) (*QueryAggregatePrevoteResponse, error)
	// AggregatePrevotes returns aggregate prevotes of all validators
	AggregatePrevotes(context.Context, *QueryAggregatePrevotes) (*QueryAggregatePrevotesResponse, error)
	// AggregateVote returns an aggregate vote of a validator
	AggregateVote(context.Context, *QueryAggregateVote) (*QueryAggregateVoteResponse, error)
	// AggregateVotes returns aggregate votes of all validators
	AggregateVotes(context.Context, *QueryAggregateVotes) (*QueryAggregateVotesResponse, error)
	// Params queries all parameters.
	Params(context.Context, *QueryParams) (*QueryParamsResponse, error)
	// Medians returns medians of all denoms,
	// or, if specified, returns a single median
	Medians(context.Context, *QueryMedians) (*QueryMediansResponse, error)
	// MedianDeviations returns median deviations of all denoms,
	// or, if specified, returns a single median deviation
	MedianDeviations(context.Context, *QueryMedianDeviations) (*QueryMedianDeviationsResponse, error)
	// ValidatorRewardSet returns the set of validators that is
	// earning rewards for voting on exchange rates based on their
	// misscounter in a given Slash Window
	ValidatorRewardSet(context.Context, *QueryValidatorRewardSet) (*QueryValidatorRewardSetResponse, error)
}

QueryServer is the server API for Query service.

type QuerySlashWindow 

type QuerySlashWindow struct {
}

QuerySlashWindow is the request type for the Query/SlashWindow RPC method.

func (*QuerySlashWindow) Descriptor 

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

func (*QuerySlashWindow) Marshal 

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

func (*QuerySlashWindow) MarshalTo 

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

func (*QuerySlashWindow) MarshalToSizedBuffer 

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

func (*QuerySlashWindow) ProtoMessage 

func (*QuerySlashWindow) ProtoMessage()

func (*QuerySlashWindow) Reset 

func (m *QuerySlashWindow) Reset()

func (*QuerySlashWindow) Size 

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

func (*QuerySlashWindow) String 

func (m *QuerySlashWindow) String() string

func (*QuerySlashWindow) Unmarshal 

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

func (*QuerySlashWindow) XXX_DiscardUnknown 

func (m *QuerySlashWindow) XXX_DiscardUnknown()

func (*QuerySlashWindow) XXX_Marshal 

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

func (*QuerySlashWindow) XXX_Merge 

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

func (*QuerySlashWindow) XXX_Size 

func (m *QuerySlashWindow) XXX_Size() int

func (*QuerySlashWindow) XXX_Unmarshal 

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

type QuerySlashWindowResponse 

type QuerySlashWindowResponse struct {
	// window_progress defines the number of voting periods
	// since the last slashing event would have taken place.
	WindowProgress uint64 `protobuf:"varint,1,opt,name=window_progress,json=windowProgress,proto3" json:"window_progress,omitempty"`
}

QuerySlashWindowResponse is response type for the Query/SlashWindow RPC method.

func (*QuerySlashWindowResponse) Descriptor 

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

func (*QuerySlashWindowResponse) Marshal 

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

func (*QuerySlashWindowResponse) MarshalTo 

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

func (*QuerySlashWindowResponse) MarshalToSizedBuffer 

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

func (*QuerySlashWindowResponse) ProtoMessage 

func (*QuerySlashWindowResponse) ProtoMessage()

func (*QuerySlashWindowResponse) Reset 

func (m *QuerySlashWindowResponse) Reset()

func (*QuerySlashWindowResponse) Size 

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

func (*QuerySlashWindowResponse) String 

func (m *QuerySlashWindowResponse) String() string

func (*QuerySlashWindowResponse) Unmarshal 

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

func (*QuerySlashWindowResponse) XXX_DiscardUnknown 

func (m *QuerySlashWindowResponse) XXX_DiscardUnknown()

func (*QuerySlashWindowResponse) XXX_Marshal 

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

func (*QuerySlashWindowResponse) XXX_Merge 

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

func (*QuerySlashWindowResponse) XXX_Size 

func (m *QuerySlashWindowResponse) XXX_Size() int

func (*QuerySlashWindowResponse) XXX_Unmarshal 

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

type QueryValidatorRewardSet added in v0.1.3 

type QueryValidatorRewardSet struct {
}

QueryValidatorRewardSet is the request type for the Query/ValidatorRewardSet RPC method.

func (*QueryValidatorRewardSet) Descriptor added in v0.1.3 

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

func (*QueryValidatorRewardSet) Marshal added in v0.1.3 

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

func (*QueryValidatorRewardSet) MarshalTo added in v0.1.3 

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

func (*QueryValidatorRewardSet) MarshalToSizedBuffer added in v0.1.3 

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

func (*QueryValidatorRewardSet) ProtoMessage added in v0.1.3 

func (*QueryValidatorRewardSet) ProtoMessage()

func (*QueryValidatorRewardSet) Reset added in v0.1.3 

func (m *QueryValidatorRewardSet) Reset()

func (*QueryValidatorRewardSet) Size added in v0.1.3 

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

func (*QueryValidatorRewardSet) String added in v0.1.3 

func (m *QueryValidatorRewardSet) String() string

func (*QueryValidatorRewardSet) Unmarshal added in v0.1.3 

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

func (*QueryValidatorRewardSet) XXX_DiscardUnknown added in v0.1.3 

func (m *QueryValidatorRewardSet) XXX_DiscardUnknown()

func (*QueryValidatorRewardSet) XXX_Marshal added in v0.1.3 

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

func (*QueryValidatorRewardSet) XXX_Merge added in v0.1.3 

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

func (*QueryValidatorRewardSet) XXX_Size added in v0.1.3 

func (m *QueryValidatorRewardSet) XXX_Size() int

func (*QueryValidatorRewardSet) XXX_Unmarshal added in v0.1.3 

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

type QueryValidatorRewardSetResponse added in v0.1.3 

type QueryValidatorRewardSetResponse struct {
	Validators ValidatorRewardSet `protobuf:"bytes,1,opt,name=validators,proto3" json:"validators"`
}

QueryValidatorRewardSetResponse is the response type for the Query/ValidatorRewardSet RPC method.

func (*QueryValidatorRewardSetResponse) Descriptor added in v0.1.3 

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

func (*QueryValidatorRewardSetResponse) Marshal added in v0.1.3 

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

func (*QueryValidatorRewardSetResponse) MarshalTo added in v0.1.3 

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

func (*QueryValidatorRewardSetResponse) MarshalToSizedBuffer added in v0.1.3 

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

func (*QueryValidatorRewardSetResponse) ProtoMessage added in v0.1.3 

func (*QueryValidatorRewardSetResponse) ProtoMessage()

func (*QueryValidatorRewardSetResponse) Reset added in v0.1.3 

func (m *QueryValidatorRewardSetResponse) Reset()

func (*QueryValidatorRewardSetResponse) Size added in v0.1.3 

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

func (*QueryValidatorRewardSetResponse) String added in v0.1.3 

func (m *QueryValidatorRewardSetResponse) String() string

func (*QueryValidatorRewardSetResponse) Unmarshal added in v0.1.3 

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

func (*QueryValidatorRewardSetResponse) XXX_DiscardUnknown added in v0.1.3 

func (m *QueryValidatorRewardSetResponse) XXX_DiscardUnknown()

func (*QueryValidatorRewardSetResponse) XXX_Marshal added in v0.1.3 

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

func (*QueryValidatorRewardSetResponse) XXX_Merge added in v0.1.3 

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

func (*QueryValidatorRewardSetResponse) XXX_Size added in v0.1.3 

func (m *QueryValidatorRewardSetResponse) XXX_Size() int

func (*QueryValidatorRewardSetResponse) XXX_Unmarshal added in v0.1.3 

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

type RewardBand added in v0.1.2 

type RewardBand struct {
	SymbolDenom string                                 `protobuf:"bytes,1,opt,name=symbol_denom,json=symbolDenom,proto3" json:"symbol_denom,omitempty" yaml:"symbol_denom"`
	RewardBand  github_com_cosmos_cosmos_sdk_types.Dec `` /* 150-byte string literal not displayed */
}

RewardBand - the object to hold the reward band configuration for a given denom.

func (*RewardBand) Descriptor added in v0.1.2 

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

func (RewardBand) Equal added in v0.1.2 

func (rb RewardBand) Equal(rb2 *RewardBand) bool

func (*RewardBand) Marshal added in v0.1.2 

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

func (*RewardBand) MarshalTo added in v0.1.2 

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

func (*RewardBand) MarshalToSizedBuffer added in v0.1.2 

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

func (*RewardBand) ProtoMessage added in v0.1.2 

func (*RewardBand) ProtoMessage()

func (*RewardBand) Reset added in v0.1.2 

func (m *RewardBand) Reset()

func (*RewardBand) Size added in v0.1.2 

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

func (RewardBand) String added in v0.1.2 

func (rb RewardBand) String() string

String implements fmt.Stringer interface

func (*RewardBand) Unmarshal added in v0.1.2 

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

func (*RewardBand) XXX_DiscardUnknown added in v0.1.2 

func (m *RewardBand) XXX_DiscardUnknown()

func (*RewardBand) XXX_Marshal added in v0.1.2 

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

func (*RewardBand) XXX_Merge added in v0.1.2 

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

func (*RewardBand) XXX_Size added in v0.1.2 

func (m *RewardBand) XXX_Size() int

func (*RewardBand) XXX_Unmarshal added in v0.1.2 

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

type RewardBandList added in v0.1.2 

type RewardBandList []RewardBand

RewardBandList is array of RewardBand

func DefaultRewardBands added in v0.1.2 

func DefaultRewardBands() RewardBandList

DefaultRewardBands returns a new default RewardBandList object.

This function is necessary because we cannot use a constant, and the reward band list is manipulated in our unit tests.

func (RewardBandList) GetBandFromDenom added in v0.1.2 

func (rbl RewardBandList) GetBandFromDenom(denom string) (sdk.Dec, error)

GetRewardBand returns the reward band of a given Denom. It will return an error if it can not find it.

func (RewardBandList) String added in v0.1.2 

func (rbl RewardBandList) String() (out string)

type StakingKeeper 

type StakingKeeper interface {
	Validator(ctx sdk.Context, address sdk.ValAddress) stakingtypes.ValidatorI
	GetBondedValidatorsByPower(ctx sdk.Context) []stakingtypes.Validator
	TotalBondedTokens(sdk.Context) sdkmath.Int
	Slash(sdk.Context, sdk.ConsAddress, int64, int64, sdk.Dec) sdkmath.Int
	Jail(sdk.Context, sdk.ConsAddress)
	ValidatorsPowerStoreIterator(ctx sdk.Context) sdk.Iterator
	MaxValidators(sdk.Context) uint32
	PowerReduction(ctx sdk.Context) (res sdkmath.Int)
}

StakingKeeper defines the expected interface contract defined by the x/staking module.

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) AggregateExchangeRatePrevote 

func (*UnimplementedMsgServer) AggregateExchangeRatePrevote(ctx context.Context, req *MsgAggregateExchangeRatePrevote) (*MsgAggregateExchangeRatePrevoteResponse, error)

func (*UnimplementedMsgServer) AggregateExchangeRateVote 

func (*UnimplementedMsgServer) AggregateExchangeRateVote(ctx context.Context, req *MsgAggregateExchangeRateVote) (*MsgAggregateExchangeRateVoteResponse, error)

func (*UnimplementedMsgServer) DelegateFeedConsent 

func (*UnimplementedMsgServer) DelegateFeedConsent(ctx context.Context, req *MsgDelegateFeedConsent) (*MsgDelegateFeedConsentResponse, error)

func (*UnimplementedMsgServer) GovUpdateParams added in v0.1.3 

func (*UnimplementedMsgServer) GovUpdateParams(ctx context.Context, req *MsgGovUpdateParams) (*MsgGovUpdateParamsResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) ActiveExchangeRates 

func (*UnimplementedQueryServer) ActiveExchangeRates(ctx context.Context, req *QueryActiveExchangeRates) (*QueryActiveExchangeRatesResponse, error)

func (*UnimplementedQueryServer) AggregatePrevote 

func (*UnimplementedQueryServer) AggregatePrevote(ctx context.Context, req *QueryAggregatePrevote) (*QueryAggregatePrevoteResponse, error)

func (*UnimplementedQueryServer) AggregatePrevotes 

func (*UnimplementedQueryServer) AggregatePrevotes(ctx context.Context, req *QueryAggregatePrevotes) (*QueryAggregatePrevotesResponse, error)

func (*UnimplementedQueryServer) AggregateVote 

func (*UnimplementedQueryServer) AggregateVote(ctx context.Context, req *QueryAggregateVote) (*QueryAggregateVoteResponse, error)

func (*UnimplementedQueryServer) AggregateVotes 

func (*UnimplementedQueryServer) AggregateVotes(ctx context.Context, req *QueryAggregateVotes) (*QueryAggregateVotesResponse, error)

func (*UnimplementedQueryServer) ExchangeRates 

func (*UnimplementedQueryServer) ExchangeRates(ctx context.Context, req *QueryExchangeRates) (*QueryExchangeRatesResponse, error)

func (*UnimplementedQueryServer) FeederDelegation 

func (*UnimplementedQueryServer) FeederDelegation(ctx context.Context, req *QueryFeederDelegation) (*QueryFeederDelegationResponse, error)

func (*UnimplementedQueryServer) MedianDeviations 

func (*UnimplementedQueryServer) MedianDeviations(ctx context.Context, req *QueryMedianDeviations) (*QueryMedianDeviationsResponse, error)

func (*UnimplementedQueryServer) Medians 

func (*UnimplementedQueryServer) Medians(ctx context.Context, req *QueryMedians) (*QueryMediansResponse, error)

func (*UnimplementedQueryServer) MissCounter 

func (*UnimplementedQueryServer) MissCounter(ctx context.Context, req *QueryMissCounter) (*QueryMissCounterResponse, error)

func (*UnimplementedQueryServer) Params 

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

func (*UnimplementedQueryServer) SlashWindow 

func (*UnimplementedQueryServer) SlashWindow(ctx context.Context, req *QuerySlashWindow) (*QuerySlashWindowResponse, error)

func (*UnimplementedQueryServer) ValidatorRewardSet added in v0.1.3 

func (*UnimplementedQueryServer) ValidatorRewardSet(ctx context.Context, req *QueryValidatorRewardSet) (*QueryValidatorRewardSetResponse, error)

type ValidatorRewardSet added in v0.1.3 

type ValidatorRewardSet struct {
	ValidatorSet []string `protobuf:"bytes,1,rep,name=validator_set,json=validatorSet,proto3" json:"validator_set,omitempty" yaml:"validator_set"`
}

ValidatorRewardSet is the set of validators that is earning rewards for voting on exchange rates based on their misscounter in a given Slash Window. This set gets updated every Slash Window.

func (*ValidatorRewardSet) Descriptor added in v0.1.3 

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

func (*ValidatorRewardSet) Marshal added in v0.1.3 

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

func (*ValidatorRewardSet) MarshalTo added in v0.1.3 

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

func (*ValidatorRewardSet) MarshalToSizedBuffer added in v0.1.3 

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

func (*ValidatorRewardSet) ProtoMessage added in v0.1.3 

func (*ValidatorRewardSet) ProtoMessage()

func (*ValidatorRewardSet) Reset added in v0.1.3 

func (m *ValidatorRewardSet) Reset()

func (*ValidatorRewardSet) Size added in v0.1.3 

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

func (*ValidatorRewardSet) String added in v0.1.3 

func (m *ValidatorRewardSet) String() string

func (*ValidatorRewardSet) Unmarshal added in v0.1.3 

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

func (*ValidatorRewardSet) XXX_DiscardUnknown added in v0.1.3 

func (m *ValidatorRewardSet) XXX_DiscardUnknown()

func (*ValidatorRewardSet) XXX_Marshal added in v0.1.3 

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

func (*ValidatorRewardSet) XXX_Merge added in v0.1.3 

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

func (*ValidatorRewardSet) XXX_Size added in v0.1.3 

func (m *ValidatorRewardSet) XXX_Size() int

func (*ValidatorRewardSet) XXX_Unmarshal added in v0.1.3 

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

type VoteForTally 

type VoteForTally struct {
	Denom        string
	ExchangeRate sdk.Dec
	Voter        sdk.ValAddress
	Power        int64
}

VoteForTally is a convenience wrapper to reduce redundant lookup cost.

func NewVoteForTally 

func NewVoteForTally(rate sdk.Dec, denom string, voter sdk.ValAddress, power int64) VoteForTally

NewVoteForTally returns a new VoteForTally instance.

type VoteHash 

type VoteHash []byte

VoteHash defines a hash value to hide vote exchange rate which is formatted as a HEX string: SHA256("{salt}:{symbol}:{exchangeRate},...,{symbol}:{exchangeRate}:{voter}")

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.