flwrs-plugin 0.0.1

Crate for building plugins for flwrs.
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
29
30
31
32
33
34
35

use crate::plugin::error::TransformError;
use crate::plugin::msg_client::MSG_CLIENT;
use crate::schema::source::source_message::Payload;
use crate::schema::source::{SourceEvent, SourceMessage};
use prost::Message;

pub struct LocalSink {
    _plugin_id: String,
}

impl LocalSink {
    pub fn new(plugin_id: String) -> Self {
        Self { _plugin_id: plugin_id }
    }

    pub async fn event(&self, evt: SourceEvent) -> Result<(), TransformError> {
        let msg = SourceMessage {
            payload: Some(Payload::Event(evt)),
        };
        match MSG_CLIENT
            .read()
            .await
            .send(msg.encode_to_vec().as_slice())
            .await
        {
            Ok(_) => Ok(()),
            Err(err) => {
                log::error!("Error sending message: {}", err);
                Err(TransformError {
                    source: Box::new(err),
                })
            }
        }
    }
}