feat: add datastream v1

.repo-metadata.json

@@ -10,7 +10,7 @@
     "repo": "googleapis/python-datastream",
     "distribution_name": "google-cloud-datastream",
     "api_id": "datastream.googleapis.com",
-    "default_version": "v1alpha1",
+    "default_version": "v1",
     "codeowner_team": "",
     "api_shortname": "datastream"
 }

docs/datastream_v1/datastream.rst

@@ -0,0 +1,10 @@
+Datastream
+----------------------------
+
+.. automodule:: google.cloud.datastream_v1.services.datastream
+    :members:
+    :inherited-members:
+
+.. automodule:: google.cloud.datastream_v1.services.datastream.pagers
+    :members:
+    :inherited-members:

docs/datastream_v1/services.rst

@@ -0,0 +1,6 @@
+Services for Google Cloud Datastream v1 API
+===========================================
+.. toctree::
+    :maxdepth: 2
+
+    datastream

docs/datastream_v1/types.rst

@@ -0,0 +1,7 @@
+Types for Google Cloud Datastream v1 API
+========================================
+
+.. automodule:: google.cloud.datastream_v1.types
+    :members:
+    :undoc-members:
+    :show-inheritance:

docs/index.rst

@@ -2,6 +2,17 @@
 
 .. include:: multiprocessing.rst
 
+This package includes clients for multiple versions of Datastream.
+By default, you will get version ``datastream_v1``.
+
+
+API Reference
+-------------
+.. toctree::
+    :maxdepth: 2
+
+    datastream_v1/services
+    datastream_v1/types
 
 API Reference
 -------------

google/cloud/datastream/__init__.py

@@ -14,122 +14,86 @@
 # limitations under the License.
 #
 
