types

package
v0.0.0-...-3792732 Latest Latest
Warning

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

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

Documentation

Index

Constants

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

	// StoreKey to be used when creating the KVStore
	StoreKey = ModuleName

	// TStoreKey to be used when creating the Transient KVStore
	TStoreKey = "transient_chainlink"

	// RouterKey to be used for routing msgs
	RouterKey = ModuleName

	// QuerierRoute to be used for querier msgs
	QuerierRoute = ModuleName
)
View Source
const (
	TypeMsgCreateFeed             = "createFeed"
	TypeMsgUpdateFeed             = "updateFeed"
	TypeMsgTransmit               = "transmit"
	TypeMsgFundFeedRewardPool     = "fundFeedRewardPool"
	TypeMsgWithdrawFeedRewardPool = "withdrawFeedRewardPool"
	TypeMsgSetPayees              = "setPayees"
	TypeMsgTransferPayeeship      = "transferPayeeship"
	TypeMsgAcceptPayeeship        = "acceptPayeeship"
	TypeMsgUpdateParams           = "updateParams"
)
View Source
const (
	ProposalTypeOcrSetConfig      string = "ProposalTypeOcrSetConfig"
	ProposalTypeOcrBatchSetConfig string = "ProposalTypeOcrBatchSetConfig"
)

constants

View Source
const FeedIDMaxLength = 20

Variables

View Source
var (
	ErrStaleReport               = errors.Register(ModuleName, 1, "stale report")
	ErrIncompleteProposal        = errors.Register(ModuleName, 2, "incomplete proposal")
	ErrRepeatedAddress           = errors.Register(ModuleName, 3, "repeated oracle address")
	ErrTooManySigners            = errors.Register(ModuleName, 4, "too many signers")
	ErrIncorrectConfig           = errors.Register(ModuleName, 5, "incorrect config")
	ErrConfigDigestNotMatch      = errors.Register(ModuleName, 6, "config digest doesn't match")
	ErrWrongNumberOfSignatures   = errors.Register(ModuleName, 7, "wrong number of signatures")
	ErrIncorrectSignature        = errors.Register(ModuleName, 8, "incorrect signature")
	ErrNoTransmitter             = errors.Register(ModuleName, 9, "no transmitter specified")
	ErrIncorrectTransmissionData = errors.Register(ModuleName, 10, "incorrect transmission data")
	ErrNoTransmissionsFound      = errors.Register(ModuleName, 11, "no transmissions found")
	ErrMedianValueOutOfBounds    = errors.Register(ModuleName, 12, "median value is out of bounds")
	ErrIncorrectRewardPoolDenom  = errors.Register(ModuleName, 13, "LINK denom doesn't match")
	ErrNoRewardPool              = errors.Register(ModuleName, 14, "Reward Pool doesn't exist")
	ErrInvalidPayees             = errors.Register(ModuleName, 15, "wrong number of payees and transmitters")
	ErrModuleAdminRestricted     = errors.Register(ModuleName, 16, "action is restricted to the module admin")
	ErrFeedAlreadyExists         = errors.Register(ModuleName, 17, "feed already exists")
	ErrFeedDoesntExists          = errors.Register(ModuleName, 19, "feed doesnt exists")
	ErrAdminRestricted           = errors.Register(ModuleName, 20, "action is admin-restricted")
	ErrInsufficientRewardPool    = errors.Register(ModuleName, 21, "insufficient reward pool")
	ErrPayeeAlreadySet           = errors.Register(ModuleName, 22, "payee already set")
	ErrPayeeRestricted           = errors.Register(ModuleName, 23, "action is payee-restricted")
	ErrFeedConfigNotFound        = errors.Register(ModuleName, 24, "feed config not found")
)
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 (
	FeedConfigPrefix           = []byte{0x01}
	FeedConfigInfoPrefix       = []byte{0x02}
	LatestEpochAndRoundPrefix  = []byte{0x03}
	TransmissionPrefix         = []byte{0x04}
	AggregatorRoundIDPrefix    = []byte{0x05}
	FeedPoolPrefix             = []byte{0x06}
	ObservationsCountPrefix    = []byte{0x07}
	TransmissionsCountPrefix   = []byte{0x08}
	PayeePrefix                = []byte{0x09}
	PendingPayeeTransferPrefix = []byte{0x10}
	ParamsKey                  = []byte{0x11}
)
View Source
var (
	ErrInvalidLengthOcr        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowOcr          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupOcr = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	KeyLinkDenom      = []byte("LinkDenom")
	KeyPayoutInterval = []byte("PayoutInterval")
	KeyModuleAdmin    = []byte("ModuleAdmin")
)

Parameter keys

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 MaxNumOracles = 31

MaxNumOracles denotes number of oracles the offchain reporting protocol is designed for

