types

package
v3.0.0-rc0 Latest Latest
Warning

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

 Go to latest Published: Dec 6, 2024 License: GPL-3.0 Imports: 42 Imported by: 0

Documentation

Overview

NOTE: Usage of x/params to manage parameters is deprecated in favor of x/gov controlled execution of MsgUpdateParams messages. These types remains solely for migration purposes and will be removed in a future release.

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

	MaximumOwasmGas = 8000000
)
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"
	EventTypeSendPacketFail        = "send_packet_fail"
	EventTypeUpdateParams          = "update_params"
	EventTypeHandleRequestSignFail = "handle_request_sign_fail"

	AttributeKeyID                  = "id"
	AttributeKeySigningID           = "signing_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"
	AttributeKeyTotalFees           = "total_fees"
	AttributeKeyFee                 = "fee"
	AttributeKeyResult              = "result"
	AttributeKeyReason              = "reason"
	AttributeKeyParams              = "params"
	AttributeKeySigningErrCodespace = "signing_error_codespace"
	AttributeKeySigningErrCode      = "signing_error_code"
)
View Source 
const (
	// ModuleName is the name of the module.
	ModuleName = "oracle"

	// Version defines the current version the IBC oracle module supports
	Version = "bandchain-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 (
	// 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(16)
	DefaultMaxAskCount             = uint64(16)
	DefaultMaxCalldataSize         = uint64(256) // 256B
	DefaultMaxReportDataSize       = uint64(512) // 512B
	DefaultExpirationBlockCount    = uint64(100)
	DefaultBaseRequestGas          = uint64(50000)
	DefaultPerValidatorRequestGas  = uint64(0)
	DefaultSamplingTryCount        = uint64(3)
	DefaultOracleRewardPercentage  = uint64(70)
	DefaultInactivePenaltyDuration = uint64(10 * time.Minute)
	DefaultIBCRequestEnabled       = true
)
View Source 
const (
	QueryParams           = "params"
	QueryCounts           = "counts"
	QueryData             = "data"
	QueryDataSources      = "data_sources"
	QueryOracleScripts    = "oracle_scripts"
	QueryRequests         = "requests"
	QueryValidatorStatus  = "validator_status"
	QueryReporters        = "reporters"
	QueryActiveValidators = "active_validators"
	QueryPendingRequests  = "pending_requests"
)

Query endpoints supported by the oracle Querier.

View Source 
const (
	SignatureOrderTypeOracle = "oracle"
)

signature order types

Variables

View Source 
var (
	ErrOwasmCompilation         = errorsmod.Register(ModuleName, 1, "owasm compilation failed")
	ErrBadWasmExecution         = errorsmod.Register(ModuleName, 2, "bad wasm execution")
	ErrDataSourceNotFound       = errorsmod.Register(ModuleName, 3, "data source not found")
	ErrOracleScriptNotFound     = errorsmod.Register(ModuleName, 4, "oracle script not found")
	ErrRequestNotFound          = errorsmod.Register(ModuleName, 5, "request not found")
	ErrRawRequestNotFound       = errorsmod.Register(ModuleName, 6, "raw request not found")
	ErrReporterNotFound         = errorsmod.Register(ModuleName, 7, "reporter not found")
	ErrResultNotFound           = errorsmod.Register(ModuleName, 8, "result not found")
	ErrReporterAlreadyExists    = errorsmod.Register(ModuleName, 9, "reporter already exists")
	ErrValidatorNotRequested    = errorsmod.Register(ModuleName, 10, "validator not requested")
	ErrValidatorAlreadyReported = errorsmod.Register(ModuleName, 11, "validator already reported")
	ErrInvalidReportSize        = errorsmod.Register(ModuleName, 12, "invalid report size")
	ErrReporterNotAuthorized    = errorsmod.Register(ModuleName, 13, "reporter not authorized")
	ErrEditorNotAuthorized      = errorsmod.Register(ModuleName, 14, "editor not authorized")
	ErrValidatorAlreadyActive   = errorsmod.Register(ModuleName, 16, "validator already active")
	ErrTooSoonToActivate        = errorsmod.Register(ModuleName, 17, "too soon to activate")
	ErrTooLongName              = errorsmod.Register(ModuleName, 18, "too long name")
	ErrTooLongDescription       = errorsmod.Register(ModuleName, 19, "too long description")
	ErrEmptyExecutable          = errorsmod.Register(ModuleName, 20, "empty executable")
	ErrEmptyWasmCode            = errorsmod.Register(ModuleName, 21, "empty wasm code")
	ErrTooLargeExecutable       = errorsmod.Register(ModuleName, 22, "too large executable")
	ErrTooLargeWasmCode         = errorsmod.Register(ModuleName, 23, "too large wasm code")
	ErrInvalidMinCount          = errorsmod.Register(ModuleName, 24, "invalid min count")
	ErrInvalidAskCount          = errorsmod.Register(ModuleName, 25, "invalid ask count")
	ErrTooLargeCalldata         = errorsmod.Register(ModuleName, 26, "too large calldata")
	ErrTooLongClientID          = errorsmod.Register(ModuleName, 27, "too long client id")
	ErrEmptyRawRequests         = errorsmod.Register(ModuleName, 28, "empty raw requests")
	ErrEmptyReport              = errorsmod.Register(ModuleName, 29, "empty report")
	ErrDuplicateExternalID      = errorsmod.Register(ModuleName, 30, "duplicate external id")
	ErrTooLongSchema            = errorsmod.Register(ModuleName, 31, "too long schema")
	ErrTooLongURL               = errorsmod.Register(ModuleName, 32, "too long url")
	ErrTooLargeRawReportData    = errorsmod.Register(ModuleName, 33, "too large raw report data")
	ErrInsufficientValidators   = errorsmod.Register(ModuleName, 34, "insufficient available validators")
	ErrCreateWithDoNotModify    = errorsmod.Register(ModuleName, 35, "cannot create with [do-not-modify] content")
	ErrSelfReferenceAsReporter  = errorsmod.Register(ModuleName, 36, "cannot reference self as reporter")
	ErrOBIDecode                = errorsmod.Register(ModuleName, 37, "obi decode failed")
	ErrUncompressionFailed      = errorsmod.Register(ModuleName, 38, "uncompression failed")
	ErrRequestAlreadyExpired    = errorsmod.Register(ModuleName, 39, "request already expired")
	ErrBadDrbgInitialization    = errorsmod.Register(ModuleName, 40, "bad drbg initialization")
	ErrMaxOracleChannels        = errorsmod.Register(ModuleName, 41, "max oracle channels")
	ErrInvalidVersion           = errorsmod.Register(ModuleName, 42, "invalid ICS20 version")
	ErrNotEnoughFee             = errorsmod.Register(ModuleName, 43, "not enough fee")
	ErrInvalidOwasmGas          = errorsmod.Register(ModuleName, 44, "invalid owasm gas")
	ErrIBCRequestDisabled       = errorsmod.Register(ModuleName, 45, "sending oracle request via IBC is disabled")
	ErrSigningResultNotFound    = errorsmod.Register(ModuleName, 46, "signing result not found")
	ErrInvalidRequestID         = errorsmod.Register(ModuleName, 47, "invalid request id")
	ErrInvalidOracleEncoder     = errorsmod.Register(ModuleName, 48, "invalid oracle encoder")
	ErrCreateSigningPanic       = errorsmod.Register(ModuleName, 49, "panic in creating tss signing")
)
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 (
	// 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 script count.
	OracleScriptCountStoreKey = append(GlobalStoreKeyPrefix, []byte("OracleScriptCount")...)

	// 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}
	// ValidatorStatusKeyPrefix is the prefix for validator status store.
	ValidatorStatusKeyPrefix = []byte{0x05}
	// ParamsKeyPrefix is the prefix for the parameters of the module.
	ParamsKeyPrefix = []byte{0x06}
	// SigningResultStoreKeyPrefix is the prefix for signing ID store.
	SigningResultStoreKeyPrefix = []byte{0x07}
	// 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 (
	// 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")
	KeyMaxCalldataSize         = []byte("MaxCalldataSize")
	KeyMaxReportDataSize       = []byte("MaxReportDataSize")
	KeyExpirationBlockCount    = []byte("ExpirationBlockCount")
	KeyBaseOwasmGas            = []byte("BaseOwasmGas")
	KeyPerValidatorRequestGas  = []byte("PerValidatorRequestGas")
	KeySamplingTryCount        = []byte("SamplingTryCount")
	KeyOracleRewardPercentage  = []byte("OracleRewardPercentage")
	KeyInactivePenaltyDuration = []byte("InactivePenaltyDuration")
	KeyIBCRequestEnabled       = []byte("IBCRequestEnabled")
)

