Skip to content

Commit e1f4bee

Browse files
yoshi-automationyoshi-automation
authored
chore: add grpc service config json (#193)
PiperOrigin-RevId: 325320185 Source-Author: Google APIs <[email protected]> Source-Date: Thu Aug 6 15:10:08 2020 -0700 Source-Repo: googleapis/googleapis Source-Sha: bea01b071d915207a58af2d0f000c5cb4b0177ae Source-Link: googleapis/googleapis@bea01b0
1 parent c8504c3 commit e1f4bee

File tree

11 files changed

+74
-81
lines changed

11 files changed

+74
-81
lines changed

‎google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/PartitionAssignmentServiceClient.java‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -31,9 +31,6 @@
3131
* Service Description: The service that a subscriber client application uses to determine which
3232
* partitions it should connect to.
3333
*
34-
* <p>This is an under development API being published to build client libraries. Users will not be
35-
* able to access it until fully launched.
36-
*
3734
* <p>This class provides the ability to make remote calls to the backing service through method
3835
* calls that map to API methods. Sample code to get started:
3936
*

‎google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/package-info.java‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -94,9 +94,6 @@
9494
* <p>Service Description: The service that a subscriber client application uses to determine which
9595
* partitions it should connect to.
9696
*
97-
* <p>This is an under development API being published to build client libraries. Users will not be
98-
* able to access it until fully launched.
99-
*
10097
* <p>Sample for PartitionAssignmentServiceClient:
10198
*
10299
* <pre>

‎google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/stub/AdminServiceStubSettings.java‎

Lines changed: 31 additions & 29 deletions
Original file line numberDiff line numberDiff line change
@@ -498,11 +498,11 @@ public static class Builder extends StubSettings.Builder<AdminServiceStubSetting
498498
ImmutableMap.Builder<String, ImmutableSet<StatusCode.Code>> definitions =
499499
ImmutableMap.builder();
500500
definitions.put(
501-
"idempotent",
501+
"retry_policy_1_codes",
502502
ImmutableSet.copyOf(
503503
Lists.<StatusCode.Code>newArrayList(
504504
StatusCode.Code.DEADLINE_EXCEEDED, StatusCode.Code.UNAVAILABLE)));
505-
definitions.put("non_idempotent", ImmutableSet.copyOf(Lists.<StatusCode.Code>newArrayList()));
505+
definitions.put("no_retry_codes", ImmutableSet.copyOf(Lists.<StatusCode.Code>newArrayList()));
506506
RETRYABLE_CODE_DEFINITIONS = definitions.build();
507507
}
508508

@@ -516,12 +516,14 @@ public static class Builder extends StubSettings.Builder<AdminServiceStubSetting
516516
.setInitialRetryDelay(Duration.ofMillis(100L))
517517
.setRetryDelayMultiplier(1.3)
518518
.setMaxRetryDelay(Duration.ofMillis(60000L))
519-
.setInitialRpcTimeout(Duration.ofMillis(20000L))
519+
.setInitialRpcTimeout(Duration.ofMillis(600000L))
520520
.setRpcTimeoutMultiplier(1.0)
521-
.setMaxRpcTimeout(Duration.ofMillis(20000L))
521+
.setMaxRpcTimeout(Duration.ofMillis(600000L))
522522
.setTotalTimeout(Duration.ofMillis(600000L))
523523
.build();
524-
definitions.put("default", settings);
524+
definitions.put("retry_policy_1_params", settings);
525+
settings = RetrySettings.newBuilder().setRpcTimeoutMultiplier(1.0).build();
526+
definitions.put("no_retry_params", settings);
525527
RETRY_PARAM_DEFINITIONS = definitions.build();
526528
}
527529

@@ -588,63 +590,63 @@ private static Builder initDefaults(Builder builder) {
588590

589591
builder
590592
.createTopicSettings()
591-
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
592-
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
593+
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
594+
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
593595

594596
builder
595597
.getTopicSettings()
596-
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
597-
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
598+
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
599+
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
598600

599601
builder
600602
.getTopicPartitionsSettings()
601-
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
602-
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
603+
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
604+
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
603605

604606
builder
605607
.listTopicsSettings()
606-
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
607-
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
608+
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
609+
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
608610

609611
builder
610612
.updateTopicSettings()
611-
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
612-
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
613+
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
614+
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
613615

614616
builder
615617
.deleteTopicSettings()
616-
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
617-
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
618+
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
619+
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
618620

619621
builder
620622
.listTopicSubscriptionsSettings()
621-
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
622-
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
623+
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
624+
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
623625

624626
builder
625627
.createSubscriptionSettings()
626-
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
627-
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
628+
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
629+
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
628630

629631
builder
630632
.getSubscriptionSettings()
631-
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
632-
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
633+
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
634+
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
633635

634636
builder
635637
.listSubscriptionsSettings()
636-
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
637-
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
638+
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
639+
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
638640

639641
builder
640642
.updateSubscriptionSettings()
641-
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
642-
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
643+
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
644+
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
643645

644646
builder
645647
.deleteSubscriptionSettings()
646-
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
647-
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
648+
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
649+
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
648650

649651
return builder;
650652
}

‎google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/stub/CursorServiceStubSettings.java‎

Lines changed: 11 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -284,11 +284,11 @@ public static class Builder extends StubSettings.Builder<CursorServiceStubSettin
284284
ImmutableMap.Builder<String, ImmutableSet<StatusCode.Code>> definitions =
285285
ImmutableMap.builder();
286286
definitions.put(
287-
"idempotent",
287+
"retry_policy_1_codes",
288288
ImmutableSet.copyOf(
289289
Lists.<StatusCode.Code>newArrayList(
290290
StatusCode.Code.DEADLINE_EXCEEDED, StatusCode.Code.UNAVAILABLE)));
291-
definitions.put("non_idempotent", ImmutableSet.copyOf(Lists.<StatusCode.Code>newArrayList()));
291+
definitions.put("no_retry_codes", ImmutableSet.copyOf(Lists.<StatusCode.Code>newArrayList()));
292292
RETRYABLE_CODE_DEFINITIONS = definitions.build();
293293
}
294294

@@ -302,12 +302,14 @@ public static class Builder extends StubSettings.Builder<CursorServiceStubSettin
302302
.setInitialRetryDelay(Duration.ofMillis(100L))
303303
.setRetryDelayMultiplier(1.3)
304304
.setMaxRetryDelay(Duration.ofMillis(60000L))
305-
.setInitialRpcTimeout(Duration.ofMillis(20000L))
305+
.setInitialRpcTimeout(Duration.ofMillis(600000L))
306306
.setRpcTimeoutMultiplier(1.0)
307-
.setMaxRpcTimeout(Duration.ofMillis(20000L))
307+
.setMaxRpcTimeout(Duration.ofMillis(600000L))
308308
.setTotalTimeout(Duration.ofMillis(600000L))
309309
.build();
310-
definitions.put("default", settings);
310+
definitions.put("retry_policy_1_params", settings);
311+
settings = RetrySettings.newBuilder().setRpcTimeoutMultiplier(1.0).build();
312+
definitions.put("no_retry_params", settings);
311313
RETRY_PARAM_DEFINITIONS = definitions.build();
312314
}
313315

@@ -345,13 +347,13 @@ private static Builder initDefaults(Builder builder) {
345347

346348
builder
347349
.commitCursorSettings()
348-
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
349-
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
350+
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
351+
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
350352

351353
builder
352354
.listPartitionCursorsSettings()
353-
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
354-
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
355+
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
356+
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
355357

356358
return builder;
357359
}

‎google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/stub/PartitionAssignmentServiceStubSettings.java‎

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -161,11 +161,11 @@ public static class Builder
161161
ImmutableMap.Builder<String, ImmutableSet<StatusCode.Code>> definitions =
162162
ImmutableMap.builder();
163163
definitions.put(
164-
"idempotent",
164+
"retry_policy_1_codes",
165165
ImmutableSet.copyOf(
166166
Lists.<StatusCode.Code>newArrayList(
167167
StatusCode.Code.DEADLINE_EXCEEDED, StatusCode.Code.UNAVAILABLE)));
168-
definitions.put("non_idempotent", ImmutableSet.copyOf(Lists.<StatusCode.Code>newArrayList()));
168+
definitions.put("no_retry_codes", ImmutableSet.copyOf(Lists.<StatusCode.Code>newArrayList()));
169169
RETRYABLE_CODE_DEFINITIONS = definitions.build();
170170
}
171171

@@ -179,12 +179,14 @@ public static class Builder
179179
.setInitialRetryDelay(Duration.ofMillis(100L))
180180
.setRetryDelayMultiplier(1.3)
181181
.setMaxRetryDelay(Duration.ofMillis(60000L))
182-
.setInitialRpcTimeout(Duration.ofMillis(20000L))
182+
.setInitialRpcTimeout(Duration.ofMillis(600000L))
183183
.setRpcTimeoutMultiplier(1.0)
184-
.setMaxRpcTimeout(Duration.ofMillis(20000L))
184+
.setMaxRpcTimeout(Duration.ofMillis(600000L))
185185
.setTotalTimeout(Duration.ofMillis(600000L))
186186
.build();
187-
definitions.put("default", settings);
187+
definitions.put("retry_policy_1_params", settings);
188+
settings = RetrySettings.newBuilder().setRpcTimeoutMultiplier(1.0).build();
189+
definitions.put("no_retry_params", settings);
188190
RETRY_PARAM_DEFINITIONS = definitions.build();
189191
}
190192

