keeper

func (*Keeper) AccountKeeper ¶ added in v0.0.4

func (k *Keeper) AccountKeeper() AccountKeeper

func (*Keeper) AddAddressTopics ¶

func (k *Keeper) AddAddressTopics(ctx context.Context, address sdk.AccAddress, newTopics []uint64) error

AddAddressTopics adds new topics to the address's list of topics, avoiding duplicates.

func (*Keeper) AddStake ¶

func (k *Keeper) AddStake(ctx context.Context, TopicIds []TOPIC_ID, delegator string, target string, stake Uint) error

Add stake adds stake to the system for a given delegator and target it adds to existing holdings. it places the stake upon target, from delegator, in amount. it also updates the total stake for the subnet in question and the total global stake. see comments in keeper.go data structures for examples of how the data structure tracking works

func (*Keeper) AddStakePlacedUponTarget ¶

func (k *Keeper) AddStakePlacedUponTarget(ctx context.Context, target sdk.AccAddress, amount Uint) error

Used by Modify functions to change stake placements. This function adds to the stakePlacedUponTarget mapping ONLY and does not modify any of the other stake mappings e.g. delegatorStake totalStake or topicStake in a system.

func (*Keeper) AddStakePlacement ¶

func (k *Keeper) AddStakePlacement(ctx context.Context, delegator sdk.AccAddress, target sdk.AccAddress, amount Uint) error

Used by Modify functions to change stake placements. This function adds to the stakePlacement mapping ONLY and does not modify any of the other stake mappings e.g. delegatorStake totalStake or topicStake in a system.

func (*Keeper) AddStakeToTopics ¶

func (k *Keeper) AddStakeToTopics(ctx context.Context, TopicIds []TOPIC_ID, stake Uint) error

Add stake into an array of topics

func (*Keeper) AddToMempool ¶

func (k *Keeper) AddToMempool(ctx context.Context, request state.InferenceRequest) error

func (*Keeper) AddToTopicCreationWhitelist ¶ added in v0.0.1

func (k *Keeper) AddToTopicCreationWhitelist(ctx context.Context, address sdk.AccAddress) error

func (*Keeper) AddToWeightSettingWhitelist ¶ added in v0.0.1

func (k *Keeper) AddToWeightSettingWhitelist(ctx context.Context, address sdk.AccAddress) error

func (*Keeper) AddTopicAccumulateMetDemand ¶

func (k *Keeper) AddTopicAccumulateMetDemand(ctx context.Context, topicId TOPIC_ID, metDemand Uint) error

func (*Keeper) AddUnmetDemand ¶

func (k *Keeper) AddUnmetDemand(ctx context.Context, topicId TOPIC_ID, amt cosmosMath.Uint) error

func (*Keeper) AddWhitelistAdmin ¶ added in v0.0.1

func (k *Keeper) AddWhitelistAdmin(ctx context.Context, admin sdk.AccAddress) error

func (*Keeper) BankKeeper ¶ added in v0.0.4

func (k *Keeper) BankKeeper() BankKeeper

func (*Keeper) ExportGenesis ¶

func (k *Keeper) ExportGenesis(ctx context.Context) (*state.GenesisState, error)

ExportGenesis exports the module state to a genesis state.

func (*Keeper) FindWorkerNodesByOwner ¶

func (k *Keeper) FindWorkerNodesByOwner(ctx sdk.Context, nodeId string) ([]*state.OffchainNode, error)

func (*Keeper) GetActiveTopics ¶

func (k *Keeper) GetActiveTopics(ctx context.Context) ([]*state.Topic, error)

GetActiveTopics returns a slice of all active topics.

func (*Keeper) GetAllBondsForDelegator ¶

func (k *Keeper) GetAllBondsForDelegator(ctx context.Context, delegator sdk.AccAddress) ([]sdk.AccAddress, []Uint, error)

For a given delegator, return a map of every target they've placed stake upon, and how much stake they've placed upon them O(n) over the number of targets registered. since maps of byte array types aren't supported in golang, we instead return two equal length arrays where the first array is the targets, and the second array is the amount of stake placed upon them indexes in the two arrays correspond to each other invariant that len(targets) == len(stakes)

