pool

Documentation

Index

• func ComputeKeyForAttesterSlashing(slashing *cltypes.AttesterSlashing) libcommon.Bytes96
• func ComputeKeyForProposerSlashing(slashing *cltypes.ProposerSlashing) libcommon.Bytes96
• type OperationPool
  • func NewOperationPool[K comparable, T any](maxOperationsPerBlock int, matricName string) *OperationPool[K, T]
  • func (o *OperationPool[K, T]) DeleteIfExist(k K) (removed bool)
  • func (o *OperationPool[K, T]) Has(k K) (hash bool)
  • func (o *OperationPool[K, T]) Insert(k K, operation T)
  • func (o *OperationPool[K, T]) Raw() []T
• type OperationsPool
  • func NewOperationsPool(beaconCfg *clparams.BeaconChainConfig) OperationsPool
  • func (o *OperationsPool) NotifyBlock(blk *cltypes.BeaconBlock)

Functions

func ComputeKeyForAttesterSlashing

func ComputeKeyForAttesterSlashing(slashing *cltypes.AttesterSlashing) libcommon.Bytes96

func ComputeKeyForProposerSlashing

func ComputeKeyForProposerSlashing(slashing *cltypes.ProposerSlashing) libcommon.Bytes96

Types

type OperationPool

type OperationPool[K comparable, T any] struct {
	// contains filtered or unexported fields
}

func NewOperationPool

func NewOperationPool[K comparable, T any](maxOperationsPerBlock int, matricName string) *OperationPool[K, T]

func (*OperationPool[K, T]) DeleteIfExist

func (o *OperationPool[K, T]) DeleteIfExist(k K) (removed bool)

func (*OperationPool[K, T]) Has

func (o *OperationPool[K, T]) Has(k K) (hash bool)

func (*OperationPool[K, T]) Insert

func (o *OperationPool[K, T]) Insert(k K, operation T)

func (*OperationPool[K, T]) Raw

func (o *OperationPool[K, T]) Raw() []T

type OperationsPool

type OperationsPool struct {
	AttestationsPool          *OperationPool[libcommon.Bytes96, *solid.Attestation]
	AttesterSlashingsPool     *OperationPool[libcommon.Bytes96, *cltypes.AttesterSlashing]
	ProposerSlashingsPool     *OperationPool[libcommon.Bytes96, *cltypes.ProposerSlashing]
	BLSToExecutionChangesPool *OperationPool[libcommon.Bytes96, *cltypes.SignedBLSToExecutionChange]
	VoluntaryExistsPool       *OperationPool[uint64, *cltypes.SignedVoluntaryExit]
}

OperationsPool is the collection of all gossip-collectable operations.

func NewOperationsPool

func NewOperationsPool(beaconCfg *clparams.BeaconChainConfig) OperationsPool

func (*OperationsPool) NotifyBlock

func (o *OperationsPool) NotifyBlock(blk *cltypes.BeaconBlock)