types

package
v0.0.0-...-f42d900 Latest Latest
Warning

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

 Go to latest Published: Jun 27, 2023 License: Apache-2.0 Imports: 42 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypeExchangeRateUpdate = "exchange_rate_update"
	EventTypeVote               = "vote"
	EventTypeFeedDelegate       = "feed_delegate"
	EventTypeAggregateVote      = "aggregate_vote"
	EventTypeEndSlashWindow     = "end_slash_window"

	AttributeKeyDenom         = "denom"
	AttributeKeyVoter         = "voter"
	AttributeKeyExchangeRate  = "exchange_rate"
	AttributeKeyExchangeRates = "exchange_rates"
	AttributeKeyOperator      = "operator"
	AttributeKeyFeeder        = "feeder"
	AttributeKeyMissCount     = "miss_count"
	AttributeKeyAbstainCount  = "abstain_count"
	AttributeKeyWinCount      = "win_count"
	AttributeKeySuccessCount  = "success_count"

	AttributeValueCategory = ModuleName
)

Oracle module event types

View Source 
const (
	// ModuleName is the name of the oracle module
	ModuleName = "oracle"

	// StoreKey is the string store representation
	StoreKey = ModuleName

	// RouterKey is the msg router key for the oracle module
	RouterKey = ModuleName

	// QuerierRoute is the query router key for the oracle module
	QuerierRoute = ModuleName
)
View Source 
const (
	TypeMsgDelegateFeedConsent       = "delegate_feeder"
	TypeMsgAggregateExchangeRateVote = "aggregate_exchange_rate_vote"
)

oracle message types

View Source 
const (
	DefaultVotePeriod  = 1                   // Voting every block
	DefaultSlashWindow = utils.BlocksPerWeek // window for a week
)

Default parameter values

View Source 
const (
	QueryParameters           = "parameters"
	QueryExchangeRate         = "exchangeRate"
	QueryExchangeRates        = "exchangeRates"
	QueryPriceSnapshotHistory = "priceSnapshotHistory"
	QueryTwaps                = "twaps"
	QueryActives              = "actives"
	QueryFeederDelegation     = "feederDelegation"
	QueryVotePenaltyCounter   = "votePenaltyCounter"
	QueryAggregateVote        = "aggregateVote"
	QueryAggregateVotes       = "aggregateVotes"
	QueryVoteTargets          = "voteTargets"
)

Defines the prefix of each query path

View Source 
const OracleDecPrecision = 8

OracleDecPrecision nolint

Variables

View Source 
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewProtoCodec(codectypes.NewInterfaceRegistry())
)
View Source 
var (
	ErrInvalidExchangeRate   = sdkerrors.Register(ModuleName, 2, "invalid exchange rate")
	ErrNoVote                = sdkerrors.Register(ModuleName, 4, "no vote")
	ErrNoVotingPermission    = sdkerrors.Register(ModuleName, 5, "unauthorized voter")
	ErrInvalidHash           = sdkerrors.Register(ModuleName, 6, "invalid hash")
	ErrInvalidHashLength     = sdkerrors.Register(ModuleName, 7, fmt.Sprintf("invalid hash length; should equal %d", ed25519.TruncatedSize))
	ErrVerificationFailed    = sdkerrors.Register(ModuleName, 8, "hash verification failed")
	ErrNoAggregateVote       = sdkerrors.Register(ModuleName, 12, "no aggregate vote")
	ErrNoVoteTarget          = sdkerrors.Register(ModuleName, 13, "no vote target")
	ErrUnknownDenom          = sdkerrors.Register(ModuleName, 14, "unknown denom")
	ErrNoLatestPriceSnapshot = sdkerrors.Register(ModuleName, 15, "no latest snapshot")
	ErrInvalidTwapLookback   = sdkerrors.Register(ModuleName, 16, "Twap lookback seconds is greater than max lookback duration or less than or equal to 0")
	ErrNoTwapData            = sdkerrors.Register(ModuleName, 17, "No data for the twap calculation")
	ErrParsingOracleQuery    = sdkerrors.Register(ModuleName, 18, "Error parsing SeiOracleQuery")
	ErrGettingExchangeRates  = sdkerrors.Register(ModuleName, 19, "Error while getting Exchange Rates")
	ErrEncodingExchangeRates = sdkerrors.Register(ModuleName, 20, "Error encoding exchange rates as JSON")
	ErrGettingOracleTwaps    = sdkerrors.Register(ModuleName, 21, "Error while getting Oracle Twaps in wasmd")
	ErrEncodingOracleTwaps   = sdkerrors.Register(ModuleName, 22, "Error encoding oracle twaps as JSON")
	ErrUnknownSeiOracleQuery = sdkerrors.Register(ModuleName, 23, "Error unknown sei oracle query")
	ErrAggregateVoteExist    = sdkerrors.Register(ModuleName, 24, "aggregate vote still present in current voting window")
)

Oracle Errors

View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// Keys for store prefixes
	ExchangeRateKey       = []byte{0x01} // prefix for each key to a rate
	FeederDelegationKey   = []byte{0x02} // prefix for each key to a feeder delegation
	VotePenaltyCounterKey = []byte{0x03} // prefix for each key to a miss counter
	// DEPRECATED AggregateExchangeRatePrevoteKey = []byte{0x04}
	AggregateExchangeRateVoteKey = []byte{0x05} // prefix for each key to a aggregate vote
	VoteTargetKey                = []byte{0x06} // prefix for each key to a vote target
	PriceSnapshotKey             = []byte{0x07} // key for price snapshots history
)

Keys for oracle store Items are stored with the following key: values

- 0x01<denom_Bytes>: sdk.Dec

- 0x02<valAddress_Bytes>: accAddress

- 0x03<valAddress_Bytes>: int64

- 0x04<valAddress_Bytes>: DEPRECATED: AggregateExchangeRatePrevote

- 0x05<valAddress_Bytes>: AggregateExchangeRateVote

- 0x06<denom_Bytes>: sdk.Dec

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")
	KeyRewardBand        = []byte("RewardBand")
	KeyWhitelist         = []byte("Whitelist")
	KeySlashFraction     = []byte("SlashFraction")
	KeySlashWindow       = []byte("SlashWindow")
	KeyMinValidPerWindow = []byte("MinValidPerWindow")
	KeyLookbackDuration  = []byte("LookbackDuration")
)

Parameter keys

View Source 
var (
	DefaultVoteThreshold = sdk.NewDecWithPrec(50, 2) // 50%
	DefaultRewardBand    = sdk.NewDecWithPrec(2, 2)  // 2% (-1, 1)
	DefaultWhitelist     = DenomList{
		{Name: utils.MicroAtomDenom},

		{Name: utils.MicroEthDenom},
	}
	DefaultSlashFraction     = sdk.NewDecWithPrec(0, 4) // 0.00%
	DefaultMinValidPerWindow = sdk.NewDecWithPrec(5, 2) // 5%
	DefaultLookbackDuration  = uint64(3600)             // in seconds
)

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

Functions

func ExtractDenomFromVoteTargetKey 

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

func GetAggregateExchangeRateVoteKey 

func GetAggregateExchangeRateVoteKey(v sdk.ValAddress) []byte

GetAggregateExchangeRateVoteKey - stored by *Validator* address

func GetExchangeRateKey 

func GetExchangeRateKey(denom string) []byte

GetExchangeRateKey - stored by *denom*

func GetFeederDelegationKey 

func GetFeederDelegationKey(v sdk.ValAddress) []byte

GetFeederDelegationKey - stored by *Validator* address

func GetKeyForTimestamp 

func GetKeyForTimestamp(timestamp uint64) []byte

func GetPriceSnapshotKey 

func GetPriceSnapshotKey(timestamp uint64) []byte

func GetVotePenaltyCounterKey 

func GetVotePenaltyCounterKey(v sdk.ValAddress) []byte

GetVotePenaltyCounterKey - stored by *Validator* address

func GetVoteTargetKey 

func GetVoteTargetKey(d string) []byte

func ParamKeyTable 

func ParamKeyTable() paramstypes.KeyTable

ParamKeyTable returns the parameter key table.

func RegisterInterfaces 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

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
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI // only used for simulation
}

AccountKeeper is expected keeper for auth module

type AggregateExchangeRateVote 

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

func NewAggregateExchangeRateVote 

func NewAggregateExchangeRateVote(exchangeRateTuples ExchangeRateTuples, voter sdk.ValAddress) AggregateExchangeRateVote

