chore: auto-gen by protobufs

triggered by commit: instill-ai/protobufs@cbf05a5

Author: droplet-bot

vdp/connector/v1alpha/connector_pb2.py

@@ -0,0 +1,256 @@
+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+"""Client and server classes corresponding to protobuf-defined services."""
+import grpc
+
+from vdp.connector.v1alpha import connector_pb2 as vdp_dot_connector_dot_v1alpha_dot_connector__pb2
+
+
+class ConnectorPrivateServiceStub(object):
+    """/////////////////////////////////////////////////////////////////////////////
+    Connector service responds to internal incoming connector requests.
+    """
+
+    def __init__(self, channel):
+        """Constructor.
+
+        Args:
+            channel: A grpc.Channel.
+        """
+        self.ListSourceConnectorAdmin = channel.unary_unary(
+                '/vdp.connector.v1alpha.ConnectorPrivateService/ListSourceConnectorAdmin',
+                request_serializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.ListSourceConnectorAdminRequest.SerializeToString,
+                response_deserializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.ListSourceConnectorAdminResponse.FromString,
+                )
+        self.GetSourceConnectorAdmin = channel.unary_unary(
+                '/vdp.connector.v1alpha.ConnectorPrivateService/GetSourceConnectorAdmin',
+                request_serializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.GetSourceConnectorAdminRequest.SerializeToString,
+                response_deserializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.GetSourceConnectorAdminResponse.FromString,
+                )
+        self.LookUpSourceConnectorAdmin = channel.unary_unary(
+                '/vdp.connector.v1alpha.ConnectorPrivateService/LookUpSourceConnectorAdmin',
+                request_serializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.LookUpSourceConnectorAdminRequest.SerializeToString,
+                response_deserializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.LookUpSourceConnectorAdminResponse.FromString,
+                )
+        self.ListDestinationConnectorAdmin = channel.unary_unary(
+                '/vdp.connector.v1alpha.ConnectorPrivateService/ListDestinationConnectorAdmin',
+                request_serializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.ListDestinationConnectorAdminRequest.SerializeToString,
+                response_deserializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.ListDestinationConnectorAdminResponse.FromString,
+                )
+        self.GetDestinationConnectorAdmin = channel.unary_unary(
+                '/vdp.connector.v1alpha.ConnectorPrivateService/GetDestinationConnectorAdmin',
+                request_serializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.GetDestinationConnectorAdminRequest.SerializeToString,
+                response_deserializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.GetDestinationConnectorAdminResponse.FromString,
+                )
+        self.LookUpDestinationConnectorAdmin = channel.unary_unary(
+                '/vdp.connector.v1alpha.ConnectorPrivateService/LookUpDestinationConnectorAdmin',
+                request_serializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.LookUpDestinationConnectorAdminRequest.SerializeToString,
+                response_deserializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.LookUpDestinationConnectorAdminResponse.FromString,
+                )
+
+
+class ConnectorPrivateServiceServicer(object):
+    """/////////////////////////////////////////////////////////////////////////////
+    Connector service responds to internal incoming connector requests.
+    """
+
+    def ListSourceConnectorAdmin(self, request, context):
+        """========== Admin API ========== 
+
+        *SourceConnector methods
+
+        ListSourceConnectorAdmin method receives a ListSourceConnectorAdminRequest message
+        and returns a ListSourceConnectorAdminResponse message.
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def GetSourceConnectorAdmin(self, request, context):
+        """GetSourceConnectorAdmin method receives a GetSourceConnectorAdminRequest message and
+        returns a GetSourceConnectorAdminResponse message.
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def LookUpSourceConnectorAdmin(self, request, context):
+        """LookUpSourceConnectorAdmin method receives a LookUpSourceConnectorAdminRequest
+        message and returns a LookUpSourceConnectorAdminResponse
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def ListDestinationConnectorAdmin(self, request, context):
+        """*DestinationConnector methods
+
+        ListDestinationConnectorAdmin method receives a ListDestinationConnectorAdminRequest
+        message and returns a ListDestinationConnectorResponse message.
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def GetDestinationConnectorAdmin(self, request, context):
+        """GetDestinationConnectorAdmin method receives a GetDestinationConnectorAdminRequest
+        message and returns a GetDestinationConnectorAdminResponse message.
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def LookUpDestinationConnectorAdmin(self, request, context):
+        """LookUpDestinationConnectorAdmin method receives a
+        LookUpDestinationConnectorAdminRequest message and returns a
+        LookUpDestinationConnectorAdminResponse
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+
+def add_ConnectorPrivateServiceServicer_to_server(servicer, server):
+    rpc_method_handlers = {
+            'ListSourceConnectorAdmin': grpc.unary_unary_rpc_method_handler(
+                    servicer.ListSourceConnectorAdmin,
+                    request_deserializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.ListSourceConnectorAdminRequest.FromString,
+                    response_serializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.ListSourceConnectorAdminResponse.SerializeToString,
+            ),
+            'GetSourceConnectorAdmin': grpc.unary_unary_rpc_method_handler(
+                    servicer.GetSourceConnectorAdmin,
+                    request_deserializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.GetSourceConnectorAdminRequest.FromString,
+                    response_serializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.GetSourceConnectorAdminResponse.SerializeToString,
+            ),
+            'LookUpSourceConnectorAdmin': grpc.unary_unary_rpc_method_handler(
+                    servicer.LookUpSourceConnectorAdmin,
+                    request_deserializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.LookUpSourceConnectorAdminRequest.FromString,
+                    response_serializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.LookUpSourceConnectorAdminResponse.SerializeToString,
+            ),
+            'ListDestinationConnectorAdmin': grpc.unary_unary_rpc_method_handler(
+                    servicer.ListDestinationConnectorAdmin,
+                    request_deserializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.ListDestinationConnectorAdminRequest.FromString,
+                    response_serializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.ListDestinationConnectorAdminResponse.SerializeToString,
+            ),
+            'GetDestinationConnectorAdmin': grpc.unary_unary_rpc_method_handler(
+                    servicer.GetDestinationConnectorAdmin,
+                    request_deserializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.GetDestinationConnectorAdminRequest.FromString,
+                    response_serializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.GetDestinationConnectorAdminResponse.SerializeToString,
+            ),
+            'LookUpDestinationConnectorAdmin': grpc.unary_unary_rpc_method_handler(
+                    servicer.LookUpDestinationConnectorAdmin,
+                    request_deserializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.LookUpDestinationConnectorAdminRequest.FromString,
+                    response_serializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.LookUpDestinationConnectorAdminResponse.SerializeToString,
+            ),
+    }
+    generic_handler = grpc.method_handlers_generic_handler(
+            'vdp.connector.v1alpha.ConnectorPrivateService', rpc_method_handlers)
+    server.add_generic_rpc_handlers((generic_handler,))
+
+
+ # This class is part of an EXPERIMENTAL API.
+class ConnectorPrivateService(object):
+    """/////////////////////////////////////////////////////////////////////////////
+    Connector service responds to internal incoming connector requests.
+    """
+
+    @staticmethod
+    def ListSourceConnectorAdmin(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_unary(request, target, '/vdp.connector.v1alpha.ConnectorPrivateService/ListSourceConnectorAdmin',
+            vdp_dot_connector_dot_v1alpha_dot_connector__pb2.ListSourceConnectorAdminRequest.SerializeToString,
+            vdp_dot_connector_dot_v1alpha_dot_connector__pb2.ListSourceConnectorAdminResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def GetSourceConnectorAdmin(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_unary(request, target, '/vdp.connector.v1alpha.ConnectorPrivateService/GetSourceConnectorAdmin',
+            vdp_dot_connector_dot_v1alpha_dot_connector__pb2.GetSourceConnectorAdminRequest.SerializeToString,
+            vdp_dot_connector_dot_v1alpha_dot_connector__pb2.GetSourceConnectorAdminResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def LookUpSourceConnectorAdmin(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_unary(request, target, '/vdp.connector.v1alpha.ConnectorPrivateService/LookUpSourceConnectorAdmin',
+            vdp_dot_connector_dot_v1alpha_dot_connector__pb2.LookUpSourceConnectorAdminRequest.SerializeToString,
+            vdp_dot_connector_dot_v1alpha_dot_connector__pb2.LookUpSourceConnectorAdminResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def ListDestinationConnectorAdmin(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_unary(request, target, '/vdp.connector.v1alpha.ConnectorPrivateService/ListDestinationConnectorAdmin',
+            vdp_dot_connector_dot_v1alpha_dot_connector__pb2.ListDestinationConnectorAdminRequest.SerializeToString,
+            vdp_dot_connector_dot_v1alpha_dot_connector__pb2.ListDestinationConnectorAdminResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def GetDestinationConnectorAdmin(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_unary(request, target, '/vdp.connector.v1alpha.ConnectorPrivateService/GetDestinationConnectorAdmin',
+            vdp_dot_connector_dot_v1alpha_dot_connector__pb2.GetDestinationConnectorAdminRequest.SerializeToString,
+            vdp_dot_connector_dot_v1alpha_dot_connector__pb2.GetDestinationConnectorAdminResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def LookUpDestinationConnectorAdmin(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_unary(request, target, '/vdp.connector.v1alpha.ConnectorPrivateService/LookUpDestinationConnectorAdmin',
+            vdp_dot_connector_dot_v1alpha_dot_connector__pb2.LookUpDestinationConnectorAdminRequest.SerializeToString,
+            vdp_dot_connector_dot_v1alpha_dot_connector__pb2.LookUpDestinationConnectorAdminResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)