Struct ByteSink 

pub struct ByteSink<W: Write, Factory: VerdictFactory<MonitorOutput, OutputTime, Record = Verdict>, MonitorOutput: VerdictRepresentation, OutputTime: OutputTimeRepresentation, Verdict: Into<Vec<u8>>> { /* private fields */ }

Generic VerdictSink that accepts verdicts as bytes and writes them to a Writer.

Implementations

impl<W: Write, Factory: VerdictFactory<MonitorOutput, OutputTime, Record = Verdict>, MonitorOutput: VerdictRepresentation, OutputTime: OutputTimeRepresentation, Verdict: Into<Vec<u8>>> ByteSink<W, Factory, MonitorOutput, OutputTime, Verdict>

pub fn new(writer: W, factory: Factory) -> Self

Create a new ByteSink that receives bytes and forwards them to a writer

Trait Implementations

impl<W: Debug + Write, Factory: Debug + VerdictFactory<MonitorOutput, OutputTime, Record = Verdict>, MonitorOutput: Debug + VerdictRepresentation, OutputTime: Debug + OutputTimeRepresentation, Verdict: Debug + Into<Vec<u8>>> Debug for ByteSink<W, Factory, MonitorOutput, OutputTime, Verdict>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<W: Write, Factory: VerdictFactory<MonitorOutput, OutputTime, Record = Verdict>, MonitorOutput: VerdictRepresentation, OutputTime: OutputTimeRepresentation, Verdict: Into<Vec<u8>>> VerdictsSink<MonitorOutput, OutputTime> for ByteSink<W, Factory, MonitorOutput, OutputTime, Verdict>

type Error = Error

Error Type of a VerdictsSink implementation

type Factory = Factory

Factory Type to convert the monitor output to the required representation

type Return = ()

Return Type of a VerdictsSink implementation

fn sink(&mut self, verdict: Verdict) -> Result<Self::Return, Self::Error>

Function to dispatch the converted verdict to the sink

fn factory(&mut self) -> &mut Self::Factory

Function to return a reference to the Verdictfactory

fn sink_verdicts( &mut self, verdicts: Verdicts<V, T>, ) -> Result<Vec<Self::Return>, VerdictSinkError<Self::Error, <Self::Factory as VerdictFactory<V, T>>::Error>>

Defines how the verdicts of the monitor needs to be handled

fn sink_verdict( &mut self, ts: <T as TimeRepresentation>::InnerTime, verdict: V, ) -> Result<Self::Return, VerdictSinkError<Self::Error, <Self::Factory as VerdictFactory<V, T>>::Error>>

Defines how one verdict of the monitor needs to be handled, timed and event-based