storage

Jul 2, 2024

Changes in this version

type Shares

+ Range func(txn basedb.Reader, fn func(*types.SSVShare) bool)

Feb 28, 2024

Changes in this version

type RecipientData

+ func (r *RecipientData) MarshalJSON() ([]byte, error)

+ func (r *RecipientData) UnmarshalJSON(input []byte) error

Nov 7, 2023

Changes in this version

+ type Nonce uint16

type Operators

+ DropOperators func() error

+ OperatorsExist func(r basedb.Reader, ids []spectypes.OperatorID) (bool, error)

type RecipientData

+ Nonce *Nonce

type Recipients

+ BumpNonce func(rw basedb.ReadWriter, owner common.Address) error

+ DropRecipients func() error

+ GetNextNonce func(r basedb.Reader, owner common.Address) (Nonce, error)

type Shares

+ Delete func(txn basedb.ReadWriter, pubKey []byte) error

+ Drop func() error

+ Get func(txn basedb.Reader, pubKey []byte) *types.SSVShare

+ List func(txn basedb.Reader, filters ...SharesFilter) []*types.SSVShare

+ Save func(txn basedb.ReadWriter, shares ...*types.SSVShare) error

+ UpdateValidatorMetadata func(pk string, metadata *beaconprotocol.ValidatorMetadata) error

+ type SharesFilter func(*types.SSVShare) bool

+ func ByActiveValidator() SharesFilter

+ func ByAttesting() SharesFilter

+ func ByNotLiquidated() SharesFilter

+ type SharesListFunc = func(filters ...SharesFilter) []*types.SSVShare

Mar 22, 2023

Changes in this version

+ func ByClusterID(clusterID []byte) func(share *types.SSVShare) bool

+ func ByOperatorID(operatorID spectypes.OperatorID) func(share *types.SSVShare) bool

+ func ByOperatorIDAndActive(operatorID spectypes.OperatorID) func(share *types.SSVShare) bool

+ func ByOperatorIDAndNotLiquidated(operatorID spectypes.OperatorID) func(share *types.SSVShare) bool

+ func NotLiquidated() func(share *types.SSVShare) bool

+ type FilteredSharesFunc = func(logger *zap.Logger, f func(share *types.SSVShare) bool) ([]*types.SSVShare, error)

type OperatorData

+ ID spectypes.OperatorID

+ type Operators interface

+ DeleteOperatorData func(id spectypes.OperatorID) error

+ GetOperatorData func(id spectypes.OperatorID) (*OperatorData, bool, error)

+ GetOperatorDataByPubKey func(logger *zap.Logger, operatorPubKey []byte) (*OperatorData, bool, error)

+ GetOperatorsPrefix func() []byte

+ ListOperators func(logger *zap.Logger, from uint64, to uint64) ([]OperatorData, error)

+ SaveOperatorData func(logger *zap.Logger, operatorData *OperatorData) (bool, error)

+ type RecipientData struct

+ FeeRecipient bellatrix.ExecutionAddress

+ Owner common.Address

+ type Recipients interface

+ DeleteRecipientData func(owner common.Address) error

+ GetRecipientData func(owner common.Address) (*RecipientData, bool, error)

+ GetRecipientDataMany func(logger *zap.Logger, owners []common.Address) (map[common.Address]bellatrix.ExecutionAddress, error)

+ GetRecipientsPrefix func() []byte

+ SaveRecipientData func(recipientData *RecipientData) (*RecipientData, error)

+ func NewRecipientsStorage(db basedb.IDb, prefix []byte) Recipients

+ type Shares interface

+ DeleteShare func(key []byte) error

+ GetAllShares func(logger *zap.Logger) ([]*types.SSVShare, error)

+ GetFilteredShares func(logger *zap.Logger, f func(share *types.SSVShare) bool) ([]*types.SSVShare, error)

+ GetShare func(key []byte) (*types.SSVShare, bool, error)

+ SaveShare func(logger *zap.Logger, share *types.SSVShare) error

+ SaveShareMany func(logger *zap.Logger, shares []*types.SSVShare) error

+ func NewSharesStorage(db basedb.IDb, prefix []byte) Shares

Aug 17, 2022

Changes in this version

type OperatorsCollection

+ DeleteOperatorData func(index uint64) error

Jun 15, 2022

Changes in this version

+ type GetOperatorData = func(index uint64) (*OperatorData, bool, error)

+ type OperatorData struct

+ Index uint64

+ Name string

+ OwnerAddress common.Address

+ PublicKey string

type OperatorsCollection

+ GetOperatorData func(index uint64) (*OperatorData, bool, error)

+ GetOperatorDataByPubKey func(operatorPubKey string) (*OperatorData, bool, error)

+ SaveOperatorData func(operatorData *OperatorData) error

Apr 7, 2022

Changes in this version

+ type OperatorInformation struct

+ Index int64

+ Name string

+ OwnerAddress common.Address

+ PublicKey string

+ type OperatorsCollection interface

+ GetOperatorInformation func(operatorPubKey string) (*OperatorInformation, bool, error)

+ GetOperatorsPrefix func() []byte

+ ListOperators func(from int64, to int64) ([]OperatorInformation, error)

+ SaveOperatorInformation func(operatorInformation *OperatorInformation) error

+ func NewOperatorsStorage(db basedb.IDb, logger *zap.Logger, prefix []byte) OperatorsCollection