types

package
v0.2.5 Latest Latest
Warning

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

 Go to latest Published: Feb 29, 2024 License: Apache-2.0 Imports: 44 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

nolint

Index

Constants

View Source 
const (
	EventTypeExchangeRateUpdate = "exchange_rate_update"
	EventTypePrevote            = "prevote"
	EventTypeVote               = "vote"
	EventTypeFeedDelegate       = "feed_delegate"
	EventTypeAggregatePrevote   = "aggregate_prevote"
	EventTypeAggregateVote      = "aggregate_vote"

	AttributeKeyDenom         = "denom"
	AttributeKeyVoter         = "voter"
	AttributeKeyExchangeRate  = "exchange_rate"
	AttributeKeyExchangeRates = "exchange_rates"
	AttributeKeyOperator      = "operator"
	AttributeKeyFeeder        = "feeder"

	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"
	TypeMsgAggregateExchangeRatePrevote = "aggregate_exchange_rate_prevote"
	TypeMsgAggregateExchangeRateVote    = "aggregate_exchange_rate_vote"
)

oracle message types

View Source 
const (
	DefaultVotePeriod               = uint64(14)       // 30 seconds
	DefaultSlashWindow              = uint64(274000)   // window for a week
	DefaultRewardDistributionWindow = uint64(14250000) // window for a year
)

Default parameter values

View Source 
const (
	QueryParameters        = "parameters"
	QueryExchangeRate      = "exchangeRate"
	QueryExchangeRates     = "exchangeRates"
	QueryActives           = "actives"
	QueryFeederDelegation  = "feederDelegation"
	QueryMissCounter       = "missCounter"
	QueryAggregatePrevote  = "aggregatePrevote"
	QueryAggregatePrevotes = "aggregatePrevotes"
	QueryAggregateVote     = "aggregateVote"
	QueryAggregateVotes    = "aggregateVotes"
)

Defines the prefix of each query path

View Source 
const (
	TestDenomA = "uqube"
	TestDenomB = "denomB"
	TestDenomC = "denomC"
	TestDenomD = "denomD"
	TestDenomE = "denomE"
	TestDenomF = "denomF"
	TestDenomG = "denomG"
	TestDenomH = "denomH"
	TestDenomI = "denomI"
	MicroUnit  = int64(1e6)
)

nolint

View Source 
const (
	EventRegisterAddNewDenomProposal = "register_add_new_denom_proposal"
)
View Source 
const OracleDecPrecision = 8

OracleDecPrecision nolint

View Source 
const (
	ProposalTypeRegisterAddNewDenomProposal string = "RegisterAddNewDenomProposal"
)

constants

Variables

View Source 
var (
	ErrInvalidExchangeRate   = sdkerrors.Register(ModuleName, 1, "invalid exchange rate")
	ErrNoPrevote             = sdkerrors.Register(ModuleName, 2, "no prevote")
	ErrNoVote                = sdkerrors.Register(ModuleName, 3, "no vote")
	ErrNoVotingPermission    = sdkerrors.Register(ModuleName, 4, "unauthorized voter")
	ErrInvalidHash           = sdkerrors.Register(ModuleName, 5, "invalid hash")
	ErrInvalidHashLength     = sdkerrors.Register(ModuleName, 6, fmt.Sprintf("invalid hash length; should equal %d", tmhash.TruncatedSize))
	ErrVerificationFailed    = sdkerrors.Register(ModuleName, 7, "hash verification failed")
	ErrRevealPeriodMissMatch = sdkerrors.Register(ModuleName, 8, "reveal period of submitted vote do not match with registered prevote")
	ErrInvalidSaltLength     = sdkerrors.Register(ModuleName, 9, "invalid salt length; must be 64")
	ErrInvalidSaltFormat     = sdkerrors.Register(ModuleName, 10, "invalid salt format")
	ErrNoAggregatePrevote    = sdkerrors.Register(ModuleName, 11, "no aggregate prevote")
	ErrNoAggregateVote       = sdkerrors.Register(ModuleName, 12, "no aggregate vote")
	ErrUnknownDenom          = sdkerrors.Register(ModuleName, 13, "unknown denom")
	ErrBallotNotSorted       = sdkerrors.Register(ModuleName, 14, "ballot not sorted")
)

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
	MissCounterKey                  = []byte{0x03} // prefix for each key to a miss counter
	AggregateExchangeRatePrevoteKey = []byte{0x04} // prefix for each key to a aggregate prevote
	AggregateExchangeRateVoteKey    = []byte{0x05} // prefix for each key to a aggregate vote
)

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>: 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")
	KeyRewardDistributionWindow = []byte("RewardDistributionWindow")
	KeyWhitelist                = []byte("Whitelist")
	KeySlashFraction            = []byte("SlashFraction")
	KeySlashWindow              = []byte("SlashWindow")
	KeyMinValidPerWindow        = []byte("MinValidPerWindow")
)

Parameter keys

View Source 
var (
	DefaultVoteThreshold     = sdk.NewDecWithPrec(50, 2) // 50%
	DefaultRewardBand        = sdk.NewDecWithPrec(2, 2)  // 2% (-1, 1)
	DefaultWhitelist         = DenomList{}
	DefaultSlashFraction     = sdk.NewDecWithPrec(1, 4) // 0.01%
	DefaultMinValidPerWindow = sdk.NewDecWithPrec(5, 2) // 5%
)

Default parameter values

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

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

Functions

func GetAggregateExchangeRatePrevoteKey added in v0.1.1 

func GetAggregateExchangeRatePrevoteKey(v sdk.ValAddress) []byte

GetAggregateExchangeRatePrevoteKey - stored by *Validator* address

func GetAggregateExchangeRateVoteKey added in v0.1.1 

func GetAggregateExchangeRateVoteKey(v sdk.ValAddress) []byte

GetAggregateExchangeRateVoteKey - stored by *Validator* address

func GetExchangeRateKey added in v0.1.1 

func GetExchangeRateKey(denom string) []byte

GetExchangeRateKey - stored by *denom*

func GetFeederDelegationKey added in v0.1.1 

func GetFeederDelegationKey(v sdk.ValAddress) []byte

GetFeederDelegationKey - stored by *Validator* address

func GetMissCounterKey added in v0.1.1 

func GetMissCounterKey(v sdk.ValAddress) []byte

GetMissCounterKey - stored by *Validator* address

func NewRegisterAddNewDenomProposal added in v0.1.5 

func NewRegisterAddNewDenomProposal(title, description string, denom string) govtypes.Content

func ParamKeyTable 

func ParamKeyTable() paramstypes.KeyTable

ParamKeyTable returns the parameter key table.

func RegisterInterfaces 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

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

func RegisterLegacyAminoCodec added in v0.1.1 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

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

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

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

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

func RegisterQueryHandlerClient 

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

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

func RegisterQueryHandlerFromEndpoint 

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

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

func RegisterQueryHandlerServer 

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

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

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func ValidateGenesis added in v0.1.1 

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 AggregateExchangeRatePrevote added in v0.1.1 

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

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

func NewAggregateExchangeRatePrevote added in v0.1.1 

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

NewAggregateExchangeRatePrevote returns AggregateExchangeRatePrevote object

func (*AggregateExchangeRatePrevote) Descriptor added in v0.1.1 

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

func (*AggregateExchangeRatePrevote) Marshal added in v0.1.1 

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

func (*AggregateExchangeRatePrevote) MarshalTo added in v0.1.1 

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

func (*AggregateExchangeRatePrevote) MarshalToSizedBuffer added in v0.1.1 

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

func (*AggregateExchangeRatePrevote) ProtoMessage added in v0.1.1 

func (*AggregateExchangeRatePrevote) ProtoMessage()

func (*AggregateExchangeRatePrevote) Reset added in v0.1.1 

func (m *AggregateExchangeRatePrevote) Reset()

func (*AggregateExchangeRatePrevote) Size added in v0.1.1 

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

func (AggregateExchangeRatePrevote) String added in v0.1.1 

func (v AggregateExchangeRatePrevote) String() string

String implement stringify

func (*AggregateExchangeRatePrevote) Unmarshal added in v0.1.1 

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

func (*AggregateExchangeRatePrevote) XXX_DiscardUnknown added in v0.1.1 

func (m *AggregateExchangeRatePrevote) XXX_DiscardUnknown()

func (*AggregateExchangeRatePrevote) XXX_Marshal added in v0.1.1 

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

func (*AggregateExchangeRatePrevote) XXX_Merge added in v0.1.1 

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

func (*AggregateExchangeRatePrevote) XXX_Size added in v0.1.1 

func (m *AggregateExchangeRatePrevote) XXX_Size() int

func (*AggregateExchangeRatePrevote) XXX_Unmarshal added in v0.1.1 

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

type AggregateExchangeRateVote added in v0.1.1 

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

MsgAggregateExchangeRateVote - struct for voting on exchange rates.

func NewAggregateExchangeRateVote added in v0.1.1 

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

NewAggregateExchangeRateVote creates a AggregateExchangeRateVote instance

func (*AggregateExchangeRateVote) Descriptor added in v0.1.1 

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

func (*AggregateExchangeRateVote) Marshal added in v0.1.1 

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

func (*AggregateExchangeRateVote) MarshalTo added in v0.1.1 

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

func (*AggregateExchangeRateVote) MarshalToSizedBuffer added in v0.1.1 

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

func (*AggregateExchangeRateVote) ProtoMessage added in v0.1.1 

func (*AggregateExchangeRateVote) ProtoMessage()

func (*AggregateExchangeRateVote) Reset added in v0.1.1 

func (m *AggregateExchangeRateVote) Reset()

func (*AggregateExchangeRateVote) Size added in v0.1.1 

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

func (AggregateExchangeRateVote) String added in v0.1.1 

func (v AggregateExchangeRateVote) String() string

String implement stringify

func (*AggregateExchangeRateVote) Unmarshal added in v0.1.1 

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

func (*AggregateExchangeRateVote) XXX_DiscardUnknown added in v0.1.1 

func (m *AggregateExchangeRateVote) XXX_DiscardUnknown()

func (*AggregateExchangeRateVote) XXX_Marshal added in v0.1.1 

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

func (*AggregateExchangeRateVote) XXX_Merge added in v0.1.1 

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

func (*AggregateExchangeRateVote) XXX_Size added in v0.1.1 

func (m *AggregateExchangeRateVote) XXX_Size() int

func (*AggregateExchangeRateVote) XXX_Unmarshal added in v0.1.1 

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

type AggregateVoteHash added in v0.1.1 

type AggregateVoteHash []byte

AggregateVoteHash is hash value to hide vote exchange rates which is formatted as hex string in SHA256("{salt}:{exchange rate}{denom},...,{exchange rate}{denom}:{voter}")

