utxpool

package

v0.11.0 Latest Latest Go to latest Published: Mar 24, 2026 License: MIT Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type BulkValidator interface {
	Validate(ctx context.Context)
}

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

Cleaner is responsible for validating transactions in the UTX pool and removing invalid ones.

func NewCleaner(state cleanerState, pool types.UtxPool, tm types.Time, scheme proto.Scheme) *Cleaner

func (a *Cleaner) Clean(ctx context.Context)

type NoOpValidator struct {
}

func (a NoOpValidator) Validate(_ types.UtxPoolValidatorState, _ proto.Transaction) error

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

func New(sizeLimit uint64, validator Validator, settings *settings.BlockchainSettings) *UtxImpl

func (a *UtxImpl) Add(st types.UtxPoolValidatorState, tx proto.Transaction) error

Add Must only be called inside state Map or MapUnsafe.

func (a *UtxImpl) AddWithBytes(st types.UtxPoolValidatorState, tx proto.Transaction, b []byte) error

AddWithBytes Must only be called inside state Map or MapUnsafe.

func (a *UtxImpl) AddWithBytesRaw(tx proto.Transaction, b []byte) error

func (a *UtxImpl) AllTransactions() []proto.Transaction

func (a *UtxImpl) Clean(ctx context.Context, shouldDrop func(tx proto.Transaction) bool) (int, int)

func (a *UtxImpl) CurSize() uint64

func (a *UtxImpl) Exists(tx proto.Transaction) bool

func (a *UtxImpl) ExistsByID(id []byte) bool

func (a *UtxImpl) Len() int

func (a *UtxImpl) Pop() *types.TransactionWithBytes

type Validator interface {
	Validate(st types.UtxPoolValidatorState, t proto.Transaction) error
}

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

func NewValidator(tm types.Time, obsolescence time.Duration) (*ValidatorImpl, error)

func (a *ValidatorImpl) Validate(st types.UtxPoolValidatorState, tx proto.Transaction) error