types

package
v0.0.2 Latest Latest
Warning

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

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

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	BlocksPerMinute = util.BlocksPerMinute
	BlocksPerHour   = util.BlocksPerHour
	BlocksPerDay    = util.BlocksPerDay
	BlocksPerWeek   = util.BlocksPerWeek
	BlocksPerMonth  = util.BlocksPerMonth
	BlocksPerYear   = util.BlocksPerYear
)
View Source 
const (
	EventTypeValidatorsWhitelistUpdate = "validators_whitelist_update"
	EventTypePrevote                   = "prevote"
	EventTypeVote                      = "vote"
	EventTypeFeedDelegate              = "feed_delegate"
	EventTypeAggregatePrevote          = "aggregate_prevote"
	EventTypeAggregateVote             = "aggregate_vote"

	AttributeKeyAddress    = "address"
	AttributeKeyVoter      = "voter"
	AttributeKeyValidator  = "validator whitelist"
	AttributeKeyValidators = "validators whitelisted"
	AttributeKeyOperator   = "operator"
	AttributeKeyFeeder     = "feeder"

	AttributeValueCategory = ModuleName
)

Oracle module event types

View Source 
const (
	// ModuleName defines the module name
	ModuleName = "validatororacle"

	// StoreKey defines the primary module store key
	StoreKey = ModuleName

	// RouterKey is the message route for slashing
	RouterKey = ModuleName

	// QuerierRoute defines the module's query routing key
	QuerierRoute = ModuleName

	// MemStoreKey defines the in-memory store key
	MemStoreKey = "mem_validatororacle"
)
View Source 
const (
	TypeMsgDelegateFeedConsent       = "delegate_feeder"
	TypeMsgAggregateValidatorPrevote = "aggregate_exchange_rate_prevote"
	TypeMsgAggregateValidatorVote    = "aggregate_exchange_rate_vote"
)

oracle message types

View Source 
const (
	DefaultVotePeriod  = BlocksPerMinute / 2 // 30 seconds
	DefaultSlashWindow = BlocksPerWeek       // window for a week
)

Default parameter values

View Source 
const DefaultIndex uint64 = 1

DefaultIndex is the default capability global index

View Source 
const MAX_NUM_VALIDATORS = 130

Variables

View Source 
var (
	IsPeriodLastBlock = util.IsPeriodLastBlock
	AddressVerifier   = util.AddressVerifier
)
View Source 
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry())
)
View Source 
var (
	ErrInvalidValidatorList     = sdkerrors.Register(ModuleName, 2, "invalid validator list")
	ErrNoPrevote                = sdkerrors.Register(ModuleName, 3, "no prevote")
	ErrNoVote                   = sdkerrors.Register(ModuleName, 4, "no vote")
	ErrNoVotingPermission       = sdkerrors.Register(ModuleName, 5, "unauthorized voter")
	ErrInvalidHash              = sdkerrors.Register(ModuleName, 6, "invalid hash")
	ErrInvalidHashLength        = sdkerrors.Register(ModuleName, 7, fmt.Sprintf("invalid hash length; should equal %d", tmhash.TruncatedSize))
	ErrVerificationFailed       = sdkerrors.Register(ModuleName, 8, "hash verification failed")
	ErrRevealPeriodMissMatch    = sdkerrors.Register(ModuleName, 9, "reveal period of submitted vote do not match with registered prevote")
	ErrInvalidSaltLength        = sdkerrors.Register(ModuleName, 10, "invalid salt length; should be 1~4")
	ErrNoAggregatePrevote       = sdkerrors.Register(ModuleName, 11, "no aggregate prevote")
	ErrNoAggregateVote          = sdkerrors.Register(ModuleName, 12, "no aggregate vote")
	ErrExceedNumberOfValidators = sdkerrors.Register(ModuleName, 13, "invalid number of validators whitelisted")
)

x/validatororacle module sentinel errors

View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// Keys for store prefixes
	ValidatorsWhitelistKey       = []byte{0x01} // prefix for each key to a rate
	FeederValDelegationKey       = []byte{0x02} // prefix for each key to a feeder delegation
	MissCounterValKey            = []byte{0x03} // prefix for each key to a miss counter
	AggregateValidatorPrevoteKey = []byte{0x04} // prefix for each key to a aggregate prevote
	AggregateValidatorVoteKey    = []byte{0x05} // prefix for each key to a aggregate vote
)
View Source 
var (
	KeyVotePeriod        = []byte("VotePeriod")
	KeyVoteThreshold     = []byte("VoteThreshold")
	KeyWhitelist         = []byte("Whitelist")
	KeySlashFraction     = []byte("SlashFraction")
	KeySlashWindow       = []byte("SlashWindow")
	KeyMinValidPerWindow = []byte("MinValidPerWindow")
)

Parameter keys

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

Default parameter values

View Source 
var (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = 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")
)

Functions

func GetAggregateValidatorPrevoteKey 

func GetAggregateValidatorPrevoteKey(v sdk.ValAddress) []byte

GetAggregateValidatorPrevoteKey - stored by *Validator* address

func GetAggregateValidatorVoteKey 

func GetAggregateValidatorVoteKey(v sdk.ValAddress) []byte

GetAggregateValidatorVoteKey - stored by *Validator* address

func GetFeederDelegationKey 

func GetFeederDelegationKey(v sdk.ValAddress) []byte

GetFeederDelegationKey - stored by *Validator* address

func GetMissCounterKey 

func GetMissCounterKey(v sdk.ValAddress) []byte

GetMissCounterKey - stored by *Validator* address

func GetValidatorsWhitelistKey 

func GetValidatorsWhitelistKey(address string) []byte

GetValidatorsWhitelistKey - stored by *denom*

func KeyPrefix 

func KeyPrefix(p string) []byte

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable the param key table for launch module

func RegisterCodec 

func RegisterCodec(cdc *codec.LegacyAmino)

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

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 (such as grpc.SendHeader, etc) to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type AccountKeeper 

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

AccountKeeper defines the expected account keeper used for simulations (noalias)

type AddressBallot 

type AddressBallot []VoteForTally

ExchangeRateBallot is a convenience wrapper around a AddressVote slice

type AggregateValidatorPrevote 

type AggregateValidatorPrevote 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 ValidatorVote. The purpose of aggregate prevote is to hide vote validators whitelist with hash which is formatted as hex string in SHA256("{salt}:{validator-addresss},...,{validator-addresss}:{voter}")

func NewAggregateValidatorPrevote 

func NewAggregateValidatorPrevote(hash AggregateVoteHash, voter sdk.ValAddress, submitBlock uint64) AggregateValidatorPrevote

NewAggregateValidatorPrevote returns AggregateValidatorPrevote object

func (*AggregateValidatorPrevote) Descriptor 

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

func (*AggregateValidatorPrevote) Marshal 

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

func (*AggregateValidatorPrevote) MarshalTo 

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

func (*AggregateValidatorPrevote) MarshalToSizedBuffer 

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

func (*AggregateValidatorPrevote) ProtoMessage 

func (*AggregateValidatorPrevote) ProtoMessage()

func (*AggregateValidatorPrevote) Reset 

func (m *AggregateValidatorPrevote) Reset()

func (*AggregateValidatorPrevote) Size 

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

func (AggregateValidatorPrevote) String 

func (v AggregateValidatorPrevote) String() string

String implement stringify

func (*AggregateValidatorPrevote) Unmarshal 

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

func (*AggregateValidatorPrevote) XXX_DiscardUnknown 

func (m *AggregateValidatorPrevote) XXX_DiscardUnknown()

func (*AggregateValidatorPrevote) XXX_Marshal 

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

func (*AggregateValidatorPrevote) XXX_Merge 

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

func (*AggregateValidatorPrevote) XXX_Size 

func (m *AggregateValidatorPrevote) XXX_Size() int

func (*AggregateValidatorPrevote) XXX_Unmarshal 

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

type AggregateValidatorVote 

type AggregateValidatorVote struct {
	Validators []Validator `protobuf:"bytes,1,rep,name=validators,proto3" json:"validators" yaml:"validators"`
	Voter      string      `protobuf:"bytes,2,opt,name=voter,proto3" json:"voter,omitempty" yaml:"voter"`
}

MsgAggregateValidatorVote - struct for voting on

func NewAggregateValidatorVote 

func NewAggregateValidatorVote(validators Validators, voter sdk.ValAddress) AggregateValidatorVote

NewAggregateValidatorVote creates a AggregateValidatorVote instance

func (*AggregateValidatorVote) Descriptor 

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

func (*AggregateValidatorVote) Marshal 

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

func (*AggregateValidatorVote) MarshalTo 

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

func (*AggregateValidatorVote) MarshalToSizedBuffer 

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

func (*AggregateValidatorVote) ProtoMessage 

func (*AggregateValidatorVote) ProtoMessage()

func (*AggregateValidatorVote) Reset 

func (m *AggregateValidatorVote) Reset()

func (*AggregateValidatorVote) Size 

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

func (AggregateValidatorVote) String 

func (v AggregateValidatorVote) String() string

String implement stringify

func (*AggregateValidatorVote) Unmarshal 

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

func (*AggregateValidatorVote) XXX_DiscardUnknown 

func (m *AggregateValidatorVote) XXX_DiscardUnknown()

func (*AggregateValidatorVote) XXX_Marshal 

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

func (*AggregateValidatorVote) XXX_Merge 

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

func (*AggregateValidatorVote) XXX_Size 

func (m *AggregateValidatorVote) XXX_Size() int

func (*AggregateValidatorVote) XXX_Unmarshal 

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

type AggregateVoteHash 

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 

func AggregateVoteHashFromHexString(s string) (AggregateVoteHash, error)

AggregateVoteHashFromHexString convert hex string to AggregateVoteHash

func GetAggregateVoteHash 

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 

func (h AggregateVoteHash) Bytes() []byte

Bytes returns the raw address bytes.

func (AggregateVoteHash) Empty 

func (h AggregateVoteHash) Empty() bool

Empty check the name hash has zero length

func (AggregateVoteHash) Equal 

func (h AggregateVoteHash) Equal(h2 AggregateVoteHash) bool

Equal does bytes equal check

func (AggregateVoteHash) Format 

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

Format implements the fmt.Formatter interface.

func (AggregateVoteHash) Marshal 

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

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

func (AggregateVoteHash) MarshalJSON 

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

MarshalJSON marshals to JSON using Bech32.

func (AggregateVoteHash) MarshalYAML 

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

MarshalYAML marshals to YAML using Bech32.

func (AggregateVoteHash) Size 

func (h AggregateVoteHash) Size() int

Size returns the raw address bytes.

func (AggregateVoteHash) String 

func (h AggregateVoteHash) String() string

String implements fmt.Stringer interface

func (*AggregateVoteHash) Unmarshal 

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

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

func (*AggregateVoteHash) UnmarshalJSON 

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

UnmarshalJSON unmarshals from JSON assuming Bech32 encoding.

type BankKeeper 

type BankKeeper interface {
	SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
}

BankKeeper defines the expected interface needed to retrieve account balances.

type Claim 

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

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

func NewClaim 

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

NewClaim generates a Claim instance.

type DistributionKeeper 

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

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

DistributionKeeper is expected keeper for distribution module

type GenesisState 