NewAggregateExchangeRateVote creates a AggregateExchangeRateVote instance

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

	// only used for simulation
	SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
}

BankKeeper defines the expected interface needed to retrieve account balances.

type Claim 

type Claim struct {
	Power     int64
	Weight    int64
	WinCount  int64
	DidVote   bool
	Recipient sdk.ValAddress
}

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

func NewClaim 

func NewClaim(power, weight, winCount int64, recipient sdk.ValAddress, didVote bool) Claim

NewClaim generates a Claim instance.

type Denom 

type Denom struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" yaml:"name"`
}

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

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

String implements fmt.Stringer interface

type DenomOracleExchangeRatePair 

type DenomOracleExchangeRatePair struct {
	Denom              string             `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
	OracleExchangeRate OracleExchangeRate `protobuf:"bytes,2,opt,name=oracle_exchange_rate,json=oracleExchangeRate,proto3" json:"oracle_exchange_rate"`
}

func NewDenomOracleExchangeRatePair 

func NewDenomOracleExchangeRatePair(denom string, exchangeRate sdk.Dec, lastUpdate sdk.Int) DenomOracleExchangeRatePair

func (*DenomOracleExchangeRatePair) Descriptor 

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

func (*DenomOracleExchangeRatePair) GetDenom 

func (m *DenomOracleExchangeRatePair) GetDenom() string

func (*DenomOracleExchangeRatePair) GetOracleExchangeRate 

func (m *DenomOracleExchangeRatePair) GetOracleExchangeRate() OracleExchangeRate

func (*DenomOracleExchangeRatePair) Marshal 

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

func (*DenomOracleExchangeRatePair) MarshalTo 

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

func (*DenomOracleExchangeRatePair) MarshalToSizedBuffer 

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

func (*DenomOracleExchangeRatePair) ProtoMessage 

func (*DenomOracleExchangeRatePair) ProtoMessage()

func (*DenomOracleExchangeRatePair) Reset 

func (m *DenomOracleExchangeRatePair) Reset()

func (*DenomOracleExchangeRatePair) Size 

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

func (*DenomOracleExchangeRatePair) String 

func (m *DenomOracleExchangeRatePair) String() string

func (*DenomOracleExchangeRatePair) Unmarshal 

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

func (*DenomOracleExchangeRatePair) XXX_DiscardUnknown 

func (m *DenomOracleExchangeRatePair) XXX_DiscardUnknown()

func (*DenomOracleExchangeRatePair) XXX_Marshal 

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

func (*DenomOracleExchangeRatePair) XXX_Merge 

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

func (*DenomOracleExchangeRatePair) XXX_Size 

func (m *DenomOracleExchangeRatePair) XXX_Size() int

func (*DenomOracleExchangeRatePair) XXX_Unmarshal 

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

type DenomOracleExchangeRatePairs 

type DenomOracleExchangeRatePairs []DenomOracleExchangeRatePair

OracleExchangeRates - array of OracleExchangeRate

func (DenomOracleExchangeRatePairs) String 

func (rates DenomOracleExchangeRatePairs) String() string

String implements fmt.Stringer interface

type DistributionKeeper 

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

	// only used for simulation
	GetValidatorOutstandingRewardsCoins(ctx sdk.Context, val sdk.ValAddress) sdk.DecCoins
}

DistributionKeeper is expected keeper for distribution module

type DummyStakingKeeper 

type DummyStakingKeeper struct {
	// contains filtered or unexported fields
}

DummyStakingKeeper dummy staking keeper to test ballot

func GenerateRandomTestCase 

func GenerateRandomTestCase() (rates []float64, valValAddrs []sdk.ValAddress, stakingKeeper DummyStakingKeeper)

GenerateRandomTestCase nolint

func NewDummyStakingKeeper 

func NewDummyStakingKeeper(validators []MockValidator) DummyStakingKeeper

NewDummyStakingKeeper returns new DummyStakingKeeper instance

func (DummyStakingKeeper) GetLastValidatorPower 

func (sk DummyStakingKeeper) GetLastValidatorPower(ctx sdk.Context, operator sdk.ValAddress) (power int64)

GetLastValidatorPower

func (DummyStakingKeeper) Jail 

func (DummyStakingKeeper) Jail(sdk.Context, sdk.ConsAddress)

Jail

func (DummyStakingKeeper) MaxValidators 

func (DummyStakingKeeper) MaxValidators(sdk.Context) uint32

MaxValidators returns the maximum amount of bonded validators

func (DummyStakingKeeper) PowerReduction 

func (DummyStakingKeeper) PowerReduction(ctx sdk.Context) (res sdk.Int)

PowerReduction - is the amount of staking tokens required for 1 unit of consensus-engine power

func (DummyStakingKeeper) Slash 

func (DummyStakingKeeper) Slash(sdk.Context, sdk.ConsAddress, int64, int64, sdk.Dec)

Slash nolint

func (DummyStakingKeeper) TotalBondedTokens 

func (DummyStakingKeeper) TotalBondedTokens(_ sdk.Context) sdk.Int

TotalBondedTokens nolint

func (DummyStakingKeeper) Validator 

func (sk DummyStakingKeeper) Validator(ctx sdk.Context, address sdk.ValAddress) stakingtypes.ValidatorI

Validator nolint

func (DummyStakingKeeper) Validators 

func (sk DummyStakingKeeper) Validators() []MockValidator

Validators nolint

func (DummyStakingKeeper) ValidatorsPowerStoreIterator 

func (DummyStakingKeeper) ValidatorsPowerStoreIterator(ctx sdk.Context) sdk.Iterator

ValidatorsPowerStoreIterator

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(median sdk.Dec) (standardDeviation sdk.Dec)

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

func (pb ExchangeRateBallot) ToCrossRate(bases map[string]sdk.Dec) (cb ExchangeRateBallot)

ToCrossRate return cross_rate(base/exchange_rate) ballot

func (ExchangeRateBallot) ToCrossRateWithSort 

func (pb ExchangeRateBallot) ToCrossRateWithSort(bases map[string]sdk.Dec) (cb ExchangeRateBallot)

ToCrossRateWithSort return cross_rate(base/exchange_rate) ballot

func (ExchangeRateBallot) ToMap 

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

ToMap return organized exchange rate map by validator

func (ExchangeRateBallot) WeightedMedian 

func (pb ExchangeRateBallot) WeightedMedian() sdk.Dec

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

func (ExchangeRateBallot) WeightedMedianWithAssertion 

func (pb ExchangeRateBallot) WeightedMedianWithAssertion() sdk.Dec

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

type ExchangeRateTuple 

type ExchangeRateTuple struct {
	Denom        string                                 `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty" yaml:"denom"`
	ExchangeRate github_com_cosmos_cosmos_sdk_types.Dec `` /* 158-byte string literal not displayed */
}

func NewExchangeRateTuple 

func NewExchangeRateTuple(denom string, exchangeRate sdk.Dec) ExchangeRateTuple

NewExchangeRateTuple creates a ExchangeRateTuple instance

func (*ExchangeRateTuple) Descriptor 

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

func (*ExchangeRateTuple) Marshal 

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

func (*ExchangeRateTuple) MarshalTo 

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

func (*ExchangeRateTuple) MarshalToSizedBuffer 

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

func (*ExchangeRateTuple) ProtoMessage 

func (*ExchangeRateTuple) ProtoMessage()

func (*ExchangeRateTuple) Reset 

func (m *ExchangeRateTuple) Reset()

func (*ExchangeRateTuple) Size 

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

func (ExchangeRateTuple) String 

func (v ExchangeRateTuple) String() string

String implement stringify

func (*ExchangeRateTuple) Unmarshal 

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

func (*ExchangeRateTuple) XXX_DiscardUnknown 

func (m *ExchangeRateTuple) XXX_DiscardUnknown()

func (*ExchangeRateTuple) XXX_Marshal 

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

func (*ExchangeRateTuple) XXX_Merge 

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

func (*ExchangeRateTuple) XXX_Size 

func (m *ExchangeRateTuple) XXX_Size() int

func (*ExchangeRateTuple) XXX_Unmarshal 

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

type ExchangeRateTuples 

type ExchangeRateTuples []ExchangeRateTuple

ExchangeRateTuples - array of ExchangeRateTuple

func ParseExchangeRateTuples 

func ParseExchangeRateTuples(tuplesStr string) (ExchangeRateTuples, error)

