Struct LogSink 

pub struct LogSink { /* private fields */ }

Implementations

impl LogSink

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

pub fn restart_signal(&self) -> Arc<Atomic<bool>>

pub fn restart(&mut self) -> Result<(), PluginError>

pub fn restarted(&self) -> bool

pub fn bytes_written(&self) -> u64

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

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

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

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

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

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