Skip to content

[draft][5/7]Implement paged callable rpc method's sample code #522

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
summer-ji-eng wants to merge 1 commit into from
Closed

[draft][5/7]Implement paged callable rpc method's sample code #522

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
221 changes: 201 additions & 20 deletions src/main/java/com/google/api/generator/gapic/composer/SampleCodeHelperComposer.java
View file
Open in desktop

Large diffs are not rendered by default.

22 changes: 20 additions & 2 deletions src/test/java/com/google/api/generator/gapic/composer/goldens/EchoClient.golden
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -438,7 +438,13 @@ public class EchoClient implements BackgroundResource {
*
* <pre>{@code
* try (EchoClient echoClient = EchoClient.create()) {
* // Note: Not implement yet, placeholder for Paged Rpc callable methods' sample code.
* PagedExpandRequest request = PagedExpandRequest.newBuilder().build();
* ApiFuture<PagedExpandPagedResponse> future =
* echoClient.pagedExpandPagedCallable().futureCall(request);
* // Do something.
* for (PagedExpandResponse element : future.get().iterateAll()) {
* // doThingsWith(element);
* }
* }
* }</pre>
*/
Expand All @@ -453,7 +459,19 @@ public class EchoClient implements BackgroundResource {
*
* <pre>{@code
* try (EchoClient echoClient = EchoClient.create()) {
* // Note: Not implement yet, placeholder for Paged Rpc callable methods' sample code.
* PagedExpandRequest request = PagedExpandRequest.newBuilder().build();
* while (true) {
* PagedExpandResponse response = echoClient.pagedExpandCallable().call(request);
* for (PagedExpandResponse element : response.getResponsesList()) {
* // doThingsWith(element);
* }
* String nextPageToken = response.getNextPageToken();
* if (!String.isNullOrEmpty(nextPageToken)) {
* request = request.toBuilder().setPageToken(nextPageToken).build();
* } else {
* break;
* }
* }
* }
* }</pre>
*/
Expand Down
22 changes: 20 additions & 2 deletions src/test/java/com/google/api/generator/gapic/composer/goldens/IdentityClient.golden
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -442,7 +442,13 @@ public class IdentityClient implements BackgroundResource {
*
* <pre>{@code
* try (IdentityClient identityClient = IdentityClient.create()) {
* // Note: Not implement yet, placeholder for Paged Rpc callable methods' sample code.
* ListUsersRequest request = ListUsersRequest.newBuilder().build();
* ApiFuture<ListUsersPagedResponse> future =
* identityClient.listUsersPagedCallable().futureCall(request);
* // Do something.
* for (ListUsersResponse element : future.get().iterateAll()) {
* // doThingsWith(element);
* }
* }
* }</pre>
*/
Expand All @@ -456,7 +462,19 @@ public class IdentityClient implements BackgroundResource {
*
* <pre>{@code
* try (IdentityClient identityClient = IdentityClient.create()) {
* // Note: Not implement yet, placeholder for Paged Rpc callable methods' sample code.
* ListUsersRequest request = ListUsersRequest.newBuilder().build();
* while (true) {
* ListUsersResponse response = identityClient.listUsersCallable().call(request);
* for (ListUsersResponse element : response.getResponsesList()) {
* // doThingsWith(element);
* }
* String nextPageToken = response.getNextPageToken();
* if (!String.isNullOrEmpty(nextPageToken)) {
* request = request.toBuilder().setPageToken(nextPageToken).build();
* } else {
* break;
* }
* }
* }
* }</pre>
*/
Expand Down
68 changes: 64 additions & 4 deletions test/integration/goldens/asset/AssetServiceClient.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -751,7 +751,21 @@ public final SearchAllResourcesPagedResponse searchAllResources(
*
* <pre>{@code
* try (AssetServiceClient assetServiceClient = AssetServiceClient.create()) {
* // Note: Not implement yet, placeholder for Paged Rpc callable methods' sample code.
* String scope = "scope109264468";
* String query = "query107944136";
* List<String> asset_types = new ArrayList<>();
* SearchAllResourcesRequest request =
* SearchAllResourcesRequest.newBuilder()
* .setScope(scope)
* .setQuery(query)
* .setAssetTypes(asset_types)
* .build();
* ApiFuture<SearchAllResourcesPagedResponse> future =
* assetServiceClient.searchAllResourcesPagedCallable().futureCall(request);
* // Do something.
* for (SearchAllResourcesResponse element : future.get().iterateAll()) {
* // doThingsWith(element);
* }
* }
* }</pre>
*/
Expand All @@ -770,7 +784,28 @@ public final SearchAllResourcesPagedResponse searchAllResources(
*
* <pre>{@code
* try (AssetServiceClient assetServiceClient = AssetServiceClient.create()) {
* // Note: Not implement yet, placeholder for Paged Rpc callable methods' sample code.
* String scope = "scope109264468";
* String query = "query107944136";
* List<String> asset_types = new ArrayList<>();
* SearchAllResourcesRequest request =
* SearchAllResourcesRequest.newBuilder()
* .setScope(scope)
* .setQuery(query)
* .setAssetTypes(asset_types)
* .build();
* while (true) {
* SearchAllResourcesResponse response =
* assetServiceClient.searchAllResourcesCallable().call(request);
* for (SearchAllResourcesResponse element : response.getResponsesList()) {
* // doThingsWith(element);
* }
* String nextPageToken = response.getNextPageToken();
* if (!String.isNullOrEmpty(nextPageToken)) {
* request = request.toBuilder().setPageToken(nextPageToken).build();
* } else {
* break;
* }
* }
* }
* }</pre>
*/
Expand Down Expand Up @@ -881,7 +916,16 @@ public final SearchAllIamPoliciesPagedResponse searchAllIamPolicies(
*
* <pre>{@code
* try (AssetServiceClient assetServiceClient = AssetServiceClient.create()) {
* // Note: Not implement yet, placeholder for Paged Rpc callable methods' sample code.
* String scope = "scope109264468";
* String query = "query107944136";
* SearchAllIamPoliciesRequest request =
* SearchAllIamPoliciesRequest.newBuilder().setScope(scope).setQuery(query).build();
* ApiFuture<SearchAllIamPoliciesPagedResponse> future =
* assetServiceClient.searchAllIamPoliciesPagedCallable().futureCall(request);
* // Do something.
* for (SearchAllIamPoliciesResponse element : future.get().iterateAll()) {
* // doThingsWith(element);
* }
* }
* }</pre>
*/
Expand All @@ -900,7 +944,23 @@ public final SearchAllIamPoliciesPagedResponse searchAllIamPolicies(
*
* <pre>{@code
* try (AssetServiceClient assetServiceClient = AssetServiceClient.create()) {
* // Note: Not implement yet, placeholder for Paged Rpc callable methods' sample code.
* String scope = "scope109264468";
* String query = "query107944136";
* SearchAllIamPoliciesRequest request =
* SearchAllIamPoliciesRequest.newBuilder().setScope(scope).setQuery(query).build();
* while (true) {
* SearchAllIamPoliciesResponse response =
* assetServiceClient.searchAllIamPoliciesCallable().call(request);
* for (SearchAllIamPoliciesResponse element : response.getResponsesList()) {
* // doThingsWith(element);
* }
* String nextPageToken = response.getNextPageToken();
* if (!String.isNullOrEmpty(nextPageToken)) {
* request = request.toBuilder().setPageToken(nextPageToken).build();
* } else {
* break;
* }
* }
* }
* }</pre>
*/
Expand Down
75 changes: 69 additions & 6 deletions test/integration/goldens/logging/ConfigServiceV2Client.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -341,7 +341,15 @@ public final ListBucketsPagedResponse listBuckets(ListBucketsRequest request) {
*
* <pre>{@code
* try (ConfigServiceV2Client configServiceV2Client = ConfigServiceV2Client.create()) {
* // Note: Not implement yet, placeholder for Paged Rpc callable methods' sample code.
* BillingAccountLocationName parent =
* BillingAccountLocationName.of("[BILLING_ACCOUNT]", "[LOCATION]");
* ListBucketsRequest request = ListBucketsRequest.newBuilder().setParent(parent).build();
* ApiFuture<ListBucketsPagedResponse> future =
* configServiceV2Client.listBucketsPagedCallable().futureCall(request);
* // Do something.
* for (ListBucketsResponse element : future.get().iterateAll()) {
* // doThingsWith(element);
* }
* }
* }</pre>
*/
Expand All @@ -358,7 +366,21 @@ public final ListBucketsPagedResponse listBuckets(ListBucketsRequest request) {
*
* <pre>{@code
* try (ConfigServiceV2Client configServiceV2Client = ConfigServiceV2Client.create()) {
* // Note: Not implement yet, placeholder for Paged Rpc callable methods' sample code.
* BillingAccountLocationName parent =
* BillingAccountLocationName.of("[BILLING_ACCOUNT]", "[LOCATION]");
* ListBucketsRequest request = ListBucketsRequest.newBuilder().setParent(parent).build();
* while (true) {
* ListBucketsResponse response = configServiceV2Client.listBucketsCallable().call(request);
* for (ListBucketsResponse element : response.getResponsesList()) {
* // doThingsWith(element);
* }
* String nextPageToken = response.getNextPageToken();
* if (!String.isNullOrEmpty(nextPageToken)) {
* request = request.toBuilder().setPageToken(nextPageToken).build();
* } else {
* break;
* }
* }
* }
* }</pre>
*/
Expand Down Expand Up @@ -630,7 +652,14 @@ public final ListSinksPagedResponse listSinks(ListSinksRequest request) {
*
* <pre>{@code
* try (ConfigServiceV2Client configServiceV2Client = ConfigServiceV2Client.create()) {
* // Note: Not implement yet, placeholder for Paged Rpc callable methods' sample code.
* BillingAccountName parent = BillingAccountName.of("[BILLING_ACCOUNT]");
* ListSinksRequest request = ListSinksRequest.newBuilder().setParent(parent).build();
* ApiFuture<ListSinksPagedResponse> future =
* configServiceV2Client.listSinksPagedCallable().futureCall(request);
* // Do something.
* for (ListSinksResponse element : future.get().iterateAll()) {
* // doThingsWith(element);
* }
* }
* }</pre>
*/
Expand All @@ -646,7 +675,20 @@ public final UnaryCallable<ListSinksRequest, ListSinksPagedResponse> listSinksPa
*
* <pre>{@code
* try (ConfigServiceV2Client configServiceV2Client = ConfigServiceV2Client.create()) {
* // Note: Not implement yet, placeholder for Paged Rpc callable methods' sample code.
* BillingAccountName parent = BillingAccountName.of("[BILLING_ACCOUNT]");
* ListSinksRequest request = ListSinksRequest.newBuilder().setParent(parent).build();
* while (true) {
* ListSinksResponse response = configServiceV2Client.listSinksCallable().call(request);
* for (ListSinksResponse element : response.getResponsesList()) {
* // doThingsWith(element);
* }
* String nextPageToken = response.getNextPageToken();
* if (!String.isNullOrEmpty(nextPageToken)) {
* request = request.toBuilder().setPageToken(nextPageToken).build();
* } else {
* break;
* }
* }
* }
* }</pre>
*/
Expand Down Expand Up @@ -1448,7 +1490,14 @@ public final ListExclusionsPagedResponse listExclusions(ListExclusionsRequest re
*
* <pre>{@code
* try (ConfigServiceV2Client configServiceV2Client = ConfigServiceV2Client.create()) {
* // Note: Not implement yet, placeholder for Paged Rpc callable methods' sample code.
* BillingAccountName parent = BillingAccountName.of("[BILLING_ACCOUNT]");
* ListExclusionsRequest request = ListExclusionsRequest.newBuilder().setParent(parent).build();
* ApiFuture<ListExclusionsPagedResponse> future =
* configServiceV2Client.listExclusionsPagedCallable().futureCall(request);
* // Do something.
* for (ListExclusionsResponse element : future.get().iterateAll()) {
* // doThingsWith(element);
* }
* }
* }</pre>
*/
Expand All @@ -1465,7 +1514,21 @@ public final ListExclusionsPagedResponse listExclusions(ListExclusionsRequest re
*
* <pre>{@code
* try (ConfigServiceV2Client configServiceV2Client = ConfigServiceV2Client.create()) {
* // Note: Not implement yet, placeholder for Paged Rpc callable methods' sample code.
* BillingAccountName parent = BillingAccountName.of("[BILLING_ACCOUNT]");
* ListExclusionsRequest request = ListExclusionsRequest.newBuilder().setParent(parent).build();
* while (true) {
* ListExclusionsResponse response =
* configServiceV2Client.listExclusionsCallable().call(request);
* for (ListExclusionsResponse element : response.getResponsesList()) {
* // doThingsWith(element);
* }
* String nextPageToken = response.getNextPageToken();
* if (!String.isNullOrEmpty(nextPageToken)) {
* request = request.toBuilder().setPageToken(nextPageToken).build();
* } else {
* break;
* }
* }
* }
* }</pre>
*/
Expand Down
Loading