func AggregateVoteHashFromHexString added in v0.1.1 

func AggregateVoteHashFromHexString(s string) (AggregateVoteHash, error)

AggregateVoteHashFromHexString convert hex string to AggregateVoteHash

func GetAggregateVoteHash added in v0.1.1 

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

GetAggregateVoteHash computes hash value of ExchangeRateVote to avoid redundant DecCoins stringify operation, use string argument

func (AggregateVoteHash) Bytes added in v0.1.1 

func (h AggregateVoteHash) Bytes() []byte

Bytes returns the raw address bytes.

func (AggregateVoteHash) Empty added in v0.1.1 

func (h AggregateVoteHash) Empty() bool

Empty check the name hash has zero length

func (AggregateVoteHash) Equal added in v0.1.1 

func (h AggregateVoteHash) Equal(h2 AggregateVoteHash) bool

Equal does bytes equal check

func (AggregateVoteHash) Format added in v0.1.1 

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

Format implements the fmt.Formatter interface.

func (AggregateVoteHash) Marshal added in v0.1.1 

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

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

func (AggregateVoteHash) MarshalJSON added in v0.1.1 

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

MarshalJSON marshals to JSON using Bech32.

func (AggregateVoteHash) MarshalYAML added in v0.1.1 

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

MarshalYAML marshals to YAML using Bech32.

func (AggregateVoteHash) Size added in v0.1.1 

func (h AggregateVoteHash) Size() int

Size returns the raw address bytes.

func (AggregateVoteHash) String added in v0.1.1 

func (h AggregateVoteHash) String() string

String implements fmt.Stringer interface

func (*AggregateVoteHash) Unmarshal added in v0.1.1 

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

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

func (*AggregateVoteHash) UnmarshalJSON added in v0.1.1 

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

UnmarshalJSON unmarshals from JSON assuming Bech32 encoding.

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 added in v0.1.1 

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

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

func NewClaim added in v0.1.1 

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

NewClaim generates a Claim instance.

type Denom added in v0.1.1 

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

Denom - the object to hold configurations of each denom

func (*Denom) Descriptor added in v0.1.1 

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

func (Denom) Equal added in v0.1.1 

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

Equal implements equal interface

func (*Denom) Marshal added in v0.1.1 

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

func (*Denom) MarshalTo added in v0.1.1 

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

func (*Denom) MarshalToSizedBuffer added in v0.1.1 

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

func (*Denom) ProtoMessage added in v0.1.1 

func (*Denom) ProtoMessage()

func (*Denom) Reset added in v0.1.1 

func (m *Denom) Reset()

func (*Denom) Size added in v0.1.1 

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

func (Denom) String added in v0.1.1 

func (d Denom) String() string

String implements fmt.Stringer interface

func (*Denom) Unmarshal added in v0.1.1 

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

func (*Denom) XXX_DiscardUnknown added in v0.1.1 

func (m *Denom) XXX_DiscardUnknown()

func (*Denom) XXX_Marshal added in v0.1.1 

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

func (*Denom) XXX_Merge added in v0.1.1 

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

func (*Denom) XXX_Size added in v0.1.1 

func (m *Denom) XXX_Size() int

func (*Denom) XXX_Unmarshal added in v0.1.1 

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

type DenomList added in v0.1.1 

type DenomList []Denom

DenomList is array of Denom

func (DenomList) String added in v0.1.1 

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

String implements fmt.Stringer interface

type DistributionKeeper added in v0.1.1 

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 added in v0.1.1 

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

DummyStakingKeeper dummy staking keeper to test ballot

func GenerateRandomTestCase added in v0.1.1 

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

GenerateRandomTestCase nolint 

#nosec

func NewDummyStakingKeeper added in v0.1.1 

func NewDummyStakingKeeper(validators []MockValidator) DummyStakingKeeper

NewDummyStakingKeeper returns new DummyStakingKeeper instance

func (DummyStakingKeeper) GetLastValidatorPower added in v0.1.1 

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

GetLastValidatorPower nolint

func (DummyStakingKeeper) Jail added in v0.1.1 

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

Jail nolint

func (DummyStakingKeeper) MaxValidators added in v0.1.1 

func (DummyStakingKeeper) MaxValidators(sdk.Context) uint32

MaxValidators returns the maximum amount of bonded validators

func (DummyStakingKeeper) PowerReduction added in v0.1.1 

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 added in v0.1.1 

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

Slash nolint

func (DummyStakingKeeper) TotalBondedTokens added in v0.1.1 

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

TotalBondedTokens nolint

func (DummyStakingKeeper) Validator added in v0.1.1 

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

Validator nolint

func (DummyStakingKeeper) Validators added in v0.1.1 

func (sk DummyStakingKeeper) Validators() []MockValidator

Validators nolint

func (DummyStakingKeeper) ValidatorsPowerStoreIterator added in v0.1.1 

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

ValidatorsPowerStoreIterator nolint

type ExchangeRateBallot added in v0.1.1 

type ExchangeRateBallot []VoteForTally

ExchangeRateBallot is a convenience wrapper around a ExchangeRateVote slice

func (ExchangeRateBallot) Len added in v0.1.1 

func (pb ExchangeRateBallot) Len() int

Len implements sort.Interface

func (ExchangeRateBallot) Less added in v0.1.1 

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 added in v0.1.1 

func (pb ExchangeRateBallot) Power() int64

Power returns the total amount of voting power in the ballot

func (ExchangeRateBallot) StandardDeviation added in v0.1.1 

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

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

func (ExchangeRateBallot) Swap added in v0.1.1 

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

Swap implements sort.Interface.

func (ExchangeRateBallot) ToMap added in v0.1.1 

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

ToMap return organized exchange rate map by validator

func (ExchangeRateBallot) WeightedMedian added in v0.1.1 

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

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

type ExchangeRateTuple added in v0.1.1 

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 */
}

ExchangeRateTuple - struct to store interpreted exchange rates data to store

func NewExchangeRateTuple added in v0.1.1 

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

NewExchangeRateTuple creates a ExchangeRateTuple instance

func (*ExchangeRateTuple) Descriptor added in v0.1.1 

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

func (*ExchangeRateTuple) Marshal added in v0.1.1 

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

func (*ExchangeRateTuple) MarshalTo added in v0.1.1 

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

func (*ExchangeRateTuple) MarshalToSizedBuffer added in v0.1.1 

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

func (*ExchangeRateTuple) ProtoMessage added in v0.1.1 

func (*ExchangeRateTuple) ProtoMessage()

func (*ExchangeRateTuple) Reset added in v0.1.1 

func (m *ExchangeRateTuple) Reset()

func (*ExchangeRateTuple) Size added in v0.1.1 

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

func (ExchangeRateTuple) String added in v0.1.1 

func (v ExchangeRateTuple) String() string

String implement stringify

func (*ExchangeRateTuple) Unmarshal added in v0.1.1 

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

func (*ExchangeRateTuple) XXX_DiscardUnknown added in v0.1.1 

func (m *ExchangeRateTuple) XXX_DiscardUnknown()

func (*ExchangeRateTuple) XXX_Marshal added in v0.1.1 

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

func (*ExchangeRateTuple) XXX_Merge added in v0.1.1 

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

func (*ExchangeRateTuple) XXX_Size added in v0.1.1 

func (m *ExchangeRateTuple) XXX_Size() int

func (*ExchangeRateTuple) XXX_Unmarshal added in v0.1.1 

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

type ExchangeRateTuples added in v0.1.1 

type ExchangeRateTuples []ExchangeRateTuple

ExchangeRateTuples - array of ExchangeRateTuple

func ParseExchangeRateTuples added in v0.1.1 

func ParseExchangeRateTuples(tuplesStr string) (ExchangeRateTuples, error)

ParseExchangeRateTuples ExchangeRateTuple parser

func (ExchangeRateTuples) String added in v0.1.1 

func (tuples ExchangeRateTuples) String() string

String implements fmt.Stringer interface

type FeederDelegation added in v0.1.1 

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

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

func (*FeederDelegation) Descriptor added in v0.1.1 

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

func (*FeederDelegation) GetFeederAddress added in v0.1.1 

func (m *FeederDelegation) GetFeederAddress() string

func (*FeederDelegation) GetValidatorAddress added in v0.1.1 

func (m *FeederDelegation) GetValidatorAddress() string

func (*FeederDelegation) Marshal added in v0.1.1 

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

func (*FeederDelegation) MarshalTo added in v0.1.1 

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

func (*FeederDelegation) MarshalToSizedBuffer added in v0.1.1 

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

func (*FeederDelegation) ProtoMessage added in v0.1.1 

func (*FeederDelegation) ProtoMessage()

func (*FeederDelegation) Reset added in v0.1.1 

func (m *FeederDelegation) Reset()

func (*FeederDelegation) Size added in v0.1.1 

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

func (*FeederDelegation) String added in v0.1.1 

func (m *FeederDelegation) String() string

func (*FeederDelegation) Unmarshal added in v0.1.1 

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

func (*FeederDelegation) XXX_DiscardUnknown added in v0.1.1 

func (m *FeederDelegation) XXX_DiscardUnknown()

func (*FeederDelegation) XXX_Marshal added in v0.1.1 

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

func (*FeederDelegation) XXX_Merge added in v0.1.1 

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

func (*FeederDelegation) XXX_Size added in v0.1.1 

func (m *FeederDelegation) XXX_Size() int

func (*FeederDelegation) XXX_Unmarshal added in v0.1.1 

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"`
	MissCounters                  []MissCounter                  `protobuf:"bytes,4,rep,name=miss_counters,json=missCounters,proto3" json:"miss_counters"`
	AggregateExchangeRatePrevotes []AggregateExchangeRatePrevote `` /* 142-byte string literal not displayed */
	AggregateExchangeRateVotes    []AggregateExchangeRateVote    `` /* 133-byte string literal not displayed */
}

GenesisState defines the oracle module's genesis state.

func DefaultGenesisState added in v0.1.1 

func DefaultGenesisState() *GenesisState

DefaultGenesisState - default GenesisState used by columbus-2

func GetGenesisStateFromAppState added in v0.1.1 

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

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

func NewGenesisState added in v0.1.1 

func NewGenesisState(
	params Params, rates []ExchangeRateTuple,
	feederDelegations []FeederDelegation, missCounters []MissCounter,
	aggregateExchangeRatePrevotes []AggregateExchangeRatePrevote,
	aggregateExchangeRateVotes []AggregateExchangeRateVote,
) *GenesisState

NewGenesisState creates a new GenesisState object

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetAggregateExchangeRatePrevotes added in v0.1.1 

func (m *GenesisState) GetAggregateExchangeRatePrevotes() []AggregateExchangeRatePrevote

func (*GenesisState) GetAggregateExchangeRateVotes added in v0.1.1 

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

func (*GenesisState) GetExchangeRates added in v0.1.1 

func (m *GenesisState) GetExchangeRates() ExchangeRateTuples

func (*GenesisState) GetFeederDelegations added in v0.1.1 

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

func (*GenesisState) GetMissCounters added in v0.1.1 

func (m *GenesisState) GetMissCounters() []MissCounter

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type MissCounter added in v0.1.1 

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

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

func (*MissCounter) Descriptor added in v0.1.1 

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

func (*MissCounter) GetMissCounter added in v0.1.1 

func (m *MissCounter) GetMissCounter() uint64

func (*MissCounter) GetValidatorAddress added in v0.1.1 

func (m *MissCounter) GetValidatorAddress() string

func (*MissCounter) Marshal added in v0.1.1 

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

func (*MissCounter) MarshalTo added in v0.1.1 

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

func (*MissCounter) MarshalToSizedBuffer added in v0.1.1 

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

func (*MissCounter) ProtoMessage added in v0.1.1 

func (*MissCounter) ProtoMessage()

func (*MissCounter) Reset added in v0.1.1 

func (m *MissCounter) Reset()

func (*MissCounter) Size added in v0.1.1 

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

func (*MissCounter) String added in v0.1.1 

func (m *MissCounter) String() string

func (*MissCounter) Unmarshal added in v0.1.1 

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

func (*MissCounter) XXX_DiscardUnknown added in v0.1.1 

func (m *MissCounter) XXX_DiscardUnknown()

func (*MissCounter) XXX_Marshal added in v0.1.1 

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

func (*MissCounter) XXX_Merge added in v0.1.1 

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

func (*MissCounter) XXX_Size added in v0.1.1 

func (m *MissCounter) XXX_Size() int

func (*MissCounter) XXX_Unmarshal added in v0.1.1 

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

type MockValidator added in v0.1.1 

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

MockValidator nolint

func NewMockValidator added in v0.1.1 

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

func (MockValidator) ConsPubKey added in v0.1.1 

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

func (MockValidator) GetBondedTokens added in v0.1.1 

func (v MockValidator) GetBondedTokens() sdk.Int

func (MockValidator) GetCommission added in v0.1.1 

func (v MockValidator) GetCommission() sdk.Dec

func (MockValidator) GetConsAddr added in v0.1.1 

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

func (MockValidator) GetConsensusPower added in v0.1.1 

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

func (MockValidator) GetDelegatorShares added in v0.1.1 

func (v MockValidator) GetDelegatorShares() sdk.Dec

func (MockValidator) GetMinSelfDelegation added in v0.1.1 

func (v MockValidator) GetMinSelfDelegation() sdk.Int

func (MockValidator) GetMoniker added in v0.1.1 

func (MockValidator) GetMoniker() string

func (MockValidator) GetOperator added in v0.1.1 

func (v MockValidator) GetOperator() sdk.ValAddress

func (MockValidator) GetStatus added in v0.1.1 

func (MockValidator) GetStatus() stakingtypes.BondStatus

func (MockValidator) GetTokens added in v0.1.1 

func (v MockValidator) GetTokens() sdk.Int

func (MockValidator) IsBonded added in v0.1.1 

func (MockValidator) IsBonded() bool

func (MockValidator) IsJailed added in v0.1.1 

func (MockValidator) IsJailed() bool

func (MockValidator) IsUnbonded added in v0.1.1 

func (MockValidator) IsUnbonded() bool

func (MockValidator) IsUnbonding added in v0.1.1 

func (MockValidator) IsUnbonding() bool

func (*MockValidator) SetConsensusPower added in v0.1.1 

func (v *MockValidator) SetConsensusPower(power int64)

func (MockValidator) SharesFromTokens added in v0.1.1 

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

func (MockValidator) SharesFromTokensTruncated added in v0.1.1 

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

func (MockValidator) TmConsPublicKey added in v0.1.1 

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

func (MockValidator) TokensFromShares added in v0.1.1 

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

func (MockValidator) TokensFromSharesRoundUp added in v0.1.1 

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

func (MockValidator) TokensFromSharesTruncated added in v0.1.1 

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

type MsgAggregateExchangeRatePrevote added in v0.1.1 

type MsgAggregateExchangeRatePrevote struct {
	Hash      string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty" yaml:"hash"`
	Feeder    string `protobuf:"bytes,2,opt,name=feeder,proto3" json:"feeder,omitempty" yaml:"feeder"`
	Validator string `protobuf:"bytes,3,opt,name=validator,proto3" json:"validator,omitempty" yaml:"validator"`
}

MsgAggregateExchangeRatePrevote represents a message to submit aggregate exchange rate prevote.

func NewMsgAggregateExchangeRatePrevote added in v0.1.1 

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

NewMsgAggregateExchangeRatePrevote returns MsgAggregateExchangeRatePrevote instance

func (*MsgAggregateExchangeRatePrevote) Descriptor added in v0.1.1 

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

func (MsgAggregateExchangeRatePrevote) GetSignBytes added in v0.1.1 

func (msg MsgAggregateExchangeRatePrevote) GetSignBytes() []byte

GetSignBytes implements sdk.Msg

func (MsgAggregateExchangeRatePrevote) GetSigners added in v0.1.1 

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

GetSigners implements sdk.Msg

func (*MsgAggregateExchangeRatePrevote) Marshal added in v0.1.1 

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

func (*MsgAggregateExchangeRatePrevote) MarshalTo added in v0.1.1 

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

func (*MsgAggregateExchangeRatePrevote) MarshalToSizedBuffer added in v0.1.1 

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

func (*MsgAggregateExchangeRatePrevote) ProtoMessage added in v0.1.1 

func (*MsgAggregateExchangeRatePrevote) ProtoMessage()

func (*MsgAggregateExchangeRatePrevote) Reset added in v0.1.1 

func (m *MsgAggregateExchangeRatePrevote) Reset()

func (MsgAggregateExchangeRatePrevote) Route added in v0.1.1 

func (msg MsgAggregateExchangeRatePrevote) Route() string

Route implements sdk.Msg

func (*MsgAggregateExchangeRatePrevote) Size added in v0.1.1 

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

func (*MsgAggregateExchangeRatePrevote) String added in v0.1.1 

func (m *MsgAggregateExchangeRatePrevote) String() string

func (MsgAggregateExchangeRatePrevote) Type added in v0.1.1 

func (msg MsgAggregateExchangeRatePrevote) Type() string

Type implements sdk.Msg

func (*MsgAggregateExchangeRatePrevote) Unmarshal added in v0.1.1 

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

func (MsgAggregateExchangeRatePrevote) ValidateBasic added in v0.1.1 

func (msg MsgAggregateExchangeRatePrevote) ValidateBasic() error

ValidateBasic Implements sdk.Msg

func (*MsgAggregateExchangeRatePrevote) XXX_DiscardUnknown added in v0.1.1 

func (m *MsgAggregateExchangeRatePrevote) XXX_DiscardUnknown()

func (*MsgAggregateExchangeRatePrevote) XXX_Marshal added in v0.1.1 

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

func (*MsgAggregateExchangeRatePrevote) XXX_Merge added in v0.1.1 

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

func (*MsgAggregateExchangeRatePrevote) XXX_Size added in v0.1.1 

func (m *MsgAggregateExchangeRatePrevote) XXX_Size() int

func (*MsgAggregateExchangeRatePrevote) XXX_Unmarshal added in v0.1.1 

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

type MsgAggregateExchangeRatePrevoteResponse added in v0.1.1 

type MsgAggregateExchangeRatePrevoteResponse struct {
}

MsgAggregateExchangeRatePrevoteResponse defines the Msg/AggregateExchangeRatePrevote response type.

func (*MsgAggregateExchangeRatePrevoteResponse) Descriptor added in v0.1.1 

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

func (*MsgAggregateExchangeRatePrevoteResponse) Marshal added in v0.1.1 

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

func (*MsgAggregateExchangeRatePrevoteResponse) MarshalTo added in v0.1.1 

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

func (*MsgAggregateExchangeRatePrevoteResponse) MarshalToSizedBuffer added in v0.1.1 

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

func (*MsgAggregateExchangeRatePrevoteResponse) ProtoMessage added in v0.1.1 

func (*MsgAggregateExchangeRatePrevoteResponse) ProtoMessage()

func (*MsgAggregateExchangeRatePrevoteResponse) Reset added in v0.1.1 

func (m *MsgAggregateExchangeRatePrevoteResponse) Reset()

func (*MsgAggregateExchangeRatePrevoteResponse) Size added in v0.1.1 

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

func (*MsgAggregateExchangeRatePrevoteResponse) String added in v0.1.1 

func (m *MsgAggregateExchangeRatePrevoteResponse) String() string

func (*MsgAggregateExchangeRatePrevoteResponse) Unmarshal added in v0.1.1 

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

func (*MsgAggregateExchangeRatePrevoteResponse) XXX_DiscardUnknown added in v0.1.1 

func (m *MsgAggregateExchangeRatePrevoteResponse) XXX_DiscardUnknown()

func (*MsgAggregateExchangeRatePrevoteResponse) XXX_Marshal added in v0.1.1 

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

func (*MsgAggregateExchangeRatePrevoteResponse) XXX_Merge added in v0.1.1 

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

func (*MsgAggregateExchangeRatePrevoteResponse) XXX_Size added in v0.1.1 

func (m *MsgAggregateExchangeRatePrevoteResponse) XXX_Size() int

func (*MsgAggregateExchangeRatePrevoteResponse) XXX_Unmarshal added in v0.1.1 

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

type MsgAggregateExchangeRateVote added in v0.1.1 

