Uses of Class
com.google.cloud.pubsublite.proto.Cursor

Packages that use Cursor

Package	Description
com.google.cloud.pubsublite.internal
com.google.cloud.pubsublite.proto

Uses of Cursor in com.google.cloud.pubsublite.internal

Methods in com.google.cloud.pubsublite.internal that return types with arguments of type Cursor

Modifier and Type	Method	Description
com.google.api.core.ApiFuture<Optional<Cursor>>	TopicStatsClient.computeCursorForEventTime(TopicPath path, Partition partition, com.google.protobuf.Timestamp eventTime)	Compute the cursor of the first message with event time greater than or equal to the specified event time, for a topic partition.
com.google.api.core.ApiFuture<Optional<Cursor>>	TopicStatsClientImpl.computeCursorForEventTime(TopicPath path, Partition partition, com.google.protobuf.Timestamp eventTime)
com.google.api.core.ApiFuture<Optional<Cursor>>	TopicStatsClient.computeCursorForPublishTime(TopicPath path, Partition partition, com.google.protobuf.Timestamp publishTime)	Compute the cursor of the first message with publish time greater than or equal to the specified publish time, for a topic partition.
com.google.api.core.ApiFuture<Optional<Cursor>>	TopicStatsClientImpl.computeCursorForPublishTime(TopicPath path, Partition partition, com.google.protobuf.Timestamp publishTime)
com.google.api.core.ApiFuture<Cursor>	TopicStatsClient.computeHeadCursor(TopicPath path, Partition partition)	Compute the head cursor for the partition.
com.google.api.core.ApiFuture<Cursor>	TopicStatsClientImpl.computeHeadCursor(TopicPath path, Partition partition)

Uses of Cursor in com.google.cloud.pubsublite.proto

Methods in com.google.cloud.pubsublite.proto that return Cursor

Modifier and Type	Method	Description
Cursor	Cursor.Builder.build()
Cursor	Cursor.Builder.buildPartial()
Cursor	CommitCursorRequest.Builder.getCursor()	The new value for the committed cursor.
Cursor	CommitCursorRequest.getCursor()	The new value for the committed cursor.
Cursor	CommitCursorRequestOrBuilder.getCursor()	The new value for the committed cursor.
Cursor	ComputeTimeCursorResponse.Builder.getCursor()	If present, the cursor references the first message with time greater than or equal to the specified target time.
Cursor	ComputeTimeCursorResponse.getCursor()	If present, the cursor references the first message with time greater than or equal to the specified target time.
Cursor	ComputeTimeCursorResponseOrBuilder.getCursor()	If present, the cursor references the first message with time greater than or equal to the specified target time.
Cursor	InitialSubscribeResponse.Builder.getCursor()	The cursor from which the subscriber will start receiving messages once flow control tokens become available.
Cursor	InitialSubscribeResponse.getCursor()	The cursor from which the subscriber will start receiving messages once flow control tokens become available.
Cursor	InitialSubscribeResponseOrBuilder.getCursor()	The cursor from which the subscriber will start receiving messages once flow control tokens become available.
Cursor	PartitionCursor.Builder.getCursor()	The value of the cursor.
Cursor	PartitionCursor.getCursor()	The value of the cursor.
Cursor	PartitionCursorOrBuilder.getCursor()	The value of the cursor.
Cursor	SeekRequest.Builder.getCursor()	A target corresponding to the cursor, pointing to anywhere in the topic partition.
Cursor	SeekRequest.getCursor()	A target corresponding to the cursor, pointing to anywhere in the topic partition.
Cursor	SeekRequestOrBuilder.getCursor()	A target corresponding to the cursor, pointing to anywhere in the topic partition.
Cursor	SeekResponse.Builder.getCursor()	The new delivery cursor for the current stream.
Cursor	SeekResponse.getCursor()	The new delivery cursor for the current stream.
Cursor	SeekResponseOrBuilder.getCursor()	The new delivery cursor for the current stream.
Cursor	SequencedCommitCursorRequest.Builder.getCursor()	The new value for the committed cursor.
Cursor	SequencedCommitCursorRequest.getCursor()	The new value for the committed cursor.
Cursor	SequencedCommitCursorRequestOrBuilder.getCursor()	The new value for the committed cursor.
Cursor	SequencedMessage.Builder.getCursor()	The position of a message within the partition where it is stored.
Cursor	SequencedMessage.getCursor()	The position of a message within the partition where it is stored.
Cursor	SequencedMessageOrBuilder.getCursor()	The position of a message within the partition where it is stored.
static Cursor	Cursor.getDefaultInstance()
Cursor	Cursor.Builder.getDefaultInstanceForType()
Cursor	Cursor.getDefaultInstanceForType()
Cursor	ComputeMessageStatsRequest.Builder.getEndCursor()	The exclusive end of the range.
Cursor	ComputeMessageStatsRequest.getEndCursor()	The exclusive end of the range.
Cursor	ComputeMessageStatsRequestOrBuilder.getEndCursor()	The exclusive end of the range.
Cursor	ComputeHeadCursorResponse.Builder.getHeadCursor()	The head cursor.
Cursor	ComputeHeadCursorResponse.getHeadCursor()	The head cursor.
Cursor	ComputeHeadCursorResponseOrBuilder.getHeadCursor()	The head cursor.
Cursor	ComputeMessageStatsRequest.Builder.getStartCursor()	The inclusive start of the range.
Cursor	ComputeMessageStatsRequest.getStartCursor()	The inclusive start of the range.
Cursor	ComputeMessageStatsRequestOrBuilder.getStartCursor()	The inclusive start of the range.
Cursor	MessagePublishResponse.Builder.getStartCursor()	The cursor of the first published message in the batch.
Cursor	MessagePublishResponse.CursorRange.Builder.getStartCursor()	The cursor of the message at the start index.
Cursor	MessagePublishResponse.CursorRange.getStartCursor()	The cursor of the message at the start index.
Cursor	MessagePublishResponse.CursorRangeOrBuilder.getStartCursor()	The cursor of the message at the start index.
Cursor	MessagePublishResponse.getStartCursor()	The cursor of the first published message in the batch.
Cursor	MessagePublishResponseOrBuilder.getStartCursor()	The cursor of the first published message in the batch.
static Cursor	Cursor.parseDelimitedFrom(InputStream input)
static Cursor	Cursor.parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Cursor	Cursor.parseFrom(byte[] data)
static Cursor	Cursor.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Cursor	Cursor.parseFrom(com.google.protobuf.ByteString data)
static Cursor	Cursor.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Cursor	Cursor.parseFrom(com.google.protobuf.CodedInputStream input)
static Cursor	Cursor.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Cursor	Cursor.parseFrom(InputStream input)
static Cursor	Cursor.parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Cursor	Cursor.parseFrom(ByteBuffer data)
static Cursor	Cursor.parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

