Merge pull request #142 from Thaumy/main

Add OTLP export interval config

Author: saying121

doc/config.toml

@@ -26,3 +26,4 @@ buf_watermark = 2048
 [remote.otlp]
 enable = false
 addr = "https://otel-col.optimatist.com"
+interval = 10

src/config.rs

@@ -62,6 +62,8 @@ pub struct RpcConfig {
 pub struct OtlpConfig {
     pub enable: bool,
     pub addr: String,
+    /// in seconds
+    pub interval: u64,
 }
 
 #[derive(Deserialize)]

src/main.rs

@@ -173,7 +173,11 @@ async fn async_tasks(remote_cfg: RemoteConfig, mut task_rt: TaskRuntime) -> Resu
             endpoint: Some(remote_cfg.otlp.addr),
             ..Default::default()
         };
-        let otlp = otlp::Otlp::new(remote_cfg.token, Duration::from_secs(1), export_conf)?;
+        let otlp = otlp::Otlp::new(
+            remote_cfg.token,
+            Duration::from_secs(remote_cfg.otlp.interval),
+            export_conf,
+        )?;
 
         otlp.otlp_tasks().await?;
         Ok::<(), Error>(())

src/otlp/mod.rs

@@ -44,7 +44,7 @@ pub struct Otlp {
 
 impl Otlp {
     pub fn new(token: String, interval: Duration, export_config: ExportConfig) -> Result<Self> {
-        let provider = meter_provider(export_config, token.clone())?;
+        let provider = meter_provider(export_config, token.clone(), interval)?;
         let meter = provider.meter("SystemProfile");
         Ok(Self {
             token,
@@ -93,7 +93,11 @@ impl Otlp {
     }
 }
 
-fn meter_provider(export_config: ExportConfig, token: String) -> Result<SdkMeterProvider> {
+fn meter_provider(
+    export_config: ExportConfig,
+    token: String,
+    interval: Duration,
+) -> Result<SdkMeterProvider> {
     let mut meta = MetadataMap::new();
     meta.insert("authorization", format!("Bearer {}", token).parse()?);
     let otlp_exporter = MetricExporter::builder()
@@ -104,7 +108,7 @@ fn meter_provider(export_config: ExportConfig, token: String) -> Result<SdkMeter
         .with_export_config(export_config)
         .build()?;
     let reader = PeriodicReader::builder(otlp_exporter, runtime::Tokio)
-        .with_interval(Duration::from_secs(1))
+        .with_interval(interval)
         .build();
 
     let a = SdkMeterProvider::builder()