func (*Keeper) GetAllInferences ¶

func (k *Keeper) GetAllInferences(ctx context.Context, topicId TOPIC_ID, timestamp uint64) (*state.Inferences, error)

func (*Keeper) GetAllTopics ¶ added in v0.0.4

func (k *Keeper) GetAllTopics(ctx context.Context) ([]*state.Topic, error)

Gets every topic

func (*Keeper) GetBond ¶

func (k *Keeper) GetBond(ctx context.Context, delegator sdk.AccAddress, target sdk.AccAddress) (Uint, error)

For a given delegator and target, find out how much stake the delegator has placed upon the target

func (*Keeper) GetChurnReadyTopics ¶ added in v0.0.4

func (k *Keeper) GetChurnReadyTopics(ctx context.Context) (state.TopicList, error)

Get all churn ready topics

func (*Keeper) GetDelegatorStake ¶

func (k *Keeper) GetDelegatorStake(ctx context.Context, delegator sdk.AccAddress) (Uint, error)

for a given address, find out how much stake they've put into the system

func (*Keeper) GetFeeCollectorName ¶ added in v0.0.4

func (k *Keeper) GetFeeCollectorName() string

func (*Keeper) GetLastRewardsUpdate ¶

func (k *Keeper) GetLastRewardsUpdate(ctx context.Context) (int64, error)

Returns the last block height at which rewards emissions were updated

func (*Keeper) GetLatestInferencesFromTopic ¶

func (k *Keeper) GetLatestInferencesFromTopic(ctx context.Context, topicId TOPIC_ID) ([]*state.InferenceSetForScoring, error)

A function that accepts a topicId and returns list of Inferences or error

func (*Keeper) GetMempool ¶

func (k *Keeper) GetMempool(ctx context.Context) ([]state.InferenceRequest, error)

func (*Keeper) GetMempoolInferenceRequestById ¶

func (k *Keeper) GetMempoolInferenceRequestById(ctx context.Context, topicId TOPIC_ID, requestId string) (state.InferenceRequest, error)

func (*Keeper) GetMempoolInferenceRequestsForTopic ¶

func (k *Keeper) GetMempoolInferenceRequestsForTopic(ctx context.Context, topicId TOPIC_ID) ([]state.InferenceRequest, error)

func (*Keeper) GetNumInferencesInRewardEpoch ¶ added in v0.0.1

func (k *Keeper) GetNumInferencesInRewardEpoch(ctx context.Context, topicId TOPIC_ID, worker sdk.AccAddress) (Uint, error)

func (*Keeper) GetNumTopics ¶

func (k *Keeper) GetNumTopics(ctx context.Context) (TOPIC_ID, error)

Returns the number of topics that are active in the network

func (*Keeper) GetParams ¶ added in v0.0.1

func (k *Keeper) GetParams(ctx context.Context) (state.Params, error)

func (*Keeper) GetParamsEpochLength ¶ added in v0.0.4

func (k *Keeper) GetParamsEpochLength(ctx context.Context) (int64, error)

return epoch length

func (*Keeper) GetParamsMaxInferenceRequestValidity ¶ added in v0.0.4

func (k *Keeper) GetParamsMaxInferenceRequestValidity(ctx context.Context) (uint64, error)

func (*Keeper) GetParamsMaxMissingInferencePercent ¶ added in v0.0.4

func (k *Keeper) GetParamsMaxMissingInferencePercent(ctx context.Context) (cosmosMath.LegacyDec, error)

func (*Keeper) GetParamsMaxRequestCadence ¶ added in v0.0.4

func (k *Keeper) GetParamsMaxRequestCadence(ctx context.Context) (uint64, error)

func (*Keeper) GetParamsMaxTopicsPerBlock ¶ added in v0.0.4

func (k *Keeper) GetParamsMaxTopicsPerBlock(ctx context.Context) (uint64, error)

func (*Keeper) GetParamsMinRequestCadence ¶ added in v0.0.4

func (k *Keeper) GetParamsMinRequestCadence(ctx context.Context) (uint64, error)

