feat: Added support for Content APIs (#8)

- [ ] Regenerate this pull request now. PiperOrigin-RevId: 429081053 Source-Link: googleapis/googleapis@7b42fd0 Source-Link: googleapis/googleapis-gen@3f71d2d Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiM2Y3MWQyZGY1YzEwMmVlMWZlODJmNDkyZGU1NDVjZDNhM2RjN2Y3OSJ9 feat: Added Create, Update and Delete APIs for Metadata (e.g. Entity and/or Partition).
googleapis · Feb 18, 2022 · cf8c4f3 · cf8c4f3
1 parent 9ef78cf
commit cf8c4f3
Show file tree

Hide file tree

Showing 67 changed files with 16,130 additions and 711 deletions.
diff --git a/packages/google-cloud-dataplex/docs/dataplex_v1/content_service.rst b/packages/google-cloud-dataplex/docs/dataplex_v1/content_service.rst
@@ -0,0 +1,10 @@
+ContentService
+--------------------------------
+
+.. automodule:: google.cloud.dataplex_v1.services.content_service
+    :members:
+    :inherited-members:
+
+.. automodule:: google.cloud.dataplex_v1.services.content_service.pagers
+    :members:
+    :inherited-members:
diff --git a/packages/google-cloud-dataplex/docs/dataplex_v1/services.rst b/packages/google-cloud-dataplex/docs/dataplex_v1/services.rst
@@ -3,5 +3,6 @@ Services for Google Cloud Dataplex v1 API
 .. toctree::
     :maxdepth: 2
 
+    content_service
     dataplex_service
     metadata_service
diff --git a/packages/google-cloud-dataplex/google/cloud/dataplex/__init__.py b/packages/google-cloud-dataplex/google/cloud/dataplex/__init__.py
@@ -14,6 +14,12 @@
 # limitations under the License.
 #
 
+from google.cloud.dataplex_v1.services.content_service.client import (
+    ContentServiceClient,
+)
+from google.cloud.dataplex_v1.services.content_service.async_client import (
+    ContentServiceAsyncClient,
+)
 from google.cloud.dataplex_v1.services.dataplex_service.client import (
     DataplexServiceClient,
 )
@@ -27,9 +33,22 @@
     MetadataServiceAsyncClient,
 )
 
+from google.cloud.dataplex_v1.types.analyze import Content
+from google.cloud.dataplex_v1.types.analyze import Environment
+from google.cloud.dataplex_v1.types.analyze import Session
+from google.cloud.dataplex_v1.types.content import CreateContentRequest
+from google.cloud.dataplex_v1.types.content import DeleteContentRequest
+from google.cloud.dataplex_v1.types.content import GetContentRequest
+from google.cloud.dataplex_v1.types.content import ListContentRequest
+from google.cloud.dataplex_v1.types.content import ListContentResponse
+from google.cloud.dataplex_v1.types.content import UpdateContentRequest
 from google.cloud.dataplex_v1.types.logs import DiscoveryEvent
 from google.cloud.dataplex_v1.types.logs import JobEvent
 from google.cloud.dataplex_v1.types.logs import SessionEvent
+from google.cloud.dataplex_v1.types.metadata_ import CreateEntityRequest
+from google.cloud.dataplex_v1.types.metadata_ import CreatePartitionRequest
+from google.cloud.dataplex_v1.types.metadata_ import DeleteEntityRequest
+from google.cloud.dataplex_v1.types.metadata_ import DeletePartitionRequest
 from google.cloud.dataplex_v1.types.metadata_ import Entity
 from google.cloud.dataplex_v1.types.metadata_ import GetEntityRequest
 from google.cloud.dataplex_v1.types.metadata_ import GetPartitionRequest
@@ -40,6 +59,7 @@
 from google.cloud.dataplex_v1.types.metadata_ import Partition
 from google.cloud.dataplex_v1.types.metadata_ import Schema
 from google.cloud.dataplex_v1.types.metadata_ import StorageFormat
