Uses of Class
com.google.cloud.pubsublite.proto.SeekRequest
-
Packages that use SeekRequest Package Description com.google.cloud.pubsublite.internal.wire com.google.cloud.pubsublite.proto -
-
Uses of SeekRequest in com.google.cloud.pubsublite.internal.wire
Methods in com.google.cloud.pubsublite.internal.wire with parameters of type SeekRequest Modifier and Type Method Description abstract SubscriberBuilder.Builder
SubscriberBuilder.Builder. setInitialLocation(SeekRequest initialLocation)
Constructors in com.google.cloud.pubsublite.internal.wire with parameters of type SeekRequest Constructor Description SubscriberImpl(StreamFactories.SubscribeStreamFactory streamFactory, InitialSubscribeRequest baseInitialRequest, SeekRequest initialLocation, Consumer<List<SequencedMessage>> messageConsumer, SubscriberResetHandler resetHandler, boolean retryStreamRaces)
-
Uses of SeekRequest in com.google.cloud.pubsublite.proto
Methods in com.google.cloud.pubsublite.proto that return SeekRequest Modifier and Type Method Description SeekRequest
SeekRequest.Builder. build()
SeekRequest
SeekRequest.Builder. buildPartial()
static SeekRequest
SeekRequest. getDefaultInstance()
SeekRequest
SeekRequest.Builder. getDefaultInstanceForType()
SeekRequest
SeekRequest. getDefaultInstanceForType()
SeekRequest
InitialSubscribeRequest.Builder. getInitialLocation()
Optional.SeekRequest
InitialSubscribeRequest. getInitialLocation()
Optional.SeekRequest
InitialSubscribeRequestOrBuilder. getInitialLocation()
Optional.SeekRequest
SubscribeRequest.Builder. getSeek()
Request to update the stream's delivery cursor.SeekRequest
SubscribeRequest. getSeek()
Request to update the stream's delivery cursor.SeekRequest
SubscribeRequestOrBuilder. getSeek()
Request to update the stream's delivery cursor.static SeekRequest
SeekRequest. parseDelimitedFrom(InputStream input)
static SeekRequest
SeekRequest. parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SeekRequest
SeekRequest. parseFrom(byte[] data)
static SeekRequest
SeekRequest. parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SeekRequest
SeekRequest. parseFrom(com.google.protobuf.ByteString data)
static SeekRequest
SeekRequest. parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SeekRequest
SeekRequest. parseFrom(com.google.protobuf.CodedInputStream input)
static SeekRequest
SeekRequest. parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SeekRequest
SeekRequest. parseFrom(InputStream input)
static SeekRequest
SeekRequest. parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SeekRequest
SeekRequest. parseFrom(ByteBuffer data)
static SeekRequest
SeekRequest. parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
Methods in com.google.cloud.pubsublite.proto that return types with arguments of type SeekRequest Modifier and Type Method Description com.google.protobuf.Parser<SeekRequest>
SeekRequest. getParserForType()
static com.google.protobuf.Parser<SeekRequest>
SeekRequest. parser()
Methods in com.google.cloud.pubsublite.proto with parameters of type SeekRequest Modifier and Type Method Description SeekRequest.Builder
SeekRequest.Builder. mergeFrom(SeekRequest other)
InitialSubscribeRequest.Builder
InitialSubscribeRequest.Builder. mergeInitialLocation(SeekRequest value)
Optional.SubscribeRequest.Builder
SubscribeRequest.Builder. mergeSeek(SeekRequest value)
Request to update the stream's delivery cursor.static SeekRequest.Builder
SeekRequest. newBuilder(SeekRequest prototype)
InitialSubscribeRequest.Builder
InitialSubscribeRequest.Builder. setInitialLocation(SeekRequest value)
Optional.SubscribeRequest.Builder
SubscribeRequest.Builder. setSeek(SeekRequest value)
Request to update the stream's delivery cursor.
-