1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
use once_cell::sync::Lazy;
use rill_protocol::io::provider::StreamType;

pub fn provider_type() -> StreamType {
    "rillrate::agent".into()
}

pub static TYPE: Lazy<StreamType> = Lazy::new(provider_type);

pub mod log_flow;
pub mod process_monitor;