Struct StdoutClient 

pub struct StdoutClient { /* private fields */ }

Implementations

impl StdoutClient

pub fn new() -> Self

Creates a new StdoutClient with the default writer (stdout).

Example

use otlp_stdout_client::StdoutClient;

let client = StdoutClient::new();

pub fn new_with_writer<W>(writer: W) -> Self

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

Creates a new StdoutClient with a custom writer.

This method allows you to specify an alternative writer, such as a file or an in-memory buffer.

Arguments

• writer - Any writer implementing AsyncWrite + Send + Sync + Unpin + 'static.

Example

use otlp_stdout_client::StdoutClient;
use tokio::fs::File;

// Using a file as the writer
let file = File::create("output.log").await?;
let client = StdoutClient::new_with_writer(file);

Trait Implementations

impl Debug for StdoutClient

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

Formats the value using the given formatter.

impl Default for StdoutClient

fn default() -> Self

Returns the “default value” for a type.

impl HttpClient for StdoutClient

Implements the HttpClient trait for StdoutClient.

This implementation allows the StdoutClient to be used as an HTTP client for sending OTLP (OpenTelemetry Protocol) data. It processes the request body and writes it to stdout in a JSON format suitable for log parsing.

The send method handles both JSON and non-JSON payloads, formatting them appropriately for stdout output.

fn send_bytes<'life0, 'async_trait>( &'life0 self, request: Request<Bytes>, ) -> Pin<Box<dyn Future<Output = Result<Response<Bytes>, Box<dyn StdError + Send + Sync>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send the specified HTTP request with Bytes payload.

fn send<'life0, 'async_trait>( &'life0 self, request: Request<Vec<u8>>, ) -> Pin<Box<dyn Future<Output = Result<Response<Bytes>, Box<dyn Error + Sync + Send>>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

👎Deprecated: Use send_bytes with Bytes payload instead.

Send the specified HTTP request with Vec<u8> payload