func (*Keeper) GetParamsMinRequestUnmetDemand ¶ added in v0.0.4

func (k *Keeper) GetParamsMinRequestUnmetDemand(ctx context.Context) (Uint, error)

func (*Keeper) GetParamsMinTopicUnmetDemand ¶ added in v0.0.4

func (k *Keeper) GetParamsMinTopicUnmetDemand(ctx context.Context) (Uint, error)

func (*Keeper) GetParamsMinWeightCadence ¶ added in v0.0.4

func (k *Keeper) GetParamsMinWeightCadence(ctx context.Context) (uint64, error)

func (*Keeper) GetParamsPercentRewardsReputersWorkers ¶ added in v0.0.4

func (k *Keeper) GetParamsPercentRewardsReputersWorkers(ctx context.Context) (cosmosMath.LegacyDec, error)

func (*Keeper) GetParamsRemoveStakeDelayWindow ¶ added in v0.0.4

func (k *Keeper) GetParamsRemoveStakeDelayWindow(ctx context.Context) (uint64, error)

func (*Keeper) GetParamsRequiredMinimumStake ¶ added in v0.0.4

func (k *Keeper) GetParamsRequiredMinimumStake(ctx context.Context) (Uint, error)

func (*Keeper) GetRegisteredTopicIdByReputerAddress ¶ added in v0.0.4

func (k *Keeper) GetRegisteredTopicIdByReputerAddress(ctx context.Context, address sdk.AccAddress) ([]uint64, error)

GetRegisteredTopicIdByReputerAddress returns a slice of all topics ids registered by a given reputer address.

func (*Keeper) GetRegisteredTopicIdsByAddress ¶ added in v0.0.4

func (k *Keeper) GetRegisteredTopicIdsByAddress(ctx context.Context, address sdk.AccAddress) ([]uint64, error)

GetRegisteredTopicsByAddress returns a slice of all topics ids registered by a given address.

func (*Keeper) GetRegisteredTopicIdsByWorkerAddress ¶ added in v0.0.4

func (k *Keeper) GetRegisteredTopicIdsByWorkerAddress(ctx context.Context, address sdk.AccAddress) ([]uint64, error)

GetRegisteredTopicIdsByWorkerAddress returns a slice of all topics ids registered by a given worker address.

func (*Keeper) GetReputerNormalizedStake ¶

func (k *Keeper) GetReputerNormalizedStake(
	ctx sdk.Context,
	topicId TOPIC_ID,
	topicStake *big.Float) (reputerNormalizedStakeMap map[ACC_ADDRESS]*big.Float, retErr error)

for a given topic, returns every reputer node registered to it and their normalized stake

func (*Keeper) GetRequestDemand ¶

func (k *Keeper) GetRequestDemand(ctx context.Context, requestId string) (Uint, error)

func (*Keeper) GetStakePlacedUponTarget ¶

func (k *Keeper) GetStakePlacedUponTarget(ctx context.Context, target sdk.AccAddress) (Uint, error)

func (*Keeper) GetStakeRemovalQueueForDelegator ¶

func (k *Keeper) GetStakeRemovalQueueForDelegator(ctx context.Context, delegator sdk.AccAddress) (state.StakeRemoval, error)

for a given delegator, get their stake removal information

func (*Keeper) GetStakesForAccount ¶

func (k *Keeper) GetStakesForAccount(ctx context.Context, delegator sdk.AccAddress) ([]*state.StakeInfo, error)

GetStakesForAccount returns the list of stakes for a given account address.

func (*Keeper) GetTopic ¶ added in v0.0.1

func (k *Keeper) GetTopic(ctx context.Context, topicId TOPIC_ID) (state.Topic, error)

Gets topic by topicId

func (*Keeper) GetTopicAccumulatedMetDemand ¶

func (k *Keeper) GetTopicAccumulatedMetDemand(ctx context.Context, topicId TOPIC_ID) (Uint, error)

func (*Keeper) GetTopicInferenceLastRan ¶

func (k *Keeper) GetTopicInferenceLastRan(ctx context.Context, topicId TOPIC_ID) (lastRanTime uint64, err error)

