public static final class InitialSubscribeRequest.Builder extends GeneratedMessageV3.Builder<InitialSubscribeRequest.Builder> implements InitialSubscribeRequestOrBuilder
The first request that must be sent on a newly-opened stream. The client must
wait for the response before sending subsequent requests on the stream.
Protobuf type google.cloud.pubsublite.v1.InitialSubscribeRequest
Static Methods
getDescriptor()
public static final Descriptors.Descriptor getDescriptor()
Returns
Methods
addRepeatedField(Descriptors.FieldDescriptor field, Object value)
public InitialSubscribeRequest.Builder addRepeatedField(Descriptors.FieldDescriptor field, Object value)
Parameters
Returns
Overrides
build()
public InitialSubscribeRequest build()
Returns
buildPartial()
public InitialSubscribeRequest buildPartial()
Returns
clear()
public InitialSubscribeRequest.Builder clear()
Returns
Overrides
clearField(Descriptors.FieldDescriptor field)
public InitialSubscribeRequest.Builder clearField(Descriptors.FieldDescriptor field)
Parameter
Returns
Overrides
clearInitialLocation()
public InitialSubscribeRequest.Builder clearInitialLocation()
Optional. Initial target location within the message backlog. If not set, messages
will be delivered from the commit cursor for the given subscription and
partition.
.google.cloud.pubsublite.v1.SeekRequest initial_location = 4 [(.google.api.field_behavior) = OPTIONAL];
Returns
clearOneof(Descriptors.OneofDescriptor oneof)
public InitialSubscribeRequest.Builder clearOneof(Descriptors.OneofDescriptor oneof)
Parameter
Returns
Overrides
clearPartition()
public InitialSubscribeRequest.Builder clearPartition()
The partition from which to receive messages. Partitions are zero indexed,
so partition
must be in the range [0, topic.num_partitions).
int64 partition = 2;
Returns
clearSubscription()
public InitialSubscribeRequest.Builder clearSubscription()
The subscription from which to receive messages.
string subscription = 1;
Returns
clone()
public InitialSubscribeRequest.Builder clone()
Returns
Overrides
getDefaultInstanceForType()
public InitialSubscribeRequest getDefaultInstanceForType()
Returns
getDescriptorForType()
public Descriptors.Descriptor getDescriptorForType()
Returns
Overrides
getInitialLocation()
public SeekRequest getInitialLocation()
Optional. Initial target location within the message backlog. If not set, messages
will be delivered from the commit cursor for the given subscription and
partition.
.google.cloud.pubsublite.v1.SeekRequest initial_location = 4 [(.google.api.field_behavior) = OPTIONAL];
Returns
getInitialLocationBuilder()
public SeekRequest.Builder getInitialLocationBuilder()
Optional. Initial target location within the message backlog. If not set, messages
will be delivered from the commit cursor for the given subscription and
partition.
.google.cloud.pubsublite.v1.SeekRequest initial_location = 4 [(.google.api.field_behavior) = OPTIONAL];
Returns
getInitialLocationOrBuilder()
public SeekRequestOrBuilder getInitialLocationOrBuilder()
Optional. Initial target location within the message backlog. If not set, messages
will be delivered from the commit cursor for the given subscription and
partition.
.google.cloud.pubsublite.v1.SeekRequest initial_location = 4 [(.google.api.field_behavior) = OPTIONAL];
Returns
getPartition()
public long getPartition()
The partition from which to receive messages. Partitions are zero indexed,
so partition
must be in the range [0, topic.num_partitions).
int64 partition = 2;
Returns
Type | Description |
long | The partition.
|
getSubscription()
public String getSubscription()
The subscription from which to receive messages.
string subscription = 1;
Returns
Type | Description |
String | The subscription.
|
getSubscriptionBytes()
public ByteString getSubscriptionBytes()
The subscription from which to receive messages.
string subscription = 1;
Returns
Type | Description |
ByteString | The bytes for subscription.
|
hasInitialLocation()
public boolean hasInitialLocation()
Optional. Initial target location within the message backlog. If not set, messages
will be delivered from the commit cursor for the given subscription and
partition.
.google.cloud.pubsublite.v1.SeekRequest initial_location = 4 [(.google.api.field_behavior) = OPTIONAL];
Returns
Type | Description |
boolean | Whether the initialLocation field is set.
|
internalGetFieldAccessorTable()
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Returns
Overrides
isInitialized()
public final boolean isInitialized()
Returns
Overrides
mergeFrom(InitialSubscribeRequest other)
public InitialSubscribeRequest.Builder mergeFrom(InitialSubscribeRequest other)
Parameter
Returns
public InitialSubscribeRequest.Builder mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Overrides
Exceptions
mergeFrom(Message other)
public InitialSubscribeRequest.Builder mergeFrom(Message other)
Parameter
Returns
Overrides
mergeInitialLocation(SeekRequest value)
public InitialSubscribeRequest.Builder mergeInitialLocation(SeekRequest value)
Optional. Initial target location within the message backlog. If not set, messages
will be delivered from the commit cursor for the given subscription and
partition.
.google.cloud.pubsublite.v1.SeekRequest initial_location = 4 [(.google.api.field_behavior) = OPTIONAL];
Parameter
Returns
mergeUnknownFields(UnknownFieldSet unknownFields)
public final InitialSubscribeRequest.Builder mergeUnknownFields(UnknownFieldSet unknownFields)
Parameter
Returns
Overrides
setField(Descriptors.FieldDescriptor field, Object value)
public InitialSubscribeRequest.Builder setField(Descriptors.FieldDescriptor field, Object value)
Parameters
Returns
Overrides
setInitialLocation(SeekRequest value)
public InitialSubscribeRequest.Builder setInitialLocation(SeekRequest value)
Optional. Initial target location within the message backlog. If not set, messages
will be delivered from the commit cursor for the given subscription and
partition.
.google.cloud.pubsublite.v1.SeekRequest initial_location = 4 [(.google.api.field_behavior) = OPTIONAL];
Parameter
Returns
setInitialLocation(SeekRequest.Builder builderForValue)
public InitialSubscribeRequest.Builder setInitialLocation(SeekRequest.Builder builderForValue)
Optional. Initial target location within the message backlog. If not set, messages
will be delivered from the commit cursor for the given subscription and
partition.
.google.cloud.pubsublite.v1.SeekRequest initial_location = 4 [(.google.api.field_behavior) = OPTIONAL];
Parameter
Returns
setPartition(long value)
public InitialSubscribeRequest.Builder setPartition(long value)
The partition from which to receive messages. Partitions are zero indexed,
so partition
must be in the range [0, topic.num_partitions).
int64 partition = 2;
Parameter
Name | Description |
value | long
The partition to set.
|
Returns
setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)
public InitialSubscribeRequest.Builder setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)
Parameters
Returns
Overrides
setSubscription(String value)
public InitialSubscribeRequest.Builder setSubscription(String value)
The subscription from which to receive messages.
string subscription = 1;
Parameter
Name | Description |
value | String
The subscription to set.
|
Returns
setSubscriptionBytes(ByteString value)
public InitialSubscribeRequest.Builder setSubscriptionBytes(ByteString value)
The subscription from which to receive messages.
string subscription = 1;
Parameter
Name | Description |
value | ByteString
The bytes for subscription to set.
|
Returns
setUnknownFields(UnknownFieldSet unknownFields)
public final InitialSubscribeRequest.Builder setUnknownFields(UnknownFieldSet unknownFields)
Parameter
Returns
Overrides