types

package
v0.0.0-...-7183b0c Latest Latest
Warning

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

 Go to latest Published: Sep 15, 2021 License: MIT Imports: 29 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

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

	// FeedDataStoreKey defines the store key for feed data
	FeedDataStoreKey = ModuleName + "feedData"

	// RoundStoreKey defines the store key for feed roundId
	RoundStoreKey = ModuleName + "round"

	// ModuleOwnerStoreKey defines the store key for module owner
	ModuleOwnerStoreKey = ModuleName + "moduleOwner"

	// FeedInfoStoreKey defines the store key for feed
	FeedInfoStoreKey = ModuleName + "feedInfo"

	// AccountInfoStoreKey defines the store key for chainlink accounts
	AccountStoreKey = ModuleName + "account"

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

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

	// MemStoreKey defines the in-memory store key
	MemStoreKey = "mem_chainlink"
)
View Source 
const (
	// FeedDataKey FeedDataStore key pattern: types.FeedDataKey/feedId/roundId
	FeedDataKey = "feedData"

	// RoundIdKey RoundStore key pattern: types.RoundIdKey/feedId
	RoundIdKey = "roundId"

	// ModuleOwnerKey ModuleOwnerStore key pattern: types.ModuleOwnerKey/moduleOwnerAddress
	ModuleOwnerKey = "moduleOwner"

	// FeedInfoKey FeedInfoStore key pattern: types.FeedInfoKey/feedId
	FeedInfoKey = "feed"

	// AccountKey AccountStore key pattern: types.AccountKey/accAddr
	AccountKey = "account"
)
View Source 
const (
	SubmitFeedData               = "SubmitFeedData"
	AddModuleOwner               = "AddModuleOwner"
	ModuleOwnershipTransfer      = "ModuleOwnershipTransfer"
	AddFeed                      = "AddFeed"
	AddDataProvider              = "AddDataProvider"
	RemoveDataProvider           = "RemoveDataProvider"
	SetSubmissionCount           = "SetSubmissionCount"
	SetHeartbeatTrigger          = "SetHeartbeatTrigger"
	SetDeviationThresholdTrigger = "SetDeviationThresholdTrigger"
	SetFeedReward                = "SetFeedReward"
	FeedOwnershipTransfer        = "FeedOwnershipTransfer"
	RequestNewRound              = "RequestNewRound"
	SetAccountPiggyAddress       = "SetAccountPiggyAddress"
)
View Source 
const (
	QueryRoundFeedData      = "getRoundFeedData"
	QueryLatestFeedData     = "getLatestFeedData"
	QueryModuleOwner        = "getModuleOwner"
	QueryFeedInfo           = "getFeedInfo"
	QueryAccountInfo        = "getAccountInfo"
	QueryFeedRewardStrategy = "getFeedRewardStrategy"
)

Supported endpoints

View Source 
const DefaultIndex uint64 = 1

DefaultIndex is the default capability global index

View Source 
const (
	// Chainlink token denom
	LinkDenom string = "link"
)

Variables

View Source 
var (
	ErrInvalidLengthEvent        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvent          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvent = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	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 (
	ErrSample = sdkerrors.Register(ModuleName, 1100, "sample error")
)

x/chainlink module sentinel errors

View Source 
var FeedRewardStrategyConvertor = map[string]FeedRewardStrategyFunc{}
View Source 
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)

Functions

func DeriveCosmosAddrFromPubKey 

func DeriveCosmosAddrFromPubKey(pubKey string) (sdk.AccAddress, error)

DeriveCosmosAddrFromPubKey derives the cosmos address from Bech32 cosmos pubkey

func EmitEvent 

func EmitEvent(e proto.Message, manager *types.EventManager) error

func GetAccountKey 

func GetAccountKey(account string) []byte

func GetFeedDataKey 

func GetFeedDataKey(feedId, roundId string) []byte

func GetFeedInfoKey 

func GetFeedInfoKey(feedId string) []byte

func GetModuleOwnerKey 

func GetModuleOwnerKey(moduleOwnerAddress string) []byte

func GetRoundIdKey 

func GetRoundIdKey(feedId string) []byte

func KeyPrefix 

func KeyPrefix(p string) []byte

func NewFeedRewardStrategyRegister 

func NewFeedRewardStrategyRegister(feedRewardStrategyFns map[string]FeedRewardStrategyFunc)

NewFeedRewardStrategyRegister registers the reward calculation strategies when the chain launches

func NewLinkCoin 

func NewLinkCoin(amount sdk.Int) sdk.Coin

NewLinkCoin will create a "link" coin with the provided amount.

func NewLinkCoinInt64 

func NewLinkCoinInt64(amount int64) sdk.Coin

NewLinkCoinInt64 will create a "link" coin with the given int64 amount.

func NewLinkDecCoin 

func NewLinkDecCoin(amount sdk.Int) sdk.DecCoin

NewLinkDecCoin will create a decimal "link" coin with the provided amount.

func RegisterCodec 

func RegisterCodec(cdc *codec.LegacyAmino)

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterMsgHandler 

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

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

func RegisterMsgHandlerClient 

func RegisterMsgHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MsgClient) error

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

func RegisterMsgHandlerFromEndpoint 

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

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

func RegisterMsgHandlerServer 

func RegisterMsgHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MsgServer) error

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

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

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

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

func RegisterQueryHandlerClient 

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

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

func RegisterQueryHandlerFromEndpoint 

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

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

func RegisterQueryHandlerServer 

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

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

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type BankKeeper 

