working on emit

.vscode/settings.json

@@ -0,0 +1,5 @@
+{
+    "cSpell.words": [
+        "datapoint"
+    ]
+}

keepers/validator-keeper/src/main.rs

@@ -62,10 +62,18 @@ struct Args {
     #[arg(short, long, env, default_value = "60")]
     metrics_interval: u64,
 
+    // Priority Fees (mLamports)
+    #[arg(short, long, env, default_value = "50_000")]
+    priority_fees: u64,
+
     #[arg(short, long, env, default_value_t = Cluster::Mainnet)]
     cluster: Cluster,
 }
 
+fn should_emit(tick: u64, intervals: &[u64]) -> bool {
+    intervals.iter().any(|interval| (tick + 1) % interval == 0)
+}
+
 fn should_update(tick: u64, intervals: &[u64]) -> bool {
     intervals.iter().any(|interval| tick % interval == 0)
 }
@@ -92,6 +100,7 @@ struct RunLoopConfig {
     gossip_entrypoint: Option<SocketAddr>,
     validator_history_interval: u64,
     metrics_interval: u64,
+    priority_fees: u64,
 }
 
 async fn run_loop(config: RunLoopConfig) {
@@ -104,6 +113,7 @@ async fn run_loop(config: RunLoopConfig) {
         gossip_entrypoint,
         validator_history_interval,
         metrics_interval,
+        priority_fees,
     } = config;
     let intervals = vec![validator_history_interval, metrics_interval];
 
@@ -256,6 +266,11 @@ async fn run_loop(config: RunLoopConfig) {
             );
         }
 
+        // ---------------------- EMIT ---------------------------------
+        if should_emit(tick, &intervals) {
+            KeeperOperations::emit(&keeper_state.runs_for_epoch, &keeper_state.errors_for_epoch)
+        }
+
         // ---------- SLEEP ----------
         sleep_and_tick(&mut tick).await;
     }
@@ -299,6 +314,7 @@ async fn main() {
         gossip_entrypoint,
         validator_history_interval: args.validator_history_interval,
         metrics_interval: args.metrics_interval,
+        priority_fees: args.priority_fees,
     };
 
     run_loop(config).await;

keepers/validator-keeper/src/operations/keeper_operations.rs

@@ -1,3 +1,5 @@
+use solana_metrics::datapoint_info;
+
 #[derive(Clone)]
 pub enum KeeperOperations {
     PreCreateUpdate,
@@ -13,4 +15,23 @@ pub enum KeeperOperations {
 }
 impl KeeperOperations {
     pub const LEN: usize = 10;
+
+    pub fn emit(
+        runs_for_epoch: &[u64; KeeperOperations::LEN],
+        errors_for_epoch: &[u64; KeeperOperations::LEN],
+    ) {
+        datapoint_info!(
+            "keeper-operation-stats",
+            (
+                "num-pre-create-update-runs",
+                runs_for_epoch[KeeperOperations::PreCreateUpdate as usize],
+                i64
+            ),
+            (
+                "num-pre-create-update-errors",
+                errors_for_epoch[KeeperOperations::PreCreateUpdate as usize],
+                i64
+            )
+        );
+    }
 }

keepers/validator-keeper/src/state/keeper_state.rs

@@ -2,6 +2,7 @@ use std::collections::{HashMap, HashSet};
 
 use bytemuck::Zeroable;
 use solana_client::rpc_response::RpcVoteAccountInfo;
+use solana_metrics::datapoint_info;
 use solana_sdk::{
     account::Account, epoch_info::EpochInfo, pubkey::Pubkey,
     vote::program::id as get_vote_program_id,