Struct LogSink 

pub struct LogSink { /* private fields */ }

Implementations

impl LogSink

pub fn new(tx: Sender<Bytes>) -> Self

pub fn restart_signal(&self) -> Arc<AtomicBool>

pub fn restart(&mut self) -> PluginResult<()>

pub fn restarted(&self) -> bool

pub fn bytes_written(&self) -> u64

pub async fn write(&mut self, chunk: Bytes) -> PluginResult<()>

pub async fn pipe(&mut self, response: Response) -> PluginResult<()>

pub async fn pipe_after( &mut self, response: Response, skip: u64, ) -> PluginResult<()>

pub async fn pipe_range( &mut self, response: Response, offset: u64, ) -> PluginResult<RangedRead>

pub async fn pipe_resumed<F, Fut>( &mut self, offset: Option<u64>, fetch: F, ) -> PluginResult<(LogReadMode, u64)>

where F: FnMut(Option<u64>) -> Fut, Fut: Future<Output = PluginResult<Response>>,