keeper

package
v0.0.0-...-21ace4c Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const Bech32MainPrefix = "band"
View Source 
const Bip44CoinType = 494

Variables

This section is empty.

Functions

func GetAddressFromPub 

func GetAddressFromPub(pub string) sdk.AccAddress

func GetTestDataSource 

func GetTestDataSource() types.DataSource

func GetTestOracleScript 

func GetTestOracleScript(path string) types.OracleScript

func NewPubKey 

func NewPubKey(pk string) crypto.PubKey

func NewQuerier 

func NewQuerier(keeper Keeper) sdk.Querier

NewQuerier is the module level router for state queries.

func NewUBandCoins 

func NewUBandCoins(amount int64) sdk.Coins

func ParamKeyTable 

func ParamKeyTable() params.KeyTable

ParamKeyTable returns the parameter key table for zoracle module.

func SetBech32AddressPrefixesAndBip44CoinType 

func SetBech32AddressPrefixesAndBip44CoinType(config *sdk.Config)

func SetupTestValidator 

func SetupTestValidator(ctx sdk.Context, keeper Keeper, pk string, power int64) sdk.ValAddress

Types

type Keeper 

type Keeper struct {
	CoinKeeper    bank.Keeper
	StakingKeeper staking.Keeper
	SupplyKeeper  supply.Keeper
	ParamSpace    params.Subspace
	// contains filtered or unexported fields
}

func CreateTestInput 

func CreateTestInput(t *testing.T, isCheckTx bool) (sdk.Context, Keeper)

func NewKeeper 

func NewKeeper(cdc *codec.Codec, key sdk.StoreKey, coinKeeper bank.Keeper, stakingKeeper staking.Keeper, supplyKeeper supply.Keeper, paramSpace params.Subspace) Keeper

NewKeeper creates a new zoracle Keeper instance.

func (Keeper) AddDataSource 

func (k Keeper) AddDataSource(
	ctx sdk.Context, owner sdk.AccAddress, name string, description string,
	fee sdk.Coins, executable []byte,
) (types.DataSourceID, sdk.Error)

AddDataSource adds the given data source to the storage.

func (Keeper) AddNewRawDataRequest 

func (k Keeper) AddNewRawDataRequest(
	ctx sdk.Context, requestID types.RequestID, externalID types.ExternalID, dataSourceID types.DataSourceID, calldata []byte,
) sdk.Error

AddNewRawDataRequest checks all conditions before saving a new raw data request to the store.

func (Keeper) AddOracleScript 

func (k Keeper) AddOracleScript(
	ctx sdk.Context, owner sdk.AccAddress, name string, description string, code []byte,
) (types.OracleScriptID, sdk.Error)

AddOracleScript adds the given oracle script to the storage.

func (Keeper) AddPendingRequest 

func (k Keeper) AddPendingRequest(ctx sdk.Context, requestID types.RequestID) sdk.Error

AddPendingRequest checks and append new request id to list if id already existed in list, it will return error.

func (Keeper) AddReport 

func (k Keeper) AddReport(
	ctx sdk.Context,
	requestID types.RequestID,
	dataSet []types.RawDataReportWithID,
	validator sdk.ValAddress,
) sdk.Error

func (Keeper) AddRequest 

func (k Keeper) AddRequest(
	ctx sdk.Context, oracleScriptID types.OracleScriptID, calldata []byte,
	requestedValidatorCount, sufficientValidatorCount, expiration int64, executeGas uint64,
) (types.RequestID, sdk.Error)

AddRequest attempts to create a new request. An error is returned if some conditions failed.

func (Keeper) AddResult 

func (k Keeper) AddResult(
	ctx sdk.Context, requestID types.RequestID, oracleScriptID types.OracleScriptID, calldata []byte, result []byte,
) sdk.Error

AddResult is a function to validate result size and set to store.

func (Keeper) CheckDataSourceExists 

func (k Keeper) CheckDataSourceExists(ctx sdk.Context, id types.DataSourceID) bool

CheckDataSourceExists checks if the data source of this ID exists in the storage.

func (Keeper) CheckOracleScriptExists 

func (k Keeper) CheckOracleScriptExists(ctx sdk.Context, id types.OracleScriptID) bool

