Class StreamingCommitCursorRequest
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite
-
- com.google.protobuf.AbstractMessage
-
- com.google.protobuf.GeneratedMessageV3
-
- com.google.cloud.pubsublite.proto.StreamingCommitCursorRequest
-
- All Implemented Interfaces:
StreamingCommitCursorRequestOrBuilder,com.google.protobuf.Message,com.google.protobuf.MessageLite,com.google.protobuf.MessageLiteOrBuilder,com.google.protobuf.MessageOrBuilder,Serializable
public final class StreamingCommitCursorRequest extends com.google.protobuf.GeneratedMessageV3 implements StreamingCommitCursorRequestOrBuilder
A request sent from the client to the server on a stream.
Protobuf typegoogle.cloud.pubsublite.v1.StreamingCommitCursorRequest- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classStreamingCommitCursorRequest.BuilderA request sent from the client to the server on a stream.static classStreamingCommitCursorRequest.RequestCase-
Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessageV3
com.google.protobuf.GeneratedMessageV3.BuilderParent, com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT,BuilderT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable, com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter
-
-
Field Summary
Fields Modifier and Type Field Description static intCOMMIT_FIELD_NUMBERstatic intINITIAL_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object obj)SequencedCommitCursorRequestgetCommit()Request to commit a new cursor value.SequencedCommitCursorRequestOrBuildergetCommitOrBuilder()Request to commit a new cursor value.static StreamingCommitCursorRequestgetDefaultInstance()StreamingCommitCursorRequestgetDefaultInstanceForType()static com.google.protobuf.Descriptors.DescriptorgetDescriptor()InitialCommitCursorRequestgetInitial()Initial request on the stream.InitialCommitCursorRequestOrBuildergetInitialOrBuilder()Initial request on the stream.com.google.protobuf.Parser<StreamingCommitCursorRequest>getParserForType()StreamingCommitCursorRequest.RequestCasegetRequestCase()intgetSerializedSize()booleanhasCommit()Request to commit a new cursor value.inthashCode()booleanhasInitial()Initial request on the stream.protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTableinternalGetFieldAccessorTable()booleanisInitialized()static StreamingCommitCursorRequest.BuildernewBuilder()static StreamingCommitCursorRequest.BuildernewBuilder(StreamingCommitCursorRequest prototype)StreamingCommitCursorRequest.BuildernewBuilderForType()protected StreamingCommitCursorRequest.BuildernewBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)protected ObjectnewInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)static StreamingCommitCursorRequestparseDelimitedFrom(InputStream input)static StreamingCommitCursorRequestparseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static StreamingCommitCursorRequestparseFrom(byte[] data)static StreamingCommitCursorRequestparseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static StreamingCommitCursorRequestparseFrom(com.google.protobuf.ByteString data)static StreamingCommitCursorRequestparseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static StreamingCommitCursorRequestparseFrom(com.google.protobuf.CodedInputStream input)static StreamingCommitCursorRequestparseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static StreamingCommitCursorRequestparseFrom(InputStream input)static StreamingCommitCursorRequestparseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static StreamingCommitCursorRequestparseFrom(ByteBuffer data)static StreamingCommitCursorRequestparseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static com.google.protobuf.Parser<StreamingCommitCursorRequest>parser()StreamingCommitCursorRequest.BuildertoBuilder()voidwriteTo(com.google.protobuf.CodedOutputStream output)-
Methods inherited from class com.google.protobuf.GeneratedMessageV3
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, internalGetMapField, isStringEmpty, makeExtensionsImmutable, makeMutableCopy, mergeFromAndMakeImmutableInternal, mutableCopy, mutableCopy, mutableCopy, mutableCopy, mutableCopy, newBooleanList, newBuilderForType, newDoubleList, newFloatList, newIntList, newLongList, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTag
-
Methods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
-
Methods inherited from class com.google.protobuf.AbstractMessageLite
addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
-
-
-
Field Detail
-
INITIAL_FIELD_NUMBER
public static final int INITIAL_FIELD_NUMBER
- See Also:
- Constant Field Values
-
COMMIT_FIELD_NUMBER
public static final int COMMIT_FIELD_NUMBER
- See Also:
- Constant Field Values
-
-
Method Detail
-
newInstance
protected Object newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
- Overrides:
newInstancein classcom.google.protobuf.GeneratedMessageV3
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTablein classcom.google.protobuf.GeneratedMessageV3
-
getRequestCase
public StreamingCommitCursorRequest.RequestCase getRequestCase()
- Specified by:
getRequestCasein interfaceStreamingCommitCursorRequestOrBuilder
-
hasInitial
public boolean hasInitial()
Initial request on the stream.
.google.cloud.pubsublite.v1.InitialCommitCursorRequest initial = 1;- Specified by:
hasInitialin interfaceStreamingCommitCursorRequestOrBuilder- Returns:
- Whether the initial field is set.
-
getInitial
public InitialCommitCursorRequest getInitial()
Initial request on the stream.
.google.cloud.pubsublite.v1.InitialCommitCursorRequest initial = 1;- Specified by:
getInitialin interfaceStreamingCommitCursorRequestOrBuilder- Returns:
- The initial.
-
getInitialOrBuilder
public InitialCommitCursorRequestOrBuilder getInitialOrBuilder()
Initial request on the stream.
.google.cloud.pubsublite.v1.InitialCommitCursorRequest initial = 1;- Specified by:
getInitialOrBuilderin interfaceStreamingCommitCursorRequestOrBuilder
-
hasCommit
public boolean hasCommit()
Request to commit a new cursor value.
.google.cloud.pubsublite.v1.SequencedCommitCursorRequest commit = 2;- Specified by:
hasCommitin interfaceStreamingCommitCursorRequestOrBuilder- Returns:
- Whether the commit field is set.
-
getCommit
public SequencedCommitCursorRequest getCommit()
Request to commit a new cursor value.
.google.cloud.pubsublite.v1.SequencedCommitCursorRequest commit = 2;- Specified by:
getCommitin interfaceStreamingCommitCursorRequestOrBuilder- Returns:
- The commit.
-
getCommitOrBuilder
public SequencedCommitCursorRequestOrBuilder getCommitOrBuilder()
Request to commit a new cursor value.
.google.cloud.pubsublite.v1.SequencedCommitCursorRequest commit = 2;- Specified by:
getCommitOrBuilderin interfaceStreamingCommitCursorRequestOrBuilder
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessageV3
-
writeTo
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException- Specified by:
writeToin interfacecom.google.protobuf.MessageLite- Overrides:
writeToin classcom.google.protobuf.GeneratedMessageV3- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSizein interfacecom.google.protobuf.MessageLite- Overrides:
getSerializedSizein classcom.google.protobuf.GeneratedMessageV3
-
equals
public boolean equals(Object obj)
- Specified by:
equalsin interfacecom.google.protobuf.Message- Overrides:
equalsin classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()
- Specified by:
hashCodein interfacecom.google.protobuf.Message- Overrides:
hashCodein classcom.google.protobuf.AbstractMessage
-
parseFrom
public static StreamingCommitCursorRequest parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static StreamingCommitCursorRequest parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static StreamingCommitCursorRequest parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static StreamingCommitCursorRequest parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static StreamingCommitCursorRequest parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static StreamingCommitCursorRequest parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static StreamingCommitCursorRequest parseFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static StreamingCommitCursorRequest parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static StreamingCommitCursorRequest parseDelimitedFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static StreamingCommitCursorRequest parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseFrom
public static StreamingCommitCursorRequest parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static StreamingCommitCursorRequest parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
newBuilderForType
public StreamingCommitCursorRequest.Builder newBuilderForType()
- Specified by:
newBuilderForTypein interfacecom.google.protobuf.Message- Specified by:
newBuilderForTypein interfacecom.google.protobuf.MessageLite
-
newBuilder
public static StreamingCommitCursorRequest.Builder newBuilder()
-
newBuilder
public static StreamingCommitCursorRequest.Builder newBuilder(StreamingCommitCursorRequest prototype)
-
toBuilder
public StreamingCommitCursorRequest.Builder toBuilder()
- Specified by:
toBuilderin interfacecom.google.protobuf.Message- Specified by:
toBuilderin interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected StreamingCommitCursorRequest.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
- Specified by:
newBuilderForTypein classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstance
public static StreamingCommitCursorRequest getDefaultInstance()
-
parser
public static com.google.protobuf.Parser<StreamingCommitCursorRequest> parser()
-
getParserForType
public com.google.protobuf.Parser<StreamingCommitCursorRequest> getParserForType()
- Specified by:
getParserForTypein interfacecom.google.protobuf.Message- Specified by:
getParserForTypein interfacecom.google.protobuf.MessageLite- Overrides:
getParserForTypein classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstanceForType
public StreamingCommitCursorRequest getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-
-