‎google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/stub/PublisherServiceStubSettings.java‎

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -156,11 +156,11 @@ public static class Builder extends StubSettings.Builder<PublisherServiceStubSet
156156
ImmutableMap.Builder<String, ImmutableSet<StatusCode.Code>> definitions =
157157
ImmutableMap.builder();
158158
definitions.put(
159-
"idempotent",
159+
"retry_policy_1_codes",
160160
ImmutableSet.copyOf(
161161
Lists.<StatusCode.Code>newArrayList(
162162
StatusCode.Code.DEADLINE_EXCEEDED, StatusCode.Code.UNAVAILABLE)));
163-
definitions.put("non_idempotent", ImmutableSet.copyOf(Lists.<StatusCode.Code>newArrayList()));
163+
definitions.put("no_retry_codes", ImmutableSet.copyOf(Lists.<StatusCode.Code>newArrayList()));
164164
RETRYABLE_CODE_DEFINITIONS = definitions.build();
165165
}
166166

@@ -174,12 +174,14 @@ public static class Builder extends StubSettings.Builder<PublisherServiceStubSet
174174
.setInitialRetryDelay(Duration.ofMillis(100L))
175175
.setRetryDelayMultiplier(1.3)
176176
.setMaxRetryDelay(Duration.ofMillis(60000L))
177-
.setInitialRpcTimeout(Duration.ofMillis(20000L))
177+
.setInitialRpcTimeout(Duration.ofMillis(600000L))
178178
.setRpcTimeoutMultiplier(1.0)
179-
.setMaxRpcTimeout(Duration.ofMillis(20000L))
179+
.setMaxRpcTimeout(Duration.ofMillis(600000L))
180180
.setTotalTimeout(Duration.ofMillis(600000L))
181181
.build();
182-
definitions.put("default", settings);
182+
definitions.put("retry_policy_1_params", settings);
183+
settings = RetrySettings.newBuilder().setRpcTimeoutMultiplier(1.0).build();
184+
definitions.put("no_retry_params", settings);
183185
RETRY_PARAM_DEFINITIONS = definitions.build();
184186
}
185187

‎google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/stub/SubscriberServiceStubSettings.java‎

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -157,11 +157,11 @@ public static class Builder extends StubSettings.Builder<SubscriberServiceStubSe
157157
ImmutableMap.Builder<String, ImmutableSet<StatusCode.Code>> definitions =
158158
ImmutableMap.builder();
159159
definitions.put(
160-
"idempotent",
160+
"retry_policy_1_codes",
161161
ImmutableSet.copyOf(
162162
Lists.<StatusCode.Code>newArrayList(
163163
StatusCode.Code.DEADLINE_EXCEEDED, StatusCode.Code.UNAVAILABLE)));
164-
definitions.put("non_idempotent", ImmutableSet.copyOf(Lists.<StatusCode.Code>newArrayList()));
164+
definitions.put("no_retry_codes", ImmutableSet.copyOf(Lists.<StatusCode.Code>newArrayList()));
165165
RETRYABLE_CODE_DEFINITIONS = definitions.build();
166166
}
167167

@@ -175,12 +175,14 @@ public static class Builder extends StubSettings.Builder<SubscriberServiceStubSe
175175
.setInitialRetryDelay(Duration.ofMillis(100L))
176176
.setRetryDelayMultiplier(1.3)
177177
.setMaxRetryDelay(Duration.ofMillis(60000L))
178-
.setInitialRpcTimeout(Duration.ofMillis(20000L))
178+
.setInitialRpcTimeout(Duration.ofMillis(600000L))
179179
.setRpcTimeoutMultiplier(1.0)
180-
.setMaxRpcTimeout(Duration.ofMillis(20000L))
180+
.setMaxRpcTimeout(Duration.ofMillis(600000L))
181181
.setTotalTimeout(Duration.ofMillis(600000L))
182182
.build();
183-
definitions.put("default", settings);
183+
definitions.put("retry_policy_1_params", settings);
184+
settings = RetrySettings.newBuilder().setRpcTimeoutMultiplier(1.0).build();
185+
definitions.put("no_retry_params", settings);
184186
RETRY_PARAM_DEFINITIONS = definitions.build();
185187
}
186188

