types

package
v0.0.0-...-81ad42b Latest Latest
Warning

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

 Go to latest Published: Sep 22, 2020 License: GPL-3.0 Imports: 21 Imported by: 0

Documentation

Overview

Code generated by protoconstructorgen.py. DO NOT EDIT.

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
	MaxDataSize             = 256             // 256B

	WasmPrepareGas = 1000000
	WasmExecuteGas = 5000000
)

nolint

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

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

nolint

View Source 
const (
	// ModuleName is the name of the module.
	ModuleName = "oracle"
	// StoreKey to be used when creating the KVStore.
	StoreKey = ModuleName
	// Default PortID that oracle module binds to.
	PortID = ModuleName
)
View Source 
const (
	// DefaultParamspace is the parameter namespace key for this module - "oracle"
	DefaultParamspace = ModuleName
	// Each value below is the default value for each parameter when generating the default
	// genesis file. See comments in types.proto for explanation for each parameter.
	DefaultMaxRawRequestCount      = uint64(12)
	DefaultMaxAskCount             = uint64(16)
	DefaultExpirationBlockCount    = uint64(100)
	DefaultBaseRequestGas          = uint64(150000)
	DefaultPerValidatorRequestGas  = uint64(30000)
	DefaultSamplingTryCount        = uint64(3)
	DefaultOracleRewardPercentage  = uint64(70)
	DefaultInactivePenaltyDuration = uint64(10 * time.Minute)
)

nolint

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

Query endpoints supported by the oracle Querier.

View Source 
const RouterKey = ModuleName

RouterKey is the name of the oracle module

Variables

View Source 
var (
	ErrOwasmCompilation         = sdkerrors.Register(ModuleName, 1, "owasm compilation failed")
	ErrBadWasmExecution         = sdkerrors.Register(ModuleName, 2, "bad wasm execution")
	ErrDataSourceNotFound       = sdkerrors.Register(ModuleName, 3, "data source not found")
	ErrOracleScriptNotFound     = sdkerrors.Register(ModuleName, 4, "oracle script not found")
	ErrRequestNotFound          = sdkerrors.Register(ModuleName, 5, "request not found")
	ErrRawRequestNotFound       = sdkerrors.Register(ModuleName, 6, "raw request not found")
	ErrReporterNotFound         = sdkerrors.Register(ModuleName, 7, "reporter not found")
	ErrResultNotFound           = sdkerrors.Register(ModuleName, 8, "result not found")
	ErrReporterAlreadyExists    = sdkerrors.Register(ModuleName, 9, "reporter already exists")
	ErrValidatorNotRequested    = sdkerrors.Register(ModuleName, 10, "validator not requested")
	ErrValidatorAlreadyReported = sdkerrors.Register(ModuleName, 11, "validator already reported")
	ErrInvalidReportSize        = sdkerrors.Register(ModuleName, 12, "invalid report size")
	ErrReporterNotAuthorized    = sdkerrors.Register(ModuleName, 13, "reporter not authorized")
	ErrEditorNotAuthorized      = sdkerrors.Register(ModuleName, 14, "editor not authorized")
	ErrValidatorAlreadyActive   = sdkerrors.Register(ModuleName, 16, "validator already active")
	ErrTooSoonToActivate        = sdkerrors.Register(ModuleName, 17, "too soon to activate")
	ErrTooLongName              = sdkerrors.Register(ModuleName, 18, "too long name")
	ErrTooLongDescription       = sdkerrors.Register(ModuleName, 19, "too long description")
	ErrEmptyExecutable          = sdkerrors.Register(ModuleName, 20, "empty executable")
	ErrEmptyWasmCode            = sdkerrors.Register(ModuleName, 21, "empty wasm code")
	ErrTooLargeExecutable       = sdkerrors.Register(ModuleName, 22, "too large executable")
	ErrTooLargeWasmCode         = sdkerrors.Register(ModuleName, 23, "too large wasm code")
	ErrInvalidMinCount          = sdkerrors.Register(ModuleName, 24, "invalid min count")
	ErrInvalidAskCount          = sdkerrors.Register(ModuleName, 25, "invalid ask count")
	ErrTooLargeCalldata         = sdkerrors.Register(ModuleName, 26, "too large calldata")
	ErrTooLongClientID          = sdkerrors.Register(ModuleName, 27, "too long client id")
	ErrEmptyRawRequests         = sdkerrors.Register(ModuleName, 28, "empty raw requests")
	ErrEmptyReport              = sdkerrors.Register(ModuleName, 29, "empty report")
	ErrDuplicateExternalID      = sdkerrors.Register(ModuleName, 30, "duplicate external id")
	ErrTooLongSchema            = sdkerrors.Register(ModuleName, 31, "too long schema")
	ErrTooLongURL               = sdkerrors.Register(ModuleName, 32, "too long url")
	ErrTooLargeRawReportData    = sdkerrors.Register(ModuleName, 33, "too large raw report data")
	ErrInsufficientValidators   = sdkerrors.Register(ModuleName, 34, "insufficent available validators")
	ErrCreateWithDoNotModify    = sdkerrors.Register(ModuleName, 35, "cannot create with [do-not-modify] content")
	ErrSelfReferenceAsReporter  = sdkerrors.Register(ModuleName, 36, "cannot reference self as reporter")
	ErrOBIDecode                = sdkerrors.Register(ModuleName, 37, "obi decode failed")
	ErrUncompressionFailed      = sdkerrors.Register(ModuleName, 38, "uncompression failed")
	ErrRequestAlreadyExpired    = sdkerrors.Register(ModuleName, 39, "request already expired")
	ErrBadDrbgInitialization    = sdkerrors.Register(ModuleName, 40, "bad drbg initialization")
)
View Source 
var (
	// RollingSeedSizeInBytes is the size of rolling block hash for random seed.
	RollingSeedSizeInBytes = 32
	// GlobalStoreKeyPrefix is the prefix for global primitive state variables.
	GlobalStoreKeyPrefix = []byte{0x00}
	// RollingSeedStoreKey is the key that keeps the seed based on the first 8-bit of the most recent 32 block hashes.
	RollingSeedStoreKey = append(GlobalStoreKeyPrefix, []byte("RollingSeed")...)
	// RequestCountStoreKey is the key that keeps the total request count.
	RequestCountStoreKey = append(GlobalStoreKeyPrefix, []byte("RequestCount")...)
	// RequestLastExpiredStoreKey is the key that keeps the ID of the last expired request, or 0 if none.
	RequestLastExpiredStoreKey = append(GlobalStoreKeyPrefix, []byte("RequestLastExpired")...)
	// PendingResolveListStoreKey is the key that keeps the list of pending-resolve requests.
	PendingResolveListStoreKey = append(GlobalStoreKeyPrefix, []byte("PendingList")...)
	// DataSourceCountStoreKey is the key that keeps the total data source count.
	DataSourceCountStoreKey = append(GlobalStoreKeyPrefix, []byte("DataSourceCount")...)
	// OracleScriptCountStoreKey is the key that keeps the total oracle sciprt count.
	OracleScriptCountStoreKey = append(GlobalStoreKeyPrefix, []byte("OracleScriptCount")...)

	// RequestStoreKeyPrefix is the prefix for request store.
	RequestStoreKeyPrefix = []byte{0x01}
	// ReportStoreKeyPrefix is the prefix for report store.
	ReportStoreKeyPrefix = []byte{0x02}
	// DataSourceStoreKeyPrefix is the prefix for data source store.
	DataSourceStoreKeyPrefix = []byte{0x03}
	// OracleScriptStoreKeyPrefix is the prefix for oracle script store.
	OracleScriptStoreKeyPrefix = []byte{0x04}
	// ReporterStoreKeyPrefix is the prefix for reporter store.
	ReporterStoreKeyPrefix = []byte{0x05}
	// ValidatorStatusKeyPrefix is the prefix for validator status store.
	ValidatorStatusKeyPrefix = []byte{0x06}
	// ResultStoreKeyPrefix is the prefix for request result store.
	ResultStoreKeyPrefix = []byte{0xff}
)
View Source 
var (
	// Each value below is the key to store the respective oracle module parameter. See comments
	// in types.proto for explanation for each parameter.
	KeyMaxRawRequestCount      = []byte("MaxRawRequestCount")
	KeyMaxAskCount             = []byte("MaxAskCount")
	KeyExpirationBlockCount    = []byte("ExpirationBlockCount")
	KeyBaseRequestGas          = []byte("BaseRequestGas")
	KeyPerValidatorRequestGas  = []byte("PerValidatorRequestGas")
	KeySamplingTryCount        = []byte("SamplingTryCount")
	KeyOracleRewardPercentage  = []byte("OracleRewardPercentage")
	KeyInactivePenaltyDuration = []byte("InactivePenaltyDuration")
)

