types

package
v3.0.0-...-1ba514b Latest Latest
Warning

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

 Go to latest Published: Nov 23, 2024 License: GPL-3.0 Imports: 43 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	// MaxSignalIDCharacters defines the maximum number of characters allowed in a signal ID.
	MaxSignalIDCharacters uint64 = 32

	// MaxGuaranteeBlockTime specifies the maximum capped block time (in seconds) during a grace period.
	// If block times are slower, they will be capped at this value to prevent validator deactivation,
	// as long as the block height remains within the calculated threshold for MaxGuaranteeBlockTime.
	MaxGuaranteeBlockTime int64 = 3
)
View Source 
const (
	EncoderFixedPointABIPrefix = "\xcb\xa0\xad\x5a" // tss.Hash([]byte("FixedPointABI"))[:4]
	EncoderTickABIPrefix       = "\xdb\x99\xb2\xb3" // tss.Hash([]byte("TickABI"))[:4]
)
View Source 
const (
	EventTypeSubmitSignalPrice           = "submit_signal_price"
	EventTypeUpdatePrice                 = "update_price"
	EventTypeUpdateSignalTotalPower      = "update_signal_total_power"
	EventTypeDeleteSignalTotalPower      = "delete_signal_total_power"
	EventTypeUpdateCurrentFeeds          = "update_current_feeds"
	EventTypeUpdateReferenceSourceConfig = "update_reference_source_config"
	EventTypeUpdateParams                = "update_params"

	AttributeKeySignalPriceStatus   = "signal_price_status"
	AttributeKeyPriceStatus         = "price_status"
	AttributeKeyValidator           = "validator"
	AttributeKeyPrice               = "price"
	AttributeKeyTimestamp           = "timestamp"
	AttributeKeySignalID            = "signal_id"
	AttributeKeyPower               = "power"
	AttributeKeyInterval            = "interval"
	AttributeKeyLastUpdateTimestamp = "last_update_timestamp"
	AttributeKeyLastUpdateBlock     = "last_update_block"
	AttributeKeyDeviationBasisPoint = "deviation_basis_point"
	AttributeKeyErrorMessage        = "error_message"
	AttributeKeyRegistryIPFSHash    = "registry_ipfs_hash"
	AttributeKeyRegistryVersion     = "registry_version"
	AttributeKeyParams              = "params"
)

events

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

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

	// RouterKey defines the module's message routing key
	RouterKey = ModuleName

	// QuerierRoute is the querier route for the feeds module
	QuerierRoute = ModuleName
)
View Source 
const (
	SignatureOrderTypeFeeds = "Feeds"
)

signature order types

Variables

View Source 
var (
	ErrPriceNotFound            = errorsmod.Register(ModuleName, 2, "price not found")
	ErrValidatorPriceNotFound   = errorsmod.Register(ModuleName, 3, "validator price not found")
	ErrOracleStatusNotActive    = errorsmod.Register(ModuleName, 4, "oracle status not active")
	ErrPriceSubmitTooEarly      = errorsmod.Register(ModuleName, 5, "price is submitted too early")
	ErrInvalidTimestamp         = errorsmod.Register(ModuleName, 6, "invalid timestamp")
	ErrNotEnoughValidatorPrice  = errorsmod.Register(ModuleName, 7, "not enough validator price")
	ErrInvalidSigner            = errorsmod.Register(ModuleName, 8, "invalid signer")
	ErrNotBondedValidator       = errorsmod.Register(ModuleName, 9, "not bonded validator")
	ErrInvalidWeightedPrices    = errorsmod.Register(ModuleName, 10, "invalid weighted prices")
	ErrPowerNegative            = errorsmod.Register(ModuleName, 11, "power is negative")
	ErrSignalIDNotSupported     = errorsmod.Register(ModuleName, 12, "signal id is not supported")
	ErrSignalPricesTooLarge     = errorsmod.Register(ModuleName, 13, "signal prices list is too large")
	ErrSignalIDTooLarge         = errorsmod.Register(ModuleName, 14, "signal id is too large")
	ErrSignalTotalPowerNotFound = errorsmod.Register(ModuleName, 15, "signal-total-power not found")
	ErrInvalidSignal            = errorsmod.Register(ModuleName, 16, "invalid signal")
	ErrSubmittedSignalsTooLarge = errorsmod.Register(ModuleName, 17, "submitted signals list is too large")
	ErrDuplicateSignalID        = errorsmod.Register(ModuleName, 18, "duplicate signal id")
	ErrInvalidSignalIDs         = errorsmod.Register(ModuleName, 19, "invalid signal ids")
	ErrInvalidEncoder           = errorsmod.Register(ModuleName, 20, "invalid encoder")
	ErrEncodingPriceFailed      = errorsmod.Register(ModuleName, 21, "fail to encode price")
)

x/feeds module sentinel errors

View Source 
var (
	ErrInvalidLengthFeeds        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFeeds          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupFeeds = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// global store keys
	ReferenceSourceConfigStoreKey = []byte{0x00}
	CurrentFeedsStoreKey          = []byte{0x01}

	// store prefixes
	ValidatorPriceListStoreKeyPrefix = []byte{0x10}
	PriceStoreKeyPrefix              = []byte{0x11}
	VoteStoreKeyPrefix               = []byte{0x12}
	SignalTotalPowerStoreKeyPrefix   = []byte{0x13}

	// index prefixes
	SignalTotalPowerByPowerIndexKeyPrefix = []byte{0x80}

	// params store keys
	ParamsKey = []byte{0x90}
)

Constants for keys

View Source 
var (
	// Default values for Params
	DefaultAllowableBlockTimeDiscrepancy = int64(60)
	DefaultGracePeriod                   = int64(30)
	DefaultMinInterval                   = int64(60)
	DefaultMaxInterval                   = int64(3600)
	DefaultPowerStepThreshold            = int64(1_000_000_000)
	DefaultMaxCurrentFeeds               = uint64(300)
	DefaultCooldownTime                  = int64(30)
	DefaultMinDeviationBasisPoint        = int64(50)
	DefaultMaxDeviationBasisPoint        = int64(3000)
	// estimated from block time of 1 seconds, aims for 1 day update
	DefaultCurrentFeedsUpdateInterval = int64(86400)
	DefaultPriceQuorum                = math.LegacyNewDecWithPrec(30, 2)
	DefaultMaxSignalIDsPerSigning     = uint64(25)
)
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")
)
View Source 
var Encoder_name = map[int32]string{
	0: "ENCODER_UNSPECIFIED",
	1: "ENCODER_FIXED_POINT_ABI",
	2: "ENCODER_TICK_ABI",
}
View Source 
var Encoder_value = map[string]int32{
	"ENCODER_UNSPECIFIED":     0,
	"ENCODER_FIXED_POINT_ABI": 1,
	"ENCODER_TICK_ABI":        2,
}
View Source 
var PriceStatus_name = map[int32]string{
	0: "PRICE_STATUS_UNSPECIFIED",
	1: "PRICE_STATUS_UNKNOWN_SIGNAL_ID",
	2: "PRICE_STATUS_NOT_READY",
	3: "PRICE_STATUS_AVAILABLE",
	4: "PRICE_STATUS_NOT_IN_CURRENT_FEEDS",
}
View Source 
var PriceStatus_value = map[string]int32{
	"PRICE_STATUS_UNSPECIFIED":          0,
	"PRICE_STATUS_UNKNOWN_SIGNAL_ID":    1,
	"PRICE_STATUS_NOT_READY":            2,
	"PRICE_STATUS_AVAILABLE":            3,
	"PRICE_STATUS_NOT_IN_CURRENT_FEEDS": 4,
}
View Source 
var SignalPriceStatus_name = map[int32]string{
	0: "SIGNAL_PRICE_STATUS_UNSPECIFIED",
	1: "SIGNAL_PRICE_STATUS_UNSUPPORTED",
	2: "SIGNAL_PRICE_STATUS_UNAVAILABLE",
	3: "SIGNAL_PRICE_STATUS_AVAILABLE",
}
View Source 
var SignalPriceStatus_value = map[string]int32{
	"SIGNAL_PRICE_STATUS_UNSPECIFIED": 0,
	"SIGNAL_PRICE_STATUS_UNSUPPORTED": 1,
	"SIGNAL_PRICE_STATUS_UNAVAILABLE": 2,
	"SIGNAL_PRICE_STATUS_AVAILABLE":   3,
}

Functions

func AbsInt64 

func AbsInt64(x int64) int64

AbsInt64 returns an absolute of int64. Panics on min int64 (-9223372036854775808).

func CalculateDeviation 

func CalculateDeviation(power int64, powerStep int64, minDeviationBP int64, maxDeviationBP int64) (deviation int64)

CalculateDeviation calculates feed deviation from power

func CalculateInterval 

func CalculateInterval(power int64, powerStep int64, minInterval int64, maxInterval int64) (interval int64)

CalculateInterval calculates feed interval from power

func CalculatePricesPowers 

func CalculatePricesPowers(
	validatorPriceInfos []ValidatorPriceInfo,
) (sdkmath.Int, sdkmath.Int, sdkmath.Int, sdkmath.Int)

CalculatePricesPowers calculates total, available, unavailable, and unsupported powers

func EncodeTss 

func EncodeTss(prices []Price, timestamp int64, encoder Encoder) ([]byte, error)

EncodeTss encodes the feed prices to tss message

func MedianValidatorPriceInfos 

func MedianValidatorPriceInfos(validatorPriceInfos []ValidatorPriceInfo) (uint64, error)

MedianValidatorPriceInfos calculates a time-weighted and power-weighted median price from ValidatorPriceInfo entries, prioritizing recent timestamps and higher power values.

Algorithm Overview:

  1. **Filter and Sum Power**: Filter entries with available prices and sum their power to set a baseline for section capacities.

  2. **Sort Entries**: Sort entries by timestamp (newest first) and, within equal timestamps, by power (highest first). This ensures recent, high-power entries are prioritized.

  3. **Set Multipliers and Sections**: Define multipliers and sections for weighting. Each section has a capacity based on a fraction of the total power, and earlier sections have higher multipliers to favor recent entries.

4. **Distribute Power Across Sections**: For each entry, distribute power across sections:

  • Start from the section where the previous entry left off, progressing until all power is allocated.
  • For each section, calculate the maximum power that can be taken without exceeding its capacity. Apply the section’s multiplier to this power to accumulate a weighted total for the entry.

5. **Store Weighted Prices**: Calculate the weighted price for each entry and store it in a list.

  1. **Compute Median**: Calculate the median of weighted prices, yielding a time- and power-weighted median price that reflects the most recent and influential entries.

func MedianWeightedPrice 

func MedianWeightedPrice(weightedPrices []WeightedPrice) (uint64, error)

MedianWeightedPrice finds the median price from a list of weighted prices.

func PriceStoreKey 

func PriceStoreKey(signalID string) []byte

PriceStoreKey creates a key for storing price data

func RegisterInterfaces 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

RegisterInterfaces register the feeds module interfaces to protobuf Any.

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec registers concrete types on the LegacyAmino codec

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 SignalTotalPowerByPowerIndexKey 

func SignalTotalPowerByPowerIndexKey(signalID string, power int64) []byte

SignalTotalPowerByPowerIndexKey creates a key for storing signal-total-powers by power index

func SignalTotalPowerStoreKey 

func SignalTotalPowerStoreKey(signalID string) []byte

SignalTotalPowerStoreKey creates a key for storing signal-total-powers

func StringToBytes32 

func StringToBytes32(str string) ([32]byte, error)

StringToBytes32 converts a string to a fixed size byte array.

func SumPower 

func SumPower(signals []Signal) (sum int64)

SumPower sums power from a list of signals

func ValidateEncoder 

func ValidateEncoder(encoder Encoder) error

ValidateEncoder validates the encoder.

func ValidatorPriceListStoreKey 

func ValidatorPriceListStoreKey(validator sdk.ValAddress) []byte

ValidatorPriceListStoreKey creates a key for storing a validator prices list

func VoteStoreKey 

func VoteStoreKey(voter sdk.AccAddress) []byte

VoteStoreKey creates a key for storing vote

Types

type AuthzKeeper 

type AuthzKeeper interface {
	GetAuthorization(
		ctx context.Context,
		feeder sdk.AccAddress,
		granter sdk.AccAddress,
		msgType string,
	) (authz.Authorization, *time.Time)
}

AuthzKeeper defines the expected authz keeper. for query and testing only don't use to create/remove grant on deliver tx

type CurrentFeedWithDeviations 

type CurrentFeedWithDeviations struct {
	// feeds is a list of currently supported feed-with-deviations.
	Feeds []FeedWithDeviation `protobuf:"bytes,1,rep,name=feeds,proto3" json:"feeds"`
	// last_update_timestamp is the timestamp of the last time supported feeds list is updated.
	LastUpdateTimestamp int64 `protobuf:"varint,2,opt,name=last_update_timestamp,json=lastUpdateTimestamp,proto3" json:"last_update_timestamp,omitempty"`
	// last_update_block is the number of blocks of the last time supported feeds list is updated.
	LastUpdateBlock int64 `protobuf:"varint,3,opt,name=last_update_block,json=lastUpdateBlock,proto3" json:"last_update_block,omitempty"`
}

CurrentFeedWithDeviations is a structure that holds a list of currently supported feed-with-deviations, and its last update time and block.

func NewCurrentFeedWithDeviations 

