Skip to content
This repository has been archived by the owner on Sep 16, 2023. It is now read-only.

fix: update gapic-generator-java with mock service generation fixes #188

Merged
merged 12 commits into from Jun 28, 2022
Merged
Expand Up @@ -1461,6 +1461,254 @@ public final UnaryCallable<DeleteChannelRequest, Operation> deleteChannelCallabl
return stub.deleteChannelCallable();
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Get a single Provider.
*
* <p>Sample code:
*
* <pre>{@code
* // This snippet has been automatically generated for illustrative purposes only.
* // It may require modifications to work in your environment.
* try (EventarcClient eventarcClient = EventarcClient.create()) {
* ProviderName name = ProviderName.of("[PROJECT]", "[LOCATION]", "[PROVIDER]");
* Provider response = eventarcClient.getProvider(name);
* }
* }</pre>
*
* @param name Required. The name of the provider to get.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final Provider getProvider(ProviderName name) {
GetProviderRequest request =
GetProviderRequest.newBuilder().setName(name == null ? null : name.toString()).build();
return getProvider(request);
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Get a single Provider.
*
* <p>Sample code:
*
* <pre>{@code
* // This snippet has been automatically generated for illustrative purposes only.
* // It may require modifications to work in your environment.
* try (EventarcClient eventarcClient = EventarcClient.create()) {
* String name = ProviderName.of("[PROJECT]", "[LOCATION]", "[PROVIDER]").toString();
* Provider response = eventarcClient.getProvider(name);
* }
* }</pre>
*
* @param name Required. The name of the provider to get.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final Provider getProvider(String name) {
GetProviderRequest request = GetProviderRequest.newBuilder().setName(name).build();
return getProvider(request);
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Get a single Provider.
*
* <p>Sample code:
*
* <pre>{@code
* // This snippet has been automatically generated for illustrative purposes only.
* // It may require modifications to work in your environment.
* try (EventarcClient eventarcClient = EventarcClient.create()) {
* GetProviderRequest request =
* GetProviderRequest.newBuilder()
* .setName(ProviderName.of("[PROJECT]", "[LOCATION]", "[PROVIDER]").toString())
* .build();
* Provider response = eventarcClient.getProvider(request);
* }
* }</pre>
*
* @param request The request object containing all of the parameters for the API call.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final Provider getProvider(GetProviderRequest request) {
return getProviderCallable().call(request);
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Get a single Provider.
*
* <p>Sample code:
*
* <pre>{@code
* // This snippet has been automatically generated for illustrative purposes only.
* // It may require modifications to work in your environment.
* try (EventarcClient eventarcClient = EventarcClient.create()) {
* GetProviderRequest request =
* GetProviderRequest.newBuilder()
* .setName(ProviderName.of("[PROJECT]", "[LOCATION]", "[PROVIDER]").toString())
* .build();
* ApiFuture<Provider> future = eventarcClient.getProviderCallable().futureCall(request);
* // Do something.
* Provider response = future.get();
* }
* }</pre>
*/
public final UnaryCallable<GetProviderRequest, Provider> getProviderCallable() {
return stub.getProviderCallable();
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* List providers.
*
* <p>Sample code:
*
* <pre>{@code
* // This snippet has been automatically generated for illustrative purposes only.
* // It may require modifications to work in your environment.
* try (EventarcClient eventarcClient = EventarcClient.create()) {
* LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
* for (Provider element : eventarcClient.listProviders(parent).iterateAll()) {
* // doThingsWith(element);
* }
* }
* }</pre>
*
* @param parent Required. The parent of the provider to get.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final ListProvidersPagedResponse listProviders(LocationName parent) {
ListProvidersRequest request =
ListProvidersRequest.newBuilder()
.setParent(parent == null ? null : parent.toString())
.build();
return listProviders(request);
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* List providers.
*
* <p>Sample code:
*
* <pre>{@code
* // This snippet has been automatically generated for illustrative purposes only.
* // It may require modifications to work in your environment.
* try (EventarcClient eventarcClient = EventarcClient.create()) {
* String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
* for (Provider element : eventarcClient.listProviders(parent).iterateAll()) {
* // doThingsWith(element);
* }
* }
* }</pre>
*
* @param parent Required. The parent of the provider to get.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final ListProvidersPagedResponse listProviders(String parent) {
ListProvidersRequest request = ListProvidersRequest.newBuilder().setParent(parent).build();
return listProviders(request);
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* List providers.
*
* <p>Sample code:
*
* <pre>{@code
* // This snippet has been automatically generated for illustrative purposes only.
* // It may require modifications to work in your environment.
* try (EventarcClient eventarcClient = EventarcClient.create()) {
* ListProvidersRequest request =
* ListProvidersRequest.newBuilder()
* .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
* .setPageSize(883849137)
* .setPageToken("pageToken873572522")
* .setOrderBy("orderBy-1207110587")
* .setFilter("filter-1274492040")
* .build();
* for (Provider element : eventarcClient.listProviders(request).iterateAll()) {
* // doThingsWith(element);
* }
* }
* }</pre>
*
* @param request The request object containing all of the parameters for the API call.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final ListProvidersPagedResponse listProviders(ListProvidersRequest request) {
return listProvidersPagedCallable().call(request);
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* List providers.
*
* <p>Sample code:
*
* <pre>{@code
* // This snippet has been automatically generated for illustrative purposes only.
* // It may require modifications to work in your environment.
* try (EventarcClient eventarcClient = EventarcClient.create()) {
* ListProvidersRequest request =
* ListProvidersRequest.newBuilder()
* .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
* .setPageSize(883849137)
* .setPageToken("pageToken873572522")
* .setOrderBy("orderBy-1207110587")
* .setFilter("filter-1274492040")
* .build();
* ApiFuture<Provider> future = eventarcClient.listProvidersPagedCallable().futureCall(request);
* // Do something.
* for (Provider element : future.get().iterateAll()) {
* // doThingsWith(element);
* }
* }
* }</pre>
*/
public final UnaryCallable<ListProvidersRequest, ListProvidersPagedResponse>
listProvidersPagedCallable() {
return stub.listProvidersPagedCallable();
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* List providers.
*
* <p>Sample code:
*
* <pre>{@code
* // This snippet has been automatically generated for illustrative purposes only.
* // It may require modifications to work in your environment.
* try (EventarcClient eventarcClient = EventarcClient.create()) {
* ListProvidersRequest request =
* ListProvidersRequest.newBuilder()
* .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
* .setPageSize(883849137)
* .setPageToken("pageToken873572522")
* .setOrderBy("orderBy-1207110587")
* .setFilter("filter-1274492040")
* .build();
* while (true) {
* ListProvidersResponse response = eventarcClient.listProvidersCallable().call(request);
* for (Provider element : response.getResponsesList()) {
* // doThingsWith(element);
* }
* String nextPageToken = response.getNextPageToken();
* if (!Strings.isNullOrEmpty(nextPageToken)) {
* request = request.toBuilder().setPageToken(nextPageToken).build();
* } else {
* break;
* }
* }
* }
* }</pre>
*/
public final UnaryCallable<ListProvidersRequest, ListProvidersResponse> listProvidersCallable() {
return stub.listProvidersCallable();
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Get a single ChannelConnection.
Expand Down Expand Up @@ -2198,6 +2446,82 @@ protected ListChannelsFixedSizeCollection createCollection(
}
}

public static class ListProvidersPagedResponse
extends AbstractPagedListResponse<
ListProvidersRequest,
ListProvidersResponse,
Provider,
ListProvidersPage,
ListProvidersFixedSizeCollection> {

public static ApiFuture<ListProvidersPagedResponse> createAsync(
PageContext<ListProvidersRequest, ListProvidersResponse, Provider> context,
ApiFuture<ListProvidersResponse> futureResponse) {
ApiFuture<ListProvidersPage> futurePage =
ListProvidersPage.createEmptyPage().createPageAsync(context, futureResponse);
return ApiFutures.transform(
futurePage,
input -> new ListProvidersPagedResponse(input),
MoreExecutors.directExecutor());
}

private ListProvidersPagedResponse(ListProvidersPage page) {
super(page, ListProvidersFixedSizeCollection.createEmptyCollection());
}
}

public static class ListProvidersPage
extends AbstractPage<
ListProvidersRequest, ListProvidersResponse, Provider, ListProvidersPage> {

private ListProvidersPage(
PageContext<ListProvidersRequest, ListProvidersResponse, Provider> context,
ListProvidersResponse response) {
super(context, response);
}

private static ListProvidersPage createEmptyPage() {
return new ListProvidersPage(null, null);
}

@Override
protected ListProvidersPage createPage(
PageContext<ListProvidersRequest, ListProvidersResponse, Provider> context,
ListProvidersResponse response) {
return new ListProvidersPage(context, response);
}

@Override
public ApiFuture<ListProvidersPage> createPageAsync(
PageContext<ListProvidersRequest, ListProvidersResponse, Provider> context,
ApiFuture<ListProvidersResponse> futureResponse) {
return super.createPageAsync(context, futureResponse);
}
}

public static class ListProvidersFixedSizeCollection
extends AbstractFixedSizeCollection<
ListProvidersRequest,
ListProvidersResponse,
Provider,
ListProvidersPage,
ListProvidersFixedSizeCollection> {

private ListProvidersFixedSizeCollection(List<ListProvidersPage> pages, int collectionSize) {
super(pages, collectionSize);
}

private static ListProvidersFixedSizeCollection createEmptyCollection() {
return new ListProvidersFixedSizeCollection(null, 0);
}

@Override
protected ListProvidersFixedSizeCollection createCollection(
List<ListProvidersPage> pages, int collectionSize) {
return new ListProvidersFixedSizeCollection(pages, collectionSize);
}
}

public static class ListChannelConnectionsPagedResponse
extends AbstractPagedListResponse<
ListChannelConnectionsRequest,
Expand Down
Expand Up @@ -18,6 +18,7 @@

import static com.google.cloud.eventarc.v1.EventarcClient.ListChannelConnectionsPagedResponse;
import static com.google.cloud.eventarc.v1.EventarcClient.ListChannelsPagedResponse;
import static com.google.cloud.eventarc.v1.EventarcClient.ListProvidersPagedResponse;
import static com.google.cloud.eventarc.v1.EventarcClient.ListTriggersPagedResponse;

import com.google.api.core.ApiFunction;
Expand Down Expand Up @@ -162,6 +163,17 @@ public UnaryCallSettings<DeleteChannelRequest, Operation> deleteChannelSettings(
return ((EventarcStubSettings) getStubSettings()).deleteChannelOperationSettings();
}

/** Returns the object with the settings used for calls to getProvider. */
public UnaryCallSettings<GetProviderRequest, Provider> getProviderSettings() {
return ((EventarcStubSettings) getStubSettings()).getProviderSettings();
}

/** Returns the object with the settings used for calls to listProviders. */
public PagedCallSettings<ListProvidersRequest, ListProvidersResponse, ListProvidersPagedResponse>
listProvidersSettings() {
return ((EventarcStubSettings) getStubSettings()).listProvidersSettings();
}

/** Returns the object with the settings used for calls to getChannelConnection. */
public UnaryCallSettings<GetChannelConnectionRequest, ChannelConnection>
getChannelConnectionSettings() {
Expand Down Expand Up @@ -387,6 +399,18 @@ public UnaryCallSettings.Builder<DeleteChannelRequest, Operation> deleteChannelS
return getStubSettingsBuilder().deleteChannelOperationSettings();
}

/** Returns the builder for the settings used for calls to getProvider. */
public UnaryCallSettings.Builder<GetProviderRequest, Provider> getProviderSettings() {
return getStubSettingsBuilder().getProviderSettings();
}

/** Returns the builder for the settings used for calls to listProviders. */
public PagedCallSettings.Builder<
ListProvidersRequest, ListProvidersResponse, ListProvidersPagedResponse>
listProvidersSettings() {
return getStubSettingsBuilder().listProvidersSettings();
}

/** Returns the builder for the settings used for calls to getChannelConnection. */
public UnaryCallSettings.Builder<GetChannelConnectionRequest, ChannelConnection>
getChannelConnectionSettings() {
Expand Down