Package com.google.cloud.pubsublite.proto

Interface TopicStatsServiceGrpc.AsyncService

All Known Implementing Classes:

TopicStatsServiceGrpc.TopicStatsServiceImplBase

Enclosing class:

TopicStatsServiceGrpc

public static interface TopicStatsServiceGrpc.AsyncService

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

Method Summary

Modifier and Type	Method	Description
default void	computeHeadCursor(ComputeHeadCursorRequest request, io.grpc.stub.StreamObserver<ComputeHeadCursorResponse> responseObserver)	Compute the head cursor for the partition.
default void	computeMessageStats(ComputeMessageStatsRequest request, io.grpc.stub.StreamObserver<ComputeMessageStatsResponse> responseObserver)	Compute statistics about a range of messages in a given topic and partition.
default void	computeTimeCursor(ComputeTimeCursorRequest request, io.grpc.stub.StreamObserver<ComputeTimeCursorResponse> responseObserver)	Compute the corresponding cursor for a publish or event time in a topic partition.

Method Detail

computeMessageStats

default void computeMessageStats(ComputeMessageStatsRequest request,
                                 io.grpc.stub.StreamObserver<ComputeMessageStatsResponse> responseObserver)

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

computeHeadCursor

default void computeHeadCursor(ComputeHeadCursorRequest request,
                               io.grpc.stub.StreamObserver<ComputeHeadCursorResponse> responseObserver)

 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.
 

computeTimeCursor

default void computeTimeCursor(ComputeTimeCursorRequest request,
                               io.grpc.stub.StreamObserver<ComputeTimeCursorResponse> responseObserver)

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