ParseExchangeRateTuples ExchangeRateTuple parser

func (ExchangeRateTuples) String 

func (tuples ExchangeRateTuples) String() string

String implements fmt.Stringer interface

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"`
}

func (*FeederDelegation) Descriptor 

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

func (*FeederDelegation) GetFeederAddress 

func (m *FeederDelegation) GetFeederAddress() string

func (*FeederDelegation) GetValidatorAddress 

func (m *FeederDelegation) GetValidatorAddress() string

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              ExchangeRateTuples          `protobuf:"bytes,3,rep,name=exchange_rates,json=exchangeRates,proto3,castrepeated=ExchangeRateTuples" json:"exchange_rates"`
	PenaltyCounters            []PenaltyCounter            `protobuf:"bytes,4,rep,name=penalty_counters,json=penaltyCounters,proto3" json:"penalty_counters"`
	AggregateExchangeRateVotes []AggregateExchangeRateVote `` /* 133-byte string literal not displayed */
	PriceSnapshots             PriceSnapshots              `protobuf:"bytes,7,rep,name=price_snapshots,json=priceSnapshots,proto3,castrepeated=PriceSnapshots" json:"price_snapshots"`
}

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

DefaultGenesisState - default GenesisState used by columbus-2

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 []ExchangeRateTuple,
	feederDelegations []FeederDelegation, penaltyCounters []PenaltyCounter,
	aggregateExchangeRateVotes []AggregateExchangeRateVote,
	priceSnapshots []PriceSnapshot,
) *GenesisState

NewGenesisState creates a new GenesisState object

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetAggregateExchangeRateVotes 

func (m *GenesisState) GetAggregateExchangeRateVotes() []AggregateExchangeRateVote

func (*GenesisState) GetExchangeRates 

func (m *GenesisState) GetExchangeRates() ExchangeRateTuples

func (*GenesisState) GetFeederDelegations 

func (m *GenesisState) GetFeederDelegations() []FeederDelegation

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetPenaltyCounters 

func (m *GenesisState) GetPenaltyCounters() []PenaltyCounter

func (*GenesisState) GetPriceSnapshots 

func (m *GenesisState) GetPriceSnapshots() PriceSnapshots

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 MockValidator 

type MockValidator struct {
	// contains filtered or unexported fields
}

MockValidator

func NewMockValidator 

func NewMockValidator(valAddr sdk.ValAddress, power int64) MockValidator

func (MockValidator) ConsPubKey 

func (MockValidator) ConsPubKey() (cryptotypes.PubKey, error)

func (MockValidator) GetBondedTokens 

func (v MockValidator) GetBondedTokens() sdk.Int

func (MockValidator) GetCommission 

func (v MockValidator) GetCommission() sdk.Dec

func (MockValidator) GetConsAddr 

func (MockValidator) GetConsAddr() (sdk.ConsAddress, error)

func (MockValidator) GetConsensusPower 

func (v MockValidator) GetConsensusPower(powerReduction sdk.Int) int64

func (MockValidator) GetDelegatorShares 

func (v MockValidator) GetDelegatorShares() sdk.Dec

func (MockValidator) GetMinSelfDelegation 

func (v MockValidator) GetMinSelfDelegation() sdk.Int

func (MockValidator) GetMoniker 

func (MockValidator) GetMoniker() string

func (MockValidator) GetOperator 

func (v MockValidator) GetOperator() sdk.ValAddress

func (MockValidator) GetStatus 

func (MockValidator) GetStatus() stakingtypes.BondStatus

func (MockValidator) GetTokens 

func (v MockValidator) GetTokens() sdk.Int

func (MockValidator) IsBonded 

func (MockValidator) IsBonded() bool

func (MockValidator) IsJailed 

func (MockValidator) IsJailed() bool

func (MockValidator) IsUnbonded 

func (MockValidator) IsUnbonded() bool

func (MockValidator) IsUnbonding 

func (MockValidator) IsUnbonding() bool

func (*MockValidator) SetConsensusPower 

func (v *MockValidator) SetConsensusPower(power int64)

func (MockValidator) SharesFromTokens 

func (v MockValidator) SharesFromTokens(amt sdk.Int) (sdk.Dec, error)

func (MockValidator) SharesFromTokensTruncated 

func (v MockValidator) SharesFromTokensTruncated(amt sdk.Int) (sdk.Dec, error)

func (MockValidator) TmConsPublicKey 

func (MockValidator) TmConsPublicKey() (tmprotocrypto.PublicKey, error)

func (MockValidator) TokensFromShares 

func (v MockValidator) TokensFromShares(sdk.Dec) sdk.Dec

func (MockValidator) TokensFromSharesRoundUp 

func (v MockValidator) TokensFromSharesRoundUp(sdk.Dec) sdk.Dec

func (MockValidator) TokensFromSharesTruncated 

func (v MockValidator) TokensFromSharesTruncated(sdk.Dec) sdk.Dec

type MsgAggregateExchangeRateVote 