nolint

View Source 
var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	DoNotModifyBytes = []byte(DoNotModify)
)

nolint

View Source 
var ModuleCdc = codec.New()

ModuleCdc is the codec for the module.

View Source 
var ResolveStatus_name = map[int32]string{
	0: "Open",
	1: "Success",
	2: "Failure",
	3: "Expired",
}
View Source 
var ResolveStatus_value = map[string]int32{
	"Open":    0,
	"Success": 1,
	"Failure": 2,
	"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

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

func QueryBadRequest 

func QueryBadRequest(result interface{}) ([]byte, error)

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

func QueryNotFound 

func QueryNotFound(result interface{}) ([]byte, error)

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

func QueryOK 

func QueryOK(result interface{}) ([]byte, error)

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

func RegisterCodec 

func RegisterCodec(cdc *codec.Codec)

RegisterCodec registers the module's concrete types on the codec.

func ReportStoreKey 

func ReportStoreKey(requestID RequestID) []byte

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

func ReporterStoreKey 

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

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

func ReportersOfValidatorPrefixKey 

func ReportersOfValidatorPrefixKey(val sdk.ValAddress) []byte

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

func ReportsOfValidatorPrefixKey 

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

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

func RequestStoreKey 

func RequestStoreKey(requestID RequestID) []byte

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

func ResultStoreKey 

func ResultStoreKey(requestID RequestID) []byte

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

func ValidatorStatusStoreKey 

func ValidatorStatusStoreKey(v sdk.ValAddress) []byte

ValidatorStatusStoreKey returns the key to a validator's status.

func WrapMaxError 

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

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

Types

type AccountKeeper 

type AccountKeeper interface {
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authexported.Account
}

AccountKeeper defines the expected account 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) 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) SetReturnData 

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

SetReturnData implements Owasm ExecEnv interface.

type DataSource 

type DataSource struct {
	Owner       github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,1,opt,name=owner,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"owner,omitempty"`
	Name        string                                        `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description string                                        `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Filename    string                                        `protobuf:"bytes,4,opt,name=filename,proto3" json:"filename,omitempty"`
}

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

func NewDataSource 

func NewDataSource(
	Owner github_com_cosmos_cosmos_sdk_types.AccAddress,
	Name string,
	Description string,
	Filename string,
) 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) GetFilename 

func (m *DataSource) GetFilename() string

func (*DataSource) GetName 

func (m *DataSource) GetName() string

func (*DataSource) GetOwner 

func (m *DataSource) GetOwner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*DataSource) Marshal 

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

func (*DataSource) MarshalTo 

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

func (*DataSource) MarshalToSizedBuffer 

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

func (*DataSource) ProtoMessage 

func (*DataSource) ProtoMessage()

func (*DataSource) Reset 

func (m *DataSource) Reset()

func (*DataSource) Size 

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

func (*DataSource) String 

func (m *DataSource) String() string

func (*DataSource) Unmarshal 

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

func (*DataSource) XXX_DiscardUnknown 

func (m *DataSource) XXX_DiscardUnknown()

func (*DataSource) XXX_Marshal 

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

func (*DataSource) XXX_Merge 

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

func (*DataSource) XXX_Size 

func (m *DataSource) XXX_Size() int

func (*DataSource) XXX_Unmarshal 

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

type DataSourceID 

type DataSourceID int64

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

type DistrKeeper 

type DistrKeeper interface {
	GetCommunityTax(ctx sdk.Context) (percent sdk.Dec)
	GetFeePool(ctx sdk.Context) (feePool distr.FeePool)
	SetFeePool(ctx sdk.Context, feePool distr.FeePool)
	AllocateTokensToValidator(ctx sdk.Context, val stakingexported.ValidatorI, tokens sdk.DecCoins)
}

DistrKeeper defines the expected distribution keeper.

type ExecuteEnv 

type ExecuteEnv struct {
	BaseEnv

	Retdata []byte
	// 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) *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) GetExternalData 

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

GetExternalData implements Owasm ExecEnv interface.

func (*ExecuteEnv) GetExternalDataStatus 

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

GetExternalDataStatus implements Owasm ExecEnv interface.

func (*ExecuteEnv) SetReturnData 

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

SetReturnData implements Owasm ExecEnv interface.

type ExternalID 

type ExternalID int64

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

type MsgActivate 

type MsgActivate struct {
	// Validator is the signer of this message and the validator to be activated.
	Validator github_com_cosmos_cosmos_sdk_types.ValAddress `` /* 126-byte string literal not displayed */
}

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

func NewMsgActivate 

func NewMsgActivate(
	Validator github_com_cosmos_cosmos_sdk_types.ValAddress,
) MsgActivate

func (*MsgActivate) Descriptor 

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

func (*MsgActivate) Equal 

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

func (MsgActivate) GetSignBytes 

func (msg MsgActivate) GetSignBytes() []byte

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

func (MsgActivate) GetSigners 

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

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

func (*MsgActivate) GetValidator 

func (m *MsgActivate) GetValidator() github_com_cosmos_cosmos_sdk_types.ValAddress

func (*MsgActivate) Marshal 

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

func (*MsgActivate) MarshalTo 

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

func (*MsgActivate) MarshalToSizedBuffer 

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

func (*MsgActivate) ProtoMessage 

func (*MsgActivate) ProtoMessage()

func (*MsgActivate) Reset 

func (m *MsgActivate) Reset()

func (MsgActivate) Route 

func (msg MsgActivate) Route() string

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

func (*MsgActivate) Size 

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

func (*MsgActivate) String 

func (m *MsgActivate) String() string

func (MsgActivate) Type 

func (msg MsgActivate) Type() string

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

func (*MsgActivate) Unmarshal 

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

func (MsgActivate) ValidateBasic 

func (msg MsgActivate) ValidateBasic() error

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

func (*MsgActivate) XXX_DiscardUnknown 

func (m *MsgActivate) XXX_DiscardUnknown()

func (*MsgActivate) XXX_Marshal 

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

func (*MsgActivate) XXX_Merge 

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

func (*MsgActivate) XXX_Size 

func (m *MsgActivate) XXX_Size() int

func (*MsgActivate) XXX_Unmarshal 

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

type MsgAddReporter 

type MsgAddReporter struct {
	// Validator is the validator that wishes to add a new reporter. This is the signer.
	Validator github_com_cosmos_cosmos_sdk_types.ValAddress `` /* 126-byte string literal not displayed */
	// Reporter is the address to be added as a reporter to the validator.
	Reporter github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,2,opt,name=reporter,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"reporter,omitempty"`
}

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