Parameter store keys

View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var DoNotModifyBytes = []byte(DoNotModify)
View Source 
var Encoder_name = map[int32]string{
	0: "ENCODER_UNSPECIFIED",
	1: "ENCODER_PROTO",
	2: "ENCODER_FULL_ABI",
	3: "ENCODER_PARTIAL_ABI",
}
View Source 
var Encoder_value = map[string]int32{
	"ENCODER_UNSPECIFIED": 0,
	"ENCODER_PROTO":       1,
	"ENCODER_FULL_ABI":    2,
	"ENCODER_PARTIAL_ABI": 3,
}
View Source 
var ModuleCdc = codec.NewProtoCodec(codectypes.NewInterfaceRegistry())

ModuleCdc references the global x/oracle 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/oracle and defined at the application level.

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 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 QueryBadRequest 

func QueryBadRequest(legacyQuerierCdc *codec.LegacyAmino, result interface{}) ([]byte, error)

QueryBadRequest creates and marshals a QueryResult instance with HTTP status BadRequest.

func QueryNotFound 

func QueryNotFound(legacyQuerierCdc *codec.LegacyAmino, result interface{}) ([]byte, error)

QueryNotFound creates and marshals a QueryResult instance with HTTP status NotFound.

func QueryOK 

func QueryOK(legacyQuerierCdc *codec.LegacyAmino, result interface{}) ([]byte, error)

QueryOK creates and marshals a QueryResult instance with HTTP status OK.

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/oracle 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 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 SigningResultStoreKey 

func SigningResultStoreKey(requestID RequestID) []byte

SigningResultStoreKey returns the key to a signing id 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 *errorsmod.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 context.Context, addr sdk.AccAddress) sdk.AccountI
	GetModuleAccount(ctx context.Context, moduleName string) sdk.ModuleAccountI
}

AccountKeeper defines the expected account keeper.

type ActiveValidator 

type ActiveValidator struct {
	// Address is a validator address
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Power is an amount of token that the validator is holding
	Power uint64 `protobuf:"varint,2,opt,name=power,proto3" json:"power,omitempty"`
}

ActiveValidator is information of currently active validator

func (*ActiveValidator) Descriptor 

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

func (*ActiveValidator) GetAddress 

func (m *ActiveValidator) GetAddress() string

func (*ActiveValidator) GetPower 

func (m *ActiveValidator) GetPower() uint64

func (*ActiveValidator) Marshal 

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

func (*ActiveValidator) MarshalTo 

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

func (*ActiveValidator) MarshalToSizedBuffer 

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

func (*ActiveValidator) ProtoMessage 

func (*ActiveValidator) ProtoMessage()

func (*ActiveValidator) Reset 

func (m *ActiveValidator) Reset()

func (*ActiveValidator) Size 

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

func (*ActiveValidator) String 

func (m *ActiveValidator) String() string

func (*ActiveValidator) Unmarshal 

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

func (*ActiveValidator) XXX_DiscardUnknown 

func (m *ActiveValidator) XXX_DiscardUnknown()

func (*ActiveValidator) XXX_Marshal 

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

func (*ActiveValidator) XXX_Merge 

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

func (*ActiveValidator) XXX_Size 

func (m *ActiveValidator) XXX_Size() int

func (*ActiveValidator) XXX_Unmarshal 

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

type AuthzKeeper 

type AuthzKeeper interface {
	DispatchActions(ctx context.Context, grantee sdk.AccAddress, msgs []sdk.Msg) ([][]byte, error)
	GetAuthorization(
		ctx context.Context,
		grantee, granter sdk.AccAddress,
		msgType string,
	) (authz.Authorization, *time.Time)
	GetAuthorizations(ctx context.Context, grantee, granter sdk.AccAddress) ([]authz.Authorization, error)
	SaveGrant(
		ctx context.Context,
		grantee, granter sdk.AccAddress,
		authorization authz.Authorization,
		expiration *time.Time,
	) error
	DeleteGrant(ctx context.Context, grantee, granter sdk.AccAddress, msgType string) error
	GranterGrants(ctx context.Context, req *authz.QueryGranterGrantsRequest) (*authz.QueryGranterGrantsResponse, error)
}

AuthzKeeper defines the expected authz keeper. for query and testing only don't use to create/remove grant on deliver tx

type BandtssKeeper 

type BandtssKeeper interface {
	CreateDirectSigningRequest(
		ctx sdk.Context,
		content tsstypes.Content,
		memo string,
		sender sdk.AccAddress,
		feeLimit sdk.Coins,
	) (bandtsstypes.SigningID, error)
}

BandtssKeeper defines the expected tss keeper.