Get the last time an inference was ran for a given topic

func (*Keeper) GetTopicStake ¶

func (k *Keeper) GetTopicStake(ctx context.Context, topicId TOPIC_ID) (Uint, error)

Gets the stake in the network for a given topic

func (*Keeper) GetTopicUnmetDemand ¶

func (k *Keeper) GetTopicUnmetDemand(ctx context.Context, topicId TOPIC_ID) (Uint, error)

func (*Keeper) GetTopicWeightLastRan ¶

func (k *Keeper) GetTopicWeightLastRan(ctx context.Context, topicId TOPIC_ID) (uint64, error)

func (*Keeper) GetTopicsByCreator ¶

func (k *Keeper) GetTopicsByCreator(ctx context.Context, creator string) ([]*state.Topic, error)

GetTopicsByCreator returns a slice of all topics created by a given creator.

func (*Keeper) GetTotalStake ¶

func (k *Keeper) GetTotalStake(ctx context.Context) (Uint, error)

Gets the total sum of all stake in the network across all topics

func (*Keeper) GetWeightsFromTopic ¶

func (k *Keeper) GetWeightsFromTopic(ctx context.Context, topicId TOPIC_ID) (map[REPUTERS]map[WORKERS]*Uint, error)

For a given topic return the matrix (double map) of all (reputers, workers) -> weight of reputer upon worker

func (*Keeper) GetWorkerAddressByP2PKey ¶

func (k *Keeper) GetWorkerAddressByP2PKey(ctx context.Context, p2pKey string) (sdk.AccAddress, error)

func (*Keeper) GetWorkerLatestInferenceByTopicId ¶ added in v0.0.4

func (k *Keeper) GetWorkerLatestInferenceByTopicId(
	ctx context.Context,
	topicId TOPIC_ID,
	worker sdk.AccAddress) (state.Inference, error)

func (*Keeper) InactivateTopic ¶

func (k *Keeper) InactivateTopic(ctx context.Context, topicId TOPIC_ID) error

func (*Keeper) IncrementNumInferencesInRewardEpoch ¶ added in v0.0.1

func (k *Keeper) IncrementNumInferencesInRewardEpoch(ctx context.Context, topicId TOPIC_ID, worker sdk.AccAddress) error

func (*Keeper) IncrementTopicId ¶

func (k *Keeper) IncrementTopicId(ctx context.Context) (TOPIC_ID, error)

Gets next topic id

func (*Keeper) InitGenesis ¶

func (k *Keeper) InitGenesis(ctx context.Context, data *state.GenesisState) error

InitGenesis initializes the module state from a genesis state.

func (*Keeper) InsertInferences ¶

func (k *Keeper) InsertInferences(ctx context.Context, topicId TOPIC_ID, timestamp uint64, inferences state.Inferences) error

Insert a complete set of inferences for a topic/timestamp. Overwrites previous ones.

func (*Keeper) InsertReputer ¶

func (k *Keeper) InsertReputer(ctx context.Context, TopicIds []TOPIC_ID, reputer sdk.AccAddress, reputerInfo state.OffchainNode) error

Adds a new reputer to the reputer tracking data structures, reputers and topicReputers

func (*Keeper) InsertWorker ¶

func (k *Keeper) InsertWorker(ctx context.Context, TopicIds []TOPIC_ID, worker sdk.AccAddress, workerInfo state.OffchainNode) error

Adds a new worker to the worker tracking data structures, workers and topicWorkers

func (*Keeper) IsInTopicCreationWhitelist ¶ added in v0.0.1

func (k *Keeper) IsInTopicCreationWhitelist(ctx context.Context, address sdk.AccAddress) (bool, error)

func (*Keeper) IsInWeightSettingWhitelist ¶ added in v0.0.1

func (k *Keeper) IsInWeightSettingWhitelist(ctx context.Context, address sdk.AccAddress) (bool, error)

func (*Keeper) IsRequestInMempool ¶

func (k *Keeper) IsRequestInMempool(ctx context.Context, topicId TOPIC_ID, requestId string) (bool, error)

func (*Keeper) IsWhitelistAdmin ¶ added in v0.0.1