func NewMsgAddReporter 

func NewMsgAddReporter(
	Validator github_com_cosmos_cosmos_sdk_types.ValAddress,
	Reporter github_com_cosmos_cosmos_sdk_types.AccAddress,
) MsgAddReporter

func (*MsgAddReporter) Descriptor 

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

func (*MsgAddReporter) Equal 

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

func (*MsgAddReporter) GetReporter 

func (m *MsgAddReporter) GetReporter() github_com_cosmos_cosmos_sdk_types.AccAddress

func (MsgAddReporter) GetSignBytes 

func (msg MsgAddReporter) GetSignBytes() []byte

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

func (MsgAddReporter) GetSigners 

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

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

func (*MsgAddReporter) GetValidator 

func (m *MsgAddReporter) GetValidator() github_com_cosmos_cosmos_sdk_types.ValAddress

func (*MsgAddReporter) Marshal 

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

func (*MsgAddReporter) MarshalTo 

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

func (*MsgAddReporter) MarshalToSizedBuffer 

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

func (*MsgAddReporter) ProtoMessage 

func (*MsgAddReporter) ProtoMessage()

func (*MsgAddReporter) Reset 

func (m *MsgAddReporter) Reset()

func (MsgAddReporter) Route 

func (msg MsgAddReporter) Route() string

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

func (*MsgAddReporter) Size 

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

func (*MsgAddReporter) String 

func (m *MsgAddReporter) String() string

func (MsgAddReporter) Type 

func (msg MsgAddReporter) Type() string

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

func (*MsgAddReporter) Unmarshal 

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

func (MsgAddReporter) ValidateBasic 

func (msg MsgAddReporter) ValidateBasic() error

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

func (*MsgAddReporter) XXX_DiscardUnknown 

func (m *MsgAddReporter) XXX_DiscardUnknown()

func (*MsgAddReporter) XXX_Marshal 

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

func (*MsgAddReporter) XXX_Merge 

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

func (*MsgAddReporter) XXX_Size 

func (m *MsgAddReporter) XXX_Size() int

func (*MsgAddReporter) XXX_Unmarshal 

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

type MsgCreateDataSource 

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

MsgCreateDataSource is a message for creating a new data source.

func NewMsgCreateDataSource 

func NewMsgCreateDataSource(
	Owner github_com_cosmos_cosmos_sdk_types.AccAddress,
	Name string,
	Description string,
	Executable []byte,
	Sender github_com_cosmos_cosmos_sdk_types.AccAddress,
) MsgCreateDataSource

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

func (m *MsgCreateDataSource) GetName() string

func (*MsgCreateDataSource) GetOwner 

func (m *MsgCreateDataSource) GetOwner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgCreateDataSource) GetSender 

func (m *MsgCreateDataSource) GetSender() github_com_cosmos_cosmos_sdk_types.AccAddress

func (MsgCreateDataSource) GetSignBytes 

func (msg MsgCreateDataSource) GetSignBytes() []byte

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

func (MsgCreateDataSource) GetSigners 

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

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

func (*MsgCreateDataSource) Marshal 

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

func (*MsgCreateDataSource) MarshalTo 

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

func (*MsgCreateDataSource) MarshalToSizedBuffer 

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

func (*MsgCreateDataSource) ProtoMessage 

func (*MsgCreateDataSource) ProtoMessage()

func (*MsgCreateDataSource) Reset 

func (m *MsgCreateDataSource) Reset()

func (MsgCreateDataSource) Route 

func (msg MsgCreateDataSource) Route() string

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

func (*MsgCreateDataSource) Size 

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

func (*MsgCreateDataSource) String 

func (m *MsgCreateDataSource) String() string

func (MsgCreateDataSource) Type 

func (msg MsgCreateDataSource) Type() string

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

func (*MsgCreateDataSource) Unmarshal 

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

func (MsgCreateDataSource) ValidateBasic 

func (msg MsgCreateDataSource) ValidateBasic() error

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

func (*MsgCreateDataSource) XXX_DiscardUnknown 

func (m *MsgCreateDataSource) XXX_DiscardUnknown()

func (*MsgCreateDataSource) XXX_Marshal 

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

func (*MsgCreateDataSource) XXX_Merge 

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

func (*MsgCreateDataSource) XXX_Size 

func (m *MsgCreateDataSource) XXX_Size() int

func (*MsgCreateDataSource) XXX_Unmarshal 

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

type MsgCreateOracleScript 

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

MsgCreateOracleScript is a message for creating an oracle script.

func NewMsgCreateOracleScript 

func NewMsgCreateOracleScript(
	Owner github_com_cosmos_cosmos_sdk_types.AccAddress,
	Name string,
	Description string,
	Code []byte,
	Schema string,
	SourceCodeURL string,
	Sender github_com_cosmos_cosmos_sdk_types.AccAddress,
) MsgCreateOracleScript

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() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgCreateOracleScript) GetSchema 

func (m *MsgCreateOracleScript) GetSchema() string

func (*MsgCreateOracleScript) GetSender 

func (m *MsgCreateOracleScript) GetSender() github_com_cosmos_cosmos_sdk_types.AccAddress

func (MsgCreateOracleScript) GetSignBytes 

func (msg MsgCreateOracleScript) GetSignBytes() []byte

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

func (MsgCreateOracleScript) GetSigners 

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

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

func (*MsgCreateOracleScript) GetSourceCodeURL 

func (m *MsgCreateOracleScript) GetSourceCodeURL() string

func (*MsgCreateOracleScript) Marshal 

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

func (*MsgCreateOracleScript) MarshalTo 

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

func (*MsgCreateOracleScript) MarshalToSizedBuffer 

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

