Struct AccessLogServiceClient

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

Service for streaming access logs from Envoy to an access log server.

Implementations

impl AccessLogServiceClient<Channel>

pub async fn connect<D>(dst: D) -> Result<Self, Error>

where D: TryInto<Endpoint>, D::Error: Into<StdError>,

Attempt to create a new client by connecting to a given endpoint.

impl<T> AccessLogServiceClient<T>

where T: GrpcService<BoxBody>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

pub fn new(inner: T) -> Self

pub fn with_origin(inner: T, origin: Uri) -> Self

pub fn with_interceptor<F>( inner: T, interceptor: F, ) -> AccessLogServiceClient<InterceptedService<T, F>>

where F: Interceptor, T::ResponseBody: Default, T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>, <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

Compress requests with the given encoding.

This requires the server to support it otherwise it might respond with an error.

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

Enable decompressing responses.

pub async fn stream_access_logs( &mut self, request: impl IntoStreamingRequest<Message = StreamAccessLogsMessage>, ) -> Result<Response<StreamAccessLogsResponse>, Status>

Envoy will connect and send StreamAccessLogsMessage messages forever. It does not expect any response to be sent as nothing would be done in the case of failure. The server should disconnect if it expects Envoy to reconnect. In the future we may decide to add a different API for “critical” access logs in which Envoy will buffer access logs for some period of time until it gets an ACK so it could then retry. This API is designed for high throughput with the expectation that it might be lossy.

Trait Implementations

impl<T: Clone> Clone for AccessLogServiceClient<T>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for AccessLogServiceClient<T>

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

Formats the value using the given formatter.