View Source
var (

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

Functions

func GetAggregatorRoundIDKey

func GetAggregatorRoundIDKey(feedId string) []byte

func GetFeedConfigInfoKey

func GetFeedConfigInfoKey(feedId string) []byte

func GetFeedConfigKey

func GetFeedConfigKey(feedId string) []byte

func GetFeedIdFromPaddedFeedIdBz

func GetFeedIdFromPaddedFeedIdBz(feedIdBz []byte) string

func GetFeedObservationsKey

func GetFeedObservationsKey(feedId string, addr sdk.AccAddress) []byte

func GetFeedObservationsPrefix

func GetFeedObservationsPrefix(feedId string) []byte

func GetFeedPoolKey

func GetFeedPoolKey(feedId string) []byte

func GetFeedTransmissionsKey

func GetFeedTransmissionsKey(feedId string, addr sdk.AccAddress) []byte

func GetFeedTransmissionsPrefix

func GetFeedTransmissionsPrefix(feedId string) []byte

func GetLatestEpochAndRoundKey

func GetLatestEpochAndRoundKey(feedId string) []byte

func GetPayeePrefix

func GetPayeePrefix(feedId string, transmitter sdk.AccAddress) []byte

func GetPendingPayeeshipTransferPrefix

func GetPendingPayeeshipTransferPrefix(feedId string, transmitter sdk.AccAddress) []byte

func GetTransmissionKey

func GetTransmissionKey(feedId string) []byte

func ParamKeyTable

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable returns the parameter key table.

func RegisterInterfaces

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterLegacyAminoCodec

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

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

func RegisterMsgServer

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryServer

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type BankKeeper

type BankKeeper interface {
	GetBalance(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin
	GetAllBalances(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	SendCoinsFromModuleToModule(ctx sdk.Context, senderModule, recipientModule string, amt sdk.Coins) error
	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
	MintCoins(ctx sdk.Context, moduleName string, amt sdk.Coins) error
	BurnCoins(ctx sdk.Context, moduleName string, amt sdk.Coins) error
	SetDenomMetaData(ctx sdk.Context, denomMeta bank.Metadata)
}

BankKeeper defines the expected bank keeper methods

type ContractConfig

type ContractConfig struct {
	// config_count ordinal number of this config setting among all config
	// settings
	ConfigCount uint64 `protobuf:"varint,1,opt,name=config_count,json=configCount,proto3" json:"config_count,omitempty"`
	// signers ith element is address ith oracle uses to sign a report
	Signers []string `protobuf:"bytes,2,rep,name=signers,proto3" json:"signers,omitempty"`
	// transmitters ith element is address ith oracle uses to transmit a report
	// via the transmit method
	Transmitters []string `protobuf:"bytes,3,rep,name=transmitters,proto3" json:"transmitters,omitempty"`
	// f maximum number of faulty/dishonest oracles the protocol can tolerate
	// while still working correctly
	F uint32 `protobuf:"varint,4,opt,name=f,proto3" json:"f,omitempty"`
	// onchain_config serialized data with reporting plugin params on chain.
	OnchainConfig []byte `protobuf:"bytes,5,opt,name=onchain_config,json=onchainConfig,proto3" json:"onchain_config,omitempty"`
	// offchain_config_version version of the serialization format used for
	// "offchain_config" parameter
	OffchainConfigVersion uint64 `` /* 127-byte string literal not displayed */
	// offchain_config serialized data used by oracles to configure their offchain
	// operation
	OffchainConfig []byte `protobuf:"bytes,7,opt,name=offchain_config,json=offchainConfig,proto3" json:"offchain_config,omitempty"`
}

func (*ContractConfig) Descriptor

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

func (*ContractConfig) Digest

func (cfg *ContractConfig) Digest(chainID, feedID string) []byte

func (*ContractConfig) GetConfigCount

func (m *ContractConfig) GetConfigCount() uint64

func (*ContractConfig) GetF

func (m *ContractConfig) GetF() uint32

func (*ContractConfig) GetOffchainConfig

func (m *ContractConfig) GetOffchainConfig() []byte

func (*ContractConfig) GetOffchainConfigVersion

func (m *ContractConfig) GetOffchainConfigVersion() uint64

func (*ContractConfig) GetOnchainConfig

func (m *ContractConfig) GetOnchainConfig() []byte

func (*ContractConfig) GetSigners

func (m *ContractConfig) GetSigners() []string

func (*ContractConfig) GetTransmitters

func (m *ContractConfig) GetTransmitters() []string

func (*ContractConfig) Marshal

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

func (*ContractConfig) MarshalTo

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

func (*ContractConfig) MarshalToSizedBuffer

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

func (*ContractConfig) ProtoMessage

func (*ContractConfig) ProtoMessage()

func (*ContractConfig) Reset

func (m *ContractConfig) Reset()

func (*ContractConfig) Size

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

func (*ContractConfig) String

func (m *ContractConfig) String() string

func (*ContractConfig) Unmarshal

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

func (*ContractConfig) XXX_DiscardUnknown

func (m *ContractConfig) XXX_DiscardUnknown()

func (*ContractConfig) XXX_Marshal

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

func (*ContractConfig) XXX_Merge

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

func (*ContractConfig) XXX_Size

func (m *ContractConfig) XXX_Size() int

func (*ContractConfig) XXX_Unmarshal

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

type Count

type Count struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Count   uint64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
}

func (*Count) Descriptor

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

func (*Count) GetAddress

func (m *Count) GetAddress() string

func (*Count) GetCount

func (m *Count) GetCount() uint64

func (*Count) Marshal

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

func (*Count) MarshalTo

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

func (*Count) MarshalToSizedBuffer

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

func (*Count) ProtoMessage

func (*Count) ProtoMessage()

func (*Count) Reset

func (m *Count) Reset()

func (*Count) Size

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

func (*Count) String

func (m *Count) String() string

func (*Count) Unmarshal

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

func (*Count) XXX_DiscardUnknown

func (m *Count) XXX_DiscardUnknown()

func (*Count) XXX_Marshal

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

func (*Count) XXX_Merge

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

func (*Count) XXX_Size

func (m *Count) XXX_Size() int

func (*Count) XXX_Unmarshal

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

type EpochAndRound

type EpochAndRound struct {
	Epoch uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Round uint64 `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"`
}

func (*EpochAndRound) Descriptor

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

func (*EpochAndRound) GetEpoch

func (m *EpochAndRound) GetEpoch() uint64

func (*EpochAndRound) GetRound

func (m *EpochAndRound) GetRound() uint64

func (*EpochAndRound) Marshal

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

func (*EpochAndRound) MarshalTo

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

func (*EpochAndRound) MarshalToSizedBuffer

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

func (*EpochAndRound) ProtoMessage

func (*EpochAndRound) ProtoMessage()

func (*EpochAndRound) Reset

func (m *EpochAndRound) Reset()

func (*EpochAndRound) Size

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

func (*EpochAndRound) String

func (m *EpochAndRound) String() string

func (*EpochAndRound) Unmarshal

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

func (*EpochAndRound) XXX_DiscardUnknown

func (m *EpochAndRound) XXX_DiscardUnknown()

func (*EpochAndRound) XXX_Marshal

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

func (*EpochAndRound) XXX_Merge

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

func (*EpochAndRound) XXX_Size

func (m *EpochAndRound) XXX_Size() int

func (*EpochAndRound) XXX_Unmarshal

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

type EventAnswerUpdated

type EventAnswerUpdated struct {
	Current   github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,1,opt,name=current,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"current"`
	RoundId   github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,2,opt,name=round_id,json=roundId,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"round_id"`
	UpdatedAt time.Time                              `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3,stdtime" json:"updated_at"`
}

func (*EventAnswerUpdated) Descriptor

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

func (*EventAnswerUpdated) GetUpdatedAt

func (m *EventAnswerUpdated) GetUpdatedAt() time.Time

func (*EventAnswerUpdated) Marshal

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

func (*EventAnswerUpdated) MarshalTo

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

func (*EventAnswerUpdated) MarshalToSizedBuffer

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

func (*EventAnswerUpdated) ProtoMessage

func (*EventAnswerUpdated) ProtoMessage()

func (*EventAnswerUpdated) Reset

func (m *EventAnswerUpdated) Reset()

func (*EventAnswerUpdated) Size

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

func (*EventAnswerUpdated) String

func (m *EventAnswerUpdated) String() string

func (*EventAnswerUpdated) Unmarshal

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

func (*EventAnswerUpdated) XXX_DiscardUnknown

func (m *EventAnswerUpdated) XXX_DiscardUnknown()

func (*EventAnswerUpdated) XXX_Marshal

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

func (*EventAnswerUpdated) XXX_Merge

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

func (*EventAnswerUpdated) XXX_Size

func (m *EventAnswerUpdated) XXX_Size() int

func (*EventAnswerUpdated) XXX_Unmarshal

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

type EventConfigSet

type EventConfigSet struct {
	// hash of the config
	ConfigDigest []byte `protobuf:"bytes,1,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"`
	// previous_config_block_number block in which the previous config was set, to
	// simplify historic analysis
	PreviousConfigBlockNumber int64           `` /* 141-byte string literal not displayed */
	Config                    *FeedConfig     `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	ConfigInfo                *FeedConfigInfo `protobuf:"bytes,4,opt,name=config_info,json=configInfo,proto3" json:"config_info,omitempty"`
}

func (*EventConfigSet) Descriptor

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

func (*EventConfigSet) GetConfig

func (m *EventConfigSet) GetConfig() *FeedConfig

func (*EventConfigSet) GetConfigDigest

func (m *EventConfigSet) GetConfigDigest() []byte

func (*EventConfigSet) GetConfigInfo

func (m *EventConfigSet) GetConfigInfo() *FeedConfigInfo

func (*EventConfigSet) GetPreviousConfigBlockNumber

func (m *EventConfigSet) GetPreviousConfigBlockNumber() int64

func (*EventConfigSet) Marshal

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

func (*EventConfigSet) MarshalTo

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

func (*EventConfigSet) MarshalToSizedBuffer

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

func (*EventConfigSet) ProtoMessage

func (*EventConfigSet) ProtoMessage()

func (*EventConfigSet) Reset

func (m *EventConfigSet) Reset()

func (*EventConfigSet) Size

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

func (*EventConfigSet) String

func (m *EventConfigSet) String() string

func (*EventConfigSet) Unmarshal

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

func (*EventConfigSet) XXX_DiscardUnknown

func (m *EventConfigSet) XXX_DiscardUnknown()

func (*EventConfigSet) XXX_Marshal

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

func (*EventConfigSet) XXX_Merge

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

func (*EventConfigSet) XXX_Size

func (m *EventConfigSet) XXX_Size() int

func (*EventConfigSet) XXX_Unmarshal

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

type EventNewRound

type EventNewRound struct {
	RoundId github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,1,opt,name=round_id,json=roundId,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"round_id"`
	// address of starter
	StartedBy string    `protobuf:"bytes,2,opt,name=started_by,json=startedBy,proto3" json:"started_by,omitempty"`
	StartedAt time.Time `protobuf:"bytes,3,opt,name=started_at,json=startedAt,proto3,stdtime" json:"started_at"`
}

func (*EventNewRound) Descriptor

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

func (*EventNewRound) GetStartedAt

func (m *EventNewRound) GetStartedAt() time.Time

func (*EventNewRound) GetStartedBy

func (m *EventNewRound) GetStartedBy() string

func (*EventNewRound) Marshal

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

func (*EventNewRound) MarshalTo

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

func (*EventNewRound) MarshalToSizedBuffer

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

func (*EventNewRound) ProtoMessage

func (*EventNewRound) ProtoMessage()

func (*EventNewRound) Reset

func (m *EventNewRound) Reset()

func (*EventNewRound) Size

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

func (*EventNewRound) String

func (m *EventNewRound) String() string

func (*EventNewRound) Unmarshal

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

func (*EventNewRound) XXX_DiscardUnknown

func (m *EventNewRound) XXX_DiscardUnknown()

func (*EventNewRound) XXX_Marshal

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

func (*EventNewRound) XXX_Merge

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

func (*EventNewRound) XXX_Size

func (m *EventNewRound) XXX_Size() int

func (*EventNewRound) XXX_Unmarshal

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

type EventNewTransmission

type EventNewTransmission struct {
	FeedId                string                                   `protobuf:"bytes,1,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
	AggregatorRoundId     uint32                                   `protobuf:"varint,2,opt,name=aggregator_round_id,json=aggregatorRoundId,proto3" json:"aggregator_round_id,omitempty"`
	Answer                github_com_cosmos_cosmos_sdk_types.Dec   `protobuf:"bytes,3,opt,name=answer,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"answer"`
	Transmitter           string                                   `protobuf:"bytes,4,opt,name=transmitter,proto3" json:"transmitter,omitempty"`
	ObservationsTimestamp int64                                    `protobuf:"varint,5,opt,name=observations_timestamp,json=observationsTimestamp,proto3" json:"observations_timestamp,omitempty"`
	Observations          []github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,6,rep,name=observations,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"observations"`
	Observers             []byte                                   `protobuf:"bytes,7,opt,name=observers,proto3" json:"observers,omitempty"`
	ConfigDigest          []byte                                   `protobuf:"bytes,8,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"`
	EpochAndRound         *EpochAndRound                           `protobuf:"bytes,9,opt,name=epoch_and_round,json=epochAndRound,proto3" json:"epoch_and_round,omitempty"`
}

func (*EventNewTransmission) Descriptor

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

func (*EventNewTransmission) GetAggregatorRoundId

func (m *EventNewTransmission) GetAggregatorRoundId() uint32

func (*EventNewTransmission) GetConfigDigest

func (m *EventNewTransmission) GetConfigDigest() []byte

func (*EventNewTransmission) GetEpochAndRound

func (m *EventNewTransmission) GetEpochAndRound() *EpochAndRound

func (*EventNewTransmission) GetFeedId

func (m *EventNewTransmission) GetFeedId() string

func (*EventNewTransmission) GetObservationsTimestamp

func (m *EventNewTransmission) GetObservationsTimestamp() int64

func (*EventNewTransmission) GetObservers

func (m *EventNewTransmission) GetObservers() []byte

func (*EventNewTransmission) GetTransmitter

func (m *EventNewTransmission) GetTransmitter() string

func (*EventNewTransmission) Marshal

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

func (*EventNewTransmission) MarshalTo

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

func (*EventNewTransmission) MarshalToSizedBuffer

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

func (*EventNewTransmission) ProtoMessage

func (*EventNewTransmission) ProtoMessage()

func (*EventNewTransmission) Reset

func (m *EventNewTransmission) Reset()

func (*EventNewTransmission) Size

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

func (*EventNewTransmission) String

func (m *EventNewTransmission) String() string

func (*EventNewTransmission) Unmarshal

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

func (*EventNewTransmission) XXX_DiscardUnknown

func (m *EventNewTransmission) XXX_DiscardUnknown()

func (*EventNewTransmission) XXX_Marshal

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

func (*EventNewTransmission) XXX_Merge

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

func (*EventNewTransmission) XXX_Size

func (m *EventNewTransmission) XXX_Size() int

func (*EventNewTransmission) XXX_Unmarshal

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

type EventOraclePaid

type EventOraclePaid struct {
	TransmitterAddr string     `protobuf:"bytes,1,opt,name=transmitter_addr,json=transmitterAddr,proto3" json:"transmitter_addr,omitempty"`
	PayeeAddr       string     `protobuf:"bytes,2,opt,name=payee_addr,json=payeeAddr,proto3" json:"payee_addr,omitempty"`
	Amount          types.Coin `protobuf:"bytes,3,opt,name=amount,proto3" json:"amount"`
}

func (*EventOraclePaid) Descriptor

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

func (*EventOraclePaid) GetAmount

func (m *EventOraclePaid) GetAmount() types.Coin

func (*EventOraclePaid) GetPayeeAddr

func (m *EventOraclePaid) GetPayeeAddr() string

func (*EventOraclePaid) GetTransmitterAddr

func (m *EventOraclePaid) GetTransmitterAddr() string

func (*EventOraclePaid) Marshal

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

func (*EventOraclePaid) MarshalTo

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

func (*EventOraclePaid) MarshalToSizedBuffer

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

func (*EventOraclePaid) ProtoMessage

func (*EventOraclePaid) ProtoMessage()

func (*EventOraclePaid) Reset

func (m *EventOraclePaid) Reset()

func (*EventOraclePaid) Size

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

func (*EventOraclePaid) String

func (m *EventOraclePaid) String() string

func (*EventOraclePaid) Unmarshal

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

func (*EventOraclePaid) XXX_DiscardUnknown

func (m *EventOraclePaid) XXX_DiscardUnknown()

func (*EventOraclePaid) XXX_Marshal

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

func (*EventOraclePaid) XXX_Merge

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

func (*EventOraclePaid) XXX_Size

func (m *EventOraclePaid) XXX_Size() int

func (*EventOraclePaid) XXX_Unmarshal

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

type EventTransmitted

type EventTransmitted struct {
	ConfigDigest []byte `protobuf:"bytes,1,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"`
	Epoch        uint64 `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
}

func (*EventTransmitted) Descriptor

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

func (*EventTransmitted) GetConfigDigest

func (m *EventTransmitted) GetConfigDigest() []byte

func (*EventTransmitted) GetEpoch

func (m *EventTransmitted) GetEpoch() uint64

func (*EventTransmitted) Marshal

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

func (*EventTransmitted) MarshalTo

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

func (*EventTransmitted) MarshalToSizedBuffer

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

func (*EventTransmitted) ProtoMessage

func (*EventTransmitted) ProtoMessage()

func (*EventTransmitted) Reset

func (m *EventTransmitted) Reset()

func (*EventTransmitted) Size

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

func (*EventTransmitted) String

func (m *EventTransmitted) String() string

func (*EventTransmitted) Unmarshal

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

func (*EventTransmitted) XXX_DiscardUnknown

func (m *EventTransmitted) XXX_DiscardUnknown()

func (*EventTransmitted) XXX_Marshal

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

func (*EventTransmitted) XXX_Merge

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

func (*EventTransmitted) XXX_Size

func (m *EventTransmitted) XXX_Size() int

func (*EventTransmitted) XXX_Unmarshal

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

type FeedConfig

type FeedConfig struct {
	// signers ith element is address ith oracle uses to sign a report
	Signers []string `protobuf:"bytes,1,rep,name=signers,proto3" json:"signers,omitempty"`
	// transmitters ith element is address ith oracle uses to transmit a report
	// via the transmit method
	Transmitters []string `protobuf:"bytes,2,rep,name=transmitters,proto3" json:"transmitters,omitempty"`
	// f maximum number of faulty/dishonest oracles the protocol can tolerate
	// while still working correctly
	F uint32 `protobuf:"varint,3,opt,name=f,proto3" json:"f,omitempty"`
	// onchain_config serialized data with reporting plugin params on chain.
	OnchainConfig []byte `protobuf:"bytes,4,opt,name=onchain_config,json=onchainConfig,proto3" json:"onchain_config,omitempty"`
	// offchain_config_version version of the serialization format used for
	// "offchain_config" parameter
	OffchainConfigVersion uint64 `` /* 127-byte string literal not displayed */
	// offchain_config serialized data used by oracles to configure their offchain
	// operation
	OffchainConfig []byte `protobuf:"bytes,6,opt,name=offchain_config,json=offchainConfig,proto3" json:"offchain_config,omitempty"`
	// feed-specific params for the Cosmos module.
	ModuleParams *ModuleParams `protobuf:"bytes,7,opt,name=module_params,json=moduleParams,proto3" json:"module_params,omitempty"`
}

func (*FeedConfig) Descriptor

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

func (*FeedConfig) GetF

func (m *FeedConfig) GetF() uint32

func (*FeedConfig) GetModuleParams

func (m *FeedConfig) GetModuleParams() *ModuleParams

func (*FeedConfig) GetOffchainConfig

func (m *FeedConfig) GetOffchainConfig() []byte

func (*FeedConfig) GetOffchainConfigVersion

func (m *FeedConfig) GetOffchainConfigVersion() uint64

func (*FeedConfig) GetOnchainConfig

func (m *FeedConfig) GetOnchainConfig() []byte

func (*FeedConfig) GetSigners

func (m *FeedConfig) GetSigners() []string

func (*FeedConfig) GetTransmitters

func (m *FeedConfig) GetTransmitters() []string

func (*FeedConfig) Marshal

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

func (*FeedConfig) MarshalTo

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

func (*FeedConfig) MarshalToSizedBuffer

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

func (*FeedConfig) ProtoMessage

func (*FeedConfig) ProtoMessage()

func (*FeedConfig) Reset

func (m *FeedConfig) Reset()

func (*FeedConfig) Size

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

func (*FeedConfig) String

func (m *FeedConfig) String() string

func (*FeedConfig) TransmitterFromSigner

func (cfg *FeedConfig) TransmitterFromSigner() map[string]sdk.AccAddress

func (*FeedConfig) Unmarshal

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

func (*FeedConfig) ValidTransmitters

func (cfg *FeedConfig) ValidTransmitters() map[string]struct{}

func (*FeedConfig) ValidateBasic

func (cfg *FeedConfig) ValidateBasic() error

func (*FeedConfig) XXX_DiscardUnknown

func (m *FeedConfig) XXX_DiscardUnknown()

func (*FeedConfig) XXX_Marshal

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

func (*FeedConfig) XXX_Merge

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

func (*FeedConfig) XXX_Size

func (m *FeedConfig) XXX_Size() int

func (*FeedConfig) XXX_Unmarshal

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

type FeedConfigInfo

type FeedConfigInfo struct {
	LatestConfigDigest []byte `protobuf:"bytes,1,opt,name=latest_config_digest,json=latestConfigDigest,proto3" json:"latest_config_digest,omitempty"`
	F                  uint32 `protobuf:"varint,2,opt,name=f,proto3" json:"f,omitempty"`
	N                  uint32 `protobuf:"varint,3,opt,name=n,proto3" json:"n,omitempty"`
	// config_count ordinal number of this config setting among all config
	// settings
	ConfigCount             uint64 `protobuf:"varint,4,opt,name=config_count,json=configCount,proto3" json:"config_count,omitempty"`
	LatestConfigBlockNumber int64  `` /* 135-byte string literal not displayed */
}

func (*FeedConfigInfo) Descriptor

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

func (*FeedConfigInfo) GetConfigCount

func (m *FeedConfigInfo) GetConfigCount() uint64

func (*FeedConfigInfo) GetF

func (m *FeedConfigInfo) GetF() uint32

func (*FeedConfigInfo) GetLatestConfigBlockNumber

func (m *FeedConfigInfo) GetLatestConfigBlockNumber() int64

func (*FeedConfigInfo) GetLatestConfigDigest

func (m *FeedConfigInfo) GetLatestConfigDigest() []byte

func (*FeedConfigInfo) GetN

func (m *FeedConfigInfo) GetN() uint32

func (*FeedConfigInfo) Marshal

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

func (*FeedConfigInfo) MarshalTo

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

func (*FeedConfigInfo) MarshalToSizedBuffer

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

func (*FeedConfigInfo) ProtoMessage

func (*FeedConfigInfo) ProtoMessage()

func (*FeedConfigInfo) Reset

func (m *FeedConfigInfo) Reset()

func (*FeedConfigInfo) Size

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

func (*FeedConfigInfo) String

func (m *FeedConfigInfo) String() string

func (*FeedConfigInfo) Unmarshal

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

func (*FeedConfigInfo) XXX_DiscardUnknown

func (m *FeedConfigInfo) XXX_DiscardUnknown()

func (*FeedConfigInfo) XXX_Marshal

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

func (*FeedConfigInfo) XXX_Merge

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

func (*FeedConfigInfo) XXX_Size

func (m *FeedConfigInfo) XXX_Size() int

func (*FeedConfigInfo) XXX_Unmarshal

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

type FeedCounts

type FeedCounts struct {
	FeedId string   `protobuf:"bytes,1,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
	Counts []*Count `protobuf:"bytes,2,rep,name=counts,proto3" json:"counts,omitempty"`
}

func (*FeedCounts) Descriptor

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

func (*FeedCounts) GetCounts

func (m *FeedCounts) GetCounts() []*Count

func (*FeedCounts) GetFeedId

func (m *FeedCounts) GetFeedId() string

func (*FeedCounts) Marshal

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

func (*FeedCounts) MarshalTo

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

func (*FeedCounts) MarshalToSizedBuffer

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

func (*FeedCounts) ProtoMessage

func (*FeedCounts) ProtoMessage()

func (*FeedCounts) Reset

func (m *FeedCounts) Reset()

func (*FeedCounts) Size

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

func (*FeedCounts) String

func (m *FeedCounts) String() string

func (*FeedCounts) Unmarshal

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

func (*FeedCounts) XXX_DiscardUnknown

func (m *FeedCounts) XXX_DiscardUnknown()

func (*FeedCounts) XXX_Marshal

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

func (*FeedCounts) XXX_Merge

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

func (*FeedCounts) XXX_Size

func (m *FeedCounts) XXX_Size() int

func (*FeedCounts) XXX_Unmarshal

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

type FeedEpochAndRound

type FeedEpochAndRound struct {
	FeedId        string         `protobuf:"bytes,1,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
	EpochAndRound *EpochAndRound `protobuf:"bytes,2,opt,name=epoch_and_round,json=epochAndRound,proto3" json:"epoch_and_round,omitempty"`
}

func (*FeedEpochAndRound) Descriptor

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

func (*FeedEpochAndRound) GetEpochAndRound

func (m *FeedEpochAndRound) GetEpochAndRound() *EpochAndRound

func (*FeedEpochAndRound) GetFeedId

func (m *FeedEpochAndRound) GetFeedId() string

func (*FeedEpochAndRound) Marshal

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

func (*FeedEpochAndRound) MarshalTo

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

func (*FeedEpochAndRound) MarshalToSizedBuffer

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

func (*FeedEpochAndRound) ProtoMessage

func (*FeedEpochAndRound) ProtoMessage()

func (*FeedEpochAndRound) Reset

func (m *FeedEpochAndRound) Reset()

func (*FeedEpochAndRound) Size

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

func (*FeedEpochAndRound) String

func (m *FeedEpochAndRound) String() string

func (*FeedEpochAndRound) Unmarshal

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

func (*FeedEpochAndRound) XXX_DiscardUnknown

func (m *FeedEpochAndRound) XXX_DiscardUnknown()

func (*FeedEpochAndRound) XXX_Marshal

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

func (*FeedEpochAndRound) XXX_Merge

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

func (*FeedEpochAndRound) XXX_Size

func (m *FeedEpochAndRound) XXX_Size() int

func (*FeedEpochAndRound) XXX_Unmarshal

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

type FeedLatestAggregatorRoundIDs

type FeedLatestAggregatorRoundIDs struct {
	FeedId            string `protobuf:"bytes,1,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
	AggregatorRoundId uint64 `protobuf:"varint,2,opt,name=aggregator_round_id,json=aggregatorRoundId,proto3" json:"aggregator_round_id,omitempty"`
}

func (*FeedLatestAggregatorRoundIDs) Descriptor

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

func (*FeedLatestAggregatorRoundIDs) GetAggregatorRoundId

func (m *FeedLatestAggregatorRoundIDs) GetAggregatorRoundId() uint64

func (*FeedLatestAggregatorRoundIDs) GetFeedId

func (m *FeedLatestAggregatorRoundIDs) GetFeedId() string

func (*FeedLatestAggregatorRoundIDs) Marshal

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

func (*FeedLatestAggregatorRoundIDs) MarshalTo

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

func (*FeedLatestAggregatorRoundIDs) MarshalToSizedBuffer

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

func (*FeedLatestAggregatorRoundIDs) ProtoMessage

func (*FeedLatestAggregatorRoundIDs) ProtoMessage()

func (*FeedLatestAggregatorRoundIDs) Reset

func (m *FeedLatestAggregatorRoundIDs) Reset()

func (*FeedLatestAggregatorRoundIDs) Size

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

func (*FeedLatestAggregatorRoundIDs) String

func (*FeedLatestAggregatorRoundIDs) Unmarshal

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

func (*FeedLatestAggregatorRoundIDs) XXX_DiscardUnknown

func (m *FeedLatestAggregatorRoundIDs) XXX_DiscardUnknown()

func (*FeedLatestAggregatorRoundIDs) XXX_Marshal

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

func (*FeedLatestAggregatorRoundIDs) XXX_Merge

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

func (*FeedLatestAggregatorRoundIDs) XXX_Size

func (m *FeedLatestAggregatorRoundIDs) XXX_Size() int

func (*FeedLatestAggregatorRoundIDs) XXX_Unmarshal

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

type FeedProperties

type FeedProperties struct {
	// feed_id is an unique ID for the target of this config
	FeedId string `protobuf:"bytes,1,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
	// f maximum number of faulty/dishonest oracles the protocol can tolerate
	// while still working correctly
	F uint32 `protobuf:"varint,2,opt,name=f,proto3" json:"f,omitempty"`
	// onchain_config serialized data with reporting plugin params on chain.
	OnchainConfig []byte `protobuf:"bytes,3,opt,name=onchain_config,json=onchainConfig,proto3" json:"onchain_config,omitempty"`
	// offchain_config_version version of the serialization format used for
	// "offchain_config" parameter
	OffchainConfigVersion uint64 `` /* 127-byte string literal not displayed */
	// offchain_config serialized data used by oracles to configure their offchain
	// operation
	OffchainConfig []byte `protobuf:"bytes,5,opt,name=offchain_config,json=offchainConfig,proto3" json:"offchain_config,omitempty"`
	// lowest answer the median of a report is allowed to be
	MinAnswer github_com_cosmos_cosmos_sdk_types.Dec `` /* 128-byte string literal not displayed */
	// highest answer the median of a report is allowed to be
	MaxAnswer github_com_cosmos_cosmos_sdk_types.Dec `` /* 128-byte string literal not displayed */
	// Fixed LINK reward for each observer
	LinkPerObservation github_com_cosmos_cosmos_sdk_types.Int `` /* 157-byte string literal not displayed */
	// Fixed LINK reward for transmitter
	LinkPerTransmission github_com_cosmos_cosmos_sdk_types.Int `` /* 160-byte string literal not displayed */
	// Enables unique reports
	UniqueReports bool `protobuf:"varint,10,opt,name=unique_reports,json=uniqueReports,proto3" json:"unique_reports,omitempty"`
	// short human-readable description of observable this feed's answers pertain
	// to
	Description string `protobuf:"bytes,11,opt,name=description,proto3" json:"description,omitempty"`
}

func (*FeedProperties) Descriptor

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

func (*FeedProperties) GetDescription

func (m *FeedProperties) GetDescription() string

func (*FeedProperties) GetF

func (m *FeedProperties) GetF() uint32

func (*FeedProperties) GetFeedId

func (m *FeedProperties) GetFeedId() string

func (*FeedProperties) GetOffchainConfig

func (m *FeedProperties) GetOffchainConfig() []byte

func (*FeedProperties) GetOffchainConfigVersion

func (m *FeedProperties) GetOffchainConfigVersion() uint64

func (*FeedProperties) GetOnchainConfig

func (m *FeedProperties) GetOnchainConfig() []byte

func (*FeedProperties) GetUniqueReports

func (m *FeedProperties) GetUniqueReports() bool

func (*FeedProperties) Marshal

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

func (*FeedProperties) MarshalTo

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

func (*FeedProperties) MarshalToSizedBuffer

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

func (*FeedProperties) ProtoMessage

func (*FeedProperties) ProtoMessage()

func (*FeedProperties) Reset

func (m *FeedProperties) Reset()

func (*FeedProperties) Size

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

func (*FeedProperties) String

func (m *FeedProperties) String() string

func (*FeedProperties) Unmarshal

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

func (*FeedProperties) XXX_DiscardUnknown

func (m *FeedProperties) XXX_DiscardUnknown()

func (*FeedProperties) XXX_Marshal

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

func (*FeedProperties) XXX_Merge

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

func (*FeedProperties) XXX_Size

func (m *FeedProperties) XXX_Size() int

func (*FeedProperties) XXX_Unmarshal

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

type FeedTransmission

type FeedTransmission struct {
	FeedId       string        `protobuf:"bytes,1,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
	Transmission *Transmission `protobuf:"bytes,2,opt,name=transmission,proto3" json:"transmission,omitempty"`
}

func (*FeedTransmission) Descriptor

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

func (*FeedTransmission) GetFeedId

func (m *FeedTransmission) GetFeedId() string

func (*FeedTransmission) GetTransmission

func (m *FeedTransmission) GetTransmission() *Transmission

func (*FeedTransmission) Marshal

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

func (*FeedTransmission) MarshalTo

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

func (*FeedTransmission) MarshalToSizedBuffer

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

func (*FeedTransmission) ProtoMessage

func (*FeedTransmission) ProtoMessage()

func (*FeedTransmission) Reset

func (m *FeedTransmission) Reset()

func (*FeedTransmission) Size

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

func (*FeedTransmission) String

func (m *FeedTransmission) String() string

func (*FeedTransmission) Unmarshal

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

func (*FeedTransmission) XXX_DiscardUnknown

func (m *FeedTransmission) XXX_DiscardUnknown()

func (*FeedTransmission) XXX_Marshal

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

func (*FeedTransmission) XXX_Merge

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

func (*FeedTransmission) XXX_Size

func (m *FeedTransmission) XXX_Size() int

func (*FeedTransmission) XXX_Unmarshal

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

type GasReimbursements

type GasReimbursements struct {
	Reimbursements []*types.Coin `protobuf:"bytes,1,rep,name=reimbursements,proto3" json:"reimbursements,omitempty"`
}

LINK-INJ-denominated reimbursements for gas used by transmitters.

func (*GasReimbursements) Descriptor

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

func (*GasReimbursements) GetReimbursements

func (m *GasReimbursements) GetReimbursements() []*types.Coin

func (*GasReimbursements) Marshal

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

func (*GasReimbursements) MarshalTo

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

func (*GasReimbursements) MarshalToSizedBuffer

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

func (*GasReimbursements) ProtoMessage

func (*GasReimbursements) ProtoMessage()

func (*GasReimbursements) Reset

func (m *GasReimbursements) Reset()

func (*GasReimbursements) Size

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

func (*GasReimbursements) String

func (m *GasReimbursements) String() string

func (*GasReimbursements) Unmarshal

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

func (*GasReimbursements) XXX_DiscardUnknown

func (m *GasReimbursements) XXX_DiscardUnknown()

func (*GasReimbursements) XXX_Marshal

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

func (*GasReimbursements) XXX_Merge

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

func (*GasReimbursements) XXX_Size

func (m *GasReimbursements) XXX_Size() int

func (*GasReimbursements) XXX_Unmarshal

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

type GenesisState

type GenesisState struct {
	// params defines all the parameters of related to OCR.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	// feed_configs stores all of the supported OCR feeds
	FeedConfigs []*FeedConfig `protobuf:"bytes,2,rep,name=feed_configs,json=feedConfigs,proto3" json:"feed_configs,omitempty"`
	// latest_epoch_and_rounds stores the latest epoch and round for each feedId
	LatestEpochAndRounds []*FeedEpochAndRound `protobuf:"bytes,3,rep,name=latest_epoch_and_rounds,json=latestEpochAndRounds,proto3" json:"latest_epoch_and_rounds,omitempty"`
	// feed_transmissions stores the last transmission for each feed
	FeedTransmissions []*FeedTransmission `protobuf:"bytes,4,rep,name=feed_transmissions,json=feedTransmissions,proto3" json:"feed_transmissions,omitempty"`
	// latest_aggregator_round_ids stores the latest aggregator round ID for each
	// feedId
	LatestAggregatorRoundIds []*FeedLatestAggregatorRoundIDs `` /* 137-byte string literal not displayed */
	// reward_pools stores the reward pools
	RewardPools []*RewardPool `protobuf:"bytes,6,rep,name=reward_pools,json=rewardPools,proto3" json:"reward_pools,omitempty"`
	// feed_observation_counts stores the feed observation counts
	FeedObservationCounts []*FeedCounts `` /* 126-byte string literal not displayed */
	// feed_transmission_counts stores the feed transmission counts
	FeedTransmissionCounts []*FeedCounts `` /* 129-byte string literal not displayed */
	// pending_payeeships stores the pending payeeships
	PendingPayeeships []*PendingPayeeship `protobuf:"bytes,9,rep,name=pending_payeeships,json=pendingPayeeships,proto3" json:"pending_payeeships,omitempty"`
}

GenesisState defines the OCR module's genesis state.

func DefaultGenesisState

func DefaultGenesisState() *GenesisState

func NewGenesisState

func NewGenesisState() GenesisState

func (*GenesisState) Descriptor

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

func (*GenesisState) GetFeedConfigs

func (m *GenesisState) GetFeedConfigs() []*FeedConfig

func (*GenesisState) GetFeedObservationCounts

func (m *GenesisState) GetFeedObservationCounts() []*FeedCounts

func (*GenesisState) GetFeedTransmissionCounts

func (m *GenesisState) GetFeedTransmissionCounts() []*FeedCounts

func (*GenesisState) GetFeedTransmissions

func (m *GenesisState) GetFeedTransmissions() []*FeedTransmission

func (*GenesisState) GetLatestAggregatorRoundIds

func (m *GenesisState) GetLatestAggregatorRoundIds() []*FeedLatestAggregatorRoundIDs

func (*GenesisState) GetLatestEpochAndRounds

func (m *GenesisState) GetLatestEpochAndRounds() []*FeedEpochAndRound

func (*GenesisState) GetParams

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetPendingPayeeships

func (m *GenesisState) GetPendingPayeeships() []*PendingPayeeship

func (*GenesisState) GetRewardPools

func (m *GenesisState) GetRewardPools() []*RewardPool

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

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 ModuleParams

type ModuleParams struct {
	// feed_id is an unique ID for the target of this config
	FeedId string `protobuf:"bytes,1,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
	// lowest answer the median of a report is allowed to be
	MinAnswer github_com_cosmos_cosmos_sdk_types.Dec `` /* 128-byte string literal not displayed */
	// highest answer the median of a report is allowed to be
	MaxAnswer github_com_cosmos_cosmos_sdk_types.Dec `` /* 128-byte string literal not displayed */
	// Fixed LINK reward for each observer
	LinkPerObservation github_com_cosmos_cosmos_sdk_types.Int `` /* 157-byte string literal not displayed */
	// Fixed LINK reward for transmitter
	LinkPerTransmission github_com_cosmos_cosmos_sdk_types.Int `` /* 160-byte string literal not displayed */
	// Native denom for LINK coin in the bank keeper
	LinkDenom string `protobuf:"bytes,6,opt,name=link_denom,json=linkDenom,proto3" json:"link_denom,omitempty"`
	// Enables unique reports
	UniqueReports bool `protobuf:"varint,7,opt,name=unique_reports,json=uniqueReports,proto3" json:"unique_reports,omitempty"`
	// short human-readable description of observable this feed's answers pertain
	// to
	Description string `protobuf:"bytes,8,opt,name=description,proto3" json:"description,omitempty"`
	// feed administrator
	FeedAdmin string `protobuf:"bytes,9,opt,name=feed_admin,json=feedAdmin,proto3" json:"feed_admin,omitempty"`
	// feed billing administrator
	BillingAdmin string `protobuf:"bytes,10,opt,name=billing_admin,json=billingAdmin,proto3" json:"billing_admin,omitempty"`
}

func (*ModuleParams) Descriptor

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

func (*ModuleParams) GetBillingAdmin

func (m *ModuleParams) GetBillingAdmin() string

func (*ModuleParams) GetDescription

func (m *ModuleParams) GetDescription() string

func (*ModuleParams) GetFeedAdmin

func (m *ModuleParams) GetFeedAdmin() string

func (*ModuleParams) GetFeedId

func (m *ModuleParams) GetFeedId() string

func (*ModuleParams) GetLinkDenom

func (m *ModuleParams) GetLinkDenom() string

func (*ModuleParams) GetUniqueReports

func (m *ModuleParams) GetUniqueReports() bool

func (*ModuleParams) Marshal

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

func (*ModuleParams) MarshalTo

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

func (*ModuleParams) MarshalToSizedBuffer

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

func (*ModuleParams) ProtoMessage

func (*ModuleParams) ProtoMessage()

func (*ModuleParams) Reset

func (m *ModuleParams) Reset()

func (*ModuleParams) Size

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

func (*ModuleParams) String

func (m *ModuleParams) String() string

func (*ModuleParams) Unmarshal

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

func (*ModuleParams) XXX_DiscardUnknown

func (m *ModuleParams) XXX_DiscardUnknown()

func (*ModuleParams) XXX_Marshal

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

func (*ModuleParams) XXX_Merge

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

func (*ModuleParams) XXX_Size

func (m *ModuleParams) XXX_Size() int

func (*ModuleParams) XXX_Unmarshal

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

type MsgAcceptPayeeship

type MsgAcceptPayeeship struct {
	// new payee address
	Payee string `protobuf:"bytes,1,opt,name=payee,proto3" json:"payee,omitempty"`
	// transmitter address of oracle whose payee is changing
	Transmitter string `protobuf:"bytes,2,opt,name=transmitter,proto3" json:"transmitter,omitempty"`
	FeedId      string `protobuf:"bytes,3,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
}

func (*MsgAcceptPayeeship) Descriptor

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

func (*MsgAcceptPayeeship) GetSignBytes

func (msg *MsgAcceptPayeeship) GetSignBytes() []byte

GetSignBytes implements the sdk.Msg interface. It encodes the message for signing

func (MsgAcceptPayeeship) GetSigners

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

GetSigners implements the sdk.Msg interface. It defines whose signature is required

func (*MsgAcceptPayeeship) Marshal

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

func (*MsgAcceptPayeeship) MarshalTo

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

func (*MsgAcceptPayeeship) MarshalToSizedBuffer

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

func (*MsgAcceptPayeeship) ProtoMessage

func (*MsgAcceptPayeeship) ProtoMessage()

func (*MsgAcceptPayeeship) Reset

func (m *MsgAcceptPayeeship) Reset()

func (MsgAcceptPayeeship) Route

func (msg MsgAcceptPayeeship) Route() string

Route implements the sdk.Msg interface. It should return the name of the module

func (*MsgAcceptPayeeship) Size

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

func (*MsgAcceptPayeeship) String

func (m *MsgAcceptPayeeship) String() string

func (MsgAcceptPayeeship) Type

func (msg MsgAcceptPayeeship) Type() string

Type implements the sdk.Msg interface. It should return the action.

func (*MsgAcceptPayeeship) Unmarshal

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

func (MsgAcceptPayeeship) ValidateBasic

func (msg MsgAcceptPayeeship) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface for MsgAcceptPayeeship.

func (*MsgAcceptPayeeship) XXX_DiscardUnknown

func (m *MsgAcceptPayeeship) XXX_DiscardUnknown()

func (*MsgAcceptPayeeship) XXX_Marshal

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

func (*MsgAcceptPayeeship) XXX_Merge

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

func (*MsgAcceptPayeeship) XXX_Size

func (m *MsgAcceptPayeeship) XXX_Size() int

func (*MsgAcceptPayeeship) XXX_Unmarshal

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

type MsgAcceptPayeeshipResponse

type MsgAcceptPayeeshipResponse struct {
}

func (*MsgAcceptPayeeshipResponse) Descriptor

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

func (*MsgAcceptPayeeshipResponse) Marshal

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

func (*MsgAcceptPayeeshipResponse) MarshalTo

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

func (*MsgAcceptPayeeshipResponse) MarshalToSizedBuffer

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

func (*MsgAcceptPayeeshipResponse) ProtoMessage

func (*MsgAcceptPayeeshipResponse) ProtoMessage()

func (*MsgAcceptPayeeshipResponse) Reset

func (m *MsgAcceptPayeeshipResponse) Reset()

func (*MsgAcceptPayeeshipResponse) Size

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

func (*MsgAcceptPayeeshipResponse) String

func (m *MsgAcceptPayeeshipResponse) String() string

func (*MsgAcceptPayeeshipResponse) Unmarshal

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

func (*MsgAcceptPayeeshipResponse) XXX_DiscardUnknown

func (m *MsgAcceptPayeeshipResponse) XXX_DiscardUnknown()

func (*MsgAcceptPayeeshipResponse) XXX_Marshal

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

func (*MsgAcceptPayeeshipResponse) XXX_Merge

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

func (*MsgAcceptPayeeshipResponse) XXX_Size

func (m *MsgAcceptPayeeshipResponse) XXX_Size() int

func (*MsgAcceptPayeeshipResponse) XXX_Unmarshal

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

type MsgClient

type MsgClient interface {
	// CreateFeed defines a method for creating feed by module admin
	CreateFeed(ctx context.Context, in *MsgCreateFeed, opts ...grpc.CallOption) (*MsgCreateFeedResponse, error)
	// CreateFeed defines a method for creating feed by feed admin or feed billing
	// admin
	UpdateFeed(ctx context.Context, in *MsgUpdateFeed, opts ...grpc.CallOption) (*MsgUpdateFeedResponse, error)
	// Transmit defines a method for transmitting the feed info by transmitter
	Transmit(ctx context.Context, in *MsgTransmit, opts ...grpc.CallOption) (*MsgTransmitResponse, error)
	// FundFeedRewardPool defines a method to put funds into feed reward pool
	FundFeedRewardPool(ctx context.Context, in *MsgFundFeedRewardPool, opts ...grpc.CallOption) (*MsgFundFeedRewardPoolResponse, error)
	// WithdrawFeedRewardPool defines a method to witdhraw feed reward by feed
	// admin or billing admin
	WithdrawFeedRewardPool(ctx context.Context, in *MsgWithdrawFeedRewardPool, opts ...grpc.CallOption) (*MsgWithdrawFeedRewardPoolResponse, error)
	// SetPayees defines a method to set payees for transmitters (batch action)
	SetPayees(ctx context.Context, in *MsgSetPayees, opts ...grpc.CallOption) (*MsgSetPayeesResponse, error)
	// TransferPayeeship defines a method for a payee to transfer reward receive
	// ownership
	TransferPayeeship(ctx context.Context, in *MsgTransferPayeeship, opts ...grpc.CallOption) (*MsgTransferPayeeshipResponse, error)
	// AcceptPayeeship defines a method for a new payee to accept reward receive
	// ownership
	AcceptPayeeship(ctx context.Context, in *MsgAcceptPayeeship, opts ...grpc.CallOption) (*MsgAcceptPayeeshipResponse, error)
	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 MsgCreateFeed

type MsgCreateFeed struct {
	Sender string      `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	Config *FeedConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
}

func (*MsgCreateFeed) Descriptor

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

func (*MsgCreateFeed) GetSignBytes

func (msg *MsgCreateFeed) GetSignBytes() []byte

GetSignBytes implements the sdk.Msg interface. It encodes the message for signing

func (MsgCreateFeed) GetSigners

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

GetSigners implements the sdk.Msg interface. It defines whose signature is required

func (*MsgCreateFeed) Marshal

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

func (*MsgCreateFeed) MarshalTo

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

func (*MsgCreateFeed) MarshalToSizedBuffer

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

func (*MsgCreateFeed) ProtoMessage

func (*MsgCreateFeed) ProtoMessage()

func (*MsgCreateFeed) Reset

func (m *MsgCreateFeed) Reset()

func (MsgCreateFeed) Route

func (msg MsgCreateFeed) Route() string

Route implements the sdk.Msg interface. It should return the name of the module

func (*MsgCreateFeed) Size

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

func (*MsgCreateFeed) String

func (m *MsgCreateFeed) String() string

func (MsgCreateFeed) Type

func (msg MsgCreateFeed) Type() string

Type implements the sdk.Msg interface. It should return the action.

func (*MsgCreateFeed) Unmarshal

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

func (MsgCreateFeed) ValidateBasic

func (msg MsgCreateFeed) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface for MsgCreateFeed.

func (*MsgCreateFeed) XXX_DiscardUnknown

func (m *MsgCreateFeed) XXX_DiscardUnknown()

func (*MsgCreateFeed) XXX_Marshal

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

func (*MsgCreateFeed) XXX_Merge

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

func (*MsgCreateFeed) XXX_Size

func (m *MsgCreateFeed) XXX_Size() int

func (*MsgCreateFeed) XXX_Unmarshal

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

type MsgCreateFeedResponse

type MsgCreateFeedResponse struct {
}

func (*MsgCreateFeedResponse) Descriptor

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

func (*MsgCreateFeedResponse) Marshal

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

func (*MsgCreateFeedResponse) MarshalTo

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

func (*MsgCreateFeedResponse) MarshalToSizedBuffer

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

func (*MsgCreateFeedResponse) ProtoMessage

func (*MsgCreateFeedResponse) ProtoMessage()

func (*MsgCreateFeedResponse) Reset

func (m *MsgCreateFeedResponse) Reset()

func (*MsgCreateFeedResponse) Size

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

func (*MsgCreateFeedResponse) String

func (m *MsgCreateFeedResponse) String() string

func (*MsgCreateFeedResponse) Unmarshal

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

func (*MsgCreateFeedResponse) XXX_DiscardUnknown

func (m *MsgCreateFeedResponse) XXX_DiscardUnknown()

func (*MsgCreateFeedResponse) XXX_Marshal

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

func (*MsgCreateFeedResponse) XXX_Merge

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

func (*MsgCreateFeedResponse) XXX_Size

func (m *MsgCreateFeedResponse) XXX_Size() int

func (*MsgCreateFeedResponse) XXX_Unmarshal

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

type MsgFundFeedRewardPool

type MsgFundFeedRewardPool struct {
	Sender string     `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	FeedId string     `protobuf:"bytes,2,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
	Amount types.Coin `protobuf:"bytes,3,opt,name=amount,proto3" json:"amount"`
}

func (*MsgFundFeedRewardPool) Descriptor

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

func (*MsgFundFeedRewardPool) GetSignBytes

func (msg *MsgFundFeedRewardPool) GetSignBytes() []byte

GetSignBytes implements the sdk.Msg interface. It encodes the message for signing

func (MsgFundFeedRewardPool) GetSigners

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

GetSigners implements the sdk.Msg interface. It defines whose signature is required

func (*MsgFundFeedRewardPool) Marshal

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

func (*MsgFundFeedRewardPool) MarshalTo

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

func (*MsgFundFeedRewardPool) MarshalToSizedBuffer

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

func (*MsgFundFeedRewardPool) ProtoMessage

func (*MsgFundFeedRewardPool) ProtoMessage()

func (*MsgFundFeedRewardPool) Reset

func (m *MsgFundFeedRewardPool) Reset()

func (MsgFundFeedRewardPool) Route

func (msg MsgFundFeedRewardPool) Route() string

Route implements the sdk.Msg interface. It should return the name of the module

func (*MsgFundFeedRewardPool) Size

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

func (*MsgFundFeedRewardPool) String

func (m *MsgFundFeedRewardPool) String() string

func (MsgFundFeedRewardPool) Type

func (msg MsgFundFeedRewardPool) Type() string

Type implements the sdk.Msg interface. It should return the action.

func (*MsgFundFeedRewardPool) Unmarshal

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

func (MsgFundFeedRewardPool) ValidateBasic

func (msg MsgFundFeedRewardPool) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface for MsgFundFeedRewardPool.

func (*MsgFundFeedRewardPool) XXX_DiscardUnknown

func (m *MsgFundFeedRewardPool) XXX_DiscardUnknown()

func (*MsgFundFeedRewardPool) XXX_Marshal

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

func (*MsgFundFeedRewardPool) XXX_Merge

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

func (*MsgFundFeedRewardPool) XXX_Size

func (m *MsgFundFeedRewardPool) XXX_Size() int

func (*MsgFundFeedRewardPool) XXX_Unmarshal

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

type MsgFundFeedRewardPoolResponse

type MsgFundFeedRewardPoolResponse struct {
}

func (*MsgFundFeedRewardPoolResponse) Descriptor

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

func (*MsgFundFeedRewardPoolResponse) Marshal

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

func (*MsgFundFeedRewardPoolResponse) MarshalTo

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

func (*MsgFundFeedRewardPoolResponse) MarshalToSizedBuffer

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

func (*MsgFundFeedRewardPoolResponse) ProtoMessage

func (*MsgFundFeedRewardPoolResponse) ProtoMessage()

func (*MsgFundFeedRewardPoolResponse) Reset

func (m *MsgFundFeedRewardPoolResponse) Reset()

func (*MsgFundFeedRewardPoolResponse) Size

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

func (*MsgFundFeedRewardPoolResponse) String

func (*MsgFundFeedRewardPoolResponse) Unmarshal

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

func (*MsgFundFeedRewardPoolResponse) XXX_DiscardUnknown

func (m *MsgFundFeedRewardPoolResponse) XXX_DiscardUnknown()

func (*MsgFundFeedRewardPoolResponse) XXX_Marshal

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

func (*MsgFundFeedRewardPoolResponse) XXX_Merge

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

func (*MsgFundFeedRewardPoolResponse) XXX_Size

func (m *MsgFundFeedRewardPoolResponse) XXX_Size() int

func (*MsgFundFeedRewardPoolResponse) XXX_Unmarshal

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

type MsgServer

type MsgServer interface {
	// CreateFeed defines a method for creating feed by module admin
	CreateFeed(context.Context, *MsgCreateFeed) (*MsgCreateFeedResponse, error)
	// CreateFeed defines a method for creating feed by feed admin or feed billing
	// admin
	UpdateFeed(context.Context, *MsgUpdateFeed) (*MsgUpdateFeedResponse, error)
	// Transmit defines a method for transmitting the feed info by transmitter
	Transmit(context.Context, *MsgTransmit) (*MsgTransmitResponse, error)
	// FundFeedRewardPool defines a method to put funds into feed reward pool
	FundFeedRewardPool(context.Context, *MsgFundFeedRewardPool) (*MsgFundFeedRewardPoolResponse, error)
	// WithdrawFeedRewardPool defines a method to witdhraw feed reward by feed
	// admin or billing admin
	WithdrawFeedRewardPool(context.Context, *MsgWithdrawFeedRewardPool) (*MsgWithdrawFeedRewardPoolResponse, error)
	// SetPayees defines a method to set payees for transmitters (batch action)
	SetPayees(context.Context, *MsgSetPayees) (*MsgSetPayeesResponse, error)
	// TransferPayeeship defines a method for a payee to transfer reward receive
	// ownership
	TransferPayeeship(context.Context, *MsgTransferPayeeship) (*MsgTransferPayeeshipResponse, error)
	// AcceptPayeeship defines a method for a new payee to accept reward receive
	// ownership
	AcceptPayeeship(context.Context, *MsgAcceptPayeeship) (*MsgAcceptPayeeshipResponse, error)
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSetPayees

type MsgSetPayees struct {
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	FeedId string `protobuf:"bytes,2,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
	// addresses oracles use to transmit the reports
	Transmitters []string `protobuf:"bytes,3,rep,name=transmitters,proto3" json:"transmitters,omitempty"`
	// addresses of payees corresponding to list of transmitters
	Payees []string `protobuf:"bytes,4,rep,name=payees,proto3" json:"payees,omitempty"`
}

func (*MsgSetPayees) Descriptor

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

func (*MsgSetPayees) GetSignBytes

func (msg *MsgSetPayees) GetSignBytes() []byte

GetSignBytes implements the sdk.Msg interface. It encodes the message for signing

func (MsgSetPayees) GetSigners

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

GetSigners implements the sdk.Msg interface. It defines whose signature is required

func (*MsgSetPayees) Marshal

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

func (*MsgSetPayees) MarshalTo

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

func (*MsgSetPayees) MarshalToSizedBuffer

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

func (*MsgSetPayees) ProtoMessage

func (*MsgSetPayees) ProtoMessage()

func (*MsgSetPayees) Reset

func (m *MsgSetPayees) Reset()

func (MsgSetPayees) Route

func (msg MsgSetPayees) Route() string

Route implements the sdk.Msg interface. It should return the name of the module

func (*MsgSetPayees) Size

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

func (*MsgSetPayees) String

func (m *MsgSetPayees) String() string

func (MsgSetPayees) Type

func (msg MsgSetPayees) Type() string

Type implements the sdk.Msg interface. It should return the action.

func (*MsgSetPayees) Unmarshal

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

func (MsgSetPayees) ValidateBasic

func (msg MsgSetPayees) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface for MsgSetPayees.

func (*MsgSetPayees) XXX_DiscardUnknown

func (m *MsgSetPayees) XXX_DiscardUnknown()

func (*MsgSetPayees) XXX_Marshal

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

func (*MsgSetPayees) XXX_Merge

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

func (*MsgSetPayees) XXX_Size

func (m *MsgSetPayees) XXX_Size() int

func (*MsgSetPayees) XXX_Unmarshal

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

type MsgSetPayeesResponse

type MsgSetPayeesResponse struct {
}

func (*MsgSetPayeesResponse) Descriptor

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

func (*MsgSetPayeesResponse) Marshal

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

func (*MsgSetPayeesResponse) MarshalTo

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

func (*MsgSetPayeesResponse) MarshalToSizedBuffer

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

func (*MsgSetPayeesResponse) ProtoMessage

func (*MsgSetPayeesResponse) ProtoMessage()

func (*MsgSetPayeesResponse) Reset

func (m *MsgSetPayeesResponse) Reset()

func (*MsgSetPayeesResponse) Size

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

func (*MsgSetPayeesResponse) String

func (m *MsgSetPayeesResponse) String() string

func (*MsgSetPayeesResponse) Unmarshal

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

func (*MsgSetPayeesResponse) XXX_DiscardUnknown

func (m *MsgSetPayeesResponse) XXX_DiscardUnknown()

func (*MsgSetPayeesResponse) XXX_Marshal

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

func (*MsgSetPayeesResponse) XXX_Merge

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

func (*MsgSetPayeesResponse) XXX_Size

func (m *MsgSetPayeesResponse) XXX_Size() int

func (*MsgSetPayeesResponse) XXX_Unmarshal

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

type MsgTransferPayeeship

type MsgTransferPayeeship struct {
	// transmitter address of oracle whose payee is changing
	Sender      string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	Transmitter string `protobuf:"bytes,2,opt,name=transmitter,proto3" json:"transmitter,omitempty"`
	FeedId      string `protobuf:"bytes,3,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
	// new payee address
	Proposed string `protobuf:"bytes,4,opt,name=proposed,proto3" json:"proposed,omitempty"`
}

func (*MsgTransferPayeeship) Descriptor

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

func (*MsgTransferPayeeship) GetSignBytes

func (msg *MsgTransferPayeeship) GetSignBytes() []byte

GetSignBytes implements the sdk.Msg interface. It encodes the message for signing

func (MsgTransferPayeeship) GetSigners

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

GetSigners implements the sdk.Msg interface. It defines whose signature is required

func (*MsgTransferPayeeship) Marshal

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

func (*MsgTransferPayeeship) MarshalTo

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

func (*MsgTransferPayeeship) MarshalToSizedBuffer

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

func (*MsgTransferPayeeship) ProtoMessage

func (*MsgTransferPayeeship) ProtoMessage()

func (*MsgTransferPayeeship) Reset

func (m *MsgTransferPayeeship) Reset()

func (MsgTransferPayeeship) Route

func (msg MsgTransferPayeeship) Route() string

Route implements the sdk.Msg interface. It should return the name of the module

func (*MsgTransferPayeeship) Size

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

func (*MsgTransferPayeeship) String

func (m *MsgTransferPayeeship) String() string

func (MsgTransferPayeeship) Type

func (msg MsgTransferPayeeship) Type() string

Type implements the sdk.Msg interface. It should return the action.

func (*MsgTransferPayeeship) Unmarshal

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

func (MsgTransferPayeeship) ValidateBasic

func (msg MsgTransferPayeeship) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface for MsgTransferPayeeship.

func (*MsgTransferPayeeship) XXX_DiscardUnknown

func (m *MsgTransferPayeeship) XXX_DiscardUnknown()

func (*MsgTransferPayeeship) XXX_Marshal

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

func (*MsgTransferPayeeship) XXX_Merge

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

func (*MsgTransferPayeeship) XXX_Size

func (m *MsgTransferPayeeship) XXX_Size() int

func (*MsgTransferPayeeship) XXX_Unmarshal

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

type MsgTransferPayeeshipResponse

type MsgTransferPayeeshipResponse struct {
}

func (*MsgTransferPayeeshipResponse) Descriptor

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

func (*MsgTransferPayeeshipResponse) Marshal

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

func (*MsgTransferPayeeshipResponse) MarshalTo

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

func (*MsgTransferPayeeshipResponse) MarshalToSizedBuffer

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

func (*MsgTransferPayeeshipResponse) ProtoMessage

func (*MsgTransferPayeeshipResponse) ProtoMessage()

func (*MsgTransferPayeeshipResponse) Reset

func (m *MsgTransferPayeeshipResponse) Reset()

func (*MsgTransferPayeeshipResponse) Size

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

func (*MsgTransferPayeeshipResponse) String

func (*MsgTransferPayeeshipResponse) Unmarshal

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

func (*MsgTransferPayeeshipResponse) XXX_DiscardUnknown

func (m *MsgTransferPayeeshipResponse) XXX_DiscardUnknown()

func (*MsgTransferPayeeshipResponse) XXX_Marshal

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

func (*MsgTransferPayeeshipResponse) XXX_Merge

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

func (*MsgTransferPayeeshipResponse) XXX_Size

func (m *MsgTransferPayeeshipResponse) XXX_Size() int

func (*MsgTransferPayeeshipResponse) XXX_Unmarshal

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

type MsgTransmit

type MsgTransmit struct {
	// Address of the transmitter
	Transmitter  string   `protobuf:"bytes,1,opt,name=transmitter,proto3" json:"transmitter,omitempty"`
	ConfigDigest []byte   `protobuf:"bytes,2,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"`
	FeedId       string   `protobuf:"bytes,3,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
	Epoch        uint64   `protobuf:"varint,4,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Round        uint64   `protobuf:"varint,5,opt,name=round,proto3" json:"round,omitempty"`
	ExtraHash    []byte   `protobuf:"bytes,6,opt,name=extra_hash,json=extraHash,proto3" json:"extra_hash,omitempty"`
	Report       *Report  `protobuf:"bytes,7,opt,name=report,proto3" json:"report,omitempty"`
	Signatures   [][]byte `protobuf:"bytes,8,rep,name=signatures,proto3" json:"signatures,omitempty"`
}

func (*MsgTransmit) Descriptor

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

func (*MsgTransmit) GetSignBytes

func (msg *MsgTransmit) GetSignBytes() []byte

GetSignBytes implements the sdk.Msg interface. It encodes the message for signing

func (MsgTransmit) GetSigners

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

GetSigners implements the sdk.Msg interface. It defines whose signature is required

func (*MsgTransmit) Marshal

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

func (*MsgTransmit) MarshalTo

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

func (*MsgTransmit) MarshalToSizedBuffer

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

func (*MsgTransmit) ProtoMessage

func (*MsgTransmit) ProtoMessage()

func (*MsgTransmit) Reset

func (m *MsgTransmit) Reset()

func (MsgTransmit) Route

func (msg MsgTransmit) Route() string

Route implements the sdk.Msg interface. It should return the name of the module

func (*MsgTransmit) Size

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

func (*MsgTransmit) String

func (m *MsgTransmit) String() string

func (MsgTransmit) Type

func (msg MsgTransmit) Type() string

Type implements the sdk.Msg interface. It should return the action.

func (*MsgTransmit) Unmarshal

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

func (MsgTransmit) ValidateBasic

func (msg MsgTransmit) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface for MsgTransmit.

func (*MsgTransmit) XXX_DiscardUnknown

func (m *MsgTransmit) XXX_DiscardUnknown()

func (*MsgTransmit) XXX_Marshal

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

func (*MsgTransmit) XXX_Merge

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

func (*MsgTransmit) XXX_Size

func (m *MsgTransmit) XXX_Size() int

func (*MsgTransmit) XXX_Unmarshal

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

type MsgTransmitResponse

type MsgTransmitResponse struct {
}

func (*MsgTransmitResponse) Descriptor

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

func (*MsgTransmitResponse) Marshal

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

func (*MsgTransmitResponse) MarshalTo

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

func (*MsgTransmitResponse) MarshalToSizedBuffer

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

func (*MsgTransmitResponse) ProtoMessage

func (*MsgTransmitResponse) ProtoMessage()

func (*MsgTransmitResponse) Reset

func (m *MsgTransmitResponse) Reset()

func (*MsgTransmitResponse) Size

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

func (*MsgTransmitResponse) String

func (m *MsgTransmitResponse) String() string

func (*MsgTransmitResponse) Unmarshal

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

func (*MsgTransmitResponse) XXX_DiscardUnknown

func (m *MsgTransmitResponse) XXX_DiscardUnknown()

func (*MsgTransmitResponse) XXX_Marshal

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

func (*MsgTransmitResponse) XXX_Merge

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

func (*MsgTransmitResponse) XXX_Size

func (m *MsgTransmitResponse) XXX_Size() int

func (*MsgTransmitResponse) XXX_Unmarshal

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

type MsgUpdateFeed

type MsgUpdateFeed struct {
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// feed_id is an unique ID for the target of this config
	FeedId string `protobuf:"bytes,2,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
	// signers ith element is address ith oracle uses to sign a report
	Signers []string `protobuf:"bytes,3,rep,name=signers,proto3" json:"signers,omitempty"`
	// transmitters ith element is address ith oracle uses to transmit a report
	// via the transmit method
	Transmitters []string `protobuf:"bytes,4,rep,name=transmitters,proto3" json:"transmitters,omitempty"`
	// Fixed LINK reward for each observer
	LinkPerObservation *github_com_cosmos_cosmos_sdk_types.Int `` /* 167-byte string literal not displayed */
	// Fixed LINK reward for transmitter
	LinkPerTransmission *github_com_cosmos_cosmos_sdk_types.Int `` /* 170-byte string literal not displayed */
	// Native denom for LINK coin in the bank keeper
	LinkDenom string `protobuf:"bytes,7,opt,name=link_denom,json=linkDenom,proto3" json:"link_denom,omitempty"`
	// feed administrator
	FeedAdmin string `protobuf:"bytes,8,opt,name=feed_admin,json=feedAdmin,proto3" json:"feed_admin,omitempty"`
	// feed billing administrator
	BillingAdmin string `protobuf:"bytes,9,opt,name=billing_admin,json=billingAdmin,proto3" json:"billing_admin,omitempty"`
}

func (*MsgUpdateFeed) Descriptor

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

func (*MsgUpdateFeed) GetSignBytes

func (msg *MsgUpdateFeed) GetSignBytes() []byte

GetSignBytes implements the sdk.Msg interface. It encodes the message for signing

func (MsgUpdateFeed) GetSigners

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

GetSigners implements the sdk.Msg interface. It defines whose signature is required

func (*MsgUpdateFeed) Marshal

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

func (*MsgUpdateFeed) MarshalTo

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

func (*MsgUpdateFeed) MarshalToSizedBuffer

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

func (*MsgUpdateFeed) ProtoMessage

func (*MsgUpdateFeed) ProtoMessage()

func (*MsgUpdateFeed) Reset

func (m *MsgUpdateFeed) Reset()

func (MsgUpdateFeed) Route

func (msg MsgUpdateFeed) Route() string

Route implements the sdk.Msg interface. It should return the name of the module

func (*MsgUpdateFeed) Size

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

func (*MsgUpdateFeed) String

func (m *MsgUpdateFeed) String() string

func (MsgUpdateFeed) Type

func (msg MsgUpdateFeed) Type() string

Type implements the sdk.Msg interface. It should return the action.

func (*MsgUpdateFeed) Unmarshal

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

func (MsgUpdateFeed) ValidateBasic

func (msg MsgUpdateFeed) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface for MsgUpdateFeed.

func (*MsgUpdateFeed) XXX_DiscardUnknown

func (m *MsgUpdateFeed) XXX_DiscardUnknown()

func (*MsgUpdateFeed) XXX_Marshal

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

func (*MsgUpdateFeed) XXX_Merge

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

func (*MsgUpdateFeed) XXX_Size

func (m *MsgUpdateFeed) XXX_Size() int

func (*MsgUpdateFeed) XXX_Unmarshal

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

type MsgUpdateFeedResponse

type MsgUpdateFeedResponse struct {
}

func (*MsgUpdateFeedResponse) Descriptor

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

func (*MsgUpdateFeedResponse) Marshal

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

func (*MsgUpdateFeedResponse) MarshalTo

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

func (*MsgUpdateFeedResponse) MarshalToSizedBuffer

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

func (*MsgUpdateFeedResponse) ProtoMessage

func (*MsgUpdateFeedResponse) ProtoMessage()

func (*MsgUpdateFeedResponse) Reset

func (m *MsgUpdateFeedResponse) Reset()

func (*MsgUpdateFeedResponse) Size

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

func (*MsgUpdateFeedResponse) String

func (m *MsgUpdateFeedResponse) String() string

func (*MsgUpdateFeedResponse) Unmarshal

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

func (*MsgUpdateFeedResponse) XXX_DiscardUnknown

func (m *MsgUpdateFeedResponse) XXX_DiscardUnknown()

func (*MsgUpdateFeedResponse) XXX_Marshal

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

func (*MsgUpdateFeedResponse) XXX_Merge

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

func (*MsgUpdateFeedResponse) XXX_Size

func (m *MsgUpdateFeedResponse) XXX_Size() int

func (*MsgUpdateFeedResponse) XXX_Unmarshal

func (m *MsgUpdateFeedResponse) 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 defines the ocr parameters to update.
	//
	// NOTE: All parameters must be supplied.
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

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

func (msg *MsgUpdateParams) GetSignBytes() []byte

GetSignBytes implements the sdk.Msg interface. It encodes the message for signing

func (MsgUpdateParams) GetSigners

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

GetSigners implements the sdk.Msg interface. It defines whose signature is required

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

func (msg MsgUpdateParams) Route() string

Route implements the sdk.Msg interface. It should return the name of the module

func (*MsgUpdateParams) Size

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

func (*MsgUpdateParams) String

func (m *MsgUpdateParams) String() string

func (MsgUpdateParams) Type

func (msg MsgUpdateParams) Type() string

Type implements the sdk.Msg interface. It should return the action.

func (*MsgUpdateParams) Unmarshal

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

func (MsgUpdateParams) ValidateBasic

func (msg MsgUpdateParams) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface for MsgUpdateParams.

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 {
}

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 MsgWithdrawFeedRewardPool

type MsgWithdrawFeedRewardPool struct {
	Sender string     `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	FeedId string     `protobuf:"bytes,2,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
	Amount types.Coin `protobuf:"bytes,3,opt,name=amount,proto3" json:"amount"`
}

func (*MsgWithdrawFeedRewardPool) Descriptor

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

func (*MsgWithdrawFeedRewardPool) GetSignBytes

func (msg *MsgWithdrawFeedRewardPool) GetSignBytes() []byte

GetSignBytes implements the sdk.Msg interface. It encodes the message for signing

func (MsgWithdrawFeedRewardPool) GetSigners

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

GetSigners implements the sdk.Msg interface. It defines whose signature is required

func (*MsgWithdrawFeedRewardPool) Marshal

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

func (*MsgWithdrawFeedRewardPool) MarshalTo

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

func (*MsgWithdrawFeedRewardPool) MarshalToSizedBuffer

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

func (*MsgWithdrawFeedRewardPool) ProtoMessage

func (*MsgWithdrawFeedRewardPool) ProtoMessage()

func (*MsgWithdrawFeedRewardPool) Reset

func (m *MsgWithdrawFeedRewardPool) Reset()

func (MsgWithdrawFeedRewardPool) Route

func (msg MsgWithdrawFeedRewardPool) Route() string

Route implements the sdk.Msg interface. It should return the name of the module

func (*MsgWithdrawFeedRewardPool) Size

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

func (*MsgWithdrawFeedRewardPool) String

func (m *MsgWithdrawFeedRewardPool) String() string

func (MsgWithdrawFeedRewardPool) Type

func (msg MsgWithdrawFeedRewardPool) Type() string

Type implements the sdk.Msg interface. It should return the action.

func (*MsgWithdrawFeedRewardPool) Unmarshal

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

func (MsgWithdrawFeedRewardPool) ValidateBasic

func (msg MsgWithdrawFeedRewardPool) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface for MsgWithdrawFeedRewardPool.

func (*MsgWithdrawFeedRewardPool) XXX_DiscardUnknown

func (m *MsgWithdrawFeedRewardPool) XXX_DiscardUnknown()

func (*MsgWithdrawFeedRewardPool) XXX_Marshal

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

func (*MsgWithdrawFeedRewardPool) XXX_Merge

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

func (*MsgWithdrawFeedRewardPool) XXX_Size

func (m *MsgWithdrawFeedRewardPool) XXX_Size() int

func (*MsgWithdrawFeedRewardPool) XXX_Unmarshal

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

type MsgWithdrawFeedRewardPoolResponse

type MsgWithdrawFeedRewardPoolResponse struct {
}

func (*MsgWithdrawFeedRewardPoolResponse) Descriptor

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

func (*MsgWithdrawFeedRewardPoolResponse) Marshal

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

func (*MsgWithdrawFeedRewardPoolResponse) MarshalTo

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

func (*MsgWithdrawFeedRewardPoolResponse) MarshalToSizedBuffer

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

func (*MsgWithdrawFeedRewardPoolResponse) ProtoMessage

func (*MsgWithdrawFeedRewardPoolResponse) ProtoMessage()

func (*MsgWithdrawFeedRewardPoolResponse) Reset

func (*MsgWithdrawFeedRewardPoolResponse) Size

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

func (*MsgWithdrawFeedRewardPoolResponse) String

func (*MsgWithdrawFeedRewardPoolResponse) Unmarshal

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

func (*MsgWithdrawFeedRewardPoolResponse) XXX_DiscardUnknown

func (m *MsgWithdrawFeedRewardPoolResponse) XXX_DiscardUnknown()

func (*MsgWithdrawFeedRewardPoolResponse) XXX_Marshal

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

func (*MsgWithdrawFeedRewardPoolResponse) XXX_Merge

func (*MsgWithdrawFeedRewardPoolResponse) XXX_Size

func (m *MsgWithdrawFeedRewardPoolResponse) XXX_Size() int

func (*MsgWithdrawFeedRewardPoolResponse) XXX_Unmarshal

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

type MultiOcrHooks

type MultiOcrHooks []OcrHooks

func NewMultiOcrHooks

func NewMultiOcrHooks(hooks ...OcrHooks) MultiOcrHooks

func (MultiOcrHooks) AfterFundFeedRewardPool

func (h MultiOcrHooks) AfterFundFeedRewardPool(ctx sdk.Context, feedId string, newPoolAmount sdk.Coin)

func (MultiOcrHooks) AfterSetFeedConfig

func (h MultiOcrHooks) AfterSetFeedConfig(ctx sdk.Context, feedConfig *FeedConfig)

func (MultiOcrHooks) AfterTransmit

func (h MultiOcrHooks) AfterTransmit(ctx sdk.Context, feedId string, answer sdk.Dec, timestamp int64)

type OcrHooks

type OcrHooks interface {
	AfterSetFeedConfig(ctx sdk.Context, feedConfig *FeedConfig)
	AfterTransmit(ctx sdk.Context, feedId string, answer sdk.Dec, timestamp int64)
	AfterFundFeedRewardPool(ctx sdk.Context, feedId string, newPoolAmount sdk.Coin)
}

type OracleObservationsCounts

type OracleObservationsCounts struct {
	Counts []uint32 `protobuf:"varint,1,rep,packed,name=counts,proto3" json:"counts,omitempty"`
}

func (*OracleObservationsCounts) Descriptor

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

func (*OracleObservationsCounts) GetCounts

func (m *OracleObservationsCounts) GetCounts() []uint32

func (*OracleObservationsCounts) Marshal

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

func (*OracleObservationsCounts) MarshalTo

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

func (*OracleObservationsCounts) MarshalToSizedBuffer

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

func (*OracleObservationsCounts) ProtoMessage

func (*OracleObservationsCounts) ProtoMessage()

func (*OracleObservationsCounts) Reset

func (m *OracleObservationsCounts) Reset()

func (*OracleObservationsCounts) Size

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

func (*OracleObservationsCounts) String

func (m *OracleObservationsCounts) String() string

func (*OracleObservationsCounts) Unmarshal

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

func (*OracleObservationsCounts) XXX_DiscardUnknown

func (m *OracleObservationsCounts) XXX_DiscardUnknown()

func (*OracleObservationsCounts) XXX_Marshal

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

func (*OracleObservationsCounts) XXX_Merge

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

func (*OracleObservationsCounts) XXX_Size

func (m *OracleObservationsCounts) XXX_Size() int

func (*OracleObservationsCounts) XXX_Unmarshal

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

type ParamSubspace

type ParamSubspace interface {
	WithKeyTable(table params.KeyTable) params.Subspace
	Get(ctx sdk.Context, key []byte, ptr interface{})
	GetParamSet(ctx sdk.Context, ps params.ParamSet)
	SetParamSet(ctx sdk.Context, ps params.ParamSet)
}

ParamSubspace defines the expected Subspace interfacace

type Params

type Params struct {
	// Native denom for LINK coin in the bank keeper
	LinkDenom string `protobuf:"bytes,1,opt,name=link_denom,json=linkDenom,proto3" json:"link_denom,omitempty"`
	// The block number interval at which payouts are made
	PayoutBlockInterval uint64 `protobuf:"varint,2,opt,name=payout_block_interval,json=payoutBlockInterval,proto3" json:"payout_block_interval,omitempty"`
	// The admin for the OCR module
	ModuleAdmin string `protobuf:"bytes,3,opt,name=module_admin,json=moduleAdmin,proto3" json:"module_admin,omitempty"`
}

func DefaultParams

func DefaultParams() Params

DefaultParams returns a default set of parameters.

func NewParams

func NewParams(
	linkDenom string,
	payoutInterval uint64,
	moduleAdmin sdk.AccAddress,
) 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) GetLinkDenom

func (m *Params) GetLinkDenom() string

func (*Params) GetModuleAdmin

func (m *Params) GetModuleAdmin() string

func (*Params) GetPayoutBlockInterval

func (m *Params) GetPayoutBlockInterval() uint64

func (*Params) Marshal

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

func (*Params) MarshalTo

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

func (*Params) MarshalToSizedBuffer

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

func (*Params) ParamSetPairs

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

ParamSetPairs returns the parameter set pairs.

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 performs basic validation on insurance parameters.

func (*Params) XXX_DiscardUnknown

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal

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

func (*Params) XXX_Merge

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

func (*Params) XXX_Size

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal

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

type Payee

type Payee struct {
	TransmitterAddr string `protobuf:"bytes,1,opt,name=transmitter_addr,json=transmitterAddr,proto3" json:"transmitter_addr,omitempty"`
	PaymentAddr     string `protobuf:"bytes,2,opt,name=payment_addr,json=paymentAddr,proto3" json:"payment_addr,omitempty"`
}

func (*Payee) Descriptor

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

func (*Payee) GetPaymentAddr

func (m *Payee) GetPaymentAddr() string

func (*Payee) GetTransmitterAddr

func (m *Payee) GetTransmitterAddr() string

func (*Payee) Marshal

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

func (*Payee) MarshalTo

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

func (*Payee) MarshalToSizedBuffer

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

func (*Payee) ProtoMessage

func (*Payee) ProtoMessage()

func (*Payee) Reset

func (m *Payee) Reset()

func (*Payee) Size

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

func (*Payee) String

func (m *Payee) String() string

func (*Payee) Unmarshal

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

func (*Payee) XXX_DiscardUnknown

func (m *Payee) XXX_DiscardUnknown()

func (*Payee) XXX_Marshal

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

func (*Payee) XXX_Merge

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

func (*Payee) XXX_Size

func (m *Payee) XXX_Size() int

func (*Payee) XXX_Unmarshal

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

type PendingPayeeship

type PendingPayeeship struct {
	FeedId        string `protobuf:"bytes,1,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
	Transmitter   string `protobuf:"bytes,2,opt,name=transmitter,proto3" json:"transmitter,omitempty"`
	ProposedPayee string `protobuf:"bytes,3,opt,name=proposed_payee,json=proposedPayee,proto3" json:"proposed_payee,omitempty"`
}

func (*PendingPayeeship) Descriptor

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

func (*PendingPayeeship) GetFeedId

func (m *PendingPayeeship) GetFeedId() string

func (*PendingPayeeship) GetProposedPayee

func (m *PendingPayeeship) GetProposedPayee() string

func (*PendingPayeeship) GetTransmitter

func (m *PendingPayeeship) GetTransmitter() string

func (*PendingPayeeship) Marshal

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

func (*PendingPayeeship) MarshalTo

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

func (*PendingPayeeship) MarshalToSizedBuffer

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

func (*PendingPayeeship) ProtoMessage

func (*PendingPayeeship) ProtoMessage()

func (*PendingPayeeship) Reset

func (m *PendingPayeeship) Reset()

func (*PendingPayeeship) Size

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

func (*PendingPayeeship) String

func (m *PendingPayeeship) String() string

func (*PendingPayeeship) Unmarshal

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

func (*PendingPayeeship) XXX_DiscardUnknown

func (m *PendingPayeeship) XXX_DiscardUnknown()

func (*PendingPayeeship) XXX_Marshal

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

func (*PendingPayeeship) XXX_Merge

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

func (*PendingPayeeship) XXX_Size

func (m *PendingPayeeship) XXX_Size() int

func (*PendingPayeeship) XXX_Unmarshal

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

type QueryClient

type QueryClient interface {
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// Retrieves the OCR FeedConfig for a given FeedId
	FeedConfig(ctx context.Context, in *QueryFeedConfigRequest, opts ...grpc.CallOption) (*QueryFeedConfigResponse, error)
	// Retrieves the OCR FeedConfigInfo for a given FeedId
	FeedConfigInfo(ctx context.Context, in *QueryFeedConfigInfoRequest, opts ...grpc.CallOption) (*QueryFeedConfigInfoResponse, error)
	// Retrieves latest round ID and data, including median answer for that round
	LatestRound(ctx context.Context, in *QueryLatestRoundRequest, opts ...grpc.CallOption) (*QueryLatestRoundResponse, error)
	// LatestTransmissionDetails returns details about the latest trasmission
	// recorded on chain for the given feed ID.
	LatestTransmissionDetails(ctx context.Context, in *QueryLatestTransmissionDetailsRequest, opts ...grpc.CallOption) (*QueryLatestTransmissionDetailsResponse, error)
	// Retrieves transmitter's owed amount
	OwedAmount(ctx context.Context, in *QueryOwedAmountRequest, opts ...grpc.CallOption) (*QueryOwedAmountResponse, error)
	// Retrieves the entire OCR module's state
	OcrModuleState(ctx context.Context, in *QueryModuleStateRequest, opts ...grpc.CallOption) (*QueryModuleStateResponse, 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 QueryFeedConfigInfoRequest

type QueryFeedConfigInfoRequest struct {
	FeedId string `protobuf:"bytes,1,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
}

func (*QueryFeedConfigInfoRequest) Descriptor

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

func (*QueryFeedConfigInfoRequest) GetFeedId

func (m *QueryFeedConfigInfoRequest) GetFeedId() string

func (*QueryFeedConfigInfoRequest) Marshal

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

func (*QueryFeedConfigInfoRequest) MarshalTo

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

func (*QueryFeedConfigInfoRequest) MarshalToSizedBuffer

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

func (*QueryFeedConfigInfoRequest) ProtoMessage

func (*QueryFeedConfigInfoRequest) ProtoMessage()

func (*QueryFeedConfigInfoRequest) Reset

func (m *QueryFeedConfigInfoRequest) Reset()

func (*QueryFeedConfigInfoRequest) Size

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

func (*QueryFeedConfigInfoRequest) String

func (m *QueryFeedConfigInfoRequest) String() string

func (*QueryFeedConfigInfoRequest) Unmarshal

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

func (*QueryFeedConfigInfoRequest) XXX_DiscardUnknown

func (m *QueryFeedConfigInfoRequest) XXX_DiscardUnknown()

func (*QueryFeedConfigInfoRequest) XXX_Marshal

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

func (*QueryFeedConfigInfoRequest) XXX_Merge

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

func (*QueryFeedConfigInfoRequest) XXX_Size

func (m *QueryFeedConfigInfoRequest) XXX_Size() int

func (*QueryFeedConfigInfoRequest) XXX_Unmarshal

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

type QueryFeedConfigInfoResponse

type QueryFeedConfigInfoResponse struct {
	FeedConfigInfo *FeedConfigInfo `protobuf:"bytes,1,opt,name=feed_config_info,json=feedConfigInfo,proto3" json:"feed_config_info,omitempty"`
	EpochAndRound  *EpochAndRound  `protobuf:"bytes,2,opt,name=epoch_and_round,json=epochAndRound,proto3" json:"epoch_and_round,omitempty"`
}

func (*QueryFeedConfigInfoResponse) Descriptor

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

func (*QueryFeedConfigInfoResponse) GetEpochAndRound

func (m *QueryFeedConfigInfoResponse) GetEpochAndRound() *EpochAndRound

func (*QueryFeedConfigInfoResponse) GetFeedConfigInfo

func (m *QueryFeedConfigInfoResponse) GetFeedConfigInfo() *FeedConfigInfo

func (*QueryFeedConfigInfoResponse) Marshal

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

func (*QueryFeedConfigInfoResponse) MarshalTo

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

func (*QueryFeedConfigInfoResponse) MarshalToSizedBuffer

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

func (*QueryFeedConfigInfoResponse) ProtoMessage

func (*QueryFeedConfigInfoResponse) ProtoMessage()

func (*QueryFeedConfigInfoResponse) Reset

func (m *QueryFeedConfigInfoResponse) Reset()

func (*QueryFeedConfigInfoResponse) Size

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

func (*QueryFeedConfigInfoResponse) String

func (m *QueryFeedConfigInfoResponse) String() string

func (*QueryFeedConfigInfoResponse) Unmarshal

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

func (*QueryFeedConfigInfoResponse) XXX_DiscardUnknown

func (m *QueryFeedConfigInfoResponse) XXX_DiscardUnknown()

func (*QueryFeedConfigInfoResponse) XXX_Marshal

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

func (*QueryFeedConfigInfoResponse) XXX_Merge

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

func (*QueryFeedConfigInfoResponse) XXX_Size

func (m *QueryFeedConfigInfoResponse) XXX_Size() int

func (*QueryFeedConfigInfoResponse) XXX_Unmarshal

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

type QueryFeedConfigRequest

type QueryFeedConfigRequest struct {
	FeedId string `protobuf:"bytes,1,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
}

func (*QueryFeedConfigRequest) Descriptor

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

func (*QueryFeedConfigRequest) GetFeedId

func (m *QueryFeedConfigRequest) GetFeedId() string

func (*QueryFeedConfigRequest) Marshal

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

func (*QueryFeedConfigRequest) MarshalTo

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

func (*QueryFeedConfigRequest) MarshalToSizedBuffer

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

func (*QueryFeedConfigRequest) ProtoMessage

func (*QueryFeedConfigRequest) ProtoMessage()

func (*QueryFeedConfigRequest) Reset

func (m *QueryFeedConfigRequest) Reset()

func (*QueryFeedConfigRequest) Size

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

func (*QueryFeedConfigRequest) String

func (m *QueryFeedConfigRequest) String() string

func (*QueryFeedConfigRequest) Unmarshal

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

func (*QueryFeedConfigRequest) XXX_DiscardUnknown

func (m *QueryFeedConfigRequest) XXX_DiscardUnknown()

func (*QueryFeedConfigRequest) XXX_Marshal

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

func (*QueryFeedConfigRequest) XXX_Merge

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

func (*QueryFeedConfigRequest) XXX_Size

func (m *QueryFeedConfigRequest) XXX_Size() int

func (*QueryFeedConfigRequest) XXX_Unmarshal

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

type QueryFeedConfigResponse

type QueryFeedConfigResponse struct {
	FeedConfigInfo *FeedConfigInfo `protobuf:"bytes,1,opt,name=feed_config_info,json=feedConfigInfo,proto3" json:"feed_config_info,omitempty"`
	FeedConfig     *FeedConfig     `protobuf:"bytes,2,opt,name=feed_config,json=feedConfig,proto3" json:"feed_config,omitempty"`
}

func (*QueryFeedConfigResponse) Descriptor

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

func (*QueryFeedConfigResponse) GetFeedConfig

func (m *QueryFeedConfigResponse) GetFeedConfig() *FeedConfig

func (*QueryFeedConfigResponse) GetFeedConfigInfo

func (m *QueryFeedConfigResponse) GetFeedConfigInfo() *FeedConfigInfo

func (*QueryFeedConfigResponse) Marshal

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

func (*QueryFeedConfigResponse) MarshalTo

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

func (*QueryFeedConfigResponse) MarshalToSizedBuffer

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

func (*QueryFeedConfigResponse) ProtoMessage

func (*QueryFeedConfigResponse) ProtoMessage()

func (*QueryFeedConfigResponse) Reset

func (m *QueryFeedConfigResponse) Reset()

func (*QueryFeedConfigResponse) Size

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

func (*QueryFeedConfigResponse) String

func (m *QueryFeedConfigResponse) String() string

func (*QueryFeedConfigResponse) Unmarshal

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

func (*QueryFeedConfigResponse) XXX_DiscardUnknown

func (m *QueryFeedConfigResponse) XXX_DiscardUnknown()

func (*QueryFeedConfigResponse) XXX_Marshal

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

func (*QueryFeedConfigResponse) XXX_Merge

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

func (*QueryFeedConfigResponse) XXX_Size

func (m *QueryFeedConfigResponse) XXX_Size() int

func (*QueryFeedConfigResponse) XXX_Unmarshal

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

type QueryLatestRoundRequest

type QueryLatestRoundRequest struct {
	FeedId string `protobuf:"bytes,1,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
}

func (*QueryLatestRoundRequest) Descriptor

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

func (*QueryLatestRoundRequest) GetFeedId

func (m *QueryLatestRoundRequest) GetFeedId() string

func (*QueryLatestRoundRequest) Marshal

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

func (*QueryLatestRoundRequest) MarshalTo

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

func (*QueryLatestRoundRequest) MarshalToSizedBuffer

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

func (*QueryLatestRoundRequest) ProtoMessage

func (*QueryLatestRoundRequest) ProtoMessage()

func (*QueryLatestRoundRequest) Reset

func (m *QueryLatestRoundRequest) Reset()

func (*QueryLatestRoundRequest) Size

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

func (*QueryLatestRoundRequest) String

func (m *QueryLatestRoundRequest) String() string

func (*QueryLatestRoundRequest) Unmarshal

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

func (*QueryLatestRoundRequest) XXX_DiscardUnknown

func (m *QueryLatestRoundRequest) XXX_DiscardUnknown()

func (*QueryLatestRoundRequest) XXX_Marshal

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

func (*QueryLatestRoundRequest) XXX_Merge

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

func (*QueryLatestRoundRequest) XXX_Size

func (m *QueryLatestRoundRequest) XXX_Size() int

func (*QueryLatestRoundRequest) XXX_Unmarshal

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

type QueryLatestRoundResponse

type QueryLatestRoundResponse struct {
	LatestRoundId uint64        `protobuf:"varint,1,opt,name=latest_round_id,json=latestRoundId,proto3" json:"latest_round_id,omitempty"`
	Data          *Transmission `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*QueryLatestRoundResponse) Descriptor

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

func (*QueryLatestRoundResponse) GetData

func (m *QueryLatestRoundResponse) GetData() *Transmission

func (*QueryLatestRoundResponse) GetLatestRoundId

func (m *QueryLatestRoundResponse) GetLatestRoundId() uint64

func (*QueryLatestRoundResponse) Marshal

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

func (*QueryLatestRoundResponse) MarshalTo

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

func (*QueryLatestRoundResponse) MarshalToSizedBuffer

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

func (*QueryLatestRoundResponse) ProtoMessage

func (*QueryLatestRoundResponse) ProtoMessage()

func (*QueryLatestRoundResponse) Reset

func (m *QueryLatestRoundResponse) Reset()

func (*QueryLatestRoundResponse) Size

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

func (*QueryLatestRoundResponse) String

func (m *QueryLatestRoundResponse) String() string

func (*QueryLatestRoundResponse) Unmarshal

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

func (*QueryLatestRoundResponse) XXX_DiscardUnknown

func (m *QueryLatestRoundResponse) XXX_DiscardUnknown()

func (*QueryLatestRoundResponse) XXX_Marshal

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

func (*QueryLatestRoundResponse) XXX_Merge

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

func (*QueryLatestRoundResponse) XXX_Size

func (m *QueryLatestRoundResponse) XXX_Size() int

func (*QueryLatestRoundResponse) XXX_Unmarshal

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

type QueryLatestTransmissionDetailsRequest

type QueryLatestTransmissionDetailsRequest struct {
	FeedId string `protobuf:"bytes,1,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
}

func (*QueryLatestTransmissionDetailsRequest) Descriptor

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

func (*QueryLatestTransmissionDetailsRequest) GetFeedId

func (*QueryLatestTransmissionDetailsRequest) Marshal

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

func (*QueryLatestTransmissionDetailsRequest) MarshalTo

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

func (*QueryLatestTransmissionDetailsRequest) MarshalToSizedBuffer

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

func (*QueryLatestTransmissionDetailsRequest) ProtoMessage

func (*QueryLatestTransmissionDetailsRequest) ProtoMessage()

func (*QueryLatestTransmissionDetailsRequest) Reset

func (*QueryLatestTransmissionDetailsRequest) Size

func (*QueryLatestTransmissionDetailsRequest) String

func (*QueryLatestTransmissionDetailsRequest) Unmarshal

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

func (*QueryLatestTransmissionDetailsRequest) XXX_DiscardUnknown

func (m *QueryLatestTransmissionDetailsRequest) XXX_DiscardUnknown()

func (*QueryLatestTransmissionDetailsRequest) XXX_Marshal

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

func (*QueryLatestTransmissionDetailsRequest) XXX_Merge

func (*QueryLatestTransmissionDetailsRequest) XXX_Size

func (*QueryLatestTransmissionDetailsRequest) XXX_Unmarshal

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

type QueryLatestTransmissionDetailsResponse

type QueryLatestTransmissionDetailsResponse struct {
	ConfigDigest  []byte         `protobuf:"bytes,1,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"`
	EpochAndRound *EpochAndRound `protobuf:"bytes,2,opt,name=epoch_and_round,json=epochAndRound,proto3" json:"epoch_and_round,omitempty"`
	Data          *Transmission  `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}

func (*QueryLatestTransmissionDetailsResponse) Descriptor

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

func (*QueryLatestTransmissionDetailsResponse) GetConfigDigest

func (m *QueryLatestTransmissionDetailsResponse) GetConfigDigest() []byte

func (*QueryLatestTransmissionDetailsResponse) GetData

func (*QueryLatestTransmissionDetailsResponse) GetEpochAndRound

func (*QueryLatestTransmissionDetailsResponse) Marshal

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

func (*QueryLatestTransmissionDetailsResponse) MarshalTo

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

func (*QueryLatestTransmissionDetailsResponse) MarshalToSizedBuffer

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

func (*QueryLatestTransmissionDetailsResponse) ProtoMessage

func (*QueryLatestTransmissionDetailsResponse) Reset

func (*QueryLatestTransmissionDetailsResponse) Size

func (*QueryLatestTransmissionDetailsResponse) String

func (*QueryLatestTransmissionDetailsResponse) Unmarshal

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

func (*QueryLatestTransmissionDetailsResponse) XXX_DiscardUnknown

func (m *QueryLatestTransmissionDetailsResponse) XXX_DiscardUnknown()

func (*QueryLatestTransmissionDetailsResponse) XXX_Marshal

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

func (*QueryLatestTransmissionDetailsResponse) XXX_Merge

func (*QueryLatestTransmissionDetailsResponse) XXX_Size

func (*QueryLatestTransmissionDetailsResponse) XXX_Unmarshal

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

type QueryModuleStateRequest

type QueryModuleStateRequest struct {
}

func (*QueryModuleStateRequest) Descriptor

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

func (*QueryModuleStateRequest) Marshal

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

func (*QueryModuleStateRequest) MarshalTo

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

func (*QueryModuleStateRequest) MarshalToSizedBuffer

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

func (*QueryModuleStateRequest) ProtoMessage

func (*QueryModuleStateRequest) ProtoMessage()

func (*QueryModuleStateRequest) Reset

func (m *QueryModuleStateRequest) Reset()

func (*QueryModuleStateRequest) Size

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

func (*QueryModuleStateRequest) String

func (m *QueryModuleStateRequest) String() string

func (*QueryModuleStateRequest) Unmarshal

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

func (*QueryModuleStateRequest) XXX_DiscardUnknown

func (m *QueryModuleStateRequest) XXX_DiscardUnknown()

func (*QueryModuleStateRequest) XXX_Marshal

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

func (*QueryModuleStateRequest) XXX_Merge

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

func (*QueryModuleStateRequest) XXX_Size

func (m *QueryModuleStateRequest) XXX_Size() int

func (*QueryModuleStateRequest) XXX_Unmarshal

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

type QueryModuleStateResponse

type QueryModuleStateResponse struct {
	State *GenesisState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
}

func (*QueryModuleStateResponse) Descriptor

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

func (*QueryModuleStateResponse) GetState

func (m *QueryModuleStateResponse) GetState() *GenesisState

func (*QueryModuleStateResponse) Marshal

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

func (*QueryModuleStateResponse) MarshalTo

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

func (*QueryModuleStateResponse) MarshalToSizedBuffer

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

func (*QueryModuleStateResponse) ProtoMessage

func (*QueryModuleStateResponse) ProtoMessage()

func (*QueryModuleStateResponse) Reset

func (m *QueryModuleStateResponse) Reset()

func (*QueryModuleStateResponse) Size

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

func (*QueryModuleStateResponse) String

func (m *QueryModuleStateResponse) String() string

func (*QueryModuleStateResponse) Unmarshal

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

func (*QueryModuleStateResponse) XXX_DiscardUnknown

func (m *QueryModuleStateResponse) XXX_DiscardUnknown()

func (*QueryModuleStateResponse) XXX_Marshal

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

func (*QueryModuleStateResponse) XXX_Merge

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

func (*QueryModuleStateResponse) XXX_Size

func (m *QueryModuleStateResponse) XXX_Size() int

func (*QueryModuleStateResponse) XXX_Unmarshal

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

type QueryOwedAmountRequest

type QueryOwedAmountRequest struct {
	Transmitter string `protobuf:"bytes,1,opt,name=transmitter,proto3" json:"transmitter,omitempty"`
}

func (*QueryOwedAmountRequest) Descriptor

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

func (*QueryOwedAmountRequest) GetTransmitter

func (m *QueryOwedAmountRequest) GetTransmitter() string

func (*QueryOwedAmountRequest) Marshal

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

func (*QueryOwedAmountRequest) MarshalTo

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

func (*QueryOwedAmountRequest) MarshalToSizedBuffer

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

func (*QueryOwedAmountRequest) ProtoMessage

func (*QueryOwedAmountRequest) ProtoMessage()

func (*QueryOwedAmountRequest) Reset

func (m *QueryOwedAmountRequest) Reset()

func (*QueryOwedAmountRequest) Size

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

func (*QueryOwedAmountRequest) String

func (m *QueryOwedAmountRequest) String() string

func (*QueryOwedAmountRequest) Unmarshal

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

func (*QueryOwedAmountRequest) XXX_DiscardUnknown

func (m *QueryOwedAmountRequest) XXX_DiscardUnknown()

func (*QueryOwedAmountRequest) XXX_Marshal

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

func (*QueryOwedAmountRequest) XXX_Merge

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

func (*QueryOwedAmountRequest) XXX_Size

func (m *QueryOwedAmountRequest) XXX_Size() int

func (*QueryOwedAmountRequest) XXX_Unmarshal

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

type QueryOwedAmountResponse

type QueryOwedAmountResponse struct {
	Amount types.Coin `protobuf:"bytes,1,opt,name=amount,proto3" json:"amount"`
}

func (*QueryOwedAmountResponse) Descriptor

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

func (*QueryOwedAmountResponse) GetAmount

func (m *QueryOwedAmountResponse) GetAmount() types.Coin

func (*QueryOwedAmountResponse) Marshal

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

func (*QueryOwedAmountResponse) MarshalTo

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

func (*QueryOwedAmountResponse) MarshalToSizedBuffer

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

func (*QueryOwedAmountResponse) ProtoMessage

func (*QueryOwedAmountResponse) ProtoMessage()

func (*QueryOwedAmountResponse) Reset

func (m *QueryOwedAmountResponse) Reset()

func (*QueryOwedAmountResponse) Size

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

func (*QueryOwedAmountResponse) String

func (m *QueryOwedAmountResponse) String() string

func (*QueryOwedAmountResponse) Unmarshal

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

func (*QueryOwedAmountResponse) XXX_DiscardUnknown

func (m *QueryOwedAmountResponse) XXX_DiscardUnknown()

func (*QueryOwedAmountResponse) XXX_Marshal

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

func (*QueryOwedAmountResponse) XXX_Merge

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

func (*QueryOwedAmountResponse) XXX_Size

func (m *QueryOwedAmountResponse) XXX_Size() int

func (*QueryOwedAmountResponse) XXX_Unmarshal

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

type QueryParamsRequest

type QueryParamsRequest struct {
}

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 Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

func (*QueryParamsResponse) Descriptor

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

func (*QueryParamsResponse) GetParams

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal

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

func (*QueryParamsResponse) MarshalTo

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

func (*QueryParamsResponse) MarshalToSizedBuffer

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

func (*QueryParamsResponse) ProtoMessage

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size

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

func (*QueryParamsResponse) String

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal

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

func (*QueryParamsResponse) XXX_DiscardUnknown

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal

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

func (*QueryParamsResponse) XXX_Merge

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

func (*QueryParamsResponse) XXX_Size

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal

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

type QueryServer

type QueryServer interface {
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// Retrieves the OCR FeedConfig for a given FeedId
	FeedConfig(context.Context, *QueryFeedConfigRequest) (*QueryFeedConfigResponse, error)
	// Retrieves the OCR FeedConfigInfo for a given FeedId
	FeedConfigInfo(context.Context, *QueryFeedConfigInfoRequest) (*QueryFeedConfigInfoResponse, error)
	// Retrieves latest round ID and data, including median answer for that round
	LatestRound(context.Context, *QueryLatestRoundRequest) (*QueryLatestRoundResponse, error)
	// LatestTransmissionDetails returns details about the latest trasmission
	// recorded on chain for the given feed ID.
	LatestTransmissionDetails(context.Context, *QueryLatestTransmissionDetailsRequest) (*QueryLatestTransmissionDetailsResponse, error)
	// Retrieves transmitter's owed amount
	OwedAmount(context.Context, *QueryOwedAmountRequest) (*QueryOwedAmountResponse, error)
	// Retrieves the entire OCR module's state
	OcrModuleState(context.Context, *QueryModuleStateRequest) (*QueryModuleStateResponse, error)
}

QueryServer is the server API for Query service.

type Report

type Report struct {
	ObservationsTimestamp int64                                    `protobuf:"varint,1,opt,name=observations_timestamp,json=observationsTimestamp,proto3" json:"observations_timestamp,omitempty"`
	Observers             []byte                                   `protobuf:"bytes,2,opt,name=observers,proto3" json:"observers,omitempty"`
	Observations          []github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,3,rep,name=observations,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"observations"`
}

func (*Report) Descriptor

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

func (*Report) GetObservationsTimestamp

func (m *Report) GetObservationsTimestamp() int64

func (*Report) GetObservers

func (m *Report) GetObservers() []byte

func (*Report) Marshal

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

func (*Report) MarshalTo

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

func (*Report) MarshalToSizedBuffer

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

func (*Report) ProtoMessage

func (*Report) ProtoMessage()

func (*Report) Reset

func (m *Report) Reset()

func (*Report) Size

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

func (*Report) String

func (m *Report) String() string

func (*Report) Unmarshal

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

func (*Report) XXX_DiscardUnknown

func (m *Report) XXX_DiscardUnknown()

func (*Report) XXX_Marshal

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

func (*Report) XXX_Merge

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

func (*Report) XXX_Size

func (m *Report) XXX_Size() int

func (*Report) XXX_Unmarshal

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

type ReportToSign

type ReportToSign struct {
	ConfigDigest []byte `protobuf:"bytes,1,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"`
	Epoch        uint64 `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Round        uint64 `protobuf:"varint,3,opt,name=round,proto3" json:"round,omitempty"`
	ExtraHash    []byte `protobuf:"bytes,4,opt,name=extra_hash,json=extraHash,proto3" json:"extra_hash,omitempty"`
	// Opaque report
	Report []byte `protobuf:"bytes,5,opt,name=report,proto3" json:"report,omitempty"`
}

func ReportFromBytes

func ReportFromBytes(buf []byte) (*ReportToSign, error)

func (*ReportToSign) Bytes

func (r *ReportToSign) Bytes() []byte

func (*ReportToSign) Descriptor

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

func (*ReportToSign) Digest

func (r *ReportToSign) Digest() []byte

func (*ReportToSign) GetConfigDigest

func (m *ReportToSign) GetConfigDigest() []byte

func (*ReportToSign) GetEpoch

func (m *ReportToSign) GetEpoch() uint64

func (*ReportToSign) GetExtraHash

func (m *ReportToSign) GetExtraHash() []byte

func (*ReportToSign) GetReport

func (m *ReportToSign) GetReport() []byte

func (*ReportToSign) GetRound

func (m *ReportToSign) GetRound() uint64

func (*ReportToSign) Marshal

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

func (*ReportToSign) MarshalTo

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

func (*ReportToSign) MarshalToSizedBuffer

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

func (*ReportToSign) ProtoMessage

func (*ReportToSign) ProtoMessage()

func (*ReportToSign) Reset

func (m *ReportToSign) Reset()

func (*ReportToSign) Size

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

func (*ReportToSign) String

func (m *ReportToSign) String() string

func (*ReportToSign) Unmarshal

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

func (*ReportToSign) XXX_DiscardUnknown

func (m *ReportToSign) XXX_DiscardUnknown()

func (*ReportToSign) XXX_Marshal

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

func (*ReportToSign) XXX_Merge

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

func (*ReportToSign) XXX_Size

func (m *ReportToSign) XXX_Size() int

func (*ReportToSign) XXX_Unmarshal

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

type Reward

type Reward struct {
	Addr   sdk.AccAddress
	Amount sdk.Coin
}

type RewardPool

type RewardPool struct {
	FeedId string     `protobuf:"bytes,1,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
	Amount types.Coin `protobuf:"bytes,2,opt,name=amount,proto3" json:"amount"`
}

func (*RewardPool) Descriptor

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

func (*RewardPool) GetAmount

func (m *RewardPool) GetAmount() types.Coin

func (*RewardPool) GetFeedId

func (m *RewardPool) GetFeedId() string

func (*RewardPool) Marshal

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

func (*RewardPool) MarshalTo

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

func (*RewardPool) MarshalToSizedBuffer

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

func (*RewardPool) ProtoMessage

func (*RewardPool) ProtoMessage()

func (*RewardPool) Reset

func (m *RewardPool) Reset()

func (*RewardPool) Size

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

func (*RewardPool) String

func (m *RewardPool) String() string

func (*RewardPool) Unmarshal

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

func (*RewardPool) XXX_DiscardUnknown

func (m *RewardPool) XXX_DiscardUnknown()

func (*RewardPool) XXX_Marshal

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

func (*RewardPool) XXX_Merge

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

func (*RewardPool) XXX_Size

func (m *RewardPool) XXX_Size() int

func (*RewardPool) XXX_Unmarshal

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

type SetBatchConfigProposal

type SetBatchConfigProposal struct {
	Title       string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// signers ith element is address ith oracle uses to sign a report
	Signers []string `protobuf:"bytes,3,rep,name=signers,proto3" json:"signers,omitempty"`
	// transmitters ith element is address ith oracle uses to transmit a report
	// via the transmit method
	Transmitters []string `protobuf:"bytes,4,rep,name=transmitters,proto3" json:"transmitters,omitempty"`
	// Native denom for LINK coin in the bank keeper
	LinkDenom string `protobuf:"bytes,5,opt,name=link_denom,json=linkDenom,proto3" json:"link_denom,omitempty"`
	// feed properties
	FeedProperties []*FeedProperties `protobuf:"bytes,6,rep,name=feed_properties,json=feedProperties,proto3" json:"feed_properties,omitempty"`
}

func (*SetBatchConfigProposal) Descriptor

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

func (*SetBatchConfigProposal) GetDescription

func (p *SetBatchConfigProposal) GetDescription() string

GetDescription returns the description of this proposal.

func (*SetBatchConfigProposal) GetTitle

func (p *SetBatchConfigProposal) GetTitle() string

GetTitle returns the title of this proposal.

func (*SetBatchConfigProposal) Marshal

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

func (*SetBatchConfigProposal) MarshalTo

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

func (*SetBatchConfigProposal) MarshalToSizedBuffer

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

func (*SetBatchConfigProposal) ProposalRoute

func (p *SetBatchConfigProposal) ProposalRoute() string

ProposalRoute returns router key of this proposal.

func (*SetBatchConfigProposal) ProposalType

func (p *SetBatchConfigProposal) ProposalType() string

ProposalType returns proposal type of this proposal.

func (*SetBatchConfigProposal) ProtoMessage

func (*SetBatchConfigProposal) ProtoMessage()

func (*SetBatchConfigProposal) Reset

func (m *SetBatchConfigProposal) Reset()

func (*SetBatchConfigProposal) Size

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

func (*SetBatchConfigProposal) String

func (m *SetBatchConfigProposal) String() string

func (*SetBatchConfigProposal) Unmarshal

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

func (*SetBatchConfigProposal) ValidateBasic

func (p *SetBatchConfigProposal) ValidateBasic() error

ValidateBasic returns ValidateBasic result of this proposal.

func (*SetBatchConfigProposal) XXX_DiscardUnknown

func (m *SetBatchConfigProposal) XXX_DiscardUnknown()

func (*SetBatchConfigProposal) XXX_Marshal

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

func (*SetBatchConfigProposal) XXX_Merge

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

func (*SetBatchConfigProposal) XXX_Size

func (m *SetBatchConfigProposal) XXX_Size() int

func (*SetBatchConfigProposal) XXX_Unmarshal

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

type SetConfigProposal

type SetConfigProposal struct {
	Title       string      `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Description string      `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Config      *FeedConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
}

func (*SetConfigProposal) Descriptor

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

func (*SetConfigProposal) GetDescription

func (p *SetConfigProposal) GetDescription() string

GetDescription returns the description of this proposal.

func (*SetConfigProposal) GetTitle

func (p *SetConfigProposal) GetTitle() string

GetTitle returns the title of this proposal.

func (*SetConfigProposal) Marshal

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

func (*SetConfigProposal) MarshalTo

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

func (*SetConfigProposal) MarshalToSizedBuffer

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

func (*SetConfigProposal) ProposalRoute

func (p *SetConfigProposal) ProposalRoute() string

ProposalRoute returns router key of this proposal.

func (*SetConfigProposal) ProposalType

func (p *SetConfigProposal) ProposalType() string

ProposalType returns proposal type of this proposal.

func (*SetConfigProposal) ProtoMessage

func (*SetConfigProposal) ProtoMessage()

func (*SetConfigProposal) Reset

func (m *SetConfigProposal) Reset()

func (*SetConfigProposal) Size

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

func (*SetConfigProposal) String

func (m *SetConfigProposal) String() string

func (*SetConfigProposal) Unmarshal

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

func (*SetConfigProposal) ValidateBasic

func (p *SetConfigProposal) ValidateBasic() error

ValidateBasic returns ValidateBasic result of this proposal.

func (*SetConfigProposal) XXX_DiscardUnknown

func (m *SetConfigProposal) XXX_DiscardUnknown()

func (*SetConfigProposal) XXX_Marshal

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

func (*SetConfigProposal) XXX_Merge

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

func (*SetConfigProposal) XXX_Size

func (m *SetConfigProposal) XXX_Size() int

func (*SetConfigProposal) XXX_Unmarshal

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

type Transmission

type Transmission struct {
	Answer                github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,1,opt,name=answer,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"answer"`
	ObservationsTimestamp int64                                  `protobuf:"varint,2,opt,name=observations_timestamp,json=observationsTimestamp,proto3" json:"observations_timestamp,omitempty"`
	TransmissionTimestamp int64                                  `protobuf:"varint,3,opt,name=transmission_timestamp,json=transmissionTimestamp,proto3" json:"transmission_timestamp,omitempty"`
}

Transmission records the median answer from the transmit transaction at time timestamp

func (*Transmission) Descriptor

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

func (*Transmission) GetObservationsTimestamp

func (m *Transmission) GetObservationsTimestamp() int64

func (*Transmission) GetTransmissionTimestamp

func (m *Transmission) GetTransmissionTimestamp() int64

func (*Transmission) Marshal

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

func (*Transmission) MarshalTo

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

func (*Transmission) MarshalToSizedBuffer

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

func (*Transmission) ProtoMessage

func (*Transmission) ProtoMessage()

func (*Transmission) Reset

func (m *Transmission) Reset()

func (*Transmission) Size

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

func (*Transmission) String

func (m *Transmission) String() string

func (*Transmission) Unmarshal

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

func (*Transmission) XXX_DiscardUnknown

func (m *Transmission) XXX_DiscardUnknown()

func (*Transmission) XXX_Marshal

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

func (*Transmission) XXX_Merge

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

func (*Transmission) XXX_Size

func (m *Transmission) XXX_Size() int

func (*Transmission) XXX_Unmarshal

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

type UnimplementedMsgServer

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) AcceptPayeeship

func (*UnimplementedMsgServer) CreateFeed

func (*UnimplementedMsgServer) FundFeedRewardPool

func (*UnimplementedMsgServer) SetPayees

func (*UnimplementedMsgServer) TransferPayeeship

func (*UnimplementedMsgServer) Transmit

func (*UnimplementedMsgServer) UpdateFeed

func (*UnimplementedMsgServer) UpdateParams

func (*UnimplementedMsgServer) WithdrawFeedRewardPool

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) FeedConfig

func (*UnimplementedQueryServer) FeedConfigInfo

func (*UnimplementedQueryServer) LatestRound

func (*UnimplementedQueryServer) OcrModuleState

func (*UnimplementedQueryServer) OwedAmount

func (*UnimplementedQueryServer) Params

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL