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;