type BankKeeper interface {
	SendCoins(ctx sdk.Context, fromAddr sdk.AccAddress, toAddr sdk.AccAddress, amt sdk.Coins) error
	MintCoins(ctx sdk.Context, moduleName string, amt sdk.Coins) error
	BurnCoins(ctx sdk.Context, moduleName 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
}

BankKeeper defines the expected bank keeper

type Coin 

type Coin struct {
	Denom  string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
	Amount uint64 `protobuf:"varint,2,opt,name=amount,proto3" json:"amount,omitempty"`
}

func (*Coin) Descriptor 

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

func (*Coin) GetAmount 

func (m *Coin) GetAmount() uint64

func (*Coin) GetDenom 

func (m *Coin) GetDenom() string

func (*Coin) Marshal 

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

func (*Coin) MarshalTo 

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

func (*Coin) MarshalToSizedBuffer 

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

func (*Coin) ProtoMessage 

func (*Coin) ProtoMessage()

func (*Coin) Reset 

func (m *Coin) Reset()

func (*Coin) Size 

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

func (*Coin) String 

func (m *Coin) String() string

func (*Coin) Unmarshal 

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

func (*Coin) XXX_DiscardUnknown 

func (m *Coin) XXX_DiscardUnknown()

func (*Coin) XXX_Marshal 

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

func (*Coin) XXX_Merge 

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

func (*Coin) XXX_Size 

func (m *Coin) XXX_Size() int

func (*Coin) XXX_Unmarshal 

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

type DataProvider 

type DataProvider struct {
	Address github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,1,opt,name=address,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"address,omitempty"`
	PubKey  []byte                                        `protobuf:"bytes,2,opt,name=pubKey,proto3" json:"pubKey,omitempty"`
}

DataProvider is the type defined for feed data provider

func (*DataProvider) Descriptor 

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

func (*DataProvider) GetAddress 

func (m *DataProvider) GetAddress() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*DataProvider) GetPubKey 

func (m *DataProvider) GetPubKey() []byte

func (*DataProvider) Marshal 

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

func (*DataProvider) MarshalTo 

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

func (*DataProvider) MarshalToSizedBuffer 

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

func (*DataProvider) ProtoMessage 

func (*DataProvider) ProtoMessage()

func (*DataProvider) Reset 

func (m *DataProvider) Reset()

func (*DataProvider) Size 

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

func (*DataProvider) String 

func (m *DataProvider) String() string

func (*DataProvider) Unmarshal 

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

func (*DataProvider) Verify 

func (m *DataProvider) Verify() bool

func (*DataProvider) XXX_DiscardUnknown 

func (m *DataProvider) XXX_DiscardUnknown()

func (*DataProvider) XXX_Marshal 

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

func (*DataProvider) XXX_Merge 

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

func (*DataProvider) XXX_Size 

func (m *DataProvider) XXX_Size() int

func (*DataProvider) XXX_Unmarshal 

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

type DataProviders 

type DataProviders []*DataProvider

func (DataProviders) Contains 

func (dp DataProviders) Contains(addr sdk.Address) bool

Contains returns true if the given address exists in a slice of DataProviders.

func (DataProviders) Remove 

func (dp DataProviders) Remove(addr sdk.Address) DataProviders

type FeedRewardSchema 

type FeedRewardSchema struct {
	// amount is the base value that rewarded to each valid data provider before designated strategy applied
	// amount is not allowed to be zero
	Amount uint64 `protobuf:"varint,1,opt,name=amount,proto3" json:"amount,omitempty"`
	// reward strategy name, must be a registered strategy
	// this is allowed to be empty, in which case every data provider will be rewarded the same amount token
	Strategy string `protobuf:"bytes,2,opt,name=strategy,proto3" json:"strategy,omitempty"`
}

func (*FeedRewardSchema) Descriptor 

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

func (*FeedRewardSchema) GetAmount 

func (m *FeedRewardSchema) GetAmount() uint64

func (*FeedRewardSchema) GetStrategy 

func (m *FeedRewardSchema) GetStrategy() string

func (*FeedRewardSchema) Marshal 

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

func (*FeedRewardSchema) MarshalTo 

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

func (*FeedRewardSchema) MarshalToSizedBuffer 

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

func (*FeedRewardSchema) ProtoMessage 

func (*FeedRewardSchema) ProtoMessage()

func (*FeedRewardSchema) Reset 

func (m *FeedRewardSchema) Reset()

func (*FeedRewardSchema) Size 

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

func (*FeedRewardSchema) String 

func (m *FeedRewardSchema) String() string

func (*FeedRewardSchema) Unmarshal 

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

func (*FeedRewardSchema) XXX_DiscardUnknown 

func (m *FeedRewardSchema) XXX_DiscardUnknown()

func (*FeedRewardSchema) XXX_Marshal 

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

func (*FeedRewardSchema) XXX_Merge 

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

func (*FeedRewardSchema) XXX_Size 

func (m *FeedRewardSchema) XXX_Size() int

func (*FeedRewardSchema) XXX_Unmarshal 

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

type FeedRewardStrategyFunc 

type FeedRewardStrategyFunc func(*MsgFeed, *MsgFeedData) ([]RewardPayout, error)

type GenesisState 

type GenesisState struct {
	// MsgModuleOwner is an array containing the chainlink init module owner accounts.
	ModuleOwners []*MsgModuleOwner `protobuf:"bytes,1,rep,name=moduleOwners,proto3" json:"moduleOwners,omitempty"`
}

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default Capability genesis state This is where the init genesis can be defined

func GetGenesisStateFromAppState 

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

GetGenesisStateFromAppState returns chainlink module GenesisState given raw application genesis state.

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetModuleOwners 

func (m *GenesisState) GetModuleOwners() []*MsgModuleOwner

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (GenesisState) Validate 

func (gs GenesisState) Validate() error

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

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type GetAccountRequest 

type GetAccountRequest struct {
	AccountAddress github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 136-byte string literal not displayed */
}

func (*GetAccountRequest) Descriptor 

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

func (*GetAccountRequest) GetAccountAddress 

func (m *GetAccountRequest) GetAccountAddress() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*GetAccountRequest) Marshal 

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

func (*GetAccountRequest) MarshalTo 

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

func (*GetAccountRequest) MarshalToSizedBuffer 

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

func (*GetAccountRequest) ProtoMessage 

func (*GetAccountRequest) ProtoMessage()

func (*GetAccountRequest) Reset 

func (m *GetAccountRequest) Reset()

func (*GetAccountRequest) Size 

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

func (*GetAccountRequest) String 

func (m *GetAccountRequest) String() string

func (*GetAccountRequest) Unmarshal 

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

func (*GetAccountRequest) XXX_DiscardUnknown 

func (m *GetAccountRequest) XXX_DiscardUnknown()

func (*GetAccountRequest) XXX_Marshal 

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

func (*GetAccountRequest) XXX_Merge 

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

func (*GetAccountRequest) XXX_Size 

func (m *GetAccountRequest) XXX_Size() int

func (*GetAccountRequest) XXX_Unmarshal 

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

type GetAccountResponse 

type GetAccountResponse struct {
	Account *MsgAccount `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
}

func (*GetAccountResponse) Descriptor 

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

func (*GetAccountResponse) GetAccount 

func (m *GetAccountResponse) GetAccount() *MsgAccount

func (*GetAccountResponse) Marshal 

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

func (*GetAccountResponse) MarshalTo 

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

func (*GetAccountResponse) MarshalToSizedBuffer 

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

func (*GetAccountResponse) ProtoMessage 

func (*GetAccountResponse) ProtoMessage()

func (*GetAccountResponse) Reset 

func (m *GetAccountResponse) Reset()

func (*GetAccountResponse) Size 

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

func (*GetAccountResponse) String 

func (m *GetAccountResponse) String() string

func (*GetAccountResponse) Unmarshal 

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

func (*GetAccountResponse) XXX_DiscardUnknown 

func (m *GetAccountResponse) XXX_DiscardUnknown()

func (*GetAccountResponse) XXX_Marshal 

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

func (*GetAccountResponse) XXX_Merge 

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

func (*GetAccountResponse) XXX_Size 

func (m *GetAccountResponse) XXX_Size() int

func (*GetAccountResponse) XXX_Unmarshal 

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

type GetFeedByIdRequest 

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

func (*GetFeedByIdRequest) Descriptor 

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

func (*GetFeedByIdRequest) GetFeedId 

func (m *GetFeedByIdRequest) GetFeedId() string

func (*GetFeedByIdRequest) Marshal 

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

func (*GetFeedByIdRequest) MarshalTo 

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

func (*GetFeedByIdRequest) MarshalToSizedBuffer 

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

func (*GetFeedByIdRequest) ProtoMessage 

func (*GetFeedByIdRequest) ProtoMessage()

func (*GetFeedByIdRequest) Reset 

func (m *GetFeedByIdRequest) Reset()

func (*GetFeedByIdRequest) Size 

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

func (*GetFeedByIdRequest) String 

func (m *GetFeedByIdRequest) String() string

func (*GetFeedByIdRequest) Unmarshal 

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

func (*GetFeedByIdRequest) XXX_DiscardUnknown 

func (m *GetFeedByIdRequest) XXX_DiscardUnknown()

func (*GetFeedByIdRequest) XXX_Marshal 

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

func (*GetFeedByIdRequest) XXX_Merge 

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

func (*GetFeedByIdRequest) XXX_Size 

func (m *GetFeedByIdRequest) XXX_Size() int

func (*GetFeedByIdRequest) XXX_Unmarshal 

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

type GetFeedByIdResponse 

type GetFeedByIdResponse struct {
	Feed *MsgFeed `protobuf:"bytes,1,opt,name=feed,proto3" json:"feed,omitempty"`
}

func (*GetFeedByIdResponse) Descriptor 

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

func (*GetFeedByIdResponse) GetFeed 

func (m *GetFeedByIdResponse) GetFeed() *MsgFeed

func (*GetFeedByIdResponse) Marshal 

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

func (*GetFeedByIdResponse) MarshalTo 

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

func (*GetFeedByIdResponse) MarshalToSizedBuffer 

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

func (*GetFeedByIdResponse) ProtoMessage 

func (*GetFeedByIdResponse) ProtoMessage()

func (*GetFeedByIdResponse) Reset 

func (m *GetFeedByIdResponse) Reset()

func (*GetFeedByIdResponse) Size 

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

func (*GetFeedByIdResponse) String 

func (m *GetFeedByIdResponse) String() string

func (*GetFeedByIdResponse) Unmarshal 

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

func (*GetFeedByIdResponse) XXX_DiscardUnknown 

func (m *GetFeedByIdResponse) XXX_DiscardUnknown()

func (*GetFeedByIdResponse) XXX_Marshal 

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

func (*GetFeedByIdResponse) XXX_Merge 

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

func (*GetFeedByIdResponse) XXX_Size 

func (m *GetFeedByIdResponse) XXX_Size() int

func (*GetFeedByIdResponse) XXX_Unmarshal 

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

type GetFeedRewardAvailStrategiesRequest 

type GetFeedRewardAvailStrategiesRequest struct {
}

func (*GetFeedRewardAvailStrategiesRequest) Descriptor 

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

func (*GetFeedRewardAvailStrategiesRequest) Marshal 

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

func (*GetFeedRewardAvailStrategiesRequest) MarshalTo 

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

func (*GetFeedRewardAvailStrategiesRequest) MarshalToSizedBuffer 

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

func (*GetFeedRewardAvailStrategiesRequest) ProtoMessage 

func (*GetFeedRewardAvailStrategiesRequest) ProtoMessage()

func (*GetFeedRewardAvailStrategiesRequest) Reset 

func (m *GetFeedRewardAvailStrategiesRequest) Reset()

func (*GetFeedRewardAvailStrategiesRequest) Size 

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

func (*GetFeedRewardAvailStrategiesRequest) String 

func (m *GetFeedRewardAvailStrategiesRequest) String() string

func (*GetFeedRewardAvailStrategiesRequest) Unmarshal 

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

func (*GetFeedRewardAvailStrategiesRequest) XXX_DiscardUnknown 

func (m *GetFeedRewardAvailStrategiesRequest) XXX_DiscardUnknown()

func (*GetFeedRewardAvailStrategiesRequest) XXX_Marshal 

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

func (*GetFeedRewardAvailStrategiesRequest) XXX_Merge 

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

func (*GetFeedRewardAvailStrategiesRequest) XXX_Size 

func (m *GetFeedRewardAvailStrategiesRequest) XXX_Size() int

func (*GetFeedRewardAvailStrategiesRequest) XXX_Unmarshal 

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

type GetFeedRewardAvailStrategiesResponse 

type GetFeedRewardAvailStrategiesResponse struct {
	AvailStrategies []string `protobuf:"bytes,1,rep,name=availStrategies,proto3" json:"availStrategies,omitempty"`
}

func (*GetFeedRewardAvailStrategiesResponse) Descriptor 

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

func (*GetFeedRewardAvailStrategiesResponse) GetAvailStrategies 

func (m *GetFeedRewardAvailStrategiesResponse) GetAvailStrategies() []string

func (*GetFeedRewardAvailStrategiesResponse) Marshal 

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

func (*GetFeedRewardAvailStrategiesResponse) MarshalTo 

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

func (*GetFeedRewardAvailStrategiesResponse) MarshalToSizedBuffer 

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

func (*GetFeedRewardAvailStrategiesResponse) ProtoMessage 

func (*GetFeedRewardAvailStrategiesResponse) ProtoMessage()

func (*GetFeedRewardAvailStrategiesResponse) Reset 

func (m *GetFeedRewardAvailStrategiesResponse) Reset()

func (*GetFeedRewardAvailStrategiesResponse) Size 

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

func (*GetFeedRewardAvailStrategiesResponse) String 

func (m *GetFeedRewardAvailStrategiesResponse) String() string

func (*GetFeedRewardAvailStrategiesResponse) Unmarshal 

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

func (*GetFeedRewardAvailStrategiesResponse) XXX_DiscardUnknown 

func (m *GetFeedRewardAvailStrategiesResponse) XXX_DiscardUnknown()

func (*GetFeedRewardAvailStrategiesResponse) XXX_Marshal 

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

func (*GetFeedRewardAvailStrategiesResponse) XXX_Merge 

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

func (*GetFeedRewardAvailStrategiesResponse) XXX_Size 

func (m *GetFeedRewardAvailStrategiesResponse) XXX_Size() int

func (*GetFeedRewardAvailStrategiesResponse) XXX_Unmarshal 

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

type GetLatestRoundDataRequest 

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

func (*GetLatestRoundDataRequest) Descriptor 

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

func (*GetLatestRoundDataRequest) GetFeedId 

func (m *GetLatestRoundDataRequest) GetFeedId() string

func (*GetLatestRoundDataRequest) Marshal 

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

func (*GetLatestRoundDataRequest) MarshalTo 

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

func (*GetLatestRoundDataRequest) MarshalToSizedBuffer 

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

func (*GetLatestRoundDataRequest) ProtoMessage 

func (*GetLatestRoundDataRequest) ProtoMessage()

func (*GetLatestRoundDataRequest) Reset 

func (m *GetLatestRoundDataRequest) Reset()

func (*GetLatestRoundDataRequest) Size 

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

func (*GetLatestRoundDataRequest) String 

func (m *GetLatestRoundDataRequest) String() string

func (*GetLatestRoundDataRequest) Unmarshal 

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

func (*GetLatestRoundDataRequest) XXX_DiscardUnknown 

func (m *GetLatestRoundDataRequest) XXX_DiscardUnknown()

func (*GetLatestRoundDataRequest) XXX_Marshal 

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

func (*GetLatestRoundDataRequest) XXX_Merge 

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

func (*GetLatestRoundDataRequest) XXX_Size 

func (m *GetLatestRoundDataRequest) XXX_Size() int

func (*GetLatestRoundDataRequest) XXX_Unmarshal 

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

type GetLatestRoundDataResponse 

type GetLatestRoundDataResponse struct {
	RoundData []*RoundData `protobuf:"bytes,1,rep,name=roundData,proto3" json:"roundData,omitempty"`
}

func (*GetLatestRoundDataResponse) Descriptor 

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

func (*GetLatestRoundDataResponse) GetRoundData 

func (m *GetLatestRoundDataResponse) GetRoundData() []*RoundData

func (*GetLatestRoundDataResponse) Marshal 

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

func (*GetLatestRoundDataResponse) MarshalTo 

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

func (*GetLatestRoundDataResponse) MarshalToSizedBuffer 

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

func (*GetLatestRoundDataResponse) ProtoMessage 

func (*GetLatestRoundDataResponse) ProtoMessage()

func (*GetLatestRoundDataResponse) Reset 

func (m *GetLatestRoundDataResponse) Reset()

func (*GetLatestRoundDataResponse) Size 

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

func (*GetLatestRoundDataResponse) String 

func (m *GetLatestRoundDataResponse) String() string

func (*GetLatestRoundDataResponse) Unmarshal 

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

func (*GetLatestRoundDataResponse) XXX_DiscardUnknown 

func (m *GetLatestRoundDataResponse) XXX_DiscardUnknown()

func (*GetLatestRoundDataResponse) XXX_Marshal 

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

func (*GetLatestRoundDataResponse) XXX_Merge 

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

func (*GetLatestRoundDataResponse) XXX_Size 

func (m *GetLatestRoundDataResponse) XXX_Size() int

func (*GetLatestRoundDataResponse) XXX_Unmarshal 

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

type GetModuleOwnerRequest 

type GetModuleOwnerRequest struct {
}

func (*GetModuleOwnerRequest) Descriptor 

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

func (*GetModuleOwnerRequest) Marshal 

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

func (*GetModuleOwnerRequest) MarshalTo 

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

func (*GetModuleOwnerRequest) MarshalToSizedBuffer 

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

func (*GetModuleOwnerRequest) ProtoMessage 

func (*GetModuleOwnerRequest) ProtoMessage()

func (*GetModuleOwnerRequest) Reset 

func (m *GetModuleOwnerRequest) Reset()

func (*GetModuleOwnerRequest) Size 

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

func (*GetModuleOwnerRequest) String 

func (m *GetModuleOwnerRequest) String() string

func (*GetModuleOwnerRequest) Unmarshal 

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

func (*GetModuleOwnerRequest) XXX_DiscardUnknown 

func (m *GetModuleOwnerRequest) XXX_DiscardUnknown()

func (*GetModuleOwnerRequest) XXX_Marshal 

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

func (*GetModuleOwnerRequest) XXX_Merge 

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

func (*GetModuleOwnerRequest) XXX_Size 

func (m *GetModuleOwnerRequest) XXX_Size() int

func (*GetModuleOwnerRequest) XXX_Unmarshal 

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

type GetModuleOwnerResponse 

type GetModuleOwnerResponse struct {
	ModuleOwner []*MsgModuleOwner `protobuf:"bytes,1,rep,name=moduleOwner,proto3" json:"moduleOwner,omitempty"`
}

func (*GetModuleOwnerResponse) Descriptor 

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

func (*GetModuleOwnerResponse) GetModuleOwner 

func (m *GetModuleOwnerResponse) GetModuleOwner() []*MsgModuleOwner

func (*GetModuleOwnerResponse) Marshal 

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

func (*GetModuleOwnerResponse) MarshalTo 

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

func (*GetModuleOwnerResponse) MarshalToSizedBuffer 

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

func (*GetModuleOwnerResponse) ProtoMessage 

func (*GetModuleOwnerResponse) ProtoMessage()

func (*GetModuleOwnerResponse) Reset 

func (m *GetModuleOwnerResponse) Reset()

func (*GetModuleOwnerResponse) Size 

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

func (*GetModuleOwnerResponse) String 

func (m *GetModuleOwnerResponse) String() string

func (*GetModuleOwnerResponse) Unmarshal 

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

func (*GetModuleOwnerResponse) XXX_DiscardUnknown 

func (m *GetModuleOwnerResponse) XXX_DiscardUnknown()

func (*GetModuleOwnerResponse) XXX_Marshal 

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

func (*GetModuleOwnerResponse) XXX_Merge 

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

func (*GetModuleOwnerResponse) XXX_Size 

func (m *GetModuleOwnerResponse) XXX_Size() int

func (*GetModuleOwnerResponse) XXX_Unmarshal 

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

type GetRoundDataRequest 

type GetRoundDataRequest struct {
	FeedId     string             `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"`
	RoundId    uint64             `protobuf:"varint,2,opt,name=roundId,proto3" json:"roundId,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*GetRoundDataRequest) Descriptor 

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

func (*GetRoundDataRequest) GetFeedId 

func (m *GetRoundDataRequest) GetFeedId() string

func (*GetRoundDataRequest) GetPagination 

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

func (*GetRoundDataRequest) GetRoundId 

func (m *GetRoundDataRequest) GetRoundId() uint64

func (*GetRoundDataRequest) Marshal 

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

func (*GetRoundDataRequest) MarshalTo 

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

func (*GetRoundDataRequest) MarshalToSizedBuffer 

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

func (*GetRoundDataRequest) ProtoMessage 

func (*GetRoundDataRequest) ProtoMessage()

func (*GetRoundDataRequest) Reset 

func (m *GetRoundDataRequest) Reset()

func (*GetRoundDataRequest) Size 

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

func (*GetRoundDataRequest) String 

func (m *GetRoundDataRequest) String() string

func (*GetRoundDataRequest) Unmarshal 

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

func (*GetRoundDataRequest) XXX_DiscardUnknown 

func (m *GetRoundDataRequest) XXX_DiscardUnknown()

func (*GetRoundDataRequest) XXX_Marshal 

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

func (*GetRoundDataRequest) XXX_Merge 

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

func (*GetRoundDataRequest) XXX_Size 

func (m *GetRoundDataRequest) XXX_Size() int

func (*GetRoundDataRequest) XXX_Unmarshal 

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

type GetRoundDataResponse 

type GetRoundDataResponse struct {
	RoundData  []*RoundData        `protobuf:"bytes,1,rep,name=roundData,proto3" json:"roundData,omitempty"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*GetRoundDataResponse) Descriptor 

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

func (*GetRoundDataResponse) GetPagination 

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

func (*GetRoundDataResponse) GetRoundData 

func (m *GetRoundDataResponse) GetRoundData() []*RoundData

func (*GetRoundDataResponse) Marshal 

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

func (*GetRoundDataResponse) MarshalTo 

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

func (*GetRoundDataResponse) MarshalToSizedBuffer 

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

func (*GetRoundDataResponse) ProtoMessage 

func (*GetRoundDataResponse) ProtoMessage()

func (*GetRoundDataResponse) Reset 

func (m *GetRoundDataResponse) Reset()

func (*GetRoundDataResponse) Size 

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

func (*GetRoundDataResponse) String 

func (m *GetRoundDataResponse) String() string

func (*GetRoundDataResponse) Unmarshal 

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

func (*GetRoundDataResponse) XXX_DiscardUnknown 

func (m *GetRoundDataResponse) XXX_DiscardUnknown()

func (*GetRoundDataResponse) XXX_Marshal 

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

func (*GetRoundDataResponse) XXX_Merge 

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

func (*GetRoundDataResponse) XXX_Size 

func (m *GetRoundDataResponse) XXX_Size() int

func (*GetRoundDataResponse) XXX_Unmarshal 

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

type MsgAccount 

type MsgAccount struct {
	// submitter - associated cosmos account address
	Submitter github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 126-byte string literal not displayed */
	// chainlinkPublicKey - public key of the associated Chainlink Oracle account
	ChainlinkPublicKey []byte `protobuf:"bytes,2,opt,name=chainlinkPublicKey,proto3" json:"chainlinkPublicKey,omitempty"`
	// chainlinkSigningKey - signing key of the associated Chainlink Oracle account
	ChainlinkSigningKey []byte `protobuf:"bytes,3,opt,name=chainlinkSigningKey,proto3" json:"chainlinkSigningKey,omitempty"`
	// piggyAddress - cosmos account address receivable for reward and fee distribution
	PiggyAddress github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 132-byte string literal not displayed */
}

MsgAccount is the type defined for account associated with the Chainlink node

func NewMsgAddAccount 

func NewMsgAddAccount(submitter githubcosmossdktypes.AccAddress, chainlinkPublicKey, chainlinkSigningKey []byte, piggyAddress githubcosmossdktypes.AccAddress) *MsgAccount

func (*MsgAccount) Descriptor 

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

func (*MsgAccount) GetChainlinkPublicKey 

func (m *MsgAccount) GetChainlinkPublicKey() []byte

func (*MsgAccount) GetChainlinkSigningKey 

func (m *MsgAccount) GetChainlinkSigningKey() []byte

func (*MsgAccount) GetPiggyAddress 

func (m *MsgAccount) GetPiggyAddress() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgAccount) GetSignBytes 