type MsgAggregateExchangeRateVote struct {
	// 1 reserved from old field `salt`
	ExchangeRates string `protobuf:"bytes,2,opt,name=exchange_rates,json=exchangeRates,proto3" json:"exchange_rates,omitempty" yaml:"exchange_rates"`
	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 aggregate exchange rate vote.

func NewMsgAggregateExchangeRateVote 

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

NewMsgAggregateExchangeRateVote returns MsgAggregateExchangeRateVote instance

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

func (msg MsgAggregateExchangeRateVote) Route() string

Route implements sdk.Msg

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 sdk.Msg

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 {
	// AggregateExchangeRateVote defines a method for submitting
	// 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)
}

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

func (msg MsgDelegateFeedConsent) Route() string

Route implements sdk.Msg

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 sdk.Msg

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 MsgServer 

type MsgServer interface {
	// AggregateExchangeRateVote defines a method for submitting
	// 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)
}

MsgServer is the server API for Msg service.

type OracleExchangeRate 

type OracleExchangeRate struct {
	ExchangeRate github_com_cosmos_cosmos_sdk_types.Dec `` /* 158-byte string literal not displayed */
	LastUpdate   github_com_cosmos_cosmos_sdk_types.Int `` /* 150-byte string literal not displayed */
}

func (*OracleExchangeRate) Descriptor 

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

func (*OracleExchangeRate) Marshal 

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

func (*OracleExchangeRate) MarshalTo 

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

func (*OracleExchangeRate) MarshalToSizedBuffer 

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

func (*OracleExchangeRate) ProtoMessage 

func (*OracleExchangeRate) ProtoMessage()

func (*OracleExchangeRate) Reset 

func (m *OracleExchangeRate) Reset()

func (*OracleExchangeRate) Size 

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

func (OracleExchangeRate) String 

func (ex OracleExchangeRate) String() string

String implement stringify

func (*OracleExchangeRate) Unmarshal 

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

func (*OracleExchangeRate) XXX_DiscardUnknown 

func (m *OracleExchangeRate) XXX_DiscardUnknown()

func (*OracleExchangeRate) XXX_Marshal 

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

func (*OracleExchangeRate) XXX_Merge 

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

func (*OracleExchangeRate) XXX_Size 

func (m *OracleExchangeRate) XXX_Size() int

func (*OracleExchangeRate) XXX_Unmarshal 

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

type OracleTwap 

type OracleTwap struct {
	Denom           string                                 `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
	Twap            github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,2,opt,name=twap,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"twap" yaml:"twap"`
	LookbackSeconds int64                                  `protobuf:"varint,3,opt,name=lookback_seconds,json=lookbackSeconds,proto3" json:"lookback_seconds,omitempty"`
}

func (*OracleTwap) Descriptor 

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

func (*OracleTwap) GetDenom 

func (m *OracleTwap) GetDenom() string

func (*OracleTwap) GetLookbackSeconds 

func (m *OracleTwap) GetLookbackSeconds() int64

func (*OracleTwap) Marshal 

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

func (*OracleTwap) MarshalTo 

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

func (*OracleTwap) MarshalToSizedBuffer 

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

func (*OracleTwap) ProtoMessage 

func (*OracleTwap) ProtoMessage()

func (*OracleTwap) Reset 

func (m *OracleTwap) Reset()

func (*OracleTwap) Size 

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

func (*OracleTwap) String 

func (m *OracleTwap) String() string

func (*OracleTwap) Unmarshal 

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

func (*OracleTwap) XXX_DiscardUnknown 

func (m *OracleTwap) XXX_DiscardUnknown()

func (*OracleTwap) XXX_Marshal 

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

func (*OracleTwap) XXX_Merge 

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

func (*OracleTwap) XXX_Size 

func (m *OracleTwap) XXX_Size() int

func (*OracleTwap) XXX_Unmarshal 

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

type OracleTwaps 

type OracleTwaps []OracleTwap

type Params 

type Params struct {
	// The number of blocks per voting window, at the end of the vote period, the oracle votes are assessed and exchange rates are calculated. If the vote period is 1 this is equivalent to having oracle votes assessed and exchange rates calculated in each block.
	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 */
	RewardBand    github_com_cosmos_cosmos_sdk_types.Dec `` /* 150-byte string literal not displayed */
	Whitelist     DenomList                              `protobuf:"bytes,4,rep,name=whitelist,proto3,castrepeated=DenomList" json:"whitelist" yaml:"whitelist"`
	SlashFraction github_com_cosmos_cosmos_sdk_types.Dec `` /* 162-byte string literal not displayed */
	// The interval in blocks at which the oracle module will assess validator penalty counters, and penalize validators with too poor performance.
	SlashWindow uint64 `protobuf:"varint,6,opt,name=slash_window,json=slashWindow,proto3" json:"slash_window,omitempty" yaml:"slash_window"`
	// The minimum percentage of voting windows for which a validator must have `success`es in order to not be penalized at the end of the slash window.
	MinValidPerWindow github_com_cosmos_cosmos_sdk_types.Dec `` /* 184-byte string literal not displayed */
	LookbackDuration  uint64                                 `` /* 135-byte string literal not displayed */
}

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

func (m *Params) GetLookbackDuration() uint64

func (*Params) GetSlashWindow 

func (m *Params) GetSlashWindow() uint64

func (*Params) GetVotePeriod 

func (m *Params) GetVotePeriod() uint64

func (*Params) GetWhitelist 

func (m *Params) GetWhitelist() DenomList

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 PenaltyCounter 

type PenaltyCounter struct {
	ValidatorAddress   string              `protobuf:"bytes,1,opt,name=validator_address,json=validatorAddress,proto3" json:"validator_address,omitempty"`
	VotePenaltyCounter *VotePenaltyCounter `protobuf:"bytes,2,opt,name=vote_penalty_counter,json=votePenaltyCounter,proto3" json:"vote_penalty_counter,omitempty"`
}

func (*PenaltyCounter) Descriptor 

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

func (*PenaltyCounter) GetValidatorAddress 

func (m *PenaltyCounter) GetValidatorAddress() string

func (*PenaltyCounter) GetVotePenaltyCounter 

func (m *PenaltyCounter) GetVotePenaltyCounter() *VotePenaltyCounter

func (*PenaltyCounter) Marshal 

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

func (*PenaltyCounter) MarshalTo 

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

func (*PenaltyCounter) MarshalToSizedBuffer 

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

func (*PenaltyCounter) ProtoMessage 

func (*PenaltyCounter) ProtoMessage()

func (*PenaltyCounter) Reset 

func (m *PenaltyCounter) Reset()

func (*PenaltyCounter) Size 

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

func (*PenaltyCounter) String 

func (m *PenaltyCounter) String() string

func (*PenaltyCounter) Unmarshal 

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

func (*PenaltyCounter) XXX_DiscardUnknown 

func (m *PenaltyCounter) XXX_DiscardUnknown()

func (*PenaltyCounter) XXX_Marshal 

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

func (*PenaltyCounter) XXX_Merge 

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

func (*PenaltyCounter) XXX_Size 

func (m *PenaltyCounter) XXX_Size() int

func (*PenaltyCounter) XXX_Unmarshal 

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

type PriceSnapshot 

type PriceSnapshot struct {
	SnapshotTimestamp  int64              `protobuf:"varint,1,opt,name=snapshotTimestamp,proto3" json:"snapshotTimestamp,omitempty" yaml:"snapshot_timestamp"`
	PriceSnapshotItems PriceSnapshotItems `` /* 167-byte string literal not displayed */
}

func NewPriceSnapshot 

func NewPriceSnapshot(priceSnapshotItems PriceSnapshotItems, snapshotTimestamp int64) PriceSnapshot

func (*PriceSnapshot) Descriptor 

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

func (*PriceSnapshot) GetPriceSnapshotItems 

func (m *PriceSnapshot) GetPriceSnapshotItems() PriceSnapshotItems

func (*PriceSnapshot) GetSnapshotTimestamp 

func (m *PriceSnapshot) GetSnapshotTimestamp() int64

func (*PriceSnapshot) Marshal 

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

func (*PriceSnapshot) MarshalTo 

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

func (*PriceSnapshot) MarshalToSizedBuffer 

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

func (*PriceSnapshot) ProtoMessage 

func (*PriceSnapshot) ProtoMessage()

func (*PriceSnapshot) Reset 

func (m *PriceSnapshot) Reset()

func (*PriceSnapshot) Size 

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

func (*PriceSnapshot) String 

func (m *PriceSnapshot) String() string

func (*PriceSnapshot) Unmarshal 

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

func (*PriceSnapshot) XXX_DiscardUnknown 

func (m *PriceSnapshot) XXX_DiscardUnknown()

func (*PriceSnapshot) XXX_Marshal 

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

func (*PriceSnapshot) XXX_Merge 

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

func (*PriceSnapshot) XXX_Size 

func (m *PriceSnapshot) XXX_Size() int

func (*PriceSnapshot) XXX_Unmarshal 

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

type PriceSnapshotItem 

type PriceSnapshotItem struct {
	Denom              string             `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
	OracleExchangeRate OracleExchangeRate `protobuf:"bytes,2,opt,name=oracle_exchange_rate,json=oracleExchangeRate,proto3" json:"oracle_exchange_rate"`
}

func NewPriceSnapshotItem 

func NewPriceSnapshotItem(denom string, exchangeRate OracleExchangeRate) PriceSnapshotItem

func (*PriceSnapshotItem) Descriptor 

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

func (*PriceSnapshotItem) GetDenom 

func (m *PriceSnapshotItem) GetDenom() string

func (*PriceSnapshotItem) GetOracleExchangeRate 

func (m *PriceSnapshotItem) GetOracleExchangeRate() OracleExchangeRate

func (*PriceSnapshotItem) Marshal 

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

func (*PriceSnapshotItem) MarshalTo 

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

func (*PriceSnapshotItem) MarshalToSizedBuffer 

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

func (*PriceSnapshotItem) ProtoMessage 

func (*PriceSnapshotItem) ProtoMessage()

func (*PriceSnapshotItem) Reset 

func (m *PriceSnapshotItem) Reset()

func (*PriceSnapshotItem) Size 

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

func (*PriceSnapshotItem) String 

func (m *PriceSnapshotItem) String() string

func (*PriceSnapshotItem) Unmarshal 

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

func (*PriceSnapshotItem) XXX_DiscardUnknown 

func (m *PriceSnapshotItem) XXX_DiscardUnknown()

func (*PriceSnapshotItem) XXX_Marshal 

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

func (*PriceSnapshotItem) XXX_Merge 

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

func (*PriceSnapshotItem) XXX_Size 

func (m *PriceSnapshotItem) XXX_Size() int

func (*PriceSnapshotItem) XXX_Unmarshal 

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

type PriceSnapshotItems 

type PriceSnapshotItems []PriceSnapshotItem

func (PriceSnapshotItems) String 

func (items PriceSnapshotItems) String() string

String implements fmt.Stringer interface

type PriceSnapshots 

type PriceSnapshots []PriceSnapshot

OracleExchangeRates - array of OracleExchangeRate

func (PriceSnapshots) String 

func (snapshots PriceSnapshots) String() string

String implements fmt.Stringer interface

type QueryActivesRequest 

type QueryActivesRequest struct {
}

QueryActivesRequest is the request type for the Query/Actives RPC method.

func (*QueryActivesRequest) Descriptor 

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

func (*QueryActivesRequest) Marshal 

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

func (*QueryActivesRequest) MarshalTo 

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

func (*QueryActivesRequest) MarshalToSizedBuffer 

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

func (*QueryActivesRequest) ProtoMessage 

func (*QueryActivesRequest) ProtoMessage()

func (*QueryActivesRequest) Reset 

func (m *QueryActivesRequest) Reset()

func (*QueryActivesRequest) Size 

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

func (*QueryActivesRequest) String 

func (m *QueryActivesRequest) String() string

func (*QueryActivesRequest) Unmarshal 

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

func (*QueryActivesRequest) XXX_DiscardUnknown 

func (m *QueryActivesRequest) XXX_DiscardUnknown()

func (*QueryActivesRequest) XXX_Marshal 

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

func (*QueryActivesRequest) XXX_Merge 

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

func (*QueryActivesRequest) XXX_Size 

func (m *QueryActivesRequest) XXX_Size() int

func (*QueryActivesRequest) XXX_Unmarshal 

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

type QueryActivesResponse 

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

QueryActivesResponse is response type for the Query/Actives RPC method.

func (*QueryActivesResponse) Descriptor 

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

func (*QueryActivesResponse) GetActives 

func (m *QueryActivesResponse) GetActives() []string

func (*QueryActivesResponse) Marshal 

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

func (*QueryActivesResponse) MarshalTo 

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

func (*QueryActivesResponse) MarshalToSizedBuffer 

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

func (*QueryActivesResponse) ProtoMessage 

func (*QueryActivesResponse) ProtoMessage()

func (*QueryActivesResponse) Reset 

func (m *QueryActivesResponse) Reset()

func (*QueryActivesResponse) Size 

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

func (*QueryActivesResponse) String 

func (m *QueryActivesResponse) String() string

func (*QueryActivesResponse) Unmarshal 

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

func (*QueryActivesResponse) XXX_DiscardUnknown 

func (m *QueryActivesResponse) XXX_DiscardUnknown()

func (*QueryActivesResponse) XXX_Marshal 

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

func (*QueryActivesResponse) XXX_Merge 

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

func (*QueryActivesResponse) XXX_Size 

func (m *QueryActivesResponse) XXX_Size() int

func (*QueryActivesResponse) XXX_Unmarshal 

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

type QueryAggregateVoteParams 

type QueryAggregateVoteParams struct {
	Validator sdk.ValAddress
}

QueryAggregateVoteParams defines the params for the following queries: - 'custom/oracle/aggregateVote'

func NewQueryAggregateVoteParams 

func NewQueryAggregateVoteParams(validator sdk.ValAddress) QueryAggregateVoteParams

NewQueryAggregateVoteParams returns params for feeder delegation query

type QueryClient 

type QueryClient interface {
	// ExchangeRate returns exchange rate of a denom
	ExchangeRate(ctx context.Context, in *QueryExchangeRateRequest, opts ...grpc.CallOption) (*QueryExchangeRateResponse, error)
	// ExchangeRates returns exchange rates of all denoms
	ExchangeRates(ctx context.Context, in *QueryExchangeRatesRequest, opts ...grpc.CallOption) (*QueryExchangeRatesResponse, error)
	// Actives returns all active denoms
	Actives(ctx context.Context, in *QueryActivesRequest, opts ...grpc.CallOption) (*QueryActivesResponse, error)
	// VoteTargets returns all vote target denoms
	VoteTargets(ctx context.Context, in *QueryVoteTargetsRequest, opts ...grpc.CallOption) (*QueryVoteTargetsResponse, error)
	// PriceSnapshotHistory returns the history of price snapshots for all assets
	PriceSnapshotHistory(ctx context.Context, in *QueryPriceSnapshotHistoryRequest, opts ...grpc.CallOption) (*QueryPriceSnapshotHistoryResponse, error)
	Twaps(ctx context.Context, in *QueryTwapsRequest, opts ...grpc.CallOption) (*QueryTwapsResponse, error)
	// FeederDelegation returns feeder delegation of a validator
	FeederDelegation(ctx context.Context, in *QueryFeederDelegationRequest, opts ...grpc.CallOption) (*QueryFeederDelegationResponse, error)
	// MissCounter returns oracle miss counter of a validator
	VotePenaltyCounter(ctx context.Context, in *QueryVotePenaltyCounterRequest, opts ...grpc.CallOption) (*QueryVotePenaltyCounterResponse, error)
	// SlashWindow returns slash window information
	SlashWindow(ctx context.Context, in *QuerySlashWindowRequest, opts ...grpc.CallOption) (*QuerySlashWindowResponse, error)
	// Params queries all parameters.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, 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 QueryExchangeRateParams 

type QueryExchangeRateParams struct {
	Denom string
}

QueryExchangeRateParams defines the params for the following queries: - 'custom/oracle/exchange_rate'

func NewQueryExchangeRateParams 

func NewQueryExchangeRateParams(denom string) QueryExchangeRateParams

NewQueryExchangeRateParams returns params for exchange_rate query

type QueryExchangeRateRequest 

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

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

func (*QueryExchangeRateRequest) Descriptor 

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

func (*QueryExchangeRateRequest) Marshal 

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

func (*QueryExchangeRateRequest) MarshalTo 

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

func (*QueryExchangeRateRequest) MarshalToSizedBuffer 

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

func (*QueryExchangeRateRequest) ProtoMessage 

func (*QueryExchangeRateRequest) ProtoMessage()

func (*QueryExchangeRateRequest) Reset 

func (m *QueryExchangeRateRequest) Reset()

func (*QueryExchangeRateRequest) Size 

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

func (*QueryExchangeRateRequest) String 

func (m *QueryExchangeRateRequest) String() string

func (*QueryExchangeRateRequest) Unmarshal 

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

func (*QueryExchangeRateRequest) XXX_DiscardUnknown 

func (m *QueryExchangeRateRequest) XXX_DiscardUnknown()

func (*QueryExchangeRateRequest) XXX_Marshal 

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

func (*QueryExchangeRateRequest) XXX_Merge 

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

func (*QueryExchangeRateRequest) XXX_Size 

func (m *QueryExchangeRateRequest) XXX_Size() int

func (*QueryExchangeRateRequest) XXX_Unmarshal 

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

type QueryExchangeRateResponse 

type QueryExchangeRateResponse struct {
	// exchange_rate defines the exchange rate of Sei denominated in various Sei
	OracleExchangeRate OracleExchangeRate `protobuf:"bytes,1,opt,name=oracle_exchange_rate,json=oracleExchangeRate,proto3" json:"oracle_exchange_rate"`
}

QueryExchangeRateResponse is response type for the Query/ExchangeRate RPC method.

func (*QueryExchangeRateResponse) Descriptor 

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

func (*QueryExchangeRateResponse) GetOracleExchangeRate 

func (m *QueryExchangeRateResponse) GetOracleExchangeRate() OracleExchangeRate

func (*QueryExchangeRateResponse) Marshal 

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

func (*QueryExchangeRateResponse) MarshalTo 

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

func (*QueryExchangeRateResponse) MarshalToSizedBuffer 

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

func (*QueryExchangeRateResponse) ProtoMessage 

func (*QueryExchangeRateResponse) ProtoMessage()

func (*QueryExchangeRateResponse) Reset 

func (m *QueryExchangeRateResponse) Reset()

func (*QueryExchangeRateResponse) Size 

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

func (*QueryExchangeRateResponse) String 

func (m *QueryExchangeRateResponse) String() string

func (*QueryExchangeRateResponse) Unmarshal 

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

func (*QueryExchangeRateResponse) XXX_DiscardUnknown 

func (m *QueryExchangeRateResponse) XXX_DiscardUnknown()

func (*QueryExchangeRateResponse) XXX_Marshal 

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

func (*QueryExchangeRateResponse) XXX_Merge 

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

func (*QueryExchangeRateResponse) XXX_Size 

func (m *QueryExchangeRateResponse) XXX_Size() int

func (*QueryExchangeRateResponse) XXX_Unmarshal 

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

type QueryExchangeRatesRequest 

type QueryExchangeRatesRequest struct {
}

QueryExchangeRatesRequest is the request type for the Query/ExchangeRates RPC method.

func (*QueryExchangeRatesRequest) Descriptor 

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

func (*QueryExchangeRatesRequest) Marshal 

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

func (*QueryExchangeRatesRequest) MarshalTo 

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

func (*QueryExchangeRatesRequest) MarshalToSizedBuffer 

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

func (*QueryExchangeRatesRequest) ProtoMessage 

func (*QueryExchangeRatesRequest) ProtoMessage()

func (*QueryExchangeRatesRequest) Reset 

func (m *QueryExchangeRatesRequest) Reset()

func (*QueryExchangeRatesRequest) Size 

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

func (*QueryExchangeRatesRequest) String 

func (m *QueryExchangeRatesRequest) String() string

func (*QueryExchangeRatesRequest) Unmarshal 

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

func (*QueryExchangeRatesRequest) XXX_DiscardUnknown 

func (m *QueryExchangeRatesRequest) XXX_DiscardUnknown()

func (*QueryExchangeRatesRequest) XXX_Marshal 

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

func (*QueryExchangeRatesRequest) XXX_Merge 

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

func (*QueryExchangeRatesRequest) XXX_Size 

func (m *QueryExchangeRatesRequest) XXX_Size() int

func (*QueryExchangeRatesRequest) XXX_Unmarshal 

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

type QueryExchangeRatesResponse 

type QueryExchangeRatesResponse struct {
	// exchange_rates defines a list of the exchange rate for all whitelisted denoms.
	DenomOracleExchangeRatePairs DenomOracleExchangeRatePairs `` /* 183-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) GetDenomOracleExchangeRatePairs 

func (m *QueryExchangeRatesResponse) GetDenomOracleExchangeRatePairs() DenomOracleExchangeRatePairs

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 QueryFeederDelegationParams 

type QueryFeederDelegationParams struct {
	Validator sdk.ValAddress
}

QueryFeederDelegationParams defeins the params for the following queries: - 'custom/oracle/feederDelegation'

func NewQueryFeederDelegationParams 

func NewQueryFeederDelegationParams(validator sdk.ValAddress) QueryFeederDelegationParams

NewQueryFeederDelegationParams returns params for feeder delegation query

type QueryFeederDelegationRequest 

type QueryFeederDelegationRequest 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"`
}

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

func (*QueryFeederDelegationRequest) Descriptor 

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

func (*QueryFeederDelegationRequest) Marshal 

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

func (*QueryFeederDelegationRequest) MarshalTo 

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

func (*QueryFeederDelegationRequest) MarshalToSizedBuffer 

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

func (*QueryFeederDelegationRequest) ProtoMessage 

func (*QueryFeederDelegationRequest) ProtoMessage()

func (*QueryFeederDelegationRequest) Reset 

func (m *QueryFeederDelegationRequest) Reset()

func (*QueryFeederDelegationRequest) Size 

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

func (*QueryFeederDelegationRequest) String 

func (m *QueryFeederDelegationRequest) String() string

func (*QueryFeederDelegationRequest) Unmarshal 

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

func (*QueryFeederDelegationRequest) XXX_DiscardUnknown 

func (m *QueryFeederDelegationRequest) XXX_DiscardUnknown()

func (*QueryFeederDelegationRequest) XXX_Marshal 

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

func (*QueryFeederDelegationRequest) XXX_Merge 

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

func (*QueryFeederDelegationRequest) XXX_Size 

func (m *QueryFeederDelegationRequest) XXX_Size() int

func (*QueryFeederDelegationRequest) XXX_Unmarshal 

func (m *QueryFeederDelegationRequest) 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) GetFeederAddr 

