types

package
v0.7.32 Latest Latest
Warning

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

 Go to latest Published: Jan 10, 2024 License: GPL-3.0 Imports: 41 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	DoNotModify = "[do-not-modify]"

	MaxNameLength        = 128
	MaxDescriptionLength = 4096
	MaxClientIDLength    = 128
	MaxSchemaLength      = 512
	MaxURLLength         = 128

	MaxExecutableSize       = 8 * 1024        // 8kB
	MaxWasmCodeSize         = 512 * 1024      // 512kB
	MaxCompiledWasmCodeSize = 1 * 1024 * 1024 // 1MB

	WasmPrepareGas = 1000000
	WasmExecuteGas = 5000000
)

nolint

View Source 
const (
	EventTypeCreateDataSource   = "create_data_source"
	EventTypeEditDataSource     = "edit_data_source"
	EventTypeCreateOracleScript = "create_oracle_script"
	EventTypeEditOracleScript   = "edit_oracle_script"
	EventTypeRequest            = "request"
	EventTypeRawRequest         = "raw_request"
	EventTypeReport             = "report"
	EventTypeActivate           = "activate"
	EventTypeDeactivate         = "deactivate"
	EventTypeAddReporter        = "add_reporter"
	EventTypeRemoveReporter     = "remove_reporter"
	EventTypeResolve            = "resolve"

	AttributeKeyID             = "id"
	AttributeKeyDataSourceID   = "data_source_id"
	AttributeKeyOracleScriptID = "oracle_script_id"
	AttributeKeyExternalID     = "external_id"
	AttributeKeyDataSourceHash = "data_source_hash"
	AttributeKeyCalldata       = "calldata"
	AttributeKeyValidator      = "validator"
	AttributeKeyReporter       = "reporter"
	AttributeKeyClientID       = "client_id"
	AttributeKeyAskCount       = "ask_count"
	AttributeKeyMinCount       = "min_count"
	AttributeKeyResolveStatus  = "resolve_status"
	AttributeKeyGasUsed        = "gas_used"
	AttributeKeyResult         = "result"
	AttributeKeyReason         = "reason"
)

nolint

View Source 
const (
	// ModuleName is the name of the module.
	ModuleName = "oracle"
	// ModuleVersion defines the current module version
	ModuleVersion = 1

	// Version defines the current version the IBC oracle module supports
	// TODO: Using our new version for oracle packet (new ics?)
	Version = "oracle-1"

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

	// QuerierRoute is the querier route for the oracle module
	QuerierRoute = ModuleName

	// RouterKey is the msg router key for the oracle module
	RouterKey = ModuleName

	// PortID is the default port id that oracle module binds to.
	PortID = ModuleName
)
View Source 
const (
	TypeMsgRequestData        = "request"
	TypeMsgReportData         = "report"
	TypeMsgCreateDataSource   = "create_data_source"
	TypeMsgEditDataSource     = "edit_data_source"
	TypeMsgCreateOracleScript = "create_oracle_script"
	TypeMsgEditOracleScript   = "edit_oracle_script"
	TypeMsgActivate           = "activate"
	TypeMsgAddReporter        = "add_reporter"
	TypeMsgRemoveReporter     = "remove_reporter"
)

oracle message types

View Source 
const (
	// Each value below is the default value for each parameter when generating the default
	// genesis file. See comments in types.proto for explanation for each parameter.
	DefaultMaxRawRequestCount      = uint64(12)
	DefaultMaxAskCount             = uint64(16)
	DefaultExpirationBlockCount    = uint64(100)
	DefaultBaseRequestGas          = uint64(150000)
	DefaultPerValidatorRequestGas  = uint64(30000)
	DefaultSamplingTryCount        = uint64(3)
	DefaultOracleRewardPercentage  = uint64(70)
	DefaultInactivePenaltyDuration = uint64(10 * time.Minute)
	DefaultMaxDataSize             = uint64(1 * 1024) // 1 KB
	DefaultMaxCalldataSize         = uint64(1 * 1024) // 1 KB
	DefaultPrepareGas              = uint64(40000)
	DefaultExecuteGas              = uint64(300000)
	DefaultRewardThresholdBlocks   = uint64(28820)
	DefaultMaxReportDataSize       = uint64(512) // 512B
	DefaultDataProviderRewardDenom = "minigeo"
	DefaultDataRequesterFeeDenom   = "loki"
)

nolint

View Source 
const (
	QueryParams             = "params"
	QueryCounts             = "counts"
	QueryData               = "data"
	QueryDataSources        = "data_sources"
	QueryOracleScripts      = "oracle_scripts"
	QueryRequests           = "requests"
	QueryRequestReports     = "request_reports"
	QueryRequestPrices      = "request_prices"
	QueryPriceSymbols       = "price_symbols"
	QueryLatestRequest      = "latest_request"
	QueryMultiRequestSearch = "multi_request_search"
	QueryRequestSearch      = "request_search"
	QueryValidatorStatus    = "validator_status"
	QueryReporters          = "reporters"
	QueryActiveValidators   = "active_validators"
	QueryPendingRequests    = "pending_requests"
	QueryDataProvidersPool  = "data_providers_pool"
	QueryDataProviderReward = "data_provider_reward"
	QueryProof              = "proof"
	QueryMultiProof         = "multi_proof"
	QueryRequestsCountProof = "requests_count_proof"
)

Query endpoints supported by the oracle Querier.

Variables

View Source 
var (
	ErrOwasmCompilation         = sdkerrors.Register(ModuleName, 1, "owasm compilation failed")
	ErrBadWasmExecution         = sdkerrors.Register(ModuleName, 2, "bad wasm execution")
	ErrDataSourceNotFound       = sdkerrors.Register(ModuleName, 3, "data source not found")
	ErrOracleScriptNotFound     = sdkerrors.Register(ModuleName, 4, "oracle script not found")
	ErrRequestNotFound          = sdkerrors.Register(ModuleName, 5, "request not found")
	ErrRawRequestNotFound       = sdkerrors.Register(ModuleName, 6, "raw request not found")
	ErrReporterNotFound         = sdkerrors.Register(ModuleName, 7, "reporter not found")
	ErrResultNotFound           = sdkerrors.Register(ModuleName, 8, "result not found")
	ErrReporterAlreadyExists    = sdkerrors.Register(ModuleName, 9, "reporter already exists")
	ErrValidatorNotRequested    = sdkerrors.Register(ModuleName, 10, "validator not requested")
	ErrValidatorAlreadyReported = sdkerrors.Register(ModuleName, 11, "validator already reported")
	ErrInvalidReportSize        = sdkerrors.Register(ModuleName, 12, "invalid report size")
	ErrReporterNotAuthorized    = sdkerrors.Register(ModuleName, 13, "reporter not authorized")
	ErrEditorNotAuthorized      = sdkerrors.Register(ModuleName, 14, "editor not authorized")
	ErrValidatorAlreadyActive   = sdkerrors.Register(ModuleName, 16, "validator already active")
	ErrTooSoonToActivate        = sdkerrors.Register(ModuleName, 17, "too soon to activate")
	ErrTooLongName              = sdkerrors.Register(ModuleName, 18, "too long name")
	ErrTooLongDescription       = sdkerrors.Register(ModuleName, 19, "too long description")
	ErrEmptyExecutable          = sdkerrors.Register(ModuleName, 20, "empty executable")
	ErrEmptyWasmCode            = sdkerrors.Register(ModuleName, 21, "empty wasm code")
	ErrTooLargeExecutable       = sdkerrors.Register(ModuleName, 22, "too large executable")
	ErrTooLargeWasmCode         = sdkerrors.Register(ModuleName, 23, "too large wasm code")
	ErrInvalidMinCount          = sdkerrors.Register(ModuleName, 24, "invalid min count")
	ErrInvalidAskCount          = sdkerrors.Register(ModuleName, 25, "invalid ask count")
	ErrTooLargeCalldata         = sdkerrors.Register(ModuleName, 26, "too large calldata")
	ErrTooLongClientID          = sdkerrors.Register(ModuleName, 27, "too long client id")
	ErrEmptyRawRequests         = sdkerrors.Register(ModuleName, 28, "empty raw requests")
	ErrEmptyReport              = sdkerrors.Register(ModuleName, 29, "empty report")
	ErrDuplicateExternalID      = sdkerrors.Register(ModuleName, 30, "duplicate external id")
	ErrTooLongSchema            = sdkerrors.Register(ModuleName, 31, "too long schema")
	ErrTooLongURL               = sdkerrors.Register(ModuleName, 32, "too long url")
	ErrTooLargeRawReportData    = sdkerrors.Register(ModuleName, 33, "too large raw report data")
	ErrInsufficientValidators   = sdkerrors.Register(ModuleName, 34, "insufficient available validators")
	ErrCreateWithDoNotModify    = sdkerrors.Register(ModuleName, 35, "cannot create with [do-not-modify] content")
	ErrSelfReferenceAsReporter  = sdkerrors.Register(ModuleName, 36, "cannot reference self as reporter")
	ErrOBIDecode                = sdkerrors.Register(ModuleName, 37, "obi decode failed")
	ErrUncompressionFailed      = sdkerrors.Register(ModuleName, 38, "uncompression failed")
	ErrRequestAlreadyExpired    = sdkerrors.Register(ModuleName, 39, "request already expired")
	ErrBadDrbgInitialization    = sdkerrors.Register(ModuleName, 40, "bad drbg initialization")
	ErrMaxOracleChannels        = sdkerrors.Register(ModuleName, 41, "max oracle channels")
	ErrInvalidVersion           = sdkerrors.Register(ModuleName, 42, "invalid ICS20 version")
	ErrNotEnoughFee             = sdkerrors.Register(ModuleName, 43, "not enough fee")
	ErrInvalidOwasmGas          = sdkerrors.Register(ModuleName, 44, "invalid owasm gas")
	ErrIBCRequestDisabled       = sdkerrors.Register(ModuleName, 45, "sending oracle request via IBC is disabled")
	ErrInvalidFeeDenom          = sdkerrors.Register(ModuleName, 46, "given fee denom is invalid")
)
View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// RollingSeedSizeInBytes is the size of rolling block hash for random seed.
	RollingSeedSizeInBytes = 32
	// GlobalStoreKeyPrefix is the prefix for global primitive state variables.
	GlobalStoreKeyPrefix = []byte{0x00}
	// RollingSeedStoreKey is the key that keeps the seed based on the first 8-bit of the most recent 32 block hashes.
	RollingSeedStoreKey = append(GlobalStoreKeyPrefix, []byte("RollingSeed")...)
	// RequestCountStoreKey is the key that keeps the total request count.
	RequestCountStoreKey = append(GlobalStoreKeyPrefix, []byte("RequestCount")...)
	// RequestLastExpiredStoreKey is the key that keeps the ID of the last expired request, or 0 if none.
	RequestLastExpiredStoreKey = append(GlobalStoreKeyPrefix, []byte("RequestLastExpired")...)
	// PendingResolveListStoreKey is the key that keeps the list of pending-resolve requests.
	PendingResolveListStoreKey = append(GlobalStoreKeyPrefix, []byte("PendingList")...)
	// DataSourceCountStoreKey is the key that keeps the total data source count.
	DataSourceCountStoreKey = append(GlobalStoreKeyPrefix, []byte("DataSourceCount")...)
	// OracleScriptCountStoreKey is the key that keeps the total oracle sciprt count.
	OracleScriptCountStoreKey = append(GlobalStoreKeyPrefix, []byte("OracleScriptCount")...)
	// AccumulatedDataProvidersRewardsStoreKey the key that keeps the total allocated rewards to data providers for one day
	AccumulatedDataProvidersRewardsStoreKey = append(GlobalStoreKeyPrefix, []byte("AllocateRewardsToDataProviders")...)
	// AccumulatedPaymentsForDataStoreKey the key that keeps the accumulated payments for data
	AccumulatedPaymentsForDataStoreKey = append(GlobalStoreKeyPrefix, []byte("AccumulatedPaymentsForData")...)
	// OraclePoolStoreKey is the key that keeps the oracle pool
	OraclePoolStoreKey = append(GlobalStoreKeyPrefix, []byte("OraclePool")...) // key for global oracle pool state

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

	// RequestStoreKeyPrefix is the prefix for request store.
	RequestStoreKeyPrefix = []byte{0x01}
	// ReportStoreKeyPrefix is the prefix for report store.
	ReportStoreKeyPrefix = []byte{0x02}
	// DataSourceStoreKeyPrefix is the prefix for data source store.
	DataSourceStoreKeyPrefix = []byte{0x03}
	// OracleScriptStoreKeyPrefix is the prefix for oracle script store.
	OracleScriptStoreKeyPrefix = []byte{0x04}
	// ReporterStoreKeyPrefix is the prefix for reporter store.
	ReporterStoreKeyPrefix = []byte{0x05}
	// ValidatorStatusKeyPrefix is the prefix for validator status store.
	ValidatorStatusKeyPrefix     = []byte{0x06}
	DataProviderRewardsKeyPrefix = []byte{0x07}
	// DataRequesterFeesKeyPrefix is the prefix for the data requester address with accumulated fee
	DataRequesterFeesKeyPrefix = []byte{0x08}
	// ResultStoreKeyPrefix is the prefix for request result store.
	ResultStoreKeyPrefix = []byte{0xff}

	// PortKey defines the key to store the port ID in store
	PortKey = []byte{0xf0}
)
View Source 
var (
	ErrInvalidLengthOracle        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowOracle          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupOracle = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	DefaultDataProviderRewardPerByte = sdk.NewCoins(sdk.NewInt64Coin(DefaultDataProviderRewardDenom, 1000000), sdk.NewInt64Coin("loki", 1000000)) // 1 * 10^6
	DefaultDataRequesterFeeDenoms    = []string{DefaultDataRequesterFeeDenom, "minigeo"}
	DefaultFeeLimit                  = sdk.NewCoins()
	DefaultRewardThresholdAmount     = sdk.NewCoins(sdk.NewInt64Coin(DefaultDataProviderRewardDenom, 200000000000), sdk.NewInt64Coin("loki", 200000000000)) // 200000 * 10^6
	DefaultRewardDecreasingFraction  = sdk.NewDec(1).Quo(sdk.NewDec(20))
)
View Source 
var (
	// Each value below is the key to store the respective oracle module parameter. See comments
	// in types.proto for explanation for each parameter.
	KeyMaxRawRequestCount          = []byte("MaxRawRequestCount")
	KeyMaxAskCount                 = []byte("MaxAskCount")
	KeyExpirationBlockCount        = []byte("ExpirationBlockCount")
	KeyBaseOwasmGas                = []byte("BaseOwasmGas")
	KeyPerValidatorRequestGas      = []byte("PerValidatorRequestGas")
	KeySamplingTryCount            = []byte("SamplingTryCount")
	KeyOracleRewardPercentage      = []byte("OracleRewardPercentage")
	KeyInactivePenaltyDuration     = []byte("InactivePenaltyDuration")
	KeyMaxDataSize                 = []byte("MaxDataSize")
	KeyMaxCalldataSize             = []byte("MaxCalldataSize")
	KeyDataProviderRewardPerByte   = []byte("DataProviderRewardPerByte")
	KeyRewardDecreasingFraction    = []byte("RewardDecreasingFraction")
	KeyDataProviderRewardThreshold = []byte("DataProviderRewardThreshold")
	KeyDataRequesterFeeDenoms      = []byte("DataRequesterFeeDenoms")
	KeyMaxReportDataSize           = []byte("MaxReportDataSize")
)

nolint

View Source 
var (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	DoNotModifyBytes = []byte(DoNotModify)
)

nolint

View Source 
var (

	// ModuleCdc references the global x/ibc-transfer module codec. Note, the codec
	// should ONLY be used in certain instances of tests and for JSON encoding.
	//
	// The actual codec used for serialization should be provided to x/ibc-transfer and
	// defined at the application level.
	ModuleCdc = codec.NewProtoCodec(codectypes.NewInterfaceRegistry())
)
View Source 
var ResolveStatus_name = map[int32]string{
	0: "RESOLVE_STATUS_OPEN_UNSPECIFIED",
	1: "RESOLVE_STATUS_SUCCESS",
	2: "RESOLVE_STATUS_FAILURE",
	3: "RESOLVE_STATUS_EXPIRED",
}
View Source 
var ResolveStatus_value = map[string]int32{
	"RESOLVE_STATUS_OPEN_UNSPECIFIED": 0,
	"RESOLVE_STATUS_SUCCESS":          1,
	"RESOLVE_STATUS_FAILURE":          2,
	"RESOLVE_STATUS_EXPIRED":          3,
}

Functions

func DataProviderRewardsPrefixKey 

func DataProviderRewardsPrefixKey(acc sdk.AccAddress) []byte

func DataSourceStoreKey 

func DataSourceStoreKey(dataSourceID DataSourceID) []byte

DataSourceStoreKey returns the key to retrieve a specific data source from the store.

func OracleScriptStoreKey 

func OracleScriptStoreKey(oracleScriptID OracleScriptID) []byte

OracleScriptStoreKey returns the key to retrieve a specific oracle script from the store.

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable for oracle module

func RegisterInterfaces 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

RegisterInterfaces register the oracle module interfaces to protobuf Any.

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

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

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

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

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

func RegisterQueryHandlerClient 

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

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

func RegisterQueryHandlerFromEndpoint 

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

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

func RegisterQueryHandlerServer 

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

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

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func ReportStoreKey 

func ReportStoreKey(requestID RequestID) []byte

ReportStoreKey returns the key to retrieve all data reports for a request.

func ReporterStoreKey 

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

ReporterStoreKey returns the key to check whether an address is a reporter of a validator.

func ReportersOfValidatorPrefixKey 

func ReportersOfValidatorPrefixKey(val sdk.ValAddress) []byte

ReportersOfValidatorPrefixKey returns the prefix key to get all reporters of a validator.

func ReportsOfValidatorPrefixKey 

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

ReportsOfValidatorPrefixKey returns the prefix key to get all reports for a request from a validator.

func RequestStoreKey 

func RequestStoreKey(requestID RequestID) []byte

RequestStoreKey returns the key to retrieve a specific request from the store.

func ResultStoreKey 

func ResultStoreKey(requestID RequestID) []byte

ResultStoreKey returns the key to a request result in the store.

func ValidatorStatusStoreKey 

func ValidatorStatusStoreKey(v sdk.ValAddress) []byte

ValidatorStatusStoreKey returns the key to a validator's status.

func WrapMaxError 

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

WrapMaxError wraps an error message with additional info of the current and max values.

Types

type AccountKeeper 

type AccountKeeper interface {
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
	GetModuleAccount(ctx sdk.Context, name string) authtypes.ModuleAccountI

	GetModuleAddress(name string) sdk.AccAddress
	SetModuleAccount(sdk.Context, authtypes.ModuleAccountI)
}

AccountKeeper defines the expected account keeper.

type AccumulatedPaymentsForData 

type AccumulatedPaymentsForData struct {
	AccumulatedAmount github_com_cosmos_cosmos_sdk_types.Coins `` /* 156-byte string literal not displayed */
}

func (*AccumulatedPaymentsForData) Descriptor 

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

func (*AccumulatedPaymentsForData) GetAccumulatedAmount 

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

func (*AccumulatedPaymentsForData) Marshal 

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

func (*AccumulatedPaymentsForData) MarshalTo 

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

func (*AccumulatedPaymentsForData) MarshalToSizedBuffer 

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

func (*AccumulatedPaymentsForData) ProtoMessage 

func (*AccumulatedPaymentsForData) ProtoMessage()

func (*AccumulatedPaymentsForData) Reset 

func (m *AccumulatedPaymentsForData) Reset()

func (*AccumulatedPaymentsForData) Size 

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

func (*AccumulatedPaymentsForData) String 

func (m *AccumulatedPaymentsForData) String() string

func (*AccumulatedPaymentsForData) Unmarshal 

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

func (*AccumulatedPaymentsForData) XXX_DiscardUnknown 

func (m *AccumulatedPaymentsForData) XXX_DiscardUnknown()

func (*AccumulatedPaymentsForData) XXX_Marshal 

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

func (*AccumulatedPaymentsForData) XXX_Merge 

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

func (*AccumulatedPaymentsForData) XXX_Size 

func (m *AccumulatedPaymentsForData) XXX_Size() int

func (*AccumulatedPaymentsForData) XXX_Unmarshal 

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

type BankKeeper 

