Struct RequestWriterService 

pub struct RequestWriterService<S, W> { /* private fields */ }

Middleware to print Http request in std format.

Request bodies are observed while they stream to the inner service. The writer receives an owned body stream and processes frames concurrently.

See the module docs for more details.

Implementations

impl<S, W> RequestWriterService<S, W>

pub fn new(inner: S, writer: W) -> Self

Create a new RequestWriterService with a custom RequestWriter.

Use Self::new_with_executor when streaming writer tasks must participate in graceful shutdown.

pub fn new_with_executor(inner: S, writer: W, executor: Executor) -> Self

Create a new RequestWriterService with a custom RequestWriter and executor for streaming writer tasks.

impl<S> RequestWriterService<S, UnboundedSender<Request>>

pub fn writer_unbounded<W>( inner: S, executor: &Executor, writer: W, mode: Option<WriterMode>, ) -> Self

where W: AsyncWrite + Unpin + Send + Sync + 'static,

Create a new RequestWriterService that prints requests to an AsyncWriter over an unbounded channel

pub fn stdout_unbounded( inner: S, executor: &Executor, mode: Option<WriterMode>, ) -> Self

Create a new RequestWriterService that prints requests to stdout over an unbounded channel.

pub fn stderr_unbounded( inner: S, executor: &Executor, mode: Option<WriterMode>, ) -> Self

Create a new RequestWriterService that prints requests to stderr over an unbounded channel.

impl<S> RequestWriterService<S, PerMessageFileWriter>

pub async fn file_per_request( inner: S, executor: &Executor, directory: impl Into<PathBuf>, prefix: impl AsRef<str>, mode: Option<WriterMode>, ) -> Result<Self>

Create a service that streams every request into a unique file below directory using the portable filename prefix.

impl<S> RequestWriterService<S, Sender<Request>>

pub fn writer<W>( inner: S, executor: &Executor, writer: W, buffer_size: usize, mode: Option<WriterMode>, ) -> Self

where W: AsyncWrite + Unpin + Send + Sync + 'static,

Create a new RequestWriterService that prints requests to an AsyncWriter over a bounded channel with a fixed buffer size.

pub fn stdout( inner: S, executor: &Executor, buffer_size: usize, mode: Option<WriterMode>, ) -> Self

Create a new RequestWriterService that prints requests to stdout over a bounded channel with a fixed buffer size.

pub fn stderr( inner: S, executor: &Executor, buffer_size: usize, mode: Option<WriterMode>, ) -> Self

Create a new RequestWriterService that prints requests to stderr over a bounded channel with a fixed buffer size.

Trait Implementations

impl<S: Clone, W: Clone> Clone for RequestWriterService<S, W>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S: Debug, W> Debug for RequestWriterService<S, W>

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

Formats the value using the given formatter.

impl<S, W, ReqBody> Service<Request<ReqBody>> for RequestWriterService<S, W>

where S: Service<Request, Error: Into<BoxError>>, ReqBody: StreamingBody<Data = Bytes, Error: Into<BoxError>> + Send + Sync + 'static, W: RequestWriter,

type Error = Box<dyn Error + Send + Sync>

The type of error returned by the service.

type Output = <S as Service<Request>>::Output

The type of the output returned by the service.

async fn serve( &self, req: Request<ReqBody>, ) -> Result<Self::Output, Self::Error>

Serve an output or an error for the given input

fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>

Box this service to allow for dynamic dispatch.