Skip to content
Permalink
Browse files
feat: add support for ssl credentials; add throttled field to UpdateD…
…atabaseDdlMetadata (#161)

* changes without context

        autosynth cannot find the source of changes triggered by earlier changes in this
        repository, or by version upgrades to tools such as linters.

* chore: revert breaking docstrings and unneeded bigquery doc ignore

Co-authored-by: larkee <larkee@users.noreply.github.com>
  • Loading branch information
yoshi-automation and larkee committed Dec 11, 2020
1 parent af5a3c6 commit 2faf01b135360586ef27c66976646593fd85fd1e
@@ -3,3 +3,4 @@ Types for Google Cloud Spanner Admin Database v1 API

.. automodule:: google.cloud.spanner_admin_database_v1.types
:members:
:show-inheritance:
@@ -3,3 +3,4 @@ Types for Google Cloud Spanner Admin Instance v1 API

.. automodule:: google.cloud.spanner_admin_instance_v1.types
:members:
:show-inheritance:
@@ -3,3 +3,4 @@ Types for Google Cloud Spanner v1 API

.. automodule:: google.cloud.spanner_v1.types
:members:
:show-inheritance:
@@ -514,6 +514,11 @@ message UpdateDatabaseDdlMetadata {
// succeeded so far, where `commit_timestamps[i]` is the commit
// timestamp for the statement `statements[i]`.
repeated google.protobuf.Timestamp commit_timestamps = 3;

// Output only. When true, indicates that the operation is throttled e.g
// due to resource constraints. When resources become available the operation
// will resume and this field will be false again.
bool throttled = 4 [(google.api.field_behavior) = OUTPUT_ONLY];
}

// The request for [DropDatabase][google.spanner.admin.database.v1.DatabaseAdmin.DropDatabase].
@@ -113,13 +113,16 @@ def __init__(
google.api_core.exceptions.DuplicateCredentialArgs: If both ``credentials``
and ``credentials_file`` are passed.
"""
self._ssl_channel_credentials = ssl_channel_credentials

if channel:
# Sanity check: Ensure that channel and credentials are not both
# provided.
credentials = False

# If a channel was explicitly provided, set it.
self._grpc_channel = channel
self._ssl_channel_credentials = None
elif api_mtls_endpoint:
warnings.warn(
"api_mtls_endpoint and client_cert_source are deprecated",
@@ -156,6 +159,7 @@ def __init__(
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
)
self._ssl_channel_credentials = ssl_credentials
else:
host = host if ":" in host else host + ":443"

@@ -158,13 +158,16 @@ def __init__(
google.api_core.exceptions.DuplicateCredentialArgs: If both ``credentials``
and ``credentials_file`` are passed.
"""
self._ssl_channel_credentials = ssl_channel_credentials

if channel:
# Sanity check: Ensure that channel and credentials are not both
# provided.
credentials = False

# If a channel was explicitly provided, set it.
self._grpc_channel = channel
self._ssl_channel_credentials = None
elif api_mtls_endpoint:
warnings.warn(
"api_mtls_endpoint and client_cert_source are deprecated",
@@ -201,6 +204,7 @@ def __init__(
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
)
self._ssl_channel_credentials = ssl_credentials
else:
host = host if ":" in host else host + ":443"

@@ -287,6 +287,12 @@ class UpdateDatabaseDdlMetadata(proto.Message):
Reports the commit timestamps of all statements that have
succeeded so far, where ``commit_timestamps[i]`` is the
commit timestamp for the statement ``statements[i]``.
throttled (bool):
Output only. When true, indicates that the
operation is throttled e.g due to resource
constraints. When resources become available the
operation will resume and this field will be
false again.
"""

database = proto.Field(proto.STRING, number=1)
@@ -297,6 +303,8 @@ class UpdateDatabaseDdlMetadata(proto.Message):
proto.MESSAGE, number=3, message=timestamp.Timestamp,
)

throttled = proto.Field(proto.BOOL, number=4)


class DropDatabaseRequest(proto.Message):
r"""The request for
@@ -126,13 +126,16 @@ def __init__(
google.api_core.exceptions.DuplicateCredentialArgs: If both ``credentials``
and ``credentials_file`` are passed.
"""
self._ssl_channel_credentials = ssl_channel_credentials

if channel:
# Sanity check: Ensure that channel and credentials are not both
# provided.
credentials = False

# If a channel was explicitly provided, set it.
self._grpc_channel = channel
self._ssl_channel_credentials = None
elif api_mtls_endpoint:
warnings.warn(
"api_mtls_endpoint and client_cert_source are deprecated",
@@ -169,6 +172,7 @@ def __init__(
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
)
self._ssl_channel_credentials = ssl_credentials
else:
host = host if ":" in host else host + ":443"

@@ -171,13 +171,16 @@ def __init__(
google.api_core.exceptions.DuplicateCredentialArgs: If both ``credentials``
and ``credentials_file`` are passed.
"""
self._ssl_channel_credentials = ssl_channel_credentials

if channel:
# Sanity check: Ensure that channel and credentials are not both
# provided.
credentials = False

# If a channel was explicitly provided, set it.
self._grpc_channel = channel
self._ssl_channel_credentials = None
elif api_mtls_endpoint:
warnings.warn(
"api_mtls_endpoint and client_cert_source are deprecated",
@@ -214,6 +217,7 @@ def __init__(
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
)
self._ssl_channel_credentials = ssl_credentials
else:
host = host if ":" in host else host + ":443"

@@ -106,13 +106,16 @@ def __init__(
google.api_core.exceptions.DuplicateCredentialArgs: If both ``credentials``
and ``credentials_file`` are passed.
"""
self._ssl_channel_credentials = ssl_channel_credentials

if channel:
# Sanity check: Ensure that channel and credentials are not both
# provided.
credentials = False

# If a channel was explicitly provided, set it.
self._grpc_channel = channel
self._ssl_channel_credentials = None
elif api_mtls_endpoint:
warnings.warn(
"api_mtls_endpoint and client_cert_source are deprecated",
@@ -149,6 +152,7 @@ def __init__(
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
)
self._ssl_channel_credentials = ssl_credentials
else:
host = host if ":" in host else host + ":443"

@@ -151,13 +151,16 @@ def __init__(
google.api_core.exceptions.DuplicateCredentialArgs: If both ``credentials``
and ``credentials_file`` are passed.
"""
self._ssl_channel_credentials = ssl_channel_credentials

if channel:
# Sanity check: Ensure that channel and credentials are not both
# provided.
credentials = False

# If a channel was explicitly provided, set it.
self._grpc_channel = channel
self._ssl_channel_credentials = None
elif api_mtls_endpoint:
warnings.warn(
"api_mtls_endpoint and client_cert_source are deprecated",
@@ -194,6 +197,7 @@ def __init__(
scopes=scopes or self.AUTH_SCOPES,
quota_project_id=quota_project_id,
)
self._ssl_channel_credentials = ssl_credentials
else:
host = host if ":" in host else host + ":443"

@@ -1,3 +1,4 @@
#! /usr/bin/env python3
# -*- coding: utf-8 -*-

# Copyright 2020 Google LLC
@@ -1,3 +1,4 @@
#! /usr/bin/env python3
# -*- coding: utf-8 -*-

# Copyright 2020 Google LLC
@@ -1,3 +1,4 @@
#! /usr/bin/env python3
# -*- coding: utf-8 -*-

# Copyright 2020 Google LLC
@@ -3,8 +3,16 @@
{
"git": {
"name": ".",
"remote": "git@github.com:larkee/python-spanner.git",
"sha": "1d3e65af688c31937b0110223679607c19c328e9"
"remote": "https://github.com/googleapis/python-spanner.git",
"sha": "af5a3c65fbf81a93c1b4d4a8a9f65f06e96df325"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
"sha": "53eb2512a55caabcbad1898225080a2a3dfcb6aa",
"internalRef": "346818879"
}
},
{
@@ -50,5 +58,144 @@
"generator": "bazel"
}
}
],
"generatedFiles": [
".flake8",
".github/CONTRIBUTING.md",
".github/ISSUE_TEMPLATE/bug_report.md",
".github/ISSUE_TEMPLATE/feature_request.md",
".github/ISSUE_TEMPLATE/support_request.md",
".github/PULL_REQUEST_TEMPLATE.md",
".github/release-please.yml",
".github/snippet-bot.yml",
".gitignore",
".kokoro/build.sh",
".kokoro/continuous/common.cfg",
".kokoro/continuous/continuous.cfg",
".kokoro/docker/docs/Dockerfile",
".kokoro/docker/docs/fetch_gpg_keys.sh",
".kokoro/docs/common.cfg",
".kokoro/docs/docs-presubmit.cfg",
".kokoro/docs/docs.cfg",
".kokoro/populate-secrets.sh",
".kokoro/presubmit/common.cfg",
".kokoro/presubmit/presubmit.cfg",
".kokoro/publish-docs.sh",
".kokoro/release.sh",
".kokoro/release/common.cfg",
".kokoro/release/release.cfg",
".kokoro/samples/lint/common.cfg",
".kokoro/samples/lint/continuous.cfg",
".kokoro/samples/lint/periodic.cfg",
".kokoro/samples/lint/presubmit.cfg",
".kokoro/samples/python3.6/common.cfg",
".kokoro/samples/python3.6/continuous.cfg",
".kokoro/samples/python3.6/periodic.cfg",
".kokoro/samples/python3.6/presubmit.cfg",
".kokoro/samples/python3.7/common.cfg",
".kokoro/samples/python3.7/continuous.cfg",
".kokoro/samples/python3.7/periodic.cfg",
".kokoro/samples/python3.7/presubmit.cfg",
".kokoro/samples/python3.8/common.cfg",
".kokoro/samples/python3.8/continuous.cfg",
".kokoro/samples/python3.8/periodic.cfg",
".kokoro/samples/python3.8/presubmit.cfg",
".kokoro/test-samples.sh",
".kokoro/trampoline.sh",
".kokoro/trampoline_v2.sh",
".trampolinerc",
"CODE_OF_CONDUCT.md",
"CONTRIBUTING.rst",
"LICENSE",
"MANIFEST.in",
"docs/_static/custom.css",
"docs/_templates/layout.html",
"docs/conf.py",
"docs/multiprocessing.rst",
"docs/spanner_admin_database_v1/services.rst",
"docs/spanner_admin_database_v1/types.rst",
"docs/spanner_admin_instance_v1/services.rst",
"docs/spanner_admin_instance_v1/types.rst",
"docs/spanner_v1/services.rst",
"docs/spanner_v1/types.rst",
"google/cloud/spanner_admin_database_v1/__init__.py",
"google/cloud/spanner_admin_database_v1/proto/backup.proto",
"google/cloud/spanner_admin_database_v1/proto/common.proto",
"google/cloud/spanner_admin_database_v1/proto/spanner_database_admin.proto",
"google/cloud/spanner_admin_database_v1/py.typed",
"google/cloud/spanner_admin_database_v1/services/__init__.py",
"google/cloud/spanner_admin_database_v1/services/database_admin/__init__.py",
"google/cloud/spanner_admin_database_v1/services/database_admin/async_client.py",
"google/cloud/spanner_admin_database_v1/services/database_admin/client.py",
"google/cloud/spanner_admin_database_v1/services/database_admin/pagers.py",
"google/cloud/spanner_admin_database_v1/services/database_admin/transports/__init__.py",
"google/cloud/spanner_admin_database_v1/services/database_admin/transports/base.py",
"google/cloud/spanner_admin_database_v1/services/database_admin/transports/grpc.py",
"google/cloud/spanner_admin_database_v1/services/database_admin/transports/grpc_asyncio.py",
"google/cloud/spanner_admin_database_v1/types/__init__.py",
"google/cloud/spanner_admin_database_v1/types/backup.py",
"google/cloud/spanner_admin_database_v1/types/common.py",
"google/cloud/spanner_admin_database_v1/types/spanner_database_admin.py",
"google/cloud/spanner_admin_instance_v1/__init__.py",
"google/cloud/spanner_admin_instance_v1/proto/spanner_instance_admin.proto",
"google/cloud/spanner_admin_instance_v1/py.typed",
"google/cloud/spanner_admin_instance_v1/services/__init__.py",
"google/cloud/spanner_admin_instance_v1/services/instance_admin/__init__.py",
"google/cloud/spanner_admin_instance_v1/services/instance_admin/async_client.py",
"google/cloud/spanner_admin_instance_v1/services/instance_admin/client.py",
"google/cloud/spanner_admin_instance_v1/services/instance_admin/pagers.py",
"google/cloud/spanner_admin_instance_v1/services/instance_admin/transports/__init__.py",
"google/cloud/spanner_admin_instance_v1/services/instance_admin/transports/base.py",
"google/cloud/spanner_admin_instance_v1/services/instance_admin/transports/grpc.py",
"google/cloud/spanner_admin_instance_v1/services/instance_admin/transports/grpc_asyncio.py",
"google/cloud/spanner_admin_instance_v1/types/__init__.py",
"google/cloud/spanner_admin_instance_v1/types/spanner_instance_admin.py",
"google/cloud/spanner_v1/proto/keys.proto",
"google/cloud/spanner_v1/proto/mutation.proto",
"google/cloud/spanner_v1/proto/query_plan.proto",
"google/cloud/spanner_v1/proto/result_set.proto",
"google/cloud/spanner_v1/proto/spanner.proto",
"google/cloud/spanner_v1/proto/transaction.proto",
"google/cloud/spanner_v1/proto/type.proto",
"google/cloud/spanner_v1/py.typed",
"google/cloud/spanner_v1/services/__init__.py",
"google/cloud/spanner_v1/services/spanner/__init__.py",
"google/cloud/spanner_v1/services/spanner/async_client.py",
"google/cloud/spanner_v1/services/spanner/client.py",
"google/cloud/spanner_v1/services/spanner/pagers.py",
"google/cloud/spanner_v1/services/spanner/transports/__init__.py",
"google/cloud/spanner_v1/services/spanner/transports/base.py",
"google/cloud/spanner_v1/services/spanner/transports/grpc.py",
"google/cloud/spanner_v1/services/spanner/transports/grpc_asyncio.py",
"google/cloud/spanner_v1/types/__init__.py",
"google/cloud/spanner_v1/types/keys.py",
"google/cloud/spanner_v1/types/mutation.py",
"google/cloud/spanner_v1/types/query_plan.py",
"google/cloud/spanner_v1/types/result_set.py",
"google/cloud/spanner_v1/types/spanner.py",
"google/cloud/spanner_v1/types/transaction.py",
"google/cloud/spanner_v1/types/type.py",
"renovate.json",
"samples/AUTHORING_GUIDE.md",
"samples/CONTRIBUTING.md",
"samples/samples/noxfile.py",
"scripts/decrypt-secrets.sh",
"scripts/fixup_spanner_admin_database_v1_keywords.py",
"scripts/fixup_spanner_admin_instance_v1_keywords.py",
"scripts/fixup_spanner_v1_keywords.py",
"scripts/readme-gen/readme_gen.py",
"scripts/readme-gen/templates/README.tmpl.rst",
"scripts/readme-gen/templates/auth.tmpl.rst",
"scripts/readme-gen/templates/auth_api_key.tmpl.rst",
"scripts/readme-gen/templates/install_deps.tmpl.rst",
"scripts/readme-gen/templates/install_portaudio.tmpl.rst",
"setup.cfg",
"testing/.gitignore",
"tests/unit/gapic/spanner_admin_database_v1/__init__.py",
"tests/unit/gapic/spanner_admin_database_v1/test_database_admin.py",
"tests/unit/gapic/spanner_admin_instance_v1/__init__.py",
"tests/unit/gapic/spanner_admin_instance_v1/test_instance_admin.py",
"tests/unit/gapic/spanner_v1/__init__.py",
"tests/unit/gapic/spanner_v1/test_spanner.py"
]
}

0 comments on commit 2faf01b

Please sign in to comment.