Package com.google.cloud.pubsublite.proto

Interface CursorServiceGrpc.AsyncService

All Known Implementing Classes:

CursorServiceGrpc.CursorServiceImplBase

Enclosing class:

CursorServiceGrpc

public static interface CursorServiceGrpc.AsyncService

 The service that a subscriber client application uses to manage committed
 cursors while receiving messsages. A cursor represents a subscriber's
 progress within a topic partition for a given subscription.
 

Method Summary

Modifier and Type	Method	Description
default void	commitCursor(CommitCursorRequest request, io.grpc.stub.StreamObserver<CommitCursorResponse> responseObserver)	Updates the committed cursor.
default void	listPartitionCursors(ListPartitionCursorsRequest request, io.grpc.stub.StreamObserver<ListPartitionCursorsResponse> responseObserver)	Returns all committed cursor information for a subscription.
default io.grpc.stub.StreamObserver<StreamingCommitCursorRequest>	streamingCommitCursor(io.grpc.stub.StreamObserver<StreamingCommitCursorResponse> responseObserver)	Establishes a stream with the server for managing committed cursors.

Method Detail

streamingCommitCursor

default io.grpc.stub.StreamObserver<StreamingCommitCursorRequest> streamingCommitCursor(io.grpc.stub.StreamObserver<StreamingCommitCursorResponse> responseObserver)

 Establishes a stream with the server for managing committed cursors.
 

commitCursor

default void commitCursor(CommitCursorRequest request,
                          io.grpc.stub.StreamObserver<CommitCursorResponse> responseObserver)

 Updates the committed cursor.
 

listPartitionCursors

default void listPartitionCursors(ListPartitionCursorsRequest request,
                                  io.grpc.stub.StreamObserver<ListPartitionCursorsResponse> responseObserver)

 Returns all committed cursor information for a subscription.