func (*MsgCreateOracleScript) ProtoMessage 

func (*MsgCreateOracleScript) ProtoMessage()

func (*MsgCreateOracleScript) Reset 

func (m *MsgCreateOracleScript) Reset()

func (MsgCreateOracleScript) Route 

func (msg MsgCreateOracleScript) Route() string

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

func (*MsgCreateOracleScript) Size 

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

func (*MsgCreateOracleScript) String 

func (m *MsgCreateOracleScript) String() string

func (MsgCreateOracleScript) Type 

func (msg MsgCreateOracleScript) Type() string

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

func (*MsgCreateOracleScript) Unmarshal 

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

func (MsgCreateOracleScript) ValidateBasic 

func (msg MsgCreateOracleScript) ValidateBasic() error

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

func (*MsgCreateOracleScript) XXX_DiscardUnknown 

func (m *MsgCreateOracleScript) XXX_DiscardUnknown()

func (*MsgCreateOracleScript) XXX_Marshal 

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

func (*MsgCreateOracleScript) XXX_Merge 

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

func (*MsgCreateOracleScript) XXX_Size 

func (m *MsgCreateOracleScript) XXX_Size() int

func (*MsgCreateOracleScript) XXX_Unmarshal 

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

type 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"`
	// Owner is the new address who is allowed to make further changes to the data source.
	Owner github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,2,opt,name=owner,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"owner,omitempty"`
	// Name is the name of this data source (optional).
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Description is the description of this data source (optional).
	Description string `protobuf:"bytes,4,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,5,opt,name=executable,proto3" json:"executable,omitempty"`
	// Sender is the signer of this message. Must be the current data source's owner.
	Sender github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,6,opt,name=sender,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"sender,omitempty"`
}

MsgEditDataSource is a message for editing an existing data source.

func NewMsgEditDataSource 

func NewMsgEditDataSource(
	DataSourceID DataSourceID,
	Owner github_com_cosmos_cosmos_sdk_types.AccAddress,
	Name string,
	Description string,
	Executable []byte,
	Sender github_com_cosmos_cosmos_sdk_types.AccAddress,
) MsgEditDataSource

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

func (m *MsgEditDataSource) GetName() string

func (*MsgEditDataSource) GetOwner 

func (m *MsgEditDataSource) GetOwner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgEditDataSource) GetSender 

func (m *MsgEditDataSource) GetSender() github_com_cosmos_cosmos_sdk_types.AccAddress

func (MsgEditDataSource) GetSignBytes 

func (msg MsgEditDataSource) GetSignBytes() []byte

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

func (MsgEditDataSource) GetSigners 

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

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

func (*MsgEditDataSource) Marshal 

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

func (*MsgEditDataSource) MarshalTo 

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

func (*MsgEditDataSource) MarshalToSizedBuffer 

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

func (*MsgEditDataSource) ProtoMessage 

func (*MsgEditDataSource) ProtoMessage()

func (*MsgEditDataSource) Reset 

func (m *MsgEditDataSource) Reset()

func (MsgEditDataSource) Route 

func (msg MsgEditDataSource) Route() string

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

func (*MsgEditDataSource) Size 

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

func (*MsgEditDataSource) String 

func (m *MsgEditDataSource) String() string

func (MsgEditDataSource) Type 

func (msg MsgEditDataSource) Type() string

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

func (*MsgEditDataSource) Unmarshal 

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

func (MsgEditDataSource) ValidateBasic 

func (msg MsgEditDataSource) ValidateBasic() error

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

func (*MsgEditDataSource) XXX_DiscardUnknown 

func (m *MsgEditDataSource) XXX_DiscardUnknown()

func (*MsgEditDataSource) XXX_Marshal 

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

func (*MsgEditDataSource) XXX_Merge 

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

func (*MsgEditDataSource) XXX_Size 

func (m *MsgEditDataSource) XXX_Size() int

func (*MsgEditDataSource) XXX_Unmarshal 

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

type MsgEditOracleScript 

type MsgEditOracleScript struct {
	// OracleScriptID is the unique identifier of the oracle script to be edited.
	OracleScriptID OracleScriptID `` /* 130-byte string literal not displayed */
	// Owner is new the address who is allowed to make further changes to the oracle script.
	Owner github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,2,opt,name=owner,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"owner,omitempty"`
	// Name is the name of this oracle script (optional).
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Description is the description of this oracle script (optional).
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,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"`
	// Schema is the OBI schema of this oracle script (optional).
	Schema string `protobuf:"bytes,6,opt,name=schema,proto3" json:"schema,omitempty"`
	// SourceCodeURL is the absolute URI to the script's source code (optional).
	SourceCodeURL string `protobuf:"bytes,7,opt,name=source_code_url,json=sourceCodeUrl,proto3" json:"source_code_url,omitempty"`
	// Sender is the signer of this message. Must be the current oracle script's owner.
	Sender github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,8,opt,name=sender,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"sender,omitempty"`
}

MsgEditOracleScript is a message for editing an existing oracle script.

func NewMsgEditOracleScript 

func NewMsgEditOracleScript(
	OracleScriptID OracleScriptID,
	Owner github_com_cosmos_cosmos_sdk_types.AccAddress,
	Name string,
	Description string,
	Code []byte,
	Schema string,
	SourceCodeURL string,
	Sender github_com_cosmos_cosmos_sdk_types.AccAddress,
) MsgEditOracleScript

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() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgEditOracleScript) GetSchema 

func (m *MsgEditOracleScript) GetSchema() string

func (*MsgEditOracleScript) GetSender 

func (m *MsgEditOracleScript) GetSender() github_com_cosmos_cosmos_sdk_types.AccAddress

func (MsgEditOracleScript) GetSignBytes 

func (msg MsgEditOracleScript) GetSignBytes() []byte

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

func (MsgEditOracleScript) GetSigners 

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

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

func (*MsgEditOracleScript) GetSourceCodeURL 

func (m *MsgEditOracleScript) GetSourceCodeURL() string

func (*MsgEditOracleScript) Marshal 

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

func (*MsgEditOracleScript) MarshalTo 

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

func (*MsgEditOracleScript) MarshalToSizedBuffer 

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

func (*MsgEditOracleScript) ProtoMessage 

func (*MsgEditOracleScript) ProtoMessage()

func (*MsgEditOracleScript) Reset 

func (m *MsgEditOracleScript) Reset()

func (MsgEditOracleScript) Route 

func (msg MsgEditOracleScript) Route() string

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

func (*MsgEditOracleScript) Size 

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

func (*MsgEditOracleScript) String 

func (m *MsgEditOracleScript) String() string

func (MsgEditOracleScript) Type 

func (msg MsgEditOracleScript) Type() string

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

func (*MsgEditOracleScript) Unmarshal 

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

func (MsgEditOracleScript) ValidateBasic 

func (msg MsgEditOracleScript) ValidateBasic() error

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

func (*MsgEditOracleScript) XXX_DiscardUnknown 

func (m *MsgEditOracleScript) XXX_DiscardUnknown()

func (*MsgEditOracleScript) XXX_Marshal 

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

func (*MsgEditOracleScript) XXX_Merge 

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

func (*MsgEditOracleScript) XXX_Size 

func (m *MsgEditOracleScript) XXX_Size() int

func (*MsgEditOracleScript) XXX_Unmarshal 

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

type MsgRemoveReporter 

type MsgRemoveReporter struct {
	// Validator is the validator that wishes to remove an existing reporter. This is the signer.
	Validator github_com_cosmos_cosmos_sdk_types.ValAddress `` /* 126-byte string literal not displayed */
	// Reporter is the address to be removed from being the validators' reporter.
	Reporter github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,2,opt,name=reporter,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"reporter,omitempty"`
}

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