func (m *MsgAccount) GetSignBytes() []byte

func (*MsgAccount) GetSigners 

func (m *MsgAccount) GetSigners() []githubcosmossdktypes.AccAddress

func (*MsgAccount) GetSubmitter 

func (m *MsgAccount) GetSubmitter() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgAccount) Marshal 

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

func (*MsgAccount) MarshalTo 

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

func (*MsgAccount) MarshalToSizedBuffer 

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

func (*MsgAccount) ProtoMessage 

func (*MsgAccount) ProtoMessage()

func (*MsgAccount) Reset 

func (m *MsgAccount) Reset()

func (*MsgAccount) Route 

func (m *MsgAccount) Route() string

func (*MsgAccount) Size 

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

func (*MsgAccount) String 

func (m *MsgAccount) String() string

func (*MsgAccount) Type 

func (m *MsgAccount) Type() string

func (*MsgAccount) Unmarshal 

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

func (*MsgAccount) ValidateBasic 

func (m *MsgAccount) ValidateBasic() error

func (*MsgAccount) XXX_DiscardUnknown 

func (m *MsgAccount) XXX_DiscardUnknown()

func (*MsgAccount) XXX_Marshal 

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

func (*MsgAccount) XXX_Merge 

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

func (*MsgAccount) XXX_Size 

func (m *MsgAccount) XXX_Size() int

func (*MsgAccount) XXX_Unmarshal 

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

type MsgAddDataProvider 

type MsgAddDataProvider struct {
	// FeedId is the unique identifier of the feed
	FeedId string `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"`
	// DataProvider is the new data provider of the feed to add
	DataProvider *DataProvider `protobuf:"bytes,2,opt,name=dataProvider,proto3" json:"dataProvider,omitempty"`
	// Signer is the feed owner who signs the add feed provided tx
	Signer github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,3,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"`
}

MsgAddProvider is the type defined for adding new data provider of the feed

func NewMsgAddDataProvider 

func NewMsgAddDataProvider(signer githubcosmossdktypes.AccAddress, feedId string, provider *DataProvider) *MsgAddDataProvider

func (*MsgAddDataProvider) Descriptor 

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

func (*MsgAddDataProvider) GetDataProvider 

func (m *MsgAddDataProvider) GetDataProvider() *DataProvider

func (*MsgAddDataProvider) GetFeedId 

func (m *MsgAddDataProvider) GetFeedId() string

func (*MsgAddDataProvider) GetSignBytes 

func (m *MsgAddDataProvider) GetSignBytes() []byte

func (*MsgAddDataProvider) GetSigner 

func (m *MsgAddDataProvider) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgAddDataProvider) GetSigners 

func (m *MsgAddDataProvider) GetSigners() []githubcosmossdktypes.AccAddress

func (*MsgAddDataProvider) Marshal 

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

func (*MsgAddDataProvider) MarshalTo 

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

func (*MsgAddDataProvider) MarshalToSizedBuffer 

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

func (*MsgAddDataProvider) ProtoMessage 

func (*MsgAddDataProvider) ProtoMessage()

func (*MsgAddDataProvider) Reset 

func (m *MsgAddDataProvider) Reset()

func (*MsgAddDataProvider) Route 

func (m *MsgAddDataProvider) Route() string

func (*MsgAddDataProvider) Size 

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

func (*MsgAddDataProvider) String 

func (m *MsgAddDataProvider) String() string

func (*MsgAddDataProvider) Type 

func (m *MsgAddDataProvider) Type() string

func (*MsgAddDataProvider) Unmarshal 

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

func (*MsgAddDataProvider) ValidateBasic 

func (m *MsgAddDataProvider) ValidateBasic() error

func (*MsgAddDataProvider) XXX_DiscardUnknown 

func (m *MsgAddDataProvider) XXX_DiscardUnknown()

func (*MsgAddDataProvider) XXX_Marshal 

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

func (*MsgAddDataProvider) XXX_Merge 

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

func (*MsgAddDataProvider) XXX_Size 

func (m *MsgAddDataProvider) XXX_Size() int

func (*MsgAddDataProvider) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	SubmitFeedDataTx(ctx context.Context, in *MsgFeedData, opts ...grpc.CallOption) (*MsgResponse, error)
	AddModuleOwnerTx(ctx context.Context, in *MsgModuleOwner, opts ...grpc.CallOption) (*MsgResponse, error)
	ModuleOwnershipTransferTx(ctx context.Context, in *MsgModuleOwnershipTransfer, opts ...grpc.CallOption) (*MsgResponse, error)
	AddFeedTx(ctx context.Context, in *MsgFeed, opts ...grpc.CallOption) (*MsgResponse, error)
	AddDataProviderTx(ctx context.Context, in *MsgAddDataProvider, opts ...grpc.CallOption) (*MsgResponse, error)
	RemoveDataProviderTx(ctx context.Context, in *MsgRemoveDataProvider, opts ...grpc.CallOption) (*MsgResponse, error)
	SetSubmissionCountTx(ctx context.Context, in *MsgSetSubmissionCount, opts ...grpc.CallOption) (*MsgResponse, error)
	SetHeartbeatTriggerTx(ctx context.Context, in *MsgSetHeartbeatTrigger, opts ...grpc.CallOption) (*MsgResponse, error)
	SetDeviationThresholdTriggerTx(ctx context.Context, in *MsgSetDeviationThresholdTrigger, opts ...grpc.CallOption) (*MsgResponse, error)
	SetFeedRewardTx(ctx context.Context, in *MsgSetFeedReward, opts ...grpc.CallOption) (*MsgResponse, error)
	RequestNewRoundTx(ctx context.Context, in *MsgRequestNewRound, opts ...grpc.CallOption) (*MsgResponse, error)
	FeedOwnershipTransferTx(ctx context.Context, in *MsgFeedOwnershipTransfer, opts ...grpc.CallOption) (*MsgResponse, error)
	AddAccountTx(ctx context.Context, in *MsgAccount, opts ...grpc.CallOption) (*MsgResponse, error)
	EditAccountTx(ctx context.Context, in *MsgEditAccount, opts ...grpc.CallOption) (*MsgResponse, 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 MsgDataProviderSetChangeEvent 

type MsgDataProviderSetChangeEvent struct {
	FeedId string `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"`
	// changeType: either add or remove
	ChangeType       string                                        `protobuf:"bytes,2,opt,name=changeType,proto3" json:"changeType,omitempty"`
	DataProviderAddr github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 140-byte string literal not displayed */
	Signer           github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,4,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"`
}

func (*MsgDataProviderSetChangeEvent) Descriptor 

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

func (*MsgDataProviderSetChangeEvent) GetChangeType 

func (m *MsgDataProviderSetChangeEvent) GetChangeType() string

func (*MsgDataProviderSetChangeEvent) GetDataProviderAddr 

func (m *MsgDataProviderSetChangeEvent) GetDataProviderAddr() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgDataProviderSetChangeEvent) GetFeedId 

func (m *MsgDataProviderSetChangeEvent) GetFeedId() string

func (*MsgDataProviderSetChangeEvent) GetSigner 

func (m *MsgDataProviderSetChangeEvent) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgDataProviderSetChangeEvent) Marshal 

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

func (*MsgDataProviderSetChangeEvent) MarshalTo 

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

func (*MsgDataProviderSetChangeEvent) MarshalToSizedBuffer 

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

func (*MsgDataProviderSetChangeEvent) ProtoMessage 

func (*MsgDataProviderSetChangeEvent) ProtoMessage()

func (*MsgDataProviderSetChangeEvent) Reset 

func (m *MsgDataProviderSetChangeEvent) Reset()

func (*MsgDataProviderSetChangeEvent) Size 

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

func (*MsgDataProviderSetChangeEvent) String 

func (m *MsgDataProviderSetChangeEvent) String() string

func (*MsgDataProviderSetChangeEvent) Unmarshal 

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

func (*MsgDataProviderSetChangeEvent) XXX_DiscardUnknown 

func (m *MsgDataProviderSetChangeEvent) XXX_DiscardUnknown()

func (*MsgDataProviderSetChangeEvent) XXX_Marshal 

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

func (*MsgDataProviderSetChangeEvent) XXX_Merge 

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

func (*MsgDataProviderSetChangeEvent) XXX_Size 

func (m *MsgDataProviderSetChangeEvent) XXX_Size() int

func (*MsgDataProviderSetChangeEvent) XXX_Unmarshal 

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

type MsgEditAccount 

type MsgEditAccount struct {
	// submitter - associated cosmos account address
	Submitter github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 126-byte string literal not displayed */
	// piggyAddress - cosmos account address receivable for reward and fee distribution
	PiggyAddress github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 132-byte string literal not displayed */
}

MsgEditAccount is the type defined to edit a Chainlink account

func NewMsgEditAccount 

func NewMsgEditAccount(submitter githubcosmossdktypes.AccAddress, piggyAddress githubcosmossdktypes.AccAddress) *MsgEditAccount

func (*MsgEditAccount) Descriptor 

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

func (*MsgEditAccount) GetPiggyAddress 

func (m *MsgEditAccount) GetPiggyAddress() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgEditAccount) GetSignBytes 

func (m *MsgEditAccount) GetSignBytes() []byte

func (*MsgEditAccount) GetSigners 

func (m *MsgEditAccount) GetSigners() []githubcosmossdktypes.AccAddress

func (*MsgEditAccount) GetSubmitter 

func (m *MsgEditAccount) GetSubmitter() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgEditAccount) Marshal 

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

func (*MsgEditAccount) MarshalTo 

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

func (*MsgEditAccount) MarshalToSizedBuffer 

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

func (*MsgEditAccount) ProtoMessage 

func (*MsgEditAccount) ProtoMessage()

func (*MsgEditAccount) Reset 

func (m *MsgEditAccount) Reset()

func (*MsgEditAccount) Route 

func (m *MsgEditAccount) Route() string

func (*MsgEditAccount) Size 

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

func (*MsgEditAccount) String 

func (m *MsgEditAccount) String() string

func (*MsgEditAccount) Type 

func (m *MsgEditAccount) Type() string

func (*MsgEditAccount) Unmarshal 

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

func (*MsgEditAccount) ValidateBasic 

func (m *MsgEditAccount) ValidateBasic() error

func (*MsgEditAccount) XXX_DiscardUnknown 

func (m *MsgEditAccount) XXX_DiscardUnknown()

func (*MsgEditAccount) XXX_Marshal 

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

func (*MsgEditAccount) XXX_Merge 

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

func (*MsgEditAccount) XXX_Size 

func (m *MsgEditAccount) XXX_Size() int

func (*MsgEditAccount) XXX_Unmarshal 

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

type MsgFeed 

type MsgFeed struct {
	// FeedId is the unique identifier of the feed
	FeedId string `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"`
	// FeedOwner is the owner of the feed
	FeedOwner github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 126-byte string literal not displayed */
	// DataProviders is the init list of data provider of the feed
	DataProviders []*DataProvider `protobuf:"bytes,3,rep,name=dataProviders,proto3" json:"dataProviders,omitempty"`
	// The number of signatures required for a feedData submission to be valid
	SubmissionCount uint32 `protobuf:"varint,4,opt,name=submissionCount,proto3" json:"submissionCount,omitempty"`
	// The interval between which a new round should automatically be triggered.
	// The given value in milliseconds will only be approximate within block intervals
	HeartbeatTrigger uint32 `protobuf:"varint,5,opt,name=heartbeatTrigger,proto3" json:"heartbeatTrigger,omitempty"`
	// The fraction of deviation in the feed data required to trigger a new round.
	// For example if the price of ATOM/USD changes by 1% then a new round should occur
	// even if the heartbeat interval has not elapsed.
	DeviationThresholdTrigger uint32 `protobuf:"varint,6,opt,name=deviationThresholdTrigger,proto3" json:"deviationThresholdTrigger,omitempty"`
	// Module owner who signs the add feed tx
	ModuleOwnerAddress github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 144-byte string literal not displayed */
	// feedReward struct describing how rewards should be paid
	FeedReward *FeedRewardSchema `protobuf:"bytes,8,opt,name=feedReward,proto3" json:"feedReward,omitempty"`
	// Feed description
	Desc string `protobuf:"bytes,9,opt,name=desc,proto3" json:"desc,omitempty"`
}