‎google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/stub/TopicStatsServiceStubSettings.java‎

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -174,11 +174,11 @@ public static class Builder extends StubSettings.Builder<TopicStatsServiceStubSe
174174
ImmutableMap.Builder<String, ImmutableSet<StatusCode.Code>> definitions =
175175
ImmutableMap.builder();
176176
definitions.put(
177-
"idempotent",
177+
"retry_policy_1_codes",
178178
ImmutableSet.copyOf(
179179
Lists.<StatusCode.Code>newArrayList(
180180
StatusCode.Code.DEADLINE_EXCEEDED, StatusCode.Code.UNAVAILABLE)));
181-
definitions.put("non_idempotent", ImmutableSet.copyOf(Lists.<StatusCode.Code>newArrayList()));
181+
definitions.put("no_retry_codes", ImmutableSet.copyOf(Lists.<StatusCode.Code>newArrayList()));
182182
RETRYABLE_CODE_DEFINITIONS = definitions.build();
183183
}
184184

@@ -192,12 +192,14 @@ public static class Builder extends StubSettings.Builder<TopicStatsServiceStubSe
192192
.setInitialRetryDelay(Duration.ofMillis(100L))
193193
.setRetryDelayMultiplier(1.3)
194194
.setMaxRetryDelay(Duration.ofMillis(60000L))
195-
.setInitialRpcTimeout(Duration.ofMillis(20000L))
195+
.setInitialRpcTimeout(Duration.ofMillis(600000L))
196196
.setRpcTimeoutMultiplier(1.0)
197-
.setMaxRpcTimeout(Duration.ofMillis(20000L))
197+
.setMaxRpcTimeout(Duration.ofMillis(600000L))
198198
.setTotalTimeout(Duration.ofMillis(600000L))
199199
.build();
200-
definitions.put("default", settings);
200+
definitions.put("retry_policy_1_params", settings);
201+
settings = RetrySettings.newBuilder().setRpcTimeoutMultiplier(1.0).build();
202+
definitions.put("no_retry_params", settings);
201203
RETRY_PARAM_DEFINITIONS = definitions.build();
202204
}
203205

@@ -229,8 +231,8 @@ private static Builder initDefaults(Builder builder) {
229231

230232
builder
231233
.computeMessageStatsSettings()
232-
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
233-
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
234+
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
235+
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
234236

235237
return builder;
236238
}

‎grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/PartitionAssignmentServiceGrpc.java‎

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,6 @@
2626
* <pre>
2727
* The service that a subscriber client application uses to determine which
2828
* partitions it should connect to.
29-
* This is an under development API being published to build client libraries.
30-
* Users will not be able to access it until fully launched.
3129
* </pre>
3230
*/
3331
@javax.annotation.Generated(
@@ -137,8 +135,6 @@ public PartitionAssignmentServiceFutureStub newStub(
137135
* <pre>
138136
* The service that a subscriber client application uses to determine which
139137
* partitions it should connect to.
140-
* This is an under development API being published to build client libraries.
141-
* Users will not be able to access it until fully launched.
142138
* </pre>
143139
*/
144140
public abstract static class PartitionAssignmentServiceImplBase
@@ -183,8 +179,6 @@ public final io.grpc.ServerServiceDefinition bindService() {
183179
* <pre>
184180
* The service that a subscriber client application uses to determine which
185181
* partitions it should connect to.
186-
* This is an under development API being published to build client libraries.
187-
* Users will not be able to access it until fully launched.
188182
* </pre>
189183
*/
190184
public static final class PartitionAssignmentServiceStub
@@ -227,8 +221,6 @@ protected PartitionAssignmentServiceStub build(
227221
* <pre>
228222
* The service that a subscriber client application uses to determine which
229223
* partitions it should connect to.
230-
* This is an under development API being published to build client libraries.
231-
* Users will not be able to access it until fully launched.
232224
* </pre>
233225
*/
234226
public static final class PartitionAssignmentServiceBlockingStub
@@ -251,8 +243,6 @@ protected PartitionAssignmentServiceBlockingStub build(
251243
* <pre>
252244
* The service that a subscriber client application uses to determine which
253245
* partitions it should connect to.
254-
* This is an under development API being published to build client libraries.
255-
* Users will not be able to access it until fully launched.
256246
* </pre>
257247
*/
258248
public static final class PartitionAssignmentServiceFutureStub

‎proto-google-cloud-pubsublite-v1/src/main/proto/google/cloud/pubsublite/v1/subscriber.proto‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -38,9 +38,6 @@ service SubscriberService {
3838

3939
// The service that a subscriber client application uses to determine which
4040
// partitions it should connect to.
41-
//
42-
// This is an under development API being published to build client libraries.
43-
// Users will not be able to access it until fully launched.
4441
service PartitionAssignmentService {
4542
option (google.api.default_host) = "pubsublite.googleapis.com";
4643
option (google.api.oauth_scopes) = "https://www.googleapis.com/auth/cloud-platform";

0 commit comments

Comments
 (0)