Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

keeper

package

Go to main page

Versions in this module

v6

v6.1.0

Dec 19, 2024

v6.0.0

Dec 18, 2024

Changes in this version

+ func AccountsBalancesInvariants(k *Keeper) sdk.Invariant

+ func AllowedOperatorsExistInvariant(k *Keeper) sdk.Invariant

+ func NewMsgServer(keeper *Keeper) types.MsgServer

+ func OperatorDelegationToOperatorDelegationResponse(ctx context.Context, k *Keeper, delegation types.Delegation) (types.DelegationResponse, error)

+ func OperatorsDelegatorsSharesInvariant(k *Keeper) sdk.Invariant

+ func OperatorsJoinedServicesExistInvariant(k *Keeper) sdk.Invariant

+ func PoolDelegationToPoolDelegationResponse(ctx context.Context, k *Keeper, delegation types.Delegation) (types.DelegationResponse, error)

+ func PoolsDelegatorsSharesInvariant(k *Keeper) sdk.Invariant

+ func PositiveOperatorsDelegationsInvariant(k *Keeper) sdk.Invariant

+ func PositivePoolsDelegationsInvariant(k *Keeper) sdk.Invariant

+ func PositiveServicesDelegationsInvariant(k *Keeper) sdk.Invariant

+ func RegisterInvariants(ir sdk.InvariantRegistry, k *Keeper)

+ func ServiceDelegationToServiceDelegationResponse(ctx context.Context, k *Keeper, delegation types.Delegation) (types.DelegationResponse, error)

+ func ServicesDelegatorsSharesInvariant(k *Keeper) sdk.Invariant

+ type Keeper struct

+ Schema collections.Schema

+ func NewKeeper(cdc codec.Codec, storeService corestoretypes.KVStoreService, ...) *Keeper

+ func (k *Keeper) AddOperatorToServiceAllowList(ctx context.Context, serviceID uint32, operatorID uint32) error

+ func (k *Keeper) AddOperatorTokensAndShares(ctx context.Context, operator operatorstypes.Operator, tokensToAdd sdk.Coins) (operatorOut operatorstypes.Operator, addedShares sdk.DecCoins, err error)

+ func (k *Keeper) AddPoolToServiceSecuringPools(ctx context.Context, serviceID uint32, poolID uint32) error

+ func (k *Keeper) AddPoolTokensAndShares(ctx context.Context, pool poolstypes.Pool, tokensToAdd sdk.Coin) (poolOut poolstypes.Pool, addedShares sdk.DecCoin, err error)

+ func (k *Keeper) AddServiceToOperatorJoinedServices(ctx context.Context, operatorID uint32, serviceID uint32) error

+ func (k *Keeper) AddServiceTokensAndShares(ctx context.Context, service servicestypes.Service, tokensToAdd sdk.Coins) (serviceOut servicestypes.Service, addedShares sdk.DecCoins, err error)

+ func (k *Keeper) AfterOperatorDelegationModified(ctx context.Context, operatorID uint32, delegator string) error

+ func (k *Keeper) AfterPoolDelegationModified(ctx context.Context, poolID uint32, delegator string) error

+ func (k *Keeper) AfterServiceDelegationModified(ctx context.Context, serviceID uint32, delegator string) error

+ func (k *Keeper) AfterUnbondingInitiated(ctx context.Context, unbondingDelegationID uint64) error

+ func (k *Keeper) AfterUserPreferencesModified(ctx context.Context, userAddress string, ...) error

+ func (k *Keeper) BeforeOperatorDelegationCreated(ctx context.Context, operatorID uint32, delegator string) error

+ func (k *Keeper) BeforeOperatorDelegationRemoved(ctx context.Context, operatorID uint32, delegator string) error

+ func (k *Keeper) BeforeOperatorDelegationSharesModified(ctx context.Context, operatorID uint32, delegator string) error

+ func (k *Keeper) BeforePoolDelegationCreated(ctx context.Context, poolID uint32, delegator string) error

+ func (k *Keeper) BeforePoolDelegationRemoved(ctx context.Context, poolID uint32, delegator string) error