CheckOracleScriptExists checks if the oracle script of this ID exists in the storage.

func (Keeper) CheckRawDataRequestExists 

func (k Keeper) CheckRawDataRequestExists(ctx sdk.Context, requestID types.RequestID, externalID types.ExternalID) bool

CheckRawDataRequestExists checks if the raw request data at this request id and external id presents in the store or not.

func (Keeper) CheckRequestExists 

func (k Keeper) CheckRequestExists(ctx sdk.Context, id types.RequestID) bool

CheckRequestExists checks if the request at this id is present in the store or not.

func (Keeper) EditDataSource 

func (k Keeper) EditDataSource(ctx sdk.Context, dataSourceID types.DataSourceID, owner sdk.AccAddress, name string, description string, fee sdk.Coins, executable []byte) sdk.Error

EditDataSource edits the given data source by given data source id to the storage.

func (Keeper) EditOracleScript 

func (k Keeper) EditOracleScript(ctx sdk.Context, oracleScriptID types.OracleScriptID, owner sdk.AccAddress, name string, description string, code []byte) sdk.Error

EditOracleScript edits the given oracle script by given oracle script id to the storage.

func (Keeper) EndBlockExecuteGasLimit 

func (keeper Keeper) EndBlockExecuteGasLimit(ctx sdk.Context) (res uint64)

func (Keeper) GasPerRawDataRequestPerValidator 

func (keeper Keeper) GasPerRawDataRequestPerValidator(ctx sdk.Context) (res uint64)

func (Keeper) GetAllDataSources 

func (k Keeper) GetAllDataSources(ctx sdk.Context) []types.DataSource

GetAllDataSources returns list of all data sources.

func (Keeper) GetAllOracleScripts 

func (k Keeper) GetAllOracleScripts(ctx sdk.Context) []types.OracleScript

GetAllOracleScripts returns list of all oracle scripts.

func (Keeper) GetDataSource 

func (k Keeper) GetDataSource(ctx sdk.Context, id types.DataSourceID) (types.DataSource, sdk.Error)

GetDataSource returns the entire DataSource struct for the given ID.

func (Keeper) GetDataSourceCount 

func (k Keeper) GetDataSourceCount(ctx sdk.Context) int64

GetDataSourceCount returns the current number of all data sources ever exist.

func (Keeper) GetDataSourceIterator 

func (k Keeper) GetDataSourceIterator(ctx sdk.Context) sdk.Iterator

GetDataSourceIterator returns an iterator for all data sources in the store.

func (Keeper) GetNextDataSourceID 

func (k Keeper) GetNextDataSourceID(ctx sdk.Context) types.DataSourceID

GetNextDataSourceID increments and returns the current number of data source. If the global data source count is not set, it initializes the value and returns 1.

func (Keeper) GetNextOracleScriptID 

func (k Keeper) GetNextOracleScriptID(ctx sdk.Context) types.OracleScriptID

GetNextOracleScriptID increments and returns the current number of oracle script. If the global oracle script count is not set, it initializes the value and returns 1.

func (Keeper) GetNextRequestID 

func (k Keeper) GetNextRequestID(ctx sdk.Context) types.RequestID

GetNextRequestID increments and returns the current number of requests. If the global request count is not set, it initializes it with value 0.

func (Keeper) GetOracleScript 

func (k Keeper) GetOracleScript(ctx sdk.Context, id types.OracleScriptID) (types.OracleScript, sdk.Error)

GetOracleScript returns the entire OracleScript struct for the given ID.

func (Keeper) GetOracleScriptCount 

func (k Keeper) GetOracleScriptCount(ctx sdk.Context) int64

GetOracleScriptCount returns the current number of all oracle scripts ever exist.

func (Keeper) GetOracleScriptIterator 

func (k Keeper) GetOracleScriptIterator(ctx sdk.Context) sdk.Iterator

GetOracleScriptIterator returns an iterator for all oracle scripts in the store.

func (Keeper) GetParams 

func (keeper Keeper) GetParams(ctx sdk.Context) types.Params

GetParams returns all current parameters as a types.Params instance.

func (Keeper) GetPendingResolveList 

func (k Keeper) GetPendingResolveList(ctx sdk.Context) []types.RequestID