-from google.cloud.datastream_v1alpha1.services.datastream.client import DatastreamClient
-from google.cloud.datastream_v1alpha1.services.datastream.async_client import (
+from google.cloud.datastream_v1.services.datastream.client import DatastreamClient
+from google.cloud.datastream_v1.services.datastream.async_client import (
     DatastreamAsyncClient,
 )
 
-from google.cloud.datastream_v1alpha1.types.datastream import (
-    CreateConnectionProfileRequest,
-)
-from google.cloud.datastream_v1alpha1.types.datastream import (
-    CreatePrivateConnectionRequest,
-)
-from google.cloud.datastream_v1alpha1.types.datastream import CreateRouteRequest
-from google.cloud.datastream_v1alpha1.types.datastream import CreateStreamRequest
-from google.cloud.datastream_v1alpha1.types.datastream import (
-    DeleteConnectionProfileRequest,
-)
-from google.cloud.datastream_v1alpha1.types.datastream import (
-    DeletePrivateConnectionRequest,
-)
-from google.cloud.datastream_v1alpha1.types.datastream import DeleteRouteRequest
-from google.cloud.datastream_v1alpha1.types.datastream import DeleteStreamRequest
-from google.cloud.datastream_v1alpha1.types.datastream import (
-    DiscoverConnectionProfileRequest,
-)
-from google.cloud.datastream_v1alpha1.types.datastream import (
+from google.cloud.datastream_v1.types.datastream import CreateConnectionProfileRequest
+from google.cloud.datastream_v1.types.datastream import CreatePrivateConnectionRequest
+from google.cloud.datastream_v1.types.datastream import CreateRouteRequest
+from google.cloud.datastream_v1.types.datastream import CreateStreamRequest
+from google.cloud.datastream_v1.types.datastream import DeleteConnectionProfileRequest
+from google.cloud.datastream_v1.types.datastream import DeletePrivateConnectionRequest
+from google.cloud.datastream_v1.types.datastream import DeleteRouteRequest
+from google.cloud.datastream_v1.types.datastream import DeleteStreamRequest
+from google.cloud.datastream_v1.types.datastream import DiscoverConnectionProfileRequest
+from google.cloud.datastream_v1.types.datastream import (
     DiscoverConnectionProfileResponse,
 )
-from google.cloud.datastream_v1alpha1.types.datastream import FetchErrorsRequest
-from google.cloud.datastream_v1alpha1.types.datastream import FetchErrorsResponse
-from google.cloud.datastream_v1alpha1.types.datastream import FetchStaticIpsRequest
-from google.cloud.datastream_v1alpha1.types.datastream import FetchStaticIpsResponse
-from google.cloud.datastream_v1alpha1.types.datastream import (
-    GetConnectionProfileRequest,
-)
-from google.cloud.datastream_v1alpha1.types.datastream import (
-    GetPrivateConnectionRequest,
-)
-from google.cloud.datastream_v1alpha1.types.datastream import GetRouteRequest
-from google.cloud.datastream_v1alpha1.types.datastream import GetStreamRequest
-from google.cloud.datastream_v1alpha1.types.datastream import (
-    ListConnectionProfilesRequest,
-)
-from google.cloud.datastream_v1alpha1.types.datastream import (
-    ListConnectionProfilesResponse,
-)
-from google.cloud.datastream_v1alpha1.types.datastream import (
-    ListPrivateConnectionsRequest,
-)
-from google.cloud.datastream_v1alpha1.types.datastream import (
-    ListPrivateConnectionsResponse,
-)
-from google.cloud.datastream_v1alpha1.types.datastream import ListRoutesRequest
-from google.cloud.datastream_v1alpha1.types.datastream import ListRoutesResponse
-from google.cloud.datastream_v1alpha1.types.datastream import ListStreamsRequest
-from google.cloud.datastream_v1alpha1.types.datastream import ListStreamsResponse
-from google.cloud.datastream_v1alpha1.types.datastream import OperationMetadata
-from google.cloud.datastream_v1alpha1.types.datastream import (
-    UpdateConnectionProfileRequest,
-)
-from google.cloud.datastream_v1alpha1.types.datastream import UpdateStreamRequest
-from google.cloud.datastream_v1alpha1.types.datastream_resources import AvroFileFormat
-from google.cloud.datastream_v1alpha1.types.datastream_resources import (
-    ConnectionProfile,
-)
-from google.cloud.datastream_v1alpha1.types.datastream_resources import (
-    DestinationConfig,
-)
-from google.cloud.datastream_v1alpha1.types.datastream_resources import Error
-from google.cloud.datastream_v1alpha1.types.datastream_resources import (
+from google.cloud.datastream_v1.types.datastream import FetchStaticIpsRequest
+from google.cloud.datastream_v1.types.datastream import FetchStaticIpsResponse
+from google.cloud.datastream_v1.types.datastream import GetConnectionProfileRequest
+from google.cloud.datastream_v1.types.datastream import GetPrivateConnectionRequest
+from google.cloud.datastream_v1.types.datastream import GetRouteRequest
+from google.cloud.datastream_v1.types.datastream import GetStreamObjectRequest
+from google.cloud.datastream_v1.types.datastream import GetStreamRequest
+from google.cloud.datastream_v1.types.datastream import ListConnectionProfilesRequest
+from google.cloud.datastream_v1.types.datastream import ListConnectionProfilesResponse
+from google.cloud.datastream_v1.types.datastream import ListPrivateConnectionsRequest
+from google.cloud.datastream_v1.types.datastream import ListPrivateConnectionsResponse
+from google.cloud.datastream_v1.types.datastream import ListRoutesRequest
+from google.cloud.datastream_v1.types.datastream import ListRoutesResponse
+from google.cloud.datastream_v1.types.datastream import ListStreamObjectsRequest
+from google.cloud.datastream_v1.types.datastream import ListStreamObjectsResponse
+from google.cloud.datastream_v1.types.datastream import ListStreamsRequest
+from google.cloud.datastream_v1.types.datastream import ListStreamsResponse
+from google.cloud.datastream_v1.types.datastream import LookupStreamObjectRequest
+from google.cloud.datastream_v1.types.datastream import OperationMetadata
+from google.cloud.datastream_v1.types.datastream import StartBackfillJobRequest
+from google.cloud.datastream_v1.types.datastream import StartBackfillJobResponse
+from google.cloud.datastream_v1.types.datastream import StopBackfillJobRequest
+from google.cloud.datastream_v1.types.datastream import StopBackfillJobResponse
+from google.cloud.datastream_v1.types.datastream import UpdateConnectionProfileRequest
+from google.cloud.datastream_v1.types.datastream import UpdateStreamRequest
+from google.cloud.datastream_v1.types.datastream_resources import AvroFileFormat
+from google.cloud.datastream_v1.types.datastream_resources import BackfillJob
+from google.cloud.datastream_v1.types.datastream_resources import ConnectionProfile
+from google.cloud.datastream_v1.types.datastream_resources import DestinationConfig
+from google.cloud.datastream_v1.types.datastream_resources import Error
+from google.cloud.datastream_v1.types.datastream_resources import (
     ForwardSshTunnelConnectivity,
 )
-from google.cloud.datastream_v1alpha1.types.datastream_resources import (
-    GcsDestinationConfig,
-)
-from google.cloud.datastream_v1alpha1.types.datastream_resources import GcsProfile
-from google.cloud.datastream_v1alpha1.types.datastream_resources import JsonFileFormat
-from google.cloud.datastream_v1alpha1.types.datastream_resources import MysqlColumn
-from google.cloud.datastream_v1alpha1.types.datastream_resources import MysqlDatabase
-from google.cloud.datastream_v1alpha1.types.datastream_resources import MysqlProfile
-from google.cloud.datastream_v1alpha1.types.datastream_resources import MysqlRdbms
-from google.cloud.datastream_v1alpha1.types.datastream_resources import (
-    MysqlSourceConfig,
-)
-from google.cloud.datastream_v1alpha1.types.datastream_resources import MysqlSslConfig
-from google.cloud.datastream_v1alpha1.types.datastream_resources import MysqlTable
-from google.cloud.datastream_v1alpha1.types.datastream_resources import (
-    NoConnectivitySettings,
-)
-from google.cloud.datastream_v1alpha1.types.datastream_resources import OracleColumn
-from google.cloud.datastream_v1alpha1.types.datastream_resources import OracleProfile
-from google.cloud.datastream_v1alpha1.types.datastream_resources import OracleRdbms
-from google.cloud.datastream_v1alpha1.types.datastream_resources import OracleSchema
-from google.cloud.datastream_v1alpha1.types.datastream_resources import (
-    OracleSourceConfig,
-)
-from google.cloud.datastream_v1alpha1.types.datastream_resources import OracleTable
-from google.cloud.datastream_v1alpha1.types.datastream_resources import (
-    PrivateConnection,
-)
-from google.cloud.datastream_v1alpha1.types.datastream_resources import (
-    PrivateConnectivity,
-)
-from google.cloud.datastream_v1alpha1.types.datastream_resources import Route
-from google.cloud.datastream_v1alpha1.types.datastream_resources import SourceConfig
-from google.cloud.datastream_v1alpha1.types.datastream_resources import (
+from google.cloud.datastream_v1.types.datastream_resources import GcsDestinationConfig
+from google.cloud.datastream_v1.types.datastream_resources import GcsProfile
+from google.cloud.datastream_v1.types.datastream_resources import JsonFileFormat
+from google.cloud.datastream_v1.types.datastream_resources import MysqlColumn
+from google.cloud.datastream_v1.types.datastream_resources import MysqlDatabase
+from google.cloud.datastream_v1.types.datastream_resources import MysqlProfile
+from google.cloud.datastream_v1.types.datastream_resources import MysqlRdbms
+from google.cloud.datastream_v1.types.datastream_resources import MysqlSourceConfig
+from google.cloud.datastream_v1.types.datastream_resources import MysqlSslConfig
+from google.cloud.datastream_v1.types.datastream_resources import MysqlTable
+from google.cloud.datastream_v1.types.datastream_resources import OracleColumn
+from google.cloud.datastream_v1.types.datastream_resources import OracleProfile
+from google.cloud.datastream_v1.types.datastream_resources import OracleRdbms
+from google.cloud.datastream_v1.types.datastream_resources import OracleSchema
+from google.cloud.datastream_v1.types.datastream_resources import OracleSourceConfig
+from google.cloud.datastream_v1.types.datastream_resources import OracleTable
+from google.cloud.datastream_v1.types.datastream_resources import PrivateConnection
+from google.cloud.datastream_v1.types.datastream_resources import PrivateConnectivity
+from google.cloud.datastream_v1.types.datastream_resources import Route
+from google.cloud.datastream_v1.types.datastream_resources import SourceConfig
+from google.cloud.datastream_v1.types.datastream_resources import SourceObjectIdentifier
+from google.cloud.datastream_v1.types.datastream_resources import (
     StaticServiceIpConnectivity,
 )
-from google.cloud.datastream_v1alpha1.types.datastream_resources import Stream
-from google.cloud.datastream_v1alpha1.types.datastream_resources import Validation
-from google.cloud.datastream_v1alpha1.types.datastream_resources import (
-    ValidationMessage,
-)
-from google.cloud.datastream_v1alpha1.types.datastream_resources import ValidationResult
-from google.cloud.datastream_v1alpha1.types.datastream_resources import VpcPeeringConfig
-from google.cloud.datastream_v1alpha1.types.datastream_resources import GcsFileFormat
-from google.cloud.datastream_v1alpha1.types.datastream_resources import SchemaFileFormat
+from google.cloud.datastream_v1.types.datastream_resources import Stream
+from google.cloud.datastream_v1.types.datastream_resources import StreamObject
+from google.cloud.datastream_v1.types.datastream_resources import Validation
+from google.cloud.datastream_v1.types.datastream_resources import ValidationMessage
+from google.cloud.datastream_v1.types.datastream_resources import ValidationResult
+from google.cloud.datastream_v1.types.datastream_resources import VpcPeeringConfig
 
 __all__ = (
     "DatastreamClient",
@@ -144,26 +108,33 @@
     "DeleteStreamRequest",
     "DiscoverConnectionProfileRequest",
     "DiscoverConnectionProfileResponse",
-    "FetchErrorsRequest",
-    "FetchErrorsResponse",
     "FetchStaticIpsRequest",
     "FetchStaticIpsResponse",
     "GetConnectionProfileRequest",
     "GetPrivateConnectionRequest",
     "GetRouteRequest",
+    "GetStreamObjectRequest",
     "GetStreamRequest",
     "ListConnectionProfilesRequest",
     "ListConnectionProfilesResponse",
     "ListPrivateConnectionsRequest",
     "ListPrivateConnectionsResponse",
     "ListRoutesRequest",
     "ListRoutesResponse",
+    "ListStreamObjectsRequest",
+    "ListStreamObjectsResponse",
     "ListStreamsRequest",
     "ListStreamsResponse",
+    "LookupStreamObjectRequest",
     "OperationMetadata",
+    "StartBackfillJobRequest",
+    "StartBackfillJobResponse",
+    "StopBackfillJobRequest",
+    "StopBackfillJobResponse",
     "UpdateConnectionProfileRequest",
     "UpdateStreamRequest",
     "AvroFileFormat",
+    "BackfillJob",
     "ConnectionProfile",
     "DestinationConfig",
     "Error",
@@ -178,7 +149,6 @@
     "MysqlSourceConfig",
     "MysqlSslConfig",
     "MysqlTable",
-    "NoConnectivitySettings",
     "OracleColumn",
     "OracleProfile",
     "OracleRdbms",
@@ -189,12 +159,12 @@
     "PrivateConnectivity",
     "Route",
     "SourceConfig",
+    "SourceObjectIdentifier",
     "StaticServiceIpConnectivity",
     "Stream",
+    "StreamObject",
     "Validation",
     "ValidationMessage",
     "ValidationResult",
     "VpcPeeringConfig",
-    "GcsFileFormat",
-    "SchemaFileFormat",
 )