keeper

package
v0.0.5-test Latest Latest
Warning

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

 Go to latest Published: Aug 14, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

x/mymodule/keeper/keeper.go

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Keeper 

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

func NewKeeper 

func NewKeeper(
	cdc codec.BinaryCodec,
	storeKey storetypes.StoreKey,
) *Keeper

func (Keeper) AfterOracleEnd 

func (k Keeper) AfterOracleEnd(ctx sdk.Context, dataSet types.DataSet)

AfterEpochEnd executes the indicated hook after epochs ends

func (Keeper) AggregateData 

func (k Keeper) AggregateData(rule types.AggregationRule, submitDatas []*types.SubmitDataSet) (string, error)

aggregateData aggregates the submitted data based on the aggregation rule

func (Keeper) BeforeOracleStart 

func (k Keeper) BeforeOracleStart(ctx sdk.Context, dataSet types.DataSet)

BeforeEpochStart executes the indicated hook before the epochs

func (Keeper) BeginBlocker 

func (k Keeper) BeginBlocker(ctx sdk.Context)

BeginBlocker is called at the beginning of every block

func (Keeper) GetDataSet 

func (k Keeper) GetDataSet(ctx sdk.Context, requestId uint64, nonce uint64) (*types.DataSet, error)

func (Keeper) GetModeratorAddress 

func (k Keeper) GetModeratorAddress(ctx sdk.Context) string

GetModeratorAddress retrieves the moderator address from the state store Returns empty string if no address is found

func (Keeper) GetOracleData 

func (k Keeper) GetOracleData(ctx sdk.Context, requestId uint64) (*types.QueryOracleDataResponse, error)

GetOracleData retrieves the oracle data by request ID

func (Keeper) GetOracleRequestDoc 

func (k Keeper) GetOracleRequestDoc(ctx sdk.Context, id uint64) (*types.OracleRequestDoc, error)