func NewCurrentFeedWithDeviations(
	feedWithDeviations []FeedWithDeviation,
	lastUpdateTimestamp int64,
	lastUpdateBlock int64,
) CurrentFeedWithDeviations

NewCurrentFeedWithDeviations creates a new current feeds with deviations instance

func (*CurrentFeedWithDeviations) Descriptor 

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

func (*CurrentFeedWithDeviations) Equal 

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

func (*CurrentFeedWithDeviations) GetFeeds 

func (m *CurrentFeedWithDeviations) GetFeeds() []FeedWithDeviation

func (*CurrentFeedWithDeviations) GetLastUpdateBlock 

func (m *CurrentFeedWithDeviations) GetLastUpdateBlock() int64

func (*CurrentFeedWithDeviations) GetLastUpdateTimestamp 

func (m *CurrentFeedWithDeviations) GetLastUpdateTimestamp() int64

func (*CurrentFeedWithDeviations) Marshal 

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

func (*CurrentFeedWithDeviations) MarshalTo 

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

func (*CurrentFeedWithDeviations) MarshalToSizedBuffer 

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

func (*CurrentFeedWithDeviations) ProtoMessage 

func (*CurrentFeedWithDeviations) ProtoMessage()

func (*CurrentFeedWithDeviations) Reset 

func (m *CurrentFeedWithDeviations) Reset()

func (*CurrentFeedWithDeviations) Size 

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

func (*CurrentFeedWithDeviations) String 

func (m *CurrentFeedWithDeviations) String() string

func (*CurrentFeedWithDeviations) Unmarshal 

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

func (*CurrentFeedWithDeviations) XXX_DiscardUnknown 

func (m *CurrentFeedWithDeviations) XXX_DiscardUnknown()

func (*CurrentFeedWithDeviations) XXX_Marshal 

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

func (*CurrentFeedWithDeviations) XXX_Merge 

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

func (*CurrentFeedWithDeviations) XXX_Size 

func (m *CurrentFeedWithDeviations) XXX_Size() int

func (*CurrentFeedWithDeviations) XXX_Unmarshal 

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

type CurrentFeeds 

type CurrentFeeds struct {
	// feeds is a list of currently supported feeds.
	Feeds []Feed `protobuf:"bytes,1,rep,name=feeds,proto3" json:"feeds"`
	// last_update_timestamp is the timestamp of the last time supported feeds list is updated.
	LastUpdateTimestamp int64 `protobuf:"varint,2,opt,name=last_update_timestamp,json=lastUpdateTimestamp,proto3" json:"last_update_timestamp,omitempty"`
	// last_update_block is the number of blocks of the last time supported feeds list is updated.
	LastUpdateBlock int64 `protobuf:"varint,3,opt,name=last_update_block,json=lastUpdateBlock,proto3" json:"last_update_block,omitempty"`
}

CurrentFeeds is a structure that holds a list of currently supported feeds, and its last update time and block.

func NewCurrentFeeds 

func NewCurrentFeeds(
	feeds []Feed,
	lastUpdateTimestamp int64,
	lastUpdateBlock int64,
) CurrentFeeds

NewCurrentFeeds creates a new current feeds instance

func (*CurrentFeeds) Descriptor 

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

func (*CurrentFeeds) Equal 

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

func (*CurrentFeeds) GetFeeds 

func (m *CurrentFeeds) GetFeeds() []Feed

func (*CurrentFeeds) GetLastUpdateBlock 

func (m *CurrentFeeds) GetLastUpdateBlock() int64

func (*CurrentFeeds) GetLastUpdateTimestamp 

func (m *CurrentFeeds) GetLastUpdateTimestamp() int64

func (*CurrentFeeds) Marshal 

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

func (*CurrentFeeds) MarshalTo 

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

func (*CurrentFeeds) MarshalToSizedBuffer 

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

func (*CurrentFeeds) ProtoMessage 

func (*CurrentFeeds) ProtoMessage()

func (*CurrentFeeds) Reset 

func (m *CurrentFeeds) Reset()

func (*CurrentFeeds) Size 

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

func (*CurrentFeeds) String 

func (m *CurrentFeeds) String() string

func (*CurrentFeeds) Unmarshal 

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

func (*CurrentFeeds) XXX_DiscardUnknown 

func (m *CurrentFeeds) XXX_DiscardUnknown()

func (*CurrentFeeds) XXX_Marshal 

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

func (*CurrentFeeds) XXX_Merge 

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

func (*CurrentFeeds) XXX_Size 

func (m *CurrentFeeds) XXX_Size() int

func (*CurrentFeeds) XXX_Unmarshal 

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

type Encoder 

type Encoder int32

Encoder is an enumerator that defines the mode of encoding message in tss module. 

const (
	// ENCODER_UNSPECIFIED is an unspecified encoder mode.
	ENCODER_UNSPECIFIED Encoder = 0
	// ENCODER_FIXED_POINT_ABI is a fixed-point price abi encoder (price * 10^9).
	ENCODER_FIXED_POINT_ABI Encoder = 1
	// ENCODER_TICK_ABI is a tick abi encoder.
	ENCODER_TICK_ABI Encoder = 2
)

func (Encoder) EnumDescriptor 

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

func (Encoder) String 

func (x Encoder) String() string

type Feed 

type Feed struct {
	// signal_id is the unique string that identifies the unit of feed.
	SignalID string `protobuf:"bytes,1,opt,name=signal_id,json=signalId,proto3" json:"signal_id,omitempty"`
	// power is the power of the corresponding signal id.
	Power int64 `protobuf:"varint,2,opt,name=power,proto3" json:"power,omitempty"`
	// interval is the interval of the price feed.
	Interval int64 `protobuf:"varint,3,opt,name=interval,proto3" json:"interval,omitempty"`
}

Feed is a structure that holds a signal id, its total power, and its calculated interval.

func NewFeed 

func NewFeed(
	signalID string,
	power int64,
	interval int64,
) Feed

NewFeed creates a new feed instance

func (*Feed) Descriptor 

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

func (*Feed) Equal 

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

func (*Feed) GetInterval 

func (m *Feed) GetInterval() int64

func (*Feed) GetPower 

func (m *Feed) GetPower() int64

func (*Feed) GetSignalID 

func (m *Feed) GetSignalID() string

func (*Feed) Marshal 

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

func (*Feed) MarshalTo 

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

func (*Feed) MarshalToSizedBuffer 

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

func (*Feed) ProtoMessage 

func (*Feed) ProtoMessage()

func (*Feed) Reset 

func (m *Feed) Reset()

func (*Feed) Size 

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

func (*Feed) String 

func (m *Feed) String() string

func (*Feed) Unmarshal 

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

func (*Feed) XXX_DiscardUnknown 

func (m *Feed) XXX_DiscardUnknown()

func (*Feed) XXX_Marshal 

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

func (*Feed) XXX_Merge 

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

func (*Feed) XXX_Size 

func (m *Feed) XXX_Size() int

func (*Feed) XXX_Unmarshal 

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

type FeedWithDeviation 

type FeedWithDeviation struct {
	// signal_id is the unique string that identifies the unit of feed.
	SignalID string `protobuf:"bytes,1,opt,name=signal_id,json=signalId,proto3" json:"signal_id,omitempty"`
	// power is the power of the corresponding signal id.
	Power int64 `protobuf:"varint,2,opt,name=power,proto3" json:"power,omitempty"`
	// interval is the interval of the price feed.
	Interval int64 `protobuf:"varint,3,opt,name=interval,proto3" json:"interval,omitempty"`
	// deviation_basis_point is the maximum deviation value the feed can tolerate, expressed in basis points.
	DeviationBasisPoint int64 `protobuf:"varint,4,opt,name=deviation_basis_point,json=deviationBasisPoint,proto3" json:"deviation_basis_point,omitempty"`
}

FeedWithDeviation is a structure that holds a signal id, its total power, and its calculated interval and deviation.

func NewFeedWithDeviation 

func NewFeedWithDeviation(
	signalID string,
	power int64,
	interval int64,
	deviation int64,
) FeedWithDeviation

NewFeedWithDeviation creates a new feed instance with deviation

func (*FeedWithDeviation) Descriptor 

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

func (*FeedWithDeviation) Equal 

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

func (*FeedWithDeviation) GetDeviationBasisPoint 

func (m *FeedWithDeviation) GetDeviationBasisPoint() int64

func (*FeedWithDeviation) GetInterval 

func (m *FeedWithDeviation) GetInterval() int64

func (*FeedWithDeviation) GetPower 

func (m *FeedWithDeviation) GetPower() int64

func (*FeedWithDeviation) GetSignalID 

func (m *FeedWithDeviation) GetSignalID() string

func (*FeedWithDeviation) Marshal 

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

func (*FeedWithDeviation) MarshalTo 

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

func (*FeedWithDeviation) MarshalToSizedBuffer 

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

func (*FeedWithDeviation) ProtoMessage 

func (*FeedWithDeviation) ProtoMessage()

func (*FeedWithDeviation) Reset 

func (m *FeedWithDeviation) Reset()

func (*FeedWithDeviation) Size 

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

func (*FeedWithDeviation) String 

func (m *FeedWithDeviation) String() string

func (*FeedWithDeviation) Unmarshal 

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

func (*FeedWithDeviation) XXX_DiscardUnknown 

func (m *FeedWithDeviation) XXX_DiscardUnknown()

func (*FeedWithDeviation) XXX_Marshal 

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

func (*FeedWithDeviation) XXX_Merge 

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

func (*FeedWithDeviation) XXX_Size 

func (m *FeedWithDeviation) XXX_Size() int

func (*FeedWithDeviation) XXX_Unmarshal 

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

type FeedsSignatureOrder 

type FeedsSignatureOrder struct {
	// signal_ids is the list of signal ids that require signatures.
	SignalIDs []string `protobuf:"bytes,1,rep,name=signal_ids,json=signalIds,proto3" json:"signal_ids,omitempty"`
	// encoder is the mode of encoding feeds signature order.
	Encoder Encoder `protobuf:"varint,2,opt,name=encoder,proto3,enum=band.feeds.v1beta1.Encoder" json:"encoder,omitempty"`
}

FeedsSignatureOrder defines a general signature order for feed data.

func NewFeedSignatureOrder 

func NewFeedSignatureOrder(signalIDs []string, encoder Encoder) *FeedsSignatureOrder

NewFeedSignatureOrder returns a new FeedSignatureOrder object

func (*FeedsSignatureOrder) Descriptor 

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

func (*FeedsSignatureOrder) IsInternal 

func (f *FeedsSignatureOrder) IsInternal() bool

IsInternal returns false for FeedsSignatureOrder (allow user to submit this content type).

func (*FeedsSignatureOrder) Marshal 

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

func (*FeedsSignatureOrder) MarshalTo 

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

func (*FeedsSignatureOrder) MarshalToSizedBuffer 

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

func (*FeedsSignatureOrder) OrderRoute 

func (f *FeedsSignatureOrder) OrderRoute() string

OrderRoute returns the order router key

func (*FeedsSignatureOrder) OrderType 

func (f *FeedsSignatureOrder) OrderType() string

OrderType returns type of signature order that should be "Feeds"

func (*FeedsSignatureOrder) ProtoMessage 

func (*FeedsSignatureOrder) ProtoMessage()

func (*FeedsSignatureOrder) Reset 

func (m *FeedsSignatureOrder) Reset()

func (*FeedsSignatureOrder) Size 

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

func (*FeedsSignatureOrder) String 

func (m *FeedsSignatureOrder) String() string

func (*FeedsSignatureOrder) Unmarshal 

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

func (*FeedsSignatureOrder) ValidateBasic 

func (f *FeedsSignatureOrder) ValidateBasic() error

ValidateBasic validates the request's title and description of the request signature

func (*FeedsSignatureOrder) XXX_DiscardUnknown 

func (m *FeedsSignatureOrder) XXX_DiscardUnknown()

func (*FeedsSignatureOrder) XXX_Marshal 

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

func (*FeedsSignatureOrder) XXX_Merge 

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

func (*FeedsSignatureOrder) XXX_Size 

func (m *FeedsSignatureOrder) XXX_Size() int

func (*FeedsSignatureOrder) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	// params is all parameters of the module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	// votes is a list of voter signals.
	Votes []Vote `protobuf:"bytes,2,rep,name=votes,proto3" json:"votes"`
	// reference_source_config is the information about reference price config.
	ReferenceSourceConfig ReferenceSourceConfig `protobuf:"bytes,3,opt,name=reference_source_config,json=referenceSourceConfig,proto3" json:"reference_source_config"`
}

GenesisState is a structure that defines the feeds module's genesis state.

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

DefaultGenesisState returns the default genesis state

func NewGenesisState 

func NewGenesisState(
	params Params,
	votes []Vote,
	rs ReferenceSourceConfig,
) *GenesisState

NewGenesisState creates new GenesisState

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetReferenceSourceConfig 

func (m *GenesisState) GetReferenceSourceConfig() ReferenceSourceConfig

func (*GenesisState) GetVotes 

func (m *GenesisState) GetVotes() []Vote

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

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 MsgClient 