func NewMsgRemoveReporter 

func NewMsgRemoveReporter(
	Validator github_com_cosmos_cosmos_sdk_types.ValAddress,
	Reporter github_com_cosmos_cosmos_sdk_types.AccAddress,
) MsgRemoveReporter

func (*MsgRemoveReporter) Descriptor 

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

func (*MsgRemoveReporter) Equal 

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

func (*MsgRemoveReporter) GetReporter 

func (m *MsgRemoveReporter) GetReporter() github_com_cosmos_cosmos_sdk_types.AccAddress

func (MsgRemoveReporter) GetSignBytes 

func (msg MsgRemoveReporter) GetSignBytes() []byte

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

func (MsgRemoveReporter) GetSigners 

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

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

func (*MsgRemoveReporter) GetValidator 

func (m *MsgRemoveReporter) GetValidator() github_com_cosmos_cosmos_sdk_types.ValAddress

func (*MsgRemoveReporter) Marshal 

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

func (*MsgRemoveReporter) MarshalTo 

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

func (*MsgRemoveReporter) MarshalToSizedBuffer 

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

func (*MsgRemoveReporter) ProtoMessage 

func (*MsgRemoveReporter) ProtoMessage()

func (*MsgRemoveReporter) Reset 

func (m *MsgRemoveReporter) Reset()

func (MsgRemoveReporter) Route 

func (msg MsgRemoveReporter) Route() string

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

func (*MsgRemoveReporter) Size 

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

func (*MsgRemoveReporter) String 

func (m *MsgRemoveReporter) String() string

func (MsgRemoveReporter) Type 

func (msg MsgRemoveReporter) Type() string

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

func (*MsgRemoveReporter) Unmarshal 

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

func (MsgRemoveReporter) ValidateBasic 

func (msg MsgRemoveReporter) ValidateBasic() error

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

func (*MsgRemoveReporter) XXX_DiscardUnknown 

func (m *MsgRemoveReporter) XXX_DiscardUnknown()

func (*MsgRemoveReporter) XXX_Marshal 

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

func (*MsgRemoveReporter) XXX_Merge 

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

func (*MsgRemoveReporter) XXX_Size 

func (m *MsgRemoveReporter) XXX_Size() int

func (*MsgRemoveReporter) XXX_Unmarshal 

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

type MsgReportData 

type MsgReportData struct {
	// RequestID is the identifier of the request to report to.
	RequestID RequestID `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3,casttype=RequestID" json:"request_id,omitempty"`
	// RawReports is the list of report information for each of the request's external ID.
	RawReports []RawReport `protobuf:"bytes,2,rep,name=raw_reports,json=rawReports,proto3" json:"raw_reports"`
	// Validator is the address of the validator that owns this report.
	Validator github_com_cosmos_cosmos_sdk_types.ValAddress `` /* 126-byte string literal not displayed */
	// Reporter is the message signer who submits this report transaction for the validator.
	Reporter github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,4,opt,name=reporter,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"reporter,omitempty"`
}

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

func NewMsgReportData 

func NewMsgReportData(
	RequestID RequestID,
	RawReports []RawReport,
	Validator github_com_cosmos_cosmos_sdk_types.ValAddress,
	Reporter github_com_cosmos_cosmos_sdk_types.AccAddress,
) MsgReportData

func (*MsgReportData) Descriptor 

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

func (*MsgReportData) Equal 

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

func (*MsgReportData) GetRawReports 

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

func (*MsgReportData) GetReporter 

func (m *MsgReportData) GetReporter() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgReportData) GetRequestID 

func (m *MsgReportData) GetRequestID() RequestID

func (MsgReportData) GetSignBytes 

func (msg MsgReportData) GetSignBytes() []byte

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

func (MsgReportData) GetSigners 

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

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

func (*MsgReportData) GetValidator 

func (m *MsgReportData) GetValidator() github_com_cosmos_cosmos_sdk_types.ValAddress

func (*MsgReportData) Marshal 

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

func (*MsgReportData) MarshalTo 

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

func (*MsgReportData) MarshalToSizedBuffer 

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

func (*MsgReportData) ProtoMessage 

func (*MsgReportData) ProtoMessage()

func (*MsgReportData) Reset 

func (m *MsgReportData) Reset()

func (MsgReportData) Route 

func (msg MsgReportData) Route() string

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

func (*MsgReportData) Size 

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

func (*MsgReportData) String 

func (m *MsgReportData) String() string

func (MsgReportData) Type 

func (msg MsgReportData) Type() string

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

func (*MsgReportData) Unmarshal 

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

func (MsgReportData) ValidateBasic 

func (msg MsgReportData) ValidateBasic() error

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

func (*MsgReportData) XXX_DiscardUnknown 

func (m *MsgReportData) XXX_DiscardUnknown()

func (*MsgReportData) XXX_Marshal 

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

func (*MsgReportData) XXX_Merge 

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

func (*MsgReportData) XXX_Size 

func (m *MsgReportData) XXX_Size() int

func (*MsgReportData) XXX_Unmarshal 

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

type MsgRequestData 

type MsgRequestData struct {
	// OracleScriptID is the identifier of the oracle script to call.
	OracleScriptID OracleScriptID `` /* 130-byte string literal not displayed */
	// Calldata is the OBI encoded call parameters to the oracle script.
	Calldata []byte `protobuf:"bytes,2,opt,name=calldata,proto3" json:"calldata,omitempty"`
	// AskCount is the number of validators to perform the oracle task.
	AskCount uint64 `protobuf:"varint,3,opt,name=ask_count,json=askCount,proto3" json:"ask_count,omitempty"`
	// MinCount is the minimum number of validators sufficient to resolve the tasks.
	MinCount uint64 `protobuf:"varint,4,opt,name=min_count,json=minCount,proto3" json:"min_count,omitempty"`
	// ClientID is the client-provided unique identifier to tracking the request.
	ClientID string `protobuf:"bytes,5,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// Sender is the sender of this message.
	Sender github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,6,opt,name=sender,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"sender,omitempty"`
}

MsgRequestData is a message for sending a data oracle request.

func NewMsgRequestData 

func NewMsgRequestData(
	OracleScriptID OracleScriptID,
	Calldata []byte,
	AskCount uint64,
	MinCount uint64,
	ClientID string,
	Sender github_com_cosmos_cosmos_sdk_types.AccAddress,
) MsgRequestData

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

func (m *MsgRequestData) GetMinCount() uint64

func (*MsgRequestData) GetOracleScriptID 

func (m *MsgRequestData) GetOracleScriptID() OracleScriptID

func (*MsgRequestData) GetSender 

func (m *MsgRequestData) GetSender() github_com_cosmos_cosmos_sdk_types.AccAddress

func (MsgRequestData) GetSignBytes 

func (msg MsgRequestData) GetSignBytes() []byte

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

func (MsgRequestData) GetSigners 

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

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

func (*MsgRequestData) Marshal 

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

func (*MsgRequestData) MarshalTo 

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

func (*MsgRequestData) MarshalToSizedBuffer 

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

func (*MsgRequestData) ProtoMessage 

func (*MsgRequestData) ProtoMessage()

func (*MsgRequestData) Reset 

func (m *MsgRequestData) Reset()

func (MsgRequestData) Route 

func (msg MsgRequestData) Route() string

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

func (*MsgRequestData) Size 

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

func (*MsgRequestData) String 

func (m *MsgRequestData) String() string

func (MsgRequestData) Type 

func (msg MsgRequestData) Type() string

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

func (*MsgRequestData) Unmarshal 

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

func (MsgRequestData) ValidateBasic 

func (msg MsgRequestData) ValidateBasic() error

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

func (*MsgRequestData) XXX_DiscardUnknown 

func (m *MsgRequestData) XXX_DiscardUnknown()

func (*MsgRequestData) XXX_Marshal 

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

func (*MsgRequestData) XXX_Merge 

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

func (*MsgRequestData) XXX_Size 

func (m *MsgRequestData) XXX_Size() int

func (*MsgRequestData) XXX_Unmarshal 

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

type OracleRequestPacketData 

type OracleRequestPacketData struct {
	// ClientID is the unique identifier of this oracle request, as specified by the client.
	// This same unique ID will be sent back to the requester with the oracle response.
	ClientID string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// OracleScriptID is the unique identifier of the oracle script to be executed.
	OracleScriptID OracleScriptID `` /* 130-byte string literal not displayed */
	// Calldata is the calldata bytes available for oracle executor to read.
	Calldata []byte `protobuf:"bytes,3,opt,name=calldata,proto3" json:"calldata,omitempty"`
	// AskCount is the number of validators that are requested to respond to this oracle request.
	// Higher value means more security, at a higher gas cost.
	AskCount uint64 `protobuf:"varint,4,opt,name=ask_count,json=askCount,proto3" json:"ask_count,omitempty"`
	// MinCount is the minimum number of validators necessary for the request to proceed to the
	// execution phase. Higher value means more security, at the cost of liveness.
	MinCount uint64 `protobuf:"varint,5,opt,name=min_count,json=minCount,proto3" json:"min_count,omitempty"`
}

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

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 returns the bytes representation of this oracle request packet data.

func (*OracleRequestPacketData) GetCalldata 

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

func (*OracleRequestPacketData) GetClientID 

func (m *OracleRequestPacketData) GetClientID() string

func (*OracleRequestPacketData) GetMinCount 

func (m *OracleRequestPacketData) GetMinCount() uint64

func (*OracleRequestPacketData) GetOracleScriptID 

func (m *OracleRequestPacketData) GetOracleScriptID() OracleScriptID

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) 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 `` /* 148-byte string literal not displayed */
	// Result is the final aggregated value only available if status if OK.
	Result []byte `protobuf:"bytes,7,opt,name=result,proto3" json:"result,omitempty"`
}

OracleResponsePacketData encodes an oracle response from BandChain to the requester.

func NewOracleResponsePacketData 

func NewOracleResponsePacketData(
	ClientID string,
	RequestID RequestID,
	AnsCount uint64,
	RequestTime int64,
	ResolveTime int64,
	ResolveStatus ResolveStatus,
	Result []byte,
) OracleResponsePacketData

func (*OracleResponsePacketData) Descriptor 

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

func (*OracleResponsePacketData) Equal 

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

func (*OracleResponsePacketData) GetAnsCount 

func (m *OracleResponsePacketData) GetAnsCount() uint64

func (OracleResponsePacketData) GetBytes 

func (p OracleResponsePacketData) GetBytes() []byte

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

func (*OracleResponsePacketData) GetClientID 

func (m *OracleResponsePacketData) GetClientID() string

func (*OracleResponsePacketData) GetRequestID 

func (m *OracleResponsePacketData) GetRequestID() RequestID

func (*OracleResponsePacketData) GetRequestTime 

func (m *OracleResponsePacketData) GetRequestTime() int64

func (*OracleResponsePacketData) GetResolveStatus 

func (m *OracleResponsePacketData) GetResolveStatus() ResolveStatus

func (*OracleResponsePacketData) GetResolveTime 

func (m *OracleResponsePacketData) GetResolveTime() int64

func (*OracleResponsePacketData) GetResult 

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

func (*OracleResponsePacketData) Marshal 

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

func (*OracleResponsePacketData) MarshalTo 

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

func (*OracleResponsePacketData) MarshalToSizedBuffer 

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

func (*OracleResponsePacketData) ProtoMessage 

func (*OracleResponsePacketData) ProtoMessage()

func (*OracleResponsePacketData) Reset 

func (m *OracleResponsePacketData) Reset()

func (*OracleResponsePacketData) Size 

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

func (*OracleResponsePacketData) String 

func (m *OracleResponsePacketData) String() string

func (*OracleResponsePacketData) Unmarshal 

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

func (*OracleResponsePacketData) XXX_DiscardUnknown 

func (m *OracleResponsePacketData) XXX_DiscardUnknown()

func (*OracleResponsePacketData) XXX_Marshal 

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

func (*OracleResponsePacketData) XXX_Merge 

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

func (*OracleResponsePacketData) XXX_Size 

func (m *OracleResponsePacketData) XXX_Size() int

func (*OracleResponsePacketData) XXX_Unmarshal 

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

type OracleScript 

type OracleScript struct {
	Owner         github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,1,opt,name=owner,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"owner,omitempty"`
	Name          string                                        `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description   string                                        `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Filename      string                                        `protobuf:"bytes,4,opt,name=filename,proto3" json:"filename,omitempty"`
	Schema        string                                        `protobuf:"bytes,5,opt,name=schema,proto3" json:"schema,omitempty"`
	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 github_com_cosmos_cosmos_sdk_types.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() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*OracleScript) GetSchema 

func (m *OracleScript) GetSchema() string

func (*OracleScript) GetSourceCodeURL 

func (m *OracleScript) GetSourceCodeURL() string

func (*OracleScript) Marshal 

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

func (*OracleScript) MarshalTo 

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

func (*OracleScript) MarshalToSizedBuffer 

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

func (*OracleScript) ProtoMessage 

func (*OracleScript) ProtoMessage()

func (*OracleScript) Reset 