func (m *QueryFeederDelegationResponse) GetFeederAddr() string

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 QueryParamsRequest 

type QueryParamsRequest struct {
}

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

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

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

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

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryPriceSnapshotHistoryRequest 

type QueryPriceSnapshotHistoryRequest struct {
}

request type for price snapshot history RPC method

func (*QueryPriceSnapshotHistoryRequest) Descriptor 

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

func (*QueryPriceSnapshotHistoryRequest) Marshal 

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

func (*QueryPriceSnapshotHistoryRequest) MarshalTo 

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

func (*QueryPriceSnapshotHistoryRequest) MarshalToSizedBuffer 

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

func (*QueryPriceSnapshotHistoryRequest) ProtoMessage 

func (*QueryPriceSnapshotHistoryRequest) ProtoMessage()

func (*QueryPriceSnapshotHistoryRequest) Reset 

func (m *QueryPriceSnapshotHistoryRequest) Reset()

func (*QueryPriceSnapshotHistoryRequest) Size 

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

func (*QueryPriceSnapshotHistoryRequest) String 

func (m *QueryPriceSnapshotHistoryRequest) String() string

func (*QueryPriceSnapshotHistoryRequest) Unmarshal 

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

func (*QueryPriceSnapshotHistoryRequest) XXX_DiscardUnknown 

