diff --git a/cmd/reflector.go b/cmd/reflector.go index 017b9bf..d7b89aa 100644 --- a/cmd/reflector.go +++ b/cmd/reflector.go @@ -130,7 +130,7 @@ func reflectorCmd(cmd *cobra.Command, args []string) { } defer http3PeerServer.Shutdown() - httpServer := http.NewServer(underlyingStoreWithCaches, requestQueueSize) + httpServer := http.NewServer(store.WithSingleFlight("sf-http", underlyingStoreWithCaches), requestQueueSize) err = httpServer.Start(":" + strconv.Itoa(httpPeerPort)) if err != nil { log.Fatal(err)