keeper

Documentation

Index

• func NewMsgServerImpl(keeper Keeper) types.MsgServer
• func RawBundleToQueryBundle(rawFinalizedBundle types.FinalizedBundle, versionMap map[int32]uint64) (queryBundle queryTypes.FinalizedBundle)
• type Keeper
  • func NewKeeper(cdc codec.BinaryCodec, storeKey storetypes.StoreKey, ...) *Keeper
  • func (k Keeper) AssertCanPropose(ctx sdk.Context, poolId uint64, staker string, proposer string, ...) error
  • func (k Keeper) AssertCanVote(ctx sdk.Context, poolId uint64, staker string, voter string, storageId string) error
  • func (k Keeper) AssertPoolCanRun(ctx sdk.Context, poolId uint64) error
  • func (k Keeper) GetAllBundleProposals(ctx sdk.Context) (list []types.BundleProposal)
  • func (k Keeper) GetAllFinalizedBundles(ctx sdk.Context) (list []types.FinalizedBundle)
  • func (k Keeper) GetBundleProposal(ctx sdk.Context, poolId uint64) (val types.BundleProposal, found bool)
  • func (k Keeper) GetBundleVersionMap(ctx sdk.Context) (val types.BundleVersionMap)
  • func (k Keeper) GetFinalizedBundle(ctx sdk.Context, poolId, id uint64) (val types.FinalizedBundle, found bool)
  • func (k Keeper) GetFinalizedBundleByIndex(ctx sdk.Context, poolId, index uint64) (val queryTypes.FinalizedBundle, found bool)
  • func (k Keeper) GetFinalizedBundlesByPool(ctx sdk.Context, poolId uint64) (list []types.FinalizedBundle)
  • func (k Keeper) GetMaxPoints(ctx sdk.Context) (res uint64)
  • func (k Keeper) GetNetworkFee(ctx sdk.Context) (res sdk.Dec)
  • func (k Keeper) GetPaginatedFinalizedBundleQuery(ctx sdk.Context, pagination *query.PageRequest, poolId uint64) ([]queryTypes.FinalizedBundle, *query.PageResponse, error)
  • func (k Keeper) GetParams(ctx sdk.Context) (params types.Params)
  • func (k Keeper) GetStorageCost(ctx sdk.Context) (res sdk.Dec)
  • func (k Keeper) GetUploadTimeout(ctx sdk.Context) (res uint64)
  • func (k Keeper) GetVoteDistribution(ctx sdk.Context, poolId uint64) (voteDistribution types.VoteDistribution)
  • func (k Keeper) HandleUploadTimeout(goCtx context.Context)
  • func (k Keeper) InitMemStore(gasCtx sdk.Context)
  • func (k Keeper) Logger(ctx sdk.Context) log.Logger
  • func (k Keeper) Params(c context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)
  • func (k Keeper) SetBundleProposal(ctx sdk.Context, bundleProposal types.BundleProposal)
  • func (k Keeper) SetBundleVersionMap(ctx sdk.Context, bundleVersionMap types.BundleVersionMap)
  • func (k Keeper) SetFinalizedBundle(ctx sdk.Context, finalizedBundle types.FinalizedBundle)
  • func (k Keeper) SetFinalizedBundleIndexes(ctx sdk.Context, finalizedBundle types.FinalizedBundle)
  • func (k Keeper) SetParams(ctx sdk.Context, params types.Params)
• type RandomChoiceCandidate

Functions

func NewMsgServerImpl

func NewMsgServerImpl(keeper Keeper) types.MsgServer

NewMsgServerImpl returns an implementation of the MsgServer interface for the provided Keeper.

func RawBundleToQueryBundle

func RawBundleToQueryBundle(rawFinalizedBundle types.FinalizedBundle, versionMap map[int32]uint64) (queryBundle queryTypes.FinalizedBundle)

Types

type Keeper

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

func NewKeeper

func NewKeeper(
	cdc codec.BinaryCodec,
	storeKey storetypes.StoreKey,
	memKey storetypes.StoreKey,

	authority string,

	accountKeeper types.AccountKeeper,
	bankKeeper types.BankKeeper,
	distrkeeper types.DistrKeeper,
	poolKeeper types.PoolKeeper,
	stakerKeeper types.StakerKeeper,
	delegationKeeper types.DelegationKeeper,
) *Keeper

func (Keeper) AssertCanPropose

func (k Keeper) AssertCanPropose(ctx sdk.Context, poolId uint64, staker string, proposer string, fromIndex uint64) error

AssertCanPropose checks whether a participant can submit the next bundle proposal in a storage pool

func (Keeper) AssertCanVote

func (k Keeper) AssertCanVote(ctx sdk.Context, poolId uint64, staker string, voter string, storageId string) error

AssertCanVote checks whether a participant in the network can vote on a bundle proposal in a storage pool

func (Keeper) AssertPoolCanRun