func (m *QueryPriceSnapshotHistoryRequest) XXX_DiscardUnknown()

func (*QueryPriceSnapshotHistoryRequest) XXX_Marshal 

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

func (*QueryPriceSnapshotHistoryRequest) XXX_Merge 

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

func (*QueryPriceSnapshotHistoryRequest) XXX_Size 

func (m *QueryPriceSnapshotHistoryRequest) XXX_Size() int

func (*QueryPriceSnapshotHistoryRequest) XXX_Unmarshal 

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

type QueryPriceSnapshotHistoryResponse 

type QueryPriceSnapshotHistoryResponse struct {
	PriceSnapshots PriceSnapshots `protobuf:"bytes,1,rep,name=price_snapshots,json=priceSnapshots,proto3,castrepeated=PriceSnapshots" json:"price_snapshots"`
}

func (*QueryPriceSnapshotHistoryResponse) Descriptor 

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

func (*QueryPriceSnapshotHistoryResponse) GetPriceSnapshots 

func (m *QueryPriceSnapshotHistoryResponse) GetPriceSnapshots() PriceSnapshots

func (*QueryPriceSnapshotHistoryResponse) Marshal 

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

func (*QueryPriceSnapshotHistoryResponse) MarshalTo 

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

func (*QueryPriceSnapshotHistoryResponse) MarshalToSizedBuffer 

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

func (*QueryPriceSnapshotHistoryResponse) ProtoMessage 

func (*QueryPriceSnapshotHistoryResponse) ProtoMessage()

func (*QueryPriceSnapshotHistoryResponse) Reset 

func (m *QueryPriceSnapshotHistoryResponse) Reset()

func (*QueryPriceSnapshotHistoryResponse) Size 

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

func (*QueryPriceSnapshotHistoryResponse) String 

func (m *QueryPriceSnapshotHistoryResponse) String() string

func (*QueryPriceSnapshotHistoryResponse) Unmarshal 

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

func (*QueryPriceSnapshotHistoryResponse) XXX_DiscardUnknown 

func (m *QueryPriceSnapshotHistoryResponse) XXX_DiscardUnknown()

func (*QueryPriceSnapshotHistoryResponse) XXX_Marshal 

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

func (*QueryPriceSnapshotHistoryResponse) XXX_Merge 

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

func (*QueryPriceSnapshotHistoryResponse) XXX_Size 

func (m *QueryPriceSnapshotHistoryResponse) XXX_Size() int

func (*QueryPriceSnapshotHistoryResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// ExchangeRate returns exchange rate of a denom
	ExchangeRate(context.Context, *QueryExchangeRateRequest) (*QueryExchangeRateResponse, error)
	// ExchangeRates returns exchange rates of all denoms
	ExchangeRates(context.Context, *QueryExchangeRatesRequest) (*QueryExchangeRatesResponse, error)
	// Actives returns all active denoms
	Actives(context.Context, *QueryActivesRequest) (*QueryActivesResponse, error)
	// VoteTargets returns all vote target denoms
	VoteTargets(context.Context, *QueryVoteTargetsRequest) (*QueryVoteTargetsResponse, error)
	// PriceSnapshotHistory returns the history of price snapshots for all assets
	PriceSnapshotHistory(context.Context, *QueryPriceSnapshotHistoryRequest) (*QueryPriceSnapshotHistoryResponse, error)
	Twaps(context.Context, *QueryTwapsRequest) (*QueryTwapsResponse, error)
	// FeederDelegation returns feeder delegation of a validator
	FeederDelegation(context.Context, *QueryFeederDelegationRequest) (*QueryFeederDelegationResponse, error)
	// MissCounter returns oracle miss counter of a validator
	VotePenaltyCounter(context.Context, *QueryVotePenaltyCounterRequest) (*QueryVotePenaltyCounterResponse, error)
	// SlashWindow returns slash window information
	SlashWindow(context.Context, *QuerySlashWindowRequest) (*QuerySlashWindowResponse, error)
	// Params queries all parameters.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
}

QueryServer is the server API for Query service.

type QuerySlashWindowRequest 

type QuerySlashWindowRequest struct {
}

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

func (*QuerySlashWindowRequest) Descriptor 

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

func (*QuerySlashWindowRequest) Marshal 

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