Methods in com.google.cloud.pubsublite.proto that return types with arguments of type Cursor

Modifier and Type	Method	Description
com.google.protobuf.Parser<Cursor>	Cursor.getParserForType()
static com.google.protobuf.Parser<Cursor>	Cursor.parser()

Methods in com.google.cloud.pubsublite.proto with parameters of type Cursor

Modifier and Type	Method	Description
CommitCursorRequest.Builder	CommitCursorRequest.Builder.mergeCursor(Cursor value)	The new value for the committed cursor.
ComputeTimeCursorResponse.Builder	ComputeTimeCursorResponse.Builder.mergeCursor(Cursor value)	If present, the cursor references the first message with time greater than or equal to the specified target time.
InitialSubscribeResponse.Builder	InitialSubscribeResponse.Builder.mergeCursor(Cursor value)	The cursor from which the subscriber will start receiving messages once flow control tokens become available.
PartitionCursor.Builder	PartitionCursor.Builder.mergeCursor(Cursor value)	The value of the cursor.
SeekRequest.Builder	SeekRequest.Builder.mergeCursor(Cursor value)	A target corresponding to the cursor, pointing to anywhere in the topic partition.
SeekResponse.Builder	SeekResponse.Builder.mergeCursor(Cursor value)	The new delivery cursor for the current stream.
SequencedCommitCursorRequest.Builder	SequencedCommitCursorRequest.Builder.mergeCursor(Cursor value)	The new value for the committed cursor.
SequencedMessage.Builder	SequencedMessage.Builder.mergeCursor(Cursor value)	The position of a message within the partition where it is stored.
ComputeMessageStatsRequest.Builder	ComputeMessageStatsRequest.Builder.mergeEndCursor(Cursor value)	The exclusive end of the range.
Cursor.Builder	Cursor.Builder.mergeFrom(Cursor other)
ComputeHeadCursorResponse.Builder	ComputeHeadCursorResponse.Builder.mergeHeadCursor(Cursor value)	The head cursor.
ComputeMessageStatsRequest.Builder	ComputeMessageStatsRequest.Builder.mergeStartCursor(Cursor value)	The inclusive start of the range.
MessagePublishResponse.Builder	MessagePublishResponse.Builder.mergeStartCursor(Cursor value)	The cursor of the first published message in the batch.
MessagePublishResponse.CursorRange.Builder	MessagePublishResponse.CursorRange.Builder.mergeStartCursor(Cursor value)	The cursor of the message at the start index.
static Cursor.Builder	Cursor.newBuilder(Cursor prototype)
CommitCursorRequest.Builder	CommitCursorRequest.Builder.setCursor(Cursor value)	The new value for the committed cursor.
ComputeTimeCursorResponse.Builder	ComputeTimeCursorResponse.Builder.setCursor(Cursor value)	If present, the cursor references the first message with time greater than or equal to the specified target time.
InitialSubscribeResponse.Builder	InitialSubscribeResponse.Builder.setCursor(Cursor value)	The cursor from which the subscriber will start receiving messages once flow control tokens become available.
PartitionCursor.Builder	PartitionCursor.Builder.setCursor(Cursor value)	The value of the cursor.
SeekRequest.Builder	SeekRequest.Builder.setCursor(Cursor value)	A target corresponding to the cursor, pointing to anywhere in the topic partition.
SeekResponse.Builder	SeekResponse.Builder.setCursor(Cursor value)	The new delivery cursor for the current stream.
SequencedCommitCursorRequest.Builder	SequencedCommitCursorRequest.Builder.setCursor(Cursor value)	The new value for the committed cursor.
SequencedMessage.Builder	SequencedMessage.Builder.setCursor(Cursor value)	The position of a message within the partition where it is stored.
ComputeMessageStatsRequest.Builder	ComputeMessageStatsRequest.Builder.setEndCursor(Cursor value)	The exclusive end of the range.
ComputeHeadCursorResponse.Builder	ComputeHeadCursorResponse.Builder.setHeadCursor(Cursor value)	The head cursor.
ComputeMessageStatsRequest.Builder	ComputeMessageStatsRequest.Builder.setStartCursor(Cursor value)	The inclusive start of the range.
MessagePublishResponse.Builder	MessagePublishResponse.Builder.setStartCursor(Cursor value)	The cursor of the first published message in the batch.
MessagePublishResponse.CursorRange.Builder	MessagePublishResponse.CursorRange.Builder.setStartCursor(Cursor value)	The cursor of the message at the start index.