type BankKeeper 

type BankKeeper interface {
	GetAllBalances(ctx context.Context, addr sdk.AccAddress) sdk.Coins
	SendCoinsFromModuleToModule(ctx context.Context, senderModule, recipientModule string, amt sdk.Coins) error
	SendCoins(ctx context.Context, from, to sdk.AccAddress, amt sdk.Coins) error
	SpendableCoins(ctx context.Context, addr sdk.AccAddress) sdk.Coins
}

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 

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 

func (env *BaseEnv) GetPrepareTime() int64

GetPrepareTime implements Owasm ExecEnv interface.

func (*BaseEnv) GetSpanSize 

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 DataSource 

type DataSource struct {
	// Owner is an address of the account who own the data source
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// Name is data source name used for display
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description is data source description used for display
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Filename is string of file name used as reference for locating
	// data source file stored in bandchain nodes
	Filename string `protobuf:"bytes,4,opt,name=filename,proto3" json:"filename,omitempty"`
	// Treasury is the account address who receive data source fee from requester.
	Treasury string `protobuf:"bytes,5,opt,name=treasury,proto3" json:"treasury,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,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, treasury sdk.AccAddress,
) 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) GetName 

func (m *DataSource) GetName() string

func (*DataSource) GetOwner 

func (m *DataSource) GetOwner() string

func (*DataSource) GetTreasury 

func (m *DataSource) GetTreasury() 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 uint64

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

type DistrKeeper 

type DistrKeeper interface {
	GetCommunityTax(ctx context.Context) (math.LegacyDec, error)
	AllocateTokensToValidator(ctx context.Context, val stakingtypes.ValidatorI, tokens sdk.DecCoins) error
	FundCommunityPool(ctx context.Context, amount sdk.Coins, sender sdk.AccAddress) error
}

DistrKeeper defines the expected distribution keeper.

type Encoder 

type Encoder int32

Encoder is an enumerator that defines the mode of encoding message in tss module. 

const (
	// ENCODER_UNSPECIFIED is for unspecified value
	ENCODER_UNSPECIFIED Encoder = 0
	// ENCODER_PROTO is for proto encoding
	ENCODER_PROTO Encoder = 1
	// ENCODER_FULL_ABI is for ABI encoding for full data
	ENCODER_FULL_ABI Encoder = 2
	// ENCODER_PARTIAL_ABI is for ABI encoding for only important data
	ENCODER_PARTIAL_ABI Encoder = 3
)

func (Encoder) EnumDescriptor 

func (Encoder) EnumDescriptor() ([]byte, []int)

func (Encoder) String 

func (x Encoder) String() string

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, spanSize int64) *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 

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 uint64

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

type GenesisState 

type GenesisState struct {
	// Params defines all the parameters of the module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	// DataSources are data sources to be installed during genesis phase.
	DataSources []DataSource `protobuf:"bytes,2,rep,name=data_sources,json=dataSources,proto3" json:"data_sources"`
	// OracleScripts are list of oracle scripts to be installed during genesis phase.
	OracleScripts []OracleScript `protobuf:"bytes,3,rep,name=oracle_scripts,json=oracleScripts,proto3" json:"oracle_scripts"`
}

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) *GenesisState

NewGenesisState creates a new GenesisState instanc e

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetDataSources 

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

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

NewIBCChannel creates a new IBCChannel instance.

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 MsgActivate 

type MsgActivate struct {
	// Validator is the validator address who sign this message and request 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. However, the activation can be revoked once the validator is unable to provide data to fulfill requests

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

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

func (*MsgActivate) String 

func (m *MsgActivate) String() string

func (*MsgActivate) Unmarshal 

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

func (MsgActivate) ValidateBasic 

func (m 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 is response data for MsgActivate message

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 MsgClient 

type MsgClient interface {
	// RequestData defines a method for submitting a new request.
	RequestData(ctx context.Context, in *MsgRequestData, opts ...grpc.CallOption) (*MsgRequestDataResponse, error)
	// ReportData defines a method for reporting a data to resolve 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)
	// UpdateParams defines a governance operation for updating the x/oracle module
	// parameters.
	//
	// Since: cosmos-sdk 0.47
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, error)
}

MsgClient is the client API for Msg service.

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

func NewMsgClient 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgCreateDataSource 

type MsgCreateDataSource struct {
	// Name is the name of this data source used for display (optional).
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Description is the description of this data source used for display
	// (optional).
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// Executable is the content of executable script or binary file 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"`
	// Treasury is the account address who receive data source fee from requester.
	Treasury string `protobuf:"bytes,5,opt,name=treasury,proto3" json:"treasury,omitempty"`
	// Owner is the account 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.
	Sender string `protobuf:"bytes,7,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, treasury, 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) GetTreasury 

func (m *MsgCreateDataSource) GetTreasury() string

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

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

func (*MsgCreateDataSource) String 

func (m *MsgCreateDataSource) String() string

func (*MsgCreateDataSource) Unmarshal 

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

func (MsgCreateDataSource) ValidateBasic 

func (m 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 is response data for MsgCreateDataSource message

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 used for display (optional).
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Description is the description of this oracle script used for display
	// (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) 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) Size 

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

func (*MsgCreateOracleScript) String 

func (m *MsgCreateOracleScript) String() string

func (*MsgCreateOracleScript) Unmarshal 

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

func (MsgCreateOracleScript) ValidateBasic 

func (m 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 is response data for MsgCreateOracleScript message

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 used for display (optional).
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description is the description of this data source used for display
	// (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"`
	// Treasury is the address who receive data source fee from requester.
	Treasury string `protobuf:"bytes,6,opt,name=treasury,proto3" json:"treasury,omitempty"`
	// Owner is the address who is allowed to make further changes to the data
	// source.
	Owner string `protobuf:"bytes,7,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,8,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,
	treasury, 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) GetTreasury 

func (m *MsgEditDataSource) GetTreasury() string

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

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

func (*MsgEditDataSource) String 

func (m *MsgEditDataSource) String() string

func (*MsgEditDataSource) Unmarshal 

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

func (MsgEditDataSource) ValidateBasic 

func (m 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 is response data for MsgEditDataSource message

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 used for display (optional).
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description is the description of this oracle script used for display
	// (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 an account 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 an account address who sign 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) 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) Size 

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

func (*MsgEditOracleScript) String 

func (m *MsgEditOracleScript) String() string

func (*MsgEditOracleScript) Unmarshal 

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

func (MsgEditOracleScript) ValidateBasic 

func (m 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 is response data for MsgEditOracleScript message

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 MsgReportData 

type MsgReportData struct {
	// RequestID is the identifier of the request to be reported 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 provided by data sources
	// identified by 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"`
}

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

