Reduce mem usage on message time cache

h0n9 · Jul 18, 2023 · 9fdc76c · 9fdc76c
1 parent 7f75302
commit 9fdc76c
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/relayer/relayer.go b/relayer/relayer.go
@@ -126,7 +126,16 @@ func NewRelayer(ctx context.Context, logger *zerolog.Logger, seed []byte, addrs
 	subLogger.Info().Msgf("listening address %v", h.Addrs())
 	subLogger.Info().Msgf("libp2p peer ID %s", h.ID())
 
-	ps, err := pubsub.NewGossipSub(ctx, h)
+	// TODO: make this options customizable with external config file
+	ps, err := pubsub.NewGossipSub(
+		ctx,
+		h,
+		// msgs routing internally don't need to be signed and verified
+		pubsub.WithMessageSigning(false),
+		// msgs are removed from time cache after 3 seconds since first seen
+		pubsub.WithSeenMessagesTTL(3*time.Second),
+		pubsub.WithSeenMessagesStrategy(timecache.Strategy_FirstSeen),
+	)
 	if err != nil {
 		return nil, err
 	}