types

package
v1.28.4 Latest Latest
Warning

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

 Go to latest Published: Dec 24, 2021 License: MIT Imports: 27 Imported by: 2

Documentation

Index

Constants

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

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

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

	// 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"
)
View Source 
const (
	ProposalTypeOcrSetConfig      string = "ProposalTypeOcrSetConfig"
	ProposalTypeOcrBatchSetConfig string = "ProposalTypeOcrBatchSetConfig"
)

constants

View Source 
const FeedIDMaxLength = 20

Variables

View Source 
var (
	ErrStaleReport               = sdkerrors.Register(ModuleName, 1, "stale report")
	ErrIncompleteProposal        = sdkerrors.Register(ModuleName, 2, "incomplete proposal")
	ErrRepeatedAddress           = sdkerrors.Register(ModuleName, 3, "repeated oracle address")
	ErrTooManySigners            = sdkerrors.Register(ModuleName, 4, "too many signers")
	ErrIncorrectConfig           = sdkerrors.Register(ModuleName, 5, "incorrect config")
	ErrConfigDigestNotMatch      = sdkerrors.Register(ModuleName, 6, "config digest doesn't match")
	ErrWrongNumberOfSignatures   = sdkerrors.Register(ModuleName, 7, "wrong number of signatures")
	ErrIncorrectSignature        = sdkerrors.Register(ModuleName, 8, "incorrect signature")
	ErrNoTransmitter             = sdkerrors.Register(ModuleName, 9, "no transmitter specified")
	ErrIncorrectTransmissionData = sdkerrors.Register(ModuleName, 10, "incorrect transmission data")
	ErrNoTransmissionsFound      = sdkerrors.Register(ModuleName, 11, "no transmissions found")
	ErrMedianValueOutOfBounds    = sdkerrors.Register(ModuleName, 12, "median value is out of bounds")
	ErrIncorrectRewardPoolDenom  = sdkerrors.Register(ModuleName, 13, "LINK denom doesn't match")
	ErrNoRewardPool              = sdkerrors.Register(ModuleName, 14, "Reward Pool doesn't exist")
	ErrInvalidPayees             = sdkerrors.Register(ModuleName, 15, "wrong number of payees and transmitters")
	ErrModuleAdminRestricted     = sdkerrors.Register(ModuleName, 16, "action is restricted to the module admin")
	ErrFeedAlreadyExists         = sdkerrors.Register(ModuleName, 17, "feed already exists")
	ErrFeedDoesntExists          = sdkerrors.Register(ModuleName, 19, "feed doesnt exists")
	ErrAdminRestricted           = sdkerrors.Register(ModuleName, 20, "action is admin-restricted")
	ErrInsufficientRewardPool    = sdkerrors.Register(ModuleName, 21, "insufficient reward pool")
	ErrPayeeAlreadySet           = sdkerrors.Register(ModuleName, 22, "payee already set")
	ErrPayeeRestricted           = sdkerrors.Register(ModuleName, 23, "action is payee-restricted")
	ErrFeedConfigNotFound        = sdkerrors.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}
)
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 added in v1.27.8 

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 (m *FeedLatestAggregatorRoundIDs) String() 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 added in v1.27.8 

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 added in v1.27.8 

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 added in v1.27.8 

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

func (*ModuleParams) GetBillingAdmin added in v1.27.8 

func (m *ModuleParams) GetBillingAdmin() string

func (*ModuleParams) GetDescription added in v1.27.8 

func (m *ModuleParams) GetDescription() string

func (*ModuleParams) GetFeedAdmin added in v1.27.8 

func (m *ModuleParams) GetFeedAdmin() string

func (*ModuleParams) GetFeedId added in v1.27.8 

func (m *ModuleParams) GetFeedId() string

func (*ModuleParams) GetLinkDenom added in v1.27.8 

func (m *ModuleParams) GetLinkDenom() string

func (*ModuleParams) GetUniqueReports added in v1.27.8 

func (m *ModuleParams) GetUniqueReports() bool

func (*ModuleParams) Marshal added in v1.27.8 

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

func (*ModuleParams) MarshalTo added in v1.27.8 

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