NewMsgReportData creates a new MsgReportData instance

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

func (m *MsgReportData) GetRequestID() RequestID

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

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

func (*MsgReportData) String 

func (m *MsgReportData) String() string

func (*MsgReportData) Unmarshal 

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

func (MsgReportData) ValidateBasic 

func (m 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 is response data for MsgReportData message

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 be called.
	OracleScriptID OracleScriptID `` /* 130-byte string literal not displayed */
	// Calldata is the OBI-encoded call parameters for 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
	// oracle 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 track 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 an account address of message sender.
	Sender string `protobuf:"bytes,9,opt,name=sender,proto3" json:"sender,omitempty"`
	// TSSEncoder is the mode of encoding oracle result signature order.
	TSSEncoder Encoder `protobuf:"varint,10,opt,name=tss_encoder,json=tssEncoder,proto3,enum=band.oracle.v1.Encoder" json:"tss_encoder,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,
	tssEncoder Encoder,
) *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) GetTSSEncoder 

func (m *MsgRequestData) GetTSSEncoder() Encoder

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

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

func (*MsgRequestData) String 

func (m *MsgRequestData) String() string

func (*MsgRequestData) Unmarshal 

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

func (MsgRequestData) ValidateBasic 

func (m 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 is response data for MsgRequestData message

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 submitting a new request.
	RequestData(context.Context, *MsgRequestData) (*MsgRequestDataResponse, error)
	// ReportData defines a method for reporting a data to resolve 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)
	// UpdateParams defines a governance operation for updating the x/oracle module
	// parameters.
	//
	// Since: cosmos-sdk 0.47
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
}

MsgServer is the server API for Msg service.

type MsgUpdateParams 

type MsgUpdateParams struct {
	// authority is the address of the governance account.
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// params defines the x/oracle parameters to update.
	//
	// NOTE: All parameters must be supplied.
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

MsgUpdateParams is the Msg/UpdateParams request type.

Since: cosmos-sdk 0.47

func NewMsgUpdateParams 

func NewMsgUpdateParams(authority string, params Params) *MsgUpdateParams

NewMsgActivate creates a new MsgActivate instance

func (*MsgUpdateParams) Descriptor 

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

func (*MsgUpdateParams) GetAuthority 

func (m *MsgUpdateParams) GetAuthority() string

func (*MsgUpdateParams) GetParams 

func (m *MsgUpdateParams) GetParams() Params

func (*MsgUpdateParams) Marshal 

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

func (*MsgUpdateParams) MarshalTo 

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

func (*MsgUpdateParams) MarshalToSizedBuffer 

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

func (*MsgUpdateParams) ProtoMessage 

func (*MsgUpdateParams) ProtoMessage()

func (*MsgUpdateParams) Reset 

func (m *MsgUpdateParams) Reset()

func (*MsgUpdateParams) Size 

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

func (*MsgUpdateParams) String 

func (m *MsgUpdateParams) String() string

func (*MsgUpdateParams) Unmarshal 

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

func (*MsgUpdateParams) ValidateBasic 

func (m *MsgUpdateParams) ValidateBasic() error

ValidateBasic does a sanity check on the provided data.

func (*MsgUpdateParams) XXX_DiscardUnknown 

func (m *MsgUpdateParams) XXX_DiscardUnknown()

func (*MsgUpdateParams) XXX_Marshal 

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

func (*MsgUpdateParams) XXX_Merge 

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

func (*MsgUpdateParams) XXX_Size 

func (m *MsgUpdateParams) XXX_Size() int

func (*MsgUpdateParams) XXX_Unmarshal 

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

type MsgUpdateParamsResponse 

type MsgUpdateParamsResponse struct {
}

MsgUpdateParamsResponse defines the response structure for executing a MsgUpdateParams message.

Since: cosmos-sdk 0.47

func (*MsgUpdateParamsResponse) Descriptor 

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

func (*MsgUpdateParamsResponse) Marshal 

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

func (*MsgUpdateParamsResponse) MarshalTo 

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

func (*MsgUpdateParamsResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateParamsResponse) ProtoMessage 

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) Reset 

func (m *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) Size 

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

func (*MsgUpdateParamsResponse) String 

func (m *MsgUpdateParamsResponse) String() string

func (*MsgUpdateParamsResponse) Unmarshal 

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

func (*MsgUpdateParamsResponse) XXX_DiscardUnknown 

func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamsResponse) XXX_Marshal 

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

func (*MsgUpdateParamsResponse) XXX_Merge 

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

func (*MsgUpdateParamsResponse) XXX_Size 

func (m *MsgUpdateParamsResponse) XXX_Size() int

func (*MsgUpdateParamsResponse) XXX_Unmarshal 

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

type 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 OBI-encoded 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 */
	// 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"`
	// TSSEncoder is the mode of encoding oracle result signature order.
	TSSEncoder Encoder `protobuf:"varint,9,opt,name=tss_encoder,json=tssEncoder,proto3,enum=band.oracle.v1.Encoder" json:"tss_encoder,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,
	tssEncoder Encoder,
	feeLimit sdk.Coins,
	prepareGas uint64,
	executeGas uint64,
) 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) GetTSSEncoder 

func (m *OracleRequestPacketData) GetTSSEncoder() Encoder

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 `` /* 135-byte string literal not displayed */
	// Result is the final aggregated value encoded in OBI format. 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 OracleResultSignatureOrder 

type OracleResultSignatureOrder struct {
	// RequestID is oracle'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"`
	// encoder is the mode of encoding oracle result signature order.
	Encoder Encoder `protobuf:"varint,3,opt,name=encoder,proto3,enum=band.oracle.v1.Encoder" json:"encoder,omitempty"`
}

OracleResultSignatureOrder defines a request id to request bandtss signature from the oracle result.

func NewOracleResultSignatureOrder 

func NewOracleResultSignatureOrder(rid RequestID, encoder Encoder) *OracleResultSignatureOrder

NewOracleResultSignatureOrder returns a new OracleResultSignatureOrder object

func (*OracleResultSignatureOrder) Descriptor 

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

func (*OracleResultSignatureOrder) IsInternal 

func (o *OracleResultSignatureOrder) IsInternal() bool

IsInternal returns false for OracleResultSignatureOrder (allow user to submit this content type).

func (*OracleResultSignatureOrder) Marshal 

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

func (*OracleResultSignatureOrder) MarshalTo 

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

func (*OracleResultSignatureOrder) MarshalToSizedBuffer 

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

func (*OracleResultSignatureOrder) OrderRoute 

func (o *OracleResultSignatureOrder) OrderRoute() string

OrderRoute returns the order router key

func (*OracleResultSignatureOrder) OrderType 