type MsgAggregateExchangeRateVote struct {
	Salt          string `protobuf:"bytes,1,opt,name=salt,proto3" json:"salt,omitempty" yaml:"salt"`
	ExchangeRates string `protobuf:"bytes,2,opt,name=exchange_rates,json=exchangeRates,proto3" json:"exchange_rates,omitempty" yaml:"exchange_rates"`
	Feeder        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 added in v0.1.1 

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

NewMsgAggregateExchangeRateVote returns MsgAggregateExchangeRateVote instance

func (*MsgAggregateExchangeRateVote) Descriptor added in v0.1.1 

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

func (MsgAggregateExchangeRateVote) GetSignBytes added in v0.1.1 

func (msg MsgAggregateExchangeRateVote) GetSignBytes() []byte

GetSignBytes implements sdk.Msg

func (MsgAggregateExchangeRateVote) GetSigners added in v0.1.1 

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

GetSigners implements sdk.Msg

func (*MsgAggregateExchangeRateVote) Marshal added in v0.1.1 

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

func (*MsgAggregateExchangeRateVote) MarshalTo added in v0.1.1 

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

func (*MsgAggregateExchangeRateVote) MarshalToSizedBuffer added in v0.1.1 

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

func (*MsgAggregateExchangeRateVote) ProtoMessage added in v0.1.1 

func (*MsgAggregateExchangeRateVote) ProtoMessage()

func (*MsgAggregateExchangeRateVote) Reset added in v0.1.1 

func (m *MsgAggregateExchangeRateVote) Reset()

func (MsgAggregateExchangeRateVote) Route added in v0.1.1 

func (msg MsgAggregateExchangeRateVote) Route() string

Route implements sdk.Msg

func (*MsgAggregateExchangeRateVote) Size added in v0.1.1 

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

func (*MsgAggregateExchangeRateVote) String added in v0.1.1 

func (m *MsgAggregateExchangeRateVote) String() string

func (MsgAggregateExchangeRateVote) Type added in v0.1.1 

func (msg MsgAggregateExchangeRateVote) Type() string

Type implements sdk.Msg

func (*MsgAggregateExchangeRateVote) Unmarshal added in v0.1.1 

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

func (MsgAggregateExchangeRateVote) ValidateBasic added in v0.1.1 

func (msg MsgAggregateExchangeRateVote) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgAggregateExchangeRateVote) XXX_DiscardUnknown added in v0.1.1 

func (m *MsgAggregateExchangeRateVote) XXX_DiscardUnknown()

func (*MsgAggregateExchangeRateVote) XXX_Marshal added in v0.1.1 

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

func (*MsgAggregateExchangeRateVote) XXX_Merge added in v0.1.1 

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

func (*MsgAggregateExchangeRateVote) XXX_Size added in v0.1.1 

func (m *MsgAggregateExchangeRateVote) XXX_Size() int

func (*MsgAggregateExchangeRateVote) XXX_Unmarshal added in v0.1.1 

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

type MsgAggregateExchangeRateVoteResponse added in v0.1.1 

type MsgAggregateExchangeRateVoteResponse struct {
}

MsgAggregateExchangeRateVoteResponse defines the Msg/AggregateExchangeRateVote response type.

func (*MsgAggregateExchangeRateVoteResponse) Descriptor added in v0.1.1 

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

func (*MsgAggregateExchangeRateVoteResponse) Marshal added in v0.1.1 

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

func (*MsgAggregateExchangeRateVoteResponse) MarshalTo added in v0.1.1 

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

func (*MsgAggregateExchangeRateVoteResponse) MarshalToSizedBuffer added in v0.1.1 

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

func (*MsgAggregateExchangeRateVoteResponse) ProtoMessage added in v0.1.1 

func (*MsgAggregateExchangeRateVoteResponse) ProtoMessage()

func (*MsgAggregateExchangeRateVoteResponse) Reset added in v0.1.1 

func (m *MsgAggregateExchangeRateVoteResponse) Reset()

func (*MsgAggregateExchangeRateVoteResponse) Size added in v0.1.1 

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

func (*MsgAggregateExchangeRateVoteResponse) String added in v0.1.1 

func (m *MsgAggregateExchangeRateVoteResponse) String() string

func (*MsgAggregateExchangeRateVoteResponse) Unmarshal added in v0.1.1 

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

func (*MsgAggregateExchangeRateVoteResponse) XXX_DiscardUnknown added in v0.1.1 

func (m *MsgAggregateExchangeRateVoteResponse) XXX_DiscardUnknown()

func (*MsgAggregateExchangeRateVoteResponse) XXX_Marshal added in v0.1.1 

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

func (*MsgAggregateExchangeRateVoteResponse) XXX_Merge added in v0.1.1 

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

func (*MsgAggregateExchangeRateVoteResponse) XXX_Size added in v0.1.1 

func (m *MsgAggregateExchangeRateVoteResponse) XXX_Size() int

func (*MsgAggregateExchangeRateVoteResponse) XXX_Unmarshal added in v0.1.1 

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

type MsgClient 

type MsgClient interface {
	// AggregateExchangeRatePrevote defines a method for submitting
	// aggregate exchange rate prevote
	AggregateExchangeRatePrevote(ctx context.Context, in *MsgAggregateExchangeRatePrevote, opts ...grpc.CallOption) (*MsgAggregateExchangeRatePrevoteResponse, error)
	// 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 added in v0.1.1 

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 added in v0.1.1 

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

NewMsgDelegateFeedConsent creates a MsgDelegateFeedConsent instance

func (*MsgDelegateFeedConsent) Descriptor added in v0.1.1 

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

func (MsgDelegateFeedConsent) GetSignBytes added in v0.1.1 

func (msg MsgDelegateFeedConsent) GetSignBytes() []byte

GetSignBytes implements sdk.Msg

func (MsgDelegateFeedConsent) GetSigners added in v0.1.1 

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

GetSigners implements sdk.Msg

func (*MsgDelegateFeedConsent) Marshal added in v0.1.1 

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

func (*MsgDelegateFeedConsent) MarshalTo added in v0.1.1 

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

func (*MsgDelegateFeedConsent) MarshalToSizedBuffer added in v0.1.1 

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

func (*MsgDelegateFeedConsent) ProtoMessage added in v0.1.1 

func (*MsgDelegateFeedConsent) ProtoMessage()

func (*MsgDelegateFeedConsent) Reset added in v0.1.1 

func (m *MsgDelegateFeedConsent) Reset()

func (MsgDelegateFeedConsent) Route added in v0.1.1 

func (msg MsgDelegateFeedConsent) Route() string

Route implements sdk.Msg

func (*MsgDelegateFeedConsent) Size added in v0.1.1 

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

func (*MsgDelegateFeedConsent) String added in v0.1.1 

func (m *MsgDelegateFeedConsent) String() string

func (MsgDelegateFeedConsent) Type added in v0.1.1 

func (msg MsgDelegateFeedConsent) Type() string

Type implements sdk.Msg

func (*MsgDelegateFeedConsent) Unmarshal added in v0.1.1 

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

func (MsgDelegateFeedConsent) ValidateBasic added in v0.1.1 

func (msg MsgDelegateFeedConsent) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgDelegateFeedConsent) XXX_DiscardUnknown added in v0.1.1 

func (m *MsgDelegateFeedConsent) XXX_DiscardUnknown()

func (*MsgDelegateFeedConsent) XXX_Marshal added in v0.1.1 

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

func (*MsgDelegateFeedConsent) XXX_Merge added in v0.1.1 

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

func (*MsgDelegateFeedConsent) XXX_Size added in v0.1.1 

func (m *MsgDelegateFeedConsent) XXX_Size() int

func (*MsgDelegateFeedConsent) XXX_Unmarshal added in v0.1.1 

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

type MsgDelegateFeedConsentResponse added in v0.1.1 

type MsgDelegateFeedConsentResponse struct {
}

MsgDelegateFeedConsentResponse defines the Msg/DelegateFeedConsent response type.

func (*MsgDelegateFeedConsentResponse) Descriptor added in v0.1.1 

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

func (*MsgDelegateFeedConsentResponse) Marshal added in v0.1.1 

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

func (*MsgDelegateFeedConsentResponse) MarshalTo added in v0.1.1 

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

func (*MsgDelegateFeedConsentResponse) MarshalToSizedBuffer added in v0.1.1 

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

func (*MsgDelegateFeedConsentResponse) ProtoMessage added in v0.1.1 

func (*MsgDelegateFeedConsentResponse) ProtoMessage()

func (*MsgDelegateFeedConsentResponse) Reset added in v0.1.1 

func (m *MsgDelegateFeedConsentResponse) Reset()

func (*MsgDelegateFeedConsentResponse) Size added in v0.1.1 

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

func (*MsgDelegateFeedConsentResponse) String added in v0.1.1 

func (m *MsgDelegateFeedConsentResponse) String() string

func (*MsgDelegateFeedConsentResponse) Unmarshal added in v0.1.1 

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

func (*MsgDelegateFeedConsentResponse) XXX_DiscardUnknown added in v0.1.1 

func (m *MsgDelegateFeedConsentResponse) XXX_DiscardUnknown()

func (*MsgDelegateFeedConsentResponse) XXX_Marshal added in v0.1.1 

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

func (*MsgDelegateFeedConsentResponse) XXX_Merge added in v0.1.1 

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

func (*MsgDelegateFeedConsentResponse) XXX_Size added in v0.1.1 

func (m *MsgDelegateFeedConsentResponse) XXX_Size() int

func (*MsgDelegateFeedConsentResponse) XXX_Unmarshal added in v0.1.1 

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

type MsgServer 