type GenesisState struct {
	Params                     Params                      `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	WhitelistValidators        Validators                  `` /* 132-byte string literal not displayed */
	MissCounters               []MissCounter               `protobuf:"bytes,4,rep,name=miss_counters,json=missCounters,proto3" json:"miss_counters"`
	AggregateValidatorPrevotes []AggregateValidatorPrevote `` /* 131-byte string literal not displayed */
	AggregateValidatorVotes    []AggregateValidatorVote    `protobuf:"bytes,6,rep,name=aggregate_validator_votes,json=aggregateValidatorVotes,proto3" json:"aggregate_validator_votes"`
}

GenesisState defines the oraclevalidator module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default Capability genesis state

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetAggregateValidatorPrevotes 

func (m *GenesisState) GetAggregateValidatorPrevotes() []AggregateValidatorPrevote

func (*GenesisState) GetAggregateValidatorVotes 

func (m *GenesisState) GetAggregateValidatorVotes() []AggregateValidatorVote

func (*GenesisState) GetMissCounters 

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

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetWhitelistValidators 

func (m *GenesisState) GetWhitelistValidators() Validators

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (GenesisState) Validate 

func (gs GenesisState) Validate() error

Validate performs basic genesis state validation returning an error upon any failure.

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type MissCounter 

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

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

func (*MissCounter) Descriptor 

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

func (*MissCounter) GetMissCounter 

func (m *MissCounter) GetMissCounter() uint64

func (*MissCounter) GetValidatorAddress 

func (m *MissCounter) GetValidatorAddress() string

func (*MissCounter) Marshal 

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

func (*MissCounter) MarshalTo 

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

func (*MissCounter) MarshalToSizedBuffer 

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

func (*MissCounter) ProtoMessage 

func (*MissCounter) ProtoMessage()

func (*MissCounter) Reset 

func (m *MissCounter) Reset()

func (*MissCounter) Size 

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

func (*MissCounter) String 

func (m *MissCounter) String() string

func (*MissCounter) Unmarshal 

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

func (*MissCounter) XXX_DiscardUnknown 

func (m *MissCounter) XXX_DiscardUnknown()

func (*MissCounter) XXX_Marshal 

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

func (*MissCounter) XXX_Merge 

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

func (*MissCounter) XXX_Size 

func (m *MissCounter) XXX_Size() int

func (*MissCounter) XXX_Unmarshal 

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

type MsgAggregateValidatorPrevote 

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

MsgAggregateValidatorPrevote represents a message to submit aggregate exchange rate prevote.

func NewMsgAggregateValidatorPrevote 

func NewMsgAggregateValidatorPrevote(hash AggregateVoteHash, feeder sdk.AccAddress, validator sdk.ValAddress) *MsgAggregateValidatorPrevote

NewMsgAggregateValidatorPrevote returns MsgAggregateValidatorPrevote instance

func (*MsgAggregateValidatorPrevote) Descriptor 

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

func (MsgAggregateValidatorPrevote) GetSignBytes 

func (msg MsgAggregateValidatorPrevote) GetSignBytes() []byte

GetSignBytes implements sdk.Msg

func (MsgAggregateValidatorPrevote) GetSigners 

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

GetSigners implements sdk.Msg

func (*MsgAggregateValidatorPrevote) Marshal 

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

func (*MsgAggregateValidatorPrevote) MarshalTo 

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

func (*MsgAggregateValidatorPrevote) MarshalToSizedBuffer 

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

func (*MsgAggregateValidatorPrevote) ProtoMessage 

func (*MsgAggregateValidatorPrevote) ProtoMessage()

func (*MsgAggregateValidatorPrevote) Reset 

func (m *MsgAggregateValidatorPrevote) Reset()

func (MsgAggregateValidatorPrevote) Route 

func (msg MsgAggregateValidatorPrevote) Route() string

Route implements sdk.Msg

func (*MsgAggregateValidatorPrevote) Size 

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

func (*MsgAggregateValidatorPrevote) String 

func (m *MsgAggregateValidatorPrevote) String() string

func (MsgAggregateValidatorPrevote) Type 

func (msg MsgAggregateValidatorPrevote) Type() string

Type implements sdk.Msg

func (*MsgAggregateValidatorPrevote) Unmarshal 

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

func (MsgAggregateValidatorPrevote) ValidateBasic 

func (msg MsgAggregateValidatorPrevote) ValidateBasic() error

ValidateBasic Implements sdk.Msg

func (*MsgAggregateValidatorPrevote) XXX_DiscardUnknown 

func (m *MsgAggregateValidatorPrevote) XXX_DiscardUnknown()

func (*MsgAggregateValidatorPrevote) XXX_Marshal 

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

func (*MsgAggregateValidatorPrevote) XXX_Merge 

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

func (*MsgAggregateValidatorPrevote) XXX_Size 

func (m *MsgAggregateValidatorPrevote) XXX_Size() int

func (*MsgAggregateValidatorPrevote) XXX_Unmarshal 

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

type MsgAggregateValidatorPrevoteResponse 

type MsgAggregateValidatorPrevoteResponse struct {
}

MsgAggregateValidatorPrevoteResponse defines the Msg/AggregateValidatorPrevote response type.

func (*MsgAggregateValidatorPrevoteResponse) Descriptor 

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

func (*MsgAggregateValidatorPrevoteResponse) Marshal 

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

func (*MsgAggregateValidatorPrevoteResponse) MarshalTo 

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

func (*MsgAggregateValidatorPrevoteResponse) MarshalToSizedBuffer 

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

func (*MsgAggregateValidatorPrevoteResponse) ProtoMessage 

func (*MsgAggregateValidatorPrevoteResponse) ProtoMessage()

func (*MsgAggregateValidatorPrevoteResponse) Reset 

func (m *MsgAggregateValidatorPrevoteResponse) Reset()

func (*MsgAggregateValidatorPrevoteResponse) Size 

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

func (*MsgAggregateValidatorPrevoteResponse) String 

func (m *MsgAggregateValidatorPrevoteResponse) String() string

func (*MsgAggregateValidatorPrevoteResponse) Unmarshal 

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

func (*MsgAggregateValidatorPrevoteResponse) XXX_DiscardUnknown 

func (m *MsgAggregateValidatorPrevoteResponse) XXX_DiscardUnknown()

func (*MsgAggregateValidatorPrevoteResponse) XXX_Marshal 

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

func (*MsgAggregateValidatorPrevoteResponse) XXX_Merge 

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

func (*MsgAggregateValidatorPrevoteResponse) XXX_Size 

func (m *MsgAggregateValidatorPrevoteResponse) XXX_Size() int

func (*MsgAggregateValidatorPrevoteResponse) XXX_Unmarshal 

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

type MsgAggregateValidatorVote 

type MsgAggregateValidatorVote struct {
	Salt              string `protobuf:"bytes,1,opt,name=salt,proto3" json:"salt,omitempty" yaml:"salt"`
	ValidatorsAddress string `` /* 137-byte string literal not displayed */
	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"`
}