func (o *OracleResultSignatureOrder) OrderType() string

OrderType returns type of signature order that should be "oracle"

func (*OracleResultSignatureOrder) ProtoMessage 

func (*OracleResultSignatureOrder) ProtoMessage()

func (*OracleResultSignatureOrder) Reset 

func (m *OracleResultSignatureOrder) Reset()

func (*OracleResultSignatureOrder) Size 

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

func (*OracleResultSignatureOrder) String 

func (m *OracleResultSignatureOrder) String() string

func (*OracleResultSignatureOrder) Unmarshal 

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

func (*OracleResultSignatureOrder) ValidateBasic 

func (o *OracleResultSignatureOrder) ValidateBasic() error

ValidateBasic validates the request's title and description of the request signature

func (*OracleResultSignatureOrder) XXX_DiscardUnknown 

func (m *OracleResultSignatureOrder) XXX_DiscardUnknown()

func (*OracleResultSignatureOrder) XXX_Marshal 

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

func (*OracleResultSignatureOrder) XXX_Merge 

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

func (*OracleResultSignatureOrder) XXX_Size 

func (m *OracleResultSignatureOrder) XXX_Size() int

func (*OracleResultSignatureOrder) XXX_Unmarshal 

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

type OracleScript 

type OracleScript struct {
	// Owner is an address of the account who own the oracle script
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// Name is oracle script name used for display
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description is oracle script description used for display
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Filename is string of file name used as reference for locating
	// compiled oracle script WASM file stored in bandchain nodes
	Filename string `protobuf:"bytes,4,opt,name=filename,proto3" json:"filename,omitempty"`
	// Schema is the schema of the oracle script input/output
	// which is formatted in OBI format e.g.
	// "{symbol:string,multiplier:u64}/{px:u64}"
	Schema string `protobuf:"bytes,5,opt,name=schema,proto3" json:"schema,omitempty"`
	// SourceCodeURL is the URL of oracle script's source code.
	// It is recommendded to store source code on IPFS and get its URL to preserve
	// decentralization.
	SourceCodeURL string `protobuf:"bytes,6,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) 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 uint64

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"`
	// MaxCalldataSize is the maximum size limit of calldata (bytes) in a request.
	MaxCalldataSize uint64 `protobuf:"varint,3,opt,name=max_calldata_size,json=maxCalldataSize,proto3" json:"max_calldata_size,omitempty"`
	// MaxReportDataSize is the maximum size limit of report data (bytes) in a
	// report.
	MaxReportDataSize uint64 `protobuf:"varint,4,opt,name=max_report_data_size,json=maxReportDataSize,proto3" json:"max_report_data_size,omitempty"`
	// ExpirationBlockCount is the number of blocks a request stays valid before
	// it gets expired due to insufficient reports.
	ExpirationBlockCount uint64 `protobuf:"varint,5,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,6,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,8,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 `` /* 134-byte string literal not displayed */
	// IBCRequestEnabled is a flag indicating whether sending oracle request via
	// IBC is allowed
	IBCRequestEnabled bool `protobuf:"varint,11,opt,name=ibc_request_enabled,json=ibcRequestEnabled,proto3" json:"ibc_request_enabled,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, maxCalldataSize, maxReportDataSize, expirationBlockCount, baseRequestGas, perValidatorRequestGas,
	samplingTryCount, oracleRewardPercentage, inactivePenaltyDuration uint64,
	ibcRequestEnabled bool,
) 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) GetExpirationBlockCount 

func (m *Params) GetExpirationBlockCount() uint64

func (*Params) GetIBCRequestEnabled 

func (m *Params) GetIBCRequestEnabled() bool

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

func (m *Params) GetMaxRawRequestCount() uint64

func (*Params) GetMaxReportDataSize 

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 (m *Params) String() string

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

Validate does the sanity check on the params.

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 is a list of request IDs that are waiting to be resolved
	RequestIds []uint64 `protobuf:"varint,1,rep,packed,name=request_ids,json=requestIds,proto3" json:"request_ids,omitempty"`
}

PendingResolveList is a list of requests that are waiting to be resolved

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() []uint64

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, spanSize 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 PriceResult 

type PriceResult struct {
	// Symbol is unit of data indicating what the data is. It is price currencies
	// for this case.
	Symbol string `protobuf:"bytes,1,opt,name=symbol,proto3" json:"symbol,omitempty"`
	// Multiplier is a number used for left-shifting value to eliminate decimal
	// digits
	Multiplier uint64 `protobuf:"varint,2,opt,name=multiplier,proto3" json:"multiplier,omitempty"`
	// Px is the actual data, which is rate number multiplied by the multiplier.
	Px uint64 `protobuf:"varint,3,opt,name=px,proto3" json:"px,omitempty"`
	// RequestID is oracle request ID that contains this price
	RequestID RequestID `protobuf:"varint,4,opt,name=request_id,json=requestId,proto3,casttype=RequestID" json:"request_id,omitempty"`
	// ResolveTime is epoch timestamp indicating the time when the request had
	// been resolved
	ResolveTime int64 `protobuf:"varint,5,opt,name=resolve_time,json=resolveTime,proto3" json:"resolve_time,omitempty"`
}

PriceResult is a result from standard price reference

func (*PriceResult) Descriptor 

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

func (*PriceResult) GetMultiplier 

func (m *PriceResult) GetMultiplier() uint64

func (*PriceResult) GetPx 

func (m *PriceResult) GetPx() uint64

func (*PriceResult) GetRequestID 

func (m *PriceResult) GetRequestID() RequestID

func (*PriceResult) GetResolveTime 

func (m *PriceResult) GetResolveTime() int64

func (*PriceResult) GetSymbol 

func (m *PriceResult) GetSymbol() string

func (*PriceResult) Marshal 

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

func (*PriceResult) MarshalTo 

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

func (*PriceResult) MarshalToSizedBuffer 

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

func (*PriceResult) ProtoMessage 

func (*PriceResult) ProtoMessage()

func (*PriceResult) Reset 

func (m *PriceResult) Reset()

func (*PriceResult) Size 

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

func (*PriceResult) String 

func (m *PriceResult) String() string

func (*PriceResult) Unmarshal 

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

func (*PriceResult) XXX_DiscardUnknown 

func (m *PriceResult) XXX_DiscardUnknown()

func (*PriceResult) XXX_Marshal 

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

func (*PriceResult) XXX_Merge 

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

func (*PriceResult) XXX_Size 

func (m *PriceResult) XXX_Size() int

func (*PriceResult) XXX_Unmarshal 

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

type QueryActiveValidatorResult 

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

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 {
	// Validators is a list of active validators
	Validators []*ActiveValidator `protobuf:"bytes,1,rep,name=validators,proto3" json:"validators,omitempty"`
}

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

