keeper

package
v3.0.0-rc0 Latest Latest
Warning

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

Go to latest
Published: Oct 16, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMsgServerImpl

func NewMsgServerImpl(keeper Keeper) types.MsgServer

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

func UInt64FromBytes

func UInt64FromBytes(s []byte) uint64

UInt64FromBytes create uint from binary big endian representation.

Types

type Hooks

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

Hooks is a wrapper struct around Keeper.

func (Hooks) AfterDelegationModified

func (h Hooks) AfterDelegationModified(_ sdk.Context, _ sdk.AccAddress, _ sdk.ValAddress) error

func (Hooks) AfterValidatorBeginUnbonding

func (h Hooks) AfterValidatorBeginUnbonding(ctx sdk.Context, _ sdk.ConsAddress, _ sdk.ValAddress) error

func (Hooks) AfterValidatorBonded

func (h Hooks) AfterValidatorBonded(_ sdk.Context, _ sdk.ConsAddress, _ sdk.ValAddress) error

func (Hooks) AfterValidatorCreated

func (h Hooks) AfterValidatorCreated(ctx sdk.Context, addr sdk.ValAddress) error

func (Hooks) AfterValidatorRemoved

func (h Hooks) AfterValidatorRemoved(_ sdk.Context, _ sdk.ConsAddress, _ sdk.ValAddress) error

func (Hooks) BeforeDelegationCreated

func (h Hooks) BeforeDelegationCreated(_ sdk.Context, _ sdk.AccAddress, _ sdk.ValAddress) error

func (Hooks) BeforeDelegationRemoved

func (h Hooks) BeforeDelegationRemoved(_ sdk.Context, _ sdk.AccAddress, _ sdk.ValAddress) error

func (Hooks) BeforeDelegationSharesModified

func (h Hooks) BeforeDelegationSharesModified(_ sdk.Context, _ sdk.AccAddress, _ sdk.ValAddress) error

func (Hooks) BeforeValidatorModified

func (h Hooks) BeforeValidatorModified(_ sdk.Context, _ sdk.ValAddress) error

func (Hooks) BeforeValidatorSlashed

func (h Hooks) BeforeValidatorSlashed(_ sdk.Context, _ sdk.ValAddress, _ sdk.Dec) error

type Keeper

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

func NewKeeper

func NewKeeper(cdc codec.BinaryCodec, storeKey storetypes.StoreKey, paramSpace paramtypes.Subspace, stakingKeeper StakingKeeper) *Keeper

func (Keeper) CheckEarliestAvailableAttestationNonce

func (k Keeper) CheckEarliestAvailableAttestationNonce(ctx sdk.Context) bool

CheckEarliestAvailableAttestationNonce returns true if the earliest available attestation nonce has been initialized in store, and false if not.

func (Keeper) CheckLatestAttestationNonce

func (k Keeper) CheckLatestAttestationNonce(ctx sdk.Context) bool

CheckLatestAttestationNonce returns true if the latest attestation request nonce is declared in the store and false if it has not been initialized.

func (Keeper) DeleteAttestation

func (k Keeper) DeleteAttestation(ctx sdk.Context, nonce uint64)

DeleteAttestation deletes an attestation from state. Will do nothing if the attestation doesn't exist in store.

func (Keeper) DeserializeValidatorIterator

func (k Keeper) DeserializeValidatorIterator(vals []byte) stakingtypes.ValAddresses

DeserializeValidatorIterator returns validators from the validator iterator. Adding here in Blobstream keeper as cdc is not available inside endblocker.

func (Keeper) EVMAddress

EVMAddress tries to find the associated EVM address for a given validator address. If none is found, an empty address is returned

func (Keeper) EarliestAttestationNonce

EarliestAttestationNonce queries the earliest attestation nonce.

func (Keeper) GetAttestationByNonce

func (k Keeper) GetAttestationByNonce(ctx sdk.Context, nonce uint64) (types.AttestationRequestI, bool, error)

GetAttestationByNonce returns an attestation request by nonce. Returns (nil, false, nil) if the attestation is not found.

func (Keeper) GetCurrentValset

func (k Keeper) GetCurrentValset(ctx sdk.Context) (types.Valset, error)

func (Keeper) GetDataCommitmentForHeight

func (k Keeper) GetDataCommitmentForHeight(ctx sdk.Context, height uint64) (types.DataCommitment, error)

GetDataCommitmentForHeight returns the attestation containing the provided height.

func (Keeper) GetDataCommitmentWindowParam

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

func (Keeper) GetEVMAddress

func (k Keeper) GetEVMAddress(ctx sdk.Context, valAddress sdk.ValAddress) (gethcommon.Address, bool)

func (Keeper) GetEarliestAvailableAttestationNonce

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

GetEarliestAvailableAttestationNonce returns the earliest available attestation nonce. The nonce is of the earliest available attestation in store that can be retrieved. Panics if the earliest available attestation nonce doesn't exist in store. This value is set on chain startup. However, it won't be written to store until height = 1. To check if this value exists in store, use the `CheckEarliestAvailableAttestationNonce` method.