MsgAggregateValidatorVote represents a message to submit aggregate exchange rate vote.

func NewMsgAggregateValidatorVote 

func NewMsgAggregateValidatorVote(salt string, validatorsAddress string, feeder sdk.AccAddress, validator sdk.ValAddress) *MsgAggregateValidatorVote

NewMsgAggregateValidatorVote returns MsgAggregateValidatorVote instance

func (*MsgAggregateValidatorVote) Descriptor 

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

func (MsgAggregateValidatorVote) GetSignBytes 

func (msg MsgAggregateValidatorVote) GetSignBytes() []byte

GetSignBytes implements sdk.Msg

func (MsgAggregateValidatorVote) GetSigners 

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

GetSigners implements sdk.Msg

func (*MsgAggregateValidatorVote) Marshal 

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

func (*MsgAggregateValidatorVote) MarshalTo 

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

func (*MsgAggregateValidatorVote) MarshalToSizedBuffer 

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

func (*MsgAggregateValidatorVote) ProtoMessage 

func (*MsgAggregateValidatorVote) ProtoMessage()

func (*MsgAggregateValidatorVote) Reset 

func (m *MsgAggregateValidatorVote) Reset()

func (MsgAggregateValidatorVote) Route 

func (msg MsgAggregateValidatorVote) Route() string

Route implements sdk.Msg

func (*MsgAggregateValidatorVote) Size 

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

func (*MsgAggregateValidatorVote) String 

func (m *MsgAggregateValidatorVote) String() string

func (MsgAggregateValidatorVote) Type 

func (msg MsgAggregateValidatorVote) Type() string

Type implements sdk.Msg

func (*MsgAggregateValidatorVote) Unmarshal 

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

func (MsgAggregateValidatorVote) ValidateBasic 

func (msg MsgAggregateValidatorVote) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgAggregateValidatorVote) XXX_DiscardUnknown 

func (m *MsgAggregateValidatorVote) XXX_DiscardUnknown()

func (*MsgAggregateValidatorVote) XXX_Marshal 

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

func (*MsgAggregateValidatorVote) XXX_Merge 

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

func (*MsgAggregateValidatorVote) XXX_Size 

func (m *MsgAggregateValidatorVote) XXX_Size() int

func (*MsgAggregateValidatorVote) XXX_Unmarshal 

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

type MsgAggregateValidatorVoteResponse 

type MsgAggregateValidatorVoteResponse struct {
}

MsgAggregateValidatorVoteResponse defines the Msg/AggregateExchangeRateVote response type.

func (*MsgAggregateValidatorVoteResponse) Descriptor 

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

func (*MsgAggregateValidatorVoteResponse) Marshal 

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

func (*MsgAggregateValidatorVoteResponse) MarshalTo 

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

func (*MsgAggregateValidatorVoteResponse) MarshalToSizedBuffer 

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

func (*MsgAggregateValidatorVoteResponse) ProtoMessage 

func (*MsgAggregateValidatorVoteResponse) ProtoMessage()

func (*MsgAggregateValidatorVoteResponse) Reset 

func (m *MsgAggregateValidatorVoteResponse) Reset()

func (*MsgAggregateValidatorVoteResponse) Size 

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

func (*MsgAggregateValidatorVoteResponse) String 

func (m *MsgAggregateValidatorVoteResponse) String() string

func (*MsgAggregateValidatorVoteResponse) Unmarshal 

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

func (*MsgAggregateValidatorVoteResponse) XXX_DiscardUnknown 

func (m *MsgAggregateValidatorVoteResponse) XXX_DiscardUnknown()

func (*MsgAggregateValidatorVoteResponse) XXX_Marshal 

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

func (*MsgAggregateValidatorVoteResponse) XXX_Merge 

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

func (*MsgAggregateValidatorVoteResponse) XXX_Size 

func (m *MsgAggregateValidatorVoteResponse) XXX_Size() int

func (*MsgAggregateValidatorVoteResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// this line is used by starport scaffolding # proto/tx/rpc
	// AggregateValidatorPrevote defines a method for submitting
	// aggregate validator prevote
	AggregateValidatorPrevote(ctx context.Context, in *MsgAggregateValidatorPrevote, opts ...grpc.CallOption) (*MsgAggregateValidatorPrevoteResponse, error)
	// AggregateValidatorVote defines a method for submitting
	// aggregate exchange rate vote
	AggregateValidatorVote(ctx context.Context, in *MsgAggregateValidatorVote, opts ...grpc.CallOption) (*MsgAggregateValidatorVoteResponse, error)
	// DelegateFeedConsent defines a method for setting the feeder delegation
	DelegateFeedConsent(ctx context.Context, in *MsgDelegateFeedConsent, opts ...grpc.CallOption) (*MsgDelegateFeedConsentResponse, error)
}

MsgClient is the client API for Msg service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMsgClient 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgDelegateFeedConsent 

type MsgDelegateFeedConsent struct {
	Operator string `protobuf:"bytes,1,opt,name=operator,proto3" json:"operator,omitempty" yaml:"operator"`
	Delegate string `protobuf:"bytes,2,opt,name=delegate,proto3" json:"delegate,omitempty" yaml:"delegate"`
}

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

func NewMsgDelegateFeedConsent 

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

NewMsgDelegateFeedConsent creates a MsgDelegateFeedConsent instance

func (*MsgDelegateFeedConsent) Descriptor 

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

func (MsgDelegateFeedConsent) GetSignBytes 

func (msg MsgDelegateFeedConsent) GetSignBytes() []byte

GetSignBytes implements sdk.Msg

func (MsgDelegateFeedConsent) GetSigners 

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

GetSigners implements sdk.Msg

func (*MsgDelegateFeedConsent) Marshal 

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

func (*MsgDelegateFeedConsent) MarshalTo 

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

func (*MsgDelegateFeedConsent) MarshalToSizedBuffer 

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