MsgFeed is the type defined for new feed

func NewMsgFeed 

func NewMsgFeed(feedId, feedDesc string, feedOwner, moduleOwner sdk.Address, initDataProviders []*DataProvider,
	submissionCount, heartbeatTrigger, deviationThresholdTrigger uint32, baseFeedRewardAmount uint64, feedRewardStrategy string) *MsgFeed

func (*MsgFeed) Descriptor 

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

func (*MsgFeed) Empty 

func (m *MsgFeed) Empty() bool

func (*MsgFeed) GetDataProviders 

func (m *MsgFeed) GetDataProviders() []*DataProvider

func (*MsgFeed) GetDesc 

func (m *MsgFeed) GetDesc() string

func (*MsgFeed) GetDeviationThresholdTrigger 

func (m *MsgFeed) GetDeviationThresholdTrigger() uint32

func (*MsgFeed) GetFeedId 

func (m *MsgFeed) GetFeedId() string

func (*MsgFeed) GetFeedOwner 

func (m *MsgFeed) GetFeedOwner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgFeed) GetFeedReward 

func (m *MsgFeed) GetFeedReward() *FeedRewardSchema

func (*MsgFeed) GetHeartbeatTrigger 

func (m *MsgFeed) GetHeartbeatTrigger() uint32

func (*MsgFeed) GetModuleOwnerAddress 

func (m *MsgFeed) GetModuleOwnerAddress() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgFeed) GetSignBytes 

func (m *MsgFeed) GetSignBytes() []byte

func (*MsgFeed) GetSigners 

func (m *MsgFeed) GetSigners() []githubcosmossdktypes.AccAddress

func (*MsgFeed) GetSubmissionCount 

func (m *MsgFeed) GetSubmissionCount() uint32

func (*MsgFeed) Marshal 

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

func (*MsgFeed) MarshalTo 

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

func (*MsgFeed) MarshalToSizedBuffer 

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

func (*MsgFeed) ProtoMessage 

func (*MsgFeed) ProtoMessage()

func (*MsgFeed) Reset 

func (m *MsgFeed) Reset()

func (*MsgFeed) Route 

func (m *MsgFeed) Route() string

func (*MsgFeed) Size 

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

func (*MsgFeed) String 

func (m *MsgFeed) String() string

func (*MsgFeed) Type 

func (m *MsgFeed) Type() string

func (*MsgFeed) Unmarshal 

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

func (*MsgFeed) ValidateBasic 

func (m *MsgFeed) ValidateBasic() error

func (*MsgFeed) XXX_DiscardUnknown 

func (m *MsgFeed) XXX_DiscardUnknown()

func (*MsgFeed) XXX_Marshal 

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

func (*MsgFeed) XXX_Merge 

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

func (*MsgFeed) XXX_Size 

func (m *MsgFeed) XXX_Size() int

func (*MsgFeed) XXX_Unmarshal 

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

type MsgFeedData 

type MsgFeedData struct {
	// FeedId is the unique identifier of the feed
	FeedId string `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"`
	// Submitter is the leader of the current round who is calling the module to submit feed data
	Submitter github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 126-byte string literal not displayed */
	// observationFeedData is the report for price feed, could be used for general feed data
	// From proposal: The reports generated by Chainlink nodes off-chain using the OCR protocol are ABI encoded byte arrays
	// which means each report contains a byte array which could be deserialized to OCRAbiEncoded type
	// this is the original observation data array from each data provider
	ObservationFeedData [][]byte `protobuf:"bytes,3,rep,name=observationFeedData,proto3" json:"observationFeedData,omitempty"`
	// observationFeedData is the list of the data provider observation data signature of the current round, signed by chainlink prikey. This is observation signatures
	ObservationFeedDataSignatures [][]byte `protobuf:"bytes,4,rep,name=observationFeedDataSignatures,proto3" json:"observationFeedDataSignatures,omitempty"`
	// isFeedDataValid is the indicator whether feed data is valid against the external validation func, it's true by default
	IsFeedDataValid bool `protobuf:"varint,5,opt,name=isFeedDataValid,proto3" json:"isFeedDataValid,omitempty"`
	// cosmosPubKeys is the cosmos account pubKey slice of the data providers who signed this round
	CosmosPubKeys [][]byte `protobuf:"bytes,6,rep,name=cosmosPubKeys,proto3" json:"cosmosPubKeys,omitempty"`
	// txFee is the tx fee of submitting feed data
	TxFee *Coin `protobuf:"bytes,7,opt,name=txFee,proto3" json:"txFee,omitempty"`
}

MsgFeedData is the type defined for the data of the feed It could be an OCR report feed, or any general feed data in the future

func NewMsgFeedData 

func NewMsgFeedData(submitter sdk.Address, feedId string, observationFeedData [][]byte, signatures [][]byte, cosmosPubKeys [][]byte) *MsgFeedData

func (*MsgFeedData) Descriptor 

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

func (*MsgFeedData) GetCosmosPubKeys 

func (m *MsgFeedData) GetCosmosPubKeys() [][]byte

func (*MsgFeedData) GetFeedId 

func (m *MsgFeedData) GetFeedId() string

func (*MsgFeedData) GetIsFeedDataValid 

func (m *MsgFeedData) GetIsFeedDataValid() bool

func (*MsgFeedData) GetObservationFeedData 

func (m *MsgFeedData) GetObservationFeedData() [][]byte

func (*MsgFeedData) GetObservationFeedDataSignatures 

func (m *MsgFeedData) GetObservationFeedDataSignatures() [][]byte

func (*MsgFeedData) GetSignBytes 

func (m *MsgFeedData) GetSignBytes() []byte

func (*MsgFeedData) GetSigners 

func (m *MsgFeedData) GetSigners() []sdk.AccAddress

func (*MsgFeedData) GetSubmitter 

func (m *MsgFeedData) GetSubmitter() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgFeedData) GetTxFee 

func (m *MsgFeedData) GetTxFee() *Coin

func (*MsgFeedData) Marshal 

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

func (*MsgFeedData) MarshalTo 

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

func (*MsgFeedData) MarshalToSizedBuffer 

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

func (*MsgFeedData) ProtoMessage 

func (*MsgFeedData) ProtoMessage()

func (*MsgFeedData) Reset 

func (m *MsgFeedData) Reset()

func (*MsgFeedData) RewardCalculator 

func (m *MsgFeedData) RewardCalculator(feed *MsgFeed, feedData *MsgFeedData) ([]RewardPayout, uint64, error)

RewardCalculator calculates the reward for each data provider in the current submit feed data tx base on the registered reward strategy return the slice of reward payout and the total reward amount

func (*MsgFeedData) Route 

func (m *MsgFeedData) Route() string

func (*MsgFeedData) Size 

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

func (*MsgFeedData) String 

func (m *MsgFeedData) String() string

func (*MsgFeedData) Type 

func (m *MsgFeedData) Type() string

func (*MsgFeedData) Unmarshal 

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

func (*MsgFeedData) Validate 

func (m *MsgFeedData) Validate(fn func(msg sdk.Msg) bool) bool

func (*MsgFeedData) ValidateBasic 

func (m *MsgFeedData) ValidateBasic() error

func (*MsgFeedData) XXX_DiscardUnknown 

func (m *MsgFeedData) XXX_DiscardUnknown()

func (*MsgFeedData) XXX_Marshal 

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

func (*MsgFeedData) XXX_Merge 

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

func (*MsgFeedData) XXX_Size 

func (m *MsgFeedData) XXX_Size() int

func (*MsgFeedData) XXX_Unmarshal 

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

type MsgFeedDataValidationFailedEvent 

type MsgFeedDataValidationFailedEvent struct {
	FeedId    string                                        `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"`
	FeedOwner github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 126-byte string literal not displayed */
	// DataProviders is the init list of data provider of the feed
	DataProviders []*DataProvider                               `protobuf:"bytes,3,rep,name=dataProviders,proto3" json:"dataProviders,omitempty"`
	Submitter     github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 126-byte string literal not displayed */
	FeedData      [][]byte                                      `protobuf:"bytes,5,rep,name=feedData,proto3" json:"feedData,omitempty"`
	// Signatures is the data provider signature list of the current round
	Signatures [][]byte `protobuf:"bytes,6,rep,name=signatures,proto3" json:"signatures,omitempty"`
}

func (*MsgFeedDataValidationFailedEvent) Descriptor 

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

func (*MsgFeedDataValidationFailedEvent) GetDataProviders 

func (m *MsgFeedDataValidationFailedEvent) GetDataProviders() []*DataProvider

func (*MsgFeedDataValidationFailedEvent) GetFeedData 

func (m *MsgFeedDataValidationFailedEvent) GetFeedData() [][]byte

func (*MsgFeedDataValidationFailedEvent) GetFeedId 

func (m *MsgFeedDataValidationFailedEvent) GetFeedId() string

func (*MsgFeedDataValidationFailedEvent) GetFeedOwner 

func (m *MsgFeedDataValidationFailedEvent) GetFeedOwner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgFeedDataValidationFailedEvent) GetSignatures 

func (m *MsgFeedDataValidationFailedEvent) GetSignatures() [][]byte

func (*MsgFeedDataValidationFailedEvent) GetSubmitter 

func (m *MsgFeedDataValidationFailedEvent) GetSubmitter() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgFeedDataValidationFailedEvent) Marshal 

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

func (*MsgFeedDataValidationFailedEvent) MarshalTo 

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

func (*MsgFeedDataValidationFailedEvent) MarshalToSizedBuffer 

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

func (*MsgFeedDataValidationFailedEvent) ProtoMessage 

func (*MsgFeedDataValidationFailedEvent) ProtoMessage()

func (*MsgFeedDataValidationFailedEvent) Reset 

func (m *MsgFeedDataValidationFailedEvent) Reset()

func (*MsgFeedDataValidationFailedEvent) Size 

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

func (*MsgFeedDataValidationFailedEvent) String 

func (m *MsgFeedDataValidationFailedEvent) String() string

func (*MsgFeedDataValidationFailedEvent) Unmarshal 

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

func (*MsgFeedDataValidationFailedEvent) XXX_DiscardUnknown 

func (m *MsgFeedDataValidationFailedEvent) XXX_DiscardUnknown()

func (*MsgFeedDataValidationFailedEvent) XXX_Marshal 

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

func (*MsgFeedDataValidationFailedEvent) XXX_Merge 

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

func (*MsgFeedDataValidationFailedEvent) XXX_Size 

func (m *MsgFeedDataValidationFailedEvent) XXX_Size() int

func (*MsgFeedDataValidationFailedEvent) XXX_Unmarshal 

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

type MsgFeedOwnershipTransfer 

type MsgFeedOwnershipTransfer struct {
	// FeedId is the unique identifier of the feed
	FeedId string `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"`
	// NewFeedOwnerAddress is the address of the new owner of the feed
	NewFeedOwnerAddress github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 146-byte string literal not displayed */
	// Signer is the feed owner who signs the tx
	Signer github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,3,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"`
}

MsgFeedOwnershipTransfer is the type defined for feed ownership transfer

func NewMsgFeedOwnershipTransfer 

func NewMsgFeedOwnershipTransfer(signer githubcosmossdktypes.AccAddress, feedId string, newFeedOwnerAddress sdk.AccAddress) *MsgFeedOwnershipTransfer

func (*MsgFeedOwnershipTransfer) Descriptor 

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

func (*MsgFeedOwnershipTransfer) GetFeedId 

func (m *MsgFeedOwnershipTransfer) GetFeedId() string

func (*MsgFeedOwnershipTransfer) GetNewFeedOwnerAddress 

func (m *MsgFeedOwnershipTransfer) GetNewFeedOwnerAddress() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgFeedOwnershipTransfer) GetSignBytes 

func (m *MsgFeedOwnershipTransfer) GetSignBytes() []byte

func (*MsgFeedOwnershipTransfer) GetSigner 

func (m *MsgFeedOwnershipTransfer) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgFeedOwnershipTransfer) GetSigners 

func (m *MsgFeedOwnershipTransfer) GetSigners() []githubcosmossdktypes.AccAddress

func (*MsgFeedOwnershipTransfer) Marshal 

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

func (*MsgFeedOwnershipTransfer) MarshalTo 

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

func (*MsgFeedOwnershipTransfer) MarshalToSizedBuffer 

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

func (*MsgFeedOwnershipTransfer) ProtoMessage 

func (*MsgFeedOwnershipTransfer) ProtoMessage()

func (*MsgFeedOwnershipTransfer) Reset 

func (m *MsgFeedOwnershipTransfer) Reset()

func (*MsgFeedOwnershipTransfer) Route 

func (m *MsgFeedOwnershipTransfer) Route() string

func (*MsgFeedOwnershipTransfer) Size 

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

func (*MsgFeedOwnershipTransfer) String 

func (m *MsgFeedOwnershipTransfer) String() string

func (*MsgFeedOwnershipTransfer) Type 

func (m *MsgFeedOwnershipTransfer) Type() string

func (*MsgFeedOwnershipTransfer) Unmarshal 

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

func (*MsgFeedOwnershipTransfer) ValidateBasic 

func (m *MsgFeedOwnershipTransfer) ValidateBasic() error

