/// Streaming read of log entries as they are ingested. Until the stream is
/// terminated, it will continue reading logs.
Streaming read of log entries as they are ingested. Until the stream is
terminated, it will continue reading logs.
Streaming read of log entries as they are ingested . Until the stream is terminated it will continue reading logs .
pub async fn tail_log_entries(
            &mut self,
            request: impl tonic::IntoStreamingRequest<
                Message = super::TailLogEntriesRequest,
            >,
        ) -> Result<
            tonic::Response<tonic::codec::Streaming<super::TailLogEntriesResponse>>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/google.logging.v2.LoggingServiceV2/TailLogEntries",
            );
            self.inner.streaming(request.into_streaming_request(), path, codec).await
        }
pub async fn tail_log_entries ( & mut self , request : impl tonic :: IntoStreamingRequest < Message = super :: TailLogEntriesRequest , > , ) -> Result < tonic :: Response < tonic :: codec :: Streaming < super :: TailLogEntriesResponse > > , tonic :: Status , > { self . inner . ready ( ) . await . map_err ( | e | { tonic :: Status :: new ( tonic :: Code :: Unknown , format ! ( " " e into ( ) ) , ) } ) ? ; let codec = tonic :: codec :: ProstCodec :: default ( ) ; let path = http :: uri :: PathAndQuery :: from_static ( " " , ) ; self . inner . streaming ( request . into_streaming_request ( ) , path , codec ) . await }
Streaming read of log entries as they are ingested.
Streaming read of log entries as they are ingested .
&mut self
request
impl tonic::IntoStreamingRequest<
                Message = super::TailLogEntriesRequest,
            >