type MsgServer interface {
	// AggregateExchangeRatePrevote defines a method for submitting
	// aggregate exchange rate prevote
	AggregateExchangeRatePrevote(context.Context, *MsgAggregateExchangeRatePrevote) (*MsgAggregateExchangeRatePrevoteResponse, error)
	// 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 Params 

type Params struct {
	VotePeriod               uint64                                 `protobuf:"varint,1,opt,name=vote_period,json=votePeriod,proto3" json:"vote_period,omitempty" yaml:"vote_period"`
	VoteThreshold            github_com_cosmos_cosmos_sdk_types.Dec `` /* 162-byte string literal not displayed */
	RewardBand               github_com_cosmos_cosmos_sdk_types.Dec `` /* 150-byte string literal not displayed */
	RewardDistributionWindow uint64                                 `` /* 170-byte string literal not displayed */
	Whitelist                DenomList                              `protobuf:"bytes,5,rep,name=whitelist,proto3,castrepeated=DenomList" json:"whitelist" yaml:"whitelist"`
	SlashFraction            github_com_cosmos_cosmos_sdk_types.Dec `` /* 162-byte string literal not displayed */
	SlashWindow              uint64                                 `protobuf:"varint,7,opt,name=slash_window,json=slashWindow,proto3" json:"slash_window,omitempty" yaml:"slash_window"`
	MinValidPerWindow        github_com_cosmos_cosmos_sdk_types.Dec `` /* 184-byte string literal not displayed */
}

Params defines the parameters for the oracle module.

func DefaultParams 

func DefaultParams() Params

DefaultParams creates default oracle module parameters

func (*Params) Descriptor 

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

func (*Params) Equal added in v0.1.1 

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

func (*Params) GetRewardDistributionWindow added in v0.1.1 

func (m *Params) GetRewardDistributionWindow() uint64

func (*Params) GetSlashWindow added in v0.1.1 

func (m *Params) GetSlashWindow() uint64

func (*Params) GetVotePeriod added in v0.1.1 

func (m *Params) GetVotePeriod() uint64

func (*Params) GetWhitelist added in v0.1.1 

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 QueryActivesRequest added in v0.1.1 

type QueryActivesRequest struct {
}

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

func (*QueryActivesRequest) Descriptor added in v0.1.1 

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

func (*QueryActivesRequest) Marshal added in v0.1.1 

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

func (*QueryActivesRequest) MarshalTo added in v0.1.1 

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

func (*QueryActivesRequest) MarshalToSizedBuffer added in v0.1.1 

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

func (*QueryActivesRequest) ProtoMessage added in v0.1.1 

func (*QueryActivesRequest) ProtoMessage()

func (*QueryActivesRequest) Reset added in v0.1.1 

func (m *QueryActivesRequest) Reset()

func (*QueryActivesRequest) Size added in v0.1.1 

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

func (*QueryActivesRequest) String added in v0.1.1 

func (m *QueryActivesRequest) String() string

func (*QueryActivesRequest) Unmarshal added in v0.1.1 

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

func (*QueryActivesRequest) XXX_DiscardUnknown added in v0.1.1 

func (m *QueryActivesRequest) XXX_DiscardUnknown()

func (*QueryActivesRequest) XXX_Marshal added in v0.1.1 

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

func (*QueryActivesRequest) XXX_Merge added in v0.1.1 

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

func (*QueryActivesRequest) XXX_Size added in v0.1.1 

func (m *QueryActivesRequest) XXX_Size() int

func (*QueryActivesRequest) XXX_Unmarshal added in v0.1.1 

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

type QueryActivesResponse added in v0.1.1 

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 added in v0.1.1 

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

func (*QueryActivesResponse) GetActives added in v0.1.1 

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

func (*QueryActivesResponse) Marshal added in v0.1.1 

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

func (*QueryActivesResponse) MarshalTo added in v0.1.1 

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

func (*QueryActivesResponse) MarshalToSizedBuffer added in v0.1.1 

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

func (*QueryActivesResponse) ProtoMessage added in v0.1.1 

func (*QueryActivesResponse) ProtoMessage()

func (*QueryActivesResponse) Reset added in v0.1.1 

func (m *QueryActivesResponse) Reset()

func (*QueryActivesResponse) Size added in v0.1.1 

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

func (*QueryActivesResponse) String added in v0.1.1 

func (m *QueryActivesResponse) String() string

func (*QueryActivesResponse) Unmarshal added in v0.1.1 

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

func (*QueryActivesResponse) XXX_DiscardUnknown added in v0.1.1 

func (m *QueryActivesResponse) XXX_DiscardUnknown()

func (*QueryActivesResponse) XXX_Marshal added in v0.1.1 

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

func (*QueryActivesResponse) XXX_Merge added in v0.1.1 

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

func (*QueryActivesResponse) XXX_Size added in v0.1.1 

func (m *QueryActivesResponse) XXX_Size() int

func (*QueryActivesResponse) XXX_Unmarshal added in v0.1.1 

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

type QueryAggregatePrevoteParams added in v0.1.1 

type QueryAggregatePrevoteParams struct {
	Validator sdk.ValAddress
}

QueryAggregatePrevoteParams defines the params for the following queries: - 'custom/oracle/aggregatePrevote'

func NewQueryAggregatePrevoteParams added in v0.1.1 

func NewQueryAggregatePrevoteParams(validator sdk.ValAddress) QueryAggregatePrevoteParams

NewQueryAggregatePrevoteParams returns params for feeder delegation query

type QueryAggregatePrevoteRequest added in v0.1.1 

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

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

func (*QueryAggregatePrevoteRequest) Descriptor added in v0.1.1 

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

func (*QueryAggregatePrevoteRequest) Marshal added in v0.1.1 

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

func (*QueryAggregatePrevoteRequest) MarshalTo added in v0.1.1 

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

func (*QueryAggregatePrevoteRequest) MarshalToSizedBuffer added in v0.1.1 

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

func (*QueryAggregatePrevoteRequest) ProtoMessage added in v0.1.1 

func (*QueryAggregatePrevoteRequest) ProtoMessage()

func (*QueryAggregatePrevoteRequest) Reset added in v0.1.1 

func (m *QueryAggregatePrevoteRequest) Reset()

func (*QueryAggregatePrevoteRequest) Size added in v0.1.1 

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

func (*QueryAggregatePrevoteRequest) String added in v0.1.1 

func (m *QueryAggregatePrevoteRequest) String() string

func (*QueryAggregatePrevoteRequest) Unmarshal added in v0.1.1 

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

func (*QueryAggregatePrevoteRequest) XXX_DiscardUnknown added in v0.1.1 

func (m *QueryAggregatePrevoteRequest) XXX_DiscardUnknown()

func (*QueryAggregatePrevoteRequest) XXX_Marshal added in v0.1.1 

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

func (*QueryAggregatePrevoteRequest) XXX_Merge added in v0.1.1 

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

func (*QueryAggregatePrevoteRequest) XXX_Size added in v0.1.1 

func (m *QueryAggregatePrevoteRequest) XXX_Size() int

func (*QueryAggregatePrevoteRequest) XXX_Unmarshal added in v0.1.1 

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

type QueryAggregatePrevoteResponse added in v0.1.1 

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

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

func (*QueryAggregatePrevoteResponse) Descriptor added in v0.1.1 

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

func (*QueryAggregatePrevoteResponse) GetAggregatePrevote added in v0.1.1 

func (m *QueryAggregatePrevoteResponse) GetAggregatePrevote() AggregateExchangeRatePrevote

func (*QueryAggregatePrevoteResponse) Marshal added in v0.1.1 

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

func (*QueryAggregatePrevoteResponse) MarshalTo added in v0.1.1 

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

func (*QueryAggregatePrevoteResponse) MarshalToSizedBuffer added in v0.1.1 

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

func (*QueryAggregatePrevoteResponse) ProtoMessage added in v0.1.1 

func (*QueryAggregatePrevoteResponse) ProtoMessage()

func (*QueryAggregatePrevoteResponse) Reset added in v0.1.1 

func (m *QueryAggregatePrevoteResponse) Reset()

func (*QueryAggregatePrevoteResponse) Size added in v0.1.1 

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

func (*QueryAggregatePrevoteResponse) String added in v0.1.1 

func (m *QueryAggregatePrevoteResponse) String() string

func (*QueryAggregatePrevoteResponse) Unmarshal added in v0.1.1 

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

func (*QueryAggregatePrevoteResponse) XXX_DiscardUnknown added in v0.1.1 

func (m *QueryAggregatePrevoteResponse) XXX_DiscardUnknown()

func (*QueryAggregatePrevoteResponse) XXX_Marshal added in v0.1.1 

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

func (*QueryAggregatePrevoteResponse) XXX_Merge added in v0.1.1 

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

func (*QueryAggregatePrevoteResponse) XXX_Size added in v0.1.1 

func (m *QueryAggregatePrevoteResponse) XXX_Size() int

func (*QueryAggregatePrevoteResponse) XXX_Unmarshal added in v0.1.1 

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

type QueryAggregatePrevotesRequest added in v0.1.1 

type QueryAggregatePrevotesRequest struct {
}

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

func (*QueryAggregatePrevotesRequest) Descriptor added in v0.1.1 

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

func (*QueryAggregatePrevotesRequest) Marshal added in v0.1.1 

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

func (*QueryAggregatePrevotesRequest) MarshalTo added in v0.1.1 

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

func (*QueryAggregatePrevotesRequest) MarshalToSizedBuffer added in v0.1.1 

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

func (*QueryAggregatePrevotesRequest) ProtoMessage added in v0.1.1 

func (*QueryAggregatePrevotesRequest) ProtoMessage()

func (*QueryAggregatePrevotesRequest) Reset added in v0.1.1 

func (m *QueryAggregatePrevotesRequest) Reset()

func (*QueryAggregatePrevotesRequest) Size added in v0.1.1 

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

func (*QueryAggregatePrevotesRequest) String added in v0.1.1 

func (m *QueryAggregatePrevotesRequest) String() string

func (*QueryAggregatePrevotesRequest) Unmarshal added in v0.1.1 

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

func (*QueryAggregatePrevotesRequest) XXX_DiscardUnknown added in v0.1.1 

func (m *QueryAggregatePrevotesRequest) XXX_DiscardUnknown()

func (*QueryAggregatePrevotesRequest) XXX_Marshal added in v0.1.1 

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

func (*QueryAggregatePrevotesRequest) XXX_Merge added in v0.1.1 

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

func (*QueryAggregatePrevotesRequest) XXX_Size added in v0.1.1 

func (m *QueryAggregatePrevotesRequest) XXX_Size() int

func (*QueryAggregatePrevotesRequest) XXX_Unmarshal added in v0.1.1 

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

type QueryAggregatePrevotesResponse added in v0.1.1 

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

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

func (*QueryAggregatePrevotesResponse) Descriptor added in v0.1.1 

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

func (*QueryAggregatePrevotesResponse) GetAggregatePrevotes added in v0.1.1 

func (m *QueryAggregatePrevotesResponse) GetAggregatePrevotes() []AggregateExchangeRatePrevote

func (*QueryAggregatePrevotesResponse) Marshal added in v0.1.1 

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

func (*QueryAggregatePrevotesResponse) MarshalTo added in v0.1.1 

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

func (*QueryAggregatePrevotesResponse) MarshalToSizedBuffer added in v0.1.1 

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

func (*QueryAggregatePrevotesResponse) ProtoMessage added in v0.1.1 

func (*QueryAggregatePrevotesResponse) ProtoMessage()

func (*QueryAggregatePrevotesResponse) Reset added in v0.1.1 

func (m *QueryAggregatePrevotesResponse) Reset()

func (*QueryAggregatePrevotesResponse) Size added in v0.1.1 

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

func (*QueryAggregatePrevotesResponse) String added in v0.1.1 

func (m *QueryAggregatePrevotesResponse) String() string

func (*QueryAggregatePrevotesResponse) Unmarshal added in v0.1.1 

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

func (*QueryAggregatePrevotesResponse) XXX_DiscardUnknown added in v0.1.1 

func (m *QueryAggregatePrevotesResponse) XXX_DiscardUnknown()

func (*QueryAggregatePrevotesResponse) XXX_Marshal added in v0.1.1 

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

func (*QueryAggregatePrevotesResponse) XXX_Merge added in v0.1.1 

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

func (*QueryAggregatePrevotesResponse) XXX_Size added in v0.1.1 

func (m *QueryAggregatePrevotesResponse) XXX_Size() int

func (*QueryAggregatePrevotesResponse) XXX_Unmarshal added in v0.1.1 

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

type QueryAggregateVoteParams added in v0.1.1 

type QueryAggregateVoteParams struct {
	Validator sdk.ValAddress
}

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

func NewQueryAggregateVoteParams added in v0.1.1 

func NewQueryAggregateVoteParams(validator sdk.ValAddress) QueryAggregateVoteParams

NewQueryAggregateVoteParams returns params for feeder delegation query

type QueryAggregateVoteRequest added in v0.1.1 

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

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

func (*QueryAggregateVoteRequest) Descriptor added in v0.1.1 

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

func (*QueryAggregateVoteRequest) Marshal added in v0.1.1 

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

func (*QueryAggregateVoteRequest) MarshalTo added in v0.1.1 

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

func (*QueryAggregateVoteRequest) MarshalToSizedBuffer added in v0.1.1 

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

func (*QueryAggregateVoteRequest) ProtoMessage added in v0.1.1 

func (*QueryAggregateVoteRequest) ProtoMessage()

func (*QueryAggregateVoteRequest) Reset added in v0.1.1 

func (m *QueryAggregateVoteRequest) Reset()

func (*QueryAggregateVoteRequest) Size added in v0.1.1 

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

func (*QueryAggregateVoteRequest) String added in v0.1.1 

func (m *QueryAggregateVoteRequest) String() string

func (*QueryAggregateVoteRequest) Unmarshal added in v0.1.1 

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

func (*QueryAggregateVoteRequest) XXX_DiscardUnknown added in v0.1.1 

func (m *QueryAggregateVoteRequest) XXX_DiscardUnknown()

func (*QueryAggregateVoteRequest) XXX_Marshal added in v0.1.1 

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

func (*QueryAggregateVoteRequest) XXX_Merge added in v0.1.1 

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

func (*QueryAggregateVoteRequest) XXX_Size added in v0.1.1 

func (m *QueryAggregateVoteRequest) XXX_Size() int

func (*QueryAggregateVoteRequest) XXX_Unmarshal added in v0.1.1 

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

type QueryAggregateVoteResponse added in v0.1.1 

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

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

func (*QueryAggregateVoteResponse) Descriptor added in v0.1.1 

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

func (*QueryAggregateVoteResponse) GetAggregateVote added in v0.1.1 

func (m *QueryAggregateVoteResponse) GetAggregateVote() AggregateExchangeRateVote

func (*QueryAggregateVoteResponse) Marshal added in v0.1.1 

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

func (*QueryAggregateVoteResponse) MarshalTo added in v0.1.1 

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

func (*QueryAggregateVoteResponse) MarshalToSizedBuffer added in v0.1.1 

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

func (*QueryAggregateVoteResponse) ProtoMessage added in v0.1.1 

func (*QueryAggregateVoteResponse) ProtoMessage()

func (*QueryAggregateVoteResponse) Reset added in v0.1.1 

func (m *QueryAggregateVoteResponse) Reset()

func (*QueryAggregateVoteResponse) Size added in v0.1.1 

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

func (*QueryAggregateVoteResponse) String added in v0.1.1 

func (m *QueryAggregateVoteResponse) String() string

func (*QueryAggregateVoteResponse) Unmarshal added in v0.1.1 

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

func (*QueryAggregateVoteResponse) XXX_DiscardUnknown added in v0.1.1 

func (m *QueryAggregateVoteResponse) XXX_DiscardUnknown()

func (*QueryAggregateVoteResponse) XXX_Marshal added in v0.1.1 

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

func (*QueryAggregateVoteResponse) XXX_Merge added in v0.1.1 

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

func (*QueryAggregateVoteResponse) XXX_Size added in v0.1.1 

func (m *QueryAggregateVoteResponse) XXX_Size() int

func (*QueryAggregateVoteResponse) XXX_Unmarshal added in v0.1.1 

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

type QueryAggregateVotesRequest added in v0.1.1 

type QueryAggregateVotesRequest struct {
}

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

func (*QueryAggregateVotesRequest) Descriptor added in v0.1.1 

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

func (*QueryAggregateVotesRequest) Marshal added in v0.1.1 

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

func (*QueryAggregateVotesRequest) MarshalTo added in v0.1.1 

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

func (*QueryAggregateVotesRequest) MarshalToSizedBuffer added in v0.1.1 

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

func (*QueryAggregateVotesRequest) ProtoMessage added in v0.1.1 

func (*QueryAggregateVotesRequest) ProtoMessage()

func (*QueryAggregateVotesRequest) Reset added in v0.1.1 

func (m *QueryAggregateVotesRequest) Reset()

func (*QueryAggregateVotesRequest) Size added in v0.1.1 

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

func (*QueryAggregateVotesRequest) String added in v0.1.1 

func (m *QueryAggregateVotesRequest) String() string

func (*QueryAggregateVotesRequest) Unmarshal added in v0.1.1 

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

func (*QueryAggregateVotesRequest) XXX_DiscardUnknown added in v0.1.1 

func (m *QueryAggregateVotesRequest) XXX_DiscardUnknown()

func (*QueryAggregateVotesRequest) XXX_Marshal added in v0.1.1 

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

func (*QueryAggregateVotesRequest) XXX_Merge added in v0.1.1 

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

func (*QueryAggregateVotesRequest) XXX_Size added in v0.1.1 

func (m *QueryAggregateVotesRequest) XXX_Size() int

func (*QueryAggregateVotesRequest) XXX_Unmarshal added in v0.1.1 

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

type QueryAggregateVotesResponse added in v0.1.1 

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

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

func (*QueryAggregateVotesResponse) Descriptor added in v0.1.1 

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

func (*QueryAggregateVotesResponse) GetAggregateVotes added in v0.1.1 

func (m *QueryAggregateVotesResponse) GetAggregateVotes() []AggregateExchangeRateVote

func (*QueryAggregateVotesResponse) Marshal added in v0.1.1 

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

func (*QueryAggregateVotesResponse) MarshalTo added in v0.1.1 

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

func (*QueryAggregateVotesResponse) MarshalToSizedBuffer added in v0.1.1 

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

func (*QueryAggregateVotesResponse) ProtoMessage added in v0.1.1 

func (*QueryAggregateVotesResponse) ProtoMessage()

func (*QueryAggregateVotesResponse) Reset added in v0.1.1 

func (m *QueryAggregateVotesResponse) Reset()

func (*QueryAggregateVotesResponse) Size added in v0.1.1 

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

func (*QueryAggregateVotesResponse) String added in v0.1.1 

func (m *QueryAggregateVotesResponse) String() string

func (*QueryAggregateVotesResponse) Unmarshal added in v0.1.1 

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

func (*QueryAggregateVotesResponse) XXX_DiscardUnknown added in v0.1.1 

func (m *QueryAggregateVotesResponse) XXX_DiscardUnknown()

func (*QueryAggregateVotesResponse) XXX_Marshal added in v0.1.1 

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

func (*QueryAggregateVotesResponse) XXX_Merge added in v0.1.1 

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

func (*QueryAggregateVotesResponse) XXX_Size added in v0.1.1 

func (m *QueryAggregateVotesResponse) XXX_Size() int

func (*QueryAggregateVotesResponse) XXX_Unmarshal added in v0.1.1 

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

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)
	// 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
	MissCounter(ctx context.Context, in *QueryMissCounterRequest, opts ...grpc.CallOption) (*QueryMissCounterResponse, error)
	// AggregatePrevote returns an aggregate prevote of a validator
	AggregatePrevote(ctx context.Context, in *QueryAggregatePrevoteRequest, opts ...grpc.CallOption) (*QueryAggregatePrevoteResponse, error)
	// AggregatePrevotes returns aggregate prevotes of all validators
	AggregatePrevotes(ctx context.Context, in *QueryAggregatePrevotesRequest, opts ...grpc.CallOption) (*QueryAggregatePrevotesResponse, error)
	// AggregateVote returns an aggregate vote of a validator
	AggregateVote(ctx context.Context, in *QueryAggregateVoteRequest, opts ...grpc.CallOption) (*QueryAggregateVoteResponse, error)
	// AggregateVotes returns aggregate votes of all validators
	AggregateVotes(ctx context.Context, in *QueryAggregateVotesRequest, opts ...grpc.CallOption) (*QueryAggregateVotesResponse, 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 added in v0.1.1 

type QueryExchangeRateParams struct {
	Denom string
}

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

func NewQueryExchangeRateParams added in v0.1.1 

func NewQueryExchangeRateParams(denom string) QueryExchangeRateParams

NewQueryExchangeRateParams returns params for exchange_rate query

type QueryExchangeRateRequest added in v0.1.1 

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 added in v0.1.1 

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

func (*QueryExchangeRateRequest) Marshal added in v0.1.1 

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

func (*QueryExchangeRateRequest) MarshalTo added in v0.1.1 

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

func (*QueryExchangeRateRequest) MarshalToSizedBuffer added in v0.1.1 

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

func (*QueryExchangeRateRequest) ProtoMessage added in v0.1.1 

func (*QueryExchangeRateRequest) ProtoMessage()

func (*QueryExchangeRateRequest) Reset added in v0.1.1 

func (m *QueryExchangeRateRequest) Reset()

func (*QueryExchangeRateRequest) Size added in v0.1.1 

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

func (*QueryExchangeRateRequest) String added in v0.1.1 

func (m *QueryExchangeRateRequest) String() string

func (*QueryExchangeRateRequest) Unmarshal added in v0.1.1 

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

func (*QueryExchangeRateRequest) XXX_DiscardUnknown added in v0.1.1 

func (m *QueryExchangeRateRequest) XXX_DiscardUnknown()

func (*QueryExchangeRateRequest) XXX_Marshal added in v0.1.1 

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

func (*QueryExchangeRateRequest) XXX_Merge added in v0.1.1 

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

func (*QueryExchangeRateRequest) XXX_Size added in v0.1.1 

func (m *QueryExchangeRateRequest) XXX_Size() int

func (*QueryExchangeRateRequest) XXX_Unmarshal added in v0.1.1 

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

type QueryExchangeRateResponse added in v0.1.1 

type QueryExchangeRateResponse struct {
	// exchange_rate defines the exchange rate of whitelisted assets
	ExchangeRate github_com_cosmos_cosmos_sdk_types.Dec `` /* 137-byte string literal not displayed */
}

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

func (*QueryExchangeRateResponse) Descriptor added in v0.1.1 

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

func (*QueryExchangeRateResponse) Marshal added in v0.1.1 

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

func (*QueryExchangeRateResponse) MarshalTo added in v0.1.1 

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

func (*QueryExchangeRateResponse) MarshalToSizedBuffer added in v0.1.1 

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

func (*QueryExchangeRateResponse) ProtoMessage added in v0.1.1 

func (*QueryExchangeRateResponse) ProtoMessage()

func (*QueryExchangeRateResponse) Reset added in v0.1.1 

func (m *QueryExchangeRateResponse) Reset()

func (*QueryExchangeRateResponse) Size added in v0.1.1 

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

func (*QueryExchangeRateResponse) String added in v0.1.1 

func (m *QueryExchangeRateResponse) String() string

func (*QueryExchangeRateResponse) Unmarshal added in v0.1.1 

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

func (*QueryExchangeRateResponse) XXX_DiscardUnknown added in v0.1.1 

func (m *QueryExchangeRateResponse) XXX_DiscardUnknown()

func (*QueryExchangeRateResponse) XXX_Marshal added in v0.1.1 

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

func (*QueryExchangeRateResponse) XXX_Merge added in v0.1.1 

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

func (*QueryExchangeRateResponse) XXX_Size added in v0.1.1 

func (m *QueryExchangeRateResponse) XXX_Size() int

func (*QueryExchangeRateResponse) XXX_Unmarshal added in v0.1.1 

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

type QueryExchangeRatesRequest added in v0.1.1 

type QueryExchangeRatesRequest struct {
}

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

func (*QueryExchangeRatesRequest) Descriptor added in v0.1.1 

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

func (*QueryExchangeRatesRequest) Marshal added in v0.1.1 

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

func (*QueryExchangeRatesRequest) MarshalTo added in v0.1.1 

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

func (*QueryExchangeRatesRequest) MarshalToSizedBuffer added in v0.1.1 

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

func (*QueryExchangeRatesRequest) ProtoMessage added in v0.1.1 

func (*QueryExchangeRatesRequest) ProtoMessage()

func (*QueryExchangeRatesRequest) Reset added in v0.1.1 

func (m *QueryExchangeRatesRequest) Reset()

func (*QueryExchangeRatesRequest) Size added in v0.1.1 

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

func (*QueryExchangeRatesRequest) String added in v0.1.1 

func (m *QueryExchangeRatesRequest) String() string

func (*QueryExchangeRatesRequest) Unmarshal added in v0.1.1 

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

func (*QueryExchangeRatesRequest) XXX_DiscardUnknown added in v0.1.1 

func (m *QueryExchangeRatesRequest) XXX_DiscardUnknown()

func (*QueryExchangeRatesRequest) XXX_Marshal added in v0.1.1 

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

func (*QueryExchangeRatesRequest) XXX_Merge added in v0.1.1 

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

func (*QueryExchangeRatesRequest) XXX_Size added in v0.1.1 

func (m *QueryExchangeRatesRequest) XXX_Size() int

func (*QueryExchangeRatesRequest) XXX_Unmarshal added in v0.1.1 

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

type QueryExchangeRatesResponse added in v0.1.1 

type QueryExchangeRatesResponse struct {
	// exchange_rates defines a list of the exchange rate for all whitelisted denoms.
	ExchangeRates []types.DecCoin `protobuf:"bytes,1,rep,name=exchange_rates,json=exchangeRates,proto3" json:"exchange_rates"`
}

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

func (*QueryExchangeRatesResponse) Descriptor added in v0.1.1 

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

func (*QueryExchangeRatesResponse) GetExchangeRates added in v0.1.1 

func (m *QueryExchangeRatesResponse) GetExchangeRates() []types.DecCoin

func (*QueryExchangeRatesResponse) Marshal added in v0.1.1 

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

func (*QueryExchangeRatesResponse) MarshalTo added in v0.1.1 

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

func (*QueryExchangeRatesResponse) MarshalToSizedBuffer added in v0.1.1 

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

func (*QueryExchangeRatesResponse) ProtoMessage added in v0.1.1 

func (*QueryExchangeRatesResponse) ProtoMessage()

func (*QueryExchangeRatesResponse) Reset added in v0.1.1 

func (m *QueryExchangeRatesResponse) Reset()

func (*QueryExchangeRatesResponse) Size added in v0.1.1 

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

func (*QueryExchangeRatesResponse) String added in v0.1.1 

func (m *QueryExchangeRatesResponse) String() string

func (*QueryExchangeRatesResponse) Unmarshal added in v0.1.1 

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

func (*QueryExchangeRatesResponse) XXX_DiscardUnknown added in v0.1.1 

func (m *QueryExchangeRatesResponse) XXX_DiscardUnknown()

func (*QueryExchangeRatesResponse) XXX_Marshal added in v0.1.1 

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

func (*QueryExchangeRatesResponse) XXX_Merge added in v0.1.1 

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

func (*QueryExchangeRatesResponse) XXX_Size added in v0.1.1 

func (m *QueryExchangeRatesResponse) XXX_Size() int

func (*QueryExchangeRatesResponse) XXX_Unmarshal added in v0.1.1 

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

type QueryFeederDelegationParams added in v0.1.1 

type QueryFeederDelegationParams struct {
	Validator sdk.ValAddress
}

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

func NewQueryFeederDelegationParams added in v0.1.1 

func NewQueryFeederDelegationParams(validator sdk.ValAddress) QueryFeederDelegationParams

NewQueryFeederDelegationParams returns params for feeder delegation query

type QueryFeederDelegationRequest added in v0.1.1 

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 added in v0.1.1 

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

func (*QueryFeederDelegationRequest) Marshal added in v0.1.1 

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

func (*QueryFeederDelegationRequest) MarshalTo added in v0.1.1 

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

func (*QueryFeederDelegationRequest) MarshalToSizedBuffer added in v0.1.1 

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

func (*QueryFeederDelegationRequest) ProtoMessage added in v0.1.1 

func (*QueryFeederDelegationRequest) ProtoMessage()

func (*QueryFeederDelegationRequest) Reset added in v0.1.1 

func (m *QueryFeederDelegationRequest) Reset()

func (*QueryFeederDelegationRequest) Size added in v0.1.1 

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

func (*QueryFeederDelegationRequest) String added in v0.1.1 

func (m *QueryFeederDelegationRequest) String() string

func (*QueryFeederDelegationRequest) Unmarshal added in v0.1.1 

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

func (*QueryFeederDelegationRequest) XXX_DiscardUnknown added in v0.1.1 

func (m *QueryFeederDelegationRequest) XXX_DiscardUnknown()

func (*QueryFeederDelegationRequest) XXX_Marshal added in v0.1.1 

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

func (*QueryFeederDelegationRequest) XXX_Merge added in v0.1.1 

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

func (*QueryFeederDelegationRequest) XXX_Size added in v0.1.1 

func (m *QueryFeederDelegationRequest) XXX_Size() int

func (*QueryFeederDelegationRequest) XXX_Unmarshal added in v0.1.1 

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

type QueryFeederDelegationResponse added in v0.1.1 

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 added in v0.1.1 

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

func (*QueryFeederDelegationResponse) GetFeederAddr added in v0.1.1 

func (m *QueryFeederDelegationResponse) GetFeederAddr() string

func (*QueryFeederDelegationResponse) Marshal added in v0.1.1 

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

func (*QueryFeederDelegationResponse) MarshalTo added in v0.1.1 

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

func (*QueryFeederDelegationResponse) MarshalToSizedBuffer added in v0.1.1 

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

func (*QueryFeederDelegationResponse) ProtoMessage added in v0.1.1 

func (*QueryFeederDelegationResponse) ProtoMessage()

func (*QueryFeederDelegationResponse) Reset added in v0.1.1 

func (m *QueryFeederDelegationResponse) Reset()

func (*QueryFeederDelegationResponse) Size added in v0.1.1 

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

func (*QueryFeederDelegationResponse) String added in v0.1.1 

func (m *QueryFeederDelegationResponse) String() string

func (*QueryFeederDelegationResponse) Unmarshal added in v0.1.1 

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

func (*QueryFeederDelegationResponse) XXX_DiscardUnknown added in v0.1.1 

func (m *QueryFeederDelegationResponse) XXX_DiscardUnknown()

func (*QueryFeederDelegationResponse) XXX_Marshal added in v0.1.1 

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

func (*QueryFeederDelegationResponse) XXX_Merge added in v0.1.1 

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

func (*QueryFeederDelegationResponse) XXX_Size added in v0.1.1 

func (m *QueryFeederDelegationResponse) XXX_Size() int

func (*QueryFeederDelegationResponse) XXX_Unmarshal added in v0.1.1 

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

type QueryMissCounterParams added in v0.1.1 

type QueryMissCounterParams struct {
	Validator sdk.ValAddress
}

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

func NewQueryMissCounterParams added in v0.1.1 

func NewQueryMissCounterParams(validator sdk.ValAddress) QueryMissCounterParams

NewQueryMissCounterParams returns params for feeder delegation query

type QueryMissCounterRequest added in v0.1.1 

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

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

func (*QueryMissCounterRequest) Descriptor added in v0.1.1 

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

func (*QueryMissCounterRequest) Marshal added in v0.1.1 

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

func (*QueryMissCounterRequest) MarshalTo added in v0.1.1 

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

func (*QueryMissCounterRequest) MarshalToSizedBuffer added in v0.1.1 

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

func (*QueryMissCounterRequest) ProtoMessage added in v0.1.1 

func (*QueryMissCounterRequest) ProtoMessage()

func (*QueryMissCounterRequest) Reset added in v0.1.1 

func (m *QueryMissCounterRequest) Reset()

func (*QueryMissCounterRequest) Size added in v0.1.1 

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

func (*QueryMissCounterRequest) String added in v0.1.1 

func (m *QueryMissCounterRequest) String() string

func (*QueryMissCounterRequest) Unmarshal added in v0.1.1 

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

func (*QueryMissCounterRequest) XXX_DiscardUnknown added in v0.1.1 

func (m *QueryMissCounterRequest) XXX_DiscardUnknown()

func (*QueryMissCounterRequest) XXX_Marshal added in v0.1.1 

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

func (*QueryMissCounterRequest) XXX_Merge added in v0.1.1 

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

func (*QueryMissCounterRequest) XXX_Size added in v0.1.1 

func (m *QueryMissCounterRequest) XXX_Size() int

func (*QueryMissCounterRequest) XXX_Unmarshal added in v0.1.1 

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

type QueryMissCounterResponse added in v0.1.1 

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

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

func (*QueryMissCounterResponse) Descriptor added in v0.1.1 

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

func (*QueryMissCounterResponse) GetMissCounter added in v0.1.1 

func (m *QueryMissCounterResponse) GetMissCounter() uint64

func (*QueryMissCounterResponse) Marshal added in v0.1.1 

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

func (*QueryMissCounterResponse) MarshalTo added in v0.1.1 

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

func (*QueryMissCounterResponse) MarshalToSizedBuffer added in v0.1.1 

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

func (*QueryMissCounterResponse) ProtoMessage added in v0.1.1 

func (*QueryMissCounterResponse) ProtoMessage()

func (*QueryMissCounterResponse) Reset added in v0.1.1 

func (m *QueryMissCounterResponse) Reset()

func (*QueryMissCounterResponse) Size added in v0.1.1 

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

func (*QueryMissCounterResponse) String added in v0.1.1 

func (m *QueryMissCounterResponse) String() string

func (*QueryMissCounterResponse) Unmarshal added in v0.1.1 

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

func (*QueryMissCounterResponse) XXX_DiscardUnknown added in v0.1.1 

func (m *QueryMissCounterResponse) XXX_DiscardUnknown()

func (*QueryMissCounterResponse) XXX_Marshal added in v0.1.1 

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

func (*QueryMissCounterResponse) XXX_Merge added in v0.1.1 

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

func (*QueryMissCounterResponse) XXX_Size added in v0.1.1 

func (m *QueryMissCounterResponse) XXX_Size() int

func (*QueryMissCounterResponse) XXX_Unmarshal added in v0.1.1 

func (m *QueryMissCounterResponse) 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 QueryPrevotesParams added in v0.1.1 

type QueryPrevotesParams struct {
	Voter sdk.ValAddress
	Denom string
}

QueryPrevotesParams defines the params for the following queries: - 'custom/oracle/prevotes'

func NewQueryPrevotesParams added in v0.1.1 

func NewQueryPrevotesParams(voter sdk.ValAddress, denom string) QueryPrevotesParams

NewQueryPrevotesParams returns params for exchange_rate prevotes query

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)
	// FeederDelegation returns feeder delegation of a validator
	FeederDelegation(context.Context, *QueryFeederDelegationRequest) (*QueryFeederDelegationResponse, error)
	// MissCounter returns oracle miss counter of a validator
	MissCounter(context.Context, *QueryMissCounterRequest) (*QueryMissCounterResponse, error)
	// AggregatePrevote returns an aggregate prevote of a validator
	AggregatePrevote(context.Context, *QueryAggregatePrevoteRequest) (*QueryAggregatePrevoteResponse, error)
	// AggregatePrevotes returns aggregate prevotes of all validators
	AggregatePrevotes(context.Context, *QueryAggregatePrevotesRequest) (*QueryAggregatePrevotesResponse, error)
	// AggregateVote returns an aggregate vote of a validator
	AggregateVote(context.Context, *QueryAggregateVoteRequest) (*QueryAggregateVoteResponse, error)
	// AggregateVotes returns aggregate votes of all validators
	AggregateVotes(context.Context, *QueryAggregateVotesRequest) (*QueryAggregateVotesResponse, error)
	// Params queries all parameters.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
}

