greentic-runner-host 0.4.74

Host runtime shim for Greentic runner: config, pack loading, activity handling
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

use super::super::error::GResult;
use super::super::host::{SpanContext, TelemetryHost};
use async_trait::async_trait;
use std::sync::Arc;

type TelemetryFn = dyn Fn(&SpanContext, &[(&str, &str)]) -> GResult<()> + Send + Sync;

pub struct FnTelemetryHost {
    inner: Arc<TelemetryFn>,
}

impl FnTelemetryHost {
    pub fn new<F>(func: F) -> Self
    where
        F: Send + Sync + 'static + Fn(&SpanContext, &[(&str, &str)]) -> GResult<()>,
    {
        Self {
            inner: Arc::new(func),
        }
    }
}

#[async_trait]
impl TelemetryHost for FnTelemetryHost {
    async fn emit(&self, span: &SpanContext, fields: &[(&str, &str)]) -> GResult<()> {
        (self.inner)(span, fields)
    }
}