Uses of Class
com.google.cloud.pubsublite.proto.StreamingCommitCursorResponse
-
Packages that use StreamingCommitCursorResponse 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 StreamingCommitCursorResponse in com.google.cloud.pubsublite.internal.wire
Methods in com.google.cloud.pubsublite.internal.wire with parameters of type StreamingCommitCursorResponse Modifier and Type Method Description protected void
ConnectedCommitterImpl. handleStreamResponse(StreamingCommitCursorResponse response)
Constructor parameters in com.google.cloud.pubsublite.internal.wire with type arguments of type StreamingCommitCursorResponse Constructor Description CommitterImpl(StreamFactory<StreamingCommitCursorRequest,StreamingCommitCursorResponse> streamFactory, InitialCommitCursorRequest request)
-
Uses of StreamingCommitCursorResponse in com.google.cloud.pubsublite.proto
Methods in com.google.cloud.pubsublite.proto that return StreamingCommitCursorResponse Modifier and Type Method Description StreamingCommitCursorResponse
StreamingCommitCursorResponse.Builder. build()
StreamingCommitCursorResponse
StreamingCommitCursorResponse.Builder. buildPartial()
static StreamingCommitCursorResponse
StreamingCommitCursorResponse. getDefaultInstance()
StreamingCommitCursorResponse
StreamingCommitCursorResponse.Builder. getDefaultInstanceForType()
StreamingCommitCursorResponse
StreamingCommitCursorResponse. getDefaultInstanceForType()
static StreamingCommitCursorResponse
StreamingCommitCursorResponse. parseDelimitedFrom(InputStream input)
static StreamingCommitCursorResponse
StreamingCommitCursorResponse. parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StreamingCommitCursorResponse
StreamingCommitCursorResponse. parseFrom(byte[] data)
static StreamingCommitCursorResponse
StreamingCommitCursorResponse. parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StreamingCommitCursorResponse
StreamingCommitCursorResponse. parseFrom(com.google.protobuf.ByteString data)
static StreamingCommitCursorResponse
StreamingCommitCursorResponse. parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StreamingCommitCursorResponse
StreamingCommitCursorResponse. parseFrom(com.google.protobuf.CodedInputStream input)
static StreamingCommitCursorResponse
StreamingCommitCursorResponse. parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StreamingCommitCursorResponse
StreamingCommitCursorResponse. parseFrom(InputStream input)
static StreamingCommitCursorResponse
StreamingCommitCursorResponse. parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StreamingCommitCursorResponse
StreamingCommitCursorResponse. parseFrom(ByteBuffer data)
static StreamingCommitCursorResponse
StreamingCommitCursorResponse. parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
Methods in com.google.cloud.pubsublite.proto that return types with arguments of type StreamingCommitCursorResponse Modifier and Type Method Description com.google.protobuf.Parser<StreamingCommitCursorResponse>
StreamingCommitCursorResponse. getParserForType()
static io.grpc.MethodDescriptor<StreamingCommitCursorRequest,StreamingCommitCursorResponse>
CursorServiceGrpc. getStreamingCommitCursorMethod()
static com.google.protobuf.Parser<StreamingCommitCursorResponse>
StreamingCommitCursorResponse. parser()
Methods in com.google.cloud.pubsublite.proto with parameters of type StreamingCommitCursorResponse Modifier and Type Method Description StreamingCommitCursorResponse.Builder
StreamingCommitCursorResponse.Builder. mergeFrom(StreamingCommitCursorResponse other)
static StreamingCommitCursorResponse.Builder
StreamingCommitCursorResponse. newBuilder(StreamingCommitCursorResponse prototype)
Method parameters in com.google.cloud.pubsublite.proto with type arguments of type StreamingCommitCursorResponse Modifier and Type Method Description 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. -
Uses of StreamingCommitCursorResponse in com.google.cloud.pubsublite.v1
Methods in com.google.cloud.pubsublite.v1 that return types with arguments of type StreamingCommitCursorResponse 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 StreamingCommitCursorResponse in com.google.cloud.pubsublite.v1.stub
Methods in com.google.cloud.pubsublite.v1.stub that return types with arguments of type StreamingCommitCursorResponse 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.
-