GetOracleRequestDoc retrieves an oracle request document by ID from the state store id: ID of the document to retrieve Returns: retrieved oracle request document and error (error if document doesn't exist)

func (Keeper) GetOracleRequestDocCount 

func (k Keeper) GetOracleRequestDocCount(ctx sdk.Context) uint64

GetOracleRequestDocCount retrieves the total count of oracle request documents from the state store Returns: number of stored documents (0 if none exist)

func (Keeper) GetOracleRequestDocs 

func (k Keeper) GetOracleRequestDocs(ctx sdk.Context) []*types.OracleRequestDoc

func (Keeper) GetOracleRequestDocsByStatus 

func (k Keeper) GetOracleRequestDocsByStatus(ctx sdk.Context, status types.RequestStatus) []*types.OracleRequestDoc

func (Keeper) GetParams 

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

GetParams retrieves the oracle module parameters from the state store Returns default parameters if no parameters are found

func (Keeper) GetSubmitData 

func (k Keeper) GetSubmitData(ctx sdk.Context, requestId uint64, nonce uint64, provider string) ([]*types.SubmitDataSet, error)

func (Keeper) GetSubmitDatas 

func (k Keeper) GetSubmitDatas(ctx sdk.Context, requestId uint64, nonce uint64) ([]*types.SubmitDataSet, error)

func (Keeper) Logger 

func (k Keeper) Logger(ctx sdk.Context) log.Logger

Logger returns a logger instance with the module name prefixed

func (Keeper) ModeratorAddress 

func (k Keeper) ModeratorAddress(ctx context.Context, req *types.QueryModeratorAddressRequest) (*types.QueryModeratorAddressResponse, error)

GetModeratorAddress queries the moderator address

func (Keeper) OracleData 

func (k Keeper) OracleData(ctx context.Context, req *types.QueryOracleDataRequest) (*types.QueryOracleDataResponse, error)

OracleData queries oracle data by ID

func (Keeper) OracleRequestDoc 

func (k Keeper) OracleRequestDoc(ctx context.Context, req *types.QueryOracleRequestDocRequest) (*types.QueryOracleRequestDocResponse, error)

OracleRequestDoc queries oracle request doc by ID

func (Keeper) OracleRequestDocs 

func (k Keeper) OracleRequestDocs(ctx context.Context, req *types.QueryOracleRequestDocsRequest) (*types.QueryOracleRequestDocsResponse, error)

OracleRequestDocs queries an oracle request document list

func (Keeper) OracleSubmitData 

func (k Keeper) OracleSubmitData(ctx context.Context, req *types.QueryOracleSubmitDataRequest) (*types.QueryOracleSubmitDataResponse, error)

func (Keeper) Params 

func (k Keeper) Params(ctx context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)

Parameters queries the parameters of the module

func (Keeper) ProcessOracleDataSetAggregation 

func (k Keeper) ProcessOracleDataSetAggregation(ctx sdk.Context)

ProcessOracleDataSetAggregation processes oracle data set aggregation for all enabled requests It performs the following steps: 1. Retrieves all registered OracleRequestDocs 2. For each enabled document:

  • Gets submit data sets for the next nonce
  • Checks if quorum is met
  • Aggregates data based on the rule
  • Stores the result and emits events

func (Keeper) RegisterOracleRequestDoc 

func (k Keeper) RegisterOracleRequestDoc(c context.Context, doc *types.MsgRegisterOracleRequestDoc) (*types.MsgRegisterOracleRequestDocResponse, error)

RegisterOracleRequestDoc defines a method for registering a new oracle request document

func (Keeper) SetDataSet 

func (k Keeper) SetDataSet(ctx sdk.Context, dataSet types.DataSet)

SetDataSet stores the aggregated oracle data

func (*Keeper) SetHooks 

func (k *Keeper) SetHooks(eh types.OracleHooks) *Keeper

SetHooks set the oracle hooks

func (Keeper) SetModeratorAddress 

func (k Keeper) SetModeratorAddress(ctx sdk.Context, address string) error

SetModeratorAddress stores the moderator address in the state store

func (Keeper) SetOracleRequestDoc 

func (k Keeper) SetOracleRequestDoc(ctx sdk.Context, doc types.OracleRequestDoc)

SetOracleRequestDoc stores an oracle request document in the state store doc: oracle request document to store

func (Keeper) SetOracleRequestDocCount 

func (k Keeper) SetOracleRequestDocCount(ctx sdk.Context, count uint64)

SetOracleRequestDocCount stores the total count of oracle request documents in the state store count: number of documents to store

func (Keeper) SetParams 

func (k Keeper) SetParams(ctx sdk.Context, params types.Params) error

SetParams stores the oracle module parameters in the state store

func (Keeper) SetSubmitData 

func (k Keeper) SetSubmitData(ctx sdk.Context, data types.SubmitDataSet)

func (Keeper) SubmitOracleData 

func (k Keeper) SubmitOracleData(c context.Context, msg *types.MsgSubmitOracleData) (*types.MsgSubmitOracleDataResponse, error)

SubmitOracleData defines a method for submitting oracle data

func (Keeper) UpdateModeratorAddress 

func (k Keeper) UpdateModeratorAddress(c context.Context, msg *types.MsgUpdateModeratorAddress) (*types.MsgUpdateModeratorAddressResponse, error)

UpdateModeratorAddress defines a method for updating the moderator address

func (Keeper) UpdateOracleRequestDoc 

func (k Keeper) UpdateOracleRequestDoc(c context.Context, doc *types.MsgUpdateOracleRequestDoc) (*types.MsgUpdateOracleRequestDocResponse, error)

UpdateOracleRequestDoc defines a method for updating an existing oracle request document

type MultiOracleHooks 

type MultiOracleHooks []types.OracleHooks

combine multiple epoch hooks, all hook functions are run in array sequence

func NewMultiOracleHooks 

func NewMultiOracleHooks(hooks ...types.OracleHooks) MultiOracleHooks

func (MultiOracleHooks) AfterOracleEnd 

func (mh MultiOracleHooks) AfterOracleEnd(ctx sdk.Context, dataSet types.DataSet)

AfterEpochEnd is called when epoch is going to be ended, epochNumber is the number of epoch that is ending

func (MultiOracleHooks) BeforeOracleStart 

func (mh MultiOracleHooks) BeforeOracleStart(ctx sdk.Context, dataSet types.DataSet)

BeforeEpochStart is called when epoch is going to be started, epochNumber is the number of epoch that is starting

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.