func (Keeper) GetLatestAttestationNonce

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

GetLatestAttestationNonce returns the latest attestation request nonce. Panics if the latest attestation nonce doesn't exist in store. This value is set on chain startup. However, it won't be written to store until height = 1. To check if this value exists in store, use the `CheckLatestAttestationNonce` method.

func (Keeper) GetLatestDataCommitment

func (k Keeper) GetLatestDataCommitment(ctx sdk.Context) (types.DataCommitment, error)

GetLatestDataCommitment returns the latest data commitment.

func (Keeper) GetLatestUnBondingBlockHeight

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

GetLatestUnBondingBlockHeight returns the latest unbonding block height or zero if not set. This value is not saved or loaded at genesis. This value is reset to zero on chain upgrade.

func (Keeper) GetLatestValset

func (k Keeper) GetLatestValset(ctx sdk.Context) (*types.Valset, error)

GetLatestValset returns the latest validator set in store. This is different from the CurrentValset because this one has been saved and is therefore *the* latest valset saved in store. GetCurrentValset shows you what could be, if you chose to save it, this function shows you what is the latest valset that was saved. If not found, returns the current valset in case no valset exists in store after pruning. Otherwise panics.

func (Keeper) GetLatestValsetBeforeNonce

func (k Keeper) GetLatestValsetBeforeNonce(ctx sdk.Context, nonce uint64) (*types.Valset, error)

GetLatestValsetBeforeNonce returns the previous valset before the provided `nonce`. the `nonce` can be a valset, but this method will return the valset before it. If the provided nonce is 1, it will return an error, because, there is no valset before nonce 1.

func (Keeper) GetParams

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

GetParams returns the parameters from the store

func (Keeper) HasDataCommitmentInStore

func (k Keeper) HasDataCommitmentInStore(ctx sdk.Context) (bool, error)

HasDataCommitmentInStore returns true if the store has at least one data commitment.

func (Keeper) Hooks

func (k Keeper) Hooks() Hooks

Hooks Create new Blobstream hooks

func (Keeper) IsEVMAddressUnique

func (k Keeper) IsEVMAddressUnique(ctx sdk.Context, evmAddress gethcommon.Address) bool

IsEVMAddressUnique checks if the provided evm address is globally unique. This includes the defaults we set validators when they initially create a validator before registering

func (Keeper) LatestUnbondingHeight

LatestUnbondingHeight queries the latest unbonding height.

func (Keeper) LatestValsetRequestBeforeNonce

LatestValsetRequestBeforeNonce queries the latest valset request before nonce

func (Keeper) Logger

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

func (Keeper) NextDataCommitment

func (k Keeper) NextDataCommitment(ctx sdk.Context) (types.DataCommitment, error)

NextDataCommitment returns the next data commitment that can be written to state.

func (Keeper) RegisterEVMAddress

RegisterEVMAddress verifies that the validator exists on chain. It then stores the EVM address. If it already exists, it will simply overwrite the previous value

func (Keeper) SetAttestationRequest

func (k Keeper) SetAttestationRequest(ctx sdk.Context, at types.AttestationRequestI) error

SetAttestationRequest sets a new attestation request to the store to be signed by orchestrators afterwards.

func (Keeper) SetEVMAddress

func (k Keeper) SetEVMAddress(ctx sdk.Context, valAddress sdk.ValAddress, evmAddress gethcommon.Address)

func (Keeper) SetEarliestAvailableAttestationNonce

func (k Keeper) SetEarliestAvailableAttestationNonce(ctx sdk.Context, nonce uint64)

SetEarliestAvailableAttestationNonce sets the earliest available attestation nonce. The nonce is of the earliest available attestation in store that can be retrieved.

func (Keeper) SetLatestAttestationNonce

func (k Keeper) SetLatestAttestationNonce(ctx sdk.Context, nonce uint64)

SetLatestAttestationNonce sets the latest attestation request nonce, since it's expected that this value will only increase by one and it panics otherwise.

func (Keeper) SetLatestUnBondingBlockHeight

func (k Keeper) SetLatestUnBondingBlockHeight(ctx sdk.Context, unbondingBlockHeight uint64)

SetLatestUnBondingBlockHeight sets the latest unbonding block height. Note this value is not saved to state or loaded at genesis. This value is reset to zero on chain upgrade.

func (Keeper) SetParams

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

SetParams sets the parameters in the store

func (Keeper) StoreAttestation

func (k Keeper) StoreAttestation(ctx sdk.Context, at types.AttestationRequestI)

StoreAttestation saves the attestation in store. Should panic if overwriting existing one.

type StakingKeeper

type StakingKeeper interface {
	GetValidator(ctx sdk.Context, addr sdk.ValAddress) (validator stakingtypes.Validator, found bool)
	GetBondedValidatorsByPower(ctx sdk.Context) []stakingtypes.Validator
	GetLastValidatorPower(ctx sdk.Context, valAddr sdk.ValAddress) int64
}

StakingKeeper restricts the functionality of the bank keeper used in the blobstream keeper

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL