chore: remove IndexedGossipQueueAvgTime (#7125)

ChainSafe · Oct 4, 2024 · 0d1fd9c · 0d1fd9c
1 parent a19655d
commit 0d1fd9c
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 150 deletions.
diff --git a/packages/beacon-node/src/network/processor/gossipQueues/index.ts b/packages/beacon-node/src/network/processor/gossipQueues/index.ts
@@ -3,16 +3,8 @@ import {GossipType} from "../../gossip/interface.js";
 import {PendingGossipsubMessage} from "../types.js";
 import {getGossipAttestationIndex} from "../../../util/sszBytes.js";
 import {LinearGossipQueue} from "./linear.js";
-import {
-  DropType,
-  GossipQueue,
-  GossipQueueOpts,
-  QueueType,
-  isIndexedGossipQueueAvgTimeOpts,
-  isIndexedGossipQueueMinSizeOpts,
-} from "./types.js";
+import {DropType, GossipQueue, GossipQueueOpts, QueueType, isIndexedGossipQueueMinSizeOpts} from "./types.js";
 import {IndexedGossipQueueMinSize} from "./indexed.js";
-import {IndexedGossipQueueAvgTime} from "./indexedAvgTime.js";
 
 /**
  * In normal condition, the higher this value the more efficient the signature verification.
@@ -120,8 +112,6 @@ export function createGossipQueues(beaconAttestationBatchValidation = false): {
   return mapValues(gossipQueueOpts, (opts) => {
     if (isIndexedGossipQueueMinSizeOpts(opts)) {
       return new IndexedGossipQueueMinSize(opts);
-    } else if (isIndexedGossipQueueAvgTimeOpts(opts)) {
-      return new IndexedGossipQueueAvgTime(opts);
     } else {
       return new LinearGossipQueue<PendingGossipsubMessage>(opts);
     }

diff --git a/packages/beacon-node/src/network/processor/gossipQueues/indexedAvgTime.ts b/packages/beacon-node/src/network/processor/gossipQueues/indexedAvgTime.ts
diff --git a/packages/beacon-node/src/network/processor/gossipQueues/types.ts b/packages/beacon-node/src/network/processor/gossipQueues/types.ts
@@ -1,4 +1,4 @@
-export type GossipQueueOpts<T> = LinearGossipQueueOpts | IndexedGossipQueueOpts<T> | IndexedGossipQueueMinSizeOpts<T>;
+export type GossipQueueOpts<T> = LinearGossipQueueOpts | IndexedGossipQueueMinSizeOpts<T>;
 
 export type LinearGossipQueueOpts = {
   type: QueueType;
@@ -25,15 +25,6 @@ export function isIndexedGossipQueueMinSizeOpts<T>(opts: GossipQueueOpts<T>): op
   );
 }
 
-export function isIndexedGossipQueueAvgTimeOpts<T>(opts: GossipQueueOpts<T>): opts is IndexedGossipQueueOpts<T> {
-  const avgTimeOpts = opts as IndexedGossipQueueMinSizeOpts<T>;
-  return (
-    avgTimeOpts.indexFn !== undefined &&
-    avgTimeOpts.minChunkSize === undefined &&
-    avgTimeOpts.maxChunkSize === undefined
-  );
-}
-
 export interface GossipQueue<T> {
   length: number;
   keySize: number;