func (k *Keeper) IsWhitelistAdmin(ctx context.Context, admin sdk.AccAddress) (bool, error)

func (*Keeper) IterateAllTopicStake ¶

func (k *Keeper) IterateAllTopicStake(ctx context.Context) (collections.Iterator[uint64, cosmosMath.Uint], error)

func (*Keeper) ReactivateTopic ¶ added in v0.0.1

func (k *Keeper) ReactivateTopic(ctx context.Context, topicId TOPIC_ID) error

func (*Keeper) RemoveAddressTopic ¶

func (k *Keeper) RemoveAddressTopic(ctx context.Context, address sdk.AccAddress, topicToRemove uint64) error

RemoveAddressTopic removes a specified topic from the address's list of topics.

func (*Keeper) RemoveFromMempool ¶

func (k *Keeper) RemoveFromMempool(ctx context.Context, request state.InferenceRequest) error

func (*Keeper) RemoveFromTopicCreationWhitelist ¶ added in v0.0.1

func (k *Keeper) RemoveFromTopicCreationWhitelist(ctx context.Context, address sdk.AccAddress) error

func (*Keeper) RemoveFromWeightSettingWhitelist ¶ added in v0.0.1

func (k *Keeper) RemoveFromWeightSettingWhitelist(ctx context.Context, address sdk.AccAddress) error

func (*Keeper) RemoveReputer ¶

func (k *Keeper) RemoveReputer(ctx context.Context, topicId TOPIC_ID, reputerAddr sdk.AccAddress) error

Remove a reputer to the reputer tracking data structures and topicReputers

func (*Keeper) RemoveStakeFromBond ¶

func (k *Keeper) RemoveStakeFromBond(
	ctx context.Context,
	TopicIds []TOPIC_ID,
	delegator sdk.AccAddress,
	target sdk.AccAddress,
	stake Uint) error

Remove stake from bond updates the various data structures associated with removing stake from the system for a given delegator and target it removes the stake upon target, from delegator, in amount. it also updates the total stake for the topic in question and the total global stake. see comments in keeper.go data structures for examples of how the data structure tracking works

func (*Keeper) RemoveStakeFromBondMissingTotalOrTopicStake ¶

func (k *Keeper) RemoveStakeFromBondMissingTotalOrTopicStake(
	ctx context.Context,
	delegator sdk.AccAddress,
	target sdk.AccAddress,
	stake Uint) error

Remove stake from bond updates the various data structures associated with removing stake from the system for a given delegator and target it removes the stake upon target, from delegator, in amount. it *DOES NOT* update the total stake for the subnet in question and the total global stake. this is used by RemoveAllStake to avoid double counting the topic/total stake removal

func (*Keeper) RemoveStakeFromTopics ¶

func (k *Keeper) RemoveStakeFromTopics(ctx context.Context, TopicIds []TOPIC_ID, stake Uint) error

Remove stake from an array of topics

func (*Keeper) RemoveUnmetDemand ¶

func (k *Keeper) RemoveUnmetDemand(ctx context.Context, topicId TOPIC_ID, amt cosmosMath.Uint) error

func (*Keeper) RemoveWhitelistAdmin ¶ added in v0.0.1

func (k *Keeper) RemoveWhitelistAdmin(ctx context.Context, admin sdk.AccAddress) error

func (*Keeper) RemoveWorker ¶

func (k *Keeper) RemoveWorker(ctx context.Context, topicId TOPIC_ID, workerAddr sdk.AccAddress) error

Remove a worker to the worker tracking data structures and topicWorkers

func (*Keeper) ResetChurnReadyTopics ¶ added in v0.0.4

func (k *Keeper) ResetChurnReadyTopics(ctx context.Context) error

Reset the mapping entirely. Should be called at the end of every block

func (*Keeper) ResetNumInferencesInRewardEpoch ¶ added in v0.0.1

func (k *Keeper) ResetNumInferencesInRewardEpoch(ctx context.Context) error

Reset the mapping entirely. Should be called at the end of every reward epoch

func (*Keeper) SetChurnReadyTopics ¶ added in v0.0.4

