feat: added support for BigQuery destination and PostgreSQL source types

PiperOrigin-RevId: 469482613

Source-Link: googleapis/googleapis@441339a

Source-Link: https://github.com/googleapis/googleapis-gen/commit/7ac2e52b36f2f84950bb471126c543b9e88e75d2
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiN2FjMmU1MmIzNmYyZjg0OTUwYmI0NzExMjZjNTQzYjllODhlNzVkMiJ9

Author: gcf-owl-bot[bot]

grpc-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/DatastreamGrpc.java

@@ -67,13 +67,13 @@
  * methods:
  *
  * <ol>
- *   <li>A "flattened" method. With this type of method, the fields of the request type have been
+ *   <li> A "flattened" method. With this type of method, the fields of the request type have been
  *       converted into function parameters. It may be the case that not all fields are available as
  *       parameters, and not every API method will have a flattened method entry point.
- *   <li>A "request object" method. This type of method only takes one parameter, a request object,
+ *   <li> A "request object" method. This type of method only takes one parameter, a request object,
  *       which must be constructed before the call. Not every API method will have a request object
  *       method.
- *   <li>A "callable" method. This type of method takes no parameters and returns an immutable API
+ *   <li> A "callable" method. This type of method takes no parameters and returns an immutable API
  *       callable object, which can be used to initiate calls to the service.
  * </ol>
  *
@@ -3564,11 +3564,8 @@ public boolean awaitTermination(long duration, TimeUnit unit) throws Interrupted
 
   public static class ListConnectionProfilesPagedResponse
       extends AbstractPagedListResponse<
-          ListConnectionProfilesRequest,
-          ListConnectionProfilesResponse,
-          ConnectionProfile,
-          ListConnectionProfilesPage,
-          ListConnectionProfilesFixedSizeCollection> {
+          ListConnectionProfilesRequest, ListConnectionProfilesResponse, ConnectionProfile,
+          ListConnectionProfilesPage, ListConnectionProfilesFixedSizeCollection> {
 
     public static ApiFuture<ListConnectionProfilesPagedResponse> createAsync(
         PageContext<
@@ -3590,9 +3587,7 @@ private ListConnectionProfilesPagedResponse(ListConnectionProfilesPage page) {
 
   public static class ListConnectionProfilesPage
       extends AbstractPage<
-          ListConnectionProfilesRequest,
-          ListConnectionProfilesResponse,
-          ConnectionProfile,
+          ListConnectionProfilesRequest, ListConnectionProfilesResponse, ConnectionProfile,
           ListConnectionProfilesPage> {
 
     private ListConnectionProfilesPage(
@@ -3628,11 +3623,8 @@ public ApiFuture<ListConnectionProfilesPage> createPageAsync(
 
   public static class ListConnectionProfilesFixedSizeCollection
       extends AbstractFixedSizeCollection<
-          ListConnectionProfilesRequest,
-          ListConnectionProfilesResponse,
-          ConnectionProfile,
-          ListConnectionProfilesPage,
-          ListConnectionProfilesFixedSizeCollection> {
+          ListConnectionProfilesRequest, ListConnectionProfilesResponse, ConnectionProfile,
+          ListConnectionProfilesPage, ListConnectionProfilesFixedSizeCollection> {
 
     private ListConnectionProfilesFixedSizeCollection(
         List<ListConnectionProfilesPage> pages, int collectionSize) {
@@ -3652,10 +3644,7 @@ protected ListConnectionProfilesFixedSizeCollection createCollection(
 
   public static class ListStreamsPagedResponse
       extends AbstractPagedListResponse<
-          ListStreamsRequest,
-          ListStreamsResponse,
-          Stream,
-          ListStreamsPage,
+          ListStreamsRequest, ListStreamsResponse, Stream, ListStreamsPage,
           ListStreamsFixedSizeCollection> {
 
     public static ApiFuture<ListStreamsPagedResponse> createAsync(
@@ -3702,10 +3691,7 @@ public ApiFuture<ListStreamsPage> createPageAsync(
 
   public static class ListStreamsFixedSizeCollection
       extends AbstractFixedSizeCollection<
-          ListStreamsRequest,
-          ListStreamsResponse,
-          Stream,
-          ListStreamsPage,
+          ListStreamsRequest, ListStreamsResponse, Stream, ListStreamsPage,
           ListStreamsFixedSizeCollection> {
 
     private ListStreamsFixedSizeCollection(List<ListStreamsPage> pages, int collectionSize) {
@@ -3725,10 +3711,7 @@ protected ListStreamsFixedSizeCollection createCollection(
 
   public static class ListStreamObjectsPagedResponse
       extends AbstractPagedListResponse<
-          ListStreamObjectsRequest,
-          ListStreamObjectsResponse,
-          StreamObject,
-          ListStreamObjectsPage,
+          ListStreamObjectsRequest, ListStreamObjectsResponse, StreamObject, ListStreamObjectsPage,
           ListStreamObjectsFixedSizeCollection> {
 
     public static ApiFuture<ListStreamObjectsPagedResponse> createAsync(
@@ -3749,9 +3732,7 @@ private ListStreamObjectsPagedResponse(ListStreamObjectsPage page) {
 
   public static class ListStreamObjectsPage
       extends AbstractPage<
-          ListStreamObjectsRequest,
-          ListStreamObjectsResponse,
-          StreamObject,
+          ListStreamObjectsRequest, ListStreamObjectsResponse, StreamObject,
           ListStreamObjectsPage> {
 
     private ListStreamObjectsPage(
@@ -3781,10 +3762,7 @@ public ApiFuture<ListStreamObjectsPage> createPageAsync(
 
   public static class ListStreamObjectsFixedSizeCollection
       extends AbstractFixedSizeCollection<
-          ListStreamObjectsRequest,
-          ListStreamObjectsResponse,
-          StreamObject,
-          ListStreamObjectsPage,
+          ListStreamObjectsRequest, ListStreamObjectsResponse, StreamObject, ListStreamObjectsPage,
           ListStreamObjectsFixedSizeCollection> {
 
     private ListStreamObjectsFixedSizeCollection(
@@ -3805,10 +3783,7 @@ protected ListStreamObjectsFixedSizeCollection createCollection(
 
   public static class FetchStaticIpsPagedResponse
       extends AbstractPagedListResponse<
-          FetchStaticIpsRequest,
-          FetchStaticIpsResponse,
-          String,
-          FetchStaticIpsPage,
+          FetchStaticIpsRequest, FetchStaticIpsResponse, String, FetchStaticIpsPage,
           FetchStaticIpsFixedSizeCollection> {
 
     public static ApiFuture<FetchStaticIpsPagedResponse> createAsync(
@@ -3858,10 +3833,7 @@ public ApiFuture<FetchStaticIpsPage> createPageAsync(
 
   public static class FetchStaticIpsFixedSizeCollection
       extends AbstractFixedSizeCollection<
-          FetchStaticIpsRequest,
-          FetchStaticIpsResponse,
-          String,
-          FetchStaticIpsPage,
+          FetchStaticIpsRequest, FetchStaticIpsResponse, String, FetchStaticIpsPage,
           FetchStaticIpsFixedSizeCollection> {
 
     private FetchStaticIpsFixedSizeCollection(List<FetchStaticIpsPage> pages, int collectionSize) {
@@ -3881,11 +3853,8 @@ protected FetchStaticIpsFixedSizeCollection createCollection(
 
   public static class ListPrivateConnectionsPagedResponse
       extends AbstractPagedListResponse<
-          ListPrivateConnectionsRequest,
-          ListPrivateConnectionsResponse,
-          PrivateConnection,
-          ListPrivateConnectionsPage,
-          ListPrivateConnectionsFixedSizeCollection> {
+          ListPrivateConnectionsRequest, ListPrivateConnectionsResponse, PrivateConnection,
+          ListPrivateConnectionsPage, ListPrivateConnectionsFixedSizeCollection> {
 
     public static ApiFuture<ListPrivateConnectionsPagedResponse> createAsync(
         PageContext<
@@ -3907,9 +3876,7 @@ private ListPrivateConnectionsPagedResponse(ListPrivateConnectionsPage page) {
 
   public static class ListPrivateConnectionsPage
       extends AbstractPage<
-          ListPrivateConnectionsRequest,
-          ListPrivateConnectionsResponse,
-          PrivateConnection,
+          ListPrivateConnectionsRequest, ListPrivateConnectionsResponse, PrivateConnection,
           ListPrivateConnectionsPage> {
 
     private ListPrivateConnectionsPage(
@@ -3945,11 +3912,8 @@ public ApiFuture<ListPrivateConnectionsPage> createPageAsync(
 
   public static class ListPrivateConnectionsFixedSizeCollection
       extends AbstractFixedSizeCollection<
-          ListPrivateConnectionsRequest,
-          ListPrivateConnectionsResponse,
-          PrivateConnection,
-          ListPrivateConnectionsPage,
-          ListPrivateConnectionsFixedSizeCollection> {
+          ListPrivateConnectionsRequest, ListPrivateConnectionsResponse, PrivateConnection,
+          ListPrivateConnectionsPage, ListPrivateConnectionsFixedSizeCollection> {
 
     private ListPrivateConnectionsFixedSizeCollection(
         List<ListPrivateConnectionsPage> pages, int collectionSize) {
@@ -3969,10 +3933,7 @@ protected ListPrivateConnectionsFixedSizeCollection createCollection(
 
   public static class ListRoutesPagedResponse
       extends AbstractPagedListResponse<
-          ListRoutesRequest,
-          ListRoutesResponse,
-          Route,
-          ListRoutesPage,
+          ListRoutesRequest, ListRoutesResponse, Route, ListRoutesPage,
           ListRoutesFixedSizeCollection> {
 
     public static ApiFuture<ListRoutesPagedResponse> createAsync(
@@ -4019,10 +3980,7 @@ public ApiFuture<ListRoutesPage> createPageAsync(
 
   public static class ListRoutesFixedSizeCollection
       extends AbstractFixedSizeCollection<
-          ListRoutesRequest,
-          ListRoutesResponse,
-          Route,
-          ListRoutesPage,
+          ListRoutesRequest, ListRoutesResponse, Route, ListRoutesPage,
           ListRoutesFixedSizeCollection> {
 
     private ListRoutesFixedSizeCollection(List<ListRoutesPage> pages, int collectionSize) {
@@ -4042,10 +4000,7 @@ protected ListRoutesFixedSizeCollection createCollection(
 
   public static class ListLocationsPagedResponse
       extends AbstractPagedListResponse<
-          ListLocationsRequest,
-          ListLocationsResponse,
-          Location,
-          ListLocationsPage,
+          ListLocationsRequest, ListLocationsResponse, Location, ListLocationsPage,
           ListLocationsFixedSizeCollection> {
 
     public static ApiFuture<ListLocationsPagedResponse> createAsync(
@@ -4095,10 +4050,7 @@ public ApiFuture<ListLocationsPage> createPageAsync(
 
   public static class ListLocationsFixedSizeCollection
       extends AbstractFixedSizeCollection<
-          ListLocationsRequest,
-          ListLocationsResponse,
-          Location,
-          ListLocationsPage,
+          ListLocationsRequest, ListLocationsResponse, Location, ListLocationsPage,
           ListLocationsFixedSizeCollection> {
 
     private ListLocationsFixedSizeCollection(List<ListLocationsPage> pages, int collectionSize) {

grpc-google-cloud-datastream-v1alpha1/src/main/java/com/google/cloud/datastream/v1alpha1/DatastreamGrpc.java

@@ -35,6 +35,7 @@
 import com.google.api.gax.rpc.ClientSettings;
 import com.google.api.gax.rpc.OperationCallSettings;
 import com.google.api.gax.rpc.PagedCallSettings;
+import com.google.api.gax.rpc.StubSettings;
 import com.google.api.gax.rpc.TransportChannelProvider;
 import com.google.api.gax.rpc.UnaryCallSettings;
 import com.google.cloud.datastream.v1.stub.DatastreamStubSettings;
@@ -55,9 +56,9 @@
  * <p>The default instance has everything set to sensible defaults:
  *
  * <ul>
- *   <li>The default service address (datastream.googleapis.com) and default port (443) are used.
- *   <li>Credentials are acquired automatically through Application Default Credentials.
- *   <li>Retries are configured for idempotent methods but not for non-idempotent methods.
+ *   <li> The default service address (datastream.googleapis.com) and default port (443) are used.
+ *   <li> Credentials are acquired automatically through Application Default Credentials.
+ *   <li> Retries are configured for idempotent methods but not for non-idempotent methods.
  * </ul>
  *
  * <p>The builder of this class is recursive, so contained classes are themselves builders. When
@@ -86,8 +87,7 @@ public class DatastreamSettings extends ClientSettings<DatastreamSettings> {
 
   /** Returns the object with the settings used for calls to listConnectionProfiles. */
   public PagedCallSettings<
-          ListConnectionProfilesRequest,
-          ListConnectionProfilesResponse,
+          ListConnectionProfilesRequest, ListConnectionProfilesResponse,
           ListConnectionProfilesPagedResponse>
       listConnectionProfilesSettings() {
     return ((DatastreamStubSettings) getStubSettings()).listConnectionProfilesSettings();
@@ -241,8 +241,7 @@ public UnaryCallSettings<LookupStreamObjectRequest, StreamObject> lookupStreamOb
 
   /** Returns the object with the settings used for calls to listPrivateConnections. */
   public PagedCallSettings<
-          ListPrivateConnectionsRequest,
-          ListPrivateConnectionsResponse,
+          ListPrivateConnectionsRequest, ListPrivateConnectionsResponse,
           ListPrivateConnectionsPagedResponse>
       listPrivateConnectionsSettings() {
     return ((DatastreamStubSettings) getStubSettings()).listPrivateConnectionsSettings();
@@ -420,8 +419,7 @@ public Builder applyToAllUnaryMethods(
 
     /** Returns the builder for the settings used for calls to listConnectionProfiles. */
     public PagedCallSettings.Builder<
-            ListConnectionProfilesRequest,
-            ListConnectionProfilesResponse,
+            ListConnectionProfilesRequest, ListConnectionProfilesResponse,
             ListConnectionProfilesPagedResponse>
         listConnectionProfilesSettings() {
       return getStubSettingsBuilder().listConnectionProfilesSettings();
@@ -582,8 +580,7 @@ public UnaryCallSettings.Builder<DeleteStreamRequest, Operation> deleteStreamSet
 
     /** Returns the builder for the settings used for calls to listPrivateConnections. */
     public PagedCallSettings.Builder<
-            ListPrivateConnectionsRequest,
-            ListPrivateConnectionsResponse,
+            ListPrivateConnectionsRequest, ListPrivateConnectionsResponse,
             ListPrivateConnectionsPagedResponse>
         listPrivateConnectionsSettings() {
       return getStubSettingsBuilder().listPrivateConnectionsSettings();