func (*MsgDelegateFeedConsent) ProtoMessage 

func (*MsgDelegateFeedConsent) ProtoMessage()

func (*MsgDelegateFeedConsent) Reset 

func (m *MsgDelegateFeedConsent) Reset()

func (MsgDelegateFeedConsent) Route 

func (msg MsgDelegateFeedConsent) Route() string

Route implements sdk.Msg

func (*MsgDelegateFeedConsent) Size 

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

func (*MsgDelegateFeedConsent) String 

func (m *MsgDelegateFeedConsent) String() string

func (MsgDelegateFeedConsent) Type 

func (msg MsgDelegateFeedConsent) Type() string

Type implements sdk.Msg

func (*MsgDelegateFeedConsent) Unmarshal 

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

func (MsgDelegateFeedConsent) ValidateBasic 

func (msg MsgDelegateFeedConsent) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgDelegateFeedConsent) XXX_DiscardUnknown 

func (m *MsgDelegateFeedConsent) XXX_DiscardUnknown()

func (*MsgDelegateFeedConsent) XXX_Marshal 

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

func (*MsgDelegateFeedConsent) XXX_Merge 

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

func (*MsgDelegateFeedConsent) XXX_Size 

func (m *MsgDelegateFeedConsent) XXX_Size() int

func (*MsgDelegateFeedConsent) XXX_Unmarshal 

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

type MsgDelegateFeedConsentResponse 

type MsgDelegateFeedConsentResponse struct {
}

MsgDelegateFeedConsentResponse defines the Msg/DelegateFeedConsent response type.

func (*MsgDelegateFeedConsentResponse) Descriptor 

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

func (*MsgDelegateFeedConsentResponse) Marshal 

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

func (*MsgDelegateFeedConsentResponse) MarshalTo 

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

func (*MsgDelegateFeedConsentResponse) MarshalToSizedBuffer 

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

func (*MsgDelegateFeedConsentResponse) ProtoMessage 

func (*MsgDelegateFeedConsentResponse) ProtoMessage()

func (*MsgDelegateFeedConsentResponse) Reset 

func (m *MsgDelegateFeedConsentResponse) Reset()

func (*MsgDelegateFeedConsentResponse) Size 

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

func (*MsgDelegateFeedConsentResponse) String 

func (m *MsgDelegateFeedConsentResponse) String() string

func (*MsgDelegateFeedConsentResponse) Unmarshal 

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

func (*MsgDelegateFeedConsentResponse) XXX_DiscardUnknown 

func (m *MsgDelegateFeedConsentResponse) XXX_DiscardUnknown()

func (*MsgDelegateFeedConsentResponse) XXX_Marshal 

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

func (*MsgDelegateFeedConsentResponse) XXX_Merge 

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

func (*MsgDelegateFeedConsentResponse) XXX_Size 

func (m *MsgDelegateFeedConsentResponse) XXX_Size() int

func (*MsgDelegateFeedConsentResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// this line is used by starport scaffolding # proto/tx/rpc
	// AggregateValidatorPrevote defines a method for submitting
	// aggregate validator prevote
	AggregateValidatorPrevote(context.Context, *MsgAggregateValidatorPrevote) (*MsgAggregateValidatorPrevoteResponse, error)
	// AggregateValidatorVote defines a method for submitting
	// aggregate exchange rate vote
	AggregateValidatorVote(context.Context, *MsgAggregateValidatorVote) (*MsgAggregateValidatorVoteResponse, 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 OracleKeeper 

type OracleKeeper interface {
	GetFeederDelegation(ctx sdk.Context, operator sdk.ValAddress) sdk.AccAddress
}

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 */
	Whitelist         ValidatorList                          `protobuf:"bytes,3,rep,name=whitelist,proto3,castrepeated=ValidatorList" json:"whitelist" yaml:"whitelist"`
	SlashFraction     github_com_cosmos_cosmos_sdk_types.Dec `` /* 162-byte string literal not displayed */
	SlashWindow       uint64                                 `protobuf:"varint,5,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 module.

func DefaultParams 

func DefaultParams() Params

DefaultParams returns a default set of parameters

func NewParams 

func NewParams() Params

NewParams creates a new Params instance

func (*Params) Descriptor 

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

func (*Params) Equal 

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

func (*Params) GetSlashWindow 

func (m *Params) GetSlashWindow() uint64

func (*Params) GetVotePeriod 

func (m *Params) GetVotePeriod() uint64

func (*Params) GetWhitelist 

func (m *Params) GetWhitelist() ValidatorList

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

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

ParamSetPairs get the params.ParamSet

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (Params) String 

func (p Params) String() string

String implements the Stringer interface.

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

Validate validates the set of params

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type QueryActivesRequest 

type QueryActivesRequest struct {
}

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

func (*QueryActivesRequest) Descriptor 

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

func (*QueryActivesRequest) Marshal 

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

func (*QueryActivesRequest) MarshalTo 

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

func (*QueryActivesRequest) MarshalToSizedBuffer 

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

func (*QueryActivesRequest) ProtoMessage 

func (*QueryActivesRequest) ProtoMessage()

func (*QueryActivesRequest) Reset 

func (m *QueryActivesRequest) Reset()

func (*QueryActivesRequest) Size 

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

func (*QueryActivesRequest) String 

func (m *QueryActivesRequest) String() string

func (*QueryActivesRequest) Unmarshal 

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

func (*QueryActivesRequest) XXX_DiscardUnknown 

func (m *QueryActivesRequest) XXX_DiscardUnknown()

func (*QueryActivesRequest) XXX_Marshal 

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

func (*QueryActivesRequest) XXX_Merge 

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

func (*QueryActivesRequest) XXX_Size 

func (m *QueryActivesRequest) XXX_Size() int

func (*QueryActivesRequest) XXX_Unmarshal 

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

type QueryActivesResponse 

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

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

func (*QueryActivesResponse) Descriptor 

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

func (*QueryActivesResponse) GetActives 

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

func (*QueryActivesResponse) Marshal 

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

func (*QueryActivesResponse) MarshalTo 

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

func (*QueryActivesResponse) MarshalToSizedBuffer 

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

func (*QueryActivesResponse) ProtoMessage 

func (*QueryActivesResponse) ProtoMessage()

func (*QueryActivesResponse) Reset 

func (m *QueryActivesResponse) Reset()

func (*QueryActivesResponse) Size 

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

func (*QueryActivesResponse) String 

func (m *QueryActivesResponse) String() string

func (*QueryActivesResponse) Unmarshal 

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

func (*QueryActivesResponse) XXX_DiscardUnknown 

func (m *QueryActivesResponse) XXX_DiscardUnknown()

func (*QueryActivesResponse) XXX_Marshal 

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

func (*QueryActivesResponse) XXX_Merge 

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

func (*QueryActivesResponse) XXX_Size 

func (m *QueryActivesResponse) XXX_Size() int

func (*QueryActivesResponse) XXX_Unmarshal 

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

type QueryAggregatePrevoteRequest 

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 

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

func (*QueryAggregatePrevoteRequest) Marshal 

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

func (*QueryAggregatePrevoteRequest) MarshalTo 

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

func (*QueryAggregatePrevoteRequest) MarshalToSizedBuffer 

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

func (*QueryAggregatePrevoteRequest) ProtoMessage 

func (*QueryAggregatePrevoteRequest) ProtoMessage()

func (*QueryAggregatePrevoteRequest) Reset 

func (m *QueryAggregatePrevoteRequest) Reset()

func (*QueryAggregatePrevoteRequest) Size 

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

func (*QueryAggregatePrevoteRequest) String 

func (m *QueryAggregatePrevoteRequest) String() string

func (*QueryAggregatePrevoteRequest) Unmarshal 

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

func (*QueryAggregatePrevoteRequest) XXX_DiscardUnknown 

func (m *QueryAggregatePrevoteRequest) XXX_DiscardUnknown()

func (*QueryAggregatePrevoteRequest) XXX_Marshal 

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

func (*QueryAggregatePrevoteRequest) XXX_Merge 

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

func (*QueryAggregatePrevoteRequest) XXX_Size 

func (m *QueryAggregatePrevoteRequest) XXX_Size() int

func (*QueryAggregatePrevoteRequest) XXX_Unmarshal 

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

type QueryAggregatePrevoteResponse 

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

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

func (*QueryAggregatePrevoteResponse) Descriptor 

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

func (*QueryAggregatePrevoteResponse) GetAggregatePrevote 

func (m *QueryAggregatePrevoteResponse) GetAggregatePrevote() AggregateValidatorPrevote

func (*QueryAggregatePrevoteResponse) Marshal 

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

func (*QueryAggregatePrevoteResponse) MarshalTo 

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

func (*QueryAggregatePrevoteResponse) MarshalToSizedBuffer 

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

func (*QueryAggregatePrevoteResponse) ProtoMessage 

func (*QueryAggregatePrevoteResponse) ProtoMessage()

func (*QueryAggregatePrevoteResponse) Reset 

func (m *QueryAggregatePrevoteResponse) Reset()

func (*QueryAggregatePrevoteResponse) Size 

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

func (*QueryAggregatePrevoteResponse) String 

func (m *QueryAggregatePrevoteResponse) String() string

func (*QueryAggregatePrevoteResponse) Unmarshal 

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

func (*QueryAggregatePrevoteResponse) XXX_DiscardUnknown 

func (m *QueryAggregatePrevoteResponse) XXX_DiscardUnknown()

func (*QueryAggregatePrevoteResponse) XXX_Marshal 

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

func (*QueryAggregatePrevoteResponse) XXX_Merge 

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

func (*QueryAggregatePrevoteResponse) XXX_Size 

func (m *QueryAggregatePrevoteResponse) XXX_Size() int

func (*QueryAggregatePrevoteResponse) XXX_Unmarshal 

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

type QueryAggregatePrevotesRequest 

type QueryAggregatePrevotesRequest struct {
}

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

func (*QueryAggregatePrevotesRequest) Descriptor 

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

func (*QueryAggregatePrevotesRequest) Marshal 

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

func (*QueryAggregatePrevotesRequest) MarshalTo 

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

func (*QueryAggregatePrevotesRequest) MarshalToSizedBuffer 

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

func (*QueryAggregatePrevotesRequest) ProtoMessage 

func (*QueryAggregatePrevotesRequest) ProtoMessage()

func (*QueryAggregatePrevotesRequest) Reset 

func (m *QueryAggregatePrevotesRequest) Reset()

func (*QueryAggregatePrevotesRequest) Size 

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

func (*QueryAggregatePrevotesRequest) String 

func (m *QueryAggregatePrevotesRequest) String() string

func (*QueryAggregatePrevotesRequest) Unmarshal 

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

func (*QueryAggregatePrevotesRequest) XXX_DiscardUnknown 

func (m *QueryAggregatePrevotesRequest) XXX_DiscardUnknown()

func (*QueryAggregatePrevotesRequest) XXX_Marshal 

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

func (*QueryAggregatePrevotesRequest) XXX_Merge 

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

func (*QueryAggregatePrevotesRequest) XXX_Size 

func (m *QueryAggregatePrevotesRequest) XXX_Size() int

func (*QueryAggregatePrevotesRequest) XXX_Unmarshal 

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

type QueryAggregatePrevotesResponse 

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

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

func (*QueryAggregatePrevotesResponse) Descriptor 

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

func (*QueryAggregatePrevotesResponse) GetAggregatePrevotes 

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

func (*QueryAggregatePrevotesResponse) Marshal 

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

func (*QueryAggregatePrevotesResponse) MarshalTo 

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

func (*QueryAggregatePrevotesResponse) MarshalToSizedBuffer 

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

func (*QueryAggregatePrevotesResponse) ProtoMessage 

func (*QueryAggregatePrevotesResponse) ProtoMessage()

func (*QueryAggregatePrevotesResponse) Reset 

func (m *QueryAggregatePrevotesResponse) Reset()

func (*QueryAggregatePrevotesResponse) Size 

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

func (*QueryAggregatePrevotesResponse) String 

func (m *QueryAggregatePrevotesResponse) String() string

func (*QueryAggregatePrevotesResponse) Unmarshal 

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

func (*QueryAggregatePrevotesResponse) XXX_DiscardUnknown 

func (m *QueryAggregatePrevotesResponse) XXX_DiscardUnknown()

func (*QueryAggregatePrevotesResponse) XXX_Marshal 

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

func (*QueryAggregatePrevotesResponse) XXX_Merge 

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

func (*QueryAggregatePrevotesResponse) XXX_Size 

func (m *QueryAggregatePrevotesResponse) XXX_Size() int

func (*QueryAggregatePrevotesResponse) XXX_Unmarshal 

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

type QueryAggregateVoteRequest 

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 

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

func (*QueryAggregateVoteRequest) Marshal 

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

func (*QueryAggregateVoteRequest) MarshalTo 

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

func (*QueryAggregateVoteRequest) MarshalToSizedBuffer 

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

func (*QueryAggregateVoteRequest) ProtoMessage 

func (*QueryAggregateVoteRequest) ProtoMessage()

func (*QueryAggregateVoteRequest) Reset 

func (m *QueryAggregateVoteRequest) Reset()

func (*QueryAggregateVoteRequest) Size 

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

func (*QueryAggregateVoteRequest) String 

func (m *QueryAggregateVoteRequest) String() string

func (*QueryAggregateVoteRequest) Unmarshal 

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

func (*QueryAggregateVoteRequest) XXX_DiscardUnknown 

func (m *QueryAggregateVoteRequest) XXX_DiscardUnknown()

func (*QueryAggregateVoteRequest) XXX_Marshal 

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

func (*QueryAggregateVoteRequest) XXX_Merge 

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

func (*QueryAggregateVoteRequest) XXX_Size 

func (m *QueryAggregateVoteRequest) XXX_Size() int

func (*QueryAggregateVoteRequest) XXX_Unmarshal 

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

type QueryAggregateVoteResponse 

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

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

func (*QueryAggregateVoteResponse) Descriptor 

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

func (*QueryAggregateVoteResponse) GetAggregateVote 

func (m *QueryAggregateVoteResponse) GetAggregateVote() AggregateValidatorVote

func (*QueryAggregateVoteResponse) Marshal 

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

func (*QueryAggregateVoteResponse) MarshalTo 

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

func (*QueryAggregateVoteResponse) MarshalToSizedBuffer 

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

func (*QueryAggregateVoteResponse) ProtoMessage 

func (*QueryAggregateVoteResponse) ProtoMessage()

func (*QueryAggregateVoteResponse) Reset 

func (m *QueryAggregateVoteResponse) Reset()

func (*QueryAggregateVoteResponse) Size 

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

func (*QueryAggregateVoteResponse) String 

func (m *QueryAggregateVoteResponse) String() string

func (*QueryAggregateVoteResponse) Unmarshal 

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

func (*QueryAggregateVoteResponse) XXX_DiscardUnknown 

func (m *QueryAggregateVoteResponse) XXX_DiscardUnknown()

func (*QueryAggregateVoteResponse) XXX_Marshal 

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

func (*QueryAggregateVoteResponse) XXX_Merge 

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

func (*QueryAggregateVoteResponse) XXX_Size 

func (m *QueryAggregateVoteResponse) XXX_Size() int

func (*QueryAggregateVoteResponse) XXX_Unmarshal 

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

type QueryAggregateVotesRequest 

type QueryAggregateVotesRequest struct {
}

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

func (*QueryAggregateVotesRequest) Descriptor 

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

func (*QueryAggregateVotesRequest) Marshal 

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

func (*QueryAggregateVotesRequest) MarshalTo 

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

func (*QueryAggregateVotesRequest) MarshalToSizedBuffer 

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

func (*QueryAggregateVotesRequest) ProtoMessage 

func (*QueryAggregateVotesRequest) ProtoMessage()

func (*QueryAggregateVotesRequest) Reset 

func (m *QueryAggregateVotesRequest) Reset()

func (*QueryAggregateVotesRequest) Size 

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

func (*QueryAggregateVotesRequest) String 

func (m *QueryAggregateVotesRequest) String() string

func (*QueryAggregateVotesRequest) Unmarshal 

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

func (*QueryAggregateVotesRequest) XXX_DiscardUnknown 

func (m *QueryAggregateVotesRequest) XXX_DiscardUnknown()

func (*QueryAggregateVotesRequest) XXX_Marshal 

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

func (*QueryAggregateVotesRequest) XXX_Merge 

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

func (*QueryAggregateVotesRequest) XXX_Size 

func (m *QueryAggregateVotesRequest) XXX_Size() int

func (*QueryAggregateVotesRequest) XXX_Unmarshal 

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

type QueryAggregateVotesResponse 

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

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

func (*QueryAggregateVotesResponse) Descriptor 

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

func (*QueryAggregateVotesResponse) GetAggregateVotes 

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

func (*QueryAggregateVotesResponse) Marshal 

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

func (*QueryAggregateVotesResponse) MarshalTo 

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

func (*QueryAggregateVotesResponse) MarshalToSizedBuffer 

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

func (*QueryAggregateVotesResponse) ProtoMessage 

func (*QueryAggregateVotesResponse) ProtoMessage()

func (*QueryAggregateVotesResponse) Reset 

func (m *QueryAggregateVotesResponse) Reset()

func (*QueryAggregateVotesResponse) Size 

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

func (*QueryAggregateVotesResponse) String 

func (m *QueryAggregateVotesResponse) String() string

func (*QueryAggregateVotesResponse) Unmarshal 

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

func (*QueryAggregateVotesResponse) XXX_DiscardUnknown 

func (m *QueryAggregateVotesResponse) XXX_DiscardUnknown()

func (*QueryAggregateVotesResponse) XXX_Marshal 

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

func (*QueryAggregateVotesResponse) XXX_Merge 

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

func (*QueryAggregateVotesResponse) XXX_Size 

func (m *QueryAggregateVotesResponse) XXX_Size() int

func (*QueryAggregateVotesResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Parameters queries the parameters of the module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// Actives returns all whitelisted validators
	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)
	// 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)
}

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 QueryFeederDelegationRequest 

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

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

func (*QueryFeederDelegationRequest) Descriptor 

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

func (*QueryFeederDelegationRequest) Marshal 

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

func (*QueryFeederDelegationRequest) MarshalTo 

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

func (*QueryFeederDelegationRequest) MarshalToSizedBuffer 

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

func (*QueryFeederDelegationRequest) ProtoMessage 

func (*QueryFeederDelegationRequest) ProtoMessage()

func (*QueryFeederDelegationRequest) Reset 

func (m *QueryFeederDelegationRequest) Reset()

func (*QueryFeederDelegationRequest) Size 

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

func (*QueryFeederDelegationRequest) String 

func (m *QueryFeederDelegationRequest) String() string

func (*QueryFeederDelegationRequest) Unmarshal 

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

func (*QueryFeederDelegationRequest) XXX_DiscardUnknown 

func (m *QueryFeederDelegationRequest) XXX_DiscardUnknown()

func (*QueryFeederDelegationRequest) XXX_Marshal 

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

func (*QueryFeederDelegationRequest) XXX_Merge 

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

func (*QueryFeederDelegationRequest) XXX_Size 

func (m *QueryFeederDelegationRequest) XXX_Size() int

func (*QueryFeederDelegationRequest) XXX_Unmarshal 

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

type QueryFeederDelegationResponse 

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

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

func (*QueryFeederDelegationResponse) Descriptor 

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

func (*QueryFeederDelegationResponse) GetFeederAddr 

func (m *QueryFeederDelegationResponse) GetFeederAddr() string

func (*QueryFeederDelegationResponse) Marshal 

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

func (*QueryFeederDelegationResponse) MarshalTo 

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

func (*QueryFeederDelegationResponse) MarshalToSizedBuffer 

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

func (*QueryFeederDelegationResponse) ProtoMessage 

func (*QueryFeederDelegationResponse) ProtoMessage()

func (*QueryFeederDelegationResponse) Reset 

func (m *QueryFeederDelegationResponse) Reset()

func (*QueryFeederDelegationResponse) Size 

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

func (*QueryFeederDelegationResponse) String 

func (m *QueryFeederDelegationResponse) String() string

func (*QueryFeederDelegationResponse) Unmarshal 

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

func (*QueryFeederDelegationResponse) XXX_DiscardUnknown 

func (m *QueryFeederDelegationResponse) XXX_DiscardUnknown()

func (*QueryFeederDelegationResponse) XXX_Marshal 

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

func (*QueryFeederDelegationResponse) XXX_Merge 

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

func (*QueryFeederDelegationResponse) XXX_Size 

func (m *QueryFeederDelegationResponse) XXX_Size() int

func (*QueryFeederDelegationResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest is 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 holds all the parameters of this module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse is 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 QueryServer 

type QueryServer interface {
	// Parameters queries the parameters of the module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// Actives returns all whitelisted validators
	Actives(context.Context, *QueryActivesRequest) (*QueryActivesResponse, error)
	// FeederDelegation returns feeder delegation of a validator
	FeederDelegation(context.Context, *QueryFeederDelegationRequest) (*QueryFeederDelegationResponse, 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)
}

QueryServer is the server API for Query service.

type StakingKeeper 

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

StakingKeeper is expected keeper for staking module

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) AggregateValidatorPrevote 

func (*UnimplementedMsgServer) AggregateValidatorPrevote(ctx context.Context, req *MsgAggregateValidatorPrevote) (*MsgAggregateValidatorPrevoteResponse, error)

func (*UnimplementedMsgServer) AggregateValidatorVote 

func (*UnimplementedMsgServer) AggregateValidatorVote(ctx context.Context, req *MsgAggregateValidatorVote) (*MsgAggregateValidatorVoteResponse, error)

func (*UnimplementedMsgServer) DelegateFeedConsent 

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

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Actives 

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

func (*UnimplementedQueryServer) AggregatePrevote 

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

func (*UnimplementedQueryServer) AggregatePrevotes 

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

func (*UnimplementedQueryServer) AggregateVote 

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

func (*UnimplementedQueryServer) AggregateVotes 

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

func (*UnimplementedQueryServer) FeederDelegation 

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

func (*UnimplementedQueryServer) Params 

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

type Validator 

type Validator struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" yaml:"name"`
}

Validator define the parameters for each validator

func (*Validator) Descriptor 

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

func (Validator) Equal 

func (v Validator) Equal(v1 *Validator) bool

Equal implements equal interface

func (*Validator) Marshal 

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

func (*Validator) MarshalTo 

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

func (*Validator) MarshalToSizedBuffer 

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

func (*Validator) ProtoMessage 

func (*Validator) ProtoMessage()

func (*Validator) Reset 

func (m *Validator) Reset()

func (*Validator) Size 

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

func (Validator) String 

func (v Validator) String() string

String implements fmt.Stringer interface

func (*Validator) Unmarshal 

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

func (*Validator) XXX_DiscardUnknown 

func (m *Validator) XXX_DiscardUnknown()

func (*Validator) XXX_Marshal 

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

func (*Validator) XXX_Merge 

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

func (*Validator) XXX_Size 

func (m *Validator) XXX_Size() int

func (*Validator) XXX_Unmarshal 

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

type ValidatorList 

type ValidatorList []Validator

DenomList is array of Denom

func (ValidatorList) String 

func (vl ValidatorList) String() (out string)

String implements fmt.Stringer interface

type Validators 

type Validators []Validator

func ParseValidators 

func ParseValidators(validatorsStr string) (Validators, error)

type VoteForTally 

type VoteForTally struct {
	Voter sdk.ValAddress
	Power int64
}

VoteForTally is a convenience wrapper to reduce redundant lookup cost

func NewVoteForTally 

func NewVoteForTally(voter sdk.ValAddress, address string, power int64) VoteForTally

NewVoteForTally returns a new VoteForTally instance

Source Files

View all Source files

Directories

Path Synopsis

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.