func (*MsgFeedOwnershipTransfer) XXX_DiscardUnknown 

func (m *MsgFeedOwnershipTransfer) XXX_DiscardUnknown()

func (*MsgFeedOwnershipTransfer) XXX_Marshal 

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

func (*MsgFeedOwnershipTransfer) XXX_Merge 

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

func (*MsgFeedOwnershipTransfer) XXX_Size 

func (m *MsgFeedOwnershipTransfer) XXX_Size() int

func (*MsgFeedOwnershipTransfer) XXX_Unmarshal 

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

type MsgFeedOwnershipTransferEvent 

type MsgFeedOwnershipTransferEvent struct {
	FeedId           string                                        `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"`
	NewFeedOwnerAddr github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 140-byte string literal not displayed */
	Signer           github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,3,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"`
}

func (*MsgFeedOwnershipTransferEvent) Descriptor 

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

func (*MsgFeedOwnershipTransferEvent) GetFeedId 

func (m *MsgFeedOwnershipTransferEvent) GetFeedId() string

func (*MsgFeedOwnershipTransferEvent) GetNewFeedOwnerAddr 

func (m *MsgFeedOwnershipTransferEvent) GetNewFeedOwnerAddr() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgFeedOwnershipTransferEvent) GetSigner 

func (m *MsgFeedOwnershipTransferEvent) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgFeedOwnershipTransferEvent) Marshal 

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

func (*MsgFeedOwnershipTransferEvent) MarshalTo 

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

func (*MsgFeedOwnershipTransferEvent) MarshalToSizedBuffer 

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

func (*MsgFeedOwnershipTransferEvent) ProtoMessage 

func (*MsgFeedOwnershipTransferEvent) ProtoMessage()

func (*MsgFeedOwnershipTransferEvent) Reset 

func (m *MsgFeedOwnershipTransferEvent) Reset()

func (*MsgFeedOwnershipTransferEvent) Size 

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

func (*MsgFeedOwnershipTransferEvent) String 

func (m *MsgFeedOwnershipTransferEvent) String() string

func (*MsgFeedOwnershipTransferEvent) Unmarshal 

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

func (*MsgFeedOwnershipTransferEvent) XXX_DiscardUnknown 

func (m *MsgFeedOwnershipTransferEvent) XXX_DiscardUnknown()

func (*MsgFeedOwnershipTransferEvent) XXX_Marshal 

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

func (*MsgFeedOwnershipTransferEvent) XXX_Merge 

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

func (*MsgFeedOwnershipTransferEvent) XXX_Size 

func (m *MsgFeedOwnershipTransferEvent) XXX_Size() int

func (*MsgFeedOwnershipTransferEvent) XXX_Unmarshal 

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

type MsgFeedParameterChangeEvent 

type MsgFeedParameterChangeEvent struct {
	FeedId string `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"`
	// changeType: either DeviationThreshold, heartbeatTrigger, submissionCount
	ChangeType        string                                        `protobuf:"bytes,2,opt,name=changeType,proto3" json:"changeType,omitempty"`
	NewParameterValue uint32                                        `protobuf:"varint,3,opt,name=newParameterValue,proto3" json:"newParameterValue,omitempty"`
	Signer            github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,4,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"`
}

func (*MsgFeedParameterChangeEvent) Descriptor 

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

func (*MsgFeedParameterChangeEvent) GetChangeType 

func (m *MsgFeedParameterChangeEvent) GetChangeType() string

func (*MsgFeedParameterChangeEvent) GetFeedId 

func (m *MsgFeedParameterChangeEvent) GetFeedId() string

func (*MsgFeedParameterChangeEvent) GetNewParameterValue 

func (m *MsgFeedParameterChangeEvent) GetNewParameterValue() uint32

func (*MsgFeedParameterChangeEvent) GetSigner 

func (m *MsgFeedParameterChangeEvent) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgFeedParameterChangeEvent) Marshal 

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

func (*MsgFeedParameterChangeEvent) MarshalTo 

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

func (*MsgFeedParameterChangeEvent) MarshalToSizedBuffer 

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

func (*MsgFeedParameterChangeEvent) ProtoMessage 

func (*MsgFeedParameterChangeEvent) ProtoMessage()

func (*MsgFeedParameterChangeEvent) Reset 

func (m *MsgFeedParameterChangeEvent) Reset()

func (*MsgFeedParameterChangeEvent) Size 

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

func (*MsgFeedParameterChangeEvent) String 

func (m *MsgFeedParameterChangeEvent) String() string

func (*MsgFeedParameterChangeEvent) Unmarshal 

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

func (*MsgFeedParameterChangeEvent) XXX_DiscardUnknown 

func (m *MsgFeedParameterChangeEvent) XXX_DiscardUnknown()

func (*MsgFeedParameterChangeEvent) XXX_Marshal 

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

func (*MsgFeedParameterChangeEvent) XXX_Merge 

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

func (*MsgFeedParameterChangeEvent) XXX_Size 

func (m *MsgFeedParameterChangeEvent) XXX_Size() int

func (*MsgFeedParameterChangeEvent) XXX_Unmarshal 

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

type MsgFeedRewardSchemaChangeEvent 

type MsgFeedRewardSchemaChangeEvent struct {
	FeedId        string                                        `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"`
	NewStrategy   string                                        `protobuf:"bytes,2,opt,name=newStrategy,proto3" json:"newStrategy,omitempty"`
	NewBaseAmount uint64                                        `protobuf:"varint,3,opt,name=newBaseAmount,proto3" json:"newBaseAmount,omitempty"`
	Signer        github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,4,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"`
}

func (*MsgFeedRewardSchemaChangeEvent) Descriptor 

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

func (*MsgFeedRewardSchemaChangeEvent) GetFeedId 

func (m *MsgFeedRewardSchemaChangeEvent) GetFeedId() string

func (*MsgFeedRewardSchemaChangeEvent) GetNewBaseAmount 

func (m *MsgFeedRewardSchemaChangeEvent) GetNewBaseAmount() uint64

func (*MsgFeedRewardSchemaChangeEvent) GetNewStrategy 

func (m *MsgFeedRewardSchemaChangeEvent) GetNewStrategy() string

func (*MsgFeedRewardSchemaChangeEvent) GetSigner 

func (m *MsgFeedRewardSchemaChangeEvent) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgFeedRewardSchemaChangeEvent) Marshal 

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

func (*MsgFeedRewardSchemaChangeEvent) MarshalTo 

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

func (*MsgFeedRewardSchemaChangeEvent) MarshalToSizedBuffer 

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

func (*MsgFeedRewardSchemaChangeEvent) ProtoMessage 

func (*MsgFeedRewardSchemaChangeEvent) ProtoMessage()

func (*MsgFeedRewardSchemaChangeEvent) Reset 

func (m *MsgFeedRewardSchemaChangeEvent) Reset()

func (*MsgFeedRewardSchemaChangeEvent) Size 

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

func (*MsgFeedRewardSchemaChangeEvent) String 

func (m *MsgFeedRewardSchemaChangeEvent) String() string

func (*MsgFeedRewardSchemaChangeEvent) Unmarshal 

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

func (*MsgFeedRewardSchemaChangeEvent) XXX_DiscardUnknown 

func (m *MsgFeedRewardSchemaChangeEvent) XXX_DiscardUnknown()

func (*MsgFeedRewardSchemaChangeEvent) XXX_Marshal 

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

func (*MsgFeedRewardSchemaChangeEvent) XXX_Merge 

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

func (*MsgFeedRewardSchemaChangeEvent) XXX_Size 

func (m *MsgFeedRewardSchemaChangeEvent) XXX_Size() int

func (*MsgFeedRewardSchemaChangeEvent) XXX_Unmarshal 

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

type MsgModuleOwner 

type MsgModuleOwner struct {
	// address defines the address of the module owner
	Address github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 137-byte string literal not displayed */
	// pubKey defined the public key of the module owner
	PubKey []byte `protobuf:"bytes,2,opt,name=pubKey,proto3" json:"pubKey,omitempty" yaml:"pub_key"`
	// the module owner who assigned this new module owner
	AssignerAddress github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 138-byte string literal not displayed */
}

func NewMsgModuleOwner 

func NewMsgModuleOwner(assigner, address sdk.Address, pubKey []byte) *MsgModuleOwner

func (*MsgModuleOwner) Descriptor 

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

func (*MsgModuleOwner) GetAddress 

func (m *MsgModuleOwner) GetAddress() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgModuleOwner) GetAssignerAddress 

func (m *MsgModuleOwner) GetAssignerAddress() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgModuleOwner) GetMsgs 

func (m *MsgModuleOwner) GetMsgs() []githubcosmossdktypes.Msg

func (*MsgModuleOwner) GetPubKey 

func (m *MsgModuleOwner) GetPubKey() []byte

func (*MsgModuleOwner) GetSignBytes 

func (m *MsgModuleOwner) GetSignBytes() []byte

func (*MsgModuleOwner) GetSigners 

func (m *MsgModuleOwner) GetSigners() []sdk.AccAddress

func (*MsgModuleOwner) Marshal 

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

func (*MsgModuleOwner) MarshalTo 

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

func (*MsgModuleOwner) MarshalToSizedBuffer 

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

func (*MsgModuleOwner) ProtoMessage 

func (*MsgModuleOwner) ProtoMessage()

func (*MsgModuleOwner) Reset 

func (m *MsgModuleOwner) Reset()

func (*MsgModuleOwner) Route 

func (m *MsgModuleOwner) Route() string

func (*MsgModuleOwner) Size 

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

func (*MsgModuleOwner) String 

func (m *MsgModuleOwner) String() string

func (*MsgModuleOwner) Type 

func (m *MsgModuleOwner) Type() string

func (*MsgModuleOwner) Unmarshal 

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

func (MsgModuleOwner) Validate 

func (m MsgModuleOwner) Validate() error

func (*MsgModuleOwner) ValidateBasic 

func (m *MsgModuleOwner) ValidateBasic() error

func (*MsgModuleOwner) XXX_DiscardUnknown 

func (m *MsgModuleOwner) XXX_DiscardUnknown()

func (*MsgModuleOwner) XXX_Marshal 

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

func (*MsgModuleOwner) XXX_Merge 

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

func (*MsgModuleOwner) XXX_Size 

func (m *MsgModuleOwner) XXX_Size() int

func (*MsgModuleOwner) XXX_Unmarshal 

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

type MsgModuleOwners 

type MsgModuleOwners []*MsgModuleOwner

func (MsgModuleOwners) Contains 

func (mo MsgModuleOwners) Contains(addr sdk.Address) bool

Contains returns true if the given address exists in a slice of ModuleOwners.

type MsgModuleOwnershipTransfer 

type MsgModuleOwnershipTransfer struct {
	// current module owner address
	AssignerAddress       github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 138-byte string literal not displayed */
	NewModuleOwnerAddress github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 150-byte string literal not displayed */
	NewModuleOwnerPubKey  []byte                                        `protobuf:"bytes,3,opt,name=newModuleOwnerPubKey,proto3" json:"newModuleOwnerPubKey,omitempty" yaml:"pub_key"`
}

MsgModuleOwnershipTransfer is the type defined for module ownership transfer

func NewMsgModuleOwnershipTransfer 

func NewMsgModuleOwnershipTransfer(assigner, address sdk.Address, pubKey []byte) *MsgModuleOwnershipTransfer

func (*MsgModuleOwnershipTransfer) Descriptor 

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

func (*MsgModuleOwnershipTransfer) GetAssignerAddress 

func (m *MsgModuleOwnershipTransfer) GetAssignerAddress() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgModuleOwnershipTransfer) GetNewModuleOwnerAddress 

func (m *MsgModuleOwnershipTransfer) GetNewModuleOwnerAddress() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgModuleOwnershipTransfer) GetNewModuleOwnerPubKey 

func (m *MsgModuleOwnershipTransfer) GetNewModuleOwnerPubKey() []byte

func (*MsgModuleOwnershipTransfer) GetSignBytes 

func (m *MsgModuleOwnershipTransfer) GetSignBytes() []byte

func (*MsgModuleOwnershipTransfer) GetSigners 

func (m *MsgModuleOwnershipTransfer) GetSigners() []githubcosmossdktypes.AccAddress

func (*MsgModuleOwnershipTransfer) Marshal 

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

func (*MsgModuleOwnershipTransfer) MarshalTo 

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

func (*MsgModuleOwnershipTransfer) MarshalToSizedBuffer 

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

func (*MsgModuleOwnershipTransfer) ProtoMessage 

func (*MsgModuleOwnershipTransfer) ProtoMessage()

func (*MsgModuleOwnershipTransfer) Reset 

func (m *MsgModuleOwnershipTransfer) Reset()

func (*MsgModuleOwnershipTransfer) Route 

func (m *MsgModuleOwnershipTransfer) Route() string

func (*MsgModuleOwnershipTransfer) Size 

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

func (*MsgModuleOwnershipTransfer) String 

func (m *MsgModuleOwnershipTransfer) String() string

func (*MsgModuleOwnershipTransfer) Type 

func (m *MsgModuleOwnershipTransfer) Type() string

func (*MsgModuleOwnershipTransfer) Unmarshal 

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

func (*MsgModuleOwnershipTransfer) ValidateBasic 

func (m *MsgModuleOwnershipTransfer) ValidateBasic() error

func (*MsgModuleOwnershipTransfer) XXX_DiscardUnknown 

func (m *MsgModuleOwnershipTransfer) XXX_DiscardUnknown()

func (*MsgModuleOwnershipTransfer) XXX_Marshal 

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

func (*MsgModuleOwnershipTransfer) XXX_Merge 

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

func (*MsgModuleOwnershipTransfer) XXX_Size 

func (m *MsgModuleOwnershipTransfer) XXX_Size() int

func (*MsgModuleOwnershipTransfer) XXX_Unmarshal 

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

type MsgModuleOwnershipTransferEvent 

