Skip to content
This repository was archived by the owner on Sep 16, 2023. It is now read-only.
Merged
Show file tree
Hide file tree
Changes from 4 commits
Commits
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
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,6 @@

import com.google.api.core.ApiFuture;
import com.google.api.core.ApiFutures;
import com.google.api.core.BetaApi;
import com.google.api.gax.core.BackgroundResource;
import com.google.api.gax.longrunning.OperationFuture;
import com.google.api.gax.paging.AbstractFixedSizeCollection;
Expand Down Expand Up @@ -128,7 +127,6 @@ public static final EventarcClient create(EventarcSettings settings) throws IOEx
* Constructs an instance of EventarcClient, using the given stub for making calls. This is for
* advanced usage - prefer using create(EventarcSettings).
*/
@BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public static final EventarcClient create(EventarcStub stub) {
return new EventarcClient(stub);
}
Expand All @@ -143,7 +141,6 @@ protected EventarcClient(EventarcSettings settings) throws IOException {
this.operationsClient = OperationsClient.create(this.stub.getOperationsStub());
}

@BetaApi("A restructuring of stub classes is planned, so this may break in the future")
protected EventarcClient(EventarcStub stub) {
this.settings = null;
this.stub = stub;
Expand All @@ -154,7 +151,6 @@ public final EventarcSettings getSettings() {
return settings;
}

@BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public EventarcStub getStub() {
return stub;
}
Expand Down Expand Up @@ -1461,6 +1457,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 +2442,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
Loading