type MsgClient interface {
	// Vote is an RPC method to vote signal ids and their powers.
	Vote(ctx context.Context, in *MsgVote, opts ...grpc.CallOption) (*MsgVoteResponse, error)
	// SubmitSignalPrices is an RPC method to submit signal prices.
	SubmitSignalPrices(ctx context.Context, in *MsgSubmitSignalPrices, opts ...grpc.CallOption) (*MsgSubmitSignalPricesResponse, error)
	// UpdateReferenceSourceConfig is an RPC method to update reference price source configuration.
	UpdateReferenceSourceConfig(ctx context.Context, in *MsgUpdateReferenceSourceConfig, opts ...grpc.CallOption) (*MsgUpdateReferenceSourceConfigResponse, error)
	// UpdateParams is an RPC method to update parameters.
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, 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 MsgServer 

type MsgServer interface {
	// Vote is an RPC method to vote signal ids and their powers.
	Vote(context.Context, *MsgVote) (*MsgVoteResponse, error)
	// SubmitSignalPrices is an RPC method to submit signal prices.
	SubmitSignalPrices(context.Context, *MsgSubmitSignalPrices) (*MsgSubmitSignalPricesResponse, error)
	// UpdateReferenceSourceConfig is an RPC method to update reference price source configuration.
	UpdateReferenceSourceConfig(context.Context, *MsgUpdateReferenceSourceConfig) (*MsgUpdateReferenceSourceConfigResponse, error)
	// UpdateParams is an RPC method to update parameters.
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSubmitSignalPrices 

type MsgSubmitSignalPrices struct {
	// validator is the address of the validator that is performing the operation.
	Validator string `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator,omitempty"`
	// timestamp is the timestamp used as reference for the data.
	Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// signal_prices is a list of signal prices to submit.
	SignalPrices []SignalPrice `protobuf:"bytes,3,rep,name=signal_prices,json=signalPrices,proto3" json:"signal_prices"`
}

MsgSubmitSignalPrices is the transaction message to submit multiple signal prices.

func NewMsgSubmitSignalPrices 

func NewMsgSubmitSignalPrices(
	validator string,
	timestamp int64,
	signalPrices []SignalPrice,
) *MsgSubmitSignalPrices

NewMsgSubmitSignalPrices creates a new MsgSubmitSignalPrices instance.

func (*MsgSubmitSignalPrices) Descriptor 

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

func (*MsgSubmitSignalPrices) GetSignalPrices 

func (m *MsgSubmitSignalPrices) GetSignalPrices() []SignalPrice

func (*MsgSubmitSignalPrices) GetTimestamp 

func (m *MsgSubmitSignalPrices) GetTimestamp() int64

func (*MsgSubmitSignalPrices) GetValidator 

func (m *MsgSubmitSignalPrices) GetValidator() string

func (*MsgSubmitSignalPrices) Marshal 

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

func (*MsgSubmitSignalPrices) MarshalTo 

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

func (*MsgSubmitSignalPrices) MarshalToSizedBuffer 

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

func (*MsgSubmitSignalPrices) ProtoMessage 

func (*MsgSubmitSignalPrices) ProtoMessage()

func (*MsgSubmitSignalPrices) Reset 

func (m *MsgSubmitSignalPrices) Reset()

func (*MsgSubmitSignalPrices) Size 

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

func (*MsgSubmitSignalPrices) String 

func (m *MsgSubmitSignalPrices) String() string

func (*MsgSubmitSignalPrices) Unmarshal 

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

func (*MsgSubmitSignalPrices) ValidateBasic 

func (m *MsgSubmitSignalPrices) ValidateBasic() error

ValidateBasic does a check on the provided data.

func (*MsgSubmitSignalPrices) XXX_DiscardUnknown 

func (m *MsgSubmitSignalPrices) XXX_DiscardUnknown()

func (*MsgSubmitSignalPrices) XXX_Marshal 

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

func (*MsgSubmitSignalPrices) XXX_Merge 

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

func (*MsgSubmitSignalPrices) XXX_Size 

func (m *MsgSubmitSignalPrices) XXX_Size() int

func (*MsgSubmitSignalPrices) XXX_Unmarshal 

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

type MsgSubmitSignalPricesResponse 

type MsgSubmitSignalPricesResponse struct {
}

MsgSubmitSignalPricesResponse is the response type for the Msg/SubmitSignalPrices RPC method.

func (*MsgSubmitSignalPricesResponse) Descriptor 

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

func (*MsgSubmitSignalPricesResponse) Marshal 

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

func (*MsgSubmitSignalPricesResponse) MarshalTo 

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

func (*MsgSubmitSignalPricesResponse) MarshalToSizedBuffer 

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

func (*MsgSubmitSignalPricesResponse) ProtoMessage 

func (*MsgSubmitSignalPricesResponse) ProtoMessage()

func (*MsgSubmitSignalPricesResponse) Reset 

func (m *MsgSubmitSignalPricesResponse) Reset()

func (*MsgSubmitSignalPricesResponse) Size 

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

func (*MsgSubmitSignalPricesResponse) String 

func (m *MsgSubmitSignalPricesResponse) String() string

func (*MsgSubmitSignalPricesResponse) Unmarshal 

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

func (*MsgSubmitSignalPricesResponse) XXX_DiscardUnknown 

func (m *MsgSubmitSignalPricesResponse) XXX_DiscardUnknown()

func (*MsgSubmitSignalPricesResponse) XXX_Marshal 

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

func (*MsgSubmitSignalPricesResponse) XXX_Merge 

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

func (*MsgSubmitSignalPricesResponse) XXX_Size 

func (m *MsgSubmitSignalPricesResponse) XXX_Size() int

func (*MsgSubmitSignalPricesResponse) XXX_Unmarshal 

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

type MsgUpdateParams 

type MsgUpdateParams struct {
	// authority is the address of the governance account.
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// params is the x/feeds parameters to update.
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

MsgUpdateParams is the transaction message to update parameters.

func NewMsgUpdateParams 

func NewMsgUpdateParams(
	authority string,
	params Params,
) *MsgUpdateParams

NewMsgUpdateParams creates a new MsgUpdateParams instance.

func (*MsgUpdateParams) Descriptor 

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

func (*MsgUpdateParams) GetAuthority 

func (m *MsgUpdateParams) GetAuthority() string

func (*MsgUpdateParams) GetParams 

func (m *MsgUpdateParams) GetParams() Params

func (*MsgUpdateParams) Marshal 

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

func (*MsgUpdateParams) MarshalTo 

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

func (*MsgUpdateParams) MarshalToSizedBuffer 

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

func (*MsgUpdateParams) ProtoMessage 

func (*MsgUpdateParams) ProtoMessage()

func (*MsgUpdateParams) Reset 

func (m *MsgUpdateParams) Reset()

func (*MsgUpdateParams) Size 

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

func (*MsgUpdateParams) String 

func (m *MsgUpdateParams) String() string

func (*MsgUpdateParams) Unmarshal 

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

func (*MsgUpdateParams) ValidateBasic 

func (m *MsgUpdateParams) ValidateBasic() error

ValidateBasic does a check on the provided data.

func (*MsgUpdateParams) XXX_DiscardUnknown 

func (m *MsgUpdateParams) XXX_DiscardUnknown()

func (*MsgUpdateParams) XXX_Marshal 

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

func (*MsgUpdateParams) XXX_Merge 

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

func (*MsgUpdateParams) XXX_Size 

func (m *MsgUpdateParams) XXX_Size() int

func (*MsgUpdateParams) XXX_Unmarshal 

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

type MsgUpdateParamsResponse 

type MsgUpdateParamsResponse struct {
}

MsgUpdateParamsResponse is the response type for the Msg/UpdateParams RPC method.

func (*MsgUpdateParamsResponse) Descriptor 

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

func (*MsgUpdateParamsResponse) Marshal 

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

func (*MsgUpdateParamsResponse) MarshalTo 

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

func (*MsgUpdateParamsResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateParamsResponse) ProtoMessage 

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) Reset 

func (m *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) Size 

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

func (*MsgUpdateParamsResponse) String 

func (m *MsgUpdateParamsResponse) String() string

func (*MsgUpdateParamsResponse) Unmarshal 

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

func (*MsgUpdateParamsResponse) XXX_DiscardUnknown 

func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamsResponse) XXX_Marshal 

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

func (*MsgUpdateParamsResponse) XXX_Merge 

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

func (*MsgUpdateParamsResponse) XXX_Size 

func (m *MsgUpdateParamsResponse) XXX_Size() int

func (*MsgUpdateParamsResponse) XXX_Unmarshal 

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

type MsgUpdateReferenceSourceConfig 

type MsgUpdateReferenceSourceConfig struct {
	// admin is the address of the admin that is performing the operation.
	Admin string `protobuf:"bytes,1,opt,name=admin,proto3" json:"admin,omitempty"`
	// reference_source_config is the information of reference price source.
	ReferenceSourceConfig ReferenceSourceConfig `protobuf:"bytes,2,opt,name=reference_source_config,json=referenceSourceConfig,proto3" json:"reference_source_config"`
}

MsgUpdateReferenceSourceConfig is the transaction message to update reference price source's configuration.

func NewMsgUpdateReferenceSourceConfig 

func NewMsgUpdateReferenceSourceConfig(
	admin string,
	referenceSourceConfig ReferenceSourceConfig,
) *MsgUpdateReferenceSourceConfig

NewMsgUpdateReferenceSourceConfig creates a new MsgUpdateReferenceSourceConfig instance.

func (*MsgUpdateReferenceSourceConfig) Descriptor 

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

func (*MsgUpdateReferenceSourceConfig) GetAdmin 

func (m *MsgUpdateReferenceSourceConfig) GetAdmin() string

func (*MsgUpdateReferenceSourceConfig) GetReferenceSourceConfig 

func (m *MsgUpdateReferenceSourceConfig) GetReferenceSourceConfig() ReferenceSourceConfig

func (*MsgUpdateReferenceSourceConfig) Marshal 

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

func (*MsgUpdateReferenceSourceConfig) MarshalTo 

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

func (*MsgUpdateReferenceSourceConfig) MarshalToSizedBuffer 

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

func (*MsgUpdateReferenceSourceConfig) ProtoMessage 

func (*MsgUpdateReferenceSourceConfig) ProtoMessage()

func (*MsgUpdateReferenceSourceConfig) Reset 

func (m *MsgUpdateReferenceSourceConfig) Reset()

func (*MsgUpdateReferenceSourceConfig) Size 

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

func (*MsgUpdateReferenceSourceConfig) String 

func (m *MsgUpdateReferenceSourceConfig) String() string

func (*MsgUpdateReferenceSourceConfig) Unmarshal 

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

func (*MsgUpdateReferenceSourceConfig) ValidateBasic 

func (m *MsgUpdateReferenceSourceConfig) ValidateBasic() error

ValidateBasic does a check on the provided data.

func (*MsgUpdateReferenceSourceConfig) XXX_DiscardUnknown 

func (m *MsgUpdateReferenceSourceConfig) XXX_DiscardUnknown()

func (*MsgUpdateReferenceSourceConfig) XXX_Marshal 

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

func (*MsgUpdateReferenceSourceConfig) XXX_Merge 

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

func (*MsgUpdateReferenceSourceConfig) XXX_Size 

func (m *MsgUpdateReferenceSourceConfig) XXX_Size() int

func (*MsgUpdateReferenceSourceConfig) XXX_Unmarshal 

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

type MsgUpdateReferenceSourceConfigResponse 

type MsgUpdateReferenceSourceConfigResponse struct {
}

MsgUpdateReferenceSourceConfigResponse is the response type for the Msg/UpdateReferenceSourceConfig RPC method.

func (*MsgUpdateReferenceSourceConfigResponse) Descriptor 

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

func (*MsgUpdateReferenceSourceConfigResponse) Marshal 

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

func (*MsgUpdateReferenceSourceConfigResponse) MarshalTo 

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

func (*MsgUpdateReferenceSourceConfigResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateReferenceSourceConfigResponse) ProtoMessage 

func (*MsgUpdateReferenceSourceConfigResponse) ProtoMessage()

func (*MsgUpdateReferenceSourceConfigResponse) Reset 

func (m *MsgUpdateReferenceSourceConfigResponse) Reset()

func (*MsgUpdateReferenceSourceConfigResponse) Size 

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

func (*MsgUpdateReferenceSourceConfigResponse) String 

func (m *MsgUpdateReferenceSourceConfigResponse) String() string

func (*MsgUpdateReferenceSourceConfigResponse) Unmarshal 

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

func (*MsgUpdateReferenceSourceConfigResponse) XXX_DiscardUnknown 

func (m *MsgUpdateReferenceSourceConfigResponse) XXX_DiscardUnknown()

func (*MsgUpdateReferenceSourceConfigResponse) XXX_Marshal 

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

func (*MsgUpdateReferenceSourceConfigResponse) XXX_Merge 

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

func (*MsgUpdateReferenceSourceConfigResponse) XXX_Size 

func (m *MsgUpdateReferenceSourceConfigResponse) XXX_Size() int

func (*MsgUpdateReferenceSourceConfigResponse) XXX_Unmarshal 

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

type MsgVote 

type MsgVote struct {
	// voter is the address of the voter that wants to vote signals.
	Voter string `protobuf:"bytes,1,opt,name=voter,proto3" json:"voter,omitempty"`
	// signals is a list of submitted signals.
	Signals []Signal `protobuf:"bytes,2,rep,name=signals,proto3" json:"signals"`
}

MsgVote is the transaction message to vote signals.

func NewMsgVote 

func NewMsgVote(
	voter string,
	signals []Signal,
) *MsgVote

NewMsgVote creates a new MsgVote instance.

func (*MsgVote) Descriptor 

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

func (*MsgVote) GetSignals 

func (m *MsgVote) GetSignals() []Signal

func (*MsgVote) GetVoter 

func (m *MsgVote) GetVoter() string

func (*MsgVote) Marshal 

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

func (*MsgVote) MarshalTo 

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

func (*MsgVote) MarshalToSizedBuffer 

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

func (*MsgVote) ProtoMessage 

func (*MsgVote) ProtoMessage()

func (*MsgVote) Reset 

func (m *MsgVote) Reset()

func (*MsgVote) Size 

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

func (*MsgVote) String 

func (m *MsgVote) String() string

func (*MsgVote) Unmarshal 

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

func (*MsgVote) ValidateBasic 

func (m *MsgVote) ValidateBasic() error

ValidateBasic does a check on the provided data.

func (*MsgVote) XXX_DiscardUnknown 

func (m *MsgVote) XXX_DiscardUnknown()

func (*MsgVote) XXX_Marshal 

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

func (*MsgVote) XXX_Merge 

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

func (*MsgVote) XXX_Size 

func (m *MsgVote) XXX_Size() int

func (*MsgVote) XXX_Unmarshal 

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

type MsgVoteResponse 

type MsgVoteResponse struct {
}

MsgVoteResponse is the response type for the Msg/Vote RPC method.

func (*MsgVoteResponse) Descriptor 

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

func (*MsgVoteResponse) Marshal 

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

func (*MsgVoteResponse) MarshalTo 

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

func (*MsgVoteResponse) MarshalToSizedBuffer 

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

func (*MsgVoteResponse) ProtoMessage 

func (*MsgVoteResponse) ProtoMessage()

func (*MsgVoteResponse) Reset 

func (m *MsgVoteResponse) Reset()

func (*MsgVoteResponse) Size 

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

func (*MsgVoteResponse) String 

func (m *MsgVoteResponse) String() string

func (*MsgVoteResponse) Unmarshal 

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

func (*MsgVoteResponse) XXX_DiscardUnknown 

func (m *MsgVoteResponse) XXX_DiscardUnknown()

func (*MsgVoteResponse) XXX_Marshal 

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

func (*MsgVoteResponse) XXX_Merge 

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

func (*MsgVoteResponse) XXX_Size 

func (m *MsgVoteResponse) XXX_Size() int

func (*MsgVoteResponse) XXX_Unmarshal 

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

type OracleKeeper 

type OracleKeeper interface {
	MissReport(ctx sdk.Context, val sdk.ValAddress, requestTime time.Time)
	GetValidatorStatus(ctx sdk.Context, val sdk.ValAddress) oracletypes.ValidatorStatus
}

OracleKeeper defines the expected oracle keeper

type Params 

type Params struct {
	// admin is the address of the admin that is allowed to perform operations on modules.
	Admin string `protobuf:"bytes,1,opt,name=admin,proto3" json:"admin,omitempty"`
	// allowable_block_time_discrepancy is the allowed discrepancy (in seconds) between validator price timestamp and
	// block_time.
	AllowableBlockTimeDiscrepancy int64 `` /* 153-byte string literal not displayed */
	// grace_period is the time (in seconds) given for validators to adapt to changing in feed's interval.
	GracePeriod int64 `protobuf:"varint,3,opt,name=grace_period,json=gracePeriod,proto3" json:"grace_period,omitempty"`
	// min_interval is the minimum limit of every feeds' interval (in seconds).
	// If the calculated interval is lower than this, it will be capped at this value.
	MinInterval int64 `protobuf:"varint,4,opt,name=min_interval,json=minInterval,proto3" json:"min_interval,omitempty"`
	// max_interval is the maximum limit of every feeds' interval (in seconds).
	// If the calculated interval of a feed is higher than this, it will not be capped at this value.
	MaxInterval int64 `protobuf:"varint,5,opt,name=max_interval,json=maxInterval,proto3" json:"max_interval,omitempty"`
	// power_step_threshold is the amount of minimum power required to put feed in the current feeds list.
	PowerStepThreshold int64 `protobuf:"varint,6,opt,name=power_step_threshold,json=powerStepThreshold,proto3" json:"power_step_threshold,omitempty"`
	// max_current_feeds is the maximum number of feeds supported at a time.
	MaxCurrentFeeds uint64 `protobuf:"varint,7,opt,name=max_current_feeds,json=maxCurrentFeeds,proto3" json:"max_current_feeds,omitempty"`
	// cooldown_time represents the duration (in seconds) during which validators are prohibited from sending new prices.
	CooldownTime int64 `protobuf:"varint,8,opt,name=cooldown_time,json=cooldownTime,proto3" json:"cooldown_time,omitempty"`
	// min_deviation_basis_point is the minimum limit of every feeds' deviation (in basis point).
	MinDeviationBasisPoint int64 `` /* 132-byte string literal not displayed */
	// max_deviation_basis_point is the maximum limit of every feeds' deviation (in basis point).
	MaxDeviationBasisPoint int64 `` /* 133-byte string literal not displayed */
	// current_feeds_update_interval is the number of blocks after which the current feeds will be re-calculated.
	CurrentFeedsUpdateInterval int64 `` /* 145-byte string literal not displayed */
	// price_quorum is the minimum percentage of power that needs to be reached for a price to be processed.
	PriceQuorum string `protobuf:"bytes,12,opt,name=price_quorum,json=priceQuorum,proto3" json:"price_quorum,omitempty"`
	// MaxSignalIDsPerSigning is the maximum number of signals allowed in a single tss signing request.
	MaxSignalIDsPerSigning uint64 `` /* 135-byte string literal not displayed */
}

Params is the data structure that keeps the parameters of the feeds module.

func DefaultParams 

func DefaultParams() Params

DefaultParams returns a default set of parameters

func NewParams 

func NewParams(
	admin string,
	allowableBlockTimeDiscrepancy int64,
	gracePeriod int64,
	minInterval int64,
	maxInterval int64,
	powerStepThreshold int64,
	maxCurrentFeeds uint64,
	cooldownTime int64,
	minDeviationBasisPoint int64,
	maxDeviationBasisPoint int64,
	currentFeedsUpdateInterval int64,
	priceQuorum string,
	maxSignalIDsPerSigning uint64,
) 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) GetAdmin 