type MsgModuleOwnershipTransferEvent struct {
	NewModuleOwnerAddr github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 144-byte string literal not displayed */
	Signer             github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,4,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"`
}

func (*MsgModuleOwnershipTransferEvent) Descriptor 

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

func (*MsgModuleOwnershipTransferEvent) GetNewModuleOwnerAddr 

func (m *MsgModuleOwnershipTransferEvent) GetNewModuleOwnerAddr() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgModuleOwnershipTransferEvent) GetSigner 

func (m *MsgModuleOwnershipTransferEvent) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgModuleOwnershipTransferEvent) Marshal 

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

func (*MsgModuleOwnershipTransferEvent) MarshalTo 

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

func (*MsgModuleOwnershipTransferEvent) MarshalToSizedBuffer 

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

func (*MsgModuleOwnershipTransferEvent) ProtoMessage 

func (*MsgModuleOwnershipTransferEvent) ProtoMessage()

func (*MsgModuleOwnershipTransferEvent) Reset 

func (m *MsgModuleOwnershipTransferEvent) Reset()

func (*MsgModuleOwnershipTransferEvent) Size 

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

func (*MsgModuleOwnershipTransferEvent) String 

func (m *MsgModuleOwnershipTransferEvent) String() string

func (*MsgModuleOwnershipTransferEvent) Unmarshal 

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

func (*MsgModuleOwnershipTransferEvent) XXX_DiscardUnknown 

func (m *MsgModuleOwnershipTransferEvent) XXX_DiscardUnknown()

func (*MsgModuleOwnershipTransferEvent) XXX_Marshal 

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

func (*MsgModuleOwnershipTransferEvent) XXX_Merge 

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

func (*MsgModuleOwnershipTransferEvent) XXX_Size 

func (m *MsgModuleOwnershipTransferEvent) XXX_Size() int

func (*MsgModuleOwnershipTransferEvent) XXX_Unmarshal 

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

type MsgNewFeedEvent 

type MsgNewFeedEvent struct {
	FeedId        string                                        `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"`
	DataProviders []*DataProvider                               `protobuf:"bytes,2,rep,name=dataProviders,proto3" json:"dataProviders,omitempty"`
	FeedOwner     github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 126-byte string literal not displayed */
}

func (*MsgNewFeedEvent) Descriptor 

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

func (*MsgNewFeedEvent) GetDataProviders 

func (m *MsgNewFeedEvent) GetDataProviders() []*DataProvider

func (*MsgNewFeedEvent) GetFeedId 

func (m *MsgNewFeedEvent) GetFeedId() string

func (*MsgNewFeedEvent) GetFeedOwner 

func (m *MsgNewFeedEvent) GetFeedOwner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgNewFeedEvent) Marshal 

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

func (*MsgNewFeedEvent) MarshalTo 

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

func (*MsgNewFeedEvent) MarshalToSizedBuffer 

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

func (*MsgNewFeedEvent) ProtoMessage 

func (*MsgNewFeedEvent) ProtoMessage()

func (*MsgNewFeedEvent) Reset 

func (m *MsgNewFeedEvent) Reset()

func (*MsgNewFeedEvent) Size 

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

func (*MsgNewFeedEvent) String 

func (m *MsgNewFeedEvent) String() string

func (*MsgNewFeedEvent) Unmarshal 

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

func (*MsgNewFeedEvent) XXX_DiscardUnknown 

func (m *MsgNewFeedEvent) XXX_DiscardUnknown()

func (*MsgNewFeedEvent) XXX_Marshal 

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

func (*MsgNewFeedEvent) XXX_Merge 

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

func (*MsgNewFeedEvent) XXX_Size 

func (m *MsgNewFeedEvent) XXX_Size() int

func (*MsgNewFeedEvent) XXX_Unmarshal 

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

type MsgNewRoundDataEvent 

type MsgNewRoundDataEvent struct {
	FeedId   string   `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"`
	RoundId  uint64   `protobuf:"varint,2,opt,name=roundId,proto3" json:"roundId,omitempty"`
	FeedData [][]byte `protobuf:"bytes,3,rep,name=feedData,proto3" json:"feedData,omitempty"`
}

func (*MsgNewRoundDataEvent) Descriptor 

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

func (*MsgNewRoundDataEvent) GetFeedData 

func (m *MsgNewRoundDataEvent) GetFeedData() [][]byte

func (*MsgNewRoundDataEvent) GetFeedId 

func (m *MsgNewRoundDataEvent) GetFeedId() string

func (*MsgNewRoundDataEvent) GetRoundId 

func (m *MsgNewRoundDataEvent) GetRoundId() uint64

func (*MsgNewRoundDataEvent) Marshal 

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

func (*MsgNewRoundDataEvent) MarshalTo 

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

func (*MsgNewRoundDataEvent) MarshalToSizedBuffer 

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

func (*MsgNewRoundDataEvent) ProtoMessage 

func (*MsgNewRoundDataEvent) ProtoMessage()

func (*MsgNewRoundDataEvent) Reset 

func (m *MsgNewRoundDataEvent) Reset()

func (*MsgNewRoundDataEvent) Size 

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

func (*MsgNewRoundDataEvent) String 

func (m *MsgNewRoundDataEvent) String() string

func (*MsgNewRoundDataEvent) Unmarshal 

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

func (*MsgNewRoundDataEvent) XXX_DiscardUnknown 

func (m *MsgNewRoundDataEvent) XXX_DiscardUnknown()

func (*MsgNewRoundDataEvent) XXX_Marshal 

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

func (*MsgNewRoundDataEvent) XXX_Merge 

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

func (*MsgNewRoundDataEvent) XXX_Size 

func (m *MsgNewRoundDataEvent) XXX_Size() int

func (*MsgNewRoundDataEvent) XXX_Unmarshal 

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

type MsgNewRoundRequestEvent 

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

func (*MsgNewRoundRequestEvent) Descriptor 

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

func (*MsgNewRoundRequestEvent) GetFeedId 

func (m *MsgNewRoundRequestEvent) GetFeedId() string

func (*MsgNewRoundRequestEvent) Marshal 

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

func (*MsgNewRoundRequestEvent) MarshalTo 

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

func (*MsgNewRoundRequestEvent) MarshalToSizedBuffer 

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

func (*MsgNewRoundRequestEvent) ProtoMessage 

func (*MsgNewRoundRequestEvent) ProtoMessage()

func (*MsgNewRoundRequestEvent) Reset 

func (m *MsgNewRoundRequestEvent) Reset()

func (*MsgNewRoundRequestEvent) Size 

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

func (*MsgNewRoundRequestEvent) String 

func (m *MsgNewRoundRequestEvent) String() string

func (*MsgNewRoundRequestEvent) Unmarshal 

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

func (*MsgNewRoundRequestEvent) XXX_DiscardUnknown 

func (m *MsgNewRoundRequestEvent) XXX_DiscardUnknown()

func (*MsgNewRoundRequestEvent) XXX_Marshal 

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

func (*MsgNewRoundRequestEvent) XXX_Merge 

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

func (*MsgNewRoundRequestEvent) XXX_Size 

func (m *MsgNewRoundRequestEvent) XXX_Size() int

func (*MsgNewRoundRequestEvent) XXX_Unmarshal 

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

type MsgOraclePaidEvent 

type MsgOraclePaidEvent struct {
	FeedId string `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"`
	// The account that was paid to
	Account github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,2,opt,name=account,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"account,omitempty"`
	Value   uint64                                        `protobuf:"varint,3,opt,name=value,proto3" json:"value,omitempty"`
}

func (*MsgOraclePaidEvent) Descriptor 

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

func (*MsgOraclePaidEvent) GetAccount 

func (m *MsgOraclePaidEvent) GetAccount() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgOraclePaidEvent) GetFeedId 

func (m *MsgOraclePaidEvent) GetFeedId() string

func (*MsgOraclePaidEvent) GetValue 

func (m *MsgOraclePaidEvent) GetValue() uint64

func (*MsgOraclePaidEvent) Marshal 

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

func (*MsgOraclePaidEvent) MarshalTo 

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

func (*MsgOraclePaidEvent) MarshalToSizedBuffer 

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

func (*MsgOraclePaidEvent) ProtoMessage 

func (*MsgOraclePaidEvent) ProtoMessage()

func (*MsgOraclePaidEvent) Reset 

func (m *MsgOraclePaidEvent) Reset()

func (*MsgOraclePaidEvent) Size 

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

func (*MsgOraclePaidEvent) String 

func (m *MsgOraclePaidEvent) String() string

func (*MsgOraclePaidEvent) Unmarshal 

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

func (*MsgOraclePaidEvent) XXX_DiscardUnknown 

func (m *MsgOraclePaidEvent) XXX_DiscardUnknown()

func (*MsgOraclePaidEvent) XXX_Marshal 

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

func (*MsgOraclePaidEvent) XXX_Merge 

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

func (*MsgOraclePaidEvent) XXX_Size 

func (m *MsgOraclePaidEvent) XXX_Size() int

func (*MsgOraclePaidEvent) XXX_Unmarshal 

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

type MsgRemoveDataProvider 

type MsgRemoveDataProvider struct {
	// FeedId is the unique identifier of the feed
	FeedId string `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"`
	// Address of the data provider to remove from the feed
	Address github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,2,opt,name=address,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"address,omitempty"`
	// Signer is the feed owner who signs the remove feed provided tx
	Signer github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,3,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"`
}

MsgRemoveProvider is the type defined for removing a data provider of the feed

func NewMsgRemoveDataProvider 

func NewMsgRemoveDataProvider(signer githubcosmossdktypes.AccAddress, feedId string, address githubcosmossdktypes.AccAddress) *MsgRemoveDataProvider

func (*MsgRemoveDataProvider) Descriptor 

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

func (*MsgRemoveDataProvider) GetAddress 

func (m *MsgRemoveDataProvider) GetAddress() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgRemoveDataProvider) GetFeedId 

func (m *MsgRemoveDataProvider) GetFeedId() string

func (*MsgRemoveDataProvider) GetSignBytes 

func (m *MsgRemoveDataProvider) GetSignBytes() []byte

func (*MsgRemoveDataProvider) GetSigner 

func (m *MsgRemoveDataProvider) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgRemoveDataProvider) GetSigners 

func (m *MsgRemoveDataProvider) GetSigners() []githubcosmossdktypes.AccAddress

func (*MsgRemoveDataProvider) Marshal 

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

func (*MsgRemoveDataProvider) MarshalTo 

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

func (*MsgRemoveDataProvider) MarshalToSizedBuffer 

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

func (*MsgRemoveDataProvider) ProtoMessage 

func (*MsgRemoveDataProvider) ProtoMessage()

func (*MsgRemoveDataProvider) Reset 

func (m *MsgRemoveDataProvider) Reset()

func (*MsgRemoveDataProvider) Route 

func (m *MsgRemoveDataProvider) Route() string

func (*MsgRemoveDataProvider) Size 

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

func (*MsgRemoveDataProvider) String 

func (m *MsgRemoveDataProvider) String() string

func (*MsgRemoveDataProvider) Type 

func (m *MsgRemoveDataProvider) Type() string

func (*MsgRemoveDataProvider) Unmarshal 

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

func (*MsgRemoveDataProvider) ValidateBasic 

func (m *MsgRemoveDataProvider) ValidateBasic() error

func (*MsgRemoveDataProvider) XXX_DiscardUnknown 

func (m *MsgRemoveDataProvider) XXX_DiscardUnknown()

func (*MsgRemoveDataProvider) XXX_Marshal 

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

func (*MsgRemoveDataProvider) XXX_Merge 

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

func (*MsgRemoveDataProvider) XXX_Size 

func (m *MsgRemoveDataProvider) XXX_Size() int

func (*MsgRemoveDataProvider) XXX_Unmarshal 

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

type MsgRequestNewRound 

type MsgRequestNewRound struct {
	// FeedId is the unique identifier of the feed
	FeedId string `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"`
	// Signer is the feed owner who signs the tx
	Signer github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,3,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"`
}

MsgRequestNewRound is the type defined for requesting new rounds to be triggered for a given feed

func NewMsgRequestNewRound 

func NewMsgRequestNewRound(signer githubcosmossdktypes.AccAddress, feedId string) *MsgRequestNewRound

func (*MsgRequestNewRound) Descriptor 

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

func (*MsgRequestNewRound) GetFeedId 

func (m *MsgRequestNewRound) GetFeedId() string

func (*MsgRequestNewRound) GetSignBytes 

func (m *MsgRequestNewRound) GetSignBytes() []byte

func (*MsgRequestNewRound) GetSigner 

func (m *MsgRequestNewRound) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgRequestNewRound) GetSigners 

func (m *MsgRequestNewRound) GetSigners() []githubcosmossdktypes.AccAddress

func (*MsgRequestNewRound) Marshal 

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

func (*MsgRequestNewRound) MarshalTo 

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

func (*MsgRequestNewRound) MarshalToSizedBuffer 

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

func (*MsgRequestNewRound) ProtoMessage 

func (*MsgRequestNewRound) ProtoMessage()

func (*MsgRequestNewRound) Reset 

func (m *MsgRequestNewRound) Reset()

func (*MsgRequestNewRound) Route 

func (m *MsgRequestNewRound) Route() string

func (*MsgRequestNewRound) Size 

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

func (*MsgRequestNewRound) String 

func (m *MsgRequestNewRound) String() string

func (*MsgRequestNewRound) Type 

func (m *MsgRequestNewRound) Type() string

func (*MsgRequestNewRound) Unmarshal 

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

func (*MsgRequestNewRound) ValidateBasic 

func (m *MsgRequestNewRound) ValidateBasic() error

func (*MsgRequestNewRound) XXX_DiscardUnknown 

func (m *MsgRequestNewRound) XXX_DiscardUnknown()

func (*MsgRequestNewRound) XXX_Marshal 

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

func (*MsgRequestNewRound) XXX_Merge 

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

func (*MsgRequestNewRound) XXX_Size 

func (m *MsgRequestNewRound) XXX_Size() int

