Fix examples build/format

blockworks-foundation · Mar 26, 2024 · 08f0ba5 · 08f0ba5
1 parent a52c31e
commit 08f0ba5
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 14 deletions.
diff --git a/connector/examples/combined_example_consumer.rs b/connector/examples/combined_example_consumer.rs
@@ -1,7 +1,7 @@
 #![allow(unused_variables)]
 
 use mango_feeds_connector::{
-    grpc_plugin_source, metrics, AccountWrite, EntityFilter, FilterConfig, GrpcSourceConfig,
+    grpc_plugin_source, metrics, EntityFilter, FeedWrite, FilterConfig, GrpcSourceConfig,
     MetricsConfig, SlotUpdate, SnapshotSourceConfig, SourceConfig,
 };
 use std::sync::atomic::AtomicBool;
@@ -52,7 +52,7 @@ async fn main() -> anyhow::Result<()> {
     };
 
     let (account_write_queue_sender, account_write_queue_receiver) =
-        async_channel::unbounded::<AccountWrite>();
+        async_channel::unbounded::<FeedWrite>();
 
     let (slot_queue_sender, slot_queue_receiver) = async_channel::unbounded::<SlotUpdate>();
 
@@ -66,7 +66,7 @@ async fn main() -> anyhow::Result<()> {
     tokio::spawn(async move {
         loop {
             let next = account_write_queue_receiver.recv().await.unwrap();
-            println!("got account write: {:?}", next);
+            println!("got feed write: {:?}", next);
         }
     });
 
@@ -95,8 +95,8 @@ async fn main() -> anyhow::Result<()> {
     let filter_config = filter_config1;
 
     grpc_plugin_source::process_events(
-        &config,
-        &filter_config,
+        config,
+        filter_config,
         account_write_queue_sender,
         slot_queue_sender,
         metrics_tx.clone(),

diff --git a/connector/examples/geyser_example_consumer.rs b/connector/examples/geyser_example_consumer.rs
@@ -1,7 +1,7 @@
 #![allow(unused_variables)]
 
 use mango_feeds_connector::{
-    grpc_plugin_source, metrics, AccountWrite, EntityFilter, FilterConfig, GrpcSourceConfig,
+    grpc_plugin_source, metrics, EntityFilter, FeedWrite, FilterConfig, GrpcSourceConfig,
     MetricsConfig, SlotUpdate, SnapshotSourceConfig, SourceConfig,
 };
 use std::sync::atomic::AtomicBool;
@@ -52,7 +52,7 @@ async fn main() -> anyhow::Result<()> {
     };
 
     let (account_write_queue_sender, account_write_queue_receiver) =
-        async_channel::unbounded::<AccountWrite>();
+        async_channel::unbounded::<FeedWrite>();
 
     let (slot_queue_sender, slot_queue_receiver) = async_channel::unbounded::<SlotUpdate>();
 
@@ -66,7 +66,7 @@ async fn main() -> anyhow::Result<()> {
     tokio::spawn(async move {
         loop {
             let next = account_write_queue_receiver.recv().await.unwrap();
-            println!("got account write: {:?}", next);
+            println!("got feed write: {:?}", next);
         }
     });
 
@@ -95,8 +95,8 @@ async fn main() -> anyhow::Result<()> {
     let filter_config = filter_config1;
 
     grpc_plugin_source::process_events(
-        &config,
-        &filter_config,
+        config,
+        filter_config,
         account_write_queue_sender,
         slot_queue_sender,
         metrics_tx.clone(),

diff --git a/connector/examples/websocket_example_consumer.rs b/connector/examples/websocket_example_consumer.rs
@@ -1,7 +1,7 @@
 #![allow(unused_variables)]
 
 use mango_feeds_connector::{
-    websocket_source, AccountWrite, EntityFilter, FilterConfig, SlotUpdate, SnapshotSourceConfig,
+    websocket_source, EntityFilter, FeedWrite, FilterConfig, SlotUpdate, SnapshotSourceConfig,
     SourceConfig,
 };
 
@@ -58,7 +58,7 @@ async fn main() -> anyhow::Result<()> {
     let filter_config = filter_config1;
 
     let (account_write_queue_sender, account_write_queue_receiver) =
-        async_channel::unbounded::<AccountWrite>();
+        async_channel::unbounded::<FeedWrite>();
 
     let (slot_queue_sender, slot_queue_receiver) = async_channel::unbounded::<SlotUpdate>();
 
@@ -77,8 +77,8 @@ async fn main() -> anyhow::Result<()> {
     });
 
     websocket_source::process_events(
-        &config,
-        &filter_config,
+        config,
+        filter_config,
         account_write_queue_sender,
         slot_queue_sender,
     )