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