Class SubscribeRequest
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite
-
- com.google.protobuf.AbstractMessage
-
- com.google.protobuf.GeneratedMessageV3
-
- com.google.cloud.pubsublite.proto.SubscribeRequest
-
- All Implemented Interfaces:
SubscribeRequestOrBuilder
,com.google.protobuf.Message
,com.google.protobuf.MessageLite
,com.google.protobuf.MessageLiteOrBuilder
,com.google.protobuf.MessageOrBuilder
,Serializable
public final class SubscribeRequest extends com.google.protobuf.GeneratedMessageV3 implements SubscribeRequestOrBuilder
A request sent from the client to the server on a stream.
Protobuf typegoogle.cloud.pubsublite.v1.SubscribeRequest
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
SubscribeRequest.Builder
A request sent from the client to the server on a stream.static class
SubscribeRequest.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 int
FLOW_CONTROL_FIELD_NUMBER
static int
INITIAL_FIELD_NUMBER
static int
SEEK_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object obj)
static SubscribeRequest
getDefaultInstance()
SubscribeRequest
getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor
getDescriptor()
FlowControlRequest
getFlowControl()
Request to grant tokens to the server,FlowControlRequestOrBuilder
getFlowControlOrBuilder()
Request to grant tokens to the server,InitialSubscribeRequest
getInitial()
Initial request on the stream.InitialSubscribeRequestOrBuilder
getInitialOrBuilder()
Initial request on the stream.com.google.protobuf.Parser<SubscribeRequest>
getParserForType()
SubscribeRequest.RequestCase
getRequestCase()
SeekRequest
getSeek()
Request to update the stream's delivery cursor.SeekRequestOrBuilder
getSeekOrBuilder()
Request to update the stream's delivery cursor.int
getSerializedSize()
boolean
hasFlowControl()
Request to grant tokens to the server,int
hashCode()
boolean
hasInitial()
Initial request on the stream.boolean
hasSeek()
Request to update the stream's delivery cursor.protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable()
boolean
isInitialized()
static SubscribeRequest.Builder
newBuilder()
static SubscribeRequest.Builder
newBuilder(SubscribeRequest prototype)
SubscribeRequest.Builder
newBuilderForType()
protected SubscribeRequest.Builder
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
protected Object
newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
static SubscribeRequest
parseDelimitedFrom(InputStream input)
static SubscribeRequest
parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SubscribeRequest
parseFrom(byte[] data)
static SubscribeRequest
parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SubscribeRequest
parseFrom(com.google.protobuf.ByteString data)
static SubscribeRequest
parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SubscribeRequest
parseFrom(com.google.protobuf.CodedInputStream input)
static SubscribeRequest
parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SubscribeRequest
parseFrom(InputStream input)
static SubscribeRequest
parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SubscribeRequest
parseFrom(ByteBuffer data)
static SubscribeRequest
parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<SubscribeRequest>
parser()
SubscribeRequest.Builder
toBuilder()
void
writeTo(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
-
SEEK_FIELD_NUMBER
public static final int SEEK_FIELD_NUMBER
- See Also:
- Constant Field Values
-
FLOW_CONTROL_FIELD_NUMBER
public static final int FLOW_CONTROL_FIELD_NUMBER
- See Also:
- Constant Field Values
-
-
Method Detail
-
newInstance
protected Object newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
- Overrides:
newInstance
in classcom.google.protobuf.GeneratedMessageV3
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTable
in classcom.google.protobuf.GeneratedMessageV3
-
getRequestCase
public SubscribeRequest.RequestCase getRequestCase()
- Specified by:
getRequestCase
in interfaceSubscribeRequestOrBuilder
-
hasInitial
public boolean hasInitial()
Initial request on the stream.
.google.cloud.pubsublite.v1.InitialSubscribeRequest initial = 1;
- Specified by:
hasInitial
in interfaceSubscribeRequestOrBuilder
- Returns:
- Whether the initial field is set.
-
getInitial
public InitialSubscribeRequest getInitial()
Initial request on the stream.
.google.cloud.pubsublite.v1.InitialSubscribeRequest initial = 1;
- Specified by:
getInitial
in interfaceSubscribeRequestOrBuilder
- Returns:
- The initial.
-
getInitialOrBuilder
public InitialSubscribeRequestOrBuilder getInitialOrBuilder()
Initial request on the stream.
.google.cloud.pubsublite.v1.InitialSubscribeRequest initial = 1;
- Specified by:
getInitialOrBuilder
in interfaceSubscribeRequestOrBuilder
-
hasSeek
public boolean hasSeek()
Request to update the stream's delivery cursor.
.google.cloud.pubsublite.v1.SeekRequest seek = 2;
- Specified by:
hasSeek
in interfaceSubscribeRequestOrBuilder
- Returns:
- Whether the seek field is set.
-
getSeek
public SeekRequest getSeek()
Request to update the stream's delivery cursor.
.google.cloud.pubsublite.v1.SeekRequest seek = 2;
- Specified by:
getSeek
in interfaceSubscribeRequestOrBuilder
- Returns:
- The seek.
-
getSeekOrBuilder
public SeekRequestOrBuilder getSeekOrBuilder()
Request to update the stream's delivery cursor.
.google.cloud.pubsublite.v1.SeekRequest seek = 2;
- Specified by:
getSeekOrBuilder
in interfaceSubscribeRequestOrBuilder
-
hasFlowControl
public boolean hasFlowControl()
Request to grant tokens to the server,
.google.cloud.pubsublite.v1.FlowControlRequest flow_control = 3;
- Specified by:
hasFlowControl
in interfaceSubscribeRequestOrBuilder
- Returns:
- Whether the flowControl field is set.
-
getFlowControl
public FlowControlRequest getFlowControl()
Request to grant tokens to the server,
.google.cloud.pubsublite.v1.FlowControlRequest flow_control = 3;
- Specified by:
getFlowControl
in interfaceSubscribeRequestOrBuilder
- Returns:
- The flowControl.
-
getFlowControlOrBuilder
public FlowControlRequestOrBuilder getFlowControlOrBuilder()
Request to grant tokens to the server,
.google.cloud.pubsublite.v1.FlowControlRequest flow_control = 3;
- Specified by:
getFlowControlOrBuilder
in interfaceSubscribeRequestOrBuilder
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitialized
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in classcom.google.protobuf.GeneratedMessageV3
-
writeTo
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
- Specified by:
writeTo
in interfacecom.google.protobuf.MessageLite
- Overrides:
writeTo
in classcom.google.protobuf.GeneratedMessageV3
- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSize
in interfacecom.google.protobuf.MessageLite
- Overrides:
getSerializedSize
in classcom.google.protobuf.GeneratedMessageV3
-
equals
public boolean equals(Object obj)
- Specified by:
equals
in interfacecom.google.protobuf.Message
- Overrides:
equals
in classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()
- Specified by:
hashCode
in interfacecom.google.protobuf.Message
- Overrides:
hashCode
in classcom.google.protobuf.AbstractMessage
-
parseFrom
public static SubscribeRequest parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static SubscribeRequest parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static SubscribeRequest parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static SubscribeRequest parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static SubscribeRequest parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static SubscribeRequest parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static SubscribeRequest parseFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static SubscribeRequest parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static SubscribeRequest parseDelimitedFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static SubscribeRequest parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseFrom
public static SubscribeRequest parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static SubscribeRequest parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
newBuilderForType
public SubscribeRequest.Builder newBuilderForType()
- Specified by:
newBuilderForType
in interfacecom.google.protobuf.Message
- Specified by:
newBuilderForType
in interfacecom.google.protobuf.MessageLite
-
newBuilder
public static SubscribeRequest.Builder newBuilder()
-
newBuilder
public static SubscribeRequest.Builder newBuilder(SubscribeRequest prototype)
-
toBuilder
public SubscribeRequest.Builder toBuilder()
- Specified by:
toBuilder
in interfacecom.google.protobuf.Message
- Specified by:
toBuilder
in interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected SubscribeRequest.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
- Specified by:
newBuilderForType
in classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstance
public static SubscribeRequest getDefaultInstance()
-
parser
public static com.google.protobuf.Parser<SubscribeRequest> parser()
-
getParserForType
public com.google.protobuf.Parser<SubscribeRequest> getParserForType()
- Specified by:
getParserForType
in interfacecom.google.protobuf.Message
- Specified by:
getParserForType
in interfacecom.google.protobuf.MessageLite
- Overrides:
getParserForType
in classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstanceForType
public SubscribeRequest getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageOrBuilder
-
-