func (*QueryActiveValidatorsResponse) Descriptor 

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

func (*QueryActiveValidatorsResponse) GetValidators 

func (m *QueryActiveValidatorsResponse) GetValidators() []*ActiveValidator

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 existing data sources, oracle scripts, and
	// requests.
	Counts(ctx context.Context, in *QueryCountsRequest, opts ...grpc.CallOption) (*QueryCountsResponse, error)
	// Data queries content of the data source or oracle script for given SHA256
	// file hash.
	Data(ctx context.Context, in *QueryDataRequest, opts ...grpc.CallOption) (*QueryDataResponse, error)
	// DataSource queries data source summary info for given data source id.
	DataSource(ctx context.Context, in *QueryDataSourceRequest, opts ...grpc.CallOption) (*QueryDataSourceResponse, error)
	// OracleScript queries oracle script summary info for given oracle script id.
	OracleScript(ctx context.Context, in *QueryOracleScriptRequest, opts ...grpc.CallOption) (*QueryOracleScriptResponse, error)
	// Request queries request info for given request id.
	Request(ctx context.Context, in *QueryRequestRequest, opts ...grpc.CallOption) (*QueryRequestResponse, error)
	// PendingRequests queries list of pending request IDs assigned to given
	// validator.
	PendingRequests(ctx context.Context, in *QueryPendingRequestsRequest, opts ...grpc.CallOption) (*QueryPendingRequestsResponse, error)
	// Validator queries properties of 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 associated with 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 parameters used for runnning bandchain network.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// RequestSearch queries the latest request that match search criteria.
	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)
	// 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)
}

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 is total number of data sources available on the chain
	DataSourceCount uint64 `protobuf:"varint,1,opt,name=data_source_count,json=dataSourceCount,proto3" json:"data_source_count,omitempty"`
	// OracleScriptCount is total number of oracle scripts available on the chain
	OracleScriptCount uint64 `protobuf:"varint,2,opt,name=oracle_script_count,json=oracleScriptCount,proto3" json:"oracle_script_count,omitempty"`
	// RequestCount is total number of requests submitted to the chain
	RequestCount uint64 `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() uint64

func (*QueryCountsResponse) GetOracleScriptCount 

func (m *QueryCountsResponse) GetOracleScriptCount() uint64

func (*QueryCountsResponse) GetRequestCount 

func (m *QueryCountsResponse) GetRequestCount() uint64

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 QueryCountsResult 

type QueryCountsResult struct {
	DataSourceCount   uint64 `json:"data_source_count"`
	OracleScriptCount uint64 `json:"oracle_script_count"`
	RequestCount      uint64 `json:"request_count"`
}

QueryCountsResult is the struct for the result of query counts.

type QueryDataRequest 

type QueryDataRequest struct {
	// DataHash is SHA256 hash of the file's content, which can be data source or
	// oracle script
	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 is file's content, which can be data source or oracle script
	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 is ID of a data source script
	DataSourceId uint64 `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() uint64

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 is summary information of a data source
	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 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 is ID of an oracle script
	OracleScriptId uint64 `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() uint64

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 is summary information of an oracle script
	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 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 []uint64 `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() []uint64

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 is a validator address
	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 is a list of account addresses of reporters
	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 QueryRequestPriceRequest 