+from google.cloud.dataplex_v1.types.metadata_ import UpdateEntityRequest
 from google.cloud.dataplex_v1.types.metadata_ import StorageSystem
 from google.cloud.dataplex_v1.types.resources import Action
 from google.cloud.dataplex_v1.types.resources import Asset
@@ -49,14 +69,17 @@
 from google.cloud.dataplex_v1.types.resources import State
 from google.cloud.dataplex_v1.types.service import CancelJobRequest
 from google.cloud.dataplex_v1.types.service import CreateAssetRequest
+from google.cloud.dataplex_v1.types.service import CreateEnvironmentRequest
 from google.cloud.dataplex_v1.types.service import CreateLakeRequest
 from google.cloud.dataplex_v1.types.service import CreateTaskRequest
 from google.cloud.dataplex_v1.types.service import CreateZoneRequest
 from google.cloud.dataplex_v1.types.service import DeleteAssetRequest
+from google.cloud.dataplex_v1.types.service import DeleteEnvironmentRequest
 from google.cloud.dataplex_v1.types.service import DeleteLakeRequest
 from google.cloud.dataplex_v1.types.service import DeleteTaskRequest
 from google.cloud.dataplex_v1.types.service import DeleteZoneRequest
 from google.cloud.dataplex_v1.types.service import GetAssetRequest
+from google.cloud.dataplex_v1.types.service import GetEnvironmentRequest
 from google.cloud.dataplex_v1.types.service import GetJobRequest
 from google.cloud.dataplex_v1.types.service import GetLakeRequest
 from google.cloud.dataplex_v1.types.service import GetTaskRequest
@@ -65,32 +88,52 @@
 from google.cloud.dataplex_v1.types.service import ListAssetActionsRequest
 from google.cloud.dataplex_v1.types.service import ListAssetsRequest
 from google.cloud.dataplex_v1.types.service import ListAssetsResponse
+from google.cloud.dataplex_v1.types.service import ListEnvironmentsRequest
+from google.cloud.dataplex_v1.types.service import ListEnvironmentsResponse
 from google.cloud.dataplex_v1.types.service import ListJobsRequest
 from google.cloud.dataplex_v1.types.service import ListJobsResponse
 from google.cloud.dataplex_v1.types.service import ListLakeActionsRequest
 from google.cloud.dataplex_v1.types.service import ListLakesRequest
 from google.cloud.dataplex_v1.types.service import ListLakesResponse
+from google.cloud.dataplex_v1.types.service import ListSessionsRequest
+from google.cloud.dataplex_v1.types.service import ListSessionsResponse
 from google.cloud.dataplex_v1.types.service import ListTasksRequest
 from google.cloud.dataplex_v1.types.service import ListTasksResponse
 from google.cloud.dataplex_v1.types.service import ListZoneActionsRequest
 from google.cloud.dataplex_v1.types.service import ListZonesRequest
 from google.cloud.dataplex_v1.types.service import ListZonesResponse
 from google.cloud.dataplex_v1.types.service import OperationMetadata
 from google.cloud.dataplex_v1.types.service import UpdateAssetRequest