type BankKeeper interface {
	GetAllBalances(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	SendCoinsFromModuleToModule(ctx sdk.Context, senderModule, recipientModule string, amt sdk.Coins) error
	SendCoins(ctx sdk.Context, fromAddr sdk.AccAddress, toAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
}

BankKeeper defines the expected bank keeper.

type BaseEnv 

type BaseEnv struct {
	// contains filtered or unexported fields
}

BaseEnv combines shared functions used in prepare and execution Owasm program,

func (*BaseEnv) AskExternalData 

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

AskExternalData implements Owasm ExecEnv interface.

func (*BaseEnv) GetAnsCount 

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

GetAnsCount implements Owasm ExecEnv interface.

func (*BaseEnv) GetAskCount 

func (env *BaseEnv) GetAskCount() int64

GetAskCount implements Owasm ExecEnv interface.

func (*BaseEnv) GetCalldata 

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

GetCalldata implements Owasm ExecEnv interface.

func (*BaseEnv) GetExecuteTime added in v0.5.2 

func (env *BaseEnv) GetExecuteTime() (int64, error)

GetExecuteTime implements Owasm ExecEnv interface.

func (*BaseEnv) GetExternalData 

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

GetExternalData implements Owasm ExecEnv interface.

func (*BaseEnv) GetExternalDataStatus 

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

GetExternalDataStatus implements Owasm ExecEnv interface.

func (*BaseEnv) GetMinCount 

func (env *BaseEnv) GetMinCount() int64

GetMinCount implements Owasm ExecEnv interface.

func (*BaseEnv) GetPrepareTime added in v0.5.2 

func (env *BaseEnv) GetPrepareTime() int64

GetPrepareTime implements Owasm ExecEnv interface.

func (*BaseEnv) GetSpanSize added in v0.7.2 

func (env *BaseEnv) GetSpanSize() int64

GetSpanSize implements Owasm ExecEnv interface.

func (*BaseEnv) SetReturnData 

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

SetReturnData implements Owasm ExecEnv interface.

type ChannelKeeper 

type ChannelKeeper interface {
	SendPacket(
		ctx sdk.Context,
		chanCap *capabilitytypes.Capability,
		sourcePort string,
		sourceChannel string,
		timeoutHeight ibcclienttypes.Height,
		timeoutTimestamp uint64,
		data []byte,
	) (sequence uint64, err error)
}

type ClientKeeper 

type ClientKeeper interface {
	GetClientConsensusState(ctx sdk.Context, clientID string) (connection ibcexported.ConsensusState, found bool)
}

ClientKeeper defines the expected IBC client keeper

type ConnectionKeeper 

type ConnectionKeeper interface {
	GetConnection(ctx sdk.Context, connectionID string) (connection connectiontypes.ConnectionEnd, found bool)
}

ConnectionKeeper defines the expected IBC connection keeper

type DataProviderAccumulatedReward 

type DataProviderAccumulatedReward struct {
	DataProvider       string                                   `protobuf:"bytes,1,opt,name=data_provider,json=dataProvider,proto3" json:"data_provider,omitempty"`
	DataProviderReward github_com_cosmos_cosmos_sdk_types.Coins `` /* 161-byte string literal not displayed */
}

func NewDataProviderAccumulatedReward 

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

func (*DataProviderAccumulatedReward) Descriptor 

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

func (*DataProviderAccumulatedReward) GetDataProvider 

func (m *DataProviderAccumulatedReward) GetDataProvider() string

func (*DataProviderAccumulatedReward) GetDataProviderReward 

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

func (*DataProviderAccumulatedReward) Marshal 

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

func (*DataProviderAccumulatedReward) MarshalTo 

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

func (*DataProviderAccumulatedReward) MarshalToSizedBuffer 

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

func (*DataProviderAccumulatedReward) ProtoMessage 

func (*DataProviderAccumulatedReward) ProtoMessage()

func (*DataProviderAccumulatedReward) Reset 

func (m *DataProviderAccumulatedReward) Reset()

func (*DataProviderAccumulatedReward) Size 

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

func (*DataProviderAccumulatedReward) String 

func (m *DataProviderAccumulatedReward) String() string

func (*DataProviderAccumulatedReward) Unmarshal 

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

func (*DataProviderAccumulatedReward) XXX_DiscardUnknown 

func (m *DataProviderAccumulatedReward) XXX_DiscardUnknown()

func (*DataProviderAccumulatedReward) XXX_Marshal 

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

func (*DataProviderAccumulatedReward) XXX_Merge 

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

func (*DataProviderAccumulatedReward) XXX_Size 

func (m *DataProviderAccumulatedReward) XXX_Size() int

func (*DataProviderAccumulatedReward) XXX_Unmarshal 

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

type DataProvidersAccumulatedRewards 

type DataProvidersAccumulatedRewards struct {
	CurrentRewardPerByte github_com_cosmos_cosmos_sdk_types.Coins `` /* 169-byte string literal not displayed */
	AccumulatedAmount    github_com_cosmos_cosmos_sdk_types.Coins `` /* 156-byte string literal not displayed */
}

func NewDataProvidersAccumulatedRewards 

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

func (*DataProvidersAccumulatedRewards) Descriptor 

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

func (*DataProvidersAccumulatedRewards) GetAccumulatedAmount 

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

func (*DataProvidersAccumulatedRewards) GetCurrentRewardPerByte 

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

func (*DataProvidersAccumulatedRewards) Marshal 

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

func (*DataProvidersAccumulatedRewards) MarshalTo 

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

func (*DataProvidersAccumulatedRewards) MarshalToSizedBuffer 

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

func (*DataProvidersAccumulatedRewards) ProtoMessage 

func (*DataProvidersAccumulatedRewards) ProtoMessage()

func (*DataProvidersAccumulatedRewards) Reset 

func (m *DataProvidersAccumulatedRewards) Reset()

func (*DataProvidersAccumulatedRewards) Size 

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

func (*DataProvidersAccumulatedRewards) String 

func (m *DataProvidersAccumulatedRewards) String() string

func (*DataProvidersAccumulatedRewards) Unmarshal 

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

func (*DataProvidersAccumulatedRewards) XXX_DiscardUnknown 

func (m *DataProvidersAccumulatedRewards) XXX_DiscardUnknown()

func (*DataProvidersAccumulatedRewards) XXX_Marshal 

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

func (*DataProvidersAccumulatedRewards) XXX_Merge 

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

func (*DataProvidersAccumulatedRewards) XXX_Size 

func (m *DataProvidersAccumulatedRewards) XXX_Size() int

func (*DataProvidersAccumulatedRewards) XXX_Unmarshal 

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

type DataSource 

type DataSource struct {
	ID          DataSourceID                             `protobuf:"varint,1,opt,name=id,proto3,casttype=DataSourceID" json:"id,omitempty"`
	Owner       string                                   `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	Name        string                                   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Description string                                   `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Filename    string                                   `protobuf:"bytes,5,opt,name=filename,proto3" json:"filename,omitempty"`
	Fee         github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,6,rep,name=fee,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"fee"`
}

DataSource is the data structure for storing data sources in the storage.

func NewDataSource 

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

func (*DataSource) Descriptor 

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

func (*DataSource) Equal 

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

func (*DataSource) GetDescription 

func (m *DataSource) GetDescription() string

func (*DataSource) GetFee 

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

func (*DataSource) GetFilename 

func (m *DataSource) GetFilename() string

func (*DataSource) GetID 

func (m *DataSource) GetID() DataSourceID

func (*DataSource) GetName 

func (m *DataSource) GetName() string

func (*DataSource) GetOwner 

func (m *DataSource) GetOwner() string

func (*DataSource) Marshal 

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

func (*DataSource) MarshalTo 

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

func (*DataSource) MarshalToSizedBuffer 

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

func (*DataSource) ProtoMessage 

func (*DataSource) ProtoMessage()

func (*DataSource) Reset 

func (m *DataSource) Reset()

func (*DataSource) Size 

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

func (*DataSource) String 

func (m *DataSource) String() string

func (*DataSource) Unmarshal 

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

func (*DataSource) XXX_DiscardUnknown 

func (m *DataSource) XXX_DiscardUnknown()

func (*DataSource) XXX_Marshal 

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

func (*DataSource) XXX_Merge 

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

func (*DataSource) XXX_Size 

func (m *DataSource) XXX_Size() int

func (*DataSource) XXX_Unmarshal 

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

type DataSourceID 

type DataSourceID int64

DataSourceID is the type-safe unique identifier type for data sources.

type DistrKeeper 

type DistrKeeper interface {
	GetCommunityTax(ctx sdk.Context) (percent sdk.Dec)
	GetFeePool(ctx sdk.Context) (feePool distrtypes.FeePool)
	SetFeePool(ctx sdk.Context, feePool distrtypes.FeePool)
	AllocateTokensToValidator(ctx sdk.Context, val stakingtypes.ValidatorI, tokens sdk.DecCoins)
	FundCommunityPool(ctx sdk.Context, amount sdk.Coins, sender sdk.AccAddress) error
}

DistrKeeper defines the expected distribution keeper.

type ExecuteEnv 

type ExecuteEnv struct {
	BaseEnv

	Retdata     []byte
	ExecuteTime int64
	// contains filtered or unexported fields
}

ExecuteEnv implements ExecEnv interface only expected function and panic on prepare related functions.

func NewExecuteEnv 

func NewExecuteEnv(req Request, reports []Report, executeTime time.Time) *ExecuteEnv

NewExecuteEnv creates a new environment instance for execution period.

func (*ExecuteEnv) GetAnsCount 

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

GetAnsCount implements Owasm ExecEnv interface.

func (*ExecuteEnv) GetExecuteTime added in v0.5.2 

func (env *ExecuteEnv) GetExecuteTime() (int64, error)

GetExecuteTime implements Owasm ExecEnv interface.

func (*ExecuteEnv) GetExternalData 

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

GetExternalData implements Owasm ExecEnv interface.

func (*ExecuteEnv) GetExternalDataStatus 

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

GetExternalDataStatus implements Owasm ExecEnv interface.

func (*ExecuteEnv) SetReturnData 

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

SetReturnData implements Owasm ExecEnv interface.

type ExternalID 

type ExternalID int64

ExternalID is the type-safe unique identifier type for raw data requests.

type GenesisState 

type GenesisState struct {
	Params             Params         `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	DataSources        []DataSource   `protobuf:"bytes,2,rep,name=data_sources,json=dataSources,proto3" json:"data_sources"`
	OracleScripts      []OracleScript `protobuf:"bytes,3,rep,name=oracle_scripts,json=oracleScripts,proto3" json:"oracle_scripts"`
	OraclePool         OraclePool     `protobuf:"bytes,4,opt,name=oracle_pool,json=oraclePool,proto3" json:"oracle_pool"`
	ModuleCoinsAccount string         `` /* 145-byte string literal not displayed */
}

GenesisState defines the oracle module's genesis state.

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

DefaultGenesisState returns the default oracle genesis state.

func GetGenesisStateFromAppState 

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

GetGenesisStateFromAppState returns oracle GenesisState given raw application genesis state.

func NewGenesisState 

func NewGenesisState(params Params, dataSources []DataSource, oracleScripts []OracleScript, oracleModuleCoinsAccount sdk.AccAddress) *GenesisState

NewGenesisState creates a new GenesisState instance

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetDataSources 

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

func (*GenesisState) GetModuleCoinsAccount 

func (m *GenesisState) GetModuleCoinsAccount() string

func (*GenesisState) GetOraclePool 

func (m *GenesisState) GetOraclePool() OraclePool

func (*GenesisState) GetOracleScripts 

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

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (GenesisState) UnpackInterfaces 

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

UnpackInterfaces implements UnpackInterfacesMessage.UnpackInterfaces

func (GenesisState) Validate 

func (g GenesisState) Validate() error

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

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type IBCChannel 

type IBCChannel struct {
	// PortID is port ID used for sending response packet when request is
	// resolved.
	PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"`
	// ChannelID is channel ID used for sending response packet when request is
	// resolved.
	ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
}

IBCChannel is information of IBC protocol to allow communicating with other chain

func NewIBCChannel 

func NewIBCChannel(portId, channelId string) IBCChannel

func (*IBCChannel) Descriptor 

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

func (*IBCChannel) Equal 

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

func (*IBCChannel) GetChannelId 

func (m *IBCChannel) GetChannelId() string

func (*IBCChannel) GetPortId 

func (m *IBCChannel) GetPortId() string

func (*IBCChannel) Marshal 

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

func (*IBCChannel) MarshalTo 

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

func (*IBCChannel) MarshalToSizedBuffer 

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

func (*IBCChannel) ProtoMessage 

func (*IBCChannel) ProtoMessage()

func (*IBCChannel) Reset 

func (m *IBCChannel) Reset()

func (*IBCChannel) Size 

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

func (*IBCChannel) String 

func (m *IBCChannel) String() string

func (*IBCChannel) Unmarshal 

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

func (*IBCChannel) XXX_DiscardUnknown 

func (m *IBCChannel) XXX_DiscardUnknown()

func (*IBCChannel) XXX_Marshal 

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

func (*IBCChannel) XXX_Merge 

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

func (*IBCChannel) XXX_Size 

func (m *IBCChannel) XXX_Size() int

func (*IBCChannel) XXX_Unmarshal 

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

type IBCSource 

type IBCSource struct {
	// SourceChannel
	SourceChannel string `protobuf:"bytes,1,opt,name=source_channel,json=sourceChannel,proto3" json:"source_channel,omitempty"`
	// SourcePort
	SourcePort string `protobuf:"bytes,2,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"`
}

IBCSource

func NewIBCSource 

func NewIBCSource(portId, channelId string) IBCSource

func (*IBCSource) Descriptor 

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

func (*IBCSource) Equal 

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

func (*IBCSource) GetSourceChannel 

func (m *IBCSource) GetSourceChannel() string

func (*IBCSource) GetSourcePort 

func (m *IBCSource) GetSourcePort() string

func (*IBCSource) Marshal 

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

func (*IBCSource) MarshalTo 

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

func (*IBCSource) MarshalToSizedBuffer 

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

func (*IBCSource) ProtoMessage 

func (*IBCSource) ProtoMessage()

func (*IBCSource) Reset 

func (m *IBCSource) Reset()

func (*IBCSource) Size 

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

func (*IBCSource) String 

func (m *IBCSource) String() string

func (*IBCSource) Unmarshal 

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

func (*IBCSource) XXX_DiscardUnknown 

func (m *IBCSource) XXX_DiscardUnknown()

func (*IBCSource) XXX_Marshal 

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

func (*IBCSource) XXX_Merge 

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

func (*IBCSource) XXX_Size 

func (m *IBCSource) XXX_Size() int

func (*IBCSource) XXX_Unmarshal 

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

type ICS4Wrapper added in v0.6.0 

type ICS4Wrapper interface {
	SendPacket(ctx sdk.Context, channelCap *capabilitytypes.Capability, packet ibcexported.PacketI) error
}

ICS4Wrapper defines the expected ICS4Wrapper for middleware

type MsgActivate 

type MsgActivate struct {
	// Validator is the signer of this message and the validator to be activated.
	Validator string `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator,omitempty"`
}

MsgEditOracleScript is a message for activating a validator to become an oracle provider.

func NewMsgActivate 

func NewMsgActivate(validator sdk.ValAddress) *MsgActivate

NewMsgActivate creates a new MsgActivate instance

func (*MsgActivate) Descriptor 

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

func (*MsgActivate) Equal 

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

func (MsgActivate) GetSignBytes 

func (msg MsgActivate) GetSignBytes() []byte

GetSignBytes returns raw JSON bytes to be signed by the signers (sdk.Msg interface).

func (MsgActivate) GetSigners 

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

GetSigners returns the required signers for the given MsgActivate (sdk.Msg interface).

func (*MsgActivate) GetValidator 

func (m *MsgActivate) GetValidator() string

func (*MsgActivate) Marshal 

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

func (*MsgActivate) MarshalTo 

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

func (*MsgActivate) MarshalToSizedBuffer 

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

func (*MsgActivate) ProtoMessage 

func (*MsgActivate) ProtoMessage()

func (*MsgActivate) Reset 

func (m *MsgActivate) Reset()

func (MsgActivate) Route 

func (msg MsgActivate) Route() string

Route returns the route of MsgActivate - "oracle" (sdk.Msg interface).

func (*MsgActivate) Size 

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

func (*MsgActivate) String 

func (m *MsgActivate) String() string

func (MsgActivate) Type 

func (msg MsgActivate) Type() string

Type returns the message type of MsgActivate (sdk.Msg interface).

func (*MsgActivate) Unmarshal 

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

func (MsgActivate) ValidateBasic 

func (msg MsgActivate) ValidateBasic() error

ValidateBasic checks whether the given MsgActivate instance (sdk.Msg interface).

func (*MsgActivate) XXX_DiscardUnknown 

func (m *MsgActivate) XXX_DiscardUnknown()

func (*MsgActivate) XXX_Marshal 

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

func (*MsgActivate) XXX_Merge 

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

func (*MsgActivate) XXX_Size 

func (m *MsgActivate) XXX_Size() int

func (*MsgActivate) XXX_Unmarshal 

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

type MsgActivateResponse 

type MsgActivateResponse struct {
}

MsgActivateResponse

func (*MsgActivateResponse) Descriptor 

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

func (*MsgActivateResponse) Marshal 

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

func (*MsgActivateResponse) MarshalTo 

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

func (*MsgActivateResponse) MarshalToSizedBuffer 

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

func (*MsgActivateResponse) ProtoMessage 

func (*MsgActivateResponse) ProtoMessage()

func (*MsgActivateResponse) Reset 

func (m *MsgActivateResponse) Reset()

func (*MsgActivateResponse) Size 

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

func (*MsgActivateResponse) String 

func (m *MsgActivateResponse) String() string

func (*MsgActivateResponse) Unmarshal 

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

func (*MsgActivateResponse) XXX_DiscardUnknown 

func (m *MsgActivateResponse) XXX_DiscardUnknown()

func (*MsgActivateResponse) XXX_Marshal 

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

func (*MsgActivateResponse) XXX_Merge 

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

func (*MsgActivateResponse) XXX_Size 

func (m *MsgActivateResponse) XXX_Size() int

func (*MsgActivateResponse) XXX_Unmarshal 

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

type MsgAddReporter 

type MsgAddReporter struct {
	// Validator is the validator that wishes to add a new reporter. This is the
	// signer.
	Validator string `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator,omitempty"`
	// Reporter is the address to be added as a reporter to the validator.
	Reporter string `protobuf:"bytes,2,opt,name=reporter,proto3" json:"reporter,omitempty"`
}

MsgAddReporter is a message for adding a new reporter for a validator.

func NewMsgAddReporter 

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

NewMsgAddReporter creates a new MsgAddReporter instance

func (*MsgAddReporter) Descriptor 

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

func (*MsgAddReporter) Equal 

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

func (*MsgAddReporter) GetReporter 

func (m *MsgAddReporter) GetReporter() string

func (MsgAddReporter) GetSignBytes 

func (msg MsgAddReporter) GetSignBytes() []byte

GetSignBytes returns raw JSON bytes to be signed by the signers (sdk.Msg interface).

func (MsgAddReporter) GetSigners 

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

GetSigners returns the required signers for the given MsgAddReporter (sdk.Msg interface).

func (*MsgAddReporter) GetValidator 

func (m *MsgAddReporter) GetValidator() string

func (*MsgAddReporter) Marshal 

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

func (*MsgAddReporter) MarshalTo 

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

func (*MsgAddReporter) MarshalToSizedBuffer 

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

func (*MsgAddReporter) ProtoMessage 

func (*MsgAddReporter) ProtoMessage()

func (*MsgAddReporter) Reset 

func (m *MsgAddReporter) Reset()

func (MsgAddReporter) Route 

func (msg MsgAddReporter) Route() string

Route returns the route of MsgAddReporter - "oracle" (sdk.Msg interface).

func (*MsgAddReporter) Size 

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

func (*MsgAddReporter) String 

func (m *MsgAddReporter) String() string

func (MsgAddReporter) Type 

func (msg MsgAddReporter) Type() string

Type returns the message type of MsgAddReporter (sdk.Msg interface).

func (*MsgAddReporter) Unmarshal 

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

func (MsgAddReporter) ValidateBasic 

func (msg MsgAddReporter) ValidateBasic() error

ValidateBasic checks whether the given MsgAddReporter instance (sdk.Msg interface).

func (*MsgAddReporter) XXX_DiscardUnknown 

func (m *MsgAddReporter) XXX_DiscardUnknown()

func (*MsgAddReporter) XXX_Marshal 

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

func (*MsgAddReporter) XXX_Merge 

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

func (*MsgAddReporter) XXX_Size 

func (m *MsgAddReporter) XXX_Size() int

func (*MsgAddReporter) XXX_Unmarshal 

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

type MsgAddReporterResponse 

type MsgAddReporterResponse struct {
}

MsgAddReporterResponse

func (*MsgAddReporterResponse) Descriptor 

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

func (*MsgAddReporterResponse) Marshal 

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

func (*MsgAddReporterResponse) MarshalTo 

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

func (*MsgAddReporterResponse) MarshalToSizedBuffer 

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

func (*MsgAddReporterResponse) ProtoMessage 

func (*MsgAddReporterResponse) ProtoMessage()

func (*MsgAddReporterResponse) Reset 

func (m *MsgAddReporterResponse) Reset()

func (*MsgAddReporterResponse) Size 

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

func (*MsgAddReporterResponse) String 

func (m *MsgAddReporterResponse) String() string

func (*MsgAddReporterResponse) Unmarshal 

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

func (*MsgAddReporterResponse) XXX_DiscardUnknown 

func (m *MsgAddReporterResponse) XXX_DiscardUnknown()

func (*MsgAddReporterResponse) XXX_Marshal 

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

func (*MsgAddReporterResponse) XXX_Merge 

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

func (*MsgAddReporterResponse) XXX_Size 

func (m *MsgAddReporterResponse) XXX_Size() int

func (*MsgAddReporterResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// RequestData defines a method for requesting a new request.
	RequestData(ctx context.Context, in *MsgRequestData, opts ...grpc.CallOption) (*MsgRequestDataResponse, error)
	// ReportData defines a method for reporting a data to resolving the request.
	ReportData(ctx context.Context, in *MsgReportData, opts ...grpc.CallOption) (*MsgReportDataResponse, error)
	// CreateDataSource defines a method for creating a new data source.
	CreateDataSource(ctx context.Context, in *MsgCreateDataSource, opts ...grpc.CallOption) (*MsgCreateDataSourceResponse, error)
	// EditDataSource defines a method for editing an existing data source.
	EditDataSource(ctx context.Context, in *MsgEditDataSource, opts ...grpc.CallOption) (*MsgEditDataSourceResponse, error)
	// CreateOracleScript defines a method for creating a new oracle script.
	CreateOracleScript(ctx context.Context, in *MsgCreateOracleScript, opts ...grpc.CallOption) (*MsgCreateOracleScriptResponse, error)
	// EditOracleScript defines a method for editing an existing oracle script.
	EditOracleScript(ctx context.Context, in *MsgEditOracleScript, opts ...grpc.CallOption) (*MsgEditOracleScriptResponse, error)
	// Activate defines a method for applying to be an oracle validator.
	Activate(ctx context.Context, in *MsgActivate, opts ...grpc.CallOption) (*MsgActivateResponse, error)
	// AddReporter defines a method for adding a new reporter for a validator.
	AddReporter(ctx context.Context, in *MsgAddReporter, opts ...grpc.CallOption) (*MsgAddReporterResponse, error)
	// RemoveReporter defines a method for TODO
	RemoveReporter(ctx context.Context, in *MsgRemoveReporter, opts ...grpc.CallOption) (*MsgRemoveReporterResponse, error)
}

MsgClient is the client API for Msg service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMsgClient 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgCreateDataSource 

type MsgCreateDataSource struct {
	// Name is the name of this data source (optional).
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Description is the description of this data source (optional).
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// Executable is the executable script or binary to be run by validators upon
	// execution.
	Executable []byte `protobuf:"bytes,3,opt,name=executable,proto3" json:"executable,omitempty"`
	// Fee is the data source fee per ask_count that data provider will receive
	// from requester.
	Fee github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,4,rep,name=fee,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"fee"`
	// Owner is the address who is allowed to make further changes to the data
	// source.
	Owner string `protobuf:"bytes,5,opt,name=owner,proto3" json:"owner,omitempty"`
	// Sender is the signer of this message.
	Sender string `protobuf:"bytes,6,opt,name=sender,proto3" json:"sender,omitempty"`
}

MsgCreateDataSource is a message for creating a new data source.

func NewMsgCreateDataSource 

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

NewMsgCreateDataSource creates a new MsgCreateDataSource instance

func (*MsgCreateDataSource) Descriptor 

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

func (*MsgCreateDataSource) Equal 

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

func (*MsgCreateDataSource) GetDescription 

func (m *MsgCreateDataSource) GetDescription() string

func (*MsgCreateDataSource) GetExecutable 

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

func (*MsgCreateDataSource) GetFee 

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

func (*MsgCreateDataSource) GetName 

func (m *MsgCreateDataSource) GetName() string

func (*MsgCreateDataSource) GetOwner 

func (m *MsgCreateDataSource) GetOwner() string

func (*MsgCreateDataSource) GetSender 

func (m *MsgCreateDataSource) GetSender() string

func (MsgCreateDataSource) GetSignBytes 

func (msg MsgCreateDataSource) GetSignBytes() []byte

GetSignBytes returns raw JSON bytes to be signed by the signers (sdk.Msg interface).

func (MsgCreateDataSource) GetSigners 

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

GetSigners returns the required signers for the given MsgCreateDataSource (sdk.Msg interface).

func (*MsgCreateDataSource) Marshal 

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

func (*MsgCreateDataSource) MarshalTo 

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

func (*MsgCreateDataSource) MarshalToSizedBuffer 

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

func (*MsgCreateDataSource) ProtoMessage 

func (*MsgCreateDataSource) ProtoMessage()

func (*MsgCreateDataSource) Reset 

func (m *MsgCreateDataSource) Reset()

func (MsgCreateDataSource) Route 

func (msg MsgCreateDataSource) Route() string

Route returns the route of MsgCreateDataSource - "oracle" (sdk.Msg interface).

func (*MsgCreateDataSource) Size 

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

func (*MsgCreateDataSource) String 

func (m *MsgCreateDataSource) String() string

func (MsgCreateDataSource) Type 

func (msg MsgCreateDataSource) Type() string

Type returns the message type of MsgCreateDataSource (sdk.Msg interface).

func (*MsgCreateDataSource) Unmarshal 

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

func (MsgCreateDataSource) ValidateBasic 

func (msg MsgCreateDataSource) ValidateBasic() error

ValidateBasic checks whether the given MsgCreateDataSource instance (sdk.Msg interface).

func (*MsgCreateDataSource) XXX_DiscardUnknown 

func (m *MsgCreateDataSource) XXX_DiscardUnknown()

func (*MsgCreateDataSource) XXX_Marshal 

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

func (*MsgCreateDataSource) XXX_Merge 

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

func (*MsgCreateDataSource) XXX_Size 

func (m *MsgCreateDataSource) XXX_Size() int

func (*MsgCreateDataSource) XXX_Unmarshal 

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

type MsgCreateDataSourceResponse 

type MsgCreateDataSourceResponse struct {
}

MsgCreateDataSourceResponse

func (*MsgCreateDataSourceResponse) Descriptor 

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

func (*MsgCreateDataSourceResponse) Marshal 

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

func (*MsgCreateDataSourceResponse) MarshalTo 

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

func (*MsgCreateDataSourceResponse) MarshalToSizedBuffer 

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

func (*MsgCreateDataSourceResponse) ProtoMessage 

func (*MsgCreateDataSourceResponse) ProtoMessage()

func (*MsgCreateDataSourceResponse) Reset 

func (m *MsgCreateDataSourceResponse) Reset()

func (*MsgCreateDataSourceResponse) Size 

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

func (*MsgCreateDataSourceResponse) String 

func (m *MsgCreateDataSourceResponse) String() string

func (*MsgCreateDataSourceResponse) Unmarshal 

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

func (*MsgCreateDataSourceResponse) XXX_DiscardUnknown 

func (m *MsgCreateDataSourceResponse) XXX_DiscardUnknown()

func (*MsgCreateDataSourceResponse) XXX_Marshal 

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

func (*MsgCreateDataSourceResponse) XXX_Merge 

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

func (*MsgCreateDataSourceResponse) XXX_Size 

func (m *MsgCreateDataSourceResponse) XXX_Size() int

func (*MsgCreateDataSourceResponse) XXX_Unmarshal 

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

type MsgCreateOracleScript 

type MsgCreateOracleScript struct {
	// Name is the name of this oracle script (optional).
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Description is the description of this oracle script (optional).
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// Schema is the OBI schema of this oracle script (optional).
	Schema string `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	// SourceCodeURL is the absolute URI to the script's source code (optional).
	SourceCodeURL string `protobuf:"bytes,4,opt,name=source_code_url,json=sourceCodeUrl,proto3" json:"source_code_url,omitempty"`
	// Code is the oracle WebAssembly binary code. Can be raw of gzip compressed.
	Code []byte `protobuf:"bytes,5,opt,name=code,proto3" json:"code,omitempty"`
	// Owner is the address who is allowed to make further changes to the oracle
	// script.
	Owner string `protobuf:"bytes,6,opt,name=owner,proto3" json:"owner,omitempty"`
	// Sender is the signer of this message.
	Sender string `protobuf:"bytes,7,opt,name=sender,proto3" json:"sender,omitempty"`
}

MsgCreateOracleScript is a message for creating an oracle script.

func NewMsgCreateOracleScript 

func NewMsgCreateOracleScript(
	name, description, schema, sourceCodeURL string, code []byte, owner, sender sdk.AccAddress,
) *MsgCreateOracleScript

NewMsgCreateOracleScript creates a new MsgCreateOracleScript instance

func (*MsgCreateOracleScript) Descriptor 

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

func (*MsgCreateOracleScript) Equal 

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

func (*MsgCreateOracleScript) GetCode 

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

func (*MsgCreateOracleScript) GetDescription 

func (m *MsgCreateOracleScript) GetDescription() string

func (*MsgCreateOracleScript) GetName 

func (m *MsgCreateOracleScript) GetName() string

func (*MsgCreateOracleScript) GetOwner 

func (m *MsgCreateOracleScript) GetOwner() string

func (*MsgCreateOracleScript) GetSchema 

func (m *MsgCreateOracleScript) GetSchema() string

func (*MsgCreateOracleScript) GetSender 

func (m *MsgCreateOracleScript) GetSender() string

func (MsgCreateOracleScript) GetSignBytes 

func (msg MsgCreateOracleScript) GetSignBytes() []byte

GetSignBytes returns raw JSON bytes to be signed by the signers (sdk.Msg interface).

func (MsgCreateOracleScript) GetSigners 

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

GetSigners returns the required signers for the given MsgCreateOracleScript (sdk.Msg interface).

func (*MsgCreateOracleScript) GetSourceCodeURL 

func (m *MsgCreateOracleScript) GetSourceCodeURL() string

func (*MsgCreateOracleScript) Marshal 

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

func (*MsgCreateOracleScript) MarshalTo 

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

func (*MsgCreateOracleScript) MarshalToSizedBuffer 

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

func (*MsgCreateOracleScript) ProtoMessage 

func (*MsgCreateOracleScript) ProtoMessage()

func (*MsgCreateOracleScript) Reset 

func (m *MsgCreateOracleScript) Reset()

func (MsgCreateOracleScript) Route 

func (msg MsgCreateOracleScript) Route() string

Route returns the route of MsgCreateOracleScript - "oracle" (sdk.Msg interface).

func (*MsgCreateOracleScript) Size 

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

func (*MsgCreateOracleScript) String 

func (m *MsgCreateOracleScript) String() string

func (MsgCreateOracleScript) Type 

func (msg MsgCreateOracleScript) Type() string

Type returns the message type of MsgCreateOracleScript (sdk.Msg interface).

func (*MsgCreateOracleScript) Unmarshal 

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

func (MsgCreateOracleScript) ValidateBasic 

func (msg MsgCreateOracleScript) ValidateBasic() error

ValidateBasic checks whether the given MsgCreateOracleScript instance (sdk.Msg interface).

func (*MsgCreateOracleScript) XXX_DiscardUnknown 

func (m *MsgCreateOracleScript) XXX_DiscardUnknown()

func (*MsgCreateOracleScript) XXX_Marshal 

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

func (*MsgCreateOracleScript) XXX_Merge 

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

func (*MsgCreateOracleScript) XXX_Size 

func (m *MsgCreateOracleScript) XXX_Size() int

func (*MsgCreateOracleScript) XXX_Unmarshal 

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

type MsgCreateOracleScriptResponse 

type MsgCreateOracleScriptResponse struct {
}

MsgCreateOracleScriptResponse

func (*MsgCreateOracleScriptResponse) Descriptor 

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

func (*MsgCreateOracleScriptResponse) Marshal 

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

func (*MsgCreateOracleScriptResponse) MarshalTo 

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

func (*MsgCreateOracleScriptResponse) MarshalToSizedBuffer 

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

func (*MsgCreateOracleScriptResponse) ProtoMessage 

func (*MsgCreateOracleScriptResponse) ProtoMessage()

func (*MsgCreateOracleScriptResponse) Reset 

func (m *MsgCreateOracleScriptResponse) Reset()

func (*MsgCreateOracleScriptResponse) Size 

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

func (*MsgCreateOracleScriptResponse) String 

func (m *MsgCreateOracleScriptResponse) String() string

func (*MsgCreateOracleScriptResponse) Unmarshal 

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

func (*MsgCreateOracleScriptResponse) XXX_DiscardUnknown 

func (m *MsgCreateOracleScriptResponse) XXX_DiscardUnknown()

func (*MsgCreateOracleScriptResponse) XXX_Marshal 

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

func (*MsgCreateOracleScriptResponse) XXX_Merge 

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

func (*MsgCreateOracleScriptResponse) XXX_Size 

func (m *MsgCreateOracleScriptResponse) XXX_Size() int

func (*MsgCreateOracleScriptResponse) XXX_Unmarshal 

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

type MsgEditDataSource 

type MsgEditDataSource struct {
	// DataSourceID is the unique identifier of the data source to be edited.
	DataSourceID DataSourceID `protobuf:"varint,1,opt,name=data_source_id,json=dataSourceId,proto3,casttype=DataSourceID" json:"data_source_id,omitempty"`
	// Name is the name of this data source (optional).
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description is the description of this data source (optional).
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Executable is the executable script or binary to be run by validators upon
	// execution.
	Executable []byte `protobuf:"bytes,4,opt,name=executable,proto3" json:"executable,omitempty"`
	// Fee is the data source fee per ask_count that data provider will receive
	// from requester.
	Fee github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,5,rep,name=fee,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"fee"`
	// Owner is the address who is allowed to make further changes to the data
	// source.
	Owner string `protobuf:"bytes,6,opt,name=owner,proto3" json:"owner,omitempty"`
	// Sender is the signer of this message. Must be the current data source's
	// owner.
	Sender string `protobuf:"bytes,7,opt,name=sender,proto3" json:"sender,omitempty"`
}

MsgEditDataSource is a message for editing an existing data source.

func NewMsgEditDataSource 

func NewMsgEditDataSource(
	dataSourceID DataSourceID, name string, description string, executable []byte, fee sdk.Coins, owner, sender sdk.AccAddress,
) *MsgEditDataSource

NewMsgEditDataSource creates a new MsgEditDataSource instance

func (*MsgEditDataSource) Descriptor 

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

func (*MsgEditDataSource) Equal 

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

func (*MsgEditDataSource) GetDataSourceID 

func (m *MsgEditDataSource) GetDataSourceID() DataSourceID

func (*MsgEditDataSource) GetDescription 

func (m *MsgEditDataSource) GetDescription() string

func (*MsgEditDataSource) GetExecutable 

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

func (*MsgEditDataSource) GetFee 

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

func (*MsgEditDataSource) GetName 

func (m *MsgEditDataSource) GetName() string

func (*MsgEditDataSource) GetOwner 

func (m *MsgEditDataSource) GetOwner() string

func (*MsgEditDataSource) GetSender 

func (m *MsgEditDataSource) GetSender() string

func (MsgEditDataSource) GetSignBytes 

func (msg MsgEditDataSource) GetSignBytes() []byte

GetSignBytes returns raw JSON bytes to be signed by the signers (sdk.Msg interface).

func (MsgEditDataSource) GetSigners 

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

GetSigners returns the required signers for the given MsgEditDataSource (sdk.Msg interface).

func (*MsgEditDataSource) Marshal 

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

func (*MsgEditDataSource) MarshalTo 

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

func (*MsgEditDataSource) MarshalToSizedBuffer 

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

func (*MsgEditDataSource) ProtoMessage 

func (*MsgEditDataSource) ProtoMessage()

func (*MsgEditDataSource) Reset 

func (m *MsgEditDataSource) Reset()

func (MsgEditDataSource) Route 

func (msg MsgEditDataSource) Route() string

Route returns the route of MsgEditDataSource - "oracle" (sdk.Msg interface).

func (*MsgEditDataSource) Size 

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

func (*MsgEditDataSource) String 

func (m *MsgEditDataSource) String() string

func (MsgEditDataSource) Type 

func (msg MsgEditDataSource) Type() string

Type returns the message type of MsgEditDataSource (sdk.Msg interface).

func (*MsgEditDataSource) Unmarshal 

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

func (MsgEditDataSource) ValidateBasic 

func (msg MsgEditDataSource) ValidateBasic() error

ValidateBasic checks whether the given MsgEditDataSource instance (sdk.Msg interface).

func (*MsgEditDataSource) XXX_DiscardUnknown 

func (m *MsgEditDataSource) XXX_DiscardUnknown()

func (*MsgEditDataSource) XXX_Marshal 

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

func (*MsgEditDataSource) XXX_Merge 

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

func (*MsgEditDataSource) XXX_Size 

func (m *MsgEditDataSource) XXX_Size() int

func (*MsgEditDataSource) XXX_Unmarshal 

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

type MsgEditDataSourceResponse 

type MsgEditDataSourceResponse struct {
}

MsgEditDataSourceResponse

func (*MsgEditDataSourceResponse) Descriptor 

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

func (*MsgEditDataSourceResponse) Marshal 

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

func (*MsgEditDataSourceResponse) MarshalTo 

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

func (*MsgEditDataSourceResponse) MarshalToSizedBuffer 

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

func (*MsgEditDataSourceResponse) ProtoMessage 

func (*MsgEditDataSourceResponse) ProtoMessage()

func (*MsgEditDataSourceResponse) Reset 

func (m *MsgEditDataSourceResponse) Reset()

func (*MsgEditDataSourceResponse) Size 

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

func (*MsgEditDataSourceResponse) String 

func (m *MsgEditDataSourceResponse) String() string

func (*MsgEditDataSourceResponse) Unmarshal 

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

func (*MsgEditDataSourceResponse) XXX_DiscardUnknown 

func (m *MsgEditDataSourceResponse) XXX_DiscardUnknown()

func (*MsgEditDataSourceResponse) XXX_Marshal 

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

func (*MsgEditDataSourceResponse) XXX_Merge 

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

func (*MsgEditDataSourceResponse) XXX_Size 

func (m *MsgEditDataSourceResponse) XXX_Size() int

func (*MsgEditDataSourceResponse) XXX_Unmarshal 

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

type MsgEditOracleScript 

type MsgEditOracleScript struct {
	// OracleScriptID is the unique identifier of the oracle script to be edited.
	OracleScriptID OracleScriptID `` /* 130-byte string literal not displayed */
	// Name is the name of this oracle script (optional).
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description is the description of this oracle script (optional).
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Schema is the OBI schema of this oracle script (optional).
	Schema string `protobuf:"bytes,4,opt,name=schema,proto3" json:"schema,omitempty"`
	// SourceCodeURL is the absolute URI to the script's source code (optional).
	SourceCodeURL string `protobuf:"bytes,5,opt,name=source_code_url,json=sourceCodeUrl,proto3" json:"source_code_url,omitempty"`
	// Code is the oracle WebAssembly binary code. Can be raw of gzip compressed.
	Code []byte `protobuf:"bytes,6,opt,name=code,proto3" json:"code,omitempty"`
	// Owner is new the address who is allowed to make further changes to the
	// oracle script.
	Owner string `protobuf:"bytes,7,opt,name=owner,proto3" json:"owner,omitempty"`
	// Sender is the signer of this message. Must be the current oracle script's
	// owner.
	Sender string `protobuf:"bytes,8,opt,name=sender,proto3" json:"sender,omitempty"`
}

MsgEditOracleScript is a message for editing an existing oracle script.

func NewMsgEditOracleScript 

func NewMsgEditOracleScript(
	oracleScriptID OracleScriptID, name, description, schema, sourceCodeURL string, code []byte, owner, sender sdk.AccAddress,
) *MsgEditOracleScript

NewMsgEditOracleScript creates a new MsgEditOracleScript instance

func (*MsgEditOracleScript) Descriptor 

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

func (*MsgEditOracleScript) Equal 

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

func (*MsgEditOracleScript) GetCode 

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

func (*MsgEditOracleScript) GetDescription 

func (m *MsgEditOracleScript) GetDescription() string

func (*MsgEditOracleScript) GetName 

func (m *MsgEditOracleScript) GetName() string

func (*MsgEditOracleScript) GetOracleScriptID 

func (m *MsgEditOracleScript) GetOracleScriptID() OracleScriptID

func (*MsgEditOracleScript) GetOwner 

func (m *MsgEditOracleScript) GetOwner() string

func (*MsgEditOracleScript) GetSchema 

func (m *MsgEditOracleScript) GetSchema() string

func (*MsgEditOracleScript) GetSender 

func (m *MsgEditOracleScript) GetSender() string

func (MsgEditOracleScript) GetSignBytes 

func (msg MsgEditOracleScript) GetSignBytes() []byte

GetSignBytes returns raw JSON bytes to be signed by the signers (sdk.Msg interface).

func (MsgEditOracleScript) GetSigners 

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

GetSigners returns the required signers for the given MsgEditOracleScript (sdk.Msg interface).

func (*MsgEditOracleScript) GetSourceCodeURL 

func (m *MsgEditOracleScript) GetSourceCodeURL() string

func (*MsgEditOracleScript) Marshal 

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

func (*MsgEditOracleScript) MarshalTo 

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

func (*MsgEditOracleScript) MarshalToSizedBuffer 

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

func (*MsgEditOracleScript) ProtoMessage 

func (*MsgEditOracleScript) ProtoMessage()

func (*MsgEditOracleScript) Reset 

func (m *MsgEditOracleScript) Reset()

func (MsgEditOracleScript) Route 

func (msg MsgEditOracleScript) Route() string

Route returns the route of MsgEditOracleScript - "oracle" (sdk.Msg interface).

func (*MsgEditOracleScript) Size 

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

func (*MsgEditOracleScript) String 

func (m *MsgEditOracleScript) String() string

func (MsgEditOracleScript) Type 

func (msg MsgEditOracleScript) Type() string

Type returns the message type of MsgEditOracleScript (sdk.Msg interface).

func (*MsgEditOracleScript) Unmarshal 

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

func (MsgEditOracleScript) ValidateBasic 

func (msg MsgEditOracleScript) ValidateBasic() error

ValidateBasic checks whether the given MsgEditOracleScript instance (sdk.Msg interface).

func (*MsgEditOracleScript) XXX_DiscardUnknown 

func (m *MsgEditOracleScript) XXX_DiscardUnknown()

func (*MsgEditOracleScript) XXX_Marshal 

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

func (*MsgEditOracleScript) XXX_Merge 

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

func (*MsgEditOracleScript) XXX_Size 

func (m *MsgEditOracleScript) XXX_Size() int

func (*MsgEditOracleScript) XXX_Unmarshal 

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

type MsgEditOracleScriptResponse 

type MsgEditOracleScriptResponse struct {
}

MsgEditOracleScriptResponse

func (*MsgEditOracleScriptResponse) Descriptor 

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

func (*MsgEditOracleScriptResponse) Marshal 

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

func (*MsgEditOracleScriptResponse) MarshalTo 

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

func (*MsgEditOracleScriptResponse) MarshalToSizedBuffer 

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

func (*MsgEditOracleScriptResponse) ProtoMessage 

func (*MsgEditOracleScriptResponse) ProtoMessage()

func (*MsgEditOracleScriptResponse) Reset 

func (m *MsgEditOracleScriptResponse) Reset()

func (*MsgEditOracleScriptResponse) Size 

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

func (*MsgEditOracleScriptResponse) String 

func (m *MsgEditOracleScriptResponse) String() string

func (*MsgEditOracleScriptResponse) Unmarshal 

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

func (*MsgEditOracleScriptResponse) XXX_DiscardUnknown 

func (m *MsgEditOracleScriptResponse) XXX_DiscardUnknown()

func (*MsgEditOracleScriptResponse) XXX_Marshal 

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

func (*MsgEditOracleScriptResponse) XXX_Merge 

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

func (*MsgEditOracleScriptResponse) XXX_Size 

func (m *MsgEditOracleScriptResponse) XXX_Size() int

func (*MsgEditOracleScriptResponse) XXX_Unmarshal 

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

type MsgRemoveReporter 

type MsgRemoveReporter struct {
	// Validator is the validator that wishes to remove an existing reporter. This
	// is the signer.
	Validator string `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator,omitempty"`
	// Reporter is the address to be removed from being the validators' reporter.
	Reporter string `protobuf:"bytes,2,opt,name=reporter,proto3" json:"reporter,omitempty"`
}

MsgAddReporter is a message for removing an existing reporter from a validator.

func NewMsgRemoveReporter 

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

NewMsgRemoveReporter creates a new MsgRemoveReporter instance

func (*MsgRemoveReporter) Descriptor 

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

func (*MsgRemoveReporter) Equal 

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

func (*MsgRemoveReporter) GetReporter 

func (m *MsgRemoveReporter) GetReporter() string

func (MsgRemoveReporter) GetSignBytes 

func (msg MsgRemoveReporter) GetSignBytes() []byte

GetSignBytes returns raw JSON bytes to be signed by the signers (sdk.Msg interface).

func (MsgRemoveReporter) GetSigners 

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

GetSigners returns the required signers for the given MsgRemoveReporter (sdk.Msg interface).

func (*MsgRemoveReporter) GetValidator 

func (m *MsgRemoveReporter) GetValidator() string

func (*MsgRemoveReporter) Marshal 

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

func (*MsgRemoveReporter) MarshalTo 

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

func (*MsgRemoveReporter) MarshalToSizedBuffer 

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

func (*MsgRemoveReporter) ProtoMessage 

func (*MsgRemoveReporter) ProtoMessage()

func (*MsgRemoveReporter) Reset 

func (m *MsgRemoveReporter) Reset()

func (MsgRemoveReporter) Route 

func (msg MsgRemoveReporter) Route() string

Route returns the route of MsgRemoveReporter - "oracle" (sdk.Msg interface).

func (*MsgRemoveReporter) Size 

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

func (*MsgRemoveReporter) String 

func (m *MsgRemoveReporter) String() string

func (MsgRemoveReporter) Type 

func (msg MsgRemoveReporter) Type() string

Type returns the message type of MsgRemoveReporter (sdk.Msg interface).

func (*MsgRemoveReporter) Unmarshal 

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

func (MsgRemoveReporter) ValidateBasic 

func (msg MsgRemoveReporter) ValidateBasic() error

ValidateBasic checks whether the given MsgRemoveReporter instance (sdk.Msg interface).

func (*MsgRemoveReporter) XXX_DiscardUnknown 

func (m *MsgRemoveReporter) XXX_DiscardUnknown()

func (*MsgRemoveReporter) XXX_Marshal 

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

func (*MsgRemoveReporter) XXX_Merge 

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

func (*MsgRemoveReporter) XXX_Size 

func (m *MsgRemoveReporter) XXX_Size() int

func (*MsgRemoveReporter) XXX_Unmarshal 

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

type MsgRemoveReporterResponse 

type MsgRemoveReporterResponse struct {
}

MsgRemoveReporterResponse

func (*MsgRemoveReporterResponse) Descriptor 

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

func (*MsgRemoveReporterResponse) Marshal 

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

func (*MsgRemoveReporterResponse) MarshalTo 

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

func (*MsgRemoveReporterResponse) MarshalToSizedBuffer 

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

func (*MsgRemoveReporterResponse) ProtoMessage 

func (*MsgRemoveReporterResponse) ProtoMessage()

func (*MsgRemoveReporterResponse) Reset 

func (m *MsgRemoveReporterResponse) Reset()

func (*MsgRemoveReporterResponse) Size 

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

func (*MsgRemoveReporterResponse) String 

func (m *MsgRemoveReporterResponse) String() string

func (*MsgRemoveReporterResponse) Unmarshal 

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

func (*MsgRemoveReporterResponse) XXX_DiscardUnknown 

func (m *MsgRemoveReporterResponse) XXX_DiscardUnknown()

func (*MsgRemoveReporterResponse) XXX_Marshal 

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

func (*MsgRemoveReporterResponse) XXX_Merge 

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

func (*MsgRemoveReporterResponse) XXX_Size 

func (m *MsgRemoveReporterResponse) XXX_Size() int

func (*MsgRemoveReporterResponse) XXX_Unmarshal 

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

type MsgReportData 

type MsgReportData struct {
	// RequestID is the identifier of the request to report to.
	RequestID RequestID `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3,casttype=RequestID" json:"request_id,omitempty"`
	// RawReports is the list of report information for each of the request's
	// external ID.
	RawReports []RawReport `protobuf:"bytes,2,rep,name=raw_reports,json=rawReports,proto3" json:"raw_reports"`
	// Validator is the address of the validator that owns this report.
	Validator string `protobuf:"bytes,3,opt,name=validator,proto3" json:"validator,omitempty"`
	// Reporter is the message signer who submits this report transaction for the
	// validator.
	Reporter string `protobuf:"bytes,4,opt,name=reporter,proto3" json:"reporter,omitempty"`
}

MsgReportData is a message for reporting to a data request by a validator.

func NewMsgReportData 

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

func (*MsgReportData) Descriptor 

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

func (*MsgReportData) Equal 

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

func (*MsgReportData) GetRawReports 

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

func (*MsgReportData) GetReporter 

func (m *MsgReportData) GetReporter() string

func (*MsgReportData) GetRequestID 

func (m *MsgReportData) GetRequestID() RequestID

func (MsgReportData) GetSignBytes 

func (msg MsgReportData) GetSignBytes() []byte

GetSignBytes returns raw JSON bytes to be signed by the signers (sdk.Msg interface).

func (MsgReportData) GetSigners 

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

GetSigners returns the required signers for the given MsgReportData (sdk.Msg interface).

func (*MsgReportData) GetValidator 

func (m *MsgReportData) GetValidator() string

func (*MsgReportData) Marshal 

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

func (*MsgReportData) MarshalTo 

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

func (*MsgReportData) MarshalToSizedBuffer 

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

func (*MsgReportData) ProtoMessage 

func (*MsgReportData) ProtoMessage()

func (*MsgReportData) Reset 

func (m *MsgReportData) Reset()

func (MsgReportData) Route 

func (msg MsgReportData) Route() string

Route returns the route of MsgReportData - "oracle" (sdk.Msg interface).

func (*MsgReportData) Size 

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

func (*MsgReportData) String 

func (m *MsgReportData) String() string

func (MsgReportData) Type 

func (msg MsgReportData) Type() string

Type returns the message type of MsgReportData (sdk.Msg interface).

func (*MsgReportData) Unmarshal 

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

func (MsgReportData) ValidateBasic 

func (msg MsgReportData) ValidateBasic() error

ValidateBasic checks whether the given MsgReportData instance (sdk.Msg interface).

func (*MsgReportData) XXX_DiscardUnknown 

func (m *MsgReportData) XXX_DiscardUnknown()

func (*MsgReportData) XXX_Marshal 

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

func (*MsgReportData) XXX_Merge 

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

func (*MsgReportData) XXX_Size 

func (m *MsgReportData) XXX_Size() int

func (*MsgReportData) XXX_Unmarshal 

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

type MsgReportDataResponse 

type MsgReportDataResponse struct {
}

MsgReportDataResponse

func (*MsgReportDataResponse) Descriptor 

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

func (*MsgReportDataResponse) Marshal 

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

func (*MsgReportDataResponse) MarshalTo 

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

func (*MsgReportDataResponse) MarshalToSizedBuffer 

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

func (*MsgReportDataResponse) ProtoMessage 

func (*MsgReportDataResponse) ProtoMessage()

func (*MsgReportDataResponse) Reset 

func (m *MsgReportDataResponse) Reset()

func (*MsgReportDataResponse) Size 

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

func (*MsgReportDataResponse) String 

func (m *MsgReportDataResponse) String() string

func (*MsgReportDataResponse) Unmarshal 

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

func (*MsgReportDataResponse) XXX_DiscardUnknown 

func (m *MsgReportDataResponse) XXX_DiscardUnknown()

func (*MsgReportDataResponse) XXX_Marshal 

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

func (*MsgReportDataResponse) XXX_Merge 

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

func (*MsgReportDataResponse) XXX_Size 

func (m *MsgReportDataResponse) XXX_Size() int

func (*MsgReportDataResponse) XXX_Unmarshal 

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

type MsgRequestData 

type MsgRequestData struct {
	// OracleScriptID is the identifier of the oracle script to call.
	OracleScriptID OracleScriptID `` /* 130-byte string literal not displayed */
	// Calldata is the OBI encoded call parameters to the oracle script.
	Calldata []byte `protobuf:"bytes,2,opt,name=calldata,proto3" json:"calldata,omitempty"`
	// AskCount is the number of validators to perform the oracle task.
	AskCount uint64 `protobuf:"varint,3,opt,name=ask_count,json=askCount,proto3" json:"ask_count,omitempty"`
	// MinCount is the minimum number of validators sufficient to resolve the
	// tasks.
	MinCount uint64 `protobuf:"varint,4,opt,name=min_count,json=minCount,proto3" json:"min_count,omitempty"`
	// ClientID is the client-provided unique identifier to tracking the request.
	ClientID string `protobuf:"bytes,5,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// FeeLimit is the maximum tokens that will be paid to all data source
	// providers.
	FeeLimit github_com_cosmos_cosmos_sdk_types.Coins `` /* 129-byte string literal not displayed */
	// PrepareGas is amount of gas to pay to prepare raw requests
	PrepareGas uint64 `protobuf:"varint,7,opt,name=prepare_gas,json=prepareGas,proto3" json:"prepare_gas,omitempty"`
	// ExecuteGas is amount of gas to reserve for executing
	ExecuteGas uint64 `protobuf:"varint,8,opt,name=execute_gas,json=executeGas,proto3" json:"execute_gas,omitempty"`
	// Sender is the sender of this message.
	Sender string `protobuf:"bytes,9,opt,name=sender,proto3" json:"sender,omitempty"`
}

MsgRequestData is a message for sending a data oracle request.

func NewMsgRequestData 

func NewMsgRequestData(
	oracleScriptID OracleScriptID,
	calldata []byte,
	askCount, minCount uint64,
	clientID string,
	feeLimit sdk.Coins,
	prepareGas, executeGas uint64,
	sender sdk.AccAddress,
) *MsgRequestData

NewMsgRequestData creates a new MsgRequestData instance.

func (*MsgRequestData) Descriptor 

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

func (*MsgRequestData) Equal 

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

func (*MsgRequestData) GetAskCount 

func (m *MsgRequestData) GetAskCount() uint64

func (*MsgRequestData) GetCalldata 

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

func (*MsgRequestData) GetClientID 

func (m *MsgRequestData) GetClientID() string

func (*MsgRequestData) GetExecuteGas 

func (m *MsgRequestData) GetExecuteGas() uint64

func (*MsgRequestData) GetFeeLimit 

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

func (*MsgRequestData) GetMinCount 

func (m *MsgRequestData) GetMinCount() uint64

func (*MsgRequestData) GetOracleScriptID 

func (m *MsgRequestData) GetOracleScriptID() OracleScriptID

func (*MsgRequestData) GetPrepareGas 

func (m *MsgRequestData) GetPrepareGas() uint64

func (*MsgRequestData) GetSender 

func (m *MsgRequestData) GetSender() string

func (MsgRequestData) GetSignBytes 

func (msg MsgRequestData) GetSignBytes() []byte

GetSignBytes returns raw JSON bytes to be signed by the signers (sdk.Msg interface).

func (MsgRequestData) GetSigners 

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

GetSigners returns the required signers for the given MsgRequestData (sdk.Msg interface).

func (*MsgRequestData) Marshal 

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

func (*MsgRequestData) MarshalTo 

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

func (*MsgRequestData) MarshalToSizedBuffer 

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

func (*MsgRequestData) ProtoMessage 

func (*MsgRequestData) ProtoMessage()

func (*MsgRequestData) Reset 

func (m *MsgRequestData) Reset()

func (MsgRequestData) Route 

func (msg MsgRequestData) Route() string

Route returns the route of MsgRequestData - "oracle" (sdk.Msg interface).

func (*MsgRequestData) Size 

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

func (*MsgRequestData) String 

func (m *MsgRequestData) String() string

func (MsgRequestData) Type 

func (msg MsgRequestData) Type() string

Type returns the message type of MsgRequestData (sdk.Msg interface).

func (*MsgRequestData) Unmarshal 

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

func (MsgRequestData) ValidateBasic 

func (msg MsgRequestData) ValidateBasic() error

ValidateBasic checks whether the given MsgRequestData instance (sdk.Msg interface).

func (*MsgRequestData) XXX_DiscardUnknown 

func (m *MsgRequestData) XXX_DiscardUnknown()

func (*MsgRequestData) XXX_Marshal 

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

func (*MsgRequestData) XXX_Merge 

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

func (*MsgRequestData) XXX_Size 

func (m *MsgRequestData) XXX_Size() int

func (*MsgRequestData) XXX_Unmarshal 

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

type MsgRequestDataResponse 

type MsgRequestDataResponse struct {
}

MsgRequestDataResponse

func (*MsgRequestDataResponse) Descriptor 

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

func (*MsgRequestDataResponse) Marshal 

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

func (*MsgRequestDataResponse) MarshalTo 

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

func (*MsgRequestDataResponse) MarshalToSizedBuffer 

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

func (*MsgRequestDataResponse) ProtoMessage 

func (*MsgRequestDataResponse) ProtoMessage()

func (*MsgRequestDataResponse) Reset 

func (m *MsgRequestDataResponse) Reset()

func (*MsgRequestDataResponse) Size 

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

func (*MsgRequestDataResponse) String 

func (m *MsgRequestDataResponse) String() string

func (*MsgRequestDataResponse) Unmarshal 

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

func (*MsgRequestDataResponse) XXX_DiscardUnknown 

func (m *MsgRequestDataResponse) XXX_DiscardUnknown()

func (*MsgRequestDataResponse) XXX_Marshal 

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

func (*MsgRequestDataResponse) XXX_Merge 

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

func (*MsgRequestDataResponse) XXX_Size 

func (m *MsgRequestDataResponse) XXX_Size() int

func (*MsgRequestDataResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// RequestData defines a method for requesting a new request.
	RequestData(context.Context, *MsgRequestData) (*MsgRequestDataResponse, error)
	// ReportData defines a method for reporting a data to resolving the request.
	ReportData(context.Context, *MsgReportData) (*MsgReportDataResponse, error)
	// CreateDataSource defines a method for creating a new data source.
	CreateDataSource(context.Context, *MsgCreateDataSource) (*MsgCreateDataSourceResponse, error)
	// EditDataSource defines a method for editing an existing data source.
	EditDataSource(context.Context, *MsgEditDataSource) (*MsgEditDataSourceResponse, error)
	// CreateOracleScript defines a method for creating a new oracle script.
	CreateOracleScript(context.Context, *MsgCreateOracleScript) (*MsgCreateOracleScriptResponse, error)
	// EditOracleScript defines a method for editing an existing oracle script.
	EditOracleScript(context.Context, *MsgEditOracleScript) (*MsgEditOracleScriptResponse, error)
	// Activate defines a method for applying to be an oracle validator.
	Activate(context.Context, *MsgActivate) (*MsgActivateResponse, error)
	// AddReporter defines a method for adding a new reporter for a validator.
	AddReporter(context.Context, *MsgAddReporter) (*MsgAddReporterResponse, error)
	// RemoveReporter defines a method for TODO
	RemoveReporter(context.Context, *MsgRemoveReporter) (*MsgRemoveReporterResponse, error)
}

MsgServer is the server API for Msg service.

type OraclePool 

type OraclePool struct {
	DataProvidersPool github_com_cosmos_cosmos_sdk_types.Coins `` /* 158-byte string literal not displayed */
}

func InitialOraclePool 

func InitialOraclePool() OraclePool

InitialOraclePool returns zero oracle pool

func (*OraclePool) Descriptor 

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

func (*OraclePool) Equal 

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

func (*OraclePool) GetDataProvidersPool 

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

func (*OraclePool) Marshal 

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

func (*OraclePool) MarshalTo 

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

func (*OraclePool) MarshalToSizedBuffer 

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

func (*OraclePool) ProtoMessage 

func (*OraclePool) ProtoMessage()

func (*OraclePool) Reset 

func (m *OraclePool) Reset()

func (*OraclePool) Size 

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

func (*OraclePool) String 

func (m *OraclePool) String() string

func (*OraclePool) Unmarshal 

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

func (OraclePool) ValidateGenesis 

func (f OraclePool) ValidateGenesis() error

ValidateGenesis validates the oracle pool for a genesis state

func (*OraclePool) XXX_DiscardUnknown 

func (m *OraclePool) XXX_DiscardUnknown()

func (*OraclePool) XXX_Marshal 

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

func (*OraclePool) XXX_Merge 

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

func (*OraclePool) XXX_Size 

func (m *OraclePool) XXX_Size() int

func (*OraclePool) XXX_Unmarshal 

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

type OracleRequestPacketAcknowledgement 

type OracleRequestPacketAcknowledgement struct {
	// RequestID is BandChain's unique identifier for this oracle request.
	RequestID RequestID `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3,casttype=RequestID" json:"request_id,omitempty"`
}

OracleRequestPacketAcknowledgement encodes an oracle request acknowledgement send back to requester chain.

func NewOracleRequestPacketAcknowledgement 

func NewOracleRequestPacketAcknowledgement(requestID RequestID) *OracleRequestPacketAcknowledgement

func (*OracleRequestPacketAcknowledgement) Descriptor 

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

func (*OracleRequestPacketAcknowledgement) Equal 

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

func (*OracleRequestPacketAcknowledgement) GetRequestID 

func (m *OracleRequestPacketAcknowledgement) GetRequestID() RequestID

func (*OracleRequestPacketAcknowledgement) Marshal 

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

func (*OracleRequestPacketAcknowledgement) MarshalTo 

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

func (*OracleRequestPacketAcknowledgement) MarshalToSizedBuffer 

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

func (*OracleRequestPacketAcknowledgement) ProtoMessage 

func (*OracleRequestPacketAcknowledgement) ProtoMessage()

func (*OracleRequestPacketAcknowledgement) Reset 

func (m *OracleRequestPacketAcknowledgement) Reset()

func (*OracleRequestPacketAcknowledgement) Size 

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

func (*OracleRequestPacketAcknowledgement) String 

func (m *OracleRequestPacketAcknowledgement) String() string

func (*OracleRequestPacketAcknowledgement) Unmarshal 

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

func (*OracleRequestPacketAcknowledgement) XXX_DiscardUnknown 

func (m *OracleRequestPacketAcknowledgement) XXX_DiscardUnknown()

func (*OracleRequestPacketAcknowledgement) XXX_Marshal 

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

func (*OracleRequestPacketAcknowledgement) XXX_Merge 

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

func (*OracleRequestPacketAcknowledgement) XXX_Size 

func (m *OracleRequestPacketAcknowledgement) XXX_Size() int

func (*OracleRequestPacketAcknowledgement) XXX_Unmarshal 

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

type OracleRequestPacketData 

type OracleRequestPacketData struct {
	// ClientID is the unique identifier of this oracle request, as specified by
	// the client. This same unique ID will be sent back to the requester with the
	// oracle response.
	ClientID string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// OracleScriptID is the unique identifier of the oracle script to be
	// executed.
	OracleScriptID OracleScriptID `` /* 130-byte string literal not displayed */
	// Calldata is the calldata bytes available for oracle executor to read.
	Calldata []byte `protobuf:"bytes,3,opt,name=calldata,proto3" json:"calldata,omitempty"`
	// AskCount is the number of validators that are requested to respond to this
	// oracle request. Higher value means more security, at a higher gas cost.
	AskCount uint64 `protobuf:"varint,4,opt,name=ask_count,json=askCount,proto3" json:"ask_count,omitempty"`
	// MinCount is the minimum number of validators necessary for the request to
	// proceed to the execution phase. Higher value means more security, at the
	// cost of liveness.
	MinCount uint64 `protobuf:"varint,5,opt,name=min_count,json=minCount,proto3" json:"min_count,omitempty"`
	// FeeLimit is the maximum tokens that will be paid to all data source
	// providers.
	FeeLimit github_com_cosmos_cosmos_sdk_types.Coins `` /* 129-byte string literal not displayed */
	// RequestKey is the key from request chain to match data source fee payer on
	// Bandchain
	RequestKey string `protobuf:"bytes,7,opt,name=request_key,json=requestKey,proto3" json:"request_key,omitempty"`
	// PrepareGas is amount of gas to pay to prepare raw requests
	PrepareGas uint64 `protobuf:"varint,8,opt,name=prepare_gas,json=prepareGas,proto3" json:"prepare_gas,omitempty"`
	// ExecuteGas is amount of gas to reserve for executing
	ExecuteGas uint64 `protobuf:"varint,9,opt,name=execute_gas,json=executeGas,proto3" json:"execute_gas,omitempty"`
}

OracleRequestPacketData encodes an oracle request sent from other blockchains to BandChain.

func NewOracleRequestPacketData 

func NewOracleRequestPacketData(
	clientID string, oracleScriptID OracleScriptID, calldata []byte, askCount uint64, minCount uint64, feeLimit sdk.Coins, requestKey string,
) OracleRequestPacketData

NewOracleRequestPacketData contructs a new OracleRequestPacketData instance

func (*OracleRequestPacketData) Descriptor 

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

func (*OracleRequestPacketData) Equal 

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

func (*OracleRequestPacketData) GetAskCount 

func (m *OracleRequestPacketData) GetAskCount() uint64

func (OracleRequestPacketData) GetBytes 

func (p OracleRequestPacketData) GetBytes() []byte

GetBytes is a helper for serialising

func (*OracleRequestPacketData) GetCalldata 

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

func (*OracleRequestPacketData) GetClientID 

func (m *OracleRequestPacketData) GetClientID() string

func (*OracleRequestPacketData) GetExecuteGas 

func (m *OracleRequestPacketData) GetExecuteGas() uint64

func (*OracleRequestPacketData) GetFeeLimit 

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

func (*OracleRequestPacketData) GetMinCount 

func (m *OracleRequestPacketData) GetMinCount() uint64

func (*OracleRequestPacketData) GetOracleScriptID 

func (m *OracleRequestPacketData) GetOracleScriptID() OracleScriptID

func (*OracleRequestPacketData) GetPrepareGas 

func (m *OracleRequestPacketData) GetPrepareGas() uint64

func (*OracleRequestPacketData) GetRequestKey 

func (m *OracleRequestPacketData) GetRequestKey() string

func (*OracleRequestPacketData) Marshal 

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

func (*OracleRequestPacketData) MarshalTo 

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

func (*OracleRequestPacketData) MarshalToSizedBuffer 

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

func (*OracleRequestPacketData) ProtoMessage 

func (*OracleRequestPacketData) ProtoMessage()

func (*OracleRequestPacketData) Reset 

func (m *OracleRequestPacketData) Reset()

func (*OracleRequestPacketData) Size 

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

func (*OracleRequestPacketData) String 

func (m *OracleRequestPacketData) String() string

func (*OracleRequestPacketData) Unmarshal 

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

func (OracleRequestPacketData) ValidateBasic 

func (p OracleRequestPacketData) ValidateBasic() error

ValidateBasic is used for validating the request.

func (*OracleRequestPacketData) XXX_DiscardUnknown 

func (m *OracleRequestPacketData) XXX_DiscardUnknown()

func (*OracleRequestPacketData) XXX_Marshal 

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

func (*OracleRequestPacketData) XXX_Merge 

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

func (*OracleRequestPacketData) XXX_Size 

func (m *OracleRequestPacketData) XXX_Size() int

func (*OracleRequestPacketData) XXX_Unmarshal 

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

type OracleResponsePacketData 

type OracleResponsePacketData struct {
	// ClientID is the unique identifier matched with that of the oracle request
	// packet.
	ClientID string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// RequestID is BandChain's unique identifier for this oracle request.
	RequestID RequestID `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3,casttype=RequestID" json:"request_id,omitempty"`
	// AnsCount is the number of validators among to the asked validators that
	// actually responded to this oracle request prior to this oracle request
	// being resolved.
	AnsCount uint64 `protobuf:"varint,3,opt,name=ans_count,json=ansCount,proto3" json:"ans_count,omitempty"`
	// RequestTime is the UNIX epoch time at which the request was sent to
	// BandChain.
	RequestTime int64 `protobuf:"varint,4,opt,name=request_time,json=requestTime,proto3" json:"request_time,omitempty"`
	// ResolveTime is the UNIX epoch time at which the request was resolved to the
	// final result.
	ResolveTime int64 `protobuf:"varint,5,opt,name=resolve_time,json=resolveTime,proto3" json:"resolve_time,omitempty"`
	// ResolveStatus is the status of this oracle request, which can be OK,
	// FAILURE, or EXPIRED.
	ResolveStatus ResolveStatus `` /* 130-byte string literal not displayed */
	// Result is the final aggregated value only available if status if OK.
	Result []byte `protobuf:"bytes,7,opt,name=result,proto3" json:"result,omitempty"`
}

OracleResponsePacketData encodes an oracle response from BandChain to the requester.

func NewOracleResponsePacketData 

func NewOracleResponsePacketData(
	clientID string, requestID RequestID, ansCount uint64, requestTime int64,
	resolveTime int64, resolveStatus ResolveStatus, result []byte,
) OracleResponsePacketData

NewOracleResponsePacketData contructs a new OracleResponsePacketData instance

func (*OracleResponsePacketData) Descriptor 

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

func (*OracleResponsePacketData) Equal 

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

func (*OracleResponsePacketData) GetAnsCount 

func (m *OracleResponsePacketData) GetAnsCount() uint64

func (OracleResponsePacketData) GetBytes 

func (p OracleResponsePacketData) GetBytes() []byte

GetBytes returns the bytes representation of this oracle response packet data.

func (*OracleResponsePacketData) GetClientID 

func (m *OracleResponsePacketData) GetClientID() string

func (*OracleResponsePacketData) GetRequestID 

func (m *OracleResponsePacketData) GetRequestID() RequestID

func (*OracleResponsePacketData) GetRequestTime 

func (m *OracleResponsePacketData) GetRequestTime() int64

func (*OracleResponsePacketData) GetResolveStatus 

func (m *OracleResponsePacketData) GetResolveStatus() ResolveStatus

func (*OracleResponsePacketData) GetResolveTime 

func (m *OracleResponsePacketData) GetResolveTime() int64

func (*OracleResponsePacketData) GetResult 

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

func (*OracleResponsePacketData) Marshal 

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

func (*OracleResponsePacketData) MarshalTo 

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

func (*OracleResponsePacketData) MarshalToSizedBuffer 

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

func (*OracleResponsePacketData) ProtoMessage 

func (*OracleResponsePacketData) ProtoMessage()

func (*OracleResponsePacketData) Reset 

func (m *OracleResponsePacketData) Reset()

func (*OracleResponsePacketData) Size 

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

func (*OracleResponsePacketData) String 

func (m *OracleResponsePacketData) String() string

func (*OracleResponsePacketData) Unmarshal 

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

func (*OracleResponsePacketData) XXX_DiscardUnknown 

func (m *OracleResponsePacketData) XXX_DiscardUnknown()

func (*OracleResponsePacketData) XXX_Marshal 

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

func (*OracleResponsePacketData) XXX_Merge 

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

func (*OracleResponsePacketData) XXX_Size 

func (m *OracleResponsePacketData) XXX_Size() int

func (*OracleResponsePacketData) XXX_Unmarshal 

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

type OracleScript 

type OracleScript struct {
	ID            OracleScriptID `protobuf:"varint,1,opt,name=id,proto3,casttype=OracleScriptID" json:"id,omitempty"`
	Owner         string         `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	Name          string         `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Description   string         `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Filename      string         `protobuf:"bytes,5,opt,name=filename,proto3" json:"filename,omitempty"`
	Schema        string         `protobuf:"bytes,6,opt,name=schema,proto3" json:"schema,omitempty"`
	SourceCodeURL string         `protobuf:"bytes,7,opt,name=source_code_url,json=sourceCodeUrl,proto3" json:"source_code_url,omitempty"`
}

OracleScript is the data structure for storing oracle scripts in the storage.

func NewOracleScript 

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

func (*OracleScript) Descriptor 

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

func (*OracleScript) Equal 

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

func (*OracleScript) GetDescription 

func (m *OracleScript) GetDescription() string

func (*OracleScript) GetFilename 

func (m *OracleScript) GetFilename() string

func (*OracleScript) GetID 

func (m *OracleScript) GetID() OracleScriptID

func (*OracleScript) GetName 

func (m *OracleScript) GetName() string

func (*OracleScript) GetOwner 

func (m *OracleScript) GetOwner() string

func (*OracleScript) GetSchema 

func (m *OracleScript) GetSchema() string

func (*OracleScript) GetSourceCodeURL 

func (m *OracleScript) GetSourceCodeURL() string

func (*OracleScript) Marshal 

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

func (*OracleScript) MarshalTo 

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

func (*OracleScript) MarshalToSizedBuffer 

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

func (*OracleScript) ProtoMessage 

func (*OracleScript) ProtoMessage()

func (*OracleScript) Reset 

func (m *OracleScript) Reset()

func (*OracleScript) Size 

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

func (*OracleScript) String 

func (m *OracleScript) String() string

func (*OracleScript) Unmarshal 

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

func (*OracleScript) XXX_DiscardUnknown 

func (m *OracleScript) XXX_DiscardUnknown()

func (*OracleScript) XXX_Marshal 

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

func (*OracleScript) XXX_Merge 

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

func (*OracleScript) XXX_Size 

func (m *OracleScript) XXX_Size() int

func (*OracleScript) XXX_Unmarshal 

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

type OracleScriptID 

type OracleScriptID int64

OracleScriptID is the type-safe unique identifier type for oracle scripts.

type Params 

type Params struct {
	// MaxRawRequestCount is the maximum number of data source raw requests a
	// request can make.
	MaxRawRequestCount uint64 `protobuf:"varint,1,opt,name=max_raw_request_count,json=maxRawRequestCount,proto3" json:"max_raw_request_count,omitempty"`
	// MaxAskCount is the maximum number of validators a request can target.
	MaxAskCount uint64 `protobuf:"varint,2,opt,name=max_ask_count,json=maxAskCount,proto3" json:"max_ask_count,omitempty"`
	// ExpirationBlockCount is the number of blocks a request stays valid before
	// it gets expired due to insufficient reports.
	ExpirationBlockCount uint64 `protobuf:"varint,3,opt,name=expiration_block_count,json=expirationBlockCount,proto3" json:"expiration_block_count,omitempty"`
	// BaseOwasmGas is the base amount of Cosmos-SDK gas charged for owasm
	// execution.
	BaseOwasmGas uint64 `protobuf:"varint,4,opt,name=base_owasm_gas,json=baseOwasmGas,proto3" json:"base_owasm_gas,omitempty"`
	// PerValidatorRequestGas is the amount of Cosmos-SDK gas charged per
	// requested validator.
	PerValidatorRequestGas uint64 `` /* 132-byte string literal not displayed */
	// SamplingTryCount the number of validator sampling tries to pick the highest
	// voting power subset of validators to perform an oracle task.
	SamplingTryCount uint64 `protobuf:"varint,6,opt,name=sampling_try_count,json=samplingTryCount,proto3" json:"sampling_try_count,omitempty"`
	// OracleRewardPercentage is the percentage of block rewards allocated to
	// active oracle validators.
	OracleRewardPercentage uint64 `` /* 130-byte string literal not displayed */
	// InactivePenaltyDuration is the duration period where a validator cannot
	// activate back after missing an oracle report.
	InactivePenaltyDuration uint64 `` /* 133-byte string literal not displayed */
	// MaxDataSize is the maximum number of bytes that can be present in the
	// report as the result
	MaxDataSize uint64 `protobuf:"varint,9,opt,name=max_data_size,json=maxDataSize,proto3" json:"max_data_size,omitempty"`
	// MaxCalldataSize is the maximum number of bytes that can be present in the
	// calldata
	MaxCalldataSize uint64 `protobuf:"varint,10,opt,name=max_calldata_size,json=maxCalldataSize,proto3" json:"max_calldata_size,omitempty"`
	// DataProviderRewardPerByte is the amount of tokens, user gets for the byte
	// of data provided
	DataProviderRewardPerByte github_com_cosmos_cosmos_sdk_types.Coins `` /* 187-byte string literal not displayed */
	// DataProviderRewardThreshold is the maximum amount of tokens that can be
	// paid for data per time
	DataProviderRewardThreshold RewardThreshold `` /* 137-byte string literal not displayed */
	// RewardDecreasingFraction is the percentage by which the cost of data per
	// byte is reduced when the limit is reached
	RewardDecreasingFraction github_com_cosmos_cosmos_sdk_types.Dec `` /* 176-byte string literal not displayed */
	// Denominations that can be used for withdrawing fee from data requesters
	DataRequesterFeeDenoms []string `` /* 132-byte string literal not displayed */
	// MaxReportDataSize is the maximum size limit of report data (bytes) in a
	// report.
	MaxReportDataSize uint64 `protobuf:"varint,15,opt,name=max_report_data_size,json=maxReportDataSize,proto3" json:"max_report_data_size,omitempty"`
}

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

func DefaultParams 

func DefaultParams() Params

DefaultParams defines the default parameters.

func NewParams 

func NewParams(
	maxRawRequestCount, maxAskCount, expirationBlockCount, baseRequestGas, perValidatorRequestGas,
	samplingTryCount, oracleRewardPercentage, inactivePenaltyDuration, maxDataSize, maxCallDataSize uint64,
	dataProviderRewardPerByte sdk.Coins, dataProviderRewardThreshold RewardThreshold, rewardDecreasingFraction sdk.Dec,
	dataRequesterFeeDenoms []string, maxReportDataSize uint64,
) Params

NewParams creates a new parameter configuration for the oracle module

func (*Params) Descriptor 

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

func (*Params) Equal 

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

func (*Params) GetBaseOwasmGas 

func (m *Params) GetBaseOwasmGas() uint64

func (*Params) GetDataProviderRewardPerByte 

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

func (*Params) GetDataProviderRewardThreshold 

func (m *Params) GetDataProviderRewardThreshold() RewardThreshold

func (*Params) GetDataRequesterFeeDenoms 

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

func (*Params) GetExpirationBlockCount 

func (m *Params) GetExpirationBlockCount() uint64

func (*Params) GetInactivePenaltyDuration 

func (m *Params) GetInactivePenaltyDuration() uint64

func (*Params) GetMaxAskCount 

func (m *Params) GetMaxAskCount() uint64

func (*Params) GetMaxCalldataSize 

func (m *Params) GetMaxCalldataSize() uint64

func (*Params) GetMaxDataSize 

func (m *Params) GetMaxDataSize() uint64

func (*Params) GetMaxRawRequestCount 

func (m *Params) GetMaxRawRequestCount() uint64

func (*Params) GetMaxReportDataSize added in v0.7.2 

func (m *Params) GetMaxReportDataSize() uint64

func (*Params) GetOracleRewardPercentage 

func (m *Params) GetOracleRewardPercentage() uint64

func (*Params) GetPerValidatorRequestGas 

func (m *Params) GetPerValidatorRequestGas() uint64

func (*Params) GetSamplingTryCount 

func (m *Params) GetSamplingTryCount() uint64

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

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

ParamSetPairs implements the paramtypes.ParamSet interface for Params.

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (Params) String 

func (p Params) String() string

String returns a human readable string representation of the parameters.

func (*Params) Unmarshal 

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

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type PendingResolveList 

type PendingResolveList struct {
	RequestIds []int64 `protobuf:"varint,1,rep,packed,name=request_ids,json=requestIds,proto3" json:"request_ids,omitempty"`
}

PendingResolveList

func (*PendingResolveList) Descriptor 

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

func (*PendingResolveList) Equal 

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

func (*PendingResolveList) GetRequestIds 

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

func (*PendingResolveList) Marshal 

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

func (*PendingResolveList) MarshalTo 

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

func (*PendingResolveList) MarshalToSizedBuffer 

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

func (*PendingResolveList) ProtoMessage 

func (*PendingResolveList) ProtoMessage()

func (*PendingResolveList) Reset 

func (m *PendingResolveList) Reset()

func (*PendingResolveList) Size 

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

func (*PendingResolveList) String 

func (m *PendingResolveList) String() string

func (*PendingResolveList) Unmarshal 

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

func (*PendingResolveList) XXX_DiscardUnknown 

func (m *PendingResolveList) XXX_DiscardUnknown()

func (*PendingResolveList) XXX_Marshal 

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

func (*PendingResolveList) XXX_Merge 

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

func (*PendingResolveList) XXX_Size 

func (m *PendingResolveList) XXX_Size() int

func (*PendingResolveList) XXX_Unmarshal 

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

type PortKeeper 

type PortKeeper interface {
	BindPort(ctx sdk.Context, portID string) *capabilitytypes.Capability
}

PortKeeper defines the expected IBC port keeper

type PrepareEnv 

type PrepareEnv struct {
	BaseEnv
	// contains filtered or unexported fields
}

PrepareEnv implements ExecEnv interface only expected function and panic on non-prepare functions.

func NewPrepareEnv 

func NewPrepareEnv(req Request, maxCalldataSize int64, maxRawRequests int64) *PrepareEnv

NewPrepareEnv creates a new environment instance for prepare period.

func (*PrepareEnv) AskExternalData 

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

AskExternalData implements Owasm ExecEnv interface.

func (*PrepareEnv) GetRawRequests 

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

GetRawRequests returns the list of raw requests made during Owasm prepare run.

type QueryActiveValidatorResult 

type QueryActiveValidatorResult struct {
	Address sdk.ValAddress `json:"address"`
	Power   uint64         `json:"power"`
}

deprecated: for legacy REST use only QueryActiveValidatorResult is the struct for the result of request active validators.

type QueryActiveValidatorsRequest 

type QueryActiveValidatorsRequest struct {
}

QueryActiveValidatorsRequest is request type for the Query/ActiveValidators RPC method.

func (*QueryActiveValidatorsRequest) Descriptor 

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

func (*QueryActiveValidatorsRequest) Marshal 

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

func (*QueryActiveValidatorsRequest) MarshalTo 

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

func (*QueryActiveValidatorsRequest) MarshalToSizedBuffer 

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

func (*QueryActiveValidatorsRequest) ProtoMessage 

func (*QueryActiveValidatorsRequest) ProtoMessage()

func (*QueryActiveValidatorsRequest) Reset 

func (m *QueryActiveValidatorsRequest) Reset()

func (*QueryActiveValidatorsRequest) Size 

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

func (*QueryActiveValidatorsRequest) String 

func (m *QueryActiveValidatorsRequest) String() string

func (*QueryActiveValidatorsRequest) Unmarshal 

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

func (*QueryActiveValidatorsRequest) XXX_DiscardUnknown 

func (m *QueryActiveValidatorsRequest) XXX_DiscardUnknown()

func (*QueryActiveValidatorsRequest) XXX_Marshal 

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

func (*QueryActiveValidatorsRequest) XXX_Merge 

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

func (*QueryActiveValidatorsRequest) XXX_Size 

func (m *QueryActiveValidatorsRequest) XXX_Size() int

func (*QueryActiveValidatorsRequest) XXX_Unmarshal 

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

type QueryActiveValidatorsResponse 

type QueryActiveValidatorsResponse struct {
	Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
}

QueryActiveValidatorsResponse is response type for the Query/ActiveValidators RPC method.

func (*QueryActiveValidatorsResponse) Descriptor 

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

func (*QueryActiveValidatorsResponse) GetCount 

func (m *QueryActiveValidatorsResponse) GetCount() int64

func (*QueryActiveValidatorsResponse) Marshal 

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

func (*QueryActiveValidatorsResponse) MarshalTo 

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

func (*QueryActiveValidatorsResponse) MarshalToSizedBuffer 

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

func (*QueryActiveValidatorsResponse) ProtoMessage 

func (*QueryActiveValidatorsResponse) ProtoMessage()

func (*QueryActiveValidatorsResponse) Reset 

func (m *QueryActiveValidatorsResponse) Reset()

func (*QueryActiveValidatorsResponse) Size 

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

func (*QueryActiveValidatorsResponse) String 

func (m *QueryActiveValidatorsResponse) String() string

func (*QueryActiveValidatorsResponse) Unmarshal 

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

func (*QueryActiveValidatorsResponse) XXX_DiscardUnknown 

func (m *QueryActiveValidatorsResponse) XXX_DiscardUnknown()

func (*QueryActiveValidatorsResponse) XXX_Marshal 

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

func (*QueryActiveValidatorsResponse) XXX_Merge 

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

func (*QueryActiveValidatorsResponse) XXX_Size 

func (m *QueryActiveValidatorsResponse) XXX_Size() int

func (*QueryActiveValidatorsResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Counts queries the number of data sources, oracle scripts, and requests.
	Counts(ctx context.Context, in *QueryCountsRequest, opts ...grpc.CallOption) (*QueryCountsResponse, error)
	// Data queries the data source or oracle script script for given file hash.
	Data(ctx context.Context, in *QueryDataRequest, opts ...grpc.CallOption) (*QueryDataResponse, error)
	// DataSource queries data source info for given data source id.
	DataSource(ctx context.Context, in *QueryDataSourceRequest, opts ...grpc.CallOption) (*QueryDataSourceResponse, error)
	// DataSources queries data sources info.
	DataSources(ctx context.Context, in *QueryDataSourcesRequest, opts ...grpc.CallOption) (*QueryDataSourcesResponse, error)
	// OracleScript queries oracle script info for given oracle script id.
	OracleScript(ctx context.Context, in *QueryOracleScriptRequest, opts ...grpc.CallOption) (*QueryOracleScriptResponse, error)
	// OracleScripts queries all oracle scripts with pagination.
	OracleScripts(ctx context.Context, in *QueryOracleScriptsRequest, opts ...grpc.CallOption) (*QueryOracleScriptsResponse, error)
	// Request queries request info for given request id.
	Request(ctx context.Context, in *QueryRequestRequest, opts ...grpc.CallOption) (*QueryRequestResponse, error)
	// Requests queries all requests with pagination.
	Requests(ctx context.Context, in *QueryRequestsRequest, opts ...grpc.CallOption) (*QueryRequestsResponse, error)
	// Validator queries oracle info of validator for given validator address.
	Validator(ctx context.Context, in *QueryValidatorRequest, opts ...grpc.CallOption) (*QueryValidatorResponse, error)
	// IsReporter queries grant of account on this validator.
	IsReporter(ctx context.Context, in *QueryIsReporterRequest, opts ...grpc.CallOption) (*QueryIsReporterResponse, error)
	// Reporters queries all reporters of a given validator address.
	Reporters(ctx context.Context, in *QueryReportersRequest, opts ...grpc.CallOption) (*QueryReportersResponse, error)
	// ActiveValidators queries all active oracle validators.
	ActiveValidators(ctx context.Context, in *QueryActiveValidatorsRequest, opts ...grpc.CallOption) (*QueryActiveValidatorsResponse, error)
	// Params queries the oracle parameters.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// RequestSearch queries the latest request that match the given input.
	RequestSearch(ctx context.Context, in *QueryRequestSearchRequest, opts ...grpc.CallOption) (*QueryRequestSearchResponse, error)
	// RequestPrice queries the latest price on standard price reference oracle
	// script.
	RequestPrice(ctx context.Context, in *QueryRequestPriceRequest, opts ...grpc.CallOption) (*QueryRequestPriceResponse, error)
	DataProvidersPool(ctx context.Context, in *QueryDataProvidersPoolRequest, opts ...grpc.CallOption) (*QueryDataProvidersPoolResponse, error)
	RequestReports(ctx context.Context, in *QueryRequestReportsRequest, opts ...grpc.CallOption) (*QueryRequestReportsResponse, error)
	DataProviderReward(ctx context.Context, in *QueryDataProviderRewardRequest, opts ...grpc.CallOption) (*QueryDataProviderRewardResponse, error)
	// PendingRequests queries list of pending request IDs assigned to given
	// validator.
	PendingRequests(ctx context.Context, in *QueryPendingRequestsRequest, opts ...grpc.CallOption) (*QueryPendingRequestsResponse, error)
	// RequestVerification verifies a request to make sure that
	// all information that will be used to report the data is valid
	RequestVerification(ctx context.Context, in *QueryRequestVerificationRequest, opts ...grpc.CallOption) (*QueryRequestVerificationResponse, error)
	// DataProviderAccumulatedReward queries oracle info of reporter rewards for
	// given reporter address.
	DataProviderAccumulatedReward(ctx context.Context, in *QueryDataProviderAccumulatedRewardRequest, opts ...grpc.CallOption) (*QueryDataProviderAccumulatedRewardResponse, error)
}

QueryClient is the client API for Query service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryClient 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryCountsRequest 

type QueryCountsRequest struct {
}

QueryCountsRequest is request type for the Query/Count RPC method.

func (*QueryCountsRequest) Descriptor 

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

func (*QueryCountsRequest) Marshal 

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

func (*QueryCountsRequest) MarshalTo 

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

func (*QueryCountsRequest) MarshalToSizedBuffer 

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

func (*QueryCountsRequest) ProtoMessage 

func (*QueryCountsRequest) ProtoMessage()

func (*QueryCountsRequest) Reset 

func (m *QueryCountsRequest) Reset()

func (*QueryCountsRequest) Size 

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

func (*QueryCountsRequest) String 

func (m *QueryCountsRequest) String() string

func (*QueryCountsRequest) Unmarshal 

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

func (*QueryCountsRequest) XXX_DiscardUnknown 

func (m *QueryCountsRequest) XXX_DiscardUnknown()

func (*QueryCountsRequest) XXX_Marshal 

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

func (*QueryCountsRequest) XXX_Merge 

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

func (*QueryCountsRequest) XXX_Size 

func (m *QueryCountsRequest) XXX_Size() int

func (*QueryCountsRequest) XXX_Unmarshal 

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

type QueryCountsResponse 

type QueryCountsResponse struct {
	DataSourceCount   int64 `protobuf:"varint,1,opt,name=data_source_count,json=dataSourceCount,proto3" json:"data_source_count,omitempty"`
	OracleScriptCount int64 `protobuf:"varint,2,opt,name=oracle_script_count,json=oracleScriptCount,proto3" json:"oracle_script_count,omitempty"`
	RequestCount      int64 `protobuf:"varint,3,opt,name=request_count,json=requestCount,proto3" json:"request_count,omitempty"`
}

QueryCountsResponse is response type for the Query/Count RPC method.

func (*QueryCountsResponse) Descriptor 

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

func (*QueryCountsResponse) GetDataSourceCount 

func (m *QueryCountsResponse) GetDataSourceCount() int64

func (*QueryCountsResponse) GetOracleScriptCount 

func (m *QueryCountsResponse) GetOracleScriptCount() int64

func (*QueryCountsResponse) GetRequestCount 

func (m *QueryCountsResponse) GetRequestCount() int64

func (*QueryCountsResponse) Marshal 

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

func (*QueryCountsResponse) MarshalTo 

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

func (*QueryCountsResponse) MarshalToSizedBuffer 

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

func (*QueryCountsResponse) ProtoMessage 

func (*QueryCountsResponse) ProtoMessage()

func (*QueryCountsResponse) Reset 

func (m *QueryCountsResponse) Reset()

func (*QueryCountsResponse) Size 

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

func (*QueryCountsResponse) String 

func (m *QueryCountsResponse) String() string

func (*QueryCountsResponse) Unmarshal 

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

func (*QueryCountsResponse) XXX_DiscardUnknown 

func (m *QueryCountsResponse) XXX_DiscardUnknown()

func (*QueryCountsResponse) XXX_Marshal 

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

func (*QueryCountsResponse) XXX_Merge 

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

func (*QueryCountsResponse) XXX_Size 

func (m *QueryCountsResponse) XXX_Size() int

func (*QueryCountsResponse) XXX_Unmarshal 

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

type QueryDataProviderAccumulatedRewardRequest added in v0.5.4 

type QueryDataProviderAccumulatedRewardRequest struct {
	DataProviderAddress string `protobuf:"bytes,1,opt,name=data_provider_address,json=dataProviderAddress,proto3" json:"data_provider_address,omitempty"`
}

QueryDataProviderAccumulatedRewardRequest is request type for the Query/DataProviderAccumulatedReward RPC method.

func (*QueryDataProviderAccumulatedRewardRequest) Descriptor added in v0.5.4 

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

func (*QueryDataProviderAccumulatedRewardRequest) GetDataProviderAddress added in v0.5.4 

func (m *QueryDataProviderAccumulatedRewardRequest) GetDataProviderAddress() string

func (*QueryDataProviderAccumulatedRewardRequest) Marshal added in v0.5.4 

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

func (*QueryDataProviderAccumulatedRewardRequest) MarshalTo added in v0.5.4 

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

func (*QueryDataProviderAccumulatedRewardRequest) MarshalToSizedBuffer added in v0.5.4 

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

func (*QueryDataProviderAccumulatedRewardRequest) ProtoMessage added in v0.5.4 

func (*QueryDataProviderAccumulatedRewardRequest) ProtoMessage()

func (*QueryDataProviderAccumulatedRewardRequest) Reset added in v0.5.4 

func (m *QueryDataProviderAccumulatedRewardRequest) Reset()

func (*QueryDataProviderAccumulatedRewardRequest) Size added in v0.5.4 

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

func (*QueryDataProviderAccumulatedRewardRequest) String added in v0.5.4 

func (m *QueryDataProviderAccumulatedRewardRequest) String() string

func (*QueryDataProviderAccumulatedRewardRequest) Unmarshal added in v0.5.4 

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

func (*QueryDataProviderAccumulatedRewardRequest) XXX_DiscardUnknown added in v0.5.4 

func (m *QueryDataProviderAccumulatedRewardRequest) XXX_DiscardUnknown()

func (*QueryDataProviderAccumulatedRewardRequest) XXX_Marshal added in v0.5.4 

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

func (*QueryDataProviderAccumulatedRewardRequest) XXX_Merge added in v0.5.4 

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

func (*QueryDataProviderAccumulatedRewardRequest) XXX_Size added in v0.5.4 

func (m *QueryDataProviderAccumulatedRewardRequest) XXX_Size() int

func (*QueryDataProviderAccumulatedRewardRequest) XXX_Unmarshal added in v0.5.4 

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

type QueryDataProviderAccumulatedRewardResponse added in v0.5.4 

type QueryDataProviderAccumulatedRewardResponse struct {
	AccumulatedReward github_com_cosmos_cosmos_sdk_types.Coins `` /* 156-byte string literal not displayed */
}

QueryDataProviderAccumulatedRewardResponse is response type for the Query/DataProviderAccumulatedReward RPC method.

func (*QueryDataProviderAccumulatedRewardResponse) Descriptor added in v0.5.4 

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

func (*QueryDataProviderAccumulatedRewardResponse) GetAccumulatedReward added in v0.5.4 

func (m *QueryDataProviderAccumulatedRewardResponse) GetAccumulatedReward() github_com_cosmos_cosmos_sdk_types.Coins

func (*QueryDataProviderAccumulatedRewardResponse) Marshal added in v0.5.4 

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

func (*QueryDataProviderAccumulatedRewardResponse) MarshalTo added in v0.5.4 

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

func (*QueryDataProviderAccumulatedRewardResponse) MarshalToSizedBuffer added in v0.5.4 

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

func (*QueryDataProviderAccumulatedRewardResponse) ProtoMessage added in v0.5.4 

func (*QueryDataProviderAccumulatedRewardResponse) ProtoMessage()

func (*QueryDataProviderAccumulatedRewardResponse) Reset added in v0.5.4 

func (m *QueryDataProviderAccumulatedRewardResponse) Reset()

func (*QueryDataProviderAccumulatedRewardResponse) Size added in v0.5.4 

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

func (*QueryDataProviderAccumulatedRewardResponse) String added in v0.5.4 

func (m *QueryDataProviderAccumulatedRewardResponse) String() string

func (*QueryDataProviderAccumulatedRewardResponse) Unmarshal added in v0.5.4 

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

func (*QueryDataProviderAccumulatedRewardResponse) XXX_DiscardUnknown added in v0.5.4 

func (m *QueryDataProviderAccumulatedRewardResponse) XXX_DiscardUnknown()

func (*QueryDataProviderAccumulatedRewardResponse) XXX_Marshal added in v0.5.4 

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

func (*QueryDataProviderAccumulatedRewardResponse) XXX_Merge added in v0.5.4 

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

func (*QueryDataProviderAccumulatedRewardResponse) XXX_Size added in v0.5.4 

func (m *QueryDataProviderAccumulatedRewardResponse) XXX_Size() int

func (*QueryDataProviderAccumulatedRewardResponse) XXX_Unmarshal added in v0.5.4 

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

type QueryDataProviderRewardRequest 

type QueryDataProviderRewardRequest struct {
}

QueryDataProviderRewardRequest is request type for the Query/DataProviderReward RPC method.

func (*QueryDataProviderRewardRequest) Descriptor 

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

func (*QueryDataProviderRewardRequest) Marshal 

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

func (*QueryDataProviderRewardRequest) MarshalTo 

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

func (*QueryDataProviderRewardRequest) MarshalToSizedBuffer 

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

func (*QueryDataProviderRewardRequest) ProtoMessage 

func (*QueryDataProviderRewardRequest) ProtoMessage()

func (*QueryDataProviderRewardRequest) Reset 

func (m *QueryDataProviderRewardRequest) Reset()

func (*QueryDataProviderRewardRequest) Size 

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

func (*QueryDataProviderRewardRequest) String 

func (m *QueryDataProviderRewardRequest) String() string

func (*QueryDataProviderRewardRequest) Unmarshal 

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

func (*QueryDataProviderRewardRequest) XXX_DiscardUnknown 

func (m *QueryDataProviderRewardRequest) XXX_DiscardUnknown()

func (*QueryDataProviderRewardRequest) XXX_Marshal 

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

func (*QueryDataProviderRewardRequest) XXX_Merge 

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

func (*QueryDataProviderRewardRequest) XXX_Size 

func (m *QueryDataProviderRewardRequest) XXX_Size() int

func (*QueryDataProviderRewardRequest) XXX_Unmarshal 

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

type QueryDataProviderRewardResponse 

type QueryDataProviderRewardResponse struct {
	RewardPerByte github_com_cosmos_cosmos_sdk_types.Coins `` /* 146-byte string literal not displayed */
}

QueryDataProviderRewardResponse is response type for the Query/DataProviderReward RPC method.

func (*QueryDataProviderRewardResponse) Descriptor 

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

func (*QueryDataProviderRewardResponse) GetRewardPerByte 

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

func (*QueryDataProviderRewardResponse) Marshal 

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

func (*QueryDataProviderRewardResponse) MarshalTo 

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

func (*QueryDataProviderRewardResponse) MarshalToSizedBuffer 

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

func (*QueryDataProviderRewardResponse) ProtoMessage 

func (*QueryDataProviderRewardResponse) ProtoMessage()

func (*QueryDataProviderRewardResponse) Reset 

func (m *QueryDataProviderRewardResponse) Reset()

func (*QueryDataProviderRewardResponse) Size 

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

func (*QueryDataProviderRewardResponse) String 

func (m *QueryDataProviderRewardResponse) String() string

func (*QueryDataProviderRewardResponse) Unmarshal 

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

func (*QueryDataProviderRewardResponse) XXX_DiscardUnknown 

func (m *QueryDataProviderRewardResponse) XXX_DiscardUnknown()

func (*QueryDataProviderRewardResponse) XXX_Marshal 

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

func (*QueryDataProviderRewardResponse) XXX_Merge 

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

func (*QueryDataProviderRewardResponse) XXX_Size 

func (m *QueryDataProviderRewardResponse) XXX_Size() int

func (*QueryDataProviderRewardResponse) XXX_Unmarshal 

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

type QueryDataProvidersPoolRequest 

type QueryDataProvidersPoolRequest struct {
}

func (*QueryDataProvidersPoolRequest) Descriptor 

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

func (*QueryDataProvidersPoolRequest) Marshal 

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

func (*QueryDataProvidersPoolRequest) MarshalTo 

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

func (*QueryDataProvidersPoolRequest) MarshalToSizedBuffer 

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

func (*QueryDataProvidersPoolRequest) ProtoMessage 

func (*QueryDataProvidersPoolRequest) ProtoMessage()

func (*QueryDataProvidersPoolRequest) Reset 

func (m *QueryDataProvidersPoolRequest) Reset()

func (*QueryDataProvidersPoolRequest) Size 

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

func (*QueryDataProvidersPoolRequest) String 

func (m *QueryDataProvidersPoolRequest) String() string

func (*QueryDataProvidersPoolRequest) Unmarshal 

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

func (*QueryDataProvidersPoolRequest) XXX_DiscardUnknown 

func (m *QueryDataProvidersPoolRequest) XXX_DiscardUnknown()

func (*QueryDataProvidersPoolRequest) XXX_Marshal 

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

func (*QueryDataProvidersPoolRequest) XXX_Merge 

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

func (*QueryDataProvidersPoolRequest) XXX_Size 

func (m *QueryDataProvidersPoolRequest) XXX_Size() int

func (*QueryDataProvidersPoolRequest) XXX_Unmarshal 

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

type QueryDataProvidersPoolResponse 

type QueryDataProvidersPoolResponse struct {
	Pool github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,1,rep,name=pool,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"pool"`
}

QueryRequestPriceResponse is response type for the Query/RequestPrice RPC method.

func (*QueryDataProvidersPoolResponse) Descriptor 

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

func (*QueryDataProvidersPoolResponse) GetPool 

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

func (*QueryDataProvidersPoolResponse) Marshal 

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

func (*QueryDataProvidersPoolResponse) MarshalTo 

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

func (*QueryDataProvidersPoolResponse) MarshalToSizedBuffer 

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

func (*QueryDataProvidersPoolResponse) ProtoMessage 

func (*QueryDataProvidersPoolResponse) ProtoMessage()

func (*QueryDataProvidersPoolResponse) Reset 

func (m *QueryDataProvidersPoolResponse) Reset()

func (*QueryDataProvidersPoolResponse) Size 

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

func (*QueryDataProvidersPoolResponse) String 

func (m *QueryDataProvidersPoolResponse) String() string

func (*QueryDataProvidersPoolResponse) Unmarshal 

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

func (*QueryDataProvidersPoolResponse) XXX_DiscardUnknown 

func (m *QueryDataProvidersPoolResponse) XXX_DiscardUnknown()

func (*QueryDataProvidersPoolResponse) XXX_Marshal 

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

func (*QueryDataProvidersPoolResponse) XXX_Merge 

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

func (*QueryDataProvidersPoolResponse) XXX_Size 

func (m *QueryDataProvidersPoolResponse) XXX_Size() int

func (*QueryDataProvidersPoolResponse) XXX_Unmarshal 

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

type QueryDataRequest 

type QueryDataRequest struct {
	DataHash string `protobuf:"bytes,1,opt,name=data_hash,json=dataHash,proto3" json:"data_hash,omitempty"`
}

QueryDataRequest is request type for the Query/Data RPC method.

func (*QueryDataRequest) Descriptor 

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

func (*QueryDataRequest) GetDataHash 

func (m *QueryDataRequest) GetDataHash() string

func (*QueryDataRequest) Marshal 

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

func (*QueryDataRequest) MarshalTo 

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

func (*QueryDataRequest) MarshalToSizedBuffer 

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

func (*QueryDataRequest) ProtoMessage 

func (*QueryDataRequest) ProtoMessage()

func (*QueryDataRequest) Reset 

func (m *QueryDataRequest) Reset()

func (*QueryDataRequest) Size 

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

func (*QueryDataRequest) String 

func (m *QueryDataRequest) String() string

func (*QueryDataRequest) Unmarshal 

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

func (*QueryDataRequest) XXX_DiscardUnknown 

func (m *QueryDataRequest) XXX_DiscardUnknown()

func (*QueryDataRequest) XXX_Marshal 

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

func (*QueryDataRequest) XXX_Merge 

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

func (*QueryDataRequest) XXX_Size 

func (m *QueryDataRequest) XXX_Size() int

func (*QueryDataRequest) XXX_Unmarshal 

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

type QueryDataResponse 

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

QueryDataResponse is response type for the Query/Data RPC method.

func (*QueryDataResponse) Descriptor 

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

func (*QueryDataResponse) GetData 

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

func (*QueryDataResponse) Marshal 

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

func (*QueryDataResponse) MarshalTo 

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

func (*QueryDataResponse) MarshalToSizedBuffer 

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

func (*QueryDataResponse) ProtoMessage 

func (*QueryDataResponse) ProtoMessage()

func (*QueryDataResponse) Reset 

func (m *QueryDataResponse) Reset()

func (*QueryDataResponse) Size 

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

func (*QueryDataResponse) String 

func (m *QueryDataResponse) String() string

func (*QueryDataResponse) Unmarshal 

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

func (*QueryDataResponse) XXX_DiscardUnknown 

func (m *QueryDataResponse) XXX_DiscardUnknown()

func (*QueryDataResponse) XXX_Marshal 

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

func (*QueryDataResponse) XXX_Merge 

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

func (*QueryDataResponse) XXX_Size 

func (m *QueryDataResponse) XXX_Size() int

func (*QueryDataResponse) XXX_Unmarshal 

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

type QueryDataSourceRequest 

type QueryDataSourceRequest struct {
	DataSourceId int64 `protobuf:"varint,1,opt,name=data_source_id,json=dataSourceId,proto3" json:"data_source_id,omitempty"`
}

QueryDataSourceRequest is request type for the Query/DataSource RPC method.

func (*QueryDataSourceRequest) Descriptor 

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

func (*QueryDataSourceRequest) GetDataSourceId 

func (m *QueryDataSourceRequest) GetDataSourceId() int64

func (*QueryDataSourceRequest) Marshal 

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

func (*QueryDataSourceRequest) MarshalTo 

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

func (*QueryDataSourceRequest) MarshalToSizedBuffer 

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

func (*QueryDataSourceRequest) ProtoMessage 

func (*QueryDataSourceRequest) ProtoMessage()

func (*QueryDataSourceRequest) Reset 

func (m *QueryDataSourceRequest) Reset()

func (*QueryDataSourceRequest) Size 

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

func (*QueryDataSourceRequest) String 

func (m *QueryDataSourceRequest) String() string

func (*QueryDataSourceRequest) Unmarshal 

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

func (*QueryDataSourceRequest) XXX_DiscardUnknown 

func (m *QueryDataSourceRequest) XXX_DiscardUnknown()

func (*QueryDataSourceRequest) XXX_Marshal 

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

func (*QueryDataSourceRequest) XXX_Merge 

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

func (*QueryDataSourceRequest) XXX_Size 

func (m *QueryDataSourceRequest) XXX_Size() int

func (*QueryDataSourceRequest) XXX_Unmarshal 

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

type QueryDataSourceResponse 

type QueryDataSourceResponse struct {
	DataSource *DataSource `protobuf:"bytes,1,opt,name=data_source,json=dataSource,proto3" json:"data_source,omitempty"`
}

QueryDataSourceResponse is response type for the Query/DataSource RPC method.

func (*QueryDataSourceResponse) Descriptor 

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

func (*QueryDataSourceResponse) GetDataSource 

func (m *QueryDataSourceResponse) GetDataSource() *DataSource

func (*QueryDataSourceResponse) Marshal 

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

func (*QueryDataSourceResponse) MarshalTo 

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

func (*QueryDataSourceResponse) MarshalToSizedBuffer 

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

func (*QueryDataSourceResponse) ProtoMessage 

func (*QueryDataSourceResponse) ProtoMessage()

func (*QueryDataSourceResponse) Reset 

func (m *QueryDataSourceResponse) Reset()

func (*QueryDataSourceResponse) Size 

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

func (*QueryDataSourceResponse) String 

func (m *QueryDataSourceResponse) String() string

func (*QueryDataSourceResponse) Unmarshal 

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

func (*QueryDataSourceResponse) XXX_DiscardUnknown 

func (m *QueryDataSourceResponse) XXX_DiscardUnknown()

func (*QueryDataSourceResponse) XXX_Marshal 

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

func (*QueryDataSourceResponse) XXX_Merge 

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

func (*QueryDataSourceResponse) XXX_Size 

func (m *QueryDataSourceResponse) XXX_Size() int

func (*QueryDataSourceResponse) XXX_Unmarshal 

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

type QueryDataSourcesRequest 

type QueryDataSourcesRequest struct {
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryDataSourcesRequest is request type for the Query/DataSources RPC method.

func (*QueryDataSourcesRequest) Descriptor 

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

func (*QueryDataSourcesRequest) GetPagination 

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

func (*QueryDataSourcesRequest) Marshal 

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

func (*QueryDataSourcesRequest) MarshalTo 

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

func (*QueryDataSourcesRequest) MarshalToSizedBuffer 

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

func (*QueryDataSourcesRequest) ProtoMessage 

func (*QueryDataSourcesRequest) ProtoMessage()

func (*QueryDataSourcesRequest) Reset 

func (m *QueryDataSourcesRequest) Reset()

func (*QueryDataSourcesRequest) Size 

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

func (*QueryDataSourcesRequest) String 

func (m *QueryDataSourcesRequest) String() string

func (*QueryDataSourcesRequest) Unmarshal 

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

func (*QueryDataSourcesRequest) XXX_DiscardUnknown 

func (m *QueryDataSourcesRequest) XXX_DiscardUnknown()

func (*QueryDataSourcesRequest) XXX_Marshal 

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

func (*QueryDataSourcesRequest) XXX_Merge 

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

func (*QueryDataSourcesRequest) XXX_Size 

func (m *QueryDataSourcesRequest) XXX_Size() int

func (*QueryDataSourcesRequest) XXX_Unmarshal 

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

type QueryDataSourcesResponse 

type QueryDataSourcesResponse struct {
	DataSources []DataSource        `protobuf:"bytes,1,rep,name=data_sources,json=dataSources,proto3" json:"data_sources"`
	Pagination  *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryDataSourcesResponse is response type for the Query/DataSources RPC method.

func (*QueryDataSourcesResponse) Descriptor 

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

func (*QueryDataSourcesResponse) GetDataSources 

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

func (*QueryDataSourcesResponse) GetPagination 

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

func (*QueryDataSourcesResponse) Marshal 

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

func (*QueryDataSourcesResponse) MarshalTo 

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

func (*QueryDataSourcesResponse) MarshalToSizedBuffer 

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

func (*QueryDataSourcesResponse) ProtoMessage 

func (*QueryDataSourcesResponse) ProtoMessage()

func (*QueryDataSourcesResponse) Reset 

func (m *QueryDataSourcesResponse) Reset()

func (*QueryDataSourcesResponse) Size 

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

func (*QueryDataSourcesResponse) String 

func (m *QueryDataSourcesResponse) String() string

func (*QueryDataSourcesResponse) Unmarshal 

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

func (*QueryDataSourcesResponse) XXX_DiscardUnknown 

func (m *QueryDataSourcesResponse) XXX_DiscardUnknown()

func (*QueryDataSourcesResponse) XXX_Marshal 

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

func (*QueryDataSourcesResponse) XXX_Merge 

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

func (*QueryDataSourcesResponse) XXX_Size 

func (m *QueryDataSourcesResponse) XXX_Size() int

func (*QueryDataSourcesResponse) XXX_Unmarshal 

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

type QueryIsReporterRequest 

type QueryIsReporterRequest struct {
	// ValidatorAddress is a validator address
	ValidatorAddress string `protobuf:"bytes,1,opt,name=validator_address,json=validatorAddress,proto3" json:"validator_address,omitempty"`
	// ReporterAddress is a candidate account
	ReporterAddress string `protobuf:"bytes,2,opt,name=reporter_address,json=reporterAddress,proto3" json:"reporter_address,omitempty"`
}

QueryIsReporterRequest is request type for the Query/Reporter RPC method.

func (*QueryIsReporterRequest) Descriptor 

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

func (*QueryIsReporterRequest) GetReporterAddress 

func (m *QueryIsReporterRequest) GetReporterAddress() string

func (*QueryIsReporterRequest) GetValidatorAddress 

func (m *QueryIsReporterRequest) GetValidatorAddress() string

func (*QueryIsReporterRequest) Marshal 

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

func (*QueryIsReporterRequest) MarshalTo 

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

func (*QueryIsReporterRequest) MarshalToSizedBuffer 

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

func (*QueryIsReporterRequest) ProtoMessage 

func (*QueryIsReporterRequest) ProtoMessage()

func (*QueryIsReporterRequest) Reset 

func (m *QueryIsReporterRequest) Reset()

func (*QueryIsReporterRequest) Size 

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

func (*QueryIsReporterRequest) String 

func (m *QueryIsReporterRequest) String() string

func (*QueryIsReporterRequest) Unmarshal 

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

func (*QueryIsReporterRequest) XXX_DiscardUnknown 

func (m *QueryIsReporterRequest) XXX_DiscardUnknown()

func (*QueryIsReporterRequest) XXX_Marshal 

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

func (*QueryIsReporterRequest) XXX_Merge 

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

func (*QueryIsReporterRequest) XXX_Size 

func (m *QueryIsReporterRequest) XXX_Size() int

func (*QueryIsReporterRequest) XXX_Unmarshal 

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

type QueryIsReporterResponse 

type QueryIsReporterResponse struct {
	// IsReporter is true if this account has been granted by validator
	IsReporter bool `protobuf:"varint,1,opt,name=is_reporter,json=isReporter,proto3" json:"is_reporter,omitempty"`
}

QueryIsReporterResponse is response type for the Query/Reporter RPC method.

func (*QueryIsReporterResponse) Descriptor 

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

func (*QueryIsReporterResponse) GetIsReporter 

func (m *QueryIsReporterResponse) GetIsReporter() bool

func (*QueryIsReporterResponse) Marshal 

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

func (*QueryIsReporterResponse) MarshalTo 

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

func (*QueryIsReporterResponse) MarshalToSizedBuffer 

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

func (*QueryIsReporterResponse) ProtoMessage 

func (*QueryIsReporterResponse) ProtoMessage()

func (*QueryIsReporterResponse) Reset 

func (m *QueryIsReporterResponse) Reset()

func (*QueryIsReporterResponse) Size 

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

func (*QueryIsReporterResponse) String 

func (m *QueryIsReporterResponse) String() string

func (*QueryIsReporterResponse) Unmarshal 

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

func (*QueryIsReporterResponse) XXX_DiscardUnknown 

func (m *QueryIsReporterResponse) XXX_DiscardUnknown()

func (*QueryIsReporterResponse) XXX_Marshal 

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

func (*QueryIsReporterResponse) XXX_Merge 

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

func (*QueryIsReporterResponse) XXX_Size 

func (m *QueryIsReporterResponse) XXX_Size() int

func (*QueryIsReporterResponse) XXX_Unmarshal 

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

type QueryOracleScriptRequest 

type QueryOracleScriptRequest struct {
	OracleScriptId int64 `protobuf:"varint,1,opt,name=oracle_script_id,json=oracleScriptId,proto3" json:"oracle_script_id,omitempty"`
}

QueryOracleScriptRequest is request type for the Query/OracleScript RPC method.

func (*QueryOracleScriptRequest) Descriptor 

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

func (*QueryOracleScriptRequest) GetOracleScriptId 

func (m *QueryOracleScriptRequest) GetOracleScriptId() int64

func (*QueryOracleScriptRequest) Marshal 

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

func (*QueryOracleScriptRequest) MarshalTo 

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

func (*QueryOracleScriptRequest) MarshalToSizedBuffer 

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

func (*QueryOracleScriptRequest) ProtoMessage 

func (*QueryOracleScriptRequest) ProtoMessage()

func (*QueryOracleScriptRequest) Reset 

func (m *QueryOracleScriptRequest) Reset()

func (*QueryOracleScriptRequest) Size 

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

func (*QueryOracleScriptRequest) String 

func (m *QueryOracleScriptRequest) String() string

func (*QueryOracleScriptRequest) Unmarshal 

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

func (*QueryOracleScriptRequest) XXX_DiscardUnknown 

func (m *QueryOracleScriptRequest) XXX_DiscardUnknown()

func (*QueryOracleScriptRequest) XXX_Marshal 

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

func (*QueryOracleScriptRequest) XXX_Merge 

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

func (*QueryOracleScriptRequest) XXX_Size 

func (m *QueryOracleScriptRequest) XXX_Size() int

func (*QueryOracleScriptRequest) XXX_Unmarshal 

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

type QueryOracleScriptResponse 

type QueryOracleScriptResponse struct {
	OracleScript *OracleScript `protobuf:"bytes,1,opt,name=oracle_script,json=oracleScript,proto3" json:"oracle_script,omitempty"`
}

QueryOracleScriptResponse is response type for the Query/OracleScript RPC method.

func (*QueryOracleScriptResponse) Descriptor 

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

func (*QueryOracleScriptResponse) GetOracleScript 

func (m *QueryOracleScriptResponse) GetOracleScript() *OracleScript

func (*QueryOracleScriptResponse) Marshal 

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

func (*QueryOracleScriptResponse) MarshalTo 

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

func (*QueryOracleScriptResponse) MarshalToSizedBuffer 

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

func (*QueryOracleScriptResponse) ProtoMessage 

func (*QueryOracleScriptResponse) ProtoMessage()

func (*QueryOracleScriptResponse) Reset 

func (m *QueryOracleScriptResponse) Reset()

func (*QueryOracleScriptResponse) Size 

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

func (*QueryOracleScriptResponse) String 

func (m *QueryOracleScriptResponse) String() string

func (*QueryOracleScriptResponse) Unmarshal 

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

func (*QueryOracleScriptResponse) XXX_DiscardUnknown 

func (m *QueryOracleScriptResponse) XXX_DiscardUnknown()

func (*QueryOracleScriptResponse) XXX_Marshal 

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

func (*QueryOracleScriptResponse) XXX_Merge 

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

func (*QueryOracleScriptResponse) XXX_Size 

func (m *QueryOracleScriptResponse) XXX_Size() int

func (*QueryOracleScriptResponse) XXX_Unmarshal 

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

type QueryOracleScriptsRequest 

type QueryOracleScriptsRequest struct {
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryOracleScriptsRequest is request type for the Query/OracleScripts RPC method.

func (*QueryOracleScriptsRequest) Descriptor 

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

func (*QueryOracleScriptsRequest) GetPagination 

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

func (*QueryOracleScriptsRequest) Marshal 

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

func (*QueryOracleScriptsRequest) MarshalTo 

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

func (*QueryOracleScriptsRequest) MarshalToSizedBuffer 

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

func (*QueryOracleScriptsRequest) ProtoMessage 

func (*QueryOracleScriptsRequest) ProtoMessage()

func (*QueryOracleScriptsRequest) Reset 

func (m *QueryOracleScriptsRequest) Reset()

func (*QueryOracleScriptsRequest) Size 

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

func (*QueryOracleScriptsRequest) String 

func (m *QueryOracleScriptsRequest) String() string

func (*QueryOracleScriptsRequest) Unmarshal 

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

func (*QueryOracleScriptsRequest) XXX_DiscardUnknown 

func (m *QueryOracleScriptsRequest) XXX_DiscardUnknown()

func (*QueryOracleScriptsRequest) XXX_Marshal 

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

func (*QueryOracleScriptsRequest) XXX_Merge 

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

func (*QueryOracleScriptsRequest) XXX_Size 

func (m *QueryOracleScriptsRequest) XXX_Size() int

func (*QueryOracleScriptsRequest) XXX_Unmarshal 

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

type QueryOracleScriptsResponse 

type QueryOracleScriptsResponse struct {
	OracleScripts []OracleScript      `protobuf:"bytes,1,rep,name=oracle_scripts,json=oracleScripts,proto3" json:"oracle_scripts"`
	Pagination    *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryOracleScriptsResponse is response type for the Query/OracleScripts RPC method.

func (*QueryOracleScriptsResponse) Descriptor 

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

func (*QueryOracleScriptsResponse) GetOracleScripts 

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

func (*QueryOracleScriptsResponse) GetPagination 

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

func (*QueryOracleScriptsResponse) Marshal 

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

func (*QueryOracleScriptsResponse) MarshalTo 

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

func (*QueryOracleScriptsResponse) MarshalToSizedBuffer 

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

func (*QueryOracleScriptsResponse) ProtoMessage 

func (*QueryOracleScriptsResponse) ProtoMessage()

func (*QueryOracleScriptsResponse) Reset 

func (m *QueryOracleScriptsResponse) Reset()

func (*QueryOracleScriptsResponse) Size 

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

func (*QueryOracleScriptsResponse) String 

func (m *QueryOracleScriptsResponse) String() string

func (*QueryOracleScriptsResponse) Unmarshal 

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

func (*QueryOracleScriptsResponse) XXX_DiscardUnknown 

func (m *QueryOracleScriptsResponse) XXX_DiscardUnknown()

func (*QueryOracleScriptsResponse) XXX_Marshal 

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

func (*QueryOracleScriptsResponse) XXX_Merge 

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

func (*QueryOracleScriptsResponse) XXX_Size 

func (m *QueryOracleScriptsResponse) XXX_Size() int

func (*QueryOracleScriptsResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest is request type for the Query/Params RPC method.

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

type QueryParamsResponse struct {
	// pagination defines an optional pagination for the request.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse is response type for the Query/Params RPC method.

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryPendingRequestsRequest 

type QueryPendingRequestsRequest struct {
	// ValidatorAddress is address of a validator
	ValidatorAddress string `protobuf:"bytes,1,opt,name=validator_address,json=validatorAddress,proto3" json:"validator_address,omitempty"`
}

QueryPendingRequestRequest is request type for the Query/PendingRequests RPC method.

func (*QueryPendingRequestsRequest) Descriptor 

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

func (*QueryPendingRequestsRequest) GetValidatorAddress 

func (m *QueryPendingRequestsRequest) GetValidatorAddress() string

func (*QueryPendingRequestsRequest) Marshal 

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

func (*QueryPendingRequestsRequest) MarshalTo 

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

func (*QueryPendingRequestsRequest) MarshalToSizedBuffer 

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

func (*QueryPendingRequestsRequest) ProtoMessage 

func (*QueryPendingRequestsRequest) ProtoMessage()

func (*QueryPendingRequestsRequest) Reset 

func (m *QueryPendingRequestsRequest) Reset()

func (*QueryPendingRequestsRequest) Size 

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

func (*QueryPendingRequestsRequest) String 

func (m *QueryPendingRequestsRequest) String() string

func (*QueryPendingRequestsRequest) Unmarshal 

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

func (*QueryPendingRequestsRequest) XXX_DiscardUnknown 

func (m *QueryPendingRequestsRequest) XXX_DiscardUnknown()

func (*QueryPendingRequestsRequest) XXX_Marshal 

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

func (*QueryPendingRequestsRequest) XXX_Merge 

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

func (*QueryPendingRequestsRequest) XXX_Size 

func (m *QueryPendingRequestsRequest) XXX_Size() int

func (*QueryPendingRequestsRequest) XXX_Unmarshal 

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

type QueryPendingRequestsResponse 

type QueryPendingRequestsResponse struct {
	// RequestIDs is a list of pending request IDs assigned to the given validator
	RequestIDs []int64 `protobuf:"varint,1,rep,packed,name=request_ids,json=requestIds,proto3" json:"request_ids,omitempty"`
}

QueryPendingRequestResponse is response type for the Query/PendingRequests RPC method.

func (*QueryPendingRequestsResponse) Descriptor 

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

func (*QueryPendingRequestsResponse) GetRequestIDs 

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

func (*QueryPendingRequestsResponse) Marshal 

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

func (*QueryPendingRequestsResponse) MarshalTo 

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

func (*QueryPendingRequestsResponse) MarshalToSizedBuffer 

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

func (*QueryPendingRequestsResponse) ProtoMessage 

func (*QueryPendingRequestsResponse) ProtoMessage()

func (*QueryPendingRequestsResponse) Reset 

func (m *QueryPendingRequestsResponse) Reset()

func (*QueryPendingRequestsResponse) Size 

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

func (*QueryPendingRequestsResponse) String 

func (m *QueryPendingRequestsResponse) String() string

func (*QueryPendingRequestsResponse) Unmarshal 

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

func (*QueryPendingRequestsResponse) XXX_DiscardUnknown 

func (m *QueryPendingRequestsResponse) XXX_DiscardUnknown()

func (*QueryPendingRequestsResponse) XXX_Marshal 

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

func (*QueryPendingRequestsResponse) XXX_Merge 

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

func (*QueryPendingRequestsResponse) XXX_Size 

func (m *QueryPendingRequestsResponse) XXX_Size() int

func (*QueryPendingRequestsResponse) XXX_Unmarshal 

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

type QueryReportersRequest 

type QueryReportersRequest struct {
	ValidatorAddress string `protobuf:"bytes,1,opt,name=validator_address,json=validatorAddress,proto3" json:"validator_address,omitempty"`
}

QueryReportersRequest is request type for the Query/Reporters RPC method.

func (*QueryReportersRequest) Descriptor 

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

func (*QueryReportersRequest) GetValidatorAddress 

func (m *QueryReportersRequest) GetValidatorAddress() string

func (*QueryReportersRequest) Marshal 

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

func (*QueryReportersRequest) MarshalTo 

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

func (*QueryReportersRequest) MarshalToSizedBuffer 

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

func (*QueryReportersRequest) ProtoMessage 

func (*QueryReportersRequest) ProtoMessage()

func (*QueryReportersRequest) Reset 

func (m *QueryReportersRequest) Reset()

func (*QueryReportersRequest) Size 

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

func (*QueryReportersRequest) String 

func (m *QueryReportersRequest) String() string

func (*QueryReportersRequest) Unmarshal 

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

func (*QueryReportersRequest) XXX_DiscardUnknown 

func (m *QueryReportersRequest) XXX_DiscardUnknown()

func (*QueryReportersRequest) XXX_Marshal 

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

func (*QueryReportersRequest) XXX_Merge 

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

func (*QueryReportersRequest) XXX_Size 

func (m *QueryReportersRequest) XXX_Size() int

func (*QueryReportersRequest) XXX_Unmarshal 

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

type QueryReportersResponse 

type QueryReportersResponse struct {
	Reporter []string `protobuf:"bytes,1,rep,name=reporter,proto3" json:"reporter,omitempty"`
}

QueryReportersResponse is response type for the Query/Reporters RPC method.

func (*QueryReportersResponse) Descriptor 

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

func (*QueryReportersResponse) GetReporter 

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

func (*QueryReportersResponse) Marshal 

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

func (*QueryReportersResponse) MarshalTo 

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

func (*QueryReportersResponse) MarshalToSizedBuffer 

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

func (*QueryReportersResponse) ProtoMessage 

func (*QueryReportersResponse) ProtoMessage()

func (*QueryReportersResponse) Reset 

func (m *QueryReportersResponse) Reset()

func (*QueryReportersResponse) Size 

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

func (*QueryReportersResponse) String 

func (m *QueryReportersResponse) String() string

func (*QueryReportersResponse) Unmarshal 

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

func (*QueryReportersResponse) XXX_DiscardUnknown 

func (m *QueryReportersResponse) XXX_DiscardUnknown()

func (*QueryReportersResponse) XXX_Marshal 

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

func (*QueryReportersResponse) XXX_Merge 

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

func (*QueryReportersResponse) XXX_Size 

func (m *QueryReportersResponse) XXX_Size() int

func (*QueryReportersResponse) XXX_Unmarshal 

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

type QueryRequestIDs 

type QueryRequestIDs struct {
	RequestIds []int64 `protobuf:"varint,1,rep,packed,name=request_ids,json=requestIds,proto3" json:"request_ids,omitempty"`
}

func (*QueryRequestIDs) Descriptor 

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

func (*QueryRequestIDs) GetRequestIds 

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

func (*QueryRequestIDs) Marshal 

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

func (*QueryRequestIDs) MarshalTo 

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

func (*QueryRequestIDs) MarshalToSizedBuffer 

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

func (*QueryRequestIDs) ProtoMessage 

func (*QueryRequestIDs) ProtoMessage()

func (*QueryRequestIDs) Reset 

func (m *QueryRequestIDs) Reset()

func (*QueryRequestIDs) Size 

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

func (*QueryRequestIDs) String 

func (m *QueryRequestIDs) String() string

func (*QueryRequestIDs) Unmarshal 

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

func (*QueryRequestIDs) XXX_DiscardUnknown 

func (m *QueryRequestIDs) XXX_DiscardUnknown()

func (*QueryRequestIDs) XXX_Marshal 

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

func (*QueryRequestIDs) XXX_Merge 

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

func (*QueryRequestIDs) XXX_Size 

func (m *QueryRequestIDs) XXX_Size() int

func (*QueryRequestIDs) XXX_Unmarshal 

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

type QueryRequestPriceRequest 

type QueryRequestPriceRequest struct {
	Symbol   string `protobuf:"bytes,1,opt,name=symbol,proto3" json:"symbol,omitempty"`
	AskCount int64  `protobuf:"varint,2,opt,name=ask_count,json=askCount,proto3" json:"ask_count,omitempty"`
	MinCount int64  `protobuf:"varint,3,opt,name=min_count,json=minCount,proto3" json:"min_count,omitempty"`
}

QueryRequestPriceRequest is request type for the Query/RequestPrice RPC method.

func NewQueryRequestPricesRequest 

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

func (*QueryRequestPriceRequest) Descriptor 

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

func (*QueryRequestPriceRequest) GetAskCount 

func (m *QueryRequestPriceRequest) GetAskCount() int64

func (*QueryRequestPriceRequest) GetMinCount 

func (m *QueryRequestPriceRequest) GetMinCount() int64

func (*QueryRequestPriceRequest) GetSymbol 

func (m *QueryRequestPriceRequest) GetSymbol() string

func (*QueryRequestPriceRequest) Marshal 

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

func (*QueryRequestPriceRequest) MarshalTo 

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

func (*QueryRequestPriceRequest) MarshalToSizedBuffer 

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

func (*QueryRequestPriceRequest) ProtoMessage 

func (*QueryRequestPriceRequest) ProtoMessage()

func (*QueryRequestPriceRequest) Reset 

func (m *QueryRequestPriceRequest) Reset()

func (*QueryRequestPriceRequest) Size 

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

func (*QueryRequestPriceRequest) String 

func (m *QueryRequestPriceRequest) String() string

func (*QueryRequestPriceRequest) Unmarshal 

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

func (*QueryRequestPriceRequest) XXX_DiscardUnknown 

func (m *QueryRequestPriceRequest) XXX_DiscardUnknown()

func (*QueryRequestPriceRequest) XXX_Marshal 

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

func (*QueryRequestPriceRequest) XXX_Merge 

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

func (*QueryRequestPriceRequest) XXX_Size 

func (m *QueryRequestPriceRequest) XXX_Size() int

func (*QueryRequestPriceRequest) XXX_Unmarshal 

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

type QueryRequestPriceResponse 

type QueryRequestPriceResponse struct {
	OracleScriptId int64  `protobuf:"varint,1,opt,name=oracle_script_id,json=oracleScriptId,proto3" json:"oracle_script_id,omitempty"`
	Calldata       []byte `protobuf:"bytes,2,opt,name=calldata,proto3" json:"calldata,omitempty"`
	AskCount       int64  `protobuf:"varint,3,opt,name=ask_count,json=askCount,proto3" json:"ask_count,omitempty"`
	MinCount       int64  `protobuf:"varint,4,opt,name=min_count,json=minCount,proto3" json:"min_count,omitempty"`
}

QueryRequestPriceResponse is response type for the Query/RequestPrice RPC method.

func (*QueryRequestPriceResponse) Descriptor 

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

func (*QueryRequestPriceResponse) GetAskCount 

func (m *QueryRequestPriceResponse) GetAskCount() int64

func (*QueryRequestPriceResponse) GetCalldata 

func (m *QueryRequestPriceResponse) GetCalldata() []byte

func (*QueryRequestPriceResponse) GetMinCount 

func (m *QueryRequestPriceResponse) GetMinCount() int64

func (*QueryRequestPriceResponse) GetOracleScriptId 

func (m *QueryRequestPriceResponse) GetOracleScriptId() int64

func (*QueryRequestPriceResponse) Marshal 

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

func (*QueryRequestPriceResponse) MarshalTo 

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

func (*QueryRequestPriceResponse) MarshalToSizedBuffer 

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

func (*QueryRequestPriceResponse) ProtoMessage 

func (*QueryRequestPriceResponse) ProtoMessage()

func (*QueryRequestPriceResponse) Reset 

func (m *QueryRequestPriceResponse) Reset()

func (*QueryRequestPriceResponse) Size 

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

func (*QueryRequestPriceResponse) String 

func (m *QueryRequestPriceResponse) String() string

func (*QueryRequestPriceResponse) Unmarshal 

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

func (*QueryRequestPriceResponse) XXX_DiscardUnknown 

func (m *QueryRequestPriceResponse) XXX_DiscardUnknown()

func (*QueryRequestPriceResponse) XXX_Marshal 

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

func (*QueryRequestPriceResponse) XXX_Merge 

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

func (*QueryRequestPriceResponse) XXX_Size 

func (m *QueryRequestPriceResponse) XXX_Size() int

func (*QueryRequestPriceResponse) XXX_Unmarshal 

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

type QueryRequestReportsRequest 

type QueryRequestReportsRequest struct {
	RequestId  int64              `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryRequestReportsRequest is request type for the Query/RequestReports RPC method.

func (*QueryRequestReportsRequest) Descriptor 

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

func (*QueryRequestReportsRequest) GetPagination 

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

func (*QueryRequestReportsRequest) GetRequestId 

func (m *QueryRequestReportsRequest) GetRequestId() int64

func (*QueryRequestReportsRequest) Marshal 

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

func (*QueryRequestReportsRequest) MarshalTo 

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

func (*QueryRequestReportsRequest) MarshalToSizedBuffer 

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

func (*QueryRequestReportsRequest) ProtoMessage 

func (*QueryRequestReportsRequest) ProtoMessage()

func (*QueryRequestReportsRequest) Reset 

func (m *QueryRequestReportsRequest) Reset()

func (*QueryRequestReportsRequest) Size 

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

func (*QueryRequestReportsRequest) String 

func (m *QueryRequestReportsRequest) String() string

func (*QueryRequestReportsRequest) Unmarshal 

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

func (*QueryRequestReportsRequest) XXX_DiscardUnknown 

func (m *QueryRequestReportsRequest) XXX_DiscardUnknown()

func (*QueryRequestReportsRequest) XXX_Marshal 

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

func (*QueryRequestReportsRequest) XXX_Merge 

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

func (*QueryRequestReportsRequest) XXX_Size 

func (m *QueryRequestReportsRequest) XXX_Size() int

func (*QueryRequestReportsRequest) XXX_Unmarshal 

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

type QueryRequestReportsResponse 

type QueryRequestReportsResponse struct {
	Reports    []Report            `protobuf:"bytes,1,rep,name=reports,proto3" json:"reports"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryRequestReportsResponse is response type for the Query/RequestReports RPC method.

func (*QueryRequestReportsResponse) Descriptor 

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

func (*QueryRequestReportsResponse) GetPagination 

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

func (*QueryRequestReportsResponse) GetReports 

func (m *QueryRequestReportsResponse) GetReports() []Report

func (*QueryRequestReportsResponse) Marshal 

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

func (*QueryRequestReportsResponse) MarshalTo 

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

func (*QueryRequestReportsResponse) MarshalToSizedBuffer 

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

func (*QueryRequestReportsResponse) ProtoMessage 

func (*QueryRequestReportsResponse) ProtoMessage()

func (*QueryRequestReportsResponse) Reset 

func (m *QueryRequestReportsResponse) Reset()

func (*QueryRequestReportsResponse) Size 

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

func (*QueryRequestReportsResponse) String 

func (m *QueryRequestReportsResponse) String() string

func (*QueryRequestReportsResponse) Unmarshal 

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

func (*QueryRequestReportsResponse) XXX_DiscardUnknown 

func (m *QueryRequestReportsResponse) XXX_DiscardUnknown()

func (*QueryRequestReportsResponse) XXX_Marshal 

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

func (*QueryRequestReportsResponse) XXX_Merge 

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

func (*QueryRequestReportsResponse) XXX_Size 

func (m *QueryRequestReportsResponse) XXX_Size() int

func (*QueryRequestReportsResponse) XXX_Unmarshal 

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

type QueryRequestRequest 

type QueryRequestRequest struct {
	RequestId int64 `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
}

QueryRequestRequest is request type for the Query/Request RPC method.

func (*QueryRequestRequest) Descriptor 

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

func (*QueryRequestRequest) GetRequestId 

func (m *QueryRequestRequest) GetRequestId() int64

func (*QueryRequestRequest) Marshal 

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

func (*QueryRequestRequest) MarshalTo 

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

func (*QueryRequestRequest) MarshalToSizedBuffer 

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

func (*QueryRequestRequest) ProtoMessage 

func (*QueryRequestRequest) ProtoMessage()

func (*QueryRequestRequest) Reset 

func (m *QueryRequestRequest) Reset()

func (*QueryRequestRequest) Size 

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

func (*QueryRequestRequest) String 

func (m *QueryRequestRequest) String() string

func (*QueryRequestRequest) Unmarshal 

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

func (*QueryRequestRequest) XXX_DiscardUnknown 

func (m *QueryRequestRequest) XXX_DiscardUnknown()

func (*QueryRequestRequest) XXX_Marshal 

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

func (*QueryRequestRequest) XXX_Merge 

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

func (*QueryRequestRequest) XXX_Size 

func (m *QueryRequestRequest) XXX_Size() int

func (*QueryRequestRequest) XXX_Unmarshal 

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

type QueryRequestResponse 

type QueryRequestResponse struct {
	// Request is an oracle request
	Request *Request `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// Result is a final form of result data
	Result *Result `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// Reports is list of result data as raw reports that are fulfilled by
	// assigned validators
	Reports []Report `protobuf:"bytes,3,rep,name=reports,proto3" json:"reports"`
}

QueryRequestResponse is response type for the Query/Request RPC method.

func (*QueryRequestResponse) Descriptor 

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

func (*QueryRequestResponse) GetReports added in v0.5.5 

func (m *QueryRequestResponse) GetReports() []Report

func (*QueryRequestResponse) GetRequest 

func (m *QueryRequestResponse) GetRequest() *Request

func (*QueryRequestResponse) GetResult added in v0.5.5 

func (m *QueryRequestResponse) GetResult() *Result

func (*QueryRequestResponse) Marshal 

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

func (*QueryRequestResponse) MarshalTo 

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

func (*QueryRequestResponse) MarshalToSizedBuffer 

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

func (*QueryRequestResponse) ProtoMessage 

func (*QueryRequestResponse) ProtoMessage()

func (*QueryRequestResponse) Reset 

func (m *QueryRequestResponse) Reset()

func (*QueryRequestResponse) Size 

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

func (*QueryRequestResponse) String 

func (m *QueryRequestResponse) String() string

func (*QueryRequestResponse) Unmarshal 

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

func (*QueryRequestResponse) XXX_DiscardUnknown 

func (m *QueryRequestResponse) XXX_DiscardUnknown()

func (*QueryRequestResponse) XXX_Marshal 

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

func (*QueryRequestResponse) XXX_Merge 

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

func (*QueryRequestResponse) XXX_Size 

func (m *QueryRequestResponse) XXX_Size() int

func (*QueryRequestResponse) XXX_Unmarshal 

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

type QueryRequestSearchRequest 

type QueryRequestSearchRequest struct {
	OracleScriptId int64  `protobuf:"varint,1,opt,name=oracle_script_id,json=oracleScriptId,proto3" json:"oracle_script_id,omitempty"`
	Calldata       []byte `protobuf:"bytes,2,opt,name=calldata,proto3" json:"calldata,omitempty"`
	AskCount       int64  `protobuf:"varint,3,opt,name=ask_count,json=askCount,proto3" json:"ask_count,omitempty"`
	MinCount       int64  `protobuf:"varint,4,opt,name=min_count,json=minCount,proto3" json:"min_count,omitempty"`
}

QueryRequestSearchRequest is request type for the Query/RequestSearch RPC method.

func NewQueryRequestSearchRequest 

func NewQueryRequestSearchRequest(oid int64, callData []byte, askCount, minCount int64) *QueryRequestSearchRequest

func (*QueryRequestSearchRequest) Descriptor 

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

func (*QueryRequestSearchRequest) GetAskCount 

func (m *QueryRequestSearchRequest) GetAskCount() int64

func (*QueryRequestSearchRequest) GetCalldata 

func (m *QueryRequestSearchRequest) GetCalldata() []byte

func (*QueryRequestSearchRequest) GetMinCount 

func (m *QueryRequestSearchRequest) GetMinCount() int64

func (*QueryRequestSearchRequest) GetOracleScriptId 

func (m *QueryRequestSearchRequest) GetOracleScriptId() int64

func (*QueryRequestSearchRequest) Marshal 

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

func (*QueryRequestSearchRequest) MarshalTo 

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

func (*QueryRequestSearchRequest) MarshalToSizedBuffer 

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

func (*QueryRequestSearchRequest) ProtoMessage 

func (*QueryRequestSearchRequest) ProtoMessage()

func (*QueryRequestSearchRequest) Reset 

func (m *QueryRequestSearchRequest) Reset()

func (*QueryRequestSearchRequest) Size 

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

func (*QueryRequestSearchRequest) String 

func (m *QueryRequestSearchRequest) String() string

func (*QueryRequestSearchRequest) Unmarshal 

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

func (*QueryRequestSearchRequest) XXX_DiscardUnknown 

func (m *QueryRequestSearchRequest) XXX_DiscardUnknown()

func (*QueryRequestSearchRequest) XXX_Marshal 

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

func (*QueryRequestSearchRequest) XXX_Merge 

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

func (*QueryRequestSearchRequest) XXX_Size 

func (m *QueryRequestSearchRequest) XXX_Size() int

func (*QueryRequestSearchRequest) XXX_Unmarshal 

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

type QueryRequestSearchResponse 

type QueryRequestSearchResponse struct {
	Request *Request `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Result  *Result  `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	Reports []Report `protobuf:"bytes,3,rep,name=reports,proto3" json:"reports"`
}

QueryRequestSearchResponse is response type for the Query/RequestSearch RPC method.

func NewQueryRequestSearchResponse 

func NewQueryRequestSearchResponse(req QueryRequestResponse) *QueryRequestSearchResponse

func (*QueryRequestSearchResponse) Descriptor 

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

func (*QueryRequestSearchResponse) GetReports added in v0.5.5 

func (m *QueryRequestSearchResponse) GetReports() []Report

func (*QueryRequestSearchResponse) GetRequest added in v0.5.5 

func (m *QueryRequestSearchResponse) GetRequest() *Request

func (*QueryRequestSearchResponse) GetResult added in v0.5.5 

func (m *QueryRequestSearchResponse) GetResult() *Result

func (*QueryRequestSearchResponse) Marshal 

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

func (*QueryRequestSearchResponse) MarshalTo 

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

func (*QueryRequestSearchResponse) MarshalToSizedBuffer 

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

func (*QueryRequestSearchResponse) ProtoMessage 

func (*QueryRequestSearchResponse) ProtoMessage()

func (*QueryRequestSearchResponse) Reset 

func (m *QueryRequestSearchResponse) Reset()

func (*QueryRequestSearchResponse) Size 

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

func (*QueryRequestSearchResponse) String 

func (m *QueryRequestSearchResponse) String() string

func (*QueryRequestSearchResponse) Unmarshal 

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

func (*QueryRequestSearchResponse) XXX_DiscardUnknown 

func (m *QueryRequestSearchResponse) XXX_DiscardUnknown()

func (*QueryRequestSearchResponse) XXX_Marshal 

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

func (*QueryRequestSearchResponse) XXX_Merge 

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

func (*QueryRequestSearchResponse) XXX_Size 

func (m *QueryRequestSearchResponse) XXX_Size() int

func (*QueryRequestSearchResponse) XXX_Unmarshal 

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

type QueryRequestVerificationRequest 

type QueryRequestVerificationRequest struct {
	// ChainID is the chain ID to identify which chain ID is used for the
	// verification
	ChainId string `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	// Validator is a validator address
	Validator string `protobuf:"bytes,2,opt,name=validator,proto3" json:"validator,omitempty"`
	// RequestID is oracle request ID
	RequestId uint64 `protobuf:"varint,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// ExternalID is an oracle's external ID
	ExternalId uint64 `protobuf:"varint,4,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"`
	// Reporter is an bech32-encoded public key of the reporter authorized by the
	// DataSourceID is the ID of data source
	DataSourceId uint64 `protobuf:"varint,5,opt,name=data_source_id,json=dataSourceId,proto3" json:"data_source_id,omitempty"`
	// validator
	Reporter string `protobuf:"bytes,6,opt,name=reporter,proto3" json:"reporter,omitempty"`
	// Signature is a signature signed by the reporter using reporter's private
	// key
	Signature []byte `protobuf:"bytes,7,opt,name=signature,proto3" json:"signature,omitempty"`
}

QueryRequestVerificationRequest is request type for the Query/RequestVerification RPC

func (*QueryRequestVerificationRequest) Descriptor 

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

func (*QueryRequestVerificationRequest) GetChainId 

func (m *QueryRequestVerificationRequest) GetChainId() string

func (*QueryRequestVerificationRequest) GetDataSourceId added in v0.7.2 

func (m *QueryRequestVerificationRequest) GetDataSourceId() uint64

func (*QueryRequestVerificationRequest) GetExternalId 

func (m *QueryRequestVerificationRequest) GetExternalId() uint64

func (*QueryRequestVerificationRequest) GetReporter 

func (m *QueryRequestVerificationRequest) GetReporter() string

func (*QueryRequestVerificationRequest) GetRequestId 

func (m *QueryRequestVerificationRequest) GetRequestId() uint64

func (*QueryRequestVerificationRequest) GetSignature 

func (m *QueryRequestVerificationRequest) GetSignature() []byte

func (*QueryRequestVerificationRequest) GetValidator 

func (m *QueryRequestVerificationRequest) GetValidator() string

func (*QueryRequestVerificationRequest) Marshal 

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

func (*QueryRequestVerificationRequest) MarshalTo 

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

func (*QueryRequestVerificationRequest) MarshalToSizedBuffer 

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

func (*QueryRequestVerificationRequest) ProtoMessage 

func (*QueryRequestVerificationRequest) ProtoMessage()

func (*QueryRequestVerificationRequest) Reset 

func (m *QueryRequestVerificationRequest) Reset()

func (*QueryRequestVerificationRequest) Size 

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

func (*QueryRequestVerificationRequest) String 

func (m *QueryRequestVerificationRequest) String() string

func (*QueryRequestVerificationRequest) Unmarshal 

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

func (*QueryRequestVerificationRequest) XXX_DiscardUnknown 

func (m *QueryRequestVerificationRequest) XXX_DiscardUnknown()

func (*QueryRequestVerificationRequest) XXX_Marshal 

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

func (*QueryRequestVerificationRequest) XXX_Merge 

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

func (*QueryRequestVerificationRequest) XXX_Size 

func (m *QueryRequestVerificationRequest) XXX_Size() int

func (*QueryRequestVerificationRequest) XXX_Unmarshal 

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

type QueryRequestVerificationResponse 

type QueryRequestVerificationResponse struct {
	// ChainID is the targeted chain ID
	ChainId string `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	// Validator is the targeted validator address
	Validator string `protobuf:"bytes,2,opt,name=validator,proto3" json:"validator,omitempty"`
	// RequestID is the ID of targeted request
	RequestId uint64 `protobuf:"varint,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// ExternalID is the ID of targeted oracle's external data source
	ExternalId uint64 `protobuf:"varint,4,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"`
	// DataSourceID is the ID of a data source that relates to the targeted
	// external ID
	DataSourceId uint64 `protobuf:"varint,5,opt,name=data_source_id,json=dataSourceId,proto3" json:"data_source_id,omitempty"`
}

QueryRequestVerificationResponse is response type for the Query/RequestVerification RPC

func (*QueryRequestVerificationResponse) Descriptor 

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

func (*QueryRequestVerificationResponse) GetChainId 

func (m *QueryRequestVerificationResponse) GetChainId() string

func (*QueryRequestVerificationResponse) GetDataSourceId 

func (m *QueryRequestVerificationResponse) GetDataSourceId() uint64

func (*QueryRequestVerificationResponse) GetExternalId 

func (m *QueryRequestVerificationResponse) GetExternalId() uint64

func (*QueryRequestVerificationResponse) GetRequestId 

func (m *QueryRequestVerificationResponse) GetRequestId() uint64

func (*QueryRequestVerificationResponse) GetValidator 

func (m *QueryRequestVerificationResponse) GetValidator() string

func (*QueryRequestVerificationResponse) Marshal 

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

func (*QueryRequestVerificationResponse) MarshalTo 

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

func (*QueryRequestVerificationResponse) MarshalToSizedBuffer 

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

func (*QueryRequestVerificationResponse) ProtoMessage 

func (*QueryRequestVerificationResponse) ProtoMessage()

func (*QueryRequestVerificationResponse) Reset 

func (m *QueryRequestVerificationResponse) Reset()

func (*QueryRequestVerificationResponse) Size 

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

func (*QueryRequestVerificationResponse) String 

func (m *QueryRequestVerificationResponse) String() string

func (*QueryRequestVerificationResponse) Unmarshal 

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

func (*QueryRequestVerificationResponse) XXX_DiscardUnknown 

func (m *QueryRequestVerificationResponse) XXX_DiscardUnknown()

func (*QueryRequestVerificationResponse) XXX_Marshal 

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

func (*QueryRequestVerificationResponse) XXX_Merge 

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

func (*QueryRequestVerificationResponse) XXX_Size 

func (m *QueryRequestVerificationResponse) XXX_Size() int

func (*QueryRequestVerificationResponse) XXX_Unmarshal 

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

type QueryRequestsRequest 

type QueryRequestsRequest struct {
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryRequestsRequest is request type for the Query/Requests RPC method.

func (*QueryRequestsRequest) Descriptor 

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

func (*QueryRequestsRequest) GetPagination 

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

func (*QueryRequestsRequest) Marshal 

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

func (*QueryRequestsRequest) MarshalTo 

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

func (*QueryRequestsRequest) MarshalToSizedBuffer 

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

func (*QueryRequestsRequest) ProtoMessage 

func (*QueryRequestsRequest) ProtoMessage()

func (*QueryRequestsRequest) Reset 

func (m *QueryRequestsRequest) Reset()

func (*QueryRequestsRequest) Size 

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

func (*QueryRequestsRequest) String 

func (m *QueryRequestsRequest) String() string

func (*QueryRequestsRequest) Unmarshal 

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

func (*QueryRequestsRequest) XXX_DiscardUnknown 

func (m *QueryRequestsRequest) XXX_DiscardUnknown()

func (*QueryRequestsRequest) XXX_Marshal 

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

func (*QueryRequestsRequest) XXX_Merge 

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

func (*QueryRequestsRequest) XXX_Size 

func (m *QueryRequestsRequest) XXX_Size() int

func (*QueryRequestsRequest) XXX_Unmarshal 

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

type QueryRequestsResponse 

type QueryRequestsResponse struct {
	Requests   []RequestResult     `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryRequestsResponse is response type for the Query/Requests RPC method.

func (*QueryRequestsResponse) Descriptor 

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

func (*QueryRequestsResponse) GetPagination 

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

func (*QueryRequestsResponse) GetRequests 

func (m *QueryRequestsResponse) GetRequests() []RequestResult

func (*QueryRequestsResponse) Marshal 

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

func (*QueryRequestsResponse) MarshalTo 

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

func (*QueryRequestsResponse) MarshalToSizedBuffer 

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

func (*QueryRequestsResponse) ProtoMessage 

func (*QueryRequestsResponse) ProtoMessage()

func (*QueryRequestsResponse) Reset 

func (m *QueryRequestsResponse) Reset()

func (*QueryRequestsResponse) Size 

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

func (*QueryRequestsResponse) String 

func (m *QueryRequestsResponse) String() string

func (*QueryRequestsResponse) Unmarshal 

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

func (*QueryRequestsResponse) XXX_DiscardUnknown 

func (m *QueryRequestsResponse) XXX_DiscardUnknown()

func (*QueryRequestsResponse) XXX_Marshal 

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

func (*QueryRequestsResponse) XXX_Merge 

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

func (*QueryRequestsResponse) XXX_Size 

func (m *QueryRequestsResponse) XXX_Size() int

func (*QueryRequestsResponse) XXX_Unmarshal 

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

type QueryResult 

type QueryResult struct {
	Status int             `json:"status,string"`
	Result json.RawMessage `json:"result"`
}

QueryResult wraps querier result with HTTP status to return to application.

type QueryServer 

type QueryServer interface {
	// Counts queries the number of data sources, oracle scripts, and requests.
	Counts(context.Context, *QueryCountsRequest) (*QueryCountsResponse, error)
	// Data queries the data source or oracle script script for given file hash.
	Data(context.Context, *QueryDataRequest) (*QueryDataResponse, error)
	// DataSource queries data source info for given data source id.
	DataSource(context.Context, *QueryDataSourceRequest) (*QueryDataSourceResponse, error)
	// DataSources queries data sources info.
	DataSources(context.Context, *QueryDataSourcesRequest) (*QueryDataSourcesResponse, error)
	// OracleScript queries oracle script info for given oracle script id.
	OracleScript(context.Context, *QueryOracleScriptRequest) (*QueryOracleScriptResponse, error)
	// OracleScripts queries all oracle scripts with pagination.
	OracleScripts(context.Context, *QueryOracleScriptsRequest) (*QueryOracleScriptsResponse, error)
	// Request queries request info for given request id.
	Request(context.Context, *QueryRequestRequest) (*QueryRequestResponse, error)
	// Requests queries all requests with pagination.
	Requests(context.Context, *QueryRequestsRequest) (*QueryRequestsResponse, error)
	// Validator queries oracle info of validator for given validator address.
	Validator(context.Context, *QueryValidatorRequest) (*QueryValidatorResponse, error)
	// IsReporter queries grant of account on this validator.
	IsReporter(context.Context, *QueryIsReporterRequest) (*QueryIsReporterResponse, error)
	// Reporters queries all reporters of a given validator address.
	Reporters(context.Context, *QueryReportersRequest) (*QueryReportersResponse, error)
	// ActiveValidators queries all active oracle validators.
	ActiveValidators(context.Context, *QueryActiveValidatorsRequest) (*QueryActiveValidatorsResponse, error)
	// Params queries the oracle parameters.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// RequestSearch queries the latest request that match the given input.
	RequestSearch(context.Context, *QueryRequestSearchRequest) (*QueryRequestSearchResponse, error)
	// RequestPrice queries the latest price on standard price reference oracle
	// script.
	RequestPrice(context.Context, *QueryRequestPriceRequest) (*QueryRequestPriceResponse, error)
	DataProvidersPool(context.Context, *QueryDataProvidersPoolRequest) (*QueryDataProvidersPoolResponse, error)
	RequestReports(context.Context, *QueryRequestReportsRequest) (*QueryRequestReportsResponse, error)
	DataProviderReward(context.Context, *QueryDataProviderRewardRequest) (*QueryDataProviderRewardResponse, error)
	// PendingRequests queries list of pending request IDs assigned to given
	// validator.
	PendingRequests(context.Context, *QueryPendingRequestsRequest) (*QueryPendingRequestsResponse, error)
	// RequestVerification verifies a request to make sure that
	// all information that will be used to report the data is valid
	RequestVerification(context.Context, *QueryRequestVerificationRequest) (*QueryRequestVerificationResponse, error)
	// DataProviderAccumulatedReward queries oracle info of reporter rewards for
	// given reporter address.
	DataProviderAccumulatedReward(context.Context, *QueryDataProviderAccumulatedRewardRequest) (*QueryDataProviderAccumulatedRewardResponse, error)
}

QueryServer is the server API for Query service.

type QueryValidatorRequest 

type QueryValidatorRequest struct {
	ValidatorAddress string `protobuf:"bytes,1,opt,name=validator_address,json=validatorAddress,proto3" json:"validator_address,omitempty"`
}

QueryValidatorRequest is request type for the Query/Validator RPC method.

func (*QueryValidatorRequest) Descriptor 

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

func (*QueryValidatorRequest) GetValidatorAddress 

func (m *QueryValidatorRequest) GetValidatorAddress() string

func (*QueryValidatorRequest) Marshal 

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

func (*QueryValidatorRequest) MarshalTo 

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

func (*QueryValidatorRequest) MarshalToSizedBuffer 

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

func (*QueryValidatorRequest) ProtoMessage 

func (*QueryValidatorRequest) ProtoMessage()

func (*QueryValidatorRequest) Reset 

func (m *QueryValidatorRequest) Reset()

func (*QueryValidatorRequest) Size 

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

func (*QueryValidatorRequest) String 

func (m *QueryValidatorRequest) String() string

func (*QueryValidatorRequest) Unmarshal 

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

func (*QueryValidatorRequest) XXX_DiscardUnknown 

func (m *QueryValidatorRequest) XXX_DiscardUnknown()

func (*QueryValidatorRequest) XXX_Marshal 

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

func (*QueryValidatorRequest) XXX_Merge 

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

func (*QueryValidatorRequest) XXX_Size 

func (m *QueryValidatorRequest) XXX_Size() int

func (*QueryValidatorRequest) XXX_Unmarshal 

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

type QueryValidatorResponse 

type QueryValidatorResponse struct {
	Status *ValidatorStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
}

QueryValidatorResponse is response type for the Query/Validator RPC method.

func (*QueryValidatorResponse) Descriptor 

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

func (*QueryValidatorResponse) GetStatus 

func (m *QueryValidatorResponse) GetStatus() *ValidatorStatus

func (*QueryValidatorResponse) Marshal 

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

func (*QueryValidatorResponse) MarshalTo 

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

func (*QueryValidatorResponse) MarshalToSizedBuffer 

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

func (*QueryValidatorResponse) ProtoMessage 

func (*QueryValidatorResponse) ProtoMessage()

func (*QueryValidatorResponse) Reset 

func (m *QueryValidatorResponse) Reset()

func (*QueryValidatorResponse) Size 

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

func (*QueryValidatorResponse) String 

func (m *QueryValidatorResponse) String() string

func (*QueryValidatorResponse) Unmarshal 

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

func (*QueryValidatorResponse) XXX_DiscardUnknown 

func (m *QueryValidatorResponse) XXX_DiscardUnknown()

func (*QueryValidatorResponse) XXX_Marshal 

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

func (*QueryValidatorResponse) XXX_Merge 

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

func (*QueryValidatorResponse) XXX_Size 

func (m *QueryValidatorResponse) XXX_Size() int

func (*QueryValidatorResponse) XXX_Unmarshal 

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

type RawReport 

type RawReport struct {
	ExternalID ExternalID `protobuf:"varint,1,opt,name=external_id,json=externalId,proto3,casttype=ExternalID" json:"external_id,omitempty"`
	ExitCode   uint32     `protobuf:"varint,2,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	Data       []byte     `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}

RawRequest is the data structure for storing raw reporter in the storage.

func NewRawReport 

func NewRawReport(
	ExternalID ExternalID,
	ExitCode uint32,
	Data []byte,
) RawReport

func (*RawReport) Descriptor 

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

func (*RawReport) Equal 

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

func (*RawReport) GetData 

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

func (*RawReport) GetExitCode 

func (m *RawReport) GetExitCode() uint32

func (*RawReport) GetExternalID 

func (m *RawReport) GetExternalID() ExternalID

func (*RawReport) Marshal 

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

func (*RawReport) MarshalTo 

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

func (*RawReport) MarshalToSizedBuffer 

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

func (*RawReport) ProtoMessage 

func (*RawReport) ProtoMessage()

func (*RawReport) Reset 

func (m *RawReport) Reset()

func (*RawReport) Size 

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

func (*RawReport) String 

func (m *RawReport) String() string

func (*RawReport) Unmarshal 

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

func (*RawReport) XXX_DiscardUnknown 

func (m *RawReport) XXX_DiscardUnknown()

func (*RawReport) XXX_Marshal 

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

func (*RawReport) XXX_Merge 

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

func (*RawReport) XXX_Size 

func (m *RawReport) XXX_Size() int

func (*RawReport) XXX_Unmarshal 

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

type RawRequest 

type RawRequest struct {
	ExternalID   ExternalID   `protobuf:"varint,1,opt,name=external_id,json=externalId,proto3,casttype=ExternalID" json:"external_id,omitempty"`
	DataSourceID DataSourceID `protobuf:"varint,2,opt,name=data_source_id,json=dataSourceId,proto3,casttype=DataSourceID" json:"data_source_id,omitempty"`
	Calldata     []byte       `protobuf:"bytes,3,opt,name=calldata,proto3" json:"calldata,omitempty"`
}

RawRequest is the data structure for storing raw requests in the storage.

func NewRawRequest 

func NewRawRequest(
	ExternalID ExternalID,
	DataSourceID DataSourceID,
	Calldata []byte,
) RawRequest

func (*RawRequest) Descriptor 

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

func (*RawRequest) Equal 

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

func (*RawRequest) GetCalldata 

func (m *RawRequest) GetCalldata() []byte

func (*RawRequest) GetDataSourceID 

func (m *RawRequest) GetDataSourceID() DataSourceID

func (*RawRequest) GetExternalID 

func (m *RawRequest) GetExternalID() ExternalID

func (*RawRequest) Marshal 

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

func (*RawRequest) MarshalTo 

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

func (*RawRequest) MarshalToSizedBuffer 

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

func (*RawRequest) ProtoMessage 

func (*RawRequest) ProtoMessage()

func (*RawRequest) Reset 

func (m *RawRequest) Reset()

func (*RawRequest) Size 

func (m *RawRequest) Size() (n int)

func (*RawRequest) String 

func (m *RawRequest) String() string

func (*RawRequest) Unmarshal 

func (m *RawRequest) Unmarshal(dAtA []byte) error

func (*RawRequest) XXX_DiscardUnknown 

func (m *RawRequest) XXX_DiscardUnknown()

func (*RawRequest) XXX_Marshal 

func (m *RawRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawRequest) XXX_Merge 

func (m *RawRequest) XXX_Merge(src proto.Message)

func (*RawRequest) XXX_Size 

func (m *RawRequest) XXX_Size() int

func (*RawRequest) XXX_Unmarshal 

func (m *RawRequest) XXX_Unmarshal(b []byte) error

type Report 

type Report struct {
	Validator       string      `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator,omitempty"`
	InBeforeResolve bool        `protobuf:"varint,2,opt,name=in_before_resolve,json=inBeforeResolve,proto3" json:"in_before_resolve,omitempty"`
	RawReports      []RawReport `protobuf:"bytes,3,rep,name=raw_reports,json=rawReports,proto3" json:"raw_reports"`
}

Report is the data structure for storing reports in the storage.

func NewReport 

func NewReport(
	Validator sdk.ValAddress,
	InBeforeResolve bool,
	RawReports []RawReport,
) Report

func (*Report) Descriptor 

func (*Report) Descriptor() ([]byte, []int)

func (*Report) Equal 

func (this *Report) Equal(that interface{}) bool

func (*Report) GetInBeforeResolve 

func (m *Report) GetInBeforeResolve() bool

func (*Report) GetRawReports 

func (m *Report) GetRawReports() []RawReport

func (*Report) GetValidator 

func (m *Report) GetValidator() string

func (*Report) Marshal 

func (m *Report) Marshal() (dAtA []byte, err error)

func (*Report) MarshalTo 

func (m *Report) MarshalTo(dAtA []byte) (int, error)

func (*Report) MarshalToSizedBuffer 

func (m *Report) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Report) ProtoMessage 

func (*Report) ProtoMessage()

func (*Report) Reset 

func (m *Report) Reset()

func (*Report) Size 

func (m *Report) Size() (n int)

func (*Report) String 

func (m *Report) String() string

func (*Report) Unmarshal 

func (m *Report) Unmarshal(dAtA []byte) error

func (*Report) XXX_DiscardUnknown 

func (m *Report) XXX_DiscardUnknown()

func (*Report) XXX_Marshal 

func (m *Report) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Report) XXX_Merge 

func (m *Report) XXX_Merge(src proto.Message)

func (*Report) XXX_Size 

func (m *Report) XXX_Size() int

func (*Report) XXX_Unmarshal 

func (m *Report) XXX_Unmarshal(b []byte) error

type Request 

type Request struct {
	ID                  RequestID      `protobuf:"varint,1,opt,name=id,proto3,casttype=RequestID" json:"id,omitempty"`
	OracleScriptID      OracleScriptID `` /* 130-byte string literal not displayed */
	Calldata            []byte         `protobuf:"bytes,3,opt,name=calldata,proto3" json:"calldata,omitempty"`
	RequestedValidators []string       `protobuf:"bytes,4,rep,name=requested_validators,json=requestedValidators,proto3" json:"requested_validators,omitempty"`
	MinCount            uint64         `protobuf:"varint,5,opt,name=min_count,json=minCount,proto3" json:"min_count,omitempty"`
	RequestHeight       int64          `protobuf:"varint,6,opt,name=request_height,json=requestHeight,proto3" json:"request_height,omitempty"`
	RequestTime         uint64         `protobuf:"varint,7,opt,name=request_time,json=requestTime,proto3" json:"request_time,omitempty"`
	ClientID            string         `protobuf:"bytes,8,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	RawRequests         []RawRequest   `protobuf:"bytes,9,rep,name=raw_requests,json=rawRequests,proto3" json:"raw_requests"`
	IBCSource           *IBCSource     `protobuf:"bytes,10,opt,name=ibc_source,json=ibcSource,proto3" json:"ibc_source,omitempty"`
	ExecuteGas          uint64         `protobuf:"varint,11,opt,name=execute_gas,json=executeGas,proto3" json:"execute_gas,omitempty"`
}

Request is the data structure for storing requests in the storage.

func NewRequest 

func NewRequest(
	oracleScriptID OracleScriptID,
	calldata []byte,
	requestedValidators []sdk.ValAddress,
	minCount uint64,
	requestHeight int64,
	requestTime time.Time,
	clientID string,
	rawRequests []RawRequest,
	iBCSource *IBCSource,
	executeGas uint64,
) Request

func (*Request) Descriptor 

func (*Request) Descriptor() ([]byte, []int)

func (*Request) Equal 

func (this *Request) Equal(that interface{}) bool

func (*Request) GetCalldata 

func (m *Request) GetCalldata() []byte

func (*Request) GetClientID 

func (m *Request) GetClientID() string

func (*Request) GetExecuteGas 

func (m *Request) GetExecuteGas() uint64

func (*Request) GetIBCSource 

func (m *Request) GetIBCSource() *IBCSource

func (*Request) GetID 

func (m *Request) GetID() RequestID

func (*Request) GetMinCount 

func (m *Request) GetMinCount() uint64

func (*Request) GetOracleScriptID 

func (m *Request) GetOracleScriptID() OracleScriptID

func (*Request) GetRawRequests 

func (m *Request) GetRawRequests() []RawRequest

func (*Request) GetRequestHeight 

func (m *Request) GetRequestHeight() int64

func (*Request) GetRequestTime 

func (m *Request) GetRequestTime() uint64

func (*Request) GetRequestedValidators 

func (m *Request) GetRequestedValidators() []string

func (*Request) Marshal 

func (m *Request) Marshal() (dAtA []byte, err error)

func (*Request) MarshalTo 

func (m *Request) MarshalTo(dAtA []byte) (int, error)

func (*Request) MarshalToSizedBuffer 

func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) Size 

func (m *Request) Size() (n int)

func (*Request) String 

func (m *Request) String() string

func (*Request) Unmarshal 

func (m *Request) Unmarshal(dAtA []byte) error

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Request) XXX_Merge 

func (m *Request) XXX_Merge(src proto.Message)

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

func (m *Request) XXX_Unmarshal(b []byte) error

type RequestID 

type RequestID int64

RequestID is the type-safe unique identifier type for data requests.

type RequestResult 

type RequestResult struct {
	Request *Request `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Result  *Result  `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	Reports []Report `protobuf:"bytes,3,rep,name=reports,proto3" json:"reports"`
}

func (*RequestResult) Descriptor 

func (*RequestResult) Descriptor() ([]byte, []int)

func (*RequestResult) Equal 

func (this *RequestResult) Equal(that interface{}) bool

func (*RequestResult) GetReports added in v0.5.5 

func (m *RequestResult) GetReports() []Report

func (*RequestResult) GetRequest added in v0.5.5 

func (m *RequestResult) GetRequest() *Request

func (*RequestResult) GetResult added in v0.5.5 

func (m *RequestResult) GetResult() *Result

func (*RequestResult) Marshal 

func (m *RequestResult) Marshal() (dAtA []byte, err error)

func (*RequestResult) MarshalTo 

func (m *RequestResult) MarshalTo(dAtA []byte) (int, error)

func (*RequestResult) MarshalToSizedBuffer 

func (m *RequestResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RequestResult) ProtoMessage 

func (*RequestResult) ProtoMessage()

func (*RequestResult) Reset 

func (m *RequestResult) Reset()

func (*RequestResult) Size 

func (m *RequestResult) Size() (n int)

func (*RequestResult) String 

func (m *RequestResult) String() string

func (*RequestResult) Unmarshal 

func (m *RequestResult) Unmarshal(dAtA []byte) error

func (*RequestResult) XXX_DiscardUnknown 

func (m *RequestResult) XXX_DiscardUnknown()

func (*RequestResult) XXX_Marshal 

func (m *RequestResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestResult) XXX_Merge 

func (m *RequestResult) XXX_Merge(src proto.Message)

func (*RequestResult) XXX_Size 

func (m *RequestResult) XXX_Size() int

func (*RequestResult) XXX_Unmarshal 

func (m *RequestResult) XXX_Unmarshal(b []byte) error

type RequestSpec 

type RequestSpec interface {
	GetOracleScriptID() OracleScriptID
	GetCalldata() []byte
	GetAskCount() uint64
	GetMinCount() uint64
	GetClientID() string
	GetPrepareGas() uint64
	GetExecuteGas() uint64
	GetFeeLimit() sdk.Coins
}

RequestSpec captures the essence of what it means to be a request-making object.

type RequestVerification 

type RequestVerification struct {
	// ChainID is the ID of targeted chain
	ChainID string `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	// Validator is an validator address
	Validator string `protobuf:"bytes,2,opt,name=validator,proto3" json:"validator,omitempty"`
	// RequestID is the targeted request ID
	RequestID RequestID `protobuf:"varint,3,opt,name=request_id,json=requestId,proto3,casttype=RequestID" json:"request_id,omitempty"`
	// ExternalID is the oracle's external ID of data source
	ExternalID ExternalID `protobuf:"varint,4,opt,name=external_id,json=externalId,proto3,casttype=ExternalID" json:"external_id,omitempty"`
	// DataSourceID is the ID of data source
	DataSourceID DataSourceID `protobuf:"varint,5,opt,name=data_source_id,json=dataSourceId,proto3,casttype=DataSourceID" json:"data_source_id,omitempty"`
}

RequestVerification is a message that is constructed and signed by a reporter to be used as a part of verification of oracle request.

func NewRequestVerification 

func NewRequestVerification(
	chainID string,
	validator sdk.ValAddress,
	requestID RequestID,
	externalID ExternalID,
	dataSourceID DataSourceID,
) RequestVerification

func (*RequestVerification) Descriptor 

func (*RequestVerification) Descriptor() ([]byte, []int)

func (*RequestVerification) Equal 

func (this *RequestVerification) Equal(that interface{}) bool

func (*RequestVerification) GetChainID 

func (m *RequestVerification) GetChainID() string

func (*RequestVerification) GetDataSourceID added in v0.7.2 

func (m *RequestVerification) GetDataSourceID() DataSourceID

func (*RequestVerification) GetExternalID 

func (m *RequestVerification) GetExternalID() ExternalID

func (*RequestVerification) GetRequestID 

func (m *RequestVerification) GetRequestID() RequestID

func (RequestVerification) GetSignBytes 

func (msg RequestVerification) GetSignBytes() []byte

func (*RequestVerification) GetValidator 

func (m *RequestVerification) GetValidator() string

func (*RequestVerification) Marshal 

func (m *RequestVerification) Marshal() (dAtA []byte, err error)

func (*RequestVerification) MarshalTo 

func (m *RequestVerification) MarshalTo(dAtA []byte) (int, error)

func (*RequestVerification) MarshalToSizedBuffer 

func (m *RequestVerification) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RequestVerification) ProtoMessage 

func (*RequestVerification) ProtoMessage()

func (*RequestVerification) Reset 

func (m *RequestVerification) Reset()

func (*RequestVerification) Size 

func (m *RequestVerification) Size() (n int)

func (*RequestVerification) String 

func (m *RequestVerification) String() string

func (*RequestVerification) Unmarshal 

func (m *RequestVerification) Unmarshal(dAtA []byte) error

func (*RequestVerification) XXX_DiscardUnknown 

func (m *RequestVerification) XXX_DiscardUnknown()

func (*RequestVerification) XXX_Marshal 

func (m *RequestVerification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestVerification) XXX_Merge 

func (m *RequestVerification) XXX_Merge(src proto.Message)

func (*RequestVerification) XXX_Size 

func (m *RequestVerification) XXX_Size() int

func (*RequestVerification) XXX_Unmarshal 

func (m *RequestVerification) XXX_Unmarshal(b []byte) error

type ResolveStatus 

type ResolveStatus int32

ResolveStatus encodes the status of an oracle request. 

const (
	// Open - the request is not yet resolved.
	RESOLVE_STATUS_OPEN ResolveStatus = 0
	// Success - the request has been resolved successfully with no errors.
	RESOLVE_STATUS_SUCCESS ResolveStatus = 1
	// Failure - an error occured during the request's resolve call.
	RESOLVE_STATUS_FAILURE ResolveStatus = 2
	// Expired - the request does not get enough reports from validator within the
	// timeframe.
	RESOLVE_STATUS_EXPIRED ResolveStatus = 3
)

func (ResolveStatus) EnumDescriptor 

func (ResolveStatus) EnumDescriptor() ([]byte, []int)

func (ResolveStatus) String 

func (x ResolveStatus) String() string

type Result 

type Result struct {
	// ClientID is the unique identifier of this oracle request, as specified by
	// the client. This same unique ID will be sent back to the requester with the
	// oracle response.
	ClientID string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// OracleScriptID is the unique identifier of the oracle script to be
	// executed.
	OracleScriptID OracleScriptID `` /* 130-byte string literal not displayed */
	// Calldata is the calldata bytes available for oracle executor to read.
	Calldata []byte `protobuf:"bytes,3,opt,name=calldata,proto3" json:"calldata,omitempty"`
	// AskCount is the number of validators that are requested to respond to this
	// oracle request. Higher value means more security, at a higher gas cost.
	AskCount uint64 `protobuf:"varint,4,opt,name=ask_count,json=askCount,proto3" json:"ask_count,omitempty"`
	// MinCount is the minimum number of validators necessary for the request to
	// proceed to the execution phase. Higher value means more security, at the
	// cost of liveness.
	MinCount uint64 `protobuf:"varint,5,opt,name=min_count,json=minCount,proto3" json:"min_count,omitempty"`
	// RequestID is BandChain's unique identifier for this oracle request.
	RequestID RequestID `protobuf:"varint,6,opt,name=request_id,json=requestId,proto3,casttype=RequestID" json:"request_id,omitempty"`
	// AnsCount is the number of validators among to the asked validators that
	// actually responded to this oracle request prior to this oracle request
	// being resolved.
	AnsCount uint64 `protobuf:"varint,7,opt,name=ans_count,json=ansCount,proto3" json:"ans_count,omitempty"`
	// RequestTime is the UNIX epoch time at which the request was sent to
	// BandChain.
	RequestTime int64 `protobuf:"varint,8,opt,name=request_time,json=requestTime,proto3" json:"request_time,omitempty"`
	// ResolveTime is the UNIX epoch time at which the request was resolved to the
	// final result.
	ResolveTime int64 `protobuf:"varint,9,opt,name=resolve_time,json=resolveTime,proto3" json:"resolve_time,omitempty"`
	// ResolveStatus is the status of this oracle request, which can be OK,
	// FAILURE, or EXPIRED.
	ResolveStatus ResolveStatus `` /* 131-byte string literal not displayed */
	// Result is the final aggregated value only available if status if OK.
	Result []byte `protobuf:"bytes,10,opt,name=result,proto3" json:"result,omitempty"`
}

Result encodes a result of request and store in chain

func NewResult 

func NewResult(
	clientId string, oid OracleScriptID, calldata []byte, askCount, minCount uint64,
	requestId RequestID, ansCount uint64, requestTime, resolveTime int64, resolveStatus ResolveStatus, result []byte,
) Result

NewResult creates a new Result instance.

func (*Result) Descriptor 

func (*Result) Descriptor() ([]byte, []int)

func (*Result) Equal 

func (this *Result) Equal(that interface{}) bool

func (*Result) GetAnsCount 

func (m *Result) GetAnsCount() uint64

func (*Result) GetAskCount 

func (m *Result) GetAskCount() uint64

func (*Result) GetCalldata 

func (m *Result) GetCalldata() []byte

func (*Result) GetClientID 

func (m *Result) GetClientID() string

func (*Result) GetMinCount 

func (m *Result) GetMinCount() uint64

func (*Result) GetOracleScriptID 

func (m *Result) GetOracleScriptID() OracleScriptID

func (*Result) GetRequestID 

func (m *Result) GetRequestID() RequestID

func (*Result) GetRequestTime 

func (m *Result) GetRequestTime() int64

func (*Result) GetResolveStatus 

func (m *Result) GetResolveStatus() ResolveStatus

func (*Result) GetResolveTime 

func (m *Result) GetResolveTime() int64

func (*Result) GetResult 

func (m *Result) GetResult() []byte

func (*Result) Marshal 

func (m *Result) Marshal() (dAtA []byte, err error)

func (*Result) MarshalTo 

func (m *Result) MarshalTo(dAtA []byte) (int, error)

func (*Result) MarshalToSizedBuffer 

func (m *Result) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) Reset 

func (m *Result) Reset()

func (*Result) Size 

func (m *Result) Size() (n int)

func (*Result) String 

func (m *Result) String() string

func (*Result) Unmarshal 

func (m *Result) Unmarshal(dAtA []byte) error

func (*Result) XXX_DiscardUnknown 

func (m *Result) XXX_DiscardUnknown()

func (*Result) XXX_Marshal 

func (m *Result) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Result) XXX_Merge 

func (m *Result) XXX_Merge(src proto.Message)

func (*Result) XXX_Size 

func (m *Result) XXX_Size() int

func (*Result) XXX_Unmarshal 

func (m *Result) XXX_Unmarshal(b []byte) error

type RewardThreshold 

type RewardThreshold struct {
	// Amount is the maximum amount of tokens that can be paid for data
	Amount github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,1,rep,name=amount,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"amount"`
	// Blocks is the number of blocks during which the sum of the reward should
	// not exceed total_reward_amount
	Blocks uint64 `protobuf:"varint,2,opt,name=blocks,proto3" json:"blocks,omitempty"`
}

RewardThreshold

func DefaultRewardThreshold 

func DefaultRewardThreshold() RewardThreshold

func NewRewardThreshold 

func NewRewardThreshold(amount sdk.Coins, blocks uint64) RewardThreshold

func (*RewardThreshold) Descriptor 

func (*RewardThreshold) Descriptor() ([]byte, []int)

func (*RewardThreshold) Equal 

func (this *RewardThreshold) Equal(that interface{}) bool

func (*RewardThreshold) GetAmount 

func (m *RewardThreshold) GetAmount() github_com_cosmos_cosmos_sdk_types.Coins

func (*RewardThreshold) GetBlocks 

func (m *RewardThreshold) GetBlocks() uint64

func (*RewardThreshold) Marshal 

func (m *RewardThreshold) Marshal() (dAtA []byte, err error)

func (*RewardThreshold) MarshalTo 

func (m *RewardThreshold) MarshalTo(dAtA []byte) (int, error)

func (*RewardThreshold) MarshalToSizedBuffer 

func (m *RewardThreshold) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RewardThreshold) ProtoMessage 

func (*RewardThreshold) ProtoMessage()

func (*RewardThreshold) Reset 

func (m *RewardThreshold) Reset()

func (*RewardThreshold) Size 

func (m *RewardThreshold) Size() (n int)

func (*RewardThreshold) String 

func (m *RewardThreshold) String() string

func (*RewardThreshold) Unmarshal 

func (m *RewardThreshold) Unmarshal(dAtA []byte) error

func (*RewardThreshold) XXX_DiscardUnknown 

func (m *RewardThreshold) XXX_DiscardUnknown()

func (*RewardThreshold) XXX_Marshal 

func (m *RewardThreshold) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RewardThreshold) XXX_Merge 

func (m *RewardThreshold) XXX_Merge(src proto.Message)

func (*RewardThreshold) XXX_Size 

func (m *RewardThreshold) XXX_Size() int

func (*RewardThreshold) XXX_Unmarshal 

func (m *RewardThreshold) XXX_Unmarshal(b []byte) error

type StakingKeeper 

type StakingKeeper interface {
	ValidatorByConsAddr(sdk.Context, sdk.ConsAddress) stakingtypes.ValidatorI
	IterateBondedValidatorsByPower(ctx sdk.Context, fn func(index int64, validator stakingtypes.ValidatorI) (stop bool))
	Validator(ctx sdk.Context, address sdk.ValAddress) stakingtypes.ValidatorI
}

StakingKeeper defines the expected staking keeper.

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) Activate 

func (*UnimplementedMsgServer) Activate(ctx context.Context, req *MsgActivate) (*MsgActivateResponse, error)

func (*UnimplementedMsgServer) AddReporter 

func (*UnimplementedMsgServer) AddReporter(ctx context.Context, req *MsgAddReporter) (*MsgAddReporterResponse, error)

func (*UnimplementedMsgServer) CreateDataSource 

func (*UnimplementedMsgServer) CreateDataSource(ctx context.Context, req *MsgCreateDataSource) (*MsgCreateDataSourceResponse, error)

func (*UnimplementedMsgServer) CreateOracleScript 

func (*UnimplementedMsgServer) CreateOracleScript(ctx context.Context, req *MsgCreateOracleScript) (*MsgCreateOracleScriptResponse, error)

func (*UnimplementedMsgServer) EditDataSource 

func (*UnimplementedMsgServer) EditDataSource(ctx context.Context, req *MsgEditDataSource) (*MsgEditDataSourceResponse, error)

func (*UnimplementedMsgServer) EditOracleScript 

func (*UnimplementedMsgServer) EditOracleScript(ctx context.Context, req *MsgEditOracleScript) (*MsgEditOracleScriptResponse, error)

func (*UnimplementedMsgServer) RemoveReporter 

func (*UnimplementedMsgServer) RemoveReporter(ctx context.Context, req *MsgRemoveReporter) (*MsgRemoveReporterResponse, error)

func (*UnimplementedMsgServer) ReportData 

func (*UnimplementedMsgServer) ReportData(ctx context.Context, req *MsgReportData) (*MsgReportDataResponse, error)

func (*UnimplementedMsgServer) RequestData 

func (*UnimplementedMsgServer) RequestData(ctx context.Context, req *MsgRequestData) (*MsgRequestDataResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) ActiveValidators 

func (*UnimplementedQueryServer) ActiveValidators(ctx context.Context, req *QueryActiveValidatorsRequest) (*QueryActiveValidatorsResponse, error)

func (*UnimplementedQueryServer) Counts 

func (*UnimplementedQueryServer) Counts(ctx context.Context, req *QueryCountsRequest) (*QueryCountsResponse, error)

func (*UnimplementedQueryServer) Data 

func (*UnimplementedQueryServer) Data(ctx context.Context, req *QueryDataRequest) (*QueryDataResponse, error)

func (*UnimplementedQueryServer) DataProviderAccumulatedReward added in v0.5.4 

func (*UnimplementedQueryServer) DataProviderAccumulatedReward(ctx context.Context, req *QueryDataProviderAccumulatedRewardRequest) (*QueryDataProviderAccumulatedRewardResponse, error)

func (*UnimplementedQueryServer) DataProviderReward 

func (*UnimplementedQueryServer) DataProviderReward(ctx context.Context, req *QueryDataProviderRewardRequest) (*QueryDataProviderRewardResponse, error)

func (*UnimplementedQueryServer) DataProvidersPool 

func (*UnimplementedQueryServer) DataProvidersPool(ctx context.Context, req *QueryDataProvidersPoolRequest) (*QueryDataProvidersPoolResponse, error)

func (*UnimplementedQueryServer) DataSource 

func (*UnimplementedQueryServer) DataSource(ctx context.Context, req *QueryDataSourceRequest) (*QueryDataSourceResponse, error)

func (*UnimplementedQueryServer) DataSources 

func (*UnimplementedQueryServer) DataSources(ctx context.Context, req *QueryDataSourcesRequest) (*QueryDataSourcesResponse, error)

func (*UnimplementedQueryServer) IsReporter 

func (*UnimplementedQueryServer) IsReporter(ctx context.Context, req *QueryIsReporterRequest) (*QueryIsReporterResponse, error)

func (*UnimplementedQueryServer) OracleScript 

func (*UnimplementedQueryServer) OracleScript(ctx context.Context, req *QueryOracleScriptRequest) (*QueryOracleScriptResponse, error)

func (*UnimplementedQueryServer) OracleScripts 

func (*UnimplementedQueryServer) OracleScripts(ctx context.Context, req *QueryOracleScriptsRequest) (*QueryOracleScriptsResponse, error)

func (*UnimplementedQueryServer) Params 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)

func (*UnimplementedQueryServer) PendingRequests 

func (*UnimplementedQueryServer) PendingRequests(ctx context.Context, req *QueryPendingRequestsRequest) (*QueryPendingRequestsResponse, error)

func (*UnimplementedQueryServer) Reporters 

func (*UnimplementedQueryServer) Reporters(ctx context.Context, req *QueryReportersRequest) (*QueryReportersResponse, error)

func (*UnimplementedQueryServer) Request 

func (*UnimplementedQueryServer) Request(ctx context.Context, req *QueryRequestRequest) (*QueryRequestResponse, error)

func (*UnimplementedQueryServer) RequestPrice 

func (*UnimplementedQueryServer) RequestPrice(ctx context.Context, req *QueryRequestPriceRequest) (*QueryRequestPriceResponse, error)

func (*UnimplementedQueryServer) RequestReports 

func (*UnimplementedQueryServer) RequestReports(ctx context.Context, req *QueryRequestReportsRequest) (*QueryRequestReportsResponse, error)

func (*UnimplementedQueryServer) RequestSearch 

func (*UnimplementedQueryServer) RequestSearch(ctx context.Context, req *QueryRequestSearchRequest) (*QueryRequestSearchResponse, error)

func (*UnimplementedQueryServer) RequestVerification 

func (*UnimplementedQueryServer) RequestVerification(ctx context.Context, req *QueryRequestVerificationRequest) (*QueryRequestVerificationResponse, error)

func (*UnimplementedQueryServer) Requests 

func (*UnimplementedQueryServer) Requests(ctx context.Context, req *QueryRequestsRequest) (*QueryRequestsResponse, error)

func (*UnimplementedQueryServer) Validator 

func (*UnimplementedQueryServer) Validator(ctx context.Context, req *QueryValidatorRequest) (*QueryValidatorResponse, error)

type ValidatorStatus 

type ValidatorStatus struct {
	IsActive bool      `protobuf:"varint,1,opt,name=is_active,json=isActive,proto3" json:"is_active,omitempty"`
	Since    time.Time `protobuf:"bytes,2,opt,name=since,proto3,stdtime" json:"since"`
}

ValidatorStatus maintains whether a validator is an active oracle provider.

func NewValidatorStatus 

func NewValidatorStatus(
	IsActive bool,
	Since time.Time,
) ValidatorStatus

func (*ValidatorStatus) Descriptor 

func (*ValidatorStatus) Descriptor() ([]byte, []int)

func (*ValidatorStatus) Equal 

func (this *ValidatorStatus) Equal(that interface{}) bool

func (*ValidatorStatus) GetIsActive 

func (m *ValidatorStatus) GetIsActive() bool

func (*ValidatorStatus) GetSince 

func (m *ValidatorStatus) GetSince() time.Time

func (*ValidatorStatus) Marshal 

func (m *ValidatorStatus) Marshal() (dAtA []byte, err error)

func (*ValidatorStatus) MarshalTo 

func (m *ValidatorStatus) MarshalTo(dAtA []byte) (int, error)

func (*ValidatorStatus) MarshalToSizedBuffer 

func (m *ValidatorStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ValidatorStatus) ProtoMessage 

func (*ValidatorStatus) ProtoMessage()

func (*ValidatorStatus) Reset 

func (m *ValidatorStatus) Reset()

func (*ValidatorStatus) Size 

func (m *ValidatorStatus) Size() (n int)

func (*ValidatorStatus) String 

func (m *ValidatorStatus) String() string

func (*ValidatorStatus) Unmarshal 

func (m *ValidatorStatus) Unmarshal(dAtA []byte) error

func (*ValidatorStatus) XXX_DiscardUnknown 

func (m *ValidatorStatus) XXX_DiscardUnknown()

func (*ValidatorStatus) XXX_Marshal 

func (m *ValidatorStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValidatorStatus) XXX_Merge 

func (m *ValidatorStatus) XXX_Merge(src proto.Message)

func (*ValidatorStatus) XXX_Size 

func (m *ValidatorStatus) XXX_Size() int

func (*ValidatorStatus) XXX_Unmarshal 

func (m *ValidatorStatus) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.