QueryServer is the server API for Query service.

type QueryVoteTargetsRequest added in v0.1.1 

type QueryVoteTargetsRequest struct {
}

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

func (*QueryVoteTargetsRequest) Descriptor added in v0.1.1 

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

func (*QueryVoteTargetsRequest) Marshal added in v0.1.1 

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

func (*QueryVoteTargetsRequest) MarshalTo added in v0.1.1 

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

func (*QueryVoteTargetsRequest) MarshalToSizedBuffer added in v0.1.1 

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

func (*QueryVoteTargetsRequest) ProtoMessage added in v0.1.1 

func (*QueryVoteTargetsRequest) ProtoMessage()

func (*QueryVoteTargetsRequest) Reset added in v0.1.1 

func (m *QueryVoteTargetsRequest) Reset()

func (*QueryVoteTargetsRequest) Size added in v0.1.1 

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

func (*QueryVoteTargetsRequest) String added in v0.1.1 

func (m *QueryVoteTargetsRequest) String() string

func (*QueryVoteTargetsRequest) Unmarshal added in v0.1.1 

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

func (*QueryVoteTargetsRequest) XXX_DiscardUnknown added in v0.1.1 

func (m *QueryVoteTargetsRequest) XXX_DiscardUnknown()

func (*QueryVoteTargetsRequest) XXX_Marshal added in v0.1.1 

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

