Struct gapi_grpc::google::cloud::pubsublite::v1::topic_stats_service_client::TopicStatsServiceClient

pub struct TopicStatsServiceClient<T> { /* fields omitted */ }

This service allows users to get stats about messages in their topic.

Implementations

impl TopicStatsServiceClient<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> TopicStatsServiceClient<T> where
    T: GrpcService<BoxBody>,
    T::ResponseBody: Body + HttpBody + Send + 'static,
    T::Error: Into<StdError>,
    <T::ResponseBody as HttpBody>::Error: Into<StdError> + Send, 

pub fn new(inner: T) -> Self

pub fn with_interceptor(inner: T, interceptor: impl Into<Interceptor>) -> Self

pub async fn compute_message_stats(
    &mut self,
    request: impl IntoRequest<ComputeMessageStatsRequest>
) -> Result<Response<ComputeMessageStatsResponse>, Status>

Compute statistics about a range of messages in a given topic and partition.

pub async fn compute_head_cursor(
    &mut self,
    request: impl IntoRequest<ComputeHeadCursorRequest>
) -> Result<Response<ComputeHeadCursorResponse>, Status>

Compute the head cursor for the partition. The head cursor’s offset is guaranteed to be less than or equal to all messages which have not yet been acknowledged as published, and greater than the offset of any message whose publish has already been acknowledged. It is zero if there have never been messages in the partition.

pub async fn compute_time_cursor(
    &mut self,
    request: impl IntoRequest<ComputeTimeCursorRequest>
) -> Result<Response<ComputeTimeCursorResponse>, Status>

Compute the corresponding cursor for a publish or event time in a topic partition.

Trait Implementations

impl<T: Clone> Clone for TopicStatsServiceClient<T>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Debug for TopicStatsServiceClient<T>

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

Formats the value using the given formatter.