type QueryRequestPriceRequest struct {
	// Symbol is unit of data indicating what the data is
	Symbols []string `protobuf:"bytes,1,rep,name=symbols,proto3" json:"symbols,omitempty"`
	// AskCount is number of validators allowed for fulfilling the request
	AskCount uint64 `protobuf:"varint,2,opt,name=ask_count,json=askCount,proto3" json:"ask_count,omitempty"`
	// MinCount is number of validators required for fulfilling the request
	MinCount uint64 `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 (*QueryRequestPriceRequest) Descriptor 

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

func (*QueryRequestPriceRequest) GetAskCount 

func (m *QueryRequestPriceRequest) GetAskCount() uint64

func (*QueryRequestPriceRequest) GetMinCount 

func (m *QueryRequestPriceRequest) GetMinCount() uint64

func (*QueryRequestPriceRequest) GetSymbols 

func (m *QueryRequestPriceRequest) GetSymbols() []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 {
	// PriceResult is a list of price results for given symbols
	PriceResults []*PriceResult `protobuf:"bytes,1,rep,name=price_results,json=priceResults,proto3" json:"price_results,omitempty"`
}

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

func (*QueryRequestPriceResponse) Descriptor 

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

func (*QueryRequestPriceResponse) GetPriceResults 

func (m *QueryRequestPriceResponse) GetPriceResults() []*PriceResult

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 QueryRequestRequest 

type QueryRequestRequest struct {
	// RequestID is ID of an oracle request
	RequestId uint64 `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() uint64

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"`
	// Reports is list of result data as raw reports that are fulfilled by
	// assigned validators
	Reports []Report `protobuf:"bytes,2,rep,name=reports,proto3" json:"reports"`
	// Result is a final form of result data
	Result *Result `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	// Signing is the signing detail in the bandtss module.
	Signing *SigningResult `protobuf:"bytes,4,opt,name=signing,proto3" json:"signing,omitempty"`
}

QueryRequestResponse is response type for the Query/Request RPC method.

func (*QueryRequestResponse) Descriptor 

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

func (*QueryRequestResponse) GetReports 

func (m *QueryRequestResponse) GetReports() []Report

func (*QueryRequestResponse) GetRequest 

func (m *QueryRequestResponse) GetRequest() *Request

func (*QueryRequestResponse) GetResult 

func (m *QueryRequestResponse) GetResult() *Result

func (*QueryRequestResponse) GetSigning 

func (m *QueryRequestResponse) GetSigning() *SigningResult

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 QueryRequestResult 

type QueryRequestResult struct {
	Request Request  `json:"request"`
	Reports []Report `json:"reports"`
	Result  *Result  `json:"result"`
}

QueryRequestResult is the struct for the result of request query.

type QueryRequestSearchRequest 

type QueryRequestSearchRequest struct {
	// OracleScriptID is ID of an oracle script
	OracleScriptId uint64 `protobuf:"varint,1,opt,name=oracle_script_id,json=oracleScriptId,proto3" json:"oracle_script_id,omitempty"`
	// Calldata is OBI-encoded data in hex format as argument params for the
	// oracle script
	Calldata string `protobuf:"bytes,2,opt,name=calldata,proto3" json:"calldata,omitempty"`
	// AskCount is number of validators allowed for fulfilling the request
	AskCount uint64 `protobuf:"varint,3,opt,name=ask_count,json=askCount,proto3" json:"ask_count,omitempty"`
	// MinCount is number of validators required for fulfilling the request
	MinCount uint64 `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 (*QueryRequestSearchRequest) Descriptor 

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

func (*QueryRequestSearchRequest) GetAskCount 

func (m *QueryRequestSearchRequest) GetAskCount() uint64

func (*QueryRequestSearchRequest) GetCalldata 

func (m *QueryRequestSearchRequest) GetCalldata() string

func (*QueryRequestSearchRequest) GetMinCount 

func (m *QueryRequestSearchRequest) GetMinCount() uint64

func (*QueryRequestSearchRequest) GetOracleScriptId 

func (m *QueryRequestSearchRequest) GetOracleScriptId() uint64

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 is details of an oracle request
	Request *QueryRequestResponse `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
}

QueryRequestSearchResponse is response type for the Query/RequestSearch RPC method.

func (*QueryRequestSearchResponse) Descriptor 

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

func (*QueryRequestSearchResponse) GetRequest 

func (m *QueryRequestSearchResponse) GetRequest() *QueryRequestResponse

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"`
	// 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"`
	// Reporter is an bech32-encoded public key of the reporter authorized by the
	// 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"`
	// MaxDelay is a max number of RequestID delay acceptable in case of node
	// delay
	MaxDelay uint64 `protobuf:"varint,8,opt,name=max_delay,json=maxDelay,proto3" json:"max_delay,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 

func (m *QueryRequestVerificationRequest) GetDataSourceId() uint64

func (*QueryRequestVerificationRequest) GetExternalId 

func (m *QueryRequestVerificationRequest) GetExternalId() uint64

func (*QueryRequestVerificationRequest) GetMaxDelay 

func (m *QueryRequestVerificationRequest) GetMaxDelay() 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"`
	// IsDelay is a flag to tell that this request is not exist yet but in
	// MaxDelay range
	IsDelay bool `protobuf:"varint,6,opt,name=is_delay,json=isDelay,proto3" json:"is_delay,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) GetIsDelay 

func (m *QueryRequestVerificationResponse) GetIsDelay() bool

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 QueryResult 

type QueryResult struct {
	Status int             `json:"status"`
	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 existing data sources, oracle scripts, and
	// requests.
	Counts(context.Context, *QueryCountsRequest) (*QueryCountsResponse, error)
	// Data queries content of the data source or oracle script for given SHA256
	// file hash.
	Data(context.Context, *QueryDataRequest) (*QueryDataResponse, error)
	// DataSource queries data source summary info for given data source id.
	DataSource(context.Context, *QueryDataSourceRequest) (*QueryDataSourceResponse, error)
	// OracleScript queries oracle script summary info for given oracle script id.
	OracleScript(context.Context, *QueryOracleScriptRequest) (*QueryOracleScriptResponse, error)
	// Request queries request info for given request id.
	Request(context.Context, *QueryRequestRequest) (*QueryRequestResponse, error)
	// PendingRequests queries list of pending request IDs assigned to given
	// validator.
	PendingRequests(context.Context, *QueryPendingRequestsRequest) (*QueryPendingRequestsResponse, error)
	// Validator queries properties of 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 associated with given validator address.
	Reporters(context.Context, *QueryReportersRequest) (*QueryReportersResponse, error)
	// ActiveValidators queries all active oracle validators.
	ActiveValidators(context.Context, *QueryActiveValidatorsRequest) (*QueryActiveValidatorsResponse, error)
	// Params queries parameters used for runnning bandchain network.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// RequestSearch queries the latest request that match search criteria.
	RequestSearch(context.Context, *QueryRequestSearchRequest) (*QueryRequestSearchResponse, error)
	// RequestPrice queries the latest price on standard price reference oracle
	// script.
	RequestPrice(context.Context, *QueryRequestPriceRequest) (*QueryRequestPriceResponse, 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)
}

QueryServer is the server API for Query service.

type QueryValidatorRequest 

type QueryValidatorRequest struct {
	// ValidatorAddress is address of a validator
	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 is status of a validator e.g. active/inactive
	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 is an ID of the raw request
	ExternalID ExternalID `protobuf:"varint,1,opt,name=external_id,json=externalId,proto3,casttype=ExternalID" json:"external_id,omitempty"`
	// ExitCode is status code provided by validators to specify error, if any.
	// Exit code is usually filled by the exit code returned from execution of
	// specified data source script. With code 0 means there is no error.
	ExitCode uint32 `protobuf:"varint,2,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// Data is raw result provided by validators.
	// It is usually filled by the result from execution of specified data source
	// script.
	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 is an ID of the raw request
	ExternalID ExternalID `protobuf:"varint,1,opt,name=external_id,json=externalId,proto3,casttype=ExternalID" json:"external_id,omitempty"`
	// DataSourceID is an ID of data source script that relates to the raw request
	DataSourceID DataSourceID `protobuf:"varint,2,opt,name=data_source_id,json=dataSourceId,proto3,casttype=DataSourceID" json:"data_source_id,omitempty"`
	// Calldata is the data used as argument params for executing data source
	// script
	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 is a validator address who submit the report
	Validator string `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator,omitempty"`
	// InBeforeResolve indicates whether the report is submitted before the
	// request resolved
	InBeforeResolve bool `protobuf:"varint,2,opt,name=in_before_resolve,json=inBeforeResolve,proto3" json:"in_before_resolve,omitempty"`
	// RawReports is list of raw reports provided by the validator.
	// Each raw report has different external ID
	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 {
	// OracleScriptID is ID of an oracle script
	OracleScriptID OracleScriptID `` /* 130-byte string literal not displayed */
	// Calldata is the data used as argument params for the oracle script
	Calldata []byte `protobuf:"bytes,2,opt,name=calldata,proto3" json:"calldata,omitempty"`
	// RequestedValidators is a list of validator addresses that are assigned for
	// fulfilling the request
	RequestedValidators []string `protobuf:"bytes,3,rep,name=requested_validators,json=requestedValidators,proto3" json:"requested_validators,omitempty"`
	// MinCount is minimum number of validators required for fulfilling the
	// request
	MinCount uint64 `protobuf:"varint,4,opt,name=min_count,json=minCount,proto3" json:"min_count,omitempty"`
	// RequestHeight is block height that the request has been created
	RequestHeight int64 `protobuf:"varint,5,opt,name=request_height,json=requestHeight,proto3" json:"request_height,omitempty"`
	// RequestTime is timestamp of the chain's block which contains the request
	RequestTime int64 `protobuf:"varint,6,opt,name=request_time,json=requestTime,proto3" json:"request_time,omitempty"`
	// ClientID is arbitrary id provided by requester.
	// It is used by client-side for referencing the request
	ClientID string `protobuf:"bytes,7,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// RawRequests is a list of raw requests specified by execution of oracle
	// script
	RawRequests []RawRequest `protobuf:"bytes,8,rep,name=raw_requests,json=rawRequests,proto3" json:"raw_requests"`
	// IBCChannel is an IBC channel info of the other chain, which contains a
	// channel and a port to allow bandchain connect to that chain. This field
	// allows other chain be able to request data from bandchain via IBC.
	IBCChannel *IBCChannel `protobuf:"bytes,9,opt,name=ibc_channel,json=ibcChannel,proto3" json:"ibc_channel,omitempty"`
	// ExecuteGas is amount of gas to reserve for executing
	ExecuteGas uint64 `protobuf:"varint,10,opt,name=execute_gas,json=executeGas,proto3" json:"execute_gas,omitempty"`
	// TSSEncoder is the mode of encoding oracle result signature order.
	TSSEncoder Encoder `protobuf:"varint,11,opt,name=tss_encoder,json=tssEncoder,proto3,enum=band.oracle.v1.Encoder" json:"tss_encoder,omitempty"`
	// Requester is the address of person who requests the data.
	Requester string `protobuf:"bytes,12,opt,name=requester,proto3" json:"requester,omitempty"`
	// FeeLimit is the maximum tokens that will be paid for this request.
	FeeLimit github_com_cosmos_cosmos_sdk_types.Coins `` /* 130-byte string literal not displayed */
}

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,
	ibcChannel *IBCChannel,
	executeGas uint64,
	tssEncoder Encoder,
	requester string,
	feeLimit sdk.Coins,
) 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) GetFeeLimit 

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

func (*Request) GetIBCChannel 

func (m *Request) GetIBCChannel() *IBCChannel

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

func (*Request) GetRequestedValidators 

func (m *Request) GetRequestedValidators() []string

func (*Request) GetRequester 

func (m *Request) GetRequester() string

func (*Request) GetTSSEncoder 

func (m *Request) GetTSSEncoder() Encoder

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 uint64

RequestID is the type-safe unique identifier type for data requests.

type RequestSpec 

type RequestSpec interface {
	GetOracleScriptID() OracleScriptID
	GetCalldata() []byte
	GetAskCount() uint64
	GetMinCount() uint64
	GetClientID() string
	GetPrepareGas() uint64
	GetExecuteGas() uint64
	GetFeeLimit() sdk.Coins
	GetTSSEncoder() Encoder
}

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 

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 `` /* 136-byte string literal not displayed */
	// Result is the final aggregated value only available if status if OK.
	Result []byte `protobuf:"bytes,11,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) PackFullABI 

func (r Result) PackFullABI() ([]byte, error)

PackFullABI serializes a Result struct into a byte slice using the ABI encoding.

func (Result) PackPartialABI 

func (r Result) PackPartialABI() ([]byte, error)

PackPartialABI serializes a Result struct into a byte slice using the ABI encoding with only some fields.

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 RollingseedKeeper 

type RollingseedKeeper interface {
	GetRollingSeed(ctx sdk.Context) []byte
}

RollingseedKeeper defines the expected rollingseed keeper

type SigningResult 

type SigningResult struct {
	// signing_id is the id of the bandtss signing
	SigningID github_com_bandprotocol_chain_v3_x_bandtss_types.SigningID `` /* 157-byte string literal not displayed */
	// error_codespace is the codespace of the error
	ErrorCodespace string `protobuf:"bytes,2,opt,name=error_codespace,json=errorCodespace,proto3" json:"error_codespace,omitempty"`
	// error_code is the code in the codespace of the error
	ErrorCode uint64 `protobuf:"varint,3,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
}

SigningResult encodes a result of signing of request

func (*SigningResult) Descriptor 

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

func (*SigningResult) Equal 

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

func (*SigningResult) GetErrorCode 

func (m *SigningResult) GetErrorCode() uint64

func (*SigningResult) GetErrorCodespace 

func (m *SigningResult) GetErrorCodespace() string

func (*SigningResult) GetSigningID 

func (m *SigningResult) GetSigningID() github_com_bandprotocol_chain_v3_x_bandtss_types.SigningID

func (*SigningResult) Marshal 

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

func (*SigningResult) MarshalTo 

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

func (*SigningResult) MarshalToSizedBuffer 

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

func (*SigningResult) ProtoMessage 

func (*SigningResult) ProtoMessage()

func (*SigningResult) Reset 

func (m *SigningResult) Reset()

func (*SigningResult) Size 

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

func (*SigningResult) String 

func (m *SigningResult) String() string

func (*SigningResult) Unmarshal 

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

func (*SigningResult) XXX_DiscardUnknown 

func (m *SigningResult) XXX_DiscardUnknown()

func (*SigningResult) XXX_Marshal 

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

func (*SigningResult) XXX_Merge 

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

func (*SigningResult) XXX_Size 

func (m *SigningResult) XXX_Size() int

func (*SigningResult) XXX_Unmarshal 

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

type StakingKeeper 

type StakingKeeper interface {
	ValidatorByConsAddr(context.Context, sdk.ConsAddress) (stakingtypes.ValidatorI, error)
	IterateBondedValidatorsByPower(context.Context,
		func(index int64, validator stakingtypes.ValidatorI) (stop bool)) error
	Validator(context.Context, sdk.ValAddress) (stakingtypes.ValidatorI, error)
}

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

func (*UnimplementedMsgServer) ReportData(ctx context.Context, req *MsgReportData) (*MsgReportDataResponse, error)

func (*UnimplementedMsgServer) RequestData 

func (*UnimplementedMsgServer) RequestData(ctx context.Context, req *MsgRequestData) (*MsgRequestDataResponse, error)

func (*UnimplementedMsgServer) UpdateParams 

func (*UnimplementedMsgServer) UpdateParams(ctx context.Context, req *MsgUpdateParams) (*MsgUpdateParamsResponse, 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) DataSource 

func (*UnimplementedQueryServer) DataSource(ctx context.Context, req *QueryDataSourceRequest) (*QueryDataSourceResponse, 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) 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) 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) Validator 

func (*UnimplementedQueryServer) Validator(ctx context.Context, req *QueryValidatorRequest) (*QueryValidatorResponse, error)

type ValidatorStatus 

type ValidatorStatus struct {
	// IsActive is a boolean indicating active status of validator.
	// The validator will be deactivated when they are unable to send reports
	// to fulfill oracle request before the request expired.
	IsActive bool `protobuf:"varint,1,opt,name=is_active,json=isActive,proto3" json:"is_active,omitempty"`
	// Since is a block timestamp when validator has been activated/deactivated
	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.