yoshi-code-bot
diff --git a/‎packages/google-cloud-datastream/google/cloud/datastream/__init__.py‎
Lines changed: 30 additions & 0 deletions b/‎packages/google-cloud-datastream/google/cloud/datastream/__init__.py‎
Lines changed: 30 additions & 0 deletions
diff --git a/‎packages/google-cloud-datastream/google/cloud/datastream/gapic_version.py‎
Lines changed: 1 addition & 1 deletion b/‎packages/google-cloud-datastream/google/cloud/datastream/gapic_version.py‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎packages/google-cloud-datastream/google/cloud/datastream_v1/__init__.py‎
Lines changed: 30 additions & 0 deletions b/‎packages/google-cloud-datastream/google/cloud/datastream_v1/__init__.py‎
Lines changed: 30 additions & 0 deletions
diff --git a/‎packages/google-cloud-datastream/google/cloud/datastream_v1/gapic_metadata.json‎
Lines changed: 15 additions & 0 deletions b/‎packages/google-cloud-datastream/google/cloud/datastream_v1/gapic_metadata.json‎
Lines changed: 15 additions & 0 deletions
diff --git a/‎packages/google-cloud-datastream/google/cloud/datastream_v1/gapic_version.py‎
Lines changed: 1 addition & 1 deletion b/‎packages/google-cloud-datastream/google/cloud/datastream_v1/gapic_version.py‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎packages/google-cloud-datastream/google/cloud/datastream_v1/services/datastream/async_client.py‎
Lines changed: 100 additions & 3 deletions b/‎packages/google-cloud-datastream/google/cloud/datastream_v1/services/datastream/async_client.py‎
Lines changed: 100 additions & 3 deletions
@@ -52,6 +52,7 @@
     ListStreamsResponse,
     LookupStreamObjectRequest,
     OperationMetadata,
+    RunStreamRequest,
     StartBackfillJobRequest,
     StartBackfillJobResponse,
     StopBackfillJobRequest,
@@ -64,6 +65,7 @@
     BackfillJob,
     BigQueryDestinationConfig,
     BigQueryProfile,
+    CdcStrategy,
     ConnectionProfile,
     DestinationConfig,
     Error,
@@ -73,16 +75,20 @@
     JsonFileFormat,
     MysqlColumn,
     MysqlDatabase,
+    MysqlLogPosition,
     MysqlProfile,
     MysqlRdbms,
     MysqlSourceConfig,
     MysqlSslConfig,
     MysqlTable,
+    OracleAsmConfig,
     OracleColumn,
     OracleProfile,
     OracleRdbms,
     OracleSchema,
+    OracleScnPosition,
     OracleSourceConfig,
+    OracleSslConfig,
     OracleTable,
     PostgresqlColumn,
     PostgresqlProfile,
@@ -95,6 +101,15 @@
     Route,
     SourceConfig,
     SourceObjectIdentifier,
+    SqlServerChangeTables,
+    SqlServerColumn,
+    SqlServerLsnPosition,
+    SqlServerProfile,
+    SqlServerRdbms,
+    SqlServerSchema,
+    SqlServerSourceConfig,
+    SqlServerTable,
+    SqlServerTransactionLogs,
     StaticServiceIpConnectivity,
     Stream,
     StreamObject,
@@ -136,6 +151,7 @@
     "ListStreamsResponse",
     "LookupStreamObjectRequest",
     "OperationMetadata",
+    "RunStreamRequest",
     "StartBackfillJobRequest",
     "StartBackfillJobResponse",
     "StopBackfillJobRequest",
@@ -146,6 +162,7 @@
     "BackfillJob",
     "BigQueryDestinationConfig",
     "BigQueryProfile",
+    "CdcStrategy",
     "ConnectionProfile",
     "DestinationConfig",
     "Error",
@@ -155,16 +172,20 @@
     "JsonFileFormat",
     "MysqlColumn",
     "MysqlDatabase",
+    "MysqlLogPosition",
     "MysqlProfile",
     "MysqlRdbms",
     "MysqlSourceConfig",
     "MysqlSslConfig",
     "MysqlTable",
+    "OracleAsmConfig",
     "OracleColumn",
     "OracleProfile",
     "OracleRdbms",
     "OracleSchema",
+    "OracleScnPosition",
     "OracleSourceConfig",
+    "OracleSslConfig",
     "OracleTable",
     "PostgresqlColumn",
     "PostgresqlProfile",
@@ -177,6 +198,15 @@
     "Route",
     "SourceConfig",
     "SourceObjectIdentifier",
+    "SqlServerChangeTables",
+    "SqlServerColumn",
+    "SqlServerLsnPosition",
+    "SqlServerProfile",
+    "SqlServerRdbms",
+    "SqlServerSchema",
+    "SqlServerSourceConfig",
+    "SqlServerTable",
+    "SqlServerTransactionLogs",
     "StaticServiceIpConnectivity",
     "Stream",
     "StreamObject",
 