func (k *Keeper) SetChurnReadyTopics(ctx context.Context, topicList state.TopicList) error

Set a topic as churn ready

func (*Keeper) SetLastRewardsUpdate ¶

func (k *Keeper) SetLastRewardsUpdate(ctx context.Context, blockHeight int64) error

Set the last block height at which rewards emissions were updated

func (*Keeper) SetParams ¶

func (k *Keeper) SetParams(ctx context.Context, params state.Params) error

func (*Keeper) SetRequestDemand ¶

func (k *Keeper) SetRequestDemand(ctx context.Context, requestId string, amount Uint) error

func (*Keeper) SetStakePlacedUponTarget ¶

func (k *Keeper) SetStakePlacedUponTarget(ctx context.Context, target sdk.AccAddress, stake Uint) error

func (*Keeper) SetStakeRemovalQueueForDelegator ¶

func (k *Keeper) SetStakeRemovalQueueForDelegator(ctx context.Context, delegator sdk.AccAddress, removalInfo state.StakeRemoval) error

For a given delegator, adds their stake removal information to the removal queue for delay waiting

func (*Keeper) SetTopic ¶

func (k *Keeper) SetTopic(ctx context.Context, topicId TOPIC_ID, topic state.Topic) error

Sets a topic config on a topicId

func (*Keeper) SetTopicAccumulatedMetDemand ¶

func (k *Keeper) SetTopicAccumulatedMetDemand(ctx context.Context, topicId TOPIC_ID, metDemand Uint) error

func (*Keeper) SetTopicStake ¶

func (k *Keeper) SetTopicStake(ctx context.Context, topicId TOPIC_ID, stake Uint) error

Sets the stake in the network for a given topic

func (*Keeper) SetTopicUnmetDemand ¶

func (k *Keeper) SetTopicUnmetDemand(ctx context.Context, topicId TOPIC_ID, amt cosmosMath.Uint) error

func (*Keeper) SetTotalStake ¶

func (k *Keeper) SetTotalStake(ctx context.Context, totalStake Uint) error

Sets the total sum of all stake in the network across all topics

func (*Keeper) SetWeight ¶

func (k *Keeper) SetWeight(
	ctx context.Context,
	topicId TOPIC_ID,
	reputer sdk.AccAddress,
	worker sdk.AccAddress,
	weight Uint) error

func (*Keeper) SubStakePlacedUponTarget ¶

func (k *Keeper) SubStakePlacedUponTarget(ctx context.Context, target sdk.AccAddress, amount Uint) error

Used by Modify functions to change stake placements. This function subtracts from the stakePlacedUponTarget mapping ONLY and does not modify any of the other stake mappings e.g. delegatorStake totalStake or topicStake in a system.

func (*Keeper) SubStakePlacement ¶

func (k *Keeper) SubStakePlacement(ctx context.Context, delegator sdk.AccAddress, target sdk.AccAddress, amount Uint) error

Used by Modify functions to change stake placements. This function subtracts from the stakePlacement mapping ONLY and does not modify any of the other stake mappings e.g. delegatorStake totalStake or topicStake in a system.

func (*Keeper) TopicExists ¶

func (k *Keeper) TopicExists(ctx context.Context, topicId TOPIC_ID) (bool, error)

Checks if a topic exists

func (*Keeper) UpdateTopicInferenceLastRan ¶

func (k *Keeper) UpdateTopicInferenceLastRan(ctx context.Context, topicId TOPIC_ID, lastRanTime uint64) error

UpdateTopicInferenceLastRan updates the InferenceLastRan timestamp for a given topic.

func (*Keeper) UpdateTopicWeightLastRan ¶

func (k *Keeper) UpdateTopicWeightLastRan(ctx context.Context, topicId TOPIC_ID, lastRanTime uint64) error

UpdateTopicWeightLastRan updates the WeightLastRan timestamp for a given topic.

func (*Keeper) WalkAllTopicStake ¶

func (k *Keeper) WalkAllTopicStake(ctx context.Context, walkFunc func(topicId TOPIC_ID, stake Uint) (stop bool, err error)) error

Runs an arbitrary function for every topic in the network