rust log from env for examples

examples/block-finality-alerts/README.md

@@ -19,6 +19,7 @@ Create a `.env` file in the root of your project and set the following environme
 
 ```env
 RPC_WS_URL=...
+RUST_LOG=...
 ```
 
 This `RPC_WS_URL` should point to the RPC Websocket endpoint you want to use for Solana block subscribing.

examples/block-finality-alerts/src/main.rs

@@ -12,8 +12,8 @@ use {
 
 #[tokio::main]
 pub async fn main() -> CarbonResult<()> {
-    env_logger::init();
     dotenv::dotenv().ok();
+    env_logger::init();
 
     let filters = Filters::new(
         RpcBlockSubscribeFilter::All,

examples/jupiter-swap-alerts/README.md

@@ -20,6 +20,7 @@ Create a `.env` file in the root of your project and set the following environme
 ```env
 GEYSER_URL=...
 X_TOKEN=...
+RUST_LOG=...
 ```
 
 - `GEYSER_URL` should point to the Yellowstone Geyser RPC URL you want to use for Solana transaction crawling.
@@ -45,4 +46,4 @@ This will start the Geyser client and the pipeline will begin processing transac
 
 ## Metrics
 
-The example doesn't include a metrics implementation by default. However, you can easily integrate custom metrics or logging by passing your own metrics implementation to the pipeline.
+The example doesn't include a metrics implementation by default. However, you can easily integrate custom metrics or logging by passing your own metrics implementation to the pipeline.

examples/jupiter-swap-alerts/src/main.rs

@@ -23,8 +23,8 @@ use {
 
 #[tokio::main]
 pub async fn main() -> CarbonResult<()> {
-    env_logger::init();
     dotenv::dotenv().ok();
+    env_logger::init();
 
     // NOTE: Workaround, that solving issue https://github.com/rustls/rustls/issues/1877
     rustls::crypto::aws_lc_rs::default_provider()

examples/kamino-alerts/README.md

@@ -20,6 +20,7 @@ Create a `.env` file in the root of your project and set the following environme
 ```env
 GEYSER_URL=...
 X_TOKEN=...
+RUST_LOG=...
 ```
 
 - `GEYSER_URL` should point to the Yellowstone Geyser RPC URL you want to use for Solana transaction crawling.

examples/kamino-alerts/src/main.rs

@@ -25,8 +25,8 @@ use {
 
 #[tokio::main]
 pub async fn main() -> CarbonResult<()> {
-    env_logger::init();
     dotenv::dotenv().ok();
+    env_logger::init();
 
     let mut account_filters: HashMap<String, SubscribeRequestFilterAccounts> = HashMap::new();
     account_filters.insert(

examples/meteora-activities/README.md

@@ -19,6 +19,7 @@ Create a `.env` file in the root of your project and set the following environme
 
 ```env
 RPC_URL=...
+RUST_LOG=...
 ```
 
 This `RPC_URL` should point to the RPC endpoint you want to use for Solana transaction crawling.

examples/meteora-activities/src/main.rs

@@ -17,8 +17,8 @@ use {
 
 #[tokio::main]
 pub async fn main() -> CarbonResult<()> {
-    env_logger::init();
     dotenv::dotenv().ok();
+    env_logger::init();
 
     let filters = Filters::new(None, None, None);
 

examples/moonshot-alerts/README.md

@@ -19,6 +19,7 @@ Create a `.env` file in the root of your project and set the following environme
 
 ```env
 RPC_WS_URL=...
+RUST_LOG=...
 ```
 
 This `RPC_WS_URL` should point to the RPC Websocket endpoint you want to use for Solana block subscribing.

examples/moonshot-alerts/src/main.rs

@@ -22,8 +22,8 @@ use {
 
 #[tokio::main]
 pub async fn main() -> CarbonResult<()> {
-    env_logger::init();
     dotenv::dotenv().ok();
+    env_logger::init();
 
     let filters = Filters::new(
         RpcBlockSubscribeFilter::MentionsAccountOrProgram(MOONSHOT_PROGRAM_ID.to_string()),

examples/openbook-v2-alerts/README.md

@@ -19,6 +19,7 @@ Create a `.env` file in the root of your project and set the following environme
 
 ```env
 RPC_WS_URL=...
+RUST_LOG=...
 ```
 
 This `RPC_WS_URL` should point to the RPC Websocket endpoint you want to use for Solana block subscribing.

examples/openbook-v2-alerts/src/main.rs

@@ -18,8 +18,8 @@ use {
 
 #[tokio::main]
 pub async fn main() -> CarbonResult<()> {
-    env_logger::init();
     dotenv::dotenv().ok();
+    env_logger::init();
 
     let filters = Filters::new(
         RpcBlockSubscribeFilter::MentionsAccountOrProgram(OPENBOOK_V2_PROGRAM_ID.to_string()),

examples/raydium-alerts/README.md

@@ -20,6 +20,7 @@ Create a `.env` file in the root of your project and set the following environme
 ```env
 GEYSER_URL=...
 X_TOKEN=...
+RUST_LOG=...
 ```
 
 - `GEYSER_URL` should point to the Yellowstone Geyser RPC URL you want to use for Solana transaction crawling.
@@ -45,4 +46,4 @@ This will start the Geyser client and the pipeline will begin processing transac
 
 ## Metrics
 
-The example doesn't include a metrics implementation by default. However, you can easily integrate custom metrics or logging by passing your own metrics implementation to the pipeline.
+The example doesn't include a metrics implementation by default. However, you can easily integrate custom metrics or logging by passing your own metrics implementation to the pipeline.

examples/raydium-alerts/src/main.rs

@@ -30,8 +30,8 @@ use {
 
 #[tokio::main]
 pub async fn main() -> CarbonResult<()> {
-    env_logger::init();
     dotenv::dotenv().ok();
+    env_logger::init();
 
     // NOTE: Workaround, that solving issue https://github.com/rustls/rustls/issues/1877
     rustls::crypto::aws_lc_rs::default_provider()

examples/raydium-clmm-alerts/README.md

@@ -19,6 +19,7 @@ Create a `.env` file in the root of your project and set the following environme
 
 ```env
 RPC_WS_URL=...
+RUST_LOG=...
 ```
 
 This `RPC_WS_URL` should point to the RPC Websocket endpoint you want to use for Solana block subscribing.

examples/raydium-clmm-alerts/src/main.rs

@@ -19,8 +19,8 @@ use {
 
 #[tokio::main]
 pub async fn main() -> CarbonResult<()> {
-    env_logger::init();
     dotenv::dotenv().ok();
+    env_logger::init();
 
     let filters = Filters::new(
         RpcBlockSubscribeFilter::MentionsAccountOrProgram(RAYDIUM_CLMM_PROGRAM_ID.to_string()),

examples/raydium-cpmm-alerts/README.md

@@ -19,6 +19,7 @@ Create a `.env` file in the root of your project and set the following environme
 
 ```env
 RPC_WS_URL=...
+RUST_LOG=...
 ```
 
 This `RPC_WS_URL` should point to the RPC Websocket endpoint you want to use for Solana block subscribing.

examples/raydium-cpmm-alerts/src/main.rs

@@ -18,8 +18,8 @@ use {
 
 #[tokio::main]
 pub async fn main() -> CarbonResult<()> {
-    env_logger::init();
     dotenv::dotenv().ok();
+    env_logger::init();
 
     let filters = Filters::new(
         RpcBlockSubscribeFilter::MentionsAccountOrProgram(RAYDIUM_CPMM_PROGRAM_ID.to_string()),

examples/sharky-offers/README.md

@@ -19,6 +19,7 @@ Create a `.env` file in the root of your project and set the following environme
 
 ```env
 RPC_URL=...
+RUST_LOG=...
 ```
 
 - `RPC_URL` should point to the Solana RPC URL you want to use for Solana program accounts crawling and live updates.

examples/sharky-offers/src/main.rs

@@ -131,8 +131,8 @@ instruction_decoder_collection!(
 
 #[tokio::main]
 async fn main() -> anyhow::Result<()> {
-    env_logger::init();
     dotenv::dotenv().ok();
+    env_logger::init();
 
     Pipeline::builder()
         .datasource(GpaBackfillDatasource::new(

examples/token-indexing/README.md

@@ -25,7 +25,7 @@ DATABASE_URL=...
 
 - `GEYSER_URL` should point to the Yellowstone Geyser RPC URL you want to use for Solana transaction crawling.
 - `X_TOKEN` is optional and can be used if your Geyser endpoint requires an authentication token.
-- `DATABASE_URL` postgres connection url 
+- `DATABASE_URL` postgres connection url
 
 ### Step 3: Build the Project
 
@@ -45,4 +45,4 @@ cargo run --release
 
 ## Metrics
 
-The example doesn't include a metrics implementation by default. However, you can easily integrate custom metrics or logging by passing your own metrics implementation to the pipeline.
+The example doesn't include a metrics implementation by default. However, you can easily integrate custom metrics or logging by passing your own metrics implementation to the pipeline.