+ func (k *Keeper) BeforePoolDelegationSharesModified(ctx context.Context, poolID uint32, delegator string) error

+ func (k *Keeper) BeforeServiceDelegationCreated(ctx context.Context, serviceID uint32, delegator string) error

+ func (k *Keeper) BeforeServiceDelegationRemoved(ctx context.Context, serviceID uint32, delegator string) error

+ func (k *Keeper) BeforeServiceDelegationSharesModified(ctx context.Context, serviceID uint32, delegator string) error

+ func (k *Keeper) CanOperatorValidateService(ctx context.Context, serviceID uint32, operatorID uint32) (bool, error)

+ func (k *Keeper) CompleteMatureUnbondingDelegations(ctx sdk.Context) error

+ func (k *Keeper) CompleteUnbonding(ctx context.Context, data types.DTData) (sdk.Coins, error)

+ func (k *Keeper) DelegateToOperator(ctx context.Context, operatorID uint32, amount sdk.Coins, delegator string) (sdk.DecCoins, error)

+ func (k *Keeper) DelegateToPool(ctx context.Context, amount sdk.Coin, delegator string) (sdk.DecCoins, error)

+ func (k *Keeper) DelegateToService(ctx context.Context, serviceID uint32, amount sdk.Coins, delegator string) (sdk.DecCoins, error)

+ func (k *Keeper) DeleteUnbondingIndex(ctx context.Context, id uint64) error

+ func (k *Keeper) DequeueAllMatureUBDQueue(ctx context.Context, currTime time.Time) (matureUnbonds []types.DTData, err error)

+ func (k *Keeper) ExportGenesis(ctx sdk.Context) *types.GenesisState

+ func (k *Keeper) GetAllDelegations(ctx context.Context) ([]types.Delegation, error)

+ func (k *Keeper) GetAllOperatorDelegations(ctx context.Context) ([]types.Delegation, error)

+ func (k *Keeper) GetAllOperatorUnbondingDelegations(ctx context.Context) ([]types.UnbondingDelegation, error)

+ func (k *Keeper) GetAllOperatorsJoinedServices(ctx context.Context) ([]types.OperatorJoinedServices, error)

+ func (k *Keeper) GetAllPoolDelegations(ctx context.Context) ([]types.Delegation, error)

+ func (k *Keeper) GetAllPoolUnbondingDelegations(ctx context.Context) ([]types.UnbondingDelegation, error)

+ func (k *Keeper) GetAllServiceAllowedOperators(ctx context.Context, serviceID uint32) ([]uint32, error)

+ func (k *Keeper) GetAllServiceDelegations(ctx context.Context) ([]types.Delegation, error)

+ func (k *Keeper) GetAllServiceSecuringPools(ctx context.Context, serviceID uint32) ([]uint32, error)

+ func (k *Keeper) GetAllServiceUnbondingDelegations(ctx context.Context) ([]types.UnbondingDelegation, error)

+ func (k *Keeper) GetAllServicesAllowedOperators(ctx context.Context) ([]types.ServiceAllowedOperators, error)

+ func (k *Keeper) GetAllServicesSecuringPools(ctx context.Context) ([]types.ServiceSecuringPools, error)

+ func (k *Keeper) GetAllUnbondingDelegations(ctx context.Context) ([]types.UnbondingDelegation, error)

+ func (k *Keeper) GetAllUserOperatorUnbondingDelegations(ctx context.Context, userAddress string) []types.UnbondingDelegation

+ func (k *Keeper) GetAllUserPoolUnbondingDelegations(ctx context.Context, userAddress string) []types.UnbondingDelegation

+ func (k *Keeper) GetAllUserRestakedCoins(ctx context.Context, userAddress string) (sdk.DecCoins, error)

+ func (k *Keeper) GetAllUserServiceUnbondingDelegations(ctx context.Context, userAddress string) []types.UnbondingDelegation

+ func (k *Keeper) GetAllUserUnbondingDelegations(ctx context.Context, userAddress string) []types.UnbondingDelegation

+ func (k *Keeper) GetAssetAndPrice(ctx context.Context, denom string) (assetstypes.Asset, math.LegacyDec, error)

