Uses of Class
com.google.cloud.pubsublite.proto.StreamingCommitCursorRequest
-
Packages that use StreamingCommitCursorRequest Package Description com.google.cloud.pubsublite.internal.wire com.google.cloud.pubsublite.proto com.google.cloud.pubsublite.v1 A client to Pub/Sub Lite APIcom.google.cloud.pubsublite.v1.stub -
-
Uses of StreamingCommitCursorRequest in com.google.cloud.pubsublite.internal.wire
Constructor parameters in com.google.cloud.pubsublite.internal.wire with type arguments of type StreamingCommitCursorRequest Constructor Description CommitterImpl(StreamFactory<StreamingCommitCursorRequest,StreamingCommitCursorResponse> streamFactory, InitialCommitCursorRequest request)
-
Uses of StreamingCommitCursorRequest in com.google.cloud.pubsublite.proto
Methods in com.google.cloud.pubsublite.proto that return StreamingCommitCursorRequest Modifier and Type Method Description StreamingCommitCursorRequest
StreamingCommitCursorRequest.Builder. build()
StreamingCommitCursorRequest
StreamingCommitCursorRequest.Builder. buildPartial()
static StreamingCommitCursorRequest
StreamingCommitCursorRequest. getDefaultInstance()
StreamingCommitCursorRequest
StreamingCommitCursorRequest.Builder. getDefaultInstanceForType()
StreamingCommitCursorRequest
StreamingCommitCursorRequest. getDefaultInstanceForType()
static StreamingCommitCursorRequest
StreamingCommitCursorRequest. parseDelimitedFrom(InputStream input)
static StreamingCommitCursorRequest
StreamingCommitCursorRequest. parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StreamingCommitCursorRequest
StreamingCommitCursorRequest. parseFrom(byte[] data)
static StreamingCommitCursorRequest
StreamingCommitCursorRequest. parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StreamingCommitCursorRequest
StreamingCommitCursorRequest. parseFrom(com.google.protobuf.ByteString data)
static StreamingCommitCursorRequest
StreamingCommitCursorRequest. parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StreamingCommitCursorRequest
StreamingCommitCursorRequest. parseFrom(com.google.protobuf.CodedInputStream input)
static StreamingCommitCursorRequest
StreamingCommitCursorRequest. parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StreamingCommitCursorRequest
StreamingCommitCursorRequest. parseFrom(InputStream input)
static StreamingCommitCursorRequest
StreamingCommitCursorRequest. parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StreamingCommitCursorRequest
StreamingCommitCursorRequest. parseFrom(ByteBuffer data)
static StreamingCommitCursorRequest
StreamingCommitCursorRequest. parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
Methods in com.google.cloud.pubsublite.proto that return types with arguments of type StreamingCommitCursorRequest Modifier and Type Method Description com.google.protobuf.Parser<StreamingCommitCursorRequest>
StreamingCommitCursorRequest. getParserForType()
static io.grpc.MethodDescriptor<StreamingCommitCursorRequest,StreamingCommitCursorResponse>
CursorServiceGrpc. getStreamingCommitCursorMethod()
static com.google.protobuf.Parser<StreamingCommitCursorRequest>
StreamingCommitCursorRequest. parser()
default io.grpc.stub.StreamObserver<StreamingCommitCursorRequest>
CursorServiceGrpc.AsyncService. streamingCommitCursor(io.grpc.stub.StreamObserver<StreamingCommitCursorResponse> responseObserver)
Establishes a stream with the server for managing committed cursors.io.grpc.stub.StreamObserver<StreamingCommitCursorRequest>
CursorServiceGrpc.CursorServiceStub. streamingCommitCursor(io.grpc.stub.StreamObserver<StreamingCommitCursorResponse> responseObserver)
Establishes a stream with the server for managing committed cursors.Methods in com.google.cloud.pubsublite.proto with parameters of type StreamingCommitCursorRequest Modifier and Type Method Description StreamingCommitCursorRequest.Builder
StreamingCommitCursorRequest.Builder. mergeFrom(StreamingCommitCursorRequest other)
static StreamingCommitCursorRequest.Builder
StreamingCommitCursorRequest. newBuilder(StreamingCommitCursorRequest prototype)
-
Uses of StreamingCommitCursorRequest in com.google.cloud.pubsublite.v1
Methods in com.google.cloud.pubsublite.v1 that return types with arguments of type StreamingCommitCursorRequest Modifier and Type Method Description com.google.api.gax.rpc.BidiStreamingCallable<StreamingCommitCursorRequest,StreamingCommitCursorResponse>
CursorServiceClient. streamingCommitCursorCallable()
Establishes a stream with the server for managing committed cursors.com.google.api.gax.rpc.StreamingCallSettings.Builder<StreamingCommitCursorRequest,StreamingCommitCursorResponse>
CursorServiceSettings.Builder. streamingCommitCursorSettings()
Returns the builder for the settings used for calls to streamingCommitCursor.com.google.api.gax.rpc.StreamingCallSettings<StreamingCommitCursorRequest,StreamingCommitCursorResponse>
CursorServiceSettings. streamingCommitCursorSettings()
Returns the object with the settings used for calls to streamingCommitCursor. -
Uses of StreamingCommitCursorRequest in com.google.cloud.pubsublite.v1.stub
Methods in com.google.cloud.pubsublite.v1.stub that return types with arguments of type StreamingCommitCursorRequest Modifier and Type Method Description com.google.api.gax.rpc.BidiStreamingCallable<StreamingCommitCursorRequest,StreamingCommitCursorResponse>
CursorServiceStub. streamingCommitCursorCallable()
com.google.api.gax.rpc.BidiStreamingCallable<StreamingCommitCursorRequest,StreamingCommitCursorResponse>
GrpcCursorServiceStub. streamingCommitCursorCallable()
com.google.api.gax.rpc.StreamingCallSettings.Builder<StreamingCommitCursorRequest,StreamingCommitCursorResponse>
CursorServiceStubSettings.Builder. streamingCommitCursorSettings()
Returns the builder for the settings used for calls to streamingCommitCursor.com.google.api.gax.rpc.StreamingCallSettings<StreamingCommitCursorRequest,StreamingCommitCursorResponse>
CursorServiceStubSettings. streamingCommitCursorSettings()
Returns the object with the settings used for calls to streamingCommitCursor.
-