func (m *OracleScript) Reset()

func (*OracleScript) Size 

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

func (*OracleScript) String 

func (m *OracleScript) String() string

func (*OracleScript) Unmarshal 

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

func (*OracleScript) XXX_DiscardUnknown 

func (m *OracleScript) XXX_DiscardUnknown()

func (*OracleScript) XXX_Marshal 

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

func (*OracleScript) XXX_Merge 

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

func (*OracleScript) XXX_Size 

func (m *OracleScript) XXX_Size() int

func (*OracleScript) XXX_Unmarshal 

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

type OracleScriptID 

type OracleScriptID int64

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

type Params 

type Params struct {
	// MaxRawRequestCount is the maximum number of data source raw requests a request can make.
	MaxRawRequestCount uint64 `protobuf:"varint,1,opt,name=max_raw_request_count,json=maxRawRequestCount,proto3" json:"max_raw_request_count,omitempty"`
	// MaxAskCount is the maximum number of validators a request can target.
	MaxAskCount uint64 `protobuf:"varint,2,opt,name=max_ask_count,json=maxAskCount,proto3" json:"max_ask_count,omitempty"`
	// ExpirationBlockCount is the number of blocks a request stays valid before it gets
	// expired due to insufficient reports.
	ExpirationBlockCount uint64 `protobuf:"varint,3,opt,name=expiration_block_count,json=expirationBlockCount,proto3" json:"expiration_block_count,omitempty"`
	// BaseRequestGas is the base amount of Cosmos-SDK gas charged for an oracle request.
	BaseRequestGas uint64 `protobuf:"varint,4,opt,name=base_request_gas,json=baseRequestGas,proto3" json:"base_request_gas,omitempty"`
	// PerValidatorRequestGas is the amount of Cosmos-SDK gas charged per requested validator.
	PerValidatorRequestGas uint64 `` /* 132-byte string literal not displayed */
	// SamplingTryCount the number of validator sampling tries to pick the highest voting power
	// subset of validators to perform an oracle task.
	SamplingTryCount uint64 `protobuf:"varint,6,opt,name=sampling_try_count,json=samplingTryCount,proto3" json:"sampling_try_count,omitempty"`
	// OracleRewardPercentage is the percentage of block rewards allocated to active oracle validators.
	OracleRewardPercentage uint64 `` /* 130-byte string literal not displayed */
	// InactivePenaltyDuration is the duration period where a validator cannot activate back
	// after missing an oracle report.
	InactivePenaltyDuration uint64 `` /* 133-byte string literal not displayed */
}

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 uint64,
	MaxAskCount uint64,
	ExpirationBlockCount uint64,
	BaseRequestGas uint64,
	PerValidatorRequestGas uint64,
	SamplingTryCount uint64,
	OracleRewardPercentage uint64,
	InactivePenaltyDuration uint64,
) Params

func (*Params) Descriptor 

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

func (*Params) Equal 

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

func (*Params) GetBaseRequestGas 

func (m *Params) GetBaseRequestGas() uint64

func (*Params) GetExpirationBlockCount 

func (m *Params) GetExpirationBlockCount() uint64

func (*Params) GetInactivePenaltyDuration 

func (m *Params) GetInactivePenaltyDuration() uint64

func (*Params) GetMaxAskCount 

func (m *Params) GetMaxAskCount() uint64

func (*Params) GetMaxRawRequestCount 

func (m *Params) GetMaxRawRequestCount() 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() params.ParamSetPairs

ParamSetPairs implements the params.ParamSet interface for Params.

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (Params) String 

func (p Params) String() string

String implements the stringer interface for Params.

func (*Params) Unmarshal 

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

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type 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, maxRawRequests int64) *PrepareEnv

NewPrepareEnv creates a new environment instance for prepare period.

func (*PrepareEnv) AskExternalData 

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

AskExternalData implements Owasm ExecEnv interface.

func (*PrepareEnv) GetRawRequests 

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

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

type QueryActiveValidatorResult 

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

QueryActiveValidatorResult is the struct for the result of request active validators.

type QueryCountsResult 

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

QueryCountsResult is the struct for the result of query counts.

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

type RawReport struct {
	ExternalID ExternalID `protobuf:"varint,1,opt,name=external_id,json=externalId,proto3,casttype=ExternalID" json:"external_id,omitempty"`
	ExitCode   uint32     `protobuf:"varint,2,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	Data       []byte     `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}

RawRequest is the data structure for storing raw reporter in the storage.

func NewRawReport 

func NewRawReport(
	ExternalID ExternalID,
	ExitCode uint32,
	Data []byte,
) RawReport

func (*RawReport) Descriptor 

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

func (*RawReport) Equal 

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

func (*RawReport) GetData 

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

func (*RawReport) GetExitCode 

func (m *RawReport) GetExitCode() uint32

func (*RawReport) GetExternalID 

func (m *RawReport) GetExternalID() ExternalID

func (*RawReport) Marshal 

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

func (*RawReport) MarshalTo 

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

func (*RawReport) MarshalToSizedBuffer 

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

func (*RawReport) ProtoMessage 

func (*RawReport) ProtoMessage()

func (*RawReport) Reset 

func (m *RawReport) Reset()

func (*RawReport) Size 

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

func (*RawReport) String 

func (m *RawReport) String() string

func (*RawReport) Unmarshal 

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

func (*RawReport) XXX_DiscardUnknown 

func (m *RawReport) XXX_DiscardUnknown()

func (*RawReport) XXX_Marshal 

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

func (*RawReport) XXX_Merge 

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

func (*RawReport) XXX_Size 

func (m *RawReport) XXX_Size() int

func (*RawReport) XXX_Unmarshal 

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

type RawRequest 

type RawRequest struct {
	ExternalID   ExternalID   `protobuf:"varint,1,opt,name=external_id,json=externalId,proto3,casttype=ExternalID" json:"external_id,omitempty"`
	DataSourceID DataSourceID `protobuf:"varint,2,opt,name=data_source_id,json=dataSourceId,proto3,casttype=DataSourceID" json:"data_source_id,omitempty"`
	Calldata     []byte       `protobuf:"bytes,3,opt,name=calldata,proto3" json:"calldata,omitempty"`
}

RawRequest is the data structure for storing raw requests in the storage.

func NewRawRequest 

func NewRawRequest(
	ExternalID ExternalID,
	DataSourceID DataSourceID,
	Calldata []byte,
) RawRequest

func (*RawRequest) Descriptor 

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

func (*RawRequest) Equal 

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

func (*RawRequest) GetCalldata 

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

func (*RawRequest) GetDataSourceID 

func (m *RawRequest) GetDataSourceID() DataSourceID

func (*RawRequest) GetExternalID 

func (m *RawRequest) GetExternalID() ExternalID

func (*RawRequest) Marshal 

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

func (*RawRequest) MarshalTo 

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

func (*RawRequest) MarshalToSizedBuffer 

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

func (*RawRequest) ProtoMessage 

func (*RawRequest) ProtoMessage()

func (*RawRequest) Reset 