+ func (k *Keeper) GetCoinValue(ctx context.Context, coin sdk.Coin) (math.LegacyDec, error)

+ func (k *Keeper) GetCoinsValue(ctx context.Context, coins sdk.Coins) (math.LegacyDec, error)

+ func (k *Keeper) GetDelegationForTarget(ctx context.Context, target types.DelegationTarget, delegator string) (types.Delegation, bool, error)

+ func (k *Keeper) GetDelegationTargetFromDelegation(ctx context.Context, delegation types.Delegation) (types.DelegationTarget, error)

+ func (k *Keeper) GetOperatorDelegation(ctx context.Context, operatorID uint32, userAddress string) (types.Delegation, bool, error)

+ func (k *Keeper) GetOperatorUnbondingDelegation(ctx context.Context, operatorID uint32, delegatorAddress string) (types.UnbondingDelegation, bool, error)

+ func (k *Keeper) GetParams(ctx context.Context) (p types.Params, err error)

+ func (k *Keeper) GetPoolDelegation(ctx context.Context, poolID uint32, userAddress string) (types.Delegation, bool, error)

+ func (k *Keeper) GetPoolUnbondingDelegation(ctx context.Context, poolID uint32, delegator string) (types.UnbondingDelegation, bool, error)

+ func (k *Keeper) GetRestakableDenoms(ctx context.Context) ([]string, error)

+ func (k *Keeper) GetServiceDelegation(ctx context.Context, serviceID uint32, userAddress string) (types.Delegation, bool, error)

+ func (k *Keeper) GetServiceUnbondingDelegation(ctx context.Context, serviceID uint32, delegator string) (types.UnbondingDelegation, bool, error)

+ func (k *Keeper) GetTotalRestakedAssets(ctx context.Context) (sdk.Coins, error)

+ func (k *Keeper) GetUBDQueueTimeSlice(ctx context.Context, timestamp time.Time) (dvPairs []types.DTData, err error)

+ func (k *Keeper) GetUnbondingDelegation(ctx context.Context, delegatorAddress string, ubdType types.DelegationType, ...) (types.UnbondingDelegation, bool, error)

+ func (k *Keeper) GetUserPreferences(ctx context.Context, userAddress string) (types.UserPreferences, error)

+ func (k *Keeper) GetUserPreferencesEntries(ctx context.Context) ([]types.UserPreferencesEntry, error)

+ func (k *Keeper) GetUserTrustedServicesIDs(ctx context.Context, userAddress string) ([]uint32, error)

+ func (k *Keeper) HasOperatorJoinedService(ctx context.Context, operatorID uint32, serviceID uint32) (bool, error)

+ func (k *Keeper) IncrementUnbondingID(ctx context.Context) (unbondingID uint64, err error)

+ func (k *Keeper) InitGenesis(ctx sdk.Context, data *types.GenesisState) error

+ func (k *Keeper) InsertUBDQueue(ctx context.Context, ubd types.UnbondingDelegation, completionTime time.Time) error

+ func (k *Keeper) IsDenomRestakable(ctx context.Context, denom string) (bool, error)

+ func (k *Keeper) IsOperatorInServiceAllowList(ctx context.Context, serviceID uint32, operatorID uint32) (bool, error)

+ func (k *Keeper) IsPoolInServiceSecuringPools(ctx context.Context, serviceID uint32, poolID uint32) (bool, error)

+ func (k *Keeper) IsServiceOperatorsAllowListConfigured(ctx context.Context, serviceID uint32) (bool, error)

+ func (k *Keeper) IsServiceSecuredByPool(ctx context.Context, serviceID uint32, poolID uint32) (bool, error)

+ func (k *Keeper) IsServiceSecuringPoolsConfigured(ctx context.Context, serviceID uint32) (bool, error)

+ func (k *Keeper) IterateAllOperatorDelegations(ctx context.Context, cb func(del types.Delegation) (stop bool, err error)) error

+ func (k *Keeper) IterateAllOperatorsJoinedServices(ctx context.Context, ...) error

+ func (k *Keeper) IterateAllPoolDelegations(ctx context.Context, cb func(del types.Delegation) (stop bool, err error)) error

