diff --git a/packages/google-cloud-datastream/README.md b/packages/google-cloud-datastream/README.md index abc51c351a5..f48a4e57464 100644 --- a/packages/google-cloud-datastream/README.md +++ b/packages/google-cloud-datastream/README.md @@ -2,7 +2,7 @@ [//]: # "To regenerate it, use `python -m synthtool`." Google Cloud Platform logo -# [Datastream: Node.js Client](https://github.com/googleapis/google-cloud-node) +# [Datastream: Node.js Client](https://github.com/googleapis/google-cloud-node/tree/main/packages/google-cloud-datastream) [![release level](https://img.shields.io/badge/release%20level-stable-brightgreen.svg?style=flat)](https://cloud.google.com/terms/launch-stages) [![npm version](https://img.shields.io/npm/v/@google-cloud/datastream.svg)](https://www.npmjs.org/package/@google-cloud/datastream) @@ -115,58 +115,57 @@ listConnectionProfiles(); ## Samples -Samples are in the [`samples/`](https://github.com/googleapis/google-cloud-node/tree/main/samples) directory. Each sample's `README.md` has instructions for running its sample. +Samples are in the [`samples/`](https://github.com/googleapis/google-cloud-node/tree/main/packages/google-cloud-datastream/samples) directory. Each sample's `README.md` has instructions for running its sample. | Sample | Source Code | Try it | | --------------------------- | --------------------------------- | ------ | -| Datastream.create_connection_profile | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.create_connection_profile.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.create_connection_profile.js,samples/README.md) | -| Datastream.create_private_connection | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.create_private_connection.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.create_private_connection.js,samples/README.md) | -| Datastream.create_route | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.create_route.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.create_route.js,samples/README.md) | -| Datastream.create_stream | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.create_stream.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.create_stream.js,samples/README.md) | -| Datastream.delete_connection_profile | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.delete_connection_profile.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.delete_connection_profile.js,samples/README.md) | -| Datastream.delete_private_connection | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.delete_private_connection.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.delete_private_connection.js,samples/README.md) | -| Datastream.delete_route | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.delete_route.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.delete_route.js,samples/README.md) | -| Datastream.delete_stream | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.delete_stream.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.delete_stream.js,samples/README.md) | -| Datastream.discover_connection_profile | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.discover_connection_profile.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.discover_connection_profile.js,samples/README.md) | -| Datastream.fetch_static_ips | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.fetch_static_ips.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.fetch_static_ips.js,samples/README.md) | -| Datastream.get_connection_profile | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.get_connection_profile.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.get_connection_profile.js,samples/README.md) | -| Datastream.get_private_connection | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.get_private_connection.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.get_private_connection.js,samples/README.md) | -| Datastream.get_route | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.get_route.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.get_route.js,samples/README.md) | -| Datastream.get_stream | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.get_stream.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.get_stream.js,samples/README.md) | -| Datastream.get_stream_object | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.get_stream_object.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.get_stream_object.js,samples/README.md) | -| Datastream.list_connection_profiles | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.list_connection_profiles.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.list_connection_profiles.js,samples/README.md) | -| Datastream.list_private_connections | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.list_private_connections.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.list_private_connections.js,samples/README.md) | -| Datastream.list_routes | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.list_routes.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.list_routes.js,samples/README.md) | -| Datastream.list_stream_objects | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.list_stream_objects.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.list_stream_objects.js,samples/README.md) | -| Datastream.list_streams | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.list_streams.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.list_streams.js,samples/README.md) | -| Datastream.lookup_stream_object | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.lookup_stream_object.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.lookup_stream_object.js,samples/README.md) | -| Datastream.start_backfill_job | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.start_backfill_job.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.start_backfill_job.js,samples/README.md) | -| Datastream.stop_backfill_job | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.stop_backfill_job.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.stop_backfill_job.js,samples/README.md) | -| Datastream.update_connection_profile | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.update_connection_profile.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.update_connection_profile.js,samples/README.md) | -| Datastream.update_stream | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.update_stream.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.update_stream.js,samples/README.md) | -| Datastream.create_connection_profile | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.create_connection_profile.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.create_connection_profile.js,samples/README.md) | -| Datastream.create_private_connection | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.create_private_connection.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.create_private_connection.js,samples/README.md) | -| Datastream.create_route | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.create_route.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.create_route.js,samples/README.md) | -| Datastream.create_stream | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.create_stream.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.create_stream.js,samples/README.md) | -| Datastream.delete_connection_profile | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.delete_connection_profile.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.delete_connection_profile.js,samples/README.md) | -| Datastream.delete_private_connection | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.delete_private_connection.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.delete_private_connection.js,samples/README.md) | -| Datastream.delete_route | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.delete_route.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.delete_route.js,samples/README.md) | -| Datastream.delete_stream | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.delete_stream.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.delete_stream.js,samples/README.md) | -| Datastream.discover_connection_profile | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.discover_connection_profile.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.discover_connection_profile.js,samples/README.md) | -| Datastream.fetch_errors | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.fetch_errors.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.fetch_errors.js,samples/README.md) | -| Datastream.fetch_static_ips | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.fetch_static_ips.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.fetch_static_ips.js,samples/README.md) | -| Datastream.get_connection_profile | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.get_connection_profile.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.get_connection_profile.js,samples/README.md) | -| Datastream.get_private_connection | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.get_private_connection.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.get_private_connection.js,samples/README.md) | -| Datastream.get_route | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.get_route.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.get_route.js,samples/README.md) | -| Datastream.get_stream | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.get_stream.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.get_stream.js,samples/README.md) | -| Datastream.list_connection_profiles | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.list_connection_profiles.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.list_connection_profiles.js,samples/README.md) | -| Datastream.list_private_connections | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.list_private_connections.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.list_private_connections.js,samples/README.md) | -| Datastream.list_routes | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.list_routes.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.list_routes.js,samples/README.md) | -| Datastream.list_streams | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.list_streams.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.list_streams.js,samples/README.md) | -| Datastream.update_connection_profile | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.update_connection_profile.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.update_connection_profile.js,samples/README.md) | -| Datastream.update_stream | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.update_stream.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.update_stream.js,samples/README.md) | -| Quickstart | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/quickstart.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/quickstart.js,samples/README.md) | -| Quickstart | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/test/quickstart.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/test/quickstart.js,samples/README.md) | +| Datastream.create_connection_profile | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.create_connection_profile.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.create_connection_profile.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.create_private_connection | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.create_private_connection.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.create_private_connection.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.create_route | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.create_route.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.create_route.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.create_stream | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.create_stream.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.create_stream.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.delete_connection_profile | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.delete_connection_profile.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.delete_connection_profile.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.delete_private_connection | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.delete_private_connection.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.delete_private_connection.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.delete_route | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.delete_route.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.delete_route.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.delete_stream | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.delete_stream.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.delete_stream.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.discover_connection_profile | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.discover_connection_profile.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.discover_connection_profile.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.fetch_static_ips | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.fetch_static_ips.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.fetch_static_ips.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.get_connection_profile | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.get_connection_profile.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.get_connection_profile.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.get_private_connection | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.get_private_connection.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.get_private_connection.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.get_route | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.get_route.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.get_route.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.get_stream | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.get_stream.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.get_stream.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.get_stream_object | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.get_stream_object.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.get_stream_object.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.list_connection_profiles | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.list_connection_profiles.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.list_connection_profiles.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.list_private_connections | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.list_private_connections.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.list_private_connections.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.list_routes | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.list_routes.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.list_routes.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.list_stream_objects | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.list_stream_objects.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.list_stream_objects.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.list_streams | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.list_streams.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.list_streams.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.lookup_stream_object | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.lookup_stream_object.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.lookup_stream_object.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.start_backfill_job | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.start_backfill_job.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.start_backfill_job.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.stop_backfill_job | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.stop_backfill_job.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.stop_backfill_job.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.update_connection_profile | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.update_connection_profile.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.update_connection_profile.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.update_stream | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1/datastream.update_stream.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1/datastream.update_stream.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.create_connection_profile | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.create_connection_profile.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.create_connection_profile.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.create_private_connection | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.create_private_connection.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.create_private_connection.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.create_route | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.create_route.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.create_route.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.create_stream | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.create_stream.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.create_stream.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.delete_connection_profile | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.delete_connection_profile.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.delete_connection_profile.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.delete_private_connection | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.delete_private_connection.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.delete_private_connection.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.delete_route | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.delete_route.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.delete_route.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.delete_stream | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.delete_stream.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.delete_stream.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.discover_connection_profile | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.discover_connection_profile.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.discover_connection_profile.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.fetch_errors | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.fetch_errors.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.fetch_errors.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.fetch_static_ips | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.fetch_static_ips.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.fetch_static_ips.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.get_connection_profile | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.get_connection_profile.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.get_connection_profile.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.get_private_connection | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.get_private_connection.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.get_private_connection.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.get_route | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.get_route.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.get_route.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.get_stream | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.get_stream.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.get_stream.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.list_connection_profiles | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.list_connection_profiles.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.list_connection_profiles.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.list_private_connections | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.list_private_connections.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.list_private_connections.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.list_routes | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.list_routes.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.list_routes.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.list_streams | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.list_streams.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.list_streams.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.update_connection_profile | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.update_connection_profile.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.update_connection_profile.js,packages/google-cloud-datastream/samples/README.md) | +| Datastream.update_stream | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.update_stream.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/generated/v1alpha1/datastream.update_stream.js,packages/google-cloud-datastream/samples/README.md) | +| Quickstart | [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/quickstart.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/quickstart.js,packages/google-cloud-datastream/samples/README.md) | diff --git a/packages/google-cloud-datastream/protos/google/cloud/datastream/v1/datastream.proto b/packages/google-cloud-datastream/protos/google/cloud/datastream/v1/datastream.proto index cd977079450..bf0b13f5e2a 100644 --- a/packages/google-cloud-datastream/protos/google/cloud/datastream/v1/datastream.proto +++ b/packages/google-cloud-datastream/protos/google/cloud/datastream/v1/datastream.proto @@ -1,4 +1,4 @@ -// Copyright 2022 Google LLC +// Copyright 2023 Google LLC // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. @@ -22,6 +22,7 @@ import "google/api/field_behavior.proto"; import "google/api/resource.proto"; import "google/cloud/datastream/v1/datastream_resources.proto"; import "google/longrunning/operations.proto"; +import "google/protobuf/empty.proto"; import "google/protobuf/field_mask.proto"; import "google/protobuf/timestamp.proto"; @@ -36,11 +37,13 @@ option ruby_package = "Google::Cloud::Datastream::V1"; // Datastream service service Datastream { option (google.api.default_host) = "datastream.googleapis.com"; - option (google.api.oauth_scopes) = "https://www.googleapis.com/auth/cloud-platform"; + option (google.api.oauth_scopes) = + "https://www.googleapis.com/auth/cloud-platform"; // Use this method to list connection profiles created in a project and // location. - rpc ListConnectionProfiles(ListConnectionProfilesRequest) returns (ListConnectionProfilesResponse) { + rpc ListConnectionProfiles(ListConnectionProfilesRequest) + returns (ListConnectionProfilesResponse) { option (google.api.http) = { get: "/v1/{parent=projects/*/locations/*}/connectionProfiles" }; @@ -48,7 +51,8 @@ service Datastream { } // Use this method to get details about a connection profile. - rpc GetConnectionProfile(GetConnectionProfileRequest) returns (ConnectionProfile) { + rpc GetConnectionProfile(GetConnectionProfileRequest) + returns (ConnectionProfile) { option (google.api.http) = { get: "/v1/{name=projects/*/locations/*/connectionProfiles/*}" }; @@ -56,12 +60,14 @@ service Datastream { } // Use this method to create a connection profile in a project and location. - rpc CreateConnectionProfile(CreateConnectionProfileRequest) returns (google.longrunning.Operation) { + rpc CreateConnectionProfile(CreateConnectionProfileRequest) + returns (google.longrunning.Operation) { option (google.api.http) = { post: "/v1/{parent=projects/*/locations/*}/connectionProfiles" body: "connection_profile" }; - option (google.api.method_signature) = "parent,connection_profile,connection_profile_id"; + option (google.api.method_signature) = + "parent,connection_profile,connection_profile_id"; option (google.longrunning.operation_info) = { response_type: "ConnectionProfile" metadata_type: "OperationMetadata" @@ -69,7 +75,8 @@ service Datastream { } // Use this method to update the parameters of a connection profile. - rpc UpdateConnectionProfile(UpdateConnectionProfileRequest) returns (google.longrunning.Operation) { + rpc UpdateConnectionProfile(UpdateConnectionProfileRequest) + returns (google.longrunning.Operation) { option (google.api.http) = { patch: "/v1/{connection_profile.name=projects/*/locations/*/connectionProfiles/*}" body: "connection_profile" @@ -82,7 +89,8 @@ service Datastream { } // Use this method to delete a connection profile. - rpc DeleteConnectionProfile(DeleteConnectionProfileRequest) returns (google.longrunning.Operation) { + rpc DeleteConnectionProfile(DeleteConnectionProfileRequest) + returns (google.longrunning.Operation) { option (google.api.http) = { delete: "/v1/{name=projects/*/locations/*/connectionProfiles/*}" }; @@ -97,7 +105,8 @@ service Datastream { // The discover API call exposes the data objects and metadata belonging to // the profile. Typically, a request returns children data objects of a // parent data object that's optionally supplied in the request. - rpc DiscoverConnectionProfile(DiscoverConnectionProfileRequest) returns (DiscoverConnectionProfileResponse) { + rpc DiscoverConnectionProfile(DiscoverConnectionProfileRequest) + returns (DiscoverConnectionProfileResponse) { option (google.api.http) = { post: "/v1/{parent=projects/*/locations/*}/connectionProfiles:discover" body: "*" @@ -175,7 +184,8 @@ service Datastream { } // Use this method to list the objects of a specific stream. - rpc ListStreamObjects(ListStreamObjectsRequest) returns (ListStreamObjectsResponse) { + rpc ListStreamObjects(ListStreamObjectsRequest) + returns (ListStreamObjectsResponse) { option (google.api.http) = { get: "/v1/{parent=projects/*/locations/*/streams/*}/objects" }; @@ -183,7 +193,8 @@ service Datastream { } // Use this method to start a backfill job for the specified stream object. - rpc StartBackfillJob(StartBackfillJobRequest) returns (StartBackfillJobResponse) { + rpc StartBackfillJob(StartBackfillJobRequest) + returns (StartBackfillJobResponse) { option (google.api.http) = { post: "/v1/{object=projects/*/locations/*/streams/*/objects/*}:startBackfillJob" body: "*" @@ -192,7 +203,8 @@ service Datastream { } // Use this method to stop a backfill job for the specified stream object. - rpc StopBackfillJob(StopBackfillJobRequest) returns (StopBackfillJobResponse) { + rpc StopBackfillJob(StopBackfillJobRequest) + returns (StopBackfillJobResponse) { option (google.api.http) = { post: "/v1/{object=projects/*/locations/*/streams/*/objects/*}:stopBackfillJob" body: "*" @@ -210,12 +222,14 @@ service Datastream { } // Use this method to create a private connectivity configuration. - rpc CreatePrivateConnection(CreatePrivateConnectionRequest) returns (google.longrunning.Operation) { + rpc CreatePrivateConnection(CreatePrivateConnectionRequest) + returns (google.longrunning.Operation) { option (google.api.http) = { post: "/v1/{parent=projects/*/locations/*}/privateConnections" body: "private_connection" }; - option (google.api.method_signature) = "parent,private_connection,private_connection_id"; + option (google.api.method_signature) = + "parent,private_connection,private_connection_id"; option (google.longrunning.operation_info) = { response_type: "PrivateConnection" metadata_type: "OperationMetadata" @@ -223,7 +237,8 @@ service Datastream { } // Use this method to get details about a private connectivity configuration. - rpc GetPrivateConnection(GetPrivateConnectionRequest) returns (PrivateConnection) { + rpc GetPrivateConnection(GetPrivateConnectionRequest) + returns (PrivateConnection) { option (google.api.http) = { get: "/v1/{name=projects/*/locations/*/privateConnections/*}" }; @@ -232,7 +247,8 @@ service Datastream { // Use this method to list private connectivity configurations in a project // and location. - rpc ListPrivateConnections(ListPrivateConnectionsRequest) returns (ListPrivateConnectionsResponse) { + rpc ListPrivateConnections(ListPrivateConnectionsRequest) + returns (ListPrivateConnectionsResponse) { option (google.api.http) = { get: "/v1/{parent=projects/*/locations/*}/privateConnections" }; @@ -240,7 +256,8 @@ service Datastream { } // Use this method to delete a private connectivity configuration. - rpc DeletePrivateConnection(DeletePrivateConnectionRequest) returns (google.longrunning.Operation) { + rpc DeletePrivateConnection(DeletePrivateConnectionRequest) + returns (google.longrunning.Operation) { option (google.api.http) = { delete: "/v1/{name=projects/*/locations/*/privateConnections/*}" }; @@ -297,8 +314,8 @@ service Datastream { // Request message for 'discover' ConnectionProfile request. message DiscoverConnectionProfileRequest { - // Required. The parent resource of the connection profile type. Must be in the - // format `projects/*/locations/*`. + // Required. The parent resource of the connection profile type. Must be in + // the format `projects/*/locations/*`. string parent = 1 [ (google.api.field_behavior) = REQUIRED, (google.api.resource_reference) = { @@ -355,8 +372,8 @@ message DiscoverConnectionProfileResponse { // Request message for 'FetchStaticIps' request. message FetchStaticIpsRequest { - // Required. The resource name for the location for which static IPs should be returned. - // Must be in the format `projects/*/locations/*`. + // Required. The resource name for the location for which static IPs should be + // returned. Must be in the format `projects/*/locations/*`. string name = 1 [ (google.api.field_behavior) = REQUIRED, (google.api.resource_reference) = { @@ -449,7 +466,8 @@ message CreateConnectionProfileRequest { string connection_profile_id = 2 [(google.api.field_behavior) = REQUIRED]; // Required. The connection profile resource to create. - ConnectionProfile connection_profile = 3 [(google.api.field_behavior) = REQUIRED]; + ConnectionProfile connection_profile = 3 + [(google.api.field_behavior) = REQUIRED]; // Optional. A request ID to identify requests. Specify a unique request ID // so that if you must retry your request, the server will know to ignore @@ -466,8 +484,8 @@ message CreateConnectionProfileRequest { // not supported (00000000-0000-0000-0000-000000000000). string request_id = 4 [(google.api.field_behavior) = OPTIONAL]; - // Optional. Only validate the connection profile, but don't create any resources. - // The default is false. + // Optional. Only validate the connection profile, but don't create any + // resources. The default is false. bool validate_only = 5 [(google.api.field_behavior) = OPTIONAL]; // Optional. Create the connection profile without validating it. @@ -481,10 +499,12 @@ message UpdateConnectionProfileRequest { // The fields specified in the update_mask are relative to the resource, not // the full request. A field will be overwritten if it is in the mask. If the // user does not provide a mask then all fields will be overwritten. - google.protobuf.FieldMask update_mask = 1 [(google.api.field_behavior) = OPTIONAL]; + google.protobuf.FieldMask update_mask = 1 + [(google.api.field_behavior) = OPTIONAL]; // Required. The connection profile to update. - ConnectionProfile connection_profile = 2 [(google.api.field_behavior) = REQUIRED]; + ConnectionProfile connection_profile = 2 + [(google.api.field_behavior) = REQUIRED]; // Optional. A request ID to identify requests. Specify a unique request ID // so that if you must retry your request, the server will know to ignore @@ -501,8 +521,8 @@ message UpdateConnectionProfileRequest { // not supported (00000000-0000-0000-0000-000000000000). string request_id = 3 [(google.api.field_behavior) = OPTIONAL]; - // Optional. Only validate the connection profile, but don't update any resources. - // The default is false. + // Optional. Only validate the connection profile, but don't update any + // resources. The default is false. bool validate_only = 4 [(google.api.field_behavior) = OPTIONAL]; // Optional. Update the connection profile without validating it. @@ -634,7 +654,8 @@ message UpdateStreamRequest { // The fields specified in the update_mask are relative to the resource, not // the full request. A field will be overwritten if it is in the mask. If the // user does not provide a mask then all fields will be overwritten. - google.protobuf.FieldMask update_mask = 1 [(google.api.field_behavior) = OPTIONAL]; + google.protobuf.FieldMask update_mask = 1 + [(google.api.field_behavior) = OPTIONAL]; // Required. The stream resource to update. Stream stream = 2 [(google.api.field_behavior) = REQUIRED]; @@ -654,8 +675,8 @@ message UpdateStreamRequest { // not supported (00000000-0000-0000-0000-000000000000). string request_id = 3 [(google.api.field_behavior) = OPTIONAL]; - // Optional. Only validate the stream with the changes, without actually updating it. - // The default is false. + // Optional. Only validate the stream with the changes, without actually + // updating it. The default is false. bool validate_only = 4 [(google.api.field_behavior) = OPTIONAL]; // Optional. Update the stream without validating it. @@ -711,12 +732,14 @@ message LookupStreamObjectRequest { ]; // Required. The source object identifier which maps to the stream object. - SourceObjectIdentifier source_object_identifier = 2 [(google.api.field_behavior) = REQUIRED]; + SourceObjectIdentifier source_object_identifier = 2 + [(google.api.field_behavior) = REQUIRED]; } // Request for manually initiating a backfill job for a specific stream object. message StartBackfillJobRequest { - // Required. The name of the stream object resource to start a backfill job for. + // Required. The name of the stream object resource to start a backfill job + // for. string object = 1 [ (google.api.field_behavior) = REQUIRED, (google.api.resource_reference) = { @@ -734,7 +757,8 @@ message StartBackfillJobResponse { // Request for manually stopping a running backfill job for a specific stream // object. message StopBackfillJobRequest { - // Required. The name of the stream object resource to stop the backfill job for. + // Required. The name of the stream object resource to stop the backfill job + // for. string object = 1 [ (google.api.field_behavior) = REQUIRED, (google.api.resource_reference) = { @@ -784,10 +808,12 @@ message ListStreamObjectsResponse { // Represents the metadata of the long-running operation. message OperationMetadata { // Output only. The time the operation was created. - google.protobuf.Timestamp create_time = 1 [(google.api.field_behavior) = OUTPUT_ONLY]; + google.protobuf.Timestamp create_time = 1 + [(google.api.field_behavior) = OUTPUT_ONLY]; // Output only. The time the operation finished running. - google.protobuf.Timestamp end_time = 2 [(google.api.field_behavior) = OUTPUT_ONLY]; + google.protobuf.Timestamp end_time = 2 + [(google.api.field_behavior) = OUTPUT_ONLY]; // Output only. Server-defined resource path for the target of the operation. string target = 3 [(google.api.field_behavior) = OUTPUT_ONLY]; @@ -800,15 +826,17 @@ message OperationMetadata { // Output only. Identifies whether the user has requested cancellation // of the operation. Operations that have successfully been cancelled - // have [Operation.error][] value with a [google.rpc.Status.code][google.rpc.Status.code] of 1, - // corresponding to `Code.CANCELLED`. + // have [Operation.error][] value with a + // [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to + // `Code.CANCELLED`. bool requested_cancellation = 6 [(google.api.field_behavior) = OUTPUT_ONLY]; // Output only. API version used to start the operation. string api_version = 7 [(google.api.field_behavior) = OUTPUT_ONLY]; // Output only. Results of executed validations if there are any. - ValidationResult validation_result = 8 [(google.api.field_behavior) = OUTPUT_ONLY]; + ValidationResult validation_result = 8 + [(google.api.field_behavior) = OUTPUT_ONLY]; } // Request for creating a private connection. @@ -825,7 +853,8 @@ message CreatePrivateConnectionRequest { string private_connection_id = 2 [(google.api.field_behavior) = REQUIRED]; // Required. The Private Connectivity resource to create. - PrivateConnection private_connection = 3 [(google.api.field_behavior) = REQUIRED]; + PrivateConnection private_connection = 3 + [(google.api.field_behavior) = REQUIRED]; // Optional. A request ID to identify requests. Specify a unique request ID // so that if you must retry your request, the server will know to ignore @@ -841,11 +870,15 @@ message CreatePrivateConnectionRequest { // The request ID must be a valid UUID with the exception that zero UUID is // not supported (00000000-0000-0000-0000-000000000000). string request_id = 4 [(google.api.field_behavior) = OPTIONAL]; + + // Optional. If set to true, will skip validations. + bool force = 6 [(google.api.field_behavior) = OPTIONAL]; } // Request for listing private connections. message ListPrivateConnectionsRequest { - // Required. The parent that owns the collection of private connectivity configurations. + // Required. The parent that owns the collection of private connectivity + // configurations. string parent = 1 [ (google.api.field_behavior) = REQUIRED, (google.api.resource_reference) = { @@ -912,8 +945,8 @@ message DeletePrivateConnectionRequest { // not supported (00000000-0000-0000-0000-000000000000). string request_id = 2 [(google.api.field_behavior) = OPTIONAL]; - // Optional. If set to true, any child routes that belong to this PrivateConnection will - // also be deleted. + // Optional. If set to true, any child routes that belong to this + // PrivateConnection will also be deleted. bool force = 3 [(google.api.field_behavior) = OPTIONAL]; } diff --git a/packages/google-cloud-datastream/protos/google/cloud/datastream/v1/datastream_resources.proto b/packages/google-cloud-datastream/protos/google/cloud/datastream/v1/datastream_resources.proto index 80a8deeaefb..1007939dc8b 100644 --- a/packages/google-cloud-datastream/protos/google/cloud/datastream/v1/datastream_resources.proto +++ b/packages/google-cloud-datastream/protos/google/cloud/datastream/v1/datastream_resources.proto @@ -1,4 +1,4 @@ -// Copyright 2022 Google LLC +// Copyright 2023 Google LLC // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. @@ -103,14 +103,12 @@ message GcsProfile { } // BigQuery warehouse profile. -message BigQueryProfile { +message BigQueryProfile {} -} - -// Static IP address connectivity. -message StaticServiceIpConnectivity { - -} +// Static IP address connectivity. Used when the source database is configured +// to allow incoming connections from the Datastream public IP addresses +// for the region specified in the connection profile. +message StaticServiceIpConnectivity {} // Forward SSH Tunnel connectivity. message ForwardSshTunnelConnectivity { @@ -181,10 +179,12 @@ message PrivateConnection { string name = 1 [(google.api.field_behavior) = OUTPUT_ONLY]; // Output only. The create time of the resource. - google.protobuf.Timestamp create_time = 2 [(google.api.field_behavior) = OUTPUT_ONLY]; + google.protobuf.Timestamp create_time = 2 + [(google.api.field_behavior) = OUTPUT_ONLY]; // Output only. The update time of the resource. - google.protobuf.Timestamp update_time = 3 [(google.api.field_behavior) = OUTPUT_ONLY]; + google.protobuf.Timestamp update_time = 3 + [(google.api.field_behavior) = OUTPUT_ONLY]; // Labels. map labels = 4; @@ -195,7 +195,8 @@ message PrivateConnection { // Output only. The state of the Private Connection. State state = 6 [(google.api.field_behavior) = OUTPUT_ONLY]; - // Output only. In case of error, the details of the error in a user-friendly format. + // Output only. In case of error, the details of the error in a user-friendly + // format. Error error = 7 [(google.api.field_behavior) = OUTPUT_ONLY]; // VPC Peering Config. @@ -226,10 +227,12 @@ message Route { string name = 1 [(google.api.field_behavior) = OUTPUT_ONLY]; // Output only. The create time of the resource. - google.protobuf.Timestamp create_time = 2 [(google.api.field_behavior) = OUTPUT_ONLY]; + google.protobuf.Timestamp create_time = 2 + [(google.api.field_behavior) = OUTPUT_ONLY]; // Output only. The update time of the resource. - google.protobuf.Timestamp update_time = 3 [(google.api.field_behavior) = OUTPUT_ONLY]; + google.protobuf.Timestamp update_time = 3 + [(google.api.field_behavior) = OUTPUT_ONLY]; // Labels. map labels = 4; @@ -262,8 +265,8 @@ message MysqlSslConfig { // Output only. Indicates whether the client_certificate field is set. bool client_certificate_set = 4 [(google.api.field_behavior) = OUTPUT_ONLY]; - // Input only. PEM-encoded certificate of the CA that signed the source database - // server's certificate. + // Input only. PEM-encoded certificate of the CA that signed the source + // database server's certificate. string ca_certificate = 5 [(google.api.field_behavior) = INPUT_ONLY]; // Output only. Indicates whether the ca_certificate field is set. @@ -282,10 +285,12 @@ message ConnectionProfile { string name = 1 [(google.api.field_behavior) = OUTPUT_ONLY]; // Output only. The create time of the resource. - google.protobuf.Timestamp create_time = 2 [(google.api.field_behavior) = OUTPUT_ONLY]; + google.protobuf.Timestamp create_time = 2 + [(google.api.field_behavior) = OUTPUT_ONLY]; // Output only. The update time of the resource. - google.protobuf.Timestamp update_time = 3 [(google.api.field_behavior) = OUTPUT_ONLY]; + google.protobuf.Timestamp update_time = 3 + [(google.api.field_behavior) = OUTPUT_ONLY]; // Labels. map labels = 4; @@ -383,14 +388,10 @@ message OracleRdbms { // Oracle data source configuration message OracleSourceConfig { // Configuration to drop large object values. - message DropLargeObjects { - - } + message DropLargeObjects {} // Configuration to stream large object values. - message StreamLargeObjects { - - } + message StreamLargeObjects {} // Oracle objects to include in the stream. OracleRdbms include_objects = 1; @@ -398,16 +399,20 @@ message OracleSourceConfig { // Oracle objects to exclude from the stream. OracleRdbms exclude_objects = 2; - // Maximum number of concurrent CDC tasks. The number should be non negative. - // If not set (or set to 0), the system's default value will be used. + // Maximum number of concurrent CDC tasks. The number should be non-negative. + // If not set (or set to 0), the system's default value is used. int32 max_concurrent_cdc_tasks = 3; + // Maximum number of concurrent backfill tasks. The number should be + // non-negative. If not set (or set to 0), the system's default value is used. + int32 max_concurrent_backfill_tasks = 4; + // The configuration for handle Oracle large objects. oneof large_objects_handling { // Drop large object values. DropLargeObjects drop_large_objects = 100; - // Stream large object values. + // Stream large object values. NOTE: This feature is currently experimental. StreamLargeObjects stream_large_objects = 102; } } @@ -473,13 +478,21 @@ message PostgresqlSourceConfig { // PostgreSQL objects to exclude from the stream. PostgresqlRdbms exclude_objects = 2; - // Required. The name of the logical replication slot that's configured with the - // pgoutput plugin. - string replication_slot = 3 [(google.api.field_behavior) = REQUIRED]; + // Required. Immutable. The name of the logical replication slot that's + // configured with the pgoutput plugin. + string replication_slot = 3 [ + (google.api.field_behavior) = REQUIRED, + (google.api.field_behavior) = IMMUTABLE + ]; - // Required. The name of the publication that includes the set of all tables that are - // defined in the stream's include_objects. + // Required. The name of the publication that includes the set of all tables + // that are defined in the stream's include_objects. string publication = 4 [(google.api.field_behavior) = REQUIRED]; + + // Maximum number of concurrent backfill tasks. The number should be non + // negative. If not set (or set to 0), the system's default value will be + // used. + int32 max_concurrent_backfill_tasks = 5; } // MySQL Column. @@ -544,6 +557,11 @@ message MysqlSourceConfig { // Maximum number of concurrent CDC tasks. The number should be non negative. // If not set (or set to 0), the system's default value will be used. int32 max_concurrent_cdc_tasks = 3; + + // Maximum number of concurrent backfill tasks. The number should be non + // negative. If not set (or set to 0), the system's default value will be + // used. + int32 max_concurrent_backfill_tasks = 4; } // The configuration of the stream source. @@ -571,9 +589,7 @@ message SourceConfig { } // AVRO file format configuration. -message AvroFileFormat { - -} +message AvroFileFormat {} // JSON file format configuration. message JsonFileFormat { @@ -617,7 +633,8 @@ message GcsDestinationConfig { int32 file_rotation_mb = 2; // The maximum duration for which new events are added before a file is - // closed and a new file is created. + // closed and a new file is created. Values within the range of 15-60 seconds + // are allowed. google.protobuf.Duration file_rotation_interval = 3; // File Format that the data should be written in. @@ -630,9 +647,11 @@ message GcsDestinationConfig { } } +// BigQuery destination configuration message BigQueryDestinationConfig { // A single target dataset to which all data will be streamed. message SingleTargetDataset { + // The dataset ID of the target dataset. string dataset_id = 1; } @@ -661,6 +680,7 @@ message BigQueryDestinationConfig { string kms_key_name = 3; } + // The dataset template to use for dynamic dataset creation. DatasetTemplate dataset_template = 2; } @@ -759,18 +779,18 @@ message Stream { } // Backfill strategy to disable automatic backfill for the Stream's objects. - message BackfillNoneStrategy { - - } + message BackfillNoneStrategy {} // Output only. The stream's name. string name = 1 [(google.api.field_behavior) = OUTPUT_ONLY]; // Output only. The creation time of the stream. - google.protobuf.Timestamp create_time = 2 [(google.api.field_behavior) = OUTPUT_ONLY]; + google.protobuf.Timestamp create_time = 2 + [(google.api.field_behavior) = OUTPUT_ONLY]; // Output only. The last update time of the stream. - google.protobuf.Timestamp update_time = 3 [(google.api.field_behavior) = OUTPUT_ONLY]; + google.protobuf.Timestamp update_time = 3 + [(google.api.field_behavior) = OUTPUT_ONLY]; // Labels. map labels = 4; @@ -782,7 +802,8 @@ message Stream { SourceConfig source_config = 6 [(google.api.field_behavior) = REQUIRED]; // Required. Destination connection profile configuration. - DestinationConfig destination_config = 7 [(google.api.field_behavior) = REQUIRED]; + DestinationConfig destination_config = 7 + [(google.api.field_behavior) = REQUIRED]; // The state of the stream. State state = 8; @@ -804,7 +825,8 @@ message Stream { // If provided, it will be used to encrypt the data. // If left blank, data will be encrypted using an internal Stream-specific // encryption key provisioned through KMS. - optional string customer_managed_encryption_key = 10 [(google.api.field_behavior) = IMMUTABLE]; + optional string customer_managed_encryption_key = 10 + [(google.api.field_behavior) = IMMUTABLE]; } // A specific stream object (e.g a specific DB table). @@ -818,10 +840,12 @@ message StreamObject { string name = 1 [(google.api.field_behavior) = OUTPUT_ONLY]; // Output only. The creation time of the object. - google.protobuf.Timestamp create_time = 2 [(google.api.field_behavior) = OUTPUT_ONLY]; + google.protobuf.Timestamp create_time = 2 + [(google.api.field_behavior) = OUTPUT_ONLY]; // Output only. The last update time of the object. - google.protobuf.Timestamp update_time = 3 [(google.api.field_behavior) = OUTPUT_ONLY]; + google.protobuf.Timestamp update_time = 3 + [(google.api.field_behavior) = OUTPUT_ONLY]; // Required. Display name. string display_name = 5 [(google.api.field_behavior) = REQUIRED]; @@ -930,10 +954,12 @@ message BackfillJob { Trigger trigger = 2; // Output only. Backfill job's start time. - google.protobuf.Timestamp last_start_time = 3 [(google.api.field_behavior) = OUTPUT_ONLY]; + google.protobuf.Timestamp last_start_time = 3 + [(google.api.field_behavior) = OUTPUT_ONLY]; // Output only. Backfill job's end time. - google.protobuf.Timestamp last_end_time = 4 [(google.api.field_behavior) = OUTPUT_ONLY]; + google.protobuf.Timestamp last_end_time = 4 + [(google.api.field_behavior) = OUTPUT_ONLY]; // Output only. Errors which caused the backfill job to fail. repeated Error errors = 5 [(google.api.field_behavior) = OUTPUT_ONLY]; diff --git a/packages/google-cloud-datastream/protos/protos.d.ts b/packages/google-cloud-datastream/protos/protos.d.ts index ce591f8aa3c..d6e511be1be 100644 --- a/packages/google-cloud-datastream/protos/protos.d.ts +++ b/packages/google-cloud-datastream/protos/protos.d.ts @@ -3356,6 +3356,9 @@ export namespace google { /** CreatePrivateConnectionRequest requestId */ requestId?: (string|null); + + /** CreatePrivateConnectionRequest force */ + force?: (boolean|null); } /** Represents a CreatePrivateConnectionRequest. */ @@ -3379,6 +3382,9 @@ export namespace google { /** CreatePrivateConnectionRequest requestId. */ public requestId: string; + /** CreatePrivateConnectionRequest force. */ + public force: boolean; + /** * Creates a new CreatePrivateConnectionRequest instance using the specified properties. * @param [properties] Properties to set @@ -6463,6 +6469,9 @@ export namespace google { /** OracleSourceConfig maxConcurrentCdcTasks */ maxConcurrentCdcTasks?: (number|null); + /** OracleSourceConfig maxConcurrentBackfillTasks */ + maxConcurrentBackfillTasks?: (number|null); + /** OracleSourceConfig dropLargeObjects */ dropLargeObjects?: (google.cloud.datastream.v1.OracleSourceConfig.IDropLargeObjects|null); @@ -6488,6 +6497,9 @@ export namespace google { /** OracleSourceConfig maxConcurrentCdcTasks. */ public maxConcurrentCdcTasks: number; + /** OracleSourceConfig maxConcurrentBackfillTasks. */ + public maxConcurrentBackfillTasks: number; + /** OracleSourceConfig dropLargeObjects. */ public dropLargeObjects?: (google.cloud.datastream.v1.OracleSourceConfig.IDropLargeObjects|null); @@ -7216,6 +7228,9 @@ export namespace google { /** PostgresqlSourceConfig publication */ publication?: (string|null); + + /** PostgresqlSourceConfig maxConcurrentBackfillTasks */ + maxConcurrentBackfillTasks?: (number|null); } /** Represents a PostgresqlSourceConfig. */ @@ -7239,6 +7254,9 @@ export namespace google { /** PostgresqlSourceConfig publication. */ public publication: string; + /** PostgresqlSourceConfig maxConcurrentBackfillTasks. */ + public maxConcurrentBackfillTasks: number; + /** * Creates a new PostgresqlSourceConfig instance using the specified properties. * @param [properties] Properties to set @@ -7764,6 +7782,9 @@ export namespace google { /** MysqlSourceConfig maxConcurrentCdcTasks */ maxConcurrentCdcTasks?: (number|null); + + /** MysqlSourceConfig maxConcurrentBackfillTasks */ + maxConcurrentBackfillTasks?: (number|null); } /** Represents a MysqlSourceConfig. */ @@ -7784,6 +7805,9 @@ export namespace google { /** MysqlSourceConfig maxConcurrentCdcTasks. */ public maxConcurrentCdcTasks: number; + /** MysqlSourceConfig maxConcurrentBackfillTasks. */ + public maxConcurrentBackfillTasks: number; + /** * Creates a new MysqlSourceConfig instance using the specified properties. * @param [properties] Properties to set diff --git a/packages/google-cloud-datastream/protos/protos.js b/packages/google-cloud-datastream/protos/protos.js index 098953c87e5..358f987df6e 100644 --- a/packages/google-cloud-datastream/protos/protos.js +++ b/packages/google-cloud-datastream/protos/protos.js @@ -7610,6 +7610,7 @@ * @property {string|null} [privateConnectionId] CreatePrivateConnectionRequest privateConnectionId * @property {google.cloud.datastream.v1.IPrivateConnection|null} [privateConnection] CreatePrivateConnectionRequest privateConnection * @property {string|null} [requestId] CreatePrivateConnectionRequest requestId + * @property {boolean|null} [force] CreatePrivateConnectionRequest force */ /** @@ -7659,6 +7660,14 @@ */ CreatePrivateConnectionRequest.prototype.requestId = ""; + /** + * CreatePrivateConnectionRequest force. + * @member {boolean} force + * @memberof google.cloud.datastream.v1.CreatePrivateConnectionRequest + * @instance + */ + CreatePrivateConnectionRequest.prototype.force = false; + /** * Creates a new CreatePrivateConnectionRequest instance using the specified properties. * @function create @@ -7691,6 +7700,8 @@ $root.google.cloud.datastream.v1.PrivateConnection.encode(message.privateConnection, writer.uint32(/* id 3, wireType 2 =*/26).fork()).ldelim(); if (message.requestId != null && Object.hasOwnProperty.call(message, "requestId")) writer.uint32(/* id 4, wireType 2 =*/34).string(message.requestId); + if (message.force != null && Object.hasOwnProperty.call(message, "force")) + writer.uint32(/* id 6, wireType 0 =*/48).bool(message.force); return writer; }; @@ -7741,6 +7752,10 @@ message.requestId = reader.string(); break; } + case 6: { + message.force = reader.bool(); + break; + } default: reader.skipType(tag & 7); break; @@ -7790,6 +7805,9 @@ if (message.requestId != null && message.hasOwnProperty("requestId")) if (!$util.isString(message.requestId)) return "requestId: string expected"; + if (message.force != null && message.hasOwnProperty("force")) + if (typeof message.force !== "boolean") + return "force: boolean expected"; return null; }; @@ -7816,6 +7834,8 @@ } if (object.requestId != null) message.requestId = String(object.requestId); + if (object.force != null) + message.force = Boolean(object.force); return message; }; @@ -7837,6 +7857,7 @@ object.privateConnectionId = ""; object.privateConnection = null; object.requestId = ""; + object.force = false; } if (message.parent != null && message.hasOwnProperty("parent")) object.parent = message.parent; @@ -7846,6 +7867,8 @@ object.privateConnection = $root.google.cloud.datastream.v1.PrivateConnection.toObject(message.privateConnection, options); if (message.requestId != null && message.hasOwnProperty("requestId")) object.requestId = message.requestId; + if (message.force != null && message.hasOwnProperty("force")) + object.force = message.force; return object; }; @@ -15437,6 +15460,7 @@ * @property {google.cloud.datastream.v1.IOracleRdbms|null} [includeObjects] OracleSourceConfig includeObjects * @property {google.cloud.datastream.v1.IOracleRdbms|null} [excludeObjects] OracleSourceConfig excludeObjects * @property {number|null} [maxConcurrentCdcTasks] OracleSourceConfig maxConcurrentCdcTasks + * @property {number|null} [maxConcurrentBackfillTasks] OracleSourceConfig maxConcurrentBackfillTasks * @property {google.cloud.datastream.v1.OracleSourceConfig.IDropLargeObjects|null} [dropLargeObjects] OracleSourceConfig dropLargeObjects * @property {google.cloud.datastream.v1.OracleSourceConfig.IStreamLargeObjects|null} [streamLargeObjects] OracleSourceConfig streamLargeObjects */ @@ -15480,6 +15504,14 @@ */ OracleSourceConfig.prototype.maxConcurrentCdcTasks = 0; + /** + * OracleSourceConfig maxConcurrentBackfillTasks. + * @member {number} maxConcurrentBackfillTasks + * @memberof google.cloud.datastream.v1.OracleSourceConfig + * @instance + */ + OracleSourceConfig.prototype.maxConcurrentBackfillTasks = 0; + /** * OracleSourceConfig dropLargeObjects. * @member {google.cloud.datastream.v1.OracleSourceConfig.IDropLargeObjects|null|undefined} dropLargeObjects @@ -15540,6 +15572,8 @@ $root.google.cloud.datastream.v1.OracleRdbms.encode(message.excludeObjects, writer.uint32(/* id 2, wireType 2 =*/18).fork()).ldelim(); if (message.maxConcurrentCdcTasks != null && Object.hasOwnProperty.call(message, "maxConcurrentCdcTasks")) writer.uint32(/* id 3, wireType 0 =*/24).int32(message.maxConcurrentCdcTasks); + if (message.maxConcurrentBackfillTasks != null && Object.hasOwnProperty.call(message, "maxConcurrentBackfillTasks")) + writer.uint32(/* id 4, wireType 0 =*/32).int32(message.maxConcurrentBackfillTasks); if (message.dropLargeObjects != null && Object.hasOwnProperty.call(message, "dropLargeObjects")) $root.google.cloud.datastream.v1.OracleSourceConfig.DropLargeObjects.encode(message.dropLargeObjects, writer.uint32(/* id 100, wireType 2 =*/802).fork()).ldelim(); if (message.streamLargeObjects != null && Object.hasOwnProperty.call(message, "streamLargeObjects")) @@ -15590,6 +15624,10 @@ message.maxConcurrentCdcTasks = reader.int32(); break; } + case 4: { + message.maxConcurrentBackfillTasks = reader.int32(); + break; + } case 100: { message.dropLargeObjects = $root.google.cloud.datastream.v1.OracleSourceConfig.DropLargeObjects.decode(reader, reader.uint32()); break; @@ -15647,6 +15685,9 @@ if (message.maxConcurrentCdcTasks != null && message.hasOwnProperty("maxConcurrentCdcTasks")) if (!$util.isInteger(message.maxConcurrentCdcTasks)) return "maxConcurrentCdcTasks: integer expected"; + if (message.maxConcurrentBackfillTasks != null && message.hasOwnProperty("maxConcurrentBackfillTasks")) + if (!$util.isInteger(message.maxConcurrentBackfillTasks)) + return "maxConcurrentBackfillTasks: integer expected"; if (message.dropLargeObjects != null && message.hasOwnProperty("dropLargeObjects")) { properties.largeObjectsHandling = 1; { @@ -15692,6 +15733,8 @@ } if (object.maxConcurrentCdcTasks != null) message.maxConcurrentCdcTasks = object.maxConcurrentCdcTasks | 0; + if (object.maxConcurrentBackfillTasks != null) + message.maxConcurrentBackfillTasks = object.maxConcurrentBackfillTasks | 0; if (object.dropLargeObjects != null) { if (typeof object.dropLargeObjects !== "object") throw TypeError(".google.cloud.datastream.v1.OracleSourceConfig.dropLargeObjects: object expected"); @@ -15722,6 +15765,7 @@ object.includeObjects = null; object.excludeObjects = null; object.maxConcurrentCdcTasks = 0; + object.maxConcurrentBackfillTasks = 0; } if (message.includeObjects != null && message.hasOwnProperty("includeObjects")) object.includeObjects = $root.google.cloud.datastream.v1.OracleRdbms.toObject(message.includeObjects, options); @@ -15729,6 +15773,8 @@ object.excludeObjects = $root.google.cloud.datastream.v1.OracleRdbms.toObject(message.excludeObjects, options); if (message.maxConcurrentCdcTasks != null && message.hasOwnProperty("maxConcurrentCdcTasks")) object.maxConcurrentCdcTasks = message.maxConcurrentCdcTasks; + if (message.maxConcurrentBackfillTasks != null && message.hasOwnProperty("maxConcurrentBackfillTasks")) + object.maxConcurrentBackfillTasks = message.maxConcurrentBackfillTasks; if (message.dropLargeObjects != null && message.hasOwnProperty("dropLargeObjects")) { object.dropLargeObjects = $root.google.cloud.datastream.v1.OracleSourceConfig.DropLargeObjects.toObject(message.dropLargeObjects, options); if (options.oneofs) @@ -17216,6 +17262,7 @@ * @property {google.cloud.datastream.v1.IPostgresqlRdbms|null} [excludeObjects] PostgresqlSourceConfig excludeObjects * @property {string|null} [replicationSlot] PostgresqlSourceConfig replicationSlot * @property {string|null} [publication] PostgresqlSourceConfig publication + * @property {number|null} [maxConcurrentBackfillTasks] PostgresqlSourceConfig maxConcurrentBackfillTasks */ /** @@ -17265,6 +17312,14 @@ */ PostgresqlSourceConfig.prototype.publication = ""; + /** + * PostgresqlSourceConfig maxConcurrentBackfillTasks. + * @member {number} maxConcurrentBackfillTasks + * @memberof google.cloud.datastream.v1.PostgresqlSourceConfig + * @instance + */ + PostgresqlSourceConfig.prototype.maxConcurrentBackfillTasks = 0; + /** * Creates a new PostgresqlSourceConfig instance using the specified properties. * @function create @@ -17297,6 +17352,8 @@ writer.uint32(/* id 3, wireType 2 =*/26).string(message.replicationSlot); if (message.publication != null && Object.hasOwnProperty.call(message, "publication")) writer.uint32(/* id 4, wireType 2 =*/34).string(message.publication); + if (message.maxConcurrentBackfillTasks != null && Object.hasOwnProperty.call(message, "maxConcurrentBackfillTasks")) + writer.uint32(/* id 5, wireType 0 =*/40).int32(message.maxConcurrentBackfillTasks); return writer; }; @@ -17347,6 +17404,10 @@ message.publication = reader.string(); break; } + case 5: { + message.maxConcurrentBackfillTasks = reader.int32(); + break; + } default: reader.skipType(tag & 7); break; @@ -17398,6 +17459,9 @@ if (message.publication != null && message.hasOwnProperty("publication")) if (!$util.isString(message.publication)) return "publication: string expected"; + if (message.maxConcurrentBackfillTasks != null && message.hasOwnProperty("maxConcurrentBackfillTasks")) + if (!$util.isInteger(message.maxConcurrentBackfillTasks)) + return "maxConcurrentBackfillTasks: integer expected"; return null; }; @@ -17427,6 +17491,8 @@ message.replicationSlot = String(object.replicationSlot); if (object.publication != null) message.publication = String(object.publication); + if (object.maxConcurrentBackfillTasks != null) + message.maxConcurrentBackfillTasks = object.maxConcurrentBackfillTasks | 0; return message; }; @@ -17448,6 +17514,7 @@ object.excludeObjects = null; object.replicationSlot = ""; object.publication = ""; + object.maxConcurrentBackfillTasks = 0; } if (message.includeObjects != null && message.hasOwnProperty("includeObjects")) object.includeObjects = $root.google.cloud.datastream.v1.PostgresqlRdbms.toObject(message.includeObjects, options); @@ -17457,6 +17524,8 @@ object.replicationSlot = message.replicationSlot; if (message.publication != null && message.hasOwnProperty("publication")) object.publication = message.publication; + if (message.maxConcurrentBackfillTasks != null && message.hasOwnProperty("maxConcurrentBackfillTasks")) + object.maxConcurrentBackfillTasks = message.maxConcurrentBackfillTasks; return object; }; @@ -18560,6 +18629,7 @@ * @property {google.cloud.datastream.v1.IMysqlRdbms|null} [includeObjects] MysqlSourceConfig includeObjects * @property {google.cloud.datastream.v1.IMysqlRdbms|null} [excludeObjects] MysqlSourceConfig excludeObjects * @property {number|null} [maxConcurrentCdcTasks] MysqlSourceConfig maxConcurrentCdcTasks + * @property {number|null} [maxConcurrentBackfillTasks] MysqlSourceConfig maxConcurrentBackfillTasks */ /** @@ -18601,6 +18671,14 @@ */ MysqlSourceConfig.prototype.maxConcurrentCdcTasks = 0; + /** + * MysqlSourceConfig maxConcurrentBackfillTasks. + * @member {number} maxConcurrentBackfillTasks + * @memberof google.cloud.datastream.v1.MysqlSourceConfig + * @instance + */ + MysqlSourceConfig.prototype.maxConcurrentBackfillTasks = 0; + /** * Creates a new MysqlSourceConfig instance using the specified properties. * @function create @@ -18631,6 +18709,8 @@ $root.google.cloud.datastream.v1.MysqlRdbms.encode(message.excludeObjects, writer.uint32(/* id 2, wireType 2 =*/18).fork()).ldelim(); if (message.maxConcurrentCdcTasks != null && Object.hasOwnProperty.call(message, "maxConcurrentCdcTasks")) writer.uint32(/* id 3, wireType 0 =*/24).int32(message.maxConcurrentCdcTasks); + if (message.maxConcurrentBackfillTasks != null && Object.hasOwnProperty.call(message, "maxConcurrentBackfillTasks")) + writer.uint32(/* id 4, wireType 0 =*/32).int32(message.maxConcurrentBackfillTasks); return writer; }; @@ -18677,6 +18757,10 @@ message.maxConcurrentCdcTasks = reader.int32(); break; } + case 4: { + message.maxConcurrentBackfillTasks = reader.int32(); + break; + } default: reader.skipType(tag & 7); break; @@ -18725,6 +18809,9 @@ if (message.maxConcurrentCdcTasks != null && message.hasOwnProperty("maxConcurrentCdcTasks")) if (!$util.isInteger(message.maxConcurrentCdcTasks)) return "maxConcurrentCdcTasks: integer expected"; + if (message.maxConcurrentBackfillTasks != null && message.hasOwnProperty("maxConcurrentBackfillTasks")) + if (!$util.isInteger(message.maxConcurrentBackfillTasks)) + return "maxConcurrentBackfillTasks: integer expected"; return null; }; @@ -18752,6 +18839,8 @@ } if (object.maxConcurrentCdcTasks != null) message.maxConcurrentCdcTasks = object.maxConcurrentCdcTasks | 0; + if (object.maxConcurrentBackfillTasks != null) + message.maxConcurrentBackfillTasks = object.maxConcurrentBackfillTasks | 0; return message; }; @@ -18772,6 +18861,7 @@ object.includeObjects = null; object.excludeObjects = null; object.maxConcurrentCdcTasks = 0; + object.maxConcurrentBackfillTasks = 0; } if (message.includeObjects != null && message.hasOwnProperty("includeObjects")) object.includeObjects = $root.google.cloud.datastream.v1.MysqlRdbms.toObject(message.includeObjects, options); @@ -18779,6 +18869,8 @@ object.excludeObjects = $root.google.cloud.datastream.v1.MysqlRdbms.toObject(message.excludeObjects, options); if (message.maxConcurrentCdcTasks != null && message.hasOwnProperty("maxConcurrentCdcTasks")) object.maxConcurrentCdcTasks = message.maxConcurrentCdcTasks; + if (message.maxConcurrentBackfillTasks != null && message.hasOwnProperty("maxConcurrentBackfillTasks")) + object.maxConcurrentBackfillTasks = message.maxConcurrentBackfillTasks; return object; }; diff --git a/packages/google-cloud-datastream/protos/protos.json b/packages/google-cloud-datastream/protos/protos.json index 1735d370cb6..23d3888d8c7 100644 --- a/packages/google-cloud-datastream/protos/protos.json +++ b/packages/google-cloud-datastream/protos/protos.json @@ -1208,6 +1208,13 @@ "options": { "(google.api.field_behavior)": "OPTIONAL" } + }, + "force": { + "type": "bool", + "id": 6, + "options": { + "(google.api.field_behavior)": "OPTIONAL" + } } } }, @@ -1968,6 +1975,10 @@ "type": "int32", "id": 3 }, + "maxConcurrentBackfillTasks": { + "type": "int32", + "id": 4 + }, "dropLargeObjects": { "type": "DropLargeObjects", "id": 100 @@ -2071,7 +2082,7 @@ "type": "string", "id": 3, "options": { - "(google.api.field_behavior)": "REQUIRED" + "(google.api.field_behavior)": "IMMUTABLE" } }, "publication": { @@ -2080,6 +2091,10 @@ "options": { "(google.api.field_behavior)": "REQUIRED" } + }, + "maxConcurrentBackfillTasks": { + "type": "int32", + "id": 5 } } }, @@ -2163,6 +2178,10 @@ "maxConcurrentCdcTasks": { "type": "int32", "id": 3 + }, + "maxConcurrentBackfillTasks": { + "type": "int32", + "id": 4 } } }, diff --git a/packages/google-cloud-datastream/samples/README.md b/packages/google-cloud-datastream/samples/README.md index bca158717e0..fd48e19a268 100644 --- a/packages/google-cloud-datastream/samples/README.md +++ b/packages/google-cloud-datastream/samples/README.md @@ -59,7 +59,6 @@ * [Datastream.update_connection_profile](#datastream.update_connection_profile) * [Datastream.update_stream](#datastream.update_stream) * [Quickstart](#quickstart) - * [Quickstart](#quickstart) ## Before you begin @@ -870,23 +869,6 @@ __Usage:__ `node packages/google-cloud-datastream/samples/quickstart.js` ------ - - - - -### Quickstart - -View the [source code](https://github.com/googleapis/google-cloud-node/blob/main/packages/google-cloud-datastream/samples/test/quickstart.js). - -[![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/google-cloud-node&page=editor&open_in_editor=packages/google-cloud-datastream/samples/test/quickstart.js,samples/README.md) - -__Usage:__ - - -`node packages/google-cloud-datastream/samples/test/quickstart.js` - - diff --git a/packages/google-cloud-datastream/samples/generated/v1/datastream.create_connection_profile.js b/packages/google-cloud-datastream/samples/generated/v1/datastream.create_connection_profile.js index f7af7f4a91c..34ad81ed63b 100644 --- a/packages/google-cloud-datastream/samples/generated/v1/datastream.create_connection_profile.js +++ b/packages/google-cloud-datastream/samples/generated/v1/datastream.create_connection_profile.js @@ -55,8 +55,8 @@ function main(parent, connectionProfileId, connectionProfile) { */ // const requestId = 'abc123' /** - * Optional. Only validate the connection profile, but don't create any resources. - * The default is false. + * Optional. Only validate the connection profile, but don't create any + * resources. The default is false. */ // const validateOnly = true /** diff --git a/packages/google-cloud-datastream/samples/generated/v1/datastream.create_private_connection.js b/packages/google-cloud-datastream/samples/generated/v1/datastream.create_private_connection.js index acfb975e55e..15cbea3137f 100644 --- a/packages/google-cloud-datastream/samples/generated/v1/datastream.create_private_connection.js +++ b/packages/google-cloud-datastream/samples/generated/v1/datastream.create_private_connection.js @@ -54,6 +54,10 @@ function main(parent, privateConnectionId, privateConnection) { * not supported (00000000-0000-0000-0000-000000000000). */ // const requestId = 'abc123' + /** + * Optional. If set to true, will skip validations. + */ + // const force = true // Imports the Datastream library const {DatastreamClient} = require('@google-cloud/datastream').v1; diff --git a/packages/google-cloud-datastream/samples/generated/v1/datastream.delete_private_connection.js b/packages/google-cloud-datastream/samples/generated/v1/datastream.delete_private_connection.js index 312338d1a4e..5ca12d1ac7f 100644 --- a/packages/google-cloud-datastream/samples/generated/v1/datastream.delete_private_connection.js +++ b/packages/google-cloud-datastream/samples/generated/v1/datastream.delete_private_connection.js @@ -47,8 +47,8 @@ function main(name) { */ // const requestId = 'abc123' /** - * Optional. If set to true, any child routes that belong to this PrivateConnection will - * also be deleted. + * Optional. If set to true, any child routes that belong to this + * PrivateConnection will also be deleted. */ // const force = true diff --git a/packages/google-cloud-datastream/samples/generated/v1/datastream.discover_connection_profile.js b/packages/google-cloud-datastream/samples/generated/v1/datastream.discover_connection_profile.js index 781977f5536..3627ae02f73 100644 --- a/packages/google-cloud-datastream/samples/generated/v1/datastream.discover_connection_profile.js +++ b/packages/google-cloud-datastream/samples/generated/v1/datastream.discover_connection_profile.js @@ -29,8 +29,8 @@ function main(parent) { * TODO(developer): Uncomment these variables before running the sample. */ /** - * Required. The parent resource of the connection profile type. Must be in the - * format `projects/* /locations/*`. + * Required. The parent resource of the connection profile type. Must be in + * the format `projects/* /locations/*`. */ // const parent = 'abc123' /** diff --git a/packages/google-cloud-datastream/samples/generated/v1/datastream.fetch_static_ips.js b/packages/google-cloud-datastream/samples/generated/v1/datastream.fetch_static_ips.js index 8361829619a..fb209ac613b 100644 --- a/packages/google-cloud-datastream/samples/generated/v1/datastream.fetch_static_ips.js +++ b/packages/google-cloud-datastream/samples/generated/v1/datastream.fetch_static_ips.js @@ -29,8 +29,8 @@ function main(name) { * TODO(developer): Uncomment these variables before running the sample. */ /** - * Required. The resource name for the location for which static IPs should be returned. - * Must be in the format `projects/* /locations/*`. + * Required. The resource name for the location for which static IPs should be + * returned. Must be in the format `projects/* /locations/*`. */ // const name = 'abc123' /** diff --git a/packages/google-cloud-datastream/samples/generated/v1/datastream.list_private_connections.js b/packages/google-cloud-datastream/samples/generated/v1/datastream.list_private_connections.js index d67cba691e8..417b8d77b75 100644 --- a/packages/google-cloud-datastream/samples/generated/v1/datastream.list_private_connections.js +++ b/packages/google-cloud-datastream/samples/generated/v1/datastream.list_private_connections.js @@ -29,7 +29,8 @@ function main(parent) { * TODO(developer): Uncomment these variables before running the sample. */ /** - * Required. The parent that owns the collection of private connectivity configurations. + * Required. The parent that owns the collection of private connectivity + * configurations. */ // const parent = 'abc123' /** diff --git a/packages/google-cloud-datastream/samples/generated/v1/datastream.start_backfill_job.js b/packages/google-cloud-datastream/samples/generated/v1/datastream.start_backfill_job.js index 8211d507edf..8143825d24d 100644 --- a/packages/google-cloud-datastream/samples/generated/v1/datastream.start_backfill_job.js +++ b/packages/google-cloud-datastream/samples/generated/v1/datastream.start_backfill_job.js @@ -29,7 +29,8 @@ function main(object) { * TODO(developer): Uncomment these variables before running the sample. */ /** - * Required. The name of the stream object resource to start a backfill job for. + * Required. The name of the stream object resource to start a backfill job + * for. */ // const object = 'abc123' diff --git a/packages/google-cloud-datastream/samples/generated/v1/datastream.stop_backfill_job.js b/packages/google-cloud-datastream/samples/generated/v1/datastream.stop_backfill_job.js index 74db633e5ae..d5d41bf6f0c 100644 --- a/packages/google-cloud-datastream/samples/generated/v1/datastream.stop_backfill_job.js +++ b/packages/google-cloud-datastream/samples/generated/v1/datastream.stop_backfill_job.js @@ -29,7 +29,8 @@ function main(object) { * TODO(developer): Uncomment these variables before running the sample. */ /** - * Required. The name of the stream object resource to stop the backfill job for. + * Required. The name of the stream object resource to stop the backfill job + * for. */ // const object = 'abc123' diff --git a/packages/google-cloud-datastream/samples/generated/v1/datastream.update_connection_profile.js b/packages/google-cloud-datastream/samples/generated/v1/datastream.update_connection_profile.js index 84684de0713..1c82f487811 100644 --- a/packages/google-cloud-datastream/samples/generated/v1/datastream.update_connection_profile.js +++ b/packages/google-cloud-datastream/samples/generated/v1/datastream.update_connection_profile.js @@ -55,8 +55,8 @@ function main(connectionProfile) { */ // const requestId = 'abc123' /** - * Optional. Only validate the connection profile, but don't update any resources. - * The default is false. + * Optional. Only validate the connection profile, but don't update any + * resources. The default is false. */ // const validateOnly = true /** diff --git a/packages/google-cloud-datastream/samples/generated/v1/datastream.update_stream.js b/packages/google-cloud-datastream/samples/generated/v1/datastream.update_stream.js index 11a55c08515..dd42264aa24 100644 --- a/packages/google-cloud-datastream/samples/generated/v1/datastream.update_stream.js +++ b/packages/google-cloud-datastream/samples/generated/v1/datastream.update_stream.js @@ -55,8 +55,8 @@ function main(stream) { */ // const requestId = 'abc123' /** - * Optional. Only validate the stream with the changes, without actually updating it. - * The default is false. + * Optional. Only validate the stream with the changes, without actually + * updating it. The default is false. */ // const validateOnly = true /** diff --git a/packages/google-cloud-datastream/samples/generated/v1/snippet_metadata.google.cloud.datastream.v1.json b/packages/google-cloud-datastream/samples/generated/v1/snippet_metadata.google.cloud.datastream.v1.json index e61264d01ff..ea5a61dbb5f 100644 --- a/packages/google-cloud-datastream/samples/generated/v1/snippet_metadata.google.cloud.datastream.v1.json +++ b/packages/google-cloud-datastream/samples/generated/v1/snippet_metadata.google.cloud.datastream.v1.json @@ -1,7 +1,7 @@ { "clientLibrary": { "name": "nodejs-datastream", - "version": "2.2.0", + "version": "2.2.2", "language": "TYPESCRIPT", "apis": [ { @@ -734,7 +734,7 @@ "segments": [ { "start": 25, - "end": 53, + "end": 54, "type": "FULL" } ], @@ -774,7 +774,7 @@ "segments": [ { "start": 25, - "end": 53, + "end": 54, "type": "FULL" } ], @@ -862,7 +862,7 @@ "segments": [ { "start": 25, - "end": 78, + "end": 82, "type": "FULL" } ], @@ -886,6 +886,10 @@ { "name": "request_id", "type": "TYPE_STRING" + }, + { + "name": "force", + "type": "TYPE_BOOL" } ], "resultType": ".google.longrunning.Operation", @@ -954,7 +958,7 @@ "segments": [ { "start": 25, - "end": 78, + "end": 79, "type": "FULL" } ], diff --git a/packages/google-cloud-datastream/samples/generated/v1alpha1/snippet_metadata.google.cloud.datastream.v1alpha1.json b/packages/google-cloud-datastream/samples/generated/v1alpha1/snippet_metadata.google.cloud.datastream.v1alpha1.json index 015966cd05b..134d718a69d 100644 --- a/packages/google-cloud-datastream/samples/generated/v1alpha1/snippet_metadata.google.cloud.datastream.v1alpha1.json +++ b/packages/google-cloud-datastream/samples/generated/v1alpha1/snippet_metadata.google.cloud.datastream.v1alpha1.json @@ -1,7 +1,7 @@ { "clientLibrary": { "name": "nodejs-datastream", - "version": "2.2.0", + "version": "2.2.2", "language": "TYPESCRIPT", "apis": [ { diff --git a/packages/google-cloud-datastream/src/v1/datastream_client.ts b/packages/google-cloud-datastream/src/v1/datastream_client.ts index 9f2b2eaa1a8..ffa18cd1bca 100644 --- a/packages/google-cloud-datastream/src/v1/datastream_client.ts +++ b/packages/google-cloud-datastream/src/v1/datastream_client.ts @@ -694,8 +694,8 @@ export class DatastreamClient { * @param {Object} request * The request object that will be sent. * @param {string} request.parent - * Required. The parent resource of the connection profile type. Must be in the - * format `projects/* /locations/*`. + * Required. The parent resource of the connection profile type. Must be in + * the format `projects/* /locations/*`. * @param {google.cloud.datastream.v1.ConnectionProfile} request.connectionProfile * An ad-hoc connection profile configuration. * @param {string} request.connectionProfileName @@ -1080,7 +1080,8 @@ export class DatastreamClient { * @param {Object} request * The request object that will be sent. * @param {string} request.object - * Required. The name of the stream object resource to start a backfill job for. + * Required. The name of the stream object resource to start a backfill job + * for. * @param {object} [options] * Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details. * @returns {Promise} - The promise which resolves to an array. @@ -1171,7 +1172,8 @@ export class DatastreamClient { * @param {Object} request * The request object that will be sent. * @param {string} request.object - * Required. The name of the stream object resource to stop the backfill job for. + * Required. The name of the stream object resource to stop the backfill job + * for. * @param {object} [options] * Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details. * @returns {Promise} - The promise which resolves to an array. @@ -1463,8 +1465,8 @@ export class DatastreamClient { * The request ID must be a valid UUID with the exception that zero UUID is * not supported (00000000-0000-0000-0000-000000000000). * @param {boolean} [request.validateOnly] - * Optional. Only validate the connection profile, but don't create any resources. - * The default is false. + * Optional. Only validate the connection profile, but don't create any + * resources. The default is false. * @param {boolean} [request.force] * Optional. Create the connection profile without validating it. * @param {object} [options] @@ -1630,8 +1632,8 @@ export class DatastreamClient { * The request ID must be a valid UUID with the exception that zero UUID is * not supported (00000000-0000-0000-0000-000000000000). * @param {boolean} [request.validateOnly] - * Optional. Only validate the connection profile, but don't update any resources. - * The default is false. + * Optional. Only validate the connection profile, but don't update any + * resources. The default is false. * @param {boolean} [request.force] * Optional. Update the connection profile without validating it. * @param {object} [options] @@ -2114,8 +2116,8 @@ export class DatastreamClient { * The request ID must be a valid UUID with the exception that zero UUID is * not supported (00000000-0000-0000-0000-000000000000). * @param {boolean} [request.validateOnly] - * Optional. Only validate the stream with the changes, without actually updating it. - * The default is false. + * Optional. Only validate the stream with the changes, without actually + * updating it. The default is false. * @param {boolean} [request.force] * Optional. Update the stream without validating it. * @param {object} [options] @@ -2426,6 +2428,8 @@ export class DatastreamClient { * * The request ID must be a valid UUID with the exception that zero UUID is * not supported (00000000-0000-0000-0000-000000000000). + * @param {boolean} [request.force] + * Optional. If set to true, will skip validations. * @param {object} [options] * Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details. * @returns {Promise} - The promise which resolves to an array. @@ -2583,8 +2587,8 @@ export class DatastreamClient { * The request ID must be a valid UUID with the exception that zero UUID is * not supported (00000000-0000-0000-0000-000000000000). * @param {boolean} [request.force] - * Optional. If set to true, any child routes that belong to this PrivateConnection will - * also be deleted. + * Optional. If set to true, any child routes that belong to this + * PrivateConnection will also be deleted. * @param {object} [options] * Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details. * @returns {Promise} - The promise which resolves to an array. @@ -3680,8 +3684,8 @@ export class DatastreamClient { * @param {Object} request * The request object that will be sent. * @param {string} request.name - * Required. The resource name for the location for which static IPs should be returned. - * Must be in the format `projects/* /locations/*`. + * Required. The resource name for the location for which static IPs should be + * returned. Must be in the format `projects/* /locations/*`. * @param {number} request.pageSize * Maximum number of Ips to return, will likely not be specified. * @param {string} request.pageToken @@ -3780,8 +3784,8 @@ export class DatastreamClient { * @param {Object} request * The request object that will be sent. * @param {string} request.name - * Required. The resource name for the location for which static IPs should be returned. - * Must be in the format `projects/* /locations/*`. + * Required. The resource name for the location for which static IPs should be + * returned. Must be in the format `projects/* /locations/*`. * @param {number} request.pageSize * Maximum number of Ips to return, will likely not be specified. * @param {string} request.pageToken @@ -3828,8 +3832,8 @@ export class DatastreamClient { * @param {Object} request * The request object that will be sent. * @param {string} request.name - * Required. The resource name for the location for which static IPs should be returned. - * Must be in the format `projects/* /locations/*`. + * Required. The resource name for the location for which static IPs should be + * returned. Must be in the format `projects/* /locations/*`. * @param {number} request.pageSize * Maximum number of Ips to return, will likely not be specified. * @param {string} request.pageToken @@ -3876,7 +3880,8 @@ export class DatastreamClient { * @param {Object} request * The request object that will be sent. * @param {string} request.parent - * Required. The parent that owns the collection of private connectivity configurations. + * Required. The parent that owns the collection of private connectivity + * configurations. * @param {number} request.pageSize * Maximum number of private connectivity configurations to return. * If unspecified, at most 50 private connectivity configurations that will be @@ -3990,7 +3995,8 @@ export class DatastreamClient { * @param {Object} request * The request object that will be sent. * @param {string} request.parent - * Required. The parent that owns the collection of private connectivity configurations. + * Required. The parent that owns the collection of private connectivity + * configurations. * @param {number} request.pageSize * Maximum number of private connectivity configurations to return. * If unspecified, at most 50 private connectivity configurations that will be @@ -4048,7 +4054,8 @@ export class DatastreamClient { * @param {Object} request * The request object that will be sent. * @param {string} request.parent - * Required. The parent that owns the collection of private connectivity configurations. + * Required. The parent that owns the collection of private connectivity + * configurations. * @param {number} request.pageSize * Maximum number of private connectivity configurations to return. * If unspecified, at most 50 private connectivity configurations that will be