func (*QueryVoteTargetsRequest) XXX_Merge added in v0.1.1 

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

func (*QueryVoteTargetsRequest) XXX_Size added in v0.1.1 

func (m *QueryVoteTargetsRequest) XXX_Size() int

func (*QueryVoteTargetsRequest) XXX_Unmarshal added in v0.1.1 

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

type QueryVoteTargetsResponse added in v0.1.1 

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 added in v0.1.1 

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

func (*QueryVoteTargetsResponse) GetVoteTargets added in v0.1.1 

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

func (*QueryVoteTargetsResponse) Marshal added in v0.1.1 

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

func (*QueryVoteTargetsResponse) MarshalTo added in v0.1.1 

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

func (*QueryVoteTargetsResponse) MarshalToSizedBuffer added in v0.1.1 

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

func (*QueryVoteTargetsResponse) ProtoMessage added in v0.1.1 

func (*QueryVoteTargetsResponse) ProtoMessage()

func (*QueryVoteTargetsResponse) Reset added in v0.1.1 

func (m *QueryVoteTargetsResponse) Reset()

func (*QueryVoteTargetsResponse) Size added in v0.1.1 

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

func (*QueryVoteTargetsResponse) String added in v0.1.1 

func (m *QueryVoteTargetsResponse) String() string

