Skip to content

Commit a65a45d

Browse files
chore: Update generation configuration at Tue Sep 10 17:21:03 UTC 2024 (#1710)
* chore: Update generation configuration at Tue Sep 10 17:21:03 UTC 2024 * chore: generate libraries at Tue Sep 10 17:21:27 UTC 2024
1 parent 6c3cd0c commit a65a45d

File tree

27 files changed

+442
-56
lines changed

27 files changed

+442
-56
lines changed

generation_config.yaml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
1-
gapic_generator_version: 2.44.0
2-
googleapis_commitish: 32bc03653260356351854429bd7e2dfbf670d352
1+
gapic_generator_version: 2.45.0
2+
googleapis_commitish: 02f62c8e241a9f95f0d183785354e90e35388cbd
33
libraries_bom_version: 26.45.0
44
libraries:
55
- api_shortname: pubsublite

google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/AdminServiceSettings.java

Lines changed: 40 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,9 @@
8585
* <p>The builder of this class is recursive, so contained classes are themselves builders. When
8686
* build() is called, the tree of builders is called to create the complete settings object.
8787
*
88-
* <p>For example, to set the total timeout of createTopic to 30 seconds:
88+
* <p>For example, to set the
89+
* [RetrySettings](https://cloud.google.com/java/docs/reference/gax/latest/com.google.api.gax.retrying.RetrySettings)
90+
* of createTopic:
8991
*
9092
* <pre>{@code
9193
* // This snippet has been automatically generated and should be regarded as a code template only.
@@ -101,10 +103,46 @@
101103
* .createTopicSettings()
102104
* .getRetrySettings()
103105
* .toBuilder()
104-
* .setTotalTimeout(Duration.ofSeconds(30))
106+
* .setInitialRetryDelayDuration(Duration.ofSeconds(1))
107+
* .setInitialRpcTimeoutDuration(Duration.ofSeconds(5))
108+
* .setMaxAttempts(5)
109+
* .setMaxRetryDelayDuration(Duration.ofSeconds(30))
110+
* .setMaxRpcTimeoutDuration(Duration.ofSeconds(60))
111+
* .setRetryDelayMultiplier(1.3)
112+
* .setRpcTimeoutMultiplier(1.5)
113+
* .setTotalTimeoutDuration(Duration.ofSeconds(300))
105114
* .build());
106115
* AdminServiceSettings adminServiceSettings = adminServiceSettingsBuilder.build();
107116
* }</pre>
117+
*
118+
* Please refer to the [Client Side Retry
119+
* Guide](https://github.com/googleapis/google-cloud-java/blob/main/docs/client_retries.md) for
120+
* additional support in setting retries.
121+
*
122+
* <p>To configure the RetrySettings of a Long Running Operation method, create an
123+
* OperationTimedPollAlgorithm object and update the RPC's polling algorithm. For example, to
124+
* configure the RetrySettings for seekSubscription:
125+
*
126+
* <pre>{@code
127+
* // This snippet has been automatically generated and should be regarded as a code template only.
128+
* // It will require modifications to work:
129+
* // - It may require correct/in-range values for request initialization.
130+
* // - It may require specifying regional endpoints when creating the service client as shown in
131+
* // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
132+
* AdminServiceSettings.Builder adminServiceSettingsBuilder = AdminServiceSettings.newBuilder();
133+
* TimedRetryAlgorithm timedRetryAlgorithm =
134+
* OperationalTimedPollAlgorithm.create(
135+
* RetrySettings.newBuilder()
136+
* .setInitialRetryDelayDuration(Duration.ofMillis(500))
137+
* .setRetryDelayMultiplier(1.5)
138+
* .setMaxRetryDelay(Duration.ofMillis(5000))
139+
* .setTotalTimeoutDuration(Duration.ofHours(24))
140+
* .build());
141+
* adminServiceSettingsBuilder
142+
* .createClusterOperationSettings()
143+
* .setPollingAlgorithm(timedRetryAlgorithm)
144+
* .build();
145+
* }</pre>
108146
*/
109147
@Generated("by gapic-generator-java")
110148
public class AdminServiceSettings extends ClientSettings<AdminServiceSettings> {

google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/CursorServiceSettings.java

Lines changed: 15 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,9 @@
5555
* <p>The builder of this class is recursive, so contained classes are themselves builders. When
5656
* build() is called, the tree of builders is called to create the complete settings object.
5757
*
58-
* <p>For example, to set the total timeout of commitCursor to 30 seconds:
58+
* <p>For example, to set the
59+
* [RetrySettings](https://cloud.google.com/java/docs/reference/gax/latest/com.google.api.gax.retrying.RetrySettings)
60+
* of commitCursor:
5961
*
6062
* <pre>{@code
6163
* // This snippet has been automatically generated and should be regarded as a code template only.
@@ -71,10 +73,21 @@
7173
* .commitCursorSettings()
7274
* .getRetrySettings()
7375
* .toBuilder()
74-
* .setTotalTimeout(Duration.ofSeconds(30))
76+
* .setInitialRetryDelayDuration(Duration.ofSeconds(1))
77+
* .setInitialRpcTimeoutDuration(Duration.ofSeconds(5))
78+
* .setMaxAttempts(5)
79+
* .setMaxRetryDelayDuration(Duration.ofSeconds(30))
80+
* .setMaxRpcTimeoutDuration(Duration.ofSeconds(60))
81+
* .setRetryDelayMultiplier(1.3)
82+
* .setRpcTimeoutMultiplier(1.5)
83+
* .setTotalTimeoutDuration(Duration.ofSeconds(300))
7584
* .build());
7685
* CursorServiceSettings cursorServiceSettings = cursorServiceSettingsBuilder.build();
7786
* }</pre>
87+
*
88+
* Please refer to the [Client Side Retry
89+
* Guide](https://github.com/googleapis/google-cloud-java/blob/main/docs/client_retries.md) for
90+
* additional support in setting retries.
7891
*/
7992
@Generated("by gapic-generator-java")
8093
public class CursorServiceSettings extends ClientSettings<CursorServiceSettings> {

google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/PartitionAssignmentServiceSettings.java

Lines changed: 15 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,9 @@
4848
* <p>The builder of this class is recursive, so contained classes are themselves builders. When
4949
* build() is called, the tree of builders is called to create the complete settings object.
5050
*
51-
* <p>For example, to set the total timeout of assignPartitions to 30 seconds:
51+
* <p>For example, to set the
52+
* [RetrySettings](https://cloud.google.com/java/docs/reference/gax/latest/com.google.api.gax.retrying.RetrySettings)
53+
* of assignPartitions:
5254
*
5355
* <pre>{@code
5456
* // This snippet has been automatically generated and should be regarded as a code template only.
@@ -65,11 +67,22 @@
6567
* .assignPartitionsSettings()
6668
* .getRetrySettings()
6769
* .toBuilder()
68-
* .setTotalTimeout(Duration.ofSeconds(30))
70+
* .setInitialRetryDelayDuration(Duration.ofSeconds(1))
71+
* .setInitialRpcTimeoutDuration(Duration.ofSeconds(5))
72+
* .setMaxAttempts(5)
73+
* .setMaxRetryDelayDuration(Duration.ofSeconds(30))
74+
* .setMaxRpcTimeoutDuration(Duration.ofSeconds(60))
75+
* .setRetryDelayMultiplier(1.3)
76+
* .setRpcTimeoutMultiplier(1.5)
77+
* .setTotalTimeoutDuration(Duration.ofSeconds(300))
6978
* .build());
7079
* PartitionAssignmentServiceSettings partitionAssignmentServiceSettings =
7180
* partitionAssignmentServiceSettingsBuilder.build();
7281
* }</pre>
82+
*
83+
* Please refer to the [Client Side Retry
84+
* Guide](https://github.com/googleapis/google-cloud-java/blob/main/docs/client_retries.md) for
85+
* additional support in setting retries.
7386
*/
7487
@Generated("by gapic-generator-java")
7588
public class PartitionAssignmentServiceSettings

google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/PublisherServiceSettings.java

Lines changed: 15 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,9 @@
4848
* <p>The builder of this class is recursive, so contained classes are themselves builders. When
4949
* build() is called, the tree of builders is called to create the complete settings object.
5050
*
51-
* <p>For example, to set the total timeout of publish to 30 seconds:
51+
* <p>For example, to set the
52+
* [RetrySettings](https://cloud.google.com/java/docs/reference/gax/latest/com.google.api.gax.retrying.RetrySettings)
53+
* of publish:
5254
*
5355
* <pre>{@code
5456
* // This snippet has been automatically generated and should be regarded as a code template only.
@@ -65,10 +67,21 @@
6567
* .publishSettings()
6668
* .getRetrySettings()
6769
* .toBuilder()
68-
* .setTotalTimeout(Duration.ofSeconds(30))
70+
* .setInitialRetryDelayDuration(Duration.ofSeconds(1))
71+
* .setInitialRpcTimeoutDuration(Duration.ofSeconds(5))
72+
* .setMaxAttempts(5)
73+
* .setMaxRetryDelayDuration(Duration.ofSeconds(30))
74+
* .setMaxRpcTimeoutDuration(Duration.ofSeconds(60))
75+
* .setRetryDelayMultiplier(1.3)
76+
* .setRpcTimeoutMultiplier(1.5)
77+
* .setTotalTimeoutDuration(Duration.ofSeconds(300))
6978
* .build());
7079
* PublisherServiceSettings publisherServiceSettings = publisherServiceSettingsBuilder.build();
7180
* }</pre>
81+
*
82+
* Please refer to the [Client Side Retry
83+
* Guide](https://github.com/googleapis/google-cloud-java/blob/main/docs/client_retries.md) for
84+
* additional support in setting retries.
7285
*/
7386
@Generated("by gapic-generator-java")
7487
public class PublisherServiceSettings extends ClientSettings<PublisherServiceSettings> {

google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/SubscriberServiceSettings.java

Lines changed: 15 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,9 @@
4848
* <p>The builder of this class is recursive, so contained classes are themselves builders. When
4949
* build() is called, the tree of builders is called to create the complete settings object.
5050
*
51-
* <p>For example, to set the total timeout of subscribe to 30 seconds:
51+
* <p>For example, to set the
52+
* [RetrySettings](https://cloud.google.com/java/docs/reference/gax/latest/com.google.api.gax.retrying.RetrySettings)
53+
* of subscribe:
5254
*
5355
* <pre>{@code
5456
* // This snippet has been automatically generated and should be regarded as a code template only.
@@ -65,10 +67,21 @@
6567
* .subscribeSettings()
6668
* .getRetrySettings()
6769
* .toBuilder()
68-
* .setTotalTimeout(Duration.ofSeconds(30))
70+
* .setInitialRetryDelayDuration(Duration.ofSeconds(1))
71+
* .setInitialRpcTimeoutDuration(Duration.ofSeconds(5))
72+
* .setMaxAttempts(5)
73+
* .setMaxRetryDelayDuration(Duration.ofSeconds(30))
74+
* .setMaxRpcTimeoutDuration(Duration.ofSeconds(60))
75+
* .setRetryDelayMultiplier(1.3)
76+
* .setRpcTimeoutMultiplier(1.5)
77+
* .setTotalTimeoutDuration(Duration.ofSeconds(300))
6978
* .build());
7079
* SubscriberServiceSettings subscriberServiceSettings = subscriberServiceSettingsBuilder.build();
7180
* }</pre>
81+
*
82+
* Please refer to the [Client Side Retry
83+
* Guide](https://github.com/googleapis/google-cloud-java/blob/main/docs/client_retries.md) for
84+
* additional support in setting retries.
7285
*/
7386
@Generated("by gapic-generator-java")
7487
public class SubscriberServiceSettings extends ClientSettings<SubscriberServiceSettings> {

google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/TopicStatsServiceSettings.java

Lines changed: 15 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,9 @@
5151
* <p>The builder of this class is recursive, so contained classes are themselves builders. When
5252
* build() is called, the tree of builders is called to create the complete settings object.
5353
*
54-
* <p>For example, to set the total timeout of computeMessageStats to 30 seconds:
54+
* <p>For example, to set the
55+
* [RetrySettings](https://cloud.google.com/java/docs/reference/gax/latest/com.google.api.gax.retrying.RetrySettings)
56+
* of computeMessageStats:
5557
*
5658
* <pre>{@code
5759
* // This snippet has been automatically generated and should be regarded as a code template only.
@@ -68,10 +70,21 @@
6870
* .computeMessageStatsSettings()
6971
* .getRetrySettings()
7072
* .toBuilder()
71-
* .setTotalTimeout(Duration.ofSeconds(30))
73+
* .setInitialRetryDelayDuration(Duration.ofSeconds(1))
74+
* .setInitialRpcTimeoutDuration(Duration.ofSeconds(5))
75+
* .setMaxAttempts(5)
76+
* .setMaxRetryDelayDuration(Duration.ofSeconds(30))
77+
* .setMaxRpcTimeoutDuration(Duration.ofSeconds(60))
78+
* .setRetryDelayMultiplier(1.3)
79+
* .setRpcTimeoutMultiplier(1.5)
80+
* .setTotalTimeoutDuration(Duration.ofSeconds(300))
7281
* .build());
7382
* TopicStatsServiceSettings topicStatsServiceSettings = topicStatsServiceSettingsBuilder.build();
7483
* }</pre>
84+
*
85+
* Please refer to the [Client Side Retry
86+
* Guide](https://github.com/googleapis/google-cloud-java/blob/main/docs/client_retries.md) for
87+
* additional support in setting retries.
7588
*/
7689
@Generated("by gapic-generator-java")
7790
public class TopicStatsServiceSettings extends ClientSettings<TopicStatsServiceSettings> {

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

Lines changed: 46 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,9 @@
104104
* <p>The builder of this class is recursive, so contained classes are themselves builders. When
105105
* build() is called, the tree of builders is called to create the complete settings object.
106106
*
107-
* <p>For example, to set the total timeout of createTopic to 30 seconds:
107+
* <p>For example, to set the
108+
* [RetrySettings](https://cloud.google.com/java/docs/reference/gax/latest/com.google.api.gax.retrying.RetrySettings)
109+
* of createTopic:
108110
*
109111
* <pre>{@code
110112
* // This snippet has been automatically generated and should be regarded as a code template only.
@@ -121,10 +123,47 @@
121123
* .createTopicSettings()
122124
* .getRetrySettings()
123125
* .toBuilder()
124-
* .setTotalTimeout(Duration.ofSeconds(30))
126+
* .setInitialRetryDelayDuration(Duration.ofSeconds(1))
127+
* .setInitialRpcTimeoutDuration(Duration.ofSeconds(5))
128+
* .setMaxAttempts(5)
129+
* .setMaxRetryDelayDuration(Duration.ofSeconds(30))
130+
* .setMaxRpcTimeoutDuration(Duration.ofSeconds(60))
131+
* .setRetryDelayMultiplier(1.3)
132+
* .setRpcTimeoutMultiplier(1.5)
133+
* .setTotalTimeoutDuration(Duration.ofSeconds(300))
125134
* .build());
126135
* AdminServiceStubSettings adminServiceSettings = adminServiceSettingsBuilder.build();
127136
* }</pre>
137+
*
138+
* Please refer to the [Client Side Retry
139+
* Guide](https://github.com/googleapis/google-cloud-java/blob/main/docs/client_retries.md) for
140+
* additional support in setting retries.
141+
*
142+
* <p>To configure the RetrySettings of a Long Running Operation method, create an
143+
* OperationTimedPollAlgorithm object and update the RPC's polling algorithm. For example, to
144+
* configure the RetrySettings for seekSubscription:
145+
*
146+
* <pre>{@code
147+
* // This snippet has been automatically generated and should be regarded as a code template only.
148+
* // It will require modifications to work:
149+
* // - It may require correct/in-range values for request initialization.
150+
* // - It may require specifying regional endpoints when creating the service client as shown in
151+
* // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
152+
* AdminServiceStubSettings.Builder adminServiceSettingsBuilder =
153+
* AdminServiceStubSettings.newBuilder();
154+
* TimedRetryAlgorithm timedRetryAlgorithm =
155+
* OperationalTimedPollAlgorithm.create(
156+
* RetrySettings.newBuilder()
157+
* .setInitialRetryDelayDuration(Duration.ofMillis(500))
158+
* .setRetryDelayMultiplier(1.5)
159+
* .setMaxRetryDelay(Duration.ofMillis(5000))
160+
* .setTotalTimeoutDuration(Duration.ofHours(24))
161+
* .build());
162+
* adminServiceSettingsBuilder
163+
* .createClusterOperationSettings()
164+
* .setPollingAlgorithm(timedRetryAlgorithm)
165+
* .build();
166+
* }</pre>
128167
*/
129168
@Generated("by gapic-generator-java")
130169
public class AdminServiceStubSettings extends StubSettings<AdminServiceStubSettings> {
@@ -201,9 +240,7 @@ public String extractNextToken(ListTopicsResponse payload) {
201240

202241
@Override
203242
public Iterable<Topic> extractResources(ListTopicsResponse payload) {
204-
return payload.getTopicsList() == null
205-
? ImmutableList.<Topic>of()
206-
: payload.getTopicsList();
243+
return payload.getTopicsList();
207244
}
208245
};
209246

@@ -243,9 +280,7 @@ public String extractNextToken(ListTopicSubscriptionsResponse payload) {
243280

244281
@Override
245282
public Iterable<String> extractResources(ListTopicSubscriptionsResponse payload) {
246-
return payload.getSubscriptionsList() == null
247-
? ImmutableList.<String>of()
248-
: payload.getSubscriptionsList();
283+
return payload.getSubscriptionsList();
249284
}
250285
};
251286

@@ -283,9 +318,7 @@ public String extractNextToken(ListSubscriptionsResponse payload) {
283318

284319
@Override
285320
public Iterable<Subscription> extractResources(ListSubscriptionsResponse payload) {
286-
return payload.getSubscriptionsList() == null
287-
? ImmutableList.<Subscription>of()
288-
: payload.getSubscriptionsList();
321+
return payload.getSubscriptionsList();
289322
}
290323
};
291324

@@ -323,9 +356,7 @@ public String extractNextToken(ListReservationsResponse payload) {
323356

324357
@Override
325358
public Iterable<Reservation> extractResources(ListReservationsResponse payload) {
326-
return payload.getReservationsList() == null
327-
? ImmutableList.<Reservation>of()
328-
: payload.getReservationsList();
359+
return payload.getReservationsList();
329360
}
330361
};
331362

@@ -363,9 +394,7 @@ public String extractNextToken(ListReservationTopicsResponse payload) {
363394

364395
@Override
365396
public Iterable<String> extractResources(ListReservationTopicsResponse payload) {
366-
return payload.getTopicsList() == null
367-
? ImmutableList.<String>of()
368-
: payload.getTopicsList();
397+
return payload.getTopicsList();
369398
}
370399
};
371400

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

Lines changed: 16 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,9 @@
7272
* <p>The builder of this class is recursive, so contained classes are themselves builders. When
7373
* build() is called, the tree of builders is called to create the complete settings object.
7474
*
75-
* <p>For example, to set the total timeout of commitCursor to 30 seconds:
75+
* <p>For example, to set the
76+
* [RetrySettings](https://cloud.google.com/java/docs/reference/gax/latest/com.google.api.gax.retrying.RetrySettings)
77+
* of commitCursor:
7678
*
7779
* <pre>{@code
7880
* // This snippet has been automatically generated and should be regarded as a code template only.
@@ -89,10 +91,21 @@
8991
* .commitCursorSettings()
9092
* .getRetrySettings()
9193
* .toBuilder()
92-
* .setTotalTimeout(Duration.ofSeconds(30))
94+
* .setInitialRetryDelayDuration(Duration.ofSeconds(1))
95+
* .setInitialRpcTimeoutDuration(Duration.ofSeconds(5))
96+
* .setMaxAttempts(5)
97+
* .setMaxRetryDelayDuration(Duration.ofSeconds(30))
98+
* .setMaxRpcTimeoutDuration(Duration.ofSeconds(60))
99+
* .setRetryDelayMultiplier(1.3)
100+
* .setRpcTimeoutMultiplier(1.5)
101+
* .setTotalTimeoutDuration(Duration.ofSeconds(300))
93102
* .build());
94103
* CursorServiceStubSettings cursorServiceSettings = cursorServiceSettingsBuilder.build();
95104
* }</pre>
105+
*
106+
* Please refer to the [Client Side Retry
107+
* Guide](https://github.com/googleapis/google-cloud-java/blob/main/docs/client_retries.md) for
108+
* additional support in setting retries.
96109
*/
97110
@Generated("by gapic-generator-java")
98111
public class CursorServiceStubSettings extends StubSettings<CursorServiceStubSettings> {
@@ -144,9 +157,7 @@ public String extractNextToken(ListPartitionCursorsResponse payload) {
144157
@Override
145158
public Iterable<PartitionCursor> extractResources(
146159
ListPartitionCursorsResponse payload) {
147-
return payload.getPartitionCursorsList() == null
148-
? ImmutableList.<PartitionCursor>of()
149-
: payload.getPartitionCursorsList();
160+
return payload.getPartitionCursorsList();
150161
}
151162
};
152163

0 commit comments

Comments
 (0)