Dropping usage of connection.credentials in logging.

Author: dhermes

logging/google/cloud/logging/_gax.py

@@ -533,7 +533,7 @@ def make_gax_logging_api(client):
     :returns: A metrics API instance with the proper credentials.
     """
     channel = make_secure_channel(
-        client._connection.credentials, DEFAULT_USER_AGENT,
+        client._credentials, DEFAULT_USER_AGENT,
         LoggingServiceV2Client.SERVICE_ADDRESS)
     generated = LoggingServiceV2Client(
         channel=channel, lib_name='gccl', lib_version=__version__)
@@ -550,7 +550,7 @@ def make_gax_metrics_api(client):
     :returns: A metrics API instance with the proper credentials.
     """
     channel = make_secure_channel(
-        client._connection.credentials, DEFAULT_USER_AGENT,
+        client._credentials, DEFAULT_USER_AGENT,
         MetricsServiceV2Client.SERVICE_ADDRESS)
     generated = MetricsServiceV2Client(
         channel=channel, lib_name='gccl', lib_version=__version__)
@@ -567,7 +567,7 @@ def make_gax_sinks_api(client):
     :returns: A metrics API instance with the proper credentials.
     """
     channel = make_secure_channel(
-        client._connection.credentials, DEFAULT_USER_AGENT,
+        client._credentials, DEFAULT_USER_AGENT,
         ConfigServiceV2Client.SERVICE_ADDRESS)
     generated = ConfigServiceV2Client(
         channel=channel, lib_name='gccl', lib_version=__version__)

logging/google/cloud/logging/handlers/transports/background_thread.py

@@ -152,7 +152,7 @@ class BackgroundThreadTransport(Transport):
     def __init__(self, client, name):
         http = copy.deepcopy(client._http)
         self.client = client.__class__(
-            client.project, client._connection.credentials, http)
+            client.project, client._credentials, http)
         logger = self.client.logger(name)
         self.worker = _Worker(logger)
 

logging/unit_tests/test__gax.py

@@ -1113,8 +1113,7 @@ def test_it(self):
         from google.cloud.logging._gax import DEFAULT_USER_AGENT
 
         creds = object()
-        conn = mock.Mock(credentials=creds, spec=['credentials'])
-        client = mock.Mock(_connection=conn, spec=['_connection'])
+        client = mock.Mock(_credentials=creds, spec=['_credentials'])
         channels = []
         channel_args = []
         generated_api_kwargs = []
@@ -1167,8 +1166,7 @@ def test_it(self):
         from google.cloud.logging._gax import DEFAULT_USER_AGENT
 
         creds = object()
-        conn = mock.Mock(credentials=creds, spec=['credentials'])
-        client = mock.Mock(_connection=conn, spec=['_connection'])
+        client = mock.Mock(_credentials=creds, spec=['_credentials'])
         channels = []
         channel_args = []
         generated_api_kwargs = []
@@ -1221,8 +1219,7 @@ def test_it(self):
         from google.cloud.logging._gax import DEFAULT_USER_AGENT
 
         creds = object()
-        conn = mock.Mock(credentials=creds, spec=['credentials'])
-        client = mock.Mock(_connection=conn, spec=['_connection'])
+        client = mock.Mock(_credentials=creds, spec=['_credentials'])
         channels = []
         channel_args = []
         generated_api_kwargs = []