func (m *Params) GetAdmin() string

func (*Params) GetAllowableBlockTimeDiscrepancy 

func (m *Params) GetAllowableBlockTimeDiscrepancy() int64

func (*Params) GetCooldownTime 

func (m *Params) GetCooldownTime() int64

func (*Params) GetCurrentFeedsUpdateInterval 

func (m *Params) GetCurrentFeedsUpdateInterval() int64

func (*Params) GetGracePeriod 

func (m *Params) GetGracePeriod() int64

func (*Params) GetMaxCurrentFeeds 

func (m *Params) GetMaxCurrentFeeds() uint64

func (*Params) GetMaxDeviationBasisPoint 

func (m *Params) GetMaxDeviationBasisPoint() int64

func (*Params) GetMaxInterval 

func (m *Params) GetMaxInterval() int64

func (*Params) GetMaxSignalIDsPerSigning 

func (m *Params) GetMaxSignalIDsPerSigning() uint64

func (*Params) GetMinDeviationBasisPoint 

func (m *Params) GetMinDeviationBasisPoint() int64

func (*Params) GetMinInterval 

func (m *Params) GetMinInterval() int64

func (*Params) GetPowerStepThreshold 

func (m *Params) GetPowerStepThreshold() int64

func (*Params) GetPriceQuorum 

func (m *Params) GetPriceQuorum() string

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

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (*Params) String 

func (m *Params) String() string

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 Price 