func (m *RawRequest) Reset()

func (*RawRequest) Size 

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

func (*RawRequest) String 

func (m *RawRequest) String() string

func (*RawRequest) Unmarshal 

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

func (*RawRequest) XXX_DiscardUnknown 

func (m *RawRequest) XXX_DiscardUnknown()

func (*RawRequest) XXX_Marshal 

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

func (*RawRequest) XXX_Merge 

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

func (*RawRequest) XXX_Size 

func (m *RawRequest) XXX_Size() int

func (*RawRequest) XXX_Unmarshal 

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

type Report 

type Report struct {
	Validator       github_com_cosmos_cosmos_sdk_types.ValAddress `` /* 126-byte string literal not displayed */
	InBeforeResolve bool                                          `protobuf:"varint,2,opt,name=in_before_resolve,json=inBeforeResolve,proto3" json:"in_before_resolve,omitempty"`
	RawReports      []RawReport                                   `protobuf:"bytes,3,rep,name=raw_reports,json=rawReports,proto3" json:"raw_reports"`
}

Report is the data structure for storing reports in the storage.

func NewReport 

func NewReport(
	Validator github_com_cosmos_cosmos_sdk_types.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() github_com_cosmos_cosmos_sdk_types.ValAddress

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      OracleScriptID                                  `` /* 130-byte string literal not displayed */
	Calldata            []byte                                          `protobuf:"bytes,2,opt,name=calldata,proto3" json:"calldata,omitempty"`
	RequestedValidators []github_com_cosmos_cosmos_sdk_types.ValAddress `` /* 173-byte string literal not displayed */
	MinCount            uint64                                          `protobuf:"varint,4,opt,name=min_count,json=minCount,proto3" json:"min_count,omitempty"`
	RequestHeight       int64                                           `protobuf:"varint,5,opt,name=request_height,json=requestHeight,proto3" json:"request_height,omitempty"`
	RequestTime         time.Time                                       `protobuf:"bytes,6,opt,name=request_time,json=requestTime,proto3,stdtime" json:"request_time"`
	ClientID            string                                          `protobuf:"bytes,7,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	RawRequests         []RawRequest                                    `protobuf:"bytes,8,rep,name=raw_requests,json=rawRequests,proto3" json:"raw_requests"`
}

Request is the data structure for storing requests in the storage.

func NewRequest 

func NewRequest(
	OracleScriptID OracleScriptID,
	Calldata []byte,
	RequestedValidators []github_com_cosmos_cosmos_sdk_types.ValAddress,
	MinCount uint64,
	RequestHeight int64,
	RequestTime time.Time,
	ClientID string,
	RawRequests []RawRequest,
) 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) 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() time.Time

func (*Request) GetRequestedValidators 

func (m *Request) GetRequestedValidators() []github_com_cosmos_cosmos_sdk_types.ValAddress

func (*Request) Marshal 

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

func (*Request) MarshalTo 

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

func (*Request) MarshalToSizedBuffer 

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

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) Size 

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

func (*Request) String 

func (m *Request) String() string

func (*Request) Unmarshal 

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

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

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

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

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

type RequestID 

type RequestID int64

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

type RequestSpec 

type RequestSpec interface {
	GetOracleScriptID() OracleScriptID
	GetCalldata() []byte
	GetAskCount() uint64
	GetMinCount() uint64
	GetClientID() string
}

RequestSpec captures the essence of what it means to be a request-making object.

type ResolveStatus 

type ResolveStatus int32

ResolveStatus encodes the status of an oracle request. 

const (
	// Open - the request is not yet resolved.
	ResolveStatus_Open ResolveStatus = 0
	// Success - the request has been resolved successfully with no errors.
	ResolveStatus_Success ResolveStatus = 1
	// Failure - an error occured during the request's resolve call.
	ResolveStatus_Failure ResolveStatus = 2
	// Expired - the request does not get enough reports from validator within the timeframe.
	ResolveStatus_Expired ResolveStatus = 3
)

func (ResolveStatus) EnumDescriptor 

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

func (ResolveStatus) String 

func (x ResolveStatus) String() string

type Result 

type Result struct {
	RequestPacketData  OracleRequestPacketData  `json:"request_packet_data"`
	ResponsePacketData OracleResponsePacketData `json:"response_packet_data"`
}

Result is a convenience struct that keeps both request and response packets of a request.

func NewResult 

func NewResult(req OracleRequestPacketData, res OracleResponsePacketData) Result

NewResult creates a new Result instance.

type StakingKeeper 

type StakingKeeper interface {
	ValidatorByConsAddr(sdk.Context, sdk.ConsAddress) stakingexported.ValidatorI
	IterateBondedValidatorsByPower(ctx sdk.Context, fn func(index int64, validator stakingexported.ValidatorI) (stop bool))
	Validator(ctx sdk.Context, address sdk.ValAddress) stakingexported.ValidatorI
}

StakingKeeper defines the expected staking keeper.

type SupplyKeeper 

type SupplyKeeper interface {
	GetModuleAccount(ctx sdk.Context, name string) supplyexported.ModuleAccountI
	SendCoinsFromModuleToModule(ctx sdk.Context, senderModule string, recipientModule string, amt sdk.Coins) error
}

SupplyKeeper defines the expected supply Keeper.

type ValidatorStatus 

type ValidatorStatus struct {
	IsActive bool      `protobuf:"varint,1,opt,name=is_active,json=isActive,proto3" json:"is_active,omitempty"`
	Since    time.Time `protobuf:"bytes,2,opt,name=since,proto3,stdtime" json:"since"`
}

ValidatorStatus maintains whether a validator is an active oracle provider.

func NewValidatorStatus 

func NewValidatorStatus(
	IsActive bool,
	Since time.Time,
) ValidatorStatus

func (*ValidatorStatus) Descriptor 

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

func (*ValidatorStatus) Equal 

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

func (*ValidatorStatus) GetIsActive 

func (m *ValidatorStatus) GetIsActive() bool

func (*ValidatorStatus) GetSince 

func (m *ValidatorStatus) GetSince() time.Time

func (*ValidatorStatus) Marshal 

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

func (*ValidatorStatus) MarshalTo 

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

func (*ValidatorStatus) MarshalToSizedBuffer 

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

func (*ValidatorStatus) ProtoMessage 

func (*ValidatorStatus) ProtoMessage()

func (*ValidatorStatus) Reset 

func (m *ValidatorStatus) Reset()

func (*ValidatorStatus) Size 

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

func (*ValidatorStatus) String 

func (m *ValidatorStatus) String() string

func (*ValidatorStatus) Unmarshal 

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

func (*ValidatorStatus) XXX_DiscardUnknown 

func (m *ValidatorStatus) XXX_DiscardUnknown()

func (*ValidatorStatus) XXX_Marshal 

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

func (*ValidatorStatus) XXX_Merge 

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

func (*ValidatorStatus) XXX_Size 

func (m *ValidatorStatus) XXX_Size() int

func (*ValidatorStatus) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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