projects
/
rapid-gossip-sync-server
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Allow custom logger types.
[rapid-gossip-sync-server]
/
src
/
persistence.rs
diff --git
a/src/persistence.rs
b/src/persistence.rs
index ac667330c6e0c445d0e7e82f81e2649ba12111db..22abf0216d8575692a1e3e7f9b7d4ce66844df66 100644
(file)
--- a/
src/persistence.rs
+++ b/
src/persistence.rs
@@
-3,22
+3,23
@@
use std::io::{BufWriter, Write};
use std::sync::Arc;
use std::time::{Duration, Instant};
use lightning::routing::gossip::NetworkGraph;
use std::sync::Arc;
use std::time::{Duration, Instant};
use lightning::routing::gossip::NetworkGraph;
+use lightning::util::logger::Logger;
use lightning::util::ser::Writeable;
use tokio::sync::mpsc;
use tokio_postgres::NoTls;
use lightning::util::ser::Writeable;
use tokio::sync::mpsc;
use tokio_postgres::NoTls;
-use crate::
{config, TestLogger}
;
+use crate::
config
;
use crate::types::GossipMessage;
const POSTGRES_INSERT_TIMEOUT: Duration = Duration::from_secs(15);
use crate::types::GossipMessage;
const POSTGRES_INSERT_TIMEOUT: Duration = Duration::from_secs(15);
-pub(crate) struct GossipPersister {
+pub(crate) struct GossipPersister
<L: Logger>
{
gossip_persistence_receiver: mpsc::Receiver<GossipMessage>,
gossip_persistence_receiver: mpsc::Receiver<GossipMessage>,
- network_graph: Arc<NetworkGraph<
TestLogger
>>,
+ network_graph: Arc<NetworkGraph<
Arc<L>
>>,
}
}
-impl
GossipPersister
{
- pub fn new(network_graph: Arc<NetworkGraph<
TestLogger
>>) -> (Self, mpsc::Sender<GossipMessage>) {
+impl
<L: Logger> GossipPersister<L>
{
+ pub fn new(network_graph: Arc<NetworkGraph<
Arc<L>
>>) -> (Self, mpsc::Sender<GossipMessage>) {
let (gossip_persistence_sender, gossip_persistence_receiver) =
mpsc::channel::<GossipMessage>(100);
(GossipPersister {
let (gossip_persistence_sender, gossip_persistence_receiver) =
mpsc::channel::<GossipMessage>(100);
(GossipPersister {