Documentation
¶
Index ¶
- func NewQueryServerImpl(k Keeper) types.QueryServer
- type Keeper
- func (k Keeper) ActiveValidators(ctx context.Context) ([]cmttypes.GenesisValidator, error)
- func (k Keeper) BeginBlocker(ctx context.Context) error
- func (k Keeper) Claim(ctx context.Context, reqs []*goattypes.ClaimRequest) error
- func (k *Keeper) Create(ctx context.Context, req []*goattypes.CreateRequest) error
- func (k Keeper) DequeueLockingModuleTx(ctx context.Context) ([]*ethtypes.Transaction, error)
- func (k Keeper) DequeueMatureUnlocks(ctx context.Context) error
- func (k Keeper) DistributeReward(ctx context.Context) error
- func (k Keeper) EndBlocker(ctx context.Context) ([]abci.ValidatorUpdate, error)
- func (k Keeper) HandleEvidences(ctx context.Context) error
- func (k Keeper) HandleVoteInfos(ctx context.Context) error
- func (k Keeper) Lock(ctx context.Context, reqs []*goattypes.LockRequest) error
- func (k Keeper) Logger() log.Logger
- func (k Keeper) ProcessLockingRequest(ctx context.Context, reqs goattypes.LockingRequests) error
- func (k Keeper) Unlock(ctx context.Context, reqs []*goattypes.UnlockRequest) error
- func (k Keeper) UpdateForkParams(sdkctx sdktypes.Context) error
- func (k Keeper) UpdateRewardPool(ctx context.Context, gas []*goattypes.GasRequest, ...) error
- func (k Keeper) UpdateTokens(ctx context.Context, weights []*goattypes.UpdateTokenWeightRequest, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewQueryServerImpl ¶
func NewQueryServerImpl(k Keeper) types.QueryServer
NewQueryServerImpl returns an implementation of the QueryServer interface for the provided Keeper.
Types ¶
type Keeper ¶
type Keeper struct {
Schema collections.Schema
Params collections.Item[types.Params]
// (token,validator) => locking, it's used for updating power when the token weight is updated
Locking collections.Map[collections.Pair[string, sdktypes.ConsAddress], math.Int]
// (power,validator) => int64(power), it's used for getting validators of top-k power
PowerRanking collections.KeySet[collections.Pair[uint64, sdktypes.ConsAddress]]
ValidatorSet collections.Map[sdktypes.ConsAddress, uint64]
Validators collections.Map[sdktypes.ConsAddress, types.Validator]
Tokens collections.Map[string, types.Token]
Threshold collections.Item[types.Threshold]
Slashed collections.Map[string, math.Int]
EthTxNonce collections.Sequence
RewardPool collections.Item[types.RewardPool]
EthTxQueue collections.Item[types.EthTxQueue]
UnlockQueue collections.Map[time.Time, types.Unlocks]
FinalizedTime collections.Item[time.Time]
// contains filtered or unexported fields
}
func NewKeeper ¶
func NewKeeper( cdc codec.BinaryCodec, addressCodec address.Codec, storeService store.KVStoreService, accountKeeper types.AccountKeeper, logger log.Logger, ) Keeper
func (Keeper) ActiveValidators ¶
func (Keeper) DequeueLockingModuleTx ¶
func (Keeper) DequeueMatureUnlocks ¶
func (Keeper) EndBlocker ¶
func (Keeper) ProcessLockingRequest ¶
func (Keeper) UpdateForkParams ¶ added in v0.4.0
func (Keeper) UpdateRewardPool ¶
func (k Keeper) UpdateRewardPool(ctx context.Context, gas []*goattypes.GasRequest, grants []*goattypes.GrantRequest) error
func (Keeper) UpdateTokens ¶
func (k Keeper) UpdateTokens(ctx context.Context, weights []*goattypes.UpdateTokenWeightRequest, thresholds []*goattypes.UpdateTokenThresholdRequest) error
Source Files
Click to show internal directories.
Click to hide internal directories.