@@ -649,6 +649,29 @@ def make_secure_stub(credentials, user_agent, stub_class, host, port):
     return stub_class(channel)
 
 
+def make_insecure_stub(stub_class, host, port):
+    """Makes an insecure stub for an RPC service.
+
+    Uses / depends on gRPC.
+
+    :type stub_class: type
+    :param stub_class: A gRPC stub type for a given service.
+
+    :type host: str
+    :param host: The host for the service.
+
+    :type port: int
+    :param port: The port for the service.
+
+    :rtype: object, instance of ``stub_class``
+    :returns: The stub object used to make gRPC requests to a given API.
+    """
+    # NOTE: This assumes port != http_client.HTTPS_PORT:
+    target = '%s:%d' % (host, port)
+    channel = grpc.insecure_channel(target)
+    return stub_class(channel)
+
+
 def exc_to_code(exc):
     """Retrieves the status code from a gRPC exception.
 
 
@@ -969,6 +969,43 @@ def mock_plugin(*args):
                          (target, COMPOSITE_CREDS))
 
 
+class Test_make_insecure_stub(unittest.TestCase):
+
+    def _callFUT(self, *args, **kwargs):
+        from gcloud._helpers import make_insecure_stub
+        return make_insecure_stub(*args, **kwargs)
+
+    def test_it(self):
+        from unit_tests._testing import _Monkey
+        from gcloud import _helpers as MUT
+
+        mock_result = object()
+        stub_inputs = []
+        CHANNEL = object()
+
+        class _GRPCModule(object):
+
+            def insecure_channel(self, *args):
+                self.insecure_channel_args = args
+                return CHANNEL
+
+        grpc_mod = _GRPCModule()
+
+        def mock_stub_class(channel):
+            stub_inputs.append(channel)
+            return mock_result
+
+        host = 'HOST'
+        port = 1025
+        with _Monkey(MUT, grpc=grpc_mod):
+            result = self._callFUT(mock_stub_class, host, port)
+
+        self.assertTrue(result is mock_result)
+        self.assertEqual(stub_inputs, [CHANNEL])
+        target = '%s:%d' % (host, port)
+        self.assertEqual(grpc_mod.insecure_channel_args, (target,))
+
+
 class Test_exc_to_code(unittest.TestCase):
 
     def _callFUT(self, exc):