type Price struct {
	// status is the status of a the price.
	Status PriceStatus `protobuf:"varint,1,opt,name=status,proto3,enum=band.feeds.v1beta1.PriceStatus" json:"status,omitempty"`
	// signal_id is the signal id of the price.
	SignalID string `protobuf:"bytes,2,opt,name=signal_id,json=signalId,proto3" json:"signal_id,omitempty"`
	// price is the price of the signal id.
	Price uint64 `protobuf:"varint,3,opt,name=price,proto3" json:"price,omitempty"`
	// timestamp is the timestamp at which the price was aggregated.
	Timestamp int64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

Price is a structure that defines the price of a signal id.

func NewPrice 

func NewPrice(
	status PriceStatus,
	signalID string,
	price uint64,
	timestamp int64,
) Price

NewPrice creates a new price instance

func (*Price) Descriptor 

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

func (*Price) Equal 

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

func (*Price) GetPrice 

func (m *Price) GetPrice() uint64

func (*Price) GetSignalID 

func (m *Price) GetSignalID() string

func (*Price) GetStatus 

func (m *Price) GetStatus() PriceStatus

func (*Price) GetTimestamp 

func (m *Price) GetTimestamp() int64

func (*Price) Marshal 

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

func (*Price) MarshalTo 

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

func (*Price) MarshalToSizedBuffer 

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

func (*Price) ProtoMessage 

func (*Price) ProtoMessage()

func (*Price) Reset 

func (m *Price) Reset()

func (*Price) Size 

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

func (*Price) String 

func (m *Price) String() string

func (Price) ToTick 

func (p Price) ToTick() (Price, error)

ToTick converts the price to tick

func (*Price) Unmarshal 

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

func (*Price) XXX_DiscardUnknown 

func (m *Price) XXX_DiscardUnknown()

func (*Price) XXX_Marshal 

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

func (*Price) XXX_Merge 

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

func (*Price) XXX_Size 

func (m *Price) XXX_Size() int

func (*Price) XXX_Unmarshal 

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

type PriceStatus 

type PriceStatus int32

PriceStatus is a structure that defines the price status of a price. 

const (
	// PRICE_STATUS_UNSPECIFIED is an unspecified price status.
	PRICE_STATUS_UNSPECIFIED PriceStatus = 0
	// PRICE_STATUS_UNKNOWN_SIGNAL_ID is an unknown signal id price status.
	PRICE_STATUS_UNKNOWN_SIGNAL_ID PriceStatus = 1
	// PRICE_STATUS_NOT_READY is a not ready price status.
	PRICE_STATUS_NOT_READY PriceStatus = 2
	// PRICE_STATUS_AVAILABLE is an available price status.
	PRICE_STATUS_AVAILABLE PriceStatus = 3
	// PRICE_STATUS_NOT_IN_CURRENT_FEEDS is a not in current feed price status.
	PRICE_STATUS_NOT_IN_CURRENT_FEEDS PriceStatus = 4
)

func (PriceStatus) EnumDescriptor 

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

func (PriceStatus) String 

func (x PriceStatus) String() string

type QueryAllPricesRequest 

type QueryAllPricesRequest struct {
	// pagination is the pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryAllPricesRequest is the request type for the Query/AllPrices RPC method.

func (*QueryAllPricesRequest) Descriptor 

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

func (*QueryAllPricesRequest) GetPagination 

func (m *QueryAllPricesRequest) GetPagination() *query.PageRequest

func (*QueryAllPricesRequest) Marshal 

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

func (*QueryAllPricesRequest) MarshalTo 

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

func (*QueryAllPricesRequest) MarshalToSizedBuffer 

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

func (*QueryAllPricesRequest) ProtoMessage 

func (*QueryAllPricesRequest) ProtoMessage()

func (*QueryAllPricesRequest) Reset 

func (m *QueryAllPricesRequest) Reset()

func (*QueryAllPricesRequest) Size 

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

func (*QueryAllPricesRequest) String 

func (m *QueryAllPricesRequest) String() string

func (*QueryAllPricesRequest) Unmarshal 

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

func (*QueryAllPricesRequest) XXX_DiscardUnknown 

func (m *QueryAllPricesRequest) XXX_DiscardUnknown()

func (*QueryAllPricesRequest) XXX_Marshal 

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

func (*QueryAllPricesRequest) XXX_Merge 

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

func (*QueryAllPricesRequest) XXX_Size 

func (m *QueryAllPricesRequest) XXX_Size() int

func (*QueryAllPricesRequest) XXX_Unmarshal 

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

type QueryAllPricesResponse 

type QueryAllPricesResponse struct {
	// prices is a list of prices.
	Prices []Price `protobuf:"bytes,1,rep,name=prices,proto3" json:"prices"`
	// pagination is the pagination information in the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryAllPricesResponse is the response type for the Query/AllPrices RPC method.

func (*QueryAllPricesResponse) Descriptor 

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

func (*QueryAllPricesResponse) GetPagination 

func (m *QueryAllPricesResponse) GetPagination() *query.PageResponse

func (*QueryAllPricesResponse) GetPrices 

func (m *QueryAllPricesResponse) GetPrices() []Price

func (*QueryAllPricesResponse) Marshal 

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

func (*QueryAllPricesResponse) MarshalTo 

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

func (*QueryAllPricesResponse) MarshalToSizedBuffer 

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

func (*QueryAllPricesResponse) ProtoMessage 

func (*QueryAllPricesResponse) ProtoMessage()

func (*QueryAllPricesResponse) Reset 

func (m *QueryAllPricesResponse) Reset()

func (*QueryAllPricesResponse) Size 

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

func (*QueryAllPricesResponse) String 

func (m *QueryAllPricesResponse) String() string

func (*QueryAllPricesResponse) Unmarshal 

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

func (*QueryAllPricesResponse) XXX_DiscardUnknown 

func (m *QueryAllPricesResponse) XXX_DiscardUnknown()

func (*QueryAllPricesResponse) XXX_Marshal 

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

func (*QueryAllPricesResponse) XXX_Merge 

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

func (*QueryAllPricesResponse) XXX_Size 

func (m *QueryAllPricesResponse) XXX_Size() int

func (*QueryAllPricesResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// CurrentFeeds is an RPC method that returns a list of current supported feeds.
	CurrentFeeds(ctx context.Context, in *QueryCurrentFeedsRequest, opts ...grpc.CallOption) (*QueryCurrentFeedsResponse, error)
	// IsFeeder is an RPC method that returns whether an account is a feeder for a specified validator.
	IsFeeder(ctx context.Context, in *QueryIsFeederRequest, opts ...grpc.CallOption) (*QueryIsFeederResponse, error)
	// Params is an RPC method that returns all parameters of the module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// Price is an RPC method that returns price by signal id.
	Price(ctx context.Context, in *QueryPriceRequest, opts ...grpc.CallOption) (*QueryPriceResponse, error)
	// Prices is an RPC method that prices by signal ids.
	Prices(ctx context.Context, in *QueryPricesRequest, opts ...grpc.CallOption) (*QueryPricesResponse, error)
	// AllPrices is an RPC method that returns all prices.
	AllPrices(ctx context.Context, in *QueryAllPricesRequest, opts ...grpc.CallOption) (*QueryAllPricesResponse, error)
	// ReferenceSourceConfig is an RPC method that returns information on the reference price source.
	ReferenceSourceConfig(ctx context.Context, in *QueryReferenceSourceConfigRequest, opts ...grpc.CallOption) (*QueryReferenceSourceConfigResponse, error)
	// SignalTotalPowers is an RPC method that returns all signal-total-powers or specified signal-total-power by signal
	// id.
	SignalTotalPowers(ctx context.Context, in *QuerySignalTotalPowersRequest, opts ...grpc.CallOption) (*QuerySignalTotalPowersResponse, error)
	// ValidValidator is an RPC method that returns a flag to show if the validator is required to send prices.
	ValidValidator(ctx context.Context, in *QueryValidValidatorRequest, opts ...grpc.CallOption) (*QueryValidValidatorResponse, error)
	// ValidatorPrices is an RPC method that returns prices of a validator.
	ValidatorPrices(ctx context.Context, in *QueryValidatorPricesRequest, opts ...grpc.CallOption) (*QueryValidatorPricesResponse, error)
	// Vote is an RPC method that returns signals of a voter.
	Vote(ctx context.Context, in *QueryVoteRequest, opts ...grpc.CallOption) (*QueryVoteResponse, 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 QueryCurrentFeedsRequest 

type QueryCurrentFeedsRequest struct {
}

QueryCurrentFeedsRequest is the request type for the Query/CurrentFeeds RPC method.

func (*QueryCurrentFeedsRequest) Descriptor 

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

func (*QueryCurrentFeedsRequest) Marshal 

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

func (*QueryCurrentFeedsRequest) MarshalTo 

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

func (*QueryCurrentFeedsRequest) MarshalToSizedBuffer 

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

func (*QueryCurrentFeedsRequest) ProtoMessage 

func (*QueryCurrentFeedsRequest) ProtoMessage()

func (*QueryCurrentFeedsRequest) Reset 

func (m *QueryCurrentFeedsRequest) Reset()

func (*QueryCurrentFeedsRequest) Size 

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

func (*QueryCurrentFeedsRequest) String 

func (m *QueryCurrentFeedsRequest) String() string

func (*QueryCurrentFeedsRequest) Unmarshal 

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

func (*QueryCurrentFeedsRequest) XXX_DiscardUnknown 

func (m *QueryCurrentFeedsRequest) XXX_DiscardUnknown()

func (*QueryCurrentFeedsRequest) XXX_Marshal 

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

func (*QueryCurrentFeedsRequest) XXX_Merge 

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

func (*QueryCurrentFeedsRequest) XXX_Size 

func (m *QueryCurrentFeedsRequest) XXX_Size() int

func (*QueryCurrentFeedsRequest) XXX_Unmarshal 

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

type QueryCurrentFeedsResponse 

type QueryCurrentFeedsResponse struct {
	// current_feeds is a list of currently supported feed-with-deviations, and its last update time and block.
	CurrentFeeds CurrentFeedWithDeviations `protobuf:"bytes,1,opt,name=current_feeds,json=currentFeeds,proto3" json:"current_feeds"`
}

QueryCurrentFeedsResponse is the response type for the Query/CurrentFeeds RPC method.

func (*QueryCurrentFeedsResponse) Descriptor 

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

func (*QueryCurrentFeedsResponse) GetCurrentFeeds 

func (m *QueryCurrentFeedsResponse) GetCurrentFeeds() CurrentFeedWithDeviations

func (*QueryCurrentFeedsResponse) Marshal 

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

func (*QueryCurrentFeedsResponse) MarshalTo 

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

func (*QueryCurrentFeedsResponse) MarshalToSizedBuffer 

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

func (*QueryCurrentFeedsResponse) ProtoMessage 

func (*QueryCurrentFeedsResponse) ProtoMessage()

func (*QueryCurrentFeedsResponse) Reset 

func (m *QueryCurrentFeedsResponse) Reset()

func (*QueryCurrentFeedsResponse) Size 

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

func (*QueryCurrentFeedsResponse) String 

func (m *QueryCurrentFeedsResponse) String() string

func (*QueryCurrentFeedsResponse) Unmarshal 

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

func (*QueryCurrentFeedsResponse) XXX_DiscardUnknown 

func (m *QueryCurrentFeedsResponse) XXX_DiscardUnknown()

func (*QueryCurrentFeedsResponse) XXX_Marshal 

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

func (*QueryCurrentFeedsResponse) XXX_Merge 

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

func (*QueryCurrentFeedsResponse) XXX_Size 

func (m *QueryCurrentFeedsResponse) XXX_Size() int

func (*QueryCurrentFeedsResponse) XXX_Unmarshal 

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

type QueryIsFeederRequest 

type QueryIsFeederRequest struct {
	// validator is a validator address.
	Validator string `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator,omitempty"`
	// feeder is a candidate account.
	Feeder string `protobuf:"bytes,2,opt,name=feeder,proto3" json:"feeder,omitempty"`
}

QueryIsFeederRequest is the request type for the Query/IsFeeder RPC method.

func (*QueryIsFeederRequest) Descriptor 

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

func (*QueryIsFeederRequest) GetFeeder 

func (m *QueryIsFeederRequest) GetFeeder() string

func (*QueryIsFeederRequest) GetValidator 

func (m *QueryIsFeederRequest) GetValidator() string

func (*QueryIsFeederRequest) Marshal 

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

func (*QueryIsFeederRequest) MarshalTo 

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

func (*QueryIsFeederRequest) MarshalToSizedBuffer 

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

func (*QueryIsFeederRequest) ProtoMessage 

func (*QueryIsFeederRequest) ProtoMessage()

func (*QueryIsFeederRequest) Reset 

func (m *QueryIsFeederRequest) Reset()

func (*QueryIsFeederRequest) Size 

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

func (*QueryIsFeederRequest) String 

func (m *QueryIsFeederRequest) String() string

func (*QueryIsFeederRequest) Unmarshal 

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

func (*QueryIsFeederRequest) XXX_DiscardUnknown 

func (m *QueryIsFeederRequest) XXX_DiscardUnknown()

func (*QueryIsFeederRequest) XXX_Marshal 

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

func (*QueryIsFeederRequest) XXX_Merge 

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

func (*QueryIsFeederRequest) XXX_Size 

func (m *QueryIsFeederRequest) XXX_Size() int

func (*QueryIsFeederRequest) XXX_Unmarshal 

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

type QueryIsFeederResponse 

type QueryIsFeederResponse struct {
	// is_feeder is true if this account has been granted by validator.
	IsFeeder bool `protobuf:"varint,1,opt,name=is_feeder,json=isFeeder,proto3" json:"is_feeder,omitempty"`
}

QueryIsFeederResponse is the response type for the Query/IsFeeder RPC method.

func (*QueryIsFeederResponse) Descriptor 

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

func (*QueryIsFeederResponse) GetIsFeeder 

func (m *QueryIsFeederResponse) GetIsFeeder() bool

func (*QueryIsFeederResponse) Marshal 

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

func (*QueryIsFeederResponse) MarshalTo 

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

func (*QueryIsFeederResponse) MarshalToSizedBuffer 

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

func (*QueryIsFeederResponse) ProtoMessage 

func (*QueryIsFeederResponse) ProtoMessage()

func (*QueryIsFeederResponse) Reset 

func (m *QueryIsFeederResponse) Reset()

func (*QueryIsFeederResponse) Size 

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

func (*QueryIsFeederResponse) String 

func (m *QueryIsFeederResponse) String() string

func (*QueryIsFeederResponse) Unmarshal 

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

func (*QueryIsFeederResponse) XXX_DiscardUnknown 

func (m *QueryIsFeederResponse) XXX_DiscardUnknown()

func (*QueryIsFeederResponse) XXX_Marshal 

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

func (*QueryIsFeederResponse) XXX_Merge 

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

func (*QueryIsFeederResponse) XXX_Size 

func (m *QueryIsFeederResponse) XXX_Size() int

func (*QueryIsFeederResponse) XXX_Unmarshal 

func (m *QueryIsFeederResponse) 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 is 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 QueryPriceRequest 

type QueryPriceRequest struct {
	// signal_id is the signal id to query the price for.
	SignalId string `protobuf:"bytes,1,opt,name=signal_id,json=signalId,proto3" json:"signal_id,omitempty"`
}

QueryPriceRequest is the request type for the Query/Price RPC method.

func (*QueryPriceRequest) Descriptor 

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

func (*QueryPriceRequest) GetSignalId 

func (m *QueryPriceRequest) GetSignalId() string

func (*QueryPriceRequest) Marshal 

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

func (*QueryPriceRequest) MarshalTo 

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

func (*QueryPriceRequest) MarshalToSizedBuffer 

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

func (*QueryPriceRequest) ProtoMessage 

func (*QueryPriceRequest) ProtoMessage()

func (*QueryPriceRequest) Reset 

func (m *QueryPriceRequest) Reset()

func (*QueryPriceRequest) Size 

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

func (*QueryPriceRequest) String 

func (m *QueryPriceRequest) String() string

func (*QueryPriceRequest) Unmarshal 

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

func (*QueryPriceRequest) XXX_DiscardUnknown 

func (m *QueryPriceRequest) XXX_DiscardUnknown()

func (*QueryPriceRequest) XXX_Marshal 

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

func (*QueryPriceRequest) XXX_Merge 

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

func (*QueryPriceRequest) XXX_Size 

func (m *QueryPriceRequest) XXX_Size() int

func (*QueryPriceRequest) XXX_Unmarshal 

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

type QueryPriceResponse 

type QueryPriceResponse struct {
	// price is the aggregated price of the signal id.
	Price Price `protobuf:"bytes,1,opt,name=price,proto3" json:"price"`
}

QueryPriceResponse is the response type for the Query/Price RPC method.

func (*QueryPriceResponse) Descriptor 

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

func (*QueryPriceResponse) GetPrice 

func (m *QueryPriceResponse) GetPrice() Price

func (*QueryPriceResponse) Marshal 

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

func (*QueryPriceResponse) MarshalTo 

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

func (*QueryPriceResponse) MarshalToSizedBuffer 

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

func (*QueryPriceResponse) ProtoMessage 

func (*QueryPriceResponse) ProtoMessage()

func (*QueryPriceResponse) Reset 

func (m *QueryPriceResponse) Reset()

func (*QueryPriceResponse) Size 

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

func (*QueryPriceResponse) String 

func (m *QueryPriceResponse) String() string

func (*QueryPriceResponse) Unmarshal 

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

func (*QueryPriceResponse) XXX_DiscardUnknown 

func (m *QueryPriceResponse) XXX_DiscardUnknown()

func (*QueryPriceResponse) XXX_Marshal 

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

func (*QueryPriceResponse) XXX_Merge 

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

func (*QueryPriceResponse) XXX_Size 

func (m *QueryPriceResponse) XXX_Size() int

func (*QueryPriceResponse) XXX_Unmarshal 

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

type QueryPricesRequest 

type QueryPricesRequest struct {
	// signal_ids is a list of signal ids to query prices for.
	SignalIds []string `protobuf:"bytes,1,rep,name=signal_ids,json=signalIds,proto3" json:"signal_ids,omitempty"`
}

QueryPricesRequest is the request type for the Query/Prices RPC method.

func (*QueryPricesRequest) Descriptor 

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

func (*QueryPricesRequest) GetSignalIds 

func (m *QueryPricesRequest) GetSignalIds() []string

func (*QueryPricesRequest) Marshal 

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

func (*QueryPricesRequest) MarshalTo 

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

func (*QueryPricesRequest) MarshalToSizedBuffer 

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

func (*QueryPricesRequest) ProtoMessage 

func (*QueryPricesRequest) ProtoMessage()

func (*QueryPricesRequest) Reset 

func (m *QueryPricesRequest) Reset()

func (*QueryPricesRequest) Size 

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

func (*QueryPricesRequest) String 

func (m *QueryPricesRequest) String() string

func (*QueryPricesRequest) Unmarshal 

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

func (*QueryPricesRequest) XXX_DiscardUnknown 

func (m *QueryPricesRequest) XXX_DiscardUnknown()

func (*QueryPricesRequest) XXX_Marshal 

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

func (*QueryPricesRequest) XXX_Merge 

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

func (*QueryPricesRequest) XXX_Size 

func (m *QueryPricesRequest) XXX_Size() int

func (*QueryPricesRequest) XXX_Unmarshal 

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

type QueryPricesResponse 

type QueryPricesResponse struct {
	// prices is a list of prices.
	Prices []Price `protobuf:"bytes,1,rep,name=prices,proto3" json:"prices"`
}

QueryPricesResponse is the response type for the Query/Prices RPC method.

func (*QueryPricesResponse) Descriptor 

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

func (*QueryPricesResponse) GetPrices 

func (m *QueryPricesResponse) GetPrices() []Price

func (*QueryPricesResponse) Marshal 

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

func (*QueryPricesResponse) MarshalTo 

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

func (*QueryPricesResponse) MarshalToSizedBuffer 

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

func (*QueryPricesResponse) ProtoMessage 

func (*QueryPricesResponse) ProtoMessage()

func (*QueryPricesResponse) Reset 

func (m *QueryPricesResponse) Reset()

func (*QueryPricesResponse) Size 

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

func (*QueryPricesResponse) String 

func (m *QueryPricesResponse) String() string

func (*QueryPricesResponse) Unmarshal 

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

func (*QueryPricesResponse) XXX_DiscardUnknown 

func (m *QueryPricesResponse) XXX_DiscardUnknown()

func (*QueryPricesResponse) XXX_Marshal 

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

func (*QueryPricesResponse) XXX_Merge 

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

func (*QueryPricesResponse) XXX_Size 

func (m *QueryPricesResponse) XXX_Size() int

func (*QueryPricesResponse) XXX_Unmarshal 

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

type QueryReferenceSourceConfigRequest 

type QueryReferenceSourceConfigRequest struct {
}

QueryReferenceSourceConfigRequest is the request type for the Query/ReferenceSourceConfig RPC method.

func (*QueryReferenceSourceConfigRequest) Descriptor 

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

func (*QueryReferenceSourceConfigRequest) Marshal 

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

func (*QueryReferenceSourceConfigRequest) MarshalTo 

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

func (*QueryReferenceSourceConfigRequest) MarshalToSizedBuffer 

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

func (*QueryReferenceSourceConfigRequest) ProtoMessage 

func (*QueryReferenceSourceConfigRequest) ProtoMessage()

func (*QueryReferenceSourceConfigRequest) Reset 

func (m *QueryReferenceSourceConfigRequest) Reset()

func (*QueryReferenceSourceConfigRequest) Size 

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

func (*QueryReferenceSourceConfigRequest) String 

func (m *QueryReferenceSourceConfigRequest) String() string

func (*QueryReferenceSourceConfigRequest) Unmarshal 

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

func (*QueryReferenceSourceConfigRequest) XXX_DiscardUnknown 

func (m *QueryReferenceSourceConfigRequest) XXX_DiscardUnknown()

func (*QueryReferenceSourceConfigRequest) XXX_Marshal 

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

func (*QueryReferenceSourceConfigRequest) XXX_Merge 

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

func (*QueryReferenceSourceConfigRequest) XXX_Size 

func (m *QueryReferenceSourceConfigRequest) XXX_Size() int

func (*QueryReferenceSourceConfigRequest) XXX_Unmarshal 

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

type QueryReferenceSourceConfigResponse 

type QueryReferenceSourceConfigResponse struct {
	// reference_source_config is the information about the reference price source.
	ReferenceSourceConfig ReferenceSourceConfig `protobuf:"bytes,1,opt,name=reference_source_config,json=referenceSourceConfig,proto3" json:"reference_source_config"`
}

QueryReferenceSourceConfigResponse is the response type for the Query/ReferenceSourceConfig RPC method.

func (*QueryReferenceSourceConfigResponse) Descriptor 

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

func (*QueryReferenceSourceConfigResponse) GetReferenceSourceConfig 

func (m *QueryReferenceSourceConfigResponse) GetReferenceSourceConfig() ReferenceSourceConfig

func (*QueryReferenceSourceConfigResponse) Marshal 

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

func (*QueryReferenceSourceConfigResponse) MarshalTo 

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

func (*QueryReferenceSourceConfigResponse) MarshalToSizedBuffer 

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

func (*QueryReferenceSourceConfigResponse) ProtoMessage 

func (*QueryReferenceSourceConfigResponse) ProtoMessage()

func (*QueryReferenceSourceConfigResponse) Reset 

func (m *QueryReferenceSourceConfigResponse) Reset()

func (*QueryReferenceSourceConfigResponse) Size 

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

func (*QueryReferenceSourceConfigResponse) String 

func (m *QueryReferenceSourceConfigResponse) String() string

func (*QueryReferenceSourceConfigResponse) Unmarshal 

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

func (*QueryReferenceSourceConfigResponse) XXX_DiscardUnknown 

func (m *QueryReferenceSourceConfigResponse) XXX_DiscardUnknown()

func (*QueryReferenceSourceConfigResponse) XXX_Marshal 

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

func (*QueryReferenceSourceConfigResponse) XXX_Merge 

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

func (*QueryReferenceSourceConfigResponse) XXX_Size 

func (m *QueryReferenceSourceConfigResponse) XXX_Size() int

func (*QueryReferenceSourceConfigResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// CurrentFeeds is an RPC method that returns a list of current supported feeds.
	CurrentFeeds(context.Context, *QueryCurrentFeedsRequest) (*QueryCurrentFeedsResponse, error)
	// IsFeeder is an RPC method that returns whether an account is a feeder for a specified validator.
	IsFeeder(context.Context, *QueryIsFeederRequest) (*QueryIsFeederResponse, error)
	// Params is an RPC method that returns all parameters of the module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// Price is an RPC method that returns price by signal id.
	Price(context.Context, *QueryPriceRequest) (*QueryPriceResponse, error)
	// Prices is an RPC method that prices by signal ids.
	Prices(context.Context, *QueryPricesRequest) (*QueryPricesResponse, error)
	// AllPrices is an RPC method that returns all prices.
	AllPrices(context.Context, *QueryAllPricesRequest) (*QueryAllPricesResponse, error)
	// ReferenceSourceConfig is an RPC method that returns information on the reference price source.
	ReferenceSourceConfig(context.Context, *QueryReferenceSourceConfigRequest) (*QueryReferenceSourceConfigResponse, error)
	// SignalTotalPowers is an RPC method that returns all signal-total-powers or specified signal-total-power by signal
	// id.
	SignalTotalPowers(context.Context, *QuerySignalTotalPowersRequest) (*QuerySignalTotalPowersResponse, error)
	// ValidValidator is an RPC method that returns a flag to show if the validator is required to send prices.
	ValidValidator(context.Context, *QueryValidValidatorRequest) (*QueryValidValidatorResponse, error)
	// ValidatorPrices is an RPC method that returns prices of a validator.
	ValidatorPrices(context.Context, *QueryValidatorPricesRequest) (*QueryValidatorPricesResponse, error)
	// Vote is an RPC method that returns signals of a voter.
	Vote(context.Context, *QueryVoteRequest) (*QueryVoteResponse, error)
}

QueryServer is the server API for Query service.

type QuerySignalTotalPowersRequest 

type QuerySignalTotalPowersRequest struct {
	// signal_ids is a list of signal ids to query.
	SignalIds []string `protobuf:"bytes,1,rep,name=signal_ids,json=signalIds,proto3" json:"signal_ids,omitempty"`
	// pagination is the pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySignalTotalPowersRequest is the request type for the Query/SignalTotalPowers RPC method.

func (*QuerySignalTotalPowersRequest) Descriptor 

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

func (*QuerySignalTotalPowersRequest) GetPagination 

func (m *QuerySignalTotalPowersRequest) GetPagination() *query.PageRequest

func (*QuerySignalTotalPowersRequest) GetSignalIds 

func (m *QuerySignalTotalPowersRequest) GetSignalIds() []string

func (*QuerySignalTotalPowersRequest) Marshal 

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

func (*QuerySignalTotalPowersRequest) MarshalTo 

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

func (*QuerySignalTotalPowersRequest) MarshalToSizedBuffer 

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

func (*QuerySignalTotalPowersRequest) ProtoMessage 

func (*QuerySignalTotalPowersRequest) ProtoMessage()

func (*QuerySignalTotalPowersRequest) Reset 

func (m *QuerySignalTotalPowersRequest) Reset()

func (*QuerySignalTotalPowersRequest) Size 

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

func (*QuerySignalTotalPowersRequest) String 

func (m *QuerySignalTotalPowersRequest) String() string

func (*QuerySignalTotalPowersRequest) Unmarshal 

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

func (*QuerySignalTotalPowersRequest) XXX_DiscardUnknown 

func (m *QuerySignalTotalPowersRequest) XXX_DiscardUnknown()

func (*QuerySignalTotalPowersRequest) XXX_Marshal 

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

func (*QuerySignalTotalPowersRequest) XXX_Merge 

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

func (*QuerySignalTotalPowersRequest) XXX_Size 

func (m *QuerySignalTotalPowersRequest) XXX_Size() int

func (*QuerySignalTotalPowersRequest) XXX_Unmarshal 

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

type QuerySignalTotalPowersResponse 

type QuerySignalTotalPowersResponse struct {
	// signal_total_powers is a list of signal-total-powers.
	SignalTotalPowers []*Signal `protobuf:"bytes,1,rep,name=signal_total_powers,json=signalTotalPowers,proto3" json:"signal_total_powers,omitempty"`
	// pagination is the pagination information in the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySignalTotalPowersResponse is the response type for the Query/SignalTotalPowers RPC method.

func (*QuerySignalTotalPowersResponse) Descriptor 

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

func (*QuerySignalTotalPowersResponse) GetPagination 

func (m *QuerySignalTotalPowersResponse) GetPagination() *query.PageResponse

func (*QuerySignalTotalPowersResponse) GetSignalTotalPowers 

func (m *QuerySignalTotalPowersResponse) GetSignalTotalPowers() []*Signal

func (*QuerySignalTotalPowersResponse) Marshal 

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

func (*QuerySignalTotalPowersResponse) MarshalTo 

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

func (*QuerySignalTotalPowersResponse) MarshalToSizedBuffer 

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

func (*QuerySignalTotalPowersResponse) ProtoMessage 

func (*QuerySignalTotalPowersResponse) ProtoMessage()

func (*QuerySignalTotalPowersResponse) Reset 

func (m *QuerySignalTotalPowersResponse) Reset()

func (*QuerySignalTotalPowersResponse) Size 

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

func (*QuerySignalTotalPowersResponse) String 

func (m *QuerySignalTotalPowersResponse) String() string

func (*QuerySignalTotalPowersResponse) Unmarshal 

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

func (*QuerySignalTotalPowersResponse) XXX_DiscardUnknown 

func (m *QuerySignalTotalPowersResponse) XXX_DiscardUnknown()

func (*QuerySignalTotalPowersResponse) XXX_Marshal 

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

func (*QuerySignalTotalPowersResponse) XXX_Merge 

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

func (*QuerySignalTotalPowersResponse) XXX_Size 

func (m *QuerySignalTotalPowersResponse) XXX_Size() int

func (*QuerySignalTotalPowersResponse) XXX_Unmarshal 

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

type QueryValidValidatorRequest 

type QueryValidValidatorRequest struct {
	// validator is the validator address to query the flag.
	Validator string `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator,omitempty"`
}

QueryValidValidatorRequest is the request type for the Query/ValidValidator RPC method.

func (*QueryValidValidatorRequest) Descriptor 

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

func (*QueryValidValidatorRequest) GetValidator 

func (m *QueryValidValidatorRequest) GetValidator() string

func (*QueryValidValidatorRequest) Marshal 

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

func (*QueryValidValidatorRequest) MarshalTo 

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

func (*QueryValidValidatorRequest) MarshalToSizedBuffer 

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

func (*QueryValidValidatorRequest) ProtoMessage 

func (*QueryValidValidatorRequest) ProtoMessage()

func (*QueryValidValidatorRequest) Reset 

func (m *QueryValidValidatorRequest) Reset()

func (*QueryValidValidatorRequest) Size 

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

func (*QueryValidValidatorRequest) String 

func (m *QueryValidValidatorRequest) String() string

func (*QueryValidValidatorRequest) Unmarshal 

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

func (*QueryValidValidatorRequest) XXX_DiscardUnknown 

func (m *QueryValidValidatorRequest) XXX_DiscardUnknown()

func (*QueryValidValidatorRequest) XXX_Marshal 

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

func (*QueryValidValidatorRequest) XXX_Merge 

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

func (*QueryValidValidatorRequest) XXX_Size 

func (m *QueryValidValidatorRequest) XXX_Size() int

func (*QueryValidValidatorRequest) XXX_Unmarshal 

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

type QueryValidValidatorResponse 

type QueryValidValidatorResponse struct {
	// valid is a valid flag.
	Valid bool `protobuf:"varint,1,opt,name=valid,proto3" json:"valid,omitempty"`
}

QueryValidValidatorResponse is the response type for the Query/ValidValidator RPC method.

func (*QueryValidValidatorResponse) Descriptor 

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

func (*QueryValidValidatorResponse) GetValid 

func (m *QueryValidValidatorResponse) GetValid() bool

func (*QueryValidValidatorResponse) Marshal 

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

func (*QueryValidValidatorResponse) MarshalTo 

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

func (*QueryValidValidatorResponse) MarshalToSizedBuffer 

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

func (*QueryValidValidatorResponse) ProtoMessage 

func (*QueryValidValidatorResponse) ProtoMessage()

func (*QueryValidValidatorResponse) Reset 

func (m *QueryValidValidatorResponse) Reset()

func (*QueryValidValidatorResponse) Size 

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

func (*QueryValidValidatorResponse) String 

func (m *QueryValidValidatorResponse) String() string

func (*QueryValidValidatorResponse) Unmarshal 

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

func (*QueryValidValidatorResponse) XXX_DiscardUnknown 

func (m *QueryValidValidatorResponse) XXX_DiscardUnknown()

func (*QueryValidValidatorResponse) XXX_Marshal 

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

func (*QueryValidValidatorResponse) XXX_Merge 

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

func (*QueryValidValidatorResponse) XXX_Size 

func (m *QueryValidValidatorResponse) XXX_Size() int

func (*QueryValidValidatorResponse) XXX_Unmarshal 

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

type QueryValidatorPricesRequest 

type QueryValidatorPricesRequest struct {
	// validator is the validator address to query prices for.
	Validator string `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator,omitempty"`
	// signal_ids is the list of signal ids to query the price for.
	SignalIds []string `protobuf:"bytes,2,rep,name=signal_ids,json=signalIds,proto3" json:"signal_ids,omitempty"`
}

QueryValidatorPricesRequest is the request type for the Query/ValidatorPrices RPC method.

func (*QueryValidatorPricesRequest) Descriptor 

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

func (*QueryValidatorPricesRequest) GetSignalIds 

func (m *QueryValidatorPricesRequest) GetSignalIds() []string

func (*QueryValidatorPricesRequest) GetValidator 

func (m *QueryValidatorPricesRequest) GetValidator() string

func (*QueryValidatorPricesRequest) Marshal 

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

func (*QueryValidatorPricesRequest) MarshalTo 

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

func (*QueryValidatorPricesRequest) MarshalToSizedBuffer 

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

func (*QueryValidatorPricesRequest) ProtoMessage 

func (*QueryValidatorPricesRequest) ProtoMessage()

func (*QueryValidatorPricesRequest) Reset 

func (m *QueryValidatorPricesRequest) Reset()

func (*QueryValidatorPricesRequest) Size 

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

func (*QueryValidatorPricesRequest) String 

func (m *QueryValidatorPricesRequest) String() string

func (*QueryValidatorPricesRequest) Unmarshal 

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

func (*QueryValidatorPricesRequest) XXX_DiscardUnknown 

func (m *QueryValidatorPricesRequest) XXX_DiscardUnknown()

func (*QueryValidatorPricesRequest) XXX_Marshal 

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

func (*QueryValidatorPricesRequest) XXX_Merge 

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

func (*QueryValidatorPricesRequest) XXX_Size 

func (m *QueryValidatorPricesRequest) XXX_Size() int

func (*QueryValidatorPricesRequest) XXX_Unmarshal 

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

type QueryValidatorPricesResponse 

type QueryValidatorPricesResponse struct {
	// validator_prices is a list of prices submitted by the validator.
	ValidatorPrices []ValidatorPrice `protobuf:"bytes,1,rep,name=validator_prices,json=validatorPrices,proto3" json:"validator_prices"`
}

QueryValidatorPricesResponse is the response type for the Query/ValidatorPrices RPC method.

func (*QueryValidatorPricesResponse) Descriptor 

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

func (*QueryValidatorPricesResponse) GetValidatorPrices 

func (m *QueryValidatorPricesResponse) GetValidatorPrices() []ValidatorPrice

func (*QueryValidatorPricesResponse) Marshal 

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

func (*QueryValidatorPricesResponse) MarshalTo 

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

func (*QueryValidatorPricesResponse) MarshalToSizedBuffer 

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

func (*QueryValidatorPricesResponse) ProtoMessage 

func (*QueryValidatorPricesResponse) ProtoMessage()

func (*QueryValidatorPricesResponse) Reset 

func (m *QueryValidatorPricesResponse) Reset()

func (*QueryValidatorPricesResponse) Size 

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

func (*QueryValidatorPricesResponse) String 

func (m *QueryValidatorPricesResponse) String() string

func (*QueryValidatorPricesResponse) Unmarshal 

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

func (*QueryValidatorPricesResponse) XXX_DiscardUnknown 

func (m *QueryValidatorPricesResponse) XXX_DiscardUnknown()

func (*QueryValidatorPricesResponse) XXX_Marshal 

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

func (*QueryValidatorPricesResponse) XXX_Merge 

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

func (*QueryValidatorPricesResponse) XXX_Size 

func (m *QueryValidatorPricesResponse) XXX_Size() int

func (*QueryValidatorPricesResponse) XXX_Unmarshal 

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

type QueryVoteRequest 

type QueryVoteRequest struct {
	// voter is the voter address to query signal for.
	Voter string `protobuf:"bytes,1,opt,name=voter,proto3" json:"voter,omitempty"`
}

QueryVoteRequest is the request type for the Query/Vote RPC method.

func (*QueryVoteRequest) Descriptor 

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

func (*QueryVoteRequest) GetVoter 

func (m *QueryVoteRequest) GetVoter() string

func (*QueryVoteRequest) Marshal 

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

func (*QueryVoteRequest) MarshalTo 

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

func (*QueryVoteRequest) MarshalToSizedBuffer 

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

func (*QueryVoteRequest) ProtoMessage 

func (*QueryVoteRequest) ProtoMessage()

func (*QueryVoteRequest) Reset 

func (m *QueryVoteRequest) Reset()

func (*QueryVoteRequest) Size 

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

func (*QueryVoteRequest) String 

func (m *QueryVoteRequest) String() string

func (*QueryVoteRequest) Unmarshal 

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

func (*QueryVoteRequest) XXX_DiscardUnknown 

func (m *QueryVoteRequest) XXX_DiscardUnknown()

func (*QueryVoteRequest) XXX_Marshal 

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

func (*QueryVoteRequest) XXX_Merge 

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

func (*QueryVoteRequest) XXX_Size 

func (m *QueryVoteRequest) XXX_Size() int

func (*QueryVoteRequest) XXX_Unmarshal 

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

type QueryVoteResponse 

type QueryVoteResponse struct {
	// signals is a list of signals submitted by the voter.
	Signals []Signal `protobuf:"bytes,1,rep,name=signals,proto3" json:"signals"`
}

QueryVoteResponse is the response type for the Query/Vote RPC method.

func (*QueryVoteResponse) Descriptor 

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

func (*QueryVoteResponse) GetSignals 

func (m *QueryVoteResponse) GetSignals() []Signal

func (*QueryVoteResponse) Marshal 

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

func (*QueryVoteResponse) MarshalTo 

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

func (*QueryVoteResponse) MarshalToSizedBuffer 

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

func (*QueryVoteResponse) ProtoMessage 

func (*QueryVoteResponse) ProtoMessage()

func (*QueryVoteResponse) Reset 

func (m *QueryVoteResponse) Reset()

func (*QueryVoteResponse) Size 

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

func (*QueryVoteResponse) String 

func (m *QueryVoteResponse) String() string

func (*QueryVoteResponse) Unmarshal 

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

func (*QueryVoteResponse) XXX_DiscardUnknown 

func (m *QueryVoteResponse) XXX_DiscardUnknown()

func (*QueryVoteResponse) XXX_Marshal 

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

func (*QueryVoteResponse) XXX_Merge 

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

func (*QueryVoteResponse) XXX_Size 

func (m *QueryVoteResponse) XXX_Size() int

func (*QueryVoteResponse) XXX_Unmarshal 

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

type ReferenceSourceConfig 

type ReferenceSourceConfig struct {
	// registry_ipfs_hash is the hash of the reference registry.
	RegistryIPFSHash string `protobuf:"bytes,1,opt,name=registry_ipfs_hash,json=registryIpfsHash,proto3" json:"registry_ipfs_hash,omitempty"`
	// registry_version is the version of the reference registry.
	RegistryVersion string `protobuf:"bytes,2,opt,name=registry_version,json=registryVersion,proto3" json:"registry_version,omitempty"`
}

ReferenceSourceConfig is a structure that defines the information of reference price source.

func DefaultReferenceSourceConfig 

func DefaultReferenceSourceConfig() ReferenceSourceConfig

DefaultReferenceSourceConfig returns a default set of reference source config's information

func NewReferenceSourceConfig 

func NewReferenceSourceConfig(hash string, version string) ReferenceSourceConfig

NewReferenceSourceConfig creates a new reference source config instance

func (*ReferenceSourceConfig) Descriptor 

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

func (*ReferenceSourceConfig) Equal 

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

func (*ReferenceSourceConfig) GetRegistryIPFSHash 

func (m *ReferenceSourceConfig) GetRegistryIPFSHash() string

func (*ReferenceSourceConfig) GetRegistryVersion 

func (m *ReferenceSourceConfig) GetRegistryVersion() string

func (*ReferenceSourceConfig) Marshal 

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

func (*ReferenceSourceConfig) MarshalTo 

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

func (*ReferenceSourceConfig) MarshalToSizedBuffer 

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

func (*ReferenceSourceConfig) ProtoMessage 

func (*ReferenceSourceConfig) ProtoMessage()

func (*ReferenceSourceConfig) Reset 

func (m *ReferenceSourceConfig) Reset()

func (*ReferenceSourceConfig) Size 

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

func (*ReferenceSourceConfig) String 

func (m *ReferenceSourceConfig) String() string

func (*ReferenceSourceConfig) Unmarshal 

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

func (*ReferenceSourceConfig) Validate 

func (ps *ReferenceSourceConfig) Validate() error

Validate validates the reference source config

func (*ReferenceSourceConfig) XXX_DiscardUnknown 

func (m *ReferenceSourceConfig) XXX_DiscardUnknown()

func (*ReferenceSourceConfig) XXX_Marshal 

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

func (*ReferenceSourceConfig) XXX_Merge 

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

func (*ReferenceSourceConfig) XXX_Size 

func (m *ReferenceSourceConfig) XXX_Size() int

func (*ReferenceSourceConfig) XXX_Unmarshal 

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

type RestakeKeeper 

type RestakeKeeper interface {
	SetLockedPower(ctx sdk.Context, addr sdk.AccAddress, key string, amount math.Int) error
}

RestakeKeeper defines the expected restake keeper.

type Signal 

type Signal struct {
	// id is the id of the signal.
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// power is the power of the corresponding signal id.
	Power int64 `protobuf:"varint,2,opt,name=power,proto3" json:"power,omitempty"`
}

Signal is the data structure that contains signal id and power of that signal.

func NewSignal 

func NewSignal(id string, power int64) Signal

NewSignal creates a new signal

func (*Signal) Descriptor 

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

func (*Signal) Equal 

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

func (*Signal) GetID 

func (m *Signal) GetID() string

func (*Signal) GetPower 

func (m *Signal) GetPower() int64

func (*Signal) Marshal 

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

func (*Signal) MarshalTo 

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

func (*Signal) MarshalToSizedBuffer 

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

func (*Signal) ProtoMessage 

func (*Signal) ProtoMessage()

func (*Signal) Reset 

func (m *Signal) Reset()

func (*Signal) Size 

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

func (*Signal) String 

func (m *Signal) String() string

func (*Signal) Unmarshal 

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

func (*Signal) Validate 

func (s *Signal) Validate() error

func (*Signal) XXX_DiscardUnknown 

func (m *Signal) XXX_DiscardUnknown()

func (*Signal) XXX_Marshal 

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

func (*Signal) XXX_Merge 

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

func (*Signal) XXX_Size 

func (m *Signal) XXX_Size() int

func (*Signal) XXX_Unmarshal 

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

type SignalPrice 

type SignalPrice struct {
	// status is the status of the signal price.
	Status SignalPriceStatus `protobuf:"varint,1,opt,name=status,proto3,enum=band.feeds.v1beta1.SignalPriceStatus" json:"status,omitempty"`
	// signal_id is the signal id of the price.
	SignalID string `protobuf:"bytes,2,opt,name=signal_id,json=signalId,proto3" json:"signal_id,omitempty"`
	// price is the price submitted by the validator.
	Price uint64 `protobuf:"varint,3,opt,name=price,proto3" json:"price,omitempty"`
}

SignalPrice is a structure that defines the signaled price of a signal id.

func NewSignalPrice 

func NewSignalPrice(
	status SignalPriceStatus,
	signalID string,
	price uint64,
) SignalPrice

NewSignalPrice creates a new signal price instance

func (*SignalPrice) Descriptor 

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

func (*SignalPrice) Equal 

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

func (*SignalPrice) GetPrice 

func (m *SignalPrice) GetPrice() uint64

func (*SignalPrice) GetSignalID 

func (m *SignalPrice) GetSignalID() string

func (*SignalPrice) GetStatus 

func (m *SignalPrice) GetStatus() SignalPriceStatus

func (*SignalPrice) Marshal 

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

func (*SignalPrice) MarshalTo 

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

func (*SignalPrice) MarshalToSizedBuffer 

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

func (*SignalPrice) ProtoMessage 

func (*SignalPrice) ProtoMessage()

func (*SignalPrice) Reset 

func (m *SignalPrice) Reset()

func (*SignalPrice) Size 

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

func (*SignalPrice) String 

func (m *SignalPrice) String() string

func (*SignalPrice) Unmarshal 

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

func (*SignalPrice) XXX_DiscardUnknown 

func (m *SignalPrice) XXX_DiscardUnknown()

func (*SignalPrice) XXX_Marshal 

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

func (*SignalPrice) XXX_Merge 

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

func (*SignalPrice) XXX_Size 

func (m *SignalPrice) XXX_Size() int

func (*SignalPrice) XXX_Unmarshal 

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

type SignalPriceStatus 

type SignalPriceStatus int32

SignalPriceStatus is a structure that defines the price status of a signal id. 

const (
	// SIGNAL_PRICE_STATUS_UNSPECIFIED is an unspecified signal price status.
	SIGNAL_PRICE_STATUS_UNSPECIFIED SignalPriceStatus = 0
	// SIGNAL_PRICE_STATUS_UNSUPPORTED is an unsupported signal price status.
	SIGNAL_PRICE_STATUS_UNSUPPORTED SignalPriceStatus = 1
	// SIGNAL_PRICE_STATUS_UNAVAILABLE is an unavailable signal price status.
	SIGNAL_PRICE_STATUS_UNAVAILABLE SignalPriceStatus = 2
	// SIGNAL_PRICE_STATUS_AVAILABLE is an available signal price status.
	SIGNAL_PRICE_STATUS_AVAILABLE SignalPriceStatus = 3
)

func (SignalPriceStatus) EnumDescriptor 

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

func (SignalPriceStatus) String 

func (x SignalPriceStatus) String() string

type StakingKeeper 

type StakingKeeper interface {
	GetValidator(ctx context.Context, addr sdk.ValAddress) (validator stakingtypes.Validator, err error)
	IterateBondedValidatorsByPower(
		context.Context, func(index int64, validator stakingtypes.ValidatorI) (stop bool),
	) error
	TotalBondedTokens(context.Context) (math.Int, error)
}

StakingKeeper defines the expected staking keeper.

type TssPrice 

type TssPrice struct {
	SignalID [32]byte
	Price    uint64
}

TssPrice represents the price data to be encoded for encoding abi

func NewTssPrice 

func NewTssPrice(signalID [32]byte, price uint64) TssPrice

NewTssPrice creates a new EncodingPrice instance

func ToTssPrices 

func ToTssPrices(prices []Price) ([]TssPrice, error)

ToTssTickPrices converts a list of prices to TssPrice

func ToTssTickPrices 

func ToTssTickPrices(prices []Price) ([]TssPrice, error)

ToTssTickPrices converts a list of prices to TssPrice with price converted to tick

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) SubmitSignalPrices 

func (*UnimplementedMsgServer) SubmitSignalPrices(ctx context.Context, req *MsgSubmitSignalPrices) (*MsgSubmitSignalPricesResponse, error)

func (*UnimplementedMsgServer) UpdateParams 

func (*UnimplementedMsgServer) UpdateParams(ctx context.Context, req *MsgUpdateParams) (*MsgUpdateParamsResponse, error)

func (*UnimplementedMsgServer) UpdateReferenceSourceConfig 

func (*UnimplementedMsgServer) UpdateReferenceSourceConfig(ctx context.Context, req *MsgUpdateReferenceSourceConfig) (*MsgUpdateReferenceSourceConfigResponse, error)

func (*UnimplementedMsgServer) Vote 

func (*UnimplementedMsgServer) Vote(ctx context.Context, req *MsgVote) (*MsgVoteResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) AllPrices 

func (*UnimplementedQueryServer) AllPrices(ctx context.Context, req *QueryAllPricesRequest) (*QueryAllPricesResponse, error)

func (*UnimplementedQueryServer) CurrentFeeds 

func (*UnimplementedQueryServer) CurrentFeeds(ctx context.Context, req *QueryCurrentFeedsRequest) (*QueryCurrentFeedsResponse, error)

func (*UnimplementedQueryServer) IsFeeder 

func (*UnimplementedQueryServer) IsFeeder(ctx context.Context, req *QueryIsFeederRequest) (*QueryIsFeederResponse, error)

func (*UnimplementedQueryServer) Params 

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

func (*UnimplementedQueryServer) Price 

func (*UnimplementedQueryServer) Price(ctx context.Context, req *QueryPriceRequest) (*QueryPriceResponse, error)

func (*UnimplementedQueryServer) Prices 

func (*UnimplementedQueryServer) Prices(ctx context.Context, req *QueryPricesRequest) (*QueryPricesResponse, error)

func (*UnimplementedQueryServer) ReferenceSourceConfig 

func (*UnimplementedQueryServer) ReferenceSourceConfig(ctx context.Context, req *QueryReferenceSourceConfigRequest) (*QueryReferenceSourceConfigResponse, error)

func (*UnimplementedQueryServer) SignalTotalPowers 

func (*UnimplementedQueryServer) SignalTotalPowers(ctx context.Context, req *QuerySignalTotalPowersRequest) (*QuerySignalTotalPowersResponse, error)

func (*UnimplementedQueryServer) ValidValidator 

func (*UnimplementedQueryServer) ValidValidator(ctx context.Context, req *QueryValidValidatorRequest) (*QueryValidValidatorResponse, error)

func (*UnimplementedQueryServer) ValidatorPrices 

func (*UnimplementedQueryServer) ValidatorPrices(ctx context.Context, req *QueryValidatorPricesRequest) (*QueryValidatorPricesResponse, error)

func (*UnimplementedQueryServer) Vote 

func (*UnimplementedQueryServer) Vote(ctx context.Context, req *QueryVoteRequest) (*QueryVoteResponse, error)

type ValidatorInfo 

type ValidatorInfo struct {
	Address sdk.ValAddress
	Power   uint64
	Status  oracletypes.ValidatorStatus
}

ValidatorInfo contains validator info.

func NewValidatorInfo 

func NewValidatorInfo(
	address sdk.ValAddress,
	power uint64,
	status oracletypes.ValidatorStatus,
) ValidatorInfo

NewValidatorInfo returns a new ValidatorInfo.

type ValidatorPrice 

type ValidatorPrice struct {
	// signal_price_status is the status of a signal price submitted.
	SignalPriceStatus SignalPriceStatus `` /* 157-byte string literal not displayed */
	// signal_id is the signal id of the price.
	SignalID string `protobuf:"bytes,2,opt,name=signal_id,json=signalId,proto3" json:"signal_id,omitempty"`
	// price is the price submitted by the validator.
	Price uint64 `protobuf:"varint,3,opt,name=price,proto3" json:"price,omitempty"`
	// timestamp is the timestamp at which the price was submitted.
	Timestamp int64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// block_height is the block height at which the price was submitted.
	BlockHeight int64 `protobuf:"varint,5,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
}

ValidatorPrice is a structure that defines the price submitted by a validator for a signal id.

func NewValidatorPrice 

func NewValidatorPrice(
	signalPrice SignalPrice,
	blockTime int64,
	blockHeight int64,
) ValidatorPrice

NewValidatorPrice creates new ValidatorPrice.

func (*ValidatorPrice) Descriptor 

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

func (*ValidatorPrice) Equal 

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

func (*ValidatorPrice) GetBlockHeight 

func (m *ValidatorPrice) GetBlockHeight() int64

func (*ValidatorPrice) GetPrice 

func (m *ValidatorPrice) GetPrice() uint64

func (*ValidatorPrice) GetSignalID 

func (m *ValidatorPrice) GetSignalID() string

func (*ValidatorPrice) GetSignalPriceStatus 

func (m *ValidatorPrice) GetSignalPriceStatus() SignalPriceStatus

func (*ValidatorPrice) GetTimestamp 

func (m *ValidatorPrice) GetTimestamp() int64

func (*ValidatorPrice) Marshal 

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

func (*ValidatorPrice) MarshalTo 

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

func (*ValidatorPrice) MarshalToSizedBuffer 

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

func (*ValidatorPrice) ProtoMessage 

func (*ValidatorPrice) ProtoMessage()

func (*ValidatorPrice) Reset 

func (m *ValidatorPrice) Reset()

func (*ValidatorPrice) Size 

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

func (*ValidatorPrice) String 

func (m *ValidatorPrice) String() string

func (*ValidatorPrice) Unmarshal 

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

func (*ValidatorPrice) XXX_DiscardUnknown 

func (m *ValidatorPrice) XXX_DiscardUnknown()

func (*ValidatorPrice) XXX_Marshal 

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

func (*ValidatorPrice) XXX_Merge 

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

func (*ValidatorPrice) XXX_Size 

func (m *ValidatorPrice) XXX_Size() int

func (*ValidatorPrice) XXX_Unmarshal 

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

type ValidatorPriceInfo 

type ValidatorPriceInfo struct {
	SignalPriceStatus SignalPriceStatus // indicates the validity or state of the price entry
	Power             sdkmath.Int       // power or weight of this entry in calculations
	Price             uint64            // reported price value
	Timestamp         int64             // Unix timestamp for when this entry was recorded
}

ValidatorPriceInfo represents a single entry of price information from a validator. It includes the reported price, associated power (weight), and timestamp.

func NewValidatorPriceInfo 

func NewValidatorPriceInfo(
	signalPriceStatus SignalPriceStatus,
	power sdkmath.Int,
	price uint64,
	timestamp int64,
) ValidatorPriceInfo

NewValidatorPriceInfo creates a new instance of ValidatorPriceInfo.

type ValidatorPriceList 

type ValidatorPriceList struct {
	// validator is the validator address.
	Validator string `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator,omitempty"`
	// validators_prices is a list of validator prices.
	ValidatorPrices []ValidatorPrice `protobuf:"bytes,2,rep,name=validator_prices,json=validatorPrices,proto3" json:"validator_prices"`
}

ValidatorPriceList is a structure that holds a list of validator prices of a validator and its address.

func NewValidatorPriceList 

func NewValidatorPriceList(
	val sdk.ValAddress,
	prices []ValidatorPrice,
) ValidatorPriceList

NewValidatorPriceList creates new ValidatorPriceList.

func (*ValidatorPriceList) Descriptor 

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

func (*ValidatorPriceList) Equal 

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

func (*ValidatorPriceList) GetValidator 

func (m *ValidatorPriceList) GetValidator() string

func (*ValidatorPriceList) GetValidatorPrices 

func (m *ValidatorPriceList) GetValidatorPrices() []ValidatorPrice

func (*ValidatorPriceList) Marshal 

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

func (*ValidatorPriceList) MarshalTo 

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

func (*ValidatorPriceList) MarshalToSizedBuffer 

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

func (*ValidatorPriceList) ProtoMessage 

func (*ValidatorPriceList) ProtoMessage()

func (*ValidatorPriceList) Reset 

func (m *ValidatorPriceList) Reset()

func (*ValidatorPriceList) Size 

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

func (*ValidatorPriceList) String 

func (m *ValidatorPriceList) String() string

func (*ValidatorPriceList) Unmarshal 

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

func (*ValidatorPriceList) XXX_DiscardUnknown 

func (m *ValidatorPriceList) XXX_DiscardUnknown()

func (*ValidatorPriceList) XXX_Marshal 

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

func (*ValidatorPriceList) XXX_Merge 

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

func (*ValidatorPriceList) XXX_Size 

func (m *ValidatorPriceList) XXX_Size() int

func (*ValidatorPriceList) XXX_Unmarshal 

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

type Vote 

type Vote struct {
	// voter is the address of the voter of this signals.
	Voter string `protobuf:"bytes,1,opt,name=voter,proto3" json:"voter,omitempty"`
	// signals is a list of signals submit by the voter.
	Signals []Signal `protobuf:"bytes,2,rep,name=signals,proto3" json:"signals"`
}

Vote is the data structure that contains array of signals of a voter.

func NewVote 

func NewVote(voter string, signals []Signal) Vote

NewVote creates a new Vote instance.

func (*Vote) Descriptor 

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

func (*Vote) Equal 

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

func (*Vote) GetSignals 

func (m *Vote) GetSignals() []Signal

func (*Vote) GetVoter 

func (m *Vote) GetVoter() string

func (*Vote) Marshal 

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

func (*Vote) MarshalTo 

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

func (*Vote) MarshalToSizedBuffer 

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

func (*Vote) ProtoMessage 

func (*Vote) ProtoMessage()

func (*Vote) Reset 

func (m *Vote) Reset()

func (*Vote) Size 

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

func (*Vote) String 

func (m *Vote) String() string

func (*Vote) Unmarshal 

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

func (*Vote) Validate 

func (v *Vote) Validate() error

Validate validates the vote

func (*Vote) XXX_DiscardUnknown 

func (m *Vote) XXX_DiscardUnknown()

func (*Vote) XXX_Marshal 

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

func (*Vote) XXX_Merge 

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

func (*Vote) XXX_Size 

func (m *Vote) XXX_Size() int

func (*Vote) XXX_Unmarshal 

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

type WeightedPrice 

type WeightedPrice struct {
	Weight sdkmath.Int // weight of the price
	Price  uint64      // actual price value
}

WeightedPrice represents a price with an associated weight.

func NewWeightedPrice 

func NewWeightedPrice(weight sdkmath.Int, price uint64) WeightedPrice

NewWeightedPrice creates and returns a new WeightedPrice 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.