Trait vector::sources::util::framestream::FrameHandler

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

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>

Implementors

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

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