func (k Keeper) AssertPoolCanRun(ctx sdk.Context, poolId uint64) error

AssertPoolCanRun checks whether the given pool fulfils all technical/formal requirements to produce bundles

func (Keeper) GetAllBundleProposals

func (k Keeper) GetAllBundleProposals(ctx sdk.Context) (list []types.BundleProposal)

GetAllBundleProposals returns all bundle proposals of all pools

func (Keeper) GetAllFinalizedBundles

func (k Keeper) GetAllFinalizedBundles(ctx sdk.Context) (list []types.FinalizedBundle)

func (Keeper) GetBundleProposal

func (k Keeper) GetBundleProposal(ctx sdk.Context, poolId uint64) (val types.BundleProposal, found bool)

GetBundleProposal returns the bundle proposal for the given pool with id `poolId`

func (Keeper) GetBundleVersionMap

func (k Keeper) GetBundleVersionMap(ctx sdk.Context) (val types.BundleVersionMap)

GetBundleVersionMap returns the bundle version map

func (Keeper) GetFinalizedBundle

func (k Keeper) GetFinalizedBundle(ctx sdk.Context, poolId, id uint64) (val types.FinalizedBundle, found bool)

GetFinalizedBundle returns a finalized bundle by its identifier

func (Keeper) GetFinalizedBundleByIndex

func (k Keeper) GetFinalizedBundleByIndex(ctx sdk.Context, poolId, index uint64) (val queryTypes.FinalizedBundle, found bool)

func (Keeper) GetFinalizedBundlesByPool

func (k Keeper) GetFinalizedBundlesByPool(ctx sdk.Context, poolId uint64) (list []types.FinalizedBundle)

func (Keeper) GetMaxPoints

func (k Keeper) GetMaxPoints(ctx sdk.Context) (res uint64)

GetMaxPoints returns the MaxPoints param

func (Keeper) GetNetworkFee

func (k Keeper) GetNetworkFee(ctx sdk.Context) (res sdk.Dec)

GetNetworkFee returns the NetworkFee param

func (Keeper) GetPaginatedFinalizedBundleQuery

func (k Keeper) GetPaginatedFinalizedBundleQuery(ctx sdk.Context, pagination *query.PageRequest, poolId uint64) ([]queryTypes.FinalizedBundle, *query.PageResponse, error)

GetPaginatedFinalizedBundleQuery parses a paginated request and builds a valid response out of the raw finalized bundles. It uses the fact that the ID of a bundle increases incrementally (starting with 0) and allows therefore for efficient queries using `offset`.

func (Keeper) GetParams

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

GetParams returns the current x/bundles module parameters.

func (Keeper) GetStorageCost

func (k Keeper) GetStorageCost(ctx sdk.Context) (res sdk.Dec)

GetStorageCost returns the StorageCost param

func (Keeper) GetUploadTimeout

func (k Keeper) GetUploadTimeout(ctx sdk.Context) (res uint64)

GetUploadTimeout returns the UploadTimeout param

func (Keeper) GetVoteDistribution

func (k Keeper) GetVoteDistribution(ctx sdk.Context, poolId uint64) (voteDistribution types.VoteDistribution)

GetVoteDistribution is an internal function evaluates the quorum status based on the voting power of the current bundle proposal.

func (Keeper) HandleUploadTimeout

func (k Keeper) HandleUploadTimeout(goCtx context.Context)

HandleUploadTimeout is an end block hook that triggers an upload timeout for every pool (if applicable).

func (Keeper) InitMemStore

func (k Keeper) InitMemStore(gasCtx sdk.Context)

func (Keeper) Logger

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

func (Keeper) Params

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

func (Keeper) SetBundleProposal

func (k Keeper) SetBundleProposal(ctx sdk.Context, bundleProposal types.BundleProposal)

SetBundleProposal stores a current bundle proposal in the KV-Store. There is only one bundle proposal per pool

func (Keeper) SetBundleVersionMap

func (k Keeper) SetBundleVersionMap(ctx sdk.Context, bundleVersionMap types.BundleVersionMap)

SetBundleVersionMap stores the bundle version map

func (Keeper) SetFinalizedBundle

func (k Keeper) SetFinalizedBundle(ctx sdk.Context, finalizedBundle types.FinalizedBundle)

SetFinalizedBundle stores a finalized bundle identified by its `poolId` and `id`.

func (Keeper) SetFinalizedBundleIndexes

func (k Keeper) SetFinalizedBundleIndexes(ctx sdk.Context, finalizedBundle types.FinalizedBundle)

SetFinalizedBundleIndexes sets an in-memory reference for every bundle sorted by pool/fromIndex to allow querying for specific bundle ranges.

func (Keeper) SetParams

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

SetParams sets the x/bundles module parameters.

type RandomChoiceCandidate

type RandomChoiceCandidate struct {
	Account     string
	VotingPower uint64
}

RandomChoiceCandidate holds the voting power of a candidate for the next uploader selection