func (*MsgRequestNewRound) XXX_Unmarshal 

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

type MsgResponse 

type MsgResponse struct {
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	TxHash string `protobuf:"bytes,2,opt,name=txHash,proto3" json:"txHash,omitempty"`
}

func (*MsgResponse) Descriptor 

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

func (*MsgResponse) GetHeight 

func (m *MsgResponse) GetHeight() uint64

func (*MsgResponse) GetTxHash 

func (m *MsgResponse) GetTxHash() string

func (*MsgResponse) Marshal 

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

func (*MsgResponse) MarshalTo 

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

func (*MsgResponse) MarshalToSizedBuffer 

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

func (*MsgResponse) ProtoMessage 

func (*MsgResponse) ProtoMessage()

func (*MsgResponse) Reset 

func (m *MsgResponse) Reset()

func (*MsgResponse) Size 

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

func (*MsgResponse) String 

func (m *MsgResponse) String() string

func (*MsgResponse) Unmarshal 

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

func (*MsgResponse) XXX_DiscardUnknown 

func (m *MsgResponse) XXX_DiscardUnknown()

func (*MsgResponse) XXX_Marshal 

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

func (*MsgResponse) XXX_Merge 

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

func (*MsgResponse) XXX_Size 

func (m *MsgResponse) XXX_Size() int

func (*MsgResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	SubmitFeedDataTx(context.Context, *MsgFeedData) (*MsgResponse, error)
	AddModuleOwnerTx(context.Context, *MsgModuleOwner) (*MsgResponse, error)
	ModuleOwnershipTransferTx(context.Context, *MsgModuleOwnershipTransfer) (*MsgResponse, error)
	AddFeedTx(context.Context, *MsgFeed) (*MsgResponse, error)
	AddDataProviderTx(context.Context, *MsgAddDataProvider) (*MsgResponse, error)
	RemoveDataProviderTx(context.Context, *MsgRemoveDataProvider) (*MsgResponse, error)
	SetSubmissionCountTx(context.Context, *MsgSetSubmissionCount) (*MsgResponse, error)
	SetHeartbeatTriggerTx(context.Context, *MsgSetHeartbeatTrigger) (*MsgResponse, error)
	SetDeviationThresholdTriggerTx(context.Context, *MsgSetDeviationThresholdTrigger) (*MsgResponse, error)
	SetFeedRewardTx(context.Context, *MsgSetFeedReward) (*MsgResponse, error)
	RequestNewRoundTx(context.Context, *MsgRequestNewRound) (*MsgResponse, error)
	FeedOwnershipTransferTx(context.Context, *MsgFeedOwnershipTransfer) (*MsgResponse, error)
	AddAccountTx(context.Context, *MsgAccount) (*MsgResponse, error)
	EditAccountTx(context.Context, *MsgEditAccount) (*MsgResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSetDeviationThresholdTrigger 

type MsgSetDeviationThresholdTrigger struct {
	// FeedId is the unique identifier of the feed
	FeedId string `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"`
	// The fraction of deviation in the feed data required to trigger a new round.
	// For example if the price of ATOM/USD changes by 1% then a new round should occur
	// even if the heartbeat interval has not elapsed.
	DeviationThresholdTrigger uint32 `protobuf:"varint,2,opt,name=deviationThresholdTrigger,proto3" json:"deviationThresholdTrigger,omitempty"`
	// Signer is the feed owner who signs the tx
	Signer github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,3,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"`
}

func NewMsgSetDeviationThreshold 

func NewMsgSetDeviationThreshold(signer githubcosmossdktypes.AccAddress, feedId string, deviationThresholdTrigger uint32) *MsgSetDeviationThresholdTrigger

func (*MsgSetDeviationThresholdTrigger) Descriptor 

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

func (*MsgSetDeviationThresholdTrigger) GetDeviationThresholdTrigger 

func (m *MsgSetDeviationThresholdTrigger) GetDeviationThresholdTrigger() uint32

func (*MsgSetDeviationThresholdTrigger) GetFeedId 

func (m *MsgSetDeviationThresholdTrigger) GetFeedId() string

func (*MsgSetDeviationThresholdTrigger) GetSignBytes 

func (m *MsgSetDeviationThresholdTrigger) GetSignBytes() []byte

func (*MsgSetDeviationThresholdTrigger) GetSigner 

func (m *MsgSetDeviationThresholdTrigger) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgSetDeviationThresholdTrigger) GetSigners 

func (m *MsgSetDeviationThresholdTrigger) GetSigners() []githubcosmossdktypes.AccAddress

func (*MsgSetDeviationThresholdTrigger) Marshal 

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

func (*MsgSetDeviationThresholdTrigger) MarshalTo 

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

func (*MsgSetDeviationThresholdTrigger) MarshalToSizedBuffer 

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

func (*MsgSetDeviationThresholdTrigger) ProtoMessage 

func (*MsgSetDeviationThresholdTrigger) ProtoMessage()

func (*MsgSetDeviationThresholdTrigger) Reset 

func (m *MsgSetDeviationThresholdTrigger) Reset()

func (*MsgSetDeviationThresholdTrigger) Route 

func (m *MsgSetDeviationThresholdTrigger) Route() string

func (*MsgSetDeviationThresholdTrigger) Size 

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

func (*MsgSetDeviationThresholdTrigger) String 

func (m *MsgSetDeviationThresholdTrigger) String() string

func (*MsgSetDeviationThresholdTrigger) Type 

func (m *MsgSetDeviationThresholdTrigger) Type() string

func (*MsgSetDeviationThresholdTrigger) Unmarshal 

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

func (*MsgSetDeviationThresholdTrigger) ValidateBasic 

func (m *MsgSetDeviationThresholdTrigger) ValidateBasic() error

func (*MsgSetDeviationThresholdTrigger) XXX_DiscardUnknown 

func (m *MsgSetDeviationThresholdTrigger) XXX_DiscardUnknown()

func (*MsgSetDeviationThresholdTrigger) XXX_Marshal 

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

func (*MsgSetDeviationThresholdTrigger) XXX_Merge 

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

func (*MsgSetDeviationThresholdTrigger) XXX_Size 

func (m *MsgSetDeviationThresholdTrigger) XXX_Size() int

func (*MsgSetDeviationThresholdTrigger) XXX_Unmarshal 

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

type MsgSetFeedReward 

type MsgSetFeedReward struct {
	// FeedId is the unique identifier of the feed
	FeedId string `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"`
	// The reward distributed to the data providers in a given feed.
	// The reward will be given as the native token in the application, denominated as "link"
	FeedReward *FeedRewardSchema `protobuf:"bytes,2,opt,name=feedReward,proto3" json:"feedReward,omitempty"`
	// Signer is the feed owner who signs the tx
	Signer github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,3,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"`
}

func NewMsgSetFeedReward 

func NewMsgSetFeedReward(signer githubcosmossdktypes.AccAddress, feedId string, baseFeedRewardAmount uint64, feedRewardStrategy string) *MsgSetFeedReward

func (*MsgSetFeedReward) Descriptor 

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

func (*MsgSetFeedReward) GetFeedId 

func (m *MsgSetFeedReward) GetFeedId() string

func (*MsgSetFeedReward) GetFeedReward 

func (m *MsgSetFeedReward) GetFeedReward() *FeedRewardSchema

func (*MsgSetFeedReward) GetSignBytes 

func (m *MsgSetFeedReward) GetSignBytes() []byte

func (*MsgSetFeedReward) GetSigner 

func (m *MsgSetFeedReward) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgSetFeedReward) GetSigners 

func (m *MsgSetFeedReward) GetSigners() []githubcosmossdktypes.AccAddress

func (*MsgSetFeedReward) Marshal 

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

func (*MsgSetFeedReward) MarshalTo 

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

func (*MsgSetFeedReward) MarshalToSizedBuffer 

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

func (*MsgSetFeedReward) ProtoMessage 

func (*MsgSetFeedReward) ProtoMessage()

func (*MsgSetFeedReward) Reset 

func (m *MsgSetFeedReward) Reset()

func (*MsgSetFeedReward) Route 

func (m *MsgSetFeedReward) Route() string

func (*MsgSetFeedReward) Size 

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

func (*MsgSetFeedReward) String 

func (m *MsgSetFeedReward) String() string

func (*MsgSetFeedReward) Type 

func (m *MsgSetFeedReward) Type() string

func (*MsgSetFeedReward) Unmarshal 

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

func (*MsgSetFeedReward) ValidateBasic 

func (m *MsgSetFeedReward) ValidateBasic() error

func (*MsgSetFeedReward) XXX_DiscardUnknown 

func (m *MsgSetFeedReward) XXX_DiscardUnknown()

func (*MsgSetFeedReward) XXX_Marshal 

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

func (*MsgSetFeedReward) XXX_Merge 

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

func (*MsgSetFeedReward) XXX_Size 

func (m *MsgSetFeedReward) XXX_Size() int

func (*MsgSetFeedReward) XXX_Unmarshal 

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

type MsgSetHeartbeatTrigger 

type MsgSetHeartbeatTrigger struct {
	// FeedId is the unique identifier of the feed
	FeedId string `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"`
	// The interval between which a new round should automatically be triggered.
	// The given value in milliseconds will only be approximate within block intervals
	HeartbeatTrigger uint32 `protobuf:"varint,2,opt,name=heartbeatTrigger,proto3" json:"heartbeatTrigger,omitempty"`
	// Signer is the feed owner who signs the tx
	Signer github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,3,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"`
}

func NewMsgSetHeartbeatTrigger 

func NewMsgSetHeartbeatTrigger(signer githubcosmossdktypes.AccAddress, feedId string, heartbeatTrigger uint32) *MsgSetHeartbeatTrigger

func (*MsgSetHeartbeatTrigger) Descriptor 

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

func (*MsgSetHeartbeatTrigger) GetFeedId 

func (m *MsgSetHeartbeatTrigger) GetFeedId() string

func (*MsgSetHeartbeatTrigger) GetHeartbeatTrigger 

func (m *MsgSetHeartbeatTrigger) GetHeartbeatTrigger() uint32

func (*MsgSetHeartbeatTrigger) GetSignBytes 

func (m *MsgSetHeartbeatTrigger) GetSignBytes() []byte

func (*MsgSetHeartbeatTrigger) GetSigner 

func (m *MsgSetHeartbeatTrigger) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgSetHeartbeatTrigger) GetSigners 

func (m *MsgSetHeartbeatTrigger) GetSigners() []githubcosmossdktypes.AccAddress

func (*MsgSetHeartbeatTrigger) Marshal 

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

func (*MsgSetHeartbeatTrigger) MarshalTo 

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

func (*MsgSetHeartbeatTrigger) MarshalToSizedBuffer 

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

func (*MsgSetHeartbeatTrigger) ProtoMessage 

func (*MsgSetHeartbeatTrigger) ProtoMessage()

func (*MsgSetHeartbeatTrigger) Reset 

func (m *MsgSetHeartbeatTrigger) Reset()

func (*MsgSetHeartbeatTrigger) Route 

func (m *MsgSetHeartbeatTrigger) Route() string

func (*MsgSetHeartbeatTrigger) Size 

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

func (*MsgSetHeartbeatTrigger) String 

func (m *MsgSetHeartbeatTrigger) String() string

func (*MsgSetHeartbeatTrigger) Type 

func (m *MsgSetHeartbeatTrigger) Type() string

func (*MsgSetHeartbeatTrigger) Unmarshal 

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

func (*MsgSetHeartbeatTrigger) ValidateBasic 

func (m *MsgSetHeartbeatTrigger) ValidateBasic() error

func (*MsgSetHeartbeatTrigger) XXX_DiscardUnknown 

func (m *MsgSetHeartbeatTrigger) XXX_DiscardUnknown()

func (*MsgSetHeartbeatTrigger) XXX_Marshal 

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

func (*MsgSetHeartbeatTrigger) XXX_Merge 

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

func (*MsgSetHeartbeatTrigger) XXX_Size 

func (m *MsgSetHeartbeatTrigger) XXX_Size() int

func (*MsgSetHeartbeatTrigger) XXX_Unmarshal 

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

type MsgSetSubmissionCount 

type MsgSetSubmissionCount struct {
	// FeedId is the unique identifier of the feed
	FeedId string `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"`
	// The number of signatures required for a feedData submission to be valid
	SubmissionCount uint32 `protobuf:"varint,2,opt,name=submissionCount,proto3" json:"submissionCount,omitempty"`
	// Signer is the feed owner who signs the tx
	Signer github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,3,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"`
}

func NewMsgSetSubmissionCount 

func NewMsgSetSubmissionCount(signer githubcosmossdktypes.AccAddress, feedId string, submissionCount uint32) *MsgSetSubmissionCount

func (*MsgSetSubmissionCount) Descriptor 

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

func (*MsgSetSubmissionCount) GetFeedId 

func (m *MsgSetSubmissionCount) GetFeedId() string

func (*MsgSetSubmissionCount) GetSignBytes 

func (m *MsgSetSubmissionCount) GetSignBytes() []byte

func (*MsgSetSubmissionCount) GetSigner 

func (m *MsgSetSubmissionCount) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgSetSubmissionCount) GetSigners 

func (m *MsgSetSubmissionCount) GetSigners() []githubcosmossdktypes.AccAddress

func (*MsgSetSubmissionCount) GetSubmissionCount 

func (m *MsgSetSubmissionCount) GetSubmissionCount() uint32

func (*MsgSetSubmissionCount) Marshal 

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

func (*MsgSetSubmissionCount) MarshalTo 

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

func (*MsgSetSubmissionCount) MarshalToSizedBuffer 

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

func (*MsgSetSubmissionCount) ProtoMessage 

func (*MsgSetSubmissionCount) ProtoMessage()

func (*MsgSetSubmissionCount) Reset 

func (m *MsgSetSubmissionCount) Reset()

func (*MsgSetSubmissionCount) Route 

func (m *MsgSetSubmissionCount) Route() string