@@ -13,4 +13,4 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-__version__ = "1.10.1"  # {x-release-please-version}
+__version__ = "0.0.0"  # {x-release-please-version}
@@ -49,6 +49,7 @@
     ListStreamsResponse,
     LookupStreamObjectRequest,
     OperationMetadata,
+    RunStreamRequest,
     StartBackfillJobRequest,
     StartBackfillJobResponse,
     StopBackfillJobRequest,
@@ -61,6 +62,7 @@
     BackfillJob,
     BigQueryDestinationConfig,
     BigQueryProfile,
+    CdcStrategy,
     ConnectionProfile,
     DestinationConfig,
     Error,
@@ -70,16 +72,20 @@
     JsonFileFormat,
     MysqlColumn,
     MysqlDatabase,
+    MysqlLogPosition,
     MysqlProfile,
     MysqlRdbms,
     MysqlSourceConfig,
     MysqlSslConfig,
     MysqlTable,
+    OracleAsmConfig,
     OracleColumn,
     OracleProfile,
     OracleRdbms,
     OracleSchema,
+    OracleScnPosition,
     OracleSourceConfig,
+    OracleSslConfig,
     OracleTable,
     PostgresqlColumn,
     PostgresqlProfile,
@@ -92,6 +98,15 @@
     Route,
     SourceConfig,
     SourceObjectIdentifier,
+    SqlServerChangeTables,
+    SqlServerColumn,
+    SqlServerLsnPosition,
+    SqlServerProfile,
+    SqlServerRdbms,
+    SqlServerSchema,
+    SqlServerSourceConfig,
+    SqlServerTable,
+    SqlServerTransactionLogs,
     StaticServiceIpConnectivity,
     Stream,
     StreamObject,
@@ -107,6 +122,7 @@
     "BackfillJob",
     "BigQueryDestinationConfig",
     "BigQueryProfile",
+    "CdcStrategy",
     "ConnectionProfile",
     "CreateConnectionProfileRequest",
     "CreatePrivateConnectionRequest",
@@ -145,17 +161,21 @@
     "LookupStreamObjectRequest",
     "MysqlColumn",
     "MysqlDatabase",
+    "MysqlLogPosition",
     "MysqlProfile",
     "MysqlRdbms",
     "MysqlSourceConfig",
     "MysqlSslConfig",
     "MysqlTable",
     "OperationMetadata",
+    "OracleAsmConfig",
     "OracleColumn",
     "OracleProfile",
     "OracleRdbms",
     "OracleSchema",
+    "OracleScnPosition",
     "OracleSourceConfig",
+    "OracleSslConfig",
     "OracleTable",
     "PostgresqlColumn",
     "PostgresqlProfile",
@@ -166,8 +186,18 @@
     "PrivateConnection",
     "PrivateConnectivity",
     "Route",
+    "RunStreamRequest",
     "SourceConfig",
     "SourceObjectIdentifier",
+    "SqlServerChangeTables",
+    "SqlServerColumn",
+    "SqlServerLsnPosition",
+    "SqlServerProfile",
+    "SqlServerRdbms",
+    "SqlServerSchema",
+    "SqlServerSourceConfig",
+    "SqlServerTable",
+    "SqlServerTransactionLogs",
     "StartBackfillJobRequest",
     "StartBackfillJobResponse",
     "StaticServiceIpConnectivity",
 
@@ -115,6 +115,11 @@
                 "lookup_stream_object"
               ]
             },
+            "RunStream": {
+              "methods": [
+                "run_stream"
+              ]
+            },
             "StartBackfillJob": {
               "methods": [
                 "start_backfill_job"
@@ -245,6 +250,11 @@
                 "lookup_stream_object"
               ]
             },
+            "RunStream": {
+              "methods": [
+                "run_stream"
+              ]
+            },
             "StartBackfillJob": {
               "methods": [
                 "start_backfill_job"
@@ -375,6 +385,11 @@
                 "lookup_stream_object"
               ]
             },
