public final class SubscribeRequest extends GeneratedMessageV3 implements SubscribeRequestOrBuilder
A request sent from the client to the server on a stream.
Protobuf type google.cloud.pubsublite.v1.SubscribeRequest
Inherited Members
com.google.protobuf.GeneratedMessageV3.<ListT>makeMutableCopy(ListT)
com.google.protobuf.GeneratedMessageV3.<ListT>makeMutableCopy(ListT,int)
com.google.protobuf.GeneratedMessageV3.<T>emptyList(java.lang.Class<T>)
com.google.protobuf.GeneratedMessageV3.internalGetMapFieldReflection(int)
Static Fields
FLOW_CONTROL_FIELD_NUMBER
public static final int FLOW_CONTROL_FIELD_NUMBER
Field Value |
---|
Type | Description |
int | |
INITIAL_FIELD_NUMBER
public static final int INITIAL_FIELD_NUMBER
Field Value |
---|
Type | Description |
int | |
SEEK_FIELD_NUMBER
public static final int SEEK_FIELD_NUMBER
Field Value |
---|
Type | Description |
int | |
Static Methods
getDefaultInstance()
public static SubscribeRequest getDefaultInstance()
getDescriptor()
public static final Descriptors.Descriptor getDescriptor()
newBuilder()
public static SubscribeRequest.Builder newBuilder()
newBuilder(SubscribeRequest prototype)
public static SubscribeRequest.Builder newBuilder(SubscribeRequest prototype)
public static SubscribeRequest parseDelimitedFrom(InputStream input)
public static SubscribeRequest parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
parseFrom(byte[] data)
public static SubscribeRequest parseFrom(byte[] data)
Parameter |
---|
Name | Description |
data | byte[]
|
parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
public static SubscribeRequest parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
parseFrom(ByteString data)
public static SubscribeRequest parseFrom(ByteString data)
parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static SubscribeRequest parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static SubscribeRequest parseFrom(CodedInputStream input)
public static SubscribeRequest parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
public static SubscribeRequest parseFrom(InputStream input)
public static SubscribeRequest parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
parseFrom(ByteBuffer data)
public static SubscribeRequest parseFrom(ByteBuffer data)
parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
public static SubscribeRequest parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
parser()
public static Parser<SubscribeRequest> parser()
Methods
equals(Object obj)
public boolean equals(Object obj)
Parameter |
---|
Name | Description |
obj | Object
|
Overrides
getDefaultInstanceForType()
public SubscribeRequest getDefaultInstanceForType()
getFlowControl()
public FlowControlRequest getFlowControl()
Request to grant tokens to the server,
.google.cloud.pubsublite.v1.FlowControlRequest flow_control = 3;
getFlowControlOrBuilder()
public FlowControlRequestOrBuilder getFlowControlOrBuilder()
Request to grant tokens to the server,
.google.cloud.pubsublite.v1.FlowControlRequest flow_control = 3;
getInitial()
public InitialSubscribeRequest getInitial()
Initial request on the stream.
.google.cloud.pubsublite.v1.InitialSubscribeRequest initial = 1;
getInitialOrBuilder()
public InitialSubscribeRequestOrBuilder getInitialOrBuilder()
Initial request on the stream.
.google.cloud.pubsublite.v1.InitialSubscribeRequest initial = 1;
getParserForType()
public Parser<SubscribeRequest> getParserForType()
Overrides
getRequestCase()
public SubscribeRequest.RequestCase getRequestCase()
getSeek()
public SeekRequest getSeek()
Request to update the stream's delivery cursor.
.google.cloud.pubsublite.v1.SeekRequest seek = 2;
getSeekOrBuilder()
public SeekRequestOrBuilder getSeekOrBuilder()
Request to update the stream's delivery cursor.
.google.cloud.pubsublite.v1.SeekRequest seek = 2;
getSerializedSize()
public int getSerializedSize()
Returns |
---|
Type | Description |
int | |
Overrides
hasFlowControl()
public boolean hasFlowControl()
Request to grant tokens to the server,
.google.cloud.pubsublite.v1.FlowControlRequest flow_control = 3;
Returns |
---|
Type | Description |
boolean | Whether the flowControl field is set.
|
hasInitial()
public boolean hasInitial()
Initial request on the stream.
.google.cloud.pubsublite.v1.InitialSubscribeRequest initial = 1;
Returns |
---|
Type | Description |
boolean | Whether the initial field is set.
|
hasSeek()
Request to update the stream's delivery cursor.
.google.cloud.pubsublite.v1.SeekRequest seek = 2;
Returns |
---|
Type | Description |
boolean | Whether the seek field is set.
|
hashCode()
Returns |
---|
Type | Description |
int | |
Overrides
internalGetFieldAccessorTable()
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Overrides
isInitialized()
public final boolean isInitialized()
Overrides
newBuilderForType()
public SubscribeRequest.Builder newBuilderForType()
newBuilderForType(GeneratedMessageV3.BuilderParent parent)
protected SubscribeRequest.Builder newBuilderForType(GeneratedMessageV3.BuilderParent parent)
Overrides
newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
protected Object newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
Overrides
toBuilder()
public SubscribeRequest.Builder toBuilder()
writeTo(CodedOutputStream output)
public void writeTo(CodedOutputStream output)
Overrides