GetPendingResolveList returns the list of pending request.

func (Keeper) GetRawDataReport 

func (k Keeper) GetRawDataReport(
	ctx sdk.Context,
	requestID types.RequestID, externalID types.ExternalID,
	validatorAddress sdk.ValAddress,
) (types.RawDataReport, sdk.Error)

GetRawDataReport is a function that gets a raw data report from store.

func (Keeper) GetRawDataReportsIterator 

func (k Keeper) GetRawDataReportsIterator(ctx sdk.Context, requestID types.RequestID) sdk.Iterator

GetRawDataReportsIterator returns an iterator for all reports for a specific request ID.

func (Keeper) GetRawDataRequest 

func (k Keeper) GetRawDataRequest(
	ctx sdk.Context, requestID types.RequestID, externalID types.ExternalID,
) (types.RawDataRequest, sdk.Error)

GetRawDataRequest is a function to get raw data request detail by the given request id and external id.

func (Keeper) GetRawDataRequestCount 

func (k Keeper) GetRawDataRequestCount(ctx sdk.Context, requestID types.RequestID) int64

GetRawDataRequestCount returns amount of raw data requests in given request.

func (Keeper) GetRawDataRequestIterator 

func (k Keeper) GetRawDataRequestIterator(ctx sdk.Context, requestID types.RequestID) sdk.Iterator

GetRawDataRequestIterator is a function to get iterator on all raw data request that belong to given request id

func (Keeper) GetRawDataRequestWithExternalIDs 

func (k Keeper) GetRawDataRequestWithExternalIDs(
	ctx sdk.Context, requestID types.RequestID,
) []types.RawDataRequestWithExternalID

GetRawDataRequestWithExternalIDs returns a list of raw data requests with external id in given request.

func (Keeper) GetRawDataRequests 

func (k Keeper) GetRawDataRequests(ctx sdk.Context, requestID types.RequestID) []types.RawDataRequest

GetRawDataRequests returns a list of raw data requests in given request.

func (Keeper) GetRequest 

func (k Keeper) GetRequest(ctx sdk.Context, id types.RequestID) (types.Request, sdk.Error)

GetRequest returns the entire Request metadata struct.

func (Keeper) GetRequestCount 

func (k Keeper) GetRequestCount(ctx sdk.Context) int64

GetRequestCount returns the current number of all requests ever exist.

func (Keeper) GetResult 

func (k Keeper) GetResult(
	ctx sdk.Context, requestID types.RequestID, oracleScriptID types.OracleScriptID, calldata []byte,
) (types.Result, sdk.Error)

GetResult returns the result bytes in store.

func (Keeper) HasResult 

func (k Keeper) HasResult(ctx sdk.Context, requestID types.RequestID, oracleScriptID types.OracleScriptID, calldata []byte) bool

HasResult checks if the result at this request id is present in the store or not.

func (Keeper) MaxCalldataSize 

func (keeper Keeper) MaxCalldataSize(ctx sdk.Context) (res int64)

func (Keeper) MaxDataSourceCountPerRequest 

func (keeper Keeper) MaxDataSourceCountPerRequest(ctx sdk.Context) (res int64)

func (Keeper) MaxDataSourceExecutableSize 

func (keeper Keeper) MaxDataSourceExecutableSize(ctx sdk.Context) (res int64)

func (Keeper) MaxDescriptionLength 

func (keeper Keeper) MaxDescriptionLength(ctx sdk.Context) (res int64)

func (Keeper) MaxNameLength 

func (keeper Keeper) MaxNameLength(ctx sdk.Context) (res int64)

func (Keeper) MaxOracleScriptCodeSize 

func (keeper Keeper) MaxOracleScriptCodeSize(ctx sdk.Context) (res int64)

func (Keeper) MaxRawDataReportSize 

func (keeper Keeper) MaxRawDataReportSize(ctx sdk.Context) (res int64)

func (Keeper) MaxResultSize 

func (keeper Keeper) MaxResultSize(ctx sdk.Context) (res int64)

func (Keeper) PayDataSourceFees 

func (k Keeper) PayDataSourceFees(ctx sdk.Context, id types.RequestID, sender sdk.AccAddress) sdk.Error

PayDataSourceFees sends fees to the owners of the requested data sources.

func (Keeper) SetDataSource 

func (k Keeper) SetDataSource(ctx sdk.Context, id types.DataSourceID, dataSource types.DataSource)

SetDataSource saves the given data source with the given ID to the storage. WARNING: This function doesn't perform any check on ID.

func (Keeper) SetEndBlockExecuteGasLimit 

func (keeper Keeper) SetEndBlockExecuteGasLimit(ctx sdk.Context, value uint64)

func (Keeper) SetGasPerRawDataRequestPerValidator 

func (keeper Keeper) SetGasPerRawDataRequestPerValidator(ctx sdk.Context, value uint64)

func (Keeper) SetMaxCalldataSize 

func (keeper Keeper) SetMaxCalldataSize(ctx sdk.Context, value int64)

func (Keeper) SetMaxDataSourceCountPerRequest 

func (keeper Keeper) SetMaxDataSourceCountPerRequest(ctx sdk.Context, value int64)

func (Keeper) SetMaxDataSourceExecutableSize 

func (keeper Keeper) SetMaxDataSourceExecutableSize(ctx sdk.Context, value int64)

func (Keeper) SetMaxDescriptionLength 

func (keeper Keeper) SetMaxDescriptionLength(ctx sdk.Context, value int64)

func (Keeper) SetMaxNameLength 

func (keeper Keeper) SetMaxNameLength(ctx sdk.Context, value int64)

func (Keeper) SetMaxOracleScriptCodeSize 

func (keeper Keeper) SetMaxOracleScriptCodeSize(ctx sdk.Context, value int64)

func (Keeper) SetMaxRawDataReportSize 

func (keeper Keeper) SetMaxRawDataReportSize(ctx sdk.Context, value int64)

func (Keeper) SetMaxResultSize 

func (keeper Keeper) SetMaxResultSize(ctx sdk.Context, value int64)

func (Keeper) SetOracleScript 

func (k Keeper) SetOracleScript(ctx sdk.Context, id types.OracleScriptID, oracleScript types.OracleScript)

SetOracleScript saves the given oracle script with the given ID to the storage. WARNING: This function doesn't perform any check on ID.

func (Keeper) SetPendingResolveList 

func (k Keeper) SetPendingResolveList(ctx sdk.Context, reqIDs []types.RequestID)

SetPendingResolveList saves the list of pending request that will be resolved at end block.

func (Keeper) SetRawDataReport 

func (k Keeper) SetRawDataReport(
	ctx sdk.Context,
	requestID types.RequestID, externalID types.ExternalID,
	validatorAddress sdk.ValAddress,
	rawDataReport types.RawDataReport,
)

SetRawDataReport is a function that saves a raw data report to store.

func (Keeper) SetRawDataRequest 

func (k Keeper) SetRawDataRequest(
	ctx sdk.Context, requestID types.RequestID, externalID types.ExternalID, rawDataRequest types.RawDataRequest,
)

SetRawDataRequest is a function to save raw data request detail to the given request id and external id.

func (Keeper) SetRequest 

func (k Keeper) SetRequest(ctx sdk.Context, id types.RequestID, request types.Request)

SetRequest is a function to save request to the given ID.

func (Keeper) SetResolve 

func (k Keeper) SetResolve(ctx sdk.Context, id types.RequestID, resolveStatus types.ResolveStatus) sdk.Error

func (Keeper) SetResult 

func (k Keeper) SetResult(
	ctx sdk.Context, requestID types.RequestID, oracleScriptID types.OracleScriptID, calldata []byte, result types.Result,
)

SetResult is a function to save result of execute code to store.

func (Keeper) ShouldBecomePendingResolve 

func (k Keeper) ShouldBecomePendingResolve(ctx sdk.Context, id types.RequestID) bool

ShouldBecomePendingResolve checks and returns whether the given request should be moved to the pending resolve list, which will be resolved during the EndBlock call. The move will happen exactly when the request receives sufficient raw reports from the validators.

func (Keeper) ValidateDataSourceCount 

func (k Keeper) ValidateDataSourceCount(ctx sdk.Context, id types.RequestID) sdk.Error

ValidateDataSourceCount validates that the number of raw data requests is not greater than `MaxDataSourceCountPerRequest`

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.