+from google.cloud.dataplex_v1.types.service import UpdateEnvironmentRequest
 from google.cloud.dataplex_v1.types.service import UpdateLakeRequest
 from google.cloud.dataplex_v1.types.service import UpdateTaskRequest
 from google.cloud.dataplex_v1.types.service import UpdateZoneRequest
 from google.cloud.dataplex_v1.types.tasks import Job
 from google.cloud.dataplex_v1.types.tasks import Task
 
 __all__ = (
+    "ContentServiceClient",
+    "ContentServiceAsyncClient",
     "DataplexServiceClient",
     "DataplexServiceAsyncClient",
     "MetadataServiceClient",
     "MetadataServiceAsyncClient",
+    "Content",
+    "Environment",
+    "Session",
+    "CreateContentRequest",
+    "DeleteContentRequest",
+    "GetContentRequest",
+    "ListContentRequest",
+    "ListContentResponse",
+    "UpdateContentRequest",
     "DiscoveryEvent",
     "JobEvent",
     "SessionEvent",
+    "CreateEntityRequest",
+    "CreatePartitionRequest",
+    "DeleteEntityRequest",
+    "DeletePartitionRequest",
     "Entity",
     "GetEntityRequest",
     "GetPartitionRequest",
@@ -101,6 +144,7 @@
     "Partition",
     "Schema",
     "StorageFormat",
+    "UpdateEntityRequest",
     "StorageSystem",
     "Action",
     "Asset",
@@ -110,14 +154,17 @@
     "State",
     "CancelJobRequest",
     "CreateAssetRequest",
+    "CreateEnvironmentRequest",
     "CreateLakeRequest",
     "CreateTaskRequest",
     "CreateZoneRequest",
     "DeleteAssetRequest",
+    "DeleteEnvironmentRequest",
     "DeleteLakeRequest",
     "DeleteTaskRequest",
     "DeleteZoneRequest",
     "GetAssetRequest",
+    "GetEnvironmentRequest",
     "GetJobRequest",
     "GetLakeRequest",
     "GetTaskRequest",
@@ -126,18 +173,23 @@
     "ListAssetActionsRequest",
     "ListAssetsRequest",
     "ListAssetsResponse",
+    "ListEnvironmentsRequest",
+    "ListEnvironmentsResponse",
     "ListJobsRequest",
     "ListJobsResponse",
     "ListLakeActionsRequest",
     "ListLakesRequest",
     "ListLakesResponse",
+    "ListSessionsRequest",
+    "ListSessionsResponse",
     "ListTasksRequest",
     "ListTasksResponse",
     "ListZoneActionsRequest",
     "ListZonesRequest",
     "ListZonesResponse",
     "OperationMetadata",
     "UpdateAssetRequest",
+    "UpdateEnvironmentRequest",
     "UpdateLakeRequest",
     "UpdateTaskRequest",
     "UpdateZoneRequest",

diff --git a/packages/google-cloud-dataplex/google/cloud/dataplex_v1/__init__.py b/packages/google-cloud-dataplex/google/cloud/dataplex_v1/__init__.py
@@ -14,14 +14,29 @@
 # limitations under the License.
 #
 
+from .services.content_service import ContentServiceClient
+from .services.content_service import ContentServiceAsyncClient
 from .services.dataplex_service import DataplexServiceClient
 from .services.dataplex_service import DataplexServiceAsyncClient
 from .services.metadata_service import MetadataServiceClient
 from .services.metadata_service import MetadataServiceAsyncClient
 
+from .types.analyze import Content
+from .types.analyze import Environment
+from .types.analyze import Session
+from .types.content import CreateContentRequest
+from .types.content import DeleteContentRequest
+from .types.content import GetContentRequest
+from .types.content import ListContentRequest
+from .types.content import ListContentResponse
+from .types.content import UpdateContentRequest
 from .types.logs import DiscoveryEvent
 from .types.logs import JobEvent
 from .types.logs import SessionEvent
+from .types.metadata_ import CreateEntityRequest
+from .types.metadata_ import CreatePartitionRequest
+from .types.metadata_ import DeleteEntityRequest
+from .types.metadata_ import DeletePartitionRequest
 from .types.metadata_ import Entity
 from .types.metadata_ import GetEntityRequest
 from .types.metadata_ import GetPartitionRequest
@@ -32,6 +47,7 @@
 from .types.metadata_ import Partition
 from .types.metadata_ import Schema
 from .types.metadata_ import StorageFormat
+from .types.metadata_ import UpdateEntityRequest
 from .types.metadata_ import StorageSystem
 from .types.resources import Action
 from .types.resources import Asset
@@ -41,14 +57,17 @@
 from .types.resources import State
 from .types.service import CancelJobRequest
 from .types.service import CreateAssetRequest
+from .types.service import CreateEnvironmentRequest
 from .types.service import CreateLakeRequest
 from .types.service import CreateTaskRequest
 from .types.service import CreateZoneRequest
 from .types.service import DeleteAssetRequest
+from .types.service import DeleteEnvironmentRequest
 from .types.service import DeleteLakeRequest
 from .types.service import DeleteTaskRequest
 from .types.service import DeleteZoneRequest
 from .types.service import GetAssetRequest
+from .types.service import GetEnvironmentRequest
 from .types.service import GetJobRequest
 from .types.service import GetLakeRequest
 from .types.service import GetTaskRequest
@@ -57,44 +76,63 @@
 from .types.service import ListAssetActionsRequest
 from .types.service import ListAssetsRequest
 from .types.service import ListAssetsResponse
+from .types.service import ListEnvironmentsRequest
+from .types.service import ListEnvironmentsResponse
 from .types.service import ListJobsRequest
 from .types.service import ListJobsResponse
 from .types.service import ListLakeActionsRequest
 from .types.service import ListLakesRequest
 from .types.service import ListLakesResponse
+from .types.service import ListSessionsRequest
+from .types.service import ListSessionsResponse
 from .types.service import ListTasksRequest
 from .types.service import ListTasksResponse
 from .types.service import ListZoneActionsRequest
 from .types.service import ListZonesRequest
 from .types.service import ListZonesResponse
 from .types.service import OperationMetadata
 from .types.service import UpdateAssetRequest
+from .types.service import UpdateEnvironmentRequest
 from .types.service import UpdateLakeRequest
 from .types.service import UpdateTaskRequest
 from .types.service import UpdateZoneRequest
 from .types.tasks import Job
 from .types.tasks import Task
 
 __all__ = (
+    "ContentServiceAsyncClient",
     "DataplexServiceAsyncClient",
     "MetadataServiceAsyncClient",
     "Action",
     "Asset",
     "AssetStatus",
     "CancelJobRequest",
+    "Content",
+    "ContentServiceClient",
     "CreateAssetRequest",
+    "CreateContentRequest",
+    "CreateEntityRequest",
+    "CreateEnvironmentRequest",
     "CreateLakeRequest",
+    "CreatePartitionRequest",
     "CreateTaskRequest",
     "CreateZoneRequest",
     "DataplexServiceClient",
     "DeleteAssetRequest",
+    "DeleteContentRequest",
+    "DeleteEntityRequest",
+    "DeleteEnvironmentRequest",
     "DeleteLakeRequest",
+    "DeletePartitionRequest",
     "DeleteTaskRequest",
     "DeleteZoneRequest",
     "DiscoveryEvent",
     "Entity",
+    "Environment",
     "GetAssetRequest",
+    "GetContentRequest",
     "GetEntityRequest",
+    "GetEnvironmentRequest",
     "GetJobRequest",
     "GetLakeRequest",
     "GetPartitionRequest",
@@ -107,15 +145,21 @@
     "ListAssetActionsRequest",
     "ListAssetsRequest",
     "ListAssetsResponse",
+    "ListContentRequest",
+    "ListContentResponse",
     "ListEntitiesRequest",
     "ListEntitiesResponse",
+    "ListEnvironmentsRequest",
+    "ListEnvironmentsResponse",
     "ListJobsRequest",
     "ListJobsResponse",
     "ListLakeActionsRequest",
     "ListLakesRequest",
     "ListLakesResponse",
     "ListPartitionsRequest",
     "ListPartitionsResponse",
+    "ListSessionsRequest",
+    "ListSessionsResponse",
     "ListTasksRequest",
     "ListTasksResponse",
     "ListZoneActionsRequest",
@@ -125,12 +169,16 @@
     "OperationMetadata",
     "Partition",
     "Schema",
+    "Session",
     "SessionEvent",
     "State",
     "StorageFormat",
     "StorageSystem",
     "Task",
     "UpdateAssetRequest",
+    "UpdateContentRequest",
+    "UpdateEntityRequest",
+    "UpdateEnvironmentRequest",
     "UpdateLakeRequest",
     "UpdateTaskRequest",
     "UpdateZoneRequest",