Struct LogsServiceServer 

pub struct LogsServiceServer<T> { /* private fields */ }

Available on crate features grpc and http and opentelemetry and std only.

Service that can be used to push logs between one Application instrumented with OpenTelemetry and an collector, or between an collector and a central collector (in this case logs are sent/received to/from multiple Applications).

Implementations

impl<T> LogsServiceServer<T>

pub fn new(inner: T) -> LogsServiceServer<T>

pub fn from_arc(inner: Arc<T>) -> LogsServiceServer<T>

pub fn with_accept_compressed( self, encoding: CompressionEncoding, ) -> LogsServiceServer<T>

Enable decompressing requests with the given encoding.

pub fn set_accept_compressed( &mut self, encoding: CompressionEncoding, ) -> &mut LogsServiceServer<T>

Enable decompressing requests with the given encoding.

pub fn with_send_compressed( self, encoding: CompressionEncoding, ) -> LogsServiceServer<T>

Compress responses with the given encoding, if the client supports it.

pub fn set_send_compressed( &mut self, encoding: CompressionEncoding, ) -> &mut LogsServiceServer<T>

Compress responses with the given encoding, if the client supports it.

pub fn with_max_decoding_message_size( self, limit: usize, ) -> LogsServiceServer<T>

Limits the maximum size of a decoded message.

Default: 4MB

pub fn set_max_decoding_message_size( &mut self, limit: usize, ) -> &mut LogsServiceServer<T>

Limits the maximum size of a decoded message.

Default: 4MB

pub fn with_max_encoding_message_size( self, limit: usize, ) -> LogsServiceServer<T>

Limits the maximum size of an encoded message.

Default: usize::MAX

pub fn set_max_encoding_message_size( &mut self, limit: usize, ) -> &mut LogsServiceServer<T>

Limits the maximum size of an encoded message.

Default: usize::MAX

Trait Implementations

impl<T> Clone for LogsServiceServer<T>

fn clone(&self) -> LogsServiceServer<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Debug for LogsServiceServer<T>

where T: Debug,

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

Formats the value using the given formatter.

impl<T> NamedService for LogsServiceServer<T>

const NAME: &'static str = SERVICE_NAME

The Service-Name as described here.

impl<T, B> Service<Request<B>> for LogsServiceServer<T>

where T: LogsService, B: Body + Send + Sync + 'static, <B as Body>::Error: Into<Box<dyn Error + Sync + Send>> + Send + 'static,

type Output = Response

The type of the output returned by the service.

type Error = !

The type of error returned by the service.

async fn serve( &self, req: Request<B>, ) -> Result<<LogsServiceServer<T> as Service<Request<B>>>::Output, <LogsServiceServer<T> as Service<Request<B>>>::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.