func (*QueryVoteTargetsResponse) Unmarshal added in v0.1.1 

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

func (*QueryVoteTargetsResponse) XXX_DiscardUnknown added in v0.1.1 

func (m *QueryVoteTargetsResponse) XXX_DiscardUnknown()

func (*QueryVoteTargetsResponse) XXX_Marshal added in v0.1.1 

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

func (*QueryVoteTargetsResponse) XXX_Merge added in v0.1.1 

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

func (*QueryVoteTargetsResponse) XXX_Size added in v0.1.1 

func (m *QueryVoteTargetsResponse) XXX_Size() int

func (*QueryVoteTargetsResponse) XXX_Unmarshal added in v0.1.1 

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

type QueryVotesParams added in v0.1.1 

type QueryVotesParams struct {
	Voter sdk.ValAddress
	Denom string
}

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

func NewQueryVotesParams added in v0.1.1 

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

NewQueryVotesParams returns params for exchange_rate votes query

type RegisterAddNewDenomProposal added in v0.1.5 

type RegisterAddNewDenomProposal struct {
	// title of the proposal
	Title string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	// description of the proposal
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Denom       string `protobuf:"bytes,3,opt,name=denom,proto3" json:"denom,omitempty"`
}

func (*RegisterAddNewDenomProposal) Descriptor added in v0.1.5 

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

func (*RegisterAddNewDenomProposal) GetDenom added in v0.1.5 

func (m *RegisterAddNewDenomProposal) GetDenom() string

func (*RegisterAddNewDenomProposal) GetDescription added in v0.1.5 

func (m *RegisterAddNewDenomProposal) GetDescription() string

func (*RegisterAddNewDenomProposal) GetTitle added in v0.1.5 

func (m *RegisterAddNewDenomProposal) GetTitle() string

func (*RegisterAddNewDenomProposal) Marshal added in v0.1.5 

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

func (*RegisterAddNewDenomProposal) MarshalTo added in v0.1.5 

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

func (*RegisterAddNewDenomProposal) MarshalToSizedBuffer added in v0.1.5 

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

func (*RegisterAddNewDenomProposal) ProposalRoute added in v0.1.5 

func (*RegisterAddNewDenomProposal) ProposalRoute() string

func (*RegisterAddNewDenomProposal) ProposalType added in v0.1.5 

func (*RegisterAddNewDenomProposal) ProposalType() string

func (*RegisterAddNewDenomProposal) ProtoMessage added in v0.1.5 

func (*RegisterAddNewDenomProposal) ProtoMessage()

func (*RegisterAddNewDenomProposal) Reset added in v0.1.5 

func (m *RegisterAddNewDenomProposal) Reset()

func (*RegisterAddNewDenomProposal) Size added in v0.1.5 

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

func (*RegisterAddNewDenomProposal) String added in v0.1.5 

func (m *RegisterAddNewDenomProposal) String() string

func (*RegisterAddNewDenomProposal) Unmarshal added in v0.1.5 

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

func (*RegisterAddNewDenomProposal) ValidateBasic added in v0.1.5 

func (rtbp *RegisterAddNewDenomProposal) ValidateBasic() error

func (*RegisterAddNewDenomProposal) XXX_DiscardUnknown added in v0.1.5 

func (m *RegisterAddNewDenomProposal) XXX_DiscardUnknown()

func (*RegisterAddNewDenomProposal) XXX_Marshal added in v0.1.5 

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

func (*RegisterAddNewDenomProposal) XXX_Merge added in v0.1.5 

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

func (*RegisterAddNewDenomProposal) XXX_Size added in v0.1.5 

func (m *RegisterAddNewDenomProposal) XXX_Size() int

func (*RegisterAddNewDenomProposal) XXX_Unmarshal added in v0.1.5 

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

type SlashingKeeper added in v0.1.1 

type SlashingKeeper interface {
	Slash(sdk.Context, sdk.ConsAddress, sdk.Dec, int64, int64) // slash the validator and delegators of the validator, specifying slash fraction, offence power and offence height
	Jail(sdk.Context, sdk.ConsAddress)                         // jail a validator
}

StakingKeeper is expected keeper for staking module

type StakingKeeper added in v0.1.1 

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
	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) AggregateExchangeRatePrevote added in v0.1.1 

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

func (*UnimplementedMsgServer) AggregateExchangeRateVote added in v0.1.1 

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

func (*UnimplementedMsgServer) DelegateFeedConsent added in v0.1.1 

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 added in v0.1.1 

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

func (*UnimplementedQueryServer) AggregatePrevote added in v0.1.1 

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

func (*UnimplementedQueryServer) AggregatePrevotes added in v0.1.1 

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

func (*UnimplementedQueryServer) AggregateVote added in v0.1.1 

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

func (*UnimplementedQueryServer) AggregateVotes added in v0.1.1 

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

func (*UnimplementedQueryServer) ExchangeRate added in v0.1.1 

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

func (*UnimplementedQueryServer) ExchangeRates added in v0.1.1 

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

func (*UnimplementedQueryServer) FeederDelegation added in v0.1.1 

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

func (*UnimplementedQueryServer) MissCounter added in v0.1.1 

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

func (*UnimplementedQueryServer) Params 

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

type VoteForTally added in v0.1.1 

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 added in v0.1.1 

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

NewVoteForTally returns a new VoteForTally instance

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.