+ func (k *Keeper) IterateAllServiceDelegations(ctx context.Context, cb func(del types.Delegation) (stop bool, err error)) error

+ func (k *Keeper) IterateAllServicesAllowedOperators(ctx context.Context, ...) error

+ func (k *Keeper) IterateServiceDelegations(ctx context.Context, serviceID uint32, ...) error

+ func (k *Keeper) IterateUserDelegations(ctx context.Context, userAddress string, ...) error

+ func (k *Keeper) IterateUserOperatorDelegations(ctx context.Context, userAddress string, ...) error

+ func (k *Keeper) IterateUserPoolDelegations(ctx context.Context, userAddress string, ...) error

+ func (k *Keeper) IterateUserServiceDelegations(ctx context.Context, userAddress string, ...) error

+ func (k *Keeper) Logger(ctx context.Context) log.Logger

+ func (k *Keeper) OperatorsHooks() operatorstypes.OperatorsHooks

+ func (k *Keeper) PerformDelegation(ctx context.Context, data types.DelegationData) (sdk.DecCoins, error)

+ func (k *Keeper) PerformUndelegation(ctx context.Context, data types.UndelegationData) (time.Time, error)

+ func (k *Keeper) RemoveDelegation(ctx context.Context, delegation types.Delegation) error

+ func (k *Keeper) RemoveOperatorDelegation(ctx context.Context, delegation types.Delegation) error

+ func (k *Keeper) RemoveOperatorFromServiceAllowList(ctx context.Context, serviceID uint32, operatorID uint32) error

+ func (k *Keeper) RemovePoolDelegation(ctx context.Context, delegation types.Delegation) error

+ func (k *Keeper) RemovePoolFromServiceSecuringPools(ctx context.Context, serviceID uint32, poolID uint32) error

+ func (k *Keeper) RemoveServiceDelegation(ctx context.Context, delegation types.Delegation) error

+ func (k *Keeper) RemoveServiceFromOperatorJoinedServices(ctx context.Context, operatorID uint32, serviceID uint32) error

+ func (k *Keeper) RemoveTargetTokensAndShares(ctx context.Context, data types.UndelegationData) (sdk.Coins, error)

+ func (k *Keeper) RemoveUnbondingDelegation(ctx context.Context, ubd types.UnbondingDelegation) error

+ func (k *Keeper) RestakingCap(ctx context.Context) (math.LegacyDec, error)

+ func (k *Keeper) ServiceAllowedOperatorsIterator(ctx context.Context, serviceID uint32) (collections.KeySetIterator[collections.Pair[uint32, uint32]], error)

+ func (k *Keeper) ServiceSecuringPoolsIterator(ctx context.Context, serviceID uint32) (collections.KeySetIterator[collections.Pair[uint32, uint32]], error)

+ func (k *Keeper) ServicesHooks() servicestypes.ServicesHooks

+ func (k *Keeper) SetDelegation(ctx context.Context, delegation types.Delegation) error

+ func (k *Keeper) SetHooks(rs types.RestakingHooks) *Keeper

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

+ func (k *Keeper) SetRestakableDenoms(ctx context.Context, denoms []string) error

+ func (k *Keeper) SetRestakeRestriction(restriction types.RestakeRestrictionFn)

+ func (k *Keeper) SetUBDQueueTimeSlice(ctx context.Context, timestamp time.Time, keys []types.DTData) error

+ func (k *Keeper) SetUnbondingDelegation(ctx context.Context, ud types.UnbondingDelegation) ([]byte, error)

+ func (k *Keeper) SetUnbondingDelegationByUnbondingID(ctx context.Context, ubd types.UnbondingDelegation, ubdKey []byte, id uint64) error

+ func (k *Keeper) SetUnbondingDelegationEntry(ctx context.Context, data types.UndelegationData, creationHeight int64, ...) (types.UnbondingDelegation, error)

+ func (k *Keeper) SetUserPreferences(ctx context.Context, userAddress string, preferences types.UserPreferences) error

+ func (k *Keeper) UBDQueueIterator(ctx context.Context, endTime time.Time) (storetypes.Iterator, error)