func (*ModuleParams) MarshalToSizedBuffer added in v1.27.8 

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

func (*ModuleParams) ProtoMessage added in v1.27.8 

func (*ModuleParams) ProtoMessage()

func (*ModuleParams) Reset added in v1.27.8 

func (m *ModuleParams) Reset()

func (*ModuleParams) Size added in v1.27.8 

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

func (*ModuleParams) String added in v1.27.8 

func (m *ModuleParams) String() string

func (*ModuleParams) Unmarshal added in v1.27.8 

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

func (*ModuleParams) XXX_DiscardUnknown added in v1.27.8 

func (m *ModuleParams) XXX_DiscardUnknown()

func (*ModuleParams) XXX_Marshal added in v1.27.8 

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

func (*ModuleParams) XXX_Merge added in v1.27.8 

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

func (*ModuleParams) XXX_Size added in v1.27.8 

func (m *ModuleParams) XXX_Size() int

func (*ModuleParams) XXX_Unmarshal added in v1.27.8 

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(ctx context.Context, in *MsgCreateFeed, opts ...grpc.CallOption) (*MsgCreateFeedResponse, error)
	UpdateFeed(ctx context.Context, in *MsgUpdateFeed, opts ...grpc.CallOption) (*MsgUpdateFeedResponse, error)
	Transmit(ctx context.Context, in *MsgTransmit, opts ...grpc.CallOption) (*MsgTransmitResponse, error)
	FundFeedRewardPool(ctx context.Context, in *MsgFundFeedRewardPool, opts ...grpc.CallOption) (*MsgFundFeedRewardPoolResponse, error)
	WithdrawFeedRewardPool(ctx context.Context, in *MsgWithdrawFeedRewardPool, opts ...grpc.CallOption) (*MsgWithdrawFeedRewardPoolResponse, error)
	SetPayees(ctx context.Context, in *MsgSetPayees, opts ...grpc.CallOption) (*MsgSetPayeesResponse, error)
	TransferPayeeship(ctx context.Context, in *MsgTransferPayeeship, opts ...grpc.CallOption) (*MsgTransferPayeeshipResponse, error)
	AcceptPayeeship(ctx context.Context, in *MsgAcceptPayeeship, opts ...grpc.CallOption) (*MsgAcceptPayeeshipResponse, 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 (m *MsgFundFeedRewardPoolResponse) String() 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(context.Context, *MsgCreateFeed) (*MsgCreateFeedResponse, error)
	UpdateFeed(context.Context, *MsgUpdateFeed) (*MsgUpdateFeedResponse, error)
	Transmit(context.Context, *MsgTransmit) (*MsgTransmitResponse, error)
	FundFeedRewardPool(context.Context, *MsgFundFeedRewardPool) (*MsgFundFeedRewardPoolResponse, error)
	WithdrawFeedRewardPool(context.Context, *MsgWithdrawFeedRewardPool) (*MsgWithdrawFeedRewardPoolResponse, error)
	SetPayees(context.Context, *MsgSetPayees) (*MsgSetPayeesResponse, error)
	TransferPayeeship(context.Context, *MsgTransferPayeeship) (*MsgTransferPayeeshipResponse, error)
	AcceptPayeeship(context.Context, *MsgAcceptPayeeship) (*MsgAcceptPayeeshipResponse, 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 (m *MsgTransferPayeeshipResponse) String() 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 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 (m *MsgWithdrawFeedRewardPoolResponse) Reset()

func (*MsgWithdrawFeedRewardPoolResponse) Size 

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

func (*MsgWithdrawFeedRewardPoolResponse) String 

func (m *MsgWithdrawFeedRewardPoolResponse) String() 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 (m *MsgWithdrawFeedRewardPoolResponse) XXX_Merge(src proto.Message)

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 (m *QueryLatestTransmissionDetailsRequest) GetFeedId() string

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 (m *QueryLatestTransmissionDetailsRequest) Reset()

func (*QueryLatestTransmissionDetailsRequest) Size 

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

func (*QueryLatestTransmissionDetailsRequest) String 

func (m *QueryLatestTransmissionDetailsRequest) String() 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 (m *QueryLatestTransmissionDetailsRequest) XXX_Merge(src proto.Message)

func (*QueryLatestTransmissionDetailsRequest) XXX_Size 

func (m *QueryLatestTransmissionDetailsRequest) XXX_Size() int

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 (m *QueryLatestTransmissionDetailsResponse) GetData() *Transmission

func (*QueryLatestTransmissionDetailsResponse) GetEpochAndRound 

func (m *QueryLatestTransmissionDetailsResponse) GetEpochAndRound() *EpochAndRound

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

func (*QueryLatestTransmissionDetailsResponse) Reset 

func (m *QueryLatestTransmissionDetailsResponse) Reset()

func (*QueryLatestTransmissionDetailsResponse) Size 

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

func (*QueryLatestTransmissionDetailsResponse) String 

func (m *QueryLatestTransmissionDetailsResponse) String() 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 (m *QueryLatestTransmissionDetailsResponse) XXX_Merge(src proto.Message)

func (*QueryLatestTransmissionDetailsResponse) XXX_Size 

func (m *QueryLatestTransmissionDetailsResponse) XXX_Size() int

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"`
	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) AcceptPayeeship(ctx context.Context, req *MsgAcceptPayeeship) (*MsgAcceptPayeeshipResponse, error)

func (*UnimplementedMsgServer) CreateFeed 

func (*UnimplementedMsgServer) CreateFeed(ctx context.Context, req *MsgCreateFeed) (*MsgCreateFeedResponse, error)

func (*UnimplementedMsgServer) FundFeedRewardPool 

func (*UnimplementedMsgServer) FundFeedRewardPool(ctx context.Context, req *MsgFundFeedRewardPool) (*MsgFundFeedRewardPoolResponse, error)

func (*UnimplementedMsgServer) SetPayees 

func (*UnimplementedMsgServer) SetPayees(ctx context.Context, req *MsgSetPayees) (*MsgSetPayeesResponse, error)

func (*UnimplementedMsgServer) TransferPayeeship 

func (*UnimplementedMsgServer) TransferPayeeship(ctx context.Context, req *MsgTransferPayeeship) (*MsgTransferPayeeshipResponse, error)

func (*UnimplementedMsgServer) Transmit 

func (*UnimplementedMsgServer) Transmit(ctx context.Context, req *MsgTransmit) (*MsgTransmitResponse, error)

func (*UnimplementedMsgServer) UpdateFeed 

func (*UnimplementedMsgServer) UpdateFeed(ctx context.Context, req *MsgUpdateFeed) (*MsgUpdateFeedResponse, error)

func (*UnimplementedMsgServer) WithdrawFeedRewardPool 

func (*UnimplementedMsgServer) WithdrawFeedRewardPool(ctx context.Context, req *MsgWithdrawFeedRewardPool) (*MsgWithdrawFeedRewardPoolResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) FeedConfig 

func (*UnimplementedQueryServer) FeedConfig(ctx context.Context, req *QueryFeedConfigRequest) (*QueryFeedConfigResponse, error)

func (*UnimplementedQueryServer) FeedConfigInfo 

func (*UnimplementedQueryServer) FeedConfigInfo(ctx context.Context, req *QueryFeedConfigInfoRequest) (*QueryFeedConfigInfoResponse, error)

func (*UnimplementedQueryServer) LatestRound 

func (*UnimplementedQueryServer) LatestRound(ctx context.Context, req *QueryLatestRoundRequest) (*QueryLatestRoundResponse, error)

func (*UnimplementedQueryServer) LatestTransmissionDetails 

func (*UnimplementedQueryServer) LatestTransmissionDetails(ctx context.Context, req *QueryLatestTransmissionDetailsRequest) (*QueryLatestTransmissionDetailsResponse, error)

func (*UnimplementedQueryServer) OcrModuleState 

func (*UnimplementedQueryServer) OcrModuleState(ctx context.Context, req *QueryModuleStateRequest) (*QueryModuleStateResponse, error)

func (*UnimplementedQueryServer) OwedAmount 

func (*UnimplementedQueryServer) OwedAmount(ctx context.Context, req *QueryOwedAmountRequest) (*QueryOwedAmountResponse, error)

func (*UnimplementedQueryServer) Params 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.