func (*QuerySlashWindowRequest) MarshalTo 

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

func (*QuerySlashWindowRequest) MarshalToSizedBuffer 

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

func (*QuerySlashWindowRequest) ProtoMessage 

func (*QuerySlashWindowRequest) ProtoMessage()

func (*QuerySlashWindowRequest) Reset 

func (m *QuerySlashWindowRequest) Reset()

func (*QuerySlashWindowRequest) Size 

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

func (*QuerySlashWindowRequest) String 

func (m *QuerySlashWindowRequest) String() string

func (*QuerySlashWindowRequest) Unmarshal 

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

func (*QuerySlashWindowRequest) XXX_DiscardUnknown 

func (m *QuerySlashWindowRequest) XXX_DiscardUnknown()

func (*QuerySlashWindowRequest) XXX_Marshal 

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

func (*QuerySlashWindowRequest) XXX_Merge 

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

func (*QuerySlashWindowRequest) XXX_Size 

func (m *QuerySlashWindowRequest) XXX_Size() int

func (*QuerySlashWindowRequest) XXX_Unmarshal 

func (m *QuerySlashWindowRequest) 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) GetWindowProgress 

func (m *QuerySlashWindowResponse) GetWindowProgress() uint64

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 QueryTwapsParams 

type QueryTwapsParams struct {
	LookbackSeconds int64
}

QueryTwapParams defines the params for the following queries: - 'custom/oracle/twap'

func NewQueryTwapsParams 

func NewQueryTwapsParams(lookbackSeconds int64) QueryTwapsParams

NewQueryExchangeRateParams returns params for exchange_rate query

type QueryTwapsRequest 

type QueryTwapsRequest struct {
	LookbackSeconds uint64 `protobuf:"varint,1,opt,name=lookback_seconds,json=lookbackSeconds,proto3" json:"lookback_seconds,omitempty"`
}

request type for twap RPC method

func (*QueryTwapsRequest) Descriptor 

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

func (*QueryTwapsRequest) GetLookbackSeconds 

func (m *QueryTwapsRequest) GetLookbackSeconds() uint64

func (*QueryTwapsRequest) Marshal 

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

func (*QueryTwapsRequest) MarshalTo 

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

func (*QueryTwapsRequest) MarshalToSizedBuffer 

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

func (*QueryTwapsRequest) ProtoMessage 

func (*QueryTwapsRequest) ProtoMessage()

func (*QueryTwapsRequest) Reset 

func (m *QueryTwapsRequest) Reset()

func (*QueryTwapsRequest) Size 

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

func (*QueryTwapsRequest) String 

func (m *QueryTwapsRequest) String() string

func (*QueryTwapsRequest) Unmarshal 

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

func (*QueryTwapsRequest) XXX_DiscardUnknown 

func (m *QueryTwapsRequest) XXX_DiscardUnknown()

func (*QueryTwapsRequest) XXX_Marshal 

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

func (*QueryTwapsRequest) XXX_Merge 

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

func (*QueryTwapsRequest) XXX_Size 

func (m *QueryTwapsRequest) XXX_Size() int

func (*QueryTwapsRequest) XXX_Unmarshal 

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

type QueryTwapsResponse 

type QueryTwapsResponse struct {
	OracleTwaps OracleTwaps `protobuf:"bytes,1,rep,name=oracle_twaps,json=oracleTwaps,proto3,castrepeated=OracleTwaps" json:"oracle_twaps"`
}

func (*QueryTwapsResponse) Descriptor 

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

func (*QueryTwapsResponse) GetOracleTwaps 

func (m *QueryTwapsResponse) GetOracleTwaps() OracleTwaps

func (*QueryTwapsResponse) Marshal 

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

func (*QueryTwapsResponse) MarshalTo 

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

func (*QueryTwapsResponse) MarshalToSizedBuffer 

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

func (*QueryTwapsResponse) ProtoMessage 

func (*QueryTwapsResponse) ProtoMessage()

func (*QueryTwapsResponse) Reset 

func (m *QueryTwapsResponse) Reset()

func (*QueryTwapsResponse) Size 

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

func (*QueryTwapsResponse) String 

func (m *QueryTwapsResponse) String() string

func (*QueryTwapsResponse) Unmarshal 

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

func (*QueryTwapsResponse) XXX_DiscardUnknown 

func (m *QueryTwapsResponse) XXX_DiscardUnknown()

func (*QueryTwapsResponse) XXX_Marshal 

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

func (*QueryTwapsResponse) XXX_Merge 

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

func (*QueryTwapsResponse) XXX_Size 

func (m *QueryTwapsResponse) XXX_Size() int

func (*QueryTwapsResponse) XXX_Unmarshal 

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

type QueryVotePenaltyCounterParams 

type QueryVotePenaltyCounterParams struct {
	Validator sdk.ValAddress
}

QueryMissCounterParams defines the params for the following queries: - 'custom/oracle/missCounter'

func NewQueryVotePenaltyCounterParams 

func NewQueryVotePenaltyCounterParams(validator sdk.ValAddress) QueryVotePenaltyCounterParams

NewQueryVotePenaltyCounterParams returns params for feeder delegation query

type QueryVotePenaltyCounterRequest 

type QueryVotePenaltyCounterRequest 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"`
}

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

func (*QueryVotePenaltyCounterRequest) Descriptor 

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

func (*QueryVotePenaltyCounterRequest) Marshal 

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

func (*QueryVotePenaltyCounterRequest) MarshalTo 

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

func (*QueryVotePenaltyCounterRequest) MarshalToSizedBuffer 

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

func (*QueryVotePenaltyCounterRequest) ProtoMessage 

func (*QueryVotePenaltyCounterRequest) ProtoMessage()

func (*QueryVotePenaltyCounterRequest) Reset 

func (m *QueryVotePenaltyCounterRequest) Reset()

func (*QueryVotePenaltyCounterRequest) Size 

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

func (*QueryVotePenaltyCounterRequest) String 

func (m *QueryVotePenaltyCounterRequest) String() string

func (*QueryVotePenaltyCounterRequest) Unmarshal 

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

func (*QueryVotePenaltyCounterRequest) XXX_DiscardUnknown 

func (m *QueryVotePenaltyCounterRequest) XXX_DiscardUnknown()

func (*QueryVotePenaltyCounterRequest) XXX_Marshal 

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

func (*QueryVotePenaltyCounterRequest) XXX_Merge 

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

func (*QueryVotePenaltyCounterRequest) XXX_Size 

func (m *QueryVotePenaltyCounterRequest) XXX_Size() int

func (*QueryVotePenaltyCounterRequest) XXX_Unmarshal 

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

type QueryVotePenaltyCounterResponse 

type QueryVotePenaltyCounterResponse struct {
	VotePenaltyCounter *VotePenaltyCounter `protobuf:"bytes,1,opt,name=vote_penalty_counter,json=votePenaltyCounter,proto3" json:"vote_penalty_counter,omitempty"`
}

QueryVotePenaltyCounterResponse is response type for the Query/VotePenaltyCounter RPC method.

func (*QueryVotePenaltyCounterResponse) Descriptor 

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

func (*QueryVotePenaltyCounterResponse) GetVotePenaltyCounter 

func (m *QueryVotePenaltyCounterResponse) GetVotePenaltyCounter() *VotePenaltyCounter

func (*QueryVotePenaltyCounterResponse) Marshal 

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

func (*QueryVotePenaltyCounterResponse) MarshalTo 

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

func (*QueryVotePenaltyCounterResponse) MarshalToSizedBuffer 

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

func (*QueryVotePenaltyCounterResponse) ProtoMessage 

func (*QueryVotePenaltyCounterResponse) ProtoMessage()

func (*QueryVotePenaltyCounterResponse) Reset 

func (m *QueryVotePenaltyCounterResponse) Reset()

func (*QueryVotePenaltyCounterResponse) Size 

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

func (*QueryVotePenaltyCounterResponse) String 

func (m *QueryVotePenaltyCounterResponse) String() string

func (*QueryVotePenaltyCounterResponse) Unmarshal 

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

func (*QueryVotePenaltyCounterResponse) XXX_DiscardUnknown 

func (m *QueryVotePenaltyCounterResponse) XXX_DiscardUnknown()

func (*QueryVotePenaltyCounterResponse) XXX_Marshal 

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

func (*QueryVotePenaltyCounterResponse) XXX_Merge 

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