+ func (k *Keeper) Unbond(ctx context.Context, data types.UndelegationData) (amount sdk.Coins, err error)

+ func (k *Keeper) UnbondRestakedAssets(ctx context.Context, user sdk.AccAddress, amount sdk.Coins) (time.Time, error)

+ func (k *Keeper) UnbondingTime(ctx context.Context) (time.Duration, error)

+ func (k *Keeper) UndelegateFromOperator(ctx context.Context, operatorID uint32, amount sdk.Coins, delegator string) (time.Time, error)

+ func (k *Keeper) UndelegateFromPool(ctx context.Context, amount sdk.Coin, delegator string) (time.Time, error)

+ func (k *Keeper) UndelegateFromService(ctx context.Context, serviceID uint32, amount sdk.Coins, delegator string) (time.Time, error)

+ func (k *Keeper) ValidateRestake(ctx context.Context, restakerAddress string, restakedAmount sdk.Coins, ...) error

+ func (k *Keeper) ValidateUnbondAmount(ctx context.Context, delAddr string, target types.DelegationTarget, ...) (shares sdk.DecCoins, err error)

+ type OperatorsHooks struct

+ func (o *OperatorsHooks) AfterOperatorInactivatingCompleted(ctx context.Context, operatorID uint32) error

+ func (o *OperatorsHooks) AfterOperatorInactivatingStarted(ctx context.Context, operatorID uint32) error

+ func (o *OperatorsHooks) AfterOperatorReactivated(ctx context.Context, operatorID uint32) error

+ func (o *OperatorsHooks) AfterOperatorRegistered(ctx context.Context, operatorID uint32) error

+ func (o *OperatorsHooks) BeforeOperatorDeleted(ctx context.Context, operatorID uint32) error

+ type Querier struct

+ func NewQuerier(keeper *Keeper) Querier

+ func (k Querier) DelegatorOperator(ctx context.Context, req *types.QueryDelegatorOperatorRequest) (*types.QueryDelegatorOperatorResponse, error)

+ func (k Querier) DelegatorOperatorDelegations(ctx context.Context, req *types.QueryDelegatorOperatorDelegationsRequest) (*types.QueryDelegatorOperatorDelegationsResponse, error)

+ func (k Querier) DelegatorOperatorUnbondingDelegations(ctx context.Context, ...) (*types.QueryDelegatorOperatorUnbondingDelegationsResponse, error)

+ func (k Querier) DelegatorOperators(ctx context.Context, req *types.QueryDelegatorOperatorsRequest) (*types.QueryDelegatorOperatorsResponse, error)

+ func (k Querier) DelegatorPool(ctx context.Context, req *types.QueryDelegatorPoolRequest) (*types.QueryDelegatorPoolResponse, error)

+ func (k Querier) DelegatorPoolDelegations(ctx context.Context, req *types.QueryDelegatorPoolDelegationsRequest) (*types.QueryDelegatorPoolDelegationsResponse, error)

+ func (k Querier) DelegatorPoolUnbondingDelegations(ctx context.Context, req *types.QueryDelegatorPoolUnbondingDelegationsRequest) (*types.QueryDelegatorPoolUnbondingDelegationsResponse, error)

+ func (k Querier) DelegatorPools(ctx context.Context, req *types.QueryDelegatorPoolsRequest) (*types.QueryDelegatorPoolsResponse, error)

+ func (k Querier) DelegatorService(ctx context.Context, req *types.QueryDelegatorServiceRequest) (*types.QueryDelegatorServiceResponse, error)

+ func (k Querier) DelegatorServiceDelegations(ctx context.Context, req *types.QueryDelegatorServiceDelegationsRequest) (*types.QueryDelegatorServiceDelegationsResponse, error)

+ func (k Querier) DelegatorServiceUnbondingDelegations(ctx context.Context, ...) (*types.QueryDelegatorServiceUnbondingDelegationsResponse, error)

+ func (k Querier) DelegatorServices(ctx context.Context, req *types.QueryDelegatorServicesRequest) (*types.QueryDelegatorServicesResponse, error)

