vector::sources::util::framestream

Trait FrameHandler

Source
pub trait FrameHandler {
    // Required methods
    fn content_type(&self) -> String;
    fn max_frame_length(&self) -> usize;
    fn handle_event(
        &self,
        received_from: Option<Bytes>,
        frame: Bytes,
    ) -> Option<Event>;
    fn multithreaded(&self) -> bool;
    fn max_frame_handling_tasks(&self) -> u32;
    fn host_key(&self) -> &Option<OwnedValuePath>;
    fn timestamp_key(&self) -> Option<&OwnedValuePath>;
    fn source_type_key(&self) -> Option<&OwnedValuePath>;
}

Required Methods§

Source

fn content_type(&self) -> String

Source

fn max_frame_length(&self) -> usize

Source

fn handle_event( &self, received_from: Option<Bytes>, frame: Bytes, ) -> Option<Event>

Source

fn multithreaded(&self) -> bool

Source

fn max_frame_handling_tasks(&self) -> u32

Source

fn host_key(&self) -> &Option<OwnedValuePath>

Source

fn timestamp_key(&self) -> Option<&OwnedValuePath>

Source

fn source_type_key(&self) -> Option<&OwnedValuePath>

Implementors§

Source§

impl<T: FrameHandler + Clone> FrameHandler for vector::sources::dnstap::tcp::DnstapFrameHandler<T>

Source§

impl<T: FrameHandler + Clone> FrameHandler for vector::sources::dnstap::unix::DnstapFrameHandler<T>