func (*MsgSetSubmissionCount) Size 

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

func (*MsgSetSubmissionCount) String 

func (m *MsgSetSubmissionCount) String() string

func (*MsgSetSubmissionCount) Type 

func (m *MsgSetSubmissionCount) Type() string

func (*MsgSetSubmissionCount) Unmarshal 

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

func (*MsgSetSubmissionCount) ValidateBasic 

func (m *MsgSetSubmissionCount) ValidateBasic() error

func (*MsgSetSubmissionCount) XXX_DiscardUnknown 

func (m *MsgSetSubmissionCount) XXX_DiscardUnknown()

func (*MsgSetSubmissionCount) XXX_Marshal 

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

func (*MsgSetSubmissionCount) XXX_Merge 

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

func (*MsgSetSubmissionCount) XXX_Size 

func (m *MsgSetSubmissionCount) XXX_Size() int

func (*MsgSetSubmissionCount) XXX_Unmarshal 

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

type OCRAbiEncoded 

type OCRAbiEncoded struct {
	// Context should be a 32-byte array struct.
	Context []byte `protobuf:"bytes,1,opt,name=Context,proto3" json:"Context,omitempty"`
	// Oracles should be a 32-byte record of all participating oracles. Assuming this is data provider address?
	Oracles []byte `protobuf:"bytes,2,opt,name=Oracles,proto3" json:"Oracles,omitempty"`
	// Observations should be an array on int192 containing the providers' independent observations.
	Observations []*Observation `protobuf:"bytes,3,rep,name=Observations,proto3" json:"Observations,omitempty"`
}

this will be the implementation used later will use pseudo OCR ABI encoded data instead because the structure of how the OCR will be generalized is still unknown OCRAbiEncoded implments the OCR data that is ABCI encoded. The use and form will conform to the Chainlink protocol specification.

func (*OCRAbiEncoded) Descriptor 

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

func (*OCRAbiEncoded) GetContext 

func (m *OCRAbiEncoded) GetContext() []byte

func (*OCRAbiEncoded) GetObservations 

func (m *OCRAbiEncoded) GetObservations() []*Observation

func (*OCRAbiEncoded) GetOracles 

func (m *OCRAbiEncoded) GetOracles() []byte

func (*OCRAbiEncoded) Marshal 

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

func (*OCRAbiEncoded) MarshalTo 

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

func (*OCRAbiEncoded) MarshalToSizedBuffer 

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

func (*OCRAbiEncoded) ProtoMessage 

func (*OCRAbiEncoded) ProtoMessage()

func (*OCRAbiEncoded) Reset 

func (m *OCRAbiEncoded) Reset()

func (*OCRAbiEncoded) Size 

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

func (*OCRAbiEncoded) String 

func (m *OCRAbiEncoded) String() string

func (*OCRAbiEncoded) Unmarshal 

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

func (*OCRAbiEncoded) XXX_DiscardUnknown 

func (m *OCRAbiEncoded) XXX_DiscardUnknown()

func (*OCRAbiEncoded) XXX_Marshal 

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

func (*OCRAbiEncoded) XXX_Merge 

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

func (*OCRAbiEncoded) XXX_Size 

func (m *OCRAbiEncoded) XXX_Size() int

func (*OCRAbiEncoded) XXX_Unmarshal 

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

type OCRFeedDataInStore 

type OCRFeedDataInStore struct {
	FeedData              *MsgFeedData   `protobuf:"bytes,1,opt,name=feedData,proto3" json:"feedData,omitempty"`
	DeserializedOCRReport *OCRAbiEncoded `protobuf:"bytes,2,opt,name=deserializedOCRReport,proto3" json:"deserializedOCRReport,omitempty"`
	RoundId               uint64         `protobuf:"varint,3,opt,name=RoundId,proto3" json:"RoundId,omitempty"`
}

OCRFeedDataInStore defines the type for OCR report that persists into the store

func (*OCRFeedDataInStore) Descriptor 

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

func (*OCRFeedDataInStore) GetDeserializedOCRReport 

func (m *OCRFeedDataInStore) GetDeserializedOCRReport() *OCRAbiEncoded

func (*OCRFeedDataInStore) GetFeedData 

func (m *OCRFeedDataInStore) GetFeedData() *MsgFeedData

func (*OCRFeedDataInStore) GetRoundId 

func (m *OCRFeedDataInStore) GetRoundId() uint64

func (*OCRFeedDataInStore) Marshal 

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

func (*OCRFeedDataInStore) MarshalTo 

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

func (*OCRFeedDataInStore) MarshalToSizedBuffer 

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

func (*OCRFeedDataInStore) ProtoMessage 

func (*OCRFeedDataInStore) ProtoMessage()

func (*OCRFeedDataInStore) Reset 

func (m *OCRFeedDataInStore) Reset()

func (*OCRFeedDataInStore) Size 

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

func (*OCRFeedDataInStore) String 

func (m *OCRFeedDataInStore) String() string

func (*OCRFeedDataInStore) Unmarshal 

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

func (*OCRFeedDataInStore) XXX_DiscardUnknown 

func (m *OCRFeedDataInStore) XXX_DiscardUnknown()

func (*OCRFeedDataInStore) XXX_Marshal 

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

func (*OCRFeedDataInStore) XXX_Merge 

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

func (*OCRFeedDataInStore) XXX_Size 

func (m *OCRFeedDataInStore) XXX_Size() int

func (*OCRFeedDataInStore) XXX_Unmarshal 

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

type Observation 

type Observation struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Observation) Descriptor 

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

func (*Observation) GetData 

func (m *Observation) GetData() []byte

func (*Observation) Marshal 

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

func (*Observation) MarshalTo 

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

func (*Observation) MarshalToSizedBuffer 

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

func (*Observation) ProtoMessage 

func (*Observation) ProtoMessage()

func (*Observation) Reset 

func (m *Observation) Reset()

func (*Observation) Size 

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

func (*Observation) String 

func (m *Observation) String() string

func (*Observation) Unmarshal 

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

func (*Observation) XXX_DiscardUnknown 

func (m *Observation) XXX_DiscardUnknown()

func (*Observation) XXX_Marshal 

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

func (*Observation) XXX_Merge 

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

func (*Observation) XXX_Size 

func (m *Observation) XXX_Size() int

func (*Observation) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	GetRoundData(ctx context.Context, in *GetRoundDataRequest, opts ...grpc.CallOption) (*GetRoundDataResponse, error)
	LatestRoundData(ctx context.Context, in *GetLatestRoundDataRequest, opts ...grpc.CallOption) (*GetLatestRoundDataResponse, error)
	GetAllModuleOwner(ctx context.Context, in *GetModuleOwnerRequest, opts ...grpc.CallOption) (*GetModuleOwnerResponse, error)
	GetFeedByFeedId(ctx context.Context, in *GetFeedByIdRequest, opts ...grpc.CallOption) (*GetFeedByIdResponse, error)
	GetAccountInfo(ctx context.Context, in *GetAccountRequest, opts ...grpc.CallOption) (*GetAccountResponse, error)
	GetFeedRewardAvailStrategy(ctx context.Context, in *GetFeedRewardAvailStrategiesRequest, opts ...grpc.CallOption) (*GetFeedRewardAvailStrategiesResponse, 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 QueryServer 

type QueryServer interface {
	GetRoundData(context.Context, *GetRoundDataRequest) (*GetRoundDataResponse, error)
	LatestRoundData(context.Context, *GetLatestRoundDataRequest) (*GetLatestRoundDataResponse, error)
	GetAllModuleOwner(context.Context, *GetModuleOwnerRequest) (*GetModuleOwnerResponse, error)
	GetFeedByFeedId(context.Context, *GetFeedByIdRequest) (*GetFeedByIdResponse, error)
	GetAccountInfo(context.Context, *GetAccountRequest) (*GetAccountResponse, error)
	GetFeedRewardAvailStrategy(context.Context, *GetFeedRewardAvailStrategiesRequest) (*GetFeedRewardAvailStrategiesResponse, error)
}

QueryServer is the server API for Query service.

type RewardPayout 

type RewardPayout struct {
	DataProvider *DataProvider `json:"dataProvider"`
	Amount       uint64        `json:"amount"`
}

RewardPayout describes the calculated reward that data provider gets after the selected strategy applied

type RoundData 

type RoundData struct {
	FeedId   string         `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"`
	FeedData *OCRAbiEncoded `protobuf:"bytes,2,opt,name=feedData,proto3" json:"feedData,omitempty"`
}

func (*RoundData) Descriptor 

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

func (*RoundData) GetFeedData 

func (m *RoundData) GetFeedData() *OCRAbiEncoded

func (*RoundData) GetFeedId 

func (m *RoundData) GetFeedId() string

func (*RoundData) Marshal 

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

func (*RoundData) MarshalTo 

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

func (*RoundData) MarshalToSizedBuffer 

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

func (*RoundData) ProtoMessage 

func (*RoundData) ProtoMessage()

func (*RoundData) Reset 

func (m *RoundData) Reset()

func (*RoundData) Size 

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

func (*RoundData) String 

func (m *RoundData) String() string

func (*RoundData) Unmarshal 

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

func (*RoundData) XXX_DiscardUnknown 

func (m *RoundData) XXX_DiscardUnknown()

func (*RoundData) XXX_Marshal 

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

func (*RoundData) XXX_Merge 

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

func (*RoundData) XXX_Size 

func (m *RoundData) XXX_Size() int

func (*RoundData) XXX_Unmarshal 

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

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) AddAccountTx 

func (*UnimplementedMsgServer) AddAccountTx(ctx context.Context, req *MsgAccount) (*MsgResponse, error)

func (*UnimplementedMsgServer) AddDataProviderTx 

func (*UnimplementedMsgServer) AddDataProviderTx(ctx context.Context, req *MsgAddDataProvider) (*MsgResponse, error)

func (*UnimplementedMsgServer) AddFeedTx 

func (*UnimplementedMsgServer) AddFeedTx(ctx context.Context, req *MsgFeed) (*MsgResponse, error)

func (*UnimplementedMsgServer) AddModuleOwnerTx 

func (*UnimplementedMsgServer) AddModuleOwnerTx(ctx context.Context, req *MsgModuleOwner) (*MsgResponse, error)

func (*UnimplementedMsgServer) EditAccountTx 

func (*UnimplementedMsgServer) EditAccountTx(ctx context.Context, req *MsgEditAccount) (*MsgResponse, error)

func (*UnimplementedMsgServer) FeedOwnershipTransferTx 

func (*UnimplementedMsgServer) FeedOwnershipTransferTx(ctx context.Context, req *MsgFeedOwnershipTransfer) (*MsgResponse, error)

func (*UnimplementedMsgServer) ModuleOwnershipTransferTx 

func (*UnimplementedMsgServer) ModuleOwnershipTransferTx(ctx context.Context, req *MsgModuleOwnershipTransfer) (*MsgResponse, error)

func (*UnimplementedMsgServer) RemoveDataProviderTx 

func (*UnimplementedMsgServer) RemoveDataProviderTx(ctx context.Context, req *MsgRemoveDataProvider) (*MsgResponse, error)

func (*UnimplementedMsgServer) RequestNewRoundTx 

func (*UnimplementedMsgServer) RequestNewRoundTx(ctx context.Context, req *MsgRequestNewRound) (*MsgResponse, error)

func (*UnimplementedMsgServer) SetDeviationThresholdTriggerTx 

func (*UnimplementedMsgServer) SetDeviationThresholdTriggerTx(ctx context.Context, req *MsgSetDeviationThresholdTrigger) (*MsgResponse, error)

func (*UnimplementedMsgServer) SetFeedRewardTx 

func (*UnimplementedMsgServer) SetFeedRewardTx(ctx context.Context, req *MsgSetFeedReward) (*MsgResponse, error)

func (*UnimplementedMsgServer) SetHeartbeatTriggerTx 

func (*UnimplementedMsgServer) SetHeartbeatTriggerTx(ctx context.Context, req *MsgSetHeartbeatTrigger) (*MsgResponse, error)

func (*UnimplementedMsgServer) SetSubmissionCountTx 

func (*UnimplementedMsgServer) SetSubmissionCountTx(ctx context.Context, req *MsgSetSubmissionCount) (*MsgResponse, error)

func (*UnimplementedMsgServer) SubmitFeedDataTx 

func (*UnimplementedMsgServer) SubmitFeedDataTx(ctx context.Context, req *MsgFeedData) (*MsgResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) GetAccountInfo 

func (*UnimplementedQueryServer) GetAccountInfo(ctx context.Context, req *GetAccountRequest) (*GetAccountResponse, error)

func (*UnimplementedQueryServer) GetAllModuleOwner 

func (*UnimplementedQueryServer) GetAllModuleOwner(ctx context.Context, req *GetModuleOwnerRequest) (*GetModuleOwnerResponse, error)

func (*UnimplementedQueryServer) GetFeedByFeedId 

func (*UnimplementedQueryServer) GetFeedByFeedId(ctx context.Context, req *GetFeedByIdRequest) (*GetFeedByIdResponse, error)

func (*UnimplementedQueryServer) GetFeedRewardAvailStrategy 

func (*UnimplementedQueryServer) GetFeedRewardAvailStrategy(ctx context.Context, req *GetFeedRewardAvailStrategiesRequest) (*GetFeedRewardAvailStrategiesResponse, error)

func (*UnimplementedQueryServer) GetRoundData 

func (*UnimplementedQueryServer) GetRoundData(ctx context.Context, req *GetRoundDataRequest) (*GetRoundDataResponse, error)

func (*UnimplementedQueryServer) LatestRoundData 

func (*UnimplementedQueryServer) LatestRoundData(ctx context.Context, req *GetLatestRoundDataRequest) (*GetLatestRoundDataResponse, error)

type Validation 

type Validation interface {
	Validate(func(msg sdk.Msg) bool) bool
}

Validation is the interface to perform any validation against sdk.Msg

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.