+ func (k Querier) OperatorDelegation(ctx context.Context, req *types.QueryOperatorDelegationRequest) (*types.QueryOperatorDelegationResponse, error)

+ func (k Querier) OperatorDelegations(ctx context.Context, req *types.QueryOperatorDelegationsRequest) (*types.QueryOperatorDelegationsResponse, error)

+ func (k Querier) OperatorJoinedServices(ctx context.Context, req *types.QueryOperatorJoinedServicesRequest) (*types.QueryOperatorJoinedServicesResponse, error)

+ func (k Querier) OperatorUnbondingDelegation(ctx context.Context, req *types.QueryOperatorUnbondingDelegationRequest) (*types.QueryOperatorUnbondingDelegationResponse, error)

+ func (k Querier) OperatorUnbondingDelegations(ctx context.Context, req *types.QueryOperatorUnbondingDelegationsRequest) (*types.QueryOperatorUnbondingDelegationsResponse, error)

+ func (k Querier) Params(ctx context.Context, _ *types.QueryParamsRequest) (*types.QueryParamsResponse, error)

+ func (k Querier) PoolDelegation(ctx context.Context, req *types.QueryPoolDelegationRequest) (*types.QueryPoolDelegationResponse, error)

+ func (k Querier) PoolDelegations(ctx context.Context, req *types.QueryPoolDelegationsRequest) (*types.QueryPoolDelegationsResponse, error)

+ func (k Querier) PoolUnbondingDelegation(ctx context.Context, req *types.QueryPoolUnbondingDelegationRequest) (*types.QueryPoolUnbondingDelegationResponse, error)

+ func (k Querier) PoolUnbondingDelegations(ctx context.Context, req *types.QueryPoolUnbondingDelegationsRequest) (*types.QueryPoolUnbondingDelegationsResponse, error)

+ func (k Querier) ServiceAllowedOperators(ctx context.Context, req *types.QueryServiceAllowedOperatorsRequest) (*types.QueryServiceAllowedOperatorsResponse, error)

+ func (k Querier) ServiceDelegation(ctx context.Context, req *types.QueryServiceDelegationRequest) (*types.QueryServiceDelegationResponse, error)

+ func (k Querier) ServiceDelegations(ctx context.Context, req *types.QueryServiceDelegationsRequest) (*types.QueryServiceDelegationsResponse, error)

+ func (k Querier) ServiceOperators(ctx context.Context, req *types.QueryServiceOperatorsRequest) (*types.QueryServiceOperatorsResponse, error)

+ func (k Querier) ServiceSecuringPools(ctx context.Context, req *types.QueryServiceSecuringPoolsRequest) (*types.QueryServiceSecuringPoolsResponse, error)

+ func (k Querier) ServiceUnbondingDelegation(ctx context.Context, req *types.QueryServiceUnbondingDelegationRequest) (*types.QueryServiceUnbondingDelegationResponse, error)

+ func (k Querier) ServiceUnbondingDelegations(ctx context.Context, req *types.QueryServiceUnbondingDelegationsRequest) (*types.QueryServiceUnbondingDelegationsResponse, error)

+ func (k Querier) UserPreferences(ctx context.Context, req *types.QueryUserPreferencesRequest) (*types.QueryUserPreferencesResponse, error)

+ type ServicesHooks struct

+ func (h *ServicesHooks) AfterServiceAccreditationModified(ctx context.Context, serviceID uint32) error

+ func (h *ServicesHooks) AfterServiceActivated(ctx context.Context, serviceID uint32) error

+ func (h *ServicesHooks) AfterServiceCreated(ctx context.Context, serviceID uint32) error

+ func (h *ServicesHooks) AfterServiceDeactivated(ctx context.Context, serviceID uint32) error

+ func (h *ServicesHooks) BeforeServiceDeleted(ctx context.Context, serviceID uint32) error

v6.0.0-ceers

Dec 18, 2024

Other modules containing this package

github.com/milkyway-labs/milkyway

github.com/milkyway-labs/milkyway/v2

github.com/milkyway-labs/milkyway/v3

github.com/milkyway-labs/milkyway/v4

github.com/milkyway-labs/milkyway/v5

github.com/milkyway-labs/milkyway/v7