diff --git a/eth/fetcher/tx_fetcher_test.go b/eth/fetcher/tx_fetcher_test.go index 9c667dc2a0..416c27b34c 100644 --- a/eth/fetcher/tx_fetcher_test.go +++ b/eth/fetcher/tx_fetcher_test.go @@ -93,11 +93,11 @@ type txFetcherTest struct { // newTestBlobBuffer returns a BlobBuffer with no-op callbacks for tests that // don't exercise blob handling but still need a non-nil buffer. func newTestBlobBuffer() *blobpool.BlobBuffer { - return blobpool.NewBlobBuffer( - func(*types.Transaction) error { return nil }, - func(*blobpool.BlobTxForPool) error { return nil }, - func(string) {}, - ) + return blobpool.NewBlobBuffer(blobpool.BlobBufferFunctions{ + ValidateTx: func(*types.Transaction) error { return nil }, + AddToPool: func(*blobpool.BlobTxForPool) error { return nil }, + DropPeer: func(string) {}, + }) } // newTestTxFetcher creates a tx fetcher with noop callbacks, simulated clock, diff --git a/tests/fuzzers/txfetcher/txfetcher_fuzzer.go b/tests/fuzzers/txfetcher/txfetcher_fuzzer.go index 8f8660a515..09825d8c97 100644 --- a/tests/fuzzers/txfetcher/txfetcher_fuzzer.go +++ b/tests/fuzzers/txfetcher/txfetcher_fuzzer.go @@ -32,9 +32,9 @@ import ( ) var ( - peers []string - peerVersions map[string]uint - txs []*types.Transaction + peers []string + peerVersions map[string]uint + txs []*types.Transaction ) func init() { @@ -91,11 +91,12 @@ func fuzz(input []byte) int { }, func(string, []common.Hash) error { return nil }, nil, - blobpool.NewBlobBuffer( - func(*types.Transaction) error { return nil }, - func(*blobpool.BlobTxForPool) error { return nil }, - func(string) {}, - ), + + blobpool.NewBlobBuffer(blobpool.BlobBufferFunctions{ + ValidateTx: func(*types.Transaction) error { return nil }, + AddToPool: func(*blobpool.BlobTxForPool) error { return nil }, + DropPeer: func(string) {}, + }), clock, func() time.Time { nanoTime := int64(clock.Now())