+            "RunStream": {
+              "methods": [
+                "run_stream"
+              ]
+            },
             "StartBackfillJob": {
               "methods": [
                 "start_backfill_job"
 
@@ -13,4 +13,4 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-__version__ = "1.10.1"  # {x-release-please-version}
+__version__ = "0.0.0"  # {x-release-please-version}
@@ -537,7 +537,6 @@ async def sample_create_connection_profile():
                 connection_profile = datastream_v1.ConnectionProfile()
                 connection_profile.oracle_profile.hostname = "hostname_value"
                 connection_profile.oracle_profile.username = "username_value"
-                connection_profile.oracle_profile.password = "password_value"
                 connection_profile.oracle_profile.database_service = "database_service_value"
                 connection_profile.display_name = "display_name_value"
 
@@ -688,7 +687,6 @@ async def sample_update_connection_profile():
                 connection_profile = datastream_v1.ConnectionProfile()
                 connection_profile.oracle_profile.hostname = "hostname_value"
                 connection_profile.oracle_profile.username = "username_value"
-                connection_profile.oracle_profile.password = "password_value"
                 connection_profile.oracle_profile.database_service = "database_service_value"
                 connection_profile.display_name = "display_name_value"
 
@@ -965,7 +963,6 @@ async def sample_discover_connection_profile():
                 connection_profile = datastream_v1.ConnectionProfile()
                 connection_profile.oracle_profile.hostname = "hostname_value"
                 connection_profile.oracle_profile.username = "username_value"
-                connection_profile.oracle_profile.password = "password_value"
                 connection_profile.oracle_profile.database_service = "database_service_value"
                 connection_profile.display_name = "display_name_value"
 
@@ -1672,6 +1669,106 @@ async def sample_delete_stream():
         # Done; return the response.
         return response
 
+    async def run_stream(
+        self,
+        request: Optional[Union[datastream.RunStreamRequest, dict]] = None,
+        *,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
+        timeout: Union[float, object] = gapic_v1.method.DEFAULT,
+        metadata: Sequence[Tuple[str, str]] = (),
+    ) -> operation_async.AsyncOperation:
+        r"""Use this method to start, resume or recover a stream
+        with a non default CDC strategy.
+
+        .. code-block:: python
+
+            # This snippet has been automatically generated and should be regarded as a
+            # code template only.
+            # It will require modifications to work:
+            # - It may require correct/in-range values for request initialization.
+            # - It may require specifying regional endpoints when creating the service
+            #   client as shown in:
+            #   https://googleapis.dev/python/google-api-core/latest/client_options.html
+            from google.cloud import datastream_v1
+
+            async def sample_run_stream():
+                # Create a client
+                client = datastream_v1.DatastreamAsyncClient()
+
+                # Initialize request argument(s)
+                request = datastream_v1.RunStreamRequest(
+                    name="name_value",
+                )
+
+                # Make the request
+                operation = client.run_stream(request=request)
+
+                print("Waiting for operation to complete...")
+
+                response = (await operation).result()
+
+                # Handle the response
+                print(response)
+
+        Args:
+            request (Optional[Union[google.cloud.datastream_v1.types.RunStreamRequest, dict]]):
+                The request object. Request message for running a stream.
+            retry (google.api_core.retry_async.AsyncRetry): Designation of what errors, if any,
+                should be retried.
+            timeout (float): The timeout for this request.
+            metadata (Sequence[Tuple[str, str]]): Strings which should be
+                sent along with the request as metadata.
+
+        Returns:
+            google.api_core.operation_async.AsyncOperation:
+                An object representing a long-running operation.
+
+                The result type for the operation will be
+                :class:`google.cloud.datastream_v1.types.Stream` A
+                resource representing streaming data from a source to a
+                destination.
+
+        """
+        # Create or coerce a protobuf request object.
+        # - Use the request object if provided (there's no risk of modifying the input as
+        #   there are no flattened fields), or create one.
+        if not isinstance(request, datastream.RunStreamRequest):
+            request = datastream.RunStreamRequest(request)
+
+        # Wrap the RPC method; this adds retry and timeout information,
+        # and friendly error handling.
+        rpc = self._client._transport._wrapped_methods[
+            self._client._transport.run_stream
+        ]
+
+        # Certain fields should be provided within the metadata header;
+        # add these here.
+        metadata = tuple(metadata) + (
+            gapic_v1.routing_header.to_grpc_metadata((("name", request.name),)),
+        )
+
+        # Validate the universe domain.
+        self._client._validate_universe_domain()
+
+        # Send the request.
+        response = await rpc(
+            request,
+            retry=retry,
+            timeout=timeout,
+            metadata=metadata,
+        )
+
+        # Wrap the response in an operation future.
+        response = operation_async.from_gapic(
+            response,
+            self._client._transport.operations_client,
+            datastream_resources.Stream,
+            metadata_type=datastream.OperationMetadata,
+        )
+
+        # Done; return the response.
+        return response
+
     async def get_stream_object(
         self,
         request: Optional[Union[datastream.GetStreamObjectRequest, dict]] = None,
Original file line number	Diff line number	Diff line change
`@@ -13,4 +13,4 @@`
`13`	`13`	`# See the License for the specific language governing permissions and`
`14`	`14`	`# limitations under the License.`
`15`	`15`	`#`
`16`		`-__version__ = "1.10.1" # {x-release-please-version}`
	`16`	`+__version__ = "0.0.0" # {x-release-please-version}`