Skip to main content

IntakeSource

oris_intake

Trait IntakeSource 

Source 
pub trait IntakeSource: Send + Sync {
    // Required methods
    fn source_type(&self) -> IntakeSourceType;
    fn process(&self, payload: &[u8]) -> IntakeResult<Vec<IntakeEvent>>;
    fn validate(&self, payload: &[u8]) -> IntakeResult<()>;
}
Expand description

Trait for implementing intake sources

Required Methods§

Source

fn source_type(&self) -> IntakeSourceType

Get the source type

Source

fn process(&self, payload: &[u8]) -> IntakeResult<Vec<IntakeEvent>>

Process incoming data and extract potential issues

Source

fn validate(&self, payload: &[u8]) -> IntakeResult<()>

Validate the incoming data format

Implementors§