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
Inherited Members
com.google.protobuf.GeneratedMessageV3.Builder.getUnknownFieldSetBuilder()
com.google.protobuf.GeneratedMessageV3.Builder.internalGetMapFieldReflection(int)
com.google.protobuf.GeneratedMessageV3.Builder.internalGetMutableMapFieldReflection(int)
com.google.protobuf.GeneratedMessageV3.Builder.mergeUnknownLengthDelimitedField(int,com.google.protobuf.ByteString)
com.google.protobuf.GeneratedMessageV3.Builder.mergeUnknownVarintField(int,int)
com.google.protobuf.GeneratedMessageV3.Builder.parseUnknownField(com.google.protobuf.CodedInputStream,com.google.protobuf.ExtensionRegistryLite,int)
com.google.protobuf.GeneratedMessageV3.Builder.setUnknownFieldSetBuilder(com.google.protobuf.UnknownFieldSet.Builder)
Static Methods
getDescriptor()
public static final Descriptors.Descriptor getDescriptor()
Methods
addRepeatedField(Descriptors.FieldDescriptor field, Object value)
public InitialSubscribeRequest.Builder addRepeatedField(Descriptors.FieldDescriptor field, Object value)
Overrides
build()
public InitialSubscribeRequest build()
buildPartial()
public InitialSubscribeRequest buildPartial()
clear()
public InitialSubscribeRequest.Builder clear()
Overrides
clearField(Descriptors.FieldDescriptor field)
public InitialSubscribeRequest.Builder clearField(Descriptors.FieldDescriptor field)
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];
clearOneof(Descriptors.OneofDescriptor oneof)
public InitialSubscribeRequest.Builder clearOneof(Descriptors.OneofDescriptor oneof)
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;
clearSubscription()
public InitialSubscribeRequest.Builder clearSubscription()
The subscription from which to receive messages.
string subscription = 1;
clone()
public InitialSubscribeRequest.Builder clone()
Overrides
getDefaultInstanceForType()
public InitialSubscribeRequest getDefaultInstanceForType()
getDescriptorForType()
public Descriptors.Descriptor getDescriptorForType()
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 |
| Type |
Description |
SeekRequest |
The initialLocation.
|
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];
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];
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()
Overrides
isInitialized()
public final boolean isInitialized()
Overrides
mergeFrom(InitialSubscribeRequest other)
public InitialSubscribeRequest.Builder mergeFrom(InitialSubscribeRequest other)
public InitialSubscribeRequest.Builder mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
Overrides
mergeFrom(Message other)
public InitialSubscribeRequest.Builder mergeFrom(Message other)
| Parameter |
| Name |
Description |
other |
Message
|
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];
mergeUnknownFields(UnknownFieldSet unknownFields)
public final InitialSubscribeRequest.Builder mergeUnknownFields(UnknownFieldSet unknownFields)
Overrides
setField(Descriptors.FieldDescriptor field, Object value)
public InitialSubscribeRequest.Builder setField(Descriptors.FieldDescriptor field, Object value)
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];
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];
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.
|
setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)
public InitialSubscribeRequest.Builder setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)
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.
|
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.
|
setUnknownFields(UnknownFieldSet unknownFields)
public final InitialSubscribeRequest.Builder setUnknownFields(UnknownFieldSet unknownFields)
Overrides