func (*QueryVotePenaltyCounterResponse) XXX_Size 

func (m *QueryVotePenaltyCounterResponse) XXX_Size() int

func (*QueryVotePenaltyCounterResponse) XXX_Unmarshal 

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

type QueryVoteTargetsRequest 

type QueryVoteTargetsRequest struct {
}

QueryVoteTargetsRequest is the request type for the Query/VoteTargets RPC method.

func (*QueryVoteTargetsRequest) Descriptor 

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

func (*QueryVoteTargetsRequest) Marshal 

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

func (*QueryVoteTargetsRequest) MarshalTo 

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

func (*QueryVoteTargetsRequest) MarshalToSizedBuffer 

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

func (*QueryVoteTargetsRequest) ProtoMessage 

func (*QueryVoteTargetsRequest) ProtoMessage()

func (*QueryVoteTargetsRequest) Reset 

func (m *QueryVoteTargetsRequest) Reset()

func (*QueryVoteTargetsRequest) Size 

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

func (*QueryVoteTargetsRequest) String 

func (m *QueryVoteTargetsRequest) String() string

func (*QueryVoteTargetsRequest) Unmarshal 

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

func (*QueryVoteTargetsRequest) XXX_DiscardUnknown 

func (m *QueryVoteTargetsRequest) XXX_DiscardUnknown()

func (*QueryVoteTargetsRequest) XXX_Marshal 

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

func (*QueryVoteTargetsRequest) XXX_Merge 

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

func (*QueryVoteTargetsRequest) XXX_Size 

func (m *QueryVoteTargetsRequest) XXX_Size() int

func (*QueryVoteTargetsRequest) XXX_Unmarshal 

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

type QueryVoteTargetsResponse 

type QueryVoteTargetsResponse struct {
	// vote_targets defines a list of the denomination in which everyone
	// should vote in the current vote period.
	VoteTargets []string `protobuf:"bytes,1,rep,name=vote_targets,json=voteTargets,proto3" json:"vote_targets,omitempty"`
}

QueryVoteTargetsResponse is response type for the Query/VoteTargets RPC method.

func (*QueryVoteTargetsResponse) Descriptor 

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

func (*QueryVoteTargetsResponse) GetVoteTargets 

func (m *QueryVoteTargetsResponse) GetVoteTargets() []string

func (*QueryVoteTargetsResponse) Marshal 

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

func (*QueryVoteTargetsResponse) MarshalTo 

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

func (*QueryVoteTargetsResponse) MarshalToSizedBuffer 

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

func (*QueryVoteTargetsResponse) ProtoMessage 

func (*QueryVoteTargetsResponse) ProtoMessage()

func (*QueryVoteTargetsResponse) Reset 

func (m *QueryVoteTargetsResponse) Reset()

func (*QueryVoteTargetsResponse) Size 

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

func (*QueryVoteTargetsResponse) String 

func (m *QueryVoteTargetsResponse) String() string

func (*QueryVoteTargetsResponse) Unmarshal 

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

func (*QueryVoteTargetsResponse) XXX_DiscardUnknown 

func (m *QueryVoteTargetsResponse) XXX_DiscardUnknown()

func (*QueryVoteTargetsResponse) XXX_Marshal 

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

func (*QueryVoteTargetsResponse) XXX_Merge 

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

func (*QueryVoteTargetsResponse) XXX_Size 

func (m *QueryVoteTargetsResponse) XXX_Size() int

func (*QueryVoteTargetsResponse) XXX_Unmarshal 

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

type QueryVotesParams 

type QueryVotesParams struct {
	Voter sdk.ValAddress
	Denom string
}

QueryVotesParams defines the params for the following queries: - 'custom/oracle/votes'

func NewQueryVotesParams 

func NewQueryVotesParams(voter sdk.ValAddress, denom string) QueryVotesParams

NewQueryVotesParams returns params for exchange_rate votes query

type StakingKeeper 

type StakingKeeper interface {
	Validator(ctx sdk.Context, address sdk.ValAddress) stakingtypes.ValidatorI // get validator by operator address; nil when validator not found
	TotalBondedTokens(sdk.Context) sdk.Int                                     // total bonded tokens within the validator set
	Slash(sdk.Context, sdk.ConsAddress, int64, int64, sdk.Dec)                 // slash the validator and delegators of the validator, specifying offence height, offence power, and slash fraction
	Jail(sdk.Context, sdk.ConsAddress)                                         // jail a validator
	ValidatorsPowerStoreIterator(ctx sdk.Context) sdk.Iterator                 // an iterator for the current validator power store
	MaxValidators(sdk.Context) uint32                                          // MaxValidators returns the maximum amount of bonded validators
	PowerReduction(ctx sdk.Context) (res sdk.Int)
}

StakingKeeper is expected keeper for staking module

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

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)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Actives 

func (*UnimplementedQueryServer) Actives(ctx context.Context, req *QueryActivesRequest) (*QueryActivesResponse, error)

func (*UnimplementedQueryServer) ExchangeRate 

func (*UnimplementedQueryServer) ExchangeRate(ctx context.Context, req *QueryExchangeRateRequest) (*QueryExchangeRateResponse, error)

func (*UnimplementedQueryServer) ExchangeRates 

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

func (*UnimplementedQueryServer) FeederDelegation 

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

func (*UnimplementedQueryServer) Params 

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

func (*UnimplementedQueryServer) PriceSnapshotHistory 

func (*UnimplementedQueryServer) PriceSnapshotHistory(ctx context.Context, req *QueryPriceSnapshotHistoryRequest) (*QueryPriceSnapshotHistoryResponse, error)

func (*UnimplementedQueryServer) SlashWindow 

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

func (*UnimplementedQueryServer) Twaps 

func (*UnimplementedQueryServer) Twaps(ctx context.Context, req *QueryTwapsRequest) (*QueryTwapsResponse, error)

func (*UnimplementedQueryServer) VotePenaltyCounter 

func (*UnimplementedQueryServer) VotePenaltyCounter(ctx context.Context, req *QueryVotePenaltyCounterRequest) (*QueryVotePenaltyCounterResponse, error)

func (*UnimplementedQueryServer) VoteTargets 

func (*UnimplementedQueryServer) VoteTargets(ctx context.Context, req *QueryVoteTargetsRequest) (*QueryVoteTargetsResponse, 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 VotePenaltyCounter 

type VotePenaltyCounter struct {
	MissCount    uint64 `protobuf:"varint,1,opt,name=miss_count,json=missCount,proto3" json:"miss_count,omitempty"`
	AbstainCount uint64 `protobuf:"varint,2,opt,name=abstain_count,json=abstainCount,proto3" json:"abstain_count,omitempty"`
	SuccessCount uint64 `protobuf:"varint,3,opt,name=success_count,json=successCount,proto3" json:"success_count,omitempty"`
}

func (*VotePenaltyCounter) Descriptor 

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

func (*VotePenaltyCounter) GetAbstainCount 

func (m *VotePenaltyCounter) GetAbstainCount() uint64

func (*VotePenaltyCounter) GetMissCount 

func (m *VotePenaltyCounter) GetMissCount() uint64

func (*VotePenaltyCounter) GetSuccessCount 

func (m *VotePenaltyCounter) GetSuccessCount() uint64

func (*VotePenaltyCounter) Marshal 

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

func (*VotePenaltyCounter) MarshalTo 

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

func (*VotePenaltyCounter) MarshalToSizedBuffer 

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

func (*VotePenaltyCounter) ProtoMessage 

func (*VotePenaltyCounter) ProtoMessage()

func (*VotePenaltyCounter) Reset 

func (m *VotePenaltyCounter) Reset()

func (*VotePenaltyCounter) Size 

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

func (*VotePenaltyCounter) String 

func (m *VotePenaltyCounter) String() string

func (*VotePenaltyCounter) Unmarshal 

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

func (*VotePenaltyCounter) XXX_DiscardUnknown 

func (m *VotePenaltyCounter) XXX_DiscardUnknown()

func (*VotePenaltyCounter) XXX_Marshal 

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

func (*VotePenaltyCounter) XXX_Merge 

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

func (*VotePenaltyCounter) XXX_Size 

func (m *VotePenaltyCounter) XXX_Size() int

func (*VotePenaltyCounter) XXX_Unmarshal 

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

type VotePenaltyCounters 

type VotePenaltyCounters []VotePenaltyCounter

VotePenaltyCounter - array of VotePenaltyCounter

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.