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 voidConnectedCommitterImpl. 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 StreamingCommitCursorResponseStreamingCommitCursorResponse.Builder. build()StreamingCommitCursorResponseStreamingCommitCursorResponse.Builder. buildPartial()static StreamingCommitCursorResponseStreamingCommitCursorResponse. getDefaultInstance()StreamingCommitCursorResponseStreamingCommitCursorResponse.Builder. getDefaultInstanceForType()StreamingCommitCursorResponseStreamingCommitCursorResponse. getDefaultInstanceForType()static StreamingCommitCursorResponseStreamingCommitCursorResponse. parseDelimitedFrom(InputStream input)static StreamingCommitCursorResponseStreamingCommitCursorResponse. parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static StreamingCommitCursorResponseStreamingCommitCursorResponse. parseFrom(byte[] data)static StreamingCommitCursorResponseStreamingCommitCursorResponse. parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static StreamingCommitCursorResponseStreamingCommitCursorResponse. parseFrom(com.google.protobuf.ByteString data)static StreamingCommitCursorResponseStreamingCommitCursorResponse. parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static StreamingCommitCursorResponseStreamingCommitCursorResponse. parseFrom(com.google.protobuf.CodedInputStream input)static StreamingCommitCursorResponseStreamingCommitCursorResponse. parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static StreamingCommitCursorResponseStreamingCommitCursorResponse. parseFrom(InputStream input)static StreamingCommitCursorResponseStreamingCommitCursorResponse. parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static StreamingCommitCursorResponseStreamingCommitCursorResponse. parseFrom(ByteBuffer data)static StreamingCommitCursorResponseStreamingCommitCursorResponse. 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.BuilderStreamingCommitCursorResponse.Builder. mergeFrom(StreamingCommitCursorResponse other)static StreamingCommitCursorResponse.BuilderStreamingCommitCursorResponse. 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.
-