types

package

Go to main page

Versions in this module

v0

v0.5.0

Apr 27, 2022

v0.5.0-x.4

Apr 29, 2022

v0.5.0-x.3

Apr 29, 2022

v0.5.0-x.2

Apr 28, 2022

v0.5.0-x.1

Apr 28, 2022

v0.5.0-x.0

Apr 28, 2022

v0.4.4

Apr 19, 2022

v0.4.3

Apr 18, 2022

v0.4.2

Apr 11, 2022

v0.4.1

Mar 23, 2022

v0.4.0

Mar 22, 2022

Changes in this version

+ var ErrIBCRequestDisabled = sdkerrors.Register(ModuleName, 45, "sending oracle request via IBC is disabled")

+ type IBCChannel struct

+ ChannelId string

+ PortId string

+ func NewIBCChannel(portId, channelId string) IBCChannel

+ func (*IBCChannel) Descriptor() ([]byte, []int)

+ func (*IBCChannel) ProtoMessage()

+ func (m *IBCChannel) GetChannelId() string

+ func (m *IBCChannel) GetPortId() string

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

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

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

+ func (m *IBCChannel) Reset()

+ func (m *IBCChannel) Size() (n int)

+ func (m *IBCChannel) String() string

+ func (m *IBCChannel) Unmarshal(dAtA []byte) error

+ func (m *IBCChannel) XXX_DiscardUnknown()

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

+ func (m *IBCChannel) XXX_Merge(src proto.Message)

+ func (m *IBCChannel) XXX_Size() int

+ func (m *IBCChannel) XXX_Unmarshal(b []byte) error

+ func (this *IBCChannel) Equal(that interface{}) bool

type IBCSource

+ func NewIBCSource(portId, channelId string) IBCSource

v0.3.4

Mar 19, 2022

v0.3.3

Mar 14, 2022

Changes in this version

type QueryClient

+ IsReporter func(ctx context.Context, in *QueryIsReporterRequest, opts ...grpc.CallOption) (*QueryIsReporterResponse, error)

+ type QueryIsReporterRequest struct

+ ReporterAddress string

+ ValidatorAddress string

+ func (*QueryIsReporterRequest) Descriptor() ([]byte, []int)

+ func (*QueryIsReporterRequest) ProtoMessage()

+ func (m *QueryIsReporterRequest) GetReporterAddress() string

+ func (m *QueryIsReporterRequest) GetValidatorAddress() string

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

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

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

+ func (m *QueryIsReporterRequest) Reset()

+ func (m *QueryIsReporterRequest) Size() (n int)

+ func (m *QueryIsReporterRequest) String() string

+ func (m *QueryIsReporterRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryIsReporterRequest) XXX_DiscardUnknown()

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

+ func (m *QueryIsReporterRequest) XXX_Merge(src proto.Message)

+ func (m *QueryIsReporterRequest) XXX_Size() int

+ func (m *QueryIsReporterRequest) XXX_Unmarshal(b []byte) error

+ type QueryIsReporterResponse struct

+ IsReporter bool

+ func (*QueryIsReporterResponse) Descriptor() ([]byte, []int)

+ func (*QueryIsReporterResponse) ProtoMessage()

+ func (m *QueryIsReporterResponse) GetIsReporter() bool

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

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

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

+ func (m *QueryIsReporterResponse) Reset()

+ func (m *QueryIsReporterResponse) Size() (n int)

+ func (m *QueryIsReporterResponse) String() string

+ func (m *QueryIsReporterResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryIsReporterResponse) XXX_DiscardUnknown()

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

+ func (m *QueryIsReporterResponse) XXX_Merge(src proto.Message)

+ func (m *QueryIsReporterResponse) XXX_Size() int

+ func (m *QueryIsReporterResponse) XXX_Unmarshal(b []byte) error

type QueryServer

+ IsReporter func(context.Context, *QueryIsReporterRequest) (*QueryIsReporterResponse, error)

type UnimplementedQueryServer

+ func (*UnimplementedQueryServer) IsReporter(ctx context.Context, req *QueryIsReporterRequest) (*QueryIsReporterResponse, error)

v0.3.2

Feb 15, 2022

v0.3.2-x.3

Feb 3, 2022

v0.3.2-x.2

Feb 3, 2022

v0.3.2-x.1

Feb 3, 2022

v0.3.2-x.0

Feb 3, 2022

v0.3.1

Jan 24, 2022

v0.3.1-x.0

Jan 21, 2022

v0.3.0

Jan 18, 2022

Changes in this version

+ const ModuleVersion

+ var OracleModuleCoinsAccountKey = append(GlobalStoreKeyPrefix, []byte("OracleModuleCoinsAccount"))

type GenesisState

+ ModuleCoinsAccount string

+ func (m *GenesisState) GetModuleCoinsAccount() string

v0.3.0-x.1

Jan 6, 2022

v0.3.0-x.0

Jan 6, 2022

v0.2.0

Dec 9, 2021

Changes in this version

type DistrKeeper

+ FundCommunityPool func(ctx sdk.Context, amount sdk.Coins, sender sdk.AccAddress) error

v0.1.0

Nov 29, 2021

Changes in this version

+ const AttributeKeyAskCount

+ const AttributeKeyCalldata

+ const AttributeKeyClientID

+ const AttributeKeyDataSourceHash

+ const AttributeKeyDataSourceID

+ const AttributeKeyExternalID

+ const AttributeKeyGasUsed

+ const AttributeKeyID

+ const AttributeKeyMinCount

+ const AttributeKeyOracleScriptID

+ const AttributeKeyReason

+ const AttributeKeyReporter

+ const AttributeKeyResolveStatus

+ const AttributeKeyResult

+ const AttributeKeyValidator

+ const DefaultBaseRequestGas

+ const DefaultDataProviderRewardDenom

+ const DefaultDataRequesterFeeDenom

+ const DefaultExecuteGas

+ const DefaultExpirationBlockCount

+ const DefaultInactivePenaltyDuration

+ const DefaultMaxAskCount

+ const DefaultMaxCalldataSize

+ const DefaultMaxDataSize

+ const DefaultMaxRawRequestCount

+ const DefaultOracleRewardPercentage

+ const DefaultPerValidatorRequestGas

+ const DefaultPrepareGas

+ const DefaultRewardThresholdBlocks

+ const DefaultSamplingTryCount

+ const DoNotModify

+ const EventTypeActivate

+ const EventTypeAddReporter

+ const EventTypeCreateDataSource

+ const EventTypeCreateOracleScript

+ const EventTypeDeactivate

+ const EventTypeEditDataSource

+ const EventTypeEditOracleScript

+ const EventTypeRawRequest

+ const EventTypeRemoveReporter

+ const EventTypeReport

+ const EventTypeRequest

+ const EventTypeResolve

+ const MaxClientIDLength

+ const MaxCompiledWasmCodeSize

+ const MaxDescriptionLength

+ const MaxExecutableSize

+ const MaxNameLength

+ const MaxSchemaLength

+ const MaxURLLength

+ const MaxWasmCodeSize

+ const ModuleName

+ const PortID

+ const QuerierRoute

+ const QueryActiveValidators

+ const QueryCounts

+ const QueryData

+ const QueryDataProviderReward

+ const QueryDataProvidersPool

+ const QueryDataSources

+ const QueryLatestRequest

+ const QueryMultiProof

+ const QueryMultiRequestSearch

+ const QueryOracleScripts

+ const QueryParams

+ const QueryPendingRequests

+ const QueryPriceSymbols

+ const QueryProof

+ const QueryReporters

+ const QueryRequestPrices

+ const QueryRequestReports

+ const QueryRequestSearch

+ const QueryRequests

+ const QueryRequestsCountProof

+ const QueryValidatorStatus

+ const RouterKey

+ const StoreKey

+ const TypeMsgActivate

+ const TypeMsgAddReporter

+ const TypeMsgCreateDataSource

+ const TypeMsgCreateOracleScript

+ const TypeMsgEditDataSource

+ const TypeMsgEditOracleScript

+ const TypeMsgRemoveReporter

+ const TypeMsgReportData

+ const TypeMsgRequestData

+ const Version

+ const WasmExecuteGas

+ const WasmPrepareGas

+ var AccumulatedDataProvidersRewardsStoreKey = append(GlobalStoreKeyPrefix, []byte("AllocateRewardsToDataProviders"))

+ var AccumulatedPaymentsForDataStoreKey = append(GlobalStoreKeyPrefix, []byte("AccumulatedPaymentsForData"))

+ var DataProviderRewardsKeyPrefix = []byte

+ var DataRequesterFeesKeyPrefix = []byte

+ var DataSourceCountStoreKey = append(GlobalStoreKeyPrefix, []byte("DataSourceCount"))

+ var DataSourceStoreKeyPrefix = []byte

+ var DefaultDataProviderRewardPerByte = sdk.NewCoins(sdk.NewInt64Coin(DefaultDataProviderRewardDenom, 1000000))

+ var DefaultDataRequesterFeeDenoms = []string

+ var DefaultFeeLimit = sdk.NewCoins()

+ var DefaultRewardDecreasingFraction = sdk.NewDec(1).Quo(sdk.NewDec(20))

+ var DefaultRewardThresholdAmount = sdk.NewCoins(sdk.NewInt64Coin(DefaultDataProviderRewardDenom, 200000000000))

+ var DoNotModifyBytes = []byte(DoNotModify)

+ var ErrBadDrbgInitialization = sdkerrors.Register(ModuleName, 40, "bad drbg initialization")

+ var ErrBadWasmExecution = sdkerrors.Register(ModuleName, 2, "bad wasm execution")

+ var ErrCreateWithDoNotModify = sdkerrors.Register(ModuleName, 35, "cannot create with [do-not-modify] content")

+ var ErrDataSourceNotFound = sdkerrors.Register(ModuleName, 3, "data source not found")

+ var ErrDuplicateExternalID = sdkerrors.Register(ModuleName, 30, "duplicate external id")

+ var ErrEditorNotAuthorized = sdkerrors.Register(ModuleName, 14, "editor not authorized")

+ var ErrEmptyExecutable = sdkerrors.Register(ModuleName, 20, "empty executable")

+ var ErrEmptyRawRequests = sdkerrors.Register(ModuleName, 28, "empty raw requests")

+ var ErrEmptyReport = sdkerrors.Register(ModuleName, 29, "empty report")

+ var ErrEmptyWasmCode = sdkerrors.Register(ModuleName, 21, "empty wasm code")

+ var ErrInsufficientValidators = sdkerrors.Register(ModuleName, 34, "insufficent available validators")

+ var ErrIntOverflowGenesis = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowOracle = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowParams = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowTx = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidAskCount = sdkerrors.Register(ModuleName, 25, "invalid ask count")

+ var ErrInvalidLengthGenesis = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthOracle = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthParams = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthTx = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidMinCount = sdkerrors.Register(ModuleName, 24, "invalid min count")

+ var ErrInvalidOwasmGas = sdkerrors.Register(ModuleName, 44, "invalid owasm gas")

+ var ErrInvalidReportSize = sdkerrors.Register(ModuleName, 12, "invalid report size")

+ var ErrInvalidVersion = sdkerrors.Register(ModuleName, 42, "invalid ICS20 version")

+ var ErrMaxOracleChannels = sdkerrors.Register(ModuleName, 41, "max oracle channels")

+ var ErrNotEnoughFee = sdkerrors.Register(ModuleName, 43, "not enough fee")

+ var ErrOBIDecode = sdkerrors.Register(ModuleName, 37, "obi decode failed")

+ var ErrOracleScriptNotFound = sdkerrors.Register(ModuleName, 4, "oracle script not found")

+ var ErrOwasmCompilation = sdkerrors.Register(ModuleName, 1, "owasm compilation failed")

+ var ErrRawRequestNotFound = sdkerrors.Register(ModuleName, 6, "raw request not found")

+ var ErrReporterAlreadyExists = sdkerrors.Register(ModuleName, 9, "reporter already exists")

+ var ErrReporterNotAuthorized = sdkerrors.Register(ModuleName, 13, "reporter not authorized")

+ var ErrReporterNotFound = sdkerrors.Register(ModuleName, 7, "reporter not found")

+ var ErrRequestAlreadyExpired = sdkerrors.Register(ModuleName, 39, "request already expired")

+ var ErrRequestNotFound = sdkerrors.Register(ModuleName, 5, "request not found")

+ var ErrResultNotFound = sdkerrors.Register(ModuleName, 8, "result not found")

+ var ErrSelfReferenceAsReporter = sdkerrors.Register(ModuleName, 36, "cannot reference self as reporter")

+ var ErrTooLargeCalldata = sdkerrors.Register(ModuleName, 26, "too large calldata")

+ var ErrTooLargeExecutable = sdkerrors.Register(ModuleName, 22, "too large executable")

+ var ErrTooLargeRawReportData = sdkerrors.Register(ModuleName, 33, "too large raw report data")

+ var ErrTooLargeWasmCode = sdkerrors.Register(ModuleName, 23, "too large wasm code")

+ var ErrTooLongClientID = sdkerrors.Register(ModuleName, 27, "too long client id")

+ var ErrTooLongDescription = sdkerrors.Register(ModuleName, 19, "too long description")

+ var ErrTooLongName = sdkerrors.Register(ModuleName, 18, "too long name")

+ var ErrTooLongSchema = sdkerrors.Register(ModuleName, 31, "too long schema")

+ var ErrTooLongURL = sdkerrors.Register(ModuleName, 32, "too long url")

+ var ErrTooSoonToActivate = sdkerrors.Register(ModuleName, 17, "too soon to activate")

+ var ErrUncompressionFailed = sdkerrors.Register(ModuleName, 38, "uncompression failed")

+ var ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupOracle = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")

+ var ErrValidatorAlreadyActive = sdkerrors.Register(ModuleName, 16, "validator already active")

+ var ErrValidatorAlreadyReported = sdkerrors.Register(ModuleName, 11, "validator already reported")

+ var ErrValidatorNotRequested = sdkerrors.Register(ModuleName, 10, "validator not requested")

+ var GlobalStoreKeyPrefix = []byte

+ var KeyBaseOwasmGas = []byte("BaseOwasmGas")

+ var KeyDataProviderRewardPerByte = []byte("DataProviderRewardPerByte")

+ var KeyDataProviderRewardThreshold = []byte("DataProviderRewardThreshold")

+ var KeyDataRequesterFeeDenoms = []byte("DataRequesterFeeDenoms")

+ var KeyExpirationBlockCount = []byte("ExpirationBlockCount")

+ var KeyInactivePenaltyDuration = []byte("InactivePenaltyDuration")

+ var KeyMaxAskCount = []byte("MaxAskCount")

+ var KeyMaxCalldataSize = []byte("MaxCalldataSize")

+ var KeyMaxDataSize = []byte("MaxDataSize")

+ var KeyMaxRawRequestCount = []byte("MaxRawRequestCount")

+ var KeyOracleRewardPercentage = []byte("OracleRewardPercentage")

+ var KeyPerValidatorRequestGas = []byte("PerValidatorRequestGas")

+ var KeyRewardDecreasingFraction = []byte("RewardDecreasingFraction")

+ var KeySamplingTryCount = []byte("SamplingTryCount")

+ var ModuleCdc = codec.NewProtoCodec(codectypes.NewInterfaceRegistry())

+ var OraclePoolStoreKey = append(GlobalStoreKeyPrefix, []byte("OraclePool"))

+ var OracleScriptCountStoreKey = append(GlobalStoreKeyPrefix, []byte("OracleScriptCount"))

+ var OracleScriptStoreKeyPrefix = []byte

+ var PendingResolveListStoreKey = append(GlobalStoreKeyPrefix, []byte("PendingList"))

+ var PortKey = []byte

+ var ReportStoreKeyPrefix = []byte

+ var ReporterStoreKeyPrefix = []byte

+ var RequestCountStoreKey = append(GlobalStoreKeyPrefix, []byte("RequestCount"))

+ var RequestLastExpiredStoreKey = append(GlobalStoreKeyPrefix, []byte("RequestLastExpired"))

+ var RequestStoreKeyPrefix = []byte

+ var ResolveStatus_name = map[int32]string

+ var ResolveStatus_value = map[string]int32

+ var ResultStoreKeyPrefix = []byte

+ var RollingSeedSizeInBytes = 32

+ var RollingSeedStoreKey = append(GlobalStoreKeyPrefix, []byte("RollingSeed"))

+ var ValidatorStatusKeyPrefix = []byte

+ func DataProviderRewardsPrefixKey(acc sdk.AccAddress) []byte

+ func DataSourceStoreKey(dataSourceID DataSourceID) []byte

+ func OracleScriptStoreKey(oracleScriptID OracleScriptID) []byte

+ func ParamKeyTable() paramtypes.KeyTable

+ func RegisterInterfaces(registry codectypes.InterfaceRegistry)

+ func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

+ func RegisterMsgServer(s grpc1.Server, srv MsgServer)

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

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

+ func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

+ func RegisterQueryServer(s grpc1.Server, srv QueryServer)

+ func ReportStoreKey(requestID RequestID) []byte

+ func ReporterStoreKey(validatorAddress sdk.ValAddress, reporterAddress sdk.AccAddress) []byte

+ func ReportersOfValidatorPrefixKey(val sdk.ValAddress) []byte

+ func ReportsOfValidatorPrefixKey(reqID RequestID, val sdk.ValAddress) []byte

+ func RequestStoreKey(requestID RequestID) []byte

+ func ResultStoreKey(requestID RequestID) []byte

+ func ValidatorStatusStoreKey(v sdk.ValAddress) []byte

+ func WrapMaxError(err error, got int, max int) error

+ type AccountKeeper interface

+ GetAccount func(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI

+ GetModuleAccount func(ctx sdk.Context, name string) authtypes.ModuleAccountI

+ GetModuleAddress func(name string) sdk.AccAddress

+ SetModuleAccount func(sdk.Context, authtypes.ModuleAccountI)

+ type AccumulatedPaymentsForData struct

+ AccumulatedAmount github_com_cosmos_cosmos_sdk_types.Coins

+ func (*AccumulatedPaymentsForData) Descriptor() ([]byte, []int)

+ func (*AccumulatedPaymentsForData) ProtoMessage()

+ func (m *AccumulatedPaymentsForData) GetAccumulatedAmount() github_com_cosmos_cosmos_sdk_types.Coins

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

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

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

+ func (m *AccumulatedPaymentsForData) Reset()

+ func (m *AccumulatedPaymentsForData) Size() (n int)

+ func (m *AccumulatedPaymentsForData) String() string

+ func (m *AccumulatedPaymentsForData) Unmarshal(dAtA []byte) error

+ func (m *AccumulatedPaymentsForData) XXX_DiscardUnknown()

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

+ func (m *AccumulatedPaymentsForData) XXX_Merge(src proto.Message)

+ func (m *AccumulatedPaymentsForData) XXX_Size() int

+ func (m *AccumulatedPaymentsForData) XXX_Unmarshal(b []byte) error

+ type BankKeeper interface

+ GetAllBalances func(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins

+ SendCoins func(ctx sdk.Context, fromAddr sdk.AccAddress, toAddr sdk.AccAddress, amt sdk.Coins) error

+ SendCoinsFromAccountToModule func(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, ...) error

+ SendCoinsFromModuleToAccount func(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, ...) error

+ SendCoinsFromModuleToModule func(ctx sdk.Context, senderModule, recipientModule string, amt sdk.Coins) error

+ SetBalances func(ctx sdk.Context, addr sdk.AccAddress, balances sdk.Coins) error

+ type BaseEnv struct

+ func (env *BaseEnv) AskExternalData(eid int64, did int64, data []byte) error

+ func (env *BaseEnv) GetAnsCount() (int64, error)

+ func (env *BaseEnv) GetAskCount() int64

+ func (env *BaseEnv) GetCalldata() []byte

+ func (env *BaseEnv) GetExternalData(eid int64, vid int64) ([]byte, error)

+ func (env *BaseEnv) GetExternalDataStatus(eid int64, vid int64) (int64, error)

+ func (env *BaseEnv) GetMinCount() int64

+ func (env *BaseEnv) SetReturnData(data []byte) error

+ type ChannelKeeper interface

+ ChanCloseInit func(ctx sdk.Context, portID, channelID string, chanCap *capabilitytypes.Capability) error

+ GetChannel func(ctx sdk.Context, srcPort, srcChan string) (channel channeltypes.Channel, found bool)

+ GetNextSequenceSend func(ctx sdk.Context, portID, channelID string) (uint64, bool)

+ SendPacket func(ctx sdk.Context, channelCap *capabilitytypes.Capability, ...) error

+ type ClientKeeper interface

+ GetClientConsensusState func(ctx sdk.Context, clientID string) (connection ibcexported.ConsensusState, found bool)

+ type ConnectionKeeper interface

+ GetConnection func(ctx sdk.Context, connectionID string) (connection connectiontypes.ConnectionEnd, found bool)

+ type DataProviderAccumulatedReward struct

+ DataProvider string

+ DataProviderReward github_com_cosmos_cosmos_sdk_types.Coins

+ func NewDataProviderAccumulatedReward(acc sdk.AccAddress, reward sdk.Coins) *DataProviderAccumulatedReward

+ func (*DataProviderAccumulatedReward) Descriptor() ([]byte, []int)

+ func (*DataProviderAccumulatedReward) ProtoMessage()

+ func (m *DataProviderAccumulatedReward) GetDataProvider() string

+ func (m *DataProviderAccumulatedReward) GetDataProviderReward() github_com_cosmos_cosmos_sdk_types.Coins

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

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

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

+ func (m *DataProviderAccumulatedReward) Reset()

+ func (m *DataProviderAccumulatedReward) Size() (n int)

+ func (m *DataProviderAccumulatedReward) String() string

+ func (m *DataProviderAccumulatedReward) Unmarshal(dAtA []byte) error

+ func (m *DataProviderAccumulatedReward) XXX_DiscardUnknown()

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

+ func (m *DataProviderAccumulatedReward) XXX_Merge(src proto.Message)

+ func (m *DataProviderAccumulatedReward) XXX_Size() int

+ func (m *DataProviderAccumulatedReward) XXX_Unmarshal(b []byte) error

+ type DataProvidersAccumulatedRewards struct

+ AccumulatedAmount github_com_cosmos_cosmos_sdk_types.Coins

+ CurrentRewardPerByte github_com_cosmos_cosmos_sdk_types.Coins

+ func NewDataProvidersAccumulatedRewards(currentRewardPerByte sdk.Coins, accumulatedAmount sdk.Coins) DataProvidersAccumulatedRewards

+ func (*DataProvidersAccumulatedRewards) Descriptor() ([]byte, []int)

+ func (*DataProvidersAccumulatedRewards) ProtoMessage()

+ func (m *DataProvidersAccumulatedRewards) GetAccumulatedAmount() github_com_cosmos_cosmos_sdk_types.Coins

+ func (m *DataProvidersAccumulatedRewards) GetCurrentRewardPerByte() github_com_cosmos_cosmos_sdk_types.Coins

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

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

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

+ func (m *DataProvidersAccumulatedRewards) Reset()

+ func (m *DataProvidersAccumulatedRewards) Size() (n int)

+ func (m *DataProvidersAccumulatedRewards) String() string

+ func (m *DataProvidersAccumulatedRewards) Unmarshal(dAtA []byte) error

+ func (m *DataProvidersAccumulatedRewards) XXX_DiscardUnknown()

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

+ func (m *DataProvidersAccumulatedRewards) XXX_Merge(src proto.Message)

+ func (m *DataProvidersAccumulatedRewards) XXX_Size() int

+ func (m *DataProvidersAccumulatedRewards) XXX_Unmarshal(b []byte) error

+ type DataSource struct

+ Description string

+ Fee github_com_cosmos_cosmos_sdk_types.Coins

+ Filename string

+ ID DataSourceID

+ Name string

+ Owner string

+ func NewDataSource(owner sdk.AccAddress, name, description, filename string, fee sdk.Coins) DataSource

+ func (*DataSource) Descriptor() ([]byte, []int)

+ func (*DataSource) ProtoMessage()

+ func (m *DataSource) GetDescription() string

+ func (m *DataSource) GetFee() github_com_cosmos_cosmos_sdk_types.Coins

+ func (m *DataSource) GetFilename() string

+ func (m *DataSource) GetID() DataSourceID

+ func (m *DataSource) GetName() string

+ func (m *DataSource) GetOwner() string

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

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

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

+ func (m *DataSource) Reset()

+ func (m *DataSource) Size() (n int)

+ func (m *DataSource) String() string

+ func (m *DataSource) Unmarshal(dAtA []byte) error

+ func (m *DataSource) XXX_DiscardUnknown()

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

+ func (m *DataSource) XXX_Merge(src proto.Message)

+ func (m *DataSource) XXX_Size() int

+ func (m *DataSource) XXX_Unmarshal(b []byte) error

+ func (this *DataSource) Equal(that interface{}) bool

+ type DataSourceID int64

+ type DistrKeeper interface

+ AllocateTokensToValidator func(ctx sdk.Context, val stakingtypes.ValidatorI, tokens sdk.DecCoins)

+ GetCommunityTax func(ctx sdk.Context) (percent sdk.Dec)

+ GetFeePool func(ctx sdk.Context) (feePool distrtypes.FeePool)

+ SetFeePool func(ctx sdk.Context, feePool distrtypes.FeePool)

+ type ExecuteEnv struct

+ Retdata []byte

+ func NewExecuteEnv(req Request, reports []Report) *ExecuteEnv

+ func (env *ExecuteEnv) GetAnsCount() (int64, error)

+ func (env *ExecuteEnv) GetExternalData(eid int64, vid int64) ([]byte, error)

+ func (env *ExecuteEnv) GetExternalDataStatus(eid int64, vid int64) (int64, error)

+ func (env *ExecuteEnv) SetReturnData(data []byte) error

+ type ExternalID int64

+ type GenesisState struct

+ DataSources []DataSource

+ OraclePool OraclePool

+ OracleScripts []OracleScript

+ Params Params

+ func DefaultGenesisState() *GenesisState

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

+ func NewGenesisState(params Params, dataSources []DataSource, oracleScripts []OracleScript) *GenesisState

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

+ func (*GenesisState) ProtoMessage()

+ func (g GenesisState) UnpackInterfaces(c codectypes.AnyUnpacker) error

+ func (g GenesisState) Validate() error

+ func (m *GenesisState) GetDataSources() []DataSource

+ func (m *GenesisState) GetOraclePool() OraclePool

+ func (m *GenesisState) GetOracleScripts() []OracleScript

+ func (m *GenesisState) GetParams() Params

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

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

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

+ func (m *GenesisState) Reset()

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

+ func (m *GenesisState) String() string

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

+ func (m *GenesisState) XXX_DiscardUnknown()

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

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

+ func (m *GenesisState) XXX_Size() int

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

+ type IBCSource struct

+ SourceChannel string

+ SourcePort string

+ func (*IBCSource) Descriptor() ([]byte, []int)

+ func (*IBCSource) ProtoMessage()

+ func (m *IBCSource) GetSourceChannel() string

+ func (m *IBCSource) GetSourcePort() string

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

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

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

+ func (m *IBCSource) Reset()

+ func (m *IBCSource) Size() (n int)

+ func (m *IBCSource) String() string

+ func (m *IBCSource) Unmarshal(dAtA []byte) error

+ func (m *IBCSource) XXX_DiscardUnknown()

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

+ func (m *IBCSource) XXX_Merge(src proto.Message)

+ func (m *IBCSource) XXX_Size() int

+ func (m *IBCSource) XXX_Unmarshal(b []byte) error

+ func (this *IBCSource) Equal(that interface{}) bool

+ type MsgActivate struct

+ Validator string

+ func NewMsgActivate(validator sdk.ValAddress) *MsgActivate

+ func (*MsgActivate) Descriptor() ([]byte, []int)

+ func (*MsgActivate) ProtoMessage()

+ func (m *MsgActivate) GetValidator() string

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

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

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

+ func (m *MsgActivate) Reset()

+ func (m *MsgActivate) Size() (n int)

+ func (m *MsgActivate) String() string

+ func (m *MsgActivate) Unmarshal(dAtA []byte) error

+ func (m *MsgActivate) XXX_DiscardUnknown()

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

+ func (m *MsgActivate) XXX_Merge(src proto.Message)

+ func (m *MsgActivate) XXX_Size() int

+ func (m *MsgActivate) XXX_Unmarshal(b []byte) error

+ func (msg MsgActivate) GetSignBytes() []byte

+ func (msg MsgActivate) GetSigners() []sdk.AccAddress

+ func (msg MsgActivate) Route() string

+ func (msg MsgActivate) Type() string

+ func (msg MsgActivate) ValidateBasic() error

+ func (this *MsgActivate) Equal(that interface{}) bool

+ type MsgActivateResponse struct

+ func (*MsgActivateResponse) Descriptor() ([]byte, []int)

+ func (*MsgActivateResponse) ProtoMessage()

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

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

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

+ func (m *MsgActivateResponse) Reset()

+ func (m *MsgActivateResponse) Size() (n int)

+ func (m *MsgActivateResponse) String() string

+ func (m *MsgActivateResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgActivateResponse) XXX_DiscardUnknown()

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

+ func (m *MsgActivateResponse) XXX_Merge(src proto.Message)

+ func (m *MsgActivateResponse) XXX_Size() int

+ func (m *MsgActivateResponse) XXX_Unmarshal(b []byte) error

+ type MsgAddReporter struct

+ Reporter string

+ Validator string

+ func NewMsgAddReporter(validator sdk.ValAddress, reporter sdk.AccAddress) *MsgAddReporter

+ func (*MsgAddReporter) Descriptor() ([]byte, []int)

+ func (*MsgAddReporter) ProtoMessage()

+ func (m *MsgAddReporter) GetReporter() string

+ func (m *MsgAddReporter) GetValidator() string

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

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

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

+ func (m *MsgAddReporter) Reset()

+ func (m *MsgAddReporter) Size() (n int)

+ func (m *MsgAddReporter) String() string

+ func (m *MsgAddReporter) Unmarshal(dAtA []byte) error

+ func (m *MsgAddReporter) XXX_DiscardUnknown()

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

+ func (m *MsgAddReporter) XXX_Merge(src proto.Message)

+ func (m *MsgAddReporter) XXX_Size() int

+ func (m *MsgAddReporter) XXX_Unmarshal(b []byte) error

+ func (msg MsgAddReporter) GetSignBytes() []byte

+ func (msg MsgAddReporter) GetSigners() []sdk.AccAddress

+ func (msg MsgAddReporter) Route() string

+ func (msg MsgAddReporter) Type() string

+ func (msg MsgAddReporter) ValidateBasic() error

+ func (this *MsgAddReporter) Equal(that interface{}) bool

+ type MsgAddReporterResponse struct

+ func (*MsgAddReporterResponse) Descriptor() ([]byte, []int)

+ func (*MsgAddReporterResponse) ProtoMessage()

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

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

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

+ func (m *MsgAddReporterResponse) Reset()

+ func (m *MsgAddReporterResponse) Size() (n int)

+ func (m *MsgAddReporterResponse) String() string

+ func (m *MsgAddReporterResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgAddReporterResponse) XXX_DiscardUnknown()

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

+ func (m *MsgAddReporterResponse) XXX_Merge(src proto.Message)

+ func (m *MsgAddReporterResponse) XXX_Size() int

+ func (m *MsgAddReporterResponse) XXX_Unmarshal(b []byte) error

+ type MsgClient interface

+ Activate func(ctx context.Context, in *MsgActivate, opts ...grpc.CallOption) (*MsgActivateResponse, error)

+ AddReporter func(ctx context.Context, in *MsgAddReporter, opts ...grpc.CallOption) (*MsgAddReporterResponse, error)

+ CreateDataSource func(ctx context.Context, in *MsgCreateDataSource, opts ...grpc.CallOption) (*MsgCreateDataSourceResponse, error)

+ CreateOracleScript func(ctx context.Context, in *MsgCreateOracleScript, opts ...grpc.CallOption) (*MsgCreateOracleScriptResponse, error)

+ EditDataSource func(ctx context.Context, in *MsgEditDataSource, opts ...grpc.CallOption) (*MsgEditDataSourceResponse, error)

+ EditOracleScript func(ctx context.Context, in *MsgEditOracleScript, opts ...grpc.CallOption) (*MsgEditOracleScriptResponse, error)

+ RemoveReporter func(ctx context.Context, in *MsgRemoveReporter, opts ...grpc.CallOption) (*MsgRemoveReporterResponse, error)

+ ReportData func(ctx context.Context, in *MsgReportData, opts ...grpc.CallOption) (*MsgReportDataResponse, error)

+ RequestData func(ctx context.Context, in *MsgRequestData, opts ...grpc.CallOption) (*MsgRequestDataResponse, error)

+ func NewMsgClient(cc grpc1.ClientConn) MsgClient

+ type MsgCreateDataSource struct

+ Description string

+ Executable []byte

+ Fee github_com_cosmos_cosmos_sdk_types.Coins

+ Name string

+ Owner string

+ Sender string

+ func NewMsgCreateDataSource(name, description string, executable []byte, fee sdk.Coins, ...) *MsgCreateDataSource

+ func (*MsgCreateDataSource) Descriptor() ([]byte, []int)

+ func (*MsgCreateDataSource) ProtoMessage()

+ func (m *MsgCreateDataSource) GetDescription() string

+ func (m *MsgCreateDataSource) GetExecutable() []byte

+ func (m *MsgCreateDataSource) GetFee() github_com_cosmos_cosmos_sdk_types.Coins

+ func (m *MsgCreateDataSource) GetName() string

+ func (m *MsgCreateDataSource) GetOwner() string

+ func (m *MsgCreateDataSource) GetSender() string

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

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

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

+ func (m *MsgCreateDataSource) Reset()

+ func (m *MsgCreateDataSource) Size() (n int)

+ func (m *MsgCreateDataSource) String() string

+ func (m *MsgCreateDataSource) Unmarshal(dAtA []byte) error

+ func (m *MsgCreateDataSource) XXX_DiscardUnknown()

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

+ func (m *MsgCreateDataSource) XXX_Merge(src proto.Message)

+ func (m *MsgCreateDataSource) XXX_Size() int

+ func (m *MsgCreateDataSource) XXX_Unmarshal(b []byte) error

+ func (msg MsgCreateDataSource) GetSignBytes() []byte

+ func (msg MsgCreateDataSource) GetSigners() []sdk.AccAddress

+ func (msg MsgCreateDataSource) Route() string

+ func (msg MsgCreateDataSource) Type() string

+ func (msg MsgCreateDataSource) ValidateBasic() error

+ func (this *MsgCreateDataSource) Equal(that interface{}) bool

+ type MsgCreateDataSourceResponse struct

+ func (*MsgCreateDataSourceResponse) Descriptor() ([]byte, []int)

+ func (*MsgCreateDataSourceResponse) ProtoMessage()

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

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

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

+ func (m *MsgCreateDataSourceResponse) Reset()

+ func (m *MsgCreateDataSourceResponse) Size() (n int)

+ func (m *MsgCreateDataSourceResponse) String() string

+ func (m *MsgCreateDataSourceResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgCreateDataSourceResponse) XXX_DiscardUnknown()

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

+ func (m *MsgCreateDataSourceResponse) XXX_Merge(src proto.Message)

+ func (m *MsgCreateDataSourceResponse) XXX_Size() int

+ func (m *MsgCreateDataSourceResponse) XXX_Unmarshal(b []byte) error

+ type MsgCreateOracleScript struct

+ Code []byte

+ Description string

+ Name string

+ Owner string

+ Schema string

+ Sender string

+ SourceCodeURL string

+ func NewMsgCreateOracleScript(name, description, schema, sourceCodeURL string, code []byte, ...) *MsgCreateOracleScript

+ func (*MsgCreateOracleScript) Descriptor() ([]byte, []int)

+ func (*MsgCreateOracleScript) ProtoMessage()

+ func (m *MsgCreateOracleScript) GetCode() []byte

+ func (m *MsgCreateOracleScript) GetDescription() string

+ func (m *MsgCreateOracleScript) GetName() string

+ func (m *MsgCreateOracleScript) GetOwner() string

+ func (m *MsgCreateOracleScript) GetSchema() string

+ func (m *MsgCreateOracleScript) GetSender() string

+ func (m *MsgCreateOracleScript) GetSourceCodeURL() string

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

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

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

+ func (m *MsgCreateOracleScript) Reset()

+ func (m *MsgCreateOracleScript) Size() (n int)

+ func (m *MsgCreateOracleScript) String() string

+ func (m *MsgCreateOracleScript) Unmarshal(dAtA []byte) error

+ func (m *MsgCreateOracleScript) XXX_DiscardUnknown()

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

+ func (m *MsgCreateOracleScript) XXX_Merge(src proto.Message)

+ func (m *MsgCreateOracleScript) XXX_Size() int

+ func (m *MsgCreateOracleScript) XXX_Unmarshal(b []byte) error

+ func (msg MsgCreateOracleScript) GetSignBytes() []byte

+ func (msg MsgCreateOracleScript) GetSigners() []sdk.AccAddress

+ func (msg MsgCreateOracleScript) Route() string

+ func (msg MsgCreateOracleScript) Type() string

+ func (msg MsgCreateOracleScript) ValidateBasic() error

+ func (this *MsgCreateOracleScript) Equal(that interface{}) bool

+ type MsgCreateOracleScriptResponse struct

+ func (*MsgCreateOracleScriptResponse) Descriptor() ([]byte, []int)

+ func (*MsgCreateOracleScriptResponse) ProtoMessage()

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

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

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

+ func (m *MsgCreateOracleScriptResponse) Reset()

+ func (m *MsgCreateOracleScriptResponse) Size() (n int)

+ func (m *MsgCreateOracleScriptResponse) String() string

+ func (m *MsgCreateOracleScriptResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgCreateOracleScriptResponse) XXX_DiscardUnknown()

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

+ func (m *MsgCreateOracleScriptResponse) XXX_Merge(src proto.Message)

+ func (m *MsgCreateOracleScriptResponse) XXX_Size() int

+ func (m *MsgCreateOracleScriptResponse) XXX_Unmarshal(b []byte) error

+ type MsgEditDataSource struct

+ DataSourceID DataSourceID

+ Description string

+ Executable []byte

+ Fee github_com_cosmos_cosmos_sdk_types.Coins

+ Name string

+ Owner string

+ Sender string

+ func NewMsgEditDataSource(dataSourceID DataSourceID, name string, description string, executable []byte, ...) *MsgEditDataSource

+ func (*MsgEditDataSource) Descriptor() ([]byte, []int)

+ func (*MsgEditDataSource) ProtoMessage()

+ func (m *MsgEditDataSource) GetDataSourceID() DataSourceID

+ func (m *MsgEditDataSource) GetDescription() string

+ func (m *MsgEditDataSource) GetExecutable() []byte

+ func (m *MsgEditDataSource) GetFee() github_com_cosmos_cosmos_sdk_types.Coins

+ func (m *MsgEditDataSource) GetName() string

+ func (m *MsgEditDataSource) GetOwner() string

+ func (m *MsgEditDataSource) GetSender() string

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

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

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

+ func (m *MsgEditDataSource) Reset()

+ func (m *MsgEditDataSource) Size() (n int)

+ func (m *MsgEditDataSource) String() string

+ func (m *MsgEditDataSource) Unmarshal(dAtA []byte) error

+ func (m *MsgEditDataSource) XXX_DiscardUnknown()

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

+ func (m *MsgEditDataSource) XXX_Merge(src proto.Message)

+ func (m *MsgEditDataSource) XXX_Size() int

+ func (m *MsgEditDataSource) XXX_Unmarshal(b []byte) error

+ func (msg MsgEditDataSource) GetSignBytes() []byte

+ func (msg MsgEditDataSource) GetSigners() []sdk.AccAddress

+ func (msg MsgEditDataSource) Route() string

+ func (msg MsgEditDataSource) Type() string

+ func (msg MsgEditDataSource) ValidateBasic() error

+ func (this *MsgEditDataSource) Equal(that interface{}) bool

+ type MsgEditDataSourceResponse struct

+ func (*MsgEditDataSourceResponse) Descriptor() ([]byte, []int)

+ func (*MsgEditDataSourceResponse) ProtoMessage()

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

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

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

+ func (m *MsgEditDataSourceResponse) Reset()

+ func (m *MsgEditDataSourceResponse) Size() (n int)

+ func (m *MsgEditDataSourceResponse) String() string

+ func (m *MsgEditDataSourceResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgEditDataSourceResponse) XXX_DiscardUnknown()

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

+ func (m *MsgEditDataSourceResponse) XXX_Merge(src proto.Message)

+ func (m *MsgEditDataSourceResponse) XXX_Size() int

+ func (m *MsgEditDataSourceResponse) XXX_Unmarshal(b []byte) error

+ type MsgEditOracleScript struct

+ Code []byte

+ Description string

+ Name string

+ OracleScriptID OracleScriptID

+ Owner string

+ Schema string

+ Sender string

+ SourceCodeURL string

+ func NewMsgEditOracleScript(oracleScriptID OracleScriptID, name, description, schema, sourceCodeURL string, ...) *MsgEditOracleScript

+ func (*MsgEditOracleScript) Descriptor() ([]byte, []int)

+ func (*MsgEditOracleScript) ProtoMessage()

+ func (m *MsgEditOracleScript) GetCode() []byte

+ func (m *MsgEditOracleScript) GetDescription() string

+ func (m *MsgEditOracleScript) GetName() string

+ func (m *MsgEditOracleScript) GetOracleScriptID() OracleScriptID

+ func (m *MsgEditOracleScript) GetOwner() string

+ func (m *MsgEditOracleScript) GetSchema() string

+ func (m *MsgEditOracleScript) GetSender() string

+ func (m *MsgEditOracleScript) GetSourceCodeURL() string

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

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

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

+ func (m *MsgEditOracleScript) Reset()

+ func (m *MsgEditOracleScript) Size() (n int)

+ func (m *MsgEditOracleScript) String() string

+ func (m *MsgEditOracleScript) Unmarshal(dAtA []byte) error

+ func (m *MsgEditOracleScript) XXX_DiscardUnknown()

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

+ func (m *MsgEditOracleScript) XXX_Merge(src proto.Message)

+ func (m *MsgEditOracleScript) XXX_Size() int

+ func (m *MsgEditOracleScript) XXX_Unmarshal(b []byte) error

+ func (msg MsgEditOracleScript) GetSignBytes() []byte

+ func (msg MsgEditOracleScript) GetSigners() []sdk.AccAddress

+ func (msg MsgEditOracleScript) Route() string

+ func (msg MsgEditOracleScript) Type() string

+ func (msg MsgEditOracleScript) ValidateBasic() error

+ func (this *MsgEditOracleScript) Equal(that interface{}) bool

+ type MsgEditOracleScriptResponse struct

+ func (*MsgEditOracleScriptResponse) Descriptor() ([]byte, []int)

+ func (*MsgEditOracleScriptResponse) ProtoMessage()

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

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

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

+ func (m *MsgEditOracleScriptResponse) Reset()

+ func (m *MsgEditOracleScriptResponse) Size() (n int)

+ func (m *MsgEditOracleScriptResponse) String() string

+ func (m *MsgEditOracleScriptResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgEditOracleScriptResponse) XXX_DiscardUnknown()

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

+ func (m *MsgEditOracleScriptResponse) XXX_Merge(src proto.Message)

+ func (m *MsgEditOracleScriptResponse) XXX_Size() int

+ func (m *MsgEditOracleScriptResponse) XXX_Unmarshal(b []byte) error

+ type MsgRemoveReporter struct

+ Reporter string

+ Validator string

+ func NewMsgRemoveReporter(validator sdk.ValAddress, reporter sdk.AccAddress) *MsgRemoveReporter

+ func (*MsgRemoveReporter) Descriptor() ([]byte, []int)

+ func (*MsgRemoveReporter) ProtoMessage()

+ func (m *MsgRemoveReporter) GetReporter() string

+ func (m *MsgRemoveReporter) GetValidator() string

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

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

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

+ func (m *MsgRemoveReporter) Reset()

+ func (m *MsgRemoveReporter) Size() (n int)

+ func (m *MsgRemoveReporter) String() string

+ func (m *MsgRemoveReporter) Unmarshal(dAtA []byte) error

+ func (m *MsgRemoveReporter) XXX_DiscardUnknown()

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

+ func (m *MsgRemoveReporter) XXX_Merge(src proto.Message)

+ func (m *MsgRemoveReporter) XXX_Size() int

+ func (m *MsgRemoveReporter) XXX_Unmarshal(b []byte) error

+ func (msg MsgRemoveReporter) GetSignBytes() []byte

+ func (msg MsgRemoveReporter) GetSigners() []sdk.AccAddress

+ func (msg MsgRemoveReporter) Route() string

+ func (msg MsgRemoveReporter) Type() string

+ func (msg MsgRemoveReporter) ValidateBasic() error

+ func (this *MsgRemoveReporter) Equal(that interface{}) bool

+ type MsgRemoveReporterResponse struct

+ func (*MsgRemoveReporterResponse) Descriptor() ([]byte, []int)

+ func (*MsgRemoveReporterResponse) ProtoMessage()

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

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

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

+ func (m *MsgRemoveReporterResponse) Reset()

+ func (m *MsgRemoveReporterResponse) Size() (n int)

+ func (m *MsgRemoveReporterResponse) String() string

+ func (m *MsgRemoveReporterResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgRemoveReporterResponse) XXX_DiscardUnknown()

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

+ func (m *MsgRemoveReporterResponse) XXX_Merge(src proto.Message)

+ func (m *MsgRemoveReporterResponse) XXX_Size() int

+ func (m *MsgRemoveReporterResponse) XXX_Unmarshal(b []byte) error

+ type MsgReportData struct

+ RawReports []RawReport

+ Reporter string

+ RequestID RequestID

+ Validator string

+ func NewMsgReportData(requestID RequestID, rawReports []RawReport, validator sdk.ValAddress, ...) *MsgReportData

+ func (*MsgReportData) Descriptor() ([]byte, []int)

+ func (*MsgReportData) ProtoMessage()

+ func (m *MsgReportData) GetRawReports() []RawReport

+ func (m *MsgReportData) GetReporter() string

+ func (m *MsgReportData) GetRequestID() RequestID

+ func (m *MsgReportData) GetValidator() string

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

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

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

+ func (m *MsgReportData) Reset()

+ func (m *MsgReportData) Size() (n int)

+ func (m *MsgReportData) String() string

+ func (m *MsgReportData) Unmarshal(dAtA []byte) error

+ func (m *MsgReportData) XXX_DiscardUnknown()

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

+ func (m *MsgReportData) XXX_Merge(src proto.Message)

+ func (m *MsgReportData) XXX_Size() int

+ func (m *MsgReportData) XXX_Unmarshal(b []byte) error

+ func (msg MsgReportData) GetSignBytes() []byte

+ func (msg MsgReportData) GetSigners() []sdk.AccAddress

+ func (msg MsgReportData) Route() string

+ func (msg MsgReportData) Type() string

+ func (msg MsgReportData) ValidateBasic() error

+ func (this *MsgReportData) Equal(that interface{}) bool

+ type MsgReportDataResponse struct

+ func (*MsgReportDataResponse) Descriptor() ([]byte, []int)

+ func (*MsgReportDataResponse) ProtoMessage()

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

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

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

+ func (m *MsgReportDataResponse) Reset()

+ func (m *MsgReportDataResponse) Size() (n int)

+ func (m *MsgReportDataResponse) String() string

+ func (m *MsgReportDataResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgReportDataResponse) XXX_DiscardUnknown()

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

+ func (m *MsgReportDataResponse) XXX_Merge(src proto.Message)

+ func (m *MsgReportDataResponse) XXX_Size() int

+ func (m *MsgReportDataResponse) XXX_Unmarshal(b []byte) error

+ type MsgRequestData struct

+ AskCount uint64

+ Calldata []byte

+ ClientID string

+ ExecuteGas uint64

+ FeeLimit github_com_cosmos_cosmos_sdk_types.Coins

+ MinCount uint64

+ OracleScriptID OracleScriptID

+ PrepareGas uint64

+ Sender string

+ func NewMsgRequestData(oracleScriptID OracleScriptID, calldata []byte, askCount, minCount uint64, ...) *MsgRequestData

+ func (*MsgRequestData) Descriptor() ([]byte, []int)

+ func (*MsgRequestData) ProtoMessage()

+ func (m *MsgRequestData) GetAskCount() uint64

+ func (m *MsgRequestData) GetCalldata() []byte

+ func (m *MsgRequestData) GetClientID() string

+ func (m *MsgRequestData) GetExecuteGas() uint64

+ func (m *MsgRequestData) GetFeeLimit() github_com_cosmos_cosmos_sdk_types.Coins

+ func (m *MsgRequestData) GetMinCount() uint64

+ func (m *MsgRequestData) GetOracleScriptID() OracleScriptID

+ func (m *MsgRequestData) GetPrepareGas() uint64

+ func (m *MsgRequestData) GetSender() string

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

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

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

+ func (m *MsgRequestData) Reset()

+ func (m *MsgRequestData) Size() (n int)

+ func (m *MsgRequestData) String() string

+ func (m *MsgRequestData) Unmarshal(dAtA []byte) error

+ func (m *MsgRequestData) XXX_DiscardUnknown()

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

+ func (m *MsgRequestData) XXX_Merge(src proto.Message)

+ func (m *MsgRequestData) XXX_Size() int

+ func (m *MsgRequestData) XXX_Unmarshal(b []byte) error

+ func (msg MsgRequestData) GetSignBytes() []byte

+ func (msg MsgRequestData) GetSigners() []sdk.AccAddress

+ func (msg MsgRequestData) Route() string

+ func (msg MsgRequestData) Type() string

+ func (msg MsgRequestData) ValidateBasic() error

+ func (this *MsgRequestData) Equal(that interface{}) bool

+ type MsgRequestDataResponse struct

+ func (*MsgRequestDataResponse) Descriptor() ([]byte, []int)

+ func (*MsgRequestDataResponse) ProtoMessage()

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

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

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

+ func (m *MsgRequestDataResponse) Reset()

+ func (m *MsgRequestDataResponse) Size() (n int)

+ func (m *MsgRequestDataResponse) String() string

+ func (m *MsgRequestDataResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgRequestDataResponse) XXX_DiscardUnknown()

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

+ func (m *MsgRequestDataResponse) XXX_Merge(src proto.Message)

+ func (m *MsgRequestDataResponse) XXX_Size() int

+ func (m *MsgRequestDataResponse) XXX_Unmarshal(b []byte) error

+ type MsgServer interface

+ Activate func(context.Context, *MsgActivate) (*MsgActivateResponse, error)

+ AddReporter func(context.Context, *MsgAddReporter) (*MsgAddReporterResponse, error)

+ CreateDataSource func(context.Context, *MsgCreateDataSource) (*MsgCreateDataSourceResponse, error)

+ CreateOracleScript func(context.Context, *MsgCreateOracleScript) (*MsgCreateOracleScriptResponse, error)

+ EditDataSource func(context.Context, *MsgEditDataSource) (*MsgEditDataSourceResponse, error)

+ EditOracleScript func(context.Context, *MsgEditOracleScript) (*MsgEditOracleScriptResponse, error)

+ RemoveReporter func(context.Context, *MsgRemoveReporter) (*MsgRemoveReporterResponse, error)

+ ReportData func(context.Context, *MsgReportData) (*MsgReportDataResponse, error)

+ RequestData func(context.Context, *MsgRequestData) (*MsgRequestDataResponse, error)

+ type OraclePool struct

+ DataProvidersPool github_com_cosmos_cosmos_sdk_types.Coins

+ func InitialOraclePool() OraclePool

+ func (*OraclePool) Descriptor() ([]byte, []int)

+ func (*OraclePool) ProtoMessage()

+ func (f OraclePool) ValidateGenesis() error

+ func (m *OraclePool) GetDataProvidersPool() github_com_cosmos_cosmos_sdk_types.Coins

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

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

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

+ func (m *OraclePool) Reset()

+ func (m *OraclePool) Size() (n int)

+ func (m *OraclePool) String() string

+ func (m *OraclePool) Unmarshal(dAtA []byte) error

+ func (m *OraclePool) XXX_DiscardUnknown()

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

+ func (m *OraclePool) XXX_Merge(src proto.Message)

+ func (m *OraclePool) XXX_Size() int

+ func (m *OraclePool) XXX_Unmarshal(b []byte) error

+ func (this *OraclePool) Equal(that interface{}) bool

+ type OracleRequestPacketAcknowledgement struct

+ RequestID RequestID

+ func NewOracleRequestPacketAcknowledgement(requestID RequestID) *OracleRequestPacketAcknowledgement

+ func (*OracleRequestPacketAcknowledgement) Descriptor() ([]byte, []int)

+ func (*OracleRequestPacketAcknowledgement) ProtoMessage()

+ func (m *OracleRequestPacketAcknowledgement) GetRequestID() RequestID

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

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

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

+ func (m *OracleRequestPacketAcknowledgement) Reset()

+ func (m *OracleRequestPacketAcknowledgement) Size() (n int)

+ func (m *OracleRequestPacketAcknowledgement) String() string

+ func (m *OracleRequestPacketAcknowledgement) Unmarshal(dAtA []byte) error

+ func (m *OracleRequestPacketAcknowledgement) XXX_DiscardUnknown()

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

+ func (m *OracleRequestPacketAcknowledgement) XXX_Merge(src proto.Message)

+ func (m *OracleRequestPacketAcknowledgement) XXX_Size() int

+ func (m *OracleRequestPacketAcknowledgement) XXX_Unmarshal(b []byte) error

+ func (this *OracleRequestPacketAcknowledgement) Equal(that interface{}) bool

+ type OracleRequestPacketData struct

+ AskCount uint64

+ Calldata []byte

+ ClientID string

+ ExecuteGas uint64

+ FeeLimit github_com_cosmos_cosmos_sdk_types.Coins

+ MinCount uint64

+ OracleScriptID OracleScriptID

+ PrepareGas uint64

+ RequestKey string

+ func NewOracleRequestPacketData(clientID string, oracleScriptID OracleScriptID, calldata []byte, ...) OracleRequestPacketData

+ func (*OracleRequestPacketData) Descriptor() ([]byte, []int)

+ func (*OracleRequestPacketData) ProtoMessage()

+ func (m *OracleRequestPacketData) GetAskCount() uint64

+ func (m *OracleRequestPacketData) GetCalldata() []byte

+ func (m *OracleRequestPacketData) GetClientID() string

+ func (m *OracleRequestPacketData) GetExecuteGas() uint64

+ func (m *OracleRequestPacketData) GetFeeLimit() github_com_cosmos_cosmos_sdk_types.Coins

+ func (m *OracleRequestPacketData) GetMinCount() uint64

+ func (m *OracleRequestPacketData) GetOracleScriptID() OracleScriptID

+ func (m *OracleRequestPacketData) GetPrepareGas() uint64

+ func (m *OracleRequestPacketData) GetRequestKey() string

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

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

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

+ func (m *OracleRequestPacketData) Reset()

+ func (m *OracleRequestPacketData) Size() (n int)

+ func (m *OracleRequestPacketData) String() string

+ func (m *OracleRequestPacketData) Unmarshal(dAtA []byte) error

+ func (m *OracleRequestPacketData) XXX_DiscardUnknown()

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

+ func (m *OracleRequestPacketData) XXX_Merge(src proto.Message)

+ func (m *OracleRequestPacketData) XXX_Size() int

+ func (m *OracleRequestPacketData) XXX_Unmarshal(b []byte) error

+ func (p OracleRequestPacketData) GetBytes() []byte

+ func (p OracleRequestPacketData) ValidateBasic() error

+ func (this *OracleRequestPacketData) Equal(that interface{}) bool

+ type OracleResponsePacketData struct

+ AnsCount uint64

+ ClientID string

+ RequestID RequestID

+ RequestTime int64

+ ResolveStatus ResolveStatus

+ ResolveTime int64

+ Result []byte

+ func NewOracleResponsePacketData(clientID string, requestID RequestID, ansCount uint64, requestTime int64, ...) OracleResponsePacketData

+ func (*OracleResponsePacketData) Descriptor() ([]byte, []int)

+ func (*OracleResponsePacketData) ProtoMessage()

+ func (m *OracleResponsePacketData) GetAnsCount() uint64

+ func (m *OracleResponsePacketData) GetClientID() string

+ func (m *OracleResponsePacketData) GetRequestID() RequestID

+ func (m *OracleResponsePacketData) GetRequestTime() int64

+ func (m *OracleResponsePacketData) GetResolveStatus() ResolveStatus

+ func (m *OracleResponsePacketData) GetResolveTime() int64

+ func (m *OracleResponsePacketData) GetResult() []byte

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

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

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

+ func (m *OracleResponsePacketData) Reset()

+ func (m *OracleResponsePacketData) Size() (n int)

+ func (m *OracleResponsePacketData) String() string

+ func (m *OracleResponsePacketData) Unmarshal(dAtA []byte) error

+ func (m *OracleResponsePacketData) XXX_DiscardUnknown()

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

+ func (m *OracleResponsePacketData) XXX_Merge(src proto.Message)

+ func (m *OracleResponsePacketData) XXX_Size() int

+ func (m *OracleResponsePacketData) XXX_Unmarshal(b []byte) error

+ func (p OracleResponsePacketData) GetBytes() []byte

+ func (this *OracleResponsePacketData) Equal(that interface{}) bool

+ type OracleScript struct

+ Description string

+ Filename string

+ ID OracleScriptID

+ Name string

+ Owner string

+ Schema string

+ SourceCodeURL string

+ func NewOracleScript(Owner sdk.AccAddress, Name string, Description string, Filename string, ...) OracleScript

+ func (*OracleScript) Descriptor() ([]byte, []int)

+ func (*OracleScript) ProtoMessage()

+ func (m *OracleScript) GetDescription() string

+ func (m *OracleScript) GetFilename() string

+ func (m *OracleScript) GetID() OracleScriptID

+ func (m *OracleScript) GetName() string

+ func (m *OracleScript) GetOwner() string

+ func (m *OracleScript) GetSchema() string

+ func (m *OracleScript) GetSourceCodeURL() string

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

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

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

+ func (m *OracleScript) Reset()

+ func (m *OracleScript) Size() (n int)

+ func (m *OracleScript) String() string

+ func (m *OracleScript) Unmarshal(dAtA []byte) error

+ func (m *OracleScript) XXX_DiscardUnknown()

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

+ func (m *OracleScript) XXX_Merge(src proto.Message)

+ func (m *OracleScript) XXX_Size() int

+ func (m *OracleScript) XXX_Unmarshal(b []byte) error

+ func (this *OracleScript) Equal(that interface{}) bool

+ type OracleScriptID int64

+ type Params struct

+ BaseOwasmGas uint64

+ DataProviderRewardPerByte github_com_cosmos_cosmos_sdk_types.Coins

+ DataProviderRewardThreshold RewardThreshold

+ DataRequesterFeeDenoms []string

+ ExpirationBlockCount uint64

+ InactivePenaltyDuration uint64

+ MaxAskCount uint64

+ MaxCalldataSize uint64

+ MaxDataSize uint64

+ MaxRawRequestCount uint64

+ OracleRewardPercentage uint64

+ PerValidatorRequestGas uint64

+ RewardDecreasingFraction github_com_cosmos_cosmos_sdk_types.Dec

+ SamplingTryCount uint64

+ func DefaultParams() Params

+ func NewParams(...) Params

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

+ func (*Params) ProtoMessage()

+ func (m *Params) GetBaseOwasmGas() uint64

+ func (m *Params) GetDataProviderRewardPerByte() github_com_cosmos_cosmos_sdk_types.Coins

+ func (m *Params) GetDataProviderRewardThreshold() RewardThreshold

+ func (m *Params) GetDataRequesterFeeDenoms() []string

+ func (m *Params) GetExpirationBlockCount() uint64

+ func (m *Params) GetInactivePenaltyDuration() uint64

+ func (m *Params) GetMaxAskCount() uint64

+ func (m *Params) GetMaxCalldataSize() uint64

+ func (m *Params) GetMaxDataSize() uint64

+ func (m *Params) GetMaxRawRequestCount() uint64

+ func (m *Params) GetOracleRewardPercentage() uint64

+ func (m *Params) GetPerValidatorRequestGas() uint64

+ func (m *Params) GetSamplingTryCount() uint64

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

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

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

+ func (m *Params) Reset()

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

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

+ func (m *Params) XXX_DiscardUnknown()

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

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

+ func (m *Params) XXX_Size() int

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

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

+ func (p Params) String() string

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

+ type PendingResolveList struct

+ RequestIds []int64

+ func (*PendingResolveList) Descriptor() ([]byte, []int)

+ func (*PendingResolveList) ProtoMessage()

+ func (m *PendingResolveList) GetRequestIds() []int64

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

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

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

+ func (m *PendingResolveList) Reset()

+ func (m *PendingResolveList) Size() (n int)

+ func (m *PendingResolveList) String() string

+ func (m *PendingResolveList) Unmarshal(dAtA []byte) error

+ func (m *PendingResolveList) XXX_DiscardUnknown()

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

+ func (m *PendingResolveList) XXX_Merge(src proto.Message)

+ func (m *PendingResolveList) XXX_Size() int

+ func (m *PendingResolveList) XXX_Unmarshal(b []byte) error

+ func (this *PendingResolveList) Equal(that interface{}) bool

+ type PortKeeper interface

+ BindPort func(ctx sdk.Context, portID string) *capabilitytypes.Capability

+ type PrepareEnv struct

+ func NewPrepareEnv(req Request, maxRawRequests, maxDataSize int64) *PrepareEnv

+ func (env *PrepareEnv) AskExternalData(eid int64, did int64, data []byte) error

+ func (env *PrepareEnv) GetRawRequests() []RawRequest

+ type QueryActiveValidatorResult struct

+ Address sdk.ValAddress

+ Power uint64

+ type QueryActiveValidatorsRequest struct

+ func (*QueryActiveValidatorsRequest) Descriptor() ([]byte, []int)

+ func (*QueryActiveValidatorsRequest) ProtoMessage()

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

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

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

+ func (m *QueryActiveValidatorsRequest) Reset()

+ func (m *QueryActiveValidatorsRequest) Size() (n int)

+ func (m *QueryActiveValidatorsRequest) String() string

+ func (m *QueryActiveValidatorsRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryActiveValidatorsRequest) XXX_DiscardUnknown()

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

+ func (m *QueryActiveValidatorsRequest) XXX_Merge(src proto.Message)

+ func (m *QueryActiveValidatorsRequest) XXX_Size() int

+ func (m *QueryActiveValidatorsRequest) XXX_Unmarshal(b []byte) error

+ type QueryActiveValidatorsResponse struct

+ Count int64

+ func (*QueryActiveValidatorsResponse) Descriptor() ([]byte, []int)

+ func (*QueryActiveValidatorsResponse) ProtoMessage()

+ func (m *QueryActiveValidatorsResponse) GetCount() int64

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

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

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

+ func (m *QueryActiveValidatorsResponse) Reset()

+ func (m *QueryActiveValidatorsResponse) Size() (n int)

+ func (m *QueryActiveValidatorsResponse) String() string

+ func (m *QueryActiveValidatorsResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryActiveValidatorsResponse) XXX_DiscardUnknown()

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

+ func (m *QueryActiveValidatorsResponse) XXX_Merge(src proto.Message)

+ func (m *QueryActiveValidatorsResponse) XXX_Size() int

+ func (m *QueryActiveValidatorsResponse) XXX_Unmarshal(b []byte) error

+ type QueryClient interface

+ ActiveValidators func(ctx context.Context, in *QueryActiveValidatorsRequest, opts ...grpc.CallOption) (*QueryActiveValidatorsResponse, error)

+ Counts func(ctx context.Context, in *QueryCountsRequest, opts ...grpc.CallOption) (*QueryCountsResponse, error)

+ Data func(ctx context.Context, in *QueryDataRequest, opts ...grpc.CallOption) (*QueryDataResponse, error)

+ DataProviderReward func(ctx context.Context, in *QueryDataProviderRewardRequest, ...) (*QueryDataProviderRewardResponse, error)

+ DataProvidersPool func(ctx context.Context, in *QueryDataProvidersPoolRequest, ...) (*QueryDataProvidersPoolResponse, error)

+ DataSource func(ctx context.Context, in *QueryDataSourceRequest, opts ...grpc.CallOption) (*QueryDataSourceResponse, error)

+ DataSources func(ctx context.Context, in *QueryDataSourcesRequest, opts ...grpc.CallOption) (*QueryDataSourcesResponse, error)

+ OracleScript func(ctx context.Context, in *QueryOracleScriptRequest, opts ...grpc.CallOption) (*QueryOracleScriptResponse, error)

+ OracleScripts func(ctx context.Context, in *QueryOracleScriptsRequest, opts ...grpc.CallOption) (*QueryOracleScriptsResponse, error)

+ Params func(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)

+ PendingRequests func(ctx context.Context, in *QueryPendingRequestsRequest, opts ...grpc.CallOption) (*QueryPendingRequestsResponse, error)

+ Reporters func(ctx context.Context, in *QueryReportersRequest, opts ...grpc.CallOption) (*QueryReportersResponse, error)

+ Request func(ctx context.Context, in *QueryRequestRequest, opts ...grpc.CallOption) (*QueryRequestResponse, error)

+ RequestPrice func(ctx context.Context, in *QueryRequestPriceRequest, opts ...grpc.CallOption) (*QueryRequestPriceResponse, error)

+ RequestReports func(ctx context.Context, in *QueryRequestReportsRequest, opts ...grpc.CallOption) (*QueryRequestReportsResponse, error)

+ RequestSearch func(ctx context.Context, in *QueryRequestSearchRequest, opts ...grpc.CallOption) (*QueryRequestSearchResponse, error)

+ RequestVerification func(ctx context.Context, in *QueryRequestVerificationRequest, ...) (*QueryRequestVerificationResponse, error)

+ Requests func(ctx context.Context, in *QueryRequestsRequest, opts ...grpc.CallOption) (*QueryRequestsResponse, error)

+ Validator func(ctx context.Context, in *QueryValidatorRequest, opts ...grpc.CallOption) (*QueryValidatorResponse, error)

+ func NewQueryClient(cc grpc1.ClientConn) QueryClient

+ type QueryCountsRequest struct

+ func (*QueryCountsRequest) Descriptor() ([]byte, []int)

+ func (*QueryCountsRequest) ProtoMessage()

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

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

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

+ func (m *QueryCountsRequest) Reset()

+ func (m *QueryCountsRequest) Size() (n int)

+ func (m *QueryCountsRequest) String() string

+ func (m *QueryCountsRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryCountsRequest) XXX_DiscardUnknown()

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

+ func (m *QueryCountsRequest) XXX_Merge(src proto.Message)

+ func (m *QueryCountsRequest) XXX_Size() int

+ func (m *QueryCountsRequest) XXX_Unmarshal(b []byte) error

+ type QueryCountsResponse struct

+ DataSourceCount int64

+ OracleScriptCount int64

+ RequestCount int64

+ func (*QueryCountsResponse) Descriptor() ([]byte, []int)

+ func (*QueryCountsResponse) ProtoMessage()

+ func (m *QueryCountsResponse) GetDataSourceCount() int64

+ func (m *QueryCountsResponse) GetOracleScriptCount() int64

+ func (m *QueryCountsResponse) GetRequestCount() int64

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

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

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

+ func (m *QueryCountsResponse) Reset()

+ func (m *QueryCountsResponse) Size() (n int)

+ func (m *QueryCountsResponse) String() string

+ func (m *QueryCountsResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryCountsResponse) XXX_DiscardUnknown()

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

+ func (m *QueryCountsResponse) XXX_Merge(src proto.Message)

+ func (m *QueryCountsResponse) XXX_Size() int

+ func (m *QueryCountsResponse) XXX_Unmarshal(b []byte) error

+ type QueryDataProviderRewardRequest struct

+ func (*QueryDataProviderRewardRequest) Descriptor() ([]byte, []int)

+ func (*QueryDataProviderRewardRequest) ProtoMessage()

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

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

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

+ func (m *QueryDataProviderRewardRequest) Reset()

+ func (m *QueryDataProviderRewardRequest) Size() (n int)

+ func (m *QueryDataProviderRewardRequest) String() string

+ func (m *QueryDataProviderRewardRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryDataProviderRewardRequest) XXX_DiscardUnknown()

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

+ func (m *QueryDataProviderRewardRequest) XXX_Merge(src proto.Message)

+ func (m *QueryDataProviderRewardRequest) XXX_Size() int

+ func (m *QueryDataProviderRewardRequest) XXX_Unmarshal(b []byte) error

+ type QueryDataProviderRewardResponse struct

+ RewardPerByte github_com_cosmos_cosmos_sdk_types.Coins

+ func (*QueryDataProviderRewardResponse) Descriptor() ([]byte, []int)

+ func (*QueryDataProviderRewardResponse) ProtoMessage()

+ func (m *QueryDataProviderRewardResponse) GetRewardPerByte() github_com_cosmos_cosmos_sdk_types.Coins

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

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

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

+ func (m *QueryDataProviderRewardResponse) Reset()

+ func (m *QueryDataProviderRewardResponse) Size() (n int)

+ func (m *QueryDataProviderRewardResponse) String() string

+ func (m *QueryDataProviderRewardResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryDataProviderRewardResponse) XXX_DiscardUnknown()

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

+ func (m *QueryDataProviderRewardResponse) XXX_Merge(src proto.Message)

+ func (m *QueryDataProviderRewardResponse) XXX_Size() int

+ func (m *QueryDataProviderRewardResponse) XXX_Unmarshal(b []byte) error

+ type QueryDataProvidersPoolRequest struct

+ func (*QueryDataProvidersPoolRequest) Descriptor() ([]byte, []int)

+ func (*QueryDataProvidersPoolRequest) ProtoMessage()

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

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

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

+ func (m *QueryDataProvidersPoolRequest) Reset()

+ func (m *QueryDataProvidersPoolRequest) Size() (n int)

+ func (m *QueryDataProvidersPoolRequest) String() string

+ func (m *QueryDataProvidersPoolRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryDataProvidersPoolRequest) XXX_DiscardUnknown()

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

+ func (m *QueryDataProvidersPoolRequest) XXX_Merge(src proto.Message)

+ func (m *QueryDataProvidersPoolRequest) XXX_Size() int

+ func (m *QueryDataProvidersPoolRequest) XXX_Unmarshal(b []byte) error

+ type QueryDataProvidersPoolResponse struct

+ Pool github_com_cosmos_cosmos_sdk_types.Coins

+ func (*QueryDataProvidersPoolResponse) Descriptor() ([]byte, []int)

+ func (*QueryDataProvidersPoolResponse) ProtoMessage()

+ func (m *QueryDataProvidersPoolResponse) GetPool() github_com_cosmos_cosmos_sdk_types.Coins

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

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

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

+ func (m *QueryDataProvidersPoolResponse) Reset()

+ func (m *QueryDataProvidersPoolResponse) Size() (n int)

+ func (m *QueryDataProvidersPoolResponse) String() string

+ func (m *QueryDataProvidersPoolResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryDataProvidersPoolResponse) XXX_DiscardUnknown()

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

+ func (m *QueryDataProvidersPoolResponse) XXX_Merge(src proto.Message)

+ func (m *QueryDataProvidersPoolResponse) XXX_Size() int

+ func (m *QueryDataProvidersPoolResponse) XXX_Unmarshal(b []byte) error

+ type QueryDataRequest struct

+ DataHash string

+ func (*QueryDataRequest) Descriptor() ([]byte, []int)

+ func (*QueryDataRequest) ProtoMessage()

+ func (m *QueryDataRequest) GetDataHash() string

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

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

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

+ func (m *QueryDataRequest) Reset()

+ func (m *QueryDataRequest) Size() (n int)

+ func (m *QueryDataRequest) String() string

+ func (m *QueryDataRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryDataRequest) XXX_DiscardUnknown()

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

+ func (m *QueryDataRequest) XXX_Merge(src proto.Message)

+ func (m *QueryDataRequest) XXX_Size() int

+ func (m *QueryDataRequest) XXX_Unmarshal(b []byte) error

+ type QueryDataResponse struct

+ Data []byte

+ func (*QueryDataResponse) Descriptor() ([]byte, []int)

+ func (*QueryDataResponse) ProtoMessage()

+ func (m *QueryDataResponse) GetData() []byte

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

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

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

+ func (m *QueryDataResponse) Reset()

+ func (m *QueryDataResponse) Size() (n int)

+ func (m *QueryDataResponse) String() string

+ func (m *QueryDataResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryDataResponse) XXX_DiscardUnknown()

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

+ func (m *QueryDataResponse) XXX_Merge(src proto.Message)

+ func (m *QueryDataResponse) XXX_Size() int

+ func (m *QueryDataResponse) XXX_Unmarshal(b []byte) error

+ type QueryDataSourceRequest struct

+ DataSourceId int64

+ func (*QueryDataSourceRequest) Descriptor() ([]byte, []int)

+ func (*QueryDataSourceRequest) ProtoMessage()

+ func (m *QueryDataSourceRequest) GetDataSourceId() int64

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

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

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

+ func (m *QueryDataSourceRequest) Reset()

+ func (m *QueryDataSourceRequest) Size() (n int)

+ func (m *QueryDataSourceRequest) String() string

+ func (m *QueryDataSourceRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryDataSourceRequest) XXX_DiscardUnknown()

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

+ func (m *QueryDataSourceRequest) XXX_Merge(src proto.Message)

+ func (m *QueryDataSourceRequest) XXX_Size() int

+ func (m *QueryDataSourceRequest) XXX_Unmarshal(b []byte) error

+ type QueryDataSourceResponse struct

+ DataSource *DataSource

+ func (*QueryDataSourceResponse) Descriptor() ([]byte, []int)

+ func (*QueryDataSourceResponse) ProtoMessage()

+ func (m *QueryDataSourceResponse) GetDataSource() *DataSource

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

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

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

+ func (m *QueryDataSourceResponse) Reset()

+ func (m *QueryDataSourceResponse) Size() (n int)

+ func (m *QueryDataSourceResponse) String() string

+ func (m *QueryDataSourceResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryDataSourceResponse) XXX_DiscardUnknown()

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

+ func (m *QueryDataSourceResponse) XXX_Merge(src proto.Message)

+ func (m *QueryDataSourceResponse) XXX_Size() int

+ func (m *QueryDataSourceResponse) XXX_Unmarshal(b []byte) error

+ type QueryDataSourcesRequest struct

+ Pagination *query.PageRequest

+ func (*QueryDataSourcesRequest) Descriptor() ([]byte, []int)

+ func (*QueryDataSourcesRequest) ProtoMessage()

+ func (m *QueryDataSourcesRequest) GetPagination() *query.PageRequest

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

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

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

+ func (m *QueryDataSourcesRequest) Reset()

+ func (m *QueryDataSourcesRequest) Size() (n int)

+ func (m *QueryDataSourcesRequest) String() string

+ func (m *QueryDataSourcesRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryDataSourcesRequest) XXX_DiscardUnknown()

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

+ func (m *QueryDataSourcesRequest) XXX_Merge(src proto.Message)

+ func (m *QueryDataSourcesRequest) XXX_Size() int

+ func (m *QueryDataSourcesRequest) XXX_Unmarshal(b []byte) error

+ type QueryDataSourcesResponse struct

+ DataSources []DataSource

+ Pagination *query.PageResponse

+ func (*QueryDataSourcesResponse) Descriptor() ([]byte, []int)

+ func (*QueryDataSourcesResponse) ProtoMessage()

+ func (m *QueryDataSourcesResponse) GetDataSources() []DataSource

+ func (m *QueryDataSourcesResponse) GetPagination() *query.PageResponse

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

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

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

+ func (m *QueryDataSourcesResponse) Reset()

+ func (m *QueryDataSourcesResponse) Size() (n int)

+ func (m *QueryDataSourcesResponse) String() string

+ func (m *QueryDataSourcesResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryDataSourcesResponse) XXX_DiscardUnknown()

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

+ func (m *QueryDataSourcesResponse) XXX_Merge(src proto.Message)

+ func (m *QueryDataSourcesResponse) XXX_Size() int

+ func (m *QueryDataSourcesResponse) XXX_Unmarshal(b []byte) error

+ type QueryOracleScriptRequest struct

+ OracleScriptId int64

+ func (*QueryOracleScriptRequest) Descriptor() ([]byte, []int)

+ func (*QueryOracleScriptRequest) ProtoMessage()

+ func (m *QueryOracleScriptRequest) GetOracleScriptId() int64

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

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

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

+ func (m *QueryOracleScriptRequest) Reset()

+ func (m *QueryOracleScriptRequest) Size() (n int)

+ func (m *QueryOracleScriptRequest) String() string

+ func (m *QueryOracleScriptRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryOracleScriptRequest) XXX_DiscardUnknown()

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

+ func (m *QueryOracleScriptRequest) XXX_Merge(src proto.Message)

+ func (m *QueryOracleScriptRequest) XXX_Size() int

+ func (m *QueryOracleScriptRequest) XXX_Unmarshal(b []byte) error

+ type QueryOracleScriptResponse struct

+ OracleScript *OracleScript

+ func (*QueryOracleScriptResponse) Descriptor() ([]byte, []int)

+ func (*QueryOracleScriptResponse) ProtoMessage()

+ func (m *QueryOracleScriptResponse) GetOracleScript() *OracleScript

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

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

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

+ func (m *QueryOracleScriptResponse) Reset()

+ func (m *QueryOracleScriptResponse) Size() (n int)

+ func (m *QueryOracleScriptResponse) String() string

+ func (m *QueryOracleScriptResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryOracleScriptResponse) XXX_DiscardUnknown()

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

+ func (m *QueryOracleScriptResponse) XXX_Merge(src proto.Message)

+ func (m *QueryOracleScriptResponse) XXX_Size() int

+ func (m *QueryOracleScriptResponse) XXX_Unmarshal(b []byte) error

+ type QueryOracleScriptsRequest struct

+ Pagination *query.PageRequest

+ func (*QueryOracleScriptsRequest) Descriptor() ([]byte, []int)

+ func (*QueryOracleScriptsRequest) ProtoMessage()

+ func (m *QueryOracleScriptsRequest) GetPagination() *query.PageRequest

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

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

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

+ func (m *QueryOracleScriptsRequest) Reset()

+ func (m *QueryOracleScriptsRequest) Size() (n int)

+ func (m *QueryOracleScriptsRequest) String() string

+ func (m *QueryOracleScriptsRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryOracleScriptsRequest) XXX_DiscardUnknown()

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

+ func (m *QueryOracleScriptsRequest) XXX_Merge(src proto.Message)

+ func (m *QueryOracleScriptsRequest) XXX_Size() int

+ func (m *QueryOracleScriptsRequest) XXX_Unmarshal(b []byte) error

+ type QueryOracleScriptsResponse struct

+ OracleScripts []OracleScript

+ Pagination *query.PageResponse

+ func (*QueryOracleScriptsResponse) Descriptor() ([]byte, []int)

+ func (*QueryOracleScriptsResponse) ProtoMessage()

+ func (m *QueryOracleScriptsResponse) GetOracleScripts() []OracleScript

+ func (m *QueryOracleScriptsResponse) GetPagination() *query.PageResponse

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

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

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

+ func (m *QueryOracleScriptsResponse) Reset()

+ func (m *QueryOracleScriptsResponse) Size() (n int)

+ func (m *QueryOracleScriptsResponse) String() string

+ func (m *QueryOracleScriptsResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryOracleScriptsResponse) XXX_DiscardUnknown()

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

+ func (m *QueryOracleScriptsResponse) XXX_Merge(src proto.Message)

+ func (m *QueryOracleScriptsResponse) XXX_Size() int

+ func (m *QueryOracleScriptsResponse) XXX_Unmarshal(b []byte) error

+ type QueryParamsRequest struct

+ func (*QueryParamsRequest) Descriptor() ([]byte, []int)

+ func (*QueryParamsRequest) ProtoMessage()

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

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

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

+ func (m *QueryParamsRequest) Reset()

+ func (m *QueryParamsRequest) Size() (n int)

+ func (m *QueryParamsRequest) String() string

+ func (m *QueryParamsRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryParamsRequest) XXX_DiscardUnknown()

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

+ func (m *QueryParamsRequest) XXX_Merge(src proto.Message)

+ func (m *QueryParamsRequest) XXX_Size() int

+ func (m *QueryParamsRequest) XXX_Unmarshal(b []byte) error

+ type QueryParamsResponse struct

+ Params Params

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

+ func (*QueryParamsResponse) ProtoMessage()

+ func (m *QueryParamsResponse) GetParams() Params

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

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

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

+ func (m *QueryParamsResponse) Reset()

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

+ func (m *QueryParamsResponse) String() string

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

+ func (m *QueryParamsResponse) XXX_DiscardUnknown()

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

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

+ func (m *QueryParamsResponse) XXX_Size() int

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

+ type QueryPendingRequestsRequest struct

+ ValidatorAddress string

+ func (*QueryPendingRequestsRequest) Descriptor() ([]byte, []int)

+ func (*QueryPendingRequestsRequest) ProtoMessage()

+ func (m *QueryPendingRequestsRequest) GetValidatorAddress() string

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

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

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

+ func (m *QueryPendingRequestsRequest) Reset()

+ func (m *QueryPendingRequestsRequest) Size() (n int)

+ func (m *QueryPendingRequestsRequest) String() string

+ func (m *QueryPendingRequestsRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryPendingRequestsRequest) XXX_DiscardUnknown()

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

+ func (m *QueryPendingRequestsRequest) XXX_Merge(src proto.Message)

+ func (m *QueryPendingRequestsRequest) XXX_Size() int

+ func (m *QueryPendingRequestsRequest) XXX_Unmarshal(b []byte) error

+ type QueryPendingRequestsResponse struct

+ RequestIDs []int64

+ func (*QueryPendingRequestsResponse) Descriptor() ([]byte, []int)

+ func (*QueryPendingRequestsResponse) ProtoMessage()

+ func (m *QueryPendingRequestsResponse) GetRequestIDs() []int64

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

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

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

+ func (m *QueryPendingRequestsResponse) Reset()

+ func (m *QueryPendingRequestsResponse) Size() (n int)

+ func (m *QueryPendingRequestsResponse) String() string

+ func (m *QueryPendingRequestsResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryPendingRequestsResponse) XXX_DiscardUnknown()

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

+ func (m *QueryPendingRequestsResponse) XXX_Merge(src proto.Message)

+ func (m *QueryPendingRequestsResponse) XXX_Size() int

+ func (m *QueryPendingRequestsResponse) XXX_Unmarshal(b []byte) error

+ type QueryReportersRequest struct

+ ValidatorAddress string

+ func (*QueryReportersRequest) Descriptor() ([]byte, []int)

+ func (*QueryReportersRequest) ProtoMessage()

+ func (m *QueryReportersRequest) GetValidatorAddress() string

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

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

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

+ func (m *QueryReportersRequest) Reset()

+ func (m *QueryReportersRequest) Size() (n int)

+ func (m *QueryReportersRequest) String() string

+ func (m *QueryReportersRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryReportersRequest) XXX_DiscardUnknown()

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

+ func (m *QueryReportersRequest) XXX_Merge(src proto.Message)

+ func (m *QueryReportersRequest) XXX_Size() int

+ func (m *QueryReportersRequest) XXX_Unmarshal(b []byte) error

+ type QueryReportersResponse struct

+ Reporter []string

+ func (*QueryReportersResponse) Descriptor() ([]byte, []int)

+ func (*QueryReportersResponse) ProtoMessage()

+ func (m *QueryReportersResponse) GetReporter() []string

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

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

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

+ func (m *QueryReportersResponse) Reset()

+ func (m *QueryReportersResponse) Size() (n int)

+ func (m *QueryReportersResponse) String() string

+ func (m *QueryReportersResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryReportersResponse) XXX_DiscardUnknown()

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

+ func (m *QueryReportersResponse) XXX_Merge(src proto.Message)

+ func (m *QueryReportersResponse) XXX_Size() int

+ func (m *QueryReportersResponse) XXX_Unmarshal(b []byte) error

+ type QueryRequestIDs struct

+ RequestIds []int64

+ func (*QueryRequestIDs) Descriptor() ([]byte, []int)

+ func (*QueryRequestIDs) ProtoMessage()

+ func (m *QueryRequestIDs) GetRequestIds() []int64

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

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

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

+ func (m *QueryRequestIDs) Reset()

+ func (m *QueryRequestIDs) Size() (n int)

+ func (m *QueryRequestIDs) String() string

+ func (m *QueryRequestIDs) Unmarshal(dAtA []byte) error

+ func (m *QueryRequestIDs) XXX_DiscardUnknown()

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

+ func (m *QueryRequestIDs) XXX_Merge(src proto.Message)

+ func (m *QueryRequestIDs) XXX_Size() int

+ func (m *QueryRequestIDs) XXX_Unmarshal(b []byte) error

+ type QueryRequestPriceRequest struct

+ AskCount int64

+ MinCount int64

+ Symbol string

+ func NewQueryRequestPricesRequest(symbol string, minCount, askCount int64) QueryRequestPriceRequest

+ func (*QueryRequestPriceRequest) Descriptor() ([]byte, []int)

+ func (*QueryRequestPriceRequest) ProtoMessage()

+ func (m *QueryRequestPriceRequest) GetAskCount() int64

+ func (m *QueryRequestPriceRequest) GetMinCount() int64

+ func (m *QueryRequestPriceRequest) GetSymbol() string

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

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

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

+ func (m *QueryRequestPriceRequest) Reset()

+ func (m *QueryRequestPriceRequest) Size() (n int)

+ func (m *QueryRequestPriceRequest) String() string

+ func (m *QueryRequestPriceRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryRequestPriceRequest) XXX_DiscardUnknown()

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

+ func (m *QueryRequestPriceRequest) XXX_Merge(src proto.Message)

+ func (m *QueryRequestPriceRequest) XXX_Size() int

+ func (m *QueryRequestPriceRequest) XXX_Unmarshal(b []byte) error

+ type QueryRequestPriceResponse struct

+ AskCount int64

+ Calldata []byte

+ MinCount int64

+ OracleScriptId int64

+ func (*QueryRequestPriceResponse) Descriptor() ([]byte, []int)

+ func (*QueryRequestPriceResponse) ProtoMessage()

+ func (m *QueryRequestPriceResponse) GetAskCount() int64

+ func (m *QueryRequestPriceResponse) GetCalldata() []byte

+ func (m *QueryRequestPriceResponse) GetMinCount() int64

+ func (m *QueryRequestPriceResponse) GetOracleScriptId() int64

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

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

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

+ func (m *QueryRequestPriceResponse) Reset()

+ func (m *QueryRequestPriceResponse) Size() (n int)

+ func (m *QueryRequestPriceResponse) String() string

+ func (m *QueryRequestPriceResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryRequestPriceResponse) XXX_DiscardUnknown()

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

+ func (m *QueryRequestPriceResponse) XXX_Merge(src proto.Message)

+ func (m *QueryRequestPriceResponse) XXX_Size() int

+ func (m *QueryRequestPriceResponse) XXX_Unmarshal(b []byte) error

+ type QueryRequestReportsRequest struct

+ Pagination *query.PageRequest

+ RequestId int64

+ func (*QueryRequestReportsRequest) Descriptor() ([]byte, []int)

+ func (*QueryRequestReportsRequest) ProtoMessage()

+ func (m *QueryRequestReportsRequest) GetPagination() *query.PageRequest

+ func (m *QueryRequestReportsRequest) GetRequestId() int64

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

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

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

+ func (m *QueryRequestReportsRequest) Reset()

+ func (m *QueryRequestReportsRequest) Size() (n int)

+ func (m *QueryRequestReportsRequest) String() string

+ func (m *QueryRequestReportsRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryRequestReportsRequest) XXX_DiscardUnknown()

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

+ func (m *QueryRequestReportsRequest) XXX_Merge(src proto.Message)

+ func (m *QueryRequestReportsRequest) XXX_Size() int

+ func (m *QueryRequestReportsRequest) XXX_Unmarshal(b []byte) error

+ type QueryRequestReportsResponse struct

+ Pagination *query.PageResponse

+ Reports []Report

+ func (*QueryRequestReportsResponse) Descriptor() ([]byte, []int)

+ func (*QueryRequestReportsResponse) ProtoMessage()

+ func (m *QueryRequestReportsResponse) GetPagination() *query.PageResponse

+ func (m *QueryRequestReportsResponse) GetReports() []Report

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

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

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

+ func (m *QueryRequestReportsResponse) Reset()

+ func (m *QueryRequestReportsResponse) Size() (n int)

+ func (m *QueryRequestReportsResponse) String() string

+ func (m *QueryRequestReportsResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryRequestReportsResponse) XXX_DiscardUnknown()

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

+ func (m *QueryRequestReportsResponse) XXX_Merge(src proto.Message)

+ func (m *QueryRequestReportsResponse) XXX_Size() int

+ func (m *QueryRequestReportsResponse) XXX_Unmarshal(b []byte) error

+ type QueryRequestRequest struct

+ RequestId int64

+ func (*QueryRequestRequest) Descriptor() ([]byte, []int)

+ func (*QueryRequestRequest) ProtoMessage()

+ func (m *QueryRequestRequest) GetRequestId() int64

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

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

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

+ func (m *QueryRequestRequest) Reset()

+ func (m *QueryRequestRequest) Size() (n int)

+ func (m *QueryRequestRequest) String() string

+ func (m *QueryRequestRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryRequestRequest) XXX_DiscardUnknown()

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

+ func (m *QueryRequestRequest) XXX_Merge(src proto.Message)

+ func (m *QueryRequestRequest) XXX_Size() int

+ func (m *QueryRequestRequest) XXX_Unmarshal(b []byte) error

+ type QueryRequestResponse struct

+ Request *RequestResult

+ func (*QueryRequestResponse) Descriptor() ([]byte, []int)

+ func (*QueryRequestResponse) ProtoMessage()

+ func (m *QueryRequestResponse) GetRequest() *RequestResult

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

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

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

+ func (m *QueryRequestResponse) Reset()

+ func (m *QueryRequestResponse) Size() (n int)

+ func (m *QueryRequestResponse) String() string

+ func (m *QueryRequestResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryRequestResponse) XXX_DiscardUnknown()

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

+ func (m *QueryRequestResponse) XXX_Merge(src proto.Message)

+ func (m *QueryRequestResponse) XXX_Size() int

+ func (m *QueryRequestResponse) XXX_Unmarshal(b []byte) error

+ type QueryRequestSearchRequest struct

+ AskCount int64

+ Calldata []byte

+ MinCount int64

+ OracleScriptId int64

+ func NewQueryRequestSearchRequest(oid int64, callData []byte, askCount, minCount int64) *QueryRequestSearchRequest

+ func (*QueryRequestSearchRequest) Descriptor() ([]byte, []int)

+ func (*QueryRequestSearchRequest) ProtoMessage()

+ func (m *QueryRequestSearchRequest) GetAskCount() int64

+ func (m *QueryRequestSearchRequest) GetCalldata() []byte

+ func (m *QueryRequestSearchRequest) GetMinCount() int64

+ func (m *QueryRequestSearchRequest) GetOracleScriptId() int64

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

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

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

+ func (m *QueryRequestSearchRequest) Reset()

+ func (m *QueryRequestSearchRequest) Size() (n int)

+ func (m *QueryRequestSearchRequest) String() string

+ func (m *QueryRequestSearchRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryRequestSearchRequest) XXX_DiscardUnknown()

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

+ func (m *QueryRequestSearchRequest) XXX_Merge(src proto.Message)

+ func (m *QueryRequestSearchRequest) XXX_Size() int

+ func (m *QueryRequestSearchRequest) XXX_Unmarshal(b []byte) error

+ type QueryRequestSearchResponse struct

+ RequestPacketData *OracleRequestPacketData

+ ResponsePacketData *OracleResponsePacketData

+ func NewQueryRequestSearchResponse(req QueryRequestResponse) *QueryRequestSearchResponse

+ func (*QueryRequestSearchResponse) Descriptor() ([]byte, []int)

+ func (*QueryRequestSearchResponse) ProtoMessage()

+ func (m *QueryRequestSearchResponse) GetRequestPacketData() *OracleRequestPacketData

+ func (m *QueryRequestSearchResponse) GetResponsePacketData() *OracleResponsePacketData

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

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

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

+ func (m *QueryRequestSearchResponse) Reset()

+ func (m *QueryRequestSearchResponse) Size() (n int)

+ func (m *QueryRequestSearchResponse) String() string

+ func (m *QueryRequestSearchResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryRequestSearchResponse) XXX_DiscardUnknown()

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

+ func (m *QueryRequestSearchResponse) XXX_Merge(src proto.Message)

+ func (m *QueryRequestSearchResponse) XXX_Size() int

+ func (m *QueryRequestSearchResponse) XXX_Unmarshal(b []byte) error

+ type QueryRequestVerificationRequest struct

+ ChainId string

+ ExternalId uint64

+ Reporter string

+ RequestId uint64

+ Signature []byte

+ Validator string

+ func (*QueryRequestVerificationRequest) Descriptor() ([]byte, []int)

+ func (*QueryRequestVerificationRequest) ProtoMessage()

+ func (m *QueryRequestVerificationRequest) GetChainId() string

+ func (m *QueryRequestVerificationRequest) GetExternalId() uint64

+ func (m *QueryRequestVerificationRequest) GetReporter() string

+ func (m *QueryRequestVerificationRequest) GetRequestId() uint64

+ func (m *QueryRequestVerificationRequest) GetSignature() []byte

+ func (m *QueryRequestVerificationRequest) GetValidator() string

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

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

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

+ func (m *QueryRequestVerificationRequest) Reset()

+ func (m *QueryRequestVerificationRequest) Size() (n int)

+ func (m *QueryRequestVerificationRequest) String() string

+ func (m *QueryRequestVerificationRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryRequestVerificationRequest) XXX_DiscardUnknown()

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

+ func (m *QueryRequestVerificationRequest) XXX_Merge(src proto.Message)

+ func (m *QueryRequestVerificationRequest) XXX_Size() int

+ func (m *QueryRequestVerificationRequest) XXX_Unmarshal(b []byte) error

+ type QueryRequestVerificationResponse struct

+ ChainId string

+ DataSourceId uint64

+ ExternalId uint64

+ RequestId uint64

+ Validator string

+ func (*QueryRequestVerificationResponse) Descriptor() ([]byte, []int)

+ func (*QueryRequestVerificationResponse) ProtoMessage()

+ func (m *QueryRequestVerificationResponse) GetChainId() string

+ func (m *QueryRequestVerificationResponse) GetDataSourceId() uint64

+ func (m *QueryRequestVerificationResponse) GetExternalId() uint64

+ func (m *QueryRequestVerificationResponse) GetRequestId() uint64

+ func (m *QueryRequestVerificationResponse) GetValidator() string

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

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

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

+ func (m *QueryRequestVerificationResponse) Reset()

+ func (m *QueryRequestVerificationResponse) Size() (n int)

+ func (m *QueryRequestVerificationResponse) String() string

+ func (m *QueryRequestVerificationResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryRequestVerificationResponse) XXX_DiscardUnknown()

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

+ func (m *QueryRequestVerificationResponse) XXX_Merge(src proto.Message)

+ func (m *QueryRequestVerificationResponse) XXX_Size() int

+ func (m *QueryRequestVerificationResponse) XXX_Unmarshal(b []byte) error

+ type QueryRequestsRequest struct

+ Pagination *query.PageRequest

+ func (*QueryRequestsRequest) Descriptor() ([]byte, []int)

+ func (*QueryRequestsRequest) ProtoMessage()

+ func (m *QueryRequestsRequest) GetPagination() *query.PageRequest

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

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

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

+ func (m *QueryRequestsRequest) Reset()

+ func (m *QueryRequestsRequest) Size() (n int)

+ func (m *QueryRequestsRequest) String() string

+ func (m *QueryRequestsRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryRequestsRequest) XXX_DiscardUnknown()

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

+ func (m *QueryRequestsRequest) XXX_Merge(src proto.Message)

+ func (m *QueryRequestsRequest) XXX_Size() int

+ func (m *QueryRequestsRequest) XXX_Unmarshal(b []byte) error

+ type QueryRequestsResponse struct

+ Pagination *query.PageResponse

+ Requests []RequestResult

+ func (*QueryRequestsResponse) Descriptor() ([]byte, []int)

+ func (*QueryRequestsResponse) ProtoMessage()

+ func (m *QueryRequestsResponse) GetPagination() *query.PageResponse

+ func (m *QueryRequestsResponse) GetRequests() []RequestResult

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

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

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

+ func (m *QueryRequestsResponse) Reset()

+ func (m *QueryRequestsResponse) Size() (n int)

+ func (m *QueryRequestsResponse) String() string

+ func (m *QueryRequestsResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryRequestsResponse) XXX_DiscardUnknown()

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

+ func (m *QueryRequestsResponse) XXX_Merge(src proto.Message)

+ func (m *QueryRequestsResponse) XXX_Size() int

+ func (m *QueryRequestsResponse) XXX_Unmarshal(b []byte) error

+ type QueryResult struct

+ Result json.RawMessage

+ Status int

+ type QueryServer interface

+ ActiveValidators func(context.Context, *QueryActiveValidatorsRequest) (*QueryActiveValidatorsResponse, error)

+ Counts func(context.Context, *QueryCountsRequest) (*QueryCountsResponse, error)

+ Data func(context.Context, *QueryDataRequest) (*QueryDataResponse, error)

+ DataProviderReward func(context.Context, *QueryDataProviderRewardRequest) (*QueryDataProviderRewardResponse, error)

+ DataProvidersPool func(context.Context, *QueryDataProvidersPoolRequest) (*QueryDataProvidersPoolResponse, error)

+ DataSource func(context.Context, *QueryDataSourceRequest) (*QueryDataSourceResponse, error)

+ DataSources func(context.Context, *QueryDataSourcesRequest) (*QueryDataSourcesResponse, error)

+ OracleScript func(context.Context, *QueryOracleScriptRequest) (*QueryOracleScriptResponse, error)

+ OracleScripts func(context.Context, *QueryOracleScriptsRequest) (*QueryOracleScriptsResponse, error)

+ Params func(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)

+ PendingRequests func(context.Context, *QueryPendingRequestsRequest) (*QueryPendingRequestsResponse, error)

+ Reporters func(context.Context, *QueryReportersRequest) (*QueryReportersResponse, error)

+ Request func(context.Context, *QueryRequestRequest) (*QueryRequestResponse, error)

+ RequestPrice func(context.Context, *QueryRequestPriceRequest) (*QueryRequestPriceResponse, error)

+ RequestReports func(context.Context, *QueryRequestReportsRequest) (*QueryRequestReportsResponse, error)

+ RequestSearch func(context.Context, *QueryRequestSearchRequest) (*QueryRequestSearchResponse, error)

+ RequestVerification func(context.Context, *QueryRequestVerificationRequest) (*QueryRequestVerificationResponse, error)

+ Requests func(context.Context, *QueryRequestsRequest) (*QueryRequestsResponse, error)

+ Validator func(context.Context, *QueryValidatorRequest) (*QueryValidatorResponse, error)

+ type QueryValidatorRequest struct

+ ValidatorAddress string

+ func (*QueryValidatorRequest) Descriptor() ([]byte, []int)

+ func (*QueryValidatorRequest) ProtoMessage()

+ func (m *QueryValidatorRequest) GetValidatorAddress() string

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

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

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

+ func (m *QueryValidatorRequest) Reset()

+ func (m *QueryValidatorRequest) Size() (n int)

+ func (m *QueryValidatorRequest) String() string

+ func (m *QueryValidatorRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryValidatorRequest) XXX_DiscardUnknown()

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

+ func (m *QueryValidatorRequest) XXX_Merge(src proto.Message)

+ func (m *QueryValidatorRequest) XXX_Size() int

+ func (m *QueryValidatorRequest) XXX_Unmarshal(b []byte) error

+ type QueryValidatorResponse struct

+ Status *ValidatorStatus

+ func (*QueryValidatorResponse) Descriptor() ([]byte, []int)

+ func (*QueryValidatorResponse) ProtoMessage()

+ func (m *QueryValidatorResponse) GetStatus() *ValidatorStatus

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

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

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

+ func (m *QueryValidatorResponse) Reset()

+ func (m *QueryValidatorResponse) Size() (n int)

+ func (m *QueryValidatorResponse) String() string

+ func (m *QueryValidatorResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryValidatorResponse) XXX_DiscardUnknown()

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

+ func (m *QueryValidatorResponse) XXX_Merge(src proto.Message)

+ func (m *QueryValidatorResponse) XXX_Size() int

+ func (m *QueryValidatorResponse) XXX_Unmarshal(b []byte) error

+ type RawReport struct

+ Data []byte

+ ExitCode uint32

+ ExternalID ExternalID

+ func NewRawReport(ExternalID ExternalID, ExitCode uint32, Data []byte) RawReport

+ func (*RawReport) Descriptor() ([]byte, []int)

+ func (*RawReport) ProtoMessage()

+ func (m *RawReport) GetData() []byte

+ func (m *RawReport) GetExitCode() uint32

+ func (m *RawReport) GetExternalID() ExternalID

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

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

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

+ func (m *RawReport) Reset()

+ func (m *RawReport) Size() (n int)

+ func (m *RawReport) String() string

+ func (m *RawReport) Unmarshal(dAtA []byte) error

+ func (m *RawReport) XXX_DiscardUnknown()

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

+ func (m *RawReport) XXX_Merge(src proto.Message)

+ func (m *RawReport) XXX_Size() int

+ func (m *RawReport) XXX_Unmarshal(b []byte) error

+ func (this *RawReport) Equal(that interface{}) bool

+ type RawRequest struct

+ Calldata []byte

+ DataSourceID DataSourceID

+ ExternalID ExternalID

+ func NewRawRequest(ExternalID ExternalID, DataSourceID DataSourceID, Calldata []byte) RawRequest

+ func (*RawRequest) Descriptor() ([]byte, []int)

+ func (*RawRequest) ProtoMessage()

+ func (m *RawRequest) GetCalldata() []byte

+ func (m *RawRequest) GetDataSourceID() DataSourceID

+ func (m *RawRequest) GetExternalID() ExternalID

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

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

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

+ func (m *RawRequest) Reset()

+ func (m *RawRequest) Size() (n int)

+ func (m *RawRequest) String() string

+ func (m *RawRequest) Unmarshal(dAtA []byte) error

+ func (m *RawRequest) XXX_DiscardUnknown()

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

+ func (m *RawRequest) XXX_Merge(src proto.Message)

+ func (m *RawRequest) XXX_Size() int

+ func (m *RawRequest) XXX_Unmarshal(b []byte) error

+ func (this *RawRequest) Equal(that interface{}) bool

+ type Report struct

+ InBeforeResolve bool

+ RawReports []RawReport

+ Validator string

+ func NewReport(Validator sdk.ValAddress, InBeforeResolve bool, RawReports []RawReport) Report

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

+ func (*Report) ProtoMessage()

+ func (m *Report) GetInBeforeResolve() bool

+ func (m *Report) GetRawReports() []RawReport

+ func (m *Report) GetValidator() string

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

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

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

+ func (m *Report) Reset()

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

+ func (m *Report) String() string

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

+ func (m *Report) XXX_DiscardUnknown()

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

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

+ func (m *Report) XXX_Size() int

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

+ func (this *Report) Equal(that interface{}) bool

+ type Request struct

+ Calldata []byte

+ ClientID string

+ ExecuteGas uint64

+ IBCSource *IBCSource

+ ID RequestID

+ MinCount uint64

+ OracleScriptID OracleScriptID

+ RawRequests []RawRequest

+ RequestHeight int64

+ RequestTime uint64

+ RequestedValidators []string

+ func NewRequest(oracleScriptID OracleScriptID, calldata []byte, ...) Request

+ func (*Request) Descriptor() ([]byte, []int)

+ func (*Request) ProtoMessage()

+ func (m *Request) GetCalldata() []byte

+ func (m *Request) GetClientID() string

+ func (m *Request) GetExecuteGas() uint64

+ func (m *Request) GetIBCSource() *IBCSource

+ func (m *Request) GetID() RequestID

+ func (m *Request) GetMinCount() uint64

+ func (m *Request) GetOracleScriptID() OracleScriptID

+ func (m *Request) GetRawRequests() []RawRequest

+ func (m *Request) GetRequestHeight() int64

+ func (m *Request) GetRequestTime() uint64

+ func (m *Request) GetRequestedValidators() []string

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

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

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

+ func (m *Request) Reset()

+ func (m *Request) Size() (n int)

+ func (m *Request) String() string

+ func (m *Request) Unmarshal(dAtA []byte) error

+ func (m *Request) XXX_DiscardUnknown()

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

+ func (m *Request) XXX_Merge(src proto.Message)

+ func (m *Request) XXX_Size() int

+ func (m *Request) XXX_Unmarshal(b []byte) error

+ func (this *Request) Equal(that interface{}) bool

+ type RequestID int64

+ type RequestResult struct

+ RequestPacketData *OracleRequestPacketData

+ ResponsePacketData *OracleResponsePacketData

+ func (*RequestResult) Descriptor() ([]byte, []int)

+ func (*RequestResult) ProtoMessage()

+ func (m *RequestResult) GetRequestPacketData() *OracleRequestPacketData

+ func (m *RequestResult) GetResponsePacketData() *OracleResponsePacketData

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

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

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

+ func (m *RequestResult) Reset()

+ func (m *RequestResult) Size() (n int)

+ func (m *RequestResult) String() string

+ func (m *RequestResult) Unmarshal(dAtA []byte) error

+ func (m *RequestResult) XXX_DiscardUnknown()

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

+ func (m *RequestResult) XXX_Merge(src proto.Message)

+ func (m *RequestResult) XXX_Size() int

+ func (m *RequestResult) XXX_Unmarshal(b []byte) error

+ func (this *RequestResult) Equal(that interface{}) bool

+ type RequestSpec interface

+ GetAskCount func() uint64

+ GetCalldata func() []byte

+ GetClientID func() string

+ GetExecuteGas func() uint64

+ GetFeeLimit func() sdk.Coins

+ GetMinCount func() uint64

+ GetOracleScriptID func() OracleScriptID

+ GetPrepareGas func() uint64

+ type RequestVerification struct

+ ChainID string

+ ExternalID ExternalID

+ RequestID RequestID

+ Validator string

+ func NewRequestVerification(chainID string, validator sdk.ValAddress, requestID RequestID, ...) RequestVerification

+ func (*RequestVerification) Descriptor() ([]byte, []int)

+ func (*RequestVerification) ProtoMessage()

+ func (m *RequestVerification) GetChainID() string

+ func (m *RequestVerification) GetExternalID() ExternalID

+ func (m *RequestVerification) GetRequestID() RequestID

+ func (m *RequestVerification) GetValidator() string

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

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

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

+ func (m *RequestVerification) Reset()

+ func (m *RequestVerification) Size() (n int)

+ func (m *RequestVerification) String() string

+ func (m *RequestVerification) Unmarshal(dAtA []byte) error

+ func (m *RequestVerification) XXX_DiscardUnknown()

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

+ func (m *RequestVerification) XXX_Merge(src proto.Message)

+ func (m *RequestVerification) XXX_Size() int

+ func (m *RequestVerification) XXX_Unmarshal(b []byte) error

+ func (msg RequestVerification) GetSignBytes() []byte

+ func (this *RequestVerification) Equal(that interface{}) bool

+ type ResolveStatus int32

+ const RESOLVE_STATUS_EXPIRED

+ const RESOLVE_STATUS_FAILURE

+ const RESOLVE_STATUS_OPEN

+ const RESOLVE_STATUS_SUCCESS

+ func (ResolveStatus) EnumDescriptor() ([]byte, []int)

+ func (x ResolveStatus) String() string

+ type Result struct

+ AnsCount uint64

+ AskCount uint64

+ Calldata []byte

+ ClientID string

+ MinCount uint64

+ OracleScriptID OracleScriptID

+ RequestID RequestID

+ RequestTime int64

+ ResolveStatus ResolveStatus

+ ResolveTime int64

+ Result []byte

+ func NewResult(clientId string, oid OracleScriptID, calldata []byte, ...) Result

+ func (*Result) Descriptor() ([]byte, []int)

+ func (*Result) ProtoMessage()

+ func (m *Result) GetAnsCount() uint64

+ func (m *Result) GetAskCount() uint64

+ func (m *Result) GetCalldata() []byte

+ func (m *Result) GetClientID() string

+ func (m *Result) GetMinCount() uint64

+ func (m *Result) GetOracleScriptID() OracleScriptID

+ func (m *Result) GetRequestID() RequestID

+ func (m *Result) GetRequestTime() int64

+ func (m *Result) GetResolveStatus() ResolveStatus

+ func (m *Result) GetResolveTime() int64

+ func (m *Result) GetResult() []byte

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

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

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

+ func (m *Result) Reset()

+ func (m *Result) Size() (n int)

+ func (m *Result) String() string

+ func (m *Result) Unmarshal(dAtA []byte) error

+ func (m *Result) XXX_DiscardUnknown()

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

+ func (m *Result) XXX_Merge(src proto.Message)

+ func (m *Result) XXX_Size() int

+ func (m *Result) XXX_Unmarshal(b []byte) error

+ func (this *Result) Equal(that interface{}) bool

+ type RewardThreshold struct

+ Amount github_com_cosmos_cosmos_sdk_types.Coins

+ Blocks uint64

+ func DefaultRewardThreshold() RewardThreshold

+ func NewRewardThreshold(amount sdk.Coins, blocks uint64) RewardThreshold

+ func (*RewardThreshold) Descriptor() ([]byte, []int)

+ func (*RewardThreshold) ProtoMessage()

+ func (m *RewardThreshold) GetAmount() github_com_cosmos_cosmos_sdk_types.Coins

+ func (m *RewardThreshold) GetBlocks() uint64

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

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

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

+ func (m *RewardThreshold) Reset()

+ func (m *RewardThreshold) Size() (n int)

+ func (m *RewardThreshold) String() string

+ func (m *RewardThreshold) Unmarshal(dAtA []byte) error

+ func (m *RewardThreshold) XXX_DiscardUnknown()

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

+ func (m *RewardThreshold) XXX_Merge(src proto.Message)

+ func (m *RewardThreshold) XXX_Size() int

+ func (m *RewardThreshold) XXX_Unmarshal(b []byte) error

+ func (this *RewardThreshold) Equal(that interface{}) bool

+ type StakingKeeper interface

+ IterateBondedValidatorsByPower func(ctx sdk.Context, ...)

+ Validator func(ctx sdk.Context, address sdk.ValAddress) stakingtypes.ValidatorI

+ ValidatorByConsAddr func(sdk.Context, sdk.ConsAddress) stakingtypes.ValidatorI

+ type UnimplementedMsgServer struct

+ func (*UnimplementedMsgServer) Activate(ctx context.Context, req *MsgActivate) (*MsgActivateResponse, error)

+ func (*UnimplementedMsgServer) AddReporter(ctx context.Context, req *MsgAddReporter) (*MsgAddReporterResponse, error)

+ func (*UnimplementedMsgServer) CreateDataSource(ctx context.Context, req *MsgCreateDataSource) (*MsgCreateDataSourceResponse, error)

+ func (*UnimplementedMsgServer) CreateOracleScript(ctx context.Context, req *MsgCreateOracleScript) (*MsgCreateOracleScriptResponse, error)

+ func (*UnimplementedMsgServer) EditDataSource(ctx context.Context, req *MsgEditDataSource) (*MsgEditDataSourceResponse, error)

+ func (*UnimplementedMsgServer) EditOracleScript(ctx context.Context, req *MsgEditOracleScript) (*MsgEditOracleScriptResponse, error)

+ func (*UnimplementedMsgServer) RemoveReporter(ctx context.Context, req *MsgRemoveReporter) (*MsgRemoveReporterResponse, error)

+ func (*UnimplementedMsgServer) ReportData(ctx context.Context, req *MsgReportData) (*MsgReportDataResponse, error)

+ func (*UnimplementedMsgServer) RequestData(ctx context.Context, req *MsgRequestData) (*MsgRequestDataResponse, error)

+ type UnimplementedQueryServer struct

+ func (*UnimplementedQueryServer) ActiveValidators(ctx context.Context, req *QueryActiveValidatorsRequest) (*QueryActiveValidatorsResponse, error)

+ func (*UnimplementedQueryServer) Counts(ctx context.Context, req *QueryCountsRequest) (*QueryCountsResponse, error)

+ func (*UnimplementedQueryServer) Data(ctx context.Context, req *QueryDataRequest) (*QueryDataResponse, error)

+ func (*UnimplementedQueryServer) DataProviderReward(ctx context.Context, req *QueryDataProviderRewardRequest) (*QueryDataProviderRewardResponse, error)

+ func (*UnimplementedQueryServer) DataProvidersPool(ctx context.Context, req *QueryDataProvidersPoolRequest) (*QueryDataProvidersPoolResponse, error)

+ func (*UnimplementedQueryServer) DataSource(ctx context.Context, req *QueryDataSourceRequest) (*QueryDataSourceResponse, error)

+ func (*UnimplementedQueryServer) DataSources(ctx context.Context, req *QueryDataSourcesRequest) (*QueryDataSourcesResponse, error)

+ func (*UnimplementedQueryServer) OracleScript(ctx context.Context, req *QueryOracleScriptRequest) (*QueryOracleScriptResponse, error)

+ func (*UnimplementedQueryServer) OracleScripts(ctx context.Context, req *QueryOracleScriptsRequest) (*QueryOracleScriptsResponse, error)

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

+ func (*UnimplementedQueryServer) PendingRequests(ctx context.Context, req *QueryPendingRequestsRequest) (*QueryPendingRequestsResponse, error)

+ func (*UnimplementedQueryServer) Reporters(ctx context.Context, req *QueryReportersRequest) (*QueryReportersResponse, error)

+ func (*UnimplementedQueryServer) Request(ctx context.Context, req *QueryRequestRequest) (*QueryRequestResponse, error)

+ func (*UnimplementedQueryServer) RequestPrice(ctx context.Context, req *QueryRequestPriceRequest) (*QueryRequestPriceResponse, error)

+ func (*UnimplementedQueryServer) RequestReports(ctx context.Context, req *QueryRequestReportsRequest) (*QueryRequestReportsResponse, error)

+ func (*UnimplementedQueryServer) RequestSearch(ctx context.Context, req *QueryRequestSearchRequest) (*QueryRequestSearchResponse, error)

+ func (*UnimplementedQueryServer) RequestVerification(ctx context.Context, req *QueryRequestVerificationRequest) (*QueryRequestVerificationResponse, error)

+ func (*UnimplementedQueryServer) Requests(ctx context.Context, req *QueryRequestsRequest) (*QueryRequestsResponse, error)

+ func (*UnimplementedQueryServer) Validator(ctx context.Context, req *QueryValidatorRequest) (*QueryValidatorResponse, error)

+ type ValidatorStatus struct

+ IsActive bool

+ Since time.Time

+ func NewValidatorStatus(IsActive bool, Since time.Time) ValidatorStatus

+ func (*ValidatorStatus) Descriptor() ([]byte, []int)

+ func (*ValidatorStatus) ProtoMessage()

+ func (m *ValidatorStatus) GetIsActive() bool

+ func (m *ValidatorStatus) GetSince() time.Time

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

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

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

+ func (m *ValidatorStatus) Reset()

+ func (m *ValidatorStatus) Size() (n int)

+ func (m *ValidatorStatus) String() string

+ func (m *ValidatorStatus) Unmarshal(dAtA []byte) error

+ func (m *ValidatorStatus) XXX_DiscardUnknown()

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

+ func (m *ValidatorStatus) XXX_Merge(src proto.Message)

+ func (m *ValidatorStatus) XXX_Size() int

+ func (m *ValidatorStatus) XXX_Unmarshal(b []